socket.io integration, reload connection list after change

api/src/controllers/connections.js

@@ -5,9 +5,11 @@ const express = require('express');
 const router = express.Router();
 const { fork } = require('child_process');
 const _ = require('lodash');
-const datadir = require('../utility/datadir');
 const nedb = require('nedb-promises');
 
+const datadir = require('../utility/datadir');
+const socket = require('../utility/socket');
+
 module.exports = {
   datastore: null,
   async _init() {
@@ -32,15 +34,20 @@ module.exports = {
 
   save_meta: 'post',
   async save(connection) {
+    let res;
     if (connection._id) {
-      return await this.datastore.update(_.pick(connection, '_id'), connection);
+      res = await this.datastore.update(_.pick(connection, '_id'), connection);
     } else {
-      return await this.datastore.insert(connection);
+      res = await this.datastore.insert(connection);
     }
+    socket.emit('connection-list-changed');
+    return res;
   },
 
   delete_meta: 'post',
   async delete(connection) {
-    return await this.datastore.remove(_.pick(connection, '_id'));
+    let res = await this.datastore.remove(_.pick(connection, '_id'));
+    socket.emit('connection-list-changed');
+    return res;
   },
 };

api/src/index.js

@@ -1,10 +1,18 @@
 const express = require('express');
 const bodyParser = require('body-parser');
+const http = require('http');
 const cors = require('cors');
+const io = require('socket.io');
+
 const useController = require('./utility/useController');
 const connections = require('./controllers/connections');
+const socket = require('./utility/socket');
+
 const app = express();
 
+const server = http.createServer(app);
+socket.set(io(server));
+
 app.use(cors());
 app.use(bodyParser.json());
 
@@ -14,4 +22,4 @@ app.get('/', (req, res) => {
 
 useController(app, '/connections', connections);
 
-app.listen(3000);
+server.listen(3000);

api/src/utility/socket.js

@@ -0,0 +1,13 @@
+let socket = null;
+
+module.exports = {
+  set(value) {
+    socket = value;
+  },
+  get() {
+    return socket;
+  },
+  emit(message, data) {
+    socket.emit(message, data);
+  },
+};