✅ Mode MANUAL Actif
Interface complète disponible • WebSocket temps réel • API complète
${this.stats.requests}
Requêtes
${this.activeClients.size}
Clients WebSocket
${this.stats.testsExecuted}
Tests Exécutés
🌐 WebSocket Logs
Logs temps réel sur ws://localhost:${this.config.wsPort}
Status: Déconnecté
💡 Informations Mode MANUAL
- Interface Client : Dashboard complet et interface de test
- API Complète : Tests individuels, benchmarks, configuration
- WebSocket : Logs temps réel sur port ${this.config.wsPort}
- Multi-Client : Plusieurs utilisateurs simultanés
- Pas de GSheets : Données test simulées ou fournies
`;
}
// ========================================
// WEBSOCKET SERVER
// ========================================
/**
* Configure le serveur WebSocket pour logs temps réel
*/
async setupWebSocketServer() {
try {
this.wsServer = new WebSocket.Server({
port: this.config.wsPort,
host: this.config.host
});
this.wsServer.on('connection', (ws, req) => {
this.handleWebSocketConnection(ws, req);
});
this.wsServer.on('error', (error) => {
logSh(`❌ Erreur WebSocket: ${error.message}`, 'ERROR');
});
logSh(`📡 WebSocket Server démarré sur ws://${this.config.host}:${this.config.wsPort}`, 'DEBUG');
} catch (error) {
logSh(`⚠️ Impossible de démarrer WebSocket: ${error.message}`, 'WARNING');
// Continue sans WebSocket si erreur
}
}
/**
* Gère les nouvelles connexions WebSocket
*/
handleWebSocketConnection(ws, req) {
const clientId = `client_${Date.now()}_${Math.random().toString(36).substr(2, 9)}`;
const clientIP = req.socket.remoteAddress;
const clientData = { id: clientId, ws, ip: clientIP, connectedAt: Date.now() };
this.activeClients.add(clientData);
this.stats.sessions++;
logSh(`📡 Nouveau client WebSocket: ${clientId} (${clientIP})`, 'TRACE');
// Message de bienvenue
ws.send(JSON.stringify({
type: 'welcome',
message: 'Connecté aux logs temps réel SEO Generator (Mode MANUAL)',
clientId: clientId,
timestamp: new Date().toISOString()
}));
// Gestion fermeture
ws.on('close', () => {
this.activeClients.delete(clientData);
logSh(`📡 Client WebSocket déconnecté: ${clientId}`, 'TRACE');
});
// Gestion erreurs
ws.on('error', (error) => {
this.activeClients.delete(clientData);
logSh(`⚠️ Erreur client WebSocket ${clientId}: ${error.message}`, 'WARNING');
});
}
/**
* Diffuse un message à tous les clients WebSocket
*/
broadcastToClients(logData) {
if (this.activeClients.size === 0) return;
const message = JSON.stringify({
type: 'log',
...logData,
timestamp: new Date().toISOString()
});
this.activeClients.forEach(client => {
if (client.ws.readyState === WebSocket.OPEN) {
try {
client.ws.send(message);
} catch (error) {
// Client déconnecté, le supprimer
this.activeClients.delete(client);
}
}
});
}
/**
* Déconnecte tous les clients WebSocket
*/
disconnectAllClients() {
this.activeClients.forEach(client => {
try {
client.ws.close();
} catch (error) {
// Ignore les erreurs de fermeture
}
});
this.activeClients.clear();
logSh('📡 Tous les clients WebSocket déconnectés', 'DEBUG');
}
// ========================================
// SERVEUR HTTP
// ========================================
/**
* Démarre le serveur HTTP
*/
async startHTTPServer() {
return new Promise((resolve, reject) => {
try {
this.server = this.app.listen(this.config.port, this.config.host, () => {
resolve();
});
this.server.on('error', (error) => {
reject(error);
});
} catch (error) {
reject(error);
}
});
}
// ========================================
// MONITORING
// ========================================
/**
* Démarre le monitoring du serveur
*/
startMonitoring() {
const MONITOR_INTERVAL = 30000; // 30 secondes
this.monitorInterval = setInterval(() => {
this.performMonitoring();
}, MONITOR_INTERVAL);
logSh('💓 Monitoring ManualServer démarré', 'DEBUG');
}
/**
* Effectue le monitoring périodique
*/
performMonitoring() {
const memUsage = process.memoryUsage();
const uptime = Date.now() - this.stats.startTime;
logSh(`💓 ManualServer Health - Clients: ${this.activeClients.size} | Requêtes: ${this.stats.requests} | RAM: ${Math.round(memUsage.rss / 1024 / 1024)}MB`, 'TRACE');
// Nettoyage clients WebSocket morts
this.cleanupDeadClients();
}
/**
* Nettoie les clients WebSocket déconnectés
*/
cleanupDeadClients() {
let cleaned = 0;
const deadClients = [];
this.activeClients.forEach(client => {
if (client.ws.readyState !== WebSocket.OPEN) {
deadClients.push(client);
cleaned++;
}
});
// Supprimer les clients morts
deadClients.forEach(client => {
this.activeClients.delete(client);
});
if (cleaned > 0) {
logSh(`🧹 ${cleaned} clients WebSocket morts nettoyés`, 'TRACE');
}
}
// ========================================
// ÉTAT ET CONTRÔLES
// ========================================
/**
* Vérifie s'il y a des clients actifs
*/
hasActiveClients() {
return this.activeClients.size > 0;
}
/**
* Retourne l'état du serveur MANUAL
*/
getStatus() {
return {
isRunning: this.isRunning,
config: { ...this.config },
stats: {
...this.stats,
uptime: Date.now() - this.stats.startTime
},
activeClients: this.activeClients.size,
urls: {
dashboard: `http://localhost:${this.config.port}`,
testInterface: `http://localhost:${this.config.port}/test-modulaire.html`,
apiStatus: `http://localhost:${this.config.port}/api/status`,
websocket: `ws://localhost:${this.config.wsPort}`
}
};
}
}
// ============= EXPORTS =============
module.exports = { ManualServer };