Stats.php

Go to the documentation of this file.

<?php

namespace Rsi\Fred\Log\Handler;

class Stats extends \Rsi\Fred\Log\Handler{

  public $filename = null; //!< File to store messages.
  public $ttl = 3600; //!< Time to keep messages in memory.
  public $charThreshold = 100; //!< Minimum number of charactes to match, or:
  public $percThreshold = 75; //!< Minimum percentage to match.
  public $threshold = 10; //!< Send mail after this number of messages within the TTL.
  public $from = null; //!< Sender (defaults to default From address).
  public $to = null; //!< Send mail to this address (or array for multiple; defaults to default From address).
  public $subject = 'Log stats *'; //!< Subject for the mail (an asterisk is replaced with the host name).
  public $message = 'Message "[message]" ([filename]@[lineNo]) occurred [threshold] times in the last [ttl] seconds'; //!< Mail
    // message (tags [filename], [lineNo], [message], [threshold] and [ttl] are replaced with their values).

  protected function same($new_message,$old_message){
    return (similar_text($new_message,$old_message,$perc) >= $this->charThreshold) || ($perc >= $this->percThreshold);
  }

  protected function send($filename,$line_no,$message){
    return $this->_log->component('mail')->send(
      $this->from,
      $this->to ?: ini_get('sendmail_from'),
      str_replace('*',\Rsi\Http::host(),$this->subject),
      strtr($this->message,[
        '[filename]' => $filename ?: 'unknown',
        '[lineNo]' => $line_no ?: 0,
        '[message]' => $message,
        '[threshold]' => $this->threshold,
        '[ttl]' => $this->ttl
      ])
    );
  }

  public function add($prio,$message,$context){
    if($this->filename) try{
      $records = \Rsi\File::unserialize($this->filename,[]);
      $limit = time() - $this->ttl;
      foreach($records as $index => &$record){
        $times = [];
        foreach($record['times'] as $time) if($time > $limit) $times[] = $time;
        if($times) $record['times'] = $times;
        else unset($records[$index]);
      }
      unset($record);
      $filename = $context['filename'] ?? null;
      $line_no = $context['lineNo'] ?? null;
      foreach($records as $index => &$record) if(
        ($record['filename'] == $filename) &&
        ($record['lineNo'] == $line_no) &&
        $this->same($message,$record['message'])
      ){
        if((count($record['times']) >= $this->threshold) && $this->send($filename,$line_no,$message)) $record['times'] = [];
        $record['times'][] = time();
        $message = false;
        break;
      }
      unset($record);
      if($message) $records[] = ['filename' => $filename,'lineNo' => $line_no,'message' => $message,'times' => [time()]];
      \Rsi\File::serialize($this->filename,$records);
    }
    catch(\Exception $e){
      if($this->_log->fred->debug) throw $e;
    }
  }

}