@@ -18,7 +18,7 @@ discard block |
||
| 18 | 18 | use Phpfastcache\Core\Pool\{DriverBaseTrait, ExtendedCacheItemPoolInterface}; |
| 19 | 19 | use Phpfastcache\Entities\DriverStatistic; |
| 20 | 20 | use Phpfastcache\Exceptions\{ |
| 21 | - phpFastCacheInvalidArgumentException |
|
| 21 | + phpFastCacheInvalidArgumentException |
|
| 22 | 22 | }; |
| 23 | 23 | use Psr\Cache\CacheItemInterface; |
| 24 | 24 | |
@@ -112,9 +112,9 @@ discard block |
||
| 112 | 112 | { |
| 113 | 113 | $stat = new DriverStatistic(); |
| 114 | 114 | $stat->setInfo('[Devnull] A void info string') |
| 115 | - ->setSize(0) |
|
| 116 | - ->setData(\implode(', ', \array_keys($this->itemInstances))) |
|
| 117 | - ->setRawData(null); |
|
| 115 | + ->setSize(0) |
|
| 116 | + ->setData(\implode(', ', \array_keys($this->itemInstances))) |
|
| 117 | + ->setRawData(null); |
|
| 118 | 118 | |
| 119 | 119 | return $stat; |
| 120 | 120 | } |
@@ -11,7 +11,7 @@ |
||
| 11 | 11 | * @author Georges.L (Geolim4) <[email protected]> |
| 12 | 12 | * |
| 13 | 13 | */ |
| 14 | -declare(strict_types=1); |
|
| 14 | +declare(strict_types = 1); |
|
| 15 | 15 | |
| 16 | 16 | namespace Phpfastcache\Drivers\Devnull; |
| 17 | 17 | |
@@ -19,7 +19,7 @@ |
||
| 19 | 19 | use Phpfastcache\Core\Pool\ExtendedCacheItemPoolInterface; |
| 20 | 20 | use Phpfastcache\Drivers\Ssdb\Driver as SsdbDriver; |
| 21 | 21 | use Phpfastcache\Exceptions\{ |
| 22 | - phpFastCacheInvalidArgumentException, phpFastCacheInvalidArgumentTypeException |
|
| 22 | + phpFastCacheInvalidArgumentException, phpFastCacheInvalidArgumentTypeException |
|
| 23 | 23 | }; |
| 24 | 24 | |
| 25 | 25 | /** |
@@ -11,7 +11,7 @@ |
||
| 11 | 11 | * @author Georges.L (Geolim4) <[email protected]> |
| 12 | 12 | * |
| 13 | 13 | */ |
| 14 | -declare(strict_types=1); |
|
| 14 | +declare(strict_types = 1); |
|
| 15 | 15 | |
| 16 | 16 | namespace Phpfastcache\Drivers\Ssdb; |
| 17 | 17 | |
@@ -18,7 +18,7 @@ discard block |
||
| 18 | 18 | use Phpfastcache\Core\Pool\{DriverBaseTrait, ExtendedCacheItemPoolInterface}; |
| 19 | 19 | use Phpfastcache\Entities\DriverStatistic; |
| 20 | 20 | use Phpfastcache\Exceptions\{ |
| 21 | - phpFastCacheInvalidArgumentException, phpFastCacheDriverCheckException, phpFastCacheDriverException |
|
| 21 | + phpFastCacheInvalidArgumentException, phpFastCacheDriverCheckException, phpFastCacheDriverException |
|
| 22 | 22 | }; |
| 23 | 23 | use Phpfastcache\Util\ArrayObject; |
| 24 | 24 | use phpssdb\Core\{SimpleSSDB, SSDBException}; |
@@ -147,9 +147,9 @@ discard block |
||
| 147 | 147 | * using hardcoded offset of pair key-value :-( |
| 148 | 148 | */ |
| 149 | 149 | $stat->setInfo(\sprintf("Ssdb-server v%s with a total of %s call(s).\n For more information see RawData.", $info[ 2 ], $info[ 6 ])) |
| 150 | - ->setRawData($info) |
|
| 151 | - ->setData(\implode(', ', \array_keys($this->itemInstances))) |
|
| 152 | - ->setSize($this->instance->dbsize()); |
|
| 150 | + ->setRawData($info) |
|
| 151 | + ->setData(\implode(', ', \array_keys($this->itemInstances))) |
|
| 152 | + ->setSize($this->instance->dbsize()); |
|
| 153 | 153 | |
| 154 | 154 | return $stat; |
| 155 | 155 | } |
@@ -11,7 +11,7 @@ discard block |
||
| 11 | 11 | * @author Georges.L (Geolim4) <[email protected]> |
| 12 | 12 | * |
| 13 | 13 | */ |
| 14 | -declare(strict_types=1); |
|
| 14 | +declare(strict_types = 1); |
|
| 15 | 15 | |
| 16 | 16 | namespace Phpfastcache\Drivers\Ssdb; |
| 17 | 17 | |
@@ -57,9 +57,9 @@ discard block |
||
| 57 | 57 | try { |
| 58 | 58 | $clientConfig = $this->getConfig(); |
| 59 | 59 | |
| 60 | - $this->instance = new SimpleSSDB($clientConfig[ 'host' ], $clientConfig[ 'port' ], $clientConfig[ 'timeout' ]); |
|
| 61 | - if (!empty($clientConfig[ 'password' ])) { |
|
| 62 | - $this->instance->auth($clientConfig[ 'password' ]); |
|
| 60 | + $this->instance = new SimpleSSDB($clientConfig['host'], $clientConfig['port'], $clientConfig['timeout']); |
|
| 61 | + if (!empty($clientConfig['password'])) { |
|
| 62 | + $this->instance->auth($clientConfig['password']); |
|
| 63 | 63 | } |
| 64 | 64 | |
| 65 | 65 | if (!$this->instance) { |
@@ -146,7 +146,7 @@ discard block |
||
| 146 | 146 | * Data returned by Ssdb are very poorly formatted |
| 147 | 147 | * using hardcoded offset of pair key-value :-( |
| 148 | 148 | */ |
| 149 | - $stat->setInfo(\sprintf("Ssdb-server v%s with a total of %s call(s).\n For more information see RawData.", $info[ 2 ], $info[ 6 ])) |
|
| 149 | + $stat->setInfo(\sprintf("Ssdb-server v%s with a total of %s call(s).\n For more information see RawData.", $info[2], $info[6])) |
|
| 150 | 150 | ->setRawData($info) |
| 151 | 151 | ->setData(\implode(', ', \array_keys($this->itemInstances))) |
| 152 | 152 | ->setSize($this->instance->dbsize()); |
@@ -19,7 +19,7 @@ |
||
| 19 | 19 | use Phpfastcache\Core\Pool\ExtendedCacheItemPoolInterface; |
| 20 | 20 | use Phpfastcache\Drivers\Memstatic\Driver as MemstaticDriver; |
| 21 | 21 | use Phpfastcache\Exceptions\{ |
| 22 | - phpFastCacheInvalidArgumentException, phpFastCacheInvalidArgumentTypeException |
|
| 22 | + phpFastCacheInvalidArgumentException, phpFastCacheInvalidArgumentTypeException |
|
| 23 | 23 | }; |
| 24 | 24 | |
| 25 | 25 | /** |
@@ -11,7 +11,7 @@ |
||
| 11 | 11 | * @author Georges.L (Geolim4) <[email protected]> |
| 12 | 12 | * |
| 13 | 13 | */ |
| 14 | -declare(strict_types=1); |
|
| 14 | +declare(strict_types = 1); |
|
| 15 | 15 | |
| 16 | 16 | namespace Phpfastcache\Drivers\Memstatic; |
| 17 | 17 | |
@@ -18,7 +18,7 @@ discard block |
||
| 18 | 18 | use Phpfastcache\Core\Pool\{DriverBaseTrait, ExtendedCacheItemPoolInterface}; |
| 19 | 19 | use Phpfastcache\Entities\DriverStatistic; |
| 20 | 20 | use Phpfastcache\Exceptions\{ |
| 21 | - phpFastCacheInvalidArgumentException |
|
| 21 | + phpFastCacheInvalidArgumentException |
|
| 22 | 22 | }; |
| 23 | 23 | use Psr\Cache\CacheItemInterface; |
| 24 | 24 | |
@@ -129,9 +129,9 @@ discard block |
||
| 129 | 129 | { |
| 130 | 130 | $stat = new DriverStatistic(); |
| 131 | 131 | $stat->setInfo('[Memstatic] A memory static driver') |
| 132 | - ->setSize(mb_strlen(\serialize($this->staticStack))) |
|
| 133 | - ->setData(\implode(', ', \array_keys($this->itemInstances))) |
|
| 134 | - ->setRawData($this->staticStack); |
|
| 132 | + ->setSize(mb_strlen(\serialize($this->staticStack))) |
|
| 133 | + ->setData(\implode(', ', \array_keys($this->itemInstances))) |
|
| 134 | + ->setRawData($this->staticStack); |
|
| 135 | 135 | |
| 136 | 136 | return $stat; |
| 137 | 137 | } |
@@ -11,7 +11,7 @@ discard block |
||
| 11 | 11 | * @author Georges.L (Geolim4) <[email protected]> |
| 12 | 12 | * |
| 13 | 13 | */ |
| 14 | -declare(strict_types=1); |
|
| 14 | +declare(strict_types = 1); |
|
| 15 | 15 | |
| 16 | 16 | namespace Phpfastcache\Drivers\Memstatic; |
| 17 | 17 | |
@@ -60,8 +60,8 @@ discard block |
||
| 60 | 60 | protected function driverRead(CacheItemInterface $item) |
| 61 | 61 | { |
| 62 | 62 | $key = \md5($item->getKey()); |
| 63 | - if (isset($this->staticStack[ $key ])) { |
|
| 64 | - return $this->staticStack[ $key ]; |
|
| 63 | + if (isset($this->staticStack[$key])) { |
|
| 64 | + return $this->staticStack[$key]; |
|
| 65 | 65 | } |
| 66 | 66 | return null; |
| 67 | 67 | } |
@@ -77,7 +77,7 @@ discard block |
||
| 77 | 77 | * Check for Cross-Driver type confusion |
| 78 | 78 | */ |
| 79 | 79 | if ($item instanceof Item) { |
| 80 | - $this->staticStack[ \md5($item->getKey()) ] = $this->driverPreWrap($item); |
|
| 80 | + $this->staticStack[\md5($item->getKey())] = $this->driverPreWrap($item); |
|
| 81 | 81 | return true; |
| 82 | 82 | } |
| 83 | 83 | |
@@ -96,8 +96,8 @@ discard block |
||
| 96 | 96 | */ |
| 97 | 97 | if ($item instanceof Item) { |
| 98 | 98 | $key = \md5($item->getKey()); |
| 99 | - if (isset($this->staticStack[ $key ])) { |
|
| 100 | - unset($this->staticStack[ $key ]); |
|
| 99 | + if (isset($this->staticStack[$key])) { |
|
| 100 | + unset($this->staticStack[$key]); |
|
| 101 | 101 | return true; |
| 102 | 102 | } |
| 103 | 103 | return false; |
@@ -19,7 +19,7 @@ |
||
| 19 | 19 | use Phpfastcache\Core\Pool\ExtendedCacheItemPoolInterface; |
| 20 | 20 | use Phpfastcache\Drivers\Memcached\Driver as MemcachedDriver; |
| 21 | 21 | use Phpfastcache\Exceptions\{ |
| 22 | - phpFastCacheInvalidArgumentException, phpFastCacheInvalidArgumentTypeException |
|
| 22 | + phpFastCacheInvalidArgumentException, phpFastCacheInvalidArgumentTypeException |
|
| 23 | 23 | }; |
| 24 | 24 | |
| 25 | 25 | /** |
@@ -11,7 +11,7 @@ |
||
| 11 | 11 | * @author Georges.L (Geolim4) <[email protected]> |
| 12 | 12 | * |
| 13 | 13 | */ |
| 14 | -declare(strict_types=1); |
|
| 14 | +declare(strict_types = 1); |
|
| 15 | 15 | |
| 16 | 16 | namespace Phpfastcache\Drivers\Memcached; |
| 17 | 17 | |
@@ -11,7 +11,7 @@ discard block |
||
| 11 | 11 | * @author Georges.L (Geolim4) <[email protected]> |
| 12 | 12 | * |
| 13 | 13 | */ |
| 14 | -declare(strict_types=1); |
|
| 14 | +declare(strict_types = 1); |
|
| 15 | 15 | |
| 16 | 16 | namespace Phpfastcache\Drivers\Memcached; |
| 17 | 17 | |
@@ -74,7 +74,7 @@ discard block |
||
| 74 | 74 | 'path' => !empty($this->config->getOption('path')) ? $this->config->getOption('path') : false, |
| 75 | 75 | 'port' => !empty($this->config->getOption('port')) ? $this->config->getOption('port') : 11211, |
| 76 | 76 | 'saslUser' => !empty($this->config->getOption('saslUser')) ? $this->config->getOption('saslUser') : false, |
| 77 | - 'saslPassword' =>!empty($this->config->getOption('saslPassword')) ? $this->config->getOption('saslPassword'): false, |
|
| 77 | + 'saslPassword' =>!empty($this->config->getOption('saslPassword')) ? $this->config->getOption('saslPassword') : false, |
|
| 78 | 78 | ], |
| 79 | 79 | ]; |
| 80 | 80 | } |
@@ -84,14 +84,14 @@ discard block |
||
| 84 | 84 | /** |
| 85 | 85 | * If path is provided we consider it as an UNIX Socket |
| 86 | 86 | */ |
| 87 | - if(!empty($server[ 'path' ]) && !$this->instance->addServer($server[ 'path' ], 0)){ |
|
| 87 | + if (!empty($server['path']) && !$this->instance->addServer($server['path'], 0)) { |
|
| 88 | 88 | $this->fallback = true; |
| 89 | - }else if (!empty($server[ 'host' ]) && !$this->instance->addServer($server[ 'host' ], $server[ 'port' ])) { |
|
| 89 | + } else if (!empty($server['host']) && !$this->instance->addServer($server['host'], $server['port'])) { |
|
| 90 | 90 | $this->fallback = true; |
| 91 | 91 | } |
| 92 | 92 | |
| 93 | - if (!empty($server[ 'saslUser' ]) && !empty($server[ 'saslPassword' ])) { |
|
| 94 | - $this->instance->setSaslAuthData($server[ 'saslUser' ], $server[ 'saslPassword' ]); |
|
| 93 | + if (!empty($server['saslUser']) && !empty($server['saslPassword'])) { |
|
| 94 | + $this->instance->setSaslAuthData($server['saslUser'], $server['saslPassword']); |
|
| 95 | 95 | } |
| 96 | 96 | |
| 97 | 97 | } catch (\Exception $e) { |
@@ -104,7 +104,7 @@ discard block |
||
| 104 | 104 | * any error if not connected ... |
| 105 | 105 | */ |
| 106 | 106 | $version = $this->instance->getVersion(); |
| 107 | - if(!$version || $this->instance->getResultCode() !== MemcachedSoftware::RES_SUCCESS){ |
|
| 107 | + if (!$version || $this->instance->getResultCode() !== MemcachedSoftware::RES_SUCCESS) { |
|
| 108 | 108 | throw new phpFastCacheDriverException('Memcached seems to not be connected'); |
| 109 | 109 | } |
| 110 | 110 | return true; |
@@ -187,16 +187,16 @@ discard block |
||
| 187 | 187 | public function getStats(): DriverStatistic |
| 188 | 188 | { |
| 189 | 189 | $stats = current($this->instance->getStats()); |
| 190 | - $stats[ 'uptime' ] = (isset($stats[ 'uptime' ]) ? $stats[ 'uptime' ] : 0); |
|
| 191 | - $stats[ 'version' ] = (isset($stats[ 'version' ]) ? $stats[ 'version' ] : $this->instance->getVersion()); |
|
| 192 | - $stats[ 'bytes' ] = (isset($stats[ 'bytes' ]) ? $stats[ 'version' ] : 0); |
|
| 190 | + $stats['uptime'] = (isset($stats['uptime']) ? $stats['uptime'] : 0); |
|
| 191 | + $stats['version'] = (isset($stats['version']) ? $stats['version'] : $this->instance->getVersion()); |
|
| 192 | + $stats['bytes'] = (isset($stats['bytes']) ? $stats['version'] : 0); |
|
| 193 | 193 | |
| 194 | - $date = (new \DateTime())->setTimestamp(time() - $stats[ 'uptime' ]); |
|
| 194 | + $date = (new \DateTime())->setTimestamp(time() - $stats['uptime']); |
|
| 195 | 195 | |
| 196 | 196 | return (new DriverStatistic()) |
| 197 | 197 | ->setData(\implode(', ', \array_keys($this->itemInstances))) |
| 198 | - ->setInfo(\sprintf("The memcache daemon v%s is up since %s.\n For more information see RawData.", $stats[ 'version' ], $date->format(DATE_RFC2822))) |
|
| 198 | + ->setInfo(\sprintf("The memcache daemon v%s is up since %s.\n For more information see RawData.", $stats['version'], $date->format(DATE_RFC2822))) |
|
| 199 | 199 | ->setRawData($stats) |
| 200 | - ->setSize((int)$stats[ 'bytes' ]); |
|
| 200 | + ->setSize((int) $stats['bytes']); |
|
| 201 | 201 | } |
| 202 | 202 | } |
| 203 | 203 | \ No newline at end of file |
@@ -152,7 +152,7 @@ |
||
| 152 | 152 | */ |
| 153 | 153 | if(!empty($server[ 'path' ]) && !$this->instance->addServer($server[ 'path' ], 0)){ |
| 154 | 154 | $this->fallback = true; |
| 155 | - }else if (!empty($server[ 'host' ]) && !$this->instance->addServer($server[ 'host' ], $server[ 'port' ])) { |
|
| 155 | + } else if (!empty($server[ 'host' ]) && !$this->instance->addServer($server[ 'host' ], $server[ 'port' ])) { |
|
| 156 | 156 | $this->fallback = true; |
| 157 | 157 | } |
| 158 | 158 | |
@@ -20,7 +20,7 @@ discard block |
||
| 20 | 20 | use Phpfastcache\Core\Pool\{DriverBaseTrait, ExtendedCacheItemPoolInterface}; |
| 21 | 21 | use Phpfastcache\Entities\DriverStatistic; |
| 22 | 22 | use Phpfastcache\Exceptions\{ |
| 23 | - phpFastCacheInvalidArgumentException, phpFastCacheDriverException |
|
| 23 | + phpFastCacheInvalidArgumentException, phpFastCacheDriverException |
|
| 24 | 24 | }; |
| 25 | 25 | use Phpfastcache\Util\{ArrayObject, MemcacheDriverCollisionDetectorTrait}; |
| 26 | 26 | use Psr\Cache\CacheItemInterface; |
@@ -73,13 +73,13 @@ discard block |
||
| 73 | 73 | $servers = (!empty($this->config->getOption('servers')) && \is_array($this->config->getOption('servers')) ? $this->config->getOption('servers') : []); |
| 74 | 74 | if (\count($servers) < 1) { |
| 75 | 75 | $servers = [ |
| 76 | - [ |
|
| 76 | + [ |
|
| 77 | 77 | 'host' => !empty($this->config->getOption('host')) ? $this->config->getOption('host') : '127.0.0.1', |
| 78 | 78 | 'path' => !empty($this->config->getOption('path')) ? $this->config->getOption('path') : false, |
| 79 | 79 | 'port' => !empty($this->config->getOption('port')) ? $this->config->getOption('port') : 11211, |
| 80 | 80 | 'saslUser' => !empty($this->config->getOption('saslUser')) ? $this->config->getOption('saslUser') : false, |
| 81 | 81 | 'saslPassword' =>!empty($this->config->getOption('saslPassword')) ? $this->config->getOption('saslPassword'): false, |
| 82 | - ], |
|
| 82 | + ], |
|
| 83 | 83 | ]; |
| 84 | 84 | } |
| 85 | 85 | |
@@ -196,9 +196,9 @@ discard block |
||
| 196 | 196 | $date = (new \DateTime())->setTimestamp(time() - $stats[ 'uptime' ]); |
| 197 | 197 | |
| 198 | 198 | return (new DriverStatistic()) |
| 199 | - ->setData(\implode(', ', \array_keys($this->itemInstances))) |
|
| 200 | - ->setInfo(\sprintf("The memcache daemon v%s is up since %s.\n For more information see RawData.", $stats[ 'version' ], $date->format(DATE_RFC2822))) |
|
| 201 | - ->setRawData($stats) |
|
| 202 | - ->setSize((int)$stats[ 'bytes' ]); |
|
| 199 | + ->setData(\implode(', ', \array_keys($this->itemInstances))) |
|
| 200 | + ->setInfo(\sprintf("The memcache daemon v%s is up since %s.\n For more information see RawData.", $stats[ 'version' ], $date->format(DATE_RFC2822))) |
|
| 201 | + ->setRawData($stats) |
|
| 202 | + ->setSize((int)$stats[ 'bytes' ]); |
|
| 203 | 203 | } |
| 204 | 204 | } |
| 205 | 205 | \ No newline at end of file |
@@ -19,7 +19,7 @@ |
||
| 19 | 19 | use Phpfastcache\Core\Pool\ExtendedCacheItemPoolInterface; |
| 20 | 20 | use Phpfastcache\Drivers\Mongodb\Driver as MongodbDriver; |
| 21 | 21 | use Phpfastcache\Exceptions\{ |
| 22 | - phpFastCacheInvalidArgumentException, phpFastCacheInvalidArgumentTypeException |
|
| 22 | + phpFastCacheInvalidArgumentException, phpFastCacheInvalidArgumentTypeException |
|
| 23 | 23 | }; |
| 24 | 24 | |
| 25 | 25 | /** |
@@ -11,7 +11,7 @@ |
||
| 11 | 11 | * @author Georges.L (Geolim4) <[email protected]> |
| 12 | 12 | * |
| 13 | 13 | */ |
| 14 | -declare(strict_types=1); |
|
| 14 | +declare(strict_types = 1); |
|
| 15 | 15 | |
| 16 | 16 | namespace Phpfastcache\Drivers\Mongodb; |
| 17 | 17 | |
@@ -18,14 +18,14 @@ discard block |
||
| 18 | 18 | |
| 19 | 19 | use LogicException; |
| 20 | 20 | use MongoDB\{ |
| 21 | - BSON\Binary, BSON\UTCDateTime, Collection, DeleteResult, Driver\Command, Driver\Exception\Exception as MongoDBException, Driver\Manager as MongodbManager |
|
| 21 | + BSON\Binary, BSON\UTCDateTime, Collection, DeleteResult, Driver\Command, Driver\Exception\Exception as MongoDBException, Driver\Manager as MongodbManager |
|
| 22 | 22 | }; |
| 23 | 23 | use Phpfastcache\Core\Pool\{ |
| 24 | - DriverBaseTrait, ExtendedCacheItemPoolInterface |
|
| 24 | + DriverBaseTrait, ExtendedCacheItemPoolInterface |
|
| 25 | 25 | }; |
| 26 | 26 | use Phpfastcache\Entities\DriverStatistic; |
| 27 | 27 | use Phpfastcache\Exceptions\{ |
| 28 | - phpFastCacheDriverException, phpFastCacheInvalidArgumentException |
|
| 28 | + phpFastCacheDriverException, phpFastCacheInvalidArgumentException |
|
| 29 | 29 | }; |
| 30 | 30 | use Phpfastcache\Util\ArrayObject; |
| 31 | 31 | use Psr\Cache\CacheItemInterface; |
@@ -71,16 +71,16 @@ discard block |
||
| 71 | 71 | |
| 72 | 72 | if ($document) { |
| 73 | 73 | $return = [ |
| 74 | - self::DRIVER_DATA_WRAPPER_INDEX => $this->decode($document[ self::DRIVER_DATA_WRAPPER_INDEX ]->getData()), |
|
| 75 | - self::DRIVER_TAGS_WRAPPER_INDEX => $this->decode($document[ self::DRIVER_TAGS_WRAPPER_INDEX ]->getData()), |
|
| 76 | - self::DRIVER_EDATE_WRAPPER_INDEX => (new \DateTime())->setTimestamp($document[ self::DRIVER_EDATE_WRAPPER_INDEX ]->toDateTime()->getTimestamp()), |
|
| 74 | + self::DRIVER_DATA_WRAPPER_INDEX => $this->decode($document[ self::DRIVER_DATA_WRAPPER_INDEX ]->getData()), |
|
| 75 | + self::DRIVER_TAGS_WRAPPER_INDEX => $this->decode($document[ self::DRIVER_TAGS_WRAPPER_INDEX ]->getData()), |
|
| 76 | + self::DRIVER_EDATE_WRAPPER_INDEX => (new \DateTime())->setTimestamp($document[ self::DRIVER_EDATE_WRAPPER_INDEX ]->toDateTime()->getTimestamp()), |
|
| 77 | 77 | ]; |
| 78 | 78 | |
| 79 | 79 | if(!empty($this->getConfigOption('itemDetailedDate'))){ |
| 80 | 80 | $return += [ |
| 81 | - self::DRIVER_MDATE_WRAPPER_INDEX => (new \DateTime())->setTimestamp($document[ self::DRIVER_MDATE_WRAPPER_INDEX ]->toDateTime() |
|
| 81 | + self::DRIVER_MDATE_WRAPPER_INDEX => (new \DateTime())->setTimestamp($document[ self::DRIVER_MDATE_WRAPPER_INDEX ]->toDateTime() |
|
| 82 | 82 | ->getTimestamp()), |
| 83 | - self::DRIVER_CDATE_WRAPPER_INDEX => (new \DateTime())->setTimestamp($document[ self::DRIVER_CDATE_WRAPPER_INDEX ]->toDateTime() |
|
| 83 | + self::DRIVER_CDATE_WRAPPER_INDEX => (new \DateTime())->setTimestamp($document[ self::DRIVER_CDATE_WRAPPER_INDEX ]->toDateTime() |
|
| 84 | 84 | ->getTimestamp()), |
| 85 | 85 | ]; |
| 86 | 86 | } |
@@ -105,23 +105,23 @@ discard block |
||
| 105 | 105 | if ($item instanceof Item) { |
| 106 | 106 | try { |
| 107 | 107 | $set = [ |
| 108 | - self::DRIVER_DATA_WRAPPER_INDEX => new Binary($this->encode($item->get()), Binary::TYPE_GENERIC), |
|
| 109 | - self::DRIVER_TAGS_WRAPPER_INDEX => new Binary($this->encode($item->getTags()), Binary::TYPE_GENERIC), |
|
| 110 | - self::DRIVER_EDATE_WRAPPER_INDEX => ($item->getTtl() > 0 ? new UTCDateTime((time() + $item->getTtl()) * 1000) : new UTCDateTime(time() * 1000)), |
|
| 108 | + self::DRIVER_DATA_WRAPPER_INDEX => new Binary($this->encode($item->get()), Binary::TYPE_GENERIC), |
|
| 109 | + self::DRIVER_TAGS_WRAPPER_INDEX => new Binary($this->encode($item->getTags()), Binary::TYPE_GENERIC), |
|
| 110 | + self::DRIVER_EDATE_WRAPPER_INDEX => ($item->getTtl() > 0 ? new UTCDateTime((time() + $item->getTtl()) * 1000) : new UTCDateTime(time() * 1000)), |
|
| 111 | 111 | ]; |
| 112 | 112 | |
| 113 | 113 | if(!empty($this->getConfigOption('itemDetailedDate'))){ |
| 114 | 114 | $set += [ |
| 115 | - self::DRIVER_MDATE_WRAPPER_INDEX => ($item->getModificationDate() ? new UTCDateTime(($item->getModificationDate()->getTimestamp()) * 1000) : new UTCDateTime(time() * 1000)), |
|
| 116 | - self::DRIVER_CDATE_WRAPPER_INDEX => ($item->getCreationDate() ? new UTCDateTime(($item->getCreationDate()->getTimestamp()) * 1000) : new UTCDateTime(time() * 1000)), |
|
| 115 | + self::DRIVER_MDATE_WRAPPER_INDEX => ($item->getModificationDate() ? new UTCDateTime(($item->getModificationDate()->getTimestamp()) * 1000) : new UTCDateTime(time() * 1000)), |
|
| 116 | + self::DRIVER_CDATE_WRAPPER_INDEX => ($item->getCreationDate() ? new UTCDateTime(($item->getCreationDate()->getTimestamp()) * 1000) : new UTCDateTime(time() * 1000)), |
|
| 117 | 117 | ]; |
| 118 | 118 | } |
| 119 | 119 | $result = (array)$this->getCollection()->updateOne( |
| 120 | - ['_id' => $item->getEncodedKey()], |
|
| 121 | - [ |
|
| 120 | + ['_id' => $item->getEncodedKey()], |
|
| 121 | + [ |
|
| 122 | 122 | '$set' => $set, |
| 123 | - ], |
|
| 124 | - ['upsert' => true, 'multiple' => false] |
|
| 123 | + ], |
|
| 124 | + ['upsert' => true, 'multiple' => false] |
|
| 125 | 125 | ); |
| 126 | 126 | } catch (MongoDBException $e) { |
| 127 | 127 | throw new phpFastCacheDriverException('Got an exception while trying to write data to MongoDB server', null, $e); |
@@ -191,10 +191,10 @@ discard block |
||
| 191 | 191 | * @todo make an url builder |
| 192 | 192 | */ |
| 193 | 193 | $this->instance = $this->instance ?: (new MongodbManager('mongodb://' . |
| 194 | - ($clientConfig[ 'username' ] ?: '') . |
|
| 195 | - ($clientConfig[ 'password' ] ? ":{$clientConfig['password']}" : '') . |
|
| 196 | - ($clientConfig[ 'username' ] ? '@' : '') . "{$clientConfig['host']}" . |
|
| 197 | - ($clientConfig[ 'port' ] != 27017 ? ":{$clientConfig['port']}" : ''), ['connectTimeoutMS' => $clientConfig[ 'timeout' ] * 1000])); |
|
| 194 | + ($clientConfig[ 'username' ] ?: '') . |
|
| 195 | + ($clientConfig[ 'password' ] ? ":{$clientConfig['password']}" : '') . |
|
| 196 | + ($clientConfig[ 'username' ] ? '@' : '') . "{$clientConfig['host']}" . |
|
| 197 | + ($clientConfig[ 'port' ] != 27017 ? ":{$clientConfig['port']}" : ''), ['connectTimeoutMS' => $clientConfig[ 'timeout' ] * 1000])); |
|
| 198 | 198 | $this->collection = $this->collection ?: new Collection($this->instance, $clientConfig[ 'databaseName' ], $clientConfig[ 'collectionName' ]); |
| 199 | 199 | |
| 200 | 200 | return true; |
@@ -221,15 +221,15 @@ discard block |
||
| 221 | 221 | public function getStats(): DriverStatistic |
| 222 | 222 | { |
| 223 | 223 | $serverStats = $this->instance->executeCommand($this->getConfigOption('databaseName'), new Command([ |
| 224 | - 'serverStatus' => 1, |
|
| 225 | - 'recordStats' => 0, |
|
| 226 | - 'repl' => 0, |
|
| 227 | - 'metrics' => 0, |
|
| 224 | + 'serverStatus' => 1, |
|
| 225 | + 'recordStats' => 0, |
|
| 226 | + 'repl' => 0, |
|
| 227 | + 'metrics' => 0, |
|
| 228 | 228 | ]))->toArray()[ 0 ]; |
| 229 | 229 | |
| 230 | 230 | $collectionStats = $this->instance->executeCommand($this->getConfigOption('databaseName'), new Command([ |
| 231 | - 'collStats' => ($this->config->getOption('collectionName') !== null ? $this->config->getOption('collectionName') : 'Cache'), |
|
| 232 | - 'verbose' => true, |
|
| 231 | + 'collStats' => ($this->config->getOption('collectionName') !== null ? $this->config->getOption('collectionName') : 'Cache'), |
|
| 232 | + 'verbose' => true, |
|
| 233 | 233 | ]))->toArray()[ 0 ]; |
| 234 | 234 | |
| 235 | 235 | $array_filter_recursive = function ($array, callable $callback = null) use (&$array_filter_recursive) { |
@@ -258,14 +258,14 @@ discard block |
||
| 258 | 258 | $collectionStats = $array_filter_recursive($collectionStats, $callback); |
| 259 | 259 | |
| 260 | 260 | $stats = (new DriverStatistic()) |
| 261 | - ->setInfo('MongoDB version ' . $serverStats->version . ', Uptime (in days): ' . round($serverStats->uptime / 86400, |
|
| 262 | - 1) . "\n For more information see RawData.") |
|
| 263 | - ->setSize($collectionStats->size) |
|
| 264 | - ->setData(\implode(', ', \array_keys($this->itemInstances))) |
|
| 265 | - ->setRawData([ |
|
| 261 | + ->setInfo('MongoDB version ' . $serverStats->version . ', Uptime (in days): ' . round($serverStats->uptime / 86400, |
|
| 262 | + 1) . "\n For more information see RawData.") |
|
| 263 | + ->setSize($collectionStats->size) |
|
| 264 | + ->setData(\implode(', ', \array_keys($this->itemInstances))) |
|
| 265 | + ->setRawData([ |
|
| 266 | 266 | 'serverStatus' => $serverStats, |
| 267 | 267 | 'collStats' => $collectionStats, |
| 268 | - ]); |
|
| 268 | + ]); |
|
| 269 | 269 | |
| 270 | 270 | return $stats; |
| 271 | 271 | } |
@@ -12,7 +12,7 @@ discard block |
||
| 12 | 12 | * @author Fabio Covolo Mazzo (fabiocmazzo) <[email protected]> |
| 13 | 13 | * |
| 14 | 14 | */ |
| 15 | -declare(strict_types=1); |
|
| 15 | +declare(strict_types = 1); |
|
| 16 | 16 | |
| 17 | 17 | namespace Phpfastcache\Drivers\Mongodb; |
| 18 | 18 | |
@@ -71,16 +71,16 @@ discard block |
||
| 71 | 71 | |
| 72 | 72 | if ($document) { |
| 73 | 73 | $return = [ |
| 74 | - self::DRIVER_DATA_WRAPPER_INDEX => $this->decode($document[ self::DRIVER_DATA_WRAPPER_INDEX ]->getData()), |
|
| 75 | - self::DRIVER_TAGS_WRAPPER_INDEX => $this->decode($document[ self::DRIVER_TAGS_WRAPPER_INDEX ]->getData()), |
|
| 76 | - self::DRIVER_EDATE_WRAPPER_INDEX => (new \DateTime())->setTimestamp($document[ self::DRIVER_EDATE_WRAPPER_INDEX ]->toDateTime()->getTimestamp()), |
|
| 74 | + self::DRIVER_DATA_WRAPPER_INDEX => $this->decode($document[self::DRIVER_DATA_WRAPPER_INDEX]->getData()), |
|
| 75 | + self::DRIVER_TAGS_WRAPPER_INDEX => $this->decode($document[self::DRIVER_TAGS_WRAPPER_INDEX]->getData()), |
|
| 76 | + self::DRIVER_EDATE_WRAPPER_INDEX => (new \DateTime())->setTimestamp($document[self::DRIVER_EDATE_WRAPPER_INDEX]->toDateTime()->getTimestamp()), |
|
| 77 | 77 | ]; |
| 78 | 78 | |
| 79 | - if(!empty($this->getConfigOption('itemDetailedDate'))){ |
|
| 79 | + if (!empty($this->getConfigOption('itemDetailedDate'))) { |
|
| 80 | 80 | $return += [ |
| 81 | - self::DRIVER_MDATE_WRAPPER_INDEX => (new \DateTime())->setTimestamp($document[ self::DRIVER_MDATE_WRAPPER_INDEX ]->toDateTime() |
|
| 81 | + self::DRIVER_MDATE_WRAPPER_INDEX => (new \DateTime())->setTimestamp($document[self::DRIVER_MDATE_WRAPPER_INDEX]->toDateTime() |
|
| 82 | 82 | ->getTimestamp()), |
| 83 | - self::DRIVER_CDATE_WRAPPER_INDEX => (new \DateTime())->setTimestamp($document[ self::DRIVER_CDATE_WRAPPER_INDEX ]->toDateTime() |
|
| 83 | + self::DRIVER_CDATE_WRAPPER_INDEX => (new \DateTime())->setTimestamp($document[self::DRIVER_CDATE_WRAPPER_INDEX]->toDateTime() |
|
| 84 | 84 | ->getTimestamp()), |
| 85 | 85 | ]; |
| 86 | 86 | } |
@@ -110,13 +110,13 @@ discard block |
||
| 110 | 110 | self::DRIVER_EDATE_WRAPPER_INDEX => ($item->getTtl() > 0 ? new UTCDateTime((time() + $item->getTtl()) * 1000) : new UTCDateTime(time() * 1000)), |
| 111 | 111 | ]; |
| 112 | 112 | |
| 113 | - if(!empty($this->getConfigOption('itemDetailedDate'))){ |
|
| 113 | + if (!empty($this->getConfigOption('itemDetailedDate'))) { |
|
| 114 | 114 | $set += [ |
| 115 | 115 | self::DRIVER_MDATE_WRAPPER_INDEX => ($item->getModificationDate() ? new UTCDateTime(($item->getModificationDate()->getTimestamp()) * 1000) : new UTCDateTime(time() * 1000)), |
| 116 | 116 | self::DRIVER_CDATE_WRAPPER_INDEX => ($item->getCreationDate() ? new UTCDateTime(($item->getCreationDate()->getTimestamp()) * 1000) : new UTCDateTime(time() * 1000)), |
| 117 | 117 | ]; |
| 118 | 118 | } |
| 119 | - $result = (array)$this->getCollection()->updateOne( |
|
| 119 | + $result = (array) $this->getCollection()->updateOne( |
|
| 120 | 120 | ['_id' => $item->getEncodedKey()], |
| 121 | 121 | [ |
| 122 | 122 | '$set' => $set, |
@@ -127,7 +127,7 @@ discard block |
||
| 127 | 127 | throw new phpFastCacheDriverException('Got an exception while trying to write data to MongoDB server', null, $e); |
| 128 | 128 | } |
| 129 | 129 | |
| 130 | - return isset($result[ 'ok' ]) ? $result[ 'ok' ] == 1 : true; |
|
| 130 | + return isset($result['ok']) ? $result['ok'] == 1 : true; |
|
| 131 | 131 | } |
| 132 | 132 | |
| 133 | 133 | throw new phpFastCacheInvalidArgumentException('Cross-Driver type confusion detected'); |
@@ -171,7 +171,7 @@ discard block |
||
| 171 | 171 | */ |
| 172 | 172 | $this->save($this->getItem('__PFC_CACHE_CLEARED__')->set(true)); |
| 173 | 173 | |
| 174 | - return !empty($result[ 'ok' ]); |
|
| 174 | + return !empty($result['ok']); |
|
| 175 | 175 | } |
| 176 | 176 | |
| 177 | 177 | /** |
@@ -191,11 +191,11 @@ discard block |
||
| 191 | 191 | * @todo make an url builder |
| 192 | 192 | */ |
| 193 | 193 | $this->instance = $this->instance ?: (new MongodbManager('mongodb://' . |
| 194 | - ($clientConfig[ 'username' ] ?: '') . |
|
| 195 | - ($clientConfig[ 'password' ] ? ":{$clientConfig['password']}" : '') . |
|
| 196 | - ($clientConfig[ 'username' ] ? '@' : '') . "{$clientConfig['host']}" . |
|
| 197 | - ($clientConfig[ 'port' ] != 27017 ? ":{$clientConfig['port']}" : ''), ['connectTimeoutMS' => $clientConfig[ 'timeout' ] * 1000])); |
|
| 198 | - $this->collection = $this->collection ?: new Collection($this->instance, $clientConfig[ 'databaseName' ], $clientConfig[ 'collectionName' ]); |
|
| 194 | + ($clientConfig['username'] ?: '') . |
|
| 195 | + ($clientConfig['password'] ? ":{$clientConfig['password']}" : '') . |
|
| 196 | + ($clientConfig['username'] ? '@' : '') . "{$clientConfig['host']}" . |
|
| 197 | + ($clientConfig['port'] != 27017 ? ":{$clientConfig['port']}" : ''), ['connectTimeoutMS' => $clientConfig['timeout'] * 1000])); |
|
| 198 | + $this->collection = $this->collection ?: new Collection($this->instance, $clientConfig['databaseName'], $clientConfig['collectionName']); |
|
| 199 | 199 | |
| 200 | 200 | return true; |
| 201 | 201 | } |
@@ -225,14 +225,14 @@ discard block |
||
| 225 | 225 | 'recordStats' => 0, |
| 226 | 226 | 'repl' => 0, |
| 227 | 227 | 'metrics' => 0, |
| 228 | - ]))->toArray()[ 0 ]; |
|
| 228 | + ]))->toArray()[0]; |
|
| 229 | 229 | |
| 230 | 230 | $collectionStats = $this->instance->executeCommand($this->getConfigOption('databaseName'), new Command([ |
| 231 | 231 | 'collStats' => ($this->config->getOption('collectionName') !== null ? $this->config->getOption('collectionName') : 'Cache'), |
| 232 | 232 | 'verbose' => true, |
| 233 | - ]))->toArray()[ 0 ]; |
|
| 233 | + ]))->toArray()[0]; |
|
| 234 | 234 | |
| 235 | - $array_filter_recursive = function ($array, callable $callback = null) use (&$array_filter_recursive) { |
|
| 235 | + $array_filter_recursive = function($array, callable $callback = null) use (&$array_filter_recursive) { |
|
| 236 | 236 | $array = $callback($array); |
| 237 | 237 | |
| 238 | 238 | if (\is_object($array) || \is_array($array)) { |
@@ -244,12 +244,12 @@ discard block |
||
| 244 | 244 | return $array; |
| 245 | 245 | }; |
| 246 | 246 | |
| 247 | - $callback = function ($item) { |
|
| 247 | + $callback = function($item) { |
|
| 248 | 248 | /** |
| 249 | 249 | * Remove unserializable properties |
| 250 | 250 | */ |
| 251 | 251 | if ($item instanceof \MongoDB\BSON\UTCDateTime) { |
| 252 | - return (string)$item; |
|
| 252 | + return (string) $item; |
|
| 253 | 253 | } |
| 254 | 254 | return $item; |
| 255 | 255 | }; |