app/cluster/app.go

package cluster

import (
	"ddm-admin-console/router"
	"ddm-admin-console/service/codebase"
	edpComponent "ddm-admin-console/service/edp_component"
	"ddm-admin-console/service/gerrit"
	"ddm-admin-console/service/jenkins"
	"ddm-admin-console/service/k8s"
	"ddm-admin-console/service/vault"
	"fmt"

	"github.com/patrickmn/go-cache"

	"github.com/pkg/errors"

	"go.uber.org/zap"
)

type Logger interface {
	Error(msg string, fields ...zap.Field)
	Info(msg string, fields ...zap.Field)
}

type JenkinsService interface {
	CreateJobBuildRun(name, jobPath string, jobParams map[string]string) error
}

type Services struct {
	Codebase     codebase.ServiceInterface
	Jenkins      jenkins.ServiceInterface
	K8S          k8s.ServiceInterface
	Gerrit       gerrit.ServiceInterface
	EDPComponent edpComponent.ServiceInterface
	Vault        vault.ServiceInterface
}

type Config struct {
	CodebaseName                  string
	BackupSecretName              string
	RegistryRepoHost              string
	ClusterRepo                   string
	VaultClusterPathTemplate      string
	VaultClusterAdminsPasswordKey string
	VaultKVEngineName             string
	HardwareINITemplatePath       string
	TempFolder                    string
	KeycloakDefaultHostname       string
	DDMManualEDPComponent         string
	RegistryDNSManualPath         string
}

type App struct {
	Services
	Config
	router   router.Interface
	repo     string
	appCache *cache.Cache //TODO: change to interface
}

func Make(router router.Interface, services Services, cnf Config, appCache *cache.Cache) (*App, error) {
	app := App{
		Services: services,
		Config:   cnf,
		router:   router,
		repo:     fmt.Sprintf("%s/%s", cnf.RegistryRepoHost, cnf.ClusterRepo),
		appCache: appCache,
	}

	app.createRoutes()
	if err := router.AddValidator("cron-expression", CronExpressionValidator); err != nil {
		return nil, errors.Wrap(err, "unable to add cron expression validator")
	}
	if err := router.AddValidator("cron-expires", CronDaysValidator); err != nil {
		return nil, errors.Wrap(err, "unable to add cron expires validator")
	}

	return &app, nil
}