remove logs

Author: nkaradzhov

packages/client/lib/client/commands-queue.ts

@@ -124,7 +124,6 @@ export default class RedisCommandsQueue {
       //TODO: we can shave off a few cycles by not adding onPush handler at all if CSC is not used
       onPush: push => {
         if (!this.#onPush(push)) {
-          console.log('Push received', push.toString());
           // currently only supporting "invalidate" over RESP3 push messages
           switch (push[0].toString()) {
             case "invalidate": {
@@ -140,7 +139,6 @@ export default class RedisCommandsQueue {
               break;
             }
             case 'MOVING': {
-              console.log('received moving', push)
               const [_, afterMs, url] = push;
               const [host, port] = url.toString().split(':');
               this.events.emit('moving', afterMs, host, Number(port))

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

@@ -35,31 +35,23 @@ export default class EnterpriseMaintenanceManager extends EventEmitter {
     port: number,
   ): Promise<void> => {
     // 1 [EVENT] MOVING PN received
-    console.log('[EnterpriseMaintenanceManager] Pausing client');
     // 2 [ACTION] Pause writing
     this.emit('pause')
 
-    console.log(`[EnterpriseMaintenanceManager] Creating new socket for ${host}:${port}`);
     const newSocket = new RedisSocket({
       ...this.options.socket,
       host,
       port,
     });
-    console.log('[EnterpriseMaintenanceManager] Connecting to new socket');
     await newSocket.connect();
     // 3 [EVENT] New socket connected
-    console.log('[EnterpriseMaintenanceManager] New socket connected');
 
     // Wait until waitingForReply is empty
-    console.log('[EnterpriseMaintenanceManager] Waiting for reply queue to empty');
     await new Promise<void>((resolve) => {
       if (!this.commandsQueue.isWaitingForReply()) {
-        console.log('[EnterpriseMaintenanceManager] Reply queue already empty');
         resolve();
       } else {
-        console.log('[EnterpriseMaintenanceManager] Reply queue not empty, waiting for empty event');
         this.commandsQueue.events.once("waitingForReplyEmpty", () => {
-          console.log('[EnterpriseMaintenanceManager] Reply queue now empty');
           resolve();
         });
       }

packages/client/lib/client/index.ts

@@ -750,7 +750,6 @@ export default class RedisClient<
       .on('drain', () => this.#maybeScheduleWrite())
       .on('end', () => this.emit('end'));
 
-    console.log('Initiator...');
     const promises = [];
     const chainId = Symbol('Socket Initiator');
 
@@ -786,7 +785,6 @@ export default class RedisClient<
     return new RedisSocket(options?.socket)
       .on('connect', () => this.emit('connect'))
       .on('ready', () => {
-        console.log('Socket ready');
         this.emit('ready');
       });
   }

packages/client/lib/client/socket.ts

@@ -213,7 +213,6 @@ export default class RedisSocket extends EventEmitter {
   }
 
   async #connect(): Promise<void> {
-    console.log('Connecting...');
     let retries = 0;
     do {
       try {
@@ -230,7 +229,6 @@ export default class RedisSocket extends EventEmitter {
         // }
         this.#isReady = true;
         this.#socketEpoch++;
-        console.log('Socket connected, emit ready');
         this.emit('ready');
       } catch (err) {
         const retryIn = this.#shouldReconnect(retries++, err as Error);
@@ -250,7 +248,6 @@ export default class RedisSocket extends EventEmitter {
 
     let onTimeout;
     if (this.#connectTimeout !== undefined) {
-      console.log('#connectTimeout',this.#connectTimeout)
       onTimeout = () => socket.destroy(new ConnectionTimeoutError());
       socket.once('timeout', onTimeout);
       socket.setTimeout(this.#connectTimeout);
@@ -267,7 +264,6 @@ export default class RedisSocket extends EventEmitter {
     }
 
     if (this.#socketTimeout) {
-      console.log('#socketTimeout',this.#socketTimeout)
       socket.once('timeout', () => {
         socket.destroy(new SocketTimeoutError(this.#socketTimeout!));
       });