zag_agent/

session.rs

//! Session-to-worktree mapping store.
//!
//! Persists session-worktree mappings in `~/.zag/projects/<id>/sessions.json`
//! so that `zag run --resume <id>` can resume inside the correct workspace.

use crate::config::Config;
use crate::session_log::{GlobalSessionEntry, upsert_global_entry};
use anyhow::{Context, Result};
use chrono::{DateTime, FixedOffset};
use log::debug;
use serde::{Deserialize, Serialize};
use std::path::PathBuf;

#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct SessionEntry {
    pub session_id: String,
    pub provider: String,
    #[serde(default)]
    pub model: String,
    pub worktree_path: String,
    pub worktree_name: String,
    pub created_at: String,
    #[serde(default)]
    pub provider_session_id: Option<String>,
    #[serde(default)]
    pub sandbox_name: Option<String>,
    #[serde(default)]
    pub is_worktree: bool,
    #[serde(default)]
    pub discovered: bool,
    #[serde(default)]
    pub discovery_source: Option<String>,
    #[serde(default)]
    pub log_path: Option<String>,
    #[serde(default = "default_log_completeness")]
    pub log_completeness: String,
    /// Human-readable session name for discovery.
    #[serde(default)]
    pub name: Option<String>,
    /// Short description of the session's purpose.
    #[serde(default)]
    pub description: Option<String>,
    /// Arbitrary tags for categorization and discovery.
    #[serde(default)]
    pub tags: Vec<String>,
    /// Session IDs that this session depends on (must complete before this session starts).
    #[serde(default, skip_serializing_if = "Vec::is_empty")]
    pub dependencies: Vec<String>,
    /// Session ID that this session is a retry of.
    #[serde(default, skip_serializing_if = "Option::is_none")]
    pub retried_from: Option<String>,
    /// Whether this is a long-lived interactive session (FIFO-based).
    #[serde(default, skip_serializing_if = "is_false")]
    pub interactive: bool,
    /// Exit-mode constraints captured at launch (`--exit`, `--json`,
    /// `--json-schema`). `None` means the session was launched without
    /// `--exit` and `zag ps kill` accepts any result. See
    /// [`crate::exit_mode::ExitConstraints`].
    #[serde(default, skip_serializing_if = "Option::is_none")]
    pub exit: Option<crate::exit_mode::ExitConstraints>,
}

fn is_false(v: &bool) -> bool {
    !v
}

#[derive(Debug, Clone, Default, Serialize, Deserialize)]
pub struct SessionStore {
    pub sessions: Vec<SessionEntry>,
}

impl SessionStore {
    /// Path to the sessions file.
    fn path(root: Option<&str>) -> PathBuf {
        Config::agent_dir(root).join("sessions.json")
    }

    /// Load session store from disk. Returns empty store if file doesn't exist.
    pub fn load(root: Option<&str>) -> Result<Self> {
        let path = Self::path(root);
        debug!("Loading session store from {}", path.display());
        if !path.exists() {
            debug!("Session store not found, using empty store");
            return Ok(Self::default());
        }
        let content = std::fs::read_to_string(&path)
            .with_context(|| format!("Failed to read sessions file: {}", path.display()))?;
        let store: SessionStore = serde_json::from_str(&content)
            .with_context(|| format!("Failed to parse sessions file: {}", path.display()))?;
        debug!(
            "Loaded {} sessions from {}",
            store.sessions.len(),
            path.display()
        );
        Ok(store)
    }

    /// Save session store to disk.
    pub fn save(&self, root: Option<&str>) -> Result<()> {
        let path = Self::path(root);
        debug!(
            "Saving {} sessions to {}",
            self.sessions.len(),
            path.display()
        );
        if let Some(parent) = path.parent() {
            std::fs::create_dir_all(parent)
                .with_context(|| format!("Failed to create directory: {}", parent.display()))?;
        }
        let content = serde_json::to_string_pretty(self).context("Failed to serialize sessions")?;
        crate::file_util::atomic_write_str(&path, &content)
            .with_context(|| format!("Failed to write sessions file: {}", path.display()))?;
        debug!("Session store saved to {}", path.display());

        // Also upsert entries with log_path into the global session index
        let global_dir = Config::global_base_dir();
        let project = path
            .parent()
            .and_then(|p| p.file_name())
            .map(|n| n.to_string_lossy().to_string())
            .unwrap_or_default();
        for entry in &self.sessions {
            if let Some(ref log_path) = entry.log_path {
                let _ = upsert_global_entry(
                    &global_dir,
                    GlobalSessionEntry {
                        session_id: entry.session_id.clone(),
                        project: project.clone(),
                        log_path: log_path.clone(),
                        provider: entry.provider.clone(),
                        started_at: entry.created_at.clone(),
                    },
                );
            }
        }

        Ok(())
    }

    /// Load all session stores across all projects under `~/.zag/projects/`.
    pub fn load_all() -> Result<Self> {
        let projects_dir = Config::global_base_dir().join("projects");
        debug!("Loading all session stores from {}", projects_dir.display());
        let mut all_sessions = Vec::new();
        if let Ok(entries) = std::fs::read_dir(&projects_dir) {
            for entry in entries.flatten() {
                let sessions_path = entry.path().join("sessions.json");
                if sessions_path.exists() {
                    if let Ok(content) = std::fs::read_to_string(&sessions_path) {
                        if let Ok(store) = serde_json::from_str::<SessionStore>(&content) {
                            all_sessions.extend(store.sessions);
                        }
                    }
                }
            }
        }
        // Also load the global base directory sessions (non-repo usage)
        let global_sessions = Config::global_base_dir().join("sessions.json");
        if global_sessions.exists() {
            if let Ok(content) = std::fs::read_to_string(&global_sessions) {
                if let Ok(store) = serde_json::from_str::<SessionStore>(&content) {
                    all_sessions.extend(store.sessions);
                }
            }
        }
        debug!("Loaded {} sessions across all projects", all_sessions.len());
        Ok(Self {
            sessions: all_sessions,
        })
    }

    /// Add a session entry.
    pub fn add(&mut self, entry: SessionEntry) {
        self.sessions.retain(|existing| {
            existing.session_id != entry.session_id
                && !(entry.provider_session_id.is_some()
                    && existing.provider_session_id == entry.provider_session_id)
        });
        debug!(
            "Adding session: id={}, provider={}, worktree={}",
            entry.session_id, entry.provider, entry.worktree_name
        );
        self.sessions.push(entry);
    }

    /// Find a session by ID.
    pub fn find_by_session_id(&self, id: &str) -> Option<&SessionEntry> {
        let result = self.sessions.iter().find(|e| e.session_id == id);
        if result.is_some() {
            debug!("Found session: {id}");
        } else {
            debug!("Session not found: {id}");
        }
        result
    }

    /// Find a session by provider-native session ID.
    pub fn find_by_provider_session_id(&self, id: &str) -> Option<&SessionEntry> {
        let result = self
            .sessions
            .iter()
            .find(|e| e.provider_session_id.as_deref() == Some(id));
        if result.is_some() {
            debug!("Found provider session: {id}");
        } else {
            debug!("Provider session not found: {id}");
        }
        result
    }

    /// Find a session by either wrapper or provider-native ID.
    pub fn find_by_any_id(&self, id: &str) -> Option<&SessionEntry> {
        self.find_by_session_id(id)
            .or_else(|| self.find_by_provider_session_id(id))
    }

    /// Get the most recently created session.
    pub fn latest(&self) -> Option<&SessionEntry> {
        self.sessions.iter().max_by(|a, b| {
            parse_created_at(&a.created_at)
                .cmp(&parse_created_at(&b.created_at))
                .then_with(|| a.session_id.cmp(&b.session_id))
        })
    }

    /// Update a wrapper session with the provider-native session ID.
    pub fn set_provider_session_id(&mut self, session_id: &str, provider_session_id: String) {
        if let Some(entry) = self
            .sessions
            .iter_mut()
            .find(|e| e.session_id == session_id)
        {
            entry.provider_session_id = Some(provider_session_id);
        }
    }

    /// Remove a session by ID.
    pub fn remove(&mut self, session_id: &str) {
        debug!("Removing session: {session_id}");
        self.sessions.retain(|e| e.session_id != session_id);
    }

    /// List all sessions as `SessionInfo`, sorted by created_at descending (newest first).
    pub fn list(&self) -> Vec<SessionInfo> {
        let mut infos: Vec<SessionInfo> = self.sessions.iter().map(SessionInfo::from).collect();
        infos.sort_by(|a, b| {
            parse_created_at(&b.created_at)
                .cmp(&parse_created_at(&a.created_at))
                .then_with(|| b.session_id.cmp(&a.session_id))
        });
        infos
    }

    /// Get a session by any ID (wrapper or provider-native) as `SessionInfo`.
    pub fn get(&self, id: &str) -> Option<SessionInfo> {
        self.find_by_any_id(id).map(SessionInfo::from)
    }

    /// Find a session by exact name match. Returns the most recent if multiple match.
    pub fn find_by_name(&self, name: &str) -> Option<&SessionEntry> {
        self.sessions
            .iter()
            .filter(|e| e.name.as_deref() == Some(name))
            .max_by(|a, b| {
                parse_created_at(&a.created_at)
                    .cmp(&parse_created_at(&b.created_at))
                    .then_with(|| a.session_id.cmp(&b.session_id))
            })
    }

    /// Find all sessions with a matching tag (case-insensitive).
    pub fn find_by_tag(&self, tag: &str) -> Vec<&SessionEntry> {
        let tag_lower = tag.to_lowercase();
        self.sessions
            .iter()
            .filter(|e| e.tags.iter().any(|t| t.to_lowercase() == tag_lower))
            .collect()
    }
}

/// Public session info struct for programmatic API consumers.
#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct SessionInfo {
    pub session_id: String,
    pub provider: String,
    pub model: String,
    pub created_at: String,
    pub provider_session_id: Option<String>,
    pub worktree_path: Option<String>,
    pub sandbox_name: Option<String>,
    pub log_completeness: String,
    #[serde(default, skip_serializing_if = "Option::is_none")]
    pub name: Option<String>,
    #[serde(default, skip_serializing_if = "Option::is_none")]
    pub description: Option<String>,
    #[serde(default, skip_serializing_if = "Vec::is_empty")]
    pub tags: Vec<String>,
}

impl From<&SessionEntry> for SessionInfo {
    fn from(e: &SessionEntry) -> Self {
        Self {
            session_id: e.session_id.clone(),
            provider: e.provider.clone(),
            model: e.model.clone(),
            created_at: e.created_at.clone(),
            provider_session_id: e.provider_session_id.clone(),
            worktree_path: if e.worktree_path.is_empty() {
                None
            } else {
                Some(e.worktree_path.clone())
            },
            sandbox_name: e.sandbox_name.clone(),
            log_completeness: e.log_completeness.clone(),
            name: e.name.clone(),
            description: e.description.clone(),
            tags: e.tags.clone(),
        }
    }
}

fn default_log_completeness() -> String {
    "partial".to_string()
}

fn parse_created_at(created_at: &str) -> Option<DateTime<FixedOffset>> {
    DateTime::parse_from_rfc3339(created_at).ok()
}

#[cfg(test)]
#[path = "session_tests.rs"]
mod tests;