sessiontree

type AdmitPendingToolCompletionRequest struct {
	CompletionRequestID   string
	RequestFingerprint    string
	SettlementFingerprint string
	Target                PendingToolSettlementTarget
	Settlement            Entry
	ContinuationTurnID    string
	ContinuationRunID     string
	OwnerID               string
	Input                 session.Message
	Now                   time.Time
}

type AdmitPendingToolCompletionResult struct {
	Settlement         Entry
	SettlementReplayed bool
	Admission          AdmitTurnResult
	Replayed           bool
}

type AdmitSubAgentInputRequest struct {
	ParentThreadID string
	ChildThreadID  string
	TurnID         string
	RunID          string
	OwnerID        string
	Now            time.Time
}

type AdmitSubAgentInputResult struct {
	Input       SubAgentInputRecord
	Lease       TurnLease
	TurnStarted Entry
	UserMessage Entry
	Replayed    bool
}

type AdmitTurnRequest struct {
	ThreadID           string
	TurnID             string
	RunID              string
	OwnerID            string
	Input              session.Message
	RetrySourceTurnID  string
	RetrySourceEntryID string
	RequestFingerprint string
	Now                time.Time
}

type AdmitTurnResult struct {
	Lease            TurnLease
	BoundaryTerminal Entry
	TurnStarted      Entry
	UserMessage      Entry
	BaseLeafID       string
	Terminal         *TurnTerminalOutcome
	Replayed         bool
}

type AgentTodoItem struct {
	ID      string          `json:"id"`
	Content string          `json:"content"`
	Status  AgentTodoStatus `json:"status"`
}

type AgentTodoState struct {
	ThreadID          string          `json:"thread_id"`
	Version           int64           `json:"version"`
	Items             []AgentTodoItem `json:"items"`
	UpdatedAt         time.Time       `json:"updated_at,omitempty"`
	UpdatedByTurnID   string          `json:"updated_by_turn_id,omitempty"`
	UpdatedByRunID    string          `json:"updated_by_run_id,omitempty"`
	UpdatedByToolCall string          `json:"updated_by_tool_call_id,omitempty"`
}

type AgentTodoStateRepo interface {
	ReadAgentTodoState(context.Context, string) (AgentTodoState, error)
	CompareAndSwapAgentTodoState(context.Context, AgentTodoState, int64) (AgentTodoState, error)
}

type AgentTodoStatus string

type AppendCommittedError struct {
	Err error
}

type AppendOptions struct {
	ID       string
	ParentID string
	Now      time.Time
}

type ApprovalAuthorityRepo interface {
	PrepareApprovalBatch(context.Context, PrepareApprovalBatchRequest) (PrepareApprovalBatchResult, error)
	ReadApprovalQueue(context.Context, string) (ApprovalQueue, error)
	Approval(context.Context, string) (ApprovalRecord, error)
	WaitApprovalDecision(context.Context, string) (WaitApprovalDecisionResult, error)
	ResolveApproval(context.Context, ResolveApprovalRequest) (ResolveApprovalResult, error)
	CommitApprovalDispatch(context.Context, CommitApprovalDispatchRequest) (CommitApprovalDispatchResult, error)
	FinalizeApproval(context.Context, FinalizeApprovalRequest) (FinalizeApprovalResult, error)
	CancelApprovalBatch(context.Context, CancelApprovalBatchRequest) (CancelApprovalBatchResult, error)
}

type ApprovalCancellationEntry struct {
	ApprovalID string
	Entry      Entry
}

type ApprovalDecision string

type ApprovalDecisionReceipt struct {
	DecisionID             string
	ApprovalID             string
	RootThreadID           string
	Decision               ApprovalDecision
	State                  ApprovalState
	Reason                 string
	AuthorizationProofHash string
	QueueGeneration        int64
	QueueRevision          int64
	ApprovalRevision       int64
	SubmittedAt            time.Time
	ResolvedAt             time.Time
}

type ApprovalIdentity struct {
	ApprovalID      string
	ThreadID        string
	TurnID          string
	RunID           string
	ToolCallID      string
	EffectAttemptID string
}

type ApprovalPreflightItem struct {
	EffectAttemptID            string
	EffectRequestFingerprint   string
	ApprovalRequestFingerprint string
	Invocation                 EffectInvocationIdentity
	RequestedEntry             Entry
	ToolKind                   string
	Step                       int
	BatchIndex                 int
	BatchSize                  int
	Resources                  []ApprovalResource
	Effects                    []string
	Labels                     map[string]string
	HostContext                map[string]string
	ReadOnly                   bool
	Destructive                bool
	OpenWorld                  bool
}

type ApprovalQueue struct {
	RootThreadID      string
	Generation        int64
	Revision          int64
	CurrentApprovalID string
	Items             []ApprovalRecord
	GeneratedAt       time.Time
}

type ApprovalRecord struct {
	ApprovalID             string
	RootThreadID           string
	ParentThreadID         string
	ThreadID               string
	TurnID                 string
	RunID                  string
	ToolCallID             string
	EffectAttemptID        string
	ToolName               string
	ToolKind               string
	Step                   int
	BatchIndex             int
	BatchSize              int
	ArgsHash               string
	Resources              []ApprovalResource
	Effects                []string
	Labels                 map[string]string
	HostContext            map[string]string
	ReadOnly               bool
	Destructive            bool
	OpenWorld              bool
	RequestFingerprint     string
	State                  ApprovalState
	Revision               int64
	QueueSequence          int64
	DecisionID             string
	Reason                 string
	AuthorizationProofHash string
	RequestedAt            time.Time
	UpdatedAt              time.Time
	ResolvedAt             time.Time
}

type ApprovalResource struct {
	Kind  string
	Value string
}

type ApprovalState string

type ArtifactAuthorityRepo interface {
	ReadArtifact(context.Context, ArtifactReadRequest) (ArtifactContent, error)
	ArtifactClosure(context.Context, ArtifactClosureRequest) (artifact.Closure, error)
}

type ArtifactClosureRequest struct {
	SourceThreadID      string
	DestinationThreadID string
	EntryIDs            []string
}

type ArtifactContent struct {
	Ref  artifact.Ref
	Text string
}

type ArtifactReadRequest struct {
	ParentThreadID string
	ThreadID       string
	ArtifactID     string
}

type BeginAutomaticThreadTitleRequest struct {
	ThreadID string
	Token    string
	Now      time.Time
}

type BeginCompactionRequest struct {
	ThreadID             string
	RequestID            string
	RequestFingerprint   string
	Source               string
	SourceLeafID         string
	ActivePathHash       string
	SummarySchemaVersion string
	PromptIdentity       string
	RequestPayloadHash   string
	OwnerID              string
	Now                  time.Time
}

type BeginCompactionResult struct {
	Operation        CompactionOperation
	Owner            bool
	TakeoverEligible bool
	Replayed         bool
}

type BeginEffectDispatchRequest struct {
	Lease                  TurnLease
	EffectAttemptID        string
	RequestFingerprint     string
	ObservedHeartbeat      int64
	AuthorizationProofHash string
	Now                    time.Time
}

type CancelApprovalBatchRequest struct {
	Lease                   TurnLease
	RunID                   string
	CancellationFingerprint string
	CancellationEntries     []ApprovalCancellationEntry
	Now                     time.Time
}

type CancelApprovalBatchResult struct {
	Queue               ApprovalQueue
	Approvals           []ApprovalRecord
	Effects             []EffectAttempt
	CancellationEntries []Entry
	Replayed            bool
}

type CanonicalTurn struct {
	TurnID         string
	RunID          string
	StartedEntryID string
	StartedOrdinal int64
	RetrySource    *CanonicalTurnRetrySource
	Entries        []CanonicalTurnPathEntry
}

type CanonicalTurnAdmissionFact struct {
	ThreadID      string
	TurnID        string
	RunID         string
	TurnStartedID string
	UserMessageID string
	BaseLeafID    string
}

type CanonicalTurnBeforeCursor struct {
	EntryID string
}

type CanonicalTurnPageRepo interface {
	ListCanonicalTurns(context.Context, ListCanonicalTurnsOptions) (CanonicalTurnsPage, error)
}

type CanonicalTurnPathEntry struct {
	Entry   Entry
	Ordinal int64
}

type CanonicalTurnRead struct {
	Turn           CanonicalTurn
	LatestTurn     CanonicalTurn
	ThroughOrdinal int64
	HasRetryTarget bool
}

type CanonicalTurnReadRepo interface {
	ReadCanonicalTurn(context.Context, string, string) (CanonicalTurnRead, error)
}

type CanonicalTurnRepo interface {
	CanonicalTurnEntries(context.Context, string, string, string) ([]Entry, bool, error)
}

type CanonicalTurnRetrySource struct {
	TurnID  string
	EntryID string
}

type CanonicalTurnSinceCursor struct {
	EntryID string
}

type CanonicalTurnsPage struct {
	Turns          []CanonicalTurn
	BeforeCursor   *CanonicalTurnBeforeCursor
	SinceCursor    CanonicalTurnSinceCursor
	HasMore        bool
	ThroughOrdinal int64
	LatestTurnID   string
	HasRetryTarget bool
}

type CommitApprovalDispatchRequest struct {
	DecisionID               string
	ExpectedRootThreadID     string
	ExpectedGeneration       int64
	ExpectedCurrent          ApprovalIdentity
	ExpectedApprovalRevision int64
	EffectAttemptID          string
	Lease                    TurnLease
	AuthorizationProofHash   string
	ApprovedEntry            Entry
	Now                      time.Time
}

type CommitApprovalDispatchResult struct {
	Receipt       ApprovalDecisionReceipt
	Queue         ApprovalQueue
	Approval      ApprovalRecord
	Effect        EffectAttempt
	ApprovedEntry Entry
	Replayed      bool
}

type CompactionAuthorityRepo interface {
	ReadCompaction(context.Context, string, string) (CompactionOperation, bool, error)
	BeginCompaction(context.Context, BeginCompactionRequest) (BeginCompactionResult, error)
	TakeOverCompaction(context.Context, TakeOverCompactionRequest) (BeginCompactionResult, error)
	FinishCompaction(context.Context, FinishCompactionRequest) (FinishCompactionResult, error)
}

type CompactionOperation struct {
	ThreadID             string
	RequestID            string
	RequestFingerprint   string
	Source               string
	SourceLeafID         string
	ActivePathHash       string
	SummarySchemaVersion string
	PromptIdentity       string
	RequestPayloadHash   string
	State                CompactionOperationState
	Lease                TurnLease
	ResultEntryID        string
	ErrorCode            string
	ErrorMessage         string
	OutcomeFingerprint   string
	FinishedOwnerID      string
	FinishedGeneration   int64
	CreatedAt            time.Time
	UpdatedAt            time.Time
	FinishedAt           time.Time
}

type CompactionOperationState string

type CompleteAutomaticThreadTitleRequest struct {
	ThreadID   string
	Generation int64
	Token      string
	Title      string
	Now        time.Time
}

type ContextOptions struct{}

type ContextProjection struct {
	Messages []session.Message  `json:"messages"`
	Segments []ProjectedSegment `json:"segments,omitempty"`
}

type ContextProjectionOptions struct {
	Purpose ProjectionPurpose
}

type CreateRootRequest struct {
	ThreadID        string
	CreateIntentID  string
	ContractVersion string
	Meta            ThreadMeta
}

type CreateRootResult struct {
	Thread   ThreadMeta
	Replayed bool
}

type DeleteRootTreeResult struct {
	ThreadIDs []string
	Replayed  bool
}

type EffectAttempt struct {
	EffectAttemptID     string
	Invocation          EffectInvocationIdentity
	RequestFingerprint  string
	State               EffectAttemptState
	RejectionCode       string
	TerminalFingerprint string
	ResultEntryID       string
	OwnerID             string
	Generation          int64
	CreatedAt           time.Time
	UpdatedAt           time.Time
}

type EffectAttemptAuthorityRepo interface {
	PrepareEffectAttempt(context.Context, PrepareEffectAttemptRequest) (PrepareEffectAttemptResult, error)
	RejectEffectAttempt(context.Context, RejectEffectAttemptRequest) (EffectAttempt, error)
	BeginEffectDispatch(context.Context, BeginEffectDispatchRequest) (EffectAttempt, error)
	FinishEffectDispatch(context.Context, FinishEffectDispatchRequest) (FinishEffectDispatchResult, error)
	MarkEffectUnknown(context.Context, MarkEffectUnknownRequest) (EffectAttempt, error)
}

type EffectAttemptState string

type EffectInvocationIdentity struct {
	ThreadID     string
	TurnID       string
	RunID        string
	ToolCallID   string
	ToolName     string
	ArgumentHash string
}

type Entry struct {
	ID                      string              `json:"id"`
	ThreadID                string              `json:"thread_id"`
	ParentID                string              `json:"parent_id,omitempty"`
	PathDepth               int64               `json:"path_depth"`
	Type                    EntryType           `json:"type"`
	TurnID                  string              `json:"turn_id,omitempty"`
	CreatedAt               time.Time           `json:"created_at"`
	Message                 session.Message     `json:"message,omitempty"`
	Raw                     string              `json:"raw,omitempty"`
	RawHash                 string              `json:"raw_hash,omitempty"`
	TurnStatus              TurnMarkerStatus    `json:"turn_status,omitempty"`
	Provider                string              `json:"provider,omitempty"`
	Model                   string              `json:"model,omitempty"`
	CompactionID            string              `json:"compaction_id,omitempty"`
	PreviousCompactionID    string              `json:"previous_compaction_id,omitempty"`
	CompactedThroughEntryID string              `json:"compacted_through_entry_id,omitempty"`
	SummarySchemaVersion    string              `json:"summary_schema_version,omitempty"`
	CompactionGeneration    int                 `json:"compaction_generation,omitempty"`
	CompactionWindowID      string              `json:"compaction_window_id,omitempty"`
	FirstKeptEntryID        string              `json:"first_kept_entry_id,omitempty"`
	KeptUserEntryIDs        []string            `json:"kept_user_entry_ids,omitempty"`
	Summary                 string              `json:"summary,omitempty"`
	CompactionTrigger       string              `json:"compaction_trigger,omitempty"`
	CompactionReason        string              `json:"compaction_reason,omitempty"`
	CompactionPhase         string              `json:"compaction_phase,omitempty"`
	CompactionOperationID   string              `json:"compaction_operation_id,omitempty"`
	CompactionRequestID     string              `json:"compaction_request_id,omitempty"`
	CompactionSource        string              `json:"compaction_source,omitempty"`
	TokensBefore            int64               `json:"tokens_before,omitempty"`
	TokensAfterEstimate     int64               `json:"tokens_after_estimate,omitempty"`
	ContextUsageBefore      contextpolicy.Usage `json:"context_usage_before,omitempty"`
	ContextUsageAfter       contextpolicy.Usage `json:"context_usage_after,omitempty"`
	Error                   string              `json:"error,omitempty"`
	Metadata                map[string]string   `json:"metadata,omitempty"`
}

type EntryType string

type FailAutomaticThreadTitleRequest struct {
	ThreadID   string
	Generation int64
	Token      string
	Error      string
	Now        time.Time
}

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

type FinalizeApprovalRequest struct {
	ResolutionID             string
	ExpectedRootThreadID     string
	ExpectedGeneration       int64
	ExpectedCurrent          ApprovalIdentity
	ExpectedApprovalRevision int64
	State                    ApprovalState
	Reason                   string
	FinalizedEntry           Entry
	Now                      time.Time
}

type FinalizeApprovalResult struct {
	Receipt        ApprovalDecisionReceipt
	Queue          ApprovalQueue
	Approval       ApprovalRecord
	Effect         EffectAttempt
	FinalizedEntry Entry
	Replayed       bool
}

type FinishCompactionRequest struct {
	Lease              TurnLease
	RequestID          string
	RequestFingerprint string
	OutcomeFingerprint string
	Result             *Entry
	ErrorCode          string
	ErrorMessage       string
	Now                time.Time
}

type FinishCompactionResult struct {
	Operation CompactionOperation
	Entry     *Entry
	Replayed  bool
}

type FinishEffectDispatchRequest struct {
	Lease              TurnLease
	EffectAttemptID    string
	RequestFingerprint string
	OutcomeFingerprint string
	Failed             bool
	Result             Entry
	FullOutput         *artifact.FullOutput
	Now                time.Time
}

type FinishEffectDispatchResult struct {
	Attempt  EffectAttempt
	Result   Entry
	Artifact *artifact.Ref
	Replayed bool
}

type FinishSubAgentCloseRequest struct {
	CloseOperationID string
	ParentThreadID   string
	TargetThreadID   string
	Reason           string
	Now              time.Time
}

type FinishSubAgentCloseResult struct {
	Operation         SubAgentCloseOperation
	Threads           []ThreadMeta
	Entries           []Entry
	CancelledInputIDs []string
	Replayed          bool
}

type FinishTurnRequest struct {
	Lease              TurnLease
	RunID              string
	TerminalEntryID    string
	Status             TurnMarkerStatus
	Metadata           map[string]string
	FailureMessage     string
	ProviderState      *ProviderStateRecord
	ClearProviderState bool
	OutcomeFingerprint string
	Now                time.Time
}

type FinishTurnResult struct {
	Failure  *Entry
	Terminal Entry
	Replayed bool
}

type ForkDestinationMeta struct {
	ParentThreadID  string          `json:"parent_thread_id"`
	ParentTurnID    string          `json:"parent_turn_id,omitempty"`
	TaskName        string          `json:"task_name,omitempty"`
	TaskDescription string          `json:"task_description,omitempty"`
	AgentPath       string          `json:"agent_path,omitempty"`
	HostProfileRef  string          `json:"host_profile_ref,omitempty"`
	ForkMode        string          `json:"fork_mode,omitempty"`
	Lifecycle       ThreadLifecycle `json:"lifecycle,omitempty"`
}

type ForkEntryIdentity struct {
	SourceThreadID      string
	DestinationThreadID string
	TurnIDMap           map[string]string
	RunIDMap            map[string]string
}

type ForkOptions struct {
	SourceThreadID       string
	EntryID              string
	EntryIDPinned        bool
	ExpectedSourceLeafID string
	Position             ForkPosition
	NewThreadID          string
	OperationID          string
	OperationNodeID      string
	Now                  time.Time
	TurnIDMap            map[string]string
	RunIDMap             map[string]string
	DestinationMeta      *ForkDestinationMeta
	ArtifactClosure      artifact.Closure
	RewriteEntry         func(Entry, ForkEntryIdentity) (Entry, error)
}

type ForkPosition string

type ForkPrepareThreadState struct {
	Meta              ThreadMeta
	Path              []Entry
	PinnedPath        []Entry
	PendingInputCount int
}

type InterruptedTurnApprovalQueueProof struct {
	RootThreadID string
	Generation   int64
	Revision     int64
}

type InterruptedTurnRecoveryEffect struct {
	EffectAttemptID string             `json:"effect_attempt_id"`
	ToolCallID      string             `json:"tool_call_id"`
	State           EffectAttemptState `json:"state"`
}

type InterruptedTurnRecoveryFailureProof struct {
	EntryID string `json:"entry_id"`
	Message string `json:"message"`
	RawHash string `json:"raw_hash"`
}

type InterruptedTurnRecoveryPlan struct {
	RunID              string
	Status             TurnMarkerStatus
	FailureCode        string
	FailureMessage     string
	SourceFailure      *InterruptedTurnRecoveryFailureProof
	OutcomeFingerprint string
	TerminalEntryID    string
	Effects            []InterruptedTurnRecoveryEffect
}

type InterruptedTurnRecoveryRepo interface {
	RecoverInterruptedTurn(context.Context, RecoverInterruptedTurnRequest) (RecoverInterruptedTurnResult, error)
}

type InterruptedTurnResolutionValidationRepo interface {
	ValidateInterruptedTurnResolution(context.Context, RecoverInterruptedTurnRequest) error
}

type JournalRepo interface {
	Thread(context.Context, string) (ThreadMeta, error)
	Append(context.Context, Entry, AppendOptions) (Entry, error)
	Entry(context.Context, string, string) (Entry, error)
	Entries(context.Context, string) ([]Entry, error)
	Path(context.Context, string, string) ([]Entry, error)
	PathPage(context.Context, string, string, string, int) (PathPage, error)
}

type LeasePolicy struct {
	TTL                time.Duration
	RenewInterval      time.Duration
	ClockSkewAllowance time.Duration
}

type LeasePolicyRepo interface {
	AuthorityLeasePolicy() LeasePolicy
}

type ListCanonicalTurnsOptions struct {
	ThreadID     string
	BeforeCursor *CanonicalTurnBeforeCursor
	SinceCursor  *CanonicalTurnSinceCursor
	Tail         int
	Limit        int
}

type ListThreadsOptions struct {
	IncludeArchived bool
	RootOnly        bool
	Limit           int
	AfterCreatedAt  time.Time
	AfterID         string
}

type MarkEffectUnknownRequest struct {
	Lease              TurnLease
	EffectAttemptID    string
	RequestFingerprint string
	OutcomeFingerprint string
	Now                time.Time
}

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

type PathPage struct {
	Entries     []Entry
	NextEntryID string
	HasMore     bool
	// NewestOrdinal is the active-path ordinal of Entries[0]. Entries are
	// returned newest first, so later entries decrement this value by one.
	NewestOrdinal int64
}

type PendingToolCompletionAuthorityRepo interface {
	AdmitPendingToolCompletion(context.Context, AdmitPendingToolCompletionRequest) (AdmitPendingToolCompletionResult, error)
	ReadPendingToolCompletion(context.Context, AdmitPendingToolCompletionRequest) (AdmitPendingToolCompletionResult, bool, error)
}

type PendingToolRecoveryRepo interface {
	SettlePendingToolRecovery(context.Context, SettlePendingToolRecoveryRequest) (SettlePendingToolRecoveryResult, error)
}

type PendingToolSettlementTarget struct {
	ThreadID        string
	TurnID          string
	RunID           string
	ToolCallID      string
	ToolName        string
	Handle          string
	EffectAttemptID string
}

type PrepareApprovalBatchRequest struct {
	Lease TurnLease
	Items []ApprovalPreflightItem
	Now   time.Time
}

type PrepareApprovalBatchResult struct {
	Queue            ApprovalQueue
	Effects          []EffectAttempt
	Approvals        []ApprovalRecord
	RequestedEntries []Entry
	Replayed         bool
}

type PrepareEffectAttemptRequest struct {
	Lease              TurnLease
	Invocation         EffectInvocationIdentity
	RequestFingerprint string
	Now                time.Time
}

type PrepareEffectAttemptResult struct {
	Attempt  EffectAttempt
	Replayed bool
}

type PrepareSubAgentCloseRequest struct {
	CloseOperationID string
	ParentThreadID   string
	TargetThreadID   string
	Reason           string
	TargetLease      *TurnLease
	Now              time.Time
}

type PrepareSubAgentCloseResult struct {
	Operation SubAgentCloseOperation
	Replayed  bool
}

type ProjectedSegment struct {
	EntryID       string         `json:"entry_id,omitempty"`
	EntryType     EntryType      `json:"entry_type,omitempty"`
	MessageIndex  int            `json:"message_index"`
	Role          session.Role   `json:"role,omitempty"`
	ToolCallID    string         `json:"tool_call_id,omitempty"`
	ToolName      string         `json:"tool_name,omitempty"`
	TokenEstimate int64          `json:"token_estimate,omitempty"`
	ArtifactRefs  []artifact.Ref `json:"artifact_refs,omitempty"`
	UIPreview     string         `json:"ui_preview,omitempty"`
}

type ProjectionPurpose string

type ProviderStateReader interface {
	ProviderState(context.Context, string) (ProviderStateRecord, error)
}

type ProviderStateRecord struct {
	ThreadID         string
	LeafEntryID      string
	CompatibilityKey string
	State            provider.State
	CreatedByRunID   string
	CreatedByTurnID  string
	UpdatedAt        time.Time
}

type ProviderStateStore interface {
	ProviderStateReader
	PutProviderState(context.Context, ProviderStateRecord) error
	DeleteProviderState(context.Context, string) error
}

type PublishSubAgentInputRequest struct {
	InputRequestID     string
	RequestFingerprint string
	ParentThreadID     string
	ChildThreadID      string
	Message            session.Message
	HostLabels         map[string]string
	CorrelationLabels  map[string]string
	Interrupt          bool
	Now                time.Time
}

type PublishSubAgentPendingToolCompletionRequest struct {
	InputRequestID        string
	RequestFingerprint    string
	SettlementFingerprint string
	ParentThreadID        string
	ChildThreadID         string
	Target                PendingToolSettlementTarget
	Settlement            Entry
	Message               session.Message
	HostLabels            map[string]string
	CorrelationLabels     map[string]string
	Now                   time.Time
}

type PublishSubAgentPendingToolCompletionResult struct {
	Settlement         Entry
	SettlementReplayed bool
	Input              SubAgentInputRecord
	Replayed           bool
}

type PublishSubAgentRequest struct {
	PublicationID      string
	RequestFingerprint string
	ParentThreadID     string
	ChildMeta          ThreadMeta
	ForkOptions        *ForkOptions
	ArtifactClosure    artifact.Closure
	Message            session.Message
	HostLabels         map[string]string
	CorrelationLabels  map[string]string
	Now                time.Time
}

type PublishSubAgentResult struct {
	Thread   ThreadMeta
	Input    SubAgentInputRecord
	Replayed bool
}

type RecoverInterruptedTurnRequest struct {
	ExpectedLease  TurnLease
	ParentThreadID string
	Now            time.Time
}

type RecoverInterruptedTurnResult struct {
	RunID              string
	Status             TurnMarkerStatus
	OutcomeFingerprint string
	Failure            *Entry
	ToolResults        []Entry
	Terminal           Entry
	Generation         int64
	Replayed           bool
}

type RejectEffectAttemptRequest struct {
	Lease                TurnLease
	EffectAttemptID      string
	RequestFingerprint   string
	RejectionCode        string
	RejectionFingerprint string
	Now                  time.Time
}

type Repo interface {
	JournalRepo
	CreateThread(context.Context, ThreadMeta) (ThreadMeta, error)
	UpdateThread(context.Context, ThreadMeta) error
	MoveLeaf(context.Context, string, string) error
	Fork(context.Context, ForkOptions) (ThreadMeta, error)
}

type ResolveApprovalRequest struct {
	DecisionID               string
	ExpectedRootThreadID     string
	ExpectedGeneration       int64
	ExpectedRevision         int64
	ExpectedCurrent          ApprovalIdentity
	ExpectedApprovalRevision int64
	Decision                 ApprovalDecision
	RejectedEntry            Entry
	Now                      time.Time
}

type ResolveApprovalResult struct {
	Receipt       ApprovalDecisionReceipt
	Queue         ApprovalQueue
	Approval      ApprovalRecord
	Effect        EffectAttempt
	RejectedEntry Entry
	Replayed      bool
}

type RootAuthorityRepo interface {
	ThreadTombstoneRepo
	CreateRoot(context.Context, CreateRootRequest) (CreateRootResult, error)
	DeleteRootTree(context.Context, string) (DeleteRootTreeResult, error)
}

type SetThreadTitleRequest struct {
	ThreadID string
	Title    string
	Now      time.Time
}

type SettlePendingToolRecoveryRequest struct {
	Target             PendingToolSettlementTarget
	RequestFingerprint string
	Settlement         Entry
	Now                time.Time
}

type SettlePendingToolRecoveryResult struct {
	Entry    Entry
	Replayed bool
}

type SubAgentCloseAuthorityRepo interface {
	PrepareSubAgentClose(context.Context, PrepareSubAgentCloseRequest) (PrepareSubAgentCloseResult, error)
	FinishSubAgentClose(context.Context, FinishSubAgentCloseRequest) (FinishSubAgentCloseResult, error)
}

type SubAgentCloseNode struct {
	ThreadID string `json:"thread_id"`
	WasOpen  bool   `json:"was_open"`
}

type SubAgentCloseOperation struct {
	CloseOperationID   string
	ParentThreadID     string
	TargetThreadID     string
	Reason             string
	IntentFingerprint  string
	RequestFingerprint string
	State              SubAgentCloseState
	Nodes              []SubAgentCloseNode
	ResultEntryIDs     []string
	PreparedAt         time.Time
	FinishedAt         time.Time
}

type SubAgentCloseState string

type SubAgentInputAuthorityRepo interface {
	SubAgentInputReadRepo
	PublishSubAgent(context.Context, PublishSubAgentRequest) (PublishSubAgentResult, error)
	PublishSubAgentInput(context.Context, PublishSubAgentInputRequest) (SubAgentInputRecord, bool, error)
	PublishSubAgentPendingToolCompletion(context.Context, PublishSubAgentPendingToolCompletionRequest) (PublishSubAgentPendingToolCompletionResult, error)
	AdmitSubAgentInput(context.Context, AdmitSubAgentInputRequest) (AdmitSubAgentInputResult, error)
	ListSubAgentInputs(context.Context, string, SubAgentInputState) ([]SubAgentInputRecord, error)
}

type SubAgentInputReadRepo interface {
	ReadSubAgentInput(context.Context, string) (SubAgentInputRecord, bool, error)
}

type SubAgentInputRecord struct {
	SubAgentInputID    string
	ParentThreadID     string
	ChildThreadID      string
	RequestKind        SubAgentRequestKind
	RequestID          string
	RequestFingerprint string
	Sequence           int64
	State              SubAgentInputState
	Message            session.Message
	HostLabels         map[string]string
	CorrelationLabels  map[string]string
	AdmittedTurnID     string
	AdmittedRunID      string
	CreatedAt          time.Time
	AdmittedAt         time.Time
	CancelledAt        time.Time
}

type SubAgentInputState string

type SubAgentRequestKind string

type SubAgentThreadAuthorityInspectionRepo interface {
	InspectSubAgentThreadAuthority(context.Context, string, string) (SubAgentThreadAuthoritySnapshot, error)
}

type SubAgentThreadAuthoritySnapshot struct {
	Parent ThreadMeta
	Child  ThreadAuthoritySnapshot
}

type TakeOverCompactionRequest struct {
	ThreadID           string
	RequestID          string
	RequestFingerprint string
	ExpectedLease      TurnLease
	OwnerID            string
	Now                time.Time
}

type ThreadAuthorityInspectionRepo interface {
	InspectThreadAuthority(context.Context, string) (ThreadAuthoritySnapshot, error)
}

type ThreadAuthoritySnapshot struct {
	Thread           ThreadMeta
	Lease            *TurnLease
	ClaimOperationID string
	LeaseGeneration  int64
}

type ThreadLifecycle string

type ThreadListRepo interface {
	ListThreads(context.Context, ListThreadsOptions) ([]ThreadMeta, error)
}

type ThreadMeta struct {
	ID                  string            `json:"id"`
	LeafID              string            `json:"leaf_id,omitempty"`
	ParentThreadID      string            `json:"parent_thread_id,omitempty"`
	ParentTurnID        string            `json:"parent_turn_id,omitempty"`
	ForkedFromThreadID  string            `json:"forked_from_thread_id,omitempty"`
	ForkedFromEntryID   string            `json:"forked_from_entry_id,omitempty"`
	ForkOperationID     string            `json:"fork_operation_id,omitempty"`
	ForkOperationNodeID string            `json:"fork_operation_node_id,omitempty"`
	TaskName            string            `json:"task_name,omitempty"`
	TaskDescription     string            `json:"task_description,omitempty"`
	AgentPath           string            `json:"agent_path,omitempty"`
	HostProfileRef      string            `json:"host_profile_ref,omitempty"`
	ForkMode            string            `json:"fork_mode,omitempty"`
	Lifecycle           ThreadLifecycle   `json:"lifecycle,omitempty"`
	CloseOperationID    string            `json:"close_operation_id,omitempty"`
	Archived            bool              `json:"archived,omitempty"`
	Title               string            `json:"title,omitempty"`
	TitleStatus         ThreadTitleStatus `json:"title_status,omitempty"`
	TitleSource         ThreadTitleSource `json:"title_source,omitempty"`
	TitleUpdatedAt      time.Time         `json:"title_updated_at,omitempty"`
	TitleError          string            `json:"title_error,omitempty"`
	TitleGeneration     int64             `json:"title_generation,omitempty"`
	TitleToken          string            `json:"title_token,omitempty"`
	CreatedAt           time.Time         `json:"created_at"`
	UpdatedAt           time.Time         `json:"updated_at"`
	LastViewedAt        time.Time         `json:"last_viewed_at,omitempty"`
}

type ThreadPublishRepo interface {
	CreateThreadWithInitialEntry(context.Context, ThreadMeta, Entry) (ThreadMeta, Entry, error)
	ForkWithInitialEntry(context.Context, ForkOptions, Entry) (ThreadMeta, Entry, error)
}

type ThreadTitleAuthorityRepo interface {
	SetThreadTitle(context.Context, SetThreadTitleRequest) (ThreadTitleMutationResult, error)
	BeginAutomaticThreadTitle(context.Context, BeginAutomaticThreadTitleRequest) (ThreadTitleMutationResult, error)
	CompleteAutomaticThreadTitle(context.Context, CompleteAutomaticThreadTitleRequest) (ThreadTitleMutationResult, error)
	FailAutomaticThreadTitle(context.Context, FailAutomaticThreadTitleRequest) (ThreadTitleMutationResult, error)
	PendingAutomaticThreadTitles(context.Context) ([]ThreadMeta, error)
}

type ThreadTitleMutationResult struct {
	Thread  ThreadMeta
	Changed bool
}

type ThreadTitleProjection struct {
	Title      string
	Status     ThreadTitleStatus
	Source     ThreadTitleSource
	UpdatedAt  time.Time
	Error      string
	Generation int64
}

type ThreadTitleSource string

type ThreadTitleStatus string

type ThreadTombstone struct {
	ThreadID            string
	RootThreadID        string
	ParentThreadID      string
	CreateIntentID      string
	ForkOperationID     string
	ForkOperationNodeID string
	ForkedFromThreadID  string
	ForkedFromEntryID   string
	DeletedAt           time.Time
}

type ThreadTombstoneRepo interface {
	ThreadTombstone(context.Context, string) (ThreadTombstone, error)
}