remove logs

Author: nkaradzhov

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

@@ -152,7 +152,6 @@ export default class RedisCommandsQueue {
     if (this.#maxLength && this.#toWrite.length + this.#waitingForReply.length >= this.#maxLength) {
       return Promise.reject(new Error('The queue is full'));
     } else if (options?.abortSignal?.aborted) {
-      console.log('eeeeeeeee', args)
       return Promise.reject(new AbortError());
     }
 
@@ -171,12 +170,10 @@ export default class RedisCommandsQueue {
 
       const timeout = options?.timeout;
       if (timeout) {
-        console.log('set timeout', timeout);
         const signal = AbortSignal.timeout(timeout);
         value.timeout = {
           signal,
           listener: () => {
-            console.log('TIMEOUT OCCURRED', node);
             this.#toWrite.remove(node);
             value.reject(new TimeoutError());
           }
@@ -186,11 +183,9 @@ export default class RedisCommandsQueue {
 
       const signal = options?.abortSignal;
       if (signal) {
-        console.log('signal', signal)
         value.abort = {
           signal,
           listener: () => {
-            console.log('ABORT OCCURRED', node);
             this.#toWrite.remove(node);
             value.reject(new AbortError());
           }

packages/client/lib/client/index.ts

@@ -526,7 +526,7 @@ export default class RedisClient<
   async #handshake(chainId: symbol, asap: boolean) {
     const promises = [];
     const commandsWithErrorHandlers = await this.#getHandshakeCommands();
-    
+
     if (asap) commandsWithErrorHandlers.reverse()
 
     for (const { cmd, errorHandler } of commandsWithErrorHandlers) {
@@ -632,7 +632,7 @@ export default class RedisClient<
           // since they could be connected to an older version that doesn't support them.
         }
       });
-      
+
       commands.push({
         cmd: [
           'CLIENT',
@@ -889,7 +889,6 @@ export default class RedisClient<
       return Promise.reject(new ClientOfflineError());
     }
 
-    console.log('sendCommand', args, options)
     const promise = this._self.#queue.addCommand<T>(args, options);
     this._self.#scheduleWrite();
     return promise;