FM / Adapter

/usr/share/php/Symfony/Component/Cache/Adapter/

/usr/share/php/Symfony/Component/Cache/Adapter

Name	Size	Mode	Actions
AbstractAdapter.php	8327	0644	edit dl rm
AbstractTagAwareAdapter.php	12537	0644	edit dl rm
AdapterInterface.php	963	0644	edit dl rm
ApcuAdapter.php	3959	0644	edit dl rm
ArrayAdapter.php	11183	0644	edit dl rm
ChainAdapter.php	8968	0644	edit dl rm
CouchbaseBucketAdapter.php	7729	0644	edit dl rm
CouchbaseCollectionAdapter.php	6705	0644	edit dl rm
DoctrineAdapter.php	2845	0644	edit dl rm
DoctrineDbalAdapter.php	15355	0644	edit dl rm
FilesystemAdapter.php	933	0644	edit dl rm
FilesystemTagAwareAdapter.php	7584	0644	edit dl rm
MemcachedAdapter.php	13749	0644	edit dl rm
NullAdapter.php	2657	0644	edit dl rm
ParameterNormalizer.php	898	0644	edit dl rm
PdoAdapter.php	20331	0644	edit dl rm
PhpArrayAdapter.php	12537	0644	edit dl rm
PhpFilesAdapter.php	10260	0644	edit dl rm
ProxyAdapter.php	8469	0644	edit dl rm
Psr16Adapter.php	1941	0644	edit dl rm
RedisAdapter.php	1200	0644	edit dl rm
RedisTagAwareAdapter.php	12218	0644	edit dl rm
TagAwareAdapter.php	11387	0644	edit dl rm
TagAwareAdapterInterface.php	775	0644	edit dl rm
TraceableAdapter.php	6931	0644	edit dl rm
TraceableTagAwareAdapter.php	932	0644	edit dl rm

Edit: /usr/share/php/Symfony/Component/Cache/Adapter/CouchbaseCollectionAdapter.php (6705B)

<?php

/*
 * This file is part of the Symfony package.
 *
 * (c) Fabien Potencier <fabien@symfony.com>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

namespace Symfony\Component\Cache\Adapter;

use Couchbase\Bucket;
use Couchbase\Cluster;
use Couchbase\ClusterOptions;
use Couchbase\Collection;
use Couchbase\DocumentNotFoundException;
use Couchbase\UpsertOptions;
use Symfony\Component\Cache\Exception\CacheException;
use Symfony\Component\Cache\Exception\InvalidArgumentException;
use Symfony\Component\Cache\Marshaller\DefaultMarshaller;
use Symfony\Component\Cache\Marshaller\MarshallerInterface;

/**
 * @author Antonio Jose Cerezo Aranda <aj.cerezo@gmail.com>
 */
class CouchbaseCollectionAdapter extends AbstractAdapter
{
    private const MAX_KEY_LENGTH = 250;

/** @var Collection */
    private $connection;
    private $marshaller;

public function __construct(Collection $connection, string $namespace = '', int $defaultLifetime = 0, MarshallerInterface $marshaller = null)
    {
        if (!static::isSupported()) {
            throw new CacheException('Couchbase >= 3.0.0 < 4.0.0 is required.');
        }

$this->maxIdLength = static::MAX_KEY_LENGTH;

$this->connection = $connection;

parent::__construct($namespace, $defaultLifetime);
        $this->enableVersioning();
        $this->marshaller = $marshaller ?? new DefaultMarshaller();
    }

/**
     * @param array|string $dsn
     *
     * @return Bucket|Collection
     */
    public static function createConnection($dsn, array $options = [])
    {
        if (\is_string($dsn)) {
            $dsn = [$dsn];
        } elseif (!\is_array($dsn)) {
            throw new \TypeError(sprintf('Argument 1 passed to "%s()" must be array or string, "%s" given.', __METHOD__, get_debug_type($dsn)));
        }

if (!static::isSupported()) {
            throw new CacheException('Couchbase >= 3.0.0 < 4.0.0 is required.');
        }

set_error_handler(function ($type, $msg, $file, $line): bool { throw new \ErrorException($msg, 0, $type, $file, $line); });

$dsnPattern = '/^(?<protocol>couchbase(?:s)?)\:\/\/(?:(?<username>[^\:]+)\:(?<password>[^\@]{6,})@)?'
            .'(?<host>[^\:]+(?:\:\d+)?)(?:\/(?<bucketName>[^\/\?]+))(?:(?:\/(?<scopeName>[^\/]+))'
            .'(?:\/(?<collectionName>[^\/\?]+)))?(?:\/)?(?:\?(?<options>.*))?$/i';

$newServers = [];
        $protocol = 'couchbase';
        try {
            $username = $options['username'] ?? '';
            $password = $options['password'] ?? '';

foreach ($dsn as $server) {
                if (0 !== strpos($server, 'couchbase:')) {
                    throw new InvalidArgumentException(sprintf('Invalid Couchbase DSN: "%s" does not start with "couchbase:".', $server));
                }

preg_match($dsnPattern, $server, $matches);

$username = $matches['username'] ?: $username;
                $password = $matches['password'] ?: $password;
                $protocol = $matches['protocol'] ?: $protocol;

if (isset($matches['options'])) {
                    $optionsInDsn = self::getOptions($matches['options']);

foreach ($optionsInDsn as $parameter => $value) {
                        $options[$parameter] = $value;
                    }
                }

$newServers[] = $matches['host'];
            }

$option = isset($matches['options']) ? '?'.$matches['options'] : '';
            $connectionString = $protocol.'://'.implode(',', $newServers).$option;

$clusterOptions = new ClusterOptions();
            $clusterOptions->credentials($username, $password);

$client = new Cluster($connectionString, $clusterOptions);

$bucket = $client->bucket($matches['bucketName']);
            $collection = $bucket->defaultCollection();
            if (!empty($matches['scopeName'])) {
                $scope = $bucket->scope($matches['scopeName']);
                $collection = $scope->collection($matches['collectionName']);
            }

return $collection;
        } finally {
            restore_error_handler();
        }
    }

public static function isSupported(): bool
    {
        return \extension_loaded('couchbase') && version_compare(phpversion('couchbase'), '3.0.5', '>=') && version_compare(phpversion('couchbase'), '4.0', '<');
    }

private static function getOptions(string $options): array
    {
        $results = [];
        $optionsInArray = explode('&', $options);

foreach ($optionsInArray as $option) {
            [$key, $value] = explode('=', $option);

$results[$key] = $value;
        }

return $results;
    }

/**
     * {@inheritdoc}
     */
    protected function doFetch(array $ids): array
    {
        $results = [];
        foreach ($ids as $id) {
            try {
                $resultCouchbase = $this->connection->get($id);
            } catch (DocumentNotFoundException $exception) {
                continue;
            }

$content = $resultCouchbase->value ?? $resultCouchbase->content();

$results[$id] = $this->marshaller->unmarshall($content);
        }

return $results;
    }

/**
     * {@inheritdoc}
     */
    protected function doHave($id): bool
    {
        return $this->connection->exists($id)->exists();
    }

/**
     * {@inheritdoc}
     */
    protected function doClear($namespace): bool
    {
        return false;
    }

/**
     * {@inheritdoc}
     */
    protected function doDelete(array $ids): bool
    {
        $idsErrors = [];
        foreach ($ids as $id) {
            try {
                $result = $this->connection->remove($id);

if (null === $result->mutationToken()) {
                    $idsErrors[] = $id;
                }
            } catch (DocumentNotFoundException $exception) {
            }
        }

return 0 === \count($idsErrors);
    }

/**
     * {@inheritdoc}
     */
    protected function doSave(array $values, $lifetime)
    {
        if (!$values = $this->marshaller->marshall($values, $failed)) {
            return $failed;
        }

$upsertOptions = new UpsertOptions();
        $upsertOptions->expiry($lifetime);

$ko = [];
        foreach ($values as $key => $value) {
            try {
                $this->connection->upsert($key, $value, $upsertOptions);
            } catch (\Exception $exception) {
                $ko[$key] = '';
            }
        }

return [] === $ko ? true : $ko;
    }
}

cmd: