persist

type ApprovalRequestPayload struct {
	// ApprovalID is the handle the CLI / web-UI / MCP consumer uses
	// to respond. Format is run-id-scoped: ULID-shaped, deterministic
	// across replay so a resumed run sees the same handle.
	ApprovalID string `json:"approval_id"`

	// Prompt is the human-readable description of what's being
	// approved. Authors emit this from the skill via the approval()
	// binding (TS) or the Approver interface (Go).
	Prompt string `json:"prompt"`

	// TimeoutSeconds is the server-side timeout after which the
	// runtime auto-rejects the request. Zero means "no timeout";
	// callers should default to 86_400 (24h) per the design.
	TimeoutSeconds int64 `json:"timeout_seconds,omitempty"`

	// WarnAtSeconds is the elapsed time after which the runtime
	// emits a "still pending" warning to slog. Defaults to 80% of
	// TimeoutSeconds when zero on read.
	WarnAtSeconds int64 `json:"warn_at_seconds,omitempty"`
}

type ApprovalResponsePayload struct {
	// ApprovalID matches the EventApprovalRequest it answers.
	ApprovalID string `json:"approval_id"`

	// Approved reports the human's decision.
	Approved bool `json:"approved"`

	// Reason is the optional free-text justification.
	Reason string `json:"reason,omitempty"`

	// Source records who supplied the response: "cli", "web",
	// "mcp", or "timeout" for an auto-rejection.
	Source string `json:"source,omitempty"`
}

type Bus struct {
	// contains filtered or unexported fields
}

type ErrorPayload struct {
	// Message is the propagated error text.
	Message string `json:"message"`

	// NodeID names the node that produced the error, when known.
	// Empty for runtime-level errors that don't belong to a single
	// node.
	NodeID string `json:"node_id,omitempty"`
}

type Event struct {
	// RunID is the run this event belongs to. Repeated on every line
	// so a reader can sanity-check the file's contents.
	RunID string `json:"run_id"`

	// Seq is the event's position in the run. Monotonic from 1; gaps
	// indicate a corrupted ledger.
	Seq uint64 `json:"seq"`

	// Time is the wall-clock timestamp the event was recorded. UTC
	// always; the recorder normalises before writing.
	Time time.Time `json:"time"`

	// Type discriminates Payload. Always one of the EventType
	// constants above.
	Type EventType `json:"type"`

	// Payload is the type-specific body. Stored as RawMessage on
	// read to avoid forcing the reader into a sealed-union shape.
	Payload json.RawMessage `json:"payload,omitempty"`
}

type EventType string

type LLMCallPayload struct {
	// Model is the canonical model ID the runtime asked for.
	Model string `json:"model"`

	// Provider is the gridctl provider package responsible for the
	// call ("anthropic", "openai", "google", "gateway"). Populated
	// by the adapter, not the model.
	Provider string `json:"provider,omitempty"`

	// PromptTokens is the input-token count reported by the
	// provider.
	PromptTokens int `json:"prompt_tokens,omitempty"`

	// OutputTokens is the output-token count reported by the
	// provider on completion. Zero for events recorded before the
	// final chunk.
	OutputTokens int `json:"output_tokens,omitempty"`

	// CacheReadTokens captures cache-hit savings; cache-write tokens
	// land alongside (Anthropic-only on the providers we cover).
	CacheReadTokens  int `json:"cache_read_tokens,omitempty"`
	CacheWriteTokens int `json:"cache_write_tokens,omitempty"`

	// CostUSD is the dollar cost computed by pkg/pricing, in
	// fractional US dollars. Stored alongside the call so the
	// inspect view doesn't need the pricing table to render the
	// totals.
	CostUSD float64 `json:"cost_usd,omitempty"`
}

type LLMChunkPayload struct {
	// Index is the chunk's order within the streamed response.
	// Monotonic from 0.
	Index int `json:"index"`

	// Delta is the text appended in this chunk.
	Delta string `json:"delta,omitempty"`
}

type ListFilter struct {
	Status   string    // exact match against RunSummary.Status; empty = any
	Skill    string    // exact match against RunSummary.Skill; empty = any
	Parent   string    // exact match against ParentRunID; empty = any
	Since    time.Time // include runs with StartedAt >= Since; zero = no lower bound
	BeforeID string    // cursor: skip runs newer-or-equal to this ID (run ID is time-ordered)
}

type NodeEnterPayload struct {
	// NodeID is a stable identifier for the node within the run
	// graph. Used by `runs resume --from-step <node_id>`.
	NodeID string `json:"node_id"`

	// NodeName is the author-facing label. May differ from NodeID
	// (e.g. autogenerated IDs for anonymous lambda nodes).
	NodeName string `json:"node_name,omitempty"`

	// SpanID is the OTel span the node executes under. Empty when
	// tracing is not configured.
	SpanID string `json:"span_id,omitempty"`
}

type NodeExitPayload struct {
	// NodeID matches the EventNodeEnter that opened the node.
	NodeID string `json:"node_id"`

	// DurationMicros is the wall-clock duration the node held
	// execution, in microseconds. The microsecond resolution keeps
	// the JSONL parseable as integers across languages while still
	// resolving fast Go skills.
	DurationMicros int64 `json:"duration_micros"`

	// Success reports whether the node returned without error.
	Success bool `json:"success"`
}

type Recorder struct {
	// contains filtered or unexported fields
}

type ResumePlan struct {
	// RunID is the run being resumed.
	RunID string `json:"run_id"`

	// FromNodeID is the resume point. Empty means "resume from the
	// last completed step" — the runtime defaults to the highest
	// EventNodeExit it sees in the ledger.
	FromNodeID string `json:"from_node_id,omitempty"`

	// Replay is the event slice the runtime replays to rebuild
	// state. Always starts with the EventRunStarted record so
	// metadata (skill, input, parent) is available; ends just
	// before the resume point.
	Replay []Event `json:"replay"`

	// LastSeq is the seq of the last event in Replay. New events
	// emitted on resume must use Seq > LastSeq.
	LastSeq uint64 `json:"last_seq"`

	// PendingApproval is set when the resume target is an in-flight
	// approval gate. Carries the ApprovalID so a CLI consumer can
	// route the user toward `runs approve` instead of resume.
	PendingApproval string `json:"pending_approval,omitempty"`

	// Started captures the EventRunStarted payload as a convenience
	// for runtime initialisation; saves the runtime a second
	// ledger walk.
	Started *RunStartedPayload `json:"started,omitempty"`
}

type RunCompletedPayload struct {
	// Status is one of "ok", "error", "cancelled", "suspended" — the
	// last meaning the run is awaiting an approval response.
	Status string `json:"status"`

	// Output is the run's final output payload, when Status is
	// "ok". JSON-encoded; readers decode against the skill's output
	// schema. Truncated to MaxPayloadBytes (and wrapped as a JSON
	// string) when Truncated is set.
	Output json.RawMessage `json:"output,omitempty"`

	// Truncated is true when Output was capped at MaxPayloadBytes.
	Truncated bool `json:"truncated,omitempty"`

	// Error is the terminal error message when Status is "error" or
	// "cancelled". Empty otherwise.
	Error string `json:"error,omitempty"`
}

type RunStartedPayload struct {
	// Skill is the unprefixed skill name the run was launched
	// against. Empty when the run is an ad-hoc graph composition with
	// no registered skill.
	Skill string `json:"skill,omitempty"`

	// InputDigest is the SHA-256 of the canonical-JSON-encoded
	// input. Recorded so the inspect view can collapse identical
	// inputs across re-runs without surfacing the full payload.
	InputDigest string `json:"input_digest,omitempty"`

	// Input is the raw input as the caller supplied it. Stored
	// verbatim so resume can re-issue the run without recomputing.
	Input json.RawMessage `json:"input,omitempty"`

	// ParentRunID links a child run (e.g. a Handoff) to its parent.
	// Empty for a top-level run.
	ParentRunID string `json:"parent_run_id,omitempty"`

	// TraceID is the OTel root span ID for the run, hex-encoded.
	// Empty when tracing is not configured.
	TraceID string `json:"trace_id,omitempty"`

	// Flavor describes whether the run originated from a typed Go
	// skill ("go") or a TypeScript skill in the sandbox ("ts").
	// Markdown-only prompt skills surface as "prompt".
	Flavor string `json:"flavor,omitempty"`
}

type RunSummary struct {
	RunID           string    `json:"run_id"`
	Path            string    `json:"path,omitempty"`
	Skill           string    `json:"skill,omitempty"`
	Flavor          string    `json:"flavor,omitempty"`
	Status          string    `json:"status"`
	StartedAt       time.Time `json:"started_at,omitempty"`
	CompletedAt     time.Time `json:"completed_at,omitempty"`
	ModTime         time.Time `json:"mtime,omitempty"`
	EventCount      int       `json:"event_count"`
	ParentRunID     string    `json:"parent_run_id,omitempty"`
	TraceID         string    `json:"trace_id,omitempty"`
	PendingApproval string    `json:"pending_approval,omitempty"`
	Error           string    `json:"error,omitempty"`
}

type Store struct {
	// contains filtered or unexported fields
}

type StructuredOutputPayload struct {
	// SchemaDigest is the SHA-256 of the canonical JSON Schema the
	// payload was validated against. Used by the IDE's schema-delta
	// view to highlight cross-run drift.
	SchemaDigest string `json:"schema_digest,omitempty"`

	// Output is the validated payload, JSON-encoded.
	Output json.RawMessage `json:"output"`
}

type Subscriber struct {
	C chan Event
	// contains filtered or unexported fields
}

type ToolCallPayload struct {
	// CallID is the provider-issued tool-call identifier; matches
	// agent.ToolCall.ID. Used to pair tool_call with tool_result.
	CallID string `json:"call_id"`

	// NodeID, when set, links the tool call to the wrapping
	// node_enter/node_exit pair so the inspector can collapse
	// per-tool detail under its node row.
	NodeID string `json:"node_id,omitempty"`

	// Name is the prefixed tool name (server__tool) the gateway
	// dispatches against. Recording the prefixed form keeps the
	// ledger unambiguous when the same tool name is exposed by
	// multiple servers.
	Name string `json:"name"`

	// Arguments is the JSON-encoded argument object as the model
	// emitted it. Verbatim — provider key ordering and escaping is
	// preserved, unless the encoded form exceeded MaxPayloadBytes,
	// in which case it is replaced with the first MaxPayloadBytes
	// as a JSON-quoted string and Truncated is set. Consumers
	// treating a truncated payload as opaque get a syntactically
	// valid value either way.
	Arguments json.RawMessage `json:"arguments,omitempty"`

	// Truncated is true when Arguments was capped at MaxPayloadBytes.
	// Inspectors render the prefix and a "truncated" marker.
	Truncated bool `json:"truncated,omitempty"`
}

type ToolResultPayload struct {
	// CallID matches the EventToolCall it answers.
	CallID string `json:"call_id"`

	// NodeID, when set, mirrors the matching EventToolCall.NodeID so
	// the inspector can pair the two without an arguments lookup.
	NodeID string `json:"node_id,omitempty"`

	// Output is the textual content the runtime surfaced to the
	// model. Multi-block content collapses to a single string here;
	// structured-content support follows when the gateway exposes it
	// uniformly. Truncated to MaxPayloadBytes when Truncated is set.
	Output string `json:"output,omitempty"`

	// Truncated is true when Output was capped at MaxPayloadBytes.
	Truncated bool `json:"truncated,omitempty"`

	// IsError mirrors the gateway's error flag.
	IsError bool `json:"is_error,omitempty"`
}