1. <?php
  3. /**
  4. * Flags anomalies in log files for scheduled runs with graceful failure handling.
  5. *
  6. * @param string $logFilePath The path to the log file.
  7. * @param array $anomalyRules An array of anomaly rules. Each rule should be an array
  8. * with 'pattern' (regex) and 'threshold' (integer).
  9. * @param string $outputFile The path to the output file for flagged anomalies.
  10. * @return bool True on success, false on failure.
  11. */
  12. function flagLogAnomalies(string $logFilePath, array $anomalyRules, string $outputFile): bool
  13. {
  14. try {
  15. // Validate input
  16. if (!file_exists($logFilePath)) {
  17. throw new InvalidArgumentException("Log file not found: $logFilePath");
  18. }
  19. if (!is_array($anomalyRules) || empty($anomalyRules)) {
  20. throw new InvalidArgumentException("Anomaly rules must be a non-empty array.");
  21. }
  22. if (!is_string($outputFile)) {
  23. throw new InvalidArgumentException("Output file must be a string.");
  24. }
  26. $anomalies = [];
  28. // Read the log file line by line
  29. if (($handle = fopen($logFilePath, "r")) !== FALSE) {
  30. while (($line = fgets($handle)) !== FALSE) {
  31. foreach ($anomalyRules as $rule) {
  32. $pattern = $rule['pattern'];
  33. $threshold = $rule['threshold'];
  35. if (preg_match($pattern, $line)) {
  36. $anomalies[] = [
  37. 'line' => $line,
  38. 'rule' => $rule,
  39. ];
  40. }
  41. }
  42. }
  43. fclose($handle);
  44. } else {
  45. throw new RuntimeException("Failed to open log file: $logFilePath");
  46. }
  48. // Write anomalies to the output file
  49. if (file_put_contents($outputFile, json_encode($anomalies), FILE_APPEND | LOCK_EX) === FALSE) {
  50. throw new RuntimeException("Failed to write anomalies to output file: $outputFile");
  51. }
  53. return true;
  55. } catch (Exception $e) {
  56. error_log("Error flagging log anomalies: " . $e->getMessage());
  57. return false;
  58. }
  59. }

Add your comment