store

type BreakdownRow struct {
	Signal          string  `json:"signal"`
	Label           string  `json:"label"`
	Present         bool    `json:"present"`
	SubScore        float64 `json:"sub_score"`
	Detail          string  `json:"detail,omitempty"`
	NominalWeight   float64 `json:"nominal_weight"`
	EffectiveWeight float64 `json:"effective_weight"`
	Contribution    float64 `json:"contribution"`
}

type CacheMetrics struct {
	Hits      int64 `json:"hits"`
	Misses    int64 `json:"misses"`
	Evictions int64 `json:"evictions"`
	Size      int   `json:"size"`
	Capacity  int   `json:"capacity"`
}

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

type Health struct {
	Status           string   `json:"status"`
	RunCount         int      `json:"run_count"`
	IterationCount   int      `json:"iteration_count"`
	LastIterLogMtime *string  `json:"last_iter_log_mtime"`
	SubscriberCount  int      `json:"subscriber_count"`
	RubricVersion    string   `json:"rubric_version"`
	Roots            []string `json:"roots"`
}

type IntegrityRow struct {
	Signal     string     `json:"signal"`
	Role       string     `json:"role"`
	Claimed    SignalSide `json:"claimed"`
	Observed   SignalSide `json:"observed"`
	Comparable bool       `json:"comparable"`
	Delta      *float64   `json:"delta"`
}

type IterScoreRef struct {
	Iteration int      `json:"iteration"`
	Scored    bool     `json:"scored"`
	Score     *float64 `json:"score"`
	Band      string   `json:"band"`
}

type Iteration struct {
	Iteration     int      `json:"iteration"`
	SessionID     string   `json:"session_id"`
	SchemaVersion int      `json:"schema_version"`
	Date          string   `json:"date"`
	Wave          string   `json:"wave"`
	TaskID        string   `json:"task_id"`
	Commit        string   `json:"commit"`
	RubricVersion string   `json:"rubric_version"`
	Scored        bool     `json:"scored"`
	Score         *float64 `json:"score"`
	Band          string   `json:"band"`
	FilesChanged  int      `json:"files_changed"`
	LinesAdded    int      `json:"lines_added"`
	LinesRemoved  int      `json:"lines_removed"`
	Retries       int      `json:"retries"`
	// IntegrityObservationCount is populated by t06 recompute-on-miss; empty (0) from the raw read layer.
	IntegrityObservationCount int `json:"integrity_observation_count"`
	// TranscriptTurnCount is populated by t06 recompute-on-miss; empty (null) from the raw read layer.
	TranscriptTurnCount *int           `json:"transcript_turn_count"`
	TokenUsage          *TokenUsage    `json:"token_usage"`
	Verifiers           []Verifier     `json:"verifiers,omitempty"`
	Breakdown           []BreakdownRow `json:"breakdown,omitempty"`
	// Integrity is populated by t06 recompute-on-miss; empty (null) from the raw read layer.
	Integrity []IntegrityRow `json:"integrity,omitempty"`
	// Objective is populated by t06 recompute-on-miss; empty (null) from the raw read layer.
	Objective *Objective `json:"objective,omitempty"`
}

type IterationDetail = Iteration

type IterationSummary = Iteration

type Objective struct {
	RanCliCommand       SignalSide `json:"ran_cli_command"`
	CommittedAfterTests SignalSide `json:"committed_after_tests"`
	ReadLoopState       SignalSide `json:"read_loop_state"`
}

type Option func(*DiskStore)

type RecomputeStore struct {
	*DiskStore
	// contains filtered or unexported fields
}

type RubricBand struct {
	Name string  `json:"name"`
	Min  float64 `json:"min"`
}

type RubricDoc struct {
	Version     string         `json:"version"`
	Combination string         `json:"combination"`
	Signals     []RubricSignal `json:"signals"`
	Bands       []RubricBand   `json:"bands"`
}

type RubricSignal struct {
	ID          string  `json:"id"`
	Label       string  `json:"label"`
	Weight      float64 `json:"weight"`
	Description string  `json:"description"`
	TwoWay      bool    `json:"two_way"`
}

type Run struct {
	SessionID        string         `json:"session_id"`
	Harness          string         `json:"harness"`
	Model            string         `json:"model"`
	Wave             string         `json:"wave"`
	RubricVersion    string         `json:"rubric_version"`
	IterationCount   int            `json:"iteration_count"`
	Scored           bool           `json:"scored"`
	Score            *float64       `json:"score"`
	Band             string         `json:"band"`
	FirstIteration   *int           `json:"first_iteration"`
	LastIteration    *int           `json:"last_iteration"`
	LastUpdate       *string        `json:"last_update"`
	IterLogDir       string         `json:"iter_log_dir"`
	PerIteration     []IterScoreRef `json:"per_iteration,omitempty"`
	MeanCacheHitRate *float64       `json:"mean_cache_hit_rate"`
}

type RunDetail = Run

type RunFilter struct {
	Limit   int
	Offset  int
	Sort    string // last_update | score | iteration_count | session_id
	Order   string // asc | desc
	Band    string // optional exact-match band filter
	Harness string // optional exact-match harness filter
}

type RunSummary = Run

type SignalSide struct {
	Present  bool    `json:"present"`
	SubScore float64 `json:"sub_score,omitempty"`
	Detail   string  `json:"detail,omitempty"`
}

type Store interface {
	// ListRuns returns one RunSummary per session discovered across the
	// resolved roots, filtered / sorted / paginated per f. Never errors on a
	// corrupt file — the bad file is skipped and the remainder returned.
	ListRuns(ctx context.Context, f RunFilter) ([]RunSummary, error)
	// GetRun returns the full RunDetail (including per_iteration) for one
	// session, or ErrNotFound.
	GetRun(ctx context.Context, sessionID string) (RunDetail, error)
	// ListIterations returns the iteration list for one session ascending by
	// iteration, or ErrNotFound if the session is unknown. A listed iteration
	// whose score sidecar is absent returns scored:false / score:null.
	ListIterations(ctx context.Context, sessionID string) ([]IterationSummary, error)
	// GetIteration returns the full IterationDetail for iteration n in
	// iterLogDir (defaulting to the active root when empty), or ErrNotFound.
	GetIteration(ctx context.Context, iterLogDir string, n int) (IterationDetail, error)
	// Rubric returns the active rubric projection (spec R4).
	Rubric(ctx context.Context) (RubricDoc, error)
	// Health returns liveness counts for cheap operator triage (spec R9).
	Health(ctx context.Context) (Health, error)
}

type TokenUsage struct {
	InputTokens         int     `json:"input_tokens"`
	OutputTokens        int     `json:"output_tokens"`
	CacheReadTokens     int     `json:"cache_read_tokens"`
	CacheCreationTokens int     `json:"cache_creation_tokens"`
	CacheHitRate        float64 `json:"cache_hit_rate"`
}

type Verifier struct {
	Type       string `json:"type"`
	Status     string `json:"status"`
	GatePassed bool   `json:"gate_passed"`
	TestsAdded int    `json:"tests_added"`
	Retries    int    `json:"retries"`
}