fix: align broker api routes

snyk · Jan 31, 2025 · 367564e · 367564e
1 parent 62306ae
commit 367564e
Show file tree

Hide file tree

Showing 4 changed files with 7 additions and 9 deletions.
diff --git a/lib/client/auth/brokerServerConnection.ts b/lib/client/auth/brokerServerConnection.ts
@@ -18,7 +18,7 @@ export const renewBrokerServerConnection = async (
   brokerServerConnectionParams: BrokerServerConnectionParams,
 ): Promise<HttpResponse> => {
   const clientConfig = getConfig();
-  const apiHostname = clientConfig.API_BASE_URL;
+  const apiHostname = clientConfig.apiHostname;
   const body = {
     data: {
       type: 'broker_connection',

diff --git a/lib/client/socket.ts b/lib/client/socket.ts
@@ -140,8 +140,6 @@ export const createWebSocket = (
     pong: parseInt(localClientOps.config.socketPongTimeout) || 10000,
     timeout: parseInt(localClientOps.config.socketConnectTimeout) || 10000,
   };
-  console.log('@@@@@@@@@@@@@@@@@@@@@2');
-  console.log(clientOpts.accessToken?.authHeader);
   if (clientOpts.accessToken && clientOpts.config.UNIVERSAL_BROKER_GA) {
     socketSettings['transport'] = {
       extraHeaders: {
@@ -281,10 +279,10 @@ export const createWebSocket = (
   });
 
   websocket.on('close', () => {
-    if (websocket.timeoutHandlerId) {
-      logger.debug({}, `Clearing ${maskToken(websocket.identifier)} timers.`);
-      clearTimeout(websocket.timeoutHandlerId);
-    }
+    // if (websocket.timeoutHandlerId) {
+    //   logger.debug({}, `Clearing ${maskToken(websocket.identifier)} timers.`);
+    //   clearTimeout(websocket.timeoutHandlerId);
+    // }
     closeHandler(localClientOps, identifyingMetadata);
   });
 

diff --git a/lib/hybrid-sdk/http/downstream-post-stream-to-server.ts b/lib/hybrid-sdk/http/downstream-post-stream-to-server.ts
@@ -66,7 +66,7 @@ class BrokerServerPostResponseHandler {
     try {
       const backendHostname =
         this.#config.universalBrokerEnabled && this.#config.universalBrokerGa
-          ? `${this.#config.apiHostname}/hidden/broker`
+          ? `${this.#config.apiHostname}/hidden/brokers`
           : this.#config.brokerServerUrl;
       const url = new URL(
         `${backendHostname}/response-data/${this.#brokerToken}/${

diff --git a/lib/server/index.ts b/lib/server/index.ts
@@ -72,7 +72,7 @@ export const main = async (serverOpts: ServerOpts) => {
       authRefreshHandler,
     );
     app.post(
-      '/hidden/broker/response-data/:brokerToken/:streamingId',
+      '/hidden/brokers/response-data/:brokerToken/:streamingId',
       handlePostResponse,
     );