sessiontree

type AcceptTurnRequest struct {
	ThreadID                    string
	TurnID                      string
	RunID                       string
	LogicalRequestID            string
	Input                       session.Message
	RetrySourceTurnID           string
	RetrySourceEntryID          string
	PromotedQueueID             string
	PromotionRequestKey         string
	PromotionRequestFingerprint string
	InputRequestFingerprint     string
	RequestFingerprint          string
	Now                         time.Time
}

type AcceptTurnResult struct {
	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 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 BackendRepo struct {
	// contains filtered or unexported fields
}

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

type BeginEffectDispatchRequest struct {
	EffectAttemptID, RequestFingerprint, AuthorizationProofHash string
	Now                                                         time.Time
}

type CancelTurnRequest struct {
	ThreadID                     string
	TurnID                       string
	RunID                        string
	CancelEntryID                string
	TerminalEntryID              string
	RequestKey                   string
	RequestFingerprint           string
	OutcomeFingerprint           string
	InteractionResolutionPayload json.RawMessage
	Metadata                     map[string]string
	ClearProviderState           bool
	Now                          time.Time
}

type CancelTurnResult struct {
	CancelRequest          Entry
	InteractionResolutions []Entry
	ToolResults            []Entry
	Terminal               Entry
	Replayed               bool
}

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

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 ClaimEffectRetryRequest struct {
	EffectAttemptID, ToolCallID, RequestKey, RequestFingerprint string
	Now                                                         time.Time
}

type ClaimEffectRetryResult struct {
	Attempt  EffectAttempt
	Replayed bool
}

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 DeleteRootTreeResult struct {
	ThreadIDs []string
	Replayed  bool
}

type EffectAttempt struct {
	EffectAttemptID         string                   `json:"effect_attempt_id"`
	Invocation              EffectInvocationIdentity `json:"invocation"`
	RequestFingerprint      string                   `json:"request_fingerprint"`
	State                   EffectAttemptState       `json:"state"`
	RejectionCode           string                   `json:"rejection_code,omitempty"`
	TerminalFingerprint     string                   `json:"terminal_fingerprint,omitempty"`
	ResultEntryID           string                   `json:"result_entry_id,omitempty"`
	CreatedAt               time.Time                `json:"created_at"`
	UpdatedAt               time.Time                `json:"updated_at"`
	RetryRequestKey         string                   `json:"retry_request_key,omitempty"`
	RetryRequestFingerprint string                   `json:"retry_request_fingerprint,omitempty"`
	OwnerID                 string                   `json:"owner_id,omitempty"`
	Generation              int64                    `json:"generation,omitempty"`
}

type EffectAttemptReader interface {
	EffectAttempt(context.Context, string, string) (EffectAttempt, error)
}

type EffectAttemptRepo 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 `json:"thread_id"`
	TurnID                string `json:"turn_id"`
	RunID                 string `json:"run_id"`
	ToolCallID            string `json:"tool_call_id"`
	ToolName              string `json:"tool_name"`
	ArgumentHash          string `json:"argument_hash"`
	RetryKey              string `json:"retry_key,omitempty"`
	SourceEffectAttemptID string `json:"source_effect_attempt_id,omitempty"`
}

type EffectRetryRepo interface {
	ClaimEffectRetry(context.Context, ClaimEffectRetryRequest) (ClaimEffectRetryResult, error)
}

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"`
	RunID                   string              `json:"run_id,omitempty"`
	RequestKey              string              `json:"request_key,omitempty"`
	RequestFingerprint      string              `json:"request_fingerprint,omitempty"`
	Payload                 json.RawMessage     `json:"payload,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 FinishEffectDispatchRequest struct {
	EffectAttemptID, RequestFingerprint, 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 FinishTurnRequest struct {
	ThreadID           string
	TurnID             string
	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
	OriginRequestKey     string
	OriginFingerprint    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 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 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 {
	EffectAttemptID, RequestFingerprint, 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 PendingToolSettlementTarget struct {
	ThreadID        string
	TurnID          string
	RunID           string
	ToolCallID      string
	ToolName        string
	Handle          string
	EffectAttemptID string
}

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

type PrepareEffectAttemptResult struct {
	Attempt  EffectAttempt
	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 RejectEffectAttemptRequest struct {
	EffectAttemptID, RequestFingerprint, RejectionCode, 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 RootThreadInventoryItem struct {
	Meta ThreadMeta
	Path []Entry
	// ProjectionFingerprint validates the cached inventory payload; it is not a
	// lifecycle revision or host replay cursor.
	ProjectionFingerprint [32]byte `json:"-"`
}

type RuntimeJournalRepo interface {
	AppendRuntimeFacts(context.Context, string, []Entry) ([]Entry, error)
}

type RuntimeTurnRepo interface {
	AcceptTurn(context.Context, AcceptTurnRequest) (AcceptTurnResult, error)
	ReadAcceptedTurn(context.Context, string, string, string) (AcceptTurnResult, bool, error)
	CancelTurn(context.Context, CancelTurnRequest) (CancelTurnResult, error)
	FinishTurn(context.Context, FinishTurnRequest) (FinishTurnResult, error)
}

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

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 ThreadDeleteRepo interface {
	DeleteRootTreeWithRequest(context.Context, string, string, string) (DeleteRootTreeResult, error)
}

type ThreadLifecycle string

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

type ThreadMeta struct {
	ID                      string            `json:"id"`
	OriginRequestKey        string            `json:"origin_request_key,omitempty"`
	OriginFingerprint       string            `json:"origin_fingerprint,omitempty"`
	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"`
	LegacyForkRequestID     string            `json:"fork_operation_id,omitempty"`
	LegacyForkNodeID        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"`
	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"`
	TitleRequestKey         string            `json:"title_request_key,omitempty"`
	TitleRequestFingerprint string            `json:"title_request_fingerprint,omitempty"`
	CreatedAt               time.Time         `json:"created_at"`
	UpdatedAt               time.Time         `json:"updated_at"`
	LastViewedAt            time.Time         `json:"last_viewed_at,omitempty"`
}

type ThreadOrigin struct {
	Thread    *ThreadMeta
	Tombstone *ThreadTombstone
}

type ThreadOriginRepo interface {
	ThreadOrigin(context.Context, string) (ThreadOrigin, error)
}

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
	OriginRequestKey    string
	OriginFingerprint   string
	DeleteRequestKey    string
	DeleteFingerprint   string
	ForkedFromThreadID  string
	ForkedFromEntryID   string
	LegacyCreateIntent  string `json:"create_intent_id,omitempty"`
	LegacyForkRequestID string `json:"fork_operation_id,omitempty"`
	LegacyForkNodeID    string `json:"fork_operation_node_id,omitempty"`
	DeletedAt           time.Time
}

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

type TurnMarkerStatus string

type TurnTerminalOutcome struct {
	Failure  *Entry
	Terminal Entry
}