import { promises as fs } from 'fs';
import { join, dirname } from 'path';
import { fileURLToPath } from 'url';
import Logger from './logger.js';
// Configuration : chemin absolu vers le dossier data (indépendant de process.cwd())
const __filename = fileURLToPath(import.meta.url);
const __dirname = dirname(__filename);
const DATA_DIR = join(__dirname, '../../data');
const LOGS_FILE = join(DATA_DIR, 'logs.json');
// Types
export interface LogEntry {
id: string;
timestamp: Date;
guildId: string;
guildName: string;
event: string;
channelId?: string;
channelName?: string;
userId?: string;
username?: string;
targetId?: string;
targetUsername?: string;
action?: string;
reason?: string;
data?: any;
}
import { PersistenceManager } from './persistenceManager.js';
const LOG_PERSISTENCE = new PersistenceManager<LogEntry[]>(LOGS_FILE, 5000); // 5s debounce for logs as they are frequent
// Charger tous les logs depuis le fichier
export async function loadLogs(): Promise<Map<string, LogEntry>> {
const logsArray = await LOG_PERSISTENCE.load([]);
const logsMap = new Map<string, LogEntry>();
logsArray.forEach(log => {
log.timestamp = new Date(log.timestamp);
logsMap.set(log.id, log);
});
Logger.info(`✅ ${logsMap.size} logs chargés avec robustesse`);
return logsMap;
}
// Sauvegarder tous les logs dans le fichier
export async function saveLogs(logs: Map<string, LogEntry>): Promise<void> {
const logsArray = Array.from(logs.values());
// Convertir les dates en strings pour la sérialisation JSON
const logsToSave = logsArray.map(log => ({
...log,
timestamp: (log.timestamp instanceof Date) ? log.timestamp.toISOString() : log.timestamp,
}));
// Pour les logs, on peut utiliser debounced pour ne pas ralentir le bot
LOG_PERSISTENCE.saveDebounced(logsToSave as any);
}
// Ajouter un nouveau log
export async function addLog(log: LogEntry, logs: Map<string, LogEntry>): Promise<void> {
logs.set(log.id, log);
await saveLogs(logs);
}
// Créer une entrée de log
export function createLog(
guildId: string,
guildName: string,
event: string,
data: Partial<LogEntry> = {}
): LogEntry {
return {
id: `log_${Date.now()}_${Math.random().toString(36).substr(2, 9)}`,
timestamp: new Date(),
guildId,
guildName,
event,
...data,
};
}
// Filtrer les logs par critère
export function filterLogs(
logs: Map<string, LogEntry>,
filters: {
guildId?: string;
event?: string;
userId?: string;
startDate?: Date;
endDate?: Date;
}
): LogEntry[] {
return Array.from(logs.values()).filter(log => {
if (filters.guildId && log.guildId !== filters.guildId) return false;
if (filters.event && log.event !== filters.event) return false;
if (filters.userId && log.userId !== filters.userId) return false;
if (filters.startDate && log.timestamp < filters.startDate) return false;
if (filters.endDate && log.timestamp > filters.endDate) return false;
return true;
});
}
// Nettoyer les logs anciens (plus de 30 jours)
export async function cleanOldLogs(logs: Map<string, LogEntry>): Promise<number> {
const now = new Date();
const thirtyDaysAgo = new Date(now.getTime() - 30 * 24 * 60 * 60 * 1000);
let removedCount = 0;
for (const [id, log] of logs.entries()) {
if (log.timestamp < thirtyDaysAgo) {
logs.delete(id);
removedCount++;
}
}
if (removedCount > 0) {
await saveLogs(logs);
Logger.info(`🧹 ${removedCount} logs anciens supprimés`);
}
return removedCount;
}
