store

type APIKey struct {
	ID          uuid.UUID  `json:"id"`
	Name        string     `json:"name"`
	KeyHash     string     `json:"-"`          // SHA-256 hash, never exposed
	KeyPrefix   string     `json:"key_prefix"` // first 8 chars for identification
	CompanyID   uuid.UUID  `json:"company_id"`
	OrgID       *uuid.UUID `json:"org_id,omitempty"`     // optional scoping
	ProjectID   *uuid.UUID `json:"project_id,omitempty"` // optional scoping
	Permissions []string   `json:"permissions"`          // e.g., ["read", "write", "admin"]
	CreatedBy   uuid.UUID  `json:"created_by"`
	CreatedAt   time.Time  `json:"created_at"`
	ExpiresAt   *time.Time `json:"expires_at,omitempty"`
	LastUsedAt  *time.Time `json:"last_used_at,omitempty"`
	IsActive    bool       `json:"is_active"`
}

type APIKeyStore interface {
	// Create creates a new API key and returns the raw key (only available at creation time).
	Create(ctx context.Context, key *APIKey) (rawKey string, err error)
	// Get retrieves an API key by ID.
	Get(ctx context.Context, id uuid.UUID) (*APIKey, error)
	// GetByHash retrieves an API key by its hash.
	GetByHash(ctx context.Context, keyHash string) (*APIKey, error)
	// List returns all API keys for a company.
	List(ctx context.Context, companyID uuid.UUID) ([]*APIKey, error)
	// Delete removes an API key by ID.
	Delete(ctx context.Context, id uuid.UUID) error
	// UpdateLastUsed updates the last_used_at timestamp for an API key.
	UpdateLastUsed(ctx context.Context, id uuid.UUID) error
	// Validate hashes the raw key and looks up the corresponding API key.
	// Returns ErrNotFound if no matching key exists, or ErrKeyExpired / ErrKeyInactive
	// for keys that exist but cannot be used.
	Validate(ctx context.Context, rawKey string) (*APIKey, error)
}

type AuditEntry struct {
	ID           int64           `json:"id"`
	UserID       *uuid.UUID      `json:"user_id,omitempty"`
	Action       string          `json:"action"`
	ResourceType string          `json:"resource_type"`
	ResourceID   *uuid.UUID      `json:"resource_id,omitempty"`
	Details      json.RawMessage `json:"details,omitempty"`
	IPAddress    string          `json:"ip_address,omitempty"`
	UserAgent    string          `json:"user_agent,omitempty"`
	CreatedAt    time.Time       `json:"created_at"`
}

type AuditFilter struct {
	UserID       *uuid.UUID
	Action       string
	ResourceType string
	ResourceID   *uuid.UUID
	Since        *time.Time
	Until        *time.Time
	Pagination   Pagination
}

type AuditStore interface {
	// Record adds an audit entry.
	Record(ctx context.Context, e *AuditEntry) error
	// Query returns audit entries matching the filter.
	Query(ctx context.Context, f AuditFilter) ([]*AuditEntry, error)
}

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

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

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

type BackfillRequest struct {
	ID           uuid.UUID      `json:"id"`
	PipelineName string         `json:"pipeline_name"`
	SourceQuery  string         `json:"source_query"`
	StartTime    *time.Time     `json:"start_time,omitempty"`
	EndTime      *time.Time     `json:"end_time,omitempty"`
	Status       BackfillStatus `json:"status"`
	CreatedAt    time.Time      `json:"created_at"`
	CompletedAt  *time.Time     `json:"completed_at,omitempty"`
	TotalEvents  int64          `json:"total_events"`
	Processed    int64          `json:"processed"`
	Failed       int64          `json:"failed"`
	ErrorMsg     string         `json:"error_message,omitempty"`
}

type BackfillStatus string

type BackfillStore interface {
	// Create inserts a new backfill request.
	Create(ctx context.Context, req *BackfillRequest) error
	// Get retrieves a backfill request by ID.
	Get(ctx context.Context, id uuid.UUID) (*BackfillRequest, error)
	// List returns all backfill requests, ordered by creation time descending.
	List(ctx context.Context) ([]*BackfillRequest, error)
	// UpdateProgress updates the processed and failed counts for a backfill request.
	UpdateProgress(ctx context.Context, id uuid.UUID, processed, failed int64) error
	// UpdateStatus sets the status and optional error message for a backfill request.
	UpdateStatus(ctx context.Context, id uuid.UUID, status BackfillStatus, errMsg string) error
	// Cancel cancels a pending or running backfill request.
	Cancel(ctx context.Context, id uuid.UUID) error
}

type Company struct {
	ID        uuid.UUID       `json:"id"`
	Name      string          `json:"name"`
	Slug      string          `json:"slug"`
	OwnerID   uuid.UUID       `json:"owner_id"`
	Metadata  json.RawMessage `json:"metadata,omitempty"`
	CreatedAt time.Time       `json:"created_at"`
	UpdatedAt time.Time       `json:"updated_at"`
}

type CompanyFilter struct {
	OwnerID    *uuid.UUID
	Slug       string
	Pagination Pagination
}

type CompanyStore interface {
	Create(ctx context.Context, c *Company) error
	Get(ctx context.Context, id uuid.UUID) (*Company, error)
	GetBySlug(ctx context.Context, slug string) (*Company, error)
	Update(ctx context.Context, c *Company) error
	Delete(ctx context.Context, id uuid.UUID) error
	List(ctx context.Context, f CompanyFilter) ([]*Company, error)
	ListForUser(ctx context.Context, userID uuid.UUID) ([]*Company, error)
}

type CrossWorkflowLink struct {
	ID               uuid.UUID       `json:"id"`
	SourceWorkflowID uuid.UUID       `json:"source_workflow_id"`
	TargetWorkflowID uuid.UUID       `json:"target_workflow_id"`
	LinkType         string          `json:"link_type"`
	Config           json.RawMessage `json:"config,omitempty"`
	CreatedBy        uuid.UUID       `json:"created_by"`
	CreatedAt        time.Time       `json:"created_at"`
}

type CrossWorkflowLinkFilter struct {
	SourceWorkflowID *uuid.UUID
	TargetWorkflowID *uuid.UUID
	LinkType         string
	Pagination       Pagination
}

type CrossWorkflowLinkStore interface {
	Create(ctx context.Context, l *CrossWorkflowLink) error
	Get(ctx context.Context, id uuid.UUID) (*CrossWorkflowLink, error)
	Delete(ctx context.Context, id uuid.UUID) error
	List(ctx context.Context, f CrossWorkflowLinkFilter) ([]*CrossWorkflowLink, error)
}

type DLQEntry struct {
	ID            uuid.UUID       `json:"id"`
	OriginalEvent json.RawMessage `json:"original_event"`
	PipelineName  string          `json:"pipeline_name"`
	StepName      string          `json:"step_name"`
	ErrorMessage  string          `json:"error_message"`
	ErrorType     string          `json:"error_type"`
	RetryCount    int             `json:"retry_count"`
	MaxRetries    int             `json:"max_retries"`
	Status        DLQStatus       `json:"status"`
	CreatedAt     time.Time       `json:"created_at"`
	UpdatedAt     time.Time       `json:"updated_at"`
	ResolvedAt    *time.Time      `json:"resolved_at,omitempty"`
	Metadata      map[string]any  `json:"metadata,omitempty"`
}

type DLQFilter struct {
	PipelineName string
	StepName     string
	Status       DLQStatus
	ErrorType    string
	Limit        int
	Offset       int
}

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

type DLQStatus string

type DLQStore interface {
	// Add inserts a new DLQ entry.
	Add(ctx context.Context, entry *DLQEntry) error
	// Get retrieves a DLQ entry by ID.
	Get(ctx context.Context, id uuid.UUID) (*DLQEntry, error)
	// List returns DLQ entries matching the given filter.
	List(ctx context.Context, filter DLQFilter) ([]*DLQEntry, error)
	// Count returns the number of DLQ entries matching the given filter.
	Count(ctx context.Context, filter DLQFilter) (int64, error)
	// UpdateStatus sets the status of a DLQ entry.
	UpdateStatus(ctx context.Context, id uuid.UUID, status DLQStatus) error
	// Retry increments retry_count and sets status to "retrying".
	Retry(ctx context.Context, id uuid.UUID) error
	// Discard sets the status to "discarded".
	Discard(ctx context.Context, id uuid.UUID) error
	// Resolve sets the status to "resolved" and sets resolved_at.
	Resolve(ctx context.Context, id uuid.UUID) error
	// Purge removes resolved/discarded entries older than the given duration.
	Purge(ctx context.Context, olderThan time.Duration) (int64, error)
}

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

type DiffSummary struct {
	TotalSteps   int `json:"total_steps"`
	SameSteps    int `json:"same_steps"`
	DiffSteps    int `json:"different_steps"`
	AddedSteps   int `json:"added_steps"`
	RemovedSteps int `json:"removed_steps"`
}

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

type EventStore interface {
	// Append adds a new event to the log for a given execution.
	Append(ctx context.Context, executionID uuid.UUID, eventType string, data map[string]any) error
	// GetEvents returns all events for an execution ordered by sequence number.
	GetEvents(ctx context.Context, executionID uuid.UUID) ([]ExecutionEvent, error)
	// GetTimeline materializes a complete execution view from its event stream.
	GetTimeline(ctx context.Context, executionID uuid.UUID) (*MaterializedExecution, error)
	// ListExecutions returns materialized executions matching the given filter.
	ListExecutions(ctx context.Context, filter ExecutionEventFilter) ([]MaterializedExecution, error)
}

type ExecutionDiff struct {
	ExecutionA uuid.UUID   `json:"execution_a"`
	ExecutionB uuid.UUID   `json:"execution_b"`
	StepDiffs  []StepDiff  `json:"step_diffs"`
	Summary    DiffSummary `json:"summary"`
}

type ExecutionEvent struct {
	ID          uuid.UUID       `json:"id"`
	ExecutionID uuid.UUID       `json:"execution_id"`
	SequenceNum int64           `json:"sequence_num"`
	EventType   string          `json:"event_type"`
	EventData   json.RawMessage `json:"event_data"`
	CreatedAt   time.Time       `json:"created_at"`
}

type ExecutionEventFilter struct {
	Pipeline string
	TenantID string
	Status   string
	Since    *time.Time
	Until    *time.Time
	Limit    int
	Offset   int
}

type ExecutionFilter struct {
	WorkflowID *uuid.UUID
	Status     ExecutionStatus
	Since      *time.Time
	Until      *time.Time
	Pagination Pagination
}

type ExecutionLog struct {
	ID          int64           `json:"id"`
	WorkflowID  uuid.UUID       `json:"workflow_id"`
	ExecutionID *uuid.UUID      `json:"execution_id,omitempty"`
	Level       LogLevel        `json:"level"`
	Message     string          `json:"message"`
	ModuleName  string          `json:"module_name,omitempty"`
	Fields      json.RawMessage `json:"fields,omitempty"`
	CreatedAt   time.Time       `json:"created_at"`
}

type ExecutionStatus string

type ExecutionStep struct {
	ID           uuid.UUID       `json:"id"`
	ExecutionID  uuid.UUID       `json:"execution_id"`
	StepName     string          `json:"step_name"`
	StepType     string          `json:"step_type"`
	InputData    json.RawMessage `json:"input_data,omitempty"`
	OutputData   json.RawMessage `json:"output_data,omitempty"`
	Status       StepStatus      `json:"status"`
	ErrorMessage string          `json:"error_message,omitempty"`
	StartedAt    *time.Time      `json:"started_at,omitempty"`
	CompletedAt  *time.Time      `json:"completed_at,omitempty"`
	DurationMs   *int64          `json:"duration_ms,omitempty"`
	SequenceNum  int             `json:"sequence_num"`
	Metadata     json.RawMessage `json:"metadata,omitempty"`
}

type ExecutionStore interface {
	// CreateExecution creates a new workflow execution record.
	CreateExecution(ctx context.Context, e *WorkflowExecution) error
	// GetExecution retrieves an execution by ID.
	GetExecution(ctx context.Context, id uuid.UUID) (*WorkflowExecution, error)
	// UpdateExecution updates an execution record.
	UpdateExecution(ctx context.Context, e *WorkflowExecution) error
	// ListExecutions lists executions matching the filter.
	ListExecutions(ctx context.Context, f ExecutionFilter) ([]*WorkflowExecution, error)

	// CreateStep creates a new execution step.
	CreateStep(ctx context.Context, s *ExecutionStep) error
	// UpdateStep updates an execution step.
	UpdateStep(ctx context.Context, s *ExecutionStep) error
	// ListSteps lists steps for an execution.
	ListSteps(ctx context.Context, executionID uuid.UUID) ([]*ExecutionStep, error)

	// CountByStatus returns execution counts grouped by status for a workflow.
	CountByStatus(ctx context.Context, workflowID uuid.UUID) (map[ExecutionStatus]int, error)
}

type FieldChange struct {
	Path   string `json:"path"`
	ValueA any    `json:"value_a"`
	ValueB any    `json:"value_b"`
}

type FileInfo struct {
	Name        string    `json:"name"`
	Path        string    `json:"path"`
	Size        int64     `json:"size"`
	ModTime     time.Time `json:"modTime"`
	IsDir       bool      `json:"isDir"`
	ContentType string    `json:"contentType,omitempty"`
}

type IAMProviderConfig struct {
	ID           uuid.UUID       `json:"id"`
	CompanyID    uuid.UUID       `json:"company_id"`
	ProviderType IAMProviderType `json:"provider_type"`
	Name         string          `json:"name"`
	Config       json.RawMessage `json:"config"`
	Enabled      bool            `json:"enabled"`
	CreatedAt    time.Time       `json:"created_at"`
	UpdatedAt    time.Time       `json:"updated_at"`
}

type IAMProviderFilter struct {
	CompanyID    *uuid.UUID
	ProviderType IAMProviderType
	Enabled      *bool
	Pagination   Pagination
}

type IAMProviderType string

type IAMRoleMapping struct {
	ID                 uuid.UUID `json:"id"`
	ProviderID         uuid.UUID `json:"provider_id"`
	ExternalIdentifier string    `json:"external_identifier"`
	ResourceType       string    `json:"resource_type"`
	ResourceID         uuid.UUID `json:"resource_id"`
	Role               Role      `json:"role"`
	CreatedAt          time.Time `json:"created_at"`
}

type IAMRoleMappingFilter struct {
	ProviderID         *uuid.UUID
	ExternalIdentifier string
	ResourceType       string
	ResourceID         *uuid.UUID
	Pagination         Pagination
}

type IAMStore interface {
	// CreateProvider creates a new IAM provider config.
	CreateProvider(ctx context.Context, p *IAMProviderConfig) error
	// GetProvider retrieves an IAM provider by ID.
	GetProvider(ctx context.Context, id uuid.UUID) (*IAMProviderConfig, error)
	// UpdateProvider updates an IAM provider config.
	UpdateProvider(ctx context.Context, p *IAMProviderConfig) error
	// DeleteProvider deletes an IAM provider config.
	DeleteProvider(ctx context.Context, id uuid.UUID) error
	// ListProviders lists IAM providers matching the filter.
	ListProviders(ctx context.Context, f IAMProviderFilter) ([]*IAMProviderConfig, error)

	// CreateMapping creates a new IAM role mapping.
	CreateMapping(ctx context.Context, m *IAMRoleMapping) error
	// GetMapping retrieves an IAM role mapping by ID.
	GetMapping(ctx context.Context, id uuid.UUID) (*IAMRoleMapping, error)
	// DeleteMapping deletes an IAM role mapping.
	DeleteMapping(ctx context.Context, id uuid.UUID) error
	// ListMappings lists IAM role mappings matching the filter.
	ListMappings(ctx context.Context, f IAMRoleMappingFilter) ([]*IAMRoleMapping, error)

	// ResolveRole resolves the role for an external identifier on a resource.
	ResolveRole(ctx context.Context, providerID uuid.UUID, externalID string, resourceType string, resourceID uuid.UUID) (Role, error)
}

type IdempotencyRecord struct {
	Key         string          `json:"key"`
	ExecutionID uuid.UUID       `json:"execution_id"`
	StepName    string          `json:"step_name"`
	Result      json.RawMessage `json:"result"`
	CreatedAt   time.Time       `json:"created_at"`
	ExpiresAt   time.Time       `json:"expires_at"`
}

type IdempotencyStore interface {
	// Check returns the stored result if the key exists and hasn't expired.
	// Returns nil, nil if the key doesn't exist.
	Check(ctx context.Context, key string) (*IdempotencyRecord, error)
	// Store saves a result for an idempotency key with an expiration time.
	Store(ctx context.Context, record *IdempotencyRecord) error
	// Cleanup removes expired keys.
	Cleanup(ctx context.Context) (int64, error)
}

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

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

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

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

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

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

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

type LogFilter struct {
	WorkflowID  *uuid.UUID
	ExecutionID *uuid.UUID
	Level       LogLevel
	ModuleName  string
	Since       *time.Time
	Until       *time.Time
	Pagination  Pagination
}

type LogLevel string

type LogStore interface {
	// Append adds a log entry.
	Append(ctx context.Context, l *ExecutionLog) error
	// Query returns log entries matching the filter.
	Query(ctx context.Context, f LogFilter) ([]*ExecutionLog, error)
	// CountByLevel returns log counts grouped by level for a workflow.
	CountByLevel(ctx context.Context, workflowID uuid.UUID) (map[LogLevel]int, error)
}

type MaterializedExecution struct {
	ExecutionID uuid.UUID          `json:"execution_id"`
	Pipeline    string             `json:"pipeline,omitempty"`
	TenantID    string             `json:"tenant_id,omitempty"`
	Status      string             `json:"status"`
	Steps       []MaterializedStep `json:"steps,omitempty"`
	Error       string             `json:"error,omitempty"`
	StartedAt   *time.Time         `json:"started_at,omitempty"`
	CompletedAt *time.Time         `json:"completed_at,omitempty"`
	EventCount  int                `json:"event_count"`
}

type MaterializedStep struct {
	StepName    string          `json:"step_name"`
	StepType    string          `json:"step_type,omitempty"`
	Status      string          `json:"status"`
	InputData   json.RawMessage `json:"input_data,omitempty"`
	OutputData  json.RawMessage `json:"output_data,omitempty"`
	Error       string          `json:"error,omitempty"`
	Route       string          `json:"route,omitempty"`
	Retries     int             `json:"retries,omitempty"`
	StartedAt   *time.Time      `json:"started_at,omitempty"`
	CompletedAt *time.Time      `json:"completed_at,omitempty"`
}

type Membership struct {
	ID        uuid.UUID  `json:"id"`
	UserID    uuid.UUID  `json:"user_id"`
	CompanyID uuid.UUID  `json:"company_id"`
	ProjectID *uuid.UUID `json:"project_id,omitempty"` // nil means company-level membership
	Role      Role       `json:"role"`
	CreatedAt time.Time  `json:"created_at"`
	UpdatedAt time.Time  `json:"updated_at"`
}

type MembershipFilter struct {
	UserID     *uuid.UUID
	CompanyID  *uuid.UUID
	ProjectID  *uuid.UUID
	Role       Role
	Pagination Pagination
}

type MembershipStore interface {
	Create(ctx context.Context, m *Membership) error
	Get(ctx context.Context, id uuid.UUID) (*Membership, error)
	Update(ctx context.Context, m *Membership) error
	Delete(ctx context.Context, id uuid.UUID) error
	List(ctx context.Context, f MembershipFilter) ([]*Membership, error)
	// GetEffectiveRole resolves the effective role for a user in a project,
	// cascading from company-level if no project-level membership exists.
	GetEffectiveRole(ctx context.Context, userID, companyID uuid.UUID, projectID *uuid.UUID) (Role, error)
}

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

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

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

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

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

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

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

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

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

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

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

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

type OAuthProvider string

type Organization = Company

type OrganizationStore = CompanyStore

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

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

type PGConfig struct {
	URL             string `yaml:"url" json:"url"`
	MaxConns        int32  `yaml:"max_conns" json:"max_conns"`
	MinConns        int32  `yaml:"min_conns" json:"min_conns"`
	MaxConnIdleTime string `yaml:"max_conn_idle_time" json:"max_conn_idle_time"`
}

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

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

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

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

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

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

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

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

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

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

type Pagination struct {
	Offset int
	Limit  int
}

type Project struct {
	ID          uuid.UUID       `json:"id"`
	CompanyID   uuid.UUID       `json:"company_id"`
	Name        string          `json:"name"`
	Slug        string          `json:"slug"`
	Description string          `json:"description,omitempty"`
	Metadata    json.RawMessage `json:"metadata,omitempty"`
	CreatedAt   time.Time       `json:"created_at"`
	UpdatedAt   time.Time       `json:"updated_at"`
}

type ProjectFilter struct {
	CompanyID  *uuid.UUID
	Slug       string
	Pagination Pagination
}

type ProjectStore interface {
	Create(ctx context.Context, p *Project) error
	Get(ctx context.Context, id uuid.UUID) (*Project, error)
	GetBySlug(ctx context.Context, companyID uuid.UUID, slug string) (*Project, error)
	Update(ctx context.Context, p *Project) error
	Delete(ctx context.Context, id uuid.UUID) error
	List(ctx context.Context, f ProjectFilter) ([]*Project, error)
	ListForUser(ctx context.Context, userID uuid.UUID) ([]*Project, error)
}

type ReplayHandler struct {

	// ReplayFunc is called to actually replay an execution. It receives the
	// original execution's timeline and returns a new execution ID.
	// If nil, replays are queued but not executed.
	ReplayFunc func(original *MaterializedExecution, mode string, modifications map[string]any) (uuid.UUID, error)
	// contains filtered or unexported fields
}

type ReplayRequest struct {
	Mode          string         `json:"mode"`                    // "exact" or "modified"
	Modifications map[string]any `json:"modifications,omitempty"` // step overrides for "modified" mode
}

type ReplayResult struct {
	OriginalExecutionID uuid.UUID `json:"original_execution_id"`
	NewExecutionID      uuid.UUID `json:"new_execution_id"`
	Type                string    `json:"type"` // "replay"
	Mode                string    `json:"mode"`
	Status              string    `json:"status"` // "queued", "started"
}

type Role string

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

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

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

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

type Session struct {
	ID        uuid.UUID       `json:"id"`
	UserID    uuid.UUID       `json:"user_id"`
	Token     string          `json:"-"`
	IPAddress string          `json:"ip_address"`
	UserAgent string          `json:"user_agent"`
	Metadata  json.RawMessage `json:"metadata,omitempty"`
	Active    bool            `json:"active"`
	CreatedAt time.Time       `json:"created_at"`
	ExpiresAt time.Time       `json:"expires_at"`
}

type SessionFilter struct {
	UserID     *uuid.UUID
	Active     *bool
	Pagination Pagination
}

type SessionStore interface {
	Create(ctx context.Context, s *Session) error
	Get(ctx context.Context, id uuid.UUID) (*Session, error)
	GetByToken(ctx context.Context, token string) (*Session, error)
	Update(ctx context.Context, s *Session) error
	Delete(ctx context.Context, id uuid.UUID) error
	List(ctx context.Context, f SessionFilter) ([]*Session, error)
	DeleteExpired(ctx context.Context) (int64, error)
}

type StepDiff struct {
	StepName  string         `json:"step_name"`
	Status    string         `json:"status"` // "same", "different", "added", "removed"
	OutputA   map[string]any `json:"output_a,omitempty"`
	OutputB   map[string]any `json:"output_b,omitempty"`
	DurationA time.Duration  `json:"duration_a"`
	DurationB time.Duration  `json:"duration_b"`
	Changes   []FieldChange  `json:"changes,omitempty"`
}

type StepMock struct {
	ID            uuid.UUID      `json:"id"`
	PipelineName  string         `json:"pipeline_name"`
	StepName      string         `json:"step_name"`
	Response      map[string]any `json:"response"`
	ErrorResponse string         `json:"error_response,omitempty"`
	Delay         time.Duration  `json:"delay,omitempty"`
	Enabled       bool           `json:"enabled"`
	HitCount      int64          `json:"hit_count"`
	CreatedAt     time.Time      `json:"created_at"`
}

type StepMockStore interface {
	// Set creates or updates a mock for a specific pipeline step.
	Set(ctx context.Context, mock *StepMock) error
	// Get retrieves a mock for a specific pipeline and step.
	Get(ctx context.Context, pipeline, step string) (*StepMock, error)
	// List returns all mocks for a given pipeline.
	List(ctx context.Context, pipeline string) ([]*StepMock, error)
	// Remove deletes a mock for a specific pipeline and step.
	Remove(ctx context.Context, pipeline, step string) error
	// ClearAll removes all mocks.
	ClearAll(ctx context.Context) error
	// IncrementHitCount increments the hit count for a mock.
	IncrementHitCount(ctx context.Context, pipeline, step string) error
}

type StepStatus string

type StorageProvider interface {
	// List returns file entries under the given prefix.
	List(ctx context.Context, prefix string) ([]FileInfo, error)
	// Get retrieves a file by path.
	Get(ctx context.Context, path string) (io.ReadCloser, error)
	// Put writes a file at the given path.
	Put(ctx context.Context, path string, reader io.Reader) error
	// Delete removes a file at the given path.
	Delete(ctx context.Context, path string) error
	// Stat returns metadata for a file.
	Stat(ctx context.Context, path string) (FileInfo, error)
	// MkdirAll creates a directory path and all parents that do not exist.
	MkdirAll(ctx context.Context, path string) error
}

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

type User struct {
	ID            uuid.UUID       `json:"id"`
	Email         string          `json:"email"`
	PasswordHash  string          `json:"-"`
	DisplayName   string          `json:"display_name"`
	AvatarURL     string          `json:"avatar_url,omitempty"`
	OAuthProvider OAuthProvider   `json:"oauth_provider,omitempty"`
	OAuthID       string          `json:"oauth_id,omitempty"`
	Active        bool            `json:"active"`
	Metadata      json.RawMessage `json:"metadata,omitempty"`
	CreatedAt     time.Time       `json:"created_at"`
	UpdatedAt     time.Time       `json:"updated_at"`
	LastLoginAt   *time.Time      `json:"last_login_at,omitempty"`
}

type UserFilter struct {
	Email         string
	Active        *bool
	OAuthProvider OAuthProvider
	Pagination    Pagination
}

type UserStore interface {
	Create(ctx context.Context, u *User) error
	Get(ctx context.Context, id uuid.UUID) (*User, error)
	GetByEmail(ctx context.Context, email string) (*User, error)
	GetByOAuth(ctx context.Context, provider OAuthProvider, oauthID string) (*User, error)
	Update(ctx context.Context, u *User) error
	Delete(ctx context.Context, id uuid.UUID) error
	List(ctx context.Context, f UserFilter) ([]*User, error)
}

type WorkflowExecution struct {
	ID           uuid.UUID       `json:"id"`
	WorkflowID   uuid.UUID       `json:"workflow_id"`
	TriggerType  string          `json:"trigger_type"`
	TriggerData  json.RawMessage `json:"trigger_data,omitempty"`
	Status       ExecutionStatus `json:"status"`
	OutputData   json.RawMessage `json:"output_data,omitempty"`
	ErrorMessage string          `json:"error_message,omitempty"`
	ErrorStack   string          `json:"error_stack,omitempty"`
	StartedAt    time.Time       `json:"started_at"`
	CompletedAt  *time.Time      `json:"completed_at,omitempty"`
	DurationMs   *int64          `json:"duration_ms,omitempty"`
	Metadata     json.RawMessage `json:"metadata,omitempty"`
}

type WorkflowFilter struct {
	ProjectID  *uuid.UUID
	Status     WorkflowStatus
	Slug       string
	Pagination Pagination
}

type WorkflowRecord struct {
	ID          uuid.UUID      `json:"id"`
	ProjectID   uuid.UUID      `json:"project_id"`
	Name        string         `json:"name"`
	Slug        string         `json:"slug"`
	Description string         `json:"description,omitempty"`
	ConfigYAML  string         `json:"config_yaml"`
	Version     int            `json:"version"`
	Status      WorkflowStatus `json:"status"`
	CreatedBy   uuid.UUID      `json:"created_by"`
	UpdatedBy   uuid.UUID      `json:"updated_by"`
	CreatedAt   time.Time      `json:"created_at"`
	UpdatedAt   time.Time      `json:"updated_at"`
}

type WorkflowStatus string

type WorkflowStore interface {
	Create(ctx context.Context, w *WorkflowRecord) error
	Get(ctx context.Context, id uuid.UUID) (*WorkflowRecord, error)
	GetBySlug(ctx context.Context, projectID uuid.UUID, slug string) (*WorkflowRecord, error)
	Update(ctx context.Context, w *WorkflowRecord) error
	Delete(ctx context.Context, id uuid.UUID) error
	List(ctx context.Context, f WorkflowFilter) ([]*WorkflowRecord, error)
	// GetVersion retrieves a specific version of a workflow.
	GetVersion(ctx context.Context, id uuid.UUID, version int) (*WorkflowRecord, error)
	// ListVersions returns all versions for a given workflow ID.
	ListVersions(ctx context.Context, id uuid.UUID) ([]*WorkflowRecord, error)
}

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