Flush monolog state (#460)

Author: nunomaduro

src/Concerns/ProvidesDefaultConfigurationOptions.php

@@ -49,6 +49,7 @@ public static function prepareApplicationForNextOperation(): array
             \Laravel\Octane\Listeners\FlushDatabaseQueryLog::class,
             \Laravel\Octane\Listeners\FlushLogContext::class,
             \Laravel\Octane\Listeners\FlushArrayCache::class,
+            \Laravel\Octane\Listeners\FlushMonologState::class,
             \Laravel\Octane\Listeners\FlushTranslatorCache::class,
 
             // First-Party Packages...

src/Listeners/FlushMonologState.php

@@ -0,0 +1,27 @@
+<?php
+
+namespace Laravel\Octane\Listeners;
+
+use Monolog\ResettableInterface;
+
+class FlushMonologState
+{
+    /**
+     * Handle the event.
+     *
+     * @param  mixed  $event
+     * @return void
+     */
+    public function handle($event): void
+    {
+        if (! $event->sandbox->resolved('log')) {
+            return;
+        }
+
+        collect($event->sandbox->make('log')->getChannels())
+            ->map->getLogger()
+            ->filter(function ($logger) {
+                return $logger instanceof ResettableInterface;
+            })->each->reset();
+    }
+}

tests/Listeners/FlushMonologStateTest.php

@@ -0,0 +1,41 @@
+<?php
+
+namespace Laravel\Octane\Listeners;
+
+use Illuminate\Http\Request;
+use Illuminate\Log\Logger;
+use Laravel\Octane\Tests\TestCase;
+use Mockery;
+use Monolog;
+
+class FlushMonologStateTest extends TestCase
+{
+    /** @doesNotPerformAssertions */
+    public function test_logger_are_reset()
+    {
+        [$app, $worker, $client] = $this->createOctaneContext([
+            Request::create('/', 'GET'),
+            Request::create('/', 'GET'),
+        ]);
+
+        $app['router']->middleware('web')->get('/', function () {
+            // ..
+        });
+
+        $log = $app['log'];
+
+        $app['log'] = tap(Mockery::mock($log), function ($logger) {
+            $logger->shouldReceive('getChannels')->twice()->andReturn([
+                tap(Mockery::mock(Logger::class), function ($logger) {
+                    $logger->shouldReceive('getLogger')->twice()->andReturn(
+                        tap(Mockery::mock(Monolog\Logger::class), function ($logger) {
+                            $logger->shouldReceive('reset')->twice();
+                        }),
+                    );
+                }),
+            ]);
+        });
+
+        $worker->run();
+    }
+}