services_bootstrap.go

package bootstrap

import (
	"context"
	"fmt"
	"net/http"

	"github.com/getarcaneapp/arcane/backend/internal/config"
	"github.com/getarcaneapp/arcane/backend/internal/database"
	"github.com/getarcaneapp/arcane/backend/internal/services"
	"github.com/getarcaneapp/arcane/backend/resources"
)

type Services struct {
	AppImages         *services.ApplicationImagesService
	User              *services.UserService
	Project           *services.ProjectService
	Environment       *services.EnvironmentService
	Settings          *services.SettingsService
	KV                *services.KVService
	JobSchedule       *services.JobService
	SettingsSearch    *services.SettingsSearchService
	CustomizeSearch   *services.CustomizeSearchService
	Container         *services.ContainerService
	Image             *services.ImageService
	Build             *services.BuildService
	BuildWorkspace    *services.BuildWorkspaceService
	Volume            *services.VolumeService
	Network           *services.NetworkService
	Port              *services.PortService
	Swarm             *services.SwarmService
	ImageUpdate       *services.ImageUpdateService
	Auth              *services.AuthService
	Oidc              *services.OidcService
	Docker            *services.DockerClientService
	Template          *services.TemplateService
	ContainerRegistry *services.ContainerRegistryService
	System            *services.SystemService
	SystemUpgrade     *services.SystemUpgradeService
	Updater           *services.UpdaterService
	Event             *services.EventService
	Version           *services.VersionService
	Notification      *services.NotificationService
	Apprise           *services.AppriseService //nolint:staticcheck // Apprise still functional, deprecated in favor of Shoutrrr
	ApiKey            *services.ApiKeyService
	GitRepository     *services.GitRepositoryService
	GitOpsSync        *services.GitOpsSyncService
	Webhook           *services.WebhookService
	Font              *services.FontService
	Vulnerability     *services.VulnerabilityService
	Dashboard         *services.DashboardService
}

func initializeServices(ctx context.Context, db *database.DB, cfg *config.Config, httpClient *http.Client) (svcs *Services, dockerSrvice *services.DockerClientService, err error) {
	svcs = &Services{}

	svcs.Event = services.NewEventService(db, cfg, httpClient)
	svcs.Settings, err = services.NewSettingsService(ctx, db)
	if err != nil {
		return nil, nil, fmt.Errorf("failed to settings service: %w", err)
	}
	svcs.KV = services.NewKVService(db)
	svcs.JobSchedule = services.NewJobService(db, svcs.Settings, cfg)
	svcs.SettingsSearch = services.NewSettingsSearchService()
	svcs.CustomizeSearch = services.NewCustomizeSearchService()
	svcs.AppImages = services.NewApplicationImagesService(resources.FS, svcs.Settings)
	svcs.Font = services.NewFontService(resources.FS)
	dockerClient := services.NewDockerClientService(db, cfg, svcs.Settings)
	svcs.Docker = dockerClient
	svcs.User = services.NewUserService(db)
	svcs.ApiKey = services.NewApiKeyService(db, svcs.User)
	svcs.ContainerRegistry = services.NewContainerRegistryService(db, func(ctx context.Context) (services.RegistryDaemonClient, error) {
		return dockerClient.GetClient(ctx)
	})
	svcs.Environment = services.NewEnvironmentService(db, httpClient, svcs.Docker, svcs.Event, svcs.Settings, svcs.ApiKey)
	svcs.Version = services.NewVersionService(httpClient, cfg.UpdateCheckDisabled, config.Version, config.Revision, svcs.ContainerRegistry, svcs.Docker)
	svcs.Notification = services.NewNotificationService(db, cfg, svcs.Environment)
	svcs.Apprise = services.NewAppriseService(db, cfg)
	svcs.Vulnerability = services.NewVulnerabilityService(db, svcs.Docker, svcs.Event, svcs.Settings, svcs.Notification)
	svcs.ImageUpdate = services.NewImageUpdateService(db, svcs.Settings, svcs.ContainerRegistry, svcs.Docker, svcs.Event, svcs.Notification)
	svcs.Image = services.NewImageService(db, svcs.Docker, svcs.ContainerRegistry, svcs.ImageUpdate, svcs.Vulnerability, svcs.Event)
	svcs.GitRepository = services.NewGitRepositoryService(db, cfg.GitWorkDir, svcs.Event, svcs.Settings)
	svcs.Build = services.NewBuildService(db, svcs.Settings, svcs.Docker, svcs.ContainerRegistry, svcs.GitRepository)
	svcs.BuildWorkspace = services.NewBuildWorkspaceService(svcs.Settings)
	svcs.Project = services.NewProjectService(db, svcs.Settings, svcs.Event, svcs.Image, svcs.Docker, svcs.Build, cfg)
	svcs.Container = services.NewContainerService(db, svcs.Event, svcs.Docker, svcs.Image, svcs.Settings, svcs.Project)
	svcs.Dashboard = services.NewDashboardService(
		db,
		svcs.Docker,
		svcs.Container,
		svcs.Project,
		svcs.Settings,
		svcs.Vulnerability,
		svcs.Environment,
		svcs.Version,
	)
	svcs.Volume = services.NewVolumeService(db, svcs.Docker, svcs.Event, svcs.Settings, svcs.Container, svcs.Image, cfg.BackupVolumeName)
	svcs.Network = services.NewNetworkService(db, svcs.Docker, svcs.Event)
	svcs.Port = services.NewPortService(svcs.Docker)
	svcs.Swarm = services.NewSwarmService(db, svcs.Docker, svcs.Settings, svcs.KV, svcs.ContainerRegistry, svcs.Environment)
	svcs.Template = services.NewTemplateService(ctx, db, httpClient, svcs.Settings)
	svcs.Auth = services.NewAuthService(svcs.User, svcs.Settings, svcs.Event, cfg.JWTSecret, cfg)
	svcs.Oidc = services.NewOidcService(svcs.Auth, cfg, httpClient)
	svcs.System = services.NewSystemService(db, svcs.Docker, svcs.Container, svcs.Image, svcs.Volume, svcs.Network, svcs.Settings)
	svcs.SystemUpgrade = services.NewSystemUpgradeService(svcs.Docker, svcs.Version, svcs.Event, svcs.Settings)
	svcs.Updater = services.NewUpdaterService(db, svcs.Settings, svcs.Docker, svcs.Project, svcs.ImageUpdate, svcs.ContainerRegistry, svcs.Event, svcs.Image, svcs.Notification, svcs.SystemUpgrade)
	svcs.GitOpsSync = services.NewGitOpsSyncService(db, svcs.GitRepository, svcs.Project, svcs.Event, svcs.Settings)
	svcs.Webhook = services.NewWebhookService(db, svcs.Container, svcs.Updater, svcs.Project, svcs.GitOpsSync, svcs.Event)

	return svcs, dockerClient, nil
}