takeover

type Action struct {
	Kind  string `json:"kind"`
	Label string `json:"label"`
	API   string `json:"api,omitempty"`
	Value string `json:"value,omitempty"`
}

type BootDecision struct {
	Action string
	Reason string
	Run    Run
}

type Check struct {
	ID     string   `json:"id"`
	Title  string   `json:"title"`
	Status string   `json:"status"`
	Detail string   `json:"detail,omitempty"`
	Items  []string `json:"items,omitempty"`
	Fix    *Fix     `json:"fix,omitempty"`
}

type Config struct {
	Window         time.Duration
	VerifyInterval time.Duration
	StartAttempts  int
	StartWait      time.Duration
	Now            func() time.Time
}

type Containers interface {
	Stop(ctx context.Context, name string) error
	Start(ctx context.Context, name string) error
}

type DBStore struct{ DB Rows }

type Deps struct {
	Containers Containers
	Settings   Settings
	Verifier   Verifier
	// Domains lists what verification must cover.
	Domains func(ctx context.Context) ([]string, error)
	// Restart asks the process to restart itself, false when it cannot.
	Restart func() bool
	// Audit records one entry; nil records nothing.
	Audit func(ctx context.Context, action, detail string)
}

type DomainCheck struct {
	Domain    string `json:"domain"`
	OK        bool   `json:"ok"`
	Status    int    `json:"status,omitempty"`
	Delivered bool   `json:"delivered"`
	Detail    string `json:"detail,omitempty"`
}

type DomainFact struct {
	Domain       string
	App          string
	Healthy      bool
	HealthDetail string
	ResolvesTo   []string
	DNSErr       string
	CustomCert   bool
}

type DomainRow struct {
	Domain  string `json:"domain"`
	App     string `json:"app"`
	Healthy bool   `json:"healthy"`
	Detail  string `json:"detail,omitempty"`
	DNS     string `json:"dns"`
	Cert    string `json:"certificate"`
}

type Facts struct {
	Holders       []Holder
	HostListeners []int
	// HostProcess names the process per host listener port when known.
	HostProcess      map[int]string
	CurrentHTTP      string
	CurrentHTTPS     string
	TargetHTTP       string
	TargetHTTPS      string
	Domains          []DomainFact
	ServerIPs        []string
	LabelRouters     []LabelRouter
	OldDomains       []string
	ACMEEnabled      bool
	DiskFreeGB       float64
	DiskKnown        bool
	MemoryMB         int
	MinDiskGB        float64
	MinMemoryMB      int
	RestartSupported bool
	DockerAvailable  bool
	AcceptUnmanaged  bool
	// SocketActivation is true when systemd holds the ingress sockets.
	SocketActivation bool
	Window           time.Duration
	Now              time.Time
}

type Fix struct {
	Summary string  `json:"summary"`
	Action  *Action `json:"action,omitempty"`
}

type Holder struct {
	Port          int
	Container     string
	Image         string
	Kind          string
	RestartPolicy string
}

type LabelRouter struct {
	Domain    string
	Container string
}

type Plan struct {
	Verdict string      `json:"verdict"`
	Checks  []Check     `json:"checks"`
	Steps   []PlanStep  `json:"steps"`
	Domains []DomainRow `json:"domains"`
	// Rollback says what the undo button restores.
	Rollback      []string `json:"rollback"`
	WindowSeconds int      `json:"window_seconds"`
	TargetHTTP    string   `json:"target_http"`
	TargetHTTPS   string   `json:"target_https"`
	CurrentHTTP   string   `json:"current_http"`
	CurrentHTTPS  string   `json:"current_https"`
	ProxyKind     string   `json:"proxy_kind,omitempty"`
	ProxyNames    []string `json:"proxy_containers"`
	CheckedAt     string   `json:"checked_at"`
}

type PlanStep struct {
	ID     string `json:"id"`
	Title  string `json:"title"`
	Detail string `json:"detail"`
	// Reversible is false only for steps rollback cannot undo on its own.
	Reversible bool `json:"reversible"`
}

type Previous struct {
	HTTPAddr              string  `json:"http_addr"`
	HTTPSAddr             string  `json:"https_addr"`
	TLSTerminatedUpstream bool    `json:"tls_terminated_upstream"`
	PublicHTTPSPort       int     `json:"public_https_port"`
	SettingsChanged       bool    `json:"settings_changed"`
	Proxies               []Proxy `json:"proxies"`
}

type Proxy struct {
	Name       string `json:"name"`
	Image      string `json:"image"`
	WasRunning bool   `json:"was_running"`
	Stopped    bool   `json:"stopped"`
	Restored   bool   `json:"restored"`
}

type Rows interface {
	CreatePortTakeover(ctx context.Context, r store.PortTakeover) error
	SavePortTakeover(ctx context.Context, r store.PortTakeover) error
	GetPortTakeover(ctx context.Context, id string) (store.PortTakeover, error)
	ListPortTakeovers(ctx context.Context, limit int) ([]store.PortTakeover, error)
	ListPortTakeoversByState(ctx context.Context, states ...string) ([]store.PortTakeover, error)
}

type Run struct {
	ID            string        `json:"id"`
	State         string        `json:"state"`
	Actor         string        `json:"actor,omitempty"`
	Previous      Previous      `json:"previous"`
	TargetHTTP    string        `json:"target_http"`
	TargetHTTPS   string        `json:"target_https"`
	Steps         []Step        `json:"steps"`
	Verify        []DomainCheck `json:"verify"`
	Error         string        `json:"error,omitempty"`
	Boots         int           `json:"boots"`
	WindowSeconds int           `json:"window_seconds"`
	DeadlineAt    time.Time     `json:"deadline_at,omitzero"`
	CreatedAt     time.Time     `json:"created_at"`
	UpdatedAt     time.Time     `json:"updated_at"`
	FinishedAt    time.Time     `json:"finished_at,omitzero"`
}

type Runner struct {
	Store Store
	Deps  Deps
	Cfg   Config
	Log   *slog.Logger
	// contains filtered or unexported fields
}

type Settings interface {
	GetTLS(ctx context.Context) (TLSSettings, error)
	SetTLS(ctx context.Context, s TLSSettings) error
}

type StartRequest struct {
	Plan  Plan
	Actor string
}

type Step struct {
	ID         string    `json:"id"`
	Title      string    `json:"title"`
	State      string    `json:"state"`
	Detail     string    `json:"detail,omitempty"`
	StartedAt  time.Time `json:"started_at,omitzero"`
	FinishedAt time.Time `json:"finished_at,omitzero"`
}

type Store interface {
	Create(ctx context.Context, r Run) error
	Get(ctx context.Context, id string) (Run, error)
	Save(ctx context.Context, r Run) error
	List(ctx context.Context, limit int) ([]Run, error)
	ListByState(ctx context.Context, states ...string) ([]Run, error)
}

type TLSSettings struct {
	TerminatedUpstream bool
	PublicHTTPSPort    int
}

type Verifier interface {
	Verify(ctx context.Context, domain string) DomainCheck
}