workflows.go

package main

import (
	log "github.com/sirupsen/logrus"
	"github.com/urfave/cli/v2"
)

func migrateWorkflows(*cli.Context) error {
	promptConfirm := PromptDefaultInputs()
	if len(migrationReq.AppId) == 0 {
		promptConfirm = true
		migrationReq.AppId = TextInput("Please provide the application ID of the app containing the workflows -")
	}

	if len(migrationReq.WorkflowScope) == 0 {
		promptConfirm = true
		migrationReq.WorkflowScope = SelectInput("Scope for workflows:", scopes, Project)
	}

	if len(migrationReq.WorkflowIds) == 0 && !migrationReq.All {
		allWorkflowConfirm := ConfirmInput("No workflows provided. This defaults to migrating all workflows within the application. Do you want to proceed?")
		if !allWorkflowConfirm {
			promptConfirm = true
			migrationReq.WorkflowIds = TextInput("Provide the workflows that you wish to import as template as comma separated values(e.g. workflow1,workflow2)")
		}
	}

	if migrationReq.AsPipelines {
		migrationReq.PipelineScope = Project
	}

	promptConfirm = PromptOrgAndProject([]string{migrationReq.PipelineScope, migrationReq.WorkflowScope, migrationReq.SecretScope, migrationReq.ConnectorScope, migrationReq.TemplateScope}) || promptConfirm

	logMigrationDetails()

	if promptConfirm {
		confirm := ConfirmInput("Do you want to proceed with workflows migration?")
		if !confirm {
			log.Fatal("Aborting...")
		}
	}

	// Migrating the workflows
	var workflowIds []string
	if len(migrationReq.WorkflowIds) > 0 {
		workflowIds = Split(migrationReq.WorkflowIds, ",")
	}
	log.Info("Importing the workflows....")
	CreateEntities(getReqBody(Workflow, Filter{
		WorkflowIds: workflowIds,
		AppId:       migrationReq.AppId,
	}))
	log.Info("Imported the workflows.")

	return nil
}