use anyhow::anyhow;
use itertools::Itertools;
use std::path::{Component, Path, PathBuf};
use harper_core::{Dictionary, MutableDictionary, WordMetadata};
use tokio::fs::{self, File};
use tokio::io::{AsyncRead, AsyncReadExt, AsyncWrite, AsyncWriteExt, BufReader, BufWriter, Result};
use tower_lsp::lsp_types::Url;
pub async fn save_dict(path: impl AsRef<Path>, dict: impl Dictionary) -> Result<()> {
if let Some(parent) = path.as_ref().parent() {
fs::create_dir_all(parent).await?;
}
let file = File::create(path.as_ref()).await?;
let mut write = BufWriter::new(file);
write_word_list(dict, &mut write).await?;
write.flush().await?;
Ok(())
}
async fn write_word_list(dict: impl Dictionary, mut w: impl AsyncWrite + Unpin) -> Result<()> {
let mut cur_str = String::new();
for word in dict.words_iter().sorted() {
cur_str.clear();
cur_str.extend(word);
w.write_all(cur_str.as_bytes()).await?;
w.write_all(b"\n").await?;
}
Ok(())
}
pub async fn load_dict(path: impl AsRef<Path>) -> Result<MutableDictionary> {
let file = File::open(path.as_ref()).await?;
let read = BufReader::new(file);
dict_from_word_list(read).await
}
async fn dict_from_word_list(mut r: impl AsyncRead + Unpin) -> Result<MutableDictionary> {
let mut str = String::new();
r.read_to_string(&mut str).await?;
let mut dict = MutableDictionary::new();
dict.extend_words(
str.lines()
.map(|l| (l.chars().collect::<Vec<char>>(), WordMetadata::default())),
);
Ok(dict)
}
pub fn file_dict_name(url: &Url) -> anyhow::Result<PathBuf> {
let mut rewritten = String::new();
for seg in url
.to_file_path()
.map_err(|_| anyhow!("Unable to convert URL to file path."))?
.components()
{
if !matches!(seg, Component::RootDir) {
rewritten.push_str(&seg.as_os_str().to_string_lossy());
rewritten.push('%');
}
}
Ok(rewritten.into())
}
#[cfg(test)]
mod tests {
use super::*;
use std::io::Cursor;
const TEST_UNSORTED_WORDS: [&str; 10] = [
"peafowl",
"housebroken",
"blackjack",
"Žižek",
"BMX",
"icebox",
"stetting",
"ツ",
"ASCII",
"link",
];
const TEST_SORTED_WORDS: [&str; 10] = [
"ASCII",
"BMX",
"blackjack",
"housebroken",
"icebox",
"link",
"peafowl",
"stetting",
"Žižek",
"ツ",
];
fn get_test_unsorted_dict() -> MutableDictionary {
let mut test_unsorted_dict = MutableDictionary::new();
test_unsorted_dict.extend_words(
TEST_UNSORTED_WORDS.map(|w| (w.chars().collect::<Vec<_>>(), WordMetadata::default())),
);
test_unsorted_dict
}
#[tokio::test]
async fn writes_sorted_word_list() {
let test_unsorted_dict = get_test_unsorted_dict();
let mut test_writer = Cursor::new(Vec::new());
write_word_list(test_unsorted_dict, &mut test_writer)
.await
.expect("writing to Vec<u8> should not fail. (Unless OOM?)");
assert_eq!(
TEST_SORTED_WORDS.join("\n") + "\n",
String::from_utf8_lossy(&test_writer.into_inner())
);
}
}