initial version

Author: reshnm

cmd/manageDeploymentRepo.go

@@ -0,0 +1,241 @@
+package cmd
+
+import (
+	"errors"
+	"fmt"
+	"os"
+	"path/filepath"
+	"time"
+
+	"github.com/go-git/go-git/v5"
+	"github.com/go-git/go-git/v5/config"
+	"github.com/go-git/go-git/v5/plumbing"
+	"github.com/go-git/go-git/v5/plumbing/object"
+	"github.com/spf13/cobra"
+
+	gitconfig "github.com/openmcp-project/bootstrapper/internal/git-config"
+	"github.com/openmcp-project/bootstrapper/internal/template"
+)
+
+const (
+	FlagGitConfig = "git-config"
+)
+
+// manageDeploymentRepoCmd represents the manageDeploymentRepo command
+var manageDeploymentRepoCmd = &cobra.Command{
+	Use:   "manageDeploymentRepo",
+	Short: "A brief description of your command",
+	Long: `A longer description that spans multiple lines and likely contains examples
+and usage of using your command. For example:
+
+Cobra is a CLI library for Go that empowers applications.
+This application is a tool to generate the needed files
+to quickly create a Cobra application.`,
+	Args: cobra.ExactArgs(3),
+	ArgAliases: []string{
+		"deploymentRepository",
+		"deploymentRepositoryBranch",
+		"templateDirectory",
+	},
+	RunE: func(cmd *cobra.Command, args []string) error {
+		deploymentRepository := args[0]
+		deploymentRepositoryBranch := args[1]
+		templateDirectory := args[2]
+
+		gitConfig, err := gitconfig.ParseConfig(cmd.Flag(FlagGitConfig).Value.String())
+		if err != nil {
+			return err
+		}
+		if err := gitConfig.Validate(); err != nil {
+			return err
+		}
+
+		cloneOptions := &git.CloneOptions{
+			URL: deploymentRepository,
+		}
+		if err := gitConfig.ConfigureCloneOptions(cloneOptions); err != nil {
+			return err
+		}
+
+		repo, tmpDir, err := CloneRepo(deploymentRepository, gitConfig)
+		fmt.Printf("Cloned repository to temporary directory: %s\n", tmpDir)
+		if err != nil {
+			return fmt.Errorf("failed to clone repository: %w", err)
+		}
+		defer func(path string) {
+			err := os.RemoveAll(path)
+			if err != nil {
+				fmt.Fprintf(os.Stderr, "failed to remove temporary directory %s: %v\n", path, err)
+			}
+		}(tmpDir)
+
+		// Check if branch exists
+		branchExists := false
+		branches, err := repo.Branches()
+		if err != nil {
+			return fmt.Errorf("failed to list branches: %w", err)
+		}
+		branchRefName := plumbing.NewBranchReferenceName(deploymentRepositoryBranch)
+		branches.ForEach(func(ref *plumbing.Reference) error {
+			if ref.Name() == branchRefName {
+				branchExists = true
+			}
+			return nil
+		})
+
+		workTree, err := repo.Worktree()
+		if err != nil {
+			return fmt.Errorf("failed to get worktree: %w", err)
+		}
+
+		if !branchExists {
+			// Create and checkout new branch
+			fmt.Printf("Branch %s does not exist. Creating...\n", deploymentRepositoryBranch)
+			err = workTree.Checkout(&git.CheckoutOptions{
+				Branch: branchRefName,
+				Create: true,
+			})
+			if err != nil {
+				return fmt.Errorf("failed to create branch: %w", err)
+			}
+
+			pushOptions := &git.PushOptions{
+				RefSpecs: []config.RefSpec{
+					config.RefSpec(branchRefName + ":" + branchRefName),
+				},
+			}
+
+			if err := gitConfig.ConfigurePushOptions(pushOptions); err != nil {
+				return fmt.Errorf("failed to configure push options: %w", err)
+			}
+
+			// Push new branch to remote
+			err = repo.Push(pushOptions)
+			if err != nil && !errors.Is(err, git.NoErrAlreadyUpToDate) {
+				return fmt.Errorf("failed to push new branch: %w", err)
+			}
+		} else {
+			// Checkout existing branch
+			err = workTree.Checkout(&git.CheckoutOptions{
+				Branch: branchRefName,
+			})
+			if err != nil {
+				return fmt.Errorf("failed to checkout branch: %w", err)
+			}
+		}
+
+		// open the template directory
+		templateDir, err := os.Open(templateDirectory)
+		if err != nil {
+			return fmt.Errorf("failed to open template directory: %w", err)
+		}
+		defer func() {
+			if err := templateDir.Close(); err != nil {
+				fmt.Fprintf(os.Stderr, "failed to close template directory: %v\n", err)
+			}
+		}()
+
+		te := template.NewTemplateExecution()
+		templateInput := make(map[string]interface{})
+
+		// Recursively walk through all files in the template directory
+		err = filepath.WalkDir(templateDirectory, func(path string, d os.DirEntry, err error) error {
+			if err != nil {
+				return err
+			}
+			if !d.IsDir() {
+				// Process the file (path)
+				fmt.Printf("Found file: %s\n", path)
+				template, err := os.ReadFile(path)
+				if err != nil {
+					return fmt.Errorf("failed to read template file %s: %w", path, err)
+				}
+
+				templateResult, err := te.Execute(path, string(template), templateInput)
+				if err != nil {
+					return fmt.Errorf("failed to execute template %s: %w", path, err)
+				}
+
+				pathInRepo, err := filepath.Rel(templateDirectory, path)
+				fileInWt, err := workTree.Filesystem.OpenFile(pathInRepo, os.O_WRONLY|os.O_CREATE, 0644)
+				if err != nil {
+					return fmt.Errorf("failed to open file in worktree %s: %w", path, err)
+				}
+				defer fileInWt.Close()
+				_, err = fileInWt.Write(templateResult)
+				if err != nil {
+					return fmt.Errorf("failed to write to file in worktree %s: %w", path, err)
+				}
+				// Add the file to the git index
+				if _, err := workTree.Add(pathInRepo); err != nil {
+					return fmt.Errorf("failed to add file to git index: %w", err)
+				}
+			}
+			return nil
+		})
+		if err != nil {
+			return fmt.Errorf("failed to walk template directory: %w", err)
+		}
+
+		// Commit the changes
+		commitMsg := "Update deployment repo with template files"
+		_, err = workTree.Commit(commitMsg, &git.CommitOptions{
+			Author: &object.Signature{
+				Name:  "openmcp-bootstrapper",
+				Email: "[email protected]",
+				When:  time.Now(),
+			},
+		})
+		if err != nil {
+			if !errors.Is(err, git.ErrEmptyCommit) {
+				return fmt.Errorf("failed to commit changes: %w", err)
+			}
+		}
+
+		// Push the changes
+		pushOptions := &git.PushOptions{}
+		if err := gitConfig.ConfigurePushOptions(pushOptions); err != nil {
+			return fmt.Errorf("failed to configure push options: %w", err)
+		}
+		err = repo.Push(pushOptions)
+		if err != nil {
+			if !errors.Is(err, git.NoErrAlreadyUpToDate) {
+				return fmt.Errorf("failed to push changes: %w", err)
+			}
+		}
+
+		return nil
+	},
+}
+
+func init() {
+	RootCmd.AddCommand(manageDeploymentRepoCmd)
+
+	manageDeploymentRepoCmd.PersistentFlags().StringP("ocm-config", "", "", "ocm configuration file")
+	manageDeploymentRepoCmd.Flags().StringP(FlagGitConfig, "", "", "Git configuration file")
+	if err := manageDeploymentRepoCmd.MarkFlagRequired(FlagGitConfig); err != nil {
+		panic(err)
+	}
+}
+
+func CloneRepo(repoURL string, config *gitconfig.Config) (*git.Repository, string, error) {
+	cloneOptions := &git.CloneOptions{
+		URL: repoURL,
+	}
+
+	if err := config.ConfigureCloneOptions(cloneOptions); err != nil {
+		return nil, "", err
+	}
+
+	tmpDir, err := os.MkdirTemp("", "deployment-repo-")
+	if err != nil {
+		return nil, "", fmt.Errorf("failed to create temp dir: %w", err)
+	}
+
+	repo, err := git.PlainClone(tmpDir, false, cloneOptions)
+	if err != nil {
+		return nil, tmpDir, fmt.Errorf("failed to clone repository: %w", err)
+	}
+
+	return repo, tmpDir, nil
+}

go.mod

@@ -29,7 +29,7 @@ require (
 	github.com/pmezard/go-difflib v1.0.0 // indirect
 	github.com/sergi/go-diff v1.3.2-0.20230802210424-5b0b94c5c0d3 // indirect
 	github.com/skeema/knownhosts v1.3.1 // indirect
-	github.com/spf13/pflag v1.0.7 // indirect
+	github.com/spf13/pflag v1.0.6 // indirect
 	github.com/xanzy/ssh-agent v0.3.3 // indirect
 	go.yaml.in/yaml/v2 v2.4.2 // indirect
 	golang.org/x/crypto v0.37.0 // indirect

go.sum

@@ -68,9 +68,8 @@ github.com/skeema/knownhosts v1.3.1 h1:X2osQ+RAjK76shCbvhHHHVl3ZlgDm8apHEHFqRjnB
 github.com/skeema/knownhosts v1.3.1/go.mod h1:r7KTdC8l4uxWRyK2TpQZ/1o5HaSzh06ePQNxPwTcfiY=
 github.com/spf13/cobra v1.9.1 h1:CXSaggrXdbHK9CF+8ywj8Amf7PBRmPCOJugH954Nnlo=
 github.com/spf13/cobra v1.9.1/go.mod h1:nDyEzZ8ogv936Cinf6g1RU9MRY64Ir93oCnqb9wxYW0=
+github.com/spf13/pflag v1.0.6 h1:jFzHGLGAlb3ruxLB8MhbI6A8+AQX/2eW4qeyNZXNp2o=
 github.com/spf13/pflag v1.0.6/go.mod h1:McXfInJRrz4CZXVZOBLb0bTZqETkiAhM9Iw0y3An2Bg=
-github.com/spf13/pflag v1.0.7 h1:vN6T9TfwStFPFM5XzjsvmzZkLuaLX+HS+0SeFLRgU6M=
-github.com/spf13/pflag v1.0.7/go.mod h1:McXfInJRrz4CZXVZOBLb0bTZqETkiAhM9Iw0y3An2Bg=
 github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME=
 github.com/stretchr/testify v1.2.2/go.mod h1:a8OnRcib4nhh0OaRAV+Yts87kKdq0PP7pXfy6kDkUVs=
 github.com/stretchr/testify v1.4.0/go.mod h1:j7eGeouHqKxXV5pUuKE4zz7dFj8WfuZ+81PSLYec5m4=