libnoa 0.1.1

use crate::{
    error::{NoaError, Result},
    log::LogEntry,
};

pub fn serialize_entry(entry: &LogEntry) -> Result<String> {
    serde_json::to_string(entry).map_err(|e| NoaError::Serialization(e.to_string()))
}

pub fn deserialize_entry(line: &str) -> Result<LogEntry> {
    let trimmed = line.trim();
    if trimmed.is_empty() {
        return Err(NoaError::Serialization("empty log line".to_string()));
    }
    serde_json::from_str(trimmed).map_err(|e| NoaError::Serialization(e.to_string()))
}

pub fn deserialize_entries(content: &str) -> Result<Vec<LogEntry>> {
    content
        .lines()
        .filter(|line| !line.trim().is_empty())
        .map(deserialize_entry)
        .collect()
}

#[cfg(test)]
mod tests {
    use super::*;
    use crate::log::OpType;

    #[test]
    fn test_roundtrip() {
        let entry = LogEntry {
            seq: 1,
            op: OpType::Write,
            path: Some("src/main.rs".to_string()),
            blob_id: Some("abc123".to_string()),
            from_path: None,
            resolved_conflict_ours_id: None,
            resolved_conflict_theirs_id: None,
            snapshot_id: None,
            ts: 1717592400000000,
            message: None,
        };
        let json = serialize_entry(&entry).unwrap();
        let parsed = deserialize_entry(&json).unwrap();
        assert_eq!(parsed, entry);
    }

    #[test]
    fn test_deserialize_entries_multiline() {
        let content = r#"{"seq":1,"op":"write","path":"a.rs","ts":100}
{"seq":2,"op":"delete","path":"b.rs","ts":200}
"#;
        let entries = deserialize_entries(content).unwrap();
        assert_eq!(entries.len(), 2);
        assert_eq!(entries[0].seq, 1);
        assert_eq!(entries[1].seq, 2);
    }

    #[test]
    fn test_deserialize_entries_skips_blank() {
        let content = "\n{\"seq\":1,\"op\":\"write\",\"ts\":100}\n\n";
        let entries = deserialize_entries(content).unwrap();
        assert_eq!(entries.len(), 1);
    }
}