supervisor

type CronService interface {
	Service
	IsSingle() bool
	IsEnabled() bool
	GetSchedule() string
	SetEnabled(enabled bool)
	StopAll() error
	GetCommand() []string
	GetWorkDir() string
	GetEnv() map[string]string
	GetProcesses() []Process
	Run(t time.Time)
}

type Process interface {
	Start() error
	Stop(timeout time.Duration) error
	Kill() error

	IsRunning() bool

	OnStdout(listener chan string)
	OnStderr(listener chan string)
	OnExit(listener chan int)

	OffStdout(listener chan string)
	OffStderr(listener chan string)
	OffExit(listener chan int)

	GetPath() string
	GetArgs() []string
	GetWorkDir() string
	GetEnv() map[string]string
	GetPid() int
	GetID() string
	GetResourceStats() (*ProcessResourceStats, error)
}

type ProcessConfig struct {
	Path    string
	Args    []string
	WorkDir string
	Env     map[string]string
}

type ProcessResourceStats struct {
	CPUPercent    float64 `json:"cpu_percent"`
	MemoryRSS     uint64  `json:"memory_rss"`
	MemoryPercent float32 `json:"memory_percent"`
}

type ProcessService interface {
	Service
	IsRunning() bool
	GetRetries() int
	GetRestartPolicy() RestartPolicy
	GetLastExitCode() int

	Start() error
	Stop(user bool) error
	Kill() error
	Restart() error

	// New additions:
	GetProcess() Process // The main process for this service
}

type RestartMode int

type RestartPolicy interface {
	GetMode() RestartMode
	IsExponential() bool
	GetMaxRetries() int
	GetInitialDelay() time.Duration
	GetMaxDelay() time.Duration
}

type Service interface {
	GetName() string
	GetType() ServiceType
	AsProcess() ProcessService
	AsCron() CronService

	OnStdout(listener chan string)
	OnStderr(listener chan string)
	OffStdout(listener chan string)
	OffStderr(listener chan string)

	GetSerializedStats() map[string]any

	// New additions:
	ListProcesses() []Process // Expose all processes under this service
	GetProcessByID(id string) (Process, bool)
}

type ServiceType int

type Supervisor interface {
	GetService(name string) (Service, bool)
	AddService(name string, service Service) error
	RemoveService(name string) error
	StartService(name string) error
	StopService(name string) error
	RestartService(name string) error
	Start() error
	Stop() error
	GetAllServices() map[string]Service
}