oss/FrankerFaceZ
oss/FrankerFaceZ
1
0
Fork 0
mirror of https://github.com/FrankerFaceZ/FrankerFaceZ.git synced 2025-06-28 05:15:54 +00:00
Code Wiki Activity

4.56.3

Browse source 
* Experiment Updated: Yet another update for the MQTT PubSub experiment.
This commit is contained in:
SirStendec 2023-11-01 16:25:02 -04:00
parent 4d2b65e7c2
commit 0eaf1a55be
4 changed files with 8 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

2
package.json
View file

@ -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",

4
src/experiments.json
View file

@ -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}
]
}
}

4
src/modules/chat/emotes.js
View file

@ -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 => {

2
src/utilities/pubsub.js
View file

@ -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();