types

type AgentAttemptStatus string

type AgentExecutionInstance struct {
	ID                         string                       `json:"id" db:"id"`
	InstanceKey                string                       `json:"instance_key" db:"instance_key"`
	WorkspaceID                uint                         `json:"workspace_id" db:"workspace_id"`
	AgentID                    *string                      `json:"agent_id,omitempty" db:"agent_id"`
	Lane                       *string                      `json:"lane,omitempty" db:"lane"`
	ExecutionClassKey          string                       `json:"execution_class_key" db:"execution_class_key"`
	PoolName                   string                       `json:"pool_name" db:"pool_name"`
	Active                     bool                         `json:"active" db:"active"`
	Status                     AgentExecutionInstanceStatus `json:"status" db:"status"`
	FailedAttemptThreshold     int                          `json:"failed_attempt_threshold" db:"failed_attempt_threshold"`
	DesiredDispatchConcurrency int                          `json:"desired_dispatch_concurrency" db:"desired_dispatch_concurrency"`
	RunningAttempts            int                          `json:"running_attempts" db:"running_attempts"`
	PendingAttempts            int                          `json:"pending_attempts" db:"pending_attempts"`
	StoppingAttempts           int                          `json:"stopping_attempts" db:"stopping_attempts"`
	LastEventAt                *time.Time                   `json:"last_event_at,omitempty" db:"last_event_at"`
	CreatedAt                  time.Time                    `json:"created_at" db:"created_at"`
	UpdatedAt                  time.Time                    `json:"updated_at" db:"updated_at"`
}

type AgentExecutionInstanceStatus string

type AgentProfile struct {
	ID            string         `json:"id" db:"id"`
	WorkspaceID   uint           `json:"workspace_id" db:"workspace_id"`
	AgentKey      string         `json:"agent_key" db:"agent_key"`
	Name          string         `json:"name" db:"name"`
	Role          string         `json:"role" db:"role"`
	MemoryScope   string         `json:"memory_scope" db:"memory_scope"`
	QualityScore  *float64       `json:"quality_score,omitempty" db:"quality_score"`
	CostBudgetUSD *float64       `json:"cost_budget_usd,omitempty" db:"cost_budget_usd"`
	ConfigJSON    map[string]any `json:"config_json" db:"-"`
	Active        bool           `json:"active" db:"active"`
	CreatedAt     time.Time      `json:"created_at" db:"created_at"`
	UpdatedAt     time.Time      `json:"updated_at" db:"updated_at"`
}

type AgentQueueMode string

type AgentRun struct {
	ID                string         `json:"id" db:"id"`
	WorkspaceID       uint           `json:"workspace_id" db:"workspace_id"`
	AgentID           *string        `json:"agent_id,omitempty" db:"agent_id"`
	CreatedByMemberID *uint          `json:"created_by_member_id,omitempty" db:"created_by_member_id"`
	OriginTaskID      string         `json:"origin_task_id" db:"origin_task_id"`
	HookID            *uint          `json:"hook_id,omitempty" db:"hook_id"`
	Status            AgentRunStatus `json:"status" db:"status"`
	SessionID         string         `json:"session_id" db:"session_id"`
	SessionKey        *string        `json:"session_key,omitempty" db:"session_key"`
	Provider          *string        `json:"provider,omitempty" db:"provider"`
	Model             *string        `json:"model,omitempty" db:"model"`
	ExecHost          string         `json:"exec_host" db:"exec_host"`
	ExecSecurity      string         `json:"exec_security" db:"exec_security"`
	ExecAsk           string         `json:"exec_ask" db:"exec_ask"`
	RuntimeType       string         `json:"runtime_type" db:"runtime_type"`
	WorkspaceAccess   string         `json:"workspace_access" db:"workspace_access"`
	NetworkEnabled    bool           `json:"network_enabled" db:"network_enabled"`
	Interactive       bool           `json:"interactive" db:"interactive"`
	TimeoutMs         int            `json:"timeout_ms" db:"timeout_ms"`
	StartedAt         *time.Time     `json:"started_at,omitempty" db:"started_at"`
	EndedAt           *time.Time     `json:"ended_at,omitempty" db:"ended_at"`
	ClaimedByWorker   *string        `json:"claimed_by_worker_id,omitempty" db:"claimed_by_worker_id"`
	ClaimHeartbeatAt  *time.Time     `json:"claim_heartbeat_at,omitempty" db:"claim_heartbeat_at"`
	ClaimExpiresAt    *time.Time     `json:"claim_expires_at,omitempty" db:"claim_expires_at"`
	Error             *string        `json:"error,omitempty" db:"error"`
	SnapshotTS        int64          `json:"snapshot_ts" db:"snapshot_ts"`
	CostUSD           float64        `json:"cost_usd" db:"cost_usd"`
	UsageJSON         map[string]any `json:"usage_json" db:"-"`
	DeliveryJSON      map[string]any `json:"delivery_json" db:"-"`
	CreatedAt         time.Time      `json:"created_at" db:"created_at"`
	UpdatedAt         time.Time      `json:"updated_at" db:"updated_at"`
}

type AgentRunAttempt struct {
	ID              string             `json:"id" db:"id"`
	RunID           string             `json:"run_id" db:"run_id"`
	AttemptNo       int                `json:"attempt_no" db:"attempt_no"`
	Status          AgentAttemptStatus `json:"status" db:"status"`
	Strategy        string             `json:"strategy" db:"strategy"`
	Provider        *string            `json:"provider,omitempty" db:"provider"`
	Model           *string            `json:"model,omitempty" db:"model"`
	ExecHost        string             `json:"exec_host" db:"exec_host"`
	ExecSecurity    string             `json:"exec_security" db:"exec_security"`
	ExecAsk         string             `json:"exec_ask" db:"exec_ask"`
	RuntimeType     string             `json:"runtime_type" db:"runtime_type"`
	WorkspaceAccess string             `json:"workspace_access" db:"workspace_access"`
	NetworkEnabled  bool               `json:"network_enabled" db:"network_enabled"`
	Interactive     bool               `json:"interactive" db:"interactive"`
	ExecutionID     *string            `json:"execution_id,omitempty" db:"execution_task_external_id"`
	StartedAt       *time.Time         `json:"started_at,omitempty" db:"started_at"`
	EndedAt         *time.Time         `json:"ended_at,omitempty" db:"ended_at"`
	ExitCode        *int               `json:"exit_code,omitempty" db:"exit_code"`
	Error           *string            `json:"error,omitempty" db:"error"`
	CreatedAt       time.Time          `json:"created_at" db:"created_at"`
	UpdatedAt       time.Time          `json:"updated_at" db:"updated_at"`
}

type AgentRunEventType string

type AgentRunListFilter struct {
	AgentID       *string
	TaskID        *string
	Statuses      []AgentRunStatus
	SessionID     *string
	CreatedAfter  *time.Time
	CreatedBefore *time.Time
	UpdatedAfter  *time.Time
	UpdatedBefore *time.Time
	Limit         int
	Offset        int
}

type AgentRunSnapshot struct {
	ID          int64          `json:"id" db:"id"`
	RunID       string         `json:"run_id" db:"run_id"`
	Seq         int64          `json:"seq" db:"seq"`
	Status      AgentRunStatus `json:"status" db:"status"`
	StartedAtMs *int64         `json:"started_at_ms,omitempty" db:"started_at_ms"`
	EndedAtMs   *int64         `json:"ended_at_ms,omitempty" db:"ended_at_ms"`
	Error       *string        `json:"error,omitempty" db:"error"`
	TS          int64          `json:"ts" db:"ts"`
	PayloadJSON map[string]any `json:"payload_json" db:"-"`
	CreatedAt   time.Time      `json:"created_at" db:"created_at"`
}

type AgentRunStatus string

type AgentStats struct {
	Total          int            `json:"total"`
	ByState        map[string]int `json:"by_state"`
	AvgRunSec      *float64       `json:"avg_run_sec,omitempty"`
	QualityScore   *float64       `json:"quality_score,omitempty"`
	TotalCostUSD   float64        `json:"total_cost_usd"`
	RunningCount   int            `json:"running_count"`
	CompletedCount int            `json:"completed_count"`
	FailedCount    int            `json:"failed_count"`
}

type AgentTask struct {
	ID               string                `json:"id" db:"id"`
	WorkspaceID      uint                  `json:"workspace_id" db:"workspace_id"`
	AgentID          *string               `json:"agent_id,omitempty" db:"agent_id"`
	AgentName        string                `json:"agent_name,omitempty" db:"-"`
	QueueMode        AgentQueueMode        `json:"queue_mode" db:"queue_mode"`
	State            AgentTaskState        `json:"state" db:"state"`
	InputKind        InputKind             `json:"input_kind,omitempty" db:"input_kind"`
	WaitingSummary   *string               `json:"waiting_summary,omitempty" db:"waiting_summary"`
	IdempotencyKey   string                `json:"idempotency_key" db:"idempotency_key"`
	PayloadJSON      map[string]any        `json:"payload_json" db:"-"`
	RoutingJSON      map[string]any        `json:"routing_json" db:"-"`
	ParentTaskID     *string               `json:"parent_task_id,omitempty" db:"parent_envelope_id"`
	TargetRunID      *string               `json:"target_run_id,omitempty" db:"target_run_id"`
	CurrentBlockerID *string               `json:"current_blocker_id,omitempty" db:"current_blocker_id"`
	CurrentBlocker   *TaskBlocker          `json:"current_blocker,omitempty" db:"-"`
	AcceptedAt       time.Time             `json:"accepted_at" db:"accepted_at"`
	QueuedAt         *time.Time            `json:"queued_at,omitempty" db:"queued_at"`
	DispatchedAt     *time.Time            `json:"dispatched_at,omitempty" db:"dispatched_at"`
	Deadline         *time.Time            `json:"deadline,omitempty" db:"deadline"`
	DroppedReason    *string               `json:"dropped_reason,omitempty" db:"dropped_reason"`
	Priority         string                `json:"priority" db:"priority"`
	BudgetUSD        *float64              `json:"budget_usd,omitempty" db:"budget_usd"`
	CostUSD          float64               `json:"cost_usd" db:"cost_usd"`
	ArchivedAt       *time.Time            `json:"archived_at,omitempty" db:"archived_at"`
	WakeAt           *time.Time            `json:"wake_at,omitempty" db:"wake_at"`
	WakeReason       *string               `json:"wake_reason,omitempty" db:"wake_reason"`
	WakeAgenda       []*TaskWakeAgendaItem `json:"wake_agenda,omitempty" db:"-"`
	WakeCount        int                   `json:"wake_count,omitempty" db:"wake_count"`
	CreatedAt        time.Time             `json:"created_at" db:"created_at"`
	UpdatedAt        time.Time             `json:"updated_at" db:"updated_at"`
}

type AgentTaskListFilter struct {
	AgentID         *string
	States          []AgentTaskState
	CreatedAfter    *time.Time
	CreatedBefore   *time.Time
	IncludeArchived bool
	Limit           int
	Offset          int
}

type AgentTaskPriority string

type AgentTaskState string

type AppConfig struct {
	Mode        string            `key:"mode" json:"mode"` // "local" or "remote"
	DebugMode   bool              `key:"debugMode" json:"debug_mode"`
	PrettyLogs  bool              `key:"prettyLogs" json:"pretty_logs"`
	ClusterName string            `key:"clusterName" json:"cluster_name"`
	Database    DatabaseConfig    `key:"database" json:"database"`
	Image       ImageConfig       `key:"image" json:"image"`
	Sandbox     SandboxSettings   `key:"sandbox" json:"sandbox"`
	Filesystem  FilesystemConfig  `key:"filesystem" json:"filesystem"`
	Gateway     GatewayConfig     `key:"gateway" json:"gateway"`
	Scheduler   SchedulerConfig   `key:"scheduler" json:"scheduler"`
	Tools       ToolsConfig       `key:"tools" json:"tools"`
	Sources     SourcesConfig     `key:"sources" json:"sources"`         // Builtin source provider credentials
	OAuth       IntegrationOAuth  `key:"oauth" json:"oauth"`             // OAuth for workspace integrations (gmail, gdrive)
	Streams     StreamsConfig     `key:"streams" json:"streams"`         // S2 stream configuration for task logs
	Models      ModelsConfig      `key:"models" json:"models"`           // LLM provider API keys (BAML inference, sandbox tasks)
	Compression CompressionConfig `key:"compression" json:"compression"` // Context compression middleware
	Channels    ChannelsConfig    `key:"channels" json:"channels"`       // External channel provider credentials
	View        ViewConfig        `key:"view" json:"view"`               // View sync thresholds and settings
}

type ApprovalPolicy struct {
	Key string
}

type AuthInfo struct {
	TokenType TokenType
	TokenId   uint   // Internal ID of the token used for authentication
	TenantId  string // Set when the token has a tenant_id (organization tokens)
	Workspace *WorkspaceInfo
	Member    *MemberInfo
	Worker    *WorkerInfo
}

type CORSConfig struct {
	AllowedOrigins []string `key:"allowOrigins" json:"allow_origins"`
	AllowedMethods []string `key:"allowMethods" json:"allow_methods"`
	AllowedHeaders []string `key:"allowHeaders" json:"allow_headers"`
}

type ChannelAgentMailConfig struct {
	APIKey     string `key:"apiKey" json:"api_key"`
	BaseURL    string `key:"baseUrl" json:"base_url"`
	Domain     string `key:"domain" json:"domain"`
	WebhookURL string `key:"webhookUrl" json:"webhook_url"` // public URL for inbound email webhooks
}

type ChannelBinding struct {
	ID          int64          `json:"id" db:"id"`
	WorkspaceID uint           `json:"workspace_id" db:"workspace_id"`
	AgentID     *string        `json:"agent_id" db:"agent_id"`
	ChannelType string         `json:"channel_type" db:"channel_type"`
	Address     string         `json:"address" db:"address"`
	ConfigJSON  map[string]any `json:"config_json" db:"-"`
	Active      bool           `json:"active" db:"active"`
	CreatedAt   time.Time      `json:"created_at" db:"created_at"`
	UpdatedAt   time.Time      `json:"updated_at" db:"updated_at"`
}

type ChannelsConfig struct {
	AgentMail ChannelAgentMailConfig `key:"agentMail" json:"agent_mail"`
}

type ColumnMeta struct {
	Key     string         `json:"key"`
	Label   string         `json:"label,omitempty"`
	Type    string         `json:"type"`
	Format  string         `json:"format,omitempty"`
	Options []StatusOption `json:"options,omitempty"`
	Frozen  bool           `json:"frozen,omitempty"`
	Hidden  bool           `json:"hidden,omitempty"`
}

type ComponentSpec struct {
	ID         string         `json:"id"`
	Type       string         `json:"type"`
	Title      string         `json:"title"`
	Section    string         `json:"section,omitempty"`
	Position   Position       `json:"position"`
	DataSource *DataSource    `json:"dataSource,omitempty"`
	Config     map[string]any `json:"config,omitempty"`
}

type CompressionConfig struct {
	Strategy             string        `key:"strategy" json:"strategy"`                            // "strip" or "passthrough"
	CacheEnabled         bool          `key:"cacheEnabled" json:"cache_enabled"`                   // enable Redis compressed content cache (default false)
	TokenThreshold       int           `key:"tokenThreshold" json:"token_threshold"`               // skip compression if below this many tokens
	MaxContentBytes      int           `key:"maxContentBytes" json:"max_content_bytes"`            // skip if content exceeds this size
	TokenEncoding        string        `key:"tokenEncoding" json:"token_encoding"`                 // tiktoken encoding, default "cl100k_base"
	Timeout              time.Duration `key:"timeout" json:"timeout"`                              // max compression time; 0 = strategy default
	ContentCacheMaxBytes int64         `key:"contentCacheMaxBytes" json:"content_cache_max_bytes"` // per-workspace Redis budget; default 10MB (cache only)
	ContentCacheTTL      time.Duration `key:"contentCacheTTL" json:"content_cache_ttl"`            // per-entry TTL; default 5m (cache only)
}

type ContainerRuntime string

type CreateWorkspaceToolRequest struct {
	Name         string           `json:"name"`
	ProviderType string           `json:"provider_type"` // "mcp"
	MCP          *MCPServerConfig `json:"mcp,omitempty"`
}

type CurrentRunTaskStateUpdate struct {
	TaskID        string
	ExpectedRunID string
	State         AgentTaskState
	DroppedReason *string
	TargetRunID   *string
}

type DataSource struct {
	AgentID     string          `json:"agent_id,omitempty"`
	AgentIDs    []string        `json:"agent_ids,omitempty"`
	OutputType  string          `json:"output_type,omitempty"`
	ArtifactKey string          `json:"artifact_key,omitempty"`
	TimeRange   string          `json:"time_range,omitempty"`
	Statuses    []string        `json:"statuses,omitempty"`
	Transform   []TransformRule `json:"transform,omitempty"`
}

type DatabaseConfig struct {
	Redis    RedisConfig    `key:"redis" json:"redis"`
	Postgres PostgresConfig `key:"postgres" json:"postgres"`
	Mongo    MongoConfig    `key:"mongo" json:"mongo"`
}

type DirEntry struct {
	Name   string `json:"name"`
	Mode   uint32 `json:"mode"`
	Size   int64  `json:"size,omitempty"`
	Mtime  int64  `json:"mtime,omitempty"` // Unix timestamp
	IsLink bool   `json:"is_link,omitempty"`
}

type DirMeta struct {
	Path     string    `json:"path"`
	Mode     uint32    `json:"mode"`
	Uid      uint32    `json:"uid"`
	Gid      uint32    `json:"gid"`
	Mtime    time.Time `json:"mtime"`
	Children []string  `json:"children"` // Entry names in this directory
}

type ErrAgentProfileNotFound struct {
	ID string
}

type ErrAgentRunAttemptNotFound struct {
	ID string
}

type ErrAgentRunNotFound struct {
	ID string
}

type ErrAgentTaskNotFound struct {
	ID string
}

type ErrHookNotFound struct {
	ExternalId string
}

type ErrInvalidTaskInput struct {
	Message string
}

type ErrRunExecutionNotFound struct {
	ExternalId string
}

type ErrScheduledTaskNotFound struct {
	ExternalID string
}

type ErrTaskBlockerNotFound struct {
	ID string
}

type ErrTaskNotArchivable struct {
	ID    string
	State AgentTaskState
}

type ErrTaskNotCancellable struct {
	ID    string
	State AgentTaskState
}

type ErrTaskNotRetryable struct {
	ID    string
	State AgentTaskState
}

type ErrTaskOutputConflict struct {
	ID                  string
	WorkspaceID         uint
	TaskID              string
	ExistingWorkspaceID uint
	ExistingTaskID      string
}

type ErrTaskOutputNotFound struct {
	ID string
}

type ErrWorkerNotFound struct {
	WorkerId string
}

type ErrWorkerPoolNotFound struct {
	PoolName string
}

type ErrWorkspaceNotFound struct {
	ExternalId string
	Name       string
}

type ErrWorkspaceToolExists struct {
	Name string
}

type ErrWorkspaceToolNotFound struct {
	Name       string
	ExternalId string
}

type FileMeta struct {
	Path    string    `json:"path"`
	Size    int64     `json:"size"`
	Mode    uint32    `json:"mode"`
	Uid     uint32    `json:"uid"`
	Gid     uint32    `json:"gid"`
	Mtime   time.Time `json:"mtime"`
	S3Key   string    `json:"s3_key,omitempty"`  // Object storage key (for context files)
	Symlink string    `json:"symlink,omitempty"` // Target path if symlink (empty otherwise)
}

type FilesystemConfig struct {
	MountPoint       string                 `key:"mountPoint" json:"mount_point"`
	Verbose          bool                   `key:"verbose" json:"verbose"`
	WorkspaceStorage WorkspaceStorageConfig `key:"workspaceStorage" json:"workspace_storage"`
}

type FilesystemQuery struct {
	Id                 uint                     `json:"id" db:"id"`
	ExternalId         string                   `json:"external_id" db:"external_id"`
	WorkspaceId        uint                     `json:"workspace_id" db:"workspace_id"`
	CredentialMemberID *uint                    `json:"credential_member_id,omitempty" db:"credential_member_id"`
	SystemManaged      bool                     `json:"system_managed" db:"system_managed"`
	Lifecycle          FilesystemQueryLifecycle `json:"lifecycle" db:"lifecycle"`
	OwnerTaskID        *string                  `json:"owner_task_id,omitempty" db:"owner_task_id"`
	OwnerRunID         *string                  `json:"owner_run_id,omitempty" db:"owner_run_id"`
	Integration        string                   `json:"integration" db:"integration"`         // "gmail", "gdrive", "notion"
	Path               string                   `json:"path" db:"path"`                       // Full path: "/sources/gmail/unread-emails"
	Name               string                   `json:"name" db:"name"`                       // Folder/file name: "unread-emails"
	QuerySpec          string                   `json:"query_spec" db:"query_spec"`           // JSON query params
	Guidance           string                   `json:"guidance" db:"guidance"`               // Optional user-provided context (smart mode)
	OutputFormat       ViewOutputFormat         `json:"output_format" db:"output_format"`     // "folder" or "file"
	FileExt            string                   `json:"file_ext" db:"file_ext"`               // For files: ".json", ".md"
	FilenameFormat     string                   `json:"filename_format" db:"filename_format"` // Template for result filenames
	CacheTTL           int                      `json:"cache_ttl" db:"cache_ttl"`             // Seconds, 0 = always live
	Mode               ViewMode                 `json:"mode" db:"mode"`                       // "smart" or "query"
	Filter             string                   `json:"filter,omitempty" db:"filter"`         // JSON structured filter (query mode, round-trip editing)
	CreatedAt          time.Time                `json:"created_at" db:"created_at"`
	UpdatedAt          time.Time                `json:"updated_at" db:"updated_at"`
	LastExecuted       *time.Time               `json:"last_executed,omitempty" db:"last_executed"`
	BaselineItemIDs    []string                 `json:"baseline_item_ids,omitempty" db:"baseline_item_ids"`
}

type FilesystemQueryLifecycle string

type GRPCConfig struct {
	Port           int `key:"port" json:"port"`
	MaxRecvMsgSize int `key:"maxRecvMsgSize" json:"max_recv_msg_size"`
	MaxSendMsgSize int `key:"maxSendMsgSize" json:"max_send_msg_size"`
}

type GatewayConfig struct {
	GRPC            GRPCConfig    `key:"grpc" json:"grpc"`
	HTTP            HTTPConfig    `key:"http" json:"http"`
	ShutdownTimeout time.Duration `key:"shutdownTimeout" json:"shutdown_timeout"`
	AuthToken       string        `key:"authToken" json:"auth_token"`
}

type GitHubConfig struct {
	Enabled bool `key:"enabled" json:"enabled"`
}

type HTTPConfig struct {
	Host             string     `key:"host" json:"host"`
	Port             int        `key:"port" json:"port"`
	EnablePrettyLogs bool       `key:"enablePrettyLogs" json:"enable_pretty_logs"`
	CORS             CORSConfig `key:"cors" json:"cors"`
}

type Hook struct {
	Id                uint             `json:"id" db:"id"`
	ExternalId        string           `json:"external_id" db:"external_id"`
	WorkspaceId       uint             `json:"workspace_id" db:"workspace_id"`
	Path              string           `json:"path" db:"path"`
	Prompt            string           `json:"prompt" db:"prompt"`
	SkillPath         string           `json:"skill_path" db:"skill_path"`
	SkillPaths        []string         `json:"skill_paths,omitempty" db:"skill_paths"`
	AgentId           *string          `json:"agent_id,omitempty" db:"agent_id"`
	AgentKey          string           `json:"agent_key,omitempty" db:"-"`
	AgentName         string           `json:"agent_name,omitempty" db:"-"`
	AgentConfig       map[string]any   `json:"agent_config,omitempty" db:"-"`
	Active            bool             `json:"active" db:"active"`
	EventTypes        []string         `json:"event_types,omitempty" db:"event_types"`
	DeliveryMode      HookDeliveryMode `json:"delivery_mode" db:"delivery_mode"`
	TargetTaskID      *string          `json:"target_task_id,omitempty" db:"target_task_id"`
	SystemManaged     bool             `json:"system_managed" db:"system_managed"`
	OneShot           bool             `json:"one_shot" db:"one_shot"`
	CreatedByMemberId *uint            `json:"created_by_member_id,omitempty" db:"created_by_member_id"`
	TokenId           *uint            `json:"-" db:"token_id"`
	EncryptedToken    []byte           `json:"-" db:"encrypted_token"`
	CreatedAt         time.Time        `json:"created_at" db:"created_at"`
	UpdatedAt         time.Time        `json:"updated_at" db:"updated_at"`
}

type HookDeliveryMode string

type IPAllocation struct {
	IP            string `json:"ip"`
	Gateway       string `json:"gateway"`
	PrefixLen     int    `json:"prefix_len"`
	IPv6          string `json:"ipv6,omitempty"`
	GatewayIPv6   string `json:"gateway_ipv6,omitempty"`
	PrefixLenIPv6 int    `json:"prefix_len_ipv6,omitempty"`
}

type ImageConfig struct {
	S3        S3Config `key:"s3" json:"s3"`
	CachePath string   `key:"cachePath" json:"cache_path"`
	WorkPath  string   `key:"workPath" json:"work_path"`
	MountPath string   `key:"mountPath" json:"mount_path"`
}

type InputKind string

type IntegrationAPIKey struct {
	APIKey string `key:"apiKey" json:"api_key"`
}

type IntegrationAuthType string

type IntegrationCapability string

type IntegrationConnection struct {
	Id              uint       `db:"id" json:"id"`
	ExternalId      string     `db:"external_id" json:"external_id"`
	WorkspaceId     uint       `db:"workspace_id" json:"workspace_id"`
	MemberId        *uint      `db:"member_id" json:"member_id,omitempty"` // nil = workspace-shared
	IntegrationType string     `db:"integration_type" json:"integration_type"`
	Credentials     []byte     `db:"credentials" json:"-"` // Encrypted
	Scope           string     `db:"scope" json:"scope,omitempty"`
	ExpiresAt       *time.Time `db:"expires_at" json:"expires_at,omitempty"`
	CreatedAt       time.Time  `db:"created_at" json:"created_at"`
	UpdatedAt       time.Time  `db:"updated_at" json:"updated_at"`
}

type IntegrationCredentials struct {
	AccessToken  string            `json:"access_token,omitempty"`
	RefreshToken string            `json:"refresh_token,omitempty"`
	APIKey       string            `json:"api_key,omitempty"`
	ExpiresAt    *time.Time        `json:"expires_at,omitempty"`
	Extra        map[string]string `json:"extra,omitempty"`
}

type IntegrationMeta struct {
	Name                IntegrationName
	DisplayName         string
	Description         string
	Icon                string
	AuthType            IntegrationAuthType
	Scope               IntegrationScope
	Capabilities        []IntegrationCapability
	OAuthWriteScopeHint []string
}

type IntegrationName string

type IntegrationOAuth struct {
	CallbackURL string                   `key:"callbackUrl" json:"callback_url"` // e.g., https://api.airstore.ai/api/v1/oauth/callback
	Google      ProviderOAuthCredentials `key:"google" json:"google"`
	GitHub      ProviderOAuthCredentials `key:"github" json:"github"`
	Notion      ProviderOAuthCredentials `key:"notion" json:"notion"`
	Slack       ProviderOAuthCredentials `key:"slack" json:"slack"`
	Linear      ProviderOAuthCredentials `key:"linear" json:"linear"`
	Atlassian   ProviderOAuthCredentials `key:"atlassian" json:"atlassian"`
	Microsoft   ProviderOAuthCredentials `key:"microsoft" json:"microsoft"`
}

type IntegrationScope string

type IntegrationsConfig struct {
	Weather IntegrationAPIKey `key:"weather" json:"weather"`
	Exa     IntegrationAPIKey `key:"exa" json:"exa"`
	GitHub  GitHubConfig      `key:"github" json:"github"`
	Kernel  IntegrationAPIKey `key:"kernel" json:"kernel"`
}

type ItemDecision struct {
	OutputID string          `json:"output_id"`
	Action   TaskInputAction `json:"action"`
	Reason   string          `json:"reason,omitempty"`
}

type LLMModelUsage struct {
	InputTokens              int64   `json:"input_tokens,omitempty"`
	OutputTokens             int64   `json:"output_tokens,omitempty"`
	CacheCreationInputTokens int64   `json:"cache_creation_input_tokens,omitempty"`
	CacheReadInputTokens     int64   `json:"cache_read_input_tokens,omitempty"`
	TotalTokens              int64   `json:"total_tokens,omitempty"`
	CostUSD                  float64 `json:"cost_usd,omitempty"`
	WebSearchRequests        int64   `json:"web_search_requests,omitempty"`
	ContextWindow            int64   `json:"context_window,omitempty"`
	MaxOutputTokens          int64   `json:"max_output_tokens,omitempty"`
}

type LLMUsage struct {
	InputTokens              int64                    `json:"llm_input_tokens,omitempty"`
	OutputTokens             int64                    `json:"llm_output_tokens,omitempty"`
	CacheCreationInputTokens int64                    `json:"llm_cache_creation_input_tokens,omitempty"`
	CacheReadInputTokens     int64                    `json:"llm_cache_read_input_tokens,omitempty"`
	TotalTokens              int64                    `json:"llm_total_tokens,omitempty"`
	TotalCostUSD             float64                  `json:"total_cost_usd,omitempty"`
	BillingTotalCostMicrousd int64                    `json:"billing_total_cost_microusd,omitempty"`
	ModelUsage               map[string]LLMModelUsage `json:"model_usage,omitempty"`
}

type LLMUsageProtoFields struct {
	InputTokens              int64
	OutputTokens             int64
	CacheCreationInputTokens int64
	CacheReadInputTokens     int64
	TotalTokens              int64
	TotalCostUSD             float64
	ModelUsageJSON           string
}

type LayoutConfig struct {
	Columns int `json:"columns"`
}

type ListItem struct {
	Label  string `json:"label"`
	Value  string `json:"value"`
	Detail string `json:"detail,omitempty"`
}

type ListWidgetData struct {
	Items []ListItem `json:"items"`
}

type MCPAuthConfig struct {
	// Token is the bearer token for authentication.
	// For stdio: passed as MCP_AUTH_TOKEN env var (or custom var via TokenEnv)
	// For remote: passed as Authorization: Bearer <token> header
	Token string `key:"token" json:"token,omitempty"`

	// TokenEnv specifies a custom env var name for the token (stdio only, default: MCP_AUTH_TOKEN)
	TokenEnv string `key:"tokenEnv" json:"token_env,omitempty"`

	// Headers are additional auth headers.
	// For stdio: passed as MCP_AUTH_HEADER_<NAME> env vars
	// For remote: passed directly as HTTP headers
	Headers map[string]string `key:"headers" json:"headers,omitempty"`
}

type MCPServerConfig struct {
	// Local (stdio) server - spawn process
	Command    string            `key:"command" json:"command,omitempty"` // Executable (npx, uvx, python)
	Args       []string          `key:"args" json:"args,omitempty"`       // Command arguments
	Env        map[string]string `key:"env" json:"env,omitempty"`         // Environment variables
	WorkingDir string            `key:"cwd" json:"cwd,omitempty"`         // Working directory

	// Remote (HTTP/SSE) server - connect to URL
	URL string `key:"url" json:"url,omitempty"`

	// Transport specifies the remote transport type: "sse" (default) or "http" (Streamable HTTP)
	Transport string `key:"transport" json:"transport,omitempty"`

	// Auth for both local (env vars) and remote (HTTP headers)
	Auth *MCPAuthConfig `key:"auth" json:"auth,omitempty"`
}

type MapMarker struct {
	Lat    float64 `json:"lat"`
	Lng    float64 `json:"lng"`
	Label  string  `json:"label"`
	Detail string  `json:"detail,omitempty"`
}

type MapWidgetData struct {
	Markers []MapMarker `json:"markers"`
}

type MemberInfo struct {
	Id         uint
	ExternalId string
	Email      string
	Role       MemberRole
}

type MemberRole string

type MetadataNotFoundError struct {
	Key string
}

type MetricData struct {
	Value      string `json:"value"`
	Label      string `json:"label"`
	Comparison string `json:"comparison,omitempty"`
}

type ModelProviderConfig struct {
	APIKey string `key:"apiKey" json:"api_key"`
}

type ModelsConfig struct {
	Anthropic ModelProviderConfig `key:"anthropic" json:"anthropic"` // Claude models (smart queries, sandbox)
	Cerebras  ModelProviderConfig `key:"cerebras" json:"cerebras"`   // Cerebras models (distillation)
	OpenAI    ModelProviderConfig `key:"openai" json:"openai"`       // OpenAI models (embeddings)
}

type MongoConfig struct {
	URI      string `key:"uri" json:"uri"`
	Database string `key:"database" json:"database"`
}

type OrchestrationOutboxEvent struct {
	ID          int64                        `json:"id" db:"id"`
	EventType   OrchestrationOutboxEventType `json:"event_type" db:"event_type"`
	DedupeKey   string                       `json:"dedupe_key" db:"dedupe_key"`
	PayloadJSON map[string]any               `json:"payload_json" db:"-"`
	AvailableAt time.Time                    `json:"available_at" db:"available_at"`
	PublishedAt *time.Time                   `json:"published_at,omitempty" db:"published_at"`
	Attempts    int                          `json:"attempts" db:"attempts"`
	LastError   *string                      `json:"last_error,omitempty" db:"last_error"`
	CreatedAt   time.Time                    `json:"created_at" db:"created_at"`
	UpdatedAt   time.Time                    `json:"updated_at" db:"updated_at"`
}

type OrchestrationOutboxEventType string

type PoolScalerStatus struct {
	PoolName        string `json:"pool_name"`
	QueueDepth      int64  `json:"queue_depth"`
	InFlightTasks   int64  `json:"in_flight_tasks"`
	CurrentReplicas int32  `json:"current_replicas"`
	MinReplicas     int32  `json:"min_replicas"`
	MaxReplicas     int32  `json:"max_replicas"`
}

type Position struct {
	Col     int `json:"col"`
	Row     int `json:"row"`
	ColSpan int `json:"colSpan"`
	RowSpan int `json:"rowSpan"`
}

type PostgresConfig struct {
	Host            string        `key:"host" json:"host"`
	Port            int           `key:"port" json:"port"`
	User            string        `key:"user" json:"user"`
	Password        string        `key:"password" json:"password"`
	Database        string        `key:"database" json:"database"`
	SSLMode         string        `key:"sslMode" json:"ssl_mode"`
	MaxOpenConns    int           `key:"maxOpenConns" json:"max_open_conns"`
	MaxIdleConns    int           `key:"maxIdleConns" json:"max_idle_conns"`
	ConnMaxLifetime time.Duration `key:"connMaxLifetime" json:"conn_max_lifetime"`
}

type ProviderOAuthCredentials struct {
	ClientID     string `key:"clientId" json:"client_id"`
	ClientSecret string `key:"clientSecret" json:"client_secret"`
}

type RedisConfig struct {
	Mode               RedisMode     `key:"mode" json:"mode"`
	Addrs              []string      `key:"addrs" json:"addrs"`
	Username           string        `key:"username" json:"username"`
	Password           string        `key:"password" json:"password"`
	ClientName         string        `key:"clientName" json:"client_name"`
	EnableTLS          bool          `key:"enableTLS" json:"enable_tls"`
	InsecureSkipVerify bool          `key:"insecureSkipVerify" json:"insecure_skip_verify"`
	PoolSize           int           `key:"poolSize" json:"pool_size"`
	MinIdleConns       int           `key:"minIdleConns" json:"min_idle_conns"`
	MaxIdleConns       int           `key:"maxIdleConns" json:"max_idle_conns"`
	ConnMaxIdleTime    time.Duration `key:"connMaxIdleTime" json:"conn_max_idle_time"`
	ConnMaxLifetime    time.Duration `key:"connMaxLifetime" json:"conn_max_lifetime"`
	DialTimeout        time.Duration `key:"dialTimeout" json:"dial_timeout"`
	ReadTimeout        time.Duration `key:"readTimeout" json:"read_timeout"`
	WriteTimeout       time.Duration `key:"writeTimeout" json:"write_timeout"`
	MaxRedirects       int           `key:"maxRedirects" json:"max_redirects"`
	MaxRetries         int           `key:"maxRetries" json:"max_retries"`
	RouteByLatency     bool          `key:"routeByLatency" json:"route_by_latency"`
}

type RedisMode string

type ResolvedBlocker struct {
	ID              string                `json:"id,omitempty"`
	Kind            string                `json:"kind,omitempty"`
	InputKind       string                `json:"input_kind,omitempty"`
	Status          string                `json:"status,omitempty"`
	WaitGroupID     string                `json:"wait_group_id,omitempty"`
	OutputID        string                `json:"output_id,omitempty"`
	OutputStatus    string                `json:"output_status,omitempty"`
	OutputIDs       []string              `json:"output_ids,omitempty"`
	ApprovalSurface bool                  `json:"approval_surface,omitempty"`
	Summary         string                `json:"summary,omitempty"`
	Details         string                `json:"details,omitempty"`
	Items           []ResolvedBlockerItem `json:"items,omitempty"`
	PayloadJSON     map[string]any        `json:"payload_json,omitempty"`
}

type ResolvedBlockerItem struct {
	OutputID string `json:"output_id"`
	Title    string `json:"title,omitempty"`
	ItemKey  string `json:"item_key,omitempty"`
}

type ResolvedData struct {
	Columns     []string       `json:"columns"`
	ColumnMeta  []ColumnMeta   `json:"column_meta,omitempty"`
	Rows        [][]any        `json:"rows"`
	Total       int            `json:"total"`
	CachedAt    *time.Time     `json:"cached_at,omitempty"`
	Status      string         `json:"status,omitempty"`
	Error       string         `json:"error,omitempty"`
	Diagnostics map[string]any `json:"diagnostics,omitempty"`
}

type ResolvedTool struct {
	Name         string              `json:"name"`
	Help         string              `json:"help,omitempty"`
	Origin       WorkspaceToolOrigin `json:"origin"`
	ExternalId   string              `json:"external_id,omitempty"`
	Enabled      bool                `json:"enabled"`
	ToolCount    int                 `json:"tool_count,omitempty"`
	LocalCommand string              `json:"local_command,omitempty"`
}

type RunExecution struct {
	// Id is the internal ID for joins
	Id uint `json:"id" db:"id"`

	// ExternalId is the UUID exposed via API
	ExternalId string `json:"external_id" db:"external_id"`

	// WorkspaceId is the internal workspace ID (for joins)
	WorkspaceId uint `json:"workspace_id" db:"workspace_id"`

	// CreatedByMemberId is the member who created this task (for token auth)
	CreatedByMemberId *uint `json:"created_by_member_id,omitempty" db:"created_by_member_id"`

	// MemberToken is the workspace token to use for filesystem access
	// This is NOT stored in the database - it's set at creation time and passed to workers
	MemberToken string `json:"member_token,omitempty" db:"-"`

	// Status is the current run execution status
	Status RunExecutionStatus `json:"status" db:"status"`

	// Type controls run execution mode (background by default).
	Type RunExecutionType `json:"type" db:"type"`

	// Prompt is the Claude Code prompt (if this is a Claude Code task)
	Prompt string `json:"prompt,omitempty" db:"prompt"`

	// Image is the container image to use
	Image string `json:"image" db:"image"`

	// Entrypoint is the command to run
	Entrypoint []string `json:"entrypoint" db:"entrypoint"`

	// Env is environment variables for the task
	Env map[string]string `json:"env" db:"env"`

	// Resources specifies resource requirements (optional - uses defaults if nil)
	Resources *RunExecutionResources `json:"resources,omitempty" db:"-"`

	// RunAttemptID links this run execution to an orchestrated run attempt.
	RunAttemptID *string `json:"run_attempt_id,omitempty" db:"run_attempt_id"`

	// TimeoutMs applies a per-task execution timeout when set.
	TimeoutMs *int `json:"timeout_ms,omitempty" db:"timeout_ms"`

	// Execution policy fields bridged from run attempts.
	ExecHost        *string        `json:"exec_host,omitempty" db:"exec_host"`
	ExecSecurity    *string        `json:"exec_security,omitempty" db:"exec_security"`
	ExecAsk         *string        `json:"exec_ask,omitempty" db:"exec_ask"`
	RuntimeType     *string        `json:"runtime_type,omitempty" db:"runtime_type"`
	WorkspaceAccess *string        `json:"workspace_access,omitempty" db:"workspace_access"`
	NetworkEnabled  *bool          `json:"network_enabled,omitempty" db:"network_enabled"`
	ExecutionPolicy map[string]any `json:"execution_policy,omitempty" db:"-"`

	// Hook-triggered task fields (nil/defaults for manual tasks)
	HookId      *uint `json:"hook_id,omitempty" db:"hook_id"` // nil = manual, non-nil = hook-triggered
	Attempt     int   `json:"attempt" db:"attempt"`           // 1-based attempt number
	MaxAttempts int   `json:"max_attempts" db:"max_attempts"` // default 1 (manual), 3 (hook)

	// ExitCode is the exit code when complete
	ExitCode *int `json:"exit_code,omitempty" db:"exit_code"`

	// Error contains error message if failed
	Error string `json:"error,omitempty" db:"error"`

	// CreatedAt is when the task was created
	CreatedAt time.Time `json:"created_at" db:"created_at"`

	// StartedAt is when the task started running
	StartedAt *time.Time `json:"started_at,omitempty" db:"started_at"`

	// FinishedAt is when the task finished
	FinishedAt *time.Time `json:"finished_at,omitempty" db:"finished_at"`
}

type RunExecutionPostRun struct {
	WaitingForInput     bool                    `json:"waiting_for_input,omitempty"`
	WakeSignal          *RunExecutionWakeSignal `json:"wake_signal,omitempty"`
	SubtaskRequests     []*SubtaskRequest       `json:"subtask_requests,omitempty"`
	SourceWatchRequests []*SourceWatchRequest   `json:"source_watch_requests,omitempty"`
}

type RunExecutionResources struct {
	CPU    int64 `json:"cpu"`    // millicores (1000 = 1 CPU)
	Memory int64 `json:"memory"` // bytes
	GPU    int   `json:"gpu"`    // count
}

type RunExecutionResult struct {
	ID                  string                  `json:"id"`
	ExitCode            int                     `json:"exit_code"`
	Output              []byte                  `json:"output,omitempty"`
	Error               string                  `json:"error,omitempty"`
	Duration            time.Duration           `json:"duration"`
	PostRun             *RunExecutionPostRun    `json:"post_run,omitempty"`
	WaitingForInput     bool                    `json:"waiting_for_input,omitempty"`
	WakeSignal          *RunExecutionWakeSignal `json:"wake_signal,omitempty"`
	SubtaskRequests     []*SubtaskRequest       `json:"subtask_requests,omitempty"`
	SourceWatchRequests []*SourceWatchRequest   `json:"source_watch_requests,omitempty"`
	Usage               *LLMUsage               `json:"usage,omitempty"`
}

type RunExecutionState struct {
	// ID is the run execution identifier
	ID string `json:"id"`

	// Status is the current status
	Status RunExecutionStatus `json:"status"`

	// SandboxID is the sandbox running this task (empty if not yet scheduled)
	SandboxID string `json:"sandbox_id,omitempty"`

	// WorkerID is the worker running this task (empty if not yet scheduled)
	WorkerID string `json:"worker_id,omitempty"`

	// ExitCode is the exit code if complete (-1 if still running)
	ExitCode int `json:"exit_code"`

	// Error contains error message if failed
	Error string `json:"error,omitempty"`

	// CreatedAt is when the task was created
	CreatedAt time.Time `json:"created_at"`

	// ScheduledAt is when the task was scheduled
	ScheduledAt time.Time `json:"scheduled_at,omitempty"`

	// StartedAt is when the task started running
	StartedAt time.Time `json:"started_at,omitempty"`

	// FinishedAt is when the task finished
	FinishedAt time.Time `json:"finished_at,omitempty"`
}

type RunExecutionStatus string

type RunExecutionType string

type RunExecutionWakeSignal struct {
	DelayMinutes   int                   `json:"delay_minutes"`
	Reason         string                `json:"reason,omitempty"`
	FollowUpPrompt string                `json:"follow_up_prompt,omitempty"`
	WakeAgenda     []*TaskWakeAgendaItem `json:"wake_agenda,omitempty"`
}

type RunInputDeliveryOutcome string

type RunInteraction struct {
	State             RunInteractionState `json:"state"`
	ActiveExecutionID string              `json:"active_execution_id,omitempty"`
	UpdatedAt         int64               `json:"updated_at,omitempty"`
}

type RunInteractionState string

type S3Config struct {
	Bucket         string `key:"bucket" json:"bucket"`
	Region         string `key:"region" json:"region"`
	Endpoint       string `key:"endpoint" json:"endpoint"`
	AccessKey      string `key:"accessKey" json:"access_key"`
	SecretKey      string `key:"secretKey" json:"secret_key"`
	ForcePathStyle bool   `key:"forcePathStyle" json:"force_path_style"`
}

type SandboxConfig struct {
	// ID is the unique identifier for this sandbox
	ID string `json:"id"`

	// WorkspaceID is the workspace this sandbox belongs to
	WorkspaceID string `json:"workspace_id"`

	// Image is the container image to use for the sandbox
	Image string `json:"image"`

	// Runtime is the container runtime to use (runc, gvisor)
	Runtime ContainerRuntime `json:"runtime"`

	// Entrypoint is the command to run in the sandbox
	Entrypoint []string `json:"entrypoint"`

	// Env is the environment variables to set
	Env map[string]string `json:"env"`

	// WorkingDir is the working directory inside the sandbox
	WorkingDir string `json:"working_dir"`

	// Resources specifies resource limits for the sandbox
	Resources RunExecutionResources `json:"resources"`

	// Mounts specifies additional mounts for the sandbox
	Mounts []SandboxMount `json:"mounts"`

	// Network specifies network configuration
	Network SandboxNetwork `json:"network"`

	// FilesystemMount is the host path to bind-mount at /workspace (optional)
	FilesystemMount string `json:"-"`

	// FilesystemReadOnly controls whether /workspace is mounted read-only.
	FilesystemReadOnly bool `json:"-"`
}

type SandboxMount struct {
	// Source is the host path or volume name
	Source string `json:"source"`

	// Destination is the path inside the sandbox
	Destination string `json:"destination"`

	// ReadOnly specifies if the mount is read-only
	ReadOnly bool `json:"read_only"`

	// Type is the mount type (bind, volume, tmpfs)
	Type string `json:"type"`
}

type SandboxNetwork struct {
	// Mode is the network mode (none, host, bridge)
	Mode string `json:"mode"`

	// ExposedPorts is a list of ports to expose
	ExposedPorts []int `json:"exposed_ports"`
}

type SandboxSettings struct {
	// DefaultImage is the container image used when a task omits image.
	DefaultImage string `key:"defaultImage" json:"default_image"`
	// InteractiveIdleTimeout controls how long an interactive task may stay
	// inactive (no input/output activity) before it is automatically completed.
	InteractiveIdleTimeout time.Duration `key:"interactiveIdleTimeout" json:"interactive_idle_timeout"`
}

type SandboxState struct {
	// ID is the sandbox identifier
	ID string `json:"id"`

	// Status is the current status
	Status SandboxStatus `json:"status"`

	// PID is the main process ID (0 if not running)
	PID int `json:"pid"`

	// ExitCode is the exit code if stopped (-1 if still running)
	ExitCode int `json:"exit_code"`

	// Error contains error message if failed
	Error string `json:"error,omitempty"`

	// ContainerIP is the container's IP address (for routing)
	ContainerIP string `json:"container_ip,omitempty"`

	// CreatedAt is when the sandbox was created
	CreatedAt time.Time `json:"created_at"`

	// StartedAt is when the sandbox started running
	StartedAt time.Time `json:"started_at,omitempty"`

	// FinishedAt is when the sandbox stopped
	FinishedAt time.Time `json:"finished_at,omitempty"`
}

type SandboxStatus string

type ScheduledTask struct {
	ID                string     `json:"id" db:"id"`
	ExternalID        string     `json:"external_id" db:"external_id"`
	WorkspaceID       uint       `json:"workspace_id" db:"workspace_id"`
	AgentID           string     `json:"agent_id" db:"agent_id"`
	CronExpr          string     `json:"cron_expr" db:"cron_expr"`
	Timezone          string     `json:"timezone" db:"timezone"`
	Prompt            string     `json:"prompt" db:"prompt"`
	SkillPaths        []string   `json:"skill_paths" db:"skill_paths"`
	Active            bool       `json:"active" db:"active"`
	NextRunAt         time.Time  `json:"next_run_at" db:"next_run_at"`
	LastRunAt         *time.Time `json:"last_run_at,omitempty" db:"last_run_at"`
	TokenID           *uint      `json:"-" db:"token_id"`
	EncryptedToken    []byte     `json:"-" db:"encrypted_token"`
	CreatedByMemberID *uint      `json:"created_by_member_id,omitempty" db:"created_by_member_id"`
	SourceViewID      *string    `json:"source_view_id,omitempty" db:"source_view_id"`
	CreatedAt         time.Time  `json:"created_at" db:"created_at"`
	UpdatedAt         time.Time  `json:"updated_at" db:"updated_at"`
}

type SchedulerConfig struct {
	Enabled                   bool                        `key:"enabled" json:"enabled"`
	GatewayServiceName        string                      `key:"gatewayServiceName" json:"gateway_service_name"`
	WorkerImage               string                      `key:"workerImage" json:"worker_image"`
	WorkerNamespace           string                      `key:"workerNamespace" json:"worker_namespace"`
	GatewayExternalGRPCAddr   string                      `key:"gatewayExternalGRPCAddr" json:"gateway_external_grpc_addr"`
	WorkerServiceAccountName  string                      `key:"workerServiceAccountName" json:"worker_service_account_name"`
	WorkerHostNetwork         bool                        `key:"workerHostNetwork" json:"worker_host_network"`
	WorkerImagePullSecrets    []string                    `key:"workerImagePullSecrets" json:"worker_image_pull_secrets"`
	UseGatewayServiceHostname bool                        `key:"useGatewayServiceHostname" json:"use_gateway_service_hostname"`
	UseHostResolvConf         bool                        `key:"useHostResolvConf" json:"use_host_resolv_conf"`
	WorkerTTL                 time.Duration               `key:"workerTTL" json:"worker_ttl"`
	WorkerShutdownTimeout     time.Duration               `key:"workerShutdownTimeout" json:"worker_shutdown_timeout"` // Time to wait for tasks during graceful shutdown
	CleanupInterval           time.Duration               `key:"cleanupInterval" json:"cleanup_interval"`
	HeartbeatInterval         time.Duration               `key:"heartbeatInterval" json:"heartbeat_interval"`
	HeartbeatTimeout          time.Duration               `key:"heartbeatTimeout" json:"heartbeat_timeout"`
	RunClaimLeaseTTL          time.Duration               `key:"runClaimLeaseTTL" json:"run_claim_lease_ttl"`
	RecoveryLoopEnabled       bool                        `key:"recoveryLoopEnabled" json:"recovery_loop_enabled"`
	RecoveryLoopInterval      time.Duration               `key:"recoveryLoopInterval" json:"recovery_loop_interval"`
	RecoveryLoopBatchSize     int                         `key:"recoveryLoopBatchSize" json:"recovery_loop_batch_size"`
	UnclaimedRunStaleAfter    time.Duration               `key:"unclaimedRunStaleAfter" json:"unclaimed_run_stale_after"`
	DefaultWorkerCpu          int64                       `key:"defaultWorkerCpu" json:"default_worker_cpu"`       // millicores
	DefaultWorkerMemory       int64                       `key:"defaultWorkerMemory" json:"default_worker_memory"` // MiB
	Pools                     map[string]WorkerPoolConfig `key:"pools" json:"pools"`
}

type SessionCheckpoint struct {
	RunID       string `json:"run_id"`
	ExecutionID string `json:"execution_id,omitempty"`
	UpdatedAt   int64  `json:"updated_at"`
}

type SheetRelation struct {
	ID         string `json:"id"`
	Name       string `json:"name,omitempty"`
	ToSheetID  string `json:"to_sheet_id"`
	FromColumn string `json:"from_column"`
	ToColumn   string `json:"to_column"`
}

type SheetSpec struct {
	ID          string          `json:"id"`
	Name        string          `json:"name"`
	Description string          `json:"description,omitempty"`
	Layout      LayoutConfig    `json:"layout"`
	Components  []ComponentSpec `json:"components"`
	Relations   []SheetRelation `json:"relations,omitempty"`
	Widgets     []WidgetSpec    `json:"widgets,omitempty"`
}

type SourceType string

type SourceView = FilesystemQuery

type SourceWatchBlockerEntry struct {
	Integration    string
	Path           string
	EntityLabel    string
	EntityKey      string
	SourceOutputID string
	ThreadID       string
	MessageID      string
}

type SourceWatchRequest struct {
	Integration        string   `json:"integration"`
	Reason             string   `json:"reason,omitempty"`
	Query              string   `json:"query,omitempty"`
	FilenameFormat     string   `json:"filename_format,omitempty"`
	EventTypes         []string `json:"event_types,omitempty"`
	EntityKey          string   `json:"entity_key,omitempty"`
	EntityLabel        string   `json:"entity_label,omitempty"`
	SourceOutputID     string   `json:"source_output_id,omitempty"`
	ThreadID           string   `json:"thread_id,omitempty"`
	MessageID          string   `json:"message_id,omitempty"`
	IncludeAttachments bool     `json:"include_attachments,omitempty"`
	IncludeInline      bool     `json:"include_inline,omitempty"`
	IncludeMessageBody bool     `json:"include_message_body,omitempty"`
}

type SourcesConfig struct {
	Firecrawl IntegrationAPIKey `key:"firecrawl" json:"firecrawl"`
}

type StatusOption struct {
	Value string `json:"value"`
	Color string `json:"color"`
}

type StreamsConfig struct {
	Token string `key:"token" json:"token"` // S2 API token
	Basin string `key:"basin" json:"basin"` // S2 basin name (e.g., "airstore")
}

type SubtaskRequest struct {
	SourceOutputID   string `json:"source_output_id"`
	EntityLabel      string `json:"entity_label"`
	Prompt           string `json:"prompt"`
	WakeDelayMinutes int    `json:"wake_delay_minutes"`
}

type TaskBlocker struct {
	ID             string            `json:"id" db:"id"`
	WorkspaceID    uint              `json:"workspace_id" db:"workspace_id"`
	TaskID         string            `json:"task_id" db:"task_id"`
	RunID          *string           `json:"run_id,omitempty" db:"run_id"`
	Kind           TaskBlockerKind   `json:"kind" db:"kind"`
	InputKind      InputKind         `json:"input_kind,omitempty" db:"input_kind"`
	Status         TaskBlockerStatus `json:"status" db:"status"`
	WaitGroupID    *string           `json:"wait_group_id,omitempty" db:"wait_group_id"`
	PayloadJSON    map[string]any    `json:"payload_json,omitempty" db:"-"`
	ResolutionJSON map[string]any    `json:"resolution_json,omitempty" db:"-"`
	OutputIDs      []string          `json:"output_ids,omitempty" db:"-"`
	Revision       int               `json:"revision" db:"revision"`
	CreatedAt      time.Time         `json:"created_at" db:"created_at"`
	UpdatedAt      time.Time         `json:"updated_at" db:"updated_at"`
	ResolvedAt     *time.Time        `json:"resolved_at,omitempty" db:"resolved_at"`
}

type TaskBlockerKind string

type TaskBlockerOpenRequest struct {
	WorkspaceID   uint
	TaskID        string
	ExpectedRunID string
	Blocker       *TaskBlockerSpec
}

type TaskBlockerPayload struct {
	InputKind InputKind      `json:"-"`
	Summary   string         `json:"summary,omitempty"`
	Details   string         `json:"details,omitempty"`
	Fields    map[string]any `json:"-"`
}

type TaskBlockerResolution struct {
	Status         TaskBlockerStatus
	ResolutionJSON map[string]any
}

type TaskBlockerSpec struct {
	Kind        TaskBlockerKind
	InputKind   InputKind
	WaitGroupID *string
	PayloadJSON map[string]any
	OutputIDs   []string
}

type TaskBlockerStatus string

type TaskInput struct {
	ID              string           `json:"id" db:"id"`
	WorkspaceID     uint             `json:"workspace_id" db:"workspace_id"`
	TaskID          string           `json:"task_id" db:"task_id"`
	SessionID       string           `json:"session_id" db:"session_id"`
	Seq             int              `json:"seq" db:"seq"`
	Kind            InputKind        `json:"kind" db:"kind"`
	Action          *TaskInputAction `json:"action,omitempty" db:"action"`
	Message         string           `json:"message" db:"message"`
	IdempotencyKey  string           `json:"idempotency_key" db:"idempotency_key"`
	Status          TaskInputStatus  `json:"status" db:"status"`
	ClaimedByRunID  *string          `json:"claimed_by_run_id,omitempty" db:"claimed_by_run_id"`
	ClaimedByExecID *string          `json:"claimed_by_execution_id,omitempty" db:"claimed_by_execution_id"`
	CreatedAt       time.Time        `json:"created_at" db:"created_at"`
	ClaimedAt       *time.Time       `json:"claimed_at,omitempty" db:"claimed_at"`
	ConsumedAt      *time.Time       `json:"consumed_at,omitempty" db:"consumed_at"`
}

type TaskInputAction string

type TaskInputStatus string

type TaskLiveUpdate struct {
	TaskID  string
	RunID   string
	State   AgentTaskState
	Blocker *TaskBlockerSpec
}

type TaskOutput struct {
	ID          string         `json:"id"`
	WorkspaceID uint           `json:"workspace_id"`
	TaskID      string         `json:"task_id"`
	RunID       *string        `json:"run_id,omitempty"`
	AgentID     *string        `json:"agent_id,omitempty"`
	AgentName   string         `json:"agent_name,omitempty"`
	OutputType  string         `json:"output_type"`
	Title       string         `json:"title"`
	Summary     *string        `json:"summary,omitempty"`
	URI         *string        `json:"uri,omitempty"`
	Data        map[string]any `json:"data"`
	Metadata    map[string]any `json:"metadata,omitempty"`
	Status      string         `json:"status"`
	ArchivedAt  *time.Time     `json:"archived_at,omitempty"`
	CreatedAt   time.Time      `json:"created_at"`
}

type TaskOutputBlockingMetadata struct {
	BlockerID       string    `json:"blocker_id,omitempty"`
	Kind            string    `json:"kind,omitempty"`
	InputKind       InputKind `json:"input_kind,omitempty"`
	WaitGroupID     string    `json:"wait_group_id,omitempty"`
	ApprovalSurface bool      `json:"approval_surface,omitempty"`
}

type TaskOutputListFilter struct {
	TaskID          *string  `json:"task_id,omitempty"`
	TaskIDs         []string `json:"task_ids,omitempty"`
	AgentID         *string  `json:"agent_id,omitempty"`
	AgentIDIsNull   bool     `json:"agent_id_is_null,omitempty"`
	OutputType      *string  `json:"output_type,omitempty"`
	ExcludeArchived bool     `json:"exclude_archived,omitempty"`
	SourceViewID    *string  `json:"source_view_id,omitempty"`
	Limit           int      `json:"limit,omitempty"`
}

type TaskStateUpdate struct {
	TaskID        string
	State         AgentTaskState
	DroppedReason *string
	TargetRunID   *string
}

type TaskWakeAgendaItem struct {
	Seq    int    `json:"seq" db:"seq"`
	Type   string `json:"type,omitempty" db:"item_type"`
	Title  string `json:"title" db:"title"`
	Reason string `json:"reason,omitempty" db:"reason"`
}

type Token struct {
	Id          uint       `db:"id" json:"id"`
	ExternalId  string     `db:"external_id" json:"external_id"`
	WorkspaceId *uint      `db:"workspace_id" json:"workspace_id,omitempty"`
	MemberId    *uint      `db:"member_id" json:"member_id,omitempty"`
	TokenType   TokenType  `db:"token_type" json:"token_type"`
	TokenHash   string     `db:"token_hash" json:"-"`
	TokenPrefix *string    `db:"token_prefix" json:"-"`
	Name        string     `db:"name" json:"name"`
	PoolName    *string    `db:"pool_name" json:"pool_name,omitempty"`
	TenantId    *string    `db:"tenant_id" json:"tenant_id,omitempty"`
	ExpiresAt   *time.Time `db:"expires_at" json:"expires_at,omitempty"`
	CreatedAt   time.Time  `db:"created_at" json:"created_at"`
	LastUsedAt  *time.Time `db:"last_used_at" json:"last_used_at,omitempty"`
}

type TokenType string

type TokenValidationResult struct {
	// Common
	TokenType TokenType
	TokenId   uint // Internal ID of the matched token

	// Workspace fields (set for workspace_member tokens)
	WorkspaceId   uint
	WorkspaceExt  string
	WorkspaceName string
	MemberId      uint
	MemberExt     string
	MemberEmail   string
	MemberRole    MemberRole

	// Worker fields (set for worker tokens)
	PoolName string

	// Organization fields (set for organization tokens)
	TenantId string
}

type ToolsConfig struct {
	// Builtin API-key integrations
	Integrations IntegrationsConfig `key:"integrations" json:"integrations"`

	// External MCP servers (tools auto-discovered and exposed as POSIX commands)
	MCP map[string]MCPServerConfig `key:"mcp" json:"mcp"`
}

type TransformRule struct {
	Column  string `json:"column"`
	Source  string `json:"source"`
	Type    string `json:"type"`
	Extract string `json:"extract,omitempty"`
	Format  string `json:"format,omitempty"`
}

type View struct {
	ID            string         `json:"id"`
	WorkspaceID   uint           `json:"workspace_id"`
	Name          string         `json:"name"`
	Description   string         `json:"description"`
	SourceDraftID string         `json:"source_draft_id,omitempty"`
	Definition    ViewDefinition `json:"definition"`
	CreatedAt     time.Time      `json:"created_at"`
	UpdatedAt     time.Time      `json:"updated_at"`
}

type ViewConfig struct {
	Sync ViewSyncConfig `key:"sync" json:"sync"`
}

type ViewContextEntry struct {
	ID           string         `json:"id"`
	ViewID       string         `json:"view_id"`
	Timestamp    int64          `json:"timestamp"`
	EntryType    string         `json:"entry_type"`
	Content      string         `json:"content"`
	SourceTaskID string         `json:"source_task_id,omitempty"`
	Metadata     map[string]any `json:"metadata,omitempty"`
	CompactUpTo  int64          `json:"compact_up_to,omitempty"`
	SeqNum       int64          `json:"seq_num,omitempty"`
}

type ViewDefinition struct {
	Name        string          `json:"name"`
	Description string          `json:"description"`
	Agents      []string        `json:"agents"`
	Sheets      []SheetSpec     `json:"sheets"`
	Actions     []ComponentSpec `json:"actions,omitempty"`
	Settings    *ViewSettings   `json:"settings,omitempty"`
}

type ViewMode string

type ViewOutputFormat string

type ViewOutputSchemaBackend interface {
	GetAgentProfile(ctx context.Context, workspaceID uint, agentID string) (*AgentProfile, error)
	GetView(ctx context.Context, workspaceID uint, viewID string) (*View, error)
	ListViews(ctx context.Context, workspaceID uint) ([]*View, error)
}

type ViewOutputSchemaColumn struct {
	Key     string         `json:"key"`
	Label   string         `json:"label,omitempty"`
	Type    string         `json:"type,omitempty"`
	Options []StatusOption `json:"options,omitempty"`
}

type ViewOutputSchemaContext struct {
	ViewID         string                   `json:"view_id"`
	ViewName       string                   `json:"view_name,omitempty"`
	SheetID        string                   `json:"sheet_id"`
	SheetName      string                   `json:"sheet_name,omitempty"`
	ComponentID    string                   `json:"component_id"`
	ComponentTitle string                   `json:"component_title,omitempty"`
	ArtifactKey    string                   `json:"artifact_key,omitempty"`
	OutputType     string                   `json:"output_type,omitempty"`
	Columns        []ViewOutputSchemaColumn `json:"columns,omitempty"`
	Transform      []TransformRule          `json:"transform,omitempty"`
	TransformHints []string                 `json:"transform_hints,omitempty"`
}

type ViewSettings struct {
	ApprovalPolicy string `json:"approval_policy,omitempty"`
}

type ViewSyncConfig struct {
	HighMatchThreshold float64 `key:"highMatchThreshold" json:"high_match_threshold"`
	ClassifyFloor      float64 `key:"classifyFloor" json:"classify_floor"`
	VectorLimit        int     `key:"vectorLimit" json:"vector_limit"`
	MinInsertCells     int     `key:"minInsertCells" json:"min_insert_cells"`
}

type VirtualFile struct {
	ID         string                 `json:"id"`
	Name       string                 `json:"name"`
	Path       string                 `json:"path"`
	Type       VirtualFileType        `json:"type"`
	IsFolder   bool                   `json:"is_folder"`
	IsSymlink  bool                   `json:"is_symlink,omitempty"`
	IsReadOnly bool                   `json:"is_readonly,omitempty"`
	Size       int64                  `json:"size,omitempty"`
	ModifiedAt *time.Time             `json:"modified_at,omitempty"`
	ChildCount int                    `json:"child_count,omitempty"`
	Metadata   map[string]interface{} `json:"metadata,omitempty"`
}

type VirtualFileListResponse struct {
	Path    string        `json:"path"`
	Entries []VirtualFile `json:"entries"`
}

type VirtualFileSearchResponse struct {
	Query   string        `json:"query"`
	Results []VirtualFile `json:"results"`
}

type VirtualFileTreeResponse struct {
	Path    string        `json:"path"`
	Depth   int           `json:"depth"`
	Entries []VirtualFile `json:"entries"`
}

type VirtualFileType string

type WidgetData struct {
	WidgetID string          `json:"widget_id"`
	Type     string          `json:"type"`
	Metric   *MetricData     `json:"metric,omitempty"`
	MapData  *MapWidgetData  `json:"map_data,omitempty"`
	ListData *ListWidgetData `json:"list_data,omitempty"`
	Status   string          `json:"status,omitempty"`
	Error    string          `json:"error,omitempty"`
	CachedAt *time.Time      `json:"cached_at,omitempty"`
}

type WidgetSpec struct {
	ID          string         `json:"id"`
	Type        string         `json:"type"`
	Title       string         `json:"title"`
	Description string         `json:"description,omitempty"`
	Config      map[string]any `json:"config,omitempty"`
	Size        string         `json:"size,omitempty"`
	W           int            `json:"w,omitempty"`
	H           int            `json:"h,omitempty"`
}

type Worker struct {
	ID           string       `json:"id" redis:"id"`
	Status       WorkerStatus `json:"status" redis:"status"`
	PoolName     string       `json:"pool_name" redis:"pool_name"`
	Hostname     string       `json:"hostname" redis:"hostname"`
	Cpu          int64        `json:"cpu" redis:"cpu"`
	Memory       int64        `json:"memory" redis:"memory"`
	LastSeenAt   time.Time    `json:"last_seen_at" redis:"last_seen_at"`
	RegisteredAt time.Time    `json:"registered_at" redis:"registered_at"`
	Version      string       `json:"version" redis:"version"`
}

type WorkerInfo struct {
	PoolName string
}

type WorkerJobOpts struct {
	PoolName  string
	Cpu       int64
	Memory    int64
	Image     string
	Namespace string
	Labels    map[string]string
	Env       map[string]string
}

type WorkerPaths struct {
	// BundleDir is where sandbox bundles are created
	BundleDir string `key:"bundleDir" json:"bundle_dir"`

	// StateDir is where overlay state is stored (should be tmpfs)
	StateDir string `key:"stateDir" json:"state_dir"`

	// MountDir is where per-task FUSE mounts are created
	MountDir string `key:"mountDir" json:"mount_dir"`

	// CLIBinary is the path to the CLI binary for mounting
	CLIBinary string `key:"cliBinary" json:"cli_binary"`

	// WorkerMount is the global worker FUSE mount path
	WorkerMount string `key:"workerMount" json:"worker_mount"`
}

type WorkerPoolConfig struct {
	// DeploymentName is the K8s Deployment to scale (auto-generated if empty)
	DeploymentName string `key:"deploymentName" json:"deployment_name"`

	// Namespace is the K8s namespace
	Namespace string `key:"namespace" json:"namespace"`

	// MinReplicas is the minimum number of workers
	MinReplicas int32 `key:"minReplicas" json:"min_replicas"`

	// MaxReplicas is the maximum number of workers
	MaxReplicas int32 `key:"maxReplicas" json:"max_replicas"`

	// ScaleDownDelay is how long queue must be empty before scaling down
	ScaleDownDelay time.Duration `key:"scaleDownDelay" json:"scale_down_delay"`

	// Cpu is the CPU request/limit for workers (e.g., "500m", "1")
	Cpu string `key:"cpu" json:"cpu"`

	// Memory is the memory request/limit for workers (e.g., "512Mi", "1Gi")
	Memory string `key:"memory" json:"memory"`

	// RuntimeClassName optionally sets PodSpec.RuntimeClassName.
	RuntimeClassName string `key:"runtimeClassName" json:"runtime_class_name"`

	// NodeSelector pins workers to specific nodes.
	NodeSelector map[string]string `key:"nodeSelector" json:"node_selector"`
}

type WorkerPoolState struct {
	Name             string           `json:"name"`
	Status           WorkerPoolStatus `json:"status"`
	TotalWorkers     int              `json:"total_workers"`
	AvailableWorkers int              `json:"available_workers"`
}

type WorkerPoolStatus string

type WorkerStatus string

type Workspace struct {
	Id         uint      `json:"id" db:"id"`                   // Internal ID for joins
	ExternalId string    `json:"external_id" db:"external_id"` // External UUID for API
	Name       string    `json:"name" db:"name"`
	TenantId   *string   `json:"tenant_id,omitempty" db:"tenant_id"` // Nullable tenant scoping tag
	CreatedAt  time.Time `json:"created_at" db:"created_at"`
	UpdatedAt  time.Time `json:"updated_at" db:"updated_at"`
}

type WorkspaceInfo struct {
	Id         uint
	ExternalId string
	Name       string
}

type WorkspaceMember struct {
	Id          uint       `db:"id" json:"id"`
	ExternalId  string     `db:"external_id" json:"external_id"`
	WorkspaceId uint       `db:"workspace_id" json:"workspace_id"`
	Email       string     `db:"email" json:"email"`
	Name        string     `db:"name" json:"name"`
	Role        MemberRole `db:"role" json:"role"`
	CreatedAt   time.Time  `db:"created_at" json:"created_at"`
	UpdatedAt   time.Time  `db:"updated_at" json:"updated_at"`
}

type WorkspaceStorageConfig struct {
	DefaultBucketPrefix string `key:"defaultBucketPrefix" json:"default_bucket_prefix"`
	DefaultAccessKey    string `key:"defaultAccessKey" json:"default_access_key"`
	DefaultSecretKey    string `key:"defaultSecretKey" json:"default_secret_key"`
	DefaultEndpointUrl  string `key:"defaultEndpointUrl" json:"default_endpoint_url"`
	DefaultRegion       string `key:"defaultRegion" json:"default_region"`
	// PublicEndpointUrl is the browser-reachable S3 endpoint used in presigned URLs.
	// When set, presigned URLs have their host rewritten from DefaultEndpointUrl to this value.
	// Leave empty in production where S3 presigned URLs are already publicly reachable.
	PublicEndpointUrl string `key:"publicEndpointUrl" json:"public_endpoint_url"`
}

type WorkspaceTool struct {
	Id                uint                      `json:"id" db:"id"`
	ExternalId        string                    `json:"external_id" db:"external_id"`
	WorkspaceId       uint                      `json:"workspace_id" db:"workspace_id"`
	Name              string                    `json:"name" db:"name"`
	ProviderType      WorkspaceToolProviderType `json:"provider_type" db:"provider_type"`
	Config            json.RawMessage           `json:"config" db:"config"`               // Serialized MCPServerConfig
	Manifest          json.RawMessage           `json:"manifest,omitempty" db:"manifest"` // Cached tools/list output
	CreatedByMemberId *uint                     `json:"created_by_member_id,omitempty" db:"created_by_member_id"`
	CreatedAt         time.Time                 `json:"created_at" db:"created_at"`
	UpdatedAt         time.Time                 `json:"updated_at" db:"updated_at"`
}