session

type ErrSession string

type ExportBundle struct {
	Store   Store
	Session ids.SessionID
	Profile string
	Model   string
	Level   RedactLevel
	OutPath string
}

type PastSession struct {
	SessionID    ids.SessionID `json:"sessionId"`
	FirstSeenAt  time.Time     `json:"firstSeenAt"`
	LastSeenAt   time.Time     `json:"lastSeenAt"`
	EventCount   int64         `json:"eventCount"`
	FirstMessage string        `json:"firstMessage,omitempty"` // first user-turn text, truncated
}

type RedactLevel int

type Store interface {
	// AppendEvent persists one envelope. Called by an event-bus
	// subscriber on every Publish.
	AppendEvent(ctx context.Context, env control.EventEnvelope) error

	// EventsSince returns events with id > since for the given
	// session, in ID order. Used by stream-resume across all
	// transports.
	EventsSince(ctx context.Context, session ids.SessionID, since uint64, limit int) ([]control.EventEnvelope, error)

	// ListPastSessions returns a summary row per distinct session in
	// the event log, ordered newest-last-seen first. limit ≤ 0 means
	// unbounded.
	ListPastSessions(ctx context.Context, limit int) ([]PastSession, error)

	// RecordToolIntent writes a tool_call_intents row before the
	// tool spawns. For mutating tools, the implementation MUST fsync
	// before returning.
	RecordToolIntent(ctx context.Context, intent ToolIntent) error

	// RecordToolOutcome writes a tool_call_outcomes row after the
	// tool returns. fsync for mutating tools.
	RecordToolOutcome(ctx context.Context, outcome ToolOutcome) error

	// OrphanIntents returns intent rows with no matching outcome —
	// used on resume to surface tool calls that started before a
	// crash and need user disposition.
	OrphanIntents(ctx context.Context, session ids.SessionID) ([]ToolIntent, error)

	// ApplyRetention drops content from events older than ttl,
	// leaving metadata-only rows. Called by a daily scheduled task.
	ApplyRetention(ctx context.Context, ttl time.Duration) (rowsAffected int64, err error)

	// Close releases resources.
	Close() error
}

type ToolIntent struct {
	CallID    ids.CallID
	LogID     ids.LogID
	Tool      string
	ArgsHash  string // sha256 of args
	Mutating  bool
	StartedAt time.Time
}

type ToolOutcome struct {
	CallID      ids.CallID
	Outcome     string // "ok" | "error" | "cancelled" | "timeout"
	CompletedAt time.Time
	ResultRef   string // pointer into events table (event ID encoded)
}