couteau_suisse/palworld-bridge.js

const axios = require('axios');
const { getUserLink, getAllLinks } = require('./database.js');

let bridgeClient = null;
let bridgeChannelId = null;

// Initialiser le bridge
const initPalworldBridge = (client, channelId) => {
    bridgeClient = client;
    bridgeChannelId = channelId;
    
    console.log(`🌉 Pont Palworld-Discord initialisé (Salon: ${channelId})`);
    
    // Écouter les messages du salon Discord
    client.on('messageCreate', async (message) => {
        // Ignorer les messages du bot lui-même
        if (message.author.bot) return;
        
        // Vérifier que c'est bien le salon du pont
        if (message.channelId !== bridgeChannelId) return;
        
        console.log(`📨 [BRIDGE] Message Discord détecté de ${message.author.tag}: ${message.content}`);
        
        try {
            // Récupérer le pseudo Palworld lié
            const userLink = await getUserLink(message.author.id);
            console.log(`🔍 [BRIDGE] Liaison trouvée pour ${message.author.tag}:`, userLink);
            
            if (!userLink) {
                // L'utilisateur n'est pas lié
                console.log(`⚠️ [BRIDGE] ${message.author.tag} n'est pas lié`);
                await message.reply('❌ Vous devez lier votre compte Palworld pour envoyer des messages. Utilisez `/lier-rygainland`');
                return;
            }
            
            // Envoyer le message vers Palworld via broadcast
            console.log(`🚀 [BRIDGE] Envoi vers Palworld: ${userLink.palworld_username}: ${message.content}`);
            await sendToPalworld(userLink.palworld_username, message.content);
            console.log(`✅ [BRIDGE] Message envoyé avec succès vers Palworld`);
            
        } catch (error) {
            console.error('Erreur lors de l\'envoi du message vers Palworld:', error);
            await message.reply('❌ Erreur lors de l\'envoi du message vers Palworld').catch(() => {});
        }
    });
};

// Envoyer un message vers Palworld via RCON broadcast
const sendToPalworld = async (palworldUsername, content) => {
    try {
        // Nettoyer le message (enlever les mentions, emojis personnalisés, etc.)
        let cleanContent = content
            .replace(/<@!?\d+>/g, '@utilisateur') // Remplacer les mentions
            .replace(/<#\d+>/g, '#salon') // Remplacer les mentions de salons
            .replace(/<:.+?:\d+>/g, '') // Enlever les emojis personnalisés
            .replace(/\n/g, ' ') // Remplacer les sauts de ligne
            .trim();
        
        // Limiter la longueur du message
        if (cleanContent.length > 200) {
            cleanContent = cleanContent.substring(0, 197) + '...';
        }
        
        // Format du message pour Palworld
        const broadcastMessage = `[Discord] ${palworldUsername}: ${cleanContent}`;
        
        // Envoyer via l'API Palworld
        await axios({
            method: 'post',
            url: 'http://play.louismazin.ovh:8212/v1/api/announce',
            headers: { 
                'Accept': 'application/json',
                'Content-Type': 'application/json',
                'Authorization': `Basic ${process.env.PALWORLD_API_TOKEN}`
            },
            data: {
                message: broadcastMessage
            }
        });
        
        console.log(`✅ Message envoyé à Palworld: ${broadcastMessage}`);
        
    } catch (error) {
        console.error('Erreur lors de l\'envoi vers Palworld:', error.message);
        throw error;
    }
};

// Parser les messages de chat Palworld et les envoyer sur Discord
const parsePalworldChatAndSend = async (log) => {
    if (!bridgeClient || !bridgeChannelId) {
        console.log('⚠️ [BRIDGE] Bridge non initialisé, impossible de traiter le message');
        return;
    }
    
    // Format: [2026-02-01 13:08:02] [CHAT] <Lili Asuna> coucou
    const chatRegex = /\[.*?\]\s*\[CHAT\]\s*<(.+?)>\s*(.+)/i;
    const match = log.match(chatRegex);
    
    if (!match) return;
    
    console.log(`📥 [BRIDGE] Message Palworld détecté dans les logs`);
    
    const palworldUsername = match[1].trim();
    const messageContent = match[2].trim();
    
    console.log(`📥 [BRIDGE] Palworld: ${palworldUsername}: ${messageContent}`);
    
    // Ignorer les messages de commande !lier
    if (messageContent.toLowerCase().startsWith('!lier')) {
        console.log(`⏭️ [BRIDGE] Commande !lier ignorée`);
        return;
    }
    
    try {
        // Récupérer le salon
        console.log(`🔍 [BRIDGE] Récupération du salon ${bridgeChannelId}...`);
        const channel = await bridgeClient.channels.fetch(bridgeChannelId).catch(() => null);
        if (!channel) {
            console.error('❌ Impossible de trouver le salon du pont');
            return;
        }
        
        // Chercher si le joueur a un compte Discord lié
        const allLinks = await getAllLinks();
        const linkedUser = allLinks.find(link => link.palworld_username === palworldUsername);
        
        if (linkedUser) {
            // Utilisateur lié : utiliser webhook pour afficher sa PP et son pseudo Discord
            try {
                const discordUser = await bridgeClient.users.fetch(linkedUser.discord_id).catch(() => null);
                
                if (discordUser) {
                    // Créer ou récupérer un webhook pour ce salon
                    const webhooks = await channel.fetchWebhooks();
                    let webhook = webhooks.find(wh => wh.name === 'Palworld Bridge');
                    
                    if (!webhook) {
                        webhook = await channel.createWebhook({
                            name: 'Palworld Bridge',
                            avatar: 'https://i.imgur.com/AfFp7pu.png' // Logo Palworld
                        });
                    }
                    
                    // Envoyer via webhook avec le pseudo et l'avatar Discord
                    await webhook.send({
                        content: messageContent,
                        username: discordUser.username,
                        avatarURL: discordUser.displayAvatarURL({ dynamic: true, size: 256 })
                    });
                    
                    console.log(`✅ Message Palworld envoyé sur Discord (via webhook): ${discordUser.username}: ${messageContent}`);
                    return;
                }
            } catch (error) {
                console.error('Erreur lors de l\'envoi via webhook:', error);
                // Fallback vers message normal
            }
        }
        
        // Utilisateur non lié ou erreur webhook : envoyer un message normal
        await channel.send(`**${palworldUsername}**: ${messageContent}`);
        console.log(`✅ Message Palworld envoyé sur Discord: ${palworldUsername}: ${messageContent}`);
        
    } catch (error) {
        console.error('Erreur lors de l\'envoi du message Palworld vers Discord:', error);
    }
};

// Fonction appelée par consoleMonitor pour traiter les messages de chat
const handlePalworldChat = async (log) => {
    await parsePalworldChatAndSend(log);
};

module.exports = {
    initPalworldBridge,
    handlePalworldChat
};