store

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 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 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 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 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 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 Role string

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 StepStatus string

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)
}