fix: add streaming call

momentohq · Jan 3, 2024 · c810d8f · c810d8f
1 parent 2512bab
commit c810d8f
Showing 1 changed file with 7 additions and 1 deletion.
diff --git a/src/Topic/Internal/ScsTopicClient.php b/src/Topic/Internal/ScsTopicClient.php
@@ -39,9 +39,11 @@ class ScsTopicClient implements LoggerAwareInterface
     private TopicGrpcManager $grpcManager;
     private LoggerInterface $logger;
     private int $timeout;
+    private $authToken;
 
     public function __construct(IConfiguration $configuration, ICredentialProvider $authProvider)
     {
+        $authToken = $authProvider->getAuthToken();
         $operationTimeoutMs = $configuration
             ->getTransportStrategy()
             ->getGrpcConfig()
@@ -146,11 +148,15 @@ public function subscribe(string $cacheName, string $topicName, callable $onMess
 
         try {
             validateCacheName($cacheName);
+
+            $authToken = $this->authToken;
+
+
             $request = new _SubscriptionRequest();
             $request->setCacheName($cacheName);
             $request->setTopic($topicName);
 
-            $call = $this->grpcManager->client->Subscribe($request);
+            $call = $this->grpcManager->client->Subscribe($request, ['authorization' => ['Bearer ' . $authToken]]);
             $this->processStreamingCall($call);
 
             foreach ($call->responses() as $response) {