--wip-- [skip ci]

Author: nkaradzhov

packages/client/lib/client/enterprise-maintenance-manager.ts

@@ -21,6 +21,7 @@ const PN = {
   FAILING_OVER: "FAILING_OVER",
   FAILED_OVER: "FAILED_OVER",
   SMIGRATING: "SMIGRATING",
+  SMIGRATED: "SMIGRATED",
 };
 
 export type DiagnosticsEvent = {
@@ -56,6 +57,7 @@ interface Client {
   connect: () => Promise<Client>;
   destroy: () => void;
   on: (event: string, callback: (value: unknown) => void) => void;
+  emit: (event: string, ...args: Array<unknown>) => void;
 }
 
 export default class EnterpriseMaintenanceManager {
@@ -165,6 +167,11 @@ export default class EnterpriseMaintenanceManager {
         this.#onMigrated();
         return true;
       }
+      case PN.SMIGRATED: {
+        dbgMaintenance("Received SMIGRATED");
+        this.#onSMigrated();
+        return true;
+      }
     }
     return false;
   };
@@ -301,6 +308,10 @@ export default class EnterpriseMaintenanceManager {
 
     this.#client._maintenanceUpdate(update);
   };
+
+  #onSMigrated = () => {
+    this.#client.emit('__MOVED', this.#commandsQueue.removeAllPubSubListeners());
+  }
 }
 
 export type MovingEndpointType =