admin

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

type APIKeyService interface {
	// Create creates a new API key and returns the key and plaintext token.
	Create(ctx context.Context, opts CreateAPIKeyOptions) (*store.APIKey, string, error)

	// Get retrieves an API key by ID.
	Get(ctx context.Context, id string) (*store.APIKey, error)

	// List returns API keys matching the given options.
	List(ctx context.Context, opts ListAPIKeysOptions) (*ListResult[store.APIKey], error)

	// Revoke revokes an API key with an optional reason.
	Revoke(ctx context.Context, id, reason string) error
}

type ActionLogService interface {
	// Get retrieves an action log by ID.
	Get(ctx context.Context, id string) (*store.ActionLog, error)

	// List returns action logs matching the given options.
	List(ctx context.Context, opts ListActionLogsOptions) (*ListResult[store.ActionLog], error)
}

type ActionLogStore interface {
	GetActionLog(ctx context.Context, id string) (*store.ActionLog, error)
	ListActionLogs(ctx context.Context, opts store.ListActionLogsOptions) (*store.ListResult[store.ActionLog], error)
}

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

type AgentConfigService interface {
	// Create creates a new agent configuration.
	Create(ctx context.Context, opts CreateAgentConfigOptions) (*store.AgentConfig, error)

	// Get retrieves an agent configuration by ID.
	Get(ctx context.Context, id string) (*store.AgentConfig, error)

	// List returns agent configurations matching the given options.
	List(ctx context.Context, opts ListAgentConfigsOptions) (*ListResult[store.AgentConfig], error)

	// Update updates an agent configuration.
	Update(ctx context.Context, id string, opts UpdateAgentConfigOptions) (*store.AgentConfig, error)

	// Delete deletes an agent configuration.
	Delete(ctx context.Context, id string) error
}

type Config struct {
	Host     string
	Port     int
	Username string // Basic auth username
	Password string // Basic auth password
}

type CreateAPIKeyOptions struct {
	Name        string            `json:"name"`
	Scopes      []string          `json:"scopes,omitempty"`
	Labels      map[string]string `json:"labels,omitempty"`
	Annotations map[string]string `json:"annotations,omitempty"`
	ExpiresAt   *time.Time        `json:"expires_at,omitempty"`
}

type CreateAPIKeyRequest struct {
	Name        string            `json:"name"`
	Scopes      []string          `json:"scopes,omitempty"`
	Labels      map[string]string `json:"labels,omitempty"`
	Annotations map[string]string `json:"annotations,omitempty"`
	ExpiresAt   *time.Time        `json:"expires_at,omitempty"`
}

type CreateAPIKeyResponse struct {
	Key      *store.APIKey `json:"key"`
	RawToken string        `json:"raw_token"`
}

type CreateAgentConfigOptions struct {
	Name      string            `json:"name"`
	Agent     string            `json:"agent"`
	APIKey    string            `json:"api_key"`
	Model     string            `json:"model,omitempty"`
	BaseURL   string            `json:"base_url,omitempty"`
	Extra     map[string]any    `json:"extra,omitempty"`
	IsDefault bool              `json:"is_default,omitempty"`
	Labels    map[string]string `json:"labels,omitempty"`
}

type CreateAgentConfigRequest struct {
	Name      string            `json:"name"`
	Agent     string            `json:"agent"`
	APIKey    string            `json:"api_key"`
	Model     string            `json:"model,omitempty"`
	BaseURL   string            `json:"base_url,omitempty"`
	Extra     map[string]any    `json:"extra,omitempty"`
	IsDefault bool              `json:"is_default,omitempty"`
	Labels    map[string]string `json:"labels,omitempty"`
}

type CreateProfileOptions struct {
	Name             string            `json:"name"`
	Description      string            `json:"description,omitempty"`
	ProviderConfigID string            `json:"provider_config_id,omitempty"`
	Resources        map[string]any    `json:"resources,omitempty"`
	Network          map[string]any    `json:"network,omitempty"`
	InitScript       string            `json:"init_script,omitempty"`
	CleanupScript    string            `json:"cleanup_script,omitempty"`
	Tunnels          []map[string]any  `json:"tunnels,omitempty"`
	Selector         map[string]any    `json:"selector,omitempty"`
	Labels           map[string]string `json:"labels,omitempty"`
	Annotations      map[string]string `json:"annotations,omitempty"`
}

type CreateProfileRequest struct {
	Name             string            `json:"name"`
	Description      string            `json:"description,omitempty"`
	ProviderConfigID string            `json:"provider_config_id,omitempty"`
	Resources        map[string]any    `json:"resources,omitempty"`
	Network          map[string]any    `json:"network,omitempty"`
	InitScript       string            `json:"init_script,omitempty"`
	CleanupScript    string            `json:"cleanup_script,omitempty"`
	Tunnels          []map[string]any  `json:"tunnels,omitempty"`
	Selector         map[string]any    `json:"selector,omitempty"`
	Labels           map[string]string `json:"labels,omitempty"`
	Annotations      map[string]string `json:"annotations,omitempty"`
}

type CreateProviderConfigOptions struct {
	Name          string            `json:"name"`
	Provider      string            `json:"provider"`
	Config        map[string]any    `json:"config,omitempty"`
	SuspendConfig map[string]any    `json:"suspend_config,omitempty"`
	IsDefault     bool              `json:"is_default,omitempty"`
	Labels        map[string]string `json:"labels,omitempty"`
}

type CreateProviderConfigRequest struct {
	Name          string            `json:"name"`
	Provider      string            `json:"provider"`
	Config        map[string]any    `json:"config,omitempty"`
	SuspendConfig map[string]any    `json:"suspend_config,omitempty"`
	IsDefault     bool              `json:"is_default,omitempty"`
	Labels        map[string]string `json:"labels,omitempty"`
}

type CreateRunnerTokenOptions struct {
	PoolName  string            `json:"pool_name"`
	Labels    map[string]string `json:"labels,omitempty"`
	ExpiresAt *time.Time        `json:"expires_at,omitempty"`
}

type CreateRunnerTokenRequest struct {
	PoolName  string            `json:"pool_name"`
	Labels    map[string]string `json:"labels,omitempty"`
	ExpiresAt *time.Time        `json:"expires_at,omitempty"`
}

type CreateRunnerTokenResponse struct {
	Token    *store.RunnerToken `json:"token"`
	RawToken string             `json:"raw_token"`
}

type CreateWebhookInput struct {
	Name              string
	URL               string
	Events            []string
	MaxRetries        *int
	RetryDelaySeconds *int
	TimeoutSeconds    *int
	Headers           map[string]string
	TenantID          *string
	Labels            map[string]string
	Annotations       map[string]string
}

type CreateWebhookRequest struct {
	Name              string            `json:"name"`
	URL               string            `json:"url"`
	Events            []string          `json:"events"`
	MaxRetries        *int              `json:"max_retries,omitempty"`
	RetryDelaySeconds *int              `json:"retry_delay_seconds,omitempty"`
	TimeoutSeconds    *int              `json:"timeout_seconds,omitempty"`
	Headers           map[string]string `json:"headers,omitempty"`
	Labels            map[string]string `json:"labels,omitempty"`
	Annotations       map[string]string `json:"annotations,omitempty"`
}

type CreateWebhookResponse struct {
	Webhook *store.Webhook `json:"webhook"`
	Secret  string         `json:"secret"`
}

type ErrorResponse struct {
	Code    string `json:"code"`
	Message string `json:"message"`
}

type HealthResponse struct {
	Status  string `json:"status"`
	Version string `json:"version"`
	Service string `json:"service"`
}

type HealthService interface {
	CheckLiveness(ctx context.Context) health.Response
	CheckReadiness(ctx context.Context) health.Response
}

type InvalidStateError struct {
	Resource string
	ID       string
	Current  string
	Expected string
}

type ListAPIKeysOptions struct {
	Limit  int               `json:"limit,omitempty"`
	Cursor string            `json:"cursor,omitempty"`
	Labels map[string]string `json:"labels,omitempty"`
}

type ListActionLogsOptions struct {
	// Pagination
	Limit  int    `json:"limit,omitempty"`
	Cursor string `json:"cursor,omitempty"`

	// Actor filters
	ActorType string `json:"actor_type,omitempty"` // user, api_key, system, runner
	ActorID   string `json:"actor_id,omitempty"`

	// Action filters
	Action       string `json:"action,omitempty"`        // Exact match
	ActionPrefix string `json:"action_prefix,omitempty"` // Prefix match (e.g., "permission.")

	// Resource filters
	ResourceType string `json:"resource_type,omitempty"`
	ResourceID   string `json:"resource_id,omitempty"`

	// Context filters
	SessionID string `json:"session_id,omitempty"`
	TaskID    string `json:"task_id,omitempty"`

	// Result filters
	Success *bool `json:"success,omitempty"` // nil = all, true = success only, false = failure only

	// Time range filters (RFC3339 format)
	From *time.Time `json:"from,omitempty"` // created_at >= from
	To   *time.Time `json:"to,omitempty"`   // created_at <= to
}

type ListAgentConfigsOptions struct {
	Limit  int               `json:"limit,omitempty"`
	Cursor string            `json:"cursor,omitempty"`
	Agent  string            `json:"agent,omitempty"`
	Labels map[string]string `json:"labels,omitempty"`
}

type ListProfilesOptions struct {
	Limit            int               `json:"limit,omitempty"`
	Cursor           string            `json:"cursor,omitempty"`
	ProviderConfigID string            `json:"provider_config_id,omitempty"`
	IncludeBuiltin   bool              `json:"include_builtin,omitempty"`
	Labels           map[string]string `json:"labels,omitempty"`
}

type ListProviderConfigsOptions struct {
	Limit    int               `json:"limit,omitempty"`
	Cursor   string            `json:"cursor,omitempty"`
	Provider string            `json:"provider,omitempty"`
	Labels   map[string]string `json:"labels,omitempty"`
}

type ListResult[T any] struct {
	Items      []*T   `json:"items"`
	NextCursor string `json:"next_cursor,omitempty"`
	TotalCount int64  `json:"total_count,omitempty"`
}

type ListRunnerTokensOptions struct {
	Limit          int               `json:"limit,omitempty"`
	Cursor         string            `json:"cursor,omitempty"`
	PoolName       string            `json:"pool_name,omitempty"`
	Status         []string          `json:"status,omitempty"`
	IncludeRevoked bool              `json:"include_revoked,omitempty"`
	Labels         map[string]string `json:"labels,omitempty"`
}

type ListRunnersOptions struct {
	Limit    int               `json:"limit,omitempty"`
	Cursor   string            `json:"cursor,omitempty"`
	Status   []string          `json:"status,omitempty"`
	PoolName string            `json:"pool_name,omitempty"`
	Labels   map[string]string `json:"labels,omitempty"`
}

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

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

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

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

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

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

type Option func(*Server)

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

type ProfileService interface {
	// Create creates a new profile.
	Create(ctx context.Context, opts CreateProfileOptions) (*store.Profile, error)

	// Get retrieves a profile by ID.
	Get(ctx context.Context, id string) (*store.Profile, error)

	// List returns profiles matching the given options.
	List(ctx context.Context, opts ListProfilesOptions) (*ListResult[store.Profile], error)

	// Update updates a profile.
	Update(ctx context.Context, id string, opts UpdateProfileOptions) (*store.Profile, error)

	// Delete deletes a profile.
	Delete(ctx context.Context, id string) error
}

type ProfileStore interface {
	CreateProfile(ctx context.Context, profile *store.Profile) error
	GetProfile(ctx context.Context, id string) (*store.Profile, error)
	ListProfiles(ctx context.Context, opts store.ListProfilesOptions) (*store.ListResult[store.Profile], error)
	UpdateProfile(ctx context.Context, id string, updates store.ProfileUpdates) error
	DeleteProfile(ctx context.Context, id string) error
}

type ProviderConfigService interface {
	// Create creates a new provider configuration.
	Create(ctx context.Context, opts CreateProviderConfigOptions) (*store.ProviderConfig, error)

	// Get retrieves a provider configuration by ID.
	Get(ctx context.Context, id string) (*store.ProviderConfig, error)

	// List returns provider configurations matching the given options.
	List(ctx context.Context, opts ListProviderConfigsOptions) (*ListResult[store.ProviderConfig], error)

	// Update updates a provider configuration.
	Update(ctx context.Context, id string, opts UpdateProviderConfigOptions) (*store.ProviderConfig, error)

	// Delete deletes a provider configuration.
	Delete(ctx context.Context, id string) error
}

type ResolutionRequest struct {
	Width  int `json:"width"`
	Height int `json:"height"`
}

type RevokeAPIKeyRequest struct {
	Reason string `json:"reason,omitempty"`
}

type RevokeRunnerTokenRequest struct {
	Reason string `json:"reason,omitempty"`
}

type RotateRunnerTokenResponse struct {
	Token    *store.RunnerToken `json:"token"`
	RawToken string             `json:"raw_token"`
}

type RotateSecretResponse struct {
	Secret       string `json:"secret"`
	SecretPrefix string `json:"secret_prefix"`
}

type RunnerAdminService interface {
	// Spawn creates a new runner using the specified provider.
	Spawn(ctx context.Context, opts SpawnRunnerOptions) (*store.Runner, error)

	// Destroy terminates and removes a runner.
	Destroy(ctx context.Context, id string) error

	// Get retrieves a runner by ID.
	Get(ctx context.Context, id string) (*store.Runner, error)

	// List returns runners matching the given options.
	List(ctx context.Context, opts ListRunnersOptions) (*ListResult[store.Runner], error)
}

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

type RunnerTokenAdminService interface {
	// Create creates a new runner token and returns the token and plaintext secret.
	Create(ctx context.Context, opts CreateRunnerTokenOptions) (*store.RunnerToken, string, error)

	// Get retrieves a runner token by ID.
	Get(ctx context.Context, id string) (*store.RunnerToken, error)

	// List returns runner tokens matching the given options.
	List(ctx context.Context, opts ListRunnerTokensOptions) (*ListResult[store.RunnerToken], error)

	// Revoke revokes a runner token with an optional reason.
	Revoke(ctx context.Context, id, reason string) error

	// Rotate rotates a runner token and returns the new plaintext secret.
	Rotate(ctx context.Context, id string) (*store.RunnerToken, string, error)
}

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

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

type ServiceStatus struct {
	Name    string `json:"name"`
	Port    int    `json:"port"`
	Status  string `json:"status"` // "ok", "error", "unknown"
	Message string `json:"message,omitempty"`
}

type SessionActivator interface {
	// Activate activates a session with the given runner.
	Activate(ctx context.Context, sessionID, runnerID string) error

	// Suspend suspends a session with the given strategy.
	Suspend(ctx context.Context, sessionID, strategy string) error
}

type SignalingConfig struct {
	ReadBufferSize  int
	WriteBufferSize int
	WriteWait       time.Duration
	PongWait        time.Duration
	PingPeriod      time.Duration
	MaxMessageSize  int64
	AllowedOrigins  []string
}

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

type SpawnRunnerOptions struct {
	Name             string            `json:"name,omitempty"`
	ProviderConfigID string            `json:"provider_config_id,omitempty"`
	Provider         string            `json:"provider,omitempty"`
	ProfileID        string            `json:"profile_id,omitempty"`
	Labels           map[string]string `json:"labels,omitempty"`
	WorkspaceID      string            `json:"workspace_id,omitempty"`    // Optional workspace ID for mount
	WorkspaceMount   string            `json:"workspace_mount,omitempty"` // Host path to mount as workspace
}

type SpawnRunnerRequest struct {
	Name             string            `json:"name,omitempty"`
	ProviderConfigID string            `json:"provider_config_id"`
	ProfileID        string            `json:"profile_id,omitempty"`
	Labels           map[string]string `json:"labels,omitempty"`
}

type StatusResponse struct {
	Services []ServiceStatus `json:"services"`
}

type StreamCommandSender interface {
	SendCommand(runnerID string, cmd *pb.ServerCommand) error
}

type StreamManager interface {
	StartStream(ctx context.Context, opts streaming.StreamOptions) (*streaming.Stream, error)
	StopStream(ctx context.Context, streamID string) error
	GetStream(ctx context.Context, streamID string) (*streaming.Stream, error)
	GetStreamBySession(ctx context.Context, sessionID string, streamType streaming.StreamType) (*streaming.Stream, error)
	ListStreams(ctx context.Context, params streaming.ListStreamsParams) ([]*streaming.Stream, int, error)
	ListSessionStreams(ctx context.Context, sessionID string) ([]*streaming.Stream, error)
}

type StreamRequest struct {
	SessionID    string               `json:"session_id"`
	RunnerID     string               `json:"runner_id,omitempty"`
	Type         streaming.StreamType `json:"type"`
	Resolution   *ResolutionRequest   `json:"resolution,omitempty"`
	FrameRate    int                  `json:"frame_rate,omitempty"`
	BitRate      int                  `json:"bitrate,omitempty"`
	AudioEnabled bool                 `json:"audio_enabled,omitempty"`
	InputEnabled bool                 `json:"input_enabled,omitempty"`
	Metadata     map[string]string    `json:"metadata,omitempty"`
}

type StreamResponse struct {
	ID               string             `json:"id"`
	SessionID        string             `json:"session_id"`
	RunnerID         string             `json:"runner_id,omitempty"`
	Type             string             `json:"type"`
	State            string             `json:"state"`
	SignalingURL     string             `json:"signaling_url,omitempty"`
	Resolution       *ResolutionRequest `json:"resolution,omitempty"`
	FrameRate        int                `json:"frame_rate,omitempty"`
	BitRate          int                `json:"bitrate,omitempty"`
	VideoCodec       string             `json:"video_codec,omitempty"`
	AudioCodec       string             `json:"audio_codec,omitempty"`
	AudioEnabled     bool               `json:"audio_enabled"`
	InputEnabled     bool               `json:"input_enabled"`
	ProviderName     string             `json:"provider_name"`
	ProviderStreamID string             `json:"provider_stream_id,omitempty"`
	Error            string             `json:"error,omitempty"`
	Metadata         map[string]string  `json:"metadata,omitempty"`
	CreatedAt        string             `json:"created_at"`
	UpdatedAt        string             `json:"updated_at"`
	StartedAt        string             `json:"started_at,omitempty"`
	StoppedAt        string             `json:"stopped_at,omitempty"`
}

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

type UpdateAgentConfigOptions struct {
	Name      *string            `json:"name,omitempty"`
	APIKey    *string            `json:"api_key,omitempty"`
	Model     *string            `json:"model,omitempty"`
	BaseURL   *string            `json:"base_url,omitempty"`
	Extra     *map[string]any    `json:"extra,omitempty"`
	IsDefault *bool              `json:"is_default,omitempty"`
	Labels    *map[string]string `json:"labels,omitempty"`
}

type UpdateAgentConfigRequest struct {
	Name      *string            `json:"name,omitempty"`
	APIKey    *string            `json:"api_key,omitempty"`
	Model     *string            `json:"model,omitempty"`
	BaseURL   *string            `json:"base_url,omitempty"`
	Extra     *map[string]any    `json:"extra,omitempty"`
	IsDefault *bool              `json:"is_default,omitempty"`
	Labels    *map[string]string `json:"labels,omitempty"`
}

type UpdateProfileOptions struct {
	Name             *string            `json:"name,omitempty"`
	Description      *string            `json:"description,omitempty"`
	ProviderConfigID *string            `json:"provider_config_id,omitempty"`
	Resources        *map[string]any    `json:"resources,omitempty"`
	Network          *map[string]any    `json:"network,omitempty"`
	InitScript       *string            `json:"init_script,omitempty"`
	CleanupScript    *string            `json:"cleanup_script,omitempty"`
	Tunnels          *[]map[string]any  `json:"tunnels,omitempty"`
	Selector         *map[string]any    `json:"selector,omitempty"`
	Labels           *map[string]string `json:"labels,omitempty"`
	Annotations      *map[string]string `json:"annotations,omitempty"`
}

type UpdateProfileRequest struct {
	Name             *string            `json:"name,omitempty"`
	Description      *string            `json:"description,omitempty"`
	ProviderConfigID *string            `json:"provider_config_id,omitempty"`
	Resources        *map[string]any    `json:"resources,omitempty"`
	Network          *map[string]any    `json:"network,omitempty"`
	InitScript       *string            `json:"init_script,omitempty"`
	CleanupScript    *string            `json:"cleanup_script,omitempty"`
	Tunnels          *[]map[string]any  `json:"tunnels,omitempty"`
	Selector         *map[string]any    `json:"selector,omitempty"`
	Labels           *map[string]string `json:"labels,omitempty"`
	Annotations      *map[string]string `json:"annotations,omitempty"`
}

type UpdateProviderConfigOptions struct {
	Name          *string            `json:"name,omitempty"`
	Config        *map[string]any    `json:"config,omitempty"`
	SuspendConfig *map[string]any    `json:"suspend_config,omitempty"`
	IsDefault     *bool              `json:"is_default,omitempty"`
	Labels        *map[string]string `json:"labels,omitempty"`
}

type UpdateProviderConfigRequest struct {
	Name          *string            `json:"name,omitempty"`
	Config        *map[string]any    `json:"config,omitempty"`
	SuspendConfig *map[string]any    `json:"suspend_config,omitempty"`
	IsDefault     *bool              `json:"is_default,omitempty"`
	Labels        *map[string]string `json:"labels,omitempty"`
}

type UpdateWebhookInput struct {
	Name              *string
	URL               *string
	Events            []string
	IsActive          *bool
	MaxRetries        *int
	RetryDelaySeconds *int
	TimeoutSeconds    *int
	Headers           map[string]string
	Labels            map[string]string
	Annotations       map[string]string
}

type UpdateWebhookRequest struct {
	Name              *string           `json:"name,omitempty"`
	URL               *string           `json:"url,omitempty"`
	Events            []string          `json:"events,omitempty"`
	IsActive          *bool             `json:"is_active,omitempty"`
	MaxRetries        *int              `json:"max_retries,omitempty"`
	RetryDelaySeconds *int              `json:"retry_delay_seconds,omitempty"`
	TimeoutSeconds    *int              `json:"timeout_seconds,omitempty"`
	Headers           map[string]string `json:"headers,omitempty"`
	Labels            map[string]string `json:"labels,omitempty"`
	Annotations       map[string]string `json:"annotations,omitempty"`
}

type ValidationError struct {
	Field   string
	Message string
}

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

type WebhookService interface {
	// Create creates a new webhook and returns the webhook and plaintext secret.
	Create(ctx context.Context, input *CreateWebhookInput) (*store.Webhook, string, error)

	// Get retrieves a webhook by ID.
	Get(ctx context.Context, webhookID string) (*store.Webhook, error)

	// List returns webhooks matching the given options.
	List(ctx context.Context, opts store.ListWebhooksOptions) (*store.ListResult[store.Webhook], error)

	// Update updates a webhook.
	Update(ctx context.Context, webhookID string, input *UpdateWebhookInput) error

	// Delete deletes a webhook.
	Delete(ctx context.Context, webhookID string) error

	// RotateSecret generates a new secret for a webhook.
	RotateSecret(ctx context.Context, webhookID string) (string, error)

	// GetEvent retrieves a webhook event by ID.
	GetEvent(ctx context.Context, eventID string) (*store.WebhookEvent, error)

	// ListEvents returns webhook events matching the given options.
	ListEvents(ctx context.Context, opts store.ListWebhookEventsOptions) (*store.ListResult[store.WebhookEvent], error)

	// RetryEvent manually retries a failed webhook event.
	RetryEvent(ctx context.Context, eventID string) error
}