Add concurrent request to FcmV1

Author: dragermrb

src/Config/config.php

@@ -26,6 +26,7 @@
         'dry_run' => false,
         'projectId' => 'my-project-id',
         'jsonFile' => __DIR__ . '/fcmCertificates/file.json',
+        // 'concurrentRequests' => 5, // Optional, default 10
         // Optional: Default Guzzle request options for each FCM request
         // See https://docs.guzzlephp.org/en/stable/request-options.html
         'guzzle' => [],

src/FcmV1.php

@@ -8,16 +8,28 @@
 use Google\Client as GoogleClient;
 use Google\Service\FirebaseCloudMessaging;
 use GuzzleHttp\Client;
-use GuzzleHttp\Exception\ClientException;
+use GuzzleHttp\Exception\RequestException;
+use GuzzleHttp\Pool;
+use GuzzleHttp\Psr7\Request;
+use GuzzleHttp\Psr7\Response as GuzzleResponse;
 use Illuminate\Support\Facades\Cache;
 use Illuminate\Support\Str;
 
 class FcmV1 extends Fcm
 {
     const CACHE_SECONDS = 55 * 60; // 55 minutes
 
+    /**
+     * Number of concurrent requests to multiplex in the same connection.
+     *
+     * @var int
+     */
+    protected $concurrentRequests = 10;
+
     protected $unregisteredDeviceTokens = [];
 
+    protected $feedbacks = [];
+
     /**
      * Fcm constructor.
      * Override parent constructor.
@@ -29,6 +41,8 @@ public function __construct()
         $this->url = 'https://fcm.googleapis.com/v1/projects/' . $this->config['projectId'] . '/messages:send';
 
         $this->client = new Client($this->config['guzzle'] ?? []);
+
+        $this->concurrentRequests = $this->config['concurrentRequests'] ?? 10;
     }
 
     /**
@@ -88,45 +102,51 @@ public function send(array $deviceTokens, array $message)
         $headers = $this->addRequestHeaders();
         $jsonData = ['message' => $this->buildMessage($message)];
 
-        $feedbacks = [];
+        $this->feedbacks = [];
         $this->unregisteredDeviceTokens = [];
 
+        $requests = [];
         foreach ($deviceTokens as $deviceToken) {
-            try {
-                $jsonData['message']['token'] = $deviceToken;
+            $jsonData['message']['token'] = $deviceToken;
 
-                $result = $this->client->post(
-                    $this->url,
-                    [
-                        'headers' => $headers,
-                        'json' => $jsonData,
-                    ]
-                );
+            $body = json_encode($jsonData);
+
+            $requests[$deviceToken] = new Request('POST', $this->url, $headers, $body);
+        }
 
-                $json = $result->getBody();
+        $pool = new Pool($this->client, $requests, [
+            'concurrency' => $this->concurrentRequests,
+            'fulfilled' => function (GuzzleResponse $response, $deviceToken) {
+                // this is delivered each successful response
 
-                $feedbacks[$deviceToken] = [
+                $this->feedbacks[$deviceToken] = [
                     'success' => true,
-                    'response' => json_decode($json, true, 512, JSON_BIGINT_AS_STRING),
-                ];
-            } catch (ClientException $e) {
-                $feedbacks[$deviceToken] = [
-                    'success' => false,
-                    'error' => json_decode($e->getResponse()->getBody()->getContents(), true),
+                    'response' => json_decode((string) $response->getBody(), true, 512, JSON_BIGINT_AS_STRING),
                 ];
+            },
+            'rejected' => function (RequestException $reason, $deviceToken) {
+                // this is delivered each failed request
 
-                $this->unregisteredDeviceTokens[] = $deviceToken;
-            } catch (\Exception $e) {
-                $feedbacks[$deviceToken] = [
+                $error = json_decode((string) $reason->getResponse()->getBody(), true);
+
+                $this->feedbacks[$deviceToken] = [
                     'success' => false,
-                    'error' => $e->getMessage(),
+                    'error' => $error,
                 ];
 
-                $this->unregisteredDeviceTokens[] = $deviceToken;
-            }
-        }
+                if (isset($error['error']['status']) && $error['error']['status'] === 'INVALID_ARGUMENT') {
+                    $this->unregisteredDeviceTokens[] = $deviceToken;
+                }
+            },
+        ]);
+
+        // Initiate the transfers and create a promise
+        $promise = $pool->promise();
+
+        // Force the pool of requests to complete.
+        $promise->wait();
 
-        $this->setFeedback($feedbacks);
+        $this->setFeedback($this->feedbacks);
     }
 
     /**