task_command.go

package plumber

import (
	"context"
)

// Creates a NewCommand attached to the current task.
func (t *Task) CreateCommand(command string, args ...string) *Command {
	return NewCommand(t, command, args...)
}

// Returns the attached commands to this task.
func (t *Task) GetCommands() []*Command {
	return t.commands
}

// Returns the attached commands to this task as a slice of jobs.
func (t *Task) GetCommandJobs() []Job {
	j := []Job{}
	for _, c := range t.commands {
		j = append(j, c.Job())
	}

	return j
}

// Returns the attached commands to this task as a job to run as sequence depending on their definition order.
func (t *Task) GetCommandJobAsJobSequence() Job {
	j := t.GetCommandJobs()

	if len(j) == 0 {
		return nil
	}

	return JobSequence(j...)
}

// Returns the attached commands to this task as a job to run as parallel depending on their definition order.
func (t *Task) GetCommandJobAsJobParallel() Job {
	j := t.GetCommandJobs()

	if len(j) == 0 {
		return nil
	}

	return JobParallel(j...)
}

// Attaches existing commands to this task.
func (t *Task) AddCommands(commands ...*Command) *Task {
	t.taskLock.Lock()
	t.commands = append(t.commands, commands...)
	t.taskLock.Unlock()

	return t
}

// Runs the commands that are attached to this task as sequence.
func (t *Task) RunCommandJobAsJobSequence(ctx context.Context) error {
	return t.Plumber.runJobs(ctx, t.GetCommandJobAsJobSequence())
}

// Runs the commands that are attached to this task as parallel.
func (t *Task) RunCommandJobAsJobParallel(ctx context.Context) error {
	return t.Plumber.runJobs(ctx, t.GetCommandJobAsJobParallel())
}

// Runs the commands that are attached to this task as parallel with the given wrapper.
func (t *Task) RunCommandJob(ctx context.Context, fn TaskJobParserFn) error {
	return t.Plumber.runJobs(ctx, fn(t))
}