> Associative array of log type => class name */ private static array $registeredLogTypes = []; /** * Register all log types * * @return void */ public static function registerAllLogTypes(): void { self::registerLogType(LogEventBackupCreate::getType(), LogEventBackupCreate::class); self::registerLogType(LogEventBackupDelete::getType(), LogEventBackupDelete::class); self::registerLogType(LogEventWebsitesScan::getType(), LogEventWebsitesScan::class); self::registerLogType(LogEventSettingsChange::getType(), LogEventSettingsChange::class); self::registerLogType(LogEventOrphanCleanup::getType(), LogEventOrphanCleanup::class); self::registerLogType(LogEventStorageDelete::getType(), LogEventStorageDelete::class); self::registerLogType(LogEventLoopbackFailure::getType(), LogEventLoopbackFailure::class); do_action('duplicator_register_activity_log_types'); } /** * Get all log types, key is type, value is label * * @return array */ public static function getAllLogTypes(): array { $result = []; foreach (self::$registeredLogTypes as $type => $class) { $result[$type] = $class::getTypeLabel(); } return $result; } /** * Register a log type * * @param string $type The log type * @param class-string $class The class name * * @return void */ public static function registerLogType(string $type, string $class): void { self::$registeredLogTypes[$type] = $class; } /** * Get a class by log type * * @param string $type The log type * * @return class-string */ public static function getClassByType(string $type): string { return self::$registeredLogTypes[$type] ?? LogEventUnknown::class; } /** * Get labels of severity levels * * @return array */ public static function getSeverityLabels(): array { return [ AbstractLogEvent::SEVERITY_INFO => __('Info', 'duplicator'), AbstractLogEvent::SEVERITY_WARNING => __('Warning', 'duplicator'), AbstractLogEvent::SEVERITY_ERROR => __('Error', 'duplicator'), ]; } /** * Clean up old activity logs based on retention settings * Deletes all logs older than the specified retention period in seconds * * @return int Number of logs deleted, 0 if retention is disabled or no logs to delete */ public static function cleanupOldLogs(): int { /** @var \wpdb $wpdb */ global $wpdb; $dGlobal = DynamicGlobalEntity::getInstance(); $retentionSeconds = $dGlobal->getValInt('activity_log_retention'); // If retention is 0, keep all logs forever if ($retentionSeconds <= 0) { return 0; } // Calculate cutoff date (X seconds ago) $cutoffDate = gmdate('Y-m-d H:i:s', time() - $retentionSeconds); $tableName = AbstractLogEvent::getTableName(); // Delete old logs $deletedRows = $wpdb->query($wpdb->prepare( "DELETE FROM `{$tableName}` WHERE created_at < %s", $cutoffDate )); return (int) $deletedRows; } /** * Delete all activity logs from the database in batches * * @return int Number of logs deleted */ public static function deleteAllLogs(): int { $totalDeleted = 0; while (($deleted = self::deleteLogsChunk()) > 0) { $totalDeleted += $deleted; } return $totalDeleted; } /** * Delete a chunk of activity logs * * @param int $limit Number of logs to delete in this chunk * * @return int Number of logs deleted in this chunk */ public static function deleteLogsChunk(int $limit = self::BULK_DELETE_LIMIT_CHUNK): int { /** @var \wpdb $wpdb */ global $wpdb; $tableName = AbstractLogEvent::getTableName(); $deletedRows = $wpdb->query( $wpdb->prepare( "DELETE FROM `{$tableName}` ORDER BY id ASC LIMIT %d", $limit ) ); return $deletedRows !== false ? (int) $deletedRows : 0; } }