feat: add delegated errors reporter

Author: vuongxuongminh

src/DelegatedErrorsReporterInterface.php

@@ -0,0 +1,16 @@
+<?php
+
+declare(strict_types=1);
+
+namespace XGraphQL\DelegateExecution;
+
+use GraphQL\Error\Error;
+
+interface DelegatedErrorsReporterInterface
+{
+    /**
+     * @param Error[] $errors
+     * @return void
+     */
+    public function reportErrors(array $errors): void;
+}

src/Execution.php

@@ -8,13 +8,16 @@
 
 final class Execution
 {
-    public static function delegate(Schema $schema, ExecutionDelegatorInterface $delegator): void
-    {
+    public static function delegate(
+        Schema $schema,
+        ExecutionDelegatorInterface $delegator,
+        DelegatedErrorsReporterInterface $errorsReporter = null,
+    ): void {
         foreach (['query', 'mutation', 'subscription'] as $operation) {
             $rootType = $schema->getOperationType($operation);
 
             if (null !== $rootType) {
-                $rootType->resolveFieldFn = new RootFieldsResolver($delegator);
+                $rootType->resolveFieldFn = new RootFieldsResolver($delegator, $errorsReporter);
             }
         }
     }

src/RootFieldsResolver.php

@@ -25,8 +25,10 @@ final class RootFieldsResolver
      */
     private \WeakMap $delegatedPromises;
 
-    public function __construct(private readonly ExecutionDelegatorInterface $delegator)
-    {
+    public function __construct(
+        private readonly ExecutionDelegatorInterface $delegator,
+        private readonly ?DelegatedErrorsReporterInterface $delegatedErrorsReporter = null,
+    ) {
         $this->delegatedPromises = new \WeakMap();
     }
 
@@ -41,7 +43,22 @@ public function __invoke(mixed $value, array $arguments, mixed $context, Resolve
             SelectionSet::addTypename($operation->getSelectionSet());
             SelectionSet::addTypenameToFragments($fragments);
 
-            $this->delegatedPromises[$info->operation] = $this->delegator->delegate($info->schema, $operation, $fragments, $info->variableValues);
+            $this->delegatedPromises[$info->operation] = $this
+                ->delegator
+                ->delegate(
+                    $info->schema,
+                    $operation,
+                    $fragments,
+                    $info->variableValues
+                )->then(
+                    function (ExecutionResult $result): ExecutionResult {
+                        if ([] !== $result->errors) {
+                            $this->delegatedErrorsReporter?->reportErrors($result->errors);
+                        }
+
+                        return $result;
+                    }
+                );
         }
 
         return $this->resolve($info);