thread

type ACPSetupValidation struct {
	Enabled               bool
	MissingManagedFieldID string
}

type ACPSetupValidator interface {
	// InstanceACPAgent is the ACP agent profile a Bot Agent instance runs.
	InstanceACPAgent(ctx context.Context, botID, botAgentID string) (string, error)
	// ACPInstanceFor is the instance a session that names only an ACP agent
	// profile runs as: the bot's oldest active instance of it. Empty when the
	// bot has none, as bots configured before instances do.
	ACPInstanceFor(ctx context.Context, botID, agentID string) (string, error)
	KnownACPAgent(agentID string) bool
	ValidateACPSetup(ctx context.Context, botID, botAgentID, agentID string, botMetadata map[string]any) (ACPSetupValidation, error)
}

type CreateInput struct {
	BotID           string
	BotAgentID      string
	RouteID         string
	ChannelType     string
	Type            string
	SessionMode     string
	RuntimeType     string
	Title           string
	Metadata        map[string]any
	RuntimeMetadata map[string]any
	ParentThreadID  string
	CreatedByUserID string
	// WorkdirID immutably binds the thread to a bot workdir. The caller
	// (handler layer) validates the workdir; thread persistence only stores
	// the reference so this package never imports the workdir domain.
	WorkdirID string
	// WorkdirPath is the resolved workdir directory, set if and only if
	// WorkdirID is set. For ACP threads it overrides the metadata
	// project_path so the runtime works in that directory; it also
	// leaves a creation-time path snapshot in the metadata for history.
	WorkdirPath string
	// PreferredChatModelID / PreferredReasoningEffort are the first-message
	// pair written at INSERT time (issue #879, spec §3.3-D) so the
	// session_created broadcast never precedes the value. Empty = NULL.
	// Non-UUID model references degrade to NULL; the steady-state
	// write-back completes the pair on the same turn.
	PreferredChatModelID     string
	PreferredReasoningEffort string
	// Visibility overrides the default visibility derived from the session
	// mode. Schedule-created sessions use this to surface in user-facing
	// session lists while keeping session_mode='schedule' for prompt and
	// tool gating. Empty means "derive from mode".
	Visibility Visibility
}

type CreateSubagentInput struct {
	Thread       CreateInput
	ModelUUID    string
	ModelID      string
	ProviderName string
	Forked       bool
	ForkContext  []SubagentForkContextMessage
}

type Cursor struct {
	UpdatedAt time.Time
	ID        string
}

type DescriptorError struct {
	Field string
	Err   error
}

type ExternalIdentity struct {
	BotAgentID            string
	ACPAgentID            string
	ProjectPath           string
	RuntimeOwnerAccountID string
}

type ForkFromAssistantInput struct {
	BotID    string
	ThreadID string
	// RuntimeMetadataOverride replaces the clone's runtime metadata. External
	// runtime forks must pass it carrying the driver's freshly forked session
	// keys; without it the two Memoh sessions would share one runtime session.
	RuntimeMetadataOverride map[string]any
	// RuntimeForkRequired marks a source whose runtime keeps its native
	// session in runtime metadata with no owner: a copy without the runtime's
	// own fork would share that session, so the fork is refused.
	RuntimeForkRequired bool
	// TurnID names the round the fork inherits through. A turn is the identity
	// a client holds while the round is still live, and the cut is turn-level
	// anyway, so the fork point is named by turn rather than by stored message.
	TurnID string
	// MessageID is the pre-turn spelling of TurnID.
	//
	// Deprecated: accepted so a client shipped against the message-id contract
	// keeps working after a server upgrade. It is resolved to the round that
	// contains it. Remove once the compatibility window closes.
	MessageID       string
	Title           string
	CreatedByUserID string
}

type ListFilter struct {
	ParentThreadID string
	// WorkdirID filters to sessions bound to one workdir. Mutually
	// exclusive with WorkdirUnassigned.
	WorkdirID string
	// WorkdirUnassigned filters to sessions with no workdir binding — the
	// sidebar's ungrouped bucket.
	WorkdirUnassigned bool
	// Visibility filters to sessions with the given stored visibility.
	// Empty means no visibility predicate. The default session listing
	// passes VisibilityUser so schedule-created sessions surface by
	// visibility rather than by widening the legacy type filter.
	Visibility Visibility
	// HideScheduleRuns drops the sessions schedule fires created, which the
	// sidebar shows under their schedule instead. A schedule-created session
	// that a schedule still runs in (its existing_session target) stays.
	HideScheduleRuns bool
}

type Queries interface {
	CountMessagesBySession(context.Context, pgtype.UUID) (int64, error)
	CreateSession(context.Context, sqlc.CreateSessionParams) (sqlc.BotSession, error)
	CreateSubagentConfig(context.Context, sqlc.CreateSubagentConfigParams) (sqlc.SubagentConfig, error)
	CreateSubagentForkContext(context.Context, sqlc.CreateSubagentForkContextParams) (sqlc.CreateSubagentForkContextRow, error)
	ForkSessionFromAssistantTurn(context.Context, sqlc.ForkSessionFromAssistantTurnParams) (sqlc.ForkSessionFromAssistantTurnRow, error)
	GetVisibleHistoryTurnByMessage(context.Context, sqlc.GetVisibleHistoryTurnByMessageParams) (dbstore.HistoryTurn, error)
	GetBotByID(context.Context, pgtype.UUID) (sqlc.GetBotByIDRow, error)
	GetSessionByID(context.Context, pgtype.UUID) (sqlc.BotSession, error)
	GetLatestSessionModelPreference(context.Context, sqlc.GetLatestSessionModelPreferenceParams) (sqlc.GetLatestSessionModelPreferenceRow, error)
	GetSubagentConfig(context.Context, pgtype.UUID) (sqlc.SubagentConfig, error)
	ListSessionsByBot(context.Context, pgtype.UUID) ([]sqlc.ListSessionsByBotRow, error)
	ListSessionsByBotAndCreatedByUser(context.Context, sqlc.ListSessionsByBotAndCreatedByUserParams) ([]sqlc.ListSessionsByBotAndCreatedByUserRow, error)
	ListSessionsByBotAndCreatedByUserPaged(context.Context, sqlc.ListSessionsByBotAndCreatedByUserPagedParams) ([]sqlc.ListSessionsByBotAndCreatedByUserPagedRow, error)
	ListSessionsByBotPaged(context.Context, sqlc.ListSessionsByBotPagedParams) ([]sqlc.ListSessionsByBotPagedRow, error)
	ListSessionsByRoute(context.Context, pgtype.UUID) ([]sqlc.BotSession, error)
	ListSubagentForkContext(context.Context, pgtype.UUID) ([]sqlc.ListSubagentForkContextRow, error)
	ListSubagentSessionsByParent(context.Context, pgtype.UUID) ([]sqlc.BotSession, error)
	SoftDeleteSession(context.Context, pgtype.UUID) error
	TouchSession(context.Context, pgtype.UUID) error
	UpdateSessionMetadata(context.Context, sqlc.UpdateSessionMetadataParams) (sqlc.BotSession, error)
	UpdateSessionRuntimeMetadata(context.Context, sqlc.UpdateSessionRuntimeMetadataParams) (sqlc.BotSession, error)
	UpdateSessionTitle(context.Context, sqlc.UpdateSessionTitleParams) (sqlc.BotSession, error)
	UpdateSessionTypeAndMetadata(context.Context, sqlc.UpdateSessionTypeAndMetadataParams) (sqlc.BotSession, error)
}

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

type SubagentConfig struct {
	ThreadID     string    `json:"session_id"`
	ModelUUID    string    `json:"model_uuid,omitempty"`
	ModelID      string    `json:"model_id"`
	ProviderName string    `json:"provider"`
	Forked       bool      `json:"fork"`
	CreatedAt    time.Time `json:"created_at"`
	UpdatedAt    time.Time `json:"updated_at"`
}

type SubagentForkContextMessage struct {
	SourceMessageID string          `json:"source_message_id,omitempty"`
	Role            string          `json:"role"`
	Message         json.RawMessage `json:"message"`
}

type Thread struct {
	ID string `json:"id"`
	// TeamID is the team that owns the thread's bot. Server-owned work that
	// outlives the request (queued follow-ups) records it because admission
	// requires a team and nothing else can supply one later. It is internal
	// state, not part of the session API resource.
	TeamID          string         `json:"-"`
	BotID           string         `json:"bot_id"`
	BotAgentID      string         `json:"bot_agent_id,omitempty"`
	RouteID         string         `json:"route_id,omitempty"`
	ChannelType     string         `json:"channel_type,omitempty"`
	Type            string         `json:"type"`
	SessionMode     string         `json:"session_mode"`
	RuntimeType     string         `json:"runtime_type"`
	RuntimeMetadata map[string]any `json:"runtime_metadata,omitempty"`
	Title           string         `json:"title"`
	Metadata        map[string]any `json:"metadata,omitempty"`
	ParentThreadID  string         `json:"parent_session_id,omitempty"`
	CreatedByUserID string         `json:"created_by_user_id,omitempty"`
	WorkdirID       string         `json:"workdir_id,omitempty"`
	CreatedAt       time.Time      `json:"created_at"`
	UpdatedAt       time.Time      `json:"updated_at"`
	// Preferred* is the session's persisted (model, effort) pair (issue #879).
	// Empty means "no memory"; the composer reseeds from it on open/repoint.
	PreferredExternalModelID string         `json:"preferred_external_model_id,omitempty"`
	ModelPreferenceRevision  string         `json:"model_preference_revision,omitempty"`
	PreferredChatModelID     string         `json:"preferred_chat_model_id,omitempty"`
	PreferredReasoningEffort string         `json:"preferred_reasoning_effort,omitempty"`
	RouteMetadata            map[string]any `json:"route_metadata,omitempty"`
	RouteConversationType    string         `json:"route_conversation_type,omitempty"`
	// AttentionKind and Unread describe the requesting user's unread state.
	// They are filled by the attention service for list responses only.
	AttentionKind string     `json:"attention_kind,omitempty"`
	AttentionAt   *time.Time `json:"attention_at,omitempty"`
	Unread        bool       `json:"unread,omitempty"`
	Visibility    Visibility `json:"-"`

} // @name session.Session

type Visibility string