Function validateRemoteWorkflow

pkg/cli/run_workflow_validation.go:300–356

validateRemoteWorkflow checks if a workflow exists in a remote repository and can be triggered. This validation function is co-located with the run command implementation because: - It's specific to remote workflow execution - It's only called when running workflows in remote repositories - It prov

(workflowName string, repoOverride string, verbose bool)

//
// This follows the principle that domain-specific validation belongs in domain files.
func validateRemoteWorkflow(workflowName string, repoOverride string, verbose bool) error {
	if repoOverride == "" {
		return errors.New("repository must be specified for remote workflow validation")
	}

	// Normalize workflow ID to handle both "workflow-name" and ".github/workflows/workflow-name.md" formats
	normalizedID := normalizeWorkflowID(workflowName)

	// Add .lock.yml extension
	lockFileName := normalizedID + ".lock.yml"

	if verbose {
		fmt.Fprintln(os.Stderr, console.FormatProgressMessage(fmt.Sprintf("Checking if workflow '%s' exists in repository '%s'...", lockFileName, repoOverride)))
	}

	// Use gh CLI to list workflows in the target repository
	output, err := workflow.RunGH("Listing workflows...", "workflow", "list", "--repo", repoOverride, "--json", "name,path,state")
	if err != nil {
		var exitError *exec.ExitError
		if errors.As(err, &exitError) {
			return fmt.Errorf("failed to list workflows in repository '%s': %s: %w", repoOverride, string(exitError.Stderr), err)
		}
		return fmt.Errorf("failed to list workflows in repository '%s': %w", repoOverride, err)
	}

	// Parse the JSON response
	var workflows []struct {
		Name  string `json:"name"`
		Path  string `json:"path"`
		State string `json:"state"`
	}

	if err := json.Unmarshal(output, &workflows); err != nil {
		return fmt.Errorf("failed to parse workflow list response: %w", err)
	}

	// Look for the workflow by checking if the lock file path exists
	for _, wf := range workflows {
		if strings.HasSuffix(wf.Path, lockFileName) {
			if verbose {
				fmt.Fprintln(os.Stderr, console.FormatProgressMessage(fmt.Sprintf("Found workflow '%s' in repository (path: %s, state: %s)",
					wf.Name, wf.Path, wf.State)))
			}
			return nil
		}
	}

	suggestions := []string{
		"Check if the workflow has been pushed to the remote repository",
		"Verify the workflow file exists in the repository's .github/workflows directory",
		fmt.Sprintf("Run '%s status' to see available workflows", string(constants.CLIExtensionPrefix)),
	}
	return errors.New(console.FormatErrorWithSuggestions(
		fmt.Sprintf("workflow '%s' not found in repository '%s'", lockFileName, repoOverride),
		suggestions,
	))
}