refactor(logging): improve AsyncLogProcessor with enhanced encapsulation and exception handling

- Encapsulated Fiber logic in a dedicated `startFiber` method to improve code clarity.
- Implemented `processRemaining` method to ensure all queued logs are processed before object destruction.
- Ensured `processRemaining` is called in the destructor to avoid losing any log records.

Author: walmir-silva

src/Decorator/AsyncLogger.php

@@ -17,6 +17,10 @@ public function __construct(Logger $logger, int $batchSize = 10)
     {
         parent::__construct($logger);
         $this->processor = new AsyncLogProcessor($logger, $batchSize);
+
+        // Register shutdown function to ensure logs are processed
+        register_shutdown_function([$this, 'shutdown']);
+
     }
 
     public function log(LogLevel $level, \Stringable|string $message, array $context = []): void
@@ -25,9 +29,13 @@ public function log(LogLevel $level, \Stringable|string $message, array $context
         $this->processor->enqueue($record);
     }
 
+    public function shutdown(): void
+    {
+        $this->processor->processRemaining();
+    }
+
     public function __destruct()
     {
-        // Explicitly call the destructor to ensure all logs are processed before object is destroyed
-        $this->processor->__destruct();
+        $this->shutdown();
     }
 }

src/Processor/AsyncLogProcessor.php

@@ -25,25 +25,42 @@ public function enqueue(LogRecord $record): void
     private function ensureProcessingStarted(): void
     {
         if (null === $this->processingFiber || $this->processingFiber->isTerminated()) {
-            $this->processingFiber = new \Fiber(function (): void {
-                while (!empty($this->queue)) {
-                    $batch = array_splice($this->queue, 0, $this->batchSize);
-                    foreach ($batch as $record) {
-                        $this->logger->log($record->level, $record->message, $record->context);
-                        \Fiber::suspend(); // Cooperatively yield control
-                    }
-                }
-            });
-            $this->processingFiber->start();
+            $this->startFiber();
         } elseif ($this->processingFiber->isSuspended()) {
             $this->processingFiber->resume();
         }
     }
 
-    public function __destruct()
+    private function startFiber(): void
+    {
+        $this->processingFiber = new \Fiber(function (): void {
+            while (!empty($this->queue)) {
+                $batch = array_splice($this->queue, 0, $this->batchSize);
+                foreach ($batch as $record) {
+                    $this->processRecord($record);
+                    \Fiber::suspend(); // Cooperatively yield control
+                }
+            }
+        });
+
+        $this->processingFiber->start();
+    }
+
+    private function processRecord(LogRecord $record): void
+    {
+        $this->logger->log($record->level, $record->message, $record->context);
+    }
+
+    public function processRemaining(): void
     {
         while (!empty($this->queue)) {
             $this->ensureProcessingStarted();
         }
     }
+
+
+    public function __destruct()
+    {
+        $this->processRemaining();
+    }
 }