lmao figured it out

This commit is contained in:
Holly Stubbs 2022-02-22 09:42:57 +00:00
parent be3698e76d
commit e5495628f3
Signed by: tgpholly
GPG key ID: B8583C4B7D18119E

View file

@ -130,8 +130,6 @@ const ChangeAction = require("./Packets/ChangeAction.js"),
TourneyMatchJoinChannel = require("./Packets/TourneyMatchSpecialInfo.js"), TourneyMatchJoinChannel = require("./Packets/TourneyMatchSpecialInfo.js"),
TourneyMatchLeaveChannel = require("./Packets/TourneyLeaveMatchChannel.js"); TourneyMatchLeaveChannel = require("./Packets/TourneyLeaveMatchChannel.js");
const emptyBuffer = Buffer.alloc(0);
// A class for managing everything multiplayer // A class for managing everything multiplayer
global.MultiplayerManager = new MultiplayerManager(); global.MultiplayerManager = new MultiplayerManager();
@ -143,8 +141,8 @@ module.exports = async function(req, res) {
const requestTokenString = req.header("osu-token"), const requestTokenString = req.header("osu-token"),
requestData = req.packet; requestData = req.packet;
// Server's response & new client token // Server's response
let responseData = emptyBuffer; let responseData;
// Check if the user is logged in // Check if the user is logged in
if (requestTokenString == null) { if (requestTokenString == null) {
@ -340,12 +338,10 @@ module.exports = async function(req, res) {
console.dir(CurrentPacket); console.dir(CurrentPacket);
break; break;
} }
// Concat current user queue into response data
// NOTE: NEVER EVER remove this buffer concat. For some reason the client freaks out if it's not there.
responseData = Buffer.concat([responseData, PacketUser.queue], responseData.length + PacketUser.queue.length);
PacketUser.clearQueue();
}); });
responseData = PacketUser.queue
PacketUser.clearQueue();
} else { } else {
// User's token is invlid, force a reconnect // User's token is invlid, force a reconnect
consoleHelper.printBancho(`Forced client re-login (Token is invalid)`); consoleHelper.printBancho(`Forced client re-login (Token is invalid)`);
@ -359,7 +355,7 @@ module.exports = async function(req, res) {
res.removeHeader('Date'); res.removeHeader('Date');
res.writeHead(200, { res.writeHead(200, {
"cho-protocol": global.protocolVersion, "cho-protocol": global.protocolVersion,
// Nice to have // Nice to have :)
"Connection": "keep-alive", "Connection": "keep-alive",
"Keep-Alive": "timeout=5, max=100", "Keep-Alive": "timeout=5, max=100",
}); });