From dad1d57b90e4768f6841d3d7d5f395a1fc0098f2 Mon Sep 17 00:00:00 2001
From: Ankush Menat <ankush@frappe.io>
Date: Thu, 29 Jun 2023 19:51:25 +0530
Subject: [PATCH] chore: move redis sub setup

---
 realtime/index.js | 27 ++++++++++++++-------------
 1 file changed, 14 insertions(+), 13 deletions(-)

diff --git a/realtime/index.js b/realtime/index.js
index f745dedf43..c625608a2f 100644
--- a/realtime/index.js
+++ b/realtime/index.js
@@ -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");