Method save

atomic-agent/src/turn/session.rs:529–562

Save a session to disk atomically. Writes to a temporary file first, then renames to the final path. This prevents corruption if the process is killed mid-write. # Errors Returns `AgentError::SessionSaveFailed` if the write or rename fails.

(&self, session: &AgentSession)

    ///
    /// Returns `AgentError::SessionSaveFailed` if the write or rename fails.
    pub fn save(&self, session: &AgentSession) -> AgentResult<()> {
        validate_session_id(&session.session_id)?;

        let path = self.session_path(&session.session_id);
        let tmp_path = self.temp_session_path(&session.session_id);

        let data =
            serde_json::to_string_pretty(session).map_err(|e| AgentError::SessionSaveFailed {
                session_id: session.session_id.clone(),
                reason: format!("JSON serialize error: {}", e),
            })?;

        // Each writer needs its own same-directory temp file. Concurrent hook
        // processes can save the same session, and threads within one process
        // must not collide either.
        if let Err(e) = std::fs::write(&tmp_path, data.as_bytes()) {
            let _ = std::fs::remove_file(&tmp_path);
            return Err(AgentError::SessionSaveFailed {
                session_id: session.session_id.clone(),
                reason: format!("write temp file: {}", e),
            });
        }

        // Atomic rename
        if let Err(e) = std::fs::rename(&tmp_path, &path) {
            let _ = std::fs::remove_file(&tmp_path);
            return Err(AgentError::SessionSaveFailed {
                session_id: session.session_id.clone(),
                reason: format!("rename temp file: {}", e),
            });
        }

        Ok(())
    }

    /// Delete a session state file.
    ///