Function populateDispatchWorkflowFiles

pkg/workflow/safe_outputs_dispatch.go:25–69

======================================== Safe Output Dispatch Workflow Handling ======================================== This file contains functions for managing dispatch-workflow safe output configurations: mapping workflow names to their file extensions so the runtime handler knows which file to

(data *WorkflowData, markdownPath string)

//
// Priority order: .lock.yml > .yml > .md (same-batch compilation target)
func populateDispatchWorkflowFiles(data *WorkflowData, markdownPath string) {
	if data.SafeOutputs == nil || data.SafeOutputs.DispatchWorkflow == nil {
		return
	}

	if len(data.SafeOutputs.DispatchWorkflow.Workflows) == 0 {
		return
	}

	safeOutputsConfigLog.Printf("Populating workflow files for %d dispatch workflows", len(data.SafeOutputs.DispatchWorkflow.Workflows))

	// Initialize WorkflowFiles map if not already initialized
	if data.SafeOutputs.DispatchWorkflow.WorkflowFiles == nil {
		data.SafeOutputs.DispatchWorkflow.WorkflowFiles = make(map[string]string)
	}

	for _, workflowName := range data.SafeOutputs.DispatchWorkflow.Workflows {
		// Find the workflow file
		fileResult, err := findWorkflowFile(workflowName, markdownPath)
		if err != nil {
			safeOutputsConfigLog.Printf("Warning: error finding workflow %s: %v", workflowName, err)
			continue
		}

		// Determine which file to use - priority: .lock.yml > .yml > .md (batch target)
		extension, found := resolveWorkflowExtension(fileResult)
		if !found {
			safeOutputsConfigLog.Printf("Warning: no workflow file found for %s (checked .lock.yml, .yml, .md)", workflowName)
			continue
		}

		// Store the file extension for runtime use
		data.SafeOutputs.DispatchWorkflow.WorkflowFiles[workflowName] = extension
		safeOutputsConfigLog.Printf("Mapped workflow %s to extension %s", workflowName, extension)

		// Check if the target workflow declares aw_context in its workflow_dispatch.inputs.
		// We check the lock file first (compiled YAML), falling back to the markdown frontmatter.
		if workflowHasAwContextInput(fileResult, workflowName) {
			data.SafeOutputs.DispatchWorkflow.AwContextWorkflows = append(
				data.SafeOutputs.DispatchWorkflow.AwContextWorkflows, workflowName,
			)
			safeOutputsConfigLog.Printf("Workflow %s declares aw_context input", workflowName)
		}
	}
}

// workflowHasAwContextInput reports whether the workflow identified by fileResult
// has aw_context declared in its workflow_dispatch.inputs.