Method loadContextualGitArg

core/modfunc.go:1091–1180

loadContextualGitArg resolves a +defaultPath argument for GitRepository or GitRef types. For local modules with a local git path (. or .git), it uses a cache-keyed selector to prevent errant reloads. Otherwise it loads from the module context or parses a remote git URL.

(
	ctx context.Context,
	dag *dagql.Server,
	arg *FunctionArg,
)

// a cache-keyed selector to prevent errant reloads. Otherwise it loads from
// the module context or parses a remote git URL.
func (fn *ModuleFunction) loadContextualGitArg(
	ctx context.Context,
	dag *dagql.Server,
	arg *FunctionArg,
) (dagql.IDType, error) {
	isLocalMod := fn.mod.Self().ContextSource.Value.Self().Kind == ModuleSourceKindLocal
	cleanedPath := filepath.Clean(strings.Trim(arg.DefaultPath, "/"))
	isLocalGit := cleanedPath == "." || cleanedPath == ".git"

	if isLocalMod && isLocalGit {
		switch arg.TypeDef.Self().AsObject.Value.Self().Name {
		case "GitRepository":
			repo, err := fn.mod.Self().ContextSource.Value.Self().LoadContextGit(ctx, dag)
			if err != nil {
				return nil, fmt.Errorf("load contextual git repository %q: %w", arg.DefaultPath, err)
			}
			repoID, err := repo.ID()
			if err != nil {
				return nil, fmt.Errorf("get contextual git repository ID %q: %w", arg.DefaultPath, err)
			}
			return dagql.NewID[*GitRepository](repoID), nil

		case "GitRef":
			repo, err := fn.mod.Self().ContextSource.Value.Self().LoadContextGit(ctx, dag)
			if err != nil {
				return nil, fmt.Errorf("load contextual git ref %q: %w", arg.DefaultPath, err)
			}
			var gitRef dagql.ObjectResult[*GitRef]
			err = dag.Select(ctx, repo, &gitRef,
				dagql.Selector{Field: "head"},
			)
			if err != nil {
				return nil, fmt.Errorf("load contextual git ref %q: %w", arg.DefaultPath, err)
			}
			gitRefID, err := gitRef.ID()
			if err != nil {
				return nil, fmt.Errorf("get contextual git ref ID %q: %w", arg.DefaultPath, err)
			}
			return dagql.NewID[*GitRef](gitRefID), nil
		}
	}

	var git dagql.ObjectResult[*GitRepository]
	if isLocalGit {
		var err error
		git, err = fn.mod.Self().ContextSource.Value.Self().LoadContextGit(ctx, dag)
		if err != nil {
			return nil, err
		}
	} else if gitURL, err := gitutil.ParseURL(arg.DefaultPath); err == nil {
		args := []dagql.NamedInput{
			{Name: "url", Value: dagql.String(gitURL.String())},
		}
		if gitURL.Fragment != nil {
			args = append(args, dagql.NamedInput{Name: "ref", Value: dagql.String(gitURL.Fragment.Ref)})
		}
		err := dag.Select(ctx, dag.Root(), &git,
			dagql.Selector{Field: "git", Args: args},