Merge pull request #47 from lfbdev/lfb-dev2

add reinstall and unistall actions

Author: daniel-hutao

cmd/argocdapp/main.go

@@ -19,12 +19,12 @@ func (p Plugin) Install(options *map[string]interface{}) (bool, error) {
 
 // Reinstall implements the installation of an ArgoCD app.
 func (p Plugin) Reinstall(options *map[string]interface{}) (bool, error) {
-	return false, fmt.Errorf("mock: %s reinstall finished", NAME)
+	return argocdapp.Reinstall(options)
 }
 
 // Uninstall Uninstall the installation of an ArgoCD app.
 func (p Plugin) Uninstall(options *map[string]interface{}) (bool, error) {
-	return false, fmt.Errorf("mock: %s uninstall finished", NAME)
+	return argocdapp.Uninstall(options)
 }
 
 // DevStreamPlugin is the exported variable used by the DevStream core.

cmd/githubactions/main.go

@@ -19,12 +19,12 @@ func (p Plugin) Install(options *map[string]interface{}) (bool, error) {
 
 // Reinstall implements the installation of some GitHub Actions workflows.
 func (p Plugin) Reinstall(options *map[string]interface{}) (bool, error) {
-	return false, fmt.Errorf("mock: %s reinstall finished", NAME)
+	return githubactions.Reinstall(options)
 }
 
 // Uninstall implements the installation of some GitHub Actions workflows.
 func (p Plugin) Uninstall(options *map[string]interface{}) (bool, error) {
-	return false, fmt.Errorf("mock: %s uninstall finished", NAME)
+	return githubactions.Uninstall(options)
 }
 
 // DevStreamPlugin is the exported variable used by the DevStream core.

internal/pkg/argocdapp/argocdapp.go

@@ -33,12 +33,24 @@ func writeContentToTmpFile(file string, content string, param *Param) {
 	}
 }
 
-func kubectlApply(file string) {
+func kubectlApply(file string) (bool, error) {
 	cmd := exec.Command("kubectl", "apply", "-f", file)
 	stdout, err := cmd.Output()
 	if err != nil {
 		fmt.Println(err.Error())
-		return
+		return false, err
 	}
-	log.Println(string(strings.TrimSuffix(string(stdout), "\n")))
+	log.Println(strings.TrimSuffix(string(stdout), "\n"))
+	return true, nil
+}
+
+func kubectlDelete(file string) (bool, error) {
+	cmd := exec.Command("kubectl", "delete", "-f", file)
+	stdout, err := cmd.Output()
+	if err != nil {
+		fmt.Println(err.Error())
+		return false, err
+	}
+	log.Println(strings.TrimSuffix(string(stdout), "\n"))
+	return true, nil
 }

internal/pkg/argocdapp/install.go

@@ -16,7 +16,10 @@ func Install(options *map[string]interface{}) (bool, error) {
 
 	file := "./app.yaml"
 	writeContentToTmpFile(file, appTemplate, &param)
-	kubectlApply(file)
+	_, errApply := kubectlApply(file)
+	if errApply != nil {
+		return false, errApply
+	}
 
 	return true, nil
 }

internal/pkg/argocdapp/reinstall.go

@@ -0,0 +1,39 @@
+package argocdapp
+
+import (
+	"os"
+
+	"github.com/mitchellh/mapstructure"
+)
+
+// Reinstall an ArgoCD app .
+func Reinstall(options *map[string]interface{}) (bool, error) {
+	var param Param
+	err := mapstructure.Decode(*options, &param)
+	if err != nil {
+		return false, err
+	}
+
+	file := "./app.yaml"
+
+	//delete resource
+	_, errDel := kubectlDelete(file)
+	if errDel != nil {
+		return false, errDel
+	}
+
+	//remove app.yaml file
+	errRemove := os.Remove(file)
+	if errRemove != nil {
+		return false, err
+	}
+
+	//recreate  app.yaml file
+	writeContentToTmpFile(file, appTemplate, &param)
+	_, errApply := kubectlApply(file)
+	if errApply != nil {
+		return false, errApply
+	}
+
+	return true, nil
+}

internal/pkg/argocdapp/uninstall.go

@@ -0,0 +1,27 @@
+package argocdapp
+
+import (
+	"os"
+
+	"github.com/mitchellh/mapstructure"
+)
+
+// Uninstall uninstall an ArgoCD app by yaml.
+func Uninstall(options *map[string]interface{}) (bool, error) {
+	var param Param
+	err := mapstructure.Decode(*options, &param)
+	if err != nil {
+		return false, err
+	}
+
+	file := "./app.yaml"
+	_, errDel := kubectlDelete(file)
+	if errDel != nil {
+		return false, errDel
+	}
+	errRemove := os.Remove(file)
+	if errRemove != nil {
+		return false, errRemove
+	}
+	return true, nil
+}

internal/pkg/githubactions/githubactions.go

@@ -60,10 +60,10 @@ func fileExists(params *Param) bool {
 
 }
 
-func createFile(params *Param) {
+func createFile(params *Param) (bool, error) {
 	if fileExists(params) {
 		log.Printf("github actions workflow %s already exists\n", params.workflow.workflowFileName)
-		return
+		return true, nil
 	}
 
 	// Note: the file needs to be absent from the repository as you are not
@@ -83,8 +83,39 @@ func createFile(params *Param) {
 		opts)
 
 	if err != nil {
-		fmt.Println(err.Error())
-		return
+		log.Println(err.Error())
+		return false, err
 	}
 	log.Printf("github actions workflow %s created\n", params.workflow.workflowFileName)
+	return true, nil
+}
+
+func removeFile(params *Param) (bool, error) {
+	if !fileExists(params) {
+		log.Printf("github actions workflow %s already removed\n", params.workflow.workflowFileName)
+		return true, nil
+	}
+
+	// Note: the file needs to be absent from the repository as you are not
+	// specifying a SHA reference here.
+	opts := &github.RepositoryContentFileOptions{
+		Message: github.String(params.workflow.commitMessage),
+		Content: []byte(params.workflow.workflowContent),
+		Branch:  github.String("master"),
+	}
+
+	log.Printf("deleting github actions workflow %s...\n", params.workflow.workflowFileName)
+	_, _, err := params.client.Repositories.DeleteFile(
+		*params.ctx,
+		params.options.Owner,
+		params.options.Repo,
+		generateGitHubWorkflowFileByName(params.workflow.workflowFileName),
+		opts)
+
+	if err != nil {
+		log.Println(err.Error())
+		return false, err
+	}
+	log.Printf("github actions workflow %s removed\n", params.workflow.workflowFileName)
+	return true, nil
 }

internal/pkg/githubactions/install.go

@@ -23,13 +23,15 @@ func Install(options *map[string]interface{}) (bool, error) {
 	}
 
 	for _, pipeline := range workflows {
-		createFile(&Param{
+		_, errCreate := createFile(&Param{
 			&ctx,
 			getGitHubClient(&ctx),
 			&opt,
 			&pipeline,
 		})
+		if errCreate != nil {
+			return false, errCreate
+		}
 	}
-
 	return true, nil
 }

internal/pkg/githubactions/reinstall.go

@@ -0,0 +1,36 @@
+package githubactions
+
+import (
+	"context"
+	"github.com/mitchellh/mapstructure"
+)
+
+// Reinstall remove and set up GitHub Actions workflows.
+func Reinstall(options *map[string]interface{}) (bool, error) {
+	ctx := context.Background()
+
+	var opt Options
+	err := mapstructure.Decode(*options, &opt)
+	if err != nil {
+		return false, err
+	}
+
+	for _, pipeline := range workflows {
+		param := &Param{
+			&ctx,
+			getGitHubClient(&ctx),
+			&opt,
+			&pipeline,
+		}
+		_, errRemove := removeFile(param)
+		if errRemove != nil {
+			return false, errRemove
+		}
+
+		_, errCreate := createFile(param)
+		if errCreate != nil {
+			return false, errCreate
+		}
+	}
+	return true, nil
+}

internal/pkg/githubactions/uninstall.go

@@ -0,0 +1,30 @@
+package githubactions
+
+import (
+	"context"
+	"github.com/mitchellh/mapstructure"
+)
+
+// Uninstall remove GitHub Actions workflows.
+func Uninstall(options *map[string]interface{}) (bool, error) {
+	ctx := context.Background()
+
+	var opt Options
+	err := mapstructure.Decode(*options, &opt)
+	if err != nil {
+		return false, err
+	}
+
+	for _, pipeline := range workflows {
+		_, errRemove := removeFile(&Param{
+			&ctx,
+			getGitHubClient(&ctx),
+			&opt,
+			&pipeline,
+		})
+		if errRemove != nil {
+			return false, errRemove
+		}
+	}
+	return true, nil
+}