Method gitModuleSource

core/schema/modulesource.go:574–783

nolint:gocyclo

(
	ctx context.Context,
	query dagql.ObjectResult[*core.Query],
	source string,
	parsed *core.ParsedGitRefString,
	refPin string,
	// whether to search up the directory tree for a dagger.json file
	doFindUp bool,
)

//nolint:gocyclo
func (s *moduleSourceSchema) gitModuleSource(
	ctx context.Context,
	query dagql.ObjectResult[*core.Query],
	source string,
	parsed *core.ParsedGitRefString,
	refPin string,
	// whether to search up the directory tree for a dagger.json file
	doFindUp bool,
) (inst dagql.Result[*core.ModuleSource], err error) {
	dag, err := query.Self().Server.Server(ctx)
	if err != nil {
		return inst, fmt.Errorf("failed to get dag server: %w", err)
	}

	var (
		lockResolution lookupLockResolution
		lookupLock     *workspaceLookupLock
	)
	if refPin == "" {
		lockMode, err := currentLookupLockMode(ctx)
		if err != nil {
			return inst, fmt.Errorf("%s lock mode: %w", lockModulesResolveOperation, err)
		}
		if lockMode != workspace.LockModeDisabled {
			lookupLock, err = loadWorkspaceLookupLock(ctx, query.Self())
			if err != nil {
				return inst, fmt.Errorf("%s lockfile: %w", lockModulesResolveOperation, err)
			}
			if lookupLock == nil {
				return inst, fmt.Errorf("experimental lockfile support is local-only")
			}
			lockResolution, err = resolveLookupFromLock(
				lockMode,
				lookupLock.lock,
				lockModulesResolveOperation,
				[]any{source},
				workspace.PolicyFloat,
			)
			if err != nil {
				return inst, fmt.Errorf("%s lock resolution: %w", lockModulesResolveOperation, err)
			}
			refPin = lockResolution.Pin
		}
	}

	gitRef, err := parsed.GitRef(ctx, dag, refPin)
	if err != nil {
		return inst, fmt.Errorf("failed to resolve git src: %w", err)
	}

	gitSrc := &core.ModuleSource{
		ConfigExists: true, // we can't load uninitialized git modules, we'll error out later if it's not there
		Kind:         core.ModuleSourceKindGit,
		Git: &core.GitModuleSource{
			HTMLRepoURL:  parsed.RepoRoot.Repo,
			RepoRootPath: parsed.RepoRoot.Root,
			Version:      cmp.Or(gitRef.Self().Ref.ShortName(), gitRef.Self().Ref.SHA),
			Commit:       gitRef.Self().Ref.SHA,