monoloop-connector-codex 0.1.2

OpenAI Codex ACP connector profile (JSON-RPC over stdio NDJSON via codex-acp)
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

//! Optional raw NDJSON capture (test diagnostics only).

use std::path::PathBuf;
use std::sync::Mutex;

/// Bounded collector for exact inbound/outbound NDJSON lines.
#[derive(Debug, Default)]
pub struct CodexRawDump {
    lines: Mutex<Vec<String>>,
    path: Option<PathBuf>,
    max_lines: usize,
}

impl CodexRawDump {
    /// Create an in-memory collector; optionally mirror to a file.
    pub fn new(path: Option<PathBuf>, max_lines: usize) -> Self {
        Self {
            lines: Mutex::new(Vec::new()),
            path,
            max_lines: max_lines.max(1),
        }
    }

    /// Record one complete NDJSON line.
    pub fn push_line(&self, line: impl Into<String>) {
        let line = line.into();
        if let Ok(mut g) = self.lines.lock() {
            if g.len() < self.max_lines {
                g.push(line.clone());
            }
        }
        if let Some(path) = &self.path {
            use std::io::Write;
            if let Ok(mut f) = std::fs::OpenOptions::new()
                .create(true)
                .append(true)
                .open(path)
            {
                let _ = writeln!(f, "{line}");
            }
        }
    }

    /// Snapshot of captured lines.
    pub fn snapshot(&self) -> Vec<String> {
        self.lines.lock().map(|g| g.clone()).unwrap_or_default()
    }

    /// Join captured lines for file export.
    pub fn as_text(&self) -> String {
        self.snapshot().join("\n")
    }
}