Ignore prematurely closed sockets

vweevers · vweevers · commit 362f407b90aa · 2020-09-20T19:53:38.000+02:00
diff --git a/lib/proxy-server.js b/lib/proxy-server.js
@@ -30,9 +30,13 @@ module.exports = class ProxyServer extends Nanoresource {
 
     this[kServer].on('request', onRequest(proxy.web.bind(proxy)))
     this[kServer].on('upgrade', onRequest(proxy.ws.bind(proxy)))
+    this[kServer].on('error', ignorePrematureClose)
 
     enableDestroy(this[kServer])
+
     proxy.on('proxyReq', onProxyReq)
+    proxy.on('error', ignorePrematureClose)
+    proxy.onError = ignorePrematureClose
 
     function onProxyReq (proxyReq, req, res, options) {
       proxyReq.setHeader('x-airtap-context-id', cid)
@@ -85,6 +89,14 @@ module.exports = class ProxyServer extends Nanoresource {
   }
 }
 
+function ignorePrematureClose (err) {
+  if (err.code === 'ECONNRESET') {
+    debug('Socket closed prematurely')
+  } else {
+    throw err
+  }
+}
+
 function maybeLookup (hostname, opts, callback) {
   if (hostname === ip) {
     process.nextTick(callback, null, ip)
