Added Workflow Commands

cmd/workflow/create.go

@@ -0,0 +1,121 @@
+// Copyright (c) 2023, SailPoint Technologies, Inc. All rights reserved.
+package workflow
+
+import (
+	"context"
+	_ "embed"
+	"encoding/json"
+	"os"
+	"strings"
+
+	"github.com/sailpoint-oss/golang-sdk/beta"
+	"github.com/sailpoint-oss/sailpoint-cli/internal/config"
+	"github.com/sailpoint-oss/sailpoint-cli/internal/sdk"
+	"github.com/sailpoint-oss/sailpoint-cli/internal/util"
+	"github.com/spf13/cobra"
+)
+
+//go:embed create.md
+var createHelp string
+
+func newCreateCommand() *cobra.Command {
+	help := util.ParseHelp(createHelp)
+	var file bool
+	var directory bool
+	cmd := &cobra.Command{
+		Use:     "create [-f file1 file2 ... | -d workflowDirectory ]",
+		Short:   "Create Workflows in IdentityNow",
+		Long:    help.Long,
+		Example: help.Example,
+		Aliases: []string{"cr"},
+		RunE: func(cmd *cobra.Command, args []string) error {
+
+			apiClient, err := config.InitAPIClient()
+			if err != nil {
+				return err
+			}
+
+			var workflows []beta.Workflow
+			var returnedWorkflows []beta.Workflow
+			var workflowFiles []string
+
+			if directory {
+				for _, workflowDirectory := range args {
+					files, err := os.ReadDir(workflowDirectory)
+					if err != nil {
+						return err
+					}
+
+					for _, file := range files {
+						if !file.IsDir() && strings.Contains(file.Name(), ".json") {
+							workflowFiles = append(workflowFiles, file.Name())
+						}
+					}
+				}
+			} else if file {
+
+				workflowFiles = args
+
+			} else {
+				cmd.Help()
+				return nil
+			}
+
+			for _, filePath := range workflowFiles {
+
+				file, err := os.OpenFile(filePath, os.O_RDONLY, os.ModePerm)
+				if err != nil {
+					return err
+				}
+
+				decoder := json.NewDecoder(file)
+				decoder.DisallowUnknownFields()
+
+				var workflow beta.Workflow
+				err = decoder.Decode(&workflow)
+				if err != nil {
+					return err
+				}
+
+				workflows = append(workflows, workflow)
+
+			}
+
+			for _, workflow := range workflows {
+				body, err := workflow.MarshalJSON()
+				if err != nil {
+					return err
+				}
+
+				createReq := beta.CreateWorkflowRequest{}
+
+				err = createReq.UnmarshalJSON(body)
+				if err != nil {
+					return err
+				}
+
+				workflowResp, resp, sdkErr := apiClient.Beta.WorkflowsApi.CreateWorkflow(context.TODO()).CreateWorkflowRequest(createReq).Execute()
+				if sdkErr != nil {
+					err := sdk.HandleSDKError(resp, sdkErr)
+					if err != nil {
+						return err
+					}
+				}
+
+				returnedWorkflows = append(returnedWorkflows, *workflowResp)
+			}
+
+			cmd.Println(util.PrettyPrint(returnedWorkflows))
+
+			return nil
+
+		},
+	}
+
+	cmd.Flags().BoolVarP(&file, "file", "f", false, "specifies that workflow file paths are provided as arguments to be created")
+	cmd.Flags().BoolVarP(&directory, "directory", "d", false, "specifies that a directory of workflows is provided to be created")
+	cmd.MarkFlagsMutuallyExclusive("file", "directory")
+
+	return cmd
+
+}