done (#16)

Co-authored-by: paul_sleepy <pavel.chi@okwork.io>

Author: dezone

src/Monolog/Formatter/JsonTableSyncFormatter.php

@@ -0,0 +1,26 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Umbrellio\TableSync\Monolog\Formatter;
+
+use Monolog\Utils;
+
+class JsonTableSyncFormatter extends TableSyncFormatter
+{
+    public function format(array $record)
+    {
+        $record = parent::format($record);
+        $formatted = [
+            'datetime' => $record['datetime'],
+            'message' => $record['message'],
+            'direction' => $record['direction'],
+            'routing' => $record['routing'],
+            'model' => $record['model'],
+            'event' => $record['event'],
+            'count' => count($record['attributes']),
+        ];
+
+        return Utils::jsonEncode($formatted, Utils::DEFAULT_JSON_FLAGS, true) . "\n";
+    }
+}

tests/unit/Logging/FormatterTest.php

@@ -7,6 +7,7 @@
 use InfluxDB\Point;
 use Umbrellio\TableSync\Messages\PublishMessage;
 use Umbrellio\TableSync\Monolog\Formatter\InfluxDBFormatter;
+use Umbrellio\TableSync\Monolog\Formatter\JsonTableSyncFormatter;
 use Umbrellio\TableSync\Monolog\Formatter\LineTableSyncFormatter;
 use Umbrellio\TableSync\Monolog\Formatter\TableSyncFormatter;
 use Umbrellio\TableSync\Rabbit\Config\PublishMessage as Config;
@@ -78,6 +79,18 @@ public function influxDbFormatter(): void
         $this->assertSame(['model', 'event', 'direction'], array_keys($format[0]->getTags()));
     }
 
+    /**
+     * @test
+     */
+    public function jsonTableSyncFormat(): void
+    {
+        $jsonTableSyncFormatter = new JsonTableSyncFormatter();
+        $format = $jsonTableSyncFormatter->format($this->getDummyRecord());
+        $expected = '{"datetime":"datetime","message":"message","direction":"direction","routing":"routing_key","model":"model","event":"update","count":1}' . "\n";
+        $this->assertIsString($format);
+        $this->assertSame($expected, $format);
+    }
+
     private function getDummyRecord(): array
     {
         $message = new PublishMessage('model', 'event', 'routingKey', [