ragrig 0.9.4

//! Filesystem-backed [`SessionStore`] — one JSON file per session.
//!
//! Sessions live in `<folder>/.ragrig/sessions/<id>.json`.  Manifests
//! are derived from the files on disk; no separate index is kept.

use std::fs;
use std::path::PathBuf;

use anyhow::{Context, Result};
use async_trait::async_trait;

use crate::history_persistence::{
    SessionData, SessionId, SessionManifest, SessionStore,
};

/// Filesystem session store backed by a directory on disk.
#[derive(Clone, Debug)]
pub struct FsSessionStore {
    root: PathBuf,
}

impl FsSessionStore {
    /// Create a new store rooted at `root`.  The directory is created if
    /// it doesn't exist.
    pub fn new(root: PathBuf) -> Result<Self> {
        fs::create_dir_all(&root)
            .with_context(|| format!("creating session store at {:?}", root))?;
        Ok(Self { root })
    }

    fn session_path(&self, id: &SessionId) -> PathBuf {
        self.root.join(format!("{}.json", id.0))
    }
}

#[async_trait]
impl SessionStore for FsSessionStore {
    async fn save(&self, session: &SessionData) -> Result<()> {
        let path = self.session_path(&session.id);
        let json = serde_json::to_string_pretty(session)?;
        fs::write(&path, json)
            .with_context(|| format!("writing session to {:?}", path))?;
        Ok(())
    }

    async fn load(&self, id: &SessionId) -> Result<Option<SessionData>> {
        let path = self.session_path(id);
        if !path.exists() {
            return Ok(None);
        }
        let json = fs::read_to_string(&path)
            .with_context(|| format!("reading session from {:?}", path))?;
        let session: SessionData = serde_json::from_str(&json)
            .with_context(|| format!("parsing session from {:?}", path))?;
        Ok(Some(session))
    }

    async fn list(&self) -> Result<Vec<SessionManifest>> {
        let mut manifests = Vec::new();
        for entry in fs::read_dir(&self.root)
            .with_context(|| format!("listing sessions in {:?}", self.root))?
        {
            let entry = entry?;
            let path = entry.path();
            if path.extension().is_none_or(|e| e != "json") {
                continue;
            }
            let Some(id_str) = path.file_stem().and_then(|s| s.to_str()) else {
                continue;
            };
            let id = SessionId(id_str.to_string());
            let json = fs::read_to_string(&path)?;
            // Parse just the fields needed for a manifest, skipping turns.
            #[derive(serde::Deserialize)]
            struct ManifestFields {
                created: std::time::SystemTime,
                updated: std::time::SystemTime,
                turns: Vec<serde_json::Value>,
            }
            let mf: ManifestFields = serde_json::from_str(&json)?;
            manifests.push(SessionManifest {
                id,
                created: mf.created,
                updated: mf.updated,
                turn_count: mf.turns.len(),
                summary: None,
                path,
            });
        }
        manifests.sort_by_key(|m| m.created);
        Ok(manifests)
    }

    async fn delete(&self, id: &SessionId) -> Result<()> {
        let path = self.session_path(id);
        if path.exists() {
            fs::remove_file(&path)
                .with_context(|| format!("deleting session {:?}", path))?;
        }
        Ok(())
    }

    fn name(&self) -> &'static str {
        "filesystem"
    }
}

#[cfg(test)]
mod tests {
    use super::*;
    use crate::history_persistence::*;
    use std::sync::atomic::{AtomicU64, Ordering};

    static COUNTER: AtomicU64 = AtomicU64::new(0);

    fn new_store() -> FsSessionStore {
        let n = COUNTER.fetch_add(1, Ordering::Relaxed);
        let dir = std::env::temp_dir().join(format!("ragrig-sessions-{}-{}", std::process::id(), n));
        let _ = std::fs::remove_dir_all(&dir);
        FsSessionStore::new(dir).unwrap()
    }

    fn sample_session(id: &str) -> SessionData {
        SessionData {
            id: SessionId(id.into()),
            created: std::time::UNIX_EPOCH,
            updated: std::time::SystemTime::now(),
            config: SessionConfig {
                chat_backend: "test".into(), chat_model: "test".into(),
                embed_backend: "test".into(), embed_model: "test".into(),
                memory_strategy: MemoryStrategyKind::Off, memory_backend: String::new(),
                memory_model: String::new(), top_k: 3,
                similarity_threshold: 0.0, model_ctx_tokens: 4096,
            },
            turns: vec![Turn { role: TurnRole::User, text: "hello".into(), perf: None }],
        }
    }

    #[tokio::test]
    async fn save_and_load_roundtrip() {
        let store = new_store();
        let session = sample_session("test-1");
        store.save(&session).await.unwrap();
        let loaded = store.load(&SessionId("test-1".into())).await.unwrap().unwrap();
        assert_eq!(loaded.id.0, "test-1");
        assert_eq!(loaded.turns.len(), 1);
        assert_eq!(loaded.turns[0].text, "hello");
    }

    #[tokio::test]
    async fn list_returns_manifests() {
        let store = new_store();
        store.save(&sample_session("a")).await.unwrap();
        store.save(&sample_session("b")).await.unwrap();
        let manifests = store.list().await.unwrap();
        assert_eq!(manifests.len(), 2);
    }

    #[tokio::test]
    async fn delete_removes_session() {
        let store = new_store();
        store.save(&sample_session("del-me")).await.unwrap();
        store.delete(&SessionId("del-me".into())).await.unwrap();
        assert!(store.load(&SessionId("del-me".into())).await.unwrap().is_none());
    }

    #[tokio::test]
    async fn load_nonexistent_returns_none() {
        let store = new_store();
        assert!(store.load(&SessionId("nope".into())).await.unwrap().is_none());
    }

    #[test]
    fn store_name_is_filesystem() {
        let store = new_store();
        assert_eq!(store.name(), "filesystem");
    }
}