@@ -93,7 +93,7 @@ |
||
| 93 | 93 | return new CacheEntry( |
| 94 | 94 | $request, |
| 95 | 95 | $response, |
| 96 | - new \DateTime('+'.(int) $cacheControl->get($key).'seconds') |
|
| 96 | + new \DateTime('+'.(int)$cacheControl->get($key).'seconds') |
|
| 97 | 97 | ); |
| 98 | 98 | } |
| 99 | 99 | } |
@@ -69,7 +69,7 @@ discard block |
||
| 69 | 69 | |
| 70 | 70 | if ($staleIfErrorTo === null && $values->has('stale-if-error')) { |
| 71 | 71 | $this->staleIfErrorTo = (new \DateTime( |
| 72 | - '@'.($this->staleAt->getTimestamp() + (int) $values->get('stale-if-error')) |
|
| 72 | + '@'.($this->staleAt->getTimestamp() + (int)$values->get('stale-if-error')) |
|
| 73 | 73 | )); |
| 74 | 74 | } else { |
| 75 | 75 | $this->staleIfErrorTo = $staleIfErrorTo; |
@@ -77,7 +77,7 @@ discard block |
||
| 77 | 77 | |
| 78 | 78 | if ($staleWhileRevalidateTo === null && $values->has('stale-while-revalidate')) { |
| 79 | 79 | $this->staleWhileRevalidateTo = new \DateTime( |
| 80 | - '@'.($this->staleAt->getTimestamp() + (int) $values->get('stale-while-revalidate')) |
|
| 80 | + '@'.($this->staleAt->getTimestamp() + (int)$values->get('stale-while-revalidate')) |
|
| 81 | 81 | ); |
| 82 | 82 | } else { |
| 83 | 83 | $this->staleWhileRevalidateTo = $staleWhileRevalidateTo; |
@@ -245,7 +245,7 @@ discard block |
||
| 245 | 245 | $ttl = max($ttl, $this->staleAt->getTimestamp() - time()); |
| 246 | 246 | |
| 247 | 247 | // Don't return 0, it's reserved for infinite TTL |
| 248 | - return $ttl !== 0 ? (int) $ttl : -1; |
|
| 248 | + return $ttl !== 0 ? (int)$ttl : -1; |
|
| 249 | 249 | } |
| 250 | 250 | |
| 251 | 251 | /** |
@@ -290,12 +290,12 @@ discard block |
||
| 290 | 290 | if ($this->response !== null) { |
| 291 | 291 | $this->response = $this->response |
| 292 | 292 | ->withBody( |
| 293 | - \GuzzleHttp\Psr7\Utils::streamFor((string) $this->response->getBody()) |
|
| 293 | + \GuzzleHttp\Psr7\Utils::streamFor((string)$this->response->getBody()) |
|
| 294 | 294 | ); |
| 295 | 295 | } |
| 296 | 296 | $this->request = $this->request |
| 297 | 297 | ->withBody( |
| 298 | - \GuzzleHttp\Psr7\Utils::streamFor((string) $this->request->getBody()) |
|
| 298 | + \GuzzleHttp\Psr7\Utils::streamFor((string)$this->request->getBody()) |
|
| 299 | 299 | ); |
| 300 | 300 | } |
| 301 | 301 | |
@@ -120,12 +120,12 @@ discard block |
||
| 120 | 120 | */ |
| 121 | 121 | public function __invoke(callable $handler) |
| 122 | 122 | { |
| 123 | - return function (RequestInterface $request, array $options) use (&$handler) { |
|
| 123 | + return function(RequestInterface $request, array $options) use (&$handler) { |
|
| 124 | 124 | if (!isset($this->httpMethods[strtoupper($request->getMethod())])) { |
| 125 | 125 | // No caching for this method allowed |
| 126 | 126 | |
| 127 | 127 | return $handler($request, $options)->then( |
| 128 | - function (ResponseInterface $response) use ($request) { |
|
| 128 | + function(ResponseInterface $response) use ($request) { |
|
| 129 | 129 | if (!isset($this->safeMethods[$request->getMethod()])) { |
| 130 | 130 | // Invalidate cache after a call of non-safe method on the same URI |
| 131 | 131 | $response = $this->invalidateCache($request, $response); |
@@ -199,7 +199,7 @@ discard block |
||
| 199 | 199 | $promise = $handler($request, $options); |
| 200 | 200 | |
| 201 | 201 | return $promise->then( |
| 202 | - function (ResponseInterface $response) use ($request, $cacheEntry) { |
|
| 202 | + function(ResponseInterface $response) use ($request, $cacheEntry) { |
|
| 203 | 203 | // Check if error and looking for a staled content |
| 204 | 204 | if ($response->getStatusCode() >= 500) { |
| 205 | 205 | $responseStale = static::getStaleResponse($cacheEntry); |
@@ -236,7 +236,7 @@ discard block |
||
| 236 | 236 | |
| 237 | 237 | return static::addToCache($this->cacheStorage, $request, $response, $update); |
| 238 | 238 | }, |
| 239 | - function ($reason) use ($cacheEntry) { |
|
| 239 | + function($reason) use ($cacheEntry) { |
|
| 240 | 240 | if ($reason instanceof TransferException) { |
| 241 | 241 | $response = static::getStaleResponse($cacheEntry); |
| 242 | 242 | if ($response instanceof ResponseInterface) { |
@@ -295,7 +295,7 @@ discard block |
||
| 295 | 295 | */ |
| 296 | 296 | protected function addReValidationRequest( |
| 297 | 297 | RequestInterface $request, |
| 298 | - CacheStrategyInterface &$cacheStorage, |
|
| 298 | + CacheStrategyInterface & $cacheStorage, |
|
| 299 | 299 | CacheEntry $cacheEntry |
| 300 | 300 | ) { |
| 301 | 301 | // Add the promise for revalidate |
@@ -304,7 +304,7 @@ discard block |
||
| 304 | 304 | $request = $request->withHeader(self::HEADER_RE_VALIDATION, '1'); |
| 305 | 305 | $this->waitingRevalidate[] = $this->client |
| 306 | 306 | ->sendAsync($request) |
| 307 | - ->then(function (ResponseInterface $response) use ($request, &$cacheStorage, $cacheEntry) { |
|
| 307 | + ->then(function(ResponseInterface $response) use ($request, &$cacheStorage, $cacheEntry) { |
|
| 308 | 308 | $update = false; |
| 309 | 309 | |
| 310 | 310 | if ($response->getStatusCode() == 304) { |