Method directoryAsModuleSource

core/schema/modulesource.go:861–960

(
	ctx context.Context,
	contextDir dagql.ObjectResult[*core.Directory],
	args directoryAsModuleArgs,
)

}

func (s *moduleSourceSchema) directoryAsModuleSource(
	ctx context.Context,
	contextDir dagql.ObjectResult[*core.Directory],
	args directoryAsModuleArgs,
) (inst dagql.Result[*core.ModuleSource], err error) {
	query, err := core.CurrentQuery(ctx)
	if err != nil {
		return inst, err
	}
	dag, err := query.Server.Server(ctx)
	if err != nil {
		return inst, fmt.Errorf("failed to get dag server: %w", err)
	}

	sourceRootSubpath := args.SourceRootPath
	if sourceRootSubpath == "" {
		sourceRootSubpath = "."
	}

	dirSrc := &core.ModuleSource{
		ConfigExists:      true, // we can't load uninitialized dir modules, we'll error out later if it's not there
		SourceRootSubpath: sourceRootSubpath,
		ContextDirectory:  contextDir,
		Kind:              core.ModuleSourceKindDir,
		DirSrc: &core.DirModuleSource{
			OriginalContextDir:        contextDir,
			OriginalSourceRootSubpath: args.SourceRootPath,
		},
	}
	if dirSrc.SourceRootSubpath == "" {
		dirSrc.SourceRootSubpath = "."
	}

	configPath := filepath.Join(dirSrc.SourceRootSubpath, modules.Filename)
	var configContents string
	err = dag.Select(ctx, contextDir, &configContents,
		dagql.Selector{
			Field: "file",
			Args: []dagql.NamedInput{
				{Name: "path", Value: dagql.String(configPath)},
			},
		},
		dagql.Selector{Field: "contents"},
	)
	if err != nil {
		return inst, fmt.Errorf("failed to load dir module dagger config: %w", err)
	}
	if err := s.initFromModConfig([]byte(configContents), dirSrc); err != nil {
		return inst, err
	}

	// load this module source's deps in parallel
	bk, err := query.Engine(ctx)
	if err != nil {
		return inst, fmt.Errorf("failed to get engine client: %w", err)
	}

	var eg errgroup.Group