Function newBuiltinMetricsSQL

runtime/resolvers/builtin_metrics_sql.go:48–73

newBuiltinMetricsSQL is the resolver for the built-in /metrics-sql API. It executes a metrics SQL query provided dynamically through the args. It errors if the user identified by the attributes is not an admin.

(ctx context.Context, opts *runtime.ResolverOptions)

// It executes a metrics SQL query provided dynamically through the args.
// It errors if the user identified by the attributes is not an admin.
func newBuiltinMetricsSQL(ctx context.Context, opts *runtime.ResolverOptions) (runtime.Resolver, error) {
	// Only admins can run arbitrary SQL queries.
	if !opts.Claims.SkipChecks && !opts.Claims.Admin() {
		return nil, errors.New("must be an admin to run arbitrary SQL queries")
	}

	// Decode the args
	args := &builtinMetricsSQLArgs{}
	if err := mapstructure.Decode(opts.Args, args); err != nil {
		return nil, err
	}

	// Rewrite to the metrics SQL resolver
	return newMetricsSQL(ctx, &runtime.ResolverOptions{
		Runtime:    opts.Runtime,
		InstanceID: opts.InstanceID,
		Properties: map[string]any{
			"sql": args.SQL,
		},
		Args: map[string]any{
			"priority": args.Priority,
		},
		Claims:    opts.Claims,
		ForExport: opts.ForExport,
	})
}