const express = require('express');
const router = express.Router();
const mariadb = require('mariadb');
const reasonFlags = JSON.parse(process.env.REASON_FLAGS)

const { execSync } = require('child_process');

// Create a MariaDB connection pool
const pool = mariadb.createPool({
    host: process.env.DB_HOST, // Replace with your database host
	port: process.env.DB_PORT || 3306,
    user: process.env.DB_USER, // Replace with your database username
    password: process.env.DB_PASS, // Replace with your database password
    database: process.env.DB_DATABASE, // Replace with your database name
    connectionLimit: 100 // Adjust connection limit as needed
});

router.get("/v1/myIP", (req,res) => {
	res.json({
		ip: req.headers['x-forwarded-for'] || req.connection.remoteAddress
	})
});

// Route to fetch all bans
router.get('/v1/bans', async (req, res) => {
    try {
        // Get a connection from the pool
        const connection = await pool.getConnection();

        try {
            // Execute the query to fetch all rows from the `bans` table
            const rows = await connection.query('SELECT * FROM bans');
			// Convert all timestamps into epoch
			rows.forEach(row => {
                row.expiresTimestamp = row.expiresTimestamp ? new Date(`${row.expiresTimestamp}Z`).getTime() : null
                row.banTimestamp = row.banTimestamp ? new Date(`${row.banTimestamp}`).getTime() : null
				row.valid = row.expiresTimestamp ? new Date(row.expiresTimestamp) > new Date() : true
			});
            // Send the results as a JSON response
            res.json(rows);
        } finally {
            // Release the connection back to the pool
            connection.release();
        }
    } catch (err) {
        console.error('Error fetching bans:', err);

        // Respond with a 500 Internal Server Error status if something goes wrong
        res.status(500).json({ error: 'An error occurred while fetching the bans.' });
    }
});

router.get("/v1/ban/roblox/:uid", async (req, res) => {
	if (!req.params.uid) return res.status(400).json({error: "Specify user ID!"});
    try {
        // Get a connection from the pool
        const connection = await pool.getConnection();

        try {
            // Execute the query to fetch all rows from the `bans` table
            const rows = await connection.query('SELECT * FROM bans WHERE robloxId = ?', [req.params.uid]);
			// Convert all timestamps into epoch
			rows.forEach(row => {
                row.expiresTimestamp = row.expiresTimestamp ? new Date(`${row.expiresTimestamp}Z`).getTime() : null
                row.banTimestamp = row.banTimestamp ? new Date(`${row.banTimestamp}`).getTime() : null
				row.valid = row.expiresTimestamp ? new Date(row.expiresTimestamp) > new Date() : true
			});
            // Send the results as a JSON response
            res.json(rows);
        } finally {
            // Release the connection back to the pool
            connection.release();
        }
    } catch (err) {
        console.error('Error fetching bans:', err);

        // Respond with a 500 Internal Server Error status if something goes wrong
        res.status(500).json({ error: 'An error occurred while fetching the bans.' });
    }
})

router.get("/v1/ban/discord/:uid", async (req, res) => {
	if (!req.params.uid) return res.status(400).json({error: "Specify user ID!"});
    try {
        // Get a connection from the pool
        const connection = await pool.getConnection();

        try {
            // Execute the query to fetch all rows from the `bans` table
            const rows = await connection.query('SELECT * FROM bans WHERE discordId = ?', [req.params.uid]);
			// Convert all timestamps into epoch
			rows.forEach(row => {
                row.expiresTimestamp = row.expiresTimestamp ? new Date(`${row.expiresTimestamp}Z`).getTime() : null
                row.banTimestamp = row.banTimestamp ? new Date(`${row.banTimestamp}`).getTime() : null
				row.valid = row.expiresTimestamp ? new Date(row.expiresTimestamp) > new Date() : true
			});

            // Send the results as a JSON response
            res.json(rows);
        } finally {
            // Release the connection back to the pool
            connection.release();
        }
    } catch (err) {
        console.error('Error fetching bans:', err);

        // Respond with a 500 Internal Server Error status if something goes wrong
        res.status(500).json({ error: 'An error occurred while fetching the bans.' });
    }
})

router.get("/v1/info", (req,res) => {
	res.json({
		commit_hash: execSync('git rev-parse HEAD').toString().trim(),
		reasonFlags,
		currentServerTime: new Date().getTime()
	})
})

module.exports = router;