tui

type ActionKind string

type ActionLog struct {
	At   time.Time `json:"at"`
	Text string    `json:"text"`
}

type ActionRequest struct {
	Kind    ActionKind `json:"kind"`
	At      time.Time  `json:"at"`
	Service string     `json:"service,omitempty"` // Optional: target specific service
}

type ActionRequestMsg struct {
	Request ActionRequest
}

type Bus struct {
	Router     *message.Router
	Publisher  message.Publisher
	Subscriber message.Subscriber
	// contains filtered or unexported fields
}

type ConfigPatch struct {
	Plugin string `json:"plugin"`
	Key    string `json:"key"`   // dotted path, e.g., "services.backend.port"
	Value  string `json:"value"` // string representation of the value
}

type Envelope struct {
	Type    string          `json:"type"`
	Payload json.RawMessage `json:"payload,omitempty"`
}

type EventLogAppendMsg struct {
	Entry EventLogEntry
}

type EventLogEntry struct {
	At     time.Time `json:"at"`
	Source string    `json:"source,omitempty"`
	Level  LogLevel  `json:"level,omitempty"`
	Text   string    `json:"text"`
}

type HealthCheckResult struct {
	ServiceName string       `json:"service_name"`
	Status      HealthStatus `json:"status"`
	LastCheck   time.Time    `json:"last_check"`
	CheckType   string       `json:"check_type,omitempty"` // "tcp", "http", "exec"
	Endpoint    string       `json:"endpoint,omitempty"`   // e.g., "http://localhost:8080/health"
	Error       string       `json:"error,omitempty"`
	ResponseMs  int64        `json:"response_ms,omitempty"`
}

type HealthStatus string

type LogLevel string

type NavigateBackMsg struct{}

type NavigateToServiceMsg struct {
	Name string
}

type PipelineBuildResult struct {
	RunID     string               `json:"run_id"`
	At        time.Time            `json:"at"`
	Steps     []PipelineStepResult `json:"steps,omitempty"`
	Artifacts map[string]string    `json:"artifacts,omitempty"`
}

type PipelineBuildResultMsg struct {
	Result PipelineBuildResult
}

type PipelineConfigPatches struct {
	RunID   string        `json:"run_id"`
	Patches []ConfigPatch `json:"patches"`
}

type PipelineConfigPatchesMsg struct {
	Patches PipelineConfigPatches
}

type PipelineLaunchPlan struct {
	RunID    string    `json:"run_id"`
	At       time.Time `json:"at"`
	Services []string  `json:"services,omitempty"`
}

type PipelineLaunchPlanMsg struct {
	Plan PipelineLaunchPlan
}

type PipelineLiveOutput struct {
	RunID  string `json:"run_id"`
	Source string `json:"source"` // step name
	Line   string `json:"line"`
	Stream string `json:"stream"` // "stdout" or "stderr"
}

type PipelineLiveOutputMsg struct {
	Output PipelineLiveOutput
}

type PipelinePhase string

type PipelinePhaseFinished struct {
	RunID      string        `json:"run_id"`
	Phase      PipelinePhase `json:"phase"`
	At         time.Time     `json:"at"`
	Ok         bool          `json:"ok"`
	DurationMs int64         `json:"duration_ms,omitempty"`
	Error      string        `json:"error,omitempty"`
}

type PipelinePhaseFinishedMsg struct {
	Event PipelinePhaseFinished
}

type PipelinePhaseStarted struct {
	RunID string        `json:"run_id"`
	Phase PipelinePhase `json:"phase"`
	At    time.Time     `json:"at"`
}

type PipelinePhaseStartedMsg struct {
	Event PipelinePhaseStarted
}

type PipelinePrepareResult struct {
	RunID     string               `json:"run_id"`
	At        time.Time            `json:"at"`
	Steps     []PipelineStepResult `json:"steps,omitempty"`
	Artifacts map[string]string    `json:"artifacts,omitempty"`
}

type PipelinePrepareResultMsg struct {
	Result PipelinePrepareResult
}

type PipelineRunFinished struct {
	RunID      string     `json:"run_id"`
	Kind       ActionKind `json:"kind"`
	RepoRoot   string     `json:"repo_root"`
	At         time.Time  `json:"at"`
	Ok         bool       `json:"ok"`
	DurationMs int64      `json:"duration_ms,omitempty"`
	Error      string     `json:"error,omitempty"`
}

type PipelineRunFinishedMsg struct {
	Run PipelineRunFinished
}

type PipelineRunStarted struct {
	RunID    string          `json:"run_id"`
	Kind     ActionKind      `json:"kind"`
	RepoRoot string          `json:"repo_root"`
	At       time.Time       `json:"at"`
	Phases   []PipelinePhase `json:"phases,omitempty"`
}

type PipelineRunStartedMsg struct {
	Run PipelineRunStarted
}

type PipelineStepProgressMsg struct {
	RunID   string `json:"run_id"`
	Step    string `json:"step"`
	Percent int    `json:"percent"` // 0-100
}

type PipelineStepResult struct {
	Name            string `json:"name"`
	Ok              bool   `json:"ok"`
	DurationMs      int64  `json:"duration_ms,omitempty"`
	ProgressPercent int    `json:"progress_percent,omitempty"` // 0-100, for in-progress steps
}

type PipelineValidateResult struct {
	RunID    string           `json:"run_id"`
	At       time.Time        `json:"at"`
	Valid    bool             `json:"valid"`
	Errors   []protocol.Error `json:"errors,omitempty"`
	Warnings []protocol.Error `json:"warnings,omitempty"`
}

type PipelineValidateResultMsg struct {
	Result PipelineValidateResult
}

type PluginIntrospectionRefreshMsg struct{}

type PluginSummary struct {
	ID        string    `json:"id"`
	Path      string    `json:"path"`
	Priority  int       `json:"priority"`
	Status    string    `json:"status"` // "active" | "disabled" | "error"
	Protocol  string    `json:"protocol,omitempty"`
	Ops       []string  `json:"ops,omitempty"`
	Streams   []string  `json:"streams,omitempty"`
	Commands  []string  `json:"commands,omitempty"`
	CapStatus string    `json:"cap_status,omitempty"` // "unknown" | "introspecting" | "ok" | "error"
	CapError  string    `json:"cap_error,omitempty"`
	CapStart  time.Time `json:"cap_start,omitempty"`
	CapEnd    time.Time `json:"cap_end,omitempty"`
}

type RootOptions struct {
	RepoRoot string
	Config   string
	Strict   bool
	DryRun   bool
	Timeout  time.Duration
}

type ServiceExitObserved struct {
	Name   string    `json:"name"`
	PID    int       `json:"pid"`
	When   time.Time `json:"when"`
	Reason string    `json:"reason,omitempty"`
}

type StateSnapshot struct {
	RepoRoot     string                        `json:"repo_root"`
	At           time.Time                     `json:"at"`
	Exists       bool                          `json:"exists"`
	State        *state.State                  `json:"state,omitempty"`
	Alive        map[string]bool               `json:"alive,omitempty"`
	Error        string                        `json:"error,omitempty"`
	ProcessStats map[int]*proc.Stats           `json:"process_stats,omitempty"` // PID -> stats
	Health       map[string]*HealthCheckResult `json:"health,omitempty"`        // service name -> health
	Plugins      []PluginSummary               `json:"plugins,omitempty"`       // Plugin summaries
}

type StateSnapshotMsg struct {
	Snapshot StateSnapshot
}

type StateWatcher struct {
	RepoRoot string
	Interval time.Duration
	Pub      message.Publisher
	// contains filtered or unexported fields
}

type StreamEnded struct {
	StreamKey string    `json:"stream_key"`
	PluginID  string    `json:"plugin_id"`
	Op        string    `json:"op"`
	StreamID  string    `json:"stream_id"`
	At        time.Time `json:"at"`
	Ok        bool      `json:"ok"`
	Error     string    `json:"error,omitempty"`
}

type StreamEndedMsg struct {
	End StreamEnded
}

type StreamEvent struct {
	StreamKey string         `json:"stream_key"`
	PluginID  string         `json:"plugin_id"`
	Op        string         `json:"op"`
	StreamID  string         `json:"stream_id"`
	At        time.Time      `json:"at"`
	Event     protocol.Event `json:"event"`
}

type StreamEventMsg struct {
	Event StreamEvent
}

type StreamStartRequest struct {
	PluginID string         `json:"plugin_id,omitempty"` // optional; may be resolved by op
	Op       string         `json:"op"`
	Input    map[string]any `json:"input,omitempty"`
	Label    string         `json:"label,omitempty"` // optional display name
}

type StreamStartRequestMsg struct {
	Request StreamStartRequest
}

type StreamStarted struct {
	StreamKey string    `json:"stream_key"`
	PluginID  string    `json:"plugin_id"`
	Op        string    `json:"op"`
	StreamID  string    `json:"stream_id"` // protocol stream_id
	At        time.Time `json:"at"`
}

type StreamStartedMsg struct {
	Stream StreamStarted
}

type StreamStopRequest struct {
	StreamKey string `json:"stream_key"`
}

type StreamStopRequestMsg struct {
	Request StreamStopRequest
}