manager

type BuildManager interface {
	// Request requests the next available build stage for execution.
	Request(ctx context.Context, args *Request) (*core.Stage, error)

	// Accept accepts the build stage for execution.
	Accept(ctx context.Context, stage int64, machine string) (*core.Stage, error)

	// Netrc returns a valid netrc for execution.
	Netrc(ctx context.Context, repo int64) (*core.Netrc, error)

	// Details fetches build details
	Details(ctx context.Context, stage int64) (*Context, error)

	// Before signals the build step is about to start.
	Before(ctxt context.Context, step *core.Step) error

	// After signals the build step is complete.
	After(ctx context.Context, step *core.Step) error

	// Before signals the build stage is about to start.
	BeforeAll(ctxt context.Context, stage *core.Stage) error

	// After signals the build stage is complete.
	AfterAll(ctx context.Context, stage *core.Stage) error

	// Watch watches for build cancellation requests.
	Watch(ctx context.Context, stage int64) (bool, error)

	// Write writes a line to the build logs
	Write(ctx context.Context, step int64, line *core.Line) error

	// Upload uploads the full logs
	Upload(ctx context.Context, step int64, r io.Reader) error

	// UploadBytes uploads the full logs
	UploadBytes(ctx context.Context, step int64, b []byte) error
}

type Context struct {
	Repo    *core.Repository `json:"repository"`
	Build   *core.Build      `json:"build"`
	Stage   *core.Stage      `json:"stage"`
	Config  *core.File       `json:"config"`
	Secrets []*core.Secret   `json:"secrets"`
	System  *core.System     `json:"system"`
}

type Manager struct {
	Builds    core.BuildStore
	Config    core.ConfigService
	Events    core.Pubsub
	Globals   core.GlobalSecretStore
	Logs      core.LogStore
	Logz      core.LogStream
	Netrcs    core.NetrcService
	Repos     core.RepositoryStore
	Scheduler core.Scheduler
	Secrets   core.SecretStore
	Status    core.StatusService
	Stages    core.StageStore
	Steps     core.StepStore
	System    *core.System
	Users     core.UserStore
	Webhook   core.WebhookSender
}

type Request struct {
	Kind    string            `json:"kind"`
	Type    string            `json:"type"`
	OS      string            `json:"os"`
	Arch    string            `json:"arch"`
	Variant string            `json:"variant"`
	Kernel  string            `json:"kernel"`
	Labels  map[string]string `json:"labels,omitempty"`
}