Rewrite in go initial work

Author: LauJosefsen

.gitte-env

@@ -0,0 +1,3 @@
+REMOTE_GIT_FILE="gitte.yml"
+REMOTE_GIT_REPO="git@gitlab.cego.dk:cego/local-helper-configs.git"
+REMOTE_GIT_REF="master"

cmd.go

@@ -0,0 +1,44 @@
+package executor
+
+import (
+	"bytes"
+	"errors"
+	"os/exec"
+)
+
+type ExecuteResult struct {
+	ExitCode int8
+	Stdout   []byte
+	Stderr   []byte
+}
+
+func ExecuteSync(command string, args ...string) (*ExecuteResult, error) {
+	cmd := exec.Command(command, args...)
+	var stdout bytes.Buffer
+	var stderr bytes.Buffer
+
+	cmd.Stdout = &stdout
+	cmd.Stderr = &stderr
+
+	err := cmd.Run()
+
+	// if the error is of type *exec.ExitError, we can get the exit code
+	if err != nil {
+		var exitCode int8
+		var exitError *exec.ExitError
+		if errors.As(err, &exitError) {
+			exitCode = int8(exitError.ExitCode())
+		}
+		return &ExecuteResult{
+			ExitCode: exitCode,
+			Stdout:   stdout.Bytes(),
+			Stderr:   stderr.Bytes(),
+		}, nil
+	}
+
+	return &ExecuteResult{
+		ExitCode: 0,
+		Stdout:   stdout.Bytes(),
+		Stderr:   stderr.Bytes(),
+	}, nil
+}

cmd/gitops.go

@@ -0,0 +1,36 @@
+package cmd
+
+import (
+	"fmt"
+	"gitte/config"
+	"os"
+
+	"github.com/spf13/cobra"
+)
+
+// gitopsCmd represents the gitops command
+var gitopsCmd = &cobra.Command{
+	Use:   "gitops",
+	Short: "GitOps refer to GitOperations and will ensure that the enabled projects are cloned and up to date if possible.",
+	Run: func(cmd *cobra.Command, args []string) {
+		fmt.Println("gitops called")
+		fs := os.DirFS(".")
+		fd, err := config.ResolveGitteDir(fs)
+		if err != nil {
+			fmt.Println("Error resolving .gitte dir:", err)
+			return
+		}
+
+		gitteConfig, err := config.LoadConfig(fd)
+		if err != nil {
+			fmt.Println("Error loading gitte config:", err)
+			return
+		}
+
+		fmt.Println("Loaded Gitte Config:", gitteConfig)
+	},
+}
+
+func init() {
+	rootCmd.AddCommand(gitopsCmd)
+}

cmd/root.go

@@ -0,0 +1,42 @@
+package cmd
+
+import (
+	"os"
+
+	"github.com/spf13/cobra"
+)
+
+// rootCmd represents the base command when called without any subcommands
+var rootCmd = &cobra.Command{
+	Use:   "gitte",
+	Short: "Tool for managing monorepo-like structured git repositories.",
+	Long: `Gitte is a tool for managing monorepo-like structured git repositories with inter-project dependencies.
+
+For example in a microservice environment
+- Service A requires a database
+- Service B requires service A and kafka
+- Gitte will make sure that kafka and database starts first, then service a, then service b. Ensuring maximum parallelity in the dependency resolvement.
+
+Gitte also contain other sub commands for utilities managing such a setup.
+`}
+
+// Execute adds all child commands to the root command and sets flags appropriately.
+// This is called by main.main(). It only needs to happen once to the rootCmd.
+func Execute() {
+	err := rootCmd.Execute()
+	if err != nil {
+		os.Exit(1)
+	}
+}
+
+func init() {
+	// Here you will define your flags and configuration settings.
+	// Cobra supports persistent flags, which, if defined here,
+	// will be global for your application.
+
+	// rootCmd.PersistentFlags().StringVar(&cfgFile, "config", "", "config file (default is $HOME/.gitte.yaml)")
+
+	// Cobra also supports local flags, which will only run
+	// when this action is called directly.
+	rootCmd.Flags().BoolP("toggle", "t", false, "Help message for toggle")
+}

config/loader.go

@@ -0,0 +1,127 @@
+package config
+
+import (
+	"archive/tar"
+	"bytes"
+	"errors"
+	"fmt"
+	"gitte/executor"
+	"io"
+	"io/fs"
+	"os"
+	"strings"
+
+	"github.com/joho/godotenv"
+)
+
+type GitteConfig struct {
+}
+
+type GitteContext struct {
+	config *GitteConfig
+	cwd    string
+}
+
+const ConfigPath = ".gitte.yml"
+const DotEnvPath = ".gitte-env"
+const OverridePath = ".gitte.override.yml"
+const CacheDir = ".gitte" // TODO maybe make migration from .gitte-cache.json
+
+func LoadConfig(fd FileDefinition) (*GitteConfig, error) {
+	content := fd.ConfigContent
+	if fd.IsEnv {
+		dotenv, err := godotenv.Parse(strings.NewReader(content))
+		if err != nil {
+			return nil, err
+		}
+
+		// Assert required fields
+		remoteGitRepo, ok := dotenv["REMOTE_GIT_REPO"]
+		if !ok || remoteGitRepo == "" {
+			return nil, errors.New("REMOTE_GIT_REPO isn't defined in .gitte.env")
+		}
+		remoteGitFile, ok := dotenv["REMOTE_GIT_FILE"]
+		if !ok || remoteGitFile == "" {
+			return nil, errors.New("REMOTE_GIT_FILE isn't defined in .gitte.env")
+		}
+		remoteGitRef, ok := dotenv["REMOTE_GIT_REF"]
+		if !ok || remoteGitRef == "" {
+			return nil, errors.New("REMOTE_GIT_REF isn't defined in .gitte.env")
+		}
+
+		fmt.Println("Executing command to fetch remote gitte config:", "git", "archive", "--remote="+remoteGitRepo, remoteGitRef, remoteGitFile)
+
+		res, err := executor.ExecuteSync("git", "archive", "--remote="+remoteGitRepo, remoteGitRef, remoteGitFile)
+
+		if err != nil {
+			return nil, fmt.Errorf("failed to execute git archive command: %w", err)
+		}
+
+		// Untar the result to extract the file content
+		tarReader := tar.NewReader(bytes.NewReader(res.Stdout))
+		var fileContent []byte
+
+		for {
+			header, err := tarReader.Next()
+			if err == io.EOF {
+				break
+			}
+			if err != nil {
+				return nil, fmt.Errorf("failed to read tar archive: %w", err)
+			}
+
+			// Extract the file matching remoteGitFile
+			if header.Name == remoteGitFile {
+				fileContent, err = io.ReadAll(tarReader)
+				if err != nil {
+					return nil, fmt.Errorf("failed to read file from tar archive: %w", err)
+				}
+				break
+			}
+		}
+
+		if fileContent == nil {
+			return nil, fmt.Errorf("file %s not found in tar archive", remoteGitFile)
+		}
+
+		content = string(fileContent)
+	}
+
+	return &GitteConfig{}, nil // TODO parse and validate
+}
+
+type FileDefinition struct {
+	ConfigContent string
+	IsEnv         bool
+}
+
+var (
+	ErrGitteConfigNotFound = errors.New("Gitte configuration file not found")
+)
+
+func ResolveGitteDir(fs fs.FS) (FileDefinition, error) {
+	if f, err := fs.Open(DotEnvPath); err == nil {
+		defer f.Close()
+		content, err := io.ReadAll(f)
+		if err != nil {
+			return FileDefinition{}, err
+		}
+		return FileDefinition{ConfigContent: string(content), IsEnv: true}, nil
+	}
+
+	if f, err := fs.Open(ConfigPath); err == nil {
+		defer f.Close()
+		content, err := io.ReadAll(f)
+		if err != nil {
+			return FileDefinition{}, err
+		}
+		return FileDefinition{ConfigContent: string(content), IsEnv: false}, nil
+	}
+
+	parentDir := os.DirFS("..")
+	if parentDir != fs {
+		return ResolveGitteDir(parentDir)
+	}
+
+	return FileDefinition{}, ErrGitteConfigNotFound
+}

executor/cmd.go

@@ -0,0 +1,44 @@
+package executor
+
+import (
+	"bytes"
+	"errors"
+	"os/exec"
+)
+
+type ExecuteResult struct {
+	ExitCode int8
+	Stdout   []byte
+	Stderr   []byte
+}
+
+func ExecuteSync(command string, args ...string) (*ExecuteResult, error) {
+	cmd := exec.Command(command, args...)
+	var stdout bytes.Buffer
+	var stderr bytes.Buffer
+
+	cmd.Stdout = &stdout
+	cmd.Stderr = &stderr
+
+	err := cmd.Run()
+
+	// if the error is of type *exec.ExitError, we can get the exit code
+	if err != nil {
+		var exitCode int8
+		var exitError *exec.ExitError
+		if errors.As(err, &exitError) {
+			exitCode = int8(exitError.ExitCode())
+		}
+		return &ExecuteResult{
+			ExitCode: exitCode,
+			Stdout:   stdout.Bytes(),
+			Stderr:   stderr.Bytes(),
+		}, nil
+	}
+
+	return &ExecuteResult{
+		ExitCode: 0,
+		Stdout:   stdout.Bytes(),
+		Stderr:   stderr.Bytes(),
+	}, nil
+}

gitops.go

@@ -0,0 +1,36 @@
+package cmd
+
+import (
+	"fmt"
+	"gitte/config"
+	"os"
+
+	"github.com/spf13/cobra"
+)
+
+// gitopsCmd represents the gitops command
+var gitopsCmd = &cobra.Command{
+	Use:   "gitops",
+	Short: "GitOps refer to GitOperations and will ensure that the enabled projects are cloned and up to date if possible.",
+	Run: func(cmd *cobra.Command, args []string) {
+		fmt.Println("gitops called")
+		fs := os.DirFS(".")
+		fd, err := config.ResolveGitteDir(fs)
+		if err != nil {
+			fmt.Println("Error resolving .gitte dir:", err)
+			return
+		}
+
+		gitteConfig, err := config.LoadConfig(fd)
+		if err != nil {
+			fmt.Println("Error loading gitte config:", err)
+			return
+		}
+
+		fmt.Println("Loaded Gitte Config:", gitteConfig)
+	},
+}
+
+func init() {
+	rootCmd.AddCommand(gitopsCmd)
+}

go.mod

@@ -0,0 +1,10 @@
+module gitte
+
+go 1.25.3
+
+require (
+	github.com/inconshreveable/mousetrap v1.1.0 // indirect
+	github.com/joho/godotenv v1.5.1 // indirect
+	github.com/spf13/cobra v1.10.2 // indirect
+	github.com/spf13/pflag v1.0.9 // indirect
+)