Dev json logs

plugins/Monolog/Formatter/LineMessageFormatter.php

@@ -23,17 +23,22 @@ class LineMessageFormatter implements FormatterInterface
      * @var string
      */
     private $logMessageFormat;
-
+    private $excludePatterns;
+    private $customFunction;
     private $allowInlineLineBreaks;
 
     /**
      * @param string $logMessageFormat
      * @param bool $allowInlineLineBreaks If disabled, a log message will be created for each line
      */
-    public function __construct($logMessageFormat, $allowInlineLineBreaks = true)
+    public function __construct($logMessageFormat, $allowInlineLineBreaks = true, $excludePatterns = null, $customFunctionFile = null)
     {
         $this->logMessageFormat = $logMessageFormat;
         $this->allowInlineLineBreaks = $allowInlineLineBreaks;
+        $this->excludePatterns = $excludePatterns;
+        if (gettype($customFunctionFile) === "string") {
+            $this->customFunction = include_once $customFunctionFile;
+        }
     }
 
     public function format(array $record)
@@ -43,6 +48,21 @@ public function format(array $record)
 
         $message = trim($record['message']);
 
+        if (gettype($this->excludePatterns) === "array") {
+            foreach ($this->excludePatterns as $p) {
+                if (strpos($message, $p) !== false) {
+                    return;
+                }
+                if (strpos($class, $p) !== false) {
+                    return;
+                }
+            }
+        }
+
+        if ($this->logMessageFormat == 'json') {
+            return $this->jsonMessage($class, $message, $date, $record);
+        }
+
         if ($this->allowInlineLineBreaks) {
             $message  = str_replace("\n", "\n  ", $message); // intend lines
             $messages = array($message);
@@ -62,6 +82,27 @@ public function format(array $record)
         return $total;
     }
 
+    private function jsonMessage($class, $message, $date, $record)
+    {
+        $trace = isset($record['context']['trace']) ? self::formatTrace($record['context']['trace']) : '';
+        $requestId = isset($record['extra']['request_id']) ? $record['extra']['request_id'] : '';
+
+        $message = [
+            "tag" => $class,
+            "datetime" => $date,
+            "message" => $message,
+            "level" => $record['level_name'],
+            "trace" => $trace,
+            "requestId" => $requestId
+        ];
+
+        if (gettype($this->customFunction) === "string") {
+            $message = call_user_func($this->customFunction, $message);
+        }
+
+        return json_encode($message) . "\n";
+    }
+
     private function formatMessage($class, $message, $date, $record)
     {
         $trace = isset($record['context']['trace']) ? self::formatTrace($record['context']['trace']) : '';

plugins/Monolog/config/config.php

@@ -19,6 +19,7 @@
 
     'log.handler.classes' => array(
         'file'     => 'Piwik\Plugins\Monolog\Handler\FileHandler',
+        'jsonfile' => 'Piwik\Plugins\Monolog\Handler\FileHandler',
         'screen'   => 'Piwik\Plugins\Monolog\Handler\WebNotificationHandler',
         'database' => 'Piwik\Plugins\Monolog\Handler\DatabaseHandler',
         'errorlog' => 'Piwik\Plugins\Monolog\Handler\ErrorLogHandler',
@@ -226,22 +227,70 @@
     }),
 
     'Piwik\Plugins\Monolog\Formatter\LineMessageFormatter' => Piwik\DI::create('Piwik\Plugins\Monolog\Formatter\LineMessageFormatter')
-                                                                ->constructor(Piwik\DI::get('log.short.format')),
+        ->constructor(Piwik\DI::get('log.short.format')),
     'log.lineMessageFormatter' => Piwik\DI::create('Piwik\Plugins\Monolog\Formatter\LineMessageFormatter')
         ->constructor(Piwik\DI::get('log.short.format')),
 
     'log.lineMessageFormatter.file' => Piwik\DI::autowire('Piwik\Plugins\Monolog\Formatter\LineMessageFormatter')
         ->constructor(Piwik\DI::get('log.trace.format'))
-        ->constructorParameter('allowInlineLineBreaks', false),
+        ->constructorParameter('allowInlineLineBreaks', false)
+        ->constructorParameter('customFunctionFile', Piwik\DI::get('log.custom_function_file'))
+        ->constructorParameter('excludePatterns', Piwik\DI::get('log.exclude_patterns')),
+
+    'log.exclude_patterns' => Piwik\DI::factory(function (Container $c) {
+        if ($c->has('ini.log.exclude_patterns')) {
+            $xcl = [];
+            foreach (explode("|", $c->get('ini.log.exclude_patterns')) as $p) {
+                $xcl[]  = trim($p);
+            }
+            return $xcl;
+        }
+        return null;
+    }),
+
+    'log.custom_function_file' => Piwik\DI::factory(function (Container $c) {
+        if ($c->has('ini.log.custom_function_file')) {
+            $path = $c->get('ini.log.custom_function_file');
+            if (!file_exists($path)) {
+                return null;
+                throw new \Exception('Specified path to custom_function_file does not exist: ' . $path);
+            }
+
+            if (!is_readable($path)) {
+                return null;
+                throw new \Exception('Specified path to custom_function_file file is not readable: ' . $path);
+            }
+
+            return $path;
+        }
+        return null;
+    }),
+
+    'log.exclude_patterns' => Piwik\DI::factory(function (Container $c) {
+        if ($c->has('ini.log.exclude_patterns')) {
+            $xcl = [];
+            foreach (explode("|", $c->get('ini.log.exclude_patterns')) as $p) {
+                $xcl[]  = trim($p);
+            }
+            return $xcl;
+        }
+        return null;
+    }),
 
     'log.short.format' => Piwik\DI::factory(function (Container $c) {
+        if ($c->has('ini.log.enable_json')) {
+            return 'json';
+        }
         if ($c->has('ini.log.string_message_format')) {
             return $c->get('ini.log.string_message_format');
         }
         return '%level% %tag%[%datetime%] %message%';
     }),
 
     'log.trace.format' => Piwik\DI::factory(function (Container $c) {
+        if ($c->has('ini.log.enable_json')) {
+            return 'json';
+        }
         if ($c->has('ini.log.string_message_format_trace')) {
             return $c->get('ini.log.string_message_format_trace');
         }