From 0eaf1a55be8c01757295f3596566c340f999f27c Mon Sep 17 00:00:00 2001
From: SirStendec <sir@stendec.me>
Date: Wed, 1 Nov 2023 16:25:02 -0400
Subject: [PATCH] 4.56.3

* Experiment Updated: Yet another update for the MQTT PubSub experiment.
---
 package.json               | 2 +-
 src/experiments.json       | 4 ++--
 src/modules/chat/emotes.js | 4 ++++
 src/utilities/pubsub.js    | 2 +-
 4 files changed, 8 insertions(+), 4 deletions(-)

diff --git a/package.json b/package.json
index 3995a27b..90030300 100755
--- a/package.json
+++ b/package.json
@@ -1,7 +1,7 @@
 {
   "name": "frankerfacez",
   "author": "Dan Salvato LLC",
-  "version": "4.56.2",
+  "version": "4.56.3",
   "description": "FrankerFaceZ is a Twitch enhancement suite.",
   "private": true,
   "license": "Apache-2.0",
diff --git a/src/experiments.json b/src/experiments.json
index 601e384c..36d46575 100644
--- a/src/experiments.json
+++ b/src/experiments.json
@@ -20,8 +20,8 @@
 		"name": "MQTT-Based PubSub",
 		"description": "An experimental new pubsub system that should be more reliable than the existing socket cluster.",
 		"groups": [
-			{"value": true, "weight": 15},
-			{"value": false, "weight": 85}
+			{"value": true, "weight": 10},
+			{"value": false, "weight": 90}
 		]
 	}
 }
\ No newline at end of file
diff --git a/src/modules/chat/emotes.js b/src/modules/chat/emotes.js
index 04d86701..4c872fa6 100644
--- a/src/modules/chat/emotes.js
+++ b/src/modules/chat/emotes.js
@@ -648,6 +648,8 @@ export default class Emotes extends Module {
 				return;
 
 			this.addEmoteToSet(set_id, emote);
+
+			// TODO: Notify users?
 		});
 
 		this.on('pubsub:command:remove_emote', msg => {
@@ -658,6 +660,8 @@ export default class Emotes extends Module {
 				return;
 
 			this.removeEmoteFromSet(set_id, emote_id);
+
+			// TODO: Notify users?
 		});
 
 		this.on('chat:reload-data', flags => {
diff --git a/src/utilities/pubsub.js b/src/utilities/pubsub.js
index d4a30a70..af1de8aa 100644
--- a/src/utilities/pubsub.js
+++ b/src/utilities/pubsub.js
@@ -480,7 +480,7 @@ export default class PubSubClient extends EventEmitter {
 						this._live_topics.delete(topic);
 
 					// Call sendSubscribes again after a bit.
-					return delay(2000).then(() => this._sendSubscribes());
+					return sleep(2000).then(() => this._sendSubscribes());
 				});
 		else
 			return Promise.resolve();