fleet

type BlastGroup struct {
	Tag     string   `json:"tag"`     // shared tag, e.g. "group:prod"
	Total   int      `json:"total"`   // databases carrying this tag
	Faulted []string `json:"faulted"` // critically faulted members
	AtRisk  []string `json:"at_risk"` // healthy members of the same cohort
}

type CheckResult struct {
	Database string `json:"database"`
	DSN      string `json:"dsn"`
	// State is one of: "ok", "drift", "no-baseline", "error".
	State    string               `json:"state"`
	Drift    *monitor.DriftResult `json:"drift,omitempty"`
	Err      error                `json:"-"`
	Error    string               `json:"error,omitempty"`
	Duration time.Duration        `json:"-"`
}

type Config struct {
	Version      int        `yaml:"version"`
	Name         string     `yaml:"name,omitempty"`
	BaselinesDir string     `yaml:"baseline_dir,omitempty"` // default dir for captured baselines
	Databases    []Database `yaml:"databases"`
	// contains filtered or unexported fields
}

type ConvergeClusterPlan struct {
	ClusterID   string           `json:"cluster_id"`
	Members     []Database       `json:"-"`       // full entries so we have DSNs
	MemberNames []string         `json:"members"` // names, for JSON/display
	SQL         string           `json:"sql"`
	Statements  int              `json:"statements"`
	Destructive bool             `json:"destructive"` // drops a column/table on these DBs
	Drift       []diff.TableDiff `json:"drift,omitempty"`
}

type ConvergePlan struct {
	CanonicalID     string                `json:"canonical_id"`
	AlreadyOK       int                   `json:"already_ok"`        // databases already matching canonical
	Clusters        []ConvergeClusterPlan `json:"clusters"`          // drifted clusters needing convergence
	TotalToConverge int                   `json:"total_to_converge"` // total drifted databases
	Unreachable     []FingerprintError    `json:"unreachable,omitempty"`
}

type DBState string

type Database struct {
	Name     string `yaml:"name"`
	DSN      string `yaml:"dsn"`
	Baseline string `yaml:"baseline,omitempty"` // path to the baseline snapshot
	// Tags allow grouping (e.g. region, tenant) for filtered operations.
	Tags []string `yaml:"tags,omitempty"`
	// Quarantined marks a database as excluded from fleet operations — set by
	// `fleet recover` when a faulted database cannot be restored.
	Quarantined bool `yaml:"quarantined,omitempty"`
}

type FingerprintCluster struct {
	ID          string           `json:"id"`              // short hash of the canonical schema serialization
	Count       int              `json:"count"`           // number of databases in this cluster
	Members     []string         `json:"members"`         // database names, sorted
	IsCanonical bool             `json:"is_canonical"`    // true for the reference cluster (largest by default)
	Drift       []diff.TableDiff `json:"drift,omitempty"` // how this cluster differs from canonical; nil for canonical
	// contains filtered or unexported fields
}

type FingerprintError struct {
	Database string `json:"database"`
	Error    string `json:"error"`
}

type FingerprintReport struct {
	Total       int                  `json:"total"`    // databases successfully fingerprinted
	Clusters    []FingerprintCluster `json:"clusters"` // canonical first, then by count desc
	Unreachable []FingerprintError   `json:"unreachable,omitempty"`
	CheckedAt   time.Time            `json:"checked_at"`
}

type FleetReport struct {
	Results   []CheckResult `json:"results"`
	CheckedAt time.Time     `json:"checked_at"`
}

type HealthReport struct {
	Results   []HealthResult `json:"results"`
	CheckedAt time.Time      `json:"checked_at"`
}

type HealthResult struct {
	Database string         `json:"database"`
	DSN      string         `json:"dsn"`
	Report   *health.Report `json:"report"`
	Duration time.Duration  `json:"-"`
}

type RecoverOptions struct {
	BackupDir  string // where to look for backups ("" = alongside each DB)
	DryRun     bool   // report what would happen without restoring or quarantining
	Deep       bool   // exhaustive integrity_check when assessing health
	Quarantine bool   // quarantine databases with no healthy backup
}

type RecoverReport struct {
	Results   []RecoverResult `json:"results"`
	DryRun    bool            `json:"dry_run"`
	StartedAt time.Time       `json:"started_at"`
}

type RecoverResult struct {
	Database   string        `json:"database"`
	DSN        string        `json:"dsn"`
	State      RecoverState  `json:"state"`
	BackupPath string        `json:"backup_path,omitempty"` // backup used to restore
	Detail     string        `json:"detail,omitempty"`
	Err        error         `json:"-"`
	Error      string        `json:"error,omitempty"`
	Duration   time.Duration `json:"-"`
}

type RecoverState string

type RolloutOptions struct {
	DryRun    bool   // validate against every database without committing
	Canary    int    // stop after this many successful applies (0 = no canary)
	BackupDir string // where local backups are written ("" = alongside each DB)
	NoBackup  bool   // skip local backups (dry-run never backs up)
}

type RolloutReport struct {
	Results   []RolloutResult `json:"results"`
	StartedAt time.Time       `json:"started_at"`
	DryRun    bool            `json:"dry_run"`
	Halted    bool            `json:"halted"` // true when a failure stopped the rollout
}

type RolloutResult struct {
	Database   string        `json:"database"`
	DSN        string        `json:"dsn"`
	State      DBState       `json:"state"`
	Executed   int           `json:"executed"`              // statements applied
	BackupPath string        `json:"backup_path,omitempty"` // local backup, if any
	Provider   string        `json:"provider"`              // local, turso, d1
	Err        error         `json:"-"`
	Error      string        `json:"error,omitempty"`
	Duration   time.Duration `json:"-"`
}

type SnapshotResult struct {
	Database string
	Path     string
	Tables   int
	Err      error
}