Method newWorkdir

cmd/dagger/shell_fs.go:403–479

(ctx context.Context, def *moduleDef, subpath string)

}

func (h *shellCallHandler) newWorkdir(ctx context.Context, def *moduleDef, subpath string) (rwd *shellWorkdir, rerr error) {
	var context moduleContext
	var digest string
	var err error

	if def != nil && def.SourceDigest != h.modDigest() {
		context, err = newModuleContext(ctx, def)
		if err != nil {
			return nil, err
		}
		digest = def.SourceDigest
	} else {
		h.mu.RLock()
		context = h.wd.Context
		digest = h.wd.Module
		h.mu.RUnlock()
	}

	// initial context, without a loaded module (core API only)
	if context == nil {
		// a few quick checks first
		root, err := pathutil.Abs(subpath)
		if err != nil {
			return nil, err
		}
		info, err := os.Stat(root)
		if err != nil {
			return nil, err
		}
		if !info.IsDir() {
			return nil, fmt.Errorf("%q is not a directory", root)
		}

		if !h.noModule {
			// ask API where the context dir is (.git)
			ctx, span := Tracer().Start(ctx, "looking for context directory", telemetry.Internal())
			defer telemetry.EndWithCause(span, &rerr)

			src := h.dag.ModuleSource(root, dagger.ModuleSourceOpts{
				DisableFindUp:  true,
				AllowNotExists: true,
			})
			root, err = src.LocalContextDirectoryPath(ctx)
			if err != nil {
				return nil, err
			}
			subpath, err = src.SourceRootSubpath(ctx)
			if err != nil {
				return nil, err
			}
		}
		return &shellWorkdir{
			Context: localSourceContext{
				Root: root,
			},
			Path: filepath.Join("/", subpath),
		}, nil
	}