postgresql

type Approval struct {
	ID             string          `json:"id"`
	Tenant         string          `json:"tenant,omitempty"`
	Namespace      string          `json:"namespace"`
	RunName        string          `json:"runName"`
	Kind           string          `json:"kind"`
	SourceKey      string          `json:"sourceKey"`
	Summary        string          `json:"summary"`
	Details        json.RawMessage `json:"details,omitempty"`
	ApproverGroups []string        `json:"approverGroups"`
	Status         string          `json:"status"`
	RequestedAt    time.Time       `json:"requestedAt"`
	ExpiresAt      time.Time       `json:"expiresAt"`
	DecidedBy      string          `json:"decidedBy,omitempty"`
	DecidedAt      *time.Time      `json:"decidedAt,omitempty"`
	Reason         string          `json:"reason,omitempty"`
	AppliedAt      *time.Time      `json:"appliedAt,omitempty"`
	// Created is set by RequestApproval when the request is new rather than a
	// repeat of an existing one.
	Created bool `json:"-"`
}

type ApprovalQuery struct {
	// Namespaces scopes the query to a tenant's namespaces.
	Namespaces []string
	Namespace  string
	RunName    string
	Status     string
	Limit      int
}

type CostQuery struct {
	// Namespaces restricts results to these namespaces. Empty = all.
	Namespaces []string
	// Deployment restricts to runs labelled agentorca.io/deployment=<name>.
	Deployment string
	// Run restricts to a single run name.
	Run string
	// Since drops runs that finished (or, if unfinished, started) before it.
	Since *time.Time
}

type CostRow struct {
	Name      string
	Namespace string
	AgentRef  string
	Phase     string
	SpendUSD  string
	// CostIncomplete is true when the run's spend could not be captured.
	CostIncomplete bool
	// Model is the model of the run's last routing decision ("" if none).
	Model string
	// When is the completion time, falling back to start then creation time.
	When time.Time
}

type HistoryPage struct {
	Runs   []HistoryResult `json:"runs"`
	Total  int             `json:"total"`
	Limit  int             `json:"limit"`
	Offset int             `json:"offset"`
}

type HistoryQuery struct {
	// Limit caps the number of results (default 50, clamped to [1, 200]).
	Limit int
	// Offset is the number of rows to skip (for pagination).
	Offset int
	// Phase filters by AgentRun phase (e.g. "Succeeded", "Failed"). Empty = all.
	Phase string
	// AgentRef filters by the agent name referenced by the run.
	AgentRef string
	// Namespaces restricts results to the given namespaces (typically a tenant's
	// authorized set). Empty = all namespaces (only meaningful when the caller has
	// cluster-wide access).
	Namespaces []string
	// Search matches against the run name case-insensitively.
	Search string
}

type HistoryResult struct {
	Name           string     `json:"name"`
	Namespace      string     `json:"namespace"`
	AgentRef       string     `json:"agentRef"`
	Phase          string     `json:"phase"`
	SpendUSD       string     `json:"spendUSD"`
	StartTime      *time.Time `json:"startTime,omitempty"`
	CompletionTime *time.Time `json:"completionTime,omitempty"`
	Tenant         string     `json:"tenant,omitempty"`
	// ContextUsedTokens / MaxContextTokens are surfaced so the UI can show a
	// context-utilization preview without a full detail round-trip.
	ContextUsedTokens int `json:"contextUsedTokens,omitempty"`
	MaxContextTokens  int `json:"maxContextTokens,omitempty"`
}

type RunArchive struct {
	// ID is the composite primary key: "namespace/name".
	ID string `db:"id"`
	// Kubernetes metadata.
	Name      string            `db:"name"`
	Namespace string            `db:"namespace"`
	Labels    map[string]string `db:"labels"`
	// Spec-level fields.
	AgentRef     string        `db:"agent_ref"`
	Input        string        `db:"input"`
	ParentRunRef string        `db:"parent_run_ref"`
	PriorRunRef  string        `db:"prior_run_ref"`
	TimeoutSec   sql.NullInt64 `db:"timeout_sec"`
	// Status-level fields (captured at archival time).
	Phase    string `db:"phase"`
	PodName  string `db:"pod_name"`
	SpendUSD string `db:"spend_usd"`
	// CostCapture mirrors the run's CostCapture condition: "complete" when the
	// spend was read from the state store, "incomplete" when it could not be,
	// "" for rows archived before the column existed (spend unknown either way).
	CostCapture       string     `db:"cost_capture"`
	Output            string     `db:"output"`
	RawOutput         string     `db:"raw_output"`
	RestartCount      int        `db:"restart_count"`
	StartTime         *time.Time `db:"start_time"`
	CompletionTime    *time.Time `db:"completion_time"`
	ContextUsedTokens int        `db:"context_used_tokens"`
	MaxContextTokens  int        `db:"max_context_tokens"`
	// Tenant attribution (from agentorca.io/tenant label, empty if unattributed).
	Tenant string `db:"tenant"`
	// Routing decisions and child refs (JSON-serialised).
	RoutingDecisionsJSON []byte `db:"routing_decisions"`
	ChildRunRefsJSON     []byte `db:"child_run_refs"`
	// TraceEventsJSON is the archived execution trace — a JSON array of
	// {id, event, ts, childRunName} entries read from the Redis token stream
	// at archival time. NULL when no trace events were available (store
	// disabled, stream expired, or pre-feature run).
	TraceEventsJSON []byte `db:"trace_events"`
	// Timestamps.
	CreatedAt time.Time `db:"created_at"`
	UpdatedAt time.Time `db:"updated_at"`
}

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