magi-code 0.82.1

Repository-aware CLI coding agent for terminal work
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
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59

//! Exclusive writer admission, separate from shared retention protection.
use super::Session;
use crate::persistence::CrossProcessFileLock;

impl Session {
    pub(crate) fn try_frontend_writer(&self) -> anyhow::Result<Option<CrossProcessFileLock>> {
        let root = self
            .path
            .parent()
            .ok_or_else(|| anyhow::anyhow!("missing root"))?;
        super::store::prepare_session_root(root)?;
        CrossProcessFileLock::try_acquire(&self.path.with_extension("writer"))
    }
}

#[cfg(test)]
mod tests {
    use super::super::SessionManager;
    use tempfile::TempDir;

    #[test]
    fn writer_conflict_and_dead_owner_recovery_cross_process() {
        const ROOT: &str = "MAGI_TEST_SESSION_WRITER_ROOT";
        const MODE: &str = "MAGI_TEST_SESSION_WRITER_MODE";
        if let Some(root) = std::env::var_os(ROOT) {
            let session = SessionManager::new(root.into())
                .open("writer-test")
                .unwrap();
            let lease = session.try_frontend_writer().unwrap();
            if std::env::var(MODE).unwrap() == "conflict" {
                assert!(lease.is_none());
                return;
            }
            assert!(lease.is_some());
            // Leave the lock behind, like a killed TUI process.
            std::process::exit(0);
        }
        let temp = TempDir::new().unwrap();
        let root = temp.path().join("sessions");
        let session = SessionManager::new(root.clone())
            .open("writer-test")
            .unwrap();
        let owner = session.try_frontend_writer().unwrap().unwrap();
        let child = |mode: &str| {
            let output = std::process::Command::new(std::env::current_exe().unwrap())
                .args(["--exact", "sessions::writer::tests::writer_conflict_and_dead_owner_recovery_cross_process", "--quiet"])
                .env(ROOT, &root).env(MODE, mode).output().unwrap();
            assert!(
                output.status.success(),
                "{}",
                String::from_utf8_lossy(&output.stderr)
            );
        };
        child("conflict");
        drop(owner);
        child("abandon");
        assert!(session.try_frontend_writer().unwrap().is_some());
    }
}