diff options
author | vantezzen <hello@vantezzen.io> | 2019-10-18 20:53:41 +0200 |
---|---|---|
committer | vantezzen <hello@vantezzen.io> | 2019-10-18 20:53:41 +0200 |
commit | af506f40edb1c9c339cc86baf40baccf2dc6da62 (patch) | |
tree | d5efae2f9374ee11d645096208424d59812a9a58 /src/electron | |
parent | Merge branch 'develop' into local-server (diff) | |
download | ferdium-app-af506f40edb1c9c339cc86baf40baccf2dc6da62.tar.gz ferdium-app-af506f40edb1c9c339cc86baf40baccf2dc6da62.tar.zst ferdium-app-af506f40edb1c9c339cc86baf40baccf2dc6da62.zip |
Develop local server feature
Diffstat (limited to 'src/electron')
-rw-r--r-- | src/electron/ipc-api/index.js | 2 | ||||
-rw-r--r-- | src/electron/ipc-api/localServer.js | 52 |
2 files changed, 54 insertions, 0 deletions
diff --git a/src/electron/ipc-api/index.js b/src/electron/ipc-api/index.js index 3b7f31e4b..dcdef6b32 100644 --- a/src/electron/ipc-api/index.js +++ b/src/electron/ipc-api/index.js | |||
@@ -3,6 +3,7 @@ import settings from './settings'; | |||
3 | import appIndicator from './appIndicator'; | 3 | import appIndicator from './appIndicator'; |
4 | import download from './download'; | 4 | import download from './download'; |
5 | import processManager from './processManager'; | 5 | import processManager from './processManager'; |
6 | import localServer from './localServer'; | ||
6 | 7 | ||
7 | export default (params) => { | 8 | export default (params) => { |
8 | settings(params); | 9 | settings(params); |
@@ -10,4 +11,5 @@ export default (params) => { | |||
10 | appIndicator(params); | 11 | appIndicator(params); |
11 | download(params); | 12 | download(params); |
12 | processManager(params); | 13 | processManager(params); |
14 | localServer(params); | ||
13 | }; | 15 | }; |
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 @@ | |||
1 | import { ipcMain, app } from 'electron'; | ||
2 | import path from 'path'; | ||
3 | import net from 'net'; | ||
4 | import startServer from '../../server/start'; | ||
5 | |||
6 | const DEFAULT_PORT = 45569; | ||
7 | |||
8 | const portInUse = function (port) { | ||
9 | return new Promise((resolve) => { | ||
10 | const server = net.createServer((socket) => { | ||
11 | socket.write('Echo server\r\n'); | ||
12 | socket.pipe(socket); | ||
13 | }); | ||
14 | |||
15 | server.listen(port, '127.0.0.1'); | ||
16 | server.on('error', () => { | ||
17 | resolve(true); | ||
18 | }); | ||
19 | server.on('listening', () => { | ||
20 | server.close(); | ||
21 | resolve(false); | ||
22 | }); | ||
23 | }); | ||
24 | }; | ||
25 | |||
26 | let localServerStarted = false; | ||
27 | |||
28 | export default (params) => { | ||
29 | ipcMain.on('startLocalServer', () => { | ||
30 | if (!localServerStarted) { | ||
31 | // Find next unused port for server | ||
32 | let port = DEFAULT_PORT; | ||
33 | (async () => { | ||
34 | // eslint-disable-next-line no-await-in-loop | ||
35 | while (await portInUse(port) && port < DEFAULT_PORT + 10) { | ||
36 | port += 1; | ||
37 | } | ||
38 | console.log('Starting local server on port', port); | ||
39 | |||
40 | startServer( | ||
41 | path.join(app.getPath('userData'), 'server.sqlite'), | ||
42 | port, | ||
43 | ); | ||
44 | |||
45 | params.mainWindow.webContents.send('localServerPort', { | ||
46 | port, | ||
47 | }); | ||
48 | })(); | ||
49 | localServerStarted = true; | ||
50 | } | ||
51 | }); | ||
52 | }; | ||