Add a Multichannel DatabaseLogger

src/Enum/LoggerChannel.php

@@ -0,0 +1,15 @@
+<?php
+
+namespace Morebec\YDB\Enum;
+
+use Morebec\ValueObjects\BasicEnum;
+
+/**
+ * LoggerChannel
+ */
+class LoggerChannel extends BasicEnum
+{
+    const __DEFAULT = 'default';
+    const COMMAND = 'command';
+    const EVENT = 'event';
+}

src/Service/DatabaseLogger.php

@@ -6,21 +6,28 @@
 use Monolog\Logger;
 use Morebec\YDB\DatabaseConfig;
 use Morebec\YDB\Service\Database;
+use Morebec\YDB\Enum\LoggerChannel;
 
 /**
  * DatabaseLogger
  */
 class DatabaseLogger extends Logger
 {
+
+    private $loggers = [];
+
     /**
      * Constructs an instance of the database logger
      * @param string $databasePath path to the database
      */
     public function __construct(string $databasePath)
     {
-        parent::__construct('default');
-        $logsDir = $databasePath . "/" . Database::LOGS_DIR_NAME;
-
-        $this->pushHandler(new RotatingFileHandler($logsDir . '/database.log', Logger::DEBUG));
+        $channels = LoggerChannel::getValues();
+        foreach($channels as $channel){
+            $this->loggers[$channel] = new Logger($channel);
+            $logsDir = $databasePath . "/" . Database::LOGS_DIR_NAME;
+            $this->pushHandler(new RotatingFileHandler($logsDir . "/".$channel."log", Logger::DEBUG));
+        }
+
     }
 }

src/Service/Engine.php

@@ -12,6 +12,7 @@
 use Symfony\Component\EventDispatcher\EventDispatcher;
 use Symfony\Component\EventDispatcher\EventSubscriberInterface;
 use Symfony\Component\Filesystem\Filesystem;
+use Morebec\YDB\Enum\LoggerChannel;
 
 /**
  * The engine class serves as a service container.
@@ -100,14 +101,20 @@ public function dispatchEvent(string $name, DatabaseEvent $event): void
      * @param  string   $message message
      * @param  array    $context optional context data
      */
-    public function log(string $level, string $message, array $context = []): void
+    public function log(string $level, string $message, array $context = [],string $channel = LoggerChannel::__DEFAULT): void
     {
         if (!$this->logger) {
             return;
         }
-
+        Assertion::keyExists($this->logger->loggers, $channel, "Unsupported channel '$channel'");
         $context['database_root'] = (string)$this->database->getPath();
-        $this->logger->log($level, $message, $context);
+        $this->logger->loggers[LoggerChannel::__DEFAULT]->log($level, $message, $context);
+        if ($channel === LoggerChannel::__DEFAULT) {
+            return;
+        }
+        // Log in channel specific logger
+        $this->logger->loggers[$channel]->log($level, $message, $context);
+
     }
 
     /**