FlushDatabaseQueryLogListener added (#67)

Author: tarampampam

CHANGELOG.md

@@ -4,6 +4,14 @@ All notable changes to this project will be documented in this file.
 
 The format is based on [Keep a Changelog][keepachangelog] and this project adheres to [Semantic Versioning][semver].
 
+## v5.4.0
+
+### Added
+
+- Listener `FlushDatabaseQueryLogListener` for cleaning up database query log [#67]
+
+[#67]:https://github.com/spiral/roadrunner-laravel/pull/67
+
 ## v5.3.0
 
 ### Added

config/roadrunner.php

@@ -109,7 +109,7 @@
     |--------------------------------------------------------------------------
     |
     | Here you can override the worker class for processing different kinds of
-    | jobs, that received from the RoadRunner daemon.
+    | jobs, that received from the RoadRunner daemon. The key is a worker mode.
     |
     */
 

src/Defaults.php

@@ -95,6 +95,7 @@ public static function afterLoopIteration(): array
             Listeners\FlushLogContextListener::class,
             Listeners\FlushArrayCacheListener::class,
             Listeners\ResetDatabaseRecordModificationStateListener::class,
+            Listeners\FlushDatabaseQueryLogListener::class,
             Listeners\ClearInstancesListener::class,
         ];
     }

src/Listeners/FlushDatabaseQueryLogListener.php

@@ -0,0 +1,38 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Spiral\RoadRunnerLaravel\Listeners;
+
+use Illuminate\Database\Connection;
+use Illuminate\Database\DatabaseManager;
+use Spiral\RoadRunnerLaravel\Events\Contracts\WithApplication;
+
+/**
+ * @link https://github.com/laravel/octane/blob/1.x/src/Listeners/FlushDatabaseQueryLog.php
+ */
+class FlushDatabaseQueryLogListener implements ListenerInterface
+{
+    /**
+     * {@inheritdoc}
+     */
+    public function handle($event): void
+    {
+        if ($event instanceof WithApplication) {
+            $app = $event->application();
+
+            if (!$app->resolved($database_abstract = 'db')) {
+                return;
+            }
+
+            /** @var DatabaseManager $database_manager */
+            $database_manager = $app->make($database_abstract);
+
+            foreach ($database_manager->getConnections() as $connection) {
+                if ($connection instanceof Connection) {
+                    $connection->flushQueryLog();
+                }
+            }
+        }
+    }
+}

tests/Unit/Listeners/FlushDatabaseQueryLogListenerTest.php

@@ -0,0 +1,58 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Spiral\RoadRunnerLaravel\Tests\Unit\Listeners;
+
+use Mockery as m;
+use Illuminate\Support\Str;
+use Spiral\RoadRunnerLaravel\Events\Contracts\WithApplication;
+use Illuminate\Contracts\Config\Repository as ConfigRepository;
+use Spiral\RoadRunnerLaravel\Listeners\FlushDatabaseQueryLogListener;
+
+/**
+ * @covers \Spiral\RoadRunnerLaravel\Listeners\FlushDatabaseQueryLogListener
+ */
+class FlushDatabaseQueryLogListenerTest extends AbstractListenerTestCase
+{
+    /**
+     * {@inheritdoc}
+     */
+    public function testHandle(): void
+    {
+        /** @var ConfigRepository $config */
+        $config = $this->app->make(ConfigRepository::class);
+
+        $config->set('database.connections.' . ($connection_name = 'test_' . Str::random()), [
+            'driver'   => 'sqlite',
+            'database' => ':memory:',
+        ]);
+
+        /** @var \Illuminate\Database\Connection $connection */
+        $connection = $this->app->make('db')->connection($connection_name);
+
+        $connection->enableQueryLog();
+        $connection->logQuery('select $1', ['1' => '1']);
+
+        /** @var m\MockInterface|WithApplication $event_mock */
+        $event_mock = m::mock(WithApplication::class)
+            ->makePartial()
+            ->expects('application')
+            ->andReturn($this->app)
+            ->getMock();
+
+        $this->assertNotEmpty($connection->getQueryLog());
+
+        $this->listenerFactory()->handle($event_mock);
+
+        $this->assertEmpty($connection->getQueryLog());
+    }
+
+    /**
+     * @return FlushDatabaseQueryLogListener
+     */
+    protected function listenerFactory(): FlushDatabaseQueryLogListener
+    {
+        return new FlushDatabaseQueryLogListener();
+    }
+}