task

type AWSECRPushAction struct {
	Task CoreTasker

	Id   string // The ID of the task
	Name string // The name of the task
	Ctx  context.Context
	// contains filtered or unexported fields
}

type AWSECRPushActionArgs struct {
	AWSRegion         string
	AWSAccessKey      string
	AWSSecretKey      string
	Repository        string
	Registry          string
	Tag               string
	GenerateRandomTag bool
	RunECRLoginInHost bool
}

type AWSECRPushActionOptions struct {
	AWSAccessKey              string
	AWSSecretKey              string
	AWSRegion                 string
	ScanAWSCredentialsFromEnv bool
}

type AWSECRPushActions interface {
	Push() (Output, error)
}

type AWSECRTask struct {
	Init     *InitOptions
	Cfg      *Task
	Actions  []string
	UXPrefix string
}

type AWSECSDeployAction struct {
	Task CoreTasker

	Id   string // The ID of the task
	Name string // The name of the task
	Ctx  context.Context
	// contains filtered or unexported fields
}

type AWSECSDeployActionArgs struct {
	AWSRegion                string
	AWSAccessKey             string
	AWSSecretKey             string
	ClusterName              string
	ServiceName              string
	TaskDefinition           string
	ImageTagOrReleaseVersion string
	Image                    string

	EnvVarsToSetInContainerDef map[string]string
}

type AWSECSDeployActionOptions struct {
	AWSAccessKey              string
	AWSSecretKey              string
	AWSRegion                 string
	ScanAWSCredentialsFromEnv bool
}

type AWSECSDeployActions interface {
	DeployTask() (Output, error)
}

type AWSECSTask struct {
	Init     *InitOptions
	Cfg      *Task
	Actions  []string
	UXPrefix string
}

type Actions struct {
	CustomCommands  []string
	DefaultCommands []string
}

type CoreTasker interface {
	GetClient() *dagger.Client
	GetPipeline() *pipeline.Config
	GetPipelineUXLog() tui.TUIMessenger
	ConvertDir(c *dagger.Client, dir string) (*dagger.Directory, error)
	GetJob() *job.Job
	GetCoreTask() *Task
	GetJobContainerImage() string
	GetJobContainerDefault() *dagger.Container
	GetJobEnvVars() map[string]string
	SetEnvVars(envVars []map[string]string, container *dagger.Container) (*dagger.Container, error)
	SetEnvVarsFromJob(container *dagger.Container) (*dagger.Container, error)
	AuthWithRegistry(c *dagger.Client, container *dagger.Container,
		opt daggerio.RegistryAuthOptions) (*dagger.Container,
		error)
	GetContainer(fromImage string) (*dagger.Container, error)
	BuildImage(dockerFilePath string, container *dagger.Container, ctx context.Context) (*dagger.Container, error)
	PushImage(addr string, container *dagger.Container,
		dockerFileDir *dagger.Directory, ctx context.Context) error
	MountDir(workDirPath, targetDir string, client *dagger.Client, container *dagger.
		Container,
		filesPreRequisites []string, ctx context.Context) (*dagger.Container, error)

	RunCmdInContainer(container *dagger.Container, commands [][]string,
		stdOutEnabled bool, ctx context.Context) error
}

type Dirs struct {
	RootDir         string
	WorkDir         string
	MountDir        string
	TargetDir       string
	RootDirDagger   *dagger.Directory
	WorkDirDagger   *dagger.Directory
	MountDirDagger  *dagger.Directory
	TargetDirDagger *dagger.Directory
}

type DockerBuildAction struct {
	Task CoreTasker

	Id   string // The ID of the task
	Name string // The name of the task
	Ctx  context.Context
	// contains filtered or unexported fields
}

type DockerBuildActions interface {
	BuildTagAndPush(dockerFile string) (Output, error)
}

type DockerTask struct {
	Init     *InitOptions
	Cfg      *Task
	Actions  []string
	UXPrefix string
}

type InfraTerraGruntAction struct {
	Task CoreTasker

	Id   string // The ID of the task
	Name string // The name of the task
	Ctx  context.Context
	// contains filtered or unexported fields
}

type InfraTerraGruntActionArgs struct {
	AWSRegion       string
	AWSAccessKey    string
	AWSSecretKey    string
	TargetModuleDir string
	Commands        []string
	TgConfigFile    string
}

type InfraTerraGruntActionOptions struct {
	AWSAccessKey  string
	AWSSecretKey  string
	AWSRegion     string
	CommandsToRun []string // Either standard commands, or custom commands passed if applicable.
}

type InfraTerraGruntTask struct {
	Init     *InitOptions
	Cfg      *Task
	Actions  []string
	UXPrefix string
}

type InitOptions struct {
	Task  string
	Stack string

	PipelineCfg *pipeline.Config
	JobCfg      *job.Job

	// Directories that the task will use.
	WorkDir   string
	MountDir  string
	TargetDir string

	// Behaviour
	ActionCommands []string
}

type Output struct {
	Files        []*dagger.File
	Directories  []*dagger.Directory
	ExitCode     int
	DaggerOutput interface{}
	IsError      bool
}

type PreRequisites struct {
	Files       []string
	Directories []string
}

type Runner struct {
	Init *InitOptions
	Cfg  *Task
}

type Task struct {
	// Identifiers.
	Id    string
	Name  string
	Stack string

	// Configuration
	PipelineCfg *pipeline.Config
	JobCfg      *job.Job

	// Specific attributes
	EnvVarsInheritFromJob map[string]string
	Dirs                  Dirs
	ContainerImageDefault string
	ContainerNameDefault  string
	ContainerDefault      *dagger.Container

	PreReqs PreRequisites
	Actions Actions

	// Output
	Result Output

	Ctx context.Context
}

type TerrGruntActionRunner interface {
	GetOptions() (InfraTerraGruntActionArgs, error)
	Plan() (Output, error)
	Apply() (Output, error)
	Destroy() (Output, error)
	Validate() (Output, error)
	RunTGCommand(commands [][]string) (Output, error)
}