sessioncontext

type AcceptedDetectiveOperation struct {
	Identity            DetectiveIdentity `json:"identity"`
	ClientRequestDigest string            `json:"clientRequestDigest"`
}

type AcceptedDetectiveStatus struct {
	RunID         string `json:"runId"`
	State         string `json:"state"`
	FenceReason   string `json:"fenceReason,omitempty"`
	Produced      bool   `json:"produced"`
	Done          bool   `json:"done"`
	EvidenceState string `json:"evidenceState,omitempty"`
}

type AcceptedDetectiveWork struct {
	ID              string                            `json:"id"`
	Owner           string                            `json:"owner"`
	Namespace       NativeNamespace                   `json:"namespace"`
	SessionID       string                            `json:"sessionId"`
	RunID           string                            `json:"runId"`
	InputSnapshotID string                            `json:"inputSnapshotId"`
	Reference       apicontract.SessionInputReference `json:"reference"`
	Dispatch        DetectiveDispatchBinding          `json:"dispatch"`
	State           string                            `json:"state"`
	Version         int64                             `json:"version"`
	AcceptedAt      time.Time                         `json:"acceptedAt"`

	// SessionGeneration is captured atomically with acceptance, before any dispatch claim.
	SessionGeneration int64 `json:"sessionGeneration"`
	// OwnerProtocolVersion binds lifecycle generation; legacy unbound acceptances cannot dispatch.
	OwnerProtocolVersion int64 `json:"ownerProtocolVersion"`
	// ClientOperationID and AcceptanceDigest bind the durable metadata lookup.
	ClientOperationID   string `json:"clientOperationId,omitempty"`
	AcceptanceDigest    string `json:"acceptanceDigest,omitempty"`
	ClientRequestDigest string `json:"clientRequestDigest,omitempty"`
}

type Access struct {
	Principal Principal
	Action    string
	SessionID string
	Scope     *Scope
}

type AppliedContextSet struct {
	ID        string        `json:"id"`
	SessionID string        `json:"sessionId"`
	Enabled   bool          `json:"enabled"`
	Slots     []AppliedSlot `json:"slots"`
	CreatedAt time.Time     `json:"createdAt"`
}

type AppliedSlot struct {
	Scope      Scope      `json:"scope"`
	BagID      string     `json:"bagId"`
	BagVersion int64      `json:"bagVersion"`
	Version    int64      `json:"version"`
	Entries    []EntryRef `json:"entries"`
}

type AuditEvent struct {
	OpID       string    `json:"opId"`
	Actor      string    `json:"actor"`
	Action     string    `json:"action"`
	SessionID  string    `json:"sessionId"`
	ResourceID string    `json:"resourceId,omitempty"`
	Count      int       `json:"count"`
	At         time.Time `json:"at"`
}

type Authorizer func(context.Context, Access) error

type Bag struct {
	ID           string   `json:"id"`
	SessionID    string   `json:"sessionId"`
	Title        string   `json:"title"`
	Scope        Scope    `json:"scope"`
	Version      int64    `json:"version"`
	ClearVersion int64    `json:"clearVersion,omitempty"`
	EntryIDs     []string `json:"entryIds"`
}

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

type Command struct {
	OpID                 string         `json:"opId"`
	Action               string         `json:"action"`
	SessionID            string         `json:"sessionId"`
	ExpectedVersion      int64          `json:"expectedVersion,omitempty"`
	DatabaseID           string         `json:"databaseId,omitempty"`
	ProjectID            string         `json:"projectId,omitempty"`
	BagID                string         `json:"bagId,omitempty"`
	ExpectedBagVersion   int64          `json:"expectedBagVersion,omitempty"`
	ExpectedSlotVersion  int64          `json:"expectedSlotVersion,omitempty"`
	ExpectedContextSetID string         `json:"expectedContextSetId,omitempty"`
	EntryID              string         `json:"entryId,omitempty"`
	ExpectedEntryVersion int64          `json:"expectedEntryVersion,omitempty"`
	RevisionID           string         `json:"revisionId,omitempty"`
	Title                string         `json:"title,omitempty"`
	Alias                string         `json:"alias,omitempty"`
	Scope                *Scope         `json:"scope,omitempty"`
	Subject              *Subject       `json:"subject,omitempty"`
	Value                *ValueEnvelope `json:"value,omitempty"`
	Selection            []EntryRef     `json:"selection,omitempty"`
	Enabled              *bool          `json:"enabled,omitempty"`
	Transition           string         `json:"transition,omitempty"`
	// M3 input pins and durable run routing. Result rows remain in the existing result store.
	InputSnapshotID    string          `json:"inputSnapshotId,omitempty"`
	RunID              string          `json:"runId,omitempty"`
	Kind               string          `json:"kind,omitempty"`
	DefinitionID       string          `json:"definitionId,omitempty"`
	DefinitionRevision string          `json:"definitionRevision,omitempty"`
	DefinitionDocument json.RawMessage `json:"definitionDocument,omitempty"`
	ExecutionDocument  json.RawMessage `json:"executionDocument,omitempty"`
	Attachments        []EntryRef      `json:"attachments,omitempty"`
	Text               string          `json:"text,omitempty"`
	ExpectedRunVersion int64           `json:"expectedRunVersion,omitempty"`
	// reportClientRun accepts outcome-unknown only with the fixed
	// CLIENT_OUTCOME_UNKNOWN code and no result payload. It records uncertainty
	// after client interruption; it does not assert source failure or cancellation.
	RunState           string                            `json:"runState,omitempty"`
	Widgets            []WidgetOutcome                   `json:"widgets,omitempty"`
	ResultRefs         []string                          `json:"resultRefs,omitempty"`
	ErrorCode          string                            `json:"errorCode,omitempty"`
	CaseID             string                            `json:"caseId,omitempty"`
	DetectiveRunID     string                            `json:"detectiveRunId,omitempty"`
	ResolvedParameters map[string]apicontract.TypedValue `json:"resolvedParameters,omitempty"`
	LegacyImport       *LegacyImport                     `json:"legacyImport,omitempty"`
}

type CommandResult struct {
	Receipt Receipt `json:"receipt"`
}

type ContextSource struct {
	SessionID  string `json:"sessionId"`
	BagID      string `json:"bagId"`
	EntryID    string `json:"entryId"`
	RevisionID string `json:"revisionId"`
}

type CopyContextCommand struct {
	OpID, SourceSessionID, DestinationSessionID       string
	ExpectedSourceVersion, ExpectedDestinationVersion int64
	Selection                                         []EntryRef
}

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

type DetectiveAcceptedQueryPin struct {
	QueryID        string          `json:"queryId"`
	Revision       string          `json:"revision"`
	DefinitionJSON json.RawMessage `json:"definitionJson"`
}

type DetectiveCheckDefinitionPin struct {
	SchemaVersion       int                            `json:"schemaVersion"`
	Check               detective.Check                `json:"check"`
	Dependencies        []detective.Check              `json:"dependencies"`
	PublishedValidators []detective.PublishedValidator `json:"publishedValidators"`
	QueryValidators     []detective.QueryValidators    `json:"queryValidators"`
	Queries             []DetectiveAcceptedQueryPin    `json:"queries"`
	Scenario            *DetectiveScenarioStepIdentity `json:"scenario,omitempty"`
}

type DetectiveDispatchBinding struct {
	NativeOperationID   string `json:"nativeOperationId"`
	NativeStoreID       string `json:"nativeStoreId"`
	NativeSpaceID       string `json:"nativeSpaceId,omitempty"`
	NativeProjectID     string `json:"nativeProjectId"`
	Action              string `json:"action"`
	CheckID             string `json:"checkId"`
	CheckVersion        int64  `json:"checkVersion"`
	DefinitionDigest    string `json:"definitionDigest"`
	NativeRequestDigest string `json:"nativeRequestDigest"`
	CaseID              string `json:"caseId,omitempty"`
	CaseVersion         int64  `json:"caseVersion,omitempty"`
	CaseContextDigest   string `json:"caseContextDigest,omitempty"`
}

type DetectiveFence struct {
	SessionGeneration int64             `json:"sessionGeneration"`
	Identity          DetectiveIdentity `json:"identity"`
	Generation        int64             `json:"generation"`
}

type DetectiveIdentity struct {
	Namespace         NativeNamespace `json:"namespace"`
	Actor             string          `json:"actor"`
	SessionID         string          `json:"sessionId"`
	RunID             string          `json:"runId"`
	NativeStoreID     string          `json:"nativeStoreId"`
	NativeSpaceID     string          `json:"nativeSpaceId,omitempty"`
	NativeProjectID   string          `json:"nativeProjectId"`
	NativeOperationID string          `json:"nativeOperationId"`
	Digest            string          `json:"digest"`
}

type DetectiveInputPin struct {
	Reference       apicontract.SessionInputReference `json:"reference"`
	Definition      DetectiveCheckDefinitionPin       `json:"definition"`
	EffectiveInputs map[string]detective.InputValue   `json:"effectiveInputs"`
	Dispatch        DetectiveDispatchBinding          `json:"dispatch"`
}

type DetectiveObservation struct {
	// FenceGeneration copies DetectiveFence.Generation (initially 1).
	// SessionGeneration copies DetectiveFence.SessionGeneration (initially 0).
	// The native owner persists both with its acceptance and checks them at finalization.
	FenceGeneration   int64             `json:"fenceGeneration"`
	SessionGeneration int64             `json:"sessionGeneration"`
	Identity          DetectiveIdentity `json:"identity"`
	Produced          bool              `json:"produced"`
	Done              bool              `json:"done"`
	NativeRunID       string            `json:"nativeRunId,omitempty"`
	NativeReceiptID   string            `json:"nativeReceiptId,omitempty"`
	State             string            `json:"state,omitempty"` // completed, failed, canceled
	CaseLinkStatus    string            `json:"caseLinkStatus,omitempty"`
}

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

type DetectiveScenarioStepIdentity struct {
	ScenarioID      string `json:"scenarioId"`
	ScenarioVersion int64  `json:"scenarioVersion"`
	ApplicationID   string `json:"applicationId"`
	StepID          string `json:"stepId"`
}

type EntityKey struct {
	Components []KeyComponent `json:"components"`
}

type Entry struct {
	ID                string  `json:"id"`
	SessionID         string  `json:"sessionId"`
	BagID             string  `json:"bagId"`
	Alias             string  `json:"alias,omitempty"`
	Subject           Subject `json:"subject"`
	CurrentRevisionID string  `json:"currentRevisionId"`
	Version           int64   `json:"version"`
}

type EntryRef struct {
	EntryID    string `json:"entryId"`
	RevisionID string `json:"revisionId"`
}

type EntryRevision struct {
	Source           *ContextSource `json:"source,omitempty"`
	ID               string         `json:"id"`
	EntryID          string         `json:"entryId"`
	BagID            string         `json:"bagId"`
	ParentRevisionID string         `json:"parentRevisionId,omitempty"`
	Subject          Subject        `json:"subject"`
	Value            ValueEnvelope  `json:"value"`
	CreatedAt        time.Time      `json:"createdAt"`
	Provenance       string         `json:"provenance,omitempty"`
	LegacySourceID   string         `json:"legacySourceId,omitempty"`
	SourceDigest     string         `json:"sourceDigest,omitempty"`
}

type EvidenceHandoff struct {
	ID              string `json:"id"`
	SessionID       string `json:"sessionId"`
	RunID           string `json:"runId"`
	InputSnapshotID string `json:"inputSnapshotId"`
	CaseID          string `json:"caseId"`
	DetectiveRunID  string `json:"detectiveRunId"`
	State           string `json:"state"`
	ErrorCode       string `json:"errorCode,omitempty"`
}

type InputSnapshot struct {
	ID                 string                            `json:"id"`
	SessionID          string                            `json:"sessionId"`
	ContextSetID       string                            `json:"contextSetId"`
	Scope              Scope                             `json:"scope"`
	Entries            []EntryRef                        `json:"entries"`
	DefinitionDigest   string                            `json:"definitionDigest"`
	DefinitionDocument json.RawMessage                   `json:"definitionDocument"`
	ResolvedParameters map[string]apicontract.TypedValue `json:"resolvedParameters,omitempty"`
	ParametersOrigin   string                            `json:"parametersOrigin,omitempty"`
	CreatedAt          time.Time                         `json:"createdAt"`
	Detective          *DetectiveInputPin                `json:"detective,omitempty"`
}

type KeyComponent struct {
	Field string                 `json:"field"`
	Value apicontract.TypedValue `json:"value"`
}

type LegacyChatMessage struct {
	ID        string    `json:"id"`
	Role      string    `json:"role"`
	Text      string    `json:"text"`
	CreatedAt time.Time `json:"createdAt,omitempty"`
}

type LegacyEntry struct {
	ID        string        `json:"id"`
	Alias     string        `json:"alias,omitempty"`
	Subject   Subject       `json:"subject"`
	Value     ValueEnvelope `json:"value"`
	CreatedAt time.Time     `json:"createdAt,omitempty"`
}

type LegacyImport struct {
	SourceID string              `json:"sourceId"`
	Title    string              `json:"title,omitempty"`
	Scope    Scope               `json:"scope"`
	Entries  []LegacyEntry       `json:"entries,omitempty"`
	Messages []LegacyChatMessage `json:"messages,omitempty"`
}

type LegacyImportManifest struct {
	ID           string    `json:"id"`
	SessionID    string    `json:"sessionId"`
	BagID        string    `json:"bagId"`
	SourceID     string    `json:"sourceId"`
	SourceDigest string    `json:"sourceDigest"`
	Scope        Scope     `json:"scope"`
	CreatedAt    time.Time `json:"createdAt"`
}

type Message struct {
	ID              string    `json:"id"`
	SessionID       string    `json:"sessionId"`
	InputSnapshotID string    `json:"inputSnapshotId"`
	Role            string    `json:"role"`
	Text            string    `json:"text"`
	CreatedAt       time.Time `json:"createdAt"`
	Provenance      string    `json:"provenance,omitempty"`
	LegacySourceID  string    `json:"legacySourceId,omitempty"`
	SourceDigest    string    `json:"sourceDigest,omitempty"`
	HistoricalAt    time.Time `json:"historicalAt,omitempty"`
	SourceScope     Scope     `json:"sourceScope,omitempty"`
}

type MountedDatabase interface {
	ID() string
	DB() dal.DB
}

type NativeNamespace struct {
	StorageID   string `json:"storageId"`
	SpaceID     string `json:"spaceId,omitempty"`
	DatabaseID  string `json:"databaseId"`
	ProjectID   string `json:"projectId"`
	NamespaceID string `json:"namespaceId"`
}

type Page[T any] struct {
	Items      []T    `json:"items"`
	NextCursor string `json:"nextCursor,omitempty"`
	HasMore    bool   `json:"hasMore"`
}

type PinDetectiveInputCommand struct {
	// ClientRequestDigest is host-computed from a canonical transport request.
	// Empty retains compatibility for internal callers, not transport acceptance.
	ClientRequestDigest                     string
	OpID, SessionID, InputSnapshotID, RunID string
	ExpectedVersion                         int64
	ExpectedContextSetID                    string
	Scope                                   Scope
	Attachments                             []EntryRef
	Pin                                     DetectiveInputPin
	Case                                    *detective.Case
	NativeBinding                           detective.OperationBinding
}

type PinnedDetectiveInput struct {
	Receipt Receipt
	Input   InputSnapshot
	Run     Run
}

type Principal struct {
	// Executor is set only by the server runtime when persisting an actual outcome.
	Executor   bool
	Actor      string
	DatabaseID string
	ProjectID  string
}

type Reader interface {
	Load(context.Context, string, string, any) (int64, error)
	List(context.Context, string, string, string, int) ([]json.RawMessage, string, error)
}

type Receipt struct {
	Scope           *Scope    `json:"scope,omitempty"`
	OpID            string    `json:"opId"`
	Actor           string    `json:"actor"`
	Action          string    `json:"action"`
	PayloadDigest   string    `json:"payloadDigest"`
	SessionID       string    `json:"sessionId"`
	SessionVersion  int64     `json:"sessionVersion"`
	ResourceID      string    `json:"resourceId,omitempty"`
	ResourceVersion int64     `json:"resourceVersion,omitempty"`
	At              time.Time `json:"at"`

	// RecoveryBindingDigest independently binds accepted native recovery metadata.
	RecoveryBindingDigest string `json:"recoveryBindingDigest,omitempty"`
}

type Repository interface {
	View(context.Context, func(Reader) error) error
	Transact(context.Context, func(Transaction) error) error
}

type RetainedContextBinding struct {
	Namespace                                    NativeNamespace
	LifecycleSessionID                           string
	Owner, SessionID, Collection, ID, WorkItemID string
	Active                                       bool
	Scopes                                       []Scope
	Subjects                                     []RetainedScopedSubject
	Source                                       *ContextSource
	LegacySourceID, SourceDigest                 string
}

type RetainedDetectiveExecution struct {
	Namespace          NativeNamespace
	LifecycleSessionID string
	Owner              string
	Dispatch           DetectiveDispatchBinding
	Reference          apicontract.SessionInputReference
	SessionID          string
	RunID              string
	InputSnapshotID    string
	NativeRunID        string
	Scope              Scope
	Active             bool
	HandoffActive      bool
	Definition         DetectiveCheckDefinitionPin
	// Populated by the composed source reader after exact context joins.
	Subjects []RetainedScopedSubject
}

type RetainedDocument struct {
	Collection string
	ID         string
	Owner      string
	SessionID  string
	Version    int64
	Payload    json.RawMessage
}

type RetainedInventory struct {
	Namespace NativeNamespace
	// Collections includes empty collections too. Consumers must reject any
	// collection they cannot project; silently skipping a new source is unsafe.
	Collections []string
	Documents   []RetainedDocument
}

type RetainedInventoryLimits struct {
	MaxDocuments int
	MaxBytes     int
}

type RetainedOrdinaryExecution struct {
	Namespace                                                    NativeNamespace
	LifecycleSessionID                                           string
	Owner, SessionID, RunID, InputSnapshotID, ContextSetID       string
	Kind, DefinitionID, DefinitionRevision                       string
	State, ExecutionAuthority, DefinitionDigest, ExecutionDigest string
	Scope                                                        Scope
	// Active conservatively includes client outcome-unknown: client settlement
	// clears operational pending bookkeeping but proves no source completion.
	Active                                bool
	DefinitionDocument, ExecutionDocument json.RawMessage
	Subjects                              []RetainedScopedSubject
	ResultRefs                            []string
	Widgets                               []WidgetOutcome
}

type RetainedScopedSubject struct {
	Scope   Scope
	Subject Subject
}

type RetainedSessionProvenance struct {
	Namespace                                NativeNamespace
	LifecycleSessionID                       string
	Owner, SessionID, Collection, ID, Action string
	Scopes                                   []Scope
	Resources                                []RetainedSessionResource
	LegacySourceID, SourceDigest             string
}

type RetainedSessionResource struct{ Collection, ID, SessionID string }

type RetainedSessionSources struct {
	Contexts   []RetainedContextBinding
	Native     []RetainedDetectiveExecution
	Ordinary   []RetainedOrdinaryExecution
	Provenance []RetainedSessionProvenance
}

type RetainedWrite struct {
	Before *RetainedDocument
	After  RetainedDocument
}

type RetainedWriteAdmission func(context.Context, dal.ReadwriteTransaction, NativeNamespace, []RetainedWrite) (func() error, error)

type Run struct {
	ID                 string `json:"id"`
	SessionID          string `json:"sessionId"`
	InputSnapshotID    string `json:"inputSnapshotId"`
	Kind               string `json:"kind"`
	DefinitionID       string `json:"definitionId"`
	DefinitionRevision string `json:"definitionRevision"`
	// State is accepted/completed/failed/canceled; client reportClientRun may
	// also settle uncertainty as outcome-unknown.
	State                string                             `json:"state"`
	OutcomeOrigin        string                             `json:"outcomeOrigin,omitempty"`
	ExecutionAuthority   string                             `json:"executionAuthority"`
	ExecutionDigest      string                             `json:"executionDigest,omitempty"`
	ExecutionDocument    json.RawMessage                    `json:"executionDocument,omitempty"`
	ResolvedParameters   map[string]apicontract.TypedValue  `json:"resolvedParameters,omitempty"`
	Version              int64                              `json:"version"`
	Widgets              []WidgetOutcome                    `json:"widgets,omitempty"`
	ResultRefs           []string                           `json:"resultRefs,omitempty"`
	ErrorCode            string                             `json:"errorCode,omitempty"`
	CreatedAt            time.Time                          `json:"createdAt"`
	CompletedAt          *time.Time                         `json:"completedAt,omitempty"`
	InputReference       *apicontract.SessionInputReference `json:"inputReference,omitempty"`
	DetectiveOperationID string                             `json:"detectiveOperationId,omitempty"`
}

type Scope struct {
	EnvironmentID  string `json:"environmentId"`
	IdentityDomain string `json:"identityDomain"`
}

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

type Session struct {
	// WorkItemID is immutable and can only be set by a trusted Work-bound service.
	WorkItemID      string    `json:"workItemId,omitempty"`
	SchemaVersion   int       `json:"schemaVersion"`
	ID              string    `json:"id"`
	DatabaseID      string    `json:"databaseId"`
	ProjectID       string    `json:"projectId"`
	Owner           string    `json:"owner"`
	Title           string    `json:"title"`
	State           string    `json:"state"`
	Version         int64     `json:"version"`
	DefaultBagID    string    `json:"defaultBagId"`
	ContextSetID    string    `json:"contextSetId"`
	PendingRunCount int       `json:"pendingRunCount,omitempty"`
	BagIDs          []string  `json:"bagIds"`
	CreatedAt       time.Time `json:"createdAt"`
	UpdatedAt       time.Time `json:"updatedAt"`

	// NativeFenceGeneration monotonically invalidates native claims on Stop/archive/delete.
	NativeFenceGeneration int64 `json:"nativeFenceGeneration,omitempty"`
}

type SessionRedaction struct {
	SessionID  string          `json:"sessionId"`
	Owner      string          `json:"owner"`
	Namespace  NativeNamespace `json:"namespace"`
	DeleteOpID string          `json:"deleteOpId"`
	Version    int64           `json:"version"`
	RedactedAt time.Time       `json:"redactedAt"`
}

type Snapshot struct {
	Session    Session           `json:"session"`
	Bags       []Bag             `json:"bags"`
	Entries    []Entry           `json:"entries"`
	Revisions  []EntryRevision   `json:"revisions"`
	ContextSet AppliedContextSet `json:"contextSet"`
}

type Subject struct {
	ConceptID       string   `json:"conceptId"`
	FieldID         string   `json:"fieldId"`
	FieldMappingRef string   `json:"fieldMappingRef"`
	GraphResource   string   `json:"graphResource,omitempty"`
	GraphRevision   string   `json:"graphRevision,omitempty"`
	ModelRef        string   `json:"modelRef,omitempty"`
	ModelRevision   string   `json:"modelRevision,omitempty"`
	Record          string   `json:"record,omitempty"`
	Fields          []string `json:"fields,omitempty"`
}

type Transaction interface {
	Reader
	Save(context.Context, string, string, any, int64, string, string) error
}

type ValueEnvelope struct {
	SchemaVersion int                      `json:"schemaVersion"`
	Kind          string                   `json:"kind"`
	Scalar        *apicontract.TypedValue  `json:"scalar,omitempty"`
	Values        []apicontract.TypedValue `json:"values,omitempty"`
	KeyFields     []string                 `json:"keyFields,omitempty"`
	Keys          []EntityKey              `json:"keys,omitempty"`
}

type WidgetOutcome struct {
	ID        string `json:"id"`
	State     string `json:"state"`
	ResultRef string `json:"resultRef,omitempty"`
	ErrorCode string `json:"errorCode,omitempty"`
}

type WorkBinding struct {
	WorkItemID, SessionID, IndexOwner, DatabaseID, ProjectID string
}