@@ -124,7 +124,7 @@ discard block |
||
124 | 124 | */ |
125 | 125 | protected function driverConnect() |
126 | 126 | { |
127 | - $config = isset($this->config[ 'predis' ]) ? $this->config[ 'predis' ] : []; |
|
127 | + $config = isset($this->config['predis']) ? $this->config['predis'] : []; |
|
128 | 128 | |
129 | 129 | $this->instance = new PredisClient(array_merge([ |
130 | 130 | 'host' => '127.0.0.1', |
@@ -150,7 +150,7 @@ discard block |
||
150 | 150 | $info = $this->instance->info(); |
151 | 151 | $size = (isset($info['Memory']['used_memory']) ? $info['Memory']['used_memory'] : 0); |
152 | 152 | $version = (isset($info['Server']['redis_version']) ? $info['Server']['redis_version'] : 0); |
153 | - $date = (isset($info['Server'][ 'uptime_in_seconds' ]) ? (new \DateTime())->setTimestamp(time() - $info['Server'][ 'uptime_in_seconds' ]) : 'unknown date'); |
|
153 | + $date = (isset($info['Server']['uptime_in_seconds']) ? (new \DateTime())->setTimestamp(time() - $info['Server']['uptime_in_seconds']) : 'unknown date'); |
|
154 | 154 | |
155 | 155 | return (new driverStatistic()) |
156 | 156 | ->setData(implode(', ', array_keys($this->itemInstances))) |
@@ -125,10 +125,10 @@ discard block |
||
125 | 125 | $config = isset($this->config[ 'predis' ]) ? $this->config[ 'predis' ] : []; |
126 | 126 | |
127 | 127 | $this->instance = new PredisClient(array_merge([ |
128 | - 'host' => '127.0.0.1', |
|
129 | - 'port' => 6379, |
|
130 | - 'password' => null, |
|
131 | - 'database' => null, |
|
128 | + 'host' => '127.0.0.1', |
|
129 | + 'port' => 6379, |
|
130 | + 'password' => null, |
|
131 | + 'database' => null, |
|
132 | 132 | ], $config)); |
133 | 133 | |
134 | 134 | return true; |
@@ -151,9 +151,9 @@ discard block |
||
151 | 151 | $date = (isset($info['Server'][ 'uptime_in_seconds' ]) ? (new \DateTime())->setTimestamp(time() - $info['Server'][ 'uptime_in_seconds' ]) : 'unknown date'); |
152 | 152 | |
153 | 153 | return (new driverStatistic()) |
154 | - ->setData(implode(', ', array_keys($this->itemInstances))) |
|
155 | - ->setRawData($info) |
|
156 | - ->setSize($size) |
|
157 | - ->setInfo(sprintf("The Redis daemon v%s is up since %s.\n For more information see RawData. \n Driver size includes the memory allocation size.", $version, $date->format(DATE_RFC2822))); |
|
154 | + ->setData(implode(', ', array_keys($this->itemInstances))) |
|
155 | + ->setRawData($info) |
|
156 | + ->setSize($size) |
|
157 | + ->setInfo(sprintf("The Redis daemon v%s is up since %s.\n For more information see RawData. \n Driver size includes the memory allocation size.", $version, $date->format(DATE_RFC2822))); |
|
158 | 158 | } |
159 | 159 | } |
160 | 160 | \ No newline at end of file |
@@ -63,8 +63,8 @@ |
||
63 | 63 | { |
64 | 64 | try { |
65 | 65 | $cacheItem = $this->internalCacheInstance |
66 | - ->getItem($key) |
|
67 | - ->set($value); |
|
66 | + ->getItem($key) |
|
67 | + ->set($value); |
|
68 | 68 | if (is_int($ttl) || $ttl instanceof \DateInterval) { |
69 | 69 | $cacheItem->expiresAfter($ttl); |
70 | 70 | } |
@@ -110,7 +110,7 @@ |
||
110 | 110 | public function getMultiple($keys, $default = null) |
111 | 111 | { |
112 | 112 | try { |
113 | - return array_map(function (ExtendedCacheItemInterface $item) { |
|
113 | + return array_map(function(ExtendedCacheItemInterface $item) { |
|
114 | 114 | return $item->get(); |
115 | 115 | }, $this->internalCacheInstance->getItems($keys)); |
116 | 116 | } catch (phpFastCacheInvalidArgumentException $e) { |
@@ -237,7 +237,7 @@ discard block |
||
237 | 237 | |
238 | 238 | /** |
239 | 239 | * @param \Psr\Cache\CacheItemInterface $item |
240 | - * @return mixed |
|
240 | + * @return boolean |
|
241 | 241 | * @throws phpFastCacheInvalidArgumentException |
242 | 242 | * @throws \RuntimeException |
243 | 243 | */ |
@@ -294,7 +294,7 @@ discard block |
||
294 | 294 | } |
295 | 295 | |
296 | 296 | /** |
297 | - * @return mixed|null |
|
297 | + * @return boolean |
|
298 | 298 | * @throws phpFastCacheInvalidArgumentException |
299 | 299 | */ |
300 | 300 | public function commit() |
@@ -148,9 +148,9 @@ |
||
148 | 148 | * Reset the Item |
149 | 149 | */ |
150 | 150 | $item->set(null) |
151 | - ->expiresAfter(abs((int) $this->getConfig()[ 'defaultTtl' ])) |
|
152 | - ->setHit(false) |
|
153 | - ->setTags([]); |
|
151 | + ->expiresAfter(abs((int) $this->getConfig()[ 'defaultTtl' ])) |
|
152 | + ->setHit(false) |
|
153 | + ->setTags([]); |
|
154 | 154 | if($this->config['itemDetailedDate']){ |
155 | 155 | |
156 | 156 | /** |
@@ -62,7 +62,7 @@ discard block |
||
62 | 62 | public function getItem($key) |
63 | 63 | { |
64 | 64 | if (is_string($key)) { |
65 | - if (preg_match('~([' . preg_quote(self::$unsupportedKeyChars, '~') . ']+)~', $key, $matches)){ |
|
65 | + if (preg_match('~([' . preg_quote(self::$unsupportedKeyChars, '~') . ']+)~', $key, $matches)) { |
|
66 | 66 | throw new phpFastCacheInvalidArgumentException('Unsupported key character detected: "' . $matches[1] . '". Please check: https://github.com/PHPSocialNetwork/phpfastcache/wiki/%5BV6%5D-Unsupported-characters-in-key-identifiers'); |
67 | 67 | } |
68 | 68 | if (!array_key_exists($key, $this->itemInstances)) { |
@@ -81,14 +81,14 @@ discard block |
||
81 | 81 | $driverArray = $this->driverRead($item); |
82 | 82 | |
83 | 83 | if ($driverArray) { |
84 | - if(!is_array($driverArray)){ |
|
84 | + if (!is_array($driverArray)) { |
|
85 | 85 | throw new phpFastCacheCoreException(sprintf('The driverRead method returned an unexpected variable type: %s', gettype($driverArray))); |
86 | 86 | } |
87 | 87 | $driverData = $this->driverUnwrapData($driverArray); |
88 | 88 | |
89 | - if($this->getConfig()[ 'preventCacheSlams' ]){ |
|
90 | - while($driverData instanceof ItemBatch) { |
|
91 | - if($driverData->getItemDate()->getTimestamp() + $this->getConfig()[ 'cacheSlamsTimeout' ] < time()){ |
|
89 | + if ($this->getConfig()['preventCacheSlams']) { |
|
90 | + while ($driverData instanceof ItemBatch) { |
|
91 | + if ($driverData->getItemDate()->getTimestamp() + $this->getConfig()['cacheSlamsTimeout'] < time()) { |
|
92 | 92 | /** |
93 | 93 | * The timeout has been reached |
94 | 94 | * Consider that the batch has |
@@ -120,7 +120,7 @@ discard block |
||
120 | 120 | $item->set($driverData); |
121 | 121 | $item->expiresAt($this->driverUnwrapEdate($driverArray)); |
122 | 122 | |
123 | - if($this->config['itemDetailedDate']){ |
|
123 | + if ($this->config['itemDetailedDate']) { |
|
124 | 124 | |
125 | 125 | /** |
126 | 126 | * If the itemDetailedDate has been |
@@ -148,10 +148,10 @@ discard block |
||
148 | 148 | * Reset the Item |
149 | 149 | */ |
150 | 150 | $item->set(null) |
151 | - ->expiresAfter(abs((int) $this->getConfig()[ 'defaultTtl' ])) |
|
151 | + ->expiresAfter(abs((int) $this->getConfig()['defaultTtl'])) |
|
152 | 152 | ->setHit(false) |
153 | 153 | ->setTags([]); |
154 | - if($this->config['itemDetailedDate']){ |
|
154 | + if ($this->config['itemDetailedDate']) { |
|
155 | 155 | |
156 | 156 | /** |
157 | 157 | * If the itemDetailedDate has been |
@@ -164,8 +164,8 @@ discard block |
||
164 | 164 | } else { |
165 | 165 | $item->setHit(true); |
166 | 166 | } |
167 | - }else{ |
|
168 | - $item->expiresAfter(abs((int) $this->getConfig()[ 'defaultTtl' ])); |
|
167 | + } else { |
|
168 | + $item->expiresAfter(abs((int) $this->getConfig()['defaultTtl'])); |
|
169 | 169 | } |
170 | 170 | } |
171 | 171 | } |
@@ -178,9 +178,9 @@ discard block |
||
178 | 178 | * @param $this ExtendedCacheItemPoolInterface |
179 | 179 | * @param $this ExtendedCacheItemInterface |
180 | 180 | */ |
181 | - $this->eventManager->dispatch('CacheGetItem', $this, $this->itemInstances[ $key ]); |
|
181 | + $this->eventManager->dispatch('CacheGetItem', $this, $this->itemInstances[$key]); |
|
182 | 182 | |
183 | - return $this->itemInstances[ $key ]; |
|
183 | + return $this->itemInstances[$key]; |
|
184 | 184 | } |
185 | 185 | |
186 | 186 | /** |
@@ -191,7 +191,7 @@ discard block |
||
191 | 191 | public function setItem(CacheItemInterface $item) |
192 | 192 | { |
193 | 193 | if ($this->getClassNamespace() . '\\Item' === get_class($item)) { |
194 | - $this->itemInstances[ $item->getKey() ] = $item; |
|
194 | + $this->itemInstances[$item->getKey()] = $item; |
|
195 | 195 | |
196 | 196 | return $this; |
197 | 197 | } else { |
@@ -208,7 +208,7 @@ discard block |
||
208 | 208 | { |
209 | 209 | $collection = []; |
210 | 210 | foreach ($keys as $key) { |
211 | - $collection[ $key ] = $this->getItem($key); |
|
211 | + $collection[$key] = $this->getItem($key); |
|
212 | 212 | } |
213 | 213 | |
214 | 214 | return $collection; |
@@ -305,8 +305,8 @@ discard block |
||
305 | 305 | * @var ExtendedCacheItemInterface $item |
306 | 306 | */ |
307 | 307 | if (!array_key_exists($item->getKey(), $this->itemInstances)) { |
308 | - $this->itemInstances[ $item->getKey() ] = $item; |
|
309 | - } else if(spl_object_hash($item) !== spl_object_hash($this->itemInstances[ $item->getKey() ])){ |
|
308 | + $this->itemInstances[$item->getKey()] = $item; |
|
309 | + } else if (spl_object_hash($item) !== spl_object_hash($this->itemInstances[$item->getKey()])) { |
|
310 | 310 | throw new \RuntimeException('Spl object hash mismatches ! You probably tried to save a detached item which has been already retrieved from cache.'); |
311 | 311 | } |
312 | 312 | |
@@ -318,7 +318,7 @@ discard block |
||
318 | 318 | $this->eventManager->dispatch('CacheSaveItem', $this, $item); |
319 | 319 | |
320 | 320 | |
321 | - if($this->getConfig()[ 'preventCacheSlams' ]){ |
|
321 | + if ($this->getConfig()['preventCacheSlams']) { |
|
322 | 322 | /** |
323 | 323 | * @var $itemBatch ExtendedCacheItemInterface |
324 | 324 | */ |
@@ -326,7 +326,7 @@ discard block |
||
326 | 326 | $itemBatch = $class->newInstanceArgs([$this, $item->getKey()]); |
327 | 327 | $itemBatch->setEventManager($this->eventManager) |
328 | 328 | ->set(new ItemBatch($item->getKey(), new \DateTime())) |
329 | - ->expiresAfter($this->getConfig()[ 'cacheSlamsTimeout' ]); |
|
329 | + ->expiresAfter($this->getConfig()['cacheSlamsTimeout']); |
|
330 | 330 | |
331 | 331 | /** |
332 | 332 | * To avoid SPL mismatches |
@@ -358,8 +358,8 @@ discard block |
||
358 | 358 | public function saveDeferred(CacheItemInterface $item) |
359 | 359 | { |
360 | 360 | if (!array_key_exists($item->getKey(), $this->itemInstances)) { |
361 | - $this->itemInstances[ $item->getKey() ] = $item; |
|
362 | - }else if(spl_object_hash($item) !== spl_object_hash($this->itemInstances[ $item->getKey() ])){ |
|
361 | + $this->itemInstances[$item->getKey()] = $item; |
|
362 | + } else if (spl_object_hash($item) !== spl_object_hash($this->itemInstances[$item->getKey()])) { |
|
363 | 363 | throw new \RuntimeException('Spl object hash mismatches ! You probably tried to save a detached item which has been already retrieved from cache.'); |
364 | 364 | } |
365 | 365 | |
@@ -370,7 +370,7 @@ discard block |
||
370 | 370 | */ |
371 | 371 | $this->eventManager->dispatch('CacheSaveDeferredItem', $this, $item); |
372 | 372 | |
373 | - return $this->deferredList[ $item->getKey() ] = $item; |
|
373 | + return $this->deferredList[$item->getKey()] = $item; |
|
374 | 374 | } |
375 | 375 | |
376 | 376 | /** |
@@ -390,7 +390,7 @@ discard block |
||
390 | 390 | foreach ($this->deferredList as $key => $item) { |
391 | 391 | $result = $this->save($item); |
392 | 392 | if ($return !== false) { |
393 | - unset($this->deferredList[ $key ]); |
|
393 | + unset($this->deferredList[$key]); |
|
394 | 394 | $return = $result; |
395 | 395 | } |
396 | 396 | } |
@@ -164,7 +164,7 @@ discard block |
||
164 | 164 | } else { |
165 | 165 | $item->setHit(true); |
166 | 166 | } |
167 | - }else{ |
|
167 | + } else{ |
|
168 | 168 | $item->expiresAfter(abs((int) $this->getConfig()[ 'defaultTtl' ])); |
169 | 169 | } |
170 | 170 | } |
@@ -359,7 +359,7 @@ discard block |
||
359 | 359 | { |
360 | 360 | if (!array_key_exists($item->getKey(), $this->itemInstances)) { |
361 | 361 | $this->itemInstances[ $item->getKey() ] = $item; |
362 | - }else if(spl_object_hash($item) !== spl_object_hash($this->itemInstances[ $item->getKey() ])){ |
|
362 | + } else if(spl_object_hash($item) !== spl_object_hash($this->itemInstances[ $item->getKey() ])){ |
|
363 | 363 | throw new \RuntimeException('Spl object hash mismatches ! You probably tried to save a detached item which has been already retrieved from cache.'); |
364 | 364 | } |
365 | 365 |
@@ -38,6 +38,7 @@ discard block |
||
38 | 38 | |
39 | 39 | /** |
40 | 40 | * @inheritdoc |
41 | + * @param string $tagName |
|
41 | 42 | */ |
42 | 43 | public function getItemsByTag($tagName) |
43 | 44 | { |
@@ -408,7 +409,7 @@ discard block |
||
408 | 409 | |
409 | 410 | /** |
410 | 411 | * @internal This method de-register an item from $this->itemInstances |
411 | - * @param CacheItemInterface|string $item |
|
412 | + * @param CacheItemInterface $item |
|
412 | 413 | * @throws phpFastCacheInvalidArgumentException |
413 | 414 | */ |
414 | 415 | protected function deregisterItem($item) |
@@ -14,7 +14,6 @@ |
||
14 | 14 | |
15 | 15 | namespace phpFastCache\Core\Pool; |
16 | 16 | |
17 | -use InvalidArgumentException; |
|
18 | 17 | use phpFastCache\Core\Item\ExtendedCacheItemInterface; |
19 | 18 | use phpFastCache\EventManager; |
20 | 19 | use phpFastCache\Exceptions\phpFastCacheInvalidArgumentException; |
@@ -31,7 +31,7 @@ discard block |
||
31 | 31 | */ |
32 | 32 | public function getItemsAsJsonString(array $keys = [], $option = 0, $depth = 512) |
33 | 33 | { |
34 | - $callback = function (CacheItemInterface $item) { |
|
34 | + $callback = function(CacheItemInterface $item) { |
|
35 | 35 | return $item->get(); |
36 | 36 | }; |
37 | 37 | return json_encode(array_map($callback, array_values($this->getItems($keys))), $option, $depth); |
@@ -45,7 +45,7 @@ discard block |
||
45 | 45 | if (is_string($tagName)) { |
46 | 46 | $driverResponse = $this->getItem($this->getTagKey($tagName)); |
47 | 47 | if ($driverResponse->isHit()) { |
48 | - $items = (array)$driverResponse->get(); |
|
48 | + $items = (array) $driverResponse->get(); |
|
49 | 49 | |
50 | 50 | /** |
51 | 51 | * getItems() may provides expired item(s) |
@@ -57,7 +57,7 @@ discard block |
||
57 | 57 | * |
58 | 58 | * #headache |
59 | 59 | */ |
60 | - return array_filter($this->getItems(array_unique(array_keys($items))), function (ExtendedCacheItemInterface $item) { |
|
60 | + return array_filter($this->getItems(array_unique(array_keys($items))), function(ExtendedCacheItemInterface $item) { |
|
61 | 61 | return $item->isHit(); |
62 | 62 | }); |
63 | 63 | } else { |
@@ -75,9 +75,9 @@ discard block |
||
75 | 75 | { |
76 | 76 | $items = []; |
77 | 77 | foreach (array_unique($tagNames) as $tagName) { |
78 | - if(is_string($tagName)){ |
|
78 | + if (is_string($tagName)) { |
|
79 | 79 | $items = array_merge($items, $this->getItemsByTag($tagName)); |
80 | - }else{ |
|
80 | + } else { |
|
81 | 81 | throw new phpFastCacheInvalidArgumentException('$tagName must be a a string'); |
82 | 82 | } |
83 | 83 | } |
@@ -95,7 +95,7 @@ discard block |
||
95 | 95 | |
96 | 96 | foreach ($items as $key => $item) { |
97 | 97 | if (array_diff($tagNames, $item->getTags())) { |
98 | - unset($items[ $key ]); |
|
98 | + unset($items[$key]); |
|
99 | 99 | } |
100 | 100 | } |
101 | 101 | |
@@ -108,7 +108,7 @@ discard block |
||
108 | 108 | */ |
109 | 109 | public function getItemsByTagsAsJsonString(array $tagNames, $option = 0, $depth = 512) |
110 | 110 | { |
111 | - $callback = function (CacheItemInterface $item) { |
|
111 | + $callback = function(CacheItemInterface $item) { |
|
112 | 112 | return $item->get(); |
113 | 113 | }; |
114 | 114 | |
@@ -379,7 +379,7 @@ discard block |
||
379 | 379 | */ |
380 | 380 | public function detachItem(CacheItemInterface $item) |
381 | 381 | { |
382 | - if (isset($this->itemInstances[ $item->getKey() ])) { |
|
382 | + if (isset($this->itemInstances[$item->getKey()])) { |
|
383 | 383 | $this->deregisterItem($item); |
384 | 384 | } |
385 | 385 | } |
@@ -399,10 +399,10 @@ discard block |
||
399 | 399 | */ |
400 | 400 | public function attachItem(CacheItemInterface $item) |
401 | 401 | { |
402 | - if (isset($this->itemInstances[ $item->getKey() ]) && spl_object_hash($item) !== spl_object_hash($this->itemInstances[ $item->getKey() ])) { |
|
402 | + if (isset($this->itemInstances[$item->getKey()]) && spl_object_hash($item) !== spl_object_hash($this->itemInstances[$item->getKey()])) { |
|
403 | 403 | throw new phpFastCacheLogicException('The item already exists and cannot be overwritten because the Spl object hash mismatches ! You probably tried to re-attach a detached item which has been already retrieved from cache.'); |
404 | 404 | } else { |
405 | - $this->itemInstances[ $item->getKey() ] = $item; |
|
405 | + $this->itemInstances[$item->getKey()] = $item; |
|
406 | 406 | } |
407 | 407 | } |
408 | 408 | |
@@ -415,10 +415,10 @@ discard block |
||
415 | 415 | protected function deregisterItem($item) |
416 | 416 | { |
417 | 417 | if ($item instanceof CacheItemInterface) { |
418 | - unset($this->itemInstances[ $item->getKey() ]); |
|
418 | + unset($this->itemInstances[$item->getKey()]); |
|
419 | 419 | |
420 | 420 | } else if (is_string($item)) { |
421 | - unset($this->itemInstances[ $item ]); |
|
421 | + unset($this->itemInstances[$item]); |
|
422 | 422 | } else { |
423 | 423 | throw new phpFastCacheInvalidArgumentException('Invalid type for $item variable'); |
424 | 424 | } |
@@ -437,8 +437,8 @@ discard block |
||
437 | 437 | */ |
438 | 438 | public function isAttached(CacheItemInterface $item) |
439 | 439 | { |
440 | - if (isset($this->itemInstances[ $item->getKey() ])) { |
|
441 | - return spl_object_hash($item) === spl_object_hash($this->itemInstances[ $item->getKey() ]); |
|
440 | + if (isset($this->itemInstances[$item->getKey()])) { |
|
441 | + return spl_object_hash($item) === spl_object_hash($this->itemInstances[$item->getKey()]); |
|
442 | 442 | } |
443 | 443 | return null; |
444 | 444 | } |
@@ -458,8 +458,8 @@ discard block |
||
458 | 458 | */ |
459 | 459 | public function saveMultiple(...$items) |
460 | 460 | { |
461 | - if (isset($items[ 0 ]) && is_array($items[ 0 ])) { |
|
462 | - foreach ($items[ 0 ] as $item) { |
|
461 | + if (isset($items[0]) && is_array($items[0])) { |
|
462 | + foreach ($items[0] as $item) { |
|
463 | 463 | $this->save($item); |
464 | 464 | } |
465 | 465 | return true; |
@@ -77,7 +77,7 @@ |
||
77 | 77 | foreach (array_unique($tagNames) as $tagName) { |
78 | 78 | if(is_string($tagName)){ |
79 | 79 | $items = array_merge($items, $this->getItemsByTag($tagName)); |
80 | - }else{ |
|
80 | + } else{ |
|
81 | 81 | throw new phpFastCacheInvalidArgumentException('$tagName must be a a string'); |
82 | 82 | } |
83 | 83 | } |
@@ -62,7 +62,7 @@ |
||
62 | 62 | |
63 | 63 | /** |
64 | 64 | * @param \Psr\Cache\CacheItemInterface $item |
65 | - * @return mixed |
|
65 | + * @return boolean |
|
66 | 66 | * @throws phpFastCacheInvalidArgumentException |
67 | 67 | */ |
68 | 68 | protected function driverWrite(CacheItemInterface $item) |
@@ -75,16 +75,16 @@ discard block |
||
75 | 75 | try{ |
76 | 76 | $cacheData = $this->encode($this->driverPreWrap($item)); |
77 | 77 | $options = new Cassandra\ExecutionOptions([ |
78 | - 'arguments' => [ |
|
78 | + 'arguments' => [ |
|
79 | 79 | 'cache_uuid' => new Cassandra\Uuid(), |
80 | 80 | 'cache_id' => $item->getKey(), |
81 | 81 | 'cache_data' => $cacheData, |
82 | 82 | 'cache_creation_date' => new Cassandra\Timestamp((new \DateTime())->getTimestamp()), |
83 | 83 | 'cache_expiration_date' => new Cassandra\Timestamp($item->getExpirationDate()->getTimestamp()), |
84 | 84 | 'cache_length' => strlen($cacheData) |
85 | - ], |
|
86 | - 'consistency' => Cassandra::CONSISTENCY_ALL, |
|
87 | - 'serial_consistency' => Cassandra::CONSISTENCY_SERIAL |
|
85 | + ], |
|
86 | + 'consistency' => Cassandra::CONSISTENCY_ALL, |
|
87 | + 'serial_consistency' => Cassandra::CONSISTENCY_SERIAL |
|
88 | 88 | ]); |
89 | 89 | |
90 | 90 | $query = sprintf('INSERT INTO %s.%s |
@@ -122,13 +122,13 @@ discard block |
||
122 | 122 | { |
123 | 123 | try { |
124 | 124 | $options = new Cassandra\ExecutionOptions([ |
125 | - 'arguments' => ['cache_id' => $item->getKey()], |
|
126 | - 'page_size' => 1 |
|
125 | + 'arguments' => ['cache_id' => $item->getKey()], |
|
126 | + 'page_size' => 1 |
|
127 | 127 | ]); |
128 | 128 | $query = sprintf( |
129 | - 'SELECT cache_data FROM %s.%s WHERE cache_id = :cache_id;', |
|
130 | - self::CASSANDRA_KEY_SPACE, |
|
131 | - self::CASSANDRA_TABLE |
|
129 | + 'SELECT cache_data FROM %s.%s WHERE cache_id = :cache_id;', |
|
130 | + self::CASSANDRA_KEY_SPACE, |
|
131 | + self::CASSANDRA_TABLE |
|
132 | 132 | ); |
133 | 133 | $results = $this->instance->execute(new Cassandra\SimpleStatement($query), $options); |
134 | 134 | |
@@ -155,14 +155,14 @@ discard block |
||
155 | 155 | if ($item instanceof Item) { |
156 | 156 | try { |
157 | 157 | $options = new Cassandra\ExecutionOptions([ |
158 | - 'arguments' => [ |
|
158 | + 'arguments' => [ |
|
159 | 159 | 'cache_id' => $item->getKey(), |
160 | - ], |
|
160 | + ], |
|
161 | 161 | ]); |
162 | 162 | $result = $this->instance->execute(new Cassandra\SimpleStatement(sprintf( |
163 | - 'DELETE FROM %s.%s WHERE cache_id = :cache_id;', |
|
164 | - self::CASSANDRA_KEY_SPACE, |
|
165 | - self::CASSANDRA_TABLE |
|
163 | + 'DELETE FROM %s.%s WHERE cache_id = :cache_id;', |
|
164 | + self::CASSANDRA_KEY_SPACE, |
|
165 | + self::CASSANDRA_TABLE |
|
166 | 166 | )), $options); |
167 | 167 | |
168 | 168 | /** |
@@ -186,8 +186,8 @@ discard block |
||
186 | 186 | { |
187 | 187 | try { |
188 | 188 | $this->instance->execute(new Cassandra\SimpleStatement(sprintf( |
189 | - 'TRUNCATE %s.%s;', |
|
190 | - self::CASSANDRA_KEY_SPACE, self::CASSANDRA_TABLE |
|
189 | + 'TRUNCATE %s.%s;', |
|
190 | + self::CASSANDRA_KEY_SPACE, self::CASSANDRA_TABLE |
|
191 | 191 | ))); |
192 | 192 | |
193 | 193 | return true; |
@@ -213,8 +213,8 @@ discard block |
||
213 | 213 | $username = isset($this->config[ 'username' ]) ? $this->config[ 'username' ] : ''; |
214 | 214 | |
215 | 215 | $clusterBuilder = Cassandra::cluster() |
216 | - ->withContactPoints($host) |
|
217 | - ->withPort($port); |
|
216 | + ->withContactPoints($host) |
|
217 | + ->withPort($port); |
|
218 | 218 | |
219 | 219 | if(!empty($this->config['ssl']['enabled'])){ |
220 | 220 | if(!empty($this->config['ssl']['verify'])){ |
@@ -242,8 +242,8 @@ discard block |
||
242 | 242 | */ |
243 | 243 | |
244 | 244 | $this->instance->execute(new Cassandra\SimpleStatement(sprintf( |
245 | - "CREATE KEYSPACE IF NOT EXISTS %s WITH REPLICATION = { 'class' : 'SimpleStrategy', 'replication_factor' : 1 };", |
|
246 | - self::CASSANDRA_KEY_SPACE |
|
245 | + "CREATE KEYSPACE IF NOT EXISTS %s WITH REPLICATION = { 'class' : 'SimpleStrategy', 'replication_factor' : 1 };", |
|
246 | + self::CASSANDRA_KEY_SPACE |
|
247 | 247 | ))); |
248 | 248 | $this->instance->execute(new Cassandra\SimpleStatement(sprintf('USE %s;', self::CASSANDRA_KEY_SPACE))); |
249 | 249 | $this->instance->execute(new Cassandra\SimpleStatement(sprintf(' |
@@ -290,15 +290,15 @@ discard block |
||
290 | 290 | public function getStats() |
291 | 291 | { |
292 | 292 | $result = $this->instance->execute(new Cassandra\SimpleStatement(sprintf( |
293 | - 'SELECT SUM(cache_length) as cache_size FROM %s.%s', |
|
294 | - self::CASSANDRA_KEY_SPACE, |
|
295 | - self::CASSANDRA_TABLE |
|
293 | + 'SELECT SUM(cache_length) as cache_size FROM %s.%s', |
|
294 | + self::CASSANDRA_KEY_SPACE, |
|
295 | + self::CASSANDRA_TABLE |
|
296 | 296 | ))); |
297 | 297 | |
298 | 298 | return (new driverStatistic()) |
299 | - ->setSize($result->first()[ 'cache_size' ]) |
|
300 | - ->setRawData([]) |
|
301 | - ->setData(implode(', ', array_keys($this->itemInstances))) |
|
302 | - ->setInfo('The cache size represents only the cache data itself without counting data structures associated to the cache entries.'); |
|
299 | + ->setSize($result->first()[ 'cache_size' ]) |
|
300 | + ->setRawData([]) |
|
301 | + ->setData(implode(', ', array_keys($this->itemInstances))) |
|
302 | + ->setInfo('The cache size represents only the cache data itself without counting data structures associated to the cache entries.'); |
|
303 | 303 | } |
304 | 304 | } |
305 | 305 | \ No newline at end of file |
@@ -72,7 +72,7 @@ discard block |
||
72 | 72 | * Check for Cross-Driver type confusion |
73 | 73 | */ |
74 | 74 | if ($item instanceof Item) { |
75 | - try{ |
|
75 | + try { |
|
76 | 76 | $cacheData = $this->encode($this->driverPreWrap($item)); |
77 | 77 | $options = new Cassandra\ExecutionOptions([ |
78 | 78 | 'arguments' => [ |
@@ -106,7 +106,7 @@ discard block |
||
106 | 106 | * been really upserted |
107 | 107 | */ |
108 | 108 | return $result instanceof Cassandra\Rows; |
109 | - }catch(\Cassandra\Exception\InvalidArgumentException $e){ |
|
109 | + } catch (\Cassandra\Exception\InvalidArgumentException $e) { |
|
110 | 110 | throw new phpFastCacheInvalidArgumentException($e, 0, $e); |
111 | 111 | } |
112 | 112 | } else { |
@@ -132,9 +132,9 @@ discard block |
||
132 | 132 | ); |
133 | 133 | $results = $this->instance->execute(new Cassandra\SimpleStatement($query), $options); |
134 | 134 | |
135 | - if($results instanceof Cassandra\Rows && $results->count() === 1){ |
|
135 | + if ($results instanceof Cassandra\Rows && $results->count() === 1) { |
|
136 | 136 | return $this->decode($results->first()['cache_data']); |
137 | - }else{ |
|
137 | + } else { |
|
138 | 138 | return null; |
139 | 139 | } |
140 | 140 | } catch (Cassandra\Exception $e) { |
@@ -206,20 +206,20 @@ discard block |
||
206 | 206 | if ($this->instance instanceof CassandraSession) { |
207 | 207 | throw new phpFastCacheLogicException('Already connected to Couchbase server'); |
208 | 208 | } else { |
209 | - $host = isset($this->config[ 'host' ]) ? $this->config[ 'host' ] : '127.0.0.1'; |
|
210 | - $port = isset($this->config[ 'port' ]) ? $this->config[ 'port' ] : 9042; |
|
211 | - $timeout = isset($this->config[ 'timeout' ]) ? $this->config[ 'timeout' ] : 2; |
|
212 | - $password = isset($this->config[ 'password' ]) ? $this->config[ 'password' ] : ''; |
|
213 | - $username = isset($this->config[ 'username' ]) ? $this->config[ 'username' ] : ''; |
|
209 | + $host = isset($this->config['host']) ? $this->config['host'] : '127.0.0.1'; |
|
210 | + $port = isset($this->config['port']) ? $this->config['port'] : 9042; |
|
211 | + $timeout = isset($this->config['timeout']) ? $this->config['timeout'] : 2; |
|
212 | + $password = isset($this->config['password']) ? $this->config['password'] : ''; |
|
213 | + $username = isset($this->config['username']) ? $this->config['username'] : ''; |
|
214 | 214 | |
215 | 215 | $clusterBuilder = Cassandra::cluster() |
216 | 216 | ->withContactPoints($host) |
217 | 217 | ->withPort($port); |
218 | 218 | |
219 | - if(!empty($this->config['ssl']['enabled'])){ |
|
220 | - if(!empty($this->config['ssl']['verify'])){ |
|
219 | + if (!empty($this->config['ssl']['enabled'])) { |
|
220 | + if (!empty($this->config['ssl']['verify'])) { |
|
221 | 221 | $sslBuilder = Cassandra::ssl()->withVerifyFlags(Cassandra::VERIFY_PEER_CERT); |
222 | - }else{ |
|
222 | + } else { |
|
223 | 223 | $sslBuilder = Cassandra::ssl()->withVerifyFlags(Cassandra::VERIFY_NONE); |
224 | 224 | } |
225 | 225 | |
@@ -228,7 +228,7 @@ discard block |
||
228 | 228 | |
229 | 229 | $clusterBuilder->withConnectTimeout($timeout); |
230 | 230 | |
231 | - if($username){ |
|
231 | + if ($username) { |
|
232 | 232 | $clusterBuilder->withCredentials($username, $password); |
233 | 233 | } |
234 | 234 | |
@@ -296,7 +296,7 @@ discard block |
||
296 | 296 | ))); |
297 | 297 | |
298 | 298 | return (new driverStatistic()) |
299 | - ->setSize($result->first()[ 'cache_size' ]) |
|
299 | + ->setSize($result->first()['cache_size']) |
|
300 | 300 | ->setRawData([]) |
301 | 301 | ->setData(implode(', ', array_keys($this->itemInstances))) |
302 | 302 | ->setInfo('The cache size represents only the cache data itself without counting data structures associated to the cache entries.'); |
@@ -106,7 +106,7 @@ discard block |
||
106 | 106 | * been really upserted |
107 | 107 | */ |
108 | 108 | return $result instanceof Cassandra\Rows; |
109 | - }catch(\Cassandra\Exception\InvalidArgumentException $e){ |
|
109 | + } catch(\Cassandra\Exception\InvalidArgumentException $e){ |
|
110 | 110 | throw new phpFastCacheInvalidArgumentException($e, 0, $e); |
111 | 111 | } |
112 | 112 | } else { |
@@ -134,7 +134,7 @@ discard block |
||
134 | 134 | |
135 | 135 | if($results instanceof Cassandra\Rows && $results->count() === 1){ |
136 | 136 | return $this->decode($results->first()['cache_data']); |
137 | - }else{ |
|
137 | + } else{ |
|
138 | 138 | return null; |
139 | 139 | } |
140 | 140 | } catch (Cassandra\Exception $e) { |
@@ -219,7 +219,7 @@ discard block |
||
219 | 219 | if(!empty($this->config['ssl']['enabled'])){ |
220 | 220 | if(!empty($this->config['ssl']['verify'])){ |
221 | 221 | $sslBuilder = Cassandra::ssl()->withVerifyFlags(Cassandra::VERIFY_PEER_CERT); |
222 | - }else{ |
|
222 | + } else{ |
|
223 | 223 | $sslBuilder = Cassandra::ssl()->withVerifyFlags(Cassandra::VERIFY_NONE); |
224 | 224 | } |
225 | 225 |
@@ -60,7 +60,7 @@ discard block |
||
60 | 60 | |
61 | 61 | /** |
62 | 62 | * @param \Psr\Cache\CacheItemInterface $item |
63 | - * @return mixed |
|
63 | + * @return boolean |
|
64 | 64 | * @throws phpFastCacheInvalidArgumentException |
65 | 65 | */ |
66 | 66 | protected function driverWrite(CacheItemInterface $item) |
@@ -146,7 +146,7 @@ discard block |
||
146 | 146 | /** |
147 | 147 | * @param string $optionName |
148 | 148 | * @param mixed $optionValue |
149 | - * @return bool |
|
149 | + * @return boolean|null |
|
150 | 150 | * @throws phpFastCacheInvalidArgumentException |
151 | 151 | */ |
152 | 152 | public static function isValidOption($optionName, $optionValue) |
@@ -179,7 +179,7 @@ discard block |
||
179 | 179 | } |
180 | 180 | |
181 | 181 | /** |
182 | - * @return array |
|
182 | + * @return string[] |
|
183 | 183 | */ |
184 | 184 | public static function getValidOptions() |
185 | 185 | { |
@@ -187,7 +187,7 @@ discard block |
||
187 | 187 | } |
188 | 188 | |
189 | 189 | /** |
190 | - * @return array |
|
190 | + * @return string[] |
|
191 | 191 | */ |
192 | 192 | public static function getRequiredOptions() |
193 | 193 | { |
@@ -69,8 +69,8 @@ discard block |
||
69 | 69 | public function dispatch($eventName, ...$args) |
70 | 70 | { |
71 | 71 | $eventName = 'on' . ucfirst($eventName); |
72 | - if(array_key_exists($eventName, $this->events)){ |
|
73 | - foreach ($this->events[ $eventName ] as $event) { |
|
72 | + if (array_key_exists($eventName, $this->events)) { |
|
73 | + foreach ($this->events[$eventName] as $event) { |
|
74 | 74 | call_user_func_array($event, $args); |
75 | 75 | } |
76 | 76 | } |
@@ -84,17 +84,17 @@ discard block |
||
84 | 84 | */ |
85 | 85 | public function __call($name, $arguments) |
86 | 86 | { |
87 | - if(strpos($name, 'on') === 0){ |
|
88 | - if(is_callable($arguments[0])){ |
|
89 | - if(isset($arguments[1]) && is_string($arguments[0])){ |
|
87 | + if (strpos($name, 'on') === 0) { |
|
88 | + if (is_callable($arguments[0])) { |
|
89 | + if (isset($arguments[1]) && is_string($arguments[0])) { |
|
90 | 90 | $this->events[$name][$arguments[1]] = $arguments[0]; |
91 | - }else { |
|
91 | + } else { |
|
92 | 92 | $this->events[$name][] = $arguments[0]; |
93 | 93 | } |
94 | - }else{ |
|
94 | + } else { |
|
95 | 95 | throw new phpFastCacheInvalidArgumentException(sprintf('Expected Callable, got "%s"', gettype($arguments[0]))); |
96 | 96 | } |
97 | - }else{ |
|
97 | + } else { |
|
98 | 98 | throw new \BadMethodCallException('An event must start with "on" such as "onCacheGetItem"'); |
99 | 99 | } |
100 | 100 | } |
@@ -106,7 +106,7 @@ discard block |
||
106 | 106 | */ |
107 | 107 | public function unbindEventCallback($eventName, $callbackName) |
108 | 108 | { |
109 | - if(isset($this->events[$eventName][$callbackName])){ |
|
109 | + if (isset($this->events[$eventName][$callbackName])) { |
|
110 | 110 | unset($this->events[$eventName][$callbackName]); |
111 | 111 | return true; |
112 | 112 | } |
@@ -88,13 +88,13 @@ |
||
88 | 88 | if(is_callable($arguments[0])){ |
89 | 89 | if(isset($arguments[1]) && is_string($arguments[0])){ |
90 | 90 | $this->events[$name][$arguments[1]] = $arguments[0]; |
91 | - }else { |
|
91 | + } else { |
|
92 | 92 | $this->events[$name][] = $arguments[0]; |
93 | 93 | } |
94 | - }else{ |
|
94 | + } else{ |
|
95 | 95 | throw new phpFastCacheInvalidArgumentException(sprintf('Expected Callable, got "%s"', gettype($arguments[0]))); |
96 | 96 | } |
97 | - }else{ |
|
97 | + } else{ |
|
98 | 98 | throw new \BadMethodCallException('An event must start with "on" such as "onCacheGetItem"'); |
99 | 99 | } |
100 | 100 | } |
@@ -43,7 +43,7 @@ |
||
43 | 43 | $this->driver->setItem($this); |
44 | 44 | } else { |
45 | 45 | throw new phpFastCacheInvalidArgumentException(sprintf('$key must be a string, got type "%s" instead.', |
46 | - gettype($key))); |
|
46 | + gettype($key))); |
|
47 | 47 | } |
48 | 48 | } |
49 | 49 |
@@ -142,10 +142,10 @@ discard block |
||
142 | 142 | $password = isset($this->config[ 'password' ]) ? $this->config[ 'password' ] : ''; |
143 | 143 | $username = isset($this->config[ 'username' ]) ? $this->config[ 'username' ] : ''; |
144 | 144 | $buckets = isset($this->config[ 'buckets' ]) ? $this->config[ 'buckets' ] : [ |
145 | - [ |
|
145 | + [ |
|
146 | 146 | 'bucket' => 'default', |
147 | 147 | 'password' => '', |
148 | - ], |
|
148 | + ], |
|
149 | 149 | ]; |
150 | 150 | |
151 | 151 | $this->instance = new CouchbaseClient("couchbase://{$host}", $username, $password); |
@@ -195,9 +195,9 @@ discard block |
||
195 | 195 | $info = $this->getBucket()->manager()->info(); |
196 | 196 | |
197 | 197 | return (new driverStatistic()) |
198 | - ->setSize($info[ 'basicStats' ][ 'diskUsed' ]) |
|
199 | - ->setRawData($info) |
|
200 | - ->setData(implode(', ', array_keys($this->itemInstances))) |
|
201 | - ->setInfo('CouchBase version ' . $info[ 'nodes' ][ 0 ][ 'version' ] . ', Uptime (in days): ' . round($info[ 'nodes' ][ 0 ][ 'uptime' ] / 86400, 1) . "\n For more information see RawData."); |
|
198 | + ->setSize($info[ 'basicStats' ][ 'diskUsed' ]) |
|
199 | + ->setRawData($info) |
|
200 | + ->setData(implode(', ', array_keys($this->itemInstances))) |
|
201 | + ->setInfo('CouchBase version ' . $info[ 'nodes' ][ 0 ][ 'version' ] . ', Uptime (in days): ' . round($info[ 'nodes' ][ 0 ][ 'uptime' ] / 86400, 1) . "\n For more information see RawData."); |
|
202 | 202 | } |
203 | 203 | } |
204 | 204 | \ No newline at end of file |
@@ -136,10 +136,10 @@ discard block |
||
136 | 136 | } else { |
137 | 137 | |
138 | 138 | |
139 | - $host = isset($this->config[ 'host' ]) ? $this->config[ 'host' ] : '127.0.0.1'; |
|
140 | - $password = isset($this->config[ 'password' ]) ? $this->config[ 'password' ] : ''; |
|
141 | - $username = isset($this->config[ 'username' ]) ? $this->config[ 'username' ] : ''; |
|
142 | - $buckets = isset($this->config[ 'buckets' ]) ? $this->config[ 'buckets' ] : [ |
|
139 | + $host = isset($this->config['host']) ? $this->config['host'] : '127.0.0.1'; |
|
140 | + $password = isset($this->config['password']) ? $this->config['password'] : ''; |
|
141 | + $username = isset($this->config['username']) ? $this->config['username'] : ''; |
|
142 | + $buckets = isset($this->config['buckets']) ? $this->config['buckets'] : [ |
|
143 | 143 | [ |
144 | 144 | 'bucket' => 'default', |
145 | 145 | 'password' => '', |
@@ -149,8 +149,8 @@ discard block |
||
149 | 149 | $this->instance = new CouchbaseClient("couchbase://{$host}", $username, $password); |
150 | 150 | |
151 | 151 | foreach ($buckets as $bucket) { |
152 | - $this->bucketCurrent = $this->bucketCurrent ?: $bucket[ 'bucket' ]; |
|
153 | - $this->setBucket($bucket[ 'bucket' ], $this->instance->openBucket($bucket[ 'bucket' ], $bucket[ 'password' ])); |
|
152 | + $this->bucketCurrent = $this->bucketCurrent ?: $bucket['bucket']; |
|
153 | + $this->setBucket($bucket['bucket'], $this->instance->openBucket($bucket['bucket'], $bucket['password'])); |
|
154 | 154 | } |
155 | 155 | } |
156 | 156 | |
@@ -162,7 +162,7 @@ discard block |
||
162 | 162 | */ |
163 | 163 | protected function getBucket() |
164 | 164 | { |
165 | - return $this->bucketInstances[ $this->bucketCurrent ]; |
|
165 | + return $this->bucketInstances[$this->bucketCurrent]; |
|
166 | 166 | } |
167 | 167 | |
168 | 168 | /** |
@@ -173,7 +173,7 @@ discard block |
||
173 | 173 | protected function setBucket($bucketName, \CouchbaseBucket $CouchbaseBucket) |
174 | 174 | { |
175 | 175 | if (!array_key_exists($bucketName, $this->bucketInstances)) { |
176 | - $this->bucketInstances[ $bucketName ] = $CouchbaseBucket; |
|
176 | + $this->bucketInstances[$bucketName] = $CouchbaseBucket; |
|
177 | 177 | } else { |
178 | 178 | throw new phpFastCacheLogicException('A bucket instance with this name already exists.'); |
179 | 179 | } |
@@ -193,9 +193,9 @@ discard block |
||
193 | 193 | $info = $this->getBucket()->manager()->info(); |
194 | 194 | |
195 | 195 | return (new driverStatistic()) |
196 | - ->setSize($info[ 'basicStats' ][ 'diskUsed' ]) |
|
196 | + ->setSize($info['basicStats']['diskUsed']) |
|
197 | 197 | ->setRawData($info) |
198 | 198 | ->setData(implode(', ', array_keys($this->itemInstances))) |
199 | - ->setInfo('CouchBase version ' . $info[ 'nodes' ][ 0 ][ 'version' ] . ', Uptime (in days): ' . round($info[ 'nodes' ][ 0 ][ 'uptime' ] / 86400, 1) . "\n For more information see RawData."); |
|
199 | + ->setInfo('CouchBase version ' . $info['nodes'][0]['version'] . ', Uptime (in days): ' . round($info['nodes'][0]['uptime'] / 86400, 1) . "\n For more information see RawData."); |
|
200 | 200 | } |
201 | 201 | } |
202 | 202 | \ No newline at end of file |