
Checkpoint
./server.js:13690106/69
Showing
1 changed file
with
6 additions
and
3 deletions
... | @@ -2,7 +2,7 @@ const url = require('url'); | ... | @@ -2,7 +2,7 @@ const url = require('url'); |
2 | const Gun = require('gun'); | 2 | const Gun = require('gun'); |
3 | const http = require('http'); | 3 | const http = require('http'); |
4 | const WebSocket = require('ws'); | 4 | const WebSocket = require('ws'); |
5 | var server = http.createServer().listen(3000); | 5 | var server = http.createServer(); |
6 | 6 | ||
7 | // LRU with last used sockets | 7 | // LRU with last used sockets |
8 | const QuickLRU = require('quick-lru'); | 8 | const QuickLRU = require('quick-lru'); |
... | @@ -23,7 +23,7 @@ server.on('upgrade', async function (request, socket, head) { | ... | @@ -23,7 +23,7 @@ server.on('upgrade', async function (request, socket, head) { |
23 | // Create Node | 23 | // Create Node |
24 | console.log('Create id',pathname); | 24 | console.log('Create id',pathname); |
25 | gun.server = new WebSocket.Server({ noServer: true}); | 25 | gun.server = new WebSocket.Server({ noServer: true}); |
26 | gun.gun = new Gun({peers:[], ws: { noServer: true, path: pathname} }); | 26 | gun.gun = new Gun({peers:[], ws: { noServer: true } }); |
27 | lru.set(pathname,gun); | 27 | lru.set(pathname,gun); |
28 | } | 28 | } |
29 | } | 29 | } |
... | @@ -33,10 +33,13 @@ server.on('upgrade', async function (request, socket, head) { | ... | @@ -33,10 +33,13 @@ server.on('upgrade', async function (request, socket, head) { |
33 | //ws.emit('connection', socket); | 33 | //ws.emit('connection', socket); |
34 | gun.server.handleUpgrade(request, socket, head, function (ws) { | 34 | gun.server.handleUpgrade(request, socket, head, function (ws) { |
35 | console.log('connecting.. ') | 35 | console.log('connecting.. ') |
36 | ws.emit('connection', ws); | 36 | gun.server.emit('connection', ws); |
37 | }); | 37 | }); |
38 | 38 | ||
39 | } else { | 39 | } else { |
40 | socket.destroy(); | 40 | socket.destroy(); |
41 | } | 41 | } |
42 | }); | 42 | }); |
43 | |||
44 | |||
45 | server.listen(3000); | ||
... | \ No newline at end of file | ... | \ No newline at end of file | ... | ... |
-
Please register or sign in to post a comment