Adds OverwriteIfExists flag in workflow creation

Author: grussorusso

internal/api/workflow.go

@@ -33,7 +33,7 @@ func CreateWorkflowFromASL(e echo.Context) error {
 
 	// checking if the function already exists. If exists we return an error
 	_, found := workflow.Get(creationRequest.Name)
-	if found {
+	if found && !creationRequest.OverwriteIfExists {
 		log.Printf("Dropping request for already existing workflow '%s'", creationRequest.Name)
 		return e.JSON(http.StatusConflict, "workflow already exists")
 	}

internal/cli/cli.go

@@ -166,6 +166,7 @@ func Init() {
 	rootCmd.AddCommand(compCreateCmd)
 	compCreateCmd.Flags().StringVarP(&compName, "workflow", "f", "", "name of the workflow")
 	compCreateCmd.Flags().StringVarP(&jsonSrc, "src", "s", "", "source Amazon States Language file  that defines the workflow")
+	compCreateCmd.Flags().BoolVarP(&update, "update", "u", false, "Update workflow (if exists)")
 
 	rootCmd.AddCommand(compDeleteCmd)
 	compDeleteCmd.Flags().StringVarP(&compName, "workflow", "f", "", "name of the workflow")
@@ -573,8 +574,10 @@ func createWorkflow(cmd *cobra.Command, args []string) {
 	}
 	encoded := base64.StdEncoding.EncodeToString(src)
 	request := client.WorkflowCreationRequest{
-		Name:   compName,
-		ASLSrc: encoded}
+		Name:              compName,
+		ASLSrc:            encoded,
+		OverwriteIfExists: update,
+	}
 
 	requestBody, err := json.Marshal(request)
 	if err != nil {

internal/client/types.go

@@ -29,6 +29,7 @@ type WorkflowInvocationRequest struct {
 }
 
 type WorkflowCreationRequest struct {
-	Name   string // Name of the new workflow
-	ASLSrc string // Specification source in Amazon State Language (encoded in Base64)
+	Name              string // Name of the new workflow
+	ASLSrc            string // Specification source in Amazon State Language (encoded in Base64)
+	OverwriteIfExists bool
 }