Method withCurrentModule

core/schema/env.go:283–313

(ctx context.Context, env dagql.ObjectResult[*core.Env], _ struct{})

}

func (s environmentSchema) withCurrentModule(ctx context.Context, env dagql.ObjectResult[*core.Env], _ struct{}) (res dagql.ObjectResult[*core.Env], _ error) {
	query, err := core.CurrentQuery(ctx)
	if err != nil {
		return res, fmt.Errorf("failed to get current query: %w", err)
	}
	mod, err := query.CurrentModule(ctx)
	if err != nil {
		return res, fmt.Errorf("failed to get current module: %w", err)
	}
	modID, err := mod.ID()
	if err != nil {
		return res, fmt.Errorf("get current module ID: %w", err)
	}
	srv, err := core.CurrentDagqlServer(ctx)
	if err != nil {
		return res, fmt.Errorf("failed to get current dagql server: %w", err)
	}
	err = srv.Select(ctx, env, &res, dagql.Selector{
		Field: "withModule",
		Args: []dagql.NamedInput{
			{
				Name:  "module",
				Value: dagql.NewID[*core.Module](modID),
			},
		},
	})
	if err != nil {
		return res, fmt.Errorf("failed to install current module: %w", err)
	}
	return res, nil
}

func (s environmentSchema) withStringInput(ctx context.Context, env *core.Env, args struct {
	Name        string