Function processIncludesWithWorkflowSpec

pkg/cli/imports.go:153–299

processIncludesWithWorkflowSpec processes @include directives in content and replaces local file references with workflowspec format (owner/repo/path@sha) for all includes found in the package. If localWorkflowDir is non-empty, any relative import path whose file exists under that directory is left

(content string, workflow *WorkflowSpec, commitSHA, packagePath, localWorkflowDir string, verbose bool)

// If localWorkflowDir is non-empty, any relative import path whose file exists under that directory is
// left as a local relative path rather than being rewritten to a cross-repo reference.
func processIncludesWithWorkflowSpec(content string, workflow *WorkflowSpec, commitSHA, packagePath, localWorkflowDir string, verbose bool) (string, error) {
	importsLog.Printf("Processing @include directives: repo=%s, sha=%s, package=%s, localWorkflowDir=%s", workflow.RepoSlug, commitSHA, packagePath, localWorkflowDir)
	if verbose {
		fmt.Fprintln(os.Stderr, console.FormatVerboseMessage("Processing @include directives to replace with workflowspec"))
	}

	// Track visited includes to prevent cycles
	visited := make(map[string]struct {
	})

	// Use a queue to process files iteratively instead of recursion
	queue := []string{}

	// Process the main content first
	scanner := bufio.NewScanner(strings.NewReader(content))
	var result strings.Builder

	for scanner.Scan() {
		line := scanner.Text()

		// Parse import directive using the helper function that handles both syntaxes
		directive := parser.ParseImportDirective(line)
		if directive != nil {
			isOptional := directive.IsOptional
			includePath := directive.Path

			// Skip if it's already a workflowspec (owner/repo/path@sha format)
			if isWorkflowSpecFormat(includePath) {
				result.WriteString(line + "\n")
				continue
			}

			// Handle section references (file.md#Section)
			filePath, sectionName := splitImportPath(includePath)

			// Skip if filePath is empty (e.g., section-only reference like "#Section")
			if filePath == "" {
				if verbose {
					fmt.Fprintln(os.Stderr, console.FormatWarningMessage("Skipping include with empty file path: "+line))
				}
				result.WriteString(line + "\n")
				continue
			}

			// Preserve relative {{#import}} paths whose files exist in the local workflow directory.
			if localWorkflowDir != "" && !strings.HasPrefix(filePath, "/") {
				if isLocalFileForUpdate(localWorkflowDir, filePath) {
					importsLog.Printf("Include path exists locally, preserving: %s", filePath)
					result.WriteString(line + "\n")
					// Add file to queue for processing nested includes (first visit only)
					if !setutil.Contains(visited, filePath) {
						visited[filePath] = struct {
						}{}
						queue = append(queue, filePath)
					}
					continue
				}
			}