Function fetchAndSaveRemoteFrontmatterImports

pkg/cli/includes.go:125–173

fetchAndSaveRemoteFrontmatterImports fetches and saves files referenced in the frontmatter 'imports:' field of a remote workflow. These relative-path imports are resolved against the workflow's location in the source repository and saved locally so compilation can find them. This is analogous to fet

(content string, spec *WorkflowSpec, targetDir string, verbose bool, force bool, tracker *FileTracker)

// markdown body; this function handles the YAML frontmatter 'imports:' field.
// Import failures are non-fatal (best-effort); the compiler will report any still-missing files.
func fetchAndSaveRemoteFrontmatterImports(content string, spec *WorkflowSpec, targetDir string, verbose bool, force bool, tracker *FileTracker) error {
	if spec.RepoSlug == "" {
		return nil
	}

	remoteWorkflowLog.Printf("Fetching frontmatter imports for workflow: repo=%s, path=%s", spec.RepoSlug, spec.WorkflowPath)

	parts := strings.SplitN(spec.RepoSlug, "/", 2)
	if len(parts) != 2 {
		return nil
	}
	owner, repo := parts[0], parts[1]
	ref := spec.Version
	if ref == "" {
		// Resolve the actual default branch of the source repo rather than assuming "main"
		defaultBranch, err := getRepoDefaultBranch(context.Background(), spec.RepoSlug)
		if err != nil {
			remoteWorkflowLog.Printf("Failed to resolve default branch for %s, falling back to 'main': %v", spec.RepoSlug, err)
			ref = "main"
		} else {
			ref = defaultBranch
		}
		// Persist the resolved default ref so other callers do not need to re-resolve it
		spec.Version = ref
	}

	// workflowBaseDir is the directory of the top-level workflow in the source repo
	// (e.g. ".github/workflows"). It serves as both the starting point for resolving
	// relative imports and as the prefix to strip when computing local target paths.
	workflowBaseDir := getParentDir(spec.WorkflowPath)

	// seen is keyed by fully-resolved remote file path. It is shared across all recursion
	// levels so that every import (at any depth) is downloaded at most once and import
	// cycles (A imports B, B imports A) are broken without infinite recursion.
	seen := make(map[string]struct {
	})
	fetchFrontmatterImportsRecursive(content, workflowBaseDir, frontmatterImportsOpts{
		owner:           owner,
		repo:            repo,
		ref:             ref,
		originalBaseDir: workflowBaseDir,
		targetDir:       targetDir,
		verbose:         verbose,
		force:           force,
		tracker:         tracker,
		seen:            seen,
	})
	return nil
}

// frontmatterImportsOpts holds the constant parameters for fetchFrontmatterImportsRecursive.
// Only `content` and `currentBaseDir` change per recursion level; everything else is constant.