test-socket-sender-errors

lib/routes.js

@@ -29,15 +29,29 @@ const setupRoutes = function setupRoutes() {
   const events = ['build', 'done', 'invalid', 'progress'];
   const connect = async (ctx) => {
     if (ctx.ws) {
+      console.log('/wps handler');
       const socket = await ctx.ws();
 
-      const pingTimer = setInterval(() => socket.ping(), 30000);
+      const pingTimer = setInterval(() => {
+        try {
+          socket.ping();
+        } catch (error) {
+          console.log('socket ping error', error);
+        }
+      }, 30000);
 
       const send = (data) => {
+        console.log('sending', data);
         if (socket.readyState !== 1) {
           return;
         }
-        socket.send(data);
+
+        try {
+          socket.send(data);
+        } catch (error) {
+          console.log('socket send error', error);
+        }
+        console.log('sent', data);
       };
 
       socket.build = (compilerName = '<unknown>', { wpsId }) => {
@@ -83,7 +97,8 @@ const setupRoutes = function setupRoutes() {
 
       socket.invalid = (filePath = '<unknown>', compiler) => {
         const context = compiler.context || compiler.options.context || process.cwd();
-        const fileName = (filePath && filePath.replace && filePath.replace(context, '')) || filePath;
+        const fileName =
+          (filePath && filePath.replace && filePath.replace(context, '')) || filePath;
         const { wpsId } = compiler;
 
         send(prep({ action: 'invalid', data: { fileName, wpsId } }));
@@ -105,7 +120,12 @@ const setupRoutes = function setupRoutes() {
       // onto the client via the socket
       const unhandled = ({ eventName, data }) => send(prep({ action: eventName, data }));
       this.on('unhandled', unhandled);
+      socket.on('error', (error) => {
+        console.trace();
+        console.error('socket error', error);
+      });
       socket.on('close', () => {
+        console.log('socket closed');
         clearInterval(pingTimer);
         this.off('unhandled', unhandled);
       });