campaigns

type CampaignSpec struct {
	Name              string                `json:"name,omitempty" yaml:"name"`
	Description       string                `json:"description,omitempty" yaml:"description"`
	On                []OnQueryOrRepository `json:"on,omitempty" yaml:"on"`
	Steps             []Step                `json:"steps,omitempty" yaml:"steps"`
	ImportChangesets  []ImportChangeset     `json:"importChangesets,omitempty" yaml:"importChangesets"`
	ChangesetTemplate *ChangesetTemplate    `json:"changesetTemplate,omitempty" yaml:"changesetTemplate"`
}

type CampaignSpecID string

type ChangesetSpec struct {
	BaseRepository string `json:"baseRepository"`

	*ExternalChangeset
	*CreatedChangeset
}

type ChangesetSpecID string

type ChangesetTemplate struct {
	Title     string                       `json:"title,omitempty" yaml:"title"`
	Body      string                       `json:"body,omitempty" yaml:"body"`
	Branch    string                       `json:"branch,omitempty" yaml:"branch"`
	Commit    ExpandedGitCommitDescription `json:"commit,omitempty" yaml:"commit"`
	Published bool                         `json:"published" yaml:"published"`
}

type CreatedChangeset struct {
	BaseRef        string                 `json:"baseRef"`
	BaseRev        string                 `json:"baseRev"`
	HeadRepository string                 `json:"headRepository"`
	HeadRef        string                 `json:"headRef"`
	Title          string                 `json:"title"`
	Body           string                 `json:"body"`
	Commits        []GitCommitDescription `json:"commits"`
	Published      bool                   `json:"published"`
}

type ExecutionCache interface {
	Get(ctx context.Context, key ExecutionCacheKey) (result *ChangesetSpec, err error)
	Set(ctx context.Context, key ExecutionCacheKey, result *ChangesetSpec) error
	Clear(ctx context.Context, key ExecutionCacheKey) error
}

type ExecutionCacheKey struct {
	*Task
}

type ExecutionDiskCache struct {
	Dir string
}

type ExecutionNoOpCache struct{}

type Executor interface {
	AddTask(repo *graphql.Repository, steps []Step, template *ChangesetTemplate) *TaskStatus
	LogFiles() []string
	Start(ctx context.Context)
	Wait() ([]*ChangesetSpec, error)
}

type ExecutorOpts struct {
	Cache       ExecutionCache
	Parallelism int
	Timeout     time.Duration

	ClearCache    bool
	KeepLogs      bool
	VerboseLogger bool
}

type ExecutorUpdateCallback func(*Task, TaskStatus)

type ExpandedGitCommitDescription struct {
	Message string `json:"message,omitempty" yaml:"message"`
}

type ExternalChangeset struct {
	ExternalID string `json:"externalID"`
}

type GitCommitDescription struct {
	Message string `json:"message"`
	Diff    string `json:"diff"`
}

type ImportChangeset struct {
	Repository  string        `json:"repository" yaml:"repository"`
	ExternalIDs []interface{} `json:"externalIDs" yaml:"externalIDs"`
}

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

type OnQueryOrRepository struct {
	RepositoriesMatchingQuery string `json:"repositoriesMatchingQuery,omitempty" yaml:"repositoriesMatchingQuery"`
	Repository                string `json:"repository,omitempty" yaml:"repository"`
	Branch                    string `json:"branch,omitempty" yaml:"branch"`
}

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

type ServiceOpts struct {
	AllowUnsupported bool
	Client           api.Client
}

type Step struct {
	Run       string            `json:"run,omitempty" yaml:"run"`
	Container string            `json:"container,omitempty" yaml:"container"`
	Env       map[string]string `json:"env,omitempty" yaml:"env"`
	// contains filtered or unexported fields
}

type Task struct {
	Repository *graphql.Repository
	Steps      []Step
	Template   *ChangesetTemplate `json:"-"`
}

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

type TaskStatus struct {
	Cached bool

	LogFile    string
	EnqueuedAt time.Time
	StartedAt  time.Time
	FinishedAt time.Time

	// Result fields.
	ChangesetSpec *ChangesetSpec
	Err           error
}