app

type AgentListPage struct {
	Agents  []domain.Agent
	HasNext bool
}

type AgentListQuery struct {
	CreatedAtGte    *time.Time
	CreatedAtLte    *time.Time
	IncludeArchived bool
	After           *ResourcePageBoundary
	Limit           int
}

type AgentRepository interface {
	PutVersion(context.Context, domain.Agent) error
	UpdateVersion(
		context.Context,
		string,
		func(domain.Agent) (domain.Agent, bool, error),
	) (domain.Agent, error)
	Archive(context.Context, string, time.Time) (domain.Agent, error)
	Latest(context.Context, string) (domain.Agent, error)
	GetVersion(context.Context, string, int) (domain.Agent, error)
	Versions(context.Context, string, AgentVersionListQuery) (AgentVersionListPage, error)
	ListLatest(context.Context, AgentListQuery) (AgentListPage, error)
}

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

type AgentVersionListPage struct {
	Versions []domain.Agent
	HasNext  bool
}

type AgentVersionListQuery struct {
	AfterVersion int
	Limit        int
}

type BlobCleanupIntent struct {
	BlobKey  string
	Revision int64
}

type BlobCleanupRepository interface {
	RetainBlobCleanup(context.Context, string, bool) (BlobCleanupIntent, error)
	TouchBlobCleanup(context.Context, BlobCleanupIntent) error
	ListBlobCleanup(context.Context) ([]BlobCleanupIntent, error)
	RemoveBlobCleanup(context.Context, BlobCleanupIntent) error
}

type BlobInfo struct {
	SizeBytes      int64
	ChecksumSHA256 string
}

type BlobStore interface {
	Put(context.Context, string, string, io.Reader, int64) (BlobInfo, error)
	Open(context.Context, string) (io.ReadCloser, error)
	Delete(context.Context, string) error
}

type CreateSessionInput struct {
	AgentID         string
	AgentVersion    *int
	Overrides       *domain.AgentOverrides
	EnvironmentID   string
	Title           string
	Metadata        map[string]any
	InitialEvents   []domain.EventDraft
	MemoryResources []MemorySessionResourceInput
	VaultIDs        []string
	Budget          *domain.SessionBudget
	DeploymentID    *string
	DeploymentRun   *domain.DeploymentRun
}

type CredentialAuthCreateInput struct {
	Type         string
	MCPServerURL string
	Token        string
	AccessToken  string
	ExpiresAt    *time.Time
	Refresh      *OAuthRefreshCreateInput
}

type CredentialAuthUpdateInput struct {
	Type        string
	Token       NullablePatch[string]
	AccessToken NullablePatch[string]
	ExpiresAt   NullablePatch[time.Time]
	Refresh     NullablePatch[OAuthRefreshUpdateInput]
}

type CredentialCreateInput struct {
	DisplayName *string
	Metadata    map[string]string
	Auth        CredentialAuthCreateInput
}

type CredentialListPage struct {
	Credentials []domain.VaultCredential
	HasNext     bool
}

type CredentialListQuery struct {
	IncludeArchived bool
	After           *ResourcePageBoundary
	Limit           int
}

type CredentialRefreshValidation struct {
	Status       credentialruntime.OAuthRefreshStatus `json:"status"`
	HTTPResponse *credentialruntime.HTTPResponse      `json:"http_response"`
}

type CredentialUpdateInput struct {
	DisplayName NullablePatch[string]
	Metadata    NullablePatch[map[string]*string]
	Auth        *CredentialAuthUpdateInput
}

type CredentialValidation struct {
	CredentialID    string
	VaultID         string
	ValidatedAt     time.Time
	HasRefreshToken bool
	Status          credentialruntime.Verdict
	MCPProbe        *credentialruntime.MCPProbeFailure
	Refresh         *CredentialRefreshValidation
}

type DeploymentCreateInput struct {
	AgentID       string
	AgentVersion  *int
	EnvironmentID string
	Name          string
	Description   string
	InitialEvents []domain.EventDraft
	Resources     []domain.DeploymentResource
	VaultIDs      []string
	Budget        *domain.SessionBudget
	Metadata      map[string]string
	Schedule      *domain.DeploymentSchedule
}

type DeploymentListBoundary struct {
	CreatedAt time.Time
	ID        string
}

type DeploymentListPage struct {
	Deployments []domain.Deployment
	HasMore     bool
}

type DeploymentListQuery struct {
	AgentID         string
	CreatedAtGte    *time.Time
	CreatedAtLte    *time.Time
	IncludeArchived bool
	Status          string
	Boundary        *DeploymentListBoundary
	Limit           int
}

type DeploymentMemoryReader interface {
	GetStore(context.Context, string) (domain.MemoryStore, error)
}

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

type DeploymentRepository interface {
	Create(context.Context, domain.Deployment) (domain.Deployment, error)
	Get(context.Context, string) (domain.Deployment, error)
	Update(
		context.Context,
		string,
		func(domain.Deployment) (domain.Deployment, bool, error),
	) (domain.Deployment, error)
	List(context.Context, DeploymentListQuery) (DeploymentListPage, error)
	CreateRun(context.Context, domain.DeploymentRun) (domain.DeploymentRun, error)
	GetRun(context.Context, string) (domain.DeploymentRun, error)
	GetScheduledRun(context.Context, string, time.Time) (domain.DeploymentRun, error)
	ListRuns(context.Context, DeploymentRunListQuery) (DeploymentRunListPage, error)
	ClaimDue(context.Context, time.Time, time.Time, string, int) ([]DeploymentScheduleClaim, error)
	RenewScheduleClaim(context.Context, string, time.Time, string, time.Time) error
	CompleteSchedule(
		context.Context,
		string,
		time.Time,
		time.Time,
		[]time.Time,
	) error
}

type DeploymentRunListBoundary struct {
	CreatedAt time.Time
	ID        string
}

type DeploymentRunListPage struct {
	Runs    []domain.DeploymentRun
	HasMore bool
}

type DeploymentRunListQuery struct {
	CreatedAtGt  *time.Time
	CreatedAtGte *time.Time
	CreatedAtLt  *time.Time
	CreatedAtLte *time.Time
	DeploymentID *string
	HasError     *bool
	TriggerType  string
	Boundary     *DeploymentRunListBoundary
	Limit        int
}

type DeploymentScheduleClaim struct {
	WorkspaceID  string
	DeploymentID string
	ScheduledAt  time.Time
	Token        string
}

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

type DeploymentServiceConfig struct {
	Repository   DeploymentRepository
	Agents       AgentRepository
	Environments EnvironmentRepository
	Sessions     DeploymentSessionCreator
	Memory       DeploymentMemoryReader
	Vaults       DeploymentVaultReader
	IDGenerator  domain.IDGenerator
	Clock        domain.Clock
}

type DeploymentSessionCreator interface {
	Create(context.Context, CreateSessionInput) (domain.Session, error)
}

type DeploymentVaultReader interface {
	GetVault(context.Context, string) (domain.Vault, error)
}

type EnvironmentListPage struct {
	Environments []domain.Environment
	HasNext      bool
}

type EnvironmentListQuery struct {
	IncludeArchived bool
	After           *ResourcePageBoundary
	Limit           int
}

type EnvironmentRepository interface {
	Put(context.Context, domain.Environment) error
	Update(context.Context, domain.Environment) (domain.Environment, error)
	Archive(context.Context, string, time.Time) (domain.Environment, error)
	Get(context.Context, string) (domain.Environment, error)
	List(context.Context, EnvironmentListQuery) (EnvironmentListPage, error)
	DeleteIfUnreferenced(context.Context, string) error
}

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

type EnvironmentWorkListPage struct {
	Work    []domain.EnvironmentWork
	HasNext bool
}

type EnvironmentWorkListQuery struct {
	After *ResourcePageBoundary
	Limit int
}

type EnvironmentWorkPollInput struct {
	WorkerID   string
	ReclaimAge time.Duration
}

type EnvironmentWorkRepository interface {
	CreateHealthcheck(context.Context, string) (domain.EnvironmentWork, error)
	CompleteHealthcheck(context.Context, string, string, domain.EnvironmentWorkResult) (domain.EnvironmentWork, error)
	GetWork(context.Context, string, string) (domain.EnvironmentWork, error)
	UpdateWorkMetadata(context.Context, string, string, map[string]*string) (domain.EnvironmentWork, error)
	ListWork(context.Context, string, EnvironmentWorkListQuery) (EnvironmentWorkListPage, error)
	PollWork(context.Context, string, EnvironmentWorkPollInput) (*domain.EnvironmentWork, error)
	AckWork(context.Context, string, string) (domain.EnvironmentWork, error)
	HeartbeatWork(context.Context, string, string, *string, *int64) (domain.EnvironmentWorkHeartbeat, error)
	FailWork(context.Context, string, string, string) error
	StopWork(context.Context, string, string, bool, *string) error
	WorkStats(context.Context, string) (domain.EnvironmentWorkQueueStats, error)
}

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

type EventPageBoundary struct {
	ProcessedAt *time.Time
	Sequence    int64
}

type EventQuery struct {
	// ThreadID selects one Thread ledger. Empty means the primary Thread, which
	// is the public Session event surface.
	ThreadID       string
	Boundary       *EventPageBoundary
	Limit          int
	Desc           bool
	Types          []string
	ProcessedAtGt  *time.Time
	ProcessedAtGte *time.Time
	ProcessedAtLt  *time.Time
	ProcessedAtLte *time.Time
}

type FileBlobStore = BlobStore

type FileDownload struct {
	File domain.File
	Body io.ReadCloser
}

type FileListPage struct {
	Files   []domain.File
	HasMore bool
}

type FileListQuery struct {
	AfterID  string
	BeforeID string
	Limit    int
}

type FileRepository interface {
	BlobCleanupRepository
	BeginUpload(context.Context, domain.File) error
	CompleteUpload(context.Context, string, BlobInfo) (domain.File, error)
	RenewUpload(context.Context, string) error
	ReleaseUpload(context.Context, string, string, bool) error
	Get(context.Context, string) (domain.File, error)
	List(context.Context, FileListQuery) (FileListPage, error)
	BeginDelete(context.Context, string) (domain.File, error)
	RemoveIncomplete(context.Context, string) error
	ListIncomplete(context.Context) ([]domain.File, error)
	ClaimIncomplete(context.Context, string) (domain.File, bool, error)
}

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

type FileUploadInput struct {
	Filename string
	MimeType string
	Body     io.Reader
}

type Frame struct {
	Event   *domain.Event
	Preview *domain.PreviewFrame
}

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

type ListPage struct {
	AgentID         string
	AgentVersion    *int
	CreatedAtGt     *time.Time
	CreatedAtGte    *time.Time
	CreatedAtLt     *time.Time
	CreatedAtLte    *time.Time
	IncludeArchived bool
	Statuses        []domain.Status
	DeploymentID    *string
	MemoryStoreID   *string
	Boundary        *SessionPageBoundary
	Limit           int
	Desc            bool
}

type MemoryCreateInput struct {
	Path    string
	Content string
	Actor   domain.MemoryActor
}

type MemoryListPage struct {
	Items   []domain.MemoryListItem
	HasNext bool
}

type MemoryListQuery struct {
	PathPrefix string
	Depth      int
	AfterPath  string
	Limit      int
	Full       bool
}

type MemoryRepository interface {
	CreateStore(context.Context, domain.MemoryStore) (domain.MemoryStore, error)
	GetStore(context.Context, string) (domain.MemoryStore, error)
	UpdateStore(context.Context, string, MemoryStoreUpdateInput, domain.Clock) (domain.MemoryStore, error)
	ListStores(context.Context, MemoryStoreListQuery) (MemoryStoreListPage, error)
	ArchiveStore(context.Context, string, domain.Clock) (domain.MemoryStore, error)
	DeleteStore(context.Context, string) error

	CreateMemory(context.Context, domain.Memory, domain.MemoryVersion) (domain.Memory, error)
	GetMemory(context.Context, string, string) (domain.Memory, error)
	ListMemoryHeads(context.Context, string, string) ([]domain.Memory, error)
	UpdateMemory(context.Context, string, string, MemoryUpdateInput, string, domain.Clock) (domain.Memory, error)
	DeleteMemory(context.Context, string, string, *string, domain.MemoryActor, string, domain.Clock) (domain.Memory, error)

	GetMemoryVersion(context.Context, string, string) (domain.MemoryVersion, error)
	ListMemoryVersions(context.Context, string, MemoryVersionListQuery) (MemoryVersionListPage, error)
	RedactMemoryVersion(context.Context, string, string, domain.MemoryActor, domain.Clock) (domain.MemoryVersion, error)
	SyncMemoryStore(context.Context, string, []MemoryStoreSyncBaseline, []MemoryStoreSyncContent, domain.MemoryActor, domain.IDGenerator, domain.Clock) ([]domain.Memory, error)
}

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

type MemorySessionResourceInput struct {
	MemoryStoreID string
	Access        string
	Instructions  string
}

type MemoryStoreCreateInput struct {
	Name        string
	Description string
	Metadata    map[string]string
}

type MemoryStoreListPage struct {
	Stores  []domain.MemoryStore
	HasNext bool
}

type MemoryStoreListQuery struct {
	CreatedAtGte    *time.Time
	CreatedAtLte    *time.Time
	IncludeArchived bool
	After           *ResourcePageBoundary
	Limit           int
}

type MemoryStoreSyncBaseline struct {
	MemoryID      string
	Path          string
	ContentSHA256 string
}

type MemoryStoreSyncContent struct {
	Path    string
	Content string
}

type MemoryStoreUpdateInput struct {
	Name        *string
	Description *string
	Metadata    map[string]*string
}

type MemoryUpdateInput struct {
	Path               *string
	Content            *string
	ExpectedContentSHA *string
	Actor              domain.MemoryActor
}

type MemoryVersionListPage struct {
	Versions []domain.MemoryVersion
	HasNext  bool
}

type MemoryVersionListQuery struct {
	APIKeyID     string
	SessionID    string
	MemoryID     string
	Operation    string
	CreatedAtGte *time.Time
	CreatedAtLte *time.Time
	After        *ResourcePageBoundary
	Limit        int
}

type NullablePatch[T any] struct {
	Present bool
	Value   *T
}

type OAuthRefreshCreateInput struct {
	ClientID          string
	RefreshToken      string
	TokenEndpoint     string
	TokenEndpointAuth string
	ClientSecret      *string
	Resource          *string
	Scope             *string
}

type OAuthRefreshUpdateInput struct {
	RefreshToken      NullablePatch[string]
	Scope             NullablePatch[string]
	TokenEndpointAuth *OAuthTokenEndpointAuthUpdateInput
}

type OAuthTokenEndpointAuthUpdateInput struct {
	Type         string
	ClientSecret NullablePatch[string]
}

type PreparedSessionResource struct {
	Resource domain.SessionResource
}

type ResourcePageBoundary struct {
	CreatedAt time.Time
	ID        string
}

type ScheduledDeploymentRunner interface {
	ClaimDue(context.Context, int) ([]DeploymentScheduleClaim, error)
	RenewClaim(context.Context, DeploymentScheduleClaim) error
	RunScheduled(context.Context, string, time.Time) (domain.DeploymentRun, error)
}

type SessionListPage struct {
	Sessions []domain.Session
	HasPrev  bool
	HasNext  bool
}

type SessionPageBoundary struct {
	CreatedAt time.Time
	ID        string
	Backward  bool
}

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

type SessionSkillMountRepository interface {
	SessionSkillsForRuntime(context.Context, string) ([]domain.SkillVersion, error)
}

type SessionThreadListQuery struct {
	Limit    int
	Boundary *SessionThreadPageBoundary
	Statuses []domain.Status
}

type SessionThreadPageBoundary struct {
	CreatedAt time.Time
	ID        string
}

type SessionThreadSkillMountRepository interface {
	SessionThreadSkillRuntime(
		context.Context,
		string,
		string,
	) (domain.SkillRuntime, error)
}

type SkillCreateInput struct {
	DisplayTitle *string
	Files        []SkillUploadFile
}

type SkillListPage struct {
	Skills  []domain.Skill
	HasNext bool
}

type SkillListQuery struct {
	Source string
	After  *ResourcePageBoundary
	Limit  int
}

type SkillReferenceResolver interface {
	ResolveSkillReferences(
		context.Context,
		[]domain.SkillReference,
	) ([]domain.SkillReference, error)
}

type SkillRepository interface {
	BlobCleanupRepository
	BeginSkill(context.Context, domain.Skill, domain.SkillVersion) error
	BeginVersion(context.Context, domain.SkillVersion) error
	CompleteVersion(context.Context, string, string, string, BlobInfo) (domain.Skill, domain.SkillVersion, error)
	RenewUpload(context.Context, string, string, string) error
	ReleaseUpload(context.Context, string, string, string, bool) error
	GetSkill(context.Context, string) (domain.Skill, error)
	ListSkills(context.Context, SkillListQuery) (SkillListPage, error)
	GetVersion(context.Context, string, string) (domain.SkillVersion, error)
	ListVersions(context.Context, string, SkillVersionListQuery) (SkillVersionListPage, error)
	BeginDeleteVersion(context.Context, string, string) (domain.SkillVersion, error)
	RemoveIncompleteVersion(context.Context, string, string, string) error
	ListIncompleteVersions(context.Context) ([]domain.SkillVersion, error)
	ClaimIncompleteVersion(context.Context, string, string) (domain.SkillVersion, bool, error)
	DeleteEmptySkill(context.Context, string) error
	DeleteSkill(context.Context, string) (domain.Skill, error)
}

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

type SkillUploadFile struct {
	Filename string
	Body     []byte
}

type SkillVersionDownload struct {
	Version domain.SkillVersion
	Body    io.ReadCloser
}

type SkillVersionListPage struct {
	Versions []domain.SkillVersion
	HasNext  bool
}

type SkillVersionListQuery struct {
	After *ResourcePageBoundary
	Limit int
}

type VaultCreateInput struct {
	DisplayName string
	Metadata    map[string]string
}

type VaultListPage struct {
	Vaults  []domain.Vault
	HasNext bool
}

type VaultListQuery struct {
	IncludeArchived bool
	After           *ResourcePageBoundary
	Limit           int
}

type VaultRepository interface {
	CreateVault(context.Context, domain.Vault) (domain.Vault, error)
	GetVault(context.Context, string) (domain.Vault, error)
	UpdateVault(context.Context, string, VaultUpdateInput, domain.Clock) (domain.Vault, error)
	ListVaults(context.Context, VaultListQuery) (VaultListPage, error)
	ArchiveVault(context.Context, string, domain.Clock) (domain.Vault, error)
	DeleteVault(context.Context, string) error

	CreateCredential(context.Context, domain.VaultCredential, int) (domain.VaultCredential, error)
	GetCredential(context.Context, string, string) (domain.VaultCredential, error)
	UpdateCredential(context.Context, string, string, func(domain.VaultCredential) (domain.VaultCredential, bool, error)) (domain.VaultCredential, error)
	ListCredentials(context.Context, string, CredentialListQuery) (CredentialListPage, error)
	ArchiveCredential(context.Context, string, string, domain.Clock) (domain.VaultCredential, error)
	DeleteCredential(context.Context, string, string) error
}

type VaultRuntimeRepository interface {
	ResolveSessionCredentials(context.Context, string) ([]domain.VaultCredential, error)
}

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

type VaultServiceConfig struct {
	Repository     VaultRepository
	Cipher         secretcrypto.Cipher
	IDGenerator    domain.IDGenerator
	Clock          domain.Clock
	OAuthRefresher credentialruntime.OAuthRefresher
	MCPValidator   credentialruntime.MCPValidator
}

type VaultUpdateInput struct {
	DisplayName NullablePatch[string]
	Metadata    NullablePatch[map[string]*string]
}

type WebhookCreateInput struct {
	URL        string
	EventTypes []string
}

type WebhookDeliveryRepository interface {
	ClaimWebhookDeliveries(
		context.Context, time.Time, time.Time, string, int,
	) ([]domain.WebhookDelivery, error)
	CompleteWebhookDelivery(context.Context, WebhookDeliveryResult) (bool, error)
	CleanupWebhookEvents(context.Context, time.Time, int) (int64, error)
}

type WebhookDeliveryResult struct {
	WebhookID      string
	EventID        string
	ClaimID        string
	AttemptedAt    time.Time
	CompletedAt    time.Time
	Succeeded      bool
	ResponseStatus *int
	Error          string
	NextAttemptAt  *time.Time
	DisableReason  *string
}

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

type WebhookHTTPDoer interface {
	Do(*http.Request) (*http.Response, error)
}

type WebhookListPage struct {
	Webhooks []domain.Webhook
	HasNext  bool
}

type WebhookListQuery struct {
	After *ResourcePageBoundary
	Limit int
}

type WebhookRepository interface {
	CreateWebhook(context.Context, domain.Webhook, int) (domain.Webhook, error)
	GetWebhook(context.Context, string) (domain.Webhook, error)
	UpdateWebhook(context.Context, string, func(domain.Webhook) (domain.Webhook, bool, error)) (domain.Webhook, error)
	ListWebhooks(context.Context, WebhookListQuery) (WebhookListPage, error)
	DeleteWebhook(context.Context, string) error
}

type WebhookSecretResult struct {
	Webhook       domain.Webhook
	SigningSecret string
}

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

type WebhookUpdateInput struct {
	URL        *string
	EventTypes *[]string
	Status     *domain.WebhookStatus
}