use std::path::Path;
use std::sync::Arc;
use crate::config_chirho::ModuleConfigChirho;
use crate::error_chirho::{ErrorChirho, ResultChirho};
use crate::keys_chirho::sw_key_chirho::SwKeyChirho;
use crate::keys_chirho::verse_key_chirho::VerseKeyChirho;
use crate::modules_chirho::sw_module_chirho::{ModuleBaseChirho, SwModuleChirho};
use crate::storage_chirho::raw_verse_chirho::RawVerseChirho;
use crate::versification_chirho::{kjv_chirho, TestamentChirho, VersificationChirho};
use crate::{DirectionChirho, EncodingChirho, MarkupChirho};
pub struct RawComChirho {
base_chirho: ModuleBaseChirho,
storage_chirho: RawVerseChirho,
key_chirho: VerseKeyChirho,
v11n_chirho: Arc<VersificationChirho>,
}
impl RawComChirho {
pub fn new_chirho<P: AsRef<Path>>(
path_chirho: P,
config_chirho: ModuleConfigChirho,
) -> ResultChirho<Self> {
let storage_chirho = RawVerseChirho::open_chirho(path_chirho)?;
let v11n_name_chirho = config_chirho.versification_chirho();
let v11n_chirho = Arc::new(
crate::versification_chirho::get_versification_chirho(v11n_name_chirho)
.unwrap_or_else(|| kjv_chirho())
.clone()
);
let key_chirho = VerseKeyChirho::with_versification_chirho(v11n_chirho.clone());
Ok(Self {
base_chirho: ModuleBaseChirho::new_chirho(config_chirho),
storage_chirho,
key_chirho,
v11n_chirho,
})
}
pub fn verse_key_chirho(&self) -> &VerseKeyChirho {
&self.key_chirho
}
pub fn verse_key_mut_chirho(&mut self) -> &mut VerseKeyChirho {
&mut self.key_chirho
}
fn read_current_chirho(&mut self) -> ResultChirho<String> {
let testament_chirho = self.key_chirho.get_testament_chirho();
let index_chirho = self.calculate_verse_index_chirho()?;
self.storage_chirho.read_verse_chirho(testament_chirho, index_chirho)
}
fn calculate_verse_index_chirho(&self) -> ResultChirho<u32> {
let testament_enum_chirho = if self.key_chirho.get_testament_chirho() == 1 {
TestamentChirho::OldChirho
} else {
TestamentChirho::NewChirho
};
self.v11n_chirho
.calculate_index_chirho(
testament_enum_chirho,
self.key_chirho.get_book_chirho() as usize,
self.key_chirho.get_chapter_chirho() as u8,
self.key_chirho.get_verse_chirho() as u8,
)
.ok_or_else(|| ErrorChirho::verse_out_of_bounds_chirho(
self.key_chirho.get_text_chirho(),
))
}
pub fn versification_chirho(&self) -> &VersificationChirho {
&self.v11n_chirho
}
pub fn set_key_text_chirho(&mut self, text_chirho: &str) -> ResultChirho<()> {
self.key_chirho.parse_chirho(text_chirho)?;
Ok(())
}
pub fn get_commentary_chirho(&mut self, reference_chirho: &str) -> ResultChirho<String> {
self.set_key_text_chirho(reference_chirho)?;
self.read_current_chirho()
}
pub fn find_next_entry_chirho(&mut self) -> bool {
let max_search_chirho = 200;
for _ in 0..max_search_chirho {
if let Ok(text_chirho) = self.read_current_chirho() {
if !text_chirho.is_empty() {
return true;
}
}
self.key_chirho.increment_chirho(1);
if self.key_chirho.has_error_chirho() {
return false;
}
}
false
}
pub fn iter_chirho(&mut self) -> RawComIteratorChirho<'_> {
RawComIteratorChirho {
module_chirho: self,
finished_chirho: false,
}
}
}
impl SwModuleChirho for RawComChirho {
fn name_chirho(&self) -> &str {
self.base_chirho.name_chirho()
}
fn description_chirho(&self) -> &str {
self.base_chirho.description_chirho()
}
fn module_type_chirho(&self) -> &str {
"Commentaries"
}
fn language_chirho(&self) -> &str {
self.base_chirho.language_chirho()
}
fn direction_chirho(&self) -> DirectionChirho {
self.base_chirho.direction_chirho()
}
fn encoding_chirho(&self) -> EncodingChirho {
self.base_chirho.encoding_chirho()
}
fn markup_chirho(&self) -> MarkupChirho {
self.base_chirho.markup_chirho()
}
fn get_key_chirho(&self) -> &dyn SwKeyChirho {
&self.key_chirho
}
fn set_key_chirho(&mut self, key_chirho: &dyn SwKeyChirho) -> ResultChirho<()> {
self.key_chirho.set_text_chirho(key_chirho.get_text_chirho());
if self.key_chirho.has_error_chirho() {
return Err(ErrorChirho::invalid_verse_reference_chirho(
key_chirho.get_text_chirho(),
));
}
Ok(())
}
fn get_raw_entry_chirho(&mut self) -> ResultChirho<String> {
self.read_current_chirho()
}
fn has_entry_chirho(&self) -> bool {
true
}
fn is_encrypted_chirho(&self) -> bool {
self.base_chirho.is_encrypted_chirho()
}
fn get_config_entry_chirho(&self, key_chirho: &str) -> Option<&str> {
self.base_chirho.get_config_entry_chirho(key_chirho)
}
fn increment_chirho(&mut self, steps_chirho: i32) {
self.key_chirho.increment_chirho(steps_chirho);
if self.key_chirho.has_error_chirho() {
self.base_chirho.set_error_chirho(true);
}
}
fn decrement_chirho(&mut self, steps_chirho: i32) {
self.key_chirho.decrement_chirho(steps_chirho);
if self.key_chirho.has_error_chirho() {
self.base_chirho.set_error_chirho(true);
}
}
fn pop_error_chirho(&mut self) -> bool {
let key_error_chirho = self.key_chirho.has_error_chirho();
let _ = self.key_chirho.pop_error_chirho();
key_error_chirho || self.base_chirho.pop_error_chirho()
}
}
pub struct RawComIteratorChirho<'a> {
module_chirho: &'a mut RawComChirho,
finished_chirho: bool,
}
impl<'a> Iterator for RawComIteratorChirho<'a> {
type Item = (String, String);
fn next(&mut self) -> Option<Self::Item> {
if self.finished_chirho {
return None;
}
if !self.module_chirho.find_next_entry_chirho() {
self.finished_chirho = true;
return None;
}
let key_text_chirho = self.module_chirho.key_chirho.get_text_chirho().to_string();
let text_chirho = self.module_chirho.read_current_chirho().ok()?;
self.module_chirho.increment_chirho(1);
if self.module_chirho.key_chirho.has_error_chirho() {
self.finished_chirho = true;
let _ = self.module_chirho.key_chirho.pop_error_chirho();
}
Some((key_text_chirho, text_chirho))
}
}
#[cfg(test)]
mod tests_chirho {
use super::*;
use tempfile::TempDir;
fn create_test_module_chirho() -> (TempDir, RawComChirho) {
let temp_dir_chirho = TempDir::new().unwrap();
let mod_path_chirho = temp_dir_chirho.path().join("testcom");
let mut storage_chirho = RawVerseChirho::create_chirho(&mod_path_chirho).unwrap();
storage_chirho
.write_verse_chirho(1, 2, "Commentary on Genesis 1:1")
.unwrap();
storage_chirho
.write_verse_chirho(1, 4, "Commentary on Genesis 1:3")
.unwrap();
let mut config_chirho = ModuleConfigChirho::new_chirho("TestCom".to_string());
config_chirho.set_chirho("Description", "Test Commentary Module");
config_chirho.set_chirho("Lang", "en");
let module_chirho = RawComChirho::new_chirho(&mod_path_chirho, config_chirho).unwrap();
(temp_dir_chirho, module_chirho)
}
#[test]
fn test_module_creation_chirho() {
let (_temp_chirho, module_chirho) = create_test_module_chirho();
assert_eq!(module_chirho.name_chirho(), "TestCom");
assert_eq!(module_chirho.module_type_chirho(), "Commentaries");
}
#[test]
fn test_key_navigation_chirho() {
let (_temp_chirho, mut module_chirho) = create_test_module_chirho();
assert_eq!(module_chirho.verse_key_chirho().get_book_name_chirho(), "Genesis");
assert_eq!(module_chirho.verse_key_chirho().get_chapter_chirho(), 1);
assert_eq!(module_chirho.verse_key_chirho().get_verse_chirho(), 1);
module_chirho.increment_chirho(1);
assert_eq!(module_chirho.verse_key_chirho().get_verse_chirho(), 2);
}
#[test]
fn test_set_key_chirho() {
let (_temp_chirho, mut module_chirho) = create_test_module_chirho();
module_chirho.set_key_text_chirho("Romans 8:28").unwrap();
assert_eq!(module_chirho.verse_key_chirho().get_book_name_chirho(), "Romans");
assert_eq!(module_chirho.verse_key_chirho().get_chapter_chirho(), 8);
assert_eq!(module_chirho.verse_key_chirho().get_verse_chirho(), 28);
}
}