internal

type CommandExecutor func(ctx context.Context, input ExecCommandInput) (ExecCommandResponse, error)

type ComposeContainersInput struct {
	// Client is the Docker client to use. If nil, a new one will be created.
	Client DockerClientInterface
	// ProjectName is the name of the project
	ProjectName string
	// ServiceName is the name of the service
	ServiceName string
	// Status is the status of the containers to return
	Status string
}

type ContainerNameTemplateData struct {
	// ProjectName is the name of the project
	ProjectName string
	// ServiceName is the name of the service
	ServiceName string
	// InstanceID is the instance ID
	InstanceID int
}

type CronConfig struct {
	// Schedule is the cron expression or @every interval
	Schedule string
	// Timezone is the IANA timezone name
	Timezone string
	// Timeout is the maximum duration for the cron task
	Timeout time.Duration
	// NoOverlap prevents concurrent execution of the same cron task
	NoOverlap bool
	// Notify is the notification configuration
	Notify *CronNotifyConfig
}

type CronDefaults struct {
	// Timezone is the default timezone for all cron services in the project
	Timezone string
	// Notify is the default notification configuration
	Notify *CronNotifyConfig
}

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

type CronNotifyConfig struct {
	// URL is the webhook endpoint
	URL string
	// On determines when to send notifications: "success", "failure", or "always"
	On string
	// IncludeOutput includes stdout/stderr in the webhook payload
	IncludeOutput bool
}

type CronProject struct {
	// Name is the project name
	Name string
	// ComposeFiles is the list of compose file paths
	ComposeFiles []string
	// EnvFiles is the list of env file paths
	EnvFiles []string
	// WorkingDirectory is the project working directory
	WorkingDirectory string
	// Defaults is the project-level cron defaults
	Defaults *CronDefaults
	// Services is the list of cron-scheduled services
	Services []CronService
}

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

type CronService struct {
	// Name is the service name
	Name string
	// Config is the parsed cron configuration
	Config *CronConfig
	// Service is the compose service configuration
	Service *types.ServiceConfig
}

type CronWebhookPayload struct {
	Project         string  `json:"project"`
	Service         string  `json:"service"`
	Schedule        string  `json:"schedule"`
	Status          string  `json:"status"`
	ExitCode        int     `json:"exit_code"`
	DurationSeconds float64 `json:"duration_seconds"`
	TriggeredAt     string  `json:"triggered_at"`
	CompletedAt     string  `json:"completed_at"`
	ContainerName   string  `json:"container_name"`
	Stdout          string  `json:"stdout,omitempty"`
	Stderr          string  `json:"stderr,omitempty"`
}

type DeployOneShotServiceInput struct {
	// Build is whether to build images before running
	Build bool
	// ComposeFiles is the list of paths to the compose files
	ComposeFiles []string
	// ContainerName is the custom container name (empty = docker default)
	ContainerName string
	// EnvFiles is the list of paths to the env files
	EnvFiles []string
	// Executor is the command executor to use
	Executor CommandExecutor
	// Labels is the list of additional labels to attach to the container (e.g. "key=value")
	Labels []string
	// Logger is the logger to use
	Logger *command.ZerologUi
	// NoRemove when true skips the --rm flag so the container persists after exit
	NoRemove bool
	// ProjectName is the name of the project
	ProjectName string
	// PullPolicy is the pull policy override from the CLI flag
	PullPolicy string
	// Service is the service configuration
	Service *types.ServiceConfig
	// ServiceName is the name of the service
	ServiceName string
	// StreamOutput streams stdout and stderr to the terminal
	StreamOutput bool
}

type DeployProjectInput struct {
	// Build is whether to build images before deploying
	Build bool
	// Client is the Docker client to use
	Client DockerClientInterface
	// ComposeFiles is the list of paths to the compose files
	ComposeFiles []string
	// ContainerNameTemplate is the Go template for container names
	ContainerNameTemplate string
	// EnvFiles is the list of paths to the env files
	EnvFiles []string
	// EnvVars is the parsed environment variables from env files
	EnvVars map[string]string
	// Executor is the command executor to use
	Executor CommandExecutor
	// Force forces deploy even if service config is unchanged
	Force bool
	// Logger is the logger to use
	Logger *command.ZerologUi
	// Project is the project configuration
	Project *types.Project
	// ProjectName is the name of the project
	ProjectName string
	// PullPolicy is the pull policy override from the CLI flag (always, missing, never)
	PullPolicy string
	// SkipDatabases is whether to skip deploying databases
	SkipDatabases bool
}

type DeployServiceInput struct {
	// Build is whether to build images before deploying
	Build bool
	// Client is the Docker client to use
	Client DockerClientInterface
	// ComposeFiles is the list of paths to the compose files
	ComposeFiles []string
	// ContainerNameTemplate is the Go template for container names
	ContainerNameTemplate string
	// EnvFiles is the list of paths to the env files
	EnvFiles []string
	// EnvVars is the parsed environment variables from env files
	EnvVars map[string]string
	// Executor is the command executor to use
	Executor CommandExecutor
	// Force forces deploy even if service config is unchanged
	Force bool
	// Logger is the logger to use
	Logger *command.ZerologUi
	// Project is the project configuration
	Project *types.Project
	// ProjectName is the name of the project
	ProjectName string
	// PullPolicy is the pull policy override from the CLI flag (always, missing, never)
	PullPolicy string
	// Replicas is the number of replicas to deploy
	Replicas int
	// ServiceName is the name of the service
	ServiceName string
	// SkipDatabases is whether to skip deploying databases
	SkipDatabases bool
}

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

type DockerClientInterface interface {
	Close() error
	ContainerExecCreate(ctx context.Context, containerID string, config container.ExecOptions) (container.ExecCreateResponse, error)
	ContainerExecStart(ctx context.Context, execID string, config container.ExecStartOptions) error
	ContainerExecAttach(ctx context.Context, execID string, config container.ExecAttachOptions) (types.HijackedResponse, error)
	ContainerExecInspect(ctx context.Context, execID string) (container.ExecInspect, error)
	ContainerInspect(ctx context.Context, containerID string) (container.InspectResponse, error)
	ContainerList(ctx context.Context, options container.ListOptions) ([]container.Summary, error)
	ImageInspect(ctx context.Context, imageID string) (image.InspectResponse, error)
	ContainerRemove(ctx context.Context, containerID string, options container.RemoveOptions) error
	ContainerRename(ctx context.Context, containerID, newName string) error
	ContainerStart(ctx context.Context, containerID string, options container.StartOptions) error
	ContainerStop(ctx context.Context, containerID string, options container.StopOptions) error
	ContainerLogs(ctx context.Context, containerID string, options container.LogsOptions) (io.ReadCloser, error)
	ContainerTerminate(ctx context.Context, containerID string, timeoutSeconds int) error
	CopyToContainer(ctx context.Context, containerID, dstPath string, content io.Reader, options container.CopyToContainerOptions) error
	Events(ctx context.Context, options events.ListOptions) (<-chan events.Message, <-chan error)
}

type DotOrchestrateConfig struct {
	ComposeFiles []string `yaml:"compose-files"`
	EnvFiles     []string `yaml:"env-files"`
}

type ErrorWithOutput struct {
	Err    error
	Output string
}

type ExecCommandInput struct {
	// Command is the command to execute
	Command string

	// Args are the arguments to pass to the command
	Args []string

	// DisableStdioBuffer disables the stdio buffer
	DisableStdioBuffer bool

	// Env is the environment variables to pass to the command
	Env map[string]string

	// Stdin is the stdin of the command
	Stdin io.Reader

	// StreamStdio prints stdout and stderr directly to os.Stdout/err as
	// the command runs
	StreamStdio bool

	// StreamStdout prints stdout directly to os.Stdout as the command runs.
	StreamStdout bool

	// StreamStderr prints stderr directly to os.Stderr as the command runs.
	StreamStderr bool

	// StdoutWriter is the writer to write stdout to
	StdoutWriter io.Writer

	// StderrWriter is the writer to write stderr to
	StderrWriter io.Writer

	// Sudo runs the command with sudo -n -u root
	Sudo bool

	// WorkingDirectory is the working directory to run the command in
	WorkingDirectory string

	// Detached starts the command and returns immediately without waiting
	// for it to complete. The process is forked synchronously (guaranteed
	// to be running when the function returns) but runs independently
	// in the background.
	Detached bool
}

type ExecCommandResponse struct {
	// Stdout is the stdout of the command
	Stdout string

	// Stderr is the stderr of the command
	Stderr string

	// ExitCode is the exit code of the command
	ExitCode int

	// Cancelled is whether the command was cancelled
	Cancelled bool
}

type ExecResult struct {
	Stdout    string
	Stderr    string
	ExitCode  int
	Cancelled bool
}

type ExecTask struct {
	// Command is the command to execute.
	//
	// Any arguments must be given via Args
	Command string

	// Args are the arguments to pass to the command.
	Args []string

	// Shell run the command in a bash shell.
	// Note that the system must have `bash` installed in the PATH or in /bin/bash
	Shell bool

	// Env is a list of environment variables to add to the current environment,
	// these are used to override any existing environment variables.
	Env []string

	// Cwd is the working directory for the command
	Cwd string

	// Stdin connect a reader to stdin for the command
	// being executed.
	Stdin io.Reader

	// PrintCommand prints the command before executing
	PrintCommand bool

	// StreamStdio prints stdout and stderr directly to os.Stdout/err as
	// the command runs.
	StreamStdio bool

	// DisableStdioBuffer prevents any output from being saved in the
	// ExecResult, which is useful for when the result is very large, or
	// when you want to stream the output to another writer exclusively.
	DisableStdioBuffer bool

	// StdOutWriter when set will receive a copy of stdout from the command
	StdOutWriter io.Writer

	// StdErrWriter when set will receive a copy of stderr from the command
	StdErrWriter io.Writer

	// Detached starts the command synchronously (ensuring the OS process is
	// forked) but does not wait for it to complete. The process runs
	// independently in the background. A goroutine is spawned to reap
	// the child process via Wait.
	Detached bool
}

type ListRunExecutionsInput struct {
	// Client is the Docker client
	Client DockerClientInterface
	// ProjectName filters by project name (empty = all projects)
	ProjectName string
}

type MidnightPinnedSchedule struct {
	// Interval is the duration between runs
	Interval time.Duration
	// Location is the timezone for midnight calculation
	Location *time.Location
}

type OneShotServiceInfo struct {
	// Name is the service name
	Name string
	// Command is the service command as a string
	Command string
}

type RenameContainersToConventionInput struct {
	// Client is the Docker client to use. If nil, a new one will be created.
	Client DockerClientInterface
	// Containers is the list of containers to rename
	Containers []container.Summary
	// ProjectName is the name of the project
	ProjectName string
	// ServiceName is the name of the service
	ServiceName string
	// NameTemplate is the Go template for container names
	NameTemplate string
}

type RollingUpdateInput struct {
	// Build is whether to build images before deploying
	Build bool
	// Client is the Docker client to use. If nil, a new one will be created.
	Client DockerClientInterface
	// ComposeFiles is the list of paths to the compose files
	ComposeFiles []string
	// ContainersToUpdate is the list of containers to update
	ContainersToUpdate []container.Summary
	// EnvFiles is the list of paths to the env files
	EnvFiles []string
	// EnvVars is the parsed environment variables from env files
	EnvVars map[string]string
	// CurrentReplicas is the current number of replicas
	CurrentReplicas int
	// Delay is the delay between batches
	Delay time.Duration
	// DesiredReplicas is the target number of replicas
	DesiredReplicas int
	// Executor is the command executor to use. If nil, ExecCommand will be used.
	Executor CommandExecutor
	// FailureAction is the action to take on failure (pause or empty)
	FailureAction string
	// HealthcheckCommand is the command to run for health checks
	HealthcheckCommand string
	// HealthcheckWait is the duration to wait before considering a container without a Docker healthcheck as healthy
	HealthcheckWait time.Duration
	// WaitAfterHealthy is the duration to wait after a container becomes healthy before proceeding
	WaitAfterHealthy time.Duration
	// Logger is the logger to use
	Logger *command.ZerologUi
	// MaxFailureRatio is the maximum allowed failure ratio
	MaxFailureRatio float32
	// Monitor is the health check monitoring duration
	Monitor time.Duration
	// Order is the update order strategy (start-first or stop-first)
	Order string
	// Parallelism is the number of containers to update simultaneously
	Parallelism int
	// ProjectDir is the project directory
	ProjectDir string
	// ProjectName is the name of the project
	ProjectName string
	// PullPolicy is the pull policy to pass to docker compose (always, missing, never)
	PullPolicy string
	// RollbackConfig is the optional rollback configuration. Used when FailureAction is "rollback".
	RollbackConfig *types.UpdateConfig
	// ServiceName is the name of the service
	ServiceName string
	// Sleeper is the function to use for sleeping. If nil, time.Sleep will be used.
	Sleeper func(time.Duration)
	// PreStopHostCommand is the command to run before stopping a container (on host)
	PreStopHostCommand string
	// PreStopHostCommandDetached indicates if the pre-stop host command should run detached
	PreStopHostCommandDetached bool
	// PreStopCommand is the command to run inside the container before stopping
	PreStopCommand string
	// PreStopHooks are the compose spec pre_stop hooks to run inside the container before stopping
	PreStopHooks []types.ServiceHook
	// PostStopHostCommand is the command to run after stopping a container
	PostStopHostCommand string
	// PostStopHostCommandDetached indicates if the post-stop command should run detached
	PostStopHostCommandDetached bool
	// StopTimeout is the timeout in seconds for stopping containers (from stop_grace_period)
	StopTimeout int
	// TickerCh is an optional channel to use for ticking. If nil, time.NewTicker will be used.
	TickerCh <-chan time.Time
}

type RollingUpdateOutput struct {
	// Failures is the number of failures
	Failures int
	// TotalUpdates is the total number of updates
	TotalUpdates int
}

type RunContainerHookInput struct {
	// Client is the Docker client to use
	Client DockerClientInterface
	// ContainerID is the ID of the container
	ContainerID string
	// Hook is the compose spec service hook to execute
	Hook composeTypes.ServiceHook
	// ServiceName is the name of the service
	ServiceName string
}

type RunContainerHooksInput struct {
	// Client is the Docker client to use
	Client DockerClientInterface
	// ContainerID is the ID of the container
	ContainerID string
	// Hooks is the list of compose spec service hooks to execute
	Hooks []composeTypes.ServiceHook
	// ServiceName is the name of the service
	ServiceName string
}

type RunContainerScriptInput struct {
	// Client is the Docker client to use
	Client DockerClientInterface
	// ContainerID is the ID of the container
	ContainerID string
	// Env is the environment variables to pass to the container exec
	Env map[string]string
	// Script is the script content to execute
	Script string
	// ScriptPath is the path inside the container where the script will be written
	ScriptPath string
	// ServiceName is the name of the service
	ServiceName string
}

type RunExecution struct {
	// ContainerName is the name of the container
	ContainerName string
	// Service is the service name
	Service string
	// Status is the container status (e.g. "running", "exited")
	Status string
	// ExitCode is the exit code (-1 if still running)
	ExitCode int
	// TriggeredAt is when the execution was triggered
	TriggeredAt string
}

type RunServiceInput struct {
	// Build is whether to build images before running
	Build bool
	// Client is the Docker client
	Client DockerClientInterface
	// ComposeFiles is the list of paths to the compose files
	ComposeFiles []string
	// Detach runs the service in the background
	Detach bool
	// EnvFiles is the list of paths to the env files
	EnvFiles []string
	// EnvVars is the parsed environment variables
	EnvVars map[string]string
	// Executor is the command executor to use
	Executor CommandExecutor
	// Logger is the logger to use
	Logger *command.ZerologUi
	// Project is the parsed compose project
	Project *composetypes.Project
	// ProjectName is the name of the project
	ProjectName string
	// PullPolicy is the pull policy override from the CLI flag
	PullPolicy string
	// ServiceName is the name of the service
	ServiceName string
}

type ScaleDownContainersInput struct {
	// Client is the Docker client to use. If nil, a new one will be created.
	Client DockerClientInterface
	// ComposeFiles is the list of paths to the compose files
	ComposeFiles []string
	// CurrentContainers is the current list of containers
	CurrentContainers []container.Summary
	// EnvFiles is the list of paths to the env files
	EnvFiles []string
	// EnvVars is the parsed environment variables from env files
	EnvVars map[string]string
	// CurrentReplicas is the current number of containers
	CurrentReplicas int
	// DesiredReplicas is the target number of replicas
	DesiredReplicas int
	// Executor is the command executor to use. If nil, ExecCommand will be used.
	Executor CommandExecutor
	// Logger is the logger to use
	Logger *command.ZerologUi
	// ProjectName is the name of the project
	ProjectName string
	// ServiceName is the name of the service
	ServiceName string
	// SkipDatabases is whether to skip interacting with databases
	SkipDatabases bool
	// PreStopHostCommand is the command to run before stopping a container (on host)
	PreStopHostCommand string
	// PreStopHostCommandDetached indicates if the pre-stop host command should run detached
	PreStopHostCommandDetached bool
	// PreStopCommand is the command to run inside the container before stopping
	PreStopCommand string
	// PreStopHooks are the compose spec pre_stop hooks to run inside the container before stopping
	PreStopHooks []types.ServiceHook
	// PostStopHostCommand is the command to run after stopping a container
	PostStopHostCommand string
	// PostStopHostCommandDetached indicates if the post-stop command should run detached
	PostStopHostCommandDetached bool
	// StopTimeout is the timeout in seconds for stopping containers (from stop_grace_period)
	StopTimeout int
}

type ScaleUpContainersInput struct {
	// Build is whether to build images before deploying
	Build bool
	// Client is the Docker client to use. If nil, a new one will be created.
	Client DockerClientInterface
	// ComposeFiles is the list of paths to the compose files
	ComposeFiles []string
	// CurrentReplicas is the current number of containers
	CurrentReplicas int
	// EnvFiles is the list of paths to the env files
	EnvFiles []string
	// EnvVars is the parsed environment variables from env files
	EnvVars map[string]string
	// Delay is the delay between batches
	Delay time.Duration
	// DesiredReplicas is the target number of replicas
	DesiredReplicas int
	// Executor is the command executor to use. If nil, ExecCommand will be used.
	Executor CommandExecutor
	// ExistingContainers is the list of existing containers to skip
	ExistingContainers []container.Summary
	// FailureAction is the action to take on failure (pause or empty)
	FailureAction string
	// HealthcheckCommand is the command to run for health checks
	HealthcheckCommand string
	// HealthcheckWait is the duration to wait before considering a container without a Docker healthcheck as healthy
	HealthcheckWait time.Duration
	// WaitAfterHealthy is the duration to wait after a container becomes healthy before proceeding
	WaitAfterHealthy time.Duration
	// Logger is the logger to use
	Logger *command.ZerologUi
	// MaxFailureRatio is the maximum allowed failure ratio
	MaxFailureRatio float32
	// Monitor is the health check monitoring duration
	Monitor time.Duration
	// Parallelism is the number of containers to update simultaneously
	Parallelism int
	// PostStartHooks are the compose spec post_start hooks to run inside the container after starting
	PostStartHooks []types.ServiceHook
	// ProjectDir is the project directory
	ProjectDir string
	// ProjectName is the name of the project
	ProjectName string
	// PullPolicy is the pull policy to pass to docker compose (always, missing, never)
	PullPolicy string
	// RollbackConfig is the optional rollback configuration. Used when FailureAction is "rollback".
	RollbackConfig *types.UpdateConfig
	// ServiceName is the name of the service
	ServiceName string
	// Sleeper is the function to use for sleeping. If nil, time.Sleep will be used.
	Sleeper func(time.Duration)
	// PreStopHostCommand is the command to run before stopping a container (on host)
	PreStopHostCommand string
	// PreStopHostCommandDetached indicates if the pre-stop host command should run detached
	PreStopHostCommandDetached bool
	// PreStopCommand is the command to run inside the container before stopping
	PreStopCommand string
	// PreStopHooks are the compose spec pre_stop hooks to run inside the container before stopping
	PreStopHooks []types.ServiceHook
	// PostStopHostCommand is the command to run after stopping a container
	PostStopHostCommand string
	// PostStopHostCommandDetached indicates if the post-stop command should run detached
	PostStopHostCommandDetached bool
	// StopTimeout is the timeout in seconds for stopping containers (from stop_grace_period)
	StopTimeout int
	// TickerCh is an optional channel to use for ticking. If nil, time.NewTicker will be used.
	TickerCh <-chan time.Time
}

type ScriptTemplateData struct {
	// ContainerID is the ID of the container
	ContainerID string
	// ContainerIP is the IP address of the container
	ContainerIP string
	// ContainerShortID is the short ID of the container
	ContainerShortID string
	// ProjectName is the name of the project
	ProjectName string
	// ServiceName is the name of the service
	ServiceName string
}

type ServiceConfigStatus int

type ServiceConfigStatusInput struct {
	// BuildImage is whether images will actually be built for this service
	BuildImage bool
	// Client is the Docker client to use
	Client DockerClientInterface
	// ComposeFiles is the list of compose files (for pull command)
	ComposeFiles []string
	// EnvFiles is the list of env files (for pull command)
	EnvFiles []string
	// Executor is the command executor to use (for pulling images)
	Executor CommandExecutor
	// Force forces deploy even if service config is unchanged
	Force bool
	// Logger is the logger to use
	Logger *command.ZerologUi
	// ProjectName is the name of the project
	ProjectName string
	// PullPolicy is the resolved pull policy for this service
	PullPolicy string
	// Replicas is the desired number of replicas
	Replicas int
	// Service is the service configuration
	Service *types.ServiceConfig
	// ServiceName is the name of the service
	ServiceName string
}

type ShouldSkipScaleDownServiceInput struct {
	// Container is the container to check
	Container container.Summary
	// ServiceName is the name of the service
	ServiceName string
	// ShouldSkipDatabases is whether to skip interacting with databases
	ShouldSkipDatabases bool
	// Logger is the logger to use
	Logger *command.ZerologUi
}

type ShouldSkipServiceInput struct {
	// Logger is the logger to use
	Logger *command.ZerologUi
	// Service is the service configuration
	Service *types.ServiceConfig
	// ShouldSkipDatabases is whether to skip deploying databases
	ShouldSkipDatabases bool
	// SilenceLogging is whether to silence logging
	SilenceLogging bool
}

type SpawnCronTaskInput struct {
	// Build is whether to build images before running
	Build bool
	// Executor is the command executor to use
	Executor CommandExecutor
	// Logger is the logger to use
	Logger *command.ZerologUi
	// Project is the cron project configuration
	Project CronProject
	// PullPolicy is the pull policy override from the CLI flag
	PullPolicy string
	// Service is the cron service configuration
	Service CronService
}

type SpawnerFunc func(ctx context.Context, project CronProject, service CronService) error

type WaitForHealthcheckInput struct {
	// Client is the Docker client to use. If nil, a new one will be created.
	Client DockerClientInterface
	// ContainerID is the ID of the container to wait for
	ContainerID string
	// Executor is the command executor to use. If nil, ExecCommand will be used.
	Executor CommandExecutor
	// HealthcheckCommand is the command to run for health checks
	HealthcheckCommand string
	// Monitor is the health check monitoring duration
	Monitor time.Duration
	// ProjectName is the name of the project
	ProjectName string
	// ServiceName is the name of the service
	ServiceName string
	// TickerCh is an optional channel to use for ticking. If nil, time.NewTicker will be used.
	TickerCh <-chan time.Time
	// HealthcheckWait is the duration to wait before considering a container without a Docker healthcheck as healthy.
	// The container must be continuously running for this duration. If it restarts, the timer resets.
	HealthcheckWait time.Duration
}