Method Value

core/modfunc.go:443–511

(ctx context.Context)

}

func (ud *UserDefault) Value(ctx context.Context) (any, error) {
	if !ud.IsObject() && !ud.IsList() {
		return ud.UserDefaultPrimitive.Value()
	}
	// List of non-object elements (e.g. []string) is handled by the primitive path
	if ud.IsList() &&
		ud.Arg.TypeDef.Self().AsList.Valid &&
		ud.Arg.TypeDef.Self().AsList.Value.Self() != nil &&
		ud.Arg.TypeDef.Self().AsList.Value.Self().ElementTypeDef.Self() != nil &&
		ud.Arg.TypeDef.Self().AsList.Value.Self().ElementTypeDef.Self().Kind != TypeDefKindObject {
		return ud.UserDefaultPrimitive.Value()
	}
	query, err := CurrentQuery(ctx)
	if err != nil {
		return nil, fmt.Errorf("get current query: %w", err)
	}
	mainClient, err := query.NonModuleParentClientMetadata(ctx)
	if err != nil {
		return nil, fmt.Errorf("access main client: %w", err)
	}
	mainCtx := engine.ContextWithClientMetadata(ctx, mainClient)
	// Resolve object from user-supplied "address"
	srv := dagql.CurrentDagqlServer(mainCtx)

	resolveOne := func(userInput, typename string) (any, error) {
		var result dagql.AnyObjectResult
		if err := srv.Select(mainCtx, srv.Root(), &result,
			dagql.Selector{
				Field: "address",
				Args: []dagql.NamedInput{{
					Name:  "value",
					Value: dagql.NewString(userInput),
				}},
			},
			dagql.Selector{
				Field: strings.ToLower(typename),
			},
		); err != nil {
			return nil, ud.errorf(err, "resolve object (%q)", typename)
		}

		id, err := result.Select(mainCtx, srv, dagql.Selector{
			Field: "id",
		})
		if err != nil {
			return nil, ud.errorf(err, "get object ID")
		}
		return id.Unwrap(), nil
	}

	if ud.IsList() {
		// "Secret" -> "secret", "GitRef" -> "gitRef", etc (from the element type)
		typename := ud.Arg.TypeDef.Self().AsList.Value.Self().ElementTypeDef.Self().ToType().Name()
		elements := strings.Split(ud.UserInput, ",")
		ids := make([]any, 0, len(elements))
		for _, elem := range elements {
			id, err := resolveOne(strings.TrimSpace(elem), typename)
			if err != nil {