4
4
5
5
use Closure ;
6
6
use Illuminate \Database \Events \QueryExecuted ;
7
- use Illuminate \Http \JsonResponse ;
8
7
use Illuminate \Http \Request ;
9
8
use Illuminate \Support \Facades \DB ;
9
+ use Illuminate \Support \Facades \Event ;
10
10
use Illuminate \Support \Facades \Log ;
11
+ use Illuminate \Support \Str ;
11
12
use KitLoong \AppLogger \QueryLog \LogWriter as QueryLogger ;
12
- use Event ;
13
- use Str ;
14
13
use Symfony \Component \HttpFoundation \Response ;
15
14
16
-
17
15
class LaravelRequestDocsMiddleware extends QueryLogger
18
16
{
19
- private array $ queries = [];
20
- private array $ logs = [];
21
- private array $ models = [];
17
+ private array $ queries = [];
18
+ private array $ logs = [];
19
+ private array $ models = [];
22
20
private array $ modelsTimeline = [];
23
21
24
22
/**
25
23
* Handle an incoming request.
26
24
*
27
- * @param \Closure(\Illuminate\Http\Request): (\Illuminate\Http\JsonResponse ) $next
25
+ * @param \Closure(\Illuminate\Http\Request): (\Symfony\Component\HttpFoundation\Response ) $next
28
26
*/
29
- public function handle (Request $ request , Closure $ next ): JsonResponse
27
+ public function handle (Request $ request , Closure $ next ): Response
30
28
{
31
29
if (!$ request ->headers ->has ('X-Request-LRD ' ) || !config ('app.debug ' )) {
32
30
return $ next ($ request );
@@ -53,12 +51,12 @@ public function handle(Request $request, Closure $next): JsonResponse
53
51
54
52
$ content = $ response ->getData ();
55
53
$ content ->_lrd = [
56
- 'queries ' => $ this ->queries ,
57
- 'logs ' => $ this ->logs ,
58
- 'models ' => $ this ->models ,
54
+ 'queries ' => $ this ->queries ,
55
+ 'logs ' => $ this ->logs ,
56
+ 'models ' => $ this ->models ,
59
57
// 'modelsTimeline' => $this->modelsTimeline,
60
58
'modelsTimeline ' => array_unique ($ this ->modelsTimeline , SORT_REGULAR ),
61
- 'memory ' => (string ) round (memory_get_peak_usage (true ) / 1048576 , 2 ) . "MB " ,
59
+ 'memory ' => (string ) round (memory_get_peak_usage (true ) / 1048576 , 2 ) . "MB " ,
62
60
];
63
61
$ jsonContent = json_encode ($ content );
64
62
@@ -75,7 +73,7 @@ public function handle(Request $request, Closure $next): JsonResponse
75
73
return $ response ;
76
74
}
77
75
78
- public function listenToDB ()
76
+ public function listenToDB (): void
79
77
{
80
78
DB ::listen (function (QueryExecuted $ query ) {
81
79
$ this ->queries [] = $ this ->getMessages ($ query );
@@ -89,18 +87,18 @@ public function listenToLogs(): void
89
87
});
90
88
}
91
89
92
- public function listenToModels ()
90
+ public function listenToModels (): void
93
91
{
94
92
Event::listen ('eloquent.* ' , function ($ event , $ models ) {
95
93
foreach (array_filter ($ models ) as $ model ) {
96
94
// doing and booted ignore
97
95
if (Str::startsWith ($ event , 'eloquent.booting ' )
98
- || Str::startsWith ($ event , 'eloquent.booted ' )
99
- || Str::startsWith ($ event , 'eloquent.retrieving ' )
100
- || Str::startsWith ($ event , 'eloquent.creating ' )
101
- || Str::startsWith ($ event , 'eloquent.saving ' )
102
- || Str::startsWith ($ event , 'eloquent.updating ' )
103
- || Str::startsWith ($ event , 'eloquent.deleting ' )
96
+ || Str::startsWith ($ event , 'eloquent.booted ' )
97
+ || Str::startsWith ($ event , 'eloquent.retrieving ' )
98
+ || Str::startsWith ($ event , 'eloquent.creating ' )
99
+ || Str::startsWith ($ event , 'eloquent.saving ' )
100
+ || Str::startsWith ($ event , 'eloquent.updating ' )
101
+ || Str::startsWith ($ event , 'eloquent.deleting ' )
104
102
) {
105
103
continue ;
106
104
}
@@ -120,7 +118,7 @@ public function listenToModels()
120
118
if (!isset ($ this ->models [$ class ][$ event ])) {
121
119
$ this ->models [$ class ][$ event ] = 0 ;
122
120
}
123
- $ this ->models [$ class ][$ event ] = $ this ->models [$ class ][$ event ]+ 1 ;
121
+ $ this ->models [$ class ][$ event ] = $ this ->models [$ class ][$ event ] + 1 ;
124
122
}
125
123
});
126
124
}
0 commit comments