End connection

Author: Cyclonecode

scripts/delete.js

@@ -15,6 +15,6 @@ connection.connect((err) => {
       throw err;
     }
     logger.info('Removed ' + result.affectedRows + ' record(s)');
-    process.exit(0);
   });
+  connection.end();
 });

scripts/insert.js

@@ -19,6 +19,6 @@ connection.connect((err) => {
       throw err;
     }
     logger.info('Inserted ' + result.affectedRows + ' record(s)');
-    process.exit(0);
   });
+  connection.end();
 });

scripts/select.js

@@ -21,6 +21,6 @@ connection.connect((err) => {
     for (let i = 0; i < result.length; i++) {
       logger.info('', result[i]);
     }
-    process.exit(0);
   });
+  connection.end();
 });

scripts/server.js

@@ -147,6 +147,8 @@ wsServer.on('request', (request) => {
   });
   connection.on('close', (reasonCode, description) => {
     const index = connections.indexOf(this);
+    // TODO: Do we need to close the connection
+    // connections[index].close();
     connections.splice(index, 1);
     logger.debug(
       new Date() + ' Peer ' + connection.remoteAddress + ' disconnected.',

scripts/update.js

@@ -37,6 +37,6 @@ connection.connect((err) => {
       throw err;
     }
     logger.info('Updated ' + result.affectedRows + ' record(s)');
-    process.exit(0);
   });
+  connection.end();
 });