ConnectionTest::testCreateChannelWithResource() - Code Metrics - Inspection of "Changed createChannel behavior" - thomasvargiu/AMQPAL - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — master ( ccbe64...bcccab )

by Thomas Mauro

created 2016-04-30 17:46 UTC

ConnectionTest::testCreateChannelWithResource() A

↳ Parent: ConnectionTest

Complexity

Conditions	1
Paths	1

Size

Total Lines	15
Code Lines	10

Duplication

Lines	0
Ratio	0 %

Importance

Changes	1
Bugs	0	Features	0

Metric	Value
c	1
b	0
f	0
dl	0
loc	15
rs	9.4285
cc	1
eloc	10
nc	1
nop	0

<?php

namespace AMQPAL\Adapter\PhpAmqpLib;

use AMQPAL\Adapter\PhpAmqpLib\Options\ConnectionOptions;
use PhpAmqpLib\Connection\AbstractConnection;
use PhpAmqpLib\Channel\AMQPChannel;
use AMQPAL\Options;
use Prophecy\Argument;

class ConnectionTest extends \PHPUnit_Framework_TestCase
{

    public function testConstructorWithOptions()
    {
        $adapterConnection = $this->prophesize(AbstractConnection::class);
        $options = $this->prophesize(ConnectionOptions::class);
        $connectionFactoryFactory = $this->prophesize(Factory\ConnectionFactoryFactory::class);
        $connectionFactory = $this->prophesize(Factory\ConnectionFactoryInterface::class);

        $connectionFactory->createConnection($options->reveal())->willReturn($adapterConnection->reveal());
        $connectionFactoryFactory->createFactory('foo')->willReturn($connectionFactory->reveal());
        $options->getType()->shouldBeCalled()->willReturn('foo');
        $options->getConnectionFactoryFactory()->willReturn($connectionFactoryFactory->reveal());

        $connection = new Connection($options->reveal());

        $resource = $connection->getResource();

        static::assertInstanceOf(AbstractConnection::class, $resource);
        static::assertSame($adapterConnection->reveal(), $resource);
    }

    public function testSetOptions()
    {
        $adapterConnection = $this->prophesize(AbstractConnection::class);
        $options = $this->prophesize(ConnectionOptions::class);

        $connection = new Connection($adapterConnection->reveal());

        static::assertSame($connection, $connection->setOptions($options->reveal()));
    }

    public function testSetOptionsArray()
    {
        $adapterConnection = $this->prophesize(AbstractConnection::class);

        $options = [
            'type' => 'foo'
        ];

        $connection = new Connection($adapterConnection->reveal());

        static::assertSame($connection, $connection->setOptions($options));
        $optionsResult = $connection->getOptions();
        static::assertInstanceOf(ConnectionOptions::class, $optionsResult);
        static::assertEquals('foo', $optionsResult->getType());
    }

    public function testIsConnected()
    {
        $adapterConnection = $this->prophesize(AbstractConnection::class);
        $adapterConnection->isConnected()->shouldBeCalled()->willReturn(true);

        $connection = new Connection($adapterConnection->reveal());

        $result = $connection->isConnected();
        static::assertTrue($result);
    }

    public function testConnect()
    {
        $adapterConnection = $this->prophesize(AbstractConnection::class);

        $adapterConnection->isConnected()->shouldBeCalled()->willReturn(false);
        $adapterConnection->reconnect()->shouldBeCalled();

        $connection = new Connection($adapterConnection->reveal());

        $result = $connection->connect();
        static::assertInstanceOf(Connection::class, $result);
    }

    public function testReconnect()
    {
        $adapterConnection = $this->prophesize(AbstractConnection::class);

        $adapterConnection->reconnect()->shouldBeCalled();

        $connection = new Connection($adapterConnection->reveal());

        $result = $connection->reconnect();
        static::assertInstanceOf(Connection::class, $result);
    }

    public function testDisconnect()
    {
        $adapterConnection = $this->prophesize(AbstractConnection::class);

        $adapterConnection->close()->shouldBeCalled();

        $connection = new Connection($adapterConnection->reveal());

        $result = $connection->disconnect();
        static::assertInstanceOf(Connection::class, $result);
    }

    public function testCreateChannelWithResource()
    {
        $adapterConnection = $this->prophesize(AbstractConnection::class);
        $channelPrototype = $this->prophesize(Channel::class);
        $channelResource = $this->prophesize(AMQPChannel::class);

        $connection = new Connection($adapterConnection->reveal());
        $connection->registerChannel($channelPrototype->reveal());

        $channelPrototype->setResource($channelResource->reveal())->shouldBeCalled();
        $channelPrototype->setConnection($connection)->shouldBeCalled();

        $result = $connection->createChannel($channelResource->reveal());
        static::assertInstanceOf(Channel::class, $result);
    }

    public function testCreateChannel()
    {
        $adapterConnection = $this->prophesize(AbstractConnection::class);
        $channelPrototype = $this->prophesize(Channel::class);
        $channelResource = $this->prophesize(AMQPChannel::class);

        $adapterConnection->isConnected()->shouldBeCalled()->willReturn(true);
        $adapterConnection->channel()->shouldBeCalled()->willReturn($channelResource->reveal());
        $channelPrototype->setResource($channelResource->reveal())->shouldBeCalled();

        $connection = new Connection($adapterConnection->reveal());
        $connection->registerChannel($channelPrototype->reveal());
        $channelPrototype->setConnection($connection)->shouldBeCalled();

        $channel = $connection->createChannel();
        static::assertInstanceOf(Channel::class, $channel);
    }

    public function testCreateChannelWithConnect()
    {
        $adapterConnection = $this->prophesize(AbstractConnection::class);
        $channelPrototype = $this->prophesize(Channel::class);
        $channelResource = $this->prophesize(AMQPChannel::class);

        $adapterConnection->isConnected()->shouldBeCalled()->willReturn(false);
        $adapterConnection->reconnect()->shouldBeCalled();
        $adapterConnection->channel()->shouldBeCalled()->willReturn($channelResource->reveal());
        $channelPrototype->setResource($channelResource->reveal())->shouldBeCalled();

        $connection = new Connection($adapterConnection->reveal());
        $connection->registerChannel($channelPrototype->reveal());
        $channelPrototype->setConnection($connection)->shouldBeCalled();
        $channelPrototype->setConnection($connection)->shouldBeCalled();

        $channel = $connection->createChannel();
        static::assertInstanceOf(Channel::class, $channel);
    }
}


1			<?php
2
3			namespace AMQPAL\Adapter\PhpAmqpLib;
4
5			use AMQPAL\Adapter\PhpAmqpLib\Options\ConnectionOptions;
6			use PhpAmqpLib\Connection\AbstractConnection;
7			use PhpAmqpLib\Channel\AMQPChannel;
8			use AMQPAL\Options;
9			use Prophecy\Argument;
10
11			class ConnectionTest extends \PHPUnit_Framework_TestCase
12			{
13
14			public function testConstructorWithOptions()
15			{
16			$adapterConnection = $this->prophesize(AbstractConnection::class);
17			$options = $this->prophesize(ConnectionOptions::class);
18			$connectionFactoryFactory = $this->prophesize(Factory\ConnectionFactoryFactory::class);
19			$connectionFactory = $this->prophesize(Factory\ConnectionFactoryInterface::class);
20
21			$connectionFactory->createConnection($options->reveal())->willReturn($adapterConnection->reveal());
22			$connectionFactoryFactory->createFactory('foo')->willReturn($connectionFactory->reveal());
23			$options->getType()->shouldBeCalled()->willReturn('foo');
24			$options->getConnectionFactoryFactory()->willReturn($connectionFactoryFactory->reveal());
25
26			$connection = new Connection($options->reveal());
27
28			$resource = $connection->getResource();
29
30			static::assertInstanceOf(AbstractConnection::class, $resource);
31			static::assertSame($adapterConnection->reveal(), $resource);
32			}
33
34			public function testSetOptions()
35			{
36			$adapterConnection = $this->prophesize(AbstractConnection::class);
37			$options = $this->prophesize(ConnectionOptions::class);
38
39			$connection = new Connection($adapterConnection->reveal());
40
41			static::assertSame($connection, $connection->setOptions($options->reveal()));
42			}
43
44			public function testSetOptionsArray()
45			{
46			$adapterConnection = $this->prophesize(AbstractConnection::class);
47
48			$options = [
49			'type' => 'foo'
50			];
51
52			$connection = new Connection($adapterConnection->reveal());
53
54			static::assertSame($connection, $connection->setOptions($options));
55			$optionsResult = $connection->getOptions();
56			static::assertInstanceOf(ConnectionOptions::class, $optionsResult);
57			static::assertEquals('foo', $optionsResult->getType());
58			}
59
60			public function testIsConnected()
61			{
62			$adapterConnection = $this->prophesize(AbstractConnection::class);
63			$adapterConnection->isConnected()->shouldBeCalled()->willReturn(true);
64
65			$connection = new Connection($adapterConnection->reveal());
66
67			$result = $connection->isConnected();
68			static::assertTrue($result);
69			}
70
71			public function testConnect()
72			{
73			$adapterConnection = $this->prophesize(AbstractConnection::class);
74
75			$adapterConnection->isConnected()->shouldBeCalled()->willReturn(false);
76			$adapterConnection->reconnect()->shouldBeCalled();
77
78			$connection = new Connection($adapterConnection->reveal());
79
80			$result = $connection->connect();
81			static::assertInstanceOf(Connection::class, $result);
82			}
83
84			public function testReconnect()
85			{
86			$adapterConnection = $this->prophesize(AbstractConnection::class);
87
88			$adapterConnection->reconnect()->shouldBeCalled();
89
90			$connection = new Connection($adapterConnection->reveal());
91
92			$result = $connection->reconnect();
93			static::assertInstanceOf(Connection::class, $result);
94			}
95
96			public function testDisconnect()
97			{
98			$adapterConnection = $this->prophesize(AbstractConnection::class);
99
100			$adapterConnection->close()->shouldBeCalled();
101
102			$connection = new Connection($adapterConnection->reveal());
103
104			$result = $connection->disconnect();
105			static::assertInstanceOf(Connection::class, $result);
106			}
107
108			public function testCreateChannelWithResource()
109			{
110			$adapterConnection = $this->prophesize(AbstractConnection::class);
111			$channelPrototype = $this->prophesize(Channel::class);
112			$channelResource = $this->prophesize(AMQPChannel::class);
113
114			$connection = new Connection($adapterConnection->reveal());
115			$connection->registerChannel($channelPrototype->reveal());
116
117			$channelPrototype->setResource($channelResource->reveal())->shouldBeCalled();
118			$channelPrototype->setConnection($connection)->shouldBeCalled();
119
120			$result = $connection->createChannel($channelResource->reveal());
121			static::assertInstanceOf(Channel::class, $result);
122			}
123
124			public function testCreateChannel()
125			{
126			$adapterConnection = $this->prophesize(AbstractConnection::class);
127			$channelPrototype = $this->prophesize(Channel::class);
128			$channelResource = $this->prophesize(AMQPChannel::class);
129
130			$adapterConnection->isConnected()->shouldBeCalled()->willReturn(true);
131			$adapterConnection->channel()->shouldBeCalled()->willReturn($channelResource->reveal());
132			$channelPrototype->setResource($channelResource->reveal())->shouldBeCalled();
133
134			$connection = new Connection($adapterConnection->reveal());
135			$connection->registerChannel($channelPrototype->reveal());
136			$channelPrototype->setConnection($connection)->shouldBeCalled();
137
138			$channel = $connection->createChannel();
139			static::assertInstanceOf(Channel::class, $channel);
140			}
141
142			public function testCreateChannelWithConnect()
143			{
144			$adapterConnection = $this->prophesize(AbstractConnection::class);
145			$channelPrototype = $this->prophesize(Channel::class);
146			$channelResource = $this->prophesize(AMQPChannel::class);
147
148			$adapterConnection->isConnected()->shouldBeCalled()->willReturn(false);
149			$adapterConnection->reconnect()->shouldBeCalled();
150			$adapterConnection->channel()->shouldBeCalled()->willReturn($channelResource->reveal());
151			$channelPrototype->setResource($channelResource->reveal())->shouldBeCalled();
152
153			$connection = new Connection($adapterConnection->reveal());
154			$connection->registerChannel($channelPrototype->reveal());
155			$channelPrototype->setConnection($connection)->shouldBeCalled();
156			$channelPrototype->setConnection($connection)->shouldBeCalled();
157
158			$channel = $connection->createChannel();
159			static::assertInstanceOf(Channel::class, $channel);
160			}
161			}
162

thomasvargiu / AMQPAL

Push — master ( ccbe64...bcccab )

ConnectionTest::testCreateChannelWithResource() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like