Progress

Author: LauJosefsen

cmd.go

@@ -3,6 +3,7 @@ package cmd
 import (
 	"fmt"
 	"gitte/config"
+	"gitte/internal"
 	"os"
 
 	"github.com/spf13/cobra"
@@ -12,22 +13,24 @@ import (
 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) {
+	RunE: func(cmd *cobra.Command, args []string) error {
 		fmt.Println("gitops called")
 		fs := os.DirFS(".")
 		fd, err := config.ResolveGitteDir(fs)
 		if err != nil {
-			fmt.Println("Error resolving .gitte dir:", err)
-			return
+			return fmt.Errorf("error resolving gitte dir: %w", err)
 		}
 
 		gitteConfig, err := config.LoadConfig(fd)
 		if err != nil {
-			fmt.Println("Error loading gitte config:", err)
-			return
+			return fmt.Errorf("error loading gitte config: %w", err)
 		}
 
-		fmt.Println("Loaded Gitte Config:", gitteConfig)
+		//fmt.Println("Loaded Gitte Config:", gitteConfig)
+
+		cwd := "/home/lejo/gitte-test" // TODO move config loading and cwd detection to shared place
+
+		return internal.GitOps(cmd.Context(), cwd, *gitteConfig)
 	},
 }
 

cmd/gitops.go

@@ -12,8 +12,14 @@ type ExecuteResult struct {
 	Stderr   []byte
 }
 
-func ExecuteSync(command string, args ...string) (*ExecuteResult, error) {
+// ExecuteSyncInDir executes a command synchronously in the specified directory (cwd).
+// If cwd is an empty string, it executes in the current working directory.
+// It returns an ExecuteResult containing the exit code, stdout, and stderr.
+// It will only return an error if there was a problem starting or running the command itself. Not if the command exits with a non-zero exit code.
+func ExecuteSyncInDir(cwd string, command string, args ...string) (*ExecuteResult, error) {
 	cmd := exec.Command(command, args...)
+
+	cmd.Dir = cwd
 	var stdout bytes.Buffer
 	var stderr bytes.Buffer
 
@@ -42,3 +48,7 @@ func ExecuteSync(command string, args ...string) (*ExecuteResult, error) {
 		Stderr:   stderr.Bytes(),
 	}, nil
 }
+
+func ExecuteSync(command string, args ...string) (*ExecuteResult, error) {
+	return ExecuteSyncInDir("", command, args...)
+}

executor/cmd.go

@@ -0,0 +1,76 @@
+package internal
+
+import (
+	"context"
+	"fmt"
+	"gitte/config"
+	"gitte/executor"
+	"os"
+	"regexp"
+)
+
+func GitOps(ctx context.Context, cwd string, gitteConfig config.GitteConfig) error {
+	for _, pc := range gitteConfig.Projects {
+		if err := gitopsProject(ctx, cwd, pc); err != nil {
+			return err
+		}
+	}
+	return nil
+}
+
+func gitopsProject(ctx context.Context, cwd string, pc config.ProjectConfig) error {
+	relativeDirectory, err := getProjectDirFromRemote(pc)
+	if err != nil {
+		return err
+	}
+
+	projectPath := fmt.Sprintf("%s/%s", cwd, relativeDirectory) // TODO join prettier
+
+	// Check if directory exists
+	if _, err := os.Stat(projectPath); os.IsNotExist(err) {
+		// Directory does not exist, clone the repository
+		fmt.Println("Cloning repository:", pc.Remote, "into", projectPath)
+		return clone(ctx, cwd, pc)
+	}
+	return nil // TODO pull and update
+}
+
+func clone(ctx context.Context, cwd string, pc config.ProjectConfig) error {
+	relativeDirectory, err := getProjectDirFromRemote(pc)
+	if err != nil {
+		return err
+	}
+
+	res, err := executor.ExecuteSyncInDir(cwd, "git", "clone", pc.Remote, relativeDirectory)
+	if err != nil {
+		return fmt.Errorf("failed to execute git clone command: %w", err)
+	}
+
+	if res.ExitCode != 0 {
+		// If res.Stderr contains "Permission denied" return a specific error
+		if regexp.MustCompile(`(?i)permission denied`).Match(res.Stderr) {
+			return fmt.Errorf("permission denied when trying to clone repository '%s'. Please check your SSH keys and access rights", pc.Remote)
+		}
+		return fmt.Errorf("git clone command failed with exit code %d: \n%s", res.ExitCode, string(res.Stderr))
+	}
+
+	return nil
+}
+
+func getProjectDirFromRemote(pc config.ProjectConfig) (string, error) {
+	// 	const match = remote.match(/git@.*?:.*?\.git/);
+
+	regex := regexp.MustCompile(`git@.*?:(.*)?\.git`)
+	match := regex.FindStringSubmatch(pc.Remote)
+
+	firstMatch := ""
+	if len(match) > 1 {
+		firstMatch = match[1]
+	}
+
+	if firstMatch == "" {
+		return "", fmt.Errorf("'%' is not a valid git ssh url. Use git@gitlab.com:example/cego.git syntax", pc.Remote)
+	}
+
+	return firstMatch, nil
+}

gitops.go

@@ -1,7 +1,3 @@
-/*
-Copyright © 2026 NAME HERE <EMAIL ADDRESS>
-
-*/
 package main
 
 import "gitte/cmd"