conn.on('error')

local.js

@@ -82,22 +82,29 @@ var server = net.createServer(async (conn) => {
   let addrToSend = '';
   const aServer = getServer();
 
-  await new Promise((resolve, reject) => {
-    conn.once('readable', resolve);
-  });
+  conn.on('error', (err) => console.error(`local: ${err}`));
 
-  // handshake
   let data = await conn.read();
+  while (!data) {
+    await new Promise((resolve, reject) => {
+      conn.once('readable', resolve);
+    });
+    data = await conn.read();
+  }
+  // handshake
   conn.write(Buffer.from([5, 0]));
 
   const nextCmd = data.indexOf(5, 1);
   if (nextCmd !== -1) {
     data = data.subarray(nextCmd);
   } else {
-    await new Promise((resolve, reject) => {
-      conn.once('readable', resolve);
-    });
     data = await conn.read();
+    while (!data) {
+      await new Promise((resolve, reject) => {
+        conn.once('readable', resolve);
+      });
+      data = await conn.read();
+    }
   }
   // +----+-----+-------+------+----------+----------+
   // |VER | CMD |  RSV  | ATYP | DST.ADDR | DST.PORT |
@@ -191,6 +198,8 @@ var server = net.createServer(async (conn) => {
     });
   }
 
+  ws.on('error', (err) => console.error(`local: ${err}`));
+
   const wss = createWebSocketStream(ws);
   console.log(`connecting ${remoteAddr} via ${aServer}`);
 

server.js

@@ -64,6 +64,8 @@ wsserver.on('connection', async (ws) => {
   let remoteAddr;
   let remotePort;
 
+  ws.on('error', (err) => console.error(`server: ${err}`));
+
   const conn = createWebSocketStream(ws);
   const readable = conn.pipe(
     createTransform(encryptor.decrypt.bind(encryptor)),
@@ -120,6 +122,9 @@ wsserver.on('connection', async (ws) => {
   }
 
   const remote = net.connect(remotePort, remoteAddr);
+
+  remote.on('error', (err) => console.error(`server: ${err}`));
+
   console.log('connecting', remoteAddr);
   if (data.length > headerLength) {
     remote.write(data.subarray(headerLength));