symfony-bundles / redis-bundle

Tests/Redis/ClientTest.php

<?php

namespace SymfonyBundles\RedisBundle\Tests\Redis;

use Exception;
use SymfonyBundles\RedisBundle\Tests\TestCase;
use SymfonyBundles\RedisBundle\Redis\ClientInterface;
use Symfony\Component\DependencyInjection\ContainerBuilder;
use SymfonyBundles\RedisBundle\DependencyInjection\RedisExtension;

class ClientTest extends TestCase
{
    public function testDefaultClass(): void
    {
        $client = $this->getClient(['sb_redis' => []]);

        $this->assertInstanceOf(ClientInterface::class, $client);
    }

    public function testPush(): void
    {
        $client = $this->getClient();

        $client->remove('mykey');

        $this->assertSame(0, $client->count('mykey'));
        $this->assertSame(1, $client->push('mykey', 'foo'));
        $this->assertSame(3, $client->push('mykey', 'bar', 'baz'));
        $this->assertSame(3, $client->count('mykey'));
    }

    public function testPop(): void
    {
        $client = $this->getClient();

        $client->remove('mykey');

        $this->assertSame(0, $client->count('mykey'));
        $this->assertSame(3, $client->push('mykey', 'foo', 'bar', 'baz'));
        $this->assertSame('foo', $client->pop('mykey'));
        $this->assertSame('bar', $client->pop('mykey'));
        $this->assertSame('baz', $client->pop('mykey'));
        $this->assertSame(0, $client->count('mykey'));
    }

    public function testSingleConnection(): void
    {
        $client = $this->getClient([
            'sb_redis' => [
                'clients' => [
                    'test' => [
                        '$options' => [],
                        '$parameters' => ['tcp://127.0.0.1:6379'],
                    ],
                ],
            ],
        ]);

        $this->assertSame('OK', $client->flushall()->getPayload());

The method flushall() does not exist on SymfonyBundles\RedisBundle\Redis\ClientInterface. Since you implemented __call, consider adding a @method annotation.

    }

    /**
     * getClient.
     *
     * @param array[] $config
     *
     * @return ClientInterface
     *
     * @throws Exception
     */
    private function getClient(array $config = []): ClientInterface
    {
        $client = $this->loadExtension($config)->get(ClientInterface::class);

        if (!$client instanceof ClientInterface) {
            throw new Exception('Client not instanceof ClientInterface');
        }

        return $client;
    }

    /**
     * loadExtension.
     *
     * @param array[] $config
     *
     * @return ContainerBuilder
     */
    private function loadExtension(array $config = []): ContainerBuilder
    {
        $defaults = [
            'sb_redis' => [
                'clients' => [
                    'test' => [],
                ],
            ],
        ];

        $extension = new RedisExtension();
        $container = new ContainerBuilder();

        $extension->load(array_merge_recursive($defaults, $config), $container);

        return $container;
    }
}