Function excludeExistingSourcedWorkflows

pkg/cli/deploy_command.go:294–324

(workflows []string, addOpts AddOptions)

}

func excludeExistingSourcedWorkflows(workflows []string, addOpts AddOptions) ([]string, []string, error) {
	workflowsDir := addOpts.WorkflowDir
	if workflowsDir == "" {
		workflowsDir = getWorkflowsDir()
	}

	workflowsToAdd := make([]string, 0, len(workflows))
	skippedWorkflows := make([]string, 0)

	for _, workflowSpec := range workflows {
		workflowName := normalizeWorkflowID(workflowSpec)
		if addOpts.Name != "" && len(workflows) == 1 {
			workflowName = normalizeWorkflowID(addOpts.Name)
		}

		existingPath := filepath.Join(workflowsDir, workflowName+".md")
		hasSource, err := existingWorkflowHasSource(existingPath)
		if err != nil {
			return nil, nil, err
		}

		if hasSource {
			skippedWorkflows = append(skippedWorkflows, workflowName)
			continue
		}

		workflowsToAdd = append(workflowsToAdd, workflowSpec)
	}

	return workflowsToAdd, skippedWorkflows, nil
}

func existingWorkflowHasSource(path string) (bool, error) {
	content, err := os.ReadFile(path)