Whole-file parsing

To parse a transcript in one call, use Parse:

  f, err := os.Open("session.jsonl")
if err != nil {
    return err
}
defer f.Close()

s, err := agentminutes.Parse(f, harness.ClaudeCode, harness.Options{})
if err != nil {
    return err
}

fmt.Println(s.Meta.HarnessVersion, len(s.Events), s.Totals.OutputTokens)

To join tool calls with their results, in call order:

  for _, ti := range s.ToolInteractions() {
    if ti.Call == nil {
        continue // orphaned result: no matching call in the transcript
    }
    call := ti.Call.ToolCall
    fmt.Println(call.Name, call.Kind, len(ti.Results))
}

Or take the precomputed behavioral summary:

  st := s.Stats()
fmt.Println(st.ToolCallsByName, st.ResultBytes, st.WallTimeMS, st.FinalAnswer)

Streaming

For large transcripts or incremental processing, adapters emit events as an iterator:

  a, err := agentminutes.AdapterFor(harness.ClaudeCode)
if err != nil {
    return err
}
for ev, err := range a.Events(f, harness.Options{}) {
    if err != nil {
        return err // a *harness.ParseError identifying harness, version, and line
    }
    if ev.Kind == session.KindToolCall {
        fmt.Println(ev.ToolCall.Name)
    }
}

The first event of every stream is session_meta, so streaming consumers know what they are reading before EOF. session.Accumulator bridges the two modes: feed it events, ask it for the accumulated Session. This is exactly what Parse does.

Transforms

Optional post-parse policies compose as session.Transform functions, applied in order by Parse or wrapped around Events directly. Adapters translate; transforms reshape, and only when asked. The exported telemetry promotions (currently codex.PromotePatchApply and codex.PromoteWebSearch) are the canonical transforms:

  s, err := harness.Parse(codex.Adapter{}, f, harness.Options{}, codex.PromoteWebSearch)

The ACP projection

To project a session onto the Agent Client Protocol session/update vocabulary, use acp.Project. It returns a loss report quantifying what the ACP lens cannot see (system events, token usage, timestamps, empty anchors):

  updates, loss := acp.Project(s)
fmt.Println(len(updates), loss.DroppedEvents, loss.DroppedFields)

Session discovery

agentminutes.Scan and agentminutes.Locate mirror the CLI’s sessions command; see Session Discovery for the API and its accounting discipline.