api

type ConfigValidateRequest struct {
	Env map[string]string `json:"env"`
}

type ConfigValidateResponse struct {
	Detectors []DetectorReport `json:"detectors"`
}

type DetectorReport struct {
	Name       string         `json:"name"`
	Enabled    bool           `json:"enabled"`
	Reason     string         `json:"reason,omitempty"`
	Thresholds map[string]any `json:"thresholds,omitempty"`
	Warnings   []string       `json:"warnings,omitempty"`
}

type EvidenceDTO struct {
	Series  uuid.UUID          `json:"series"`
	Time    time.Time          `json:"time"`
	Kind    string             `json:"kind"`
	Score   float64            `json:"score"`
	Metrics map[string]float64 `json:"metrics,omitempty"`
}

type ExplanationDTO struct {
	FeatureEvolution   []FeatureSampleDTO `json:"feature_evolution,omitempty"`
	ComparablePeers    int                `json:"comparable_peers,omitempty"`
	BaselineWindowDays int                `json:"baseline_window_days,omitempty"`
	ThresholdUsed      float64            `json:"threshold_used,omitempty"`
	DetectorVersion    string             `json:"detector_version,omitempty"`
}

type FeatureSampleDTO struct {
	At    time.Time `json:"at"`
	Value float64   `json:"value"`
}

type FederationExportResponse struct {
	GeneratedAt  time.Time                `json:"generated_at"`
	Source       string                   `json:"source"`  // "chronos"
	Version      string                   `json:"version"` // schema version of this payload
	Patterns     []FederationPatternStats `json:"patterns"`
	TotalSignals int                      `json:"total_signals"`
}

type FederationPatternStats struct {
	Pattern          string  `json:"pattern"`
	Count            int     `json:"count"`
	AvgStrength      float64 `json:"avg_strength"`
	MinStrength      float64 `json:"min_strength"`
	MaxStrength      float64 `json:"max_strength"`
	AvgConfidence    float64 `json:"avg_confidence"`
	MinConfidence    float64 `json:"min_confidence"`
	MaxConfidence    float64 `json:"max_confidence"`
	AvgSampleSize    float64 `json:"avg_sample_size,omitempty"` // mean of metrics["n"] when populated
	TentativeCount   int     `json:"tentative_count,omitempty"`
	EstablishedCount int     `json:"established_count,omitempty"`
	StrongCount      int     `json:"strong_count,omitempty"`
}

type IngestBatchRequest struct {
	Observations []IngestRequest `json:"observations"`
	// DeferDetection is accepted for API forward-compatibility. Chronos
	// already separates ingest from detection (the compute pipeline
	// runs detection at job time, not on ingest), so the flag is
	// currently a no-op — it is echoed in the response so callers can
	// rely on the field shape without branching.
	DeferDetection bool `json:"defer_detection,omitempty"`
}

type IngestBatchResponse struct {
	Accepted       int  `json:"accepted"`
	DeferDetection bool `json:"defer_detection"`
}

type IngestRequest struct {
	ID        uuid.UUID         `json:"id,omitempty"`
	EntityID  uuid.UUID         `json:"entity_id"`
	ScopeID   uuid.UUID         `json:"scope_id"`
	Timestamp time.Time         `json:"timestamp"`
	Features  []float64         `json:"features"`
	Labels    []string          `json:"labels,omitempty"`
	Meta      map[string]string `json:"meta,omitempty"`
	// Adapter labels the source for retention policy / count queries. If
	// empty, signals fall back to "http" so streaming clients are
	// distinguishable from pull adapters in the Count column.
	Adapter string `json:"adapter,omitempty"`
}

type Middleware func(http.Handler) http.Handler

type SSEBroadcaster interface {
	// Subscribe registers a stream client. scopes is a server-side
	// allowlist: nil delivers every scope (operator-grade reads),
	// non-nil restricts delivery to the listed scope ids. The handler
	// constructs the allowlist from ?scope_id= (single-element) or
	// ?scope_in= (multi-element) so clients can't widen their own
	// filter post-handshake.
	Subscribe(scopes []uuid.UUID, pattern string) (uuid.UUID, <-chan domain.Signal)
	Unsubscribe(uuid.UUID)
}

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

type SignalDTO struct {
	ID         uuid.UUID          `json:"id"`
	ScopeID    uuid.UUID          `json:"scope_id"`
	Series     uuid.UUID          `json:"series"`
	Pattern    string             `json:"pattern"`
	DetectedAt time.Time          `json:"detected_at"`
	Window     TimeWindowDTO      `json:"window"`
	Strength   float64            `json:"strength"`
	Confidence float64            `json:"confidence"`
	Metrics    map[string]float64 `json:"metrics,omitempty"`
	Evidence   []EvidenceDTO      `json:"evidence,omitempty"`
	// Explanation carries detector-side context that lets downstream
	// consumers narrate WHY the signal fired without re-deriving the
	// data. Omitted when the detector did not surface one.
	Explanation *ExplanationDTO `json:"explanation,omitempty"`
	// ConfidenceClass is the qualitative grade (tentative /
	// established / strong) the detector assigned based on sample
	// size vs MIN_POINTS. Empty when the detector did not classify.
	ConfidenceClass string `json:"confidence_class,omitempty"`
}

type TimeWindowDTO struct {
	Start time.Time `json:"start"`
	End   time.Time `json:"end"`
}