grommunio / grommunio-web

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

Indentation +253 added lines, -253 removed lines

@@ -20,257 +20,257 @@
 
 class Config extends ConfigurationOption
 {
-    /**
-     * @var string
-     */
-    protected $host = '127.0.0.1';
-
-    /**
-     * @var int
-     */
-    protected $port = 27017;
-
-    /**
-     * @var int
-     */
-    protected $timeout = 3;
-
-    /**
-     * @var string
-     */
-    protected $username = '';
-
-    /**
-     * @var string
-     */
-    protected $password = '';
-
-    /**
-     * @var array
-     */
-    protected $servers = [];
-
-    /**
-     * @var string
-     */
-    protected $collectionName = 'phpfastcache';
-
-    /**
-     * @var string
-     */
-    protected $databaseName = Driver::MONGODB_DEFAULT_DB_NAME;
-
-    /**
-     * @var array
-     */
-    protected $options = [];
-
-    /**
-     * @var array
-     */
-    protected $driverOptions = [];
-
-    /**
-     * @var string
-     */
-    protected $protocol = 'mongodb';
-
-    /**
-     * @return string
-     */
-    public function getHost(): string
-    {
-        return $this->host;
-    }
-
-    /**
-     * @param string $host
-     * @return self
-     */
-    public function setHost(string $host): self
-    {
-        $this->host = $host;
-        return $this;
-    }
-
-    /**
-     * @return int
-     */
-    public function getPort(): int
-    {
-        return $this->port;
-    }
-
-    /**
-     * @param int $port
-     * @return self
-     */
-    public function setPort(int $port): self
-    {
-        $this->port = $port;
-        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 string
-     */
-    public function getUsername(): string
-    {
-        return $this->username;
-    }
-
-    /**
-     * @param string $username
-     * @return self
-     */
-    public function setUsername(string $username): self
-    {
-        $this->username = $username;
-        return $this;
-    }
-
-    /**
-     * @return string
-     */
-    public function getPassword(): string
-    {
-        return $this->password;
-    }
-
-    /**
-     * @param string $password
-     * @return self
-     */
-    public function setPassword(string $password): self
-    {
-        $this->password = $password;
-        return $this;
-    }
-
-    /**
-     * @return array
-     */
-    public function getServers(): array
-    {
-        return $this->servers;
-    }
-
-    /**
-     * @param array $servers
-     * @return self
-     */
-    public function setServers(array $servers): self
-    {
-        $this->servers = $servers;
-        return $this;
-    }
-
-    /**
-     * @return string
-     */
-    public function getCollectionName(): string
-    {
-        return $this->collectionName;
-    }
-
-    /**
-     * @param string $collectionName
-     * @return self
-     */
-    public function setCollectionName(string $collectionName): self
-    {
-        $this->collectionName = $collectionName;
-        return $this;
-    }
-
-    /**
-     * @return string
-     */
-    public function getDatabaseName(): string
-    {
-        return $this->databaseName;
-    }
-
-    /**
-     * @param string $databaseName
-     * @return self
-     */
-    public function setDatabaseName(string $databaseName): self
-    {
-        $this->databaseName = $databaseName;
-        return $this;
-    }
-
-    /**
-     * @return array
-     */
-    public function getOptions(): array
-    {
-        return $this->options;
-    }
-
-    /**
-     * @see https://docs.mongodb.com/manual/reference/connection-string/#connections-connection-options
-     * @param array $options
-     * @return Config
-     */
-    public function setOptions(array $options): self
-    {
-        $this->options = $options;
-        return $this;
-    }
-
-    /**
-     * @return array
-     */
-    public function getDriverOptions(): array
-    {
-        return $this->driverOptions;
-    }
-
-    /**
-     * @param array $driverOptions
-     * @return self
-     */
-    public function setDriverOptions(array $driverOptions): self
-    {
-        $this->driverOptions = $driverOptions;
-        return $this;
-    }
-
-    /**
-     * @return string
-     */
-    public function getProtocol(): string
-    {
-        return $this->protocol;
-    }
-
-    /**
-     * @param string $protocol
-     * @return self
-     */
-    public function setProtocol(string $protocol): self
-    {
-        $this->protocol = $protocol;
-        return $this;
-    }
+	/**
+	 * @var string
+	 */
+	protected $host = '127.0.0.1';
+
+	/**
+	 * @var int
+	 */
+	protected $port = 27017;
+
+	/**
+	 * @var int
+	 */
+	protected $timeout = 3;
+
+	/**
+	 * @var string
+	 */
+	protected $username = '';
+
+	/**
+	 * @var string
+	 */
+	protected $password = '';
+
+	/**
+	 * @var array
+	 */
+	protected $servers = [];
+
+	/**
+	 * @var string
+	 */
+	protected $collectionName = 'phpfastcache';
+
+	/**
+	 * @var string
+	 */
+	protected $databaseName = Driver::MONGODB_DEFAULT_DB_NAME;
+
+	/**
+	 * @var array
+	 */
+	protected $options = [];
+
+	/**
+	 * @var array
+	 */
+	protected $driverOptions = [];
+
+	/**
+	 * @var string
+	 */
+	protected $protocol = 'mongodb';
+
+	/**
+	 * @return string
+	 */
+	public function getHost(): string
+	{
+		return $this->host;
+	}
+
+	/**
+	 * @param string $host
+	 * @return self
+	 */
+	public function setHost(string $host): self
+	{
+		$this->host = $host;
+		return $this;
+	}
+
+	/**
+	 * @return int
+	 */
+	public function getPort(): int
+	{
+		return $this->port;
+	}
+
+	/**
+	 * @param int $port
+	 * @return self
+	 */
+	public function setPort(int $port): self
+	{
+		$this->port = $port;
+		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 string
+	 */
+	public function getUsername(): string
+	{
+		return $this->username;
+	}
+
+	/**
+	 * @param string $username
+	 * @return self
+	 */
+	public function setUsername(string $username): self
+	{
+		$this->username = $username;
+		return $this;
+	}
+
+	/**
+	 * @return string
+	 */
+	public function getPassword(): string
+	{
+		return $this->password;
+	}
+
+	/**
+	 * @param string $password
+	 * @return self
+	 */
+	public function setPassword(string $password): self
+	{
+		$this->password = $password;
+		return $this;
+	}
+
+	/**
+	 * @return array
+	 */
+	public function getServers(): array
+	{
+		return $this->servers;
+	}
+
+	/**
+	 * @param array $servers
+	 * @return self
+	 */
+	public function setServers(array $servers): self
+	{
+		$this->servers = $servers;
+		return $this;
+	}
+
+	/**
+	 * @return string
+	 */
+	public function getCollectionName(): string
+	{
+		return $this->collectionName;
+	}
+
+	/**
+	 * @param string $collectionName
+	 * @return self
+	 */
+	public function setCollectionName(string $collectionName): self
+	{
+		$this->collectionName = $collectionName;
+		return $this;
+	}
+
+	/**
+	 * @return string
+	 */
+	public function getDatabaseName(): string
+	{
+		return $this->databaseName;
+	}
+
+	/**
+	 * @param string $databaseName
+	 * @return self
+	 */
+	public function setDatabaseName(string $databaseName): self
+	{
+		$this->databaseName = $databaseName;
+		return $this;
+	}
+
+	/**
+	 * @return array
+	 */
+	public function getOptions(): array
+	{
+		return $this->options;
+	}
+
+	/**
+	 * @see https://docs.mongodb.com/manual/reference/connection-string/#connections-connection-options
+	 * @param array $options
+	 * @return Config
+	 */
+	public function setOptions(array $options): self
+	{
+		$this->options = $options;
+		return $this;
+	}
+
+	/**
+	 * @return array
+	 */
+	public function getDriverOptions(): array
+	{
+		return $this->driverOptions;
+	}
+
+	/**
+	 * @param array $driverOptions
+	 * @return self
+	 */
+	public function setDriverOptions(array $driverOptions): self
+	{
+		$this->driverOptions = $driverOptions;
+		return $this;
+	}
+
+	/**
+	 * @return string
+	 */
+	public function getProtocol(): string
+	{
+		return $this->protocol;
+	}
+
+	/**
+	 * @param string $protocol
+	 * @return self
+	 */
+	public function setProtocol(string $protocol): self
+	{
+		$this->protocol = $protocol;
+		return $this;
+	}
 }

plugins/files/php/lib/phpfastcache/lib/Phpfastcache/Drivers/Mongodb/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(MongodbDriver $driver, $key)
-    {
-        $this->__BaseConstruct($driver, $key);
-    }
-
-    /**
-     * @param ExtendedCacheItemPoolInterface $driver
-     * @return static
-     * @throws PhpfastcacheInvalidArgumentException
-     */
-    public function setDriver(ExtendedCacheItemPoolInterface $driver)
-    {
-        if ($driver instanceof MongodbDriver) {
-            $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(MongodbDriver $driver, $key)
+	{
+		$this->__BaseConstruct($driver, $key);
+	}
+
+	/**
+	 * @param ExtendedCacheItemPoolInterface $driver
+	 * @return static
+	 * @throws PhpfastcacheInvalidArgumentException
+	 */
+	public function setDriver(ExtendedCacheItemPoolInterface $driver)
+	{
+		if ($driver instanceof MongodbDriver) {
+			$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/Mongodb/Driver.php

Indentation +321 added lines, -321 removed lines

@@ -36,331 +36,331 @@
  */
 class Driver implements ExtendedCacheItemPoolInterface, AggregatablePoolInterface
 {
-    public const MONGODB_DEFAULT_DB_NAME = 'phpfastcache'; // Public because used in config
-
-    use DriverBaseTrait;
-
-    /**
-     * @var Collection
-     */
-    public $collection;
-
-    /**
-     * @var Database
-     */
-    public $database;
-
-    /**
-     * @return bool
-     */
-    public function driverCheck(): bool
-    {
-        $mongoExtensionExists = class_exists(Manager::class);
-
-        if (!$mongoExtensionExists && class_exists(MongoClient::class)) {
-            trigger_error(
-                'This driver is used to support the pecl MongoDb extension with mongo-php-library.
+	public const MONGODB_DEFAULT_DB_NAME = 'phpfastcache'; // Public because used in config
+
+	use DriverBaseTrait;
+
+	/**
+	 * @var Collection
+	 */
+	public $collection;
+
+	/**
+	 * @var Database
+	 */
+	public $database;
+
+	/**
+	 * @return bool
+	 */
+	public function driverCheck(): bool
+	{
+		$mongoExtensionExists = class_exists(Manager::class);
+
+		if (!$mongoExtensionExists && class_exists(MongoClient::class)) {
+			trigger_error(
+				'This driver is used to support the pecl MongoDb extension with mongo-php-library.
             For MongoDb with Mongo PECL support use Mongo Driver.',
-                E_USER_ERROR
-            );
-        }
-
-        return $mongoExtensionExists && class_exists(Collection::class);
-    }
-
-    /**
-     * @return DriverStatistic
-     */
-    public function getStats(): DriverStatistic
-    {
-        $serverStats = $this->instance->getManager()->executeCommand(
-            $this->getConfig()->getDatabaseName(),
-            new Command(
-                [
-                    'serverStatus' => 1,
-                    'recordStats' => 0,
-                    'repl' => 0,
-                    'metrics' => 0,
-                ]
-            )
-        )->toArray()[0];
-
-        $collectionStats = $this->instance->getManager()->executeCommand(
-            $this->getConfig()->getDatabaseName(),
-            new Command(
-                [
-                    'collStats' => $this->getConfig()->getCollectionName(),
-                    'verbose' => true,
-                ]
-            )
-        )->toArray()[0];
-
-        $array_filter_recursive = static function ($array, callable $callback = null) use (&$array_filter_recursive) {
-            $array = $callback($array);
-
-            if (\is_object($array) || \is_array($array)) {
-                foreach ($array as &$value) {
-                    $value = $array_filter_recursive($value, $callback);
-                }
-            }
-
-            return $array;
-        };
-
-        $callback = static function ($item) {
-            /**
-             * Remove unserializable properties
-             */
-            if ($item instanceof UTCDateTime) {
-                return (string)$item;
-            }
-            return $item;
-        };
-
-        $serverStats = $array_filter_recursive($serverStats, $callback);
-        $collectionStats = $array_filter_recursive($collectionStats, $callback);
-
-        $stats = (new DriverStatistic())
-            ->setInfo(
-                'MongoDB version ' . $serverStats->version . ', Uptime (in days): ' . round(
-                    $serverStats->uptime / 86400,
-                    1
-                ) . "\n For more information see RawData."
-            )
-            ->setSize($collectionStats->size)
-            ->setData(implode(', ', array_keys($this->itemInstances)))
-            ->setRawData(
-                [
-                    'serverStatus' => $serverStats,
-                    'collStats' => $collectionStats,
-                ]
-            );
-
-        return $stats;
-    }
-
-    /**
-     * @param CacheItemInterface $item
-     * @return null|array
-     */
-    protected function driverRead(CacheItemInterface $item)
-    {
-        $document = $this->getCollection()->findOne(['_id' => $this->getMongoDbItemKey($item)]);
-
-        if ($document) {
-            $return = [
-                self::DRIVER_DATA_WRAPPER_INDEX => $this->decode($document[self::DRIVER_DATA_WRAPPER_INDEX]->getData()),
-                self::DRIVER_TAGS_WRAPPER_INDEX => $document[self::DRIVER_TAGS_WRAPPER_INDEX]->jsonSerialize(),
-                self::DRIVER_EDATE_WRAPPER_INDEX => $document[self::DRIVER_EDATE_WRAPPER_INDEX]->toDateTime(),
-            ];
-
-            if (!empty($this->getConfig()->isItemDetailedDate())) {
-                $return += [
-                    self::DRIVER_MDATE_WRAPPER_INDEX => $document[self::DRIVER_MDATE_WRAPPER_INDEX]->toDateTime(),
-                    self::DRIVER_CDATE_WRAPPER_INDEX => $document[self::DRIVER_CDATE_WRAPPER_INDEX]->toDateTime(),
-                ];
-            }
-
-            return $return;
-        }
-
-        return null;
-    }
-
-    /**
-     * @return Collection
-     */
-    protected function getCollection(): Collection
-    {
-        return $this->collection;
-    }
-
-    /**
-     * @param CacheItemInterface $item
-     * @return mixed
-     * @throws PhpfastcacheInvalidArgumentException
-     * @throws PhpfastcacheDriverException
-     */
-    protected function driverWrite(CacheItemInterface $item): bool
-    {
-        /**
-         * Check for Cross-Driver type confusion
-         */
-        if ($item instanceof Item) {
-            try {
-                $set = [
-                    self::DRIVER_KEY_WRAPPER_INDEX => $item->getKey(),
-                    self::DRIVER_DATA_WRAPPER_INDEX => new Binary($this->encode($item->get()), Binary::TYPE_GENERIC),
-                    self::DRIVER_TAGS_WRAPPER_INDEX => $item->getTags(),
-                    self::DRIVER_EDATE_WRAPPER_INDEX => new UTCDateTime($item->getExpirationDate()),
-                ];
-
-                if (!empty($this->getConfig()->isItemDetailedDate())) {
-                    $set += [
-                        self::DRIVER_MDATE_WRAPPER_INDEX =>  new UTCDateTime($item->getModificationDate()),
-                        self::DRIVER_CDATE_WRAPPER_INDEX =>  new UTCDateTime($item->getCreationDate()),
-                    ];
-                }
-                $result = (array)$this->getCollection()->updateOne(
-                    ['_id' => $this->getMongoDbItemKey($item)],
-                    [
-                        '$set' => $set,
-                    ],
-                    ['upsert' => true, 'multiple' => false]
-                );
-            } catch (MongoDBException $e) {
-                throw new PhpfastcacheDriverException('Got an exception while trying to write data to MongoDB server: ' . $e->getMessage(), 0, $e);
-            }
-
-            return isset($result['ok']) ? $result['ok'] == 1 : true;
-        }
-
-        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) {
-            /**
-             * @var DeleteResult $deletionResult
-             */
-            $deletionResult = $this->getCollection()->deleteOne(['_id' =>  $this->getMongoDbItemKey($item)]);
-
-            return $deletionResult->isAcknowledged();
-        }
-
-        throw new PhpfastcacheInvalidArgumentException('Cross-Driver type confusion detected');
-    }
-
-    /**
-     * @return bool
-     */
-    protected function driverClear(): bool
-    {
-        try {
-           return $this->collection->deleteMany([])->isAcknowledged();
-        } catch (MongoDBException $e) {
-            throw new PhpfastcacheDriverException('Got error while trying to empty the collection: ' . $e->getMessage(), 0, $e);
-        }
-    }
-
-    /**
-     * @return bool
-     * @throws MongodbException
-     * @throws LogicException
-     */
-    protected function driverConnect(): bool
-    {
-        if ($this->instance instanceof Client) {
-            throw new LogicException('Already connected to Mongodb server');
-        }
-
-        $timeout = $this->getConfig()->getTimeout() * 1000;
-        $collectionName = $this->getConfig()->getCollectionName();
-        $databaseName = $this->getConfig()->getDatabaseName();
-        $driverOptions = $this->getConfig()->getDriverOptions();
-
-        $this->instance = $this->instance ?: new Client($this->buildConnectionURI($databaseName), ['connectTimeoutMS' => $timeout], $driverOptions);
-        $this->database = $this->database ?: $this->instance->selectDatabase($databaseName);
-
-        if (!$this->collectionExists($collectionName)) {
-            $this->database->createCollection($collectionName);
-            $this->database->selectCollection($collectionName)
-                ->createIndex(
-                    [self::DRIVER_KEY_WRAPPER_INDEX => 1],
-                    ['unique' => true, 'name' => 'unique_key_index']
-                );
-            $this->database->selectCollection($collectionName)
-                ->createIndex(
-                    [self::DRIVER_EDATE_WRAPPER_INDEX => 1],
-                    ['expireAfterSeconds' => 0,  'name' => 'auto_expire_index']
-                );
-        }
-
-        $this->collection = $this->database->selectCollection($collectionName);
-
-        return true;
-    }
-
-    /**
-     * Builds the connection URI from the given parameters.
-     *
-     * @param string $databaseName
-     * @return string The connection URI.
-     */
-    protected function buildConnectionURI(string $databaseName): string
-    {
-        $databaseName = \urlencode($databaseName);
-        $servers = $this->getConfig()->getServers();
-        $options = $this->getConfig()->getOptions();
-
-        $protocol = $this->getConfig()->getProtocol();
-        $host = $this->getConfig()->getHost();
-        $port = $this->getConfig()->getPort();
-        $username = $this->getConfig()->getUsername();
-        $password = $this->getConfig()->getPassword();
-
-        if (count($servers) > 0) {
-            $host = array_reduce(
-                $servers,
-                static function ($carry, $data) {
-                    $carry .= ($carry === '' ? '' : ',') . $data['host'] . ':' . $data['port'];
-                    return $carry;
-                },
-                ''
-            );
-            $port = false;
-        }
-
-        return implode(
-            '',
-            [
-                "{$protocol}://",
-                $username ?: '',
-                $password ? ":{$password}" : '',
-                $username ? '@' : '',
-                $host,
-                $port !== 27017 && $port !== false ? ":{$port}" : '',
-                $databaseName ? "/{$databaseName}" : '',
-                count($options) > 0 ? '?' . http_build_query($options) : '',
-            ]
-        );
-    }
-
-    protected function getMongoDbItemKey(CacheItemInterface $item)
-    {
-        return 'pfc_' . $item->getEncodedKey();
-    }
-
-    /********************
+				E_USER_ERROR
+			);
+		}
+
+		return $mongoExtensionExists && class_exists(Collection::class);
+	}
+
+	/**
+	 * @return DriverStatistic
+	 */
+	public function getStats(): DriverStatistic
+	{
+		$serverStats = $this->instance->getManager()->executeCommand(
+			$this->getConfig()->getDatabaseName(),
+			new Command(
+				[
+					'serverStatus' => 1,
+					'recordStats' => 0,
+					'repl' => 0,
+					'metrics' => 0,
+				]
+			)
+		)->toArray()[0];
+
+		$collectionStats = $this->instance->getManager()->executeCommand(
+			$this->getConfig()->getDatabaseName(),
+			new Command(
+				[
+					'collStats' => $this->getConfig()->getCollectionName(),
+					'verbose' => true,
+				]
+			)
+		)->toArray()[0];
+
+		$array_filter_recursive = static function ($array, callable $callback = null) use (&$array_filter_recursive) {
+			$array = $callback($array);
+
+			if (\is_object($array) || \is_array($array)) {
+				foreach ($array as &$value) {
+					$value = $array_filter_recursive($value, $callback);
+				}
+			}
+
+			return $array;
+		};
+
+		$callback = static function ($item) {
+			/**
+			 * Remove unserializable properties
+			 */
+			if ($item instanceof UTCDateTime) {
+				return (string)$item;
+			}
+			return $item;
+		};
+
+		$serverStats = $array_filter_recursive($serverStats, $callback);
+		$collectionStats = $array_filter_recursive($collectionStats, $callback);
+
+		$stats = (new DriverStatistic())
+			->setInfo(
+				'MongoDB version ' . $serverStats->version . ', Uptime (in days): ' . round(
+					$serverStats->uptime / 86400,
+					1
+				) . "\n For more information see RawData."
+			)
+			->setSize($collectionStats->size)
+			->setData(implode(', ', array_keys($this->itemInstances)))
+			->setRawData(
+				[
+					'serverStatus' => $serverStats,
+					'collStats' => $collectionStats,
+				]
+			);
+
+		return $stats;
+	}
+
+	/**
+	 * @param CacheItemInterface $item
+	 * @return null|array
+	 */
+	protected function driverRead(CacheItemInterface $item)
+	{
+		$document = $this->getCollection()->findOne(['_id' => $this->getMongoDbItemKey($item)]);
+
+		if ($document) {
+			$return = [
+				self::DRIVER_DATA_WRAPPER_INDEX => $this->decode($document[self::DRIVER_DATA_WRAPPER_INDEX]->getData()),
+				self::DRIVER_TAGS_WRAPPER_INDEX => $document[self::DRIVER_TAGS_WRAPPER_INDEX]->jsonSerialize(),
+				self::DRIVER_EDATE_WRAPPER_INDEX => $document[self::DRIVER_EDATE_WRAPPER_INDEX]->toDateTime(),
+			];
+
+			if (!empty($this->getConfig()->isItemDetailedDate())) {
+				$return += [
+					self::DRIVER_MDATE_WRAPPER_INDEX => $document[self::DRIVER_MDATE_WRAPPER_INDEX]->toDateTime(),
+					self::DRIVER_CDATE_WRAPPER_INDEX => $document[self::DRIVER_CDATE_WRAPPER_INDEX]->toDateTime(),
+				];
+			}
+
+			return $return;
+		}
+
+		return null;
+	}
+
+	/**
+	 * @return Collection
+	 */
+	protected function getCollection(): Collection
+	{
+		return $this->collection;
+	}
+
+	/**
+	 * @param CacheItemInterface $item
+	 * @return mixed
+	 * @throws PhpfastcacheInvalidArgumentException
+	 * @throws PhpfastcacheDriverException
+	 */
+	protected function driverWrite(CacheItemInterface $item): bool
+	{
+		/**
+		 * Check for Cross-Driver type confusion
+		 */
+		if ($item instanceof Item) {
+			try {
+				$set = [
+					self::DRIVER_KEY_WRAPPER_INDEX => $item->getKey(),
+					self::DRIVER_DATA_WRAPPER_INDEX => new Binary($this->encode($item->get()), Binary::TYPE_GENERIC),
+					self::DRIVER_TAGS_WRAPPER_INDEX => $item->getTags(),
+					self::DRIVER_EDATE_WRAPPER_INDEX => new UTCDateTime($item->getExpirationDate()),
+				];
+
+				if (!empty($this->getConfig()->isItemDetailedDate())) {
+					$set += [
+						self::DRIVER_MDATE_WRAPPER_INDEX =>  new UTCDateTime($item->getModificationDate()),
+						self::DRIVER_CDATE_WRAPPER_INDEX =>  new UTCDateTime($item->getCreationDate()),
+					];
+				}
+				$result = (array)$this->getCollection()->updateOne(
+					['_id' => $this->getMongoDbItemKey($item)],
+					[
+						'$set' => $set,
+					],
+					['upsert' => true, 'multiple' => false]
+				);
+			} catch (MongoDBException $e) {
+				throw new PhpfastcacheDriverException('Got an exception while trying to write data to MongoDB server: ' . $e->getMessage(), 0, $e);
+			}
+
+			return isset($result['ok']) ? $result['ok'] == 1 : true;
+		}
+
+		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) {
+			/**
+			 * @var DeleteResult $deletionResult
+			 */
+			$deletionResult = $this->getCollection()->deleteOne(['_id' =>  $this->getMongoDbItemKey($item)]);
+
+			return $deletionResult->isAcknowledged();
+		}
+
+		throw new PhpfastcacheInvalidArgumentException('Cross-Driver type confusion detected');
+	}
+
+	/**
+	 * @return bool
+	 */
+	protected function driverClear(): bool
+	{
+		try {
+		   return $this->collection->deleteMany([])->isAcknowledged();
+		} catch (MongoDBException $e) {
+			throw new PhpfastcacheDriverException('Got error while trying to empty the collection: ' . $e->getMessage(), 0, $e);
+		}
+	}
+
+	/**
+	 * @return bool
+	 * @throws MongodbException
+	 * @throws LogicException
+	 */
+	protected function driverConnect(): bool
+	{
+		if ($this->instance instanceof Client) {
+			throw new LogicException('Already connected to Mongodb server');
+		}
+
+		$timeout = $this->getConfig()->getTimeout() * 1000;
+		$collectionName = $this->getConfig()->getCollectionName();
+		$databaseName = $this->getConfig()->getDatabaseName();
+		$driverOptions = $this->getConfig()->getDriverOptions();
+
+		$this->instance = $this->instance ?: new Client($this->buildConnectionURI($databaseName), ['connectTimeoutMS' => $timeout], $driverOptions);
+		$this->database = $this->database ?: $this->instance->selectDatabase($databaseName);
+
+		if (!$this->collectionExists($collectionName)) {
+			$this->database->createCollection($collectionName);
+			$this->database->selectCollection($collectionName)
+				->createIndex(
+					[self::DRIVER_KEY_WRAPPER_INDEX => 1],
+					['unique' => true, 'name' => 'unique_key_index']
+				);
+			$this->database->selectCollection($collectionName)
+				->createIndex(
+					[self::DRIVER_EDATE_WRAPPER_INDEX => 1],
+					['expireAfterSeconds' => 0,  'name' => 'auto_expire_index']
+				);
+		}
+
+		$this->collection = $this->database->selectCollection($collectionName);
+
+		return true;
+	}
+
+	/**
+	 * Builds the connection URI from the given parameters.
+	 *
+	 * @param string $databaseName
+	 * @return string The connection URI.
+	 */
+	protected function buildConnectionURI(string $databaseName): string
+	{
+		$databaseName = \urlencode($databaseName);
+		$servers = $this->getConfig()->getServers();
+		$options = $this->getConfig()->getOptions();
+
+		$protocol = $this->getConfig()->getProtocol();
+		$host = $this->getConfig()->getHost();
+		$port = $this->getConfig()->getPort();
+		$username = $this->getConfig()->getUsername();
+		$password = $this->getConfig()->getPassword();
+
+		if (count($servers) > 0) {
+			$host = array_reduce(
+				$servers,
+				static function ($carry, $data) {
+					$carry .= ($carry === '' ? '' : ',') . $data['host'] . ':' . $data['port'];
+					return $carry;
+				},
+				''
+			);
+			$port = false;
+		}
+
+		return implode(
+			'',
+			[
+				"{$protocol}://",
+				$username ?: '',
+				$password ? ":{$password}" : '',
+				$username ? '@' : '',
+				$host,
+				$port !== 27017 && $port !== false ? ":{$port}" : '',
+				$databaseName ? "/{$databaseName}" : '',
+				count($options) > 0 ? '?' . http_build_query($options) : '',
+			]
+		);
+	}
+
+	protected function getMongoDbItemKey(CacheItemInterface $item)
+	{
+		return 'pfc_' . $item->getEncodedKey();
+	}
+
+	/********************
      *
      * PSR-6 Extended Methods
      *
      *******************/
 
-    /**
-     * Checks if a collection name exists on the Mongo database.
-     *
-     * @param string $collectionName The collection name to check.
-     *
-     * @return bool True if the collection exists, false if not.
-     */
-    protected function collectionExists($collectionName): bool
-    {
-        foreach ($this->database->listCollections() as $collection) {
-            if ($collection->getName() === $collectionName) {
-                return true;
-            }
-        }
-
-        return false;
-    }
+	/**
+	 * Checks if a collection name exists on the Mongo database.
+	 *
+	 * @param string $collectionName The collection name to check.
+	 *
+	 * @return bool True if the collection exists, false if not.
+	 */
+	protected function collectionExists($collectionName): bool
+	{
+		foreach ($this->database->listCollections() as $collection) {
+			if ($collection->getName() === $collectionName) {
+				return true;
+			}
+		}
+
+		return false;
+	}
 }

plugins/files/php/lib/phpfastcache/lib/Phpfastcache/Drivers/Devtrue/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(DevtrueDriver $driver, $key)
-    {
-        $this->__BaseConstruct($driver, $key);
-    }
-
-    /**
-     * @param ExtendedCacheItemPoolInterface $driver
-     * @return static
-     * @throws PhpfastcacheInvalidArgumentException
-     */
-    public function setDriver(ExtendedCacheItemPoolInterface $driver)
-    {
-        if ($driver instanceof DevtrueDriver) {
-            $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(DevtrueDriver $driver, $key)
+	{
+		$this->__BaseConstruct($driver, $key);
+	}
+
+	/**
+	 * @param ExtendedCacheItemPoolInterface $driver
+	 * @return static
+	 * @throws PhpfastcacheInvalidArgumentException
+	 */
+	public function setDriver(ExtendedCacheItemPoolInterface $driver)
+	{
+		if ($driver instanceof DevtrueDriver) {
+			$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/Devtrue/Driver.php

Indentation +87 added lines, -87 removed lines

@@ -31,96 +31,96 @@
  */
 class Driver implements ExtendedCacheItemPoolInterface
 {
-    use DriverBaseTrait;
-
-    /**
-     * @return bool
-     */
-    public function driverCheck(): bool
-    {
-        return true;
-    }
-
-    /**
-     * @return DriverStatistic
-     */
-    public function getStats(): DriverStatistic
-    {
-        $stat = new DriverStatistic();
-        $stat->setInfo('[Devtrue] A void info string')
-            ->setSize(0)
-            ->setData(implode(', ', array_keys($this->itemInstances)))
-            ->setRawData(true);
-
-        return $stat;
-    }
-
-    /**
-     * @param CacheItemInterface $item
-     * @return mixed
-     * @throws PhpfastcacheInvalidArgumentException
-     */
-    protected function driverWrite(CacheItemInterface $item): bool
-    {
-        /**
-         * Check for Cross-Driver type confusion
-         */
-        if ($item instanceof Item) {
-            return false;
-        }
-
-        throw new PhpfastcacheInvalidArgumentException('Cross-Driver type confusion detected');
-    }
-
-    /**
-     * @param CacheItemInterface $item
-     * @return array
-     */
-    protected function driverRead(CacheItemInterface $item): array
-    {
-        return [
-            self::DRIVER_DATA_WRAPPER_INDEX => true,
-            self::DRIVER_TAGS_WRAPPER_INDEX => [],
-            self::DRIVER_EDATE_WRAPPER_INDEX => new DateTime(),
-        ];
-    }
-
-    /**
-     * @param CacheItemInterface $item
-     * @return bool
-     * @throws PhpfastcacheInvalidArgumentException
-     */
-    protected function driverDelete(CacheItemInterface $item): bool
-    {
-        /**
-         * Check for Cross-Driver type confusion
-         */
-        if ($item instanceof Item) {
-            return false;
-        }
-
-        throw new PhpfastcacheInvalidArgumentException('Cross-Driver type confusion detected');
-    }
-
-    /**
-     * @return bool
-     */
-    protected function driverClear(): bool
-    {
-        return false;
-    }
-
-    /********************
+	use DriverBaseTrait;
+
+	/**
+	 * @return bool
+	 */
+	public function driverCheck(): bool
+	{
+		return true;
+	}
+
+	/**
+	 * @return DriverStatistic
+	 */
+	public function getStats(): DriverStatistic
+	{
+		$stat = new DriverStatistic();
+		$stat->setInfo('[Devtrue] A void info string')
+			->setSize(0)
+			->setData(implode(', ', array_keys($this->itemInstances)))
+			->setRawData(true);
+
+		return $stat;
+	}
+
+	/**
+	 * @param CacheItemInterface $item
+	 * @return mixed
+	 * @throws PhpfastcacheInvalidArgumentException
+	 */
+	protected function driverWrite(CacheItemInterface $item): bool
+	{
+		/**
+		 * Check for Cross-Driver type confusion
+		 */
+		if ($item instanceof Item) {
+			return false;
+		}
+
+		throw new PhpfastcacheInvalidArgumentException('Cross-Driver type confusion detected');
+	}
+
+	/**
+	 * @param CacheItemInterface $item
+	 * @return array
+	 */
+	protected function driverRead(CacheItemInterface $item): array
+	{
+		return [
+			self::DRIVER_DATA_WRAPPER_INDEX => true,
+			self::DRIVER_TAGS_WRAPPER_INDEX => [],
+			self::DRIVER_EDATE_WRAPPER_INDEX => new DateTime(),
+		];
+	}
+
+	/**
+	 * @param CacheItemInterface $item
+	 * @return bool
+	 * @throws PhpfastcacheInvalidArgumentException
+	 */
+	protected function driverDelete(CacheItemInterface $item): bool
+	{
+		/**
+		 * Check for Cross-Driver type confusion
+		 */
+		if ($item instanceof Item) {
+			return false;
+		}
+
+		throw new PhpfastcacheInvalidArgumentException('Cross-Driver type confusion detected');
+	}
+
+	/**
+	 * @return bool
+	 */
+	protected function driverClear(): bool
+	{
+		return false;
+	}
+
+	/********************
      *
      * PSR-6 Extended Methods
      *
      *******************/
 
-    /**
-     * @return bool
-     */
-    protected function driverConnect(): bool
-    {
-        return false;
-    }
+	/**
+	 * @return bool
+	 */
+	protected function driverConnect(): bool
+	{
+		return false;
+	}
 }
\ No newline at end of file

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

Indentation +38 added lines, -38 removed lines

@@ -20,48 +20,48 @@
 
 class Config extends CoubaseV2Config
 {
-    /**
-     * @var string
-     */
-    protected $bucketName = 'phpfastcache';
+	/**
+	 * @var string
+	 */
+	protected $bucketName = 'phpfastcache';
 
-    protected $scopeName = self::DEFAULT_VALUE;
+	protected $scopeName = self::DEFAULT_VALUE;
 
-    protected $collectionName = self::DEFAULT_VALUE;
+	protected $collectionName = self::DEFAULT_VALUE;
 
-    /**
-     * @return string
-     */
-    public function getScopeName(): string
-    {
-        return $this->scopeName;
-    }
+	/**
+	 * @return string
+	 */
+	public function getScopeName(): string
+	{
+		return $this->scopeName;
+	}
 
-    /**
-     * @param string $scopeName
-     * @return Config
-     */
-    public function setScopeName(string $scopeName): Config
-    {
-        $this->scopeName = $scopeName;
-        return $this;
-    }
+	/**
+	 * @param string $scopeName
+	 * @return Config
+	 */
+	public function setScopeName(string $scopeName): Config
+	{
+		$this->scopeName = $scopeName;
+		return $this;
+	}
 
-    /**
-     * @return string
-     */
-    public function getCollectionName(): string
-    {
-        return $this->collectionName;
-    }
+	/**
+	 * @return string
+	 */
+	public function getCollectionName(): string
+	{
+		return $this->collectionName;
+	}
 
-    /**
-     * @param string $collectionName
-     * @return Config
-     */
-    public function setCollectionName(string $collectionName): Config
-    {
-        $this->collectionName = $collectionName;
-        return $this;
-    }
+	/**
+	 * @param string $collectionName
+	 * @return Config
+	 */
+	public function setCollectionName(string $collectionName): Config
+	{
+		$this->collectionName = $collectionName;
+		return $this;
+	}
 }

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

Indentation +23 added lines, -23 removed lines

@@ -27,30 +27,30 @@
  */
 class Item extends CoubaseV2Item
 {
-    /**
-     * Item constructor.
-     * @param Driver $driver
-     * @param $key
-     * @throws PhpfastcacheInvalidArgumentException
-     */
-    public function __construct(CouchbaseDriver $driver, $key)
-    {
-        parent::__construct($driver, $key);
-    }
+	/**
+	 * Item constructor.
+	 * @param Driver $driver
+	 * @param $key
+	 * @throws PhpfastcacheInvalidArgumentException
+	 */
+	public function __construct(CouchbaseDriver $driver, $key)
+	{
+		parent::__construct($driver, $key);
+	}
 
-    /**
-     * @param ExtendedCacheItemPoolInterface $driver
-     * @return static
-     * @throws PhpfastcacheInvalidArgumentException
-     */
-    public function setDriver(ExtendedCacheItemPoolInterface $driver)
-    {
-        if ($driver instanceof CouchbaseDriver) {
-            $this->driver = $driver;
+	/**
+	 * @param ExtendedCacheItemPoolInterface $driver
+	 * @return static
+	 * @throws PhpfastcacheInvalidArgumentException
+	 */
+	public function setDriver(ExtendedCacheItemPoolInterface $driver)
+	{
+		if ($driver instanceof CouchbaseDriver) {
+			$this->driver = $driver;
 
-            return $this;
-        }
+			return $this;
+		}
 
-        throw new PhpfastcacheInvalidArgumentException('Invalid driver instance');
-    }
+		throw new PhpfastcacheInvalidArgumentException('Invalid driver instance');
+	}
 }

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

Indentation +166 added lines, -166 removed lines

@@ -33,170 +33,170 @@
  */
 class Driver extends CoubaseV2Driver
 {
-    /**
-     * @var Scope
-     */
-    protected $scope;
-
-    /**
-     * @var Collection
-     */
-    protected $collection;
-
-    public function __construct(ConfigurationOption $config, $instanceId)
-    {
-        $this->__baseConstruct($config, $instanceId);
-    }
-
-    /**
-     * @return bool
-     * @throws PhpfastcacheLogicException
-     */
-    protected function driverConnect(): bool
-    {
-        if (!\class_exists(ClusterOptions::class)) {
-            throw new PhpfastcacheDriverCheckException('You are using the Couchbase PHP SDK 2.x so please use driver Couchbasev3');
-        }
-
-        $connectionString = "couchbase://{$this->getConfig()->getHost()}:{$this->getConfig()->getPort()}";
-
-        $options = new ClusterOptions();
-        $options->credentials($this->getConfig()->getUsername(), $this->getConfig()->getPassword());
-        $this->instance = new Cluster($connectionString, $options);
-
-        $this->setBucket($this->instance->bucket($this->getConfig()->getBucketName()));
-        $this->setScope($this->getBucket()->scope($this->getConfig()->getScopeName()));
-        $this->setCollection($this->getScope()->collection($this->getConfig()->getCollectionName()));
-
-        return true;
-    }
-
-    /**
-     * @param CacheItemInterface $item
-     * @return null|array
-     */
-    protected function driverRead(CacheItemInterface $item)
-    {
-        try {
-            /**
-             * CouchbaseBucket::get() returns a GetResult interface
-             */
-            return $this->decodeDocument((array)$this->getCollection()->get($item->getEncodedKey())->content());
-        } catch (DocumentNotFoundException $e) {
-            return null;
-        }
-    }
-
-    /**
-     * @param CacheItemInterface $item
-     * @return bool
-     * @throws PhpfastcacheInvalidArgumentException
-     */
-    protected function driverWrite(CacheItemInterface $item): bool
-    {
-        /**
-         * Check for Cross-Driver type confusion
-         */
-        if ($item instanceof Item) {
-            try {
-                $this->getCollection()->upsert(
-                    $item->getEncodedKey(),
-                    $this->encodeDocument($this->driverPreWrap($item)),
-                    (new UpsertOptions())->expiry($item->getTtl())
-                );
-                return true;
-            } catch (CouchbaseException $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 {
-                $this->getCollection()->remove($item->getEncodedKey());
-                return true;
-            } catch (DocumentNotFoundException $e) {
-                return true;
-            } catch (CouchbaseException $e) {
-                return false;
-            }
-        }
-
-        throw new PhpfastcacheInvalidArgumentException('Cross-Driver type confusion detected');
-    }
-
-    /**
-     * @return bool
-     */
-    protected function driverClear(): bool
-    {
-        $this->instance->buckets()->flush($this->getConfig()->getBucketName());
-        return true;
-    }
-
-    /**
-     * @return DriverStatistic
-     */
-    public function getStats(): DriverStatistic
-    {
-        /**
-         * Between SDK 2 and 3 we lost a lot of useful information :(
-         * @see https://docs.couchbase.com/java-sdk/current/project-docs/migrating-sdk-code-to-3.n.html#management-apis
-         */
-        $info = $this->getBucket()->diagnostics(\bin2hex(\random_bytes(16)));
-
-        return (new DriverStatistic())
-            ->setSize(0)
-            ->setRawData($info)
-            ->setData(implode(', ', array_keys($this->itemInstances)))
-            ->setInfo( $info['sdk'] . "\n For more information see RawData.");
-    }
-
-    /**
-     * @return Collection
-     */
-    public function getCollection(): Collection
-    {
-        return $this->collection;
-    }
-
-    /**
-     * @param Collection $collection
-     * @return Driver
-     */
-    public function setCollection(Collection $collection): Driver
-    {
-        $this->collection = $collection;
-        return $this;
-    }
-
-    /**
-     * @return Scope
-     */
-    public function getScope(): Scope
-    {
-        return $this->scope;
-    }
-
-    /**
-     * @param Scope $scope
-     * @return Driver
-     */
-    public function setScope(Scope $scope): Driver
-    {
-        $this->scope = $scope;
-        return $this;
-    }
+	/**
+	 * @var Scope
+	 */
+	protected $scope;
+
+	/**
+	 * @var Collection
+	 */
+	protected $collection;
+
+	public function __construct(ConfigurationOption $config, $instanceId)
+	{
+		$this->__baseConstruct($config, $instanceId);
+	}
+
+	/**
+	 * @return bool
+	 * @throws PhpfastcacheLogicException
+	 */
+	protected function driverConnect(): bool
+	{
+		if (!\class_exists(ClusterOptions::class)) {
+			throw new PhpfastcacheDriverCheckException('You are using the Couchbase PHP SDK 2.x so please use driver Couchbasev3');
+		}
+
+		$connectionString = "couchbase://{$this->getConfig()->getHost()}:{$this->getConfig()->getPort()}";
+
+		$options = new ClusterOptions();
+		$options->credentials($this->getConfig()->getUsername(), $this->getConfig()->getPassword());
+		$this->instance = new Cluster($connectionString, $options);
+
+		$this->setBucket($this->instance->bucket($this->getConfig()->getBucketName()));
+		$this->setScope($this->getBucket()->scope($this->getConfig()->getScopeName()));
+		$this->setCollection($this->getScope()->collection($this->getConfig()->getCollectionName()));
+
+		return true;
+	}
+
+	/**
+	 * @param CacheItemInterface $item
+	 * @return null|array
+	 */
+	protected function driverRead(CacheItemInterface $item)
+	{
+		try {
+			/**
+			 * CouchbaseBucket::get() returns a GetResult interface
+			 */
+			return $this->decodeDocument((array)$this->getCollection()->get($item->getEncodedKey())->content());
+		} catch (DocumentNotFoundException $e) {
+			return null;
+		}
+	}
+
+	/**
+	 * @param CacheItemInterface $item
+	 * @return bool
+	 * @throws PhpfastcacheInvalidArgumentException
+	 */
+	protected function driverWrite(CacheItemInterface $item): bool
+	{
+		/**
+		 * Check for Cross-Driver type confusion
+		 */
+		if ($item instanceof Item) {
+			try {
+				$this->getCollection()->upsert(
+					$item->getEncodedKey(),
+					$this->encodeDocument($this->driverPreWrap($item)),
+					(new UpsertOptions())->expiry($item->getTtl())
+				);
+				return true;
+			} catch (CouchbaseException $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 {
+				$this->getCollection()->remove($item->getEncodedKey());
+				return true;
+			} catch (DocumentNotFoundException $e) {
+				return true;
+			} catch (CouchbaseException $e) {
+				return false;
+			}
+		}
+
+		throw new PhpfastcacheInvalidArgumentException('Cross-Driver type confusion detected');
+	}
+
+	/**
+	 * @return bool
+	 */
+	protected function driverClear(): bool
+	{
+		$this->instance->buckets()->flush($this->getConfig()->getBucketName());
+		return true;
+	}
+
+	/**
+	 * @return DriverStatistic
+	 */
+	public function getStats(): DriverStatistic
+	{
+		/**
+		 * Between SDK 2 and 3 we lost a lot of useful information :(
+		 * @see https://docs.couchbase.com/java-sdk/current/project-docs/migrating-sdk-code-to-3.n.html#management-apis
+		 */
+		$info = $this->getBucket()->diagnostics(\bin2hex(\random_bytes(16)));
+
+		return (new DriverStatistic())
+			->setSize(0)
+			->setRawData($info)
+			->setData(implode(', ', array_keys($this->itemInstances)))
+			->setInfo( $info['sdk'] . "\n For more information see RawData.");
+	}
+
+	/**
+	 * @return Collection
+	 */
+	public function getCollection(): Collection
+	{
+		return $this->collection;
+	}
+
+	/**
+	 * @param Collection $collection
+	 * @return Driver
+	 */
+	public function setCollection(Collection $collection): Driver
+	{
+		$this->collection = $collection;
+		return $this;
+	}
+
+	/**
+	 * @return Scope
+	 */
+	public function getScope(): Scope
+	{
+		return $this->scope;
+	}
+
+	/**
+	 * @param Scope $scope
+	 * @return Driver
+	 */
+	public function setScope(Scope $scope): Driver
+	{
+		$this->scope = $scope;
+		return $this;
+	}
 }

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

Indentation +109 added lines, -109 removed lines

@@ -23,113 +23,113 @@
 
 class Config extends ConfigurationOption
 {
-    /**
-     * @var array
-     *
-     * Multiple server can be added this way:
-     *       $cfg->setServers([
-     *         [
-     *           // If you use an UNIX socket set the host and port to null
-     *           'host' => '127.0.0.1',
-     *           //'path' => 'path/to/unix/socket',
-     *           'port' => 11211,
-     *         ]
-     *      ]);
-     */
-    protected $servers = [];
-
-    /**
-     * @var string
-     */
-    protected $host = '127.0.0.1';
-
-    /**
-     * @var int
-     */
-    protected $port = 11211;
-
-    /**
-     * @return array
-     */
-    public function getServers(): array
-    {
-        return $this->servers;
-    }
-
-    /**
-     * @param array $servers
-     * @return self
-     * @throws PhpfastcacheInvalidConfigurationException
-     */
-    public function setServers(array $servers): self
-    {
-        foreach ($servers as $server) {
-            if (\array_key_exists('saslUser', $server) || array_key_exists('saslPassword', $server)) {
-                throw new PhpfastcacheInvalidConfigurationException('Unlike Memcached, Memcache does not support SASL authentication');
-            }
-
-            if ($diff = array_diff(array_keys($server), ['host', 'port', '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');
-            }
-        }
-        $this->servers = $servers;
-        return $this;
-    }
-
-    /**
-     * @return string
-     */
-    public function getHost(): string
-    {
-        return $this->host;
-    }
-
-    /**
-     * @param string $host
-     * @return self
-     */
-    public function setHost(string $host): self
-    {
-        $this->host = $host;
-
-        return $this;
-    }
-
-    /**
-     * @return int
-     */
-    public function getPort(): int
-    {
-        return $this->port;
-    }
-
-    /**
-     * @param int $port
-     * @return self
-     */
-    public function setPort(int $port): self
-    {
-        $this->port = $port;
-        return $this;
-    }
+	/**
+	 * @var array
+	 *
+	 * Multiple server can be added this way:
+	 *       $cfg->setServers([
+	 *         [
+	 *           // If you use an UNIX socket set the host and port to null
+	 *           'host' => '127.0.0.1',
+	 *           //'path' => 'path/to/unix/socket',
+	 *           'port' => 11211,
+	 *         ]
+	 *      ]);
+	 */
+	protected $servers = [];
+
+	/**
+	 * @var string
+	 */
+	protected $host = '127.0.0.1';
+
+	/**
+	 * @var int
+	 */
+	protected $port = 11211;
+
+	/**
+	 * @return array
+	 */
+	public function getServers(): array
+	{
+		return $this->servers;
+	}
+
+	/**
+	 * @param array $servers
+	 * @return self
+	 * @throws PhpfastcacheInvalidConfigurationException
+	 */
+	public function setServers(array $servers): self
+	{
+		foreach ($servers as $server) {
+			if (\array_key_exists('saslUser', $server) || array_key_exists('saslPassword', $server)) {
+				throw new PhpfastcacheInvalidConfigurationException('Unlike Memcached, Memcache does not support SASL authentication');
+			}
+
+			if ($diff = array_diff(array_keys($server), ['host', 'port', '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');
+			}
+		}
+		$this->servers = $servers;
+		return $this;
+	}
+
+	/**
+	 * @return string
+	 */
+	public function getHost(): string
+	{
+		return $this->host;
+	}
+
+	/**
+	 * @param string $host
+	 * @return self
+	 */
+	public function setHost(string $host): self
+	{
+		$this->host = $host;
+
+		return $this;
+	}
+
+	/**
+	 * @return int
+	 */
+	public function getPort(): int
+	{
+		return $this->port;
+	}
+
+	/**
+	 * @param int $port
+	 * @return self
+	 */
+	public function setPort(int $port): self
+	{
+		$this->port = $port;
+		return $this;
+	}
 }