models

type Action struct {
	// Action Identifier (unique across project/domain/run_name/name)
	Project string `db:"project"`
	Domain  string `db:"domain"`
	RunName string `db:"run_name"`
	Name    string `db:"name"`

	// Parent action (NULL for root actions/runs)
	ParentActionName sql.NullString `db:"parent_action_name"`

	// High-level status for quick queries/filtering.
	// Stores the proto ActionPhase enum integer value directly (e.g. 1 = QUEUED).
	Phase int32 `db:"phase"`

	// Who initiated this run(web, CLI, scheduler, etc.)
	RunSource string `db:"run_source" json:"run_source,omitempty"`

	// Trigger fields — only set for runs created via RUN_SOURCE_SCHEDULE_TRIGGER.
	TriggerTaskName sql.NullString `db:"trigger_task_name"`
	TriggerName     sql.NullString `db:"trigger_name"`
	TriggerRevision sql.NullInt64  `db:"trigger_revision"`
	// TriggerType stores the automation type string (e.g. "TYPE_SCHEDULE").
	TriggerType sql.NullString `db:"trigger_type"`

	// Action type (task, trace, condition). Stores workflow.ActionType enum value.
	ActionType int32 `db:"action_type"`
	// Group this action belongs to, if applicable.
	ActionGroup sql.NullString `db:"action_group"`

	// Task reference columns
	TaskProject sql.NullString `db:"task_project"`
	TaskDomain  sql.NullString `db:"task_domain"`
	TaskName    sql.NullString `db:"task_name"`
	TaskVersion sql.NullString `db:"task_version"`

	// Task metadata columns
	TaskType        string         `db:"task_type"`
	TaskShortName   sql.NullString `db:"task_short_name"`
	FunctionName    string         `db:"function_name"`
	EnvironmentName sql.NullString `db:"environment_name"`

	// Serialized protobuf messages
	// ActionSpec contains the full action specification proto
	ActionSpec []byte `db:"action_spec"`

	// ActionDetails contains the full action details proto:
	// - ActionStatus (phase, timestamps, error, cache status, etc.)
	// - ActionAttempts array (all attempts with their phase transitions, cluster events, logs, etc.)
	// - Any other runtime state
	ActionDetails []byte `db:"action_details"`

	// DetailedInfo stores a serialized RunInfo proto containing metadata such as
	// the task spec digest (for looking up the resolved spec) and storage URIs.
	DetailedInfo []byte `db:"detailed_info"`

	// RunSpec stores a serialized task.RunSpec proto (labels, annotations, envs,
	// interruptible, cluster, etc.) for this action's run.
	RunSpec []byte `db:"run_spec"`

	// Abort tracking — set when a user requests abort; cleared once the pod is confirmed terminated.
	AbortRequestedAt  *time.Time `db:"abort_requested_at"`
	AbortAttemptCount int        `db:"abort_attempt_count"`
	AbortReason       *string    `db:"abort_reason"`

	// Timestamps
	// CreatedAt is set by the DB (NOW()) on insert — represents when the action was queued.
	CreatedAt time.Time `db:"created_at"`
	UpdatedAt time.Time `db:"updated_at"`
	// EndedAt is set when the action reaches a terminal phase.
	EndedAt     sql.NullTime            `db:"ended_at"`
	DurationMs  sql.NullInt64           `db:"duration_ms"`
	Attempts    uint32                  `db:"attempts" json:"attempts,omitempty"`
	CacheStatus core.CatalogCacheStatus `db:"cache_status" json:"cache_status,omitempty"`
}

type ActionEvent struct {
	// Composite primary key
	Project string `db:"project"`
	Domain  string `db:"domain"`
	RunName string `db:"run_name"`
	Name    string `db:"name"`
	Attempt uint32 `db:"attempt"`
	Phase   int32  `db:"phase"` // common.ActionPhase
	Version uint32 `db:"version"`

	// Serialized workflow.ActionEvent proto
	Info []byte `db:"info"`

	// Error kind denormalized from Info for faster queries
	ErrorKind *string `db:"error_kind"`

	CreatedAt time.Time `db:"created_at"`
	UpdatedAt time.Time `db:"updated_at"`
}

type Project struct {
	Identifier  string    `db:"identifier"`
	Name        string    `db:"name"`
	Description string    `db:"description"`
	Labels      []byte    `db:"labels"`
	State       *int32    `db:"state"`
	CreatedAt   time.Time `db:"created_at"`
	UpdatedAt   time.Time `db:"updated_at"`
}

type RecentAction struct {
	TaskName string `db:"task_name"`
	Phase    int32  `db:"phase"`
}

type Run = Action

type Task struct {
	TaskKey

	// Extracted from Name
	Environment  string `db:"environment"`
	FunctionName string `db:"function_name"`

	// Base fields
	CreatedAt time.Time `db:"created_at"`
	UpdatedAt time.Time `db:"updated_at"`

	// Metadata
	DeployedBy            string         `db:"deployed_by"`
	TriggerName           sql.NullString `db:"trigger_name"`
	TotalTriggers         uint32         `db:"total_triggers"`
	ActiveTriggers        uint32         `db:"active_triggers"`
	TriggerAutomationSpec []byte         `db:"trigger_automation_spec"`
	TriggerTypes          pgtype.Bits    `db:"trigger_types"`
	EnvDescription        sql.NullString `db:"env_description" json:"env_description,omitempty"`
	ShortDescription      sql.NullString `db:"short_description" json:"short_description,omitempty"`

	// Spec
	TaskSpec []byte `db:"task_spec"`
}

type TaskCounts struct {
	// FilteredTotal is the number of tasks matching the applied filter
	FilteredTotal uint32 `db:"filtered_total"`
	// Total is the total number of tasks without any filters
	Total uint32 `db:"total"`
}

type TaskGroup struct {
	TaskName        string  `db:"task_name"`
	EnvironmentName *string `db:"environment_name"`
	TaskShortName   *string `db:"task_short_name"`

	ActionCount           int64      `db:"action_count"`
	LatestCreatedAt       time.Time  `db:"latest_created_at"`
	LastRunEndedAt        *time.Time `db:"last_run_ended_at"`
	AverageFailurePercent float64    `db:"average_failure_percent"`
	AverageDurationMs     *float64   `db:"average_duration_ms"`
	CreatedByList         []string   `db:"created_by_list"`
	RecentPhases          []int32    `db:"-"`

	// Error counts from action_events table by error kind
	UserErrorCount        int64 `db:"user_error_count"`
	SystemErrorCount      int64 `db:"system_error_count"`
	UnspecifiedErrorCount int64 `db:"unspecified_error_count"`
}

type TaskGroupNotificationPayload struct {
	Project         string
	Domain          string
	TaskName        string
	EnvironmentName *string
}

type TaskKey struct {
	Project string `db:"project"`
	Domain  string `db:"domain"`
	Name    string `db:"name"`
	Version string `db:"version"`
}

type TaskListResult struct {
	Tasks         []*Task
	FilteredTotal uint32
	Total         uint32
}

type TaskName struct {
	Project string
	Domain  string
	Name    string
}

type TaskSpec struct {
	// Base64 encoded digest used as a unique identifier for the task spec
	Digest string `db:"digest"`

	// Base fields
	CreatedAt time.Time `db:"created_at"`
	UpdatedAt time.Time `db:"updated_at"`

	// Marshaled task spec
	Spec []byte `db:"spec"`
}

type TaskVersion struct {
	Version   string    `db:"version"`
	CreatedAt time.Time `db:"created_at"`
}

type TaskWithCounts struct {
	Task
	TaskCounts
}

type Trigger struct {
	ID uint `db:"id"`

	// Trigger identity — unique constraint drives upsert
	Project  string `db:"project"`
	Domain   string `db:"domain"`
	TaskName string `db:"task_name"`
	Name     string `db:"name"`

	// Monotonically increasing counter; incremented on every write
	LatestRevision uint64 `db:"latest_revision"`

	// Serialized protos
	Spec           []byte `db:"spec"`
	AutomationSpec []byte `db:"automation_spec"`

	// Denormalized fields for cheap queries without deserializing protos
	TaskVersion    string `db:"task_version"`
	Active         bool   `db:"active"`
	AutomationType string `db:"automation_type"`

	// Identity
	DeployedBy sql.NullString `db:"deployed_by"`
	UpdatedBy  sql.NullString `db:"updated_by"`

	// Timestamps
	DeployedAt  time.Time    `db:"deployed_at"`
	UpdatedAt   time.Time    `db:"updated_at"`
	TriggeredAt sql.NullTime `db:"triggered_at"`
	DeletedAt   sql.NullTime `db:"deleted_at"`

	Description sql.NullString `db:"description"`
}

type TriggerRevision struct {
	// Composite PK: trigger identity + revision number
	Project  string `db:"project"`
	Domain   string `db:"domain"`
	TaskName string `db:"task_name"`
	Name     string `db:"name"`
	Revision uint64 `db:"revision"`

	// Snapshot of state at this revision
	Spec           []byte `db:"spec"`
	AutomationSpec []byte `db:"automation_spec"`

	TaskVersion    string `db:"task_version"`
	Active         bool   `db:"active"`
	AutomationType string `db:"automation_type"`

	DeployedBy sql.NullString `db:"deployed_by"`
	UpdatedBy  sql.NullString `db:"updated_by"`

	DeployedAt  time.Time    `db:"deployed_at"`
	UpdatedAt   time.Time    `db:"updated_at"`
	TriggeredAt sql.NullTime `db:"triggered_at"`
	DeletedAt   sql.NullTime `db:"deleted_at"`

	// What action produced this revision row
	// Values: TRIGGER_REVISION_ACTION_DEPLOY, _ACTIVATE, _DEACTIVATE, _DELETE
	Action string `db:"action"`

	CreatedAt time.Time `db:"created_at"`
}