D-Net

<?php

/*

 * This file is part of the Predis package.

 *

 * (c) Daniele Alessandri <suppakilla@gmail.com>

 *

 * For the full copyright and license information, please view the LICENSE

 * file that was distributed with this source code.

 */

namespace Predis\Command\Processor;

use PredisTestCase;

/**

 *

 */

class ProcessorChainTest extends PredisTestCase

{

    /**

     * @group disconnected

     */

    public function testConstructor()

    {

        $chain = new ProcessorChain();

        $this->assertInstanceOf('Predis\Command\Processor\CommandProcessorInterface', $chain);

        $this->assertInstanceOf('Predis\Command\Processor\CommandProcessorChainInterface', $chain);

        $this->assertEmpty($chain->getProcessors());

    }

    /**

     * @group disconnected

     */

    public function testConstructorWithProcessorsArray()

    {

        $processors = array(

            $this->getMock('Predis\Command\Processor\CommandProcessorInterface'),

            $this->getMock('Predis\Command\Processor\CommandProcessorInterface'),

        );

        $chain = new ProcessorChain($processors);

        $this->assertSame($processors, $chain->getProcessors());

    }

    /**

     * @group disconnected

     */

    public function testCountProcessors()

    {

        $processors = array(

            $this->getMock('Predis\Command\Processor\CommandProcessorInterface'),

            $this->getMock('Predis\Command\Processor\CommandProcessorInterface'),

        );

        $chain = new ProcessorChain($processors);

        $this->assertEquals(2, $chain->count());

    }

    /**

     * @group disconnected

     */

    public function testAddProcessors()

    {

        $processors = array(

            $this->getMock('Predis\Command\Processor\CommandProcessorInterface'),

            $this->getMock('Predis\Command\Processor\CommandProcessorInterface'),

        );

        $chain = new ProcessorChain();

        $chain->add($processors[0]);

        $chain->add($processors[1]);

        $this->assertSame($processors, $chain->getProcessors());

    }

    /**

     * @group disconnected

     */

    public function testAddMoreProcessors()

    {

        $processors1 = array(

            $this->getMock('Predis\Command\Processor\CommandProcessorInterface'),

            $this->getMock('Predis\Command\Processor\CommandProcessorInterface'),

        );

        $processors2 = array(

            $this->getMock('Predis\Command\Processor\CommandProcessorInterface'),

            $this->getMock('Predis\Command\Processor\CommandProcessorInterface'),

        );

        $chain = new ProcessorChain($processors1);

        $chain->add($processors2[0]);

        $chain->add($processors2[1]);

        $this->assertSame(array_merge($processors1, $processors2), $chain->getProcessors());

    }

    /**

     * @group disconnected

     */

    public function testRemoveProcessors()

    {

        $processors = array(

            $this->getMock('Predis\Command\Processor\CommandProcessorInterface'),

            $this->getMock('Predis\Command\Processor\CommandProcessorInterface'),

        );

        $chain = new ProcessorChain($processors);

        $chain->remove($processors[0]);

        $this->assertSame(array($processors[1]), $chain->getProcessors());

        $chain->remove($processors[1]);

        $this->assertEmpty($chain->getProcessors());

    }

    /**

     * @group disconnected

     */

    public function testRemoveProcessorNotInChain()

    {

        $processor = $this->getMock('Predis\Command\Processor\CommandProcessorInterface');

        $processors = array(

            $this->getMock('Predis\Command\Processor\CommandProcessorInterface'),

            $this->getMock('Predis\Command\Processor\CommandProcessorInterface'),

        );

        $chain = new ProcessorChain($processors);

        $chain->remove($processor);

        $this->assertSame($processors, $chain->getProcessors());

    }

    /**

     * @group disconnected

     */

    public function testRemoveProcessorFromEmptyChain()

    {

        $processor = $this->getMock('Predis\Command\Processor\CommandProcessorInterface');

        $chain = new ProcessorChain();

        $this->assertEmpty($chain->getProcessors());

        $chain->remove($processor);

        $this->assertEmpty($chain->getProcessors());

    }

    /**

     * @group disconnected

     */

    public function testProcessChain()

    {

        $command = $this->getMock('Predis\Command\CommandInterface');

        $processor1 = $this->getMock('Predis\Command\Processor\CommandProcessorInterface');

        $processor1->expects($this->once())->method('process')->with($command);

        $processor2 = $this->getMock('Predis\Command\Processor\CommandProcessorInterface');

        $processor2->expects($this->once())->method('process')->with($command);

        $processors = array($processor1, $processor2);

        $chain = new ProcessorChain($processors);

        $chain->process($command);

    }

}