Merge pull request #88 from utopia-php/fix-fcm-expiry

Add index flag to map request to response order

Author: stnguyen90

src/Utopia/Messaging/Adapter.php

@@ -136,6 +136,7 @@ protected function request(
      * @param  array<string>  $headers
      * @param  array<array<string, mixed>>  $bodies
      * @return array<array{
+     *     index: int,
      *     url: string,
      *     statusCode: int,
      *     response: array<string, mixed>|null,
@@ -209,6 +210,7 @@ protected function requestMulti(
             \curl_setopt($ch, CURLOPT_URL, $urls[$i]);
             \curl_setopt($ch, CURLOPT_POSTFIELDS, $bodies[$i]);
             \curl_setopt($ch, CURLOPT_HTTPHEADER, $headers);
+            \curl_setopt($ch, CURLOPT_PRIVATE, $i);
             \curl_multi_add_handle($mh, \curl_copy_handle($ch));
         }
 
@@ -236,6 +238,7 @@ protected function requestMulti(
             }
 
             $responses[] = [
+                'index' => (int)\curl_getinfo($ch, CURLINFO_PRIVATE),
                 'url' => \curl_getinfo($ch, CURLINFO_EFFECTIVE_URL),
                 'statusCode' => \curl_getinfo($ch, CURLINFO_RESPONSE_CODE),
                 'response' => $response,

src/Utopia/Messaging/Adapter/Push/FCM.php

@@ -139,18 +139,18 @@ protected function process(PushMessage $message): array
 
         $response = new Response($this->getType());
 
-        foreach ($results as $index => $result) {
+        foreach ($results as $result) {
             if ($result['statusCode'] === 200) {
                 $response->incrementDeliveredTo();
-                $response->addResult($message->getTo()[$index]);
+                $response->addResult($message->getTo()[$result['index']]);
             } else {
                 $error =
                     ($result['response']['error']['status'] ?? null) === 'UNREGISTERED'
                     || ($result['response']['error']['status'] ?? null) === 'NOT_FOUND'
                         ? $this->getExpiredErrorMessage()
                         : $result['response']['error']['message'] ?? 'Unknown error';
 
-                $response->addResult($message->getTo()[$index], $error);
+                $response->addResult($message->getTo()[$result['index']], $error);
             }
         }