store

type AIRequest struct {
	ID           string          `json:"id"`
	ExecutionID  string          `json:"execution_id"`
	Provider     string          `json:"provider"`
	Model        string          `json:"model"`
	Endpoint     string          `json:"endpoint"`
	RequestJSON  string          `json:"request_json"`
	ResponseJSON *string         `json:"response_json,omitempty"`
	Status       AIRequestStatus `json:"status"`
	ErrorMessage *string         `json:"error_message,omitempty"`
	InputTokens  *int            `json:"input_tokens,omitempty"`
	OutputTokens *int            `json:"output_tokens,omitempty"`
	DurationMs   int64           `json:"duration_ms"`
	CreatedAt    int64           `json:"created_at"`
}

type AIRequestStatus string

type APIToken struct {
	ID        string `json:"id"`
	TokenHash string `json:"-"`
	Name      string `json:"name"`
	CreatedAt int64  `json:"created_at"`
	LastUsed  *int64 `json:"last_used,omitempty"`
	Revoked   bool   `json:"revoked"`
}

type CronStatus string

type DB interface {
	// CreateFunction creates a new function. Returns the created function with
	// timestamps populated.
	CreateFunction(ctx context.Context, fn Function) (Function, error)

	// GetFunction retrieves a function by ID.
	// Returns ErrFunctionNotFound if the function does not exist.
	GetFunction(ctx context.Context, id string) (Function, error)

	// ListFunctions returns paginated functions with their active versions.
	ListFunctions(ctx context.Context, params PaginationParams) ([]FunctionWithActiveVersion, int64, error)

	// UpdateFunction updates a function's fields.
	// Returns ErrFunctionNotFound if the function does not exist.
	UpdateFunction(ctx context.Context, id string, updates UpdateFunctionRequest) error

	// DeleteFunction removes a function and its associated data.
	// Returns ErrFunctionNotFound if the function does not exist.
	DeleteFunction(ctx context.Context, id string) error

	// CreateVersion creates a new version for a function and sets it as active.
	// Returns ErrFunctionNotFound if the function does not exist.
	CreateVersion(ctx context.Context, functionID string, code string, createdBy *string) (FunctionVersion, error)

	// GetVersion retrieves a specific version by function ID and version number.
	// Returns ErrVersionNotFound if the version does not exist.
	GetVersion(ctx context.Context, functionID string, version int) (FunctionVersion, error)

	// GetVersionByID retrieves a version by its unique ID.
	// Returns ErrVersionNotFound if the version does not exist.
	GetVersionByID(ctx context.Context, versionID string) (FunctionVersion, error)

	// ListVersions returns paginated versions for a function.
	ListVersions(ctx context.Context, functionID string, params PaginationParams) ([]FunctionVersion, int64, error)

	// GetActiveVersion retrieves the currently active version for a function.
	// Returns ErrNoActiveVersion if no version is active.
	GetActiveVersion(ctx context.Context, functionID string) (FunctionVersion, error)

	// ActivateVersion sets a specific version as the active version by its ID.
	// Returns ErrVersionNotFound if the version does not exist.
	ActivateVersion(ctx context.Context, versionID string) error

	// DeleteVersion removes a specific version by its ID.
	// Returns ErrVersionNotFound if the version does not exist.
	// Returns ErrCannotDeleteActiveVersion if attempting to delete the active version.
	DeleteVersion(ctx context.Context, versionID string) error

	// CreateExecution records a new execution. Returns the execution with
	// timestamps populated.
	CreateExecution(ctx context.Context, exec Execution) (Execution, error)

	// GetExecution retrieves an execution by ID.
	// Returns ErrExecutionNotFound if the execution does not exist.
	GetExecution(ctx context.Context, executionID string) (Execution, error)

	// UpdateExecution updates an execution's status and results.
	// Returns ErrExecutionNotFound if the execution does not exist.
	UpdateExecution(ctx context.Context, executionID string, status ExecutionStatus, durationMs *int64, errorMsg *string, responseJSON *string) error

	// ListExecutions returns paginated executions for a function.
	ListExecutions(ctx context.Context, functionID string, params PaginationParams) ([]Execution, int64, error)

	// DeleteOldExecutions removes executions older than the given timestamp.
	// Returns the number of deleted records.
	DeleteOldExecutions(ctx context.Context, beforeTimestamp int64) (int64, error)

	// ListFunctionsWithActiveCron returns all functions that have an active cron schedule.
	ListFunctionsWithActiveCron(ctx context.Context) ([]Function, error)

	// Ping verifies the database connection is alive.
	Ping(ctx context.Context) error

	// CreateAPIToken stores a new API token.
	CreateAPIToken(ctx context.Context, token APIToken) (APIToken, error)

	// GetAPITokenByHash retrieves a non-revoked API token by its hash.
	// Returns ErrAPITokenNotFound if no matching token exists.
	GetAPITokenByHash(ctx context.Context, tokenHash string) (APIToken, error)

	// ListAPITokens returns all API tokens ordered by creation date.
	ListAPITokens(ctx context.Context) ([]APIToken, error)

	// RevokeAPIToken marks an API token as revoked.
	// Returns ErrAPITokenNotFound if the token does not exist.
	RevokeAPIToken(ctx context.Context, id string) error

	// UpdateAPITokenLastUsed updates the last_used timestamp for a token.
	UpdateAPITokenLastUsed(ctx context.Context, id string, timestamp int64) error
}

type EmailRequest struct {
	ID           string             `json:"id"`
	ExecutionID  string             `json:"execution_id"`
	From         string             `json:"from"`
	To           []string           `json:"to"`
	Subject      string             `json:"subject"`
	HasText      bool               `json:"has_text"`
	HasHTML      bool               `json:"has_html"`
	RequestJSON  string             `json:"request_json"`
	ResponseJSON *string            `json:"response_json,omitempty"`
	Status       EmailRequestStatus `json:"status"`
	ErrorMessage *string            `json:"error_message,omitempty"`
	EmailID      *string            `json:"email_id,omitempty"`
	DurationMs   int64              `json:"duration_ms"`
	CreatedAt    int64              `json:"created_at"`
}

type EmailRequestStatus string

type Execution struct {
	ID                string           `json:"id"`
	FunctionID        string           `json:"function_id"`
	FunctionVersionID string           `json:"function_version_id"`
	Status            ExecutionStatus  `json:"status"`
	DurationMs        *int64           `json:"duration_ms,omitempty"`
	ErrorMessage      *string          `json:"error_message,omitempty"`
	EventJSON         *string          `json:"event_json,omitempty"`
	ResponseJSON      *string          `json:"response_json,omitempty"`
	Trigger           ExecutionTrigger `json:"trigger"`
	CreatedAt         int64            `json:"created_at"`
}

type ExecutionStatus string

type ExecutionTrigger string

type Function struct {
	ID            string            `json:"id"`
	Name          string            `json:"name"`
	Description   *string           `json:"description,omitempty"`
	EnvVars       map[string]string `json:"env_vars"`
	Disabled      bool              `json:"disabled"`
	RetentionDays *int              `json:"retention_days,omitempty"`
	CronSchedule  *string           `json:"cron_schedule,omitempty"`
	CronStatus    *string           `json:"cron_status,omitempty"`
	SaveResponse  bool              `json:"save_response"`
	CreatedAt     int64             `json:"created_at"`
	UpdatedAt     int64             `json:"updated_at"`
	ScopedData    map[string]string `json:"scoped_data"`
	GlobalData    map[string]string `json:"global_data"`
}

type FunctionVersion struct {
	ID         string  `json:"id"`
	FunctionID string  `json:"function_id"`
	Version    int     `json:"version"`
	Code       string  `json:"code"`
	CreatedAt  int64   `json:"created_at"`
	CreatedBy  *string `json:"created_by,omitempty"`
	IsActive   bool    `json:"is_active"`
}

type FunctionWithActiveVersion struct {
	Function
	ActiveVersion FunctionVersion `json:"active_version"`
}

type LogLevel string

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

type PaginationInfo struct {
	Total  int64 `json:"total"`  // Total number of items
	Limit  int   `json:"limit"`  // Items per page
	Offset int   `json:"offset"` // Items skipped
}

type PaginationParams struct {
	Limit  int // Number of items per page (default: 20, max: 100)
	Offset int // Number of items to skip (default: 0)
}

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

type UpdateFunctionRequest struct {
	Name          *string `json:"name,omitempty"`
	Description   *string `json:"description,omitempty"`
	Code          *string `json:"code,omitempty"`
	Disabled      *bool   `json:"disabled,omitempty"`
	RetentionDays *int    `json:"retention_days,omitempty"`
	CronSchedule  *string `json:"cron_schedule,omitempty"`
	CronStatus    *string `json:"cron_status,omitempty"`
	SaveResponse  *bool   `json:"save_response,omitempty"`
}