Method loadContextFromSource

core/modulesource.go:1315–1485

(
	ctx context.Context,
	dag *dagql.Server,
	path string,
	filterInputs []dagql.NamedInput,
)

}

func (src *ModuleSource) loadContextFromSource(
	ctx context.Context,
	dag *dagql.Server,
	path string,
	filterInputs []dagql.NamedInput,
) (inst dagql.ObjectResult[*Directory], err error) {
	query, err := CurrentQuery(ctx)
	if err != nil {
		return inst, err
	}
	switch src.Kind {
	case ModuleSourceKindLocal:
		localSourceClientMetadata, err := query.NonModuleParentClientMetadata(ctx)
		if err != nil {
			return inst, fmt.Errorf("failed to get client metadata: %w", err)
		}
		localSourceCtx := engine.ContextWithClientMetadata(ctx, localSourceClientMetadata)

		// Retrieve the absolute path to the context directory (.git or dagger.json)
		// and the module root directory (dagger.json)
		ctxPath := src.Local.ContextDirectoryPath
		modPath := filepath.Join(ctxPath, src.SourceRootSubpath)

		// If path is not absolute, it's relative to the module root directory.
		// If path is absolute, it's relative to the context directory.
		if !filepath.IsAbs(path) {
			path = filepath.Join(modPath, path)
		} else {
			path = filepath.Join(ctxPath, path)
		}

		// We just check if the path is relative to the context directory,
		// if not, that means it's a path that target an outside directory
		// which is not allowed.
		relativePathToCtx, err := filepath.Rel(ctxPath, path)
		if err != nil {
			return inst, fmt.Errorf("failed to get relative path to context: %w", err)
		}

		// If the relative path is outisde of the context directory, throw an error.
		if strings.HasPrefix(relativePathToCtx, "..") {
			return inst, fmt.Errorf("path %q is outside of context directory %q, path should be relative to the context directory", path, ctxPath)
		}

		err = dag.Select(localSourceCtx, dag.Root(), &inst,
			dagql.Selector{
				Field: "host",
			},
			dagql.Selector{
				Field: "directory",
				Args: append([]dagql.NamedInput{
					{Name: "path", Value: dagql.String(path)},
					{Name: "noCache", Value: dagql.Boolean(true)},
				}, filterInputs...),
			},
		)
		if err != nil {
			return inst, fmt.Errorf("failed to select host directory: %w", err)