Asiries335\redisSteamPhp\Tests\StreamTest

Complexity

Total Complexity

4

Size/Duplication

Total Lines	89
Duplicated Lines	0 %

Importance

Changes	1
Bugs	1	Features	1

4 Methods

Rating	Name	Duplication	Size	Complexity
A	setUp()	0	3	1
A	testAddDataToStream()	0	17	1
A	testReadEmptyStream()	0	9	1
A	testReadStream()	0	22	1

<?php


namespace Asiries335\redisSteamPhp\Tests;

use Asiries335\redisSteamPhp\Data\Collection;
use Asiries335\redisSteamPhp\Stream;
use PHPUnit\Framework\TestCase;

class StreamTest extends TestCase
{
    private $client;

    private const TEST_NAME_STREAM = 'test_stream';

    /**
     * setUp
     *
     * @return void
     */
    public function setUp() : void
    {
        $this->client = \Mockery::mock(\Redis::class);
    }

    /**
     * Read empty stream
     *
     * @throws \Exception
     *
     * @return void
     */
    public function testReadEmptyStream() : void
    {
        $this->client->shouldReceive('rawCommand')->andReturn([]);

        $stream = new Stream($this->client, self::TEST_NAME_STREAM);

        $collection = $stream->get();

        $this->assertEquals(new Collection, $collection);
    }

    /**
     * Add data to stream
     *
     * @throws \Exception
     *
     * @return void
     */
    public function testAddDataToStream() : void
    {
        $key = 'name';

        $values = [
            'id'   => 123,
            'name' => 'Barney',
            'age'  => 25,
        ];

        $this->client->shouldReceive('rawCommand')->andReturn($key);

        $this->stream = new Stream($this->client, self::TEST_NAME_STREAM);

The property stream does not exist. Although not strictly required by PHP, it is generally a best practice to declare properties explicitly.

        $result = $this->stream->add($key, $values);

        $this->assertEquals($key, $result);
    }

    /**
     * Read empty stream
     *
     * @throws \Exception
     *
     * @return void
     */
    public function testReadStream() : void
    {
        $data = [
            [
                'name',
                [
                    [
                        'id',
                        'key',
                        'body'
                    ]
                ]
            ]
        ];

        $this->client->shouldReceive('rawCommand')->andReturn($data);

        $stream = new Stream($this->client, self::TEST_NAME_STREAM);

        $collectionStream = $stream->get();

        $this->assertEquals(Collection::create($data), $collectionStream);

    }
}