From 1b96f430e8d0320f6d416d77f828ff02a0c52da3 Mon Sep 17 00:00:00 2001
From: Sambo Chea <sombochea@cubetiqs.com>
Date: Sat, 9 Jul 2022 12:27:28 +0700
Subject: [PATCH] Updated tunnel response and request

---
 lib.js | 10 ++--------
 1 file changed, 2 insertions(+), 8 deletions(-)

diff --git a/lib.js b/lib.js
index 366d8dd..761177d 100644
--- a/lib.js
+++ b/lib.js
@@ -7,14 +7,12 @@ class TunnelRequest extends stream.Readable {
     this._requestId = requestId;
 
     const onRequestPipe = (requestId, data) => {
-      console.log("Res pipe size", data.length);
       if (this._requestId === requestId) {
         this.push(data);
       }
     };
 
     const onRequestPipes = (requestId, data) => {
-      // console.log("Res pipes size", data.length)
       if (this._requestId === requestId) {
         data.forEach((chunk) => {
           this.push(chunk);
@@ -51,7 +49,7 @@ class TunnelRequest extends stream.Readable {
     this._socket.on("request-pipe-end", onRequestPipeEnd);
   }
 
-  _read() {}
+  _read() { }
 }
 
 class TunnelResponse extends stream.Duplex {
@@ -63,7 +61,6 @@ class TunnelResponse extends stream.Duplex {
     if (duplex) {
       // for websocket request： bidirection
       const onResponsePipe = (responseId, data) => {
-        console.log("Res pipe: ", data.toString());
         if (this._responseId === responseId) {
           this.push(data);
         }
@@ -108,16 +105,13 @@ class TunnelResponse extends stream.Duplex {
   }
 
   _write(chunk, encoding, callback) {
-    console.log("Res Write Chunk: ", chunk.length, encoding);
     this._socket.emit("response-pipe", this._responseId, chunk);
     this._socket.io.engine.once("drain", () => {
-      console.log("hello = ", "callback...")
       callback();
     });
   }
 
   _writev(chunks, callback) {
-    console.log("Res Write Chunks: ", chunks.length);
     this._socket.emit("response-pipes", this._responseId, chunks);
     this._socket.io.engine.once("drain", () => {
       callback();
@@ -155,7 +149,7 @@ class TunnelResponse extends stream.Duplex {
     });
   }
 
-  _read(size) {}
+  _read(size) { }
 }
 
 exports.TunnelRequest = TunnelRequest;