1 files changed, 52 insertions, 0 deletions

diff --git a/src/electron/ipc-api/localServer.js b/src/electron/ipc-api/localServer.js
new file mode 100644
index 000000000..2f8f1020a
--- /dev/null
+++ b/src/electron/ipc-api/localServer.js
@@ -0,0 +1,52 @@
+import { ipcMain, app } from 'electron';
+import path from 'path';
+import net from 'net';
+import startServer from '../../server/start';
+
+const DEFAULT_PORT = 45569;
+
+const portInUse = function (port) {
+  return new Promise((resolve) => {
+    const server = net.createServer((socket) => {
+      socket.write('Echo server\r\n');
+      socket.pipe(socket);
+    });
+
+    server.listen(port, '127.0.0.1');
+    server.on('error', () => {
+      resolve(true);
+    });
+    server.on('listening', () => {
+      server.close();
+      resolve(false);
+    });
+  });
+};
+
+let localServerStarted = false;
+
+export default (params) => {
+  ipcMain.on('startLocalServer', () => {
+    if (!localServerStarted) {
+      // Find next unused port for server
+      let port = DEFAULT_PORT;
+      (async () => {
+        // eslint-disable-next-line no-await-in-loop
+        while (await portInUse(port) && port < DEFAULT_PORT + 10) {
+          port += 1;
+        }
+        console.log('Starting local server on port', port);
+
+        startServer(
+          path.join(app.getPath('userData'), 'server.sqlite'),
+          port,
+        );
+
+        params.mainWindow.webContents.send('localServerPort', {
+          port,
+        });
+      })();
+      localServerStarted = true;
+    }
+  });
+};