Allow global resolver Middlewares

CHANGELOG.md

@@ -1,8 +1,13 @@
 CHANGELOG
 =========
 
-[Next release](https://github.com/rebing/graphql-laravel/compare/9.3.0...master)
---------------
+[Next release](https://github.com/rebing/graphql-laravel/compare/9.4.0...master)
+
+2024-02-27, 9.4.0
+-----------------
+
+## Added
+- Possibility to add resolver middleware at runtime using `GraphQL::appendGlobalResolverMiddleware(YourMiddleware::class)` or `GraphQL::appendGlobalResolverMiddleware(new YourMiddleware(...))`
 
 2024-02-18, 9.3.0
 -----------------

README.md

@@ -1151,6 +1151,28 @@ Alternatively, you can override `getMiddleware` to supply your own logic:
     }
 ```
 
+If you want to register middleware globally, use the `resolver_middleware_append` key in `config/graphql.php`:
+
+```php  
+return [
+    ...
+    'resolver_middleware_append' => [YourMiddleware::class],
+];
+```
+
+You can also use the `appendGlobalResolverMiddleware` method in any ServiceProvider:
+
+```php
+    ...
+    public function boot()
+    {
+        ...
+        GraphQL::appendGlobalResolverMiddleware(YourMiddleware::class);
+        // Or with new instance
+        GraphQL::appendGlobalResolverMiddleware(new YourMiddleware(...));
+    }
+```
+
 #### Terminable middleware
 
 Sometimes a middleware may need to do some work after the response has been sent to the browser.

config/config.php

@@ -214,4 +214,9 @@
         Rebing\GraphQL\Support\ExecutionMiddleware\AddAuthUserContextValueMiddleware::class,
         // \Rebing\GraphQL\Support\ExecutionMiddleware\UnusedVariablesMiddleware::class,
     ],
+
+    /*
+     * Globally registered ResolverMiddleware
+     */
+    'resolver_middleware_append' => null,
 ];

src/GraphQL.php

@@ -51,6 +51,13 @@ class GraphQL
      */
     protected $types = [];
 
+    /**
+     * These middleware are executed before all resolve methods
+     *
+     * @var array<object|class-string>
+     */
+    protected $globalResolverMiddlewares = [];
+
     /** @var Type[] */
     protected $typesInstances = [];
 
@@ -186,6 +193,24 @@ protected function appendGraphqlExecutionMiddleware(array $middlewares): array
         return $middlewares;
     }
 
+    /**
+     * @phpstan-param class-string|object $class
+     */
+    public function appendGlobalResolverMiddleware(object|string $class): void
+    {
+        $this->globalResolverMiddlewares[] = $class;
+    }
+
+    /**
+     * @phpstan-return array<object|class-string>
+     */
+    public function getGlobalResolverMiddlewares(): array
+    {
+        $resolverMiddlewares = $this->config->get('graphql.resolver_middleware_append') ?? [];
+
+        return array_merge($resolverMiddlewares, $this->globalResolverMiddlewares);
+    }
+
     /**
      * @param array<int|string,string> $types
      */
@@ -501,8 +526,8 @@ public function wrapType(string $typeName, string $customTypeName, string $wrapp
     }
 
     /**
-     * @see \GraphQL\Executor\ExecutionResult::setErrorFormatter
      * @return array<string,mixed>
+     * @see \GraphQL\Executor\ExecutionResult::setErrorFormatter
      */
     public static function formatError(Error $e): array
     {

src/Support/Facades/GraphQL.php

@@ -24,6 +24,8 @@
  * @method static Schema buildSchemaFromConfig(array $schemaConfig)
  * @method static array getSchemas()
  * @method static void addSchema(string $name, Schema $schema)
+ * @method static array getGlobalResolverMiddlewares()
+ * @method static void appendGlobalResolverMiddleware(object|string $class)
  * @method static void addType(object|string $class, string $name = null)
  * @method static Type objectType(ObjectType|array|string $type, array $opts = [])
  * @method static array formatError(Error $e)

src/Support/Field.php

@@ -13,6 +13,7 @@
 use Rebing\GraphQL\Error\AuthorizationError;
 use Rebing\GraphQL\Error\ValidationError;
 use Rebing\GraphQL\Support\AliasArguments\AliasArguments;
+use Rebing\GraphQL\Support\Facades\GraphQL;
 use ReflectionMethod;
 
 /**
@@ -145,6 +146,15 @@ protected function getMiddleware(): array
         return $this->middleware;
     }
 
+    /**
+     * @return array<class-string|object>
+     * @phpstan-param array<string> $middleware
+     */
+    protected function appendGlobalMiddlewares(array $middleware): array
+    {
+        return array_merge($middleware, GraphQL::getGlobalResolverMiddlewares());
+    }
+
     protected function getResolver(): ?Closure
     {
         $resolver = $this->originalResolver();
@@ -154,7 +164,7 @@ protected function getResolver(): ?Closure
         }
 
         return function ($root, ...$arguments) use ($resolver) {
-            $middleware = $this->getMiddleware();
+            $middleware = $this->appendGlobalMiddlewares($this->getMiddleware());
 
             return app()->make(Pipeline::class)
                 ->send(array_merge([$this], $arguments))
@@ -165,7 +175,7 @@ protected function getResolver(): ?Closure
 
                     foreach ($middleware as $name) {
                         /** @var Middleware $instance */
-                        $instance = app()->make($name);
+                        $instance = \is_object($name) ? $name : app()->make($name);
 
                         if (method_exists($instance, 'terminate')) {
                             app()->terminating(function () use ($arguments, $instance, $result): void {

tests/Support/Middlewares/GlobalInstanceMiddleware.php

@@ -0,0 +1,32 @@
+<?php
+
+declare(strict_types = 1);
+namespace Rebing\GraphQL\Tests\Support\Middlewares;
+
+use Closure;
+use Exception;
+use GraphQL\Type\Definition\ResolveInfo;
+use Rebing\GraphQL\Support\Middleware;
+
+class GlobalInstanceMiddleware extends Middleware
+{
+    protected int $invalidValue;
+
+    public function __construct(int $invalidValue)
+    {
+        $this->invalidValue = $invalidValue;
+    }
+
+    /**
+     * @phpstan-param mixed $root
+     * @phpstan-param mixed $context
+     */
+    public function handle($root, array $args, $context, ResolveInfo $info, Closure $next): mixed
+    {
+        if (isset($this->invalidValue) && $this->invalidValue === $args['index']) {
+            throw new Exception('Index is not allowed');
+        }
+
+        return $next($root, $args, $context, $info);
+    }
+}

tests/Support/Middlewares/GlobalMiddleware.php

@@ -0,0 +1,18 @@
+<?php declare(strict_types = 1);
+namespace Rebing\GraphQL\Tests\Support\Middlewares;
+
+use Closure;
+use GraphQL\Type\Definition\ResolveInfo;
+use Rebing\GraphQL\Support\Middleware;
+
+class GlobalMiddleware extends Middleware
+{
+    /**
+     * @phpstan-param mixed $root
+     * @phpstan-param mixed $context
+     */
+    public function handle($root, array $args, $context, ResolveInfo $info, Closure $next): mixed
+    {
+        return [['test' => 'Intercepted by GlobalMiddleware']];
+    }
+}

tests/Unit/GlobalMiddlewareTest.php

@@ -0,0 +1,36 @@
+<?php
+
+declare(strict_types = 1);
+namespace Rebing\GraphQL\Tests\Unit;
+
+use Rebing\GraphQL\Support\Facades\GraphQL;
+use Rebing\GraphQL\Tests\Support\Middlewares\GlobalInstanceMiddleware;
+use Rebing\GraphQL\Tests\Support\Middlewares\GlobalMiddleware;
+use Rebing\GraphQL\Tests\TestCase;
+
+class GlobalMiddlewareTest extends TestCase
+{
+    public function testConfigGlobalMiddlewareExecuted(): void
+    {
+        $this->app['config']->set('graphql.resolver_middleware_append', [
+            GlobalMiddleware::class,
+        ]);
+        $result = GraphQL::queryAndReturnResult($this->queries['examples']);
+        self::assertSame(['examples' => [['test' => 'Intercepted by GlobalMiddleware']]], $result->data);
+    }
+
+    public function testFacadeGlobalMiddlewareExecuted(): void
+    {
+        GraphQL::appendGlobalResolverMiddleware(GlobalMiddleware::class);
+        $result = GraphQL::queryAndReturnResult($this->queries['examples']);
+        self::assertSame(['examples' => [['test' => 'Intercepted by GlobalMiddleware']]], $result->data);
+    }
+
+    public function testCanUseMiddlewareInstance(): void
+    {
+        GraphQL::appendGlobalResolverMiddleware(new GlobalInstanceMiddleware(0));
+        $result = GraphQL::queryAndReturnResult($this->queries['examplesWithVariables'], ['index' => 0]);
+        self::assertObjectHasProperty('errors', $result);
+        self::assertSame('Index is not allowed', $result->errors[0]->getMessage());
+    }
+}