Vendor

2021-06-01 19:55:55 +02:00
parent 052cbe3038
commit d8c489c714
328 changed files with 36645 additions and 0 deletions
@@ -0,0 +1,136 @@
+<?php
+
+namespace Nuwave\Lighthouse\Subscriptions;
+
+use Illuminate\Http\Request;
+use Nuwave\Lighthouse\GraphQL;
+use Symfony\Component\HttpFoundation\Response;
+use Nuwave\Lighthouse\Schema\Types\GraphQLSubscription;
+use Illuminate\Contracts\Events\Dispatcher as EventsDispatcher;
+use Nuwave\Lighthouse\Subscriptions\Contracts\SubscriptionIterator;
+use Nuwave\Lighthouse\Subscriptions\Contracts\AuthorizesSubscriptions;
+use Nuwave\Lighthouse\Subscriptions\Contracts\BroadcastsSubscriptions;
+use Nuwave\Lighthouse\Subscriptions\Events\BroadcastSubscriptionEvent;
+
+class SubscriptionBroadcaster implements BroadcastsSubscriptions
+{
+    /**
+     * @var \Nuwave\Lighthouse\GraphQL
+     */
+    protected $graphQL;
+
+    /**
+     * @var \Nuwave\Lighthouse\Subscriptions\Contracts\AuthorizesSubscriptions
+     */
+    protected $auth;
+
+    /**
+     * @var \Nuwave\Lighthouse\Subscriptions\StorageManager
+     */
+    protected $storage;
+
+    /**
+     * @var \Nuwave\Lighthouse\Subscriptions\Contracts\SubscriptionIterator
+     */
+    protected $iterator;
+
+    /**
+     * @var \Nuwave\Lighthouse\Subscriptions\BroadcastManager
+     */
+    protected $broadcastManager;
+
+    /**
+     * @var \Illuminate\Contracts\Events\Dispatcher
+     */
+    protected $eventsDispatcher;
+
+    /**
+     * @param  \Nuwave\Lighthouse\GraphQL  $graphQL
+     * @param  \Nuwave\Lighthouse\Subscriptions\Contracts\AuthorizesSubscriptions  $auth
+     * @param  \Nuwave\Lighthouse\Subscriptions\StorageManager  $storage
+     * @param  \Nuwave\Lighthouse\Subscriptions\Contracts\SubscriptionIterator  $iterator
+     * @param  \Nuwave\Lighthouse\Subscriptions\BroadcastManager  $broadcastManager
+     * @param  \Illuminate\Contracts\Events\Dispatcher  $eventsDispatcher
+     * @return void
+     */
+    public function __construct(
+        GraphQL $graphQL,
+        AuthorizesSubscriptions $auth,
+        StorageManager $storage,
+        SubscriptionIterator $iterator,
+        BroadcastManager $broadcastManager,
+        EventsDispatcher $eventsDispatcher
+    ) {
+        $this->graphQL = $graphQL;
+        $this->auth = $auth;
+        $this->storage = $storage;
+        $this->iterator = $iterator;
+        $this->broadcastManager = $broadcastManager;
+        $this->eventsDispatcher = $eventsDispatcher;
+    }
+
+    /**
+     * Queue pushing subscription data to subscribers.
+     *
+     * @param  \Nuwave\Lighthouse\Schema\Types\GraphQLSubscription  $subscription
+     * @param  string  $fieldName
+     * @param  mixed  $root
+     * @return void
+     */
+    public function queueBroadcast(GraphQLSubscription $subscription, string $fieldName, $root): void
+    {
+        $this->eventsDispatcher->dispatch(
+            new BroadcastSubscriptionEvent($subscription, $fieldName, $root)
+        );
+    }
+
+    /**
+     * Push subscription data to subscribers.
+     *
+     * @param  \Nuwave\Lighthouse\Schema\Types\GraphQLSubscription  $subscription
+     * @param  string  $fieldName
+     * @param  mixed  $root
+     * @return void
+     */
+    public function broadcast(GraphQLSubscription $subscription, string $fieldName, $root): void
+    {
+        $topic = $subscription->decodeTopic($fieldName, $root);
+
+        $subscribers = $this->storage
+            ->subscribersByTopic($topic)
+            ->filter(function (Subscriber $subscriber) use ($subscription, $root): bool {
+                return $subscription->filter($subscriber, $root);
+            });
+
+        $this->iterator->process(
+            $subscribers,
+            function (Subscriber $subscriber) use ($root): void {
+                $data = $this->graphQL->executeQuery(
+                    $subscriber->query,
+                    $subscriber->context,
+                    $subscriber->args,
+                    $subscriber->setRoot($root),
+                    $subscriber->operationName
+                );
+
+                $this->broadcastManager->broadcast(
+                    $subscriber,
+                    $data->jsonSerialize()
+                );
+            }
+        );
+    }
+
+    /**
+     * Authorize the subscription.
+     *
+     * @param  \Illuminate\Http\Request  $request
+     * @return \Symfony\Component\HttpFoundation\Response
+     */
+    public function authorize(Request $request): Response
+    {
+        return $this->auth->authorize($request)
+            ? $this->broadcastManager->authorized($request)
+            : $this->broadcastManager->unauthorized($request);
+    }
+}