Skip to main content

Crate agent_sessions

Crate agent_sessions 

Source
Expand description

Bounded local coding-agent session readers and native snapshot imports.

Events preserve source semantics and provenance. Check ReadSummary before committing a snapshot; receiving events alone does not establish completeness.

§agent-sessions

agent-sessions is a Rust library for reading local coding-agent sessions. It reads Claude Code and Codex JSONL, with native adapters for Gemini CLI, Qwen Code, Kimi CLI, Pi, Copilot CLI, CodeBuddy, iFlow, OpenCode, Cline, Roo Code, Goose, Continue, Cursor, Grok Build, Cline CLI, Hermes Agent, WorkBuddy, Qoder, ZCode, Grok Bot, Cursor Agent CLI, Zed, Warp and Antigravity. The support matrix specifies the implemented formats, per-agent verification status, omissions and remaining gaps; this is not a claim of compatibility with every version of every agent. It discovers local sessions and streams messages, tool calls, usage and metadata as typed events with timestamps and source offsets. Use it to build usage reports, searchable archives or other tools that need to trace an event back to its original record.

crates.io · API docs · Claude Code & Codex JSONL format reference · GitHub releases

JSON/patch-based sessions use import_session; native OpenCode, Goose, Hermes, Cursor, Cursor Agent CLI, ZCode, Zed and Warp SQLite sessions use read-only import_database. Antigravity uses a full trajectory export from its native language service; the exporter reads the running macOS app without making a model request. Imported events retain JSON pointers, physical record locations or database row keys. Check summary.is_supported() and the documented omissions before treating an import as complete. Aggregate-only examples cover each API.

The reader bounds file and line sizes, reports malformed records, and keeps source provenance. Callers decide their own accounting, filtering and archive commit policies.

Live end-to-end tests launch real Codex, Grok Build and OpenCode clients, complete a file task, then verify their newly persisted native sessions. Run them explicitly with existing client authentication; see live acceptance.

Used by ccstats, Keepline, refine’s local session library, ccp, and chat-archive-rs. QuotaBar uses it through ccstats. These links point to merged integrations. Remem also uses the shared reader for transcript ingestion.

§Why share a parser?

Client names alone do not identify a Codex session’s source. The parser retains native evidence and applies the same classification across consumers:

Codex metadataResultEvidence that takes precedence
source: {"subagent": {…}}, originator: "Codex Desktop"SubagentStructured source
source: "exec", originator: "Codex Desktop"ExecExplicit source
source: "vscode", originator: "codex-tui"IdeExplicit source
source: "cli", thread_source: "subagent"SubagentThread source
Only originator: "Codex Desktop"IdeClient fallback

These cases are covered by format-contract tests. Execution provenance does not establish whether a human initiated a session. The format reference also covers the two Codex usage ledgers, Claude cache counters, history timestamps, and incomplete JSONL tails.

§Quick start

[dependencies]
agent-sessions = "0.3.0"
use agent_sessions::{Agent, Event, ReadOptions, read_from};
use std::io::Cursor;

let input = r#"{"type":"user","message":{"content":"hello"}}"#;
let mut reader = read_from(Agent::ClaudeCode, Cursor::new(input), &ReadOptions::default())?;
for event in reader.by_ref() {
    let event = event?;
    if let Event::Message(message) = event.value {
        assert_eq!(message.text, "hello");
    }
}
let summary = reader.finish();
assert!(summary.is_complete());

§Run a complete example

Clone this repository and run a report with the bundled synthetic Codex session:

git clone https://github.com/majiayu000/agent-sessions.git
cd agent-sessions
cargo run --locked --example summarize_codex
{
  "input_tokens": 150,
  "messages": 2,
  "output_tokens": 30,
  "status": "Complete",
  "usage_events": 2
}

The example reads messages and usage events, checks the final read status, and sums usage deltas. The fixture includes a repeated cumulative counter; it is not counted twice. No account or API key is required, and the default command does not read your local sessions.

To read one of your own Codex JSONL files, pass its path:

cargo run --locked --example summarize_codex -- /path/to/session.jsonl

Only aggregate counts are printed. This example selects the default Codex token_count ledger; response-only logs have no selected usage and produce null totals. Missing counters also stay null. Native input includes cache tokens and native output includes reasoning tokens; do not add those subsets again. Malformed or unknown records fail without printing a successful report. This is a single-file example, without cross-file deduplication or dollar pricing. For those application policies, see ccstats.

§Discovery and events

Roots::from_env() honors CLAUDE_CONFIG_DIR and CODEX_HOME, falling back to the platform home directory. Roots::from_home() or explicit Roots isolate tests and custom installations. Empty environment overrides return an error.

discover() scans Claude projects and Codex sessions / archived_sessions; returns files and individual discovery errors; skips symlinks. Missing roots are normal. Subagent path classification is only path evidence: Codex metadata may identify subagents in ordinary session paths. Inspect Meta events when applying subagent filtering. SessionFile::inspect() supports a hook-supplied host/path.

Events: Meta, Message, ToolCall, ToolResult, Usage. Each is wrapped in Located with timestamp, session/message ID when present, physical ordinal, byte range and event index. Text preserves whitespace and repeated occurrences; multiple text blocks are joined with a newline. Thinking/image contents are not exported. Tool arguments remain JSON values or raw strings; no implicit repair. This is a text/usage/tool projection, not a lossless multimodal transcript format.

§Usage accounting

Counters are Option<u64>: absent differs from zero. Negative, fractional or malformed counters are errors. Usage.semantics tells you how counts overlap:

Hostinputoutputcache_write_1h
Claudeexcludes cache categoriesnative outputsubset of cache_write
Codexincludes cache read/writeincludes reasoningnormally absent

TokenCounts::exclusive() produces disjoint input/output only when the required components are known; it returns None for inconsistent subtraction. It never assumes absent components are zero. Cost, model aliases, synthetic-message policy, and cross-file deduplication belong to consumers.

Codex usage is selected explicitly with ReadOptions.codex_usage:

  • TokenCount (default): skip identical cumulative vectors, prefer last sample, otherwise derive deltas; preserve totals and derivation basis.
  • Response: emit token_usage_record usage, with response ID when available.

Never sum both modes. There is no auto-switch halfway through a stream. A single-pass reader cannot retract older emitted events when a newer ledger appears later. Claude message and Codex response IDs are provided as dedup keys, but repeated source records remain observable. Caller dedup scope must include the intended host/session/source identity. Legacy Codex usage without IDs carries cumulative evidence and physical provenance, not a fabricated global ID.

§Reading and failure contracts

Default limits are 200 MiB per file and 8 MiB per physical line (including newline). Limits are checked during reading, including generic streams; oversized lines are drained without buffering their full contents. stop_at_byte requires an exact captured prefix; an input shorter than that prefix fails. Length alone does not detect concurrent rewrites: immutable snapshot verification is a caller responsibility. Readers start at record zero; arbitrary mid-file cumulative usage needs a separate baseline protocol and is not supported. When stop_at_byte is set, max_file_bytes bounds that prefix for both file and stream readers; a larger unread suffix does not cause a size-limit error.

Recoverable line errors are yielded as StreamError::Line. Continue or abort according to your application’s policy. Fatal IO/limit/snapshot errors are yielded once and stop the iterator. A malformed record invalidates cumulative continuity; the next cumulative-only usage restores its baseline with an error. Meta messages are retained, including those with isMeta; consumers choose filters.

Strict tail parsing is default. TailMode::AllowIncomplete tolerates only a final unterminated JSON value whose parser error is EOF. Invalid UTF-8, malformed final JSON, or an incomplete JSON record ending with a newline remain errors.

Always call finish() after iteration. It does not drain unread data:

StatusMeaning
Completeclean end, all selected events delivered
CompleteWithErrorsend reached after line errors
IncompleteTailappend tail was tolerated
StoppedEarlycaller did not consume to the end
Failedfatal stream error

Only Complete authorizes a whole-snapshot commit. Unknown record types are counted separately and may require an additional application completeness gate. last_complete_byte marks only the contiguous error-free, fully delivered prefix; it is not a license to advance an application cursor after failure.

EventKinds selects projections while retaining deterministic event indexes. Excluded payloads are not projected or semantically validated: malformed usage cannot block a message-only consumer, and a usage-only reader does not require content. Relevant metadata continuity and top-level diagnostics remain active; content diagnostics cover inspected projections. Event slots are 0=Meta, 1=Message, 2=Usage, 3+content-block-index=tools (Codex standalone tools use 3). Known irrelevant records are counted separately from unknown types. Summaries never contain message text.

§Development

Rust 1.88+; synchronous IO; no runtime network dependency. Native database readers use bundled SQLite in read-only transactions.

cargo +1.95.0 fmt --check
cargo +1.95.0 clippy --all-targets -- -D warnings
cargo +1.88.0 test --locked --all-targets
cargo +1.95.0 test --doc
cargo +1.95.0 run --release --example scan -- claude legacy
cargo +1.95.0 run --release --example scan -- codex response 100
cargo +1.95.0 run --release --example scan -- codex legacy 100000 16
cargo +1.95.0 run --release --example compare_messages

The scanner reads local files and prints aggregate diagnostics only. Checked-in fixtures are synthetic; no private transcripts are copied into the repository. The fourth scan argument explicitly raises the line limit in MiB. One observed local record was 10.9 MB, above the default 8 MiB limit. Do not silently discard limit errors. compare_messages checks the pinned remem text projection only, not database replay, identity-ledger behavior or the complete remem application. See product contract, technical contract and format notes. Existing PLAN.md is historical planning, not evidence of completed migrations or publication.

§Ecosystem APIs (0.2)

read_raw_file / read_raw_from preserve exact record bytes, delimiters and absolute offsets. They do not parse JSON, discard unknown records or validate UTF-8. Raw completion describes IO only; archive consumers retain their own commit/hash/partial-record policy. RawReadOptions.start_offset permits resuming from an established byte boundary. Generic sources must already be positioned.

read_history / read_history_from read Claude and Codex history with explicit millisecond/second timestamp units. Entries are not unique sessions. Missing text and IDs remain None. Strict field checking is default; a consumer preserving old record-counting behavior may explicitly select strict_fields: false, which reports malformed optional fields in HistoryEntry.invalid_fields.

load_session_titles reads only native title indices for requested IDs. It never uses message bodies as fallback titles. Message::first_text() preserves the first original text block; text_segments are UTF-8 byte ranges in joined text. A title-preview consumer may stop iteration early or use a bounded prefix source; that does not mean a complete snapshot was read.

Title reads default to a 200 MiB per-index limit and an 8 MiB Codex JSONL line limit, and capture each file’s length before reading. Claude’s JSON index is bounded by the file limit regardless of physical line layout. Customize these budgets with load_session_titles_with_options and TitleReadOptions. The original API and default options remain strict: any malformed row or IO/limit error fails the request. Explicit TitleErrorMode::Collect returns valid titles alongside errors with source paths and Codex line numbers. A nonempty error list means incomplete results, even if requested titles were found. Bad Claude entries can be isolated; malformed document syntax invalidates that index, while other project indices remain eligible. Neither mode reports title contents in errors.

§Statistical normalization and provenance

The default AccountingPolicy::Strict rejects negative counters and malformed TTL breakdowns. UsageStatistics is an explicit policy for existing statistics clients: negative Claude counters are clamped, cache-TTL subsets capped, empty usage objects remain observable, and cumulative decreases use saturating deltas. Every affected Usage carries adjustments. Missing native fields still remain None; callers own whether their aggregation treats them as zero. Codex invalid cache buckets are not clamped. This policy also accepts legacy Claude usage-only envelopes.

Located.timestamp_text retains native timestamp spelling, independently of parsed UTC time. record_id (Claude UUID) and message_id (provider message ID) are distinct. ToolCallKind distinguishes client functions, custom calls and server tools. Roots::from_env_for resolves only one host, avoiding unrelated override failures.

For Codex statistical projections, the reader borrows envelope fields and skips unrequested message/tool bodies before materializing values. Selected records use the same semantic contract; unsupported fast-path shapes and field errors are resolved by the canonical decoder, preserving error kinds and recovery behavior. Valid model observations update context even when duplicate usage is suppressed. Framing reuses its input buffer and uses vectorized newline search; raw consumers still own the exact bytes of each returned record.

§Archival and transcript projections

discover_directory shares the recursive walker for explicit archive roots and reports missing roots. It excludes descendant subagents directories when requested; explicit roots stay eligible even under a directory with that name.

project_conversation and tolerant_timestamp_epoch retain archival consumers’ lenient field policy, including empty messages and first-present timestamp priority. project_codex_function borrows native arguments/output without coercing JSON types. project_transcript supports legacy Codex envelopes, role-specific text blocks, source metadata and meta-message tags. These helpers operate on existing JSON values; callers still validate JSON syntax, incomplete tails and commit boundaries. Typed stream readers retain strict validation by default.

History entries also expose timestamp in native units even outside the datetime range. HistoryReader::next_line_no() identifies a failed physical I/O line, including preceding blank lines. Valid UTF-8 whitespace-only records are skipped.

Statistical readers count nonzero Codex last-usage records lacking cumulative totals under ReadSummary::ignored_types[CODEX_MISSING_TOTAL_USAGE]. This is an observable accounting gap; no guessed usage is emitted and stream error semantics remain unchanged. Consumers requiring complete cost attribution should reject it.

Structs§

ConversationMessage
DatabaseSession
DiscoverError
DiscoverFilter
Discovery
EventKinds
Select projections. Relevant metadata continuity is always maintained; excluded payloads are not validated or materialized.
HistoryEntry
HistoryOptions
HistoryReader
ImportedEvent
Located
Location
Message
MetaUpdate
RawReadOptions
RawReader
RawRecord
RawSummary
ReadOptions
ReadSummary
Roots
SessionFile
SessionImport
SessionMeta
SessionReader
Stateful forward-only reader. Always inspect finish() after consuming events.
SessionTitle
TitleReadError
TitleReadOptions
TitleReadResult
TokenCounts
ToolCall
ToolResult
TranscriptProjection
Usage

Enums§

AccountingPolicy
Agent
CodexContentMode
Select one Codex content representation when both are present.
CodexFunction
Native fields are borrowed without coercion; callers decide whether arguments and outputs must be strings, objects, or other JSON types.
CodexUsageMode
The ledger to emit; selection is explicit to prevent double counting.
DiscoverOperation
The failed discovery operation. InspectFile identifies a candidate already observed as a regular JSONL file, so consumers can apply their metadata policy.
Endpoint
Event
FileKind
ImportError
ImportSource
LineErrorKind
Origin
ReadError
ReadStatus
Role
SessionTitleOrigin
StreamError
TailMode
TitleErrorMode
TokenSemantics
ToolArgs
ToolCallKind
UsageAdjustment
UsageBasis

Constants§

CODEX_MISSING_TOTAL_USAGE
ReadSummary::ignored_types label for selected statistical token-count records with nonzero last usage but no cumulative total. No usage is emitted because an independent ledger cannot be inferred from that record.
VERSION
Package version, available for consumer cache keys.

Functions§

classify
Classify a known path lexically under configured roots, preserving IO errors. Paths containing parent components are rejected rather than escaping a root.
discover
discover_directory
Scan an explicitly selected directory recursively. Unlike configured default roots, a missing directory is reported in errors. Symlinks are not followed. Subagent exclusion applies to descendant directories named subagents; an explicitly selected root remains eligible regardless of its ancestors.
history_entry
history_files
import_database
Read one session within a SQLite read transaction. No byte offsets are invented. opts.max_line_bytes bounds each serialized row; max_file_bytes bounds the DB file.
import_session
Import an immutable file prefix. Database sources use import_database instead. The result must pass summary.is_supported() before claiming complete support.
import_session_from
Reads one native session/export. Patch-based sources are replayed before events are returned, so old text and rewound messages cannot masquerade as final text.
list_database_sessions
Enumerate native IDs; never creates or migrates the database.
load_session_titles
load_session_titles_with_options
Read captured index prefixes with explicit limits and error policy. Collect mode preserves valid titles across bad rows/files; malformed Claude document syntax cannot be recovered within that file. Check errors before trusting completeness. No transcript bodies are read or used as fallback titles.
project_codex_function
project_conversation
Project user/assistant records without filtering meta/control content. Empty or malformed content remains an empty message for archival classification.
project_transcript
Tolerant native transcript projection, including legacy Codex envelopes. Claude accepts text blocks; current Codex accepts role-specific text blocks. Unknown fields do not invalidate valid text. JSON syntax and tail policy are the caller’s responsibility. Meta messages are tagged, not filtered.
read
read_from
The supplied reader must start at record zero. Cumulative-only usage needs the whole prefix; this API does not infer a baseline from an arbitrary seek.
read_history
read_history_from
read_raw_file
read_raw_from
source must already be positioned at options.start_offset.
tolerant_timestamp_epoch
First present native timestamp field, in seconds. Invalid values stay absent; a malformed earlier field does not fall through to a later field.