cs2-rcon-panel/routes/game.js

const express = require('express');
const router = express.Router();
const readline = require('readline');
const fs = require('fs');

const rcon = require("../modules/rcon");
const is_authenticated = require("../modules/middleware");

const ALLOWED_STEAM_IDS = ['76561198154367261']

router.post('/api/setup-game', is_authenticated, async (req, res) => {
    try {
        const server_id = req.body.server_id;
        const team1 = req.body.team1;
        const team2 = req.body.team2;
        const selected_map = req.body.selectedMap;
        const game_mode = req.body.game_mode.toString();
        rcon.rcons[server_id].execute(`mp_teamname_1 "${team1}"`);
        rcon.rcons[server_id].execute(`mp_teamname_2 "${team2}"`);
        rcon.rcons[server_id].execute(`game_mode ${game_mode}`);
        if (game_mode == "1") {
            execute_cfg_on_server(server_id, './cfg/live.cfg');
        } else if (game_mode == "2") {
            execute_cfg_on_server(server_id, './cfg/live_wingman.cfg');
        }
        rcon.rcons[server_id].execute(`mp_warmup_pausetimer 1`);
        rcon.rcons[server_id].execute(`changelevel ${selected_map}`);

        // Adding 1 second delay in executing warmup.cfg to make it effective after map has been changed.
        setTimeout(() => {
            execute_cfg_on_server(server_id, './cfg/warmup.cfg');
        }, 1000)

        return res.status(200).json({ message: 'Game Created!' });
    } catch (error) {
        console.log(error);
        res.status(500).json({ error: 'Internal server error' });
    }
});

router.post('/api/restart', is_authenticated, async (req, res) => {
    try {
        const server_id = req.body.server_id;
        rcon.rcons[server_id].execute('mp_restartgame 1');
        return res.status(200).json({ message: 'Game restarted' });
    } catch (error) {
        console.log(error);
        res.status(500).json({ error: 'Internal server error' });
    }
});

router.post('/api/start-warmup', is_authenticated, (req, res) => {
    try {
        const server_id = req.body.server_id;
        rcon.rcons[server_id].execute('mp_restartgame 1');
        execute_cfg_on_server(server_id, './cfg/warmup.cfg');

        return res.status(200).json({ message: 'Warmup started!' });
    } catch (error) {
        console.log(error);
        res.status(500).json({ error: 'Internal server error' });
    }
});

router.post('/api/start-knife', is_authenticated, async (req, res) => {
    try {
        const server_id = req.body.server_id;
        rcon.rcons[server_id].execute('mp_warmup_end');
        rcon.rcons[server_id].execute('mp_restartgame 1');
        execute_cfg_on_server(server_id, './cfg/knife.cfg');

        return res.status(200).json({ message: 'Knife started!' });
    } catch (error) {
        console.log(error);
        res.status(500).json({ error: 'Internal server error' });
    }
});

router.post('/api/swap-team', is_authenticated, async (req, res) => {
    try {
        const server_id = req.body.server_id;
        rcon.rcons[server_id].execute('mp_swapteams');
        return res.status(200).json({ message: 'Teams Swapped!' });
    } catch (error) {
        res.status(500).json({ error: 'Internal server error' });
    }
});

router.post('/api/go-live', is_authenticated, async (req, res) => {
    try {
        const server_id = req.body.server_id;
        rcon.rcons[server_id].execute('mp_warmup_end');
        const response = await rcon.rcons[server_id].execute('game_mode');
        const game_mode = response.split("=")[1].trim().toString();
        if (game_mode == "1") {
            console.log("Executing live.cfg")
            execute_cfg_on_server(server_id, './cfg/live.cfg');
        } else if (game_mode == "2") {
            console.log("Executing live_wingman.cfg")
            execute_cfg_on_server(server_id, './cfg/live_wingman.cfg');
        }
        rcon.rcons[server_id].execute('mp_restartgame 1');

        return res.status(200).json({ message: 'Match is live!!' });
    } catch (error) {
        console.log(error);
        res.status(500).json({ error: 'Internal server error' });
    }
});

// List Round Backups API
router.post('/api/list-backups', is_authenticated, async (req, res) => {
    try {
        const server_id = req.body.server_id;
        const response = await rcon.rcons[server_id].execute('mp_backup_restore_list_files');
        console.log('Server response:', response);
        return res.status(200).json({ message: response });
    } catch (error) {
        console.log(error)
        res.status(500).json({ error: 'Internal server error' });
    }
});

// Restore Round API
router.post('/api/restore-round', is_authenticated, async (req, res) => {
    try {
        const server_id = req.body.server_id;
        let round_number = req.body.round_number.toString()
        if (round_number.length == 1) {
            round_number = "0" + round_number;
        }
        console.log(`SENDING mp_backup_restore_load_file backup_round${round_number}.txt`)
        rcon.rcons[server_id].execute(`mp_backup_restore_load_file backup_round${round_number}.txt`);
        rcon.rcons[server_id].execute('mp_pause_match');
        return res.status(200).json({ message: 'Round Restored!' });
    } catch (error) {
        res.status(500).json({ error: 'Internal server error' });
    }
});

router.post('/api/restore-latest-backup', is_authenticated, async (req, res) => {
    try {
        const server_id = req.body.server_id;
        const response = await rcon.rcons[server_id].execute('mp_backup_round_file_last');
        const last_round_file = response.split("=")[1].trim().toString();
        if (last_round_file.includes('.txt')) {
            rcon.rcons[server_id].execute(`mp_backup_restore_load_file ${last_round_file}`);
            rcon.rcons[server_id].execute('mp_pause_match');
            return res.status(200).json({ message: `Latest Round Restored! (${last_round_file})` });
        } else {
            return res.status(200).json({ message: 'No latest backup found!' });
        }

    } catch (error) {
        console.log(error);
        res.status(500).json({ error: 'Internal server error' });
    }
});

// Pause Game API
router.post('/api/pause', is_authenticated, async (req, res) => {
    try {
        const server_id = req.body.server_id;
        rcon.rcons[server_id].execute('mp_pause_match');
        return res.status(200).json({ message: 'Game paused' });
    } catch (error) {
        res.status(500).json({ error: 'Internal server error' });
    }
});

// Unpause Game API
router.post('/api/unpause', is_authenticated, async (req, res) => {
    try {
        const server_id = req.body.server_id;
        rcon.rcons[server_id].execute('mp_unpause_match');
        return res.status(200).json({ message: 'Game unpaused' });
    } catch (error) {
        res.status(500).json({ error: 'Internal server error' });
    }
});

router.post('/api/rcon', is_authenticated, async (req, res) => {
    try {
        const server_id = req.body.server_id;
        const command = req.body.command;

        // Wrap the await call in a Promise and add a timeout
        const executePromise = new Promise(async (resolve, reject) => {
            try {
                const response = await Promise.race([
                    rcon.rcons[server_id].execute(command),
                    new Promise((resolve, reject) => {
                        setTimeout(() => {
                            resolve({ error: 'Command execution timed out' });
                        }, 1000); // 1 seconds timeout
                    }),
                ]);
                resolve(response);
            } catch (error) {
                reject(error);
            }
        });

        // Wait for the wrapped Promise to resolve
        const response = await executePromise;
        console.log(response)
        // Check if the result is an error or the actual response
        if (response.error) {
            return res.status(200).json({ message: 'Command sent!' });
        }

        return res.status(200).json({ message: 'Command sent! Response received:\n' + response.toString() });
    } catch (error) {
        res.status(500).json({ error: 'Internal server error' });
    }
});

function check_whitelisted_players() {
    rcon.rcons[server_id].execute('status_json')
        .then((response) => {
            console.log(response)
            const server_status = JSON.parse(response)
            const players = server_status['server']['clients']
            for (var i = 0; i < players.length; i++) {
                let player = players[i]
                if (!player.bot && player.steamid64.includes('7656') && !ALLOWED_STEAM_IDS.includes(player.steamid64)) {
                    console.log(`kick ${player.name}`)
                    rcon.rcons[server_id].execute(`kick ${player.name}`);
                }
            }
            return;
        })
        .catch(console.error);
}

function execute_cfg_on_server(server_id, cfg_path) {
    const fileStream = fs.createReadStream(cfg_path, 'utf-8');
    const rl = readline.createInterface({
        input: fileStream,
        terminal: false
    });

    rl.on('line', (line) => {
        try {
            console.log(`Line from file: ${line}`);
            rcon.rcons[server_id].execute(line);
        } catch (error) {
            console.log(`Error in executing line ${line}, Error: ${error}`);
        }
    });

    rl.on('close', () => {
        console.log('File reading completed.');
    });
}

module.exports = {
    router
};