@@ -33,7 +33,7 @@ discard block |
||
33 | 33 | { |
34 | 34 | $next = $this->callStack; |
35 | 35 | |
36 | - $this->callStack = function (Interfaces\Query $query) use ($middleware, $next): Interfaces\Result { |
|
36 | + $this->callStack = function(Interfaces\Query $query) use ($middleware, $next): Interfaces\Result { |
|
37 | 37 | return $middleware($query, $next); |
38 | 38 | }; |
39 | 39 | |
@@ -47,7 +47,7 @@ discard block |
||
47 | 47 | |
48 | 48 | private function seedCallStack(): callable |
49 | 49 | { |
50 | - return function (Interfaces\Query $query): Interfaces\Result { |
|
50 | + return function(Interfaces\Query $query): Interfaces\Result { |
|
51 | 51 | return $this->resolver->resolve($query)->handle($query, $this); |
52 | 52 | }; |
53 | 53 | } |
@@ -61,7 +61,7 @@ |
||
61 | 61 | $stopTime = microtime(true); |
62 | 62 | $computeTime = (int) ($stopTime - $startTime); |
63 | 63 | $recomputed = $cacheItem->set(DTO\Cache\ResultWrapper::wrap($result, $computeTime, $query->getTTL())) |
64 | - ->expiresAfter($query->getTTL()); |
|
64 | + ->expiresAfter($query->getTTL()); |
|
65 | 65 | |
66 | 66 | $this->cachePool->save($recomputed); |
67 | 67 |
@@ -59,7 +59,7 @@ |
||
59 | 59 | /** @var Interfaces\Result $result */ |
60 | 60 | $result = $next($query); |
61 | 61 | $stopTime = microtime(true); |
62 | - $computeTime = (int) ($stopTime - $startTime); |
|
62 | + $computeTime = (int)($stopTime - $startTime); |
|
63 | 63 | $recomputed = $cacheItem->set(DTO\Cache\ResultWrapper::wrap($result, $computeTime, $query->getTTL())) |
64 | 64 | ->expiresAfter($query->getTTL()); |
65 | 65 |
@@ -42,7 +42,7 @@ discard block |
||
42 | 42 | 'recomputeSeconds' => $this->recomputeSeconds, |
43 | 43 | 'ttl' => $this->ttl, |
44 | 44 | 'storedTimestamp' => $this->getTimeStamp(), |
45 | - ]); |
|
45 | + ]); |
|
46 | 46 | } |
47 | 47 | |
48 | 48 | /** |
@@ -68,7 +68,7 @@ discard block |
||
68 | 68 | public function willProbablyExpireSoon(): bool |
69 | 69 | { |
70 | 70 | return ($this->getTimeStamp() - $this->recomputeSeconds * 1 * log(mt_rand() / mt_getrandmax()) |
71 | - > $this->expiresAfterTimestamp()); |
|
71 | + > $this->expiresAfterTimestamp()); |
|
72 | 72 | } |
73 | 73 | |
74 | 74 | private function expiresAfterTimestamp(): int |
@@ -73,6 +73,6 @@ |
||
73 | 73 | |
74 | 74 | private function expiresAfterTimestamp(): int |
75 | 75 | { |
76 | - return (int) (($this->storedTimestamp ?? $this->getTimeStamp()) + $this->ttl); |
|
76 | + return (int)(($this->storedTimestamp ?? $this->getTimeStamp()) + $this->ttl); |
|
77 | 77 | } |
78 | 78 | } |
@@ -34,14 +34,14 @@ |
||
34 | 34 | $startTime = microtime(true); |
35 | 35 | $startMemoryBytes = memory_get_usage(true); |
36 | 36 | $result = $next($query); |
37 | - $totalTime = (float) microtime(true) - $startTime; |
|
37 | + $totalTime = (float)microtime(true) - $startTime; |
|
38 | 38 | $totalMegabytesIncrease = (memory_get_peak_usage(true) - $startMemoryBytes) / 1000000; |
39 | 39 | |
40 | 40 | if ($this->isOverThresholds($totalTime, $totalMegabytesIncrease)) { |
41 | 41 | $this->getLogger()->log( |
42 | - (string) $this->logLevel, |
|
42 | + (string)$this->logLevel, |
|
43 | 43 | 'Performance threshold exceeded', |
44 | - ['MB' => $totalMegabytesIncrease, 'seconds' => $totalTime, 'query' => get_class($query) ] |
|
44 | + ['MB' => $totalMegabytesIncrease, 'seconds' => $totalTime, 'query' => get_class($query)] |
|
45 | 45 | ); |
46 | 46 | } |
47 | 47 |
@@ -15,7 +15,7 @@ |
||
15 | 15 | public function __invoke(Interfaces\Query $query, callable $next): Interfaces\Result |
16 | 16 | { |
17 | 17 | if ($query instanceof Interfaces\LoggableQuery) { |
18 | - $this->getLogger()->log((string) $query->getLogLevel(), $query->getLogMessage(), $query->getLogContext()); |
|
18 | + $this->getLogger()->log((string)$query->getLogLevel(), $query->getLogMessage(), $query->getLogContext()); |
|
19 | 19 | } |
20 | 20 | |
21 | 21 | return $next($query); |