Function fetchGenericURLWorkflow

pkg/cli/fetch.go:300–381

fetchGenericURLWorkflow fetches a workflow from an arbitrary HTTP(S) URL and dispatches on the response Content-Type to produce a FetchedWorkflow. Supported content types: - text/markdown, text/x-markdown → treated as raw gh-aw workflow markdown. - application/json (or any +json suffix) → treated a

(ctx context.Context, spec *WorkflowSpec, verbose bool)

// Any other content type is an error with an actionable message.
// Warnings from JSON conversion are printed to stderr when verbose is true.
func fetchGenericURLWorkflow(ctx context.Context, spec *WorkflowSpec, verbose bool) (*FetchedWorkflow, error) {
	remoteWorkflowLog.Printf("Fetching generic URL workflow")

	if verbose {
		fmt.Fprintln(os.Stderr, console.FormatInfoMessage("Fetching workflow from URL..."))
	}

	resource, err := FetchImportURL(ctx, spec.RawURL, FetchOptions{})
	if err != nil {
		return nil, err
	}

	ct := resource.ContentType
	remoteWorkflowLog.Printf("Fetched URL resource: content_type=%q bytes=%d", ct, len(resource.Body))

	switch {
	case ct == "text/markdown" || ct == "text/x-markdown":
		remoteWorkflowLog.Printf("URL returned markdown content (%d bytes)", len(resource.Body))
		if verbose {
			fmt.Fprintln(os.Stderr, console.FormatSuccessMessage(fmt.Sprintf("Downloaded workflow markdown (%d bytes)", len(resource.Body))))
		}
		return &FetchedWorkflow{
			Content:    resource.Body,
			CommitSHA:  "",
			IsLocal:    false,
			SourcePath: spec.RawURL,
		}, nil

	case ct == "application/json" || strings.HasSuffix(ct, "+json"):
		remoteWorkflowLog.Printf("URL returned JSON content (%d bytes); converting", len(resource.Body))
		if verbose {
			fmt.Fprintln(os.Stderr, console.FormatInfoMessage(fmt.Sprintf("Downloaded JSON workflow (%d bytes); converting to markdown...", len(resource.Body))))
		}

		remoteWorkflowLog.Printf("JSON payload:\n%s", string(resource.Body))

		var wf JSONWorkflow
		if err := json.Unmarshal(resource.Body, &wf); err != nil {
			return nil, fmt.Errorf("failed to parse JSON workflow from URL: %w", err)
		}

		nameOverride := selectJSONImportNameOverride(spec.WorkflowName, &wf)
		generated, err := ConvertJSONWorkflowToMarkdown(&wf, ConvertOptions{NameOverride: nameOverride})
		if err != nil {
			return nil, fmt.Errorf("failed to convert JSON workflow: %w", err)
		}

		remoteWorkflowLog.Printf("Converted JSON to markdown: filename=%s bytes=%d warnings=%d",
			generated.Filename, len(generated.Markdown), len(generated.Warnings))

		if verbose {
			for _, w := range generated.Warnings {
				fmt.Fprintln(os.Stderr, console.FormatWarningMessage("JSON workflow import: "+w))
			}
		}

		// Use the generated filename as the WorkflowName on the spec so that
		// downstream code (e.g. add_command.go) uses the correct file name.