Initial commit

Author: ilzrv

.gitignore

@@ -0,0 +1 @@
+.idea

README.md

@@ -0,0 +1,15 @@
+# Laravel Slow Query Detector
+
+## Requirements
+ * Laravel 5.5+
+ 
+## Installation
+Install the package
+```bash
+composer require ilzrv/laravel-slow-query-detector
+```
+
+Publish the configuration file
+```bash
+php artisan vendor:publish --provider="Ilzrv\LaravelSlowQueryDetector\ServiceProvider"
+```

composer.json

@@ -0,0 +1,26 @@
+{
+    "name": "ilzrv/laravel-slow-query-detector",
+    "description": "Laravel Slow DB Query Detector",
+    "require": {
+        "laravel/framework": "^5.5|^6|^7"
+    },
+    "license": "MIT",
+    "authors": [
+        {
+            "name": "Ilia Lazarev",
+            "email": "[email protected]"
+        }
+    ],
+    "autoload": {
+        "psr-4": {
+            "Ilzrv\\LaravelSlowQueryDetector\\": "src"
+        }
+    },
+    "extra": {
+        "laravel": {
+            "providers": [
+                "Ilzrv\\LaravelSlowQueryDetector\\ServiceProvider"
+            ]
+        }
+    }
+}

config/sqd.php

@@ -0,0 +1,17 @@
+<?php
+
+return [
+
+    'enabled' => (bool) env('SQD_ENABLED', true),
+
+    'code' => [
+        'max_queries' => (int) env('SQD_CODE_MAX_QUERIES', 50),
+        'max_time' => (int) env('SQD_CODE_MAX_TIME', 1000),
+    ],
+
+    'query' => [
+        'with_bindings' => (bool) env('SQD_QUERY_BINDINGS', true),
+        'max_time' => (int) env('SQD_QUERY_MAX_TIME', 50),
+    ],
+
+];

src/Http/Middleware/SlowQueryDetectorMiddleware.php

@@ -0,0 +1,77 @@
+<?php
+
+namespace Ilzrv\LaravelSlowQueryDetector\Http\Middleware;
+
+use Closure;
+use Illuminate\Support\Str;
+
+class SlowQueryDetectorMiddleware
+{
+    protected $queriesCount = 0;
+    protected $heavyQueryCount = 0;
+    protected $heaviestQueryTime = 0;
+    protected $heaviestQuery = '';
+    protected $executionTime = 0;
+
+    /**
+     * Handle an incoming request.
+     *
+     * @param  \Illuminate\Http\Request  $request
+     * @param  \Closure  $next
+     * @return mixed
+     */
+    public function handle($request, Closure $next)
+    {
+        $this->executionTime = -round(microtime(true) * 1000);
+
+        \DB::listen(function ($query) {
+            $this->queriesCount++;
+            if ($query->time > config('slow-query-detector.query.max_time')) {
+                $this->heavyQueryCount++;
+                if ($query->time > $this->heaviestQueryTime) {
+                    $this->heaviestQueryTime = $query->time;
+                    $this->heaviestQuery = $this->getQuery($query);
+                }
+            }
+        });
+
+        $next = $next($request);
+
+        $this->executionTime += round(microtime(true) * 1000);
+
+        if ($this->needNotify()) {
+            $this->notify($request);
+        }
+
+        return $next;
+    }
+
+    protected function needNotify()
+    {
+        return $this->queriesCount > config('slow-query-detector.code.max_queries')
+            || $this->executionTime > config('slow-query-detector.code.max_time')
+            || $this->heaviestQueryTime > config('slow-query-detector.query.max_time');
+    }
+
+    protected function notify($request)
+    {
+        app('log')->critical(print_r([
+            'Execution Time' => $this->executionTime,
+            'Queries Count' => $this->queriesCount,
+            'Heavy Queries Count' => $this->heavyQueryCount,
+            'Full URL' => $request->fullUrl(),
+            'Action' => $request->route()->getActionName(),
+            'Heaviest Query' => [
+                'Query' => $this->heaviestQuery,
+                'Time' => $this->heaviestQueryTime,
+            ]
+        ], true));
+    }
+
+    protected function getQuery($query)
+    {
+        return config('slow-query-detector.query.with_bindings')
+            ? Str::replaceArray('?', $query->bindings, $query->sql)
+            : $query->sql;
+    }
+}

src/ServiceProvider.php

@@ -0,0 +1,32 @@
+<?php
+
+namespace Ilzrv\LaravelSlowQueryDetector;
+
+use Ilzrv\LaravelSlowQueryDetector\Http\Middleware\SlowQueryDetectorMiddleware;
+
+class ServiceProvider extends \Illuminate\Support\ServiceProvider
+{
+    /**
+     * Register services.
+     *
+     * @return void
+     */
+    public function register()
+    {
+        //
+    }
+
+    /**
+     * Bootstrap services.
+     *
+     * @return void
+     */
+    public function boot()
+    {
+        $this->publishes([__DIR__ . '/../config/sqd.php' => config_path('sqd.php')]);
+
+        if (config('sqd.enabled')) {
+            $this->app['router']->pushMiddlewareToGroup('web', SlowQueryDetectorMiddleware::class);
+        }
+    }
+}