Method localModuleSource

core/schema/modulesource.go:338–571

nolint:gocyclo

(
	ctx context.Context,
	query dagql.ObjectResult[*core.Query],
	bk *engineutil.Client,

	// localPath is the path the user provided to load the module, it may be relative or absolute and
	// may point to either the directory containing dagger.json or any subdirectory in the
	// filetree under the directory containing dagger.json.
	// When findUp is enabled, it can also be a name of a dependency in the default dagger.json found-up from the cwd.
	localPath string,

	// whether to search up the directory tree for a dagger.json file. additionally, when enabled if a dagger.json is found-up
	// and localPath is a named dependency in that dagger.json, the returned source will be for that dependency.
	doFindUp bool,

	// if true, tolerate the localPath not existing on the filesystem (for dagger init on directories that don't exist yet)
	allowNotExists bool,
)

//nolint:gocyclo
func (s *moduleSourceSchema) localModuleSource(
	ctx context.Context,
	query dagql.ObjectResult[*core.Query],
	bk *engineutil.Client,

	// localPath is the path the user provided to load the module, it may be relative or absolute and
	// may point to either the directory containing dagger.json or any subdirectory in the
	// filetree under the directory containing dagger.json.
	// When findUp is enabled, it can also be a name of a dependency in the default dagger.json found-up from the cwd.
	localPath string,

	// whether to search up the directory tree for a dagger.json file. additionally, when enabled if a dagger.json is found-up
	// and localPath is a named dependency in that dagger.json, the returned source will be for that dependency.
	doFindUp bool,

	// if true, tolerate the localPath not existing on the filesystem (for dagger init on directories that don't exist yet)
	allowNotExists bool,
) (inst dagql.Result[*core.ModuleSource], err error) {
	if localPath == "" {
		localPath = "."
	}

	// figure out the absolute path to the local module source
	var localAbsPath string

	// first, check if the local path exists outright
	stat, err := bk.StatCallerHostPath(ctx, localPath, true)
	switch {
	case err == nil:
		localAbsPath = stat.Path
	case status.Code(err) == codes.NotFound:
		// tolerate for now, we may not be enforcing it's existence and/or may find it as named dep in a find-up
	default:
		return inst, fmt.Errorf("failed to stat local path: %w", err)
	}

	// if localPath doesn't exist and find-up is enabled, check if it's a named dep in the default dagger.json
	if localAbsPath == "" && doFindUp {
		cwd, err := bk.AbsPath(ctx, ".")
		if err != nil {
			return inst, fmt.Errorf("failed to get cwd: %w", err)
		}
		defaultFindUpSourceRootDir, defaultFindUpExists, err := core.Host{}.FindUp(ctx, core.NewCallerStatFS(bk), cwd, modules.Filename)
		if err != nil {
			return inst, fmt.Errorf("failed to find up root: %w", err)
		}
		if defaultFindUpExists {
			configPath := filepath.Join(defaultFindUpSourceRootDir, modules.Filename)
			contents, err := bk.ReadCallerHostFile(ctx, configPath)
			if err != nil {
				return inst, fmt.Errorf("failed to read module config file: %w", err)
			}
			modCfg, err := modules.ParseModuleConfig(contents)
			if err != nil {
				return inst, fmt.Errorf("failed to parse module config: %w", err)
			}

			namedDep, ok := modCfg.DependencyByName(localPath)