grommunio / grommunio-web

plugins/files/php/vendor/phpfastcache/phpfastcache/lib/Phpfastcache/Drivers/Zendshm/Driver.php

Indentation +81 added lines, -81 removed lines

@@ -29,89 +29,89 @@
  */
 class Driver implements AggregatablePoolInterface
 {
-    use TaggableCacheItemPoolTrait;
-
-    /**
-     * @return bool
-     */
-    public function driverCheck(): bool
-    {
-        return extension_loaded('Zend Data Cache') && function_exists('zend_shm_cache_store');
-    }
-
-    /**
-     * @return string
-     */
-    public function getHelp(): string
-    {
-        return <<<HELP
+	use TaggableCacheItemPoolTrait;
+
+	/**
+	 * @return bool
+	 */
+	public function driverCheck(): bool
+	{
+		return extension_loaded('Zend Data Cache') && function_exists('zend_shm_cache_store');
+	}
+
+	/**
+	 * @return string
+	 */
+	public function getHelp(): string
+	{
+		return <<<HELP
 <p>
 This driver rely on Zend Server 8.5+, see: https://www.zend.com/products/zend-server
 </p>
 HELP;
-    }
-
-    /**
-     * @return DriverStatistic
-     */
-    public function getStats(): DriverStatistic
-    {
-        $stats = (array)zend_shm_cache_info();
-        return (new DriverStatistic())
-            ->setData(implode(', ', array_keys($this->itemInstances)))
-            ->setInfo(sprintf("The Zend memory have %d item(s) in cache.\n For more information see RawData.", $stats['items_total']))
-            ->setRawData($stats)
-            ->setSize($stats['memory_total']);
-    }
-
-    /**
-     * @return bool
-     */
-    protected function driverConnect(): bool
-    {
-        return true;
-    }
-
-    /**
-     * @param ExtendedCacheItemInterface $item
-     * @return ?array<string, mixed>
-     */
-    protected function driverRead(ExtendedCacheItemInterface $item): ?array
-    {
-        $data = zend_shm_cache_fetch($item->getKey());
-
-        if (empty($data) || !\is_array($data)) {
-            return null;
-        }
-
-        return $data;
-    }
-
-    /**
-     * @param ExtendedCacheItemInterface $item
-     * @return mixed
-     * @throws PhpfastcacheInvalidArgumentException
-     */
-    protected function driverWrite(ExtendedCacheItemInterface $item): bool
-    {
-
-        $ttl = $item->getExpirationDate()->getTimestamp() - time();
-
-        return zend_shm_cache_store($item->getKey(), $this->driverPreWrap($item), ($ttl > 0 ? $ttl : 0));
-    }
-
-    /**
-     * @param string $key
-     * @param string $encodedKey
-     * @return bool
-     */
-    protected function driverDelete(string $key, string $encodedKey): bool
-    {
-        return (bool)zend_shm_cache_delete($key);
-    }
-
-    protected function driverClear(): bool
-    {
-        return @zend_shm_cache_clear();
-    }
+	}
+
+	/**
+	 * @return DriverStatistic
+	 */
+	public function getStats(): DriverStatistic
+	{
+		$stats = (array)zend_shm_cache_info();
+		return (new DriverStatistic())
+			->setData(implode(', ', array_keys($this->itemInstances)))
+			->setInfo(sprintf("The Zend memory have %d item(s) in cache.\n For more information see RawData.", $stats['items_total']))
+			->setRawData($stats)
+			->setSize($stats['memory_total']);
+	}
+
+	/**
+	 * @return bool
+	 */
+	protected function driverConnect(): bool
+	{
+		return true;
+	}
+
+	/**
+	 * @param ExtendedCacheItemInterface $item
+	 * @return ?array<string, mixed>
+	 */
+	protected function driverRead(ExtendedCacheItemInterface $item): ?array
+	{
+		$data = zend_shm_cache_fetch($item->getKey());
+
+		if (empty($data) || !\is_array($data)) {
+			return null;
+		}
+
+		return $data;
+	}
+
+	/**
+	 * @param ExtendedCacheItemInterface $item
+	 * @return mixed
+	 * @throws PhpfastcacheInvalidArgumentException
+	 */
+	protected function driverWrite(ExtendedCacheItemInterface $item): bool
+	{
+
+		$ttl = $item->getExpirationDate()->getTimestamp() - time();
+
+		return zend_shm_cache_store($item->getKey(), $this->driverPreWrap($item), ($ttl > 0 ? $ttl : 0));
+	}
+
+	/**
+	 * @param string $key
+	 * @param string $encodedKey
+	 * @return bool
+	 */
+	protected function driverDelete(string $key, string $encodedKey): bool
+	{
+		return (bool)zend_shm_cache_delete($key);
+	}
+
+	protected function driverClear(): bool
+	{
+		return @zend_shm_cache_clear();
+	}
 }

Spacing +2 added lines, -2 removed lines

@@ -56,7 +56,7 @@ 
      */
     public function getStats(): DriverStatistic
     {
-        $stats = (array)zend_shm_cache_info();
+        $stats = (array) zend_shm_cache_info();
         return (new DriverStatistic())
             ->setData(implode(', ', array_keys($this->itemInstances)))
             ->setInfo(sprintf("The Zend memory have %d item(s) in cache.\n For more information see RawData.", $stats['items_total']))
@@ -107,7 +107,7 @@ 
      */
     protected function driverDelete(string $key, string $encodedKey): bool
     {
-        return (bool)zend_shm_cache_delete($key);
+        return (bool) zend_shm_cache_delete($key);
     }
 
     protected function driverClear(): bool

plugins/files/php/vendor/phpfastcache/phpfastcache/lib/Phpfastcache/Drivers/Predis/Driver.php

Indentation +192 added lines, -192 removed lines

@@ -35,201 +35,201 @@
  */
 class Driver implements AggregatablePoolInterface
 {
-    use TaggableCacheItemPoolTrait;
-
-    /**
-     * @return bool
-     */
-    public function driverCheck(): bool
-    {
-        if (extension_loaded('Redis')) {
-            trigger_error('The native Redis extension is installed, you should use Redis instead of Predis to increase performances', E_USER_NOTICE);
-        }
-
-        return class_exists(\Predis\Client::class);
-    }
-
-    /**
-     * @return string
-     */
-    public function getHelp(): string
-    {
-        return <<<HELP
+	use TaggableCacheItemPoolTrait;
+
+	/**
+	 * @return bool
+	 */
+	public function driverCheck(): bool
+	{
+		if (extension_loaded('Redis')) {
+			trigger_error('The native Redis extension is installed, you should use Redis instead of Predis to increase performances', E_USER_NOTICE);
+		}
+
+		return class_exists(\Predis\Client::class);
+	}
+
+	/**
+	 * @return string
+	 */
+	public function getHelp(): string
+	{
+		return <<<HELP
 <p>
 To install the Predis library via Composer:
 <code>composer require "predis/predis" "~1.1.0"</code>
 </p>
 HELP;
-    }
-
-    /**
-     * @return DriverStatistic
-     */
-    public function getStats(): DriverStatistic
-    {
-        $info = $this->instance->info();
-        $size = ($info['Memory']['used_memory'] ?? 0);
-        $version = ($info['Server']['redis_version'] ?? 0);
-        $date = (isset($info['Server']['uptime_in_seconds']) ? (new DateTime())->setTimestamp(time() - $info['Server']['uptime_in_seconds']) : 'unknown date');
-
-        return (new DriverStatistic())
-            ->setData(implode(', ', array_keys($this->itemInstances)))
-            ->setRawData($info)
-            ->setSize((int)$size)
-            ->setInfo(
-                sprintf(
-                    "The Redis daemon v%s (with Predis v%s) is up since %s.\n For more information see RawData. \n Driver size includes the memory allocation size.",
-                    $version,
-                    PredisClient::VERSION,
-                    $date->format(DATE_RFC2822)
-                )
-            );
-    }
-
-    /**
-     * @return bool
-     * @throws PhpfastcacheDriverException
-     * @throws PhpfastcacheLogicException
-     */
-    protected function driverConnect(): bool
-    {
-        /**
-         * In case of a user-provided
-         * Predis client just return here
-         */
-        if ($this->getConfig()->getPredisClient() instanceof PredisClient) {
-            $this->instance = $this->getConfig()->getPredisClient();
-            if (!$this->instance->isConnected()) {
-                $this->instance->connect();
-            }
-            return true;
-        }
-
-        $options = [];
-
-        if ($this->getConfig()->getOptPrefix()) {
-            $options['prefix'] = $this->getConfig()->getOptPrefix();
-        }
-
-        if (!empty($this->getConfig()->getPath())) {
-            $this->instance = new PredisClient(
-                [
-                    'scheme' => $this->getConfig()->getScheme(),
-                    'persistent' => $this->getConfig()->isPersistent(),
-                    'timeout' => $this->getConfig()->getTimeout(),
-                    'path' => $this->getConfig()->getPath(),
-                ],
-                $options
-            );
-        } else {
-            $this->instance = new PredisClient($this->getConfig()->getPredisConfigArray(), $options);
-        }
-
-        try {
-            $this->instance->connect();
-        } catch (PredisConnectionException $e) {
-            throw new PhpfastcacheDriverException(
-                'Failed to connect to predis server. Check the Predis documentation: https://github.com/nrk/predis/tree/v1.1#how-to-install-and-use-predis',
-                0,
-                $e
-            );
-        }
-
-        return true;
-    }
-
-    /**
-     * @param ExtendedCacheItemInterface $item
-     * @return ?array<string, mixed>
-     */
-    protected function driverRead(ExtendedCacheItemInterface $item): ?array
-    {
-        $val = $this->instance->get($item->getKey());
-
-        if ($val === null) {
-            return null;
-        }
-
-        return $this->decode($val);
-    }
-
-
-    /**
-     * @param ExtendedCacheItemInterface ...$items
-     * @return array<array<string, mixed>>
-     * @throws \Phpfastcache\Exceptions\PhpfastcacheDriverException
-     * @throws \RedisException
-     */
-    protected function driverReadMultiple(ExtendedCacheItemInterface ...$items): array
-    {
-        $keys = $this->getKeys($items);
-
-        return array_combine($keys, array_map(
-            fn($val) => $val ? $this->decode($val) : null,
-            $this->instance->mget($keys)
-        ));
-    }
-
-    /**
-     * @return array<int, string>
-     * @throws \RedisException
-     */
-    protected function driverReadAllKeys(string $pattern = '*'): iterable
-    {
-        $keys = [];
-        foreach (new PredisIterator\Keyspace($this->instance, $pattern, ExtendedCacheItemPoolInterface::MAX_ALL_KEYS_COUNT) as $key) {
-            $keys[] = $key;
-        }
-        return $keys;
-    }
-
-
-    /**
-     * @param ExtendedCacheItemInterface $item
-     * @return mixed
-     * @throws PhpfastcacheInvalidArgumentException
-     * @throws PhpfastcacheLogicException
-     */
-    protected function driverWrite(ExtendedCacheItemInterface $item): bool
-    {
-
-        $ttl = $item->getExpirationDate()->getTimestamp() - time();
-
-        /**
-         * @see https://redis.io/commands/setex
-         * @see https://redis.io/commands/expire
-         */
-        if ($ttl <= 0) {
-            return (bool)$this->instance->expire($item->getKey(), 0);
-        }
-
-        return $this->instance->setex($item->getKey(), $ttl, $this->encode($this->driverPreWrap($item)))->getPayload() === 'OK';
-    }
-
-    /**
-     * @param string $key
-     * @param string $encodedKey
-     * @return bool
-     */
-    protected function driverDelete(string $key, string $encodedKey): bool
-    {
-        return (bool)$this->instance->del([$key]);
-    }
-
-    /**
-     * @param string[] $keys
-     * @return bool
-     */
-    protected function driverDeleteMultiple(array $keys): bool
-    {
-        return (bool) $this->instance->del(...$keys);
-    }
-
-    /**
-     * @return bool
-     */
-    protected function driverClear(): bool
-    {
-        return $this->instance->flushdb()->getPayload() === 'OK';
-    }
+	}
+
+	/**
+	 * @return DriverStatistic
+	 */
+	public function getStats(): DriverStatistic
+	{
+		$info = $this->instance->info();
+		$size = ($info['Memory']['used_memory'] ?? 0);
+		$version = ($info['Server']['redis_version'] ?? 0);
+		$date = (isset($info['Server']['uptime_in_seconds']) ? (new DateTime())->setTimestamp(time() - $info['Server']['uptime_in_seconds']) : 'unknown date');
+
+		return (new DriverStatistic())
+			->setData(implode(', ', array_keys($this->itemInstances)))
+			->setRawData($info)
+			->setSize((int)$size)
+			->setInfo(
+				sprintf(
+					"The Redis daemon v%s (with Predis v%s) is up since %s.\n For more information see RawData. \n Driver size includes the memory allocation size.",
+					$version,
+					PredisClient::VERSION,
+					$date->format(DATE_RFC2822)
+				)
+			);
+	}
+
+	/**
+	 * @return bool
+	 * @throws PhpfastcacheDriverException
+	 * @throws PhpfastcacheLogicException
+	 */
+	protected function driverConnect(): bool
+	{
+		/**
+		 * In case of a user-provided
+		 * Predis client just return here
+		 */
+		if ($this->getConfig()->getPredisClient() instanceof PredisClient) {
+			$this->instance = $this->getConfig()->getPredisClient();
+			if (!$this->instance->isConnected()) {
+				$this->instance->connect();
+			}
+			return true;
+		}
+
+		$options = [];
+
+		if ($this->getConfig()->getOptPrefix()) {
+			$options['prefix'] = $this->getConfig()->getOptPrefix();
+		}
+
+		if (!empty($this->getConfig()->getPath())) {
+			$this->instance = new PredisClient(
+				[
+					'scheme' => $this->getConfig()->getScheme(),
+					'persistent' => $this->getConfig()->isPersistent(),
+					'timeout' => $this->getConfig()->getTimeout(),
+					'path' => $this->getConfig()->getPath(),
+				],
+				$options
+			);
+		} else {
+			$this->instance = new PredisClient($this->getConfig()->getPredisConfigArray(), $options);
+		}
+
+		try {
+			$this->instance->connect();
+		} catch (PredisConnectionException $e) {
+			throw new PhpfastcacheDriverException(
+				'Failed to connect to predis server. Check the Predis documentation: https://github.com/nrk/predis/tree/v1.1#how-to-install-and-use-predis',
+				0,
+				$e
+			);
+		}
+
+		return true;
+	}
+
+	/**
+	 * @param ExtendedCacheItemInterface $item
+	 * @return ?array<string, mixed>
+	 */
+	protected function driverRead(ExtendedCacheItemInterface $item): ?array
+	{
+		$val = $this->instance->get($item->getKey());
+
+		if ($val === null) {
+			return null;
+		}
+
+		return $this->decode($val);
+	}
+
+
+	/**
+	 * @param ExtendedCacheItemInterface ...$items
+	 * @return array<array<string, mixed>>
+	 * @throws \Phpfastcache\Exceptions\PhpfastcacheDriverException
+	 * @throws \RedisException
+	 */
+	protected function driverReadMultiple(ExtendedCacheItemInterface ...$items): array
+	{
+		$keys = $this->getKeys($items);
+
+		return array_combine($keys, array_map(
+			fn($val) => $val ? $this->decode($val) : null,
+			$this->instance->mget($keys)
+		));
+	}
+
+	/**
+	 * @return array<int, string>
+	 * @throws \RedisException
+	 */
+	protected function driverReadAllKeys(string $pattern = '*'): iterable
+	{
+		$keys = [];
+		foreach (new PredisIterator\Keyspace($this->instance, $pattern, ExtendedCacheItemPoolInterface::MAX_ALL_KEYS_COUNT) as $key) {
+			$keys[] = $key;
+		}
+		return $keys;
+	}
+
+
+	/**
+	 * @param ExtendedCacheItemInterface $item
+	 * @return mixed
+	 * @throws PhpfastcacheInvalidArgumentException
+	 * @throws PhpfastcacheLogicException
+	 */
+	protected function driverWrite(ExtendedCacheItemInterface $item): bool
+	{
+
+		$ttl = $item->getExpirationDate()->getTimestamp() - time();
+
+		/**
+		 * @see https://redis.io/commands/setex
+		 * @see https://redis.io/commands/expire
+		 */
+		if ($ttl <= 0) {
+			return (bool)$this->instance->expire($item->getKey(), 0);
+		}
+
+		return $this->instance->setex($item->getKey(), $ttl, $this->encode($this->driverPreWrap($item)))->getPayload() === 'OK';
+	}
+
+	/**
+	 * @param string $key
+	 * @param string $encodedKey
+	 * @return bool
+	 */
+	protected function driverDelete(string $key, string $encodedKey): bool
+	{
+		return (bool)$this->instance->del([$key]);
+	}
+
+	/**
+	 * @param string[] $keys
+	 * @return bool
+	 */
+	protected function driverDeleteMultiple(array $keys): bool
+	{
+		return (bool) $this->instance->del(...$keys);
+	}
+
+	/**
+	 * @return bool
+	 */
+	protected function driverClear(): bool
+	{
+		return $this->instance->flushdb()->getPayload() === 'OK';
+	}
 }

Spacing +3 added lines, -3 removed lines

@@ -75,7 +75,7 @@ 
         return (new DriverStatistic())
             ->setData(implode(', ', array_keys($this->itemInstances)))
             ->setRawData($info)
-            ->setSize((int)$size)
+            ->setSize((int) $size)
             ->setInfo(
                 sprintf(
                     "The Redis daemon v%s (with Predis v%s) is up since %s.\n For more information see RawData. \n Driver size includes the memory allocation size.",
@@ -200,7 +200,7 @@ 
          * @see https://redis.io/commands/expire
          */
         if ($ttl <= 0) {
-            return (bool)$this->instance->expire($item->getKey(), 0);
+            return (bool) $this->instance->expire($item->getKey(), 0);
         }
 
         return $this->instance->setex($item->getKey(), $ttl, $this->encode($this->driverPreWrap($item)))->getPayload() === 'OK';
@@ -213,7 +213,7 @@ 
      */
     protected function driverDelete(string $key, string $encodedKey): bool
     {
-        return (bool)$this->instance->del([$key]);
+        return (bool) $this->instance->del([$key]);
     }
 
     /**

Braces +4 added lines, -2 removed lines

@@ -121,13 +121,15 @@
                 ],
                 $options
             );
-        } else {
+        }
+        else {
             $this->instance = new PredisClient($this->getConfig()->getPredisConfigArray(), $options);
         }
 
         try {
             $this->instance->connect();
-        } catch (PredisConnectionException $e) {
+        }
+        catch (PredisConnectionException $e) {
             throw new PhpfastcacheDriverException(
                 'Failed to connect to predis server. Check the Predis documentation: https://github.com/nrk/predis/tree/v1.1#how-to-install-and-use-predis',
                 0,

plugins/files/php/vendor/phpfastcache/phpfastcache/lib/Phpfastcache/Drivers/Predis/Config.php

Indentation +189 added lines, -189 removed lines

@@ -23,194 +23,194 @@
 
 class Config extends ConfigurationOption
 {
-    protected string $host = '127.0.0.1';
-    protected int $port = 6379;
-    protected string $password = '';
-    protected int $database = 0;
-    protected ?Client $predisClient = null;
-    protected string $optPrefix = '';
-    protected int $timeout = 5;
-    protected bool $persistent = false;
-    protected string $scheme = 'unix';
+	protected string $host = '127.0.0.1';
+	protected int $port = 6379;
+	protected string $password = '';
+	protected int $database = 0;
+	protected ?Client $predisClient = null;
+	protected string $optPrefix = '';
+	protected int $timeout = 5;
+	protected bool $persistent = false;
+	protected string $scheme = 'unix';
 /**
-     * @return array<string, mixed>
-     */
-    public function getPredisConfigArray(): array
-    {
-        return [
-            'host' => $this->getHost(),
-            'port' => $this->getPort(),
-            'password' => $this->getPassword() ?: null,
-            'database' => $this->getDatabase(),
-            'timeout' => $this->getTimeout(),
-        ];
-    }
-
-    /**
-     * @return string
-     */
-    public function getHost(): string
-    {
-        return $this->host;
-    }
-
-    /**
-     * @param string $host
-     * @return Config
-     * @throws PhpfastcacheLogicException
-     */
-    public function setHost(string $host): static
-    {
-        return $this->setProperty('host', $host);
-    }
-
-    /**
-     * @return int
-     */
-    public function getPort(): int
-    {
-        return $this->port;
-    }
-
-    /**
-     * @param int $port
-     * @return Config
-     * @throws PhpfastcacheLogicException
-     */
-    public function setPort(int $port): static
-    {
-        return $this->setProperty('port', $port);
-    }
-
-    /**
-     * @return string
-     */
-    public function getPassword(): string
-    {
-        return $this->password;
-    }
-
-    /**
-     * @param string $password
-     * @return self
-     * @throws PhpfastcacheLogicException
-     */
-    public function setPassword(string $password): static
-    {
-        return $this->setProperty('password', $password);
-    }
-
-    /**
-     * @return int
-     */
-    public function getDatabase(): int
-    {
-        return $this->database;
-    }
-
-    /**
-     * @param int $database
-     * @return Config
-     * @throws PhpfastcacheLogicException
-     */
-    public function setDatabase(int $database): static
-    {
-        return $this->setProperty('database', $database);
-    }
-
-    /**
-     * @return int
-     */
-    public function getTimeout(): int
-    {
-        return $this->timeout;
-    }
-
-    /**
-     * @param int $timeout
-     * @return self
-     * @throws PhpfastcacheLogicException
-     */
-    public function setTimeout(int $timeout): static
-    {
-        return $this->setProperty('timeout', $timeout);
-    }
-
-    /**
-     * @return Client|null
-     */
-    public function getPredisClient(): ?Client
-    {
-        return $this->predisClient;
-    }
-
-    /**
-     * @param Client|null $predisClient
-     * @return Config
-     * @throws PhpfastcacheLogicException
-     */
-    public function setPredisClient(?Client $predisClient = null): Config
-    {
-        return $this->setProperty('predisClient', $predisClient);
-    }
-
-    /**
-     * @return string
-     * @since 7.0.2
-     */
-    public function getOptPrefix(): string
-    {
-        return $this->optPrefix;
-    }
-
-    /**
-     * @param string $optPrefix
-     * @return Config
-     * @throws PhpfastcacheLogicException
-     * @since 7.0.2
-     */
-    public function setOptPrefix(string $optPrefix): Config
-    {
-        return $this->setProperty('optPrefix', trim($optPrefix));
-    }
-
-    /**
-     * @return bool
-     */
-    public function isPersistent(): bool
-    {
-        return $this->persistent;
-    }
-
-    /**
-     * @param bool $persistent
-     * @return Config
-     * @throws PhpfastcacheLogicException
-     */
-    public function setPersistent(bool $persistent): Config
-    {
-        return $this->setProperty('persistent', $persistent);
-    }
-
-    /**
-     * @return string
-     */
-    public function getScheme(): string
-    {
-        return $this->scheme;
-    }
-
-    /**
-     * @param string $scheme
-     * @return Config
-     * @throws PhpfastcacheInvalidConfigurationException
-     * @throws PhpfastcacheLogicException
-     */
-    public function setScheme(string $scheme): Config
-    {
-        if (!in_array($scheme, ['unix', 'tls'], true)) {
-            throw new PhpfastcacheInvalidConfigurationException('Invalid scheme: ' . $scheme);
-        }
-        return $this->setProperty('scheme', $scheme);
-    }
+	 * @return array<string, mixed>
+	 */
+	public function getPredisConfigArray(): array
+	{
+		return [
+			'host' => $this->getHost(),
+			'port' => $this->getPort(),
+			'password' => $this->getPassword() ?: null,
+			'database' => $this->getDatabase(),
+			'timeout' => $this->getTimeout(),
+		];
+	}
+
+	/**
+	 * @return string
+	 */
+	public function getHost(): string
+	{
+		return $this->host;
+	}
+
+	/**
+	 * @param string $host
+	 * @return Config
+	 * @throws PhpfastcacheLogicException
+	 */
+	public function setHost(string $host): static
+	{
+		return $this->setProperty('host', $host);
+	}
+
+	/**
+	 * @return int
+	 */
+	public function getPort(): int
+	{
+		return $this->port;
+	}
+
+	/**
+	 * @param int $port
+	 * @return Config
+	 * @throws PhpfastcacheLogicException
+	 */
+	public function setPort(int $port): static
+	{
+		return $this->setProperty('port', $port);
+	}
+
+	/**
+	 * @return string
+	 */
+	public function getPassword(): string
+	{
+		return $this->password;
+	}
+
+	/**
+	 * @param string $password
+	 * @return self
+	 * @throws PhpfastcacheLogicException
+	 */
+	public function setPassword(string $password): static
+	{
+		return $this->setProperty('password', $password);
+	}
+
+	/**
+	 * @return int
+	 */
+	public function getDatabase(): int
+	{
+		return $this->database;
+	}
+
+	/**
+	 * @param int $database
+	 * @return Config
+	 * @throws PhpfastcacheLogicException
+	 */
+	public function setDatabase(int $database): static
+	{
+		return $this->setProperty('database', $database);
+	}
+
+	/**
+	 * @return int
+	 */
+	public function getTimeout(): int
+	{
+		return $this->timeout;
+	}
+
+	/**
+	 * @param int $timeout
+	 * @return self
+	 * @throws PhpfastcacheLogicException
+	 */
+	public function setTimeout(int $timeout): static
+	{
+		return $this->setProperty('timeout', $timeout);
+	}
+
+	/**
+	 * @return Client|null
+	 */
+	public function getPredisClient(): ?Client
+	{
+		return $this->predisClient;
+	}
+
+	/**
+	 * @param Client|null $predisClient
+	 * @return Config
+	 * @throws PhpfastcacheLogicException
+	 */
+	public function setPredisClient(?Client $predisClient = null): Config
+	{
+		return $this->setProperty('predisClient', $predisClient);
+	}
+
+	/**
+	 * @return string
+	 * @since 7.0.2
+	 */
+	public function getOptPrefix(): string
+	{
+		return $this->optPrefix;
+	}
+
+	/**
+	 * @param string $optPrefix
+	 * @return Config
+	 * @throws PhpfastcacheLogicException
+	 * @since 7.0.2
+	 */
+	public function setOptPrefix(string $optPrefix): Config
+	{
+		return $this->setProperty('optPrefix', trim($optPrefix));
+	}
+
+	/**
+	 * @return bool
+	 */
+	public function isPersistent(): bool
+	{
+		return $this->persistent;
+	}
+
+	/**
+	 * @param bool $persistent
+	 * @return Config
+	 * @throws PhpfastcacheLogicException
+	 */
+	public function setPersistent(bool $persistent): Config
+	{
+		return $this->setProperty('persistent', $persistent);
+	}
+
+	/**
+	 * @return string
+	 */
+	public function getScheme(): string
+	{
+		return $this->scheme;
+	}
+
+	/**
+	 * @param string $scheme
+	 * @return Config
+	 * @throws PhpfastcacheInvalidConfigurationException
+	 * @throws PhpfastcacheLogicException
+	 */
+	public function setScheme(string $scheme): Config
+	{
+		if (!in_array($scheme, ['unix', 'tls'], true)) {
+			throw new PhpfastcacheInvalidConfigurationException('Invalid scheme: ' . $scheme);
+		}
+		return $this->setProperty('scheme', $scheme);
+	}
 }

plugins/files/php/vendor/phpfastcache/phpfastcache/lib/Phpfastcache/Drivers/Memcached/Driver.php

Indentation +185 added lines, -185 removed lines

@@ -42,189 +42,189 @@
  */
 class Driver implements AggregatablePoolInterface
 {
-    use TaggableCacheItemPoolTrait {
-        __construct as protected __parentConstruct;
-    }
-    use MemcacheDriverCollisionDetectorTrait;
-
-    /**
-     * Driver constructor.
-     * @param ConfigurationOption $config
-     * @param string $instanceId
-     * @param EventManagerInterface $em
-     * @throws PhpfastcacheDriverConnectException
-     * @throws PhpfastcacheInvalidArgumentException
-     * @throws PhpfastcacheCoreException
-     * @throws PhpfastcacheDriverCheckException
-     * @throws PhpfastcacheIOException
-     */
-    public function __construct(ConfigurationOption $config, string $instanceId, EventManagerInterface $em)
-    {
-        self::checkCollision('Memcached');
-        $this->__parentConstruct($config, $instanceId, $em);
-    }
-
-    /**
-     * @return bool
-     */
-    public function driverCheck(): bool
-    {
-        return class_exists('Memcached');
-    }
-
-    /**
-     * @return DriverStatistic
-     */
-    public function getStats(): DriverStatistic
-    {
-        $stats = current($this->instance->getStats());
-        $stats['uptime'] = $stats['uptime'] ?? 0;
-        $stats['bytes'] = $stats['bytes'] ?? 0;
-        $stats['version'] = $stats['version'] ?? $this->instance->getVersion();
-
-        $date = (new DateTime())->setTimestamp(time() - $stats['uptime']);
-
-        return (new DriverStatistic())
-            ->setData(implode(', ', array_keys($this->itemInstances)))
-            ->setInfo(sprintf("The memcache daemon v%s is up since %s.\n For more information see RawData.", $stats['version'], $date->format(DATE_RFC2822)))
-            ->setRawData($stats)
-            ->setSize((int)$stats['bytes']);
-    }
-
-    /**
-     * @return bool
-     * @throws PhpfastcacheDriverException
-     */
-    protected function driverConnect(): bool
-    {
-        $this->instance = new MemcachedSoftware();
-        $optPrefix = $this->getConfig()->getOptPrefix();
-        $this->instance->setOption(MemcachedSoftware::OPT_BINARY_PROTOCOL, true);
-
-        if ($optPrefix) {
-            $this->instance->setOption(MemcachedSoftware::OPT_PREFIX_KEY, $optPrefix);
-        }
-
-        foreach ($this->getConfig()->getServers() as $server) {
-            $connected = false;
-            /**
-             * If path is provided we consider it as an UNIX Socket
-             */
-            if (!empty($server['path'])) {
-                $connected = $this->instance->addServer($server['path'], 0);
-            } elseif (!empty($server['host'])) {
-                $connected = $this->instance->addServer($server['host'], $server['port']);
-            }
-            if (!empty($server['saslUser']) && !empty($server['saslPassword'])) {
-                $this->instance->setSaslAuthData($server['saslUser'], $server['saslPassword']);
-            }
-            if (!$connected) {
-                throw new PhpfastcacheDriverConnectException(
-                    sprintf(
-                        'Failed to connect to memcache host/path "%s".',
-                        $server['host'] ?: $server['path'],
-                    )
-                );
-            }
-        }
-
-        /**
-         * Since Memcached does not throw
-         * any error if not connected ...
-         */
-        $version = $this->instance->getVersion();
-        if (!$version || $this->instance->getResultCode() !== MemcachedSoftware::RES_SUCCESS) {
-            throw new PhpfastcacheDriverException('Memcached seems to not be connected');
-        }
-        return true;
-    }
-
-    /**
-     * @param ExtendedCacheItemInterface $item
-     * @return ?array<string, mixed>
-     */
-    protected function driverRead(ExtendedCacheItemInterface $item): ?array
-    {
-        $val = $this->instance->get($item->getKey());
-
-        if (empty($val) || !\is_array($val)) {
-            return null;
-        }
-
-        return $val;
-    }
-
-    /**
-     * @param ExtendedCacheItemInterface ...$items
-     * @return array<array<string, mixed>>
-     */
-    protected function driverReadMultiple(ExtendedCacheItemInterface ...$items): array
-    {
-        $keys = $this->getKeys($items);
-
-        $val = $this->instance->getMulti($keys);
-
-        if (empty($val) || !\is_array($val)) {
-            return [];
-        }
-
-        return $val;
-    }
-
-
-    /**
-     * @return array<string, mixed>
-     * @throws PhpfastcacheInvalidArgumentException
-     */
-    protected function driverReadAllKeys(string $pattern = ''): iterable
-    {
-        if ($pattern !== '') {
-            $this->throwUnsupportedDriverReadAllPattern('https://www.php.net/manual/en/memcached.getallkeys.php');
-        }
-        $keys = $this->instance->getAllKeys();
-
-        if (is_iterable($keys)) {
-            return $keys;
-        } else {
-            return [];
-        }
-    }
-
-    /**
-     * @param ExtendedCacheItemInterface $item
-     * @return bool
-     * @throws PhpfastcacheInvalidArgumentException
-     * @throws PhpfastcacheLogicException
-     */
-    protected function driverWrite(ExtendedCacheItemInterface $item): bool
-    {
-
-        $ttl = $item->getExpirationDate()->getTimestamp() - time();
-
-        // Memcache will only allow a expiration timer less than 2592000 seconds,
-        // otherwise, it will assume you're giving it a UNIX timestamp.
-        if ($ttl > 2592000) {
-            $ttl = time() + $ttl;
-        }
-
-        return $this->instance->set($item->getKey(), $this->driverPreWrap($item), $ttl);
-    }
-
-    /**
-     * @param string $key
-     * @param string $encodedKey
-     * @return bool
-     */
-    protected function driverDelete(string $key, string $encodedKey): bool
-    {
-        return $this->instance->delete($key);
-    }
-
-    /**
-     * @return bool
-     */
-    protected function driverClear(): bool
-    {
-        return $this->instance->flush();
-    }
+	use TaggableCacheItemPoolTrait {
+		__construct as protected __parentConstruct;
+	}
+	use MemcacheDriverCollisionDetectorTrait;
+
+	/**
+	 * Driver constructor.
+	 * @param ConfigurationOption $config
+	 * @param string $instanceId
+	 * @param EventManagerInterface $em
+	 * @throws PhpfastcacheDriverConnectException
+	 * @throws PhpfastcacheInvalidArgumentException
+	 * @throws PhpfastcacheCoreException
+	 * @throws PhpfastcacheDriverCheckException
+	 * @throws PhpfastcacheIOException
+	 */
+	public function __construct(ConfigurationOption $config, string $instanceId, EventManagerInterface $em)
+	{
+		self::checkCollision('Memcached');
+		$this->__parentConstruct($config, $instanceId, $em);
+	}
+
+	/**
+	 * @return bool
+	 */
+	public function driverCheck(): bool
+	{
+		return class_exists('Memcached');
+	}
+
+	/**
+	 * @return DriverStatistic
+	 */
+	public function getStats(): DriverStatistic
+	{
+		$stats = current($this->instance->getStats());
+		$stats['uptime'] = $stats['uptime'] ?? 0;
+		$stats['bytes'] = $stats['bytes'] ?? 0;
+		$stats['version'] = $stats['version'] ?? $this->instance->getVersion();
+
+		$date = (new DateTime())->setTimestamp(time() - $stats['uptime']);
+
+		return (new DriverStatistic())
+			->setData(implode(', ', array_keys($this->itemInstances)))
+			->setInfo(sprintf("The memcache daemon v%s is up since %s.\n For more information see RawData.", $stats['version'], $date->format(DATE_RFC2822)))
+			->setRawData($stats)
+			->setSize((int)$stats['bytes']);
+	}
+
+	/**
+	 * @return bool
+	 * @throws PhpfastcacheDriverException
+	 */
+	protected function driverConnect(): bool
+	{
+		$this->instance = new MemcachedSoftware();
+		$optPrefix = $this->getConfig()->getOptPrefix();
+		$this->instance->setOption(MemcachedSoftware::OPT_BINARY_PROTOCOL, true);
+
+		if ($optPrefix) {
+			$this->instance->setOption(MemcachedSoftware::OPT_PREFIX_KEY, $optPrefix);
+		}
+
+		foreach ($this->getConfig()->getServers() as $server) {
+			$connected = false;
+			/**
+			 * If path is provided we consider it as an UNIX Socket
+			 */
+			if (!empty($server['path'])) {
+				$connected = $this->instance->addServer($server['path'], 0);
+			} elseif (!empty($server['host'])) {
+				$connected = $this->instance->addServer($server['host'], $server['port']);
+			}
+			if (!empty($server['saslUser']) && !empty($server['saslPassword'])) {
+				$this->instance->setSaslAuthData($server['saslUser'], $server['saslPassword']);
+			}
+			if (!$connected) {
+				throw new PhpfastcacheDriverConnectException(
+					sprintf(
+						'Failed to connect to memcache host/path "%s".',
+						$server['host'] ?: $server['path'],
+					)
+				);
+			}
+		}
+
+		/**
+		 * Since Memcached does not throw
+		 * any error if not connected ...
+		 */
+		$version = $this->instance->getVersion();
+		if (!$version || $this->instance->getResultCode() !== MemcachedSoftware::RES_SUCCESS) {
+			throw new PhpfastcacheDriverException('Memcached seems to not be connected');
+		}
+		return true;
+	}
+
+	/**
+	 * @param ExtendedCacheItemInterface $item
+	 * @return ?array<string, mixed>
+	 */
+	protected function driverRead(ExtendedCacheItemInterface $item): ?array
+	{
+		$val = $this->instance->get($item->getKey());
+
+		if (empty($val) || !\is_array($val)) {
+			return null;
+		}
+
+		return $val;
+	}
+
+	/**
+	 * @param ExtendedCacheItemInterface ...$items
+	 * @return array<array<string, mixed>>
+	 */
+	protected function driverReadMultiple(ExtendedCacheItemInterface ...$items): array
+	{
+		$keys = $this->getKeys($items);
+
+		$val = $this->instance->getMulti($keys);
+
+		if (empty($val) || !\is_array($val)) {
+			return [];
+		}
+
+		return $val;
+	}
+
+
+	/**
+	 * @return array<string, mixed>
+	 * @throws PhpfastcacheInvalidArgumentException
+	 */
+	protected function driverReadAllKeys(string $pattern = ''): iterable
+	{
+		if ($pattern !== '') {
+			$this->throwUnsupportedDriverReadAllPattern('https://www.php.net/manual/en/memcached.getallkeys.php');
+		}
+		$keys = $this->instance->getAllKeys();
+
+		if (is_iterable($keys)) {
+			return $keys;
+		} else {
+			return [];
+		}
+	}
+
+	/**
+	 * @param ExtendedCacheItemInterface $item
+	 * @return bool
+	 * @throws PhpfastcacheInvalidArgumentException
+	 * @throws PhpfastcacheLogicException
+	 */
+	protected function driverWrite(ExtendedCacheItemInterface $item): bool
+	{
+
+		$ttl = $item->getExpirationDate()->getTimestamp() - time();
+
+		// Memcache will only allow a expiration timer less than 2592000 seconds,
+		// otherwise, it will assume you're giving it a UNIX timestamp.
+		if ($ttl > 2592000) {
+			$ttl = time() + $ttl;
+		}
+
+		return $this->instance->set($item->getKey(), $this->driverPreWrap($item), $ttl);
+	}
+
+	/**
+	 * @param string $key
+	 * @param string $encodedKey
+	 * @return bool
+	 */
+	protected function driverDelete(string $key, string $encodedKey): bool
+	{
+		return $this->instance->delete($key);
+	}
+
+	/**
+	 * @return bool
+	 */
+	protected function driverClear(): bool
+	{
+		return $this->instance->flush();
+	}
 }

Spacing +1 added lines, -1 removed lines

@@ -78,7 +78,7 @@
             ->setData(implode(', ', array_keys($this->itemInstances)))
             ->setInfo(sprintf("The memcache daemon v%s is up since %s.\n For more information see RawData.", $stats['version'], $date->format(DATE_RFC2822)))
             ->setRawData($stats)
-            ->setSize((int)$stats['bytes']);
+            ->setSize((int) $stats['bytes']);
     }
 
     /**

Braces +5 added lines, -4 removed lines

@@ -58,8 +58,7 @@ 
      * @throws PhpfastcacheDriverCheckException
      * @throws PhpfastcacheIOException
      */
-    public function __construct(ConfigurationOption $config, string $instanceId, EventManagerInterface $em)
-    {
+    public function __construct(ConfigurationOption $config, string $instanceId, EventManagerInterface $em) {
         self::checkCollision('Memcached');
         $this->__parentConstruct($config, $instanceId, $em);
     }
@@ -112,7 +111,8 @@ 
              */
             if (!empty($server['path'])) {
                 $connected = $this->instance->addServer($server['path'], 0);
-            } elseif (!empty($server['host'])) {
+            }
+            elseif (!empty($server['host'])) {
                 $connected = $this->instance->addServer($server['host'], $server['port']);
             }
             if (!empty($server['saslUser']) && !empty($server['saslPassword'])) {
@@ -185,7 +185,8 @@ 
 
         if (is_iterable($keys)) {
             return $keys;
-        } else {
+        }
+        else {
             return [];
         }
     }

plugins/files/php/vendor/phpfastcache/phpfastcache/lib/Phpfastcache/Drivers/Memcached/Config.php

Indentation +177 added lines, -177 removed lines

@@ -22,182 +22,182 @@
 
 class Config extends ConfigurationOption
 {
-    /**
-     * @var array
-     *
-     * Multiple server can be added this way:
-     *       $cfg->setServers([
-     *         [
-     *           // If you use a UNIX socket set the host and port to null
-     *           'host' => '127.0.0.1',
-     *           //'path' => 'path/to/unix/socket',
-     *           'port' => 11211,
-     *           'saslUser' => null,
-     *           'saslPassword' => null,
-     *         ]
-     *      ]);
-     */
-
-    /** @var array<array<string, mixed>> */
-    protected array $servers = [];
-    protected string $host = '127.0.0.1';
-    protected int $port = 11211;
-    protected string $saslUser = '';
-    protected string $saslPassword = '';
-    protected string $optPrefix = '';
+	/**
+	 * @var array
+	 *
+	 * Multiple server can be added this way:
+	 *       $cfg->setServers([
+	 *         [
+	 *           // If you use a UNIX socket set the host and port to null
+	 *           'host' => '127.0.0.1',
+	 *           //'path' => 'path/to/unix/socket',
+	 *           'port' => 11211,
+	 *           'saslUser' => null,
+	 *           'saslPassword' => null,
+	 *         ]
+	 *      ]);
+	 */
+
+	/** @var array<array<string, mixed>> */
+	protected array $servers = [];
+	protected string $host = '127.0.0.1';
+	protected int $port = 11211;
+	protected string $saslUser = '';
+	protected string $saslPassword = '';
+	protected string $optPrefix = '';
 /**
-     * @return string
-     */
-    public function getSaslUser(): string
-    {
-        return $this->saslUser;
-    }
-
-    /**
-     * @param string $saslUser
-     * @return self
-     * @throws PhpfastcacheLogicException
-     */
-    public function setSaslUser(string $saslUser): static
-    {
-        return $this->setProperty('saslUser', $saslUser);
-    }
-
-    /**
-     * @return string
-     */
-    public function getSaslPassword(): string
-    {
-        return $this->saslPassword;
-    }
-
-    /**
-     * @param string $saslPassword
-     * @return self
-     * @throws PhpfastcacheLogicException
-     */
-    public function setSaslPassword(string $saslPassword): static
-    {
-        return $this->setProperty('saslPassword', $saslPassword);
-    }
-
-    /**
-     * @return array<array<string, mixed>>
-     */
-    public function getServers(): array
-    {
-        if (!count($this->servers)) {
-            return [
-                [
-                    'host' => $this->getHost(),
-                    'path' => $this->getPath(),
-                    'port' => $this->getPort(),
-                    'saslUser' => $this->getSaslUser() ?: null,
-                    'saslPassword' => $this->getSaslPassword() ?: null,
-                ],
-            ];
-        }
-
-        return $this->servers;
-    }
-
-    /**
-     * @param array<array<string, mixed>> $servers
-     * @return self
-     * @throws PhpfastcacheInvalidConfigurationException
-     * @throws PhpfastcacheLogicException
-     *
-     * @SuppressWarnings(PHPMD.CyclomaticComplexity)
-     * @SuppressWarnings(PHPMD.NPathComplexity)
-     */
-    public function setServers(array $servers): static
-    {
-        foreach ($servers as $server) {
-            if ($diff = array_diff(array_keys($server), ['host', 'port', 'saslUser', 'saslPassword', 'path'])) {
-                throw new PhpfastcacheInvalidConfigurationException('Unknown keys for memcached server: ' . implode(', ', $diff));
-            }
-
-            if (!empty($server['host']) && !empty($server['path'])) {
-                throw new PhpfastcacheInvalidConfigurationException('Host and path cannot be simultaneous defined.');
-            }
-
-            if ((isset($server['host']) && !is_string($server['host'])) || (empty($server['path']) && empty($server['host']))) {
-                throw new PhpfastcacheInvalidConfigurationException('Host must be a valid string in "$server" configuration array if path is not defined');
-            }
-
-            if ((isset($server['path']) && !is_string($server['path'])) || (empty($server['host']) && empty($server['path']))) {
-                throw new PhpfastcacheInvalidConfigurationException('Path must be a valid string in "$server" configuration array if host is not defined');
-            }
-
-            if (!empty($server['host']) && (empty($server['port']) || !is_int($server['port']) || $server['port'] < 1)) {
-                throw new PhpfastcacheInvalidConfigurationException('Port must be a valid integer in "$server" configuration array');
-            }
-
-            if (!empty($server['port']) && !empty($server['path'])) {
-                throw new PhpfastcacheInvalidConfigurationException('Port should not be defined along with path');
-            }
-
-            if (!empty($server['saslUser']) && !empty($server['saslPassword']) && (!is_string($server['saslUser']) || !is_string($server['saslPassword']))) {
-                throw new PhpfastcacheInvalidConfigurationException('If provided, saslUser and saslPassword must be a string');
-            }
-        }
-
-        return $this->setProperty('servers', $servers);
-    }
-
-    /**
-     * @return string
-     */
-    public function getHost(): string
-    {
-        return $this->host;
-    }
-
-    /**
-     * @param string $host
-     * @return self
-     * @throws PhpfastcacheLogicException
-     */
-    public function setHost(string $host): static
-    {
-        return $this->setProperty('host', $host);
-    }
-
-    /**
-     * @return int
-     */
-    public function getPort(): int
-    {
-        return $this->port;
-    }
-
-    /**
-     * @param int $port
-     * @return Config
-     * @throws PhpfastcacheLogicException
-     */
-    public function setPort(int $port): static
-    {
-        return $this->setProperty('port', $port);
-    }
-
-    /**
-     * @return string
-     * @since 8.0.2
-     */
-    public function getOptPrefix(): string
-    {
-        return $this->optPrefix;
-    }
-
-    /**
-     * @param string $optPrefix
-     * @return Config
-     * @throws PhpfastcacheLogicException
-     * @since 8.0.2
-     */
-    public function setOptPrefix(string $optPrefix): Config
-    {
-        return $this->setProperty('optPrefix', trim($optPrefix));
-    }
+	 * @return string
+	 */
+	public function getSaslUser(): string
+	{
+		return $this->saslUser;
+	}
+
+	/**
+	 * @param string $saslUser
+	 * @return self
+	 * @throws PhpfastcacheLogicException
+	 */
+	public function setSaslUser(string $saslUser): static
+	{
+		return $this->setProperty('saslUser', $saslUser);
+	}
+
+	/**
+	 * @return string
+	 */
+	public function getSaslPassword(): string
+	{
+		return $this->saslPassword;
+	}
+
+	/**
+	 * @param string $saslPassword
+	 * @return self
+	 * @throws PhpfastcacheLogicException
+	 */
+	public function setSaslPassword(string $saslPassword): static
+	{
+		return $this->setProperty('saslPassword', $saslPassword);
+	}
+
+	/**
+	 * @return array<array<string, mixed>>
+	 */
+	public function getServers(): array
+	{
+		if (!count($this->servers)) {
+			return [
+				[
+					'host' => $this->getHost(),
+					'path' => $this->getPath(),
+					'port' => $this->getPort(),
+					'saslUser' => $this->getSaslUser() ?: null,
+					'saslPassword' => $this->getSaslPassword() ?: null,
+				],
+			];
+		}
+
+		return $this->servers;
+	}
+
+	/**
+	 * @param array<array<string, mixed>> $servers
+	 * @return self
+	 * @throws PhpfastcacheInvalidConfigurationException
+	 * @throws PhpfastcacheLogicException
+	 *
+	 * @SuppressWarnings(PHPMD.CyclomaticComplexity)
+	 * @SuppressWarnings(PHPMD.NPathComplexity)
+	 */
+	public function setServers(array $servers): static
+	{
+		foreach ($servers as $server) {
+			if ($diff = array_diff(array_keys($server), ['host', 'port', 'saslUser', 'saslPassword', 'path'])) {
+				throw new PhpfastcacheInvalidConfigurationException('Unknown keys for memcached server: ' . implode(', ', $diff));
+			}
+
+			if (!empty($server['host']) && !empty($server['path'])) {
+				throw new PhpfastcacheInvalidConfigurationException('Host and path cannot be simultaneous defined.');
+			}
+
+			if ((isset($server['host']) && !is_string($server['host'])) || (empty($server['path']) && empty($server['host']))) {
+				throw new PhpfastcacheInvalidConfigurationException('Host must be a valid string in "$server" configuration array if path is not defined');
+			}
+
+			if ((isset($server['path']) && !is_string($server['path'])) || (empty($server['host']) && empty($server['path']))) {
+				throw new PhpfastcacheInvalidConfigurationException('Path must be a valid string in "$server" configuration array if host is not defined');
+			}
+
+			if (!empty($server['host']) && (empty($server['port']) || !is_int($server['port']) || $server['port'] < 1)) {
+				throw new PhpfastcacheInvalidConfigurationException('Port must be a valid integer in "$server" configuration array');
+			}
+
+			if (!empty($server['port']) && !empty($server['path'])) {
+				throw new PhpfastcacheInvalidConfigurationException('Port should not be defined along with path');
+			}
+
+			if (!empty($server['saslUser']) && !empty($server['saslPassword']) && (!is_string($server['saslUser']) || !is_string($server['saslPassword']))) {
+				throw new PhpfastcacheInvalidConfigurationException('If provided, saslUser and saslPassword must be a string');
+			}
+		}
+
+		return $this->setProperty('servers', $servers);
+	}
+
+	/**
+	 * @return string
+	 */
+	public function getHost(): string
+	{
+		return $this->host;
+	}
+
+	/**
+	 * @param string $host
+	 * @return self
+	 * @throws PhpfastcacheLogicException
+	 */
+	public function setHost(string $host): static
+	{
+		return $this->setProperty('host', $host);
+	}
+
+	/**
+	 * @return int
+	 */
+	public function getPort(): int
+	{
+		return $this->port;
+	}
+
+	/**
+	 * @param int $port
+	 * @return Config
+	 * @throws PhpfastcacheLogicException
+	 */
+	public function setPort(int $port): static
+	{
+		return $this->setProperty('port', $port);
+	}
+
+	/**
+	 * @return string
+	 * @since 8.0.2
+	 */
+	public function getOptPrefix(): string
+	{
+		return $this->optPrefix;
+	}
+
+	/**
+	 * @param string $optPrefix
+	 * @return Config
+	 * @throws PhpfastcacheLogicException
+	 * @since 8.0.2
+	 */
+	public function setOptPrefix(string $optPrefix): Config
+	{
+		return $this->setProperty('optPrefix', trim($optPrefix));
+	}
 }

plugins/files/php/vendor/phpfastcache/phpfastcache/lib/Phpfastcache/Drivers/Ssdb/Driver.php

Indentation +100 added lines, -100 removed lines

@@ -35,104 +35,104 @@
  */
 class Driver implements AggregatablePoolInterface
 {
-    use TaggableCacheItemPoolTrait;
-
-    /**
-     * @return bool
-     */
-    public function driverCheck(): bool
-    {
-        static $driverCheck;
-
-        return $driverCheck ?? ($driverCheck = class_exists(SSDB::class));
-    }
-
-    /**
-     * @return DriverStatistic
-     */
-    public function getStats(): DriverStatistic
-    {
-        $stat = new DriverStatistic();
-        $info = $this->instance->info();
-
-        /**
-         * Data returned by Ssdb are very poorly formatted
-         * using hardcoded offset of pair key-value :-(
-         */
-        $stat->setInfo(sprintf("Ssdb-server v%s with a total of %s call(s).\n For more information see RawData.", $info[2], $info[6]))
-            ->setRawData($info)
-            ->setData(implode(', ', array_keys($this->itemInstances)))
-            ->setSize($this->instance->dbsize());
-
-        return $stat;
-    }
-
-    /**
-     * @return bool
-     * @throws PhpfastcacheDriverException
-     */
-    protected function driverConnect(): bool
-    {
-        try {
-            $clientConfig = $this->getConfig();
-
-            $this->instance = new SimpleSSDB($clientConfig->getHost(), $clientConfig->getPort(), $clientConfig->getTimeout());
-            if (!empty($clientConfig->getPassword())) {
-                $this->instance->auth($clientConfig->getPassword());
-            }
-            $this->instance->ping();
-
-            return true;
-        } catch (SSDBException $e) {
-            throw new PhpfastcacheDriverCheckException('Ssdb failed to connect with error: ' . $e->getMessage(), 0, $e);
-        }
-    }
-
-    /**
-     * @param ExtendedCacheItemInterface $item
-     * @return ?array<string, mixed>
-     */
-    protected function driverRead(ExtendedCacheItemInterface $item): ?array
-    {
-        $val = $this->instance->get($item->getEncodedKey());
-
-        if (empty($val)) {
-            return null;
-        }
-
-        return $this->decode($val);
-    }
-
-    /**
-     * @param ExtendedCacheItemInterface $item
-     * @return mixed
-     * @throws PhpfastcacheInvalidArgumentException
-     * @throws PhpfastcacheLogicException
-     */
-    protected function driverWrite(ExtendedCacheItemInterface $item): bool
-    {
-
-        return (bool)$this->instance->setx($item->getEncodedKey(), $this->encode($this->driverPreWrap($item)), $item->getTtl());
-    }
-
-    /**
-     * @param string $key
-     * @param string $encodedKey
-     * @return bool
-     */
-    protected function driverDelete(string $key, string $encodedKey): bool
-    {
-        return (bool)$this->instance->del($encodedKey);
-    }
-
-    /**
-     * @return bool
-     */
-    protected function driverClear(): bool
-    {
-        $this->instance->flushdb('kv');
-
-        // Status not returned, then we assume its true
-        return true;
-    }
+	use TaggableCacheItemPoolTrait;
+
+	/**
+	 * @return bool
+	 */
+	public function driverCheck(): bool
+	{
+		static $driverCheck;
+
+		return $driverCheck ?? ($driverCheck = class_exists(SSDB::class));
+	}
+
+	/**
+	 * @return DriverStatistic
+	 */
+	public function getStats(): DriverStatistic
+	{
+		$stat = new DriverStatistic();
+		$info = $this->instance->info();
+
+		/**
+		 * Data returned by Ssdb are very poorly formatted
+		 * using hardcoded offset of pair key-value :-(
+		 */
+		$stat->setInfo(sprintf("Ssdb-server v%s with a total of %s call(s).\n For more information see RawData.", $info[2], $info[6]))
+			->setRawData($info)
+			->setData(implode(', ', array_keys($this->itemInstances)))
+			->setSize($this->instance->dbsize());
+
+		return $stat;
+	}
+
+	/**
+	 * @return bool
+	 * @throws PhpfastcacheDriverException
+	 */
+	protected function driverConnect(): bool
+	{
+		try {
+			$clientConfig = $this->getConfig();
+
+			$this->instance = new SimpleSSDB($clientConfig->getHost(), $clientConfig->getPort(), $clientConfig->getTimeout());
+			if (!empty($clientConfig->getPassword())) {
+				$this->instance->auth($clientConfig->getPassword());
+			}
+			$this->instance->ping();
+
+			return true;
+		} catch (SSDBException $e) {
+			throw new PhpfastcacheDriverCheckException('Ssdb failed to connect with error: ' . $e->getMessage(), 0, $e);
+		}
+	}
+
+	/**
+	 * @param ExtendedCacheItemInterface $item
+	 * @return ?array<string, mixed>
+	 */
+	protected function driverRead(ExtendedCacheItemInterface $item): ?array
+	{
+		$val = $this->instance->get($item->getEncodedKey());
+
+		if (empty($val)) {
+			return null;
+		}
+
+		return $this->decode($val);
+	}
+
+	/**
+	 * @param ExtendedCacheItemInterface $item
+	 * @return mixed
+	 * @throws PhpfastcacheInvalidArgumentException
+	 * @throws PhpfastcacheLogicException
+	 */
+	protected function driverWrite(ExtendedCacheItemInterface $item): bool
+	{
+
+		return (bool)$this->instance->setx($item->getEncodedKey(), $this->encode($this->driverPreWrap($item)), $item->getTtl());
+	}
+
+	/**
+	 * @param string $key
+	 * @param string $encodedKey
+	 * @return bool
+	 */
+	protected function driverDelete(string $key, string $encodedKey): bool
+	{
+		return (bool)$this->instance->del($encodedKey);
+	}
+
+	/**
+	 * @return bool
+	 */
+	protected function driverClear(): bool
+	{
+		$this->instance->flushdb('kv');
+
+		// Status not returned, then we assume its true
+		return true;
+	}
 }

Spacing +2 added lines, -2 removed lines

@@ -112,7 +112,7 @@ 
     protected function driverWrite(ExtendedCacheItemInterface $item): bool
     {
 
-        return (bool)$this->instance->setx($item->getEncodedKey(), $this->encode($this->driverPreWrap($item)), $item->getTtl());
+        return (bool) $this->instance->setx($item->getEncodedKey(), $this->encode($this->driverPreWrap($item)), $item->getTtl());
     }
 
     /**
@@ -122,7 +122,7 @@ 
      */
     protected function driverDelete(string $key, string $encodedKey): bool
     {
-        return (bool)$this->instance->del($encodedKey);
+        return (bool) $this->instance->del($encodedKey);
     }
 
     /**

Braces +2 added lines, -1 removed lines

@@ -83,7 +83,8 @@
             $this->instance->ping();
 
             return true;
-        } catch (SSDBException $e) {
+        }
+        catch (SSDBException $e) {
             throw new PhpfastcacheDriverCheckException('Ssdb failed to connect with error: ' . $e->getMessage(), 0, $e);
         }
     }

plugins/files/php/vendor/phpfastcache/phpfastcache/lib/Phpfastcache/Drivers/Ssdb/Config.php

Indentation +67 added lines, -67 removed lines

@@ -21,79 +21,79 @@
 
 class Config extends ConfigurationOption
 {
-    protected string $host = '127.0.0.1';
-    protected int $port = 8888;
-    protected string $password = '';
-    protected int $timeout = 2000;
+	protected string $host = '127.0.0.1';
+	protected int $port = 8888;
+	protected string $password = '';
+	protected int $timeout = 2000;
 /**
-     * @return string
-     */
-    public function getHost(): string
-    {
-        return $this->host;
-    }
+	 * @return string
+	 */
+	public function getHost(): string
+	{
+		return $this->host;
+	}
 
-    /**
-     * @param string $host
-     * @return Config
-     * @throws PhpfastcacheLogicException
-     */
-    public function setHost(string $host): Config
-    {
-        return $this->setProperty('host', $host);
-    }
+	/**
+	 * @param string $host
+	 * @return Config
+	 * @throws PhpfastcacheLogicException
+	 */
+	public function setHost(string $host): Config
+	{
+		return $this->setProperty('host', $host);
+	}
 
-    /**
-     * @return int
-     */
-    public function getPort(): int
-    {
-        return $this->port;
-    }
+	/**
+	 * @return int
+	 */
+	public function getPort(): int
+	{
+		return $this->port;
+	}
 
-    /**
-     * @param int $port
-     * @return Config
-     * @throws PhpfastcacheLogicException
-     */
-    public function setPort(int $port): Config
-    {
-        return $this->setProperty('port', $port);
-    }
+	/**
+	 * @param int $port
+	 * @return Config
+	 * @throws PhpfastcacheLogicException
+	 */
+	public function setPort(int $port): Config
+	{
+		return $this->setProperty('port', $port);
+	}
 
-    /**
-     * @return string
-     */
-    public function getPassword(): string
-    {
-        return $this->password;
-    }
+	/**
+	 * @return string
+	 */
+	public function getPassword(): string
+	{
+		return $this->password;
+	}
 
-    /**
-     * @param string $password
-     * @return Config
-     * @throws PhpfastcacheLogicException
-     */
-    public function setPassword(string $password): Config
-    {
-        return $this->setProperty('password', $password);
-    }
+	/**
+	 * @param string $password
+	 * @return Config
+	 * @throws PhpfastcacheLogicException
+	 */
+	public function setPassword(string $password): Config
+	{
+		return $this->setProperty('password', $password);
+	}
 
-    /**
-     * @return int
-     */
-    public function getTimeout(): int
-    {
-        return $this->timeout;
-    }
+	/**
+	 * @return int
+	 */
+	public function getTimeout(): int
+	{
+		return $this->timeout;
+	}
 
-    /**
-     * @param int $timeout
-     * @return Config
-     * @throws PhpfastcacheLogicException
-     */
-    public function setTimeout(int $timeout): Config
-    {
-        return $this->setProperty('timeout', $timeout);
-    }
+	/**
+	 * @param int $timeout
+	 * @return Config
+	 * @throws PhpfastcacheLogicException
+	 */
+	public function setTimeout(int $timeout): Config
+	{
+		return $this->setProperty('timeout', $timeout);
+	}
 }

plugins/files/php/vendor/phpfastcache/phpfastcache/lib/Phpfastcache/Drivers/Apcu/Driver.php

Indentation +82 added lines, -82 removed lines

@@ -33,86 +33,86 @@
  */
 class Driver implements AggregatablePoolInterface
 {
-    use TaggableCacheItemPoolTrait;
-
-    /**
-     * @return bool
-     */
-    public function driverCheck(): bool
-    {
-        return extension_loaded('apcu') && ((ini_get('apc.enabled') && SapiDetector::isWebScript()) || (ini_get('apc.enable_cli') && SapiDetector::isCliScript()));
-    }
-
-    /**
-     * @return DriverStatistic
-     */
-    public function getStats(): DriverStatistic
-    {
-        $stats = (array)apcu_cache_info();
-        $date = (new DateTime())->setTimestamp($stats['start_time']);
-
-        return (new DriverStatistic())
-            ->setData(implode(', ', array_keys($this->itemInstances)))
-            ->setInfo(
-                sprintf(
-                    "The APCU cache is up since %s, and have %d item(s) in cache.\n For more information see RawData.",
-                    $date->format(DATE_RFC2822),
-                    $stats['num_entries']
-                )
-            )
-            ->setRawData($stats)
-            ->setSize((int)$stats['mem_size']);
-    }
-
-    /**
-     * @return bool
-     */
-    protected function driverConnect(): bool
-    {
-        return true;
-    }
-
-    /**
-     * @param ExtendedCacheItemInterface $item
-     * @return bool
-     * @throws PhpfastcacheInvalidArgumentException
-     */
-    protected function driverWrite(ExtendedCacheItemInterface $item): bool
-    {
-
-        return (bool)apcu_store($item->getKey(), $this->driverPreWrap($item), $item->getTtl());
-    }
-
-    /**
-     * @param ExtendedCacheItemInterface $item
-     * @return ?array<string, mixed>
-     */
-    protected function driverRead(ExtendedCacheItemInterface $item): ?array
-    {
-        $data = apcu_fetch($item->getKey(), $success);
-
-        if ($success === false || !\is_array($data)) {
-            return null;
-        }
-
-        return $data;
-    }
-
-    /**
-     * @param string $key
-     * @param string $encodedKey
-     * @return bool
-     */
-    protected function driverDelete(string $key, string $encodedKey): bool
-    {
-        return (bool)apcu_delete($key);
-    }
-
-    /**
-     * @return bool
-     */
-    protected function driverClear(): bool
-    {
-        return @apcu_clear_cache();
-    }
+	use TaggableCacheItemPoolTrait;
+
+	/**
+	 * @return bool
+	 */
+	public function driverCheck(): bool
+	{
+		return extension_loaded('apcu') && ((ini_get('apc.enabled') && SapiDetector::isWebScript()) || (ini_get('apc.enable_cli') && SapiDetector::isCliScript()));
+	}
+
+	/**
+	 * @return DriverStatistic
+	 */
+	public function getStats(): DriverStatistic
+	{
+		$stats = (array)apcu_cache_info();
+		$date = (new DateTime())->setTimestamp($stats['start_time']);
+
+		return (new DriverStatistic())
+			->setData(implode(', ', array_keys($this->itemInstances)))
+			->setInfo(
+				sprintf(
+					"The APCU cache is up since %s, and have %d item(s) in cache.\n For more information see RawData.",
+					$date->format(DATE_RFC2822),
+					$stats['num_entries']
+				)
+			)
+			->setRawData($stats)
+			->setSize((int)$stats['mem_size']);
+	}
+
+	/**
+	 * @return bool
+	 */
+	protected function driverConnect(): bool
+	{
+		return true;
+	}
+
+	/**
+	 * @param ExtendedCacheItemInterface $item
+	 * @return bool
+	 * @throws PhpfastcacheInvalidArgumentException
+	 */
+	protected function driverWrite(ExtendedCacheItemInterface $item): bool
+	{
+
+		return (bool)apcu_store($item->getKey(), $this->driverPreWrap($item), $item->getTtl());
+	}
+
+	/**
+	 * @param ExtendedCacheItemInterface $item
+	 * @return ?array<string, mixed>
+	 */
+	protected function driverRead(ExtendedCacheItemInterface $item): ?array
+	{
+		$data = apcu_fetch($item->getKey(), $success);
+
+		if ($success === false || !\is_array($data)) {
+			return null;
+		}
+
+		return $data;
+	}
+
+	/**
+	 * @param string $key
+	 * @param string $encodedKey
+	 * @return bool
+	 */
+	protected function driverDelete(string $key, string $encodedKey): bool
+	{
+		return (bool)apcu_delete($key);
+	}
+
+	/**
+	 * @return bool
+	 */
+	protected function driverClear(): bool
+	{
+		return @apcu_clear_cache();
+	}
 }

Spacing +4 added lines, -4 removed lines

@@ -48,7 +48,7 @@ 
      */
     public function getStats(): DriverStatistic
     {
-        $stats = (array)apcu_cache_info();
+        $stats = (array) apcu_cache_info();
         $date = (new DateTime())->setTimestamp($stats['start_time']);
 
         return (new DriverStatistic())
@@ -61,7 +61,7 @@ 
                 )
             )
             ->setRawData($stats)
-            ->setSize((int)$stats['mem_size']);
+            ->setSize((int) $stats['mem_size']);
     }
 
     /**
@@ -80,7 +80,7 @@ 
     protected function driverWrite(ExtendedCacheItemInterface $item): bool
     {
 
-        return (bool)apcu_store($item->getKey(), $this->driverPreWrap($item), $item->getTtl());
+        return (bool) apcu_store($item->getKey(), $this->driverPreWrap($item), $item->getTtl());
     }
 
     /**
@@ -105,7 +105,7 @@ 
      */
     protected function driverDelete(string $key, string $encodedKey): bool
     {
-        return (bool)apcu_delete($key);
+        return (bool) apcu_delete($key);
     }
 
     /**

plugins/files/php/vendor/phpfastcache/phpfastcache/lib/Phpfastcache/Drivers/Cassandra/Driver.php

Indentation +253 added lines, -253 removed lines

@@ -36,72 +36,72 @@ 
  */
 class Driver implements AggregatablePoolInterface
 {
-    use TaggableCacheItemPoolTrait;
-
-    protected const CASSANDRA_KEY_SPACE = 'phpfastcache';
-    protected const CASSANDRA_TABLE = 'cacheItems';
-
-    /**
-     * @return bool
-     */
-    public function driverCheck(): bool
-    {
-        return extension_loaded('Cassandra') && class_exists(Cassandra::class);
-    }
-
-    /**
-     * @return bool
-     * @throws PhpfastcacheLogicException
-     * @throws Exception
-     */
-    protected function driverConnect(): bool
-    {
-        $clientConfig = $this->getConfig();
-
-        $clusterBuilder = Cassandra::cluster()
-            ->withContactPoints($clientConfig->getHost())
-            ->withPort($clientConfig->getPort());
-
-        if (!empty($clientConfig->isSslEnabled())) {
-            $sslBuilder = Cassandra::ssl();
-            if (!empty($clientConfig->isSslVerify())) {
-                $sslBuilder->withVerifyFlags(Cassandra::VERIFY_PEER_CERT);
-            } else {
-                $sslBuilder->withVerifyFlags(Cassandra::VERIFY_NONE);
-            }
-
-            $clusterBuilder->withSSL($sslBuilder->build());
-        }
-
-        $clusterBuilder->withConnectTimeout($clientConfig->getTimeout());
-
-        if ($clientConfig->getUsername()) {
-            $clusterBuilder->withCredentials($clientConfig->getUsername(), $clientConfig->getPassword());
-        }
-
-        $this->instance = $clusterBuilder->build()->connect('');
-
-        /**
-         * In case of emergency:
-         * $this->instance->execute(
-         *      new Cassandra\SimpleStatement(\sprintf("DROP KEYSPACE %s;", self::CASSANDRA_KEY_SPACE))
-         * );
-         */
-
-        $this->instance->execute(
-            new Cassandra\SimpleStatement(
-                sprintf(
-                    "CREATE KEYSPACE IF NOT EXISTS %s WITH REPLICATION = { 'class' : 'SimpleStrategy', 'replication_factor' : 1 };",
-                    self::CASSANDRA_KEY_SPACE
-                )
-            ),
-            []
-        );
-        $this->instance->execute(new Cassandra\SimpleStatement(sprintf('USE %s;', self::CASSANDRA_KEY_SPACE)), []);
-        $this->instance->execute(
-            new Cassandra\SimpleStatement(
-                sprintf(
-                    '
+	use TaggableCacheItemPoolTrait;
+
+	protected const CASSANDRA_KEY_SPACE = 'phpfastcache';
+	protected const CASSANDRA_TABLE = 'cacheItems';
+
+	/**
+	 * @return bool
+	 */
+	public function driverCheck(): bool
+	{
+		return extension_loaded('Cassandra') && class_exists(Cassandra::class);
+	}
+
+	/**
+	 * @return bool
+	 * @throws PhpfastcacheLogicException
+	 * @throws Exception
+	 */
+	protected function driverConnect(): bool
+	{
+		$clientConfig = $this->getConfig();
+
+		$clusterBuilder = Cassandra::cluster()
+			->withContactPoints($clientConfig->getHost())
+			->withPort($clientConfig->getPort());
+
+		if (!empty($clientConfig->isSslEnabled())) {
+			$sslBuilder = Cassandra::ssl();
+			if (!empty($clientConfig->isSslVerify())) {
+				$sslBuilder->withVerifyFlags(Cassandra::VERIFY_PEER_CERT);
+			} else {
+				$sslBuilder->withVerifyFlags(Cassandra::VERIFY_NONE);
+			}
+
+			$clusterBuilder->withSSL($sslBuilder->build());
+		}
+
+		$clusterBuilder->withConnectTimeout($clientConfig->getTimeout());
+
+		if ($clientConfig->getUsername()) {
+			$clusterBuilder->withCredentials($clientConfig->getUsername(), $clientConfig->getPassword());
+		}
+
+		$this->instance = $clusterBuilder->build()->connect('');
+
+		/**
+		 * In case of emergency:
+		 * $this->instance->execute(
+		 *      new Cassandra\SimpleStatement(\sprintf("DROP KEYSPACE %s;", self::CASSANDRA_KEY_SPACE))
+		 * );
+		 */
+
+		$this->instance->execute(
+			new Cassandra\SimpleStatement(
+				sprintf(
+					"CREATE KEYSPACE IF NOT EXISTS %s WITH REPLICATION = { 'class' : 'SimpleStrategy', 'replication_factor' : 1 };",
+					self::CASSANDRA_KEY_SPACE
+				)
+			),
+			[]
+		);
+		$this->instance->execute(new Cassandra\SimpleStatement(sprintf('USE %s;', self::CASSANDRA_KEY_SPACE)), []);
+		$this->instance->execute(
+			new Cassandra\SimpleStatement(
+				sprintf(
+					'
                 CREATE TABLE IF NOT EXISTS %s (
                     cache_uuid uuid,
                     cache_id varchar,
@@ -111,72 +111,72 @@ 
                     cache_length int,
                     PRIMARY KEY (cache_id)
                 );',
-                    self::CASSANDRA_TABLE
-                )
-            ),
-            []
-        );
-
-        return true;
-    }
-
-    /**
-     * @param ExtendedCacheItemInterface $item
-     * @return ?array<string, mixed>
-     */
-    protected function driverRead(ExtendedCacheItemInterface $item): ?array
-    {
-        try {
-            $options = $this->getCompatibleExecutionOptionsArgument(
-                [
-                    'arguments' => ['cache_id' => $item->getKey()],
-                    'page_size' => 1,
-                ]
-            );
-            $query = sprintf(
-                'SELECT cache_data FROM %s.%s WHERE cache_id = :cache_id;',
-                self::CASSANDRA_KEY_SPACE,
-                self::CASSANDRA_TABLE
-            );
-            $results = $this->instance->execute(new Cassandra\SimpleStatement($query), $options);
-
-            if ($results instanceof Cassandra\Rows && $results->count() === 1) {
-                return $this->decode($results->first()['cache_data']) ?: null;
-            }
-
-            return null;
-        } catch (Exception $e) {
-            return null;
-        }
-    }
-
-    /**
-     * @param ExtendedCacheItemInterface $item
-     * @return bool
-     * @throws PhpfastcacheInvalidArgumentException
-     */
-    protected function driverWrite(ExtendedCacheItemInterface $item): bool
-    {
-
-        try {
-            $cacheData = $this->encode($this->driverPreWrap($item));
-            $options = $this->getCompatibleExecutionOptionsArgument(
-                [
-                    'arguments' => [
-                        'cache_uuid' => new Cassandra\Uuid(''),
-                        'cache_id' => $item->getKey(),
-                        'cache_data' => $cacheData,
-                        'cache_creation_date' => new Cassandra\Timestamp((new DateTime())->getTimestamp(), 0),
-                        'cache_expiration_date' => new Cassandra\Timestamp($item->getExpirationDate()->getTimestamp(), 0),
-                        'cache_length' => strlen($cacheData),
-                    ],
-                    'consistency' => Cassandra::CONSISTENCY_ALL,
-                    'serial_consistency' => Cassandra::CONSISTENCY_SERIAL,
-                ]
-            );
-
-            $query = sprintf(
-                'INSERT INTO %s.%s
+					self::CASSANDRA_TABLE
+				)
+			),
+			[]
+		);
+
+		return true;
+	}
+
+	/**
+	 * @param ExtendedCacheItemInterface $item
+	 * @return ?array<string, mixed>
+	 */
+	protected function driverRead(ExtendedCacheItemInterface $item): ?array
+	{
+		try {
+			$options = $this->getCompatibleExecutionOptionsArgument(
+				[
+					'arguments' => ['cache_id' => $item->getKey()],
+					'page_size' => 1,
+				]
+			);
+			$query = sprintf(
+				'SELECT cache_data FROM %s.%s WHERE cache_id = :cache_id;',
+				self::CASSANDRA_KEY_SPACE,
+				self::CASSANDRA_TABLE
+			);
+			$results = $this->instance->execute(new Cassandra\SimpleStatement($query), $options);
+
+			if ($results instanceof Cassandra\Rows && $results->count() === 1) {
+				return $this->decode($results->first()['cache_data']) ?: null;
+			}
+
+			return null;
+		} catch (Exception $e) {
+			return null;
+		}
+	}
+
+	/**
+	 * @param ExtendedCacheItemInterface $item
+	 * @return bool
+	 * @throws PhpfastcacheInvalidArgumentException
+	 */
+	protected function driverWrite(ExtendedCacheItemInterface $item): bool
+	{
+
+		try {
+			$cacheData = $this->encode($this->driverPreWrap($item));
+			$options = $this->getCompatibleExecutionOptionsArgument(
+				[
+					'arguments' => [
+						'cache_uuid' => new Cassandra\Uuid(''),
+						'cache_id' => $item->getKey(),
+						'cache_data' => $cacheData,
+						'cache_creation_date' => new Cassandra\Timestamp((new DateTime())->getTimestamp(), 0),
+						'cache_expiration_date' => new Cassandra\Timestamp($item->getExpirationDate()->getTimestamp(), 0),
+						'cache_length' => strlen($cacheData),
+					],
+					'consistency' => Cassandra::CONSISTENCY_ALL,
+					'serial_consistency' => Cassandra::CONSISTENCY_SERIAL,
+				]
+			);
+
+			$query = sprintf(
+				'INSERT INTO %s.%s
                     (
                       cache_uuid, 
                       cache_id, 
@@ -187,89 +187,89 @@ 
                     )
                   VALUES (:cache_uuid, :cache_id, :cache_data, :cache_creation_date, :cache_expiration_date, :cache_length);
             ',
-                self::CASSANDRA_KEY_SPACE,
-                self::CASSANDRA_TABLE
-            );
-
-            $result = $this->instance->execute(new Cassandra\SimpleStatement($query), $options);
-            /**
-             * There's no real way atm
-             * to know if the item has
-             * been really upserted
-             */
-            return $result instanceof Cassandra\Rows;
-        } catch (InvalidArgumentException $e) {
-            throw new PhpfastcacheInvalidArgumentException($e->getMessage(), 0, $e);
-        }
-    }
-
-    /**
-     * @param string $key
-     * @param string $encodedKey
-     * @return bool
-     */
-    protected function driverDelete(string $key, string $encodedKey): bool
-    {
-
-        try {
-            $options = $this->getCompatibleExecutionOptionsArgument(
-                [
-                    'arguments' => [
-                        'cache_id' => $key,
-                    ],
-                ]
-            );
-            $result = $this->instance->execute(
-                new Cassandra\SimpleStatement(
-                    sprintf(
-                        'DELETE FROM %s.%s WHERE cache_id = :cache_id;',
-                        self::CASSANDRA_KEY_SPACE,
-                        self::CASSANDRA_TABLE
-                    )
-                ),
-                $options
-            );
-
-            /**
-             * There's no real way atm
-             * to know if the item has
-             * been really deleted
-             */
-            return $result instanceof Cassandra\Rows;
-        } catch (Exception $e) {
-            return false;
-        }
-    }
-
-    /**
-     * @return bool
-     */
-    protected function driverClear(): bool
-    {
-        try {
-            $this->instance->execute(
-                new Cassandra\SimpleStatement(
-                    sprintf(
-                        'TRUNCATE %s.%s;',
-                        self::CASSANDRA_KEY_SPACE,
-                        self::CASSANDRA_TABLE
-                    )
-                ),
-                null
-            );
-
-            return true;
-        } catch (Exception) {
-            return false;
-        }
-    }
-
-    /**
-     * @return string
-     */
-    public function getHelp(): string
-    {
-        return <<<HELP
+				self::CASSANDRA_KEY_SPACE,
+				self::CASSANDRA_TABLE
+			);
+
+			$result = $this->instance->execute(new Cassandra\SimpleStatement($query), $options);
+			/**
+			 * There's no real way atm
+			 * to know if the item has
+			 * been really upserted
+			 */
+			return $result instanceof Cassandra\Rows;
+		} catch (InvalidArgumentException $e) {
+			throw new PhpfastcacheInvalidArgumentException($e->getMessage(), 0, $e);
+		}
+	}
+
+	/**
+	 * @param string $key
+	 * @param string $encodedKey
+	 * @return bool
+	 */
+	protected function driverDelete(string $key, string $encodedKey): bool
+	{
+
+		try {
+			$options = $this->getCompatibleExecutionOptionsArgument(
+				[
+					'arguments' => [
+						'cache_id' => $key,
+					],
+				]
+			);
+			$result = $this->instance->execute(
+				new Cassandra\SimpleStatement(
+					sprintf(
+						'DELETE FROM %s.%s WHERE cache_id = :cache_id;',
+						self::CASSANDRA_KEY_SPACE,
+						self::CASSANDRA_TABLE
+					)
+				),
+				$options
+			);
+
+			/**
+			 * There's no real way atm
+			 * to know if the item has
+			 * been really deleted
+			 */
+			return $result instanceof Cassandra\Rows;
+		} catch (Exception $e) {
+			return false;
+		}
+	}
+
+	/**
+	 * @return bool
+	 */
+	protected function driverClear(): bool
+	{
+		try {
+			$this->instance->execute(
+				new Cassandra\SimpleStatement(
+					sprintf(
+						'TRUNCATE %s.%s;',
+						self::CASSANDRA_KEY_SPACE,
+						self::CASSANDRA_TABLE
+					)
+				),
+				null
+			);
+
+			return true;
+		} catch (Exception) {
+			return false;
+		}
+	}
+
+	/**
+	 * @return string
+	 */
+	public function getHelp(): string
+	{
+		return <<<HELP
 <p>
 To install the php Cassandra extension via Pecl:
 <code>sudo pecl install cassandra</code>
@@ -277,42 +277,42 @@ 
 Please note that this repository only provide php stubs and C/C++ sources, it does NOT provide php client.
 </p>
 HELP;
-    }
-
-    /**
-     * @return DriverStatistic
-     * @throws Exception
-     */
-    public function getStats(): DriverStatistic
-    {
-        $result = $this->instance->execute(
-            new Cassandra\SimpleStatement(
-                sprintf(
-                    'SELECT SUM(cache_length) as cache_size FROM %s.%s',
-                    self::CASSANDRA_KEY_SPACE,
-                    self::CASSANDRA_TABLE
-                )
-            ),
-            null
-        );
-
-        return (new DriverStatistic())
-            ->setSize($result->first()['cache_size'])
-            ->setRawData([])
-            ->setData(implode(', ', array_keys($this->itemInstances)))
-            ->setInfo('The cache size represents only the cache data itself without counting data structures associated to the cache entries.');
-    }
-
-    /**
-     * @param array<string, mixed> $options
-     * @return array<string, mixed>|Cassandra\ExecutionOptions
-     */
-    protected function getCompatibleExecutionOptionsArgument(array $options): mixed
-    {
-        if ($this->getConfig()->isUseLegacyExecutionOptions()) {
-            return new Cassandra\ExecutionOptions($options);
-        }
-
-        return $options;
-    }
+	}
+
+	/**
+	 * @return DriverStatistic
+	 * @throws Exception
+	 */
+	public function getStats(): DriverStatistic
+	{
+		$result = $this->instance->execute(
+			new Cassandra\SimpleStatement(
+				sprintf(
+					'SELECT SUM(cache_length) as cache_size FROM %s.%s',
+					self::CASSANDRA_KEY_SPACE,
+					self::CASSANDRA_TABLE
+				)
+			),
+			null
+		);
+
+		return (new DriverStatistic())
+			->setSize($result->first()['cache_size'])
+			->setRawData([])
+			->setData(implode(', ', array_keys($this->itemInstances)))
+			->setInfo('The cache size represents only the cache data itself without counting data structures associated to the cache entries.');
+	}
+
+	/**
+	 * @param array<string, mixed> $options
+	 * @return array<string, mixed>|Cassandra\ExecutionOptions
+	 */
+	protected function getCompatibleExecutionOptionsArgument(array $options): mixed
+	{
+		if ($this->getConfig()->isUseLegacyExecutionOptions()) {
+			return new Cassandra\ExecutionOptions($options);
+		}
+
+		return $options;
+	}
 }

Braces +10 added lines, -5 removed lines

@@ -66,7 +66,8 @@ 
             $sslBuilder = Cassandra::ssl();
             if (!empty($clientConfig->isSslVerify())) {
                 $sslBuilder->withVerifyFlags(Cassandra::VERIFY_PEER_CERT);
-            } else {
+            }
+            else {
                 $sslBuilder->withVerifyFlags(Cassandra::VERIFY_NONE);
             }
 
@@ -145,7 +146,8 @@ 
             }
 
             return null;
-        } catch (Exception $e) {
+        }
+        catch (Exception $e) {
             return null;
         }
     }
@@ -198,7 +200,8 @@ 
              * been really upserted
              */
             return $result instanceof Cassandra\Rows;
-        } catch (InvalidArgumentException $e) {
+        }
+        catch (InvalidArgumentException $e) {
             throw new PhpfastcacheInvalidArgumentException($e->getMessage(), 0, $e);
         }
     }
@@ -236,7 +239,8 @@ 
              * been really deleted
              */
             return $result instanceof Cassandra\Rows;
-        } catch (Exception $e) {
+        }
+        catch (Exception $e) {
             return false;
         }
     }
@@ -259,7 +263,8 @@ 
             );
 
             return true;
-        } catch (Exception) {
+        }
+        catch (Exception) {
             return false;
         }
     }