vassili/seitime-frappe
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions 1

chore: move redis sub setup

Browse source
This commit is contained in:
Ankush Menat 2023-06-29 19:51:25 +05:30
parent d13cb116bc
commit dad1d57b90
1 changed files with 14 additions and 13 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

27
realtime/index.js
View file

@ -4,7 +4,6 @@ const { Server } = require("socket.io");
const { get_conf, get_redis_subscriber } = require("../node_utils");
const conf = get_conf();
const log = console.log; // eslint-disable-line
const subscriber = get_redis_subscriber();
const { get_hostname, get_url } = require("./utils");
@ -115,18 +114,6 @@ io.on("connection", function (socket) {
});
});
subscriber.on("message", function (_channel, message) {
message = JSON.parse(message);
if (message.room) {
io.to(message.room).emit(message.event, message.message);
} else {
io.emit(message.event, message.message);
}
});
subscriber.subscribe("events");
function get_doc_room(socket, doctype, docname) {
return get_site_name(socket) + ":doc:" + doctype + "/" + docname;
}
@ -259,3 +246,17 @@ function user_disconnected(socket) {
notify_subscribed_doc_users({ socket, doctype, docname });
});
}
const subscriber = get_redis_subscriber();
subscriber.on("message", function (_channel, message) {
message = JSON.parse(message);
if (message.room) {
io.to(message.room).emit(message.event, message.message);
} else {
io.emit(message.event, message.message);
}
});
subscriber.subscribe("events");