acbd873b by Glitch (hello-express)

:kiss::corn: Checkpoint

./gun-ws.js:13690106/3222
./server.js:13690106/104
1 parent 0b407bce
;(function(){
var Gun = (typeof window !== "undefined")? window.Gun : require('gun');
var url = require('url');
Gun.on('opt', function mount(ctx){
this.to.next(ctx);
var opt = ctx.opt;
if( !opt.peers )
if( typeof( opt == "string" ) )
opt.peers = [opt];
if(ctx.once){ return }
if(false === opt.ws){ return }
var ws = opt.ws || (opt.ws = {}), batch;
if(opt.web){
console.log('Initializing Gun WS socket!', ws.path);
ws.server = ws.server || opt.web;
ws.path = ws.path || '/gun';
if (!ws.web) ws.web = new WebSocket.Server(ws);
ws.web.on('connection', function(wire){
wire.upgradeReq = wire.upgradeReq || {};
wire.url = url.parse(wire.upgradeReq.url||'', true);
wire.id = wire.id || Gun.text.random(6);
var peer = opt.peers[wire.id] = {wire: wire};
wire.peer = function(){ return peer };
ctx.on('hi', peer);
wire.on('message', function(msg){
//console.log("MESSAGE", msg);
receive(msg, wire, ctx); // diff: wire is wire.
});
wire.on('close', function(){
ctx.on('bye', peer);
Gun.obj.del(opt.peers, wire.id);
});
wire.on('error', function(e){});
});
}
ctx.on('out', function(at){
this.to.next(at);
batch = JSON.stringify(at);
if(ws.drain){
ws.drain.push(batch);
return;
}
ws.drain = [];
setTimeout(function(){
if(!ws.drain){ return }
var tmp = ws.drain;
ws.drain = null;
if(!tmp.length){ return }
batch = JSON.stringify(tmp);
Gun.obj.map(opt.peers, send, ctx);
}, opt.gap || opt.wait || 1);
Gun.obj.map(opt.peers, send, ctx);
});
// EVERY message taken care of. The "extra" ones are from in-memory not having "asked" for it yet - which we won't want it to do for foreign requests. Likewise, lots of chattyness because the put/ack replies happen before the `get` syncs so everybody now has it in-memory already to reply with.
function send(peer){
var ctx = this, msg = batch;
var wire = peer.wire || open(peer, ctx);
if(!wire){ return }
if(wire.readyState === wire.OPEN){
wire.send(msg);
return;
}
(peer.queue = peer.queue || []).push(msg);
}
function receive(msg, wire, ctx){
if(!ctx){ return }
try{msg = JSON.parse(msg.data || msg);
}catch(e){}
if(msg instanceof Array){
var i = 0, m;
while(m = msg[i++]){
receive(m, wire, ctx); // wire not peer!
}
return;
}
msg.peer = wire.peer;
ctx.on('in', msg);
}
function open(peer, as){
if(!peer || !peer.url){ return }
var url = peer.url.replace('http', 'ws');
var wire = peer.wire = new WebSocket(url);
wire.on('close', function(){
reconnect(peer, as);
});
wire.on('error', function(error){
if(!error){ return }
if(error.code === 'ECONNREFUSED'){
reconnect(peer, as); // placement?
}
});
wire.on('open', function(){
var queue = peer.queue;
peer.queue = [];
Gun.obj.map(queue, function(msg){
batch = msg;
send.call(as, peer);
});
});
wire.on('message', function(msg){
receive(msg, wire, as); // diff: wire not peer!
});
return wire;
}
function reconnect(peer, as){
clearTimeout(peer.defer);
peer.defer = setTimeout(function(){
open(peer, as);
}, 2 * 1000);
}
});
var noop = function(){};
}());
\ No newline at end of file
{"jack\u001bname":{"":{":":"Jack",">":1586991984290}}}
\ No newline at end of file
{"j":{"ack\u001bname":{"":{":":"Jack",">":1587032540203}},"ill\u001bname":{"":{":":"Jill",">":1587032540204.002}}}}
\ No newline at end of file
......
const url = require('url');
const Gun = require('gun');
const Gun = require('gun/gun');
require('./gun-ws.js');
const http = require('http');
const WebSocket = require('ws');
var server = http.createServer();
......@@ -24,8 +25,8 @@ server.on('upgrade', async function (request, socket, head) {
console.log('Create id',pathname);
// HOW HOW HOW ? IS it even possible to attach the WS to the Gun Object alone?
// Works only when passing "server" to the web parameter, no WS/WSS)
//gun.server = new WebSocket.Server({ noServer: true});
gun.gun = new Gun({peers:[], ws: { noServer: true }, web: undefined });
gun.server = new WebSocket.Server({ noServer: true});
gun.gun = new Gun({peers:[], ws: { noServer: true, path: pathname, web: gun.server }, web: gun.server });
lru.set(pathname,gun);
}
}
......
Styling with Markdown is supported
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!