TraderInteractive\Api\CacheFactory

Complexity

Total Complexity

9

Size/Duplication

Total Lines	53
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	8

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	make()	0	20	5
A	getMongoCache()	0	4	1
A	getMongoCollectionFromConfig()	0	11	2
A	getRedisCache()	0	6	1

<?php

namespace TraderInteractive\Api;

use MongoDB;
use Predis;
use Psr\SimpleCache\CacheInterface;
use SubjectivePHP\Psr\SimpleCache\InMemoryCache;
use SubjectivePHP\Psr\SimpleCache\MongoCache;
use SubjectivePHP\Psr\SimpleCache\NullCache;
use SubjectivePHP\Psr\SimpleCache\RedisCache;

final class CacheFactory
{
    /**
     * @param string $name   The name of the cache object to make.
     * @param array  $config Options to use when constructing the cache.
     *
     * @return CacheInterface
     */
    public static function make(string $name, array $config) : CacheInterface
    {
        if ($name === MongoCache::class) {
            return self::getMongoCache($config);
        }

        if ($name === RedisCache::class) {
            return self::getRedisCache($config);
        }

        if ($name === InMemoryCache::class) {
            return new InMemoryCache();
        }

        if ($name === NullCache::class) {
            return new NullCache();
        }

        throw new \RuntimeException("Cannot create cache instance of '{$name}'");
    }

    private static function getMongoCache(array $config) : MongoCache
    {
        return new MongoCache(self::getMongoCollectionFromConfig($config), new ResponseSerializer());
    }

    private static function getMongoCollectionFromConfig(array $config) : MongoDB\Collection
    {
        $collection = $config['collection'];
        if ($collection instanceof MongoDB\Collection) {
            return $collection;
        }

        $uri = $config['uri'];
        $database = $config['database'];
        return (new MongoDB\Client($uri))->selectDatabase($database)->selectCollection($collection);
    }

    private static function getRedisCache(array $config) : RedisCache
    {
        $parameters = $config['parameters'] ?? null;
        $options = $config['options'] ?? null;
        return new RedisCache(new Predis\Client($parameters, $options));
    }
}