fix: make string from buffer

Author: nkaradzhov

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

@@ -6,7 +6,7 @@ import { RedisArgument } from "../..";
 import { isIP } from "net";
 import { lookup } from "dns/promises";
 import assert from "node:assert";
-import { setTimeout } from 'node:timers/promises'
+import { setTimeout } from "node:timers/promises";
 
 export const MAINTENANCE_EVENTS = {
   PAUSE_WRITING: "pause-writing",
@@ -90,13 +90,13 @@ export default class EnterpriseMaintenanceManager extends EventEmitter {
   }
 
   #onPush = (push: Array<any>): boolean => {
-    dbgMaintenance(push);
+    dbgMaintenance("ONPUSH:", push.map(String));
     switch (push[0].toString()) {
       case PN.MOVING: {
         // [ 'MOVING', '17', '15', '54.78.247.156:12075' ]
         //             ^seq   ^after    ^new ip
         const afterSeconds = push[2];
-        const url: string | null = push[3];
+        const url: string | null = push[3] ? String(push[3]) : null;
         dbgMaintenance("Received MOVING:", afterSeconds, url);
         this.#onMoving(afterSeconds, url);
         return true;
@@ -131,32 +131,32 @@ export default class EnterpriseMaintenanceManager extends EventEmitter {
   //  6. [ACTION] Resume writing -> we are going to write to the new socket from now on
   #onMoving = async (
     afterSeconds: number,
-    url: string | null
+    url: string | null,
   ): Promise<void> => {
     // 1 [EVENT] MOVING PN received
     this.#onMigrating();
 
-    let host: string
-    let port: number
+    let host: string;
+    let port: number;
 
     // The special value `none` indicates that the `MOVING` message doesn’t need
     // to contain an endpoint. Instead it contains the value `null` then. In
     // such a corner case, the client is expected to schedule a graceful
     // reconnect to its currently configured endpoint after half of the grace
     // period that was communicated by the server is over.
-    if(url === null) {
-      assert(this.#options.maintMovingEndpointType === 'none');
-      assert(this.#options.socket !== undefined)
-      assert('host' in this.#options.socket)
-      assert(typeof this.#options.socket.host === 'string')
-      host = this.#options.socket.host
-      assert(typeof this.#options.socket.port === 'number')
-      port = this.#options.socket.port
-      const waitTime = afterSeconds * 1000 / 2;
+    if (url === null) {
+      assert(this.#options.maintMovingEndpointType === "none");
+      assert(this.#options.socket !== undefined);
+      assert("host" in this.#options.socket);
+      assert(typeof this.#options.socket.host === "string");
+      host = this.#options.socket.host;
+      assert(typeof this.#options.socket.port === "number");
+      port = this.#options.socket.port;
+      const waitTime = (afterSeconds * 1000) / 2;
       dbgMaintenance(`Wait for ${waitTime}ms`);
       await setTimeout(waitTime);
     } else {
-      const split = url.split(':');
+      const split = url.split(":");
       host = split[0];
       port = Number(split[1]);
     }
@@ -262,7 +262,9 @@ async function determineEndpoint(
 ): Promise<MovingEndpointType> {
   assert(options.maintMovingEndpointType !== undefined);
   if (options.maintMovingEndpointType !== "auto") {
-    dbgMaintenance(`Determine endpoint type: ${options.maintMovingEndpointType}`);
+    dbgMaintenance(
+      `Determine endpoint type: ${options.maintMovingEndpointType}`,
+    );
     return options.maintMovingEndpointType;
   }