Binato/server/BotCommandHandler.js

const osu = require("osu-packet"),
      maths = require("./util/Maths.js"),
      OsuBattleRoyale = require("./MultiplayerExtras/OsuBattleRoyale.js");

module.exports = function(User, Message, Stream, IsCalledFromMultiplayer = false) {
    if (Message[0] != "!") return;
    const command = Message.split(" ")[0];
    const args = Message.split(" ");

    let responseMessage = "";

    let commandBanchoPacketWriter = null;

    switch (command) {
        case "!help":
            // This is terrible
            if (args.length == 1) {
                responseMessage = "Commands with an * next to them have a sub help section" +
                                  "\n!help - Shows this message" +
                                  "\n!roll - Rolls a random number or a number between 0 and a given number" +
                                  "\n!ranking* - Sets your perfered ranking type" +
                                  "\n!mp* - Shows information about all multiplayer commands" + 
                                  "\n!admin* - Shows information about all admin commands";
            } else {
                switch (args[1]) {
                    case "ranking":
                        responseMessage = "Ranking Commands:" +
                                          "\n!ranking pp - Sets your ranking type to pp" +
                                          "\n!ranking score - Sets your ranking type to score" +
                                          "\n!ranking acc - Sets your ranking type to accuracy";
                    break;

                    case "mp":
                        responseMessage = "Multiplayer Commands:" +
                                          "\n!mp start - Starts a multiplayer match with a delay" +
                                          "\n!mp abort - Aborts the currently running multiplayer match" +
                                          "\n!mp obr - Enables Battle Royale mode";
                    break;

                    case "admin":
                        responseMessage = "Admin Commands:" +
                                          "\n!lock - Locks/Unlocks a channel and limits conversation to mods and above only";
                    break;

                    default:
                        break;
                }
            }
        break;

        case "!ranking":
            if (args.length == 1) {
                responseMessage = "You need to select a ranking mode! use \"!help ranking\" to see the options.";
            } else {
                switch (args[1]) {
                    case "pp":
                        responseMessage = "Set ranking mode to pp";
                        User.rankingMode = 0;
                        User.getNewUserInformationFromDatabase();
                    break;

                    case "score":
                        responseMessage = "Set ranking mode to score";
                        User.rankingMode = 1;
                        User.getNewUserInformationFromDatabase();
                    break;

                    case "acc":
                        responseMessage = "Set ranking mode to accuracy";
                        User.rankingMode = 2;
                        User.getNewUserInformationFromDatabase();
                    break;
                }
            }
        break;

        case "!roll":
            if (args.length == 1) {
                responseMessage = User.username + " rolled " + maths.randInt(0, 65535);
            } else {
                if (`${parseInt(args[1])}` == "NaN") responseMessage = User.username + " rolled " + maths.randInt(0, 65535);
                else responseMessage = User.username + " rolled " + maths.randInt(0, parseInt(args[1]));
            }
        break;

        case "!lock":
            if (!Stream.includes("#")) responseMessage = "Multiplayer channels and private channels cannot be locked!";
            else {
                for (let i = 0; i < global.channels.length; i++) {
                    // Find the channel that pertains to this stream
                    if (global.channels[i].channelName == Stream) {
                        if (global.channels[i].locked) {
                            global.channels[i].locked = false;
                            responseMessage = "Channel is now unlocked.";
                        } else {
                            global.channels[i].locked = true;
                            responseMessage = "Channel is now locked, chat restricted to mods and above.";
                        }
                        break;
                    }
                }
            }
        break;

        case "!mp":
            if (!IsCalledFromMultiplayer) return;
            if (User.currentMatch.matchStartCountdownActive) return;
            if (args.length == 1) return;
            switch (args[1]) {
                case "start":
                    if (args.length > 3) return;
                    if (`${parseInt(args[2])}` != "NaN") {
                        User.currentMatch.matchStartCountdownActive = true;
                        let countdown = parseInt(args[2]);
                        let intervalRef = setInterval(() => {
                            let local_osuPacketWriter = new osu.Bancho.Writer;
                            if (countdown != 0 && countdown > 0) countdown--;
                            if (countdown <= 10 && countdown > 0) {
                                local_osuPacketWriter.SendMessage({
                                    sendingClient: global.users["bot"].username,
                                    message: "Starting in " + countdown,
                                    target: "#multiplayer",
                                    senderId: global.users["bot"].id
                                });
                                global.StreamsHandler.sendToStream(Stream, local_osuPacketWriter.toBuffer, null);
                            } else if (countdown == 0) {
                                local_osuPacketWriter.SendMessage({
                                    sendingClient: global.users["bot"].username,
                                    message: "Good luck, have fun!",
                                    target: "#multiplayer",
                                    senderId: global.users["bot"].id
                                });
                                global.StreamsHandler.sendToStream(Stream, local_osuPacketWriter.toBuffer, null);
                                User.currentMatch.matchStartCountdownActive = false;
                                setTimeout(() => User.currentMatch.startMatch(), 1000);
                                clearInterval(intervalRef);
                            }
                        }, 1000);
                    } else {
                        responseMessage = "Good luck, have fun!";
                        setTimeout(() => User.currentMatch.startMatch(), 1000); 
                    }
                break;

                case "abort":
                    //if (args.length > 2) return;
                    User.currentMatch.finishMatch();
                break;

                case "obr":
                    if (User.currentMatch.multiplayerExtras != null) {
                        if (User.currentMatch.multiplayerExtras.name == "osu! Battle Royale") {
                            commandBanchoPacketWriter = new osu.Bancho.Writer;
                            commandBanchoPacketWriter.SendMessage({
                                sendingClient: global.users["bot"].username,
                                message: "osu! Battle Royale has been disabled!",
                                target: "#multiplayer",
                                senderId: global.users["bot"].id
                            });
                            User.currentMatch.multiplayerExtras = null;
                            global.StreamsHandler.sendToStream(Stream, commandBanchoPacketWriter.toBuffer, null);
                        }
                        else enableOBR(User, Stream, commandBanchoPacketWriter);
                    }
                    else enableOBR(User, Stream, commandBanchoPacketWriter);
                break;

                default:
                    break;
            }
        break;
    }

    const osuPacketWriter = new osu.Bancho.Writer;
    if (responseMessage != "") {
        if (Stream.includes("#")) {
            osuPacketWriter.SendMessage({
                sendingClient: global.users["bot"].username,
                message: responseMessage,
                target: Stream,
                senderId: global.users["bot"].id
            });
        } else {
            osuPacketWriter.SendMessage({
                sendingClient: global.users["bot"].username,
                message: responseMessage,
                target: "#multiplayer",
                senderId: global.users["bot"].id
            });
        }
    }
    global.StreamsHandler.sendToStream(Stream, osuPacketWriter.toBuffer, null);
}

function enableOBR(User, Stream, commandBanchoPacketWriter) {
    User.currentMatch.multiplayerExtras = new OsuBattleRoyale(User.currentMatch);
    commandBanchoPacketWriter = new osu.Bancho.Writer;
    commandBanchoPacketWriter.SendMessage({
        sendingClient: global.users["bot"].username,
        message: "osu! Battle Royale has been enabled!",
        target: "#multiplayer",
        senderId: global.users["bot"].id
    });
    commandBanchoPacketWriter.SendMessage({
        sendingClient: global.users["bot"].username,
        message: "New Multiplayer Rules Added:\n - Players that are in a failed state by the end of the map get eliminated\n - The player(s) with the lowest score get eliminated",
        target: "#multiplayer",
        senderId: global.users["bot"].id
    });
    global.StreamsHandler.sendToStream(Stream, commandBanchoPacketWriter.toBuffer, null);
}