[2.x] Closes monolog handlers by event listener if the worker stops

config/octane.php

@@ -11,6 +11,7 @@
 use Laravel\Octane\Events\WorkerErrorOccurred;
 use Laravel\Octane\Events\WorkerStarting;
 use Laravel\Octane\Events\WorkerStopping;
+use Laravel\Octane\Listeners\CloseMonologHandlers;
 use Laravel\Octane\Listeners\CollectGarbage;
 use Laravel\Octane\Listeners\DisconnectFromDatabases;
 use Laravel\Octane\Listeners\EnsureUploadedFilesAreValid;
@@ -114,6 +115,7 @@
         ],
 
         WorkerStopping::class => [
+            CloseMonologHandlers::class,
             //
         ],
     ],

src/Listeners/CloseMonologHandlers.php

@@ -0,0 +1,18 @@
+<?php
+
+namespace Laravel\Octane\Listeners;
+
+class CloseMonologHandlers
+{
+    public function handle($event): void
+    {
+        if (! $event->app->resolved('log')) {
+            return;
+        }
+
+        collect($event->app->make('log')->getChannels())
+            ->map->getLogger()
+            ->filter(fn ($logger) => method_exists($logger, 'close'))
+            ->each->close();
+    }
+}

tests/Listeners/CloseMonologHandlersTest.php

@@ -0,0 +1,44 @@
+<?php
+
+namespace Laravel\Octane\Listeners;
+
+use Illuminate\Http\Request;
+use Illuminate\Log\Logger;
+use Laravel\Octane\Tests\TestCase;
+use Mockery;
+use Monolog;
+
+class CloseMonologHandlersTest extends TestCase
+{
+    /** @doesNotPerformAssertions */
+    public function test_logger_are_closed_after_worker_termination()
+    {
+        [$app, $worker, $client] = $this->createOctaneContext([
+            Request::create('/', 'GET'),
+            Request::create('/', 'GET'),
+        ]);
+
+        $app['router']->middleware('web')->get('/', function () {
+            // ..
+        });
+
+        $worker->run();
+
+        $log = $app['log'];
+
+        $app['log'] = tap(Mockery::mock($log), function ($logger) {
+            $logger->shouldReceive('getChannels')->once()->andReturn([
+                tap(Mockery::mock(Logger::class), function ($logger) {
+                    $logger->shouldReceive('getLogger')->once()->andReturn(
+                        tap(Mockery::mock(Monolog\Logger::class), function ($logger) {
+                            $logger->shouldReceive('close')->once();
+                        }),
+                    );
+                }),
+            ]);
+        });
+
+        // The listener should call close on the monolog handlers after terminating the worker.
+        $worker->terminate();
+    }
+}