Mirroristas/gun
2
0
Fork 0
mirror of https://github.com/amark/gun.git synced 2025-03-30 15:08:33 +00:00
Code Issues Packages Projects Releases Wiki Activity

Add server push

Browse Source 
Pushes graph updates to connected clients, listening for
acknowledgements.
This commit is contained in:
Jesse Gibson 2016-11-14 13:40:55 -07:00
parent e8194887e0
commit ba43dcac17
1 changed files with 34 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

35
lib/wsp/server-push.js
View File

@ -42,7 +42,7 @@ function ready (socket, cb) {
* @param {Obejct} context - A gun request context.
* @param {Object} clients - IDs mapped to socket instances.
* @param {Function} cb - Called for each response.
* @return {Object} - The context object.
* @return {undefined}
*/
function request (context, clients, cb) {
Gun.obj.map(clients, function (client) {
@ -61,6 +61,31 @@ function request (context, clients, cb) {
});
}
/**
* Pushes a graph update to a collection of clients.
* @param {Object} context - The context object passed by gun.
* @param {Object} clients - An object mapping URLs to clients.
* @param {Function} cb - Invoked on each client response.
* @return {undefined}
*/
function update (context, clients, cb) {
Gun.obj.map(clients, function (client) {
ready(client, function () {
var msg = {
headers: {},
body: {
'#': Gun.on.ask(cb),
'$': context.put,
},
};
var serialized = JSON.stringify(msg);
client.send(serialized);
});
});
}
/** * Attaches server push middleware to gun.
* @param {Gun} gun - The gun instance to attach to.
* @param {WebSocket.Server} server - A websocket server instance.
@ -117,6 +142,14 @@ function attach (gun, server) {
if (!isUsingServer(context.gun, server)) {
return;
}
update(context, pool, function (err, data) {
var ack = {
'!': err || null,
'$': data.$,
};
Gun.on.ack(context, ack);
});
});
}