db

type BasicAuth struct {
	BasicAuthUsername string `json:"basic_auth_username"`
	BasicAuthPassword string `json:"basic_auth_password"`
}

type Build struct {
	ID               int
	Name             string
	Status           Status
	Scheduled        bool
	InputsDetermined bool

	JobID        int
	JobName      string
	PipelineName string
	PipelineID   int

	Engine         string
	EngineMetadata string

	StartTime time.Time
	EndTime   time.Time
}

type BuildInput struct {
	Name string

	VersionedResource

	FirstOccurrence bool
}

type BuildOutput struct {
	VersionedResource
}

type BuildPreparation struct {
	BuildID          int
	PausedPipeline   BuildPreparationStatus
	PausedJob        BuildPreparationStatus
	MaxRunningBuilds BuildPreparationStatus
	Inputs           map[string]BuildPreparationStatus
	InputsSatisfied  BuildPreparationStatus
}

type BuildPreparationStatus string

type ConfigDB interface {
	GetConfig(teamName, pipelineName string) (atc.Config, ConfigVersion, error)
	SaveConfig(string, string, atc.Config, ConfigVersion, PipelinePausedState) (SavedPipeline, bool, error)
}

type ConfigVersion int

type Conn interface {
	Begin() (Tx, error)
	Close() error
	Driver() driver.Driver
	Exec(query string, args ...interface{}) (sql.Result, error)
	Ping() error
	Prepare(query string) (*sql.Stmt, error)
	Query(query string, args ...interface{}) (*sql.Rows, error)
	QueryRow(query string, args ...interface{}) *sql.Row
	SetMaxIdleConns(n int)
	SetMaxOpenConns(n int)
}

type Container struct {
	ContainerIdentifier
	ContainerMetadata
}

type ContainerIdentifier struct {
	// if it's a resource check container
	ResourceID  int
	CheckType   string
	CheckSource atc.Source

	// if it's a step container
	BuildID int
	PlanID  atc.PlanID

	// for the check + get stages of a container with a resource backed image
	ImageResourceType   string
	ImageResourceSource atc.Source

	Stage ContainerStage
}

type ContainerMetadata struct {
	Handle               string
	WorkerName           string
	BuildName            string
	ResourceName         string
	PipelineID           int
	PipelineName         string
	JobName              string
	StepName             string
	Type                 ContainerType
	WorkingDirectory     string
	EnvironmentVariables []string
	Attempts             []int
	User                 string
}

type ContainerStage string

type ContainerType string

type DB interface {
	SaveTeam(team Team) (SavedTeam, error)
	GetTeamByName(teamName string) (SavedTeam, bool, error)
	UpdateTeamBasicAuth(team Team) (SavedTeam, error)
	UpdateTeamGitHubAuth(team Team) (SavedTeam, error)
	CreateDefaultTeamIfNotExists() error
	DeleteTeamByName(teamName string) error

	GetBuild(buildID int) (Build, bool, error)
	GetBuildVersionedResources(buildID int) (SavedVersionedResources, error)
	GetBuildResources(buildID int) ([]BuildInput, []BuildOutput, error)
	GetBuilds(Page) ([]Build, Pagination, error)
	GetAllStartedBuilds() ([]Build, error)

	CreatePipe(pipeGUID string, url string) error
	GetPipe(pipeGUID string) (Pipe, error)

	CreateOneOffBuild() (Build, error)
	GetBuildPreparation(buildID int) (BuildPreparation, bool, error)
	UpdateBuildPreparation(buildPreparation BuildPreparation) error
	ResetBuildPreparationsWithPipelinePaused(pipelineID int) error

	LeaseBuildTracking(buildID int, interval time.Duration) (Lease, bool, error)
	LeaseBuildScheduling(buildID int, interval time.Duration) (Lease, bool, error)
	LeaseCacheInvalidation(interval time.Duration) (Lease, bool, error)

	StartBuild(buildID int, engineName, engineMetadata string) (bool, error)
	FinishBuild(buildID int, status Status) error
	ErrorBuild(buildID int, cause error) error

	SaveBuildInput(teamName string, buildID int, input BuildInput) (SavedVersionedResource, error)
	SaveBuildOutput(teamName string, buildID int, vr VersionedResource, explicit bool) (SavedVersionedResource, error)

	GetBuildEvents(buildID int, from uint) (EventSource, error)
	SaveBuildEvent(buildID int, event atc.Event) error

	SaveBuildEngineMetadata(buildID int, engineMetadata string) error

	AbortBuild(buildID int) error
	AbortNotifier(buildID int) (Notifier, error)

	Workers() ([]SavedWorker, error) // auto-expires workers based on ttl
	GetWorker(workerName string) (SavedWorker, bool, error)
	SaveWorker(WorkerInfo, time.Duration) (SavedWorker, error)

	FindContainersByDescriptors(Container) ([]SavedContainer, error)
	GetContainer(string) (SavedContainer, bool, error)
	CreateContainer(Container, time.Duration) (SavedContainer, error)
	FindContainerByIdentifier(ContainerIdentifier) (SavedContainer, bool, error)
	UpdateExpiresAtOnContainer(handle string, ttl time.Duration) error
	ReapContainer(handle string) error

	DeleteContainer(string) error

	GetConfigByBuildID(buildID int) (atc.Config, ConfigVersion, error)

	InsertVolume(data Volume) error
	GetVolumes() ([]SavedVolume, error)
	ReapVolume(string) error
	SetVolumeTTL(string, time.Duration) error
	GetVolumeTTL(volumeHandle string) (time.Duration, error)
	GetVolumesForOneOffBuildImageResources() ([]SavedVolume, error)

	SaveImageResourceVersion(buildID int, planID atc.PlanID, identifier VolumeIdentifier) error
	GetImageVolumeIdentifiersByBuildID(buildID int) ([]VolumeIdentifier, error)
}

type Dashboard []DashboardJob

type DashboardJob struct {
	Job       SavedJob
	JobConfig atc.JobConfig

	FinishedBuild *Build
	NextBuild     *Build
}

type EventSource interface {
	Next() (atc.Event, error)
	Close() error
}

type GitHubAuth struct {
	ClientID      string       `json:"client_id"`
	ClientSecret  string       `json:"client_secret"`
	Organizations []string     `json:"organizations"`
	Teams         []GitHubTeam `json:"teams"`
	Users         []string     `json:"users"`
}

type GitHubTeam struct {
	OrganizationName string `json:"organization_name"`
	TeamName         string `json:"team_name"`
}

type Job struct {
	Name string
}

type JobHistory struct {
	JobName string
	Builds  []Build
}

type Lease interface {
	Break()
}

type Lock interface {
	Release() error
}

type MetadataField struct {
	Name  string
	Value string
}

type Notifier interface {
	Notify() <-chan struct{}
	Close() error
}

type Page struct {
	Since int
	Until int
	Limit int
}

type Pagination struct {
	Previous *Page
	Next     *Page
}

type Pipe struct {
	ID  string
	URL string
}

type Pipeline struct {
	Name    string
	Config  atc.Config
	Version ConfigVersion
}

type PipelineDB interface {
	GetPipelineName() string
	ScopedName(string) string

	Pause() error
	Unpause() error
	IsPaused() (bool, error)

	Destroy() error

	GetConfig() (atc.Config, ConfigVersion, bool, error)

	LeaseScheduling(time.Duration) (Lease, bool, error)

	GetResource(resourceName string) (SavedResource, error)
	GetResourceVersions(resourceName string, page Page) ([]SavedVersionedResource, Pagination, bool, error)

	PauseResource(resourceName string) error
	UnpauseResource(resourceName string) error

	SaveResourceVersions(atc.ResourceConfig, []atc.Version) error
	GetLatestVersionedResource(resource SavedResource) (SavedVersionedResource, bool, error)
	GetLatestEnabledVersionedResource(resourceName string) (SavedVersionedResource, bool, error)
	EnableVersionedResource(versionedResourceID int) error
	DisableVersionedResource(versionedResourceID int) error
	SetResourceCheckError(resource SavedResource, err error) error
	LeaseResourceChecking(resource string, length time.Duration, immediate bool) (Lease, bool, error)

	GetJob(job string) (SavedJob, error)
	PauseJob(job string) error
	UnpauseJob(job string) error

	GetJobFinishedAndNextBuild(job string) (*Build, *Build, error)

	GetJobBuilds(job string, page Page) ([]Build, Pagination, error)
	GetAllJobBuilds(job string) ([]Build, error)

	GetJobBuild(job string, build string) (Build, bool, error)
	CreateJobBuild(job string) (Build, error)
	CreateJobBuildForCandidateInputs(job string) (Build, bool, error)

	UseInputsForBuild(buildID int, inputs []BuildInput) error

	LoadVersionsDB() (*algorithm.VersionsDB, error)
	GetLatestInputVersions(versions *algorithm.VersionsDB, job string, inputs []config.JobInput) ([]BuildInput, bool, error)
	GetJobBuildForInputs(job string, inputs []BuildInput) (Build, bool, error)
	GetNextPendingBuild(job string) (Build, bool, error)

	GetBuild(buildID int) (Build, bool, error)
	GetCurrentBuild(job string) (Build, bool, error)
	GetRunningBuildsBySerialGroup(jobName string, serialGroups []string) ([]Build, error)
	GetNextPendingBuildBySerialGroup(jobName string, serialGroups []string) (Build, bool, error)

	UpdateBuildToScheduled(buildID int) (bool, error)
	SaveBuildInput(buildID int, input BuildInput) (SavedVersionedResource, error)
	SaveBuildOutput(buildID int, vr VersionedResource, explicit bool) (SavedVersionedResource, error)
	GetBuildsWithVersionAsInput(versionedResourceID int) ([]Build, error)
	GetBuildsWithVersionAsOutput(versionedResourceID int) ([]Build, error)

	UpdateBuildPreparation(prep BuildPreparation) error

	GetDashboard() (Dashboard, atc.GroupConfigs, error)
}

type PipelineDBFactory interface {
	Build(pipeline SavedPipeline) PipelineDB
	BuildWithTeamNameAndName(teamName, pipelineName string) (PipelineDB, error)
	BuildDefault() (PipelineDB, bool, error)
}

type PipelinePausedState string

type PipelinesDB interface {
	GetAllPipelines() ([]SavedPipeline, error)
	GetPipelineByTeamNameAndName(teamName string, pipelineName string) (SavedPipeline, error)

	OrderPipelines([]string) error
}

type Resource struct {
	Name string
}

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

type SavedContainer struct {
	Container

	TTL       time.Duration
	ExpiresIn time.Duration
}

type SavedJob struct {
	ID           int
	Paused       bool
	PipelineName string
	Job
}

type SavedPipeline struct {
	ID     int
	Paused bool
	TeamID int

	Pipeline
}

type SavedResource struct {
	ID           int
	CheckError   error
	Paused       bool
	PipelineName string
	Resource
}

type SavedTeam struct {
	ID int
	Team
}

type SavedVersionedResource struct {
	ID int

	Enabled bool

	ModifiedTime time.Time

	VersionedResource

	CheckOrder int
}

type SavedVersionedResources []SavedVersionedResource

type SavedVolume struct {
	Volume

	ID        int
	ExpiresIn time.Duration
}

type SavedWorker struct {
	WorkerInfo

	ExpiresIn time.Duration
}

type Status string

type Team struct {
	Name  string
	Admin bool
	BasicAuth
	GitHubAuth
}

type Tx interface {
	Commit() error
	Exec(query string, args ...interface{}) (sql.Result, error)
	Prepare(query string) (*sql.Stmt, error)
	Query(query string, args ...interface{}) (*sql.Rows, error)
	QueryRow(query string, args ...interface{}) *sql.Row
	Rollback() error
	Stmt(stmt *sql.Stmt) *sql.Stmt
}

type Version map[string]string

type VersionHistory struct {
	VersionedResource SavedVersionedResource
	InputsTo          []*JobHistory
	OutputsOf         []*JobHistory
}

type VersionedResource struct {
	Resource     string
	Type         string
	Version      Version
	Metadata     []MetadataField
	PipelineName string
}

type VersionedResources []VersionedResource

type Volume struct {
	WorkerName string
	TTL        time.Duration
	Handle     string
	VolumeIdentifier
}

type VolumeIdentifier struct {
	ResourceVersion atc.Version
	ResourceHash    string
}

type WorkerInfo struct {
	GardenAddr      string
	BaggageclaimURL string

	ActiveContainers int
	ResourceTypes    []atc.WorkerResourceType
	Platform         string
	Tags             []string
	Name             string
}