put_contents( $filepath, $json, $chmod ); self::cleanupOldLogs(); } /** * Read all stored request logs. * * @return array */ public static function getRequestLogs() { $dir = self::getQueueDir(); if ( ! is_dir( $dir ) ) { return []; } $files = glob( $dir . '*.json' ); if ( ! is_array( $files ) ) { return []; } // Newest first rsort( $files ); $logs = []; foreach ( $files as $file ) { $content = file_get_contents( $file ); if ( ! is_string( $content ) ) { continue; } $decoded = json_decode( $content, true ); if ( is_array( $decoded ) ) { $logs[] = $decoded; } } return $logs; } /** * Remove old log files beyond the max limit. * * @return void */ private static function cleanupOldLogs() { $dir = self::getQueueDir(); if ( ! is_dir( $dir ) ) { return; } $files = glob( $dir . '*.json' ); if ( ! is_array( $files ) || count( $files ) <= self::MAX_STORED_REQUESTS_COUNT ) { return; } // Oldest first sort( $files ); $filesToDelete = array_slice( $files, 0, count( $files ) - self::MAX_STORED_REQUESTS_COUNT ); foreach ( $filesToDelete as $file ) { unlink( $file ); } } /** * Remove all stored request log files. * * @return bool */ public static function clearAllLogs() { $dir = self::getQueueDir(); if ( ! is_dir( $dir ) ) { return true; } $files = glob( $dir . '*.json' ); if ( ! is_array( $files ) ) { return false; } foreach ( $files as $file ) { unlink( $file ); } return true; } /** * Get number of stored request logs. * * @return int */ public static function getLogsCount() { $dir = self::getQueueDir(); if ( ! is_dir( $dir ) ) { return 0; } $files = glob( $dir . '*.json' ); if ( ! is_array( $files ) ) { return 0; } return count( $files ); } /** * Generate unique filename for request log. * * @return string */ private static function generateFilename() { return gmdate( 'Y-m-d\TH-i-s' ) . '_' . uniqid() . '.json'; } }