codetether-agent 4.5.7

A2A-native AI coding agent for the CodeTether ecosystem
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36

//! Atomic writer for [`super::workspace_index::WorkspaceIndex`].
//!
//! Uses write-to-tmp + rename to avoid torn writes and to let multiple
//! codetether processes update concurrently without corrupting the file.

use std::path::Path;

use anyhow::{Context, Result};

use super::workspace_index::WorkspaceIndex;

pub(super) fn save_sync(index: &WorkspaceIndex) -> Result<()> {
    let path = WorkspaceIndex::path()?;
    if let Some(parent) = path.parent() {
        std::fs::create_dir_all(parent).context("create sessions dir")?;
    }
    let tmp = path.with_extension("json.tmp");
    let bytes = serde_json::to_vec(index)?;
    std::fs::write(&tmp, bytes).context("write index tmp")?;
    // Atomic on POSIX; on Windows `rename` over an existing file errors,
    // so fall through to a replace when needed.
    match std::fs::rename(&tmp, &path) {
        Ok(()) => Ok(()),
        Err(_) => {
            let _ = std::fs::remove_file(&path);
            std::fs::rename(&tmp, &path).context("rename index into place")
        }
    }
}

/// Merge one workspace->session mapping into the on-disk index.
pub(super) fn upsert_sync(workspace: &Path, session_id: &str) -> Result<()> {
    let mut index = WorkspaceIndex::load_sync();
    index.set(workspace, session_id);
    save_sync(&index)
}