amayo/src/main.ts

import Amayo from "./core/client";
import { loadCommands } from "./core/loader";
import { loadEvents } from "./core/loaderEvents";
import { redis, redisConnect } from "./core/redis";
import { registeringCommands } from "./core/api/discordAPI";
import {loadComponents} from "./core/components";

export const bot = new Amayo();

// Listeners de robustez del cliente Discord
bot.on('error', (e) => console.error('🐞 Discord client error:', e));
bot.on('warn', (m) => console.warn('⚠️ Discord warn:', m));
// Evitar reintentos de re-login simultáneos
let relogging = false;
// Cuando la sesión es invalidada, intentamos reconectar/login
bot.on('invalidated', () => {
    if (relogging) return;
    relogging = true;
    console.error('🔄 Sesión de Discord invalidada. Reintentando login...');
    withRetry('Re-login tras invalidated', () => bot.play(), { minDelayMs: 2000, maxDelayMs: 60_000 })
        .catch(() => {
            console.error('No se pudo reloguear tras invalidated, se seguirá intentando en el bucle general.');
        })
        .finally(() => { relogging = false; });
});

// Utilidad: reintentos con backoff exponencial + jitter
async function withRetry<T>(name: string, fn: () => Promise<T>, opts?: {
    retries?: number;
    minDelayMs?: number;
    maxDelayMs?: number;
    factor?: number;
    jitter?: boolean;
    isRetryable?: (err: unknown, attempt: number) => boolean;
}): Promise<T> {
    const {
        retries = Infinity,
        minDelayMs = 1000,
        maxDelayMs = 30_000,
        factor = 1.8,
        jitter = true,
        isRetryable = () => true,
    } = opts ?? {};

    let attempt = 0;
    let delay = minDelayMs;

    // eslint-disable-next-line no-constant-condition
    while (true) {
        try {
            return await fn();
        } catch (err) {
            attempt++;
            const errMsg = err instanceof Error ? `${err.name}: ${err.message}` : String(err);
            console.error(`❌ ${name} falló (intento ${attempt}) =>`, errMsg);

            if (!isRetryable(err, attempt)) {
                console.error(`⛔ ${name}: error no recuperable, deteniendo reintentos.`);
                throw err;
            }

            if (attempt >= retries) throw err;

            // calcular backoff
            let wait = delay;
            if (jitter) {
                const rand = Math.random() + 0.5; // 0.5x a 1.5x
                wait = Math.min(maxDelayMs, Math.floor(delay * rand));
            } else {
                wait = Math.min(maxDelayMs, delay);
            }
            console.warn(`⏳ Reintentando ${name} en ${wait}ms...`);
            await new Promise((r) => setTimeout(r, wait));
            delay = Math.min(maxDelayMs, Math.floor(delay * factor));
        }
    }
}

// Handlers globales para robustez
process.on('unhandledRejection', (reason: any, p) => {
    console.error('🚨 UnhandledRejection en Promise:', p, 'razón:', reason);
});

process.on('uncaughtException', (err) => {
    console.error('🚨 UncaughtException:', err);
    // No salimos; dejamos que el bot continúe vivo
});

process.on('multipleResolves', (type, promise, reason: any) => {
    // Ignorar resoluciones sin razón (ruido)
    if (type === 'resolve' && (reason === undefined || reason === null)) {
        return;
    }
    const msg = reason instanceof Error ? `${reason.name}: ${reason.message}` : String(reason);
    const stack = (reason && (reason as any).stack) ? String((reason as any).stack) : '';
    const isAbortErr = (reason && ((reason as any).code === 'ABORT_ERR' || /AbortError|operation was aborted/i.test(msg)));
    const isDiscordWs = /@discordjs\/ws|WebSocketShard/.test(stack);
    if (isAbortErr && isDiscordWs) {
        // Ruido benigno de reconexiones del WS de Discord: ignorar
        return;
    }
    console.warn('⚠️ multipleResolves:', type, msg);
});

let shuttingDown = false;
async function gracefulShutdown() {
    if (shuttingDown) return;
    shuttingDown = true;
    console.log('🛑 Apagado controlado iniciado...');
    try {
        // Cerrar Redis si procede
        try {
            if (redis?.isOpen) {
                await redis.quit();
                console.log('🔌 Redis cerrado');
            }
        } catch (e) {
            console.warn('No se pudo cerrar Redis limpiamente:', e);
        }
        // Cerrar Prisma y Discord
        try {
            await bot.prisma.$disconnect();
        } catch {}
        try {
            await bot.destroy();
        } catch {}
    } finally {
        console.log('✅ Apagado controlado completo');
    }
}

process.on('SIGINT', gracefulShutdown);
process.on('SIGTERM', gracefulShutdown);

async function bootstrap() {
    console.log("🚀 Iniciando bot...");

    // Cargar recursos locales (no deberían tirar el proceso si fallan)
    try { loadCommands(); } catch (e) { console.error('Error cargando comandos:', e); }
    try { loadComponents(); } catch (e) { console.error('Error cargando componentes:', e); }
    try { loadEvents(); } catch (e) { console.error('Error cargando eventos:', e); }

    // Registrar comandos en segundo plano con reintentos; no bloquea el arranque del bot
    withRetry('Registrar slash commands', async () => {
        await registeringCommands();
    }).catch((e) => console.error('Registro de comandos agotó reintentos:', e));

    // Conectar Redis con reintentos
    await withRetry('Conectar a Redis', async () => {
        await redisConnect();
    });

    // Login Discord + DB con reintentos (gestionado en Amayo.play -> conecta Prisma + login)
    await withRetry('Login de Discord', async () => {
        await bot.play();
    }, {
        isRetryable: (err) => {
            const msg = err instanceof Error ? `${err.message}` : String(err);
            // Si falta el TOKEN o token inválido, no tiene sentido reintentar sin cambiar config
            return !/missing discord token|invalid token/i.test(msg);
        }
    });

    console.log("✅ Bot conectado a Discord");
}

// Bucle de arranque resiliente: si bootstrap completo falla, reintenta sin matar el proceso
(async function startLoop() {
    await withRetry('Arranque', bootstrap, {
        minDelayMs: 1000,
        maxDelayMs: 60_000,
        isRetryable: (err) => {
            const msg = err instanceof Error ? `${err.message}` : String(err);
            // No reintentar en bucle si el problema es falta/invalid token
            return !/missing discord token|invalid token/i.test(msg);
        }
    });
})();