txcript 0.1.0

A typed intermediate representation for converting AI coding-agent session transcripts between harness formats (Claude Code, Codex, OpenCode, pi).
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
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84

//! Campfire embeds pi and writes the identical on-disk format under
//! `~/.campfire/agent/sessions/` (honoring `CAMPFIRE_CODING_AGENT_*`). It is a
//! thin delegate: the body type, codec, and store logic are pi's, reused
//! verbatim; only the harness identity and the sessions root differ.

use std::path::PathBuf;

use crate::error::Result;
use crate::harness::jsonl;
use crate::harness::pi::{self, Record};
use crate::transcript::{Codec, Common, Discovered, Harness, Saved, Store, TextCodec, Transcript};

/// The Campfire harness marker. Shares pi's native [`Record`] body.
#[derive(Debug, Clone, Copy, PartialEq, Eq)]
pub struct Campfire;

impl Harness for Campfire {
    const NAME: &'static str = "campfire";
    type Body = Vec<Record>;
}

impl Codec for Campfire {
    fn to_common(transcript: &Transcript<Self>) -> Result<Transcript<Common>> {
        Ok(Transcript::new(
            transcript.meta.clone(),
            pi::records_to_messages(&transcript.body, transcript.meta.timestamp),
        ))
    }

    fn from_common(transcript: &Transcript<Common>) -> Result<Transcript<Self>> {
        Ok(Transcript::new(
            transcript.meta.clone(),
            pi::messages_to_records(&transcript.meta, &transcript.body),
        ))
    }
}

impl TextCodec for Campfire {
    fn from_text(text: &str) -> Result<Transcript<Self>> {
        // Identical format to pi — reuse its parser and metadata extraction.
        let records: Vec<Record> = jsonl::parse(text);
        Ok(Transcript::new(pi::meta_from_records(&records), records))
    }

    fn to_text(transcript: &Transcript<Self>) -> Result<String> {
        jsonl::render(&transcript.body)
    }
}

/// Reads and writes Campfire sessions under a sessions root.
#[derive(Debug, Clone)]
pub struct CampfireStore {
    pub sessions_dir: PathBuf,
}

impl CampfireStore {
    pub fn new(sessions_dir: impl Into<PathBuf>) -> Self {
        Self {
            sessions_dir: sessions_dir.into(),
        }
    }

    /// Campfire's default sessions root, honoring `CAMPFIRE_CODING_AGENT_*`.
    pub fn default_root() -> Option<Self> {
        pi::resolve_sessions_dir(".campfire", "CAMPFIRE").map(Self::new)
    }
}

impl Store for CampfireStore {
    type H = Campfire;
    type Ref = PathBuf;

    fn discover(&self) -> Result<Vec<Discovered<PathBuf>>> {
        pi::discover_format(&self.sessions_dir)
    }

    fn load(&self, reference: &PathBuf) -> Result<Transcript<Campfire>> {
        pi::load_session(reference, Campfire::from_text)
    }

    fn save(&self, transcript: &Transcript<Campfire>) -> Result<Saved<PathBuf>> {
        pi::write_session(&self.sessions_dir, &transcript.meta, &transcript.body)
    }
}