cskk 3.1.4

pub(crate) mod candidate;
pub(crate) mod composite_key;
pub(crate) mod dictentry;
mod dictionary_candidate;
mod dictionary_parser;
pub mod empty_dict;
pub(crate) mod file_dictionary;
mod lru_ordered_map;
pub mod static_dict;
pub mod user_dictionary;

use crate::dictionary::dictionary_candidate::{CompletionCandidate, DictionaryEntry};
use crate::error::CskkError;
use crate::form_changer::numeric_form_changer::{
    numeric_to_daiji_as_number, numeric_to_kanji_each, numeric_to_simple_kanji_as_number,
    numeric_to_thousand_separator, numeric_to_zenkaku,
};
pub(crate) use candidate::Candidate;
pub(crate) use composite_key::CompositeKey;
use dictentry::DictEntry;
pub(in crate::dictionary) use dictionary_candidate::DictionaryCandidate;
use empty_dict::EmptyDictionary;
use log::*;
use regex::Regex;
use static_dict::StaticFileDict;
use std::sync::{Arc, Mutex};
use user_dictionary::UserDictionary;

// C側に出す関係でSizedである必要があり、dyn Traitではなくenumでラップする。
#[derive(Debug)]
pub(crate) enum CskkDictionaryType {
    StaticFile(StaticFileDict),
    UserFile(UserDictionary),
    EmptyDict(EmptyDictionary),
}

// FIXME: Not sure if this is the correct inner type. Maybe we can remove Arc on other places?
#[derive(Debug)]
pub struct CskkDictionary {
    is_completable: bool,
    pub(crate) mutex: Mutex<CskkDictionaryType>,
}

impl CskkDictionary {
    fn new(dictionary: CskkDictionaryType, is_completable: bool) -> Self {
        Self {
            is_completable,
            mutex: Mutex::new(dictionary),
        }
    }

    /// Library user interface for creating new static read-only dictionary.
    /// file_path: path string
    /// encode: label of encoding that encoding_rs can recognize. "utf-8", "euc-jp", "cp866" etc.
    pub fn new_static_dict(
        file_path: &str,
        encode: &str,
        is_completable: bool,
    ) -> Result<CskkDictionary, CskkError> {
        let dictionary = StaticFileDict::new(file_path, encode)?;
        Ok(CskkDictionary::new(
            CskkDictionaryType::StaticFile(dictionary),
            is_completable,
        ))
    }

    /// Library user interface for creating new user readable and writable dictionary
    /// file_path: path string
    /// encode: label of encoding that encoding_rs can recognize. "utf-8", "euc-jp", "cp866" etc.
    pub fn new_user_dict(
        file_path: &str,
        encode: &str,
        is_completable: bool,
    ) -> Result<CskkDictionary, CskkError> {
        let dictionary = UserDictionary::new(file_path, encode)?;
        Ok(CskkDictionary::new(
            CskkDictionaryType::UserFile(dictionary),
            is_completable,
        ))
    }

    /// Library user interface for creating fallback dictionary.
    /// Dictionary is required to create the context, so this dictionary is useful when no dictionary file is available.
    pub fn new_empty_dict() -> Result<CskkDictionary, CskkError> {
        Ok(CskkDictionary::new(
            CskkDictionaryType::EmptyDict(EmptyDictionary::default()),
            false,
        ))
    }
}

/// confirm the candidate.
/// This updates writable dictionaries candidate order or add new entry which confirmed.
/// Returns true if updated the dictionary.
pub(crate) fn confirm_candidate(
    dictionary: &Arc<CskkDictionary>,
    candidate: &Candidate,
) -> Result<bool, CskkError> {
    debug!("confirm: {:?}", candidate);
    // Using mutex in match on purpose, never acquiring lock again.
    #[allow(clippy::significant_drop_in_scrutinee)]
    match *dictionary.mutex.lock().unwrap() {
        CskkDictionaryType::StaticFile(ref mut dict) => dict.select_candidate(candidate),
        CskkDictionaryType::UserFile(ref mut dict) => dict.select_candidate(candidate),
        CskkDictionaryType::EmptyDict(ref mut dict) => dict.select_candidate(candidate),
    }
}

/// purge the candidate.
/// This updates writable dictionaries candidate order or add new entry which confirmed.
/// Returns true if updated the dictionary.
pub(crate) fn purge_candidate(
    dictionary: &Arc<CskkDictionary>,
    composite_key: &CompositeKey,
    candidate: &Candidate,
) -> Result<bool, CskkError> {
    // Using mutex in match on purpose, never acquiring lock again.
    #[allow(clippy::significant_drop_in_scrutinee)]
    match *dictionary.mutex.lock().unwrap() {
        CskkDictionaryType::StaticFile(ref mut dict) => {
            dict.purge_candidate(composite_key, candidate)
        }
        CskkDictionaryType::UserFile(ref mut dict) => {
            dict.purge_candidate(composite_key, candidate)
        }
        CskkDictionaryType::EmptyDict(ref mut dict) => {
            dict.purge_candidate(composite_key, candidate)
        }
    }
}

/// 現在ueno/libskk同様にDedupはkouho_textのみ。
pub(crate) fn get_all_candidates(
    dictionaries: &[Arc<CskkDictionary>],
    composite_key: &CompositeKey,
) -> Vec<Candidate> {
    get_all_candidates_inner(dictionaries, composite_key, false)
}

///
/// 補完候補となる辞書のエントリ列を返す。
///
/// [Dictionary]の[complete]に準じて、composite_keyが送りなしのみを想定し、先頭一致する送りなし候補を返す。
///
pub(crate) fn get_all_complete(
    dictionaries: &[Arc<CskkDictionary>],
    composite_key: &CompositeKey,
) -> Vec<Candidate> {
    let dict_candidates = get_all_complete_inner(dictionaries, composite_key);
    let deduped_completion_candidate = dedup_candidates(dict_candidates);

    deduped_completion_candidate
        .into_iter()
        .map(|x| Candidate::from_completion_candidate(&x))
        .collect()
}
///
/// 補完候補となる辞書のエントリ列を返す。
///
/// [Dictionary]の[complete]に準じて、composite_keyが送りなしのみを想定し、先頭一致する送りなし候補を返す。
///
/// 使われない想定ではあるが、composite_keyが送りありだと送り仮名まで一致する候補を返すので先頭一致が完全一致と同じになる。
///
fn get_all_complete_inner(
    dictionaries: &[Arc<CskkDictionary>],
    composite_key: &CompositeKey,
) -> Vec<CompletionCandidate> {
    let mut result = Vec::new();

    for cskkdict in dictionaries.iter() {
        if cskkdict.is_completable {
            let lock = cskkdict.mutex.lock().unwrap();
            let dict_entries = match &*lock {
                CskkDictionaryType::StaticFile(dict) => dict.complete(composite_key),
                CskkDictionaryType::UserFile(dict) => dict.complete(composite_key),
                CskkDictionaryType::EmptyDict(dict) => dict.complete(composite_key),
            };
            for dict_entry in dict_entries {
                let candidates = dict_entry.get_candidates(composite_key.get_okuri());

                if let Some(candidates) = candidates {
                    // result.extend(candidates.to_owned())
                    result.extend(candidates.iter().map(|x| {
                        CompletionCandidate::from_dictionary_candidate(
                            &dict_entry.midashi,
                            composite_key.get_okuri(),
                            x,
                        )
                    }));
                }
            }
        }
    }

    result
}

///
/// First search the exact match, and then replace numerics to # and search the dict for numeric composition.
/// If numeric-re-lookup, skip the latter don't replace numerics for the "#4" type entries.
///
fn get_all_candidates_inner(
    dictionaries: &[Arc<CskkDictionary>],
    composite_key: &CompositeKey,
    is_numeric_re_lookup: bool,
) -> Vec<Candidate> {
    let mut matched_numbers: Vec<String>;

    let exact_match_candidates = get_candidates_in_order(dictionaries, &composite_key);
    let exact_match_candidates = dedup_candidates(exact_match_candidates);
    let mut all_candidates: Vec<Candidate> = exact_match_candidates
        .into_iter()
        .map(|dictionary_candidate| {
            Candidate::from_dictionary_candidate(&composite_key, &dictionary_candidate)
        })
        .collect();

    if !is_numeric_re_lookup {
        let replaced_key;
        (replaced_key, matched_numbers) = to_composite_to_numeric_dict_key(&composite_key);
        if replaced_key != *composite_key {
            let numeric_replace_match_candidates =
                get_candidates_in_order(dictionaries, &replaced_key);
            let numeric_replace_match_candidates =
                dedup_candidates(numeric_replace_match_candidates);
            let mut numeric_replace_match_candidates: Vec<Candidate> =
                numeric_replace_match_candidates
                    .into_iter()
                    .map(|dictionary_candidate| {
                        Candidate::from_dictionary_candidate(&replaced_key, &dictionary_candidate)
                    })
                    .flat_map(|candidate| {
                        replace_numeric_match(&candidate, &matched_numbers, dictionaries)
                    })
                    .collect();
            all_candidates.append(&mut numeric_replace_match_candidates);
        }
    }

    all_candidates
}

///
/// dictionary_candidatesの内容からその順番にcandidateを作り、重複を除いて返す。
///
fn dedup_candidates<T>(dictionary_candidates: Vec<T>) -> Vec<T>
where
    T: DictionaryEntry + Ord + Clone,
{
    let mut deduped_candidates = vec![];
    let mut ordered_candidates = vec![];

    deduped_candidates.extend(dictionary_candidates.to_owned());
    ordered_candidates.extend(dictionary_candidates);

    if deduped_candidates.is_empty() {
        return vec![];
    }
    deduped_candidates.sort_unstable();
    // Make Option == some come before None
    deduped_candidates.reverse();
    deduped_candidates.dedup_by(|a, b| a.get_kouho_text() == b.get_kouho_text());
    // reverse back for faster iteration? maybe unneeded.
    deduped_candidates.reverse();

    let mut result = vec![];
    for candidate in ordered_candidates {
        let mut matched_index = usize::MAX;
        for (pos, deduped) in deduped_candidates.iter().enumerate() {
            if (*deduped).eq(&candidate) {
                result.push(deduped.to_owned());
                matched_index = pos;
            }
        }
        if matched_index < usize::MAX {
            deduped_candidates.remove(matched_index);
        }
    }

    result
}

/// dictionariesからcompositeKeyに合わせた順序でDictionaryCandidateを返す。
///
/// compositeKeyが送り無しの場合、単なる辞書順
///
/// compositeKeyが送り有りの場合、まず送り仮名の厳密マッチする候補を辞書順に、その後厳密マッチのない候補を辞書順に。
/// つまりddskkのskk-henkan-strict-okuri-precedenceが設定された時の動作を行う。
///
fn get_candidates_in_order(
    dictionaries: &[Arc<CskkDictionary>],
    composite_key: &CompositeKey,
) -> Vec<DictionaryCandidate> {
    let mut result = Vec::new();

    for cskkdict in dictionaries.iter() {
        let lock = cskkdict.mutex.lock().unwrap();
        if let Some(dict_entry) = match &*lock {
            CskkDictionaryType::StaticFile(dict) => dict.lookup(composite_key),
            CskkDictionaryType::UserFile(dict) => dict.lookup(composite_key),
            CskkDictionaryType::EmptyDict(dict) => dict.lookup(composite_key),
        } {
            let strict_okuri_cands = if composite_key.has_okuri() {
                dict_entry.get_candidates(composite_key.get_okuri())
            } else {
                None
            };
            if let Some(candidates) = strict_okuri_cands {
                result.extend(candidates.to_owned());
            }

            let non_strict_okuri_cands = dict_entry.get_candidates(&None);
            if let Some(candidates) = non_strict_okuri_cands {
                result.extend(candidates.to_owned());
            }
        }
    }

    result
}

lazy_static! {
    static ref NUM_REGEX: Regex = Regex::new(r"\d+").unwrap();
}
///
/// 数字が含まれていた場合#に置きかえて数字と共にかえす。
///
/// 12がつ6にち -> (#がつ#にち, [12,6])
///
pub(crate) fn to_composite_to_numeric_dict_key(
    to_composite: &CompositeKey,
) -> (CompositeKey, Vec<String>) {
    let mut dict_key = to_composite.get_to_composite().to_owned();
    let mut matched_numbers = vec![];
    for numeric_match in NUM_REGEX.find_iter(to_composite.get_to_composite()) {
        let new_dict_key = dict_key.replacen(numeric_match.as_str(), "#", 1);
        dict_key = new_dict_key;
        matched_numbers.push(numeric_match.as_str().to_owned());
    }
    (
        CompositeKey::new(&dict_key, to_composite.get_okuri().to_owned()),
        matched_numbers,
    )
}

/// Return how many numeric string is in string to composite
///
/// compile_fail example for private fn
/// ```compile_fail
/// use cskk::dictionary::numeric_string_count;
/// assert_eq!(numeric_string_count("2かい"), 1);
/// assert_eq!(numeric_string_count("2がつ13にち"), 2);
/// ```
pub(crate) fn numeric_string_count(to_composite: &str) -> usize {
    NUM_REGEX.find_iter(to_composite).count()
}

/// Return how many numeric special string is in kouho string
///
/// compile_fail example for private fn
/// ```compile_fail
/// assert_eq!(numeric_entry_count("#1回"), 1);
/// assert_eq!(numeric_entry_count("#3日"), 1);
/// ```
///
pub(crate) fn numeric_entry_count(entry: &str) -> usize {
    lazy_static! {
        static ref NUM_ENTRY_REGEX: Regex = Regex::new(r"#[0123458]").unwrap();
    }
    NUM_ENTRY_REGEX.find_iter(entry).count()
}

// もし候補に#0等の数値マッチが入るならば元の数字でおきかえる。
fn replace_numeric_match(
    candidate: &Candidate,
    matched_numbers: &[String],
    dictionaries: &[Arc<CskkDictionary>],
) -> Vec<Candidate> {
    let output_text_list =
        replace_numeric_string(&candidate.kouho_text, matched_numbers, dictionaries);

    let mut result = vec![];
    for output_text in output_text_list {
        let mut new_candidate = candidate.clone();
        new_candidate.output = output_text;
        result.push(new_candidate)
    }
    result
}

/// given kouho_text that includes #[0123458], return the replaced text to be used for outputs.
pub(crate) fn replace_numeric_string(
    kouho_text: &str,
    numbers: &[String],
    dictionaries: &[Arc<CskkDictionary>],
) -> Vec<String> {
    lazy_static! {
        static ref NUMERIC_ENTRY_REGEX: Regex = Regex::new(r"#[0123458]").unwrap();
    }
    let mut current_output_texts = vec![kouho_text.to_string()];
    for (n, entry_match) in NUMERIC_ENTRY_REGEX.find_iter(kouho_text).enumerate() {
        if n < numbers.len() {
            match entry_match.as_str() {
                "#0" => {
                    let mut replaced_output_texts = vec![];
                    for output_text in &current_output_texts {
                        replaced_output_texts.push(output_text.replacen("#0", &numbers[n], 1));
                    }
                    current_output_texts = replaced_output_texts;
                }
                "#1" => {
                    let mut replaced_output_texts = vec![];
                    for kouho_text in &current_output_texts {
                        replaced_output_texts.push(kouho_text.replacen(
                            "#1",
                            &numeric_to_zenkaku(&numbers[n]),
                            1,
                        ));
                    }
                    current_output_texts = replaced_output_texts;
                }
                "#2" => {
                    let mut replaced_output_texts = vec![];
                    for kouho_text in &current_output_texts {
                        replaced_output_texts.push(kouho_text.replacen(
                            "#2",
                            &numeric_to_kanji_each(&numbers[n]),
                            1,
                        ));
                    }
                    current_output_texts = replaced_output_texts;
                }
                "#3" => {
                    let mut replaced_output_texts = vec![];
                    for output_text in &current_output_texts {
                        replaced_output_texts.push(output_text.replacen(
                            "#3",
                            &numeric_to_simple_kanji_as_number(&numbers[n]),
                            1,
                        ));
                    }
                    current_output_texts = replaced_output_texts;
                }
                "#4" => {
                    let mut replaced_output_texts = vec![];
                    let numeric_lookup_results = get_all_candidates_inner(
                        dictionaries,
                        &CompositeKey::new(&numbers[n], None),
                        true,
                    );
                    for kouho_text in &current_output_texts {
                        for numeric_lookup in &numeric_lookup_results {
                            replaced_output_texts.push(kouho_text.replacen(
                                "#4",
                                &numeric_lookup.kouho_text,
                                1,
                            ));
                        }
                    }
                    current_output_texts = replaced_output_texts;
                }
                "#5" => {
                    let mut replaced_output_texts = vec![];
                    for kouho_text in &current_output_texts {
                        replaced_output_texts.push(kouho_text.replacen(
                            "#5",
                            &numeric_to_daiji_as_number(&numbers[n], false),
                            1,
                        ));
                        replaced_output_texts.push(kouho_text.replacen(
                            "#5",
                            &numeric_to_daiji_as_number(&numbers[n], true),
                            1,
                        ));
                    }
                    current_output_texts = replaced_output_texts;
                }
                "#8" => {
                    let mut replaced_output_texts = vec![];
                    for kouho_text in &current_output_texts {
                        replaced_output_texts.push(kouho_text.replacen(
                            "#8",
                            &numeric_to_thousand_separator(&numbers[n]),
                            1,
                        ));
                    }
                    current_output_texts = replaced_output_texts;
                }
                _ => {}
            }
        }
    }
    current_output_texts
}

///
/// Returns the nth candidate.
/// first selection_pointer == 0
///
#[allow(dead_code)]
pub(crate) fn get_nth_candidate(
    dictionaries: &[Arc<CskkDictionary>],
    composite_key: &CompositeKey,
    selection_pointer: usize,
) -> Option<Candidate> {
    let candidates = get_all_candidates(dictionaries, composite_key);
    candidates.get(selection_pointer).cloned()
}

pub(crate) trait Dictionary {
    /// midashiと一致するエントリを返す。
    fn lookup(&self, composite_key: &CompositeKey) -> Option<&DictEntry>;

    fn is_read_only(&self) -> bool {
        true
    }
    ///
    /// `midashi_head`が送り仮名なしの場合、これから始まる送り仮名なしエントリの列を返す。送りありエントリは無視される。
    ///
    /// 補完として利用されない想定だが、この関数の実装としては`midashi_head`が送り仮名ありの場合、一致するエントリを返す。
    /// 送り仮名の仕組み上一致エントリしか存在できないため。
    ///
    /// e.g.
    /// complete(("あい", None)) -> (("あい", "/愛/相/"), ("あいさつ", "/挨拶/"), ...)
    /// complete(("あ", Some("い")) -> (("あi", "/開/合/\[い/合/開/\]/"), ...)
    fn complete<'a>(
        &'a self,
        midashi_head: &'a CompositeKey,
    ) -> Box<dyn Iterator<Item = &'a DictEntry> + 'a>;
    /// Returns true if saved, false if kindly ignored.
    /// Safe to call to read_only dictionary.
    fn save_dictionary(&mut self) -> Result<bool, CskkError> {
        Ok(false)
    }

    /// Select that candidate.
    /// Supporting dictionary will add and move that candidate to the first place so that next time it comes to candidate early.
    /// Safe to call to read_only dictionary.
    fn select_candidate(&mut self, _candidate: &Candidate) -> Result<bool, CskkError> {
        Ok(false)
    }
    /// Remove that candidate if dictionary supports editing.
    /// Safe to call to read_only dictionary
    fn purge_candidate(
        &mut self,
        _composite_key: &CompositeKey,
        _candidate: &Candidate,
    ) -> Result<bool, CskkError> {
        Ok(false)
    }

    /// Reload dictionary.
    fn reload(&mut self) -> Result<(), CskkError> {
        Ok(())
    }
}

#[cfg(test)]
mod test {
    use super::*;

    #[test]
    fn test_numeric_string_count() {
        assert_eq!(numeric_string_count("123つぶ"), 1);
        assert_eq!(numeric_string_count("1にち1かい"), 2);
        assert_eq!(numeric_string_count("1じつせんしゅう"), 1);
    }

    #[test]
    fn get_all_candidates_basic() {
        let test_dictionary =
            CskkDictionary::new_static_dict("tests/data/dictionaries/SKK-JISYO.S", "euc-jp", false)
                .unwrap();
        let dictionaries = vec![Arc::new(test_dictionary)];
        let key = CompositeKey::new("あい", None);
        let result = get_all_candidates(&dictionaries, &key);

        assert_eq!(result[0].kouho_text, "愛");
    }

    #[test]
    fn get_all_candidates_numeric_match() {
        let test_dictionary = CskkDictionary::new_static_dict(
            "tests/data/dictionaries/number_jisyo.dat",
            "utf-8",
            false,
        )
        .unwrap();
        let dictionaries = vec![Arc::new(test_dictionary)];
        let key = CompositeKey::new("5/1", None);
        let result = get_all_candidates(&dictionaries, &key);

        assert_eq!(result[0].kouho_text, "#0月#0日");
        assert_eq!(result[0].midashi, "#/#");
        assert_eq!(result[0].output, "5月1日");
    }

    #[test]
    fn get_all_candidates_numeric_exact_match() {
        let test_dictionary =
            CskkDictionary::new_static_dict("tests/data/dictionaries/maruichi.dat", "utf-8", false)
                .unwrap();
        let dictionaries = vec![Arc::new(test_dictionary)];
        let key = CompositeKey::new("まる1", None);
        let result = get_all_candidates(&dictionaries, &key);

        assert_eq!(result[0].kouho_text, "①"); // 0xE291A0 (U+02460)
        assert_eq!(result[1].kouho_text, "❶");
        assert_eq!(result[2].kouho_text, "⓵"); // 0xE293B5 (U+024F5)
    }
}