session

type ActiveRuntimeLease struct {
	SessionID string
	OwnerID   string
	OwnerPID  int
	OwnerKind string
	RunID     string
	Purpose   string
	ExpiresAt time.Time
}

type AdditionalDirectoriesEntry struct {
	EntryBase
	Directories []string `json:"directories"`
}

type ArchivedFile struct {
	// From is the path the file had in the session directory.
	From string
	// To is the archive path it was renamed to, beside From.
	To string
}

type Binding struct {
	SessionID   string `json:"sessionId"`
	ChannelType string `json:"channelType"`
	ChannelID   string `json:"channelId"`
}

type BranchSummaryEntry struct {
	EntryBase
	Summary string `json:"summary"`
	FromID  string `json:"fromId"`
}

type ChannelToolConfig struct {
	ToolName string `json:"toolName"`
	Enabled  bool   `json:"enabled"`
}

type CompactionEntry struct {
	EntryBase
	Summary              string `json:"summary"`
	FirstKeptEntry       string `json:"firstKeptEntryId"`
	TokensBefore         int    `json:"tokensBefore"`
	SummaryVersion       int    `json:"summaryVersion,omitempty"`
	PreviousCompactionID string `json:"previousCompactionId,omitempty"`
	LastSummarizedEntry  string `json:"lastSummarizedEntryId,omitempty"`
}

type ContentOverrideEntry struct {
	EntryBase
	TargetEntryID string           `json:"targetEntryId"`
	Message       provider.Message `json:"message"`
	Reason        string           `json:"reason,omitempty"`
	Code          string           `json:"code,omitempty"`
}

type ConversationTurn struct {
	ID        string
	SessionID string
	IntentID  string
	RunID     string
	Attempt   int
	Kind      string
	Status    string
	StartSeq  int64
	EndSeq    *int64
	StartedAt time.Time
	EndedAt   *time.Time
}

type DatabaseIndexRepair = database.IndexRepair

type DatabaseRecovery = database.MigrationRecovery

type DeliveryFailure struct {
	OperationID   string
	IntentID      string
	SessionID     string
	RunID         string
	Platform      string
	TargetID      string
	OperationKind string
	Status        string
	FailureCode   string
	AttemptCount  int
	UpdatedAt     time.Time
}

type DeliveryIntent struct {
	ID               string
	SessionID        string
	RunID            string
	Platform         string
	TargetID         string
	ReplyMessageID   string
	TransportContext json.RawMessage
	Status           string
	CreatedAt        time.Time
	UpdatedAt        time.Time
}

type DeliveryOperation struct {
	ID                string
	IntentID          string
	OperationKey      string
	ArtifactID        string
	OperationKind     string
	Sequence          int
	DependsOn         string
	IdempotencyKey    string
	PayloadDigest     string
	Status            string
	ProviderAssetID   string
	ProviderMessageID string
	ProviderState     json.RawMessage
	AttemptCount      int
	NextAttemptAt     *time.Time
	FailureCode       string
	// RetryWindowStartedAt restarts the transient retry budget after an explicit
	// retry; nil means the budget started at CreatedAt.
	RetryWindowStartedAt *time.Time
	LeaseOwner           string
	LeaseEpoch           int64
	LeaseExpiresAt       *time.Time
	CreatedAt            time.Time
	UpdatedAt            time.Time
}

type DeliveryPlan struct {
	Intent     DeliveryIntent
	Operations []DeliveryOperation
}

type ESMGuidance struct {
	ID               string     `json:"id"`
	SessionID        string     `json:"sessionId"`
	ObjectiveVersion string     `json:"objectiveVersion,omitempty"`
	Guidance         string     `json:"guidance"`
	Status           string     `json:"status"`
	CreatedAt        time.Time  `json:"createdAt"`
	ConsumedAt       *time.Time `json:"consumedAt,omitempty"`
}

type EntryBase struct {
	Type      EntryType `json:"type"`
	ID        string    `json:"id"`
	ParentID  *string   `json:"parentId"`
	Timestamp time.Time `json:"timestamp"`
}

type EntryType string

type ExecutionIntent struct {
	ID                 string
	SessionID          string
	Source             string
	Model              string
	Mode               string
	WorkDir            string
	RequestFingerprint string
	Request            json.RawMessage
	Policy             json.RawMessage
	CreatedAt          time.Time
}

type ForkKind string

type ForkOptions struct {
	SourceSessionID string
	AtSeq           *int64
	RequestID       string
	TitleMode       string
	// ExpertID overrides the forked session's expert binding when non-nil
	// (empty string unbinds); nil preserves the source session's binding.
	ExpertID *string
}

type ForkResult struct {
	SessionID       string   `json:"sessionId"`
	ParentSessionID string   `json:"parentSessionId"`
	ForkKind        ForkKind `json:"forkKind"`
	BoundarySeq     int64    `json:"boundarySeq"`
	SeedLength      int64    `json:"seedLength"`
}

type GeneratedArtifact struct {
	ID        string
	SessionID string
	RunID     string
	Origin    string
	Kind      string
	Filename  string
	MediaType string
	Bytes     int64
	Status    string
	CreatedAt time.Time
}

type Header struct {
	Type            EntryType `json:"type"`
	Version         int       `json:"version"`
	ID              string    `json:"id"`
	Timestamp       time.Time `json:"timestamp"`
	Cwd             string    `json:"cwd"`
	ParentSession   string    `json:"parentSession,omitempty"`
	ChannelType     string    `json:"channelType,omitempty"`
	ChannelID       string    `json:"channelId,omitempty"`
	ForkBoundarySeq int64     `json:"forkBoundarySeq,omitempty"`
	SeedLength      int64     `json:"seedLength,omitempty"`
	ForkKind        string    `json:"forkKind,omitempty"`
	// ExpertID is the bound expert bundle name (empty = no expert identity).
	// Persisted like the channel binding fields so reloads restore identity.
	ExpertID string `json:"expertId,omitempty"`
}

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

type InputResourceEvent struct {
	ID         string
	SessionID  string
	ResourceID string
	RunID      string
	EventType  string
	Status     string
	Timestamp  time.Time
	Data       json.RawMessage
}

type KnowledgeBase struct {
	ID string `json:"id"`
	KnowledgeBaseSpec
	ActiveSnapshotID string    `json:"activeSnapshotId,omitempty"`
	CreatedAt        time.Time `json:"createdAt"`
	UpdatedAt        time.Time `json:"updatedAt"`
	ConfigRevision   int64     `json:"-"`
}

type KnowledgeBaseSpec struct {
	Name              string   `json:"name"`
	RootDir           string   `json:"rootDir"`
	PreprocessProfile string   `json:"preprocessProfile"`
	Provider          string   `json:"provider"`
	Model             string   `json:"model"`
	Mode              string   `json:"mode"`
	ThinkingLevel     string   `json:"thinkingLevel,omitempty"`
	Schedule          string   `json:"schedule"`
	Enabled           bool     `json:"enabled"`
	IgnoreGlobs       []string `json:"ignoreGlobs,omitempty"`
}

type KnowledgeChunk struct {
	ID            string `json:"id"`
	SnapshotID    string `json:"snapshotId"`
	FileID        string `json:"fileId"`
	RelativePath  string `json:"relativePath,omitempty"`
	Ordinal       int    `json:"ordinal"`
	Text          string `json:"text"`
	StartLine     int    `json:"startLine"`
	EndLine       int    `json:"endLine"`
	ContentSHA256 string `json:"contentSha256"`
}

type KnowledgeDiffSummary struct {
	Added         int      `json:"added"`
	Modified      int      `json:"modified"`
	Removed       int      `json:"removed"`
	Unchanged     int      `json:"unchanged"`
	AddedPaths    []string `json:"addedPaths,omitempty"`
	ModifiedPaths []string `json:"modifiedPaths,omitempty"`
	RemovedPaths  []string `json:"removedPaths,omitempty"`
}

type KnowledgeDiscoveryEntry struct {
	Path   string `json:"path"`
	Reason string `json:"reason"`
}

type KnowledgeDiscoverySummary struct {
	Discovered     int                       `json:"discovered"`
	Ignored        int                       `json:"ignored"`
	Skipped        int                       `json:"skipped"`
	IgnoredEntries []KnowledgeDiscoveryEntry `json:"ignoredEntries,omitempty"`
	SkippedEntries []KnowledgeDiscoveryEntry `json:"skippedEntries,omitempty"`
}

type KnowledgeEdge struct {
	ID           string  `json:"id"`
	SnapshotID   string  `json:"snapshotId"`
	FromNodeID   string  `json:"fromNodeId"`
	ToNodeID     string  `json:"toNodeId"`
	RelationType string  `json:"relationType"`
	Confidence   float64 `json:"confidence"`
}

type KnowledgeEntityAlias struct {
	ID              string `json:"id"`
	SnapshotID      string `json:"snapshotId"`
	NormalizedAlias string `json:"normalizedAlias"`
	NodeID          string `json:"nodeId"`
}

type KnowledgeEvidence struct {
	ID         string  `json:"id"`
	SnapshotID string  `json:"snapshotId"`
	NodeID     string  `json:"nodeId,omitempty"`
	EdgeID     string  `json:"edgeId,omitempty"`
	ChunkID    string  `json:"chunkId"`
	StartLine  int     `json:"startLine"`
	EndLine    int     `json:"endLine"`
	Confidence float64 `json:"confidence"`
}

type KnowledgeFile struct {
	ID            string `json:"id"`
	SnapshotID    string `json:"snapshotId"`
	RelativePath  string `json:"relativePath"`
	ContentSHA256 string `json:"contentSha256"`
	ByteSize      int64  `json:"byteSize"`
	MediaType     string `json:"mediaType"`
	Title         string `json:"title,omitempty"`
	Status        string `json:"status"`
}

type KnowledgeFileGraph struct {
	File     KnowledgeFile
	Chunks   []KnowledgeChunk
	Nodes    []KnowledgeNode
	Edges    []KnowledgeEdge
	Evidence []KnowledgeEvidence
}

type KnowledgeGraphQuery struct {
	KnowledgeBase KnowledgeBase          `json:"knowledgeBase"`
	Snapshot      KnowledgeSnapshot      `json:"snapshot"`
	Chunks        []KnowledgeChunk       `json:"chunks"`
	Nodes         []KnowledgeNode        `json:"nodes"`
	Edges         []KnowledgeEdge        `json:"edges"`
	Evidence      []KnowledgeEvidence    `json:"evidence,omitempty"`
	Uncertainties []KnowledgeUncertainty `json:"uncertainties,omitempty"`
	Truncated     bool                   `json:"truncated"`
}

type KnowledgeGraphReusePlan struct {
	BaseConfigRevision int64
	SourceSnapshotID   string
	Files              map[string]KnowledgeFileGraph // key: normalized relative path
}

type KnowledgeGraphSnapshot struct {
	BaseConfigRevision int64
	Snapshot           KnowledgeSnapshot
	Files              []KnowledgeFile
	Chunks             []KnowledgeChunk
	Nodes              []KnowledgeNode
	Edges              []KnowledgeEdge
	Evidence           []KnowledgeEvidence
	Aliases            []KnowledgeEntityAlias
	DiffSummary        *KnowledgeDiffSummary
	DiscoverySummary   *KnowledgeDiscoverySummary
}

type KnowledgeNode struct {
	ID              string `json:"id"`
	SnapshotID      string `json:"snapshotId"`
	Kind            string `json:"kind"`
	Label           string `json:"label"`
	NormalizedLabel string `json:"normalizedLabel"`
	Summary         string `json:"summary,omitempty"`
	// Status is "fact" for deterministically derived nodes and "candidate" for
	// model-asserted nodes that carry no locally verifiable evidence. Confidence
	// is the Runtime-assigned reliability of the node.
	Status     string  `json:"status,omitempty"`
	Confidence float64 `json:"confidence,omitempty"`
}

type KnowledgeSnapshot struct {
	ID               string                     `json:"id"`
	KnowledgeBaseID  string                     `json:"knowledgeBaseId"`
	RunID            string                     `json:"runId,omitempty"`
	Status           string                     `json:"status"`
	SchemaVersion    int                        `json:"schemaVersion"`
	FileCount        int                        `json:"fileCount"`
	ChunkCount       int                        `json:"chunkCount"`
	NodeCount        int                        `json:"nodeCount"`
	EdgeCount        int                        `json:"edgeCount"`
	StartedAt        time.Time                  `json:"startedAt"`
	FinishedAt       time.Time                  `json:"finishedAt,omitempty"`
	ErrorSummary     string                     `json:"errorSummary,omitempty"`
	DiffSummary      *KnowledgeDiffSummary      `json:"diffSummary,omitempty"`
	DiscoverySummary *KnowledgeDiscoverySummary `json:"discoverySummary,omitempty"`
}

type KnowledgeSource struct {
	RelativePath  string `json:"relativePath"`
	Title         string `json:"title,omitempty"`
	MediaType     string `json:"mediaType,omitempty"`
	Status        string `json:"status"`
	ByteSize      int64  `json:"byteSize"`
	ChunkCount    int    `json:"chunkCount"`
	ContentSHA256 string `json:"contentSha256,omitempty"`
}

type KnowledgeUncertainty struct {
	Kind        string `json:"kind"`
	Description string `json:"description"`
	NodeID      string `json:"nodeId,omitempty"`
	EdgeID      string `json:"edgeId,omitempty"`
	Path        string `json:"path,omitempty"`
}

type LabelEntry struct {
	EntryBase
	TargetID string  `json:"targetId"`
	Label    *string `json:"label,omitempty"`
}

type LeaseHeartbeatHealth struct {
	DatabaseIdentity    string        `json:"databaseIdentity"`
	LastAttemptAt       time.Time     `json:"lastAttemptAt,omitempty"`
	LastSuccessAt       time.Time     `json:"lastSuccessAt,omitempty"`
	ConsecutiveFailures int           `json:"consecutiveFailures"`
	Attempts            uint64        `json:"attempts"`
	Failures            uint64        `json:"failures"`
	FenceLosses         uint64        `json:"fenceLosses"`
	MaxRenewDuration    time.Duration `json:"maxRenewDurationNs"`
}

type LeftBehindEntry struct {
	// Name is the entry name relative to the session directory.
	Name string
	// Directory reports whether the entry is a directory.
	Directory bool
	// Bytes is the entry size, summed recursively for directories. Symbolic
	// links are not followed.
	Bytes int64
}

type ListOption func(*listOptions)

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

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

type MessageEntry struct {
	EntryBase
	Message provider.Message `json:"message"`
}

type ModeChangeEntry struct {
	EntryBase
	Mode string `json:"mode"`
}

type ModelChangeEntry struct {
	EntryBase
	Provider string `json:"provider"`
	ModelID  string `json:"modelId"`
}

type Project struct {
	ID        string    `json:"id"`
	Name      string    `json:"name"`
	CreatedAt time.Time `json:"createdAt"`
	UpdatedAt time.Time `json:"updatedAt"`
}

type ReplayState struct {
	Messages []provider.Message
	EntryIDs []string
}

type ResetReport struct {
	// DatabaseBackup is the renamed sessions.db. It is empty when no database
	// file existed before the reset.
	DatabaseBackup string
	// Archived lists every file the reset moved aside, database first then each
	// sidecar, so a caller can report what left the directory without deriving
	// the archive naming itself.
	Archived []ArchivedFile
	// LeftBehind lists the session-directory entries a reset does not archive.
	// Attachment, channel, and knowledge-base storage each derive their own
	// paths elsewhere, so the reset reports everything beside sessions.db
	// instead of restating those rules.
	LeftBehind []LeftBehindEntry
}

type ResponseItemArchive struct {
	ID            int64
	SessionID     string
	LocalTurnID   string
	ResponseID    string
	ItemID        string
	OutputIndex   int
	ItemType      string
	ItemStatus    string
	ItemKey       string
	SanitizedJSON json.RawMessage
	CreatedAt     time.Time
}

type ResponseReplayTurn struct {
	LocalTurnID string
	Items       []json.RawMessage
}

type ResponseRun struct {
	ID                int64     `json:"id"`
	SessionID         string    `json:"sessionId"`
	LocalRunID        string    `json:"localRunId"`
	LocalTurnID       string    `json:"localTurnId,omitempty"`
	MessageID         *int64    `json:"messageId,omitempty"`
	ResponseID        string    `json:"responseId,omitempty"`
	Provider          string    `json:"provider"`
	API               string    `json:"api"`
	State             string    `json:"state"`
	PollingURL        string    `json:"pollingUrl,omitempty"`
	LastEventSequence *int64    `json:"lastEventSequence,omitempty"`
	CancelRequested   bool      `json:"cancelRequested,omitempty"`
	CreatedAt         time.Time `json:"createdAt"`
	UpdatedAt         time.Time `json:"updatedAt"`
}

type ResponseSessionState struct {
	SessionID          string
	StateMode          string
	PreviousResponseID string
	ConversationID     string
	Provider           string
	API                string
	Model              string
	Version            int64
	UpdatedAt          time.Time
}

type ResponseTurn struct {
	ID                 int64
	SessionID          string
	LocalTurnID        string
	MessageID          *int64
	RequestID          string
	ResponseID         string
	PreviousResponseID string
	ConversationID     string
	Provider           string
	API                string
	Model              string
	StateMode          string
	Status             string
	IncompleteReason   string
	RequestSummary     json.RawMessage
	ResponseSummary    json.RawMessage
	CreatedAt          time.Time
	CompletedAt        *time.Time
}

type RuntimeLeaseBinding struct {
	DatabaseIdentity string
	SessionID        string
	RunID            string
	OwnerInstanceID  string
	TokenHash        string
	Epoch            int64
	Purpose          RuntimeLeasePurpose
}

type RuntimeLeaseBusStats struct {
	// Published counts datagrams written to the loopback broadcast.
	Published uint64
	// SendFailures counts publishes that never reached the socket.
	SendFailures uint64
	// Received counts accepted ownership datagrams (after validity and self
	// filtering).
	Received uint64
	// Invalid counts dropped datagrams that failed to parse or validate.
	Invalid uint64
	// SelfSkipped counts loopback copies of this process's own announcements.
	SelfSkipped uint64
	// Duplicates counts datagrams suppressed by the dedupe window.
	Duplicates uint64
	// Applied counts notifications that mutated the ownership cache.
	Applied uint64
	// Gaps counts detected per-origin sequence gaps (a lost datagram).
	Gaps uint64
	// Uncertain counts lookups that could not be answered from a fresh entry
	// (miss, staleness, gap, or conflict) and therefore require a SQLite read.
	Uncertain uint64
}

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

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

type RuntimeLeaseNotification struct {
	Version   int    `json:"version"`
	MessageID string `json:"messageId"`
	Type      string `json:"type"`
	SessionID string `json:"sessionId,omitempty"`
	// DatabaseIdentity names the canonical session database this notification is
	// scoped to (see RuntimeDatabaseIdentity). Global-scope ownership
	// synchronization keys its in-memory view by (DatabaseIdentity, SessionID),
	// so producers that know the session directory must stamp it. Notifications
	// published without one are still valid; receivers then fall back to SQLite.
	DatabaseIdentity string `json:"databaseIdentity,omitempty"`
	// Path names the database file for the database_rebuilt wake-up; lease
	// notifications leave it empty because they are session-scoped.
	Path             string `json:"path,omitempty"`
	Origin           string `json:"origin,omitempty"`
	OriginInstanceID string `json:"originInstanceId"`
	OwnerInstanceID  string `json:"ownerInstanceId,omitempty"`
	OwnerPID         int    `json:"ownerPid,omitempty"`
	RunID            string `json:"runId,omitempty"`
	Epoch            int64  `json:"epoch,omitempty"`
	ExpiresAt        int64  `json:"expiresAt,omitempty"`
	// Seq is a per-OriginInstanceID monotonic sequence. Receivers use it to drop
	// out-of-order duplicates and to detect a gap (a jump means a lost datagram),
	// which schedules a coalesced SQLite re-read. It never authorizes anything.
	Seq uint64 `json:"seq,omitempty"`
	// RunStatus and Phase are optional projection hints carried by state_changed
	// events; receivers still re-read the durable Run before projecting it.
	RunStatus string `json:"runStatus,omitempty"`
	Phase     string `json:"phase,omitempty"`
}

type RuntimeLeasePurpose string

type RuntimeLeaseSnapshot struct {
	SessionID       string
	OwnerInstanceID string
	OwnerPID        int
	OwnerKind       string
	TokenHash       string
	Epoch           int64
	RunID           string
	Purpose         RuntimeLeasePurpose
	State           string
	AcquiredAt      time.Time
	HeartbeatAt     time.Time
	ExpiresAt       time.Time
	UpdatedAt       time.Time
	Valid           bool
}

type RuntimeOwnershipEntry struct {
	DatabaseIdentity string
	SessionID        string
	OwnerInstanceID  string
	OwnerPID         int
	Epoch            int64
	Purpose          string
	RunID            string
	State            string
	RunStatus        string
	Phase            string
	ExpiresAt        time.Time
	Seq              uint64
	OriginInstanceID string
	AppliedAt        time.Time
	// FromDatabase marks an entry primed by a local SQLite read rather than a
	// peer announcement. Both are hints; this is for diagnostics only.
	FromDatabase bool
}

type RuntimeOwnershipLookup struct {
	Entry     RuntimeOwnershipEntry
	Present   bool
	Fresh     bool
	Uncertain bool
}

type RuntimeSubmission struct {
	ID                 string
	SessionID          string
	Scope              string
	KeyHash            string
	RequestFingerprint string
	IntentID           string
	RunID              string
	CreatedAt          time.Time
}

type RuntimeSubmissionError struct {
	Existing RuntimeSubmission
	Conflict bool
}

type SequencedMessage struct {
	Seq     int64
	EntryID string
	Message provider.Message
}

type SequencedSessionCapabilityEvent struct {
	Seq   int64
	Event SessionCapabilityEvent
}

type SequencedSessionRunEvent struct {
	Seq   int64
	Event SessionRunEvent
}

type SessionCapabilities struct {
	SessionID    string
	Mode         string
	DisplayMode  string
	DelegateMode bool
	MultiAgent   bool
	Workflows    bool
	WebSearch    bool
	Browser      bool
	A2AMaster    bool
	UpdatedAt    time.Time
}

type SessionCapabilityEvent struct {
	ID         string
	SessionID  string
	RunID      string
	EventType  string
	Source     string
	Actor      string
	Capability string
	OldValue   string
	NewValue   string
	Timestamp  time.Time
	Data       json.RawMessage
}

type SessionDetail struct {
	SessionInfo
	ID           string
	MessageCount int
	Preview      string // first user message (truncated)
}

type SessionExecutionFacts struct {
	DatabaseIdentity string
	SessionID        string
	SessionExists    bool
	DatabaseNow      time.Time
	ActiveRuns       []SessionRun
	Lease            *RuntimeLeaseSnapshot
	Recovery         *SessionRunRecovery
	RemoteRun        *ResponseRun
}

type SessionInfo struct {
	Path string
	// ModTime is when the session was last used (its newest persisted entry),
	// which is what every listing orders and displays. CreatedAt keeps the
	// creation timestamp separately; it names the session handle and never
	// stands in for activity.
	ModTime         time.Time
	CreatedAt       time.Time
	Name            string
	Cwd             string
	ChannelType     string
	ChannelID       string
	ParentSession   string
	ForkBoundarySeq int64
	SeedLength      int64
	ForkKind        string
	ExpertID        string
}

type SessionInfoEntry struct {
	EntryBase
	Name   string `json:"name"`
	Source string `json:"source,omitempty"` // "manual" or "auto"
}

type SessionMetadata struct {
	ProjectID string `json:"projectId,omitempty"`
	Pinned    bool   `json:"pinned"`
	// UpdatedAt is the persisted revision time of the metadata row. It is
	// read-only output; SetSessionMetadata always stamps the write time itself.
	UpdatedAt time.Time `json:"updatedAt,omitempty"`
}

type SessionRun struct {
	ID           string
	SessionID    string
	IntentID     string
	RetryOf      string
	Attempt      int
	WorkDir      string
	Source       string
	Model        string
	Mode         string
	Status       string
	StartedAt    time.Time
	UpdatedAt    time.Time
	FinishedAt   *time.Time
	Error        string
	ErrorInfo    json.RawMessage
	Progress     json.RawMessage
	Usage        json.RawMessage
	ContextUsage json.RawMessage
	// InputResourceIDs are Runtime-prepared resources admitted with this Run.
	// They are bound by the same transaction as the intent/run/start event.
	InputResourceIDs []string
	// Submission fields are admission-only digests. They are reserved in the
	// same transaction as the intent, Run, turn, resources, and start event.
	SubmissionKeyHash     string
	SubmissionScope       string
	SubmissionFingerprint string
	// UserMessage is the canonical user entry admitted with a conversation
	// Run. It is admission-only; transcript replay remains the source of truth.
	UserEntryID string
	UserMessage *provider.Message
	// AssistantMessage is the final assistant entry held by the Runtime until
	// terminalization. It is intentionally transient and is committed together
	// with the terminal Run/turn and delivery plan.
	AssistantEntryID string
	AssistantMessage *provider.Message
	// DeliveryPlan is terminal-only. The terminal transaction creates its
	// outbox rows together with the Run, turn, and terminal event transition.
	DeliveryPlan *DeliveryPlan
}

type SessionRunEvent struct {
	ID        string
	SessionID string
	RunID     string
	EventType string
	Source    string
	Status    string
	Model     string
	Mode      string
	Timestamp time.Time
	Data      json.RawMessage
}

type SessionRunRecovery struct {
	RunID              string
	SessionID          string
	State              SessionRunRecoveryState
	TriggerSource      string
	ReasonCode         string
	Attempt            int
	PreviousLeaseEpoch int64
	LastError          string
	NextRetryAt        *time.Time
	StartedAt          time.Time
	UpdatedAt          time.Time
	CompletedAt        *time.Time
}

type SessionRunRecoveryState string

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

type Store interface {
	// Init initializes the session store, creating the underlying
	// database or storage if needed.
	Init() error

	// InitWithID initializes the session with a specific ID.
	// An empty id generates a new one.
	InitWithID(id string) error

	// AppendMessage persists a conversation message and returns its entry ID.
	AppendMessage(msg provider.Message) (string, error)

	// AppendCompaction records a context compaction event.
	AppendCompaction(summary, firstKeptEntryID string, tokensBefore int) (string, error)

	// AppendModelChange records a model switch.
	AppendModelChange(providerName, modelID string) (string, error)

	// AppendModeChange records a session execution mode change.
	AppendModeChange(mode string) (string, error)

	// AppendThinkingLevelChange records a thinking level change.
	AppendThinkingLevelChange(level string) (string, error)
	AppendAdditionalDirectories(directories []string) (string, error)

	// AppendSessionInfo records session metadata.
	AppendSessionInfo(name string) (string, error)

	// GetMessages returns all messages in the current branch,
	// with compaction summaries applied.
	GetMessages() []provider.Message

	// GetReplayState returns the full replay state including
	// messages and their entry IDs.
	GetReplayState() ReplayState

	// GetLeafID returns the current leaf entry ID, or nil if empty.
	GetLeafID() *string

	// GetLatestCompaction returns the most recent compaction entry,
	// or (zero, false) if none exists.
	GetLatestCompaction() (CompactionEntry, bool)

	// GetLatestModelChange returns the most recent persisted model binding.
	GetLatestModelChange() (ModelChangeEntry, bool)

	// GetLatestModeChange returns the most recent persisted session mode.
	GetLatestModeChange() (ModeChangeEntry, bool)

	// GetLatestThinkingLevelChange returns the most recent persisted thinking level.
	GetLatestThinkingLevelChange() (ThinkingLevelChangeEntry, bool)
	GetLatestAdditionalDirectories() (AdditionalDirectoriesEntry, bool)

	// GetFile returns the session file path (handle file for SQLite).
	GetFile() string

	// GetHeader returns the session header with metadata.
	GetHeader() *Header
}

type ThinkingLevelChangeEntry struct {
	EntryBase
	ThinkingLevel string `json:"thinkingLevel"`
}

type ToolExecutionRecord struct {
	ID               int64
	SessionID        string
	LocalTurnID      string
	ExecutionKey     string
	Provider         string
	API              string
	ResponseID       string
	ProviderCallID   string
	ToolKind         string
	ToolName         string
	ArgsHash         string
	ExecutionState   string
	ResultSummary    json.RawMessage
	ProviderMetadata json.RawMessage
	SideEffecting    bool
	CreatedAt        time.Time
	CompletedAt      *time.Time
}

type TurnEndEntry struct {
	EntryBase
	TurnID     string `json:"turnId"`
	IntentID   string `json:"intentId,omitempty"`
	RunID      string `json:"runId,omitempty"`
	Status     string `json:"status"`
	StopReason string `json:"stopReason,omitempty"`
}

type TurnStartEntry struct {
	EntryBase
	TurnID   string `json:"turnId"`
	IntentID string `json:"intentId,omitempty"`
	RunID    string `json:"runId,omitempty"`
	Attempt  int    `json:"attempt,omitempty"`
}

type Worktree struct {
	ID             string `json:"id"`
	Name           string `json:"name"`
	Branch         string `json:"branch,omitempty"`
	Directory      string `json:"directory"`
	RepositoryRoot string `json:"repositoryRoot"`
	ProjectID      string `json:"projectId,omitempty"`
	StartCommand   string `json:"startCommand,omitempty"`
	Status         string `json:"status"`
	Error          string `json:"error,omitempty"`
	// External marks a git worktree that exists in the repository but is not
	// registered (for example one created by hand). It is read-only.
	External  bool      `json:"external,omitempty"`
	CreatedAt time.Time `json:"createdAt"`
	UpdatedAt time.Time `json:"updatedAt"`
}