2020-05-19 12:44:16 +00:00
|
|
|
package registry
|
|
|
|
|
|
|
|
import (
|
2021-05-25 12:08:27 +00:00
|
|
|
"github.com/woodpecker-ci/woodpecker/model"
|
2020-05-19 12:44:16 +00:00
|
|
|
)
|
|
|
|
|
|
|
|
type combined struct {
|
|
|
|
registries []model.ReadOnlyRegistryService
|
|
|
|
dbRegistry model.RegistryService
|
|
|
|
}
|
|
|
|
|
|
|
|
func Combined(dbRegistry model.RegistryService, registries ...model.ReadOnlyRegistryService) model.RegistryService {
|
|
|
|
registries = append(registries, dbRegistry)
|
|
|
|
return &combined{
|
|
|
|
registries: registries,
|
|
|
|
dbRegistry: dbRegistry,
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
func (c combined) RegistryFind(repo *model.Repo, name string) (*model.Registry, error) {
|
|
|
|
for _, registry := range c.registries {
|
|
|
|
res, err := registry.RegistryFind(repo, name)
|
|
|
|
if err != nil {
|
|
|
|
return nil, err
|
|
|
|
}
|
|
|
|
if res != nil {
|
|
|
|
return res, nil
|
|
|
|
}
|
|
|
|
}
|
|
|
|
return nil, nil
|
|
|
|
}
|
|
|
|
|
|
|
|
func (c combined) RegistryList(repo *model.Repo) ([]*model.Registry, error) {
|
2020-05-19 14:05:45 +00:00
|
|
|
var registries []*model.Registry
|
|
|
|
for _, registry := range c.registries {
|
|
|
|
list, err := registry.RegistryList(repo)
|
2020-05-19 12:44:16 +00:00
|
|
|
if err != nil {
|
|
|
|
return nil, err
|
|
|
|
}
|
2020-05-19 14:05:45 +00:00
|
|
|
registries = append(registries, list...)
|
2020-05-19 12:44:16 +00:00
|
|
|
}
|
2020-05-19 14:05:45 +00:00
|
|
|
return registries, nil
|
2020-05-19 12:44:16 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
func (c combined) RegistryCreate(repo *model.Repo, registry *model.Registry) error {
|
|
|
|
return c.dbRegistry.RegistryCreate(repo, registry)
|
|
|
|
}
|
|
|
|
|
|
|
|
func (c combined) RegistryUpdate(repo *model.Repo, registry *model.Registry) error {
|
|
|
|
return c.dbRegistry.RegistryUpdate(repo, registry)
|
|
|
|
}
|
|
|
|
|
|
|
|
func (c combined) RegistryDelete(repo *model.Repo, name string) error {
|
|
|
|
return c.dbRegistry.RegistryDelete(repo, name)
|
|
|
|
}
|