Merge pull request #4 from mailsvb/fixClose

destroy open connections on close()

Author: mailsvb

lib/jsftpd.js

@@ -77,6 +77,9 @@ class ftpd {
             }
         }
 
+        this.lastSocketKey = 0
+        this.openSockets = {}
+
         // setup FTP on TCP
         this._tcp = net.createServer()
         this._tcp.on('connection', (socket) => this.Handler(this, socket))
@@ -98,6 +101,7 @@ class ftpd {
     }
 
     stop () {
+        Object.keys(this.openSockets).forEach((socketKey) => this.openSockets[socketKey].destroy())
         this._tcp.close()
         this._useTLS && this._tls.close()
     }
@@ -125,6 +129,8 @@ class ftpd {
     Handler (main, socket) {
         const connectionInfo = `[${socket.remoteAddress.replace(/::ffff:/g, '')}] [${socket.remotePort}]`
         const localAddr = socket.localAddress.replace(/::ffff:/g, '')
+        const socketKey = ++main.lastSocketKey
+        main.openSockets[socketKey] = socket
         let authenticated = false
         let isSecure = socket.encrypted || false
         let protection = false
@@ -176,6 +182,7 @@ class ftpd {
         socket.on('data', dataHandler)
         socket.on('error', main.ErrorHandler)
         socket.on('close', () => {
+            delete main.openSockets[socketKey]
             main.DebugHandler(`${connectionInfo} FTP connection closed`)
             if (ftpData) {
                 ftpData.close()