Phive\Queue\Tests\Queue\TarantoolQueueTest

Complexity

Total Complexity

5

Size/Duplication

Total Lines	43
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	5

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	getUnsupportedItemTypes()	0	4	1
A	testUnsupportedItemType()	0	4	1
A	testItemsOfDifferentLength()	0	7	2
A	createHandler()	0	9	1

<?php

/*
 * This file is part of the Phive Queue package.
 *
 * (c) Eugene Leonovich <gen.work@gmail.com>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

namespace Phive\Queue\Tests\Queue;

use Phive\Queue\Tests\Handler\TarantoolHandler;

/**
 * @requires extension tarantool
 */
class TarantoolQueueTest extends QueueTest
{
    use Performance;
    use Concurrency;

    protected $supportsExpiredEta = false;

    protected function getUnsupportedItemTypes()
    {
        return [Types::TYPE_ARRAY, Types::TYPE_OBJECT];
    }

    /**
     * @dataProvider provideItemsOfUnsupportedTypes
     * @expectedException PHPUnit_Framework_Exception
     * @expectedExceptionMessageRegExp /could not be converted to string|Array to string conversion|unsupported field type/
     */
    public function testUnsupportedItemType($item)
    {
        $this->queue->push($item);
    }

    /**
     * @see https://github.com/tarantool/tarantool/issues/336
     */
    public function testItemsOfDifferentLength()
    {
        for ($item = 'x'; strlen($item) < 9; $item .= 'x') {
            $this->queue->push($item);
            $this->assertEquals($item, $this->queue->pop());
        }
    }

    public static function createHandler(array $config)
    {
        return new TarantoolHandler([
            'host'      => $config['PHIVE_TARANTOOL_HOST'],
            'port'      => $config['PHIVE_TARANTOOL_PORT'],
            'space'     => $config['PHIVE_TARANTOOL_SPACE'],
            'tube_name' => $config['PHIVE_TARANTOOL_TUBE_NAME'],
        ]);
    }
}