Method Resolve

runtime/resolver.go:126–270

Resolve resolves a query using the given options. The caller must call Close on the result when done consuming it.

(ctx context.Context, opts *ResolveOptions)

// Resolve resolves a query using the given options.
// The caller must call Close on the result when done consuming it.
func (r *Runtime) Resolve(ctx context.Context, opts *ResolveOptions) (res ResolverResult, info *ResolveInfo, resErr error) {
	// Since claims don't really make sense for some resolver use cases, it's easy to forget to set them.
	// Adding an early panic to catch this.
	if opts.Claims == nil {
		panic("received nil claims")
	}

	ctx, span := tracer.Start(ctx, "runtime.Resolve", trace.WithAttributes(attribute.String("resolver", opts.Resolver)))
	var cacheHit bool
	defer func() {
		observability.AddRequestAttributes(ctx, attribute.Bool("query.cache_hit", cacheHit))
		if resErr != nil {
			span.SetAttributes(attribute.String("err", resErr.Error()))
		}
		span.End()
	}()

	// Initialize the resolver
	initializer, ok := ResolverInitializers[opts.Resolver]
	if !ok {
		return nil, nil, fmt.Errorf("no resolver found for name %q", opts.Resolver)
	}
	resolver, err := initializer(ctx, &ResolverOptions{
		Runtime:    r,
		InstanceID: opts.InstanceID,
		Properties: opts.ResolverProperties,
		Args:       opts.Args,
		Claims:     opts.Claims,
		ForExport:  false,
	})
	if err != nil {
		return nil, nil, err
	}
	defer resolver.Close()

	err = resolver.Validate(ctx)
	if err != nil {
		var invalidErr *ResolverUnusedFieldsError
		if !errors.As(err, &invalidErr) {
			return nil, nil, err
		}

		cfg, cfgErr := r.InstanceConfig(ctx, opts.InstanceID)
		if cfgErr != nil {
			return nil, nil, fmt.Errorf("failed to get instance config: %w", cfgErr)
		}

		if cfg.StrictResolverProps {
			return nil, nil, err
		}
		info = &ResolveInfo{
			Warnings: []string{invalidErr.Error()},
		}
	}

	// Get the cache key
	cacheKey, ok, err := resolver.CacheKey(ctx)
	if err != nil {