fix: distribute: fix event listener leak on socket disconnect (#462)

Author: lawrence3699

server/distribute/import.js

@@ -38,9 +38,14 @@ const addUrl = currify((url, a) => `${url}: ${a}`);
 
 const rmListeners = wraptile((socket, listeners) => {
     socket.removeListener('connect', listeners.onConnect);
+    socket.removeListener('accept', listeners.onAccept);
     socket.removeListener('config', listeners.onConfig);
     socket.removeListener('error', listeners.onError);
-    socket.removeListener('connection_error', listeners.onError);
+    socket.removeListener('connect_error', listeners.onConnectError);
+    socket.removeListener('reject', listeners.onReject);
+    
+    if (listeners.onChange)
+        socket.removeListener('change', listeners.onChange);
 });
 
 const canceled = (f) => f(null, {
@@ -106,25 +111,28 @@ export const distributeImport = (config, options, fn) => {
 
     const onConnect = emitAuth(importUrl, config, socket);
     const onAccept = logWrapped(isLog, importStr, `${connectedStr} to ${colorUrl}`);
+    const onChange = squad(logWrapped(isLog, importStr), config);
+    
+    const onReject = squad(superFn('reject'), logWrapped(
+        isLog,
+        importStr,
+        tokenRejectedStr,
+    ));
 
     const onDisconnect = squad(...[
         done(fn, statusStore),
         logWrapped(isLog, importStr, `${disconnectedStr} from ${colorUrl}`),
         rmListeners(socket, {
-            onError,
             onConnect,
+            onAccept,
             onConfig,
+            onError,
+            onConnectError,
+            onReject,
+            onChange,
         }),
     ]);
 
-    const onChange = squad(logWrapped(isLog, importStr), config);
-    
-    const onReject = squad(superFn('reject'), logWrapped(
-        isLog,
-        importStr,
-        tokenRejectedStr,
-    ));
-    
     socket.on('connect', onConnect);
     socket.on('accept', onAccept);
     socket.on('disconnect', onDisconnect);