[RSDK-9165] Stop sessions when unimplemented received (#399)

viamrobotics · Oct 30, 2024 · 3aeb2eb · 3aeb2eb
1 parent 7ef6879
commit 3aeb2eb
Showing 1 changed file with 10 additions and 2 deletions.
diff --git a/src/robot/session-manager.ts b/src/robot/session-manager.ts
@@ -1,7 +1,7 @@
 import {
   Code,
   ConnectError,
-  createPromiseClient,
+  createClient,
   type Transport,
 } from '@connectrpc/connect';
 import { RobotService } from '../gen/robot/v1/robot_connect';
@@ -32,7 +32,7 @@ export default class SessionManager {
 
   private get client() {
     const transport = this.deferredTransport();
-    return createPromiseClient(RobotService, transport);
+    return createClient(RobotService, transport);
   }
 
   constructor(private deferredTransport: () => Transport) {
@@ -78,6 +78,14 @@ export default class SessionManager {
       try {
         await this.client.sendSessionHeartbeat(sendHeartbeatReq);
       } catch (error) {
+        if (
+          error instanceof ConnectError &&
+          error.code === Code.Unimplemented
+        ) {
+          console.error('sessions unsupported; will not try again'); // eslint-disable-line no-console
+          this.sessionsSupported = false;
+          return;
+        }
         if (
           error instanceof ConnectionClosedError ||
           (error instanceof ConnectError && error.rawMessage === 'closed')