const express = require('express'); const cors = require('cors'); const path = require('path'); require('dotenv').config(); const { logSh } = require('./lib/ErrorReporting'); // Using unified logSh from ErrorReporting // Import du workflow principal (version simplifiée pour démarrage) const { handleFullWorkflow, testMainWorkflow } = require('./lib/SimpleMain'); const { getBrainConfig } = require('./lib/BrainConfig'); const { testLLMManagerComplete } = require('./lib/LLMManager'); const { triggerAutonomousWorkflow, testDigitalOceanConnection, readCSVDataWithXMLFileName, fetchXMLFromDigitalOceanSimple } = require('./lib/DigitalOceanWorkflow'); // Import du workflow modulaire const { handleModularWorkflow, benchmarkStacks } = require('./lib/main_modulaire'); const app = express(); const PORT = process.env.PORT || 3000; // Middleware app.use(express.json()); app.use(cors()); app.use(express.static('public')); // Pour servir les fichiers statiques // Dashboard HTML app.get('/', (req, res) => { res.send(` SEO Generator Server - Dashboard

🚀 SEO Generator Server Dashboard

Status: Serveur actif depuis ${Math.floor(process.uptime())} secondes
Version Node: ${process.version}
Timestamp: ${new Date().toISOString()}

🎯 Workflow Principal

Traitement automatique des Google Sheets avec génération de contenu SEO.

🤖 Tests LLM

Vérifier la connectivité et fonctionnement des modèles IA.

📊 Configuration

Gestion des données et personnalités IA.

🌊 DigitalOcean Workflow

Récupération XML depuis DigitalOcean et traitement automatique.

🧪 Interface Test Modulaire

Interface web avancée pour tester toutes les combinaisons modulaires.

🚀 Ouvrir Interface Test

🔗 Tests Réseau

`); }); // API Routes app.get('/api/status', (req, res) => { res.json({ success: true, status: 'running', uptime: process.uptime(), timestamp: new Date().toISOString(), node_version: process.version, memory: process.memoryUsage() }); }); // Test du workflow principal app.get('/api/test-workflow', async (req, res) => { try { logSh('🧪 Test workflow principal...', 'INFO'); // Using logSh instead of console.log const result = await testMainWorkflow(); res.json({ success: true, message: 'Test workflow terminé avec succès', result: result }); } catch (error) { logSh('❌ Erreur test workflow: ' + error.message, 'ERROR'); // Using logSh instead of console.error res.status(500).json({ success: false, error: error.message, stack: error.stack }); } }); // Test des LLM app.get('/api/test-llm', async (req, res) => { try { logSh('🌐 Test connectivité LLM...', 'INFO'); // Using logSh instead of console.log const result = await testLLMManagerComplete(); res.json({ success: true, message: 'Test LLM terminé', result: result }); } catch (error) { logSh('❌ Erreur test LLM: ' + error.message, 'ERROR'); // Using logSh instead of console.error res.status(500).json({ success: false, error: error.message }); } }); // Test de configuration app.get('/api/test-config', async (req, res) => { try { logSh('⚙️ Test configuration...', 'INFO'); // Using logSh instead of console.log const result = await getBrainConfig(2); res.json({ success: true, message: 'Test configuration terminé', result: result }); } catch (error) { logSh('❌ Erreur test config: ' + error.message, 'ERROR'); // Using logSh instead of console.error res.status(500).json({ success: false, error: error.message }); } }); // Test connexion DigitalOcean app.get('/api/test-digitalocean', async (req, res) => { try { logSh('🧪 Test connexion DigitalOcean...', 'INFO'); // Using logSh instead of console.log const result = await testDigitalOceanConnection(); res.json({ success: result, message: result ? 'Connexion DigitalOcean fonctionnelle' : 'Connexion DigitalOcean échouée', timestamp: new Date().toISOString() }); } catch (error) { logSh('❌ Erreur test DO: ' + error.message, 'ERROR'); // Using logSh instead of console.error res.status(500).json({ success: false, error: error.message }); } }); // Déclencher workflow DigitalOcean pour une ligne spécifique app.get('/api/digitalocean-workflow/:rowNumber', async (req, res) => { try { const rowNumber = parseInt(req.params.rowNumber); if (!rowNumber || rowNumber < 2) { return res.status(400).json({ success: false, error: 'Numéro de ligne invalide (minimum 2)' }); } logSh(`🌊 Déclenchement workflow DigitalOcean ligne ${rowNumber}...`, 'INFO'); // Using logSh instead of console.log const result = await triggerAutonomousWorkflow(rowNumber); res.json({ success: true, message: `✅ Workflow DigitalOcean ligne ${rowNumber} terminé`, rowNumber: rowNumber, result: result, source: 'digitalocean_autonomous' }); } catch (error) { logSh('❌ Erreur workflow DO: ' + error.message, 'ERROR'); // Using logSh instead of console.error res.status(500).json({ success: false, error: error.message, rowNumber: req.params.rowNumber, stack: error.stack }); } }); // Récupérer données CSV pour une ligne (debug) app.get('/api/digitalocean-csv/:rowNumber', async (req, res) => { try { const rowNumber = parseInt(req.params.rowNumber); logSh(`📋 Récupération CSV ligne ${rowNumber}...`, 'INFO'); // Using logSh instead of console.log const csvData = await readCSVDataWithXMLFileName(rowNumber); res.json({ success: true, message: 'Données CSV récupérées', rowNumber: rowNumber, csvData: csvData }); } catch (error) { logSh('❌ Erreur CSV DO: ' + error.message, 'ERROR'); // Using logSh instead of console.error res.status(500).json({ success: false, error: error.message, rowNumber: req.params.rowNumber }); } }); // Récupérer XML depuis DigitalOcean (debug) app.get('/api/digitalocean-xml/:fileName', async (req, res) => { try { const fileName = req.params.fileName; logSh(`📄 Récupération XML: ${fileName}`, 'INFO'); // Using logSh instead of console.log const xmlContent = await fetchXMLFromDigitalOceanSimple(fileName); res.json({ success: true, message: 'XML récupéré depuis DigitalOcean', fileName: fileName, contentLength: xmlContent.length, content: xmlContent.substring(0, 500) + '...' // Premier extrait }); } catch (error) { logSh('❌ Erreur XML DO: ' + error.message, 'ERROR'); // Using logSh instead of console.error res.status(500).json({ success: false, error: error.message, fileName: req.params.fileName }); } }); // Vérifier Google Sheets et traiter app.get('/api/check-and-process', async (req, res) => { try { logSh('🔍 Vérification Google Sheets...', 'INFO'); // Using logSh instead of console.log // TODO: Implémenter vérification Google Sheets // Pour l'instant, on simule avec des données test const testData = { csvData: { mc0: 'plaque signalétique professionnelle', t0: 'Découvrez nos plaques signalétiques sur mesure', personality: { nom: 'Marc', style: 'professionnel' }, tMinus1: 'Signalétique entreprise', mcPlus1: 'plaque dibond,plaque aluminium,plaque gravée,signalétique bureau', tPlus1: 'Plaque Dibond,Plaque Aluminium,Plaque Gravée,Signalétique Bureau' }, xmlTemplate: Buffer.from('

|Title_Main{{T0}}|

|Content_Intro{{MC0}}|

').toString('base64'), source: 'node_server_check' }; const result = await handleFullWorkflow(testData); res.json({ success: true, message: '✅ Traitement Google Sheets terminé', processed: true, result: result }); } catch (error) { logSh('❌ Erreur check-and-process: ' + error.message, 'ERROR'); // Using logSh instead of console.error res.status(500).json({ success: false, error: error.message, stack: error.stack }); } }); // 🆕 ROUTE PING MULTIPLE (Tests réseau) app.get('/ping-all', async (req, res) => { const targets = [ 'https://www.google.com', 'https://api.openai.com', 'https://api.anthropic.com', 'https://generativelanguage.googleapis.com' ]; logSh('🔍 Ping services réseau...', 'INFO'); // Using logSh instead of console.log const results = await Promise.allSettled( targets.map(async (url) => { const startTime = Date.now(); try { const response = await fetch(url, { method: 'HEAD', timeout: 5000 }); return { url, success: true, status: response.status, duration_ms: Date.now() - startTime, message: `✅ ${url} accessible` }; } catch (error) { return { url, success: false, error: error.message, duration_ms: Date.now() - startTime, message: `❌ ${url} inaccessible` }; } }) ); const successCount = results.filter(r => r.value?.success || r.status === 'fulfilled').length; res.json({ timestamp: new Date().toISOString(), summary: `${successCount}/${targets.length} services accessibles`, results: results.map(r => r.value || r.reason) }); }); // ============= NOUVEAUX ENDPOINTS MODULAIRES ============= // Test modulaire individuel app.post('/api/test-modulaire', async (req, res) => { try { const config = req.body; logSh(`🧪 Test modulaire: ${config.selectiveStack} + ${config.adversarialMode} + ${config.humanSimulationMode} + ${config.patternBreakingMode}`, 'INFO'); // Validation des paramètres if (!config.rowNumber || config.rowNumber < 2) { return res.status(400).json({ success: false, error: 'Numéro de ligne invalide (minimum 2)' }); } const result = await handleModularWorkflow(config); logSh(`✅ Test modulaire terminé: ${result.stats.totalDuration}ms`, 'INFO'); res.json({ success: true, message: 'Test modulaire terminé avec succès', stats: result.stats, config: config, timestamp: new Date().toISOString() }); } catch (error) { logSh(`❌ Erreur test modulaire: ${error.message}`, 'ERROR'); res.status(500).json({ success: false, error: error.message, config: req.body, timestamp: new Date().toISOString() }); } }); // Benchmark modulaire complet app.post('/api/benchmark-modulaire', async (req, res) => { try { const { rowNumber = 2 } = req.body; logSh(`📊 Benchmark modulaire ligne ${rowNumber}...`, 'INFO'); if (rowNumber < 2) { return res.status(400).json({ success: false, error: 'Numéro de ligne invalide (minimum 2)' }); } const benchResults = await benchmarkStacks(rowNumber); const successfulTests = benchResults.filter(r => r.success); const avgDuration = successfulTests.length > 0 ? successfulTests.reduce((sum, r) => sum + r.duration, 0) / successfulTests.length : 0; logSh(`📊 Benchmark terminé: ${successfulTests.length}/${benchResults.length} tests réussis`, 'INFO'); res.json({ success: true, message: `Benchmark terminé: ${successfulTests.length}/${benchResults.length} tests réussis`, summary: { totalTests: benchResults.length, successfulTests: successfulTests.length, failedTests: benchResults.length - successfulTests.length, averageDuration: Math.round(avgDuration), rowNumber: rowNumber }, results: benchResults, timestamp: new Date().toISOString() }); } catch (error) { logSh(`❌ Erreur benchmark modulaire: ${error.message}`, 'ERROR'); res.status(500).json({ success: false, error: error.message, timestamp: new Date().toISOString() }); } }); // Endpoint pour récupérer la configuration disponible app.get('/api/modulaire-config', (req, res) => { try { const config = { selectiveStacks: [ { value: 'lightEnhancement', name: 'Light Enhancement', description: 'Améliorations légères' }, { value: 'standardEnhancement', name: 'Standard Enhancement', description: 'Améliorations standard' }, { value: 'fullEnhancement', name: 'Full Enhancement', description: 'Améliorations complètes' }, { value: 'personalityFocus', name: 'Personality Focus', description: 'Focus personnalité' }, { value: 'fluidityFocus', name: 'Fluidity Focus', description: 'Focus fluidité' }, { value: 'adaptive', name: 'Adaptive', description: 'Adaptation automatique' } ], adversarialModes: [ { value: 'none', name: 'None', description: 'Aucune technique adversariale' }, { value: 'light', name: 'Light', description: 'Techniques adversariales légères' }, { value: 'standard', name: 'Standard', description: 'Techniques adversariales standard' }, { value: 'heavy', name: 'Heavy', description: 'Techniques adversariales intensives' }, { value: 'adaptive', name: 'Adaptive', description: 'Adaptation automatique' } ], humanSimulationModes: [ { value: 'none', name: 'None', description: 'Aucune simulation humaine' }, { value: 'lightSimulation', name: 'Light Simulation', description: 'Simulation légère' }, { value: 'standardSimulation', name: 'Standard Simulation', description: 'Simulation standard' }, { value: 'heavySimulation', name: 'Heavy Simulation', description: 'Simulation intensive' }, { value: 'adaptiveSimulation', name: 'Adaptive Simulation', description: 'Simulation adaptative' }, { value: 'personalityFocus', name: 'Personality Focus', description: 'Focus personnalité' }, { value: 'temporalFocus', name: 'Temporal Focus', description: 'Focus temporel' } ], patternBreakingModes: [ { value: 'none', name: 'None', description: 'Aucun pattern breaking' }, { value: 'lightPatternBreaking', name: 'Light Pattern Breaking', description: 'Pattern breaking léger' }, { value: 'standardPatternBreaking', name: 'Standard Pattern Breaking', description: 'Pattern breaking standard' }, { value: 'heavyPatternBreaking', name: 'Heavy Pattern Breaking', description: 'Pattern breaking intensif' }, { value: 'adaptivePatternBreaking', name: 'Adaptive Pattern Breaking', description: 'Pattern breaking adaptatif' }, { value: 'syntaxFocus', name: 'Syntax Focus', description: 'Focus syntaxe uniquement' }, { value: 'connectorsFocus', name: 'Connectors Focus', description: 'Focus connecteurs uniquement' } ] }; res.json({ success: true, config: config, timestamp: new Date().toISOString() }); } catch (error) { logSh(`❌ Erreur config modulaire: ${error.message}`, 'ERROR'); res.status(500).json({ success: false, error: error.message }); } }); // Middleware de gestion d'erreurs global app.use((error, req, res, next) => { logSh('❌ Erreur serveur: ' + error.message, 'ERROR'); // Using logSh instead of console.error res.status(500).json({ success: false, error: 'Erreur serveur interne', message: error.message, timestamp: new Date().toISOString() }); }); // Route 404 app.use('*', (req, res) => { res.status(404).json({ success: false, error: 'Route non trouvée', path: req.originalUrl, message: 'Cette route n\'existe pas' }); }); // Démarrage serveur app.listen(PORT, () => { logSh(`🚀 === SEO Generator Server Dashboard ===`, 'INFO'); // Using logSh instead of console.log logSh(`🌐 Interface Web: http://localhost:${PORT}`, 'INFO'); // Using logSh instead of console.log logSh(`📊 API Status: http://localhost:${PORT}/api/status`, 'INFO'); // Using logSh instead of console.log logSh(`🔗 Tests Réseau: http://localhost:${PORT}/ping-all`, 'INFO'); // Using logSh instead of console.log logSh(`✅ Serveur prêt à traiter les workflows SEO !`, 'INFO'); // Using logSh instead of console.log logSh(`🎯 Version: Phase 2 Anti-Détection Ready`, 'INFO'); // Using logSh instead of console.log });