grommunio / grommunio-web

plugins/files/php/lib/phpfastcache/lib/Phpfastcache/Drivers/Redis/Item.php

Indentation +30 added lines, -30 removed lines

@@ -27,34 +27,34 @@
  */
 class Item implements ExtendedCacheItemInterface
 {
-    use ItemBaseTrait {
-        ItemBaseTrait::__construct as __BaseConstruct;
-    }
-
-    /**
-     * Item constructor.
-     * @param Driver $driver
-     * @param $key
-     * @throws PhpfastcacheInvalidArgumentException
-     */
-    public function __construct(RedisDriver $driver, $key)
-    {
-        $this->__BaseConstruct($driver, $key);
-    }
-
-    /**
-     * @param ExtendedCacheItemPoolInterface $driver
-     * @return static
-     * @throws PhpfastcacheInvalidArgumentException
-     */
-    public function setDriver(ExtendedCacheItemPoolInterface $driver)
-    {
-        if ($driver instanceof RedisDriver) {
-            $this->driver = $driver;
-
-            return $this;
-        }
-
-        throw new PhpfastcacheInvalidArgumentException('Invalid driver instance');
-    }
+	use ItemBaseTrait {
+		ItemBaseTrait::__construct as __BaseConstruct;
+	}
+
+	/**
+	 * Item constructor.
+	 * @param Driver $driver
+	 * @param $key
+	 * @throws PhpfastcacheInvalidArgumentException
+	 */
+	public function __construct(RedisDriver $driver, $key)
+	{
+		$this->__BaseConstruct($driver, $key);
+	}
+
+	/**
+	 * @param ExtendedCacheItemPoolInterface $driver
+	 * @return static
+	 * @throws PhpfastcacheInvalidArgumentException
+	 */
+	public function setDriver(ExtendedCacheItemPoolInterface $driver)
+	{
+		if ($driver instanceof RedisDriver) {
+			$this->driver = $driver;
+
+			return $this;
+		}
+
+		throw new PhpfastcacheInvalidArgumentException('Invalid driver instance');
+	}
 }
\ No newline at end of file

plugins/files/php/lib/phpfastcache/lib/Phpfastcache/Drivers/Redis/Driver.php

Indentation +150 added lines, -150 removed lines

@@ -33,159 +33,159 @@
  */
 class Driver implements ExtendedCacheItemPoolInterface, AggregatablePoolInterface
 {
-    use DriverBaseTrait;
-
-    /**
-     * @return bool
-     */
-    public function driverCheck(): bool
-    {
-        return extension_loaded('Redis');
-    }
-
-    /**
-     * @return DriverStatistic
-     */
-    public function getStats(): DriverStatistic
-    {
-        // used_memory
-        $info = $this->instance->info();
-        $date = (new DateTime())->setTimestamp(time() - $info['uptime_in_seconds']);
-
-        return (new DriverStatistic())
-            ->setData(implode(', ', array_keys($this->itemInstances)))
-            ->setRawData($info)
-            ->setSize((int)$info['used_memory'])
-            ->setInfo(
-                sprintf(
-                    "The Redis daemon v%s is up since %s.\n For more information see RawData. \n Driver size includes the memory allocation size.",
-                    $info['redis_version'],
-                    $date->format(DATE_RFC2822)
-                )
-            );
-    }
-
-    /**
-     * @return bool
-     * @throws PhpfastcacheLogicException
-     */
-    protected function driverConnect(): bool
-    {
-        if ($this->instance instanceof RedisClient) {
-            throw new PhpfastcacheLogicException('Already connected to Redis server');
-        }
-
-        /**
-         * In case of an user-provided
-         * Redis client just return here
-         */
-        if ($this->getConfig()->getRedisClient() instanceof RedisClient) {
-            /**
-             * Unlike Predis, we can't test if we're are connected
-             * or not, so let's just assume that we are
-             */
-            $this->instance = $this->getConfig()->getRedisClient();
-            return true;
-        }
-
-        $this->instance = $this->instance ?: new RedisClient();
-
-        /**
-         * If path is provided we consider it as an UNIX Socket
-         */
-        if ($this->getConfig()->getPath()) {
-            $isConnected = $this->instance->connect($this->getConfig()->getPath());
-        } else {
-            $isConnected = $this->instance->connect($this->getConfig()->getHost(), $this->getConfig()->getPort(), $this->getConfig()->getTimeout());
-        }
-
-        if (!$isConnected && $this->getConfig()->getPath()) {
-            return false;
-        }
-
-        if ($this->getConfig()->getOptPrefix()) {
-            $this->instance->setOption(RedisClient::OPT_PREFIX, $this->getConfig()->getOptPrefix());
-        }
-
-        if ($this->getConfig()->getPassword() && !$this->instance->auth($this->getConfig()->getPassword())) {
-            return false;
-        }
-
-        if ($this->getConfig()->getDatabase() !== null) {
-            $this->instance->select($this->getConfig()->getDatabase());
-        }
-        return true;
-    }
-
-    /**
-     * @param CacheItemInterface $item
-     * @return null|array
-     */
-    protected function driverRead(CacheItemInterface $item)
-    {
-        $val = $this->instance->get($item->getKey());
-        if ($val == false) {
-            return null;
-        }
-
-        return $this->decode($val);
-    }
-
-    /**
-     * @param CacheItemInterface $item
-     * @return mixed
-     * @throws PhpfastcacheInvalidArgumentException
-     */
-    protected function driverWrite(CacheItemInterface $item): bool
-    {
-        /**
-         * Check for Cross-Driver type confusion
-         */
-        if ($item instanceof Item) {
-            $ttl = $item->getExpirationDate()->getTimestamp() - time();
-
-            /**
-             * @see https://redis.io/commands/setex
-             * @see https://redis.io/commands/expire
-             */
-            if ($ttl <= 0) {
-                return $this->instance->expire($item->getKey(), 0);
-            }
-
-            return $this->instance->setex($item->getKey(), $ttl, $this->encode($this->driverPreWrap($item)));
-        }
-
-        throw new PhpfastcacheInvalidArgumentException('Cross-Driver type confusion detected');
-    }
-
-    /**
-     * @param CacheItemInterface $item
-     * @return bool
-     * @throws PhpfastcacheInvalidArgumentException
-     */
-    protected function driverDelete(CacheItemInterface $item): bool
-    {
-        /**
-         * Check for Cross-Driver type confusion
-         */
-        if ($item instanceof Item) {
-            return (bool)$this->instance->del($item->getKey());
-        }
-
-        throw new PhpfastcacheInvalidArgumentException('Cross-Driver type confusion detected');
-    }
-
-    /********************
+	use DriverBaseTrait;
+
+	/**
+	 * @return bool
+	 */
+	public function driverCheck(): bool
+	{
+		return extension_loaded('Redis');
+	}
+
+	/**
+	 * @return DriverStatistic
+	 */
+	public function getStats(): DriverStatistic
+	{
+		// used_memory
+		$info = $this->instance->info();
+		$date = (new DateTime())->setTimestamp(time() - $info['uptime_in_seconds']);
+
+		return (new DriverStatistic())
+			->setData(implode(', ', array_keys($this->itemInstances)))
+			->setRawData($info)
+			->setSize((int)$info['used_memory'])
+			->setInfo(
+				sprintf(
+					"The Redis daemon v%s is up since %s.\n For more information see RawData. \n Driver size includes the memory allocation size.",
+					$info['redis_version'],
+					$date->format(DATE_RFC2822)
+				)
+			);
+	}
+
+	/**
+	 * @return bool
+	 * @throws PhpfastcacheLogicException
+	 */
+	protected function driverConnect(): bool
+	{
+		if ($this->instance instanceof RedisClient) {
+			throw new PhpfastcacheLogicException('Already connected to Redis server');
+		}
+
+		/**
+		 * In case of an user-provided
+		 * Redis client just return here
+		 */
+		if ($this->getConfig()->getRedisClient() instanceof RedisClient) {
+			/**
+			 * Unlike Predis, we can't test if we're are connected
+			 * or not, so let's just assume that we are
+			 */
+			$this->instance = $this->getConfig()->getRedisClient();
+			return true;
+		}
+
+		$this->instance = $this->instance ?: new RedisClient();
+
+		/**
+		 * If path is provided we consider it as an UNIX Socket
+		 */
+		if ($this->getConfig()->getPath()) {
+			$isConnected = $this->instance->connect($this->getConfig()->getPath());
+		} else {
+			$isConnected = $this->instance->connect($this->getConfig()->getHost(), $this->getConfig()->getPort(), $this->getConfig()->getTimeout());
+		}
+
+		if (!$isConnected && $this->getConfig()->getPath()) {
+			return false;
+		}
+
+		if ($this->getConfig()->getOptPrefix()) {
+			$this->instance->setOption(RedisClient::OPT_PREFIX, $this->getConfig()->getOptPrefix());
+		}
+
+		if ($this->getConfig()->getPassword() && !$this->instance->auth($this->getConfig()->getPassword())) {
+			return false;
+		}
+
+		if ($this->getConfig()->getDatabase() !== null) {
+			$this->instance->select($this->getConfig()->getDatabase());
+		}
+		return true;
+	}
+
+	/**
+	 * @param CacheItemInterface $item
+	 * @return null|array
+	 */
+	protected function driverRead(CacheItemInterface $item)
+	{
+		$val = $this->instance->get($item->getKey());
+		if ($val == false) {
+			return null;
+		}
+
+		return $this->decode($val);
+	}
+
+	/**
+	 * @param CacheItemInterface $item
+	 * @return mixed
+	 * @throws PhpfastcacheInvalidArgumentException
+	 */
+	protected function driverWrite(CacheItemInterface $item): bool
+	{
+		/**
+		 * Check for Cross-Driver type confusion
+		 */
+		if ($item instanceof Item) {
+			$ttl = $item->getExpirationDate()->getTimestamp() - time();
+
+			/**
+			 * @see https://redis.io/commands/setex
+			 * @see https://redis.io/commands/expire
+			 */
+			if ($ttl <= 0) {
+				return $this->instance->expire($item->getKey(), 0);
+			}
+
+			return $this->instance->setex($item->getKey(), $ttl, $this->encode($this->driverPreWrap($item)));
+		}
+
+		throw new PhpfastcacheInvalidArgumentException('Cross-Driver type confusion detected');
+	}
+
+	/**
+	 * @param CacheItemInterface $item
+	 * @return bool
+	 * @throws PhpfastcacheInvalidArgumentException
+	 */
+	protected function driverDelete(CacheItemInterface $item): bool
+	{
+		/**
+		 * Check for Cross-Driver type confusion
+		 */
+		if ($item instanceof Item) {
+			return (bool)$this->instance->del($item->getKey());
+		}
+
+		throw new PhpfastcacheInvalidArgumentException('Cross-Driver type confusion detected');
+	}
+
+	/********************
      *
      * PSR-6 Extended Methods
      *
      *******************/
 
-    /**
-     * @return bool
-     */
-    protected function driverClear(): bool
-    {
-        return $this->instance->flushDB();
-    }
+	/**
+	 * @return bool
+	 */
+	protected function driverClear(): bool
+	{
+		return $this->instance->flushDB();
+	}
 }

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

Indentation +226 added lines, -226 removed lines

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

plugins/files/php/lib/phpfastcache/lib/Phpfastcache/Drivers/Predis/Item.php

Indentation +30 added lines, -30 removed lines

@@ -27,34 +27,34 @@
  */
 class Item implements ExtendedCacheItemInterface
 {
-    use ItemBaseTrait {
-        ItemBaseTrait::__construct as __BaseConstruct;
-    }
-
-    /**
-     * Item constructor.
-     * @param Driver $driver
-     * @param $key
-     * @throws PhpfastcacheInvalidArgumentException
-     */
-    public function __construct(PredisDriver $driver, $key)
-    {
-        $this->__BaseConstruct($driver, $key);
-    }
-
-    /**
-     * @param ExtendedCacheItemPoolInterface $driver
-     * @return static
-     * @throws PhpfastcacheInvalidArgumentException
-     */
-    public function setDriver(ExtendedCacheItemPoolInterface $driver)
-    {
-        if ($driver instanceof PredisDriver) {
-            $this->driver = $driver;
-
-            return $this;
-        }
-
-        throw new PhpfastcacheInvalidArgumentException('Invalid driver instance');
-    }
+	use ItemBaseTrait {
+		ItemBaseTrait::__construct as __BaseConstruct;
+	}
+
+	/**
+	 * Item constructor.
+	 * @param Driver $driver
+	 * @param $key
+	 * @throws PhpfastcacheInvalidArgumentException
+	 */
+	public function __construct(PredisDriver $driver, $key)
+	{
+		$this->__BaseConstruct($driver, $key);
+	}
+
+	/**
+	 * @param ExtendedCacheItemPoolInterface $driver
+	 * @return static
+	 * @throws PhpfastcacheInvalidArgumentException
+	 */
+	public function setDriver(ExtendedCacheItemPoolInterface $driver)
+	{
+		if ($driver instanceof PredisDriver) {
+			$this->driver = $driver;
+
+			return $this;
+		}
+
+		throw new PhpfastcacheInvalidArgumentException('Invalid driver instance');
+	}
 }
\ No newline at end of file

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

Indentation +166 added lines, -166 removed lines

@@ -35,180 +35,180 @@
  */
 class Driver implements ExtendedCacheItemPoolInterface, AggregatablePoolInterface
 {
-    use DriverBaseTrait;
-
-    /**
-     * @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');
-    }
-
-    /**
-     * @return string
-     */
-    public function getHelp(): string
-    {
-        return <<<HELP
+	use DriverBaseTrait;
+
+	/**
+	 * @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');
+	}
+
+	/**
+	 * @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 = (isset($info['Memory']['used_memory']) ? $info['Memory']['used_memory'] : 0);
-        $version = (isset($info['Server']['redis_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 is up since %s.\n For more information see RawData. \n Driver size includes the memory allocation size.",
-                    $version,
-                    $date->format(DATE_RFC2822)
-                )
-            );
-    }
-
-    /**
-     * @return bool
-     * @throws PhpfastcacheDriverException
-     * @throws PhpfastcacheLogicException
-     */
-    protected function driverConnect(): bool
-    {
-        if ($this->instance instanceof PredisClient) {
-            throw new PhpfastcacheLogicException('Already connected to Predis server');
-        }
-
-        /**
-         * In case of an 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 CacheItemInterface $item
-     * @return null|array
-     */
-    protected function driverRead(CacheItemInterface $item)
-    {
-        $val = $this->instance->get($item->getKey());
-        if ($val == false) {
-            return null;
-        }
-
-        return $this->decode($val);
-    }
-
-    /**
-     * @param CacheItemInterface $item
-     * @return mixed
-     * @throws PhpfastcacheInvalidArgumentException
-     */
-    protected function driverWrite(CacheItemInterface $item): bool
-    {
-        /**
-         * Check for Cross-Driver type confusion
-         */
-        if ($item instanceof Item) {
-            $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';
-        }
-
-        throw new PhpfastcacheInvalidArgumentException('Cross-Driver type confusion detected');
-    }
-
-    /********************
+	}
+
+	/**
+	 * @return DriverStatistic
+	 */
+	public function getStats(): DriverStatistic
+	{
+		$info = $this->instance->info();
+		$size = (isset($info['Memory']['used_memory']) ? $info['Memory']['used_memory'] : 0);
+		$version = (isset($info['Server']['redis_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 is up since %s.\n For more information see RawData. \n Driver size includes the memory allocation size.",
+					$version,
+					$date->format(DATE_RFC2822)
+				)
+			);
+	}
+
+	/**
+	 * @return bool
+	 * @throws PhpfastcacheDriverException
+	 * @throws PhpfastcacheLogicException
+	 */
+	protected function driverConnect(): bool
+	{
+		if ($this->instance instanceof PredisClient) {
+			throw new PhpfastcacheLogicException('Already connected to Predis server');
+		}
+
+		/**
+		 * In case of an 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 CacheItemInterface $item
+	 * @return null|array
+	 */
+	protected function driverRead(CacheItemInterface $item)
+	{
+		$val = $this->instance->get($item->getKey());
+		if ($val == false) {
+			return null;
+		}
+
+		return $this->decode($val);
+	}
+
+	/**
+	 * @param CacheItemInterface $item
+	 * @return mixed
+	 * @throws PhpfastcacheInvalidArgumentException
+	 */
+	protected function driverWrite(CacheItemInterface $item): bool
+	{
+		/**
+		 * Check for Cross-Driver type confusion
+		 */
+		if ($item instanceof Item) {
+			$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';
+		}
+
+		throw new PhpfastcacheInvalidArgumentException('Cross-Driver type confusion detected');
+	}
+
+	/********************
      *
      * PSR-6 Extended Methods
      *
      *******************/
 
-    /**
-     * @param CacheItemInterface $item
-     * @return bool
-     * @throws PhpfastcacheInvalidArgumentException
-     */
-    protected function driverDelete(CacheItemInterface $item): bool
-    {
-        /**
-         * Check for Cross-Driver type confusion
-         */
-        if ($item instanceof Item) {
-            return (bool)$this->instance->del([$item->getKey()]);
-        }
-
-        throw new PhpfastcacheInvalidArgumentException('Cross-Driver type confusion detected');
-    }
-
-    /**
-     * @return bool
-     */
-    protected function driverClear(): bool
-    {
-        return $this->instance->flushdb()->getPayload() === 'OK';
-    }
+	/**
+	 * @param CacheItemInterface $item
+	 * @return bool
+	 * @throws PhpfastcacheInvalidArgumentException
+	 */
+	protected function driverDelete(CacheItemInterface $item): bool
+	{
+		/**
+		 * Check for Cross-Driver type confusion
+		 */
+		if ($item instanceof Item) {
+			return (bool)$this->instance->del([$item->getKey()]);
+		}
+
+		throw new PhpfastcacheInvalidArgumentException('Cross-Driver type confusion detected');
+	}
+
+	/**
+	 * @return bool
+	 */
+	protected function driverClear(): bool
+	{
+		return $this->instance->flushdb()->getPayload() === 'OK';
+	}
 }

plugins/files/php/lib/phpfastcache/lib/Phpfastcache/Drivers/Sqlite/Config.php

Indentation +1 added lines, -1 removed lines

@@ -20,5 +20,5 @@
 
 class Config extends ConfigurationOption
 {
-    use IOConfigurationOptionTrait;
+	use IOConfigurationOptionTrait;
 }
\ No newline at end of file

plugins/files/php/lib/phpfastcache/lib/Phpfastcache/Drivers/Sqlite/Item.php

Indentation +30 added lines, -30 removed lines

@@ -27,34 +27,34 @@
  */
 class Item implements ExtendedCacheItemInterface
 {
-    use ItemBaseTrait {
-        ItemBaseTrait::__construct as __BaseConstruct;
-    }
-
-    /**
-     * Item constructor.
-     * @param Driver $driver
-     * @param $key
-     * @throws PhpfastcacheInvalidArgumentException
-     */
-    public function __construct(SqliteDriver $driver, $key)
-    {
-        $this->__BaseConstruct($driver, $key);
-    }
-
-    /**
-     * @param ExtendedCacheItemPoolInterface $driver
-     * @return static
-     * @throws PhpfastcacheInvalidArgumentException
-     */
-    public function setDriver(ExtendedCacheItemPoolInterface $driver)
-    {
-        if ($driver instanceof SqliteDriver) {
-            $this->driver = $driver;
-
-            return $this;
-        }
-
-        throw new PhpfastcacheInvalidArgumentException('Invalid driver instance');
-    }
+	use ItemBaseTrait {
+		ItemBaseTrait::__construct as __BaseConstruct;
+	}
+
+	/**
+	 * Item constructor.
+	 * @param Driver $driver
+	 * @param $key
+	 * @throws PhpfastcacheInvalidArgumentException
+	 */
+	public function __construct(SqliteDriver $driver, $key)
+	{
+		$this->__BaseConstruct($driver, $key);
+	}
+
+	/**
+	 * @param ExtendedCacheItemPoolInterface $driver
+	 * @return static
+	 * @throws PhpfastcacheInvalidArgumentException
+	 */
+	public function setDriver(ExtendedCacheItemPoolInterface $driver)
+	{
+		if ($driver instanceof SqliteDriver) {
+			$this->driver = $driver;
+
+			return $this;
+		}
+
+		throw new PhpfastcacheInvalidArgumentException('Invalid driver instance');
+	}
 }
\ No newline at end of file

plugins/files/php/lib/phpfastcache/lib/Phpfastcache/Drivers/Sqlite/Driver.php

Indentation +329 added lines, -329 removed lines

@@ -32,335 +32,335 @@
  */
 class Driver implements ExtendedCacheItemPoolInterface, AggregatablePoolInterface
 {
-    use DriverBaseTrait, IOHelperTrait;
-
-    /**
-     *
-     */
-    protected const INDEXING_FILE = 'indexing';
-
-    /**
-     * @var int
-     */
-    protected $maxSize = 10; // 10 mb
-
-    /**
-     * @var int
-     */
-    protected $currentDB = 1;
-
-    /**
-     * @var string
-     */
-    protected $SqliteDir = '';
-
-    /**
-     * @var PDO
-     */
-    protected $indexing;
-
-    /**
-     * @return bool
-     */
-    public function driverCheck(): bool
-    {
-        return extension_loaded('pdo_sqlite') && (is_writable($this->getSqliteDir()) || @mkdir($this->getSqliteDir(), $this->getDefaultChmod(), true));
-    }
-
-    /**
-     * @return string
-     * @throws PhpfastcacheCoreException
-     */
-    public function getSqliteDir(): string
-    {
-        return $this->SqliteDir ?: $this->getPath();
-    }
-
-    /**
-     * @return array
-     */
-    public function __sleep(): array
-    {
-        return array_diff(array_keys(get_object_vars($this)), ['indexing', 'instance']);
-    }
-
-    /**
-     * @return bool
-     * @throws PhpfastcacheIOException
-     */
-    protected function driverConnect(): bool
-    {
-        if (!file_exists($this->getSqliteDir()) && !@mkdir($this->getSqliteDir(), $this->getDefaultChmod(), true)) {
-            throw new PhpfastcacheIOException(sprintf('Sqlite cannot write in "%s", aborting...', $this->getPath()));
-        }
-        if (!file_exists($this->getPath())) {
-            if (!mkdir($this->getPath(), $this->getDefaultChmod(), true)
-            ) {
-                $this->fallback = true;
-            }
-        }
-        $this->SqliteDir = $this->getPath();
-
-        return true;
-    }
-
-    /**
-     * @param CacheItemInterface $item
-     * @return null|array
-     */
-    protected function driverRead(CacheItemInterface $item)
-    {
-        try {
-            $stm = $this->getDb($item->getEncodedKey())
-                ->prepare("SELECT * FROM `caching` WHERE `keyword`=:keyword LIMIT 1");
-            $stm->execute(
-                [
-                    ':keyword' => $item->getEncodedKey(),
-                ]
-            );
-            $row = $stm->fetch(PDO::FETCH_ASSOC);
-        } catch (PDOException $e) {
-            try {
-                $stm = $this->getDb($item->getEncodedKey(), true)
-                    ->prepare("SELECT * FROM `caching` WHERE `keyword`=:keyword LIMIT 1");
-                $stm->execute(
-                    [
-                        ':keyword' => $item->getEncodedKey(),
-                    ]
-                );
-                $row = $stm->fetch(PDO::FETCH_ASSOC);
-            } catch (PDOException $e) {
-                return null;
-            }
-        }
-
-        if (isset($row['object'])) {
-            return $this->decode($row['object']);
-        }
-
-        return null;
-    }
-
-    /**
-     * @param string $keyword
-     * @param bool $reset
-     * @return PDO
-     */
-    public function getDb(string $keyword, bool $reset = false): PDO
-    {
-        /**
-         * Default is phpfastcache
-         */
-        $instant = $this->indexing($keyword);
-
-        /**
-         * init instant
-         */
-        if (!isset($this->instance[$instant])) {
-            // check DB Files ready or not
-            $tableCreated = false;
-            if ($reset || !file_exists($this->SqliteDir . '/db' . $instant)) {
-                $tableCreated = true;
-            }
-            $PDO = new PDO('sqlite:' . $this->SqliteDir . '/db' . $instant);
-            $PDO->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
-
-            if ($tableCreated) {
-                $this->initDB($PDO);
-            }
-
-            $this->instance[$instant] = $PDO;
-            unset($PDO);
-        }
-
-        return $this->instance[$instant];
-    }
-
-    /**
-     * INIT Instant DB
-     * Return Database of Keyword
-     * @param $keyword
-     * @return int
-     */
-    public function indexing($keyword)
-    {
-        if ($this->indexing == null) {
-            $tableCreated = false;
-            if (!file_exists($this->SqliteDir . '/indexing')) {
-                $tableCreated = true;
-            }
-
-            $PDO = new PDO("sqlite:" . $this->SqliteDir . '/' . self::INDEXING_FILE);
-            $PDO->setAttribute(
-                PDO::ATTR_ERRMODE,
-                PDO::ERRMODE_EXCEPTION
-            );
-
-            if ($tableCreated) {
-                $this->initIndexing($PDO);
-            }
-            $this->indexing = $PDO;
-            unset($PDO);
-
-            $stm = $this->indexing->prepare("SELECT MAX(`db`) as `db` FROM `balancing`");
-            $stm->execute();
-            $row = $stm->fetch(PDO::FETCH_ASSOC);
-            if (!isset($row['db'])) {
-                $db = 1;
-            } elseif ($row['db'] <= 1) {
-                $db = 1;
-            } else {
-                $db = $row['db'];
-            }
-
-            // check file size
-
-            $size = file_exists($this->SqliteDir . '/db' . $db) ? filesize($this->SqliteDir . '/db' . $db) : 1;
-            $size = round($size / 1024 / 1024, 1);
-
-
-            if ($size > $this->maxSize) {
-                $db++;
-            }
-            $this->currentDB = $db;
-        }
-
-        // look for keyword
-        $stm = $this->indexing->prepare("SELECT * FROM `balancing` WHERE `keyword`=:keyword LIMIT 1");
-        $stm->execute(
-            [
-                ':keyword' => $keyword,
-            ]
-        );
-        $row = $stm->fetch(PDO::FETCH_ASSOC);
-        if (isset($row['db']) && $row['db'] != '') {
-            $db = $row['db'];
-        } else {
-            /*
+	use DriverBaseTrait, IOHelperTrait;
+
+	/**
+	 *
+	 */
+	protected const INDEXING_FILE = 'indexing';
+
+	/**
+	 * @var int
+	 */
+	protected $maxSize = 10; // 10 mb
+
+	/**
+	 * @var int
+	 */
+	protected $currentDB = 1;
+
+	/**
+	 * @var string
+	 */
+	protected $SqliteDir = '';
+
+	/**
+	 * @var PDO
+	 */
+	protected $indexing;
+
+	/**
+	 * @return bool
+	 */
+	public function driverCheck(): bool
+	{
+		return extension_loaded('pdo_sqlite') && (is_writable($this->getSqliteDir()) || @mkdir($this->getSqliteDir(), $this->getDefaultChmod(), true));
+	}
+
+	/**
+	 * @return string
+	 * @throws PhpfastcacheCoreException
+	 */
+	public function getSqliteDir(): string
+	{
+		return $this->SqliteDir ?: $this->getPath();
+	}
+
+	/**
+	 * @return array
+	 */
+	public function __sleep(): array
+	{
+		return array_diff(array_keys(get_object_vars($this)), ['indexing', 'instance']);
+	}
+
+	/**
+	 * @return bool
+	 * @throws PhpfastcacheIOException
+	 */
+	protected function driverConnect(): bool
+	{
+		if (!file_exists($this->getSqliteDir()) && !@mkdir($this->getSqliteDir(), $this->getDefaultChmod(), true)) {
+			throw new PhpfastcacheIOException(sprintf('Sqlite cannot write in "%s", aborting...', $this->getPath()));
+		}
+		if (!file_exists($this->getPath())) {
+			if (!mkdir($this->getPath(), $this->getDefaultChmod(), true)
+			) {
+				$this->fallback = true;
+			}
+		}
+		$this->SqliteDir = $this->getPath();
+
+		return true;
+	}
+
+	/**
+	 * @param CacheItemInterface $item
+	 * @return null|array
+	 */
+	protected function driverRead(CacheItemInterface $item)
+	{
+		try {
+			$stm = $this->getDb($item->getEncodedKey())
+				->prepare("SELECT * FROM `caching` WHERE `keyword`=:keyword LIMIT 1");
+			$stm->execute(
+				[
+					':keyword' => $item->getEncodedKey(),
+				]
+			);
+			$row = $stm->fetch(PDO::FETCH_ASSOC);
+		} catch (PDOException $e) {
+			try {
+				$stm = $this->getDb($item->getEncodedKey(), true)
+					->prepare("SELECT * FROM `caching` WHERE `keyword`=:keyword LIMIT 1");
+				$stm->execute(
+					[
+						':keyword' => $item->getEncodedKey(),
+					]
+				);
+				$row = $stm->fetch(PDO::FETCH_ASSOC);
+			} catch (PDOException $e) {
+				return null;
+			}
+		}
+
+		if (isset($row['object'])) {
+			return $this->decode($row['object']);
+		}
+
+		return null;
+	}
+
+	/**
+	 * @param string $keyword
+	 * @param bool $reset
+	 * @return PDO
+	 */
+	public function getDb(string $keyword, bool $reset = false): PDO
+	{
+		/**
+		 * Default is phpfastcache
+		 */
+		$instant = $this->indexing($keyword);
+
+		/**
+		 * init instant
+		 */
+		if (!isset($this->instance[$instant])) {
+			// check DB Files ready or not
+			$tableCreated = false;
+			if ($reset || !file_exists($this->SqliteDir . '/db' . $instant)) {
+				$tableCreated = true;
+			}
+			$PDO = new PDO('sqlite:' . $this->SqliteDir . '/db' . $instant);
+			$PDO->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
+
+			if ($tableCreated) {
+				$this->initDB($PDO);
+			}
+
+			$this->instance[$instant] = $PDO;
+			unset($PDO);
+		}
+
+		return $this->instance[$instant];
+	}
+
+	/**
+	 * INIT Instant DB
+	 * Return Database of Keyword
+	 * @param $keyword
+	 * @return int
+	 */
+	public function indexing($keyword)
+	{
+		if ($this->indexing == null) {
+			$tableCreated = false;
+			if (!file_exists($this->SqliteDir . '/indexing')) {
+				$tableCreated = true;
+			}
+
+			$PDO = new PDO("sqlite:" . $this->SqliteDir . '/' . self::INDEXING_FILE);
+			$PDO->setAttribute(
+				PDO::ATTR_ERRMODE,
+				PDO::ERRMODE_EXCEPTION
+			);
+
+			if ($tableCreated) {
+				$this->initIndexing($PDO);
+			}
+			$this->indexing = $PDO;
+			unset($PDO);
+
+			$stm = $this->indexing->prepare("SELECT MAX(`db`) as `db` FROM `balancing`");
+			$stm->execute();
+			$row = $stm->fetch(PDO::FETCH_ASSOC);
+			if (!isset($row['db'])) {
+				$db = 1;
+			} elseif ($row['db'] <= 1) {
+				$db = 1;
+			} else {
+				$db = $row['db'];
+			}
+
+			// check file size
+
+			$size = file_exists($this->SqliteDir . '/db' . $db) ? filesize($this->SqliteDir . '/db' . $db) : 1;
+			$size = round($size / 1024 / 1024, 1);
+
+
+			if ($size > $this->maxSize) {
+				$db++;
+			}
+			$this->currentDB = $db;
+		}
+
+		// look for keyword
+		$stm = $this->indexing->prepare("SELECT * FROM `balancing` WHERE `keyword`=:keyword LIMIT 1");
+		$stm->execute(
+			[
+				':keyword' => $keyword,
+			]
+		);
+		$row = $stm->fetch(PDO::FETCH_ASSOC);
+		if (isset($row['db']) && $row['db'] != '') {
+			$db = $row['db'];
+		} else {
+			/*
              * Insert new to Indexing
              */
-            $db = $this->currentDB;
-            $stm = $this->indexing->prepare("INSERT INTO `balancing` (`keyword`,`db`) VALUES(:keyword, :db)");
-            $stm->execute(
-                [
-                    ':keyword' => $keyword,
-                    ':db' => $db,
-                ]
-            );
-        }
-
-        return $db;
-    }
-
-    /**
-     * INIT Indexing DB
-     * @param PDO $db
-     */
-    public function initIndexing(PDO $db)
-    {
-        // delete everything before reset indexing
-        $dir = opendir($this->SqliteDir);
-        while ($file = readdir($dir)) {
-            if ($file != '.' && $file != '..' && $file != 'indexing' && $file != 'dbfastcache') {
-                unlink($this->SqliteDir . '/' . $file);
-            }
-        }
-
-        $db->exec('DROP TABLE if exists "balancing"');
-        $db->exec('CREATE TABLE "balancing" ("keyword" VARCHAR PRIMARY KEY NOT NULL UNIQUE, "db" INTEGER)');
-        $db->exec('CREATE INDEX "db" ON "balancing" ("db")');
-        $db->exec('CREATE UNIQUE INDEX "lookup" ON "balancing" ("keyword")');
-    }
-
-    /**
-     * INIT NEW DB
-     * @param PDO $db
-     */
-    public function initDB(PDO $db)
-    {
-        $db->exec('drop table if exists "caching"');
-        $db->exec('CREATE TABLE "caching" ("id" INTEGER PRIMARY KEY AUTOINCREMENT, "keyword" VARCHAR UNIQUE, "object" BLOB, "exp" INTEGER)');
-        $db->exec('CREATE UNIQUE INDEX "cleanup" ON "caching" ("keyword","exp")');
-        $db->exec('CREATE INDEX "exp" ON "caching" ("exp")');
-        $db->exec('CREATE UNIQUE INDEX "keyword" ON "caching" ("keyword")');
-    }
-
-    /**
-     * @param CacheItemInterface $item
-     * @return mixed
-     * @throws PhpfastcacheInvalidArgumentException
-     */
-    protected function driverWrite(CacheItemInterface $item): bool
-    {
-        /**
-         * Check for Cross-Driver type confusion
-         */
-        if ($item instanceof Item) {
-            try {
-                $stm = $this->getDb($item->getEncodedKey())
-                    ->prepare("INSERT OR REPLACE INTO `caching` (`keyword`,`object`,`exp`) values(:keyword,:object,:exp)");
-                $stm->execute(
-                    [
-                        ':keyword' => $item->getEncodedKey(),
-                        ':object' => $this->encode($this->driverPreWrap($item)),
-                        ':exp' => $item->getExpirationDate()->getTimestamp(),
-                    ]
-                );
-
-                return true;
-            } catch (PDOException $e) {
-                return false;
-            }
-        }
-
-        throw new PhpfastcacheInvalidArgumentException('Cross-Driver type confusion detected');
-    }
-
-    /**
-     * @param CacheItemInterface $item
-     * @return bool
-     * @throws PhpfastcacheInvalidArgumentException
-     */
-    protected function driverDelete(CacheItemInterface $item): bool
-    {
-        /**
-         * Check for Cross-Driver type confusion
-         */
-        if ($item instanceof Item) {
-            try {
-                $stm = $this->getDb($item->getEncodedKey())
-                    ->prepare("DELETE FROM `caching` WHERE (`exp` <= :U) OR (`keyword`=:keyword) ");
-
-                return $stm->execute(
-                    [
-                        ':keyword' => $item->getEncodedKey(),
-                        ':U' => time(),
-                    ]
-                );
-            } catch (PDOException $e) {
-                return false;
-            }
-        } else {
-            throw new PhpfastcacheInvalidArgumentException('Cross-Driver type confusion detected');
-        }
-    }
-
-    /**
-     * @return bool
-     */
-    protected function driverClear(): bool
-    {
-        $this->instance = [];
-        $this->indexing = null;
-
-        // delete everything before reset indexing
-        $dir = opendir($this->getSqliteDir());
-        while ($file = readdir($dir)) {
-            if ($file != '.' && $file != '..') {
-                unlink($this->getSqliteDir() . '/' . $file);
-            }
-        }
-
-        return true;
-    }
+			$db = $this->currentDB;
+			$stm = $this->indexing->prepare("INSERT INTO `balancing` (`keyword`,`db`) VALUES(:keyword, :db)");
+			$stm->execute(
+				[
+					':keyword' => $keyword,
+					':db' => $db,
+				]
+			);
+		}
+
+		return $db;
+	}
+
+	/**
+	 * INIT Indexing DB
+	 * @param PDO $db
+	 */
+	public function initIndexing(PDO $db)
+	{
+		// delete everything before reset indexing
+		$dir = opendir($this->SqliteDir);
+		while ($file = readdir($dir)) {
+			if ($file != '.' && $file != '..' && $file != 'indexing' && $file != 'dbfastcache') {
+				unlink($this->SqliteDir . '/' . $file);
+			}
+		}
+
+		$db->exec('DROP TABLE if exists "balancing"');
+		$db->exec('CREATE TABLE "balancing" ("keyword" VARCHAR PRIMARY KEY NOT NULL UNIQUE, "db" INTEGER)');
+		$db->exec('CREATE INDEX "db" ON "balancing" ("db")');
+		$db->exec('CREATE UNIQUE INDEX "lookup" ON "balancing" ("keyword")');
+	}
+
+	/**
+	 * INIT NEW DB
+	 * @param PDO $db
+	 */
+	public function initDB(PDO $db)
+	{
+		$db->exec('drop table if exists "caching"');
+		$db->exec('CREATE TABLE "caching" ("id" INTEGER PRIMARY KEY AUTOINCREMENT, "keyword" VARCHAR UNIQUE, "object" BLOB, "exp" INTEGER)');
+		$db->exec('CREATE UNIQUE INDEX "cleanup" ON "caching" ("keyword","exp")');
+		$db->exec('CREATE INDEX "exp" ON "caching" ("exp")');
+		$db->exec('CREATE UNIQUE INDEX "keyword" ON "caching" ("keyword")');
+	}
+
+	/**
+	 * @param CacheItemInterface $item
+	 * @return mixed
+	 * @throws PhpfastcacheInvalidArgumentException
+	 */
+	protected function driverWrite(CacheItemInterface $item): bool
+	{
+		/**
+		 * Check for Cross-Driver type confusion
+		 */
+		if ($item instanceof Item) {
+			try {
+				$stm = $this->getDb($item->getEncodedKey())
+					->prepare("INSERT OR REPLACE INTO `caching` (`keyword`,`object`,`exp`) values(:keyword,:object,:exp)");
+				$stm->execute(
+					[
+						':keyword' => $item->getEncodedKey(),
+						':object' => $this->encode($this->driverPreWrap($item)),
+						':exp' => $item->getExpirationDate()->getTimestamp(),
+					]
+				);
+
+				return true;
+			} catch (PDOException $e) {
+				return false;
+			}
+		}
+
+		throw new PhpfastcacheInvalidArgumentException('Cross-Driver type confusion detected');
+	}
+
+	/**
+	 * @param CacheItemInterface $item
+	 * @return bool
+	 * @throws PhpfastcacheInvalidArgumentException
+	 */
+	protected function driverDelete(CacheItemInterface $item): bool
+	{
+		/**
+		 * Check for Cross-Driver type confusion
+		 */
+		if ($item instanceof Item) {
+			try {
+				$stm = $this->getDb($item->getEncodedKey())
+					->prepare("DELETE FROM `caching` WHERE (`exp` <= :U) OR (`keyword`=:keyword) ");
+
+				return $stm->execute(
+					[
+						':keyword' => $item->getEncodedKey(),
+						':U' => time(),
+					]
+				);
+			} catch (PDOException $e) {
+				return false;
+			}
+		} else {
+			throw new PhpfastcacheInvalidArgumentException('Cross-Driver type confusion detected');
+		}
+	}
+
+	/**
+	 * @return bool
+	 */
+	protected function driverClear(): bool
+	{
+		$this->instance = [];
+		$this->indexing = null;
+
+		// delete everything before reset indexing
+		$dir = opendir($this->getSqliteDir());
+		while ($file = readdir($dir)) {
+			if ($file != '.' && $file != '..') {
+				unlink($this->getSqliteDir() . '/' . $file);
+			}
+		}
+
+		return true;
+	}
 }

plugins/files/php/lib/phpfastcache/lib/Phpfastcache/Drivers/Wincache/Item.php

Indentation +30 added lines, -30 removed lines

@@ -27,34 +27,34 @@
  */
 class Item implements ExtendedCacheItemInterface
 {
-    use ItemBaseTrait {
-        ItemBaseTrait::__construct as __BaseConstruct;
-    }
-
-    /**
-     * Item constructor.
-     * @param Driver $driver
-     * @param $key
-     * @throws PhpfastcacheInvalidArgumentException
-     */
-    public function __construct(WincacheDriver $driver, $key)
-    {
-        $this->__BaseConstruct($driver, $key);
-    }
-
-    /**
-     * @param ExtendedCacheItemPoolInterface $driver
-     * @return static
-     * @throws PhpfastcacheInvalidArgumentException
-     */
-    public function setDriver(ExtendedCacheItemPoolInterface $driver)
-    {
-        if ($driver instanceof WincacheDriver) {
-            $this->driver = $driver;
-
-            return $this;
-        }
-
-        throw new PhpfastcacheInvalidArgumentException('Invalid driver instance');
-    }
+	use ItemBaseTrait {
+		ItemBaseTrait::__construct as __BaseConstruct;
+	}
+
+	/**
+	 * Item constructor.
+	 * @param Driver $driver
+	 * @param $key
+	 * @throws PhpfastcacheInvalidArgumentException
+	 */
+	public function __construct(WincacheDriver $driver, $key)
+	{
+		$this->__BaseConstruct($driver, $key);
+	}
+
+	/**
+	 * @param ExtendedCacheItemPoolInterface $driver
+	 * @return static
+	 * @throws PhpfastcacheInvalidArgumentException
+	 */
+	public function setDriver(ExtendedCacheItemPoolInterface $driver)
+	{
+		if ($driver instanceof WincacheDriver) {
+			$this->driver = $driver;
+
+			return $this;
+		}
+
+		throw new PhpfastcacheInvalidArgumentException('Invalid driver instance');
+	}
 }
\ No newline at end of file