BEAR\QueryRepository\StorageRedisDsnModule

Complexity

Total Complexity

2

Size/Duplication

Total Lines	27
Duplicated Lines	0 %

Importance

Changes	2
Bugs	0	Features	0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	configure()	0	10	1
A	__construct()	0	6	1

<?php

declare(strict_types=1);

namespace BEAR\QueryRepository;

use BEAR\RepositoryModule\Annotation\RedisDsn;
use BEAR\RepositoryModule\Annotation\RedisDsnOptions;
use Psr\Cache\CacheItemPoolInterface;
use Ray\Di\AbstractModule;
use Ray\Di\ProviderInterface;
use Ray\Di\Scope;
use Ray\PsrCacheModule\Annotation\CacheNamespace;
use Ray\PsrCacheModule\Annotation\Local;
use Ray\PsrCacheModule\Annotation\Shared;
use Ray\PsrCacheModule\ApcuAdapter;
use Ray\PsrCacheModule\RedisAdapter;
use ReflectionException;

/**
 * Provides ResourceStorageInterface and derived bindings
 * *
 * * The following bindings are provided:
 * *
 * * CacheItemPoolInterface-EtagPool::class
 * *
 * * The following module are installed:
 * *
 * * Psr6RedisModule
 * Provides CacheItemPool and derived bindings
 *
 * [...]
 *
 * The following bindings are provided:
 *
 *  ::RedisDsn
 *  CacheItemPoolInterface::Local
 *  CacheItemPoolInterface::Shared
 */
final class StorageRedisDsnModule extends AbstractModule
{
    /**
     * Redis configuration DSN
     *
     * @param string                                                   $dsn     Redis DSN
     * @param array<string, bool|int|string|array<string, mixed>|null> $options Redis DSN Options
     */
    public function __construct(
        private readonly string $dsn,
        private readonly array  $options = [],
        AbstractModule|null     $module = null,
    ) {
        parent::__construct($module);
    }

    /** @throws ReflectionException */
    protected function configure(): void
    {
        $this->bind()->annotatedWith(RedisDsn::class)->toInstance($this->dsn);
        $this->bind()->annotatedWith(RedisDsnOptions::class)->toInstance($this->options);
        $this->bind(CacheItemPoolInterface::class)->annotatedWith(Local::class)->toConstructor(ApcuAdapter::class, ['namespace' => CacheNamespace::class])->in(Scope::SINGLETON);
        $this->bind(CacheItemPoolInterface::class)->annotatedWith(Shared::class)->toConstructor(RedisAdapter::class, [
            'redisProvider' => 'redis',
            'namespace' => CacheNamespace::class,
        ]);
        $this->bind(ProviderInterface::class)->annotatedWith('redis')->to(RedisDsnProvider::class);
    }
}