manifest: add only necessary repositories to each pipeline

Each pipeline constructor receives the full list of repositories and
filters the list based on its own internal name.
This commit is contained in:
Achilleas Koutsou 2023-02-17 18:00:30 +01:00 committed by Tomáš Hozza
parent a66003e513
commit c7e0b69704
5 changed files with 15 additions and 10 deletions

View file

@ -66,10 +66,11 @@ func NewAnaconda(m *Manifest,
kernelName,
product,
version string) *Anaconda {
name := "anaconda-tree"
p := &Anaconda{
Base: NewBase(m, "anaconda-tree", buildPipeline),
Base: NewBase(m, name, buildPipeline),
platform: platform,
repos: repos,
repos: filterRepos(repos, name),
kernelName: kernelName,
product: product,
version: version,

View file

@ -25,11 +25,12 @@ type Build struct {
// NewBuild creates a new build pipeline from the repositories in repos
// and the specified packages.
func NewBuild(m *Manifest, runner runner.Runner, repos []rpmmd.RepoConfig) *Build {
name := "build"
pipeline := &Build{
Base: NewBase(m, "build", nil),
Base: NewBase(m, name, nil),
runner: runner,
dependents: make([]Pipeline, 0),
repos: repos,
repos: filterRepos(repos, name),
}
m.addPipeline(pipeline)
return pipeline

View file

@ -41,10 +41,11 @@ func NewOSTreeCommitServer(m *Manifest,
commitPipeline *OSTreeCommit,
nginxConfigPath,
listenPort string) *OSTreeCommitServer {
name := "container-tree"
p := &OSTreeCommitServer{
Base: NewBase(m, "container-tree", buildPipeline),
Base: NewBase(m, name, buildPipeline),
platform: platform,
repos: repos,
repos: filterRepos(repos, name),
commitPipeline: commitPipeline,
nginxConfigPath: nginxConfigPath,
listenPort: listenPort,

View file

@ -50,10 +50,11 @@ func NewCoreOSInstaller(m *Manifest,
kernelName,
product,
version string) *CoreOSInstaller {
name := "coi-tree"
p := &CoreOSInstaller{
Base: NewBase(m, "coi-tree", buildPipeline),
Base: NewBase(m, name, buildPipeline),
platform: platform,
repos: repos,
repos: filterRepos(repos, name),
kernelName: kernelName,
product: product,
version: version,

View file

@ -154,9 +154,10 @@ func NewOS(m *Manifest,
buildPipeline *Build,
platform platform.Platform,
repos []rpmmd.RepoConfig) *OS {
name := "os"
p := &OS{
Base: NewBase(m, "os", buildPipeline),
repos: repos,
Base: NewBase(m, name, buildPipeline),
repos: filterRepos(repos, name),
platform: platform,
}
buildPipeline.addDependent(p)