Initial logic is implemented

internal/controller/controller.go

@@ -0,0 +1,132 @@
+package controller
+
+import (
+	"fmt"
+
+	"git.badhouseplants.net/allanger/giops/internal/config"
+	"git.badhouseplants.net/allanger/giops/internal/config/release"
+	"git.badhouseplants.net/allanger/giops/internal/lockfile"
+	"git.badhouseplants.net/allanger/giops/internal/providers"
+	"git.badhouseplants.net/allanger/giops/internal/utils/diff"
+	"git.badhouseplants.net/allanger/giops/internal/utils/githelper"
+	"git.badhouseplants.net/allanger/giops/internal/utils/helmhelper"
+	"git.badhouseplants.net/allanger/giops/internal/utils/kustomize"
+	"git.badhouseplants.net/allanger/giops/internal/utils/workdir"
+)
+
+func ReadTheConfig(path string) (*config.Config, error) {
+	conf, err := config.NewConfigFromFile(path)
+	if err != nil {
+		return nil, err
+	}
+	return conf, nil
+}
+
+/*
+* First it must prepare the workdir
+* It must create a directorry and clone all the repos that are listed in the config
+ */
+func Reconcile(workdirPath, sshKeyPath string, conf *config.Config, dry bool) error {
+	dir, err := workdir.CreateWorkdir(workdirPath)
+	if err != nil {
+		return err
+	}
+	for _, repository := range conf.Repositories {
+		if err := repository.ValidateURL(); err != nil {
+			return err
+		}
+		if err := repository.KindFromUrl(); err != nil {
+			return err
+		}
+	}
+	gh := githelper.NewGit(sshKeyPath)
+	for _, cluster := range conf.Clusters {
+		/*
+		* 1. Clone the cluster repo
+		* 2. Check if repo is already configured
+		*    Yes -> Bootsrap the repo if it's not configured
+		*      - Create the lockfile
+		*      - ...
+		*    No -> Get the current state
+		* 3. Turn the config file into the lockfile format and compare the actual to the desired
+		 */
+		fullPath := fmt.Sprintf("%s/%s", dir, cluster.Name)
+		provider, err := providers.NewProvider(cluster.Provider, fullPath, gh)
+		if err != nil {
+			return err
+		}
+
+		if err := cluster.CloneRepo(gh, fullPath, dry); err != nil {
+			return err
+		}
+		err = cluster.BootstrapRepo(gh, fullPath, dry)
+		if err != nil {
+			return err
+		}
+		lockfileData, err := lockfile.NewFromFile(fullPath)
+		if err != nil {
+			return err
+		}
+
+		reposExisting, err := lockfileData.ReposFromLockfile()
+		if err != nil {
+			return err
+		}
+
+		if err := conf.Releases.PopulateRepositories(conf.Repositories); err != nil {
+			return err
+		}
+
+		hh := helmhelper.NewHelm()
+		for _, release := range conf.Releases {
+			err := release.VersionHandler(workdirPath, hh)
+			if err != nil {
+				return err
+			}
+		}
+
+		rsObj := release.FindReleaseByNames(cluster.Releases, conf.Releases)
+		cluster.PopulateReleases(rsObj)
+		releasesCurrent, err := release.ReleasesFromLockfile(lockfileData, conf.Repositories)
+		if err != nil {
+			return err
+		}
+
+		diffRls, err := diff.DiffReleases(releasesCurrent, cluster.ReleasesObj)
+		if err != nil {
+			return err
+		}
+		lockfile, err := diffRls.Resolve(reposExisting, fullPath)
+		if err != nil {
+			return err
+		}
+
+		if err := provider.SyncState(*diffRls); err != nil {
+			return err
+		}
+
+		if err := kustomize.Generate(fullPath, gh); err != nil {
+			return err
+		}
+
+		if err := lockfile.WriteToFile(fullPath); err != nil {
+			return err
+		}
+		if err := gh.AddAllAndCommit(fullPath, "Update the lockfile"); err != nil {
+			return err
+		}
+		if !dry {
+			if err := gh.Push(fullPath); err != nil {
+				return err
+			}
+		}
+
+	}
+	if !dry {
+		if err := workdir.RemoveWorkdir(dir); err != nil {
+			return err
+		}
+	}
+
+	return nil
+}