$topics * * @return array> */ public function subscribeToTopics(array $topics, RegistrationTokens $tokens): array { $promises = []; $tokenStrings = $tokens->asStrings(); foreach ($topics as $topic) { $topicName = $topic->value(); $promises[$topicName] = $this->client ->requestAsync('POST', '/iid/v1:batchAdd', [ 'json' => [ 'to' => '/topics/'.$topicName, 'registration_tokens' => $tokenStrings, ], ]) ->then(static fn(ResponseInterface $response) => Json::decode((string) $response->getBody(), true)) ; } $responses = Utils::settle($promises)->wait(); $result = []; foreach ($responses as $topicName => $response) { $topicName = (string) $topicName; switch ($response['state']) { case 'fulfilled': $topicResults = []; foreach ($response['value']['results'] as $index => $tokenResult) { $token = $tokenStrings[$index]; if (empty($tokenResult)) { $topicResults[$token] = 'OK'; continue; } if (isset($tokenResult['error'])) { $topicResults[$token] = $tokenResult['error']; continue; } $topicResults[$token] = 'UNKNOWN'; } $result[$topicName] = $topicResults; break; case 'rejected': $result[$topicName] = $response['reason']->getMessage(); break; } } return $result; } /** * @param array $topics * * @return array> */ public function unsubscribeFromTopics(array $topics, RegistrationTokens $tokens): array { $promises = []; $tokenStrings = $tokens->asStrings(); foreach ($topics as $topic) { $topicName = $topic->value(); $promises[$topicName] = $this->client ->requestAsync('POST', '/iid/v1:batchRemove', [ 'json' => [ 'to' => '/topics/'.$topicName, 'registration_tokens' => $tokenStrings, ], ]) ->then(static fn(ResponseInterface $response) => Json::decode((string) $response->getBody(), true)) ; } $responses = Utils::settle($promises)->wait(); $result = []; foreach ($responses as $topicName => $response) { $topicName = (string) $topicName; switch ($response['state']) { case 'fulfilled': $topicResults = []; foreach ($response['value']['results'] as $index => $tokenResult) { $token = $tokenStrings[$index]; if (empty($tokenResult)) { $topicResults[$token] = 'OK'; continue; } if (isset($tokenResult['error'])) { $topicResults[$token] = (string) $tokenResult['error']; continue; } $topicResults[$token] = 'UNKNOWN'; } $result[$topicName] = $topicResults; break; case 'rejected': $result[$topicName] = $response['reason']->getMessage(); break; } } return $result; } public function getAppInstanceAsync(RegistrationToken $registrationToken): PromiseInterface { return $this->client ->requestAsync('GET', '/iid/'.$registrationToken->value().'?details=true') ->then(static function (ResponseInterface $response) use ($registrationToken) { $data = Json::decode((string) $response->getBody(), true); return AppInstance::fromRawData($registrationToken, $data); }) ->otherwise(fn(Throwable $e) => Create::rejectionFor($this->errorHandler->convertException($e))) ; } /** * @throws MessagingException */ public function getAppInstance(RegistrationToken $registrationToken): AppInstance { try { $response = $this->client->request('GET', '/iid/'.$registrationToken->value().'?details=true'); } catch (Throwable $e) { throw $this->errorHandler->convertException($e); } try { $data = Json::decode((string) $response->getBody(), true); } catch (Throwable $e) { throw $this->errorHandler->convertException($e); } return AppInstance::fromRawData($registrationToken, $data); } }