oss/FrankerFaceZ
oss/FrankerFaceZ
1
0
Fork 0
mirror of https://github.com/FrankerFaceZ/FrankerFaceZ.git synced 2025-09-17 10:16:57 +00:00
Code Wiki Activity

4.75.2

Browse source 
* Changed: Back to work on experimental PubSub things, with a different server strategy this time.
This commit is contained in:
SirStendec 2024-10-19 01:35:47 -04:00
parent 5c06461a0e
commit 3538ef86ad
5 changed files with 12 additions and 6 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.75.1",
"version": "4.75.2",
"description": "FrankerFaceZ is a Twitch enhancement suite.",
"private": true,
"license": "Apache-2.0",

4
src/experiments.json
View file

@ -20,8 +20,8 @@
"name": "EMQX MQTT-Based PubSub",
"description": "An experimental pubsub system running on an EMQX cluster, to see how that performs.",
"groups": [
{"value": true, "weight": 0},
{"value": false, "weight": 100}
{"value": true, "weight": 20},
{"value": false, "weight": 80}
]
},
"cf_pubsub": {

5
src/utilities/constants.ts
View file

@ -317,12 +317,13 @@ export const PUBSUB_CLUSTERS = {
export const EMQX_SERVERS = [
//'catbag.frankerfacez.com',
//'pubsub-staging.frankerfacez.com',
'ayaya.frankerfacez.com',
'biblethump.frankerfacez.com',
/*'ayaya.frankerfacez.com',
'champ.frankerfacez.com',
'lilz.frankerfacez.com',
'pog.frankerfacez.com',
'yoohoo.frankerfacez.com',
'andknuckles.frankerfacez.com'
'andknuckles.frankerfacez.com'*/
];

5
src/utilities/custom_denoflare_mqtt.js
View file

@ -295,6 +295,11 @@ var _Bytes = class _Bytes {
if (DEBUG)
console.log({ maximumPacketSize });
rt = { ...rt, maximumPacketSize };
} else if (propertyId === 33) {
const receiveMaximum = reader.readUint16();
if (DEBUG)
console.log({ receiveMaximum });
rt = { ...rt, receiveMaximum };
} else if (propertyId === 34) {
const topicAliasMaximum = reader.readUint16();
if (DEBUG)

2
src/utilities/pubsub.js
View file

@ -120,7 +120,7 @@ export default class PubSubClient extends EventEmitter {
data = {
require_signing: false,
endpoint: `wss://${server}:8084/mqtt`,
endpoint: `wss://${server}/mqtt`,
username: 'anonymous',
password: `eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJzdWIiOiJhbm9ueW1vdXMifQ.5DZP1bScMz4-MV_jGZveUKq4pFy9x_PJF9gSzAvj-wA`,