httpapi

type AgentService interface {
	Create(context.Context, domain.Agent) (domain.Agent, error)
	Get(context.Context, string) (domain.Agent, error)
	List(context.Context, app.AgentListQuery) (app.AgentListPage, error)
	Versions(context.Context, string, app.AgentVersionListQuery) (app.AgentVersionListPage, error)
	Update(context.Context, string, domain.AgentPatch) (domain.Agent, error)
	Archive(context.Context, string) (domain.Agent, error)
}

type Config struct {
	RequireAuth   bool
	Authenticator WorkspaceAuthenticator
}

type DeploymentService interface {
	Create(context.Context, app.DeploymentCreateInput) (domain.Deployment, error)
	Get(context.Context, string) (domain.Deployment, error)
	Update(context.Context, string, domain.DeploymentPatch) (domain.Deployment, error)
	List(context.Context, app.DeploymentListQuery) (app.DeploymentListPage, error)
	Archive(context.Context, string) (domain.Deployment, error)
	Pause(context.Context, string) (domain.Deployment, error)
	Unpause(context.Context, string) (domain.Deployment, error)
	Run(context.Context, string) (domain.DeploymentRun, error)
	GetRun(context.Context, string) (domain.DeploymentRun, error)
	ListRuns(context.Context, app.DeploymentRunListQuery) (app.DeploymentRunListPage, error)
}

type Deps struct {
	// Readiness must honor cancellation; production uses the API PostgreSQL pool.
	Readiness       func(context.Context) error
	Agents          AgentService
	Envs            EnvironmentService
	Sessions        SessionService
	Threads         SessionThreadService
	Events          EventService
	Stream          EventSubscriber
	Files           FileService
	Skills          SkillService
	Memory          MemoryService
	Vaults          VaultService
	Webhooks        WebhookService
	Deployments     DeploymentService
	EnvironmentWork EnvironmentWorkService
}

type EnvironmentKeyAuthenticator interface {
	AuthenticateEnvironmentKey(context.Context, string) (string, workspace.EnvironmentScope, error)
}

type EnvironmentService interface {
	Create(context.Context, domain.Environment) (domain.Environment, error)
	Update(context.Context, string, domain.EnvironmentPatch) (domain.Environment, error)
	Get(context.Context, string) (domain.Environment, error)
	List(context.Context, app.EnvironmentListQuery) (app.EnvironmentListPage, error)
	Archive(context.Context, string) (domain.Environment, error)
	Delete(context.Context, string) error
}

type EnvironmentWorkService interface {
	CreateHealthcheck(context.Context, string) (domain.EnvironmentWork, error)
	CompleteHealthcheck(context.Context, string, string, domain.EnvironmentWorkResult) (domain.EnvironmentWork, error)
	Get(context.Context, string, string) (domain.EnvironmentWork, error)
	Update(context.Context, string, string, map[string]*string) (domain.EnvironmentWork, error)
	List(context.Context, string, app.EnvironmentWorkListQuery) (app.EnvironmentWorkListPage, error)
	Ack(context.Context, string, string) (domain.EnvironmentWork, error)
	Heartbeat(context.Context, string, string, *string, *int64) (domain.EnvironmentWorkHeartbeat, error)
	Fail(context.Context, string, string, string) error
	Poll(context.Context, string, string, time.Duration, *time.Duration) (*domain.EnvironmentWork, error)
	Stop(context.Context, string, string, bool, *string) error
	Stats(context.Context, string) (domain.EnvironmentWorkQueueStats, error)
}

type EventService interface {
	Query(context.Context, string, app.EventQuery) ([]domain.Event, error)
}

type EventSubscriber interface {
	SubscribeContext(context.Context, string, map[string]bool) (<-chan app.Frame, func(), error)
}

type FileService interface {
	Upload(context.Context, app.FileUploadInput) (domain.File, error)
	Get(context.Context, string) (domain.File, error)
	List(context.Context, app.FileListQuery) (app.FileListPage, error)
	Download(context.Context, string) (app.FileDownload, error)
	Delete(context.Context, string) (domain.File, error)
}

type MemoryService interface {
	CreateStore(context.Context, app.MemoryStoreCreateInput) (domain.MemoryStore, error)
	GetStore(context.Context, string) (domain.MemoryStore, error)
	UpdateStore(context.Context, string, app.MemoryStoreUpdateInput) (domain.MemoryStore, error)
	ListStores(context.Context, app.MemoryStoreListQuery) (app.MemoryStoreListPage, error)
	ArchiveStore(context.Context, string) (domain.MemoryStore, error)
	DeleteStore(context.Context, string) error
	CreateMemory(context.Context, string, app.MemoryCreateInput) (domain.Memory, error)
	GetMemory(context.Context, string, string) (domain.Memory, error)
	ListMemories(context.Context, string, app.MemoryListQuery) (app.MemoryListPage, error)
	UpdateMemory(context.Context, string, string, app.MemoryUpdateInput) (domain.Memory, error)
	DeleteMemory(context.Context, string, string, *string, domain.MemoryActor) (domain.Memory, error)
	GetMemoryVersion(context.Context, string, string) (domain.MemoryVersion, error)
	ListMemoryVersions(context.Context, string, app.MemoryVersionListQuery) (app.MemoryVersionListPage, error)
	RedactMemoryVersion(context.Context, string, string, domain.MemoryActor) (domain.MemoryVersion, error)
}

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

type SessionScopeValidator interface {
	ValidateSessionScope(context.Context, workspace.SessionScope) error
}

type SessionService interface {
	Create(context.Context, app.CreateSessionInput) (domain.Session, error)
	Get(context.Context, string) (domain.Session, error)
	List(context.Context, app.ListPage) (app.SessionListPage, error)
	SendEvent(context.Context, string, []domain.EventDraft) ([]domain.Event, error)
	Update(context.Context, string, domain.SessionUpdate) (domain.Session, error)
	Archive(context.Context, string) (domain.Session, error)
	Delete(context.Context, string) error
}

type SessionThreadService interface {
	Get(context.Context, string, string) (domain.SessionThread, error)
	List(context.Context, string, app.SessionThreadListQuery) ([]domain.SessionThread, error)
	Archive(context.Context, string, string) (domain.SessionThread, error)
}

type SessionTokenAuthenticator interface {
	AuthenticateSessionToken(context.Context, string) (string, workspace.SessionScope, error)
}

type SkillService interface {
	Create(context.Context, app.SkillCreateInput) (domain.Skill, error)
	Get(context.Context, string) (domain.Skill, error)
	List(context.Context, app.SkillListQuery) (app.SkillListPage, error)
	Delete(context.Context, string) (domain.Skill, error)
	CreateVersion(context.Context, string, []app.SkillUploadFile) (domain.SkillVersion, error)
	GetVersion(context.Context, string, string) (domain.SkillVersion, error)
	ListVersions(context.Context, string, app.SkillVersionListQuery) (app.SkillVersionListPage, error)
	DeleteVersion(context.Context, string, string) (domain.SkillVersion, error)
	Download(context.Context, string, string) (app.SkillVersionDownload, error)
}

type ThreadEventSubscriber interface {
	SubscribeThreadContext(
		context.Context, string, string, map[string]bool,
	) (<-chan app.Frame, func(), error)
}

type VaultService interface {
	CreateVault(context.Context, app.VaultCreateInput) (domain.Vault, error)
	GetVault(context.Context, string) (domain.Vault, error)
	UpdateVault(context.Context, string, app.VaultUpdateInput) (domain.Vault, error)
	ListVaults(context.Context, app.VaultListQuery) (app.VaultListPage, error)
	ArchiveVault(context.Context, string) (domain.Vault, error)
	DeleteVault(context.Context, string) error
	CreateCredential(context.Context, string, app.CredentialCreateInput) (domain.VaultCredential, error)
	GetCredential(context.Context, string, string) (domain.VaultCredential, error)
	UpdateCredential(context.Context, string, string, app.CredentialUpdateInput) (domain.VaultCredential, error)
	ListCredentials(context.Context, string, app.CredentialListQuery) (app.CredentialListPage, error)
	ArchiveCredential(context.Context, string, string) (domain.VaultCredential, error)
	DeleteCredential(context.Context, string, string) error
	ValidateMCPOAuthCredential(context.Context, string, string) (app.CredentialValidation, error)
}

type WebhookService interface {
	CreateWebhook(context.Context, app.WebhookCreateInput) (app.WebhookSecretResult, error)
	GetWebhook(context.Context, string) (domain.Webhook, error)
	UpdateWebhook(context.Context, string, app.WebhookUpdateInput) (domain.Webhook, error)
	ListWebhooks(context.Context, app.WebhookListQuery) (app.WebhookListPage, error)
	RegenerateSigningSecret(context.Context, string) (app.WebhookSecretResult, error)
	DeleteWebhook(context.Context, string) error
}

type WorkspaceAuthenticator interface {
	AuthenticateAPIKey(context.Context, string) (string, error)
}