Source for file Ethna_Logger.php

Documentation is available at Ethna_Logger.php

  1. <?php
  2. // vim: foldmethod=marker
  3. /**
  4.  *  Ethna_Logger.php
  5.  *
  6.  *  @author     Masaki Fujimoto <fujimoto@php.net>
  7.  *  @license    http://www.opensource.org/licenses/bsd-license.php The BSD License
  8.  *  @package    Ethna
  9.  *  @version    $Id$
  10.  */
  11.  
  12. /**
  13.  *  拡張ログプロパティ: ファイル出力
  14.  */
  15. define('LOG_FILE', 1 << 16);
  16.  
  17. /**
  18.  *  拡張ログプロパティ: 標準出力
  19.  */
  20. define('LOG_ECHO', 1 << 17);
  21.  
  22. // {{{ Ethna_Logger
  23. /**
  24.  *  ログ管理クラス
  25.  *
  26.  *  @author     Masaki Fujimoto <fujimoto@php.net>
  27.  *  @access     public
  28.  *  @package    Ethna
  29.  */
  30. class Ethna_Logger extends Ethna_AppManager
  31. {
  32.     // {{{ properties
  33.     /**#@+
  34.      *  @access private
  35.      */
  36.  
  37.     /** @var    array   ログファシリティ一覧 */
  38.     var $log_facility_list = array(
  39.         'auth'      => array('name' => 'LOG_AUTH'),
  40.         'cron'      => array('name' => 'LOG_CRON'),
  41.         'daemon'    => array('name' => 'LOG_DAEMON'),
  42.         'kern'      => array('name' => 'LOG_KERN'),
  43.         'lpr'       => array('name' => 'LOG_LPR'),
  44.         'mail'      => array('name' => 'LOG_MAIL'),
  45.         'news'      => array('name' => 'LOG_NEWS'),
  46.         'syslog'    => array('name' => 'LOG_SYSLOG'),
  47.         'user'      => array('name' => 'LOG_USER'),
  48.         'uucp'      => array('name' => 'LOG_UUCP'),
  49.         'file'      => array('name' => 'LOG_FILE'),
  50.         'echo'      => array('name' => 'LOG_ECHO'),
  51.     );
  52.  
  53.     /** @var    array   ログレベル一覧 */
  54.     var $log_level_list = array(
  55.         'emerg'     => array('name' => 'LOG_EMERG',     'value' => 7),
  56.         'alert'     => array('name' => 'LOG_ALERT',     'value' => 6),
  57.         'crit'      => array('name' => 'LOG_CRIT',      'value' => 5),
  58.         'err'       => array('name' => 'LOG_ERR',       'value' => 4),
  59.         'warning'   => array('name' => 'LOG_WARNING',   'value' => 3),
  60.         'notice'    => array('name' => 'LOG_NOTICE',    'value' => 2),
  61.         'info'      => array('name' => 'LOG_INFO',      'value' => 1),
  62.         'debug'     => array('name' => 'LOG_DEBUG',     'value' => 0),
  63.     );
  64.  
  65.     /** @var    object  Ethna_Controller    controllerオブジェクト */
  66.     var $controller;
  67.  
  68.     /** @var    object  Ethna_Controller    controllerオブジェクト($controllerの省略形) */
  69.     var $ctl;
  70.  
  71.     /** @var    array   ログファシリティ */
  72.     var $facility = array();
  73.  
  74.     /** @var    array   ログレベル */
  75.     var $level = array();
  76.  
  77.     /** @var    array   ログオプション */
  78.     var $option = array();
  79.  
  80.     /** @var    array   メッセージフィルタ(出力) */
  81.     var $message_filter_do = array();
  82.  
  83.     /** @var    array   メッセージフィルタ(無視) */
  84.     var $message_filter_ignore = array();
  85.  
  86.     /** @var    int     アラートレベル */
  87.     var $alert_level;
  88.  
  89.     /** @var    string  アラートメールアドレス */
  90.     var $alert_mailaddress;
  91.  
  92.     /** @var    array   Ethna_LogWriter ログ出力オブジェクト */
  93.     var $writer = array();
  94.  
  95.     /** @var    bool    ログ出力開始フラグ */
  96.     var $is_begin = false;
  97.  
  98.     /** @var    array   ログスタック(begin()前にlog()が呼び出された場合のスタック) */
  99.     var $log_stack = array();
  100.  
  101.     /**#@-*/
  102.     // }}}
  103.     
  104.     // {{{ Ethna_Logger
  105.     /**
  106.      *  Ethna_Loggerクラスのコンストラクタ
  107.      *
  108.      *  @access public
  109.      *  @param  object  Ethna_Controller    $controller controllerオブジェクト
  110.      */
  111.     function Ethna_Logger(&$controller)
  112.     {
  113.         $this->controller =& $controller;
  114.         $this->ctl =& $this->controller;
  115.         $config =& $controller->getConfig();
  116.  
  117.         // ログファシリティテーブル補完(LOCAL0〜LOCAL8)
  118.         for ($i = 0; $i < 8; $i++) {
  119.             if (defined("LOG_LOCAL$i")) {
  120.                 $this->log_facility_list["local$i"] = array('name' => "LOG_LOCAL$i");
  121.             }
  122.         }
  123.  
  124.         $config_log = $config->get('log');
  125.  
  126.         // ログファシリティ
  127.         if (is_array($config_log)) {
  128.             $this->facility = array_keys($config_log);
  129.         } else {
  130.             $this->facility = $this->_parseLogFacility($config->get('log_facility'));
  131.         }
  132.  
  133.         foreach ($this->facility as $f) {
  134.             // ログレベル
  135.             if (isset($config_log[$f]['level'])) {
  136.                 $this->level[$f] = $this->_parseLogLevel($config_log[$f]['level']);
  137.             } else if (($level = $config->get("log_level_$f")) !== null) {
  138.                 $this->level[$f] = $this->_parseLogLevel($level);
  139.             } else if (($level = $config->get("log_level")) !== null) {
  140.                 $this->level[$f] = $this->_parseLogLevel($level);
  141.             } else {
  142.                 $this->level[$f] = LOG_WARNING;
  143.             }
  144.  
  145.             // メッセージフィルタ(filter_do)
  146.             if (isset($config_log[$f]['filter_do'])) {
  147.                 $this->message_filter_do[$f] = $config_log[$f]['filter_do'];
  148.             } else if (($filter = $config->get("log_filter_do_$f")) !== null) {
  149.                 $this->message_filter_do[$f] = $filter;
  150.             } else if (($filter = $config->get("log_filter_do")) !== null) {
  151.                 $this->message_filter_do[$f] = $filter;
  152.             } else {
  153.                 $this->message_filter_do[$f] = '';
  154.             }
  155.  
  156.             // メッセージフィルタ(filter_ignore)
  157.             if (isset($config_log[$f]['filter_ignore'])) {
  158.                 $this->message_filter_ignore[$f] = $config_log[$f]['filter_ignore'];
  159.             } else if (($filter = $config->get("log_filter_ignore_$f")) !== null) {
  160.                 $this->message_filter_ignore[$f] = $filter;
  161.             } else if (($filter = $config->get("log_filter_ignore")) !== null) {
  162.                 $this->message_filter_ignore[$f] = $filter;
  163.             } else {
  164.                 $this->message_filter_ignore[$f] = '';
  165.             }
  166.  
  167.             // そのたオプション (unsetはせずにそのまま渡す)
  168.             if (isset($config_log[$f])) {
  169.                 $this->option[$f] = $config_log[$f];
  170.             } else {
  171.                 $this->option[$f] = array();
  172.             }
  173.  
  174.             // 'option' によるオプション指定 (for B.C.)
  175.             if (isset($config_log[$f]['option'])) {
  176.                 $option = $this->_parseLogOption($config_log[$f]['option']);
  177.             } else if (($option = $config->get("log_option_$f")) !== null) {
  178.                 $option = $this->_parseLogOption($option);
  179.             } else if (($option = $config->get("log_option")) !== null) {
  180.                 $option = $this->_parseLogOption($option);
  181.             }
  182.             if ($option !== null) {
  183.                 $this->option[$f] = array_merge($this->option[$f], $option);
  184.             }
  185.         }
  186.  
  187.         // アラートオプション
  188.         $this->alert_level =
  189.             $this->_parseLogLevel($config->get('log_alert_level'));
  190.         $this->alert_mailaddress
  191.             = preg_split('/\s*,\s*/', $config->get('log_alert_mailaddress'));
  192.     }
  193.     // }}}
  194.  
  195.     // {{{ getLogFacility
  196.     /**
  197.      *  ログファシリティを取得する
  198.      *
  199.      *  @access public
  200.      *  @return mixed   ログファシリティ(ファシリティが1つ以下ならscalar、
  201.      *                   2つ以上なら配列を返す for B.C.)
  202.      */
  203.     function getLogFacility()
  204.     {
  205.         if (is_array($this->facility)) {
  206.             if (count($this->facility) == 0) {
  207.                 return null;
  208.             } else if (count($this->facility) == 1) {
  209.                 return $this->facility[0];
  210.             }
  211.         }
  212.         return $this->facility;
  213.     }
  214.     // }}}
  215.  
  216.     // {{{ errorLevelToLogLevel
  217.     /**
  218.      *  PHPエラーレベルをログレベルに変換する
  219.      *
  220.      *  @access public
  221.      *  @param  int     $errno  PHPエラーレベル
  222.      *  @return array   ログレベル(LOG_NOTICE,...), エラーレベル表示名("E_NOTICE"...)
  223.      *  @static
  224.      */
  225.     function errorLevelToLogLevel($errno)
  226.     {
  227.         switch ($errno) {
  228.         case E_ERROR:           $code = "E_ERROR"; $level = LOG_ERR; break;
  229.         case E_WARNING:         $code = "E_WARNING"; $level = LOG_WARNING; break;
  230.         case E_PARSE:           $code = "E_PARSE"; $level = LOG_CRIT; break;
  231.         case E_NOTICE:          $code = "E_NOTICE"; $level = LOG_NOTICE; break;
  232.         case E_USER_ERROR:      $code = "E_USER_ERROR"; $level = LOG_ERR; break;
  233.         case E_USER_WARNING:    $code = "E_USER_WARNING"; $level = LOG_WARNING; break;
  234.         case E_USER_NOTICE:     $code = "E_USER_NOTICE"; $level = LOG_NOTICE; break;
  235.         case E_STRICT:          $code = "E_STRICT"; $level = LOG_NOTICE; return;
  236.         default:                $code = "E_UNKNOWN"; $level = LOG_DEBUG; break;
  237.         }
  238.         return array($level, $code);
  239.     }
  240.     // }}}
  241.  
  242.     // {{{ begin
  243.     /**
  244.      *  ログ出力を開始する
  245.      *
  246.      *  @access public
  247.      */
  248.     function begin()
  249.     {
  250.         // LogWriterクラスの生成
  251.         foreach ($this->facility as $f) {
  252.             $this->writer[$f] =& $this->_getLogWriter($this->option[$f], $f);
  253.             if (Ethna::isError($this->writer[$f])) {
  254.                 // use default
  255.                 $this->writer[$f] =& $this->_getLogWriter($this->option[$f],
  256.                                                           "default");
  257.             }
  258.         }
  259.  
  260.         foreach (array_keys($this->writer) as $key) {
  261.             $this->writer[$key]->begin();
  262.         }
  263.         
  264.         $this->is_begin = true;
  265.  
  266.         // begin()以前のlog()を処理
  267.         if (count($this->log_stack) > 0) {
  268.             // copy and clear for recursive calls
  269.             $tmp_stack = $this->log_stack;
  270.             $this->log_stack = array();
  271.  
  272.             while (count($tmp_stack) > 0) {
  273.                 $log = array_shift($tmp_stack);
  274.                 $this->log($log[0], $log[1]);
  275.             }
  276.         }
  277.     }
  278.     // }}}
  279.  
  280.     // {{{ log
  281.     /**
  282.      *  ログを出力する
  283.      *
  284.      *  @access public
  285.      *  @param  int     $level      ログレベル(LOG_DEBUG, LOG_NOTICE...)
  286.      *  @param  string  $message    ログメッセージ(+引数)
  287.      */
  288.     function log($level, $message)
  289.     {
  290.         if ($this->is_begin == false) {
  291.             $args = func_get_args();
  292.             if (count($args) > 2) {
  293.                 array_splice($args, 0, 2);
  294.                 $message = vsprintf($message, $args);
  295.             }
  296.             $this->log_stack[] = array($level, $message);
  297.             return;
  298.         }
  299.  
  300.         foreach (array_keys($this->writer) as $key) {
  301.             // ログメッセージフィルタ(レベルフィルタに優先する)
  302.             $r = $this->_evalMessageMask($this->message_filter_do[$key], $message);
  303.             if (is_null($r)) {
  304.                 $r = $this->_evalMessageMask($this->message_filter_ignore[$key],
  305.                                              $message);
  306.                 if ($r) {
  307.                     continue;
  308.                 }
  309.             }
  310.  
  311.             // ログレベルフィルタ
  312.             if ($this->_evalLevelMask($this->level[$key], $level)) {
  313.                 continue;
  314.             }
  315.  
  316.             // ログ出力
  317.             $args = func_get_args();
  318.             if (count($args) > 2) {
  319.                 array_splice($args, 0, 2);
  320.                 $message = vsprintf($message, $args);
  321.             }
  322.             $output = $this->writer[$key]->log($level, $message);
  323.         }
  324.  
  325.         // アラート処理
  326.         if ($this->_evalLevelMask($this->alert_level, $level) == false) {
  327.             if (count($this->alert_mailaddress) > 0) {
  328.                 $this->_alert($output);
  329.             }
  330.         }
  331.     }
  332.     // }}}
  333.  
  334.     // {{{ end
  335.     /**
  336.      *  ログ出力を終了する
  337.      *
  338.      *  @access public
  339.      */
  340.     function end()
  341.     {
  342.         foreach (array_keys($this->writer) as $key) {
  343.             $this->writer[$key]->end();
  344.         }
  345.  
  346.         $this->is_begin = false;
  347.     }
  348.     // }}}
  349.  
  350.     // {{{ _getLogWriter
  351.     /**
  352.      *  LogWriterオブジェクトを取得する
  353.      *
  354.      *  @access protected
  355.      *  @param  array   $option     ログオプション
  356.      *  @param  string  $facility   ログファシリティ
  357.      *  @return object  LogWriter   LogWriterオブジェクト
  358.      */
  359.     function &_getLogWriter($option, $facility = null)
  360.     {
  361.         if ($facility == null) {
  362.             $facility = $this->getLogFacility();
  363.             if (is_array($facility)) {
  364.                 $facility = $facility[0];
  365.             }
  366.         }
  367.  
  368.         if (is_null($facility)) {
  369.             $plugin = "default";
  370.         } else if (isset($this->log_facility_list[$facility])) {
  371.             if ($facility == "file" || $facility == "echo") {
  372.                 $plugin = $facility;
  373.  
  374.             } else {
  375.                 $plugin = "syslog";
  376.             }
  377.         } else {
  378.             $plugin = $facility;
  379.         }
  380.  
  381.         $plugin_manager =& $this->controller->getPlugin();
  382.         $plugin_object = $plugin_manager->getPlugin('Logwriter',
  383.                                                     ucfirst(strtolower($plugin)));
  384.         if (Ethna::isError($plugin_object)) {
  385.             return $plugin_object;
  386.         }
  387.  
  388.         if (isset($option['ident']) == false) {
  389.             $option['ident'] = $this->controller->getAppId();
  390.         }
  391.         if (isset($option['facility']) == false) {
  392.             $option['facility'] = $facility;
  393.         }
  394.         $plugin_object->setOption($option);
  395.  
  396.         return $plugin_object;
  397.     }
  398.     // }}}
  399.  
  400.     // {{{ _alert
  401.     /**
  402.      *  アラートメールを送信する
  403.      *
  404.      *  @access protected
  405.      *  @param  string  $message    ログメッセージ
  406.      *  @return int     0:正常終了
  407.      *  @deprecated
  408.      */
  409.     function _alert($message)
  410.     {
  411.         restore_error_handler();
  412.  
  413.         // ヘッダ
  414.         $header = "Mime-Version: 1.0\n";
  415.         $header .= "Content-Type: text/plain; charset=ISO-2022-JP\n";
  416.         $header .= "X-Alert: " . $this->controller->getAppId();
  417.         $subject = sprintf("[%s] alert (%s%s)\n",
  418.                            $this->controller->getAppId(),
  419.                            substr($message, 0, 12),
  420.                            strlen($message) > 12 ? "..." : "");
  421.         
  422.         // 本文
  423.         $mail = sprintf("--- [log message] ---\n%s\n\n", $message);
  424.         if (function_exists("debug_backtrace")) {
  425.             $bt = debug_backtrace();
  426.             $mail .= sprintf("--- [backtrace] ---\n%s\n",
  427.                              Ethna_Util::FormatBacktrace($bt));
  428.         }
  429.  
  430.         foreach ($this->alert_mailaddress as $mailaddress) {
  431.             mail($mailaddress,
  432.                  $subject,
  433.                  mb_convert_encoding($mail, "ISO-2022-JP"),
  434.                  $header);
  435.         }
  436.  
  437.         set_error_handler("ethna_error_handler");
  438.  
  439.         return 0;
  440.     }
  441.     // }}}
  442.  
  443.     // {{{ _evalMessageMask
  444.     /**
  445.      *  ログメッセージのマスクチェックを行う
  446.      *
  447.      *  @access private
  448.      *  @param  string  $filter     フィルタ
  449.      *  @param  string  $message    ログメッセージ
  450.      *  @return mixed   true:match, null:skip
  451.      */
  452.     function _evalMessageMask($filter, $message)
  453.     {
  454.         $regexp = sprintf("/%s/", $filter);
  455.  
  456.         if ($filter && preg_match($regexp, $message)) {
  457.             return true;
  458.         }
  459.  
  460.         return null;
  461.     }
  462.     // }}}
  463.  
  464.     // {{{ _evalLevelMask
  465.     /**
  466.      *  ログレベルのマスクチェックを行う
  467.      *
  468.      *  @access private
  469.      *  @param  int     $src    ログレベルマスク
  470.      *  @param  int     $dst    ログレベル
  471.      *  @return bool    true:閾値以下 false:閾値以上
  472.      */
  473.     function _evalLevelMask($src, $dst)
  474.     {
  475.         static $log_level_table = null;
  476.  
  477.         if (is_null($log_level_table)) {
  478.             $log_level_table = array();
  479.  
  480.             // ログレベルテーブル(逆引き)作成
  481.             foreach ($this->log_level_list as $key => $def) {
  482.                 if (defined($def['name']) == false) {
  483.                     continue;
  484.                 }
  485.                 $log_level_table[constant($def['name'])] = $def['value'];
  486.             }
  487.         }
  488.  
  489.         // 知らないレベルなら出力しない
  490.         if (isset($log_level_table[$src]) == false
  491.             || isset($log_level_table[$dst]) == false) {
  492.             return true;
  493.         }
  494.  
  495.         if ($log_level_table[$dst] >= $log_level_table[$src]) {
  496.             return false;
  497.         }
  498.  
  499.         return true;
  500.     }
  501.     // }}}
  502.  
  503.     // {{{ _parseLogOption
  504.     /**
  505.      *  ログオプション(設定ファイル値)を解析する
  506.      *
  507.      *  @access private
  508.      *  @param  mixed   $option ログオプション(設定ファイル値)
  509.      *  @return array   解析された設定ファイル値(アラート通知メールアドレス,
  510.      *                   アラート対象ログレベル, ログオプション)
  511.      */
  512.     function _parseLogOption($option)
  513.     {
  514.         if (is_null($option)) {
  515.             return null;
  516.         } else if (is_array($option)) {
  517.             return $option;
  518.         }
  519.  
  520.         $ret = array();
  521.         $elts = preg_split('/\s*,\s*/', $option);
  522.         foreach ($elts as $elt) {
  523.             if (preg_match('/^(.*?)\s*:\s*(.*)/', $elt, $match)) {
  524.                 $ret[$match[1]] = $match[2];
  525.             } else {
  526.                 $ret[$elt] = true;
  527.             }
  528.         }
  529.  
  530.         return $ret;
  531.     }
  532.     // }}}
  533.  
  534.     // {{{ _parseLogFacility
  535.     /**
  536.      *  ログファシリティ(設定ファイル値)を解析する
  537.      *
  538.      *  @access private
  539.      *  @param  string  $facility   ログファシリティ(設定ファイル値)
  540.      *  @return array   ログファシリティ(LOG_LOCAL0, LOG_FILE...)を格納した配列
  541.      */
  542.     function _parseLogFacility($facility)
  543.     {
  544.         $facility_list = preg_split('/\s*,\s*/', $facility, -1, PREG_SPLIT_NO_EMPTY);
  545.         return $facility_list;
  546.     }
  547.     // }}}
  548.  
  549.     // {{{ _parseLogLevel
  550.     /**
  551.      *  ログレベル(設定ファイル値)を解析する
  552.      *
  553.      *  @access private
  554.      *  @param  string  $level  ログレベル(設定ファイル値)
  555.      *  @return int     ログレベル(LOG_DEBUG, LOG_NOTICE...)
  556.      */
  557.     function _parseLogLevel($level)
  558.     {
  559.         if (isset($this->log_level_list[strtolower($level)]) == false) {
  560.             return null;
  561.         }
  562.         $constant_name = $this->log_level_list[strtolower($level)]['name'];
  563.  
  564.         return constant($constant_name);
  565.     }
  566.     // }}}
  567. }
  568. // }}}
  569. ?>

Documentation generated on Fri, 11 Nov 2011 03:59:54 +0900 by phpDocumentor 1.4.3