cli

type AffinityOut struct {
	Rows []AffinityRow `json:"rows"`
}

type AffinityRow struct {
	BeadID    core.WorkItemID        `json:"bead_id"`
	SessionID string                 `json:"session_id"`
	AgentID   core.AgentID           `json:"agent_id,omitempty"`
	Scores    planner.AffinityScores `json:"scores"`
}

type BuildInfo struct {
	Version string
	Commit  string
	Date    string
}

type ConflictsOut struct {
	Edges               []conflicts.Edge             `json:"edges"`
	Batches             []conflicts.Batch            `json:"batches"`
	WorkspaceCollisions []planner.WorkspaceCollision `json:"workspace_collisions"`
	SemanticConflicts   []planner.SemanticConflict   `json:"semantic_conflicts"`
	Notices             []string                     `json:"notices,omitempty"`
}

type OperationalContextInput struct {
	Sessions   []*core.Session                    `json:"sessions"`
	Agents     []*core.AgentRef                   `json:"agents,omitempty"`
	Workspaces []*core.Workspace                  `json:"workspaces,omitempty"`
	Profiles   map[string]*planner.SessionProfile `json:"profiles,omitempty"` // key = session id
	// Optional: explicit clock for deterministic test runs (RFC3339).
	Now string `json:"now,omitempty"`
}

type PlannerInput struct {
	// Beads are the candidate WorkItems the planner is reasoning
	// about. Each entry is the planner's projection — id + tags
	// + targets + repo affinity — derived from a real WorkItem
	// upstream.
	Beads []PlannerInputBead `json:"beads"`
	// SessionContexts are the live agent sessions the planner can
	// dispatch against. Pass them along even when only running
	// conflicts: workspace-collision detection cross-references
	// these so a ready bead routed to a worktree another session
	// is already writing in is flagged.
	SessionContexts []planner.OperationalContext `json:"session_contexts,omitempty"`
}

type PlannerInputBead struct {
	ID           core.WorkItemID         `json:"id"`
	Concepts     []planner.ConceptTag    `json:"concepts,omitempty"`
	Targets      []string                `json:"targets,omitempty"`
	Repositories []string                `json:"repositories,omitempty"`
	Branch       string                  `json:"branch,omitempty"`
	WorktreePath string                  `json:"worktree_path,omitempty"`
	GlobPatterns []targets.Pattern       `json:"glob_patterns,omitempty"`
	SemanticHits []sourceanalysis.Target `json:"semantic_hits,omitempty"`
}

type PlannerJSONOut struct {
	Conflicts *ConflictsOut `json:"conflicts,omitempty"`
	Affinity  *AffinityOut  `json:"affinity,omitempty"`
}

type RetroListInput struct {
	Grades []retro.Grade `json:"grades"`
}

type RetroListOut struct {
	Rows []retro.Grade `json:"rows"`
}

type SessionHealthEntry struct {
	Session *core.Session           `json:"session"`
	Profile *planner.SessionProfile `json:"profile,omitempty"`
}

type SessionHealthInput struct {
	Sessions     []SessionHealthEntry                               `json:"sessions"`
	BeadConcepts map[core.WorkItemID]map[planner.ConceptTag]float64 `json:"bead_concepts,omitempty"`
	// Now overrides time.Now for deterministic test runs. RFC3339
	// string. Empty → live wall clock.
	Now string `json:"now,omitempty"`
}

type SessionHealthOut struct {
	Rows []SessionHealthRow `json:"rows"`
}

type SessionHealthRow struct {
	SessionID         string  `json:"session_id"`
	AgentID           string  `json:"agent_id,omitempty"`
	ContextPressure   float64 `json:"context_pressure"`
	ConceptDrift      float64 `json:"concept_drift"`
	TimeOnTaskSeconds float64 `json:"time_on_task_seconds"`
	// PressureLevel and DriftLevel are "ok" | "warn" | "recycle"
	// per spec §4 Layer 4. The CLI carries the labels so a future
	// machine consumer doesn't need to duplicate the threshold
	// table.
	PressureLevel string `json:"pressure_level"`
	DriftLevel    string `json:"drift_level"`
}

type SessionStatusEntry struct {
	Session     *core.Session           `json:"session"`
	Profile     *planner.SessionProfile `json:"profile,omitempty"`
	Calibration float64                 `json:"calibration,omitempty"`
}

type SessionStatusInput struct {
	Sessions     []SessionStatusEntry                               `json:"sessions"`
	BeadConcepts map[core.WorkItemID]map[planner.ConceptTag]float64 `json:"bead_concepts,omitempty"`
	// Now overrides time.Now for deterministic test runs.
	Now string `json:"now,omitempty"`
}

type SessionStatusOut struct {
	Rows []SessionStatusRow `json:"rows"`
}

type SessionStatusRow struct {
	SessionID         string        `json:"session_id"`
	AgentID           string        `json:"agent_id,omitempty"`
	ContextPressure   float64       `json:"context_pressure"`
	ConceptDrift      float64       `json:"concept_drift"`
	TimeOnTaskSeconds float64       `json:"time_on_task_seconds"`
	PressureLevel     string        `json:"pressure_level"`
	DriftLevel        string        `json:"drift_level"`
	Runway            runway.Runway `json:"runway"`
}

type SizeCalibrationInput struct {
	Samples []SizeCalibrationSample `json:"samples"`
	// Targets is optional — when omitted the aggregator uses
	// sizecalibration.DefaultBucketTargets.
	Targets *SizeCalibrationTargets `json:"targets,omitempty"`
	// CurrentThresholds is optional — when omitted the aggregator
	// uses enrichment.DefaultSizeThresholds.
	CurrentThresholds *enrichment.SizeHeuristicThresholds `json:"current_thresholds,omitempty"`
}

type SizeCalibrationSample struct {
	BeadID        core.WorkItemID          `json:"bead_id,omitempty"`
	Predicted     enrichment.EstimatedSize `json:"predicted"`
	ActualSeconds float64                  `json:"actual_seconds"`
	Author        string                   `json:"author,omitempty"`
}

type SizeCalibrationTargets struct {
	SmallSeconds  float64 `json:"small_seconds"`
	MediumSeconds float64 `json:"medium_seconds"`
	LargeSeconds  float64 `json:"large_seconds"`
}