server.js
1.27 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
const url = require('url');
const Gun = require('gun');
const http = require('http');
const WebSocket = require('ws');
var server = http.createServer().listen(3000);
// LRU with last used sockets
const QuickLRU = require('quick-lru');
const lru = new QuickLRU({maxSize: 1});
//var wss_event = new WebSocket.Server({ noServer: true});
server.on('upgrade', async function (request, socket, head) {
var pathname = url.parse(request.url).pathname || '/gun';
console.log('Got WS request',pathname);
var gun = { gun: false, server: false};
if (pathname){
if (lru.has(pathname)){
// Existing Node
console.log('Recycle id',pathname);
gun = await lru.get(pathname);
} else {
// Create Node
console.log('Create id',pathname);
gun.server = new WebSocket.Server({ noServer: true});
gun.gun = new Gun({peers:[], ws: { noServer: true, path: pathname} });
lru.set(pathname,gun);
}
}
if (gun.server){
// Handle Request
console.log('handle connection...');
//ws.emit('connection', socket);
gun.server.handleUpgrade(request, socket, head, function (ws) {
console.log('connecting.. ')
ws.emit('connection', ws);
});
} else {
socket.destroy();
}
});