Method LoadContextDir

core/modulesource.go:1204–1275

LoadContextDir loads addition files+directories from the module source's context, including those that may have not been included in the original module source load.

(
	ctx context.Context,
	dag *dagql.Server,
	path string,
	filter CopyFilter,
)

// LoadContextDir loads addition files+directories from the module source's context, including those that
// may have not been included in the original module source load.
func (src *ModuleSource) LoadContextDir(
	ctx context.Context,
	dag *dagql.Server,
	path string,
	filter CopyFilter,
) (inst dagql.ObjectResult[*Directory], err error) {
	filterInputs := []dagql.NamedInput{}
	if len(filter.Include) > 0 {
		filterInputs = append(filterInputs, dagql.NamedInput{
			Name:  "include",
			Value: dagql.ArrayInput[dagql.String](dagql.NewStringArray(filter.Include...)),
		})
	}
	if len(filter.Exclude) > 0 {
		filterInputs = append(filterInputs, dagql.NamedInput{
			Name:  "exclude",
			Value: dagql.ArrayInput[dagql.String](dagql.NewStringArray(filter.Exclude...)),
		})
	}
	if filter.Gitignore {
		filterInputs = append(filterInputs, dagql.NamedInput{
			Name:  "gitignore",
			Value: dagql.NewBoolean(true),
		})
	}

	// Check if there's an Env - if so, use its workspace as the context for
	// defaultPath arguments.
	//
	// NOTE: this applies unilaterally, whether the module was loaded from Host,
	// Git, or a Directory.
	env, ok, envErr := EnvFromContext(ctx)
	if envErr != nil {
		return inst, envErr
	}
	if ok {
		inst, err = src.loadContextFromEnv(ctx, dag, env, path, filterInputs)
	} else {
		inst, err = src.loadContextFromSource(ctx, dag, path, filterInputs)
	}
	if err != nil {
		return inst, err
	}
	instID, err := inst.ID()
	if err != nil {
		return inst, fmt.Errorf("context directory ID: %w", err)
	}
	instCall, err := inst.ResultCall()
	if err != nil {
		return inst, fmt.Errorf("context directory call: %w", err)
	}
	if instID != nil && instCall.ContentDigest() == "" {
		snapshot, err := inst.Self().Snapshot.GetOrEval(ctx, inst.Result)
		if err != nil {
			return inst, fmt.Errorf("context directory snapshot: %w", err)
		}
		dirPath, err := inst.Self().Dir.GetOrEval(ctx, inst.Result)
		if err != nil {