ClientTest::testConnectionException() - Code Metrics - Inspection of "Merging 1.0 in 1.1" - thecodingmachine/oo-amqp-client - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — 1.1 ( be0fbd...d8480c )

by David

created 2018-01-25 15:33 UTC

ClientTest::testConnectionException() A

↳ Parent: ClientTest

Complexity

Conditions	1
Paths	1

Size

Total Lines	5
Code Lines	3

Duplication

Lines	0
Ratio	0 %

Importance

Changes	1
Bugs	0	Features	0

Metric	Value
c	1
b	0
f	0
dl	0
loc	5
rs	9.4285
cc	1
eloc	3
nc	1
nop	0

<?php

namespace Mouf\AmqpClient\Objects;

use Mouf\AmqpClient\Client;
use Mouf\AmqpClient\Consumer;
use Mouf\AmqpClient\ConsumerService;
use PhpAmqpLib\Message\AMQPMessage;
use PHPUnit\Framework\TestCase;
use Psr\Log\NullLogger;

class ClientTest extends TestCase
{
    /**
     * @var Client
     */
    private $client;
    private $exchange;
    /**
     * @var Queue
     */
    private $queue;
    /**
     * @var Exchange
     */
    private $deadLetterExchange;
    /**
     * @var Queue
     */
    private $deadLetterQueue;
    private $msgReceived;
    private $deadLetterMsgReceived;
    private $triggerException = false;

    private function makeClient($port = null)
    {
        global $rabbitmq_host;
function myFunction($a, $b) {
    // Do something
}
        global $rabbitmq_port;
function myFunction($a, $b) {
    // Do something
}
        global $rabbitmq_user;
function myFunction($a, $b) {
    // Do something
}
        global $rabbitmq_password;
function myFunction($a, $b) {
    // Do something
}

        if (!$port) {
            $port = $rabbitmq_port;
        }

        $client = new Client($rabbitmq_host, $port, $rabbitmq_user, $rabbitmq_password);
        $client->setPrefetchCount(1);
        return $client;
    }

    protected function init($port = null)
    {
        $this->client = $this->makeClient($port);
        $this->exchange = new Exchange($this->client, 'test_exchange', 'fanout');
        $this->queue = new Queue($this->client, 'test_queue', [
            new Consumer(function(AMQPMessage $msg) {
                $this->msgReceived = $msg;
                if ($this->triggerException) {
                    throw new \Exception('boom!');
                }
            }, new NullLogger())
        ]);
        $this->queue->setDurable(true);

        $binding = new Binding($this->exchange, $this->queue);
        $this->client->register($binding);


        $this->deadLetterExchange = new Exchange($this->client, 'test_dead_letter_exchange', 'fanout');

        $this->deadLetterQueue = new Queue($this->client, 'test_dead_letter_queue', [
            new Consumer(function(AMQPMessage $msg) {
                $this->deadLetterMsgReceived = $msg;
            }, new NullLogger())
        ]);
        $this->deadLetterQueue->setDurable(true);

        $this->queue->setDeadLetterExchange($this->deadLetterExchange);

        $binding = new Binding($this->deadLetterExchange, $this->deadLetterQueue);
        $this->client->register($binding);
    }

    public function testExchange()
    {
        $this->init();
        $this->exchange->publish(new Message('my message'), 'key');
        $this->assertTrue(true);
    }

    /**
     * @depends testExchange
     */
    public function testQueue()
    {
        $this->init();

        $consumerService = new ConsumerService($this->client, [
            $this->queue
        ]);

        $consumerService->run(true);

        $this->assertEquals('my message', $this->msgReceived->getBody());
    }

    /**
     * @depends testExchange
     */
    public function testDeadLetterQueue()
    {
        $this->init();

        $this->exchange->publish(new Message('my other message'), 'key');

        $this->triggerException = true;

        $consumerService = new ConsumerService($this->client, [
            $this->queue,
            $this->deadLetterQueue
        ]);

        $consumerService->run(true);
        $consumerService->run(true);

        $this->assertEquals('my other message', $this->msgReceived->getBody());
        $this->assertEquals('my other message', $this->deadLetterMsgReceived->getBody());
    }

    public function testExceptionOnExchangeEmptyName()
    {
        $client = $this->makeClient();
        $this->expectException(\InvalidArgumentException::class);
        new Exchange($client, '', 'direct');
    }

    public function testDefaultExchange()

    {
        $client = $this->makeClient();
        // Let's send a message on RabbitMQ default exchange (named "")
        $exchange = new DefaultExchange($client);
        $queue = new Queue($client, 'test_direct_queue', [
            new Consumer(function(AMQPMessage $msg) {
                $this->msgReceived = $msg;
            }, new NullLogger())
        ]);

        // The key is the name of the queue.
        $exchange->publish(new Message('hello'), 'test_direct_queue');

        $consumerService = new ConsumerService($client, [
            $queue
        ]);

        $consumerService->run(true);

        $this->assertEquals('hello', $this->msgReceived->getBody());
    }

    public function testPublishToQueue()

    {
        $client = $this->makeClient();
        $queue = new Queue($client, 'test_direct_queue', [
            new Consumer(function (AMQPMessage $msg) {
                $this->msgReceived = $msg;
            }, new NullLogger())
        ]);

        // The key is the name of the queue.
        $queue->publish(new Message('hello'));

        $consumerService = new ConsumerService($client, [
            $queue
        ]);

        $consumerService->run(true);

        $this->assertEquals('hello', $this->msgReceived->getBody());
    }

    /**
     * @expectedException \Mouf\AmqpClient\Exception\ConnectionException
     */
    public function testConnectionException()
    {
        $this->init(1242000042);
        $this->client->getChannel();
    }
}


1		<?php
2
3		namespace Mouf\AmqpClient\Objects;
4
5		use Mouf\AmqpClient\Client;
6		use Mouf\AmqpClient\Consumer;
7		use Mouf\AmqpClient\ConsumerService;
8		use PhpAmqpLib\Message\AMQPMessage;
9		use PHPUnit\Framework\TestCase;
10		use Psr\Log\NullLogger;
11
12		class ClientTest extends TestCase
13		{
14		/**
15		* @var Client
16		*/
17		private $client;
18		private $exchange;
19		/**
20		* @var Queue
21		*/
22		private $queue;
23		/**
24		* @var Exchange
25		*/
26		private $deadLetterExchange;
27		/**
28		* @var Queue
29		*/
30		private $deadLetterQueue;
31		private $msgReceived;
32		private $deadLetterMsgReceived;
33		private $triggerException = false;
34
35		private function makeClient($port = null)
36		{
37		global $rabbitmq_host;
		0 ignored issues – show Compatibility Best Practice introduced 2016-07-07 16:27 UTC by Report Bug Copy Issue Report Use of `global` functionality is not recommended; it makes your code harder to test, and less reusable. Instead of relying on `global` state, we recommend one of these alternatives: 1. Pass all data via parameters function myFunction($a, $b) { // Do something } 2. Create a class that maintains your state class MyClass { private $a; private $b; public function __construct($a, $b) { $this->a = $a; $this->b = $b; } public function myFunction() { // Do something } } Loading history...
38		global $rabbitmq_port;
		0 ignored issues – show Compatibility Best Practice introduced 2016-07-07 16:27 UTC by Report Bug Copy Issue Report Use of `global` functionality is not recommended; it makes your code harder to test, and less reusable. Instead of relying on `global` state, we recommend one of these alternatives: 1. Pass all data via parameters function myFunction($a, $b) { // Do something } 2. Create a class that maintains your state class MyClass { private $a; private $b; public function __construct($a, $b) { $this->a = $a; $this->b = $b; } public function myFunction() { // Do something } } Loading history...
39		global $rabbitmq_user;
		0 ignored issues – show Compatibility Best Practice introduced 2016-07-07 13:54 UTC by Report Bug Copy Issue Report Use of `global` functionality is not recommended; it makes your code harder to test, and less reusable. Instead of relying on `global` state, we recommend one of these alternatives: 1. Pass all data via parameters function myFunction($a, $b) { // Do something } 2. Create a class that maintains your state class MyClass { private $a; private $b; public function __construct($a, $b) { $this->a = $a; $this->b = $b; } public function myFunction() { // Do something } } Loading history...
40		global $rabbitmq_password;
		0 ignored issues – show Compatibility Best Practice introduced 2018-01-25 15:44 UTC by Report Bug Copy Issue Report Use of `global` functionality is not recommended; it makes your code harder to test, and less reusable. Instead of relying on `global` state, we recommend one of these alternatives: 1. Pass all data via parameters function myFunction($a, $b) { // Do something } 2. Create a class that maintains your state class MyClass { private $a; private $b; public function __construct($a, $b) { $this->a = $a; $this->b = $b; } public function myFunction() { // Do something } } Loading history...
41
42		if (!$port) {
43		$port = $rabbitmq_port;
44		}
45
46		$client = new Client($rabbitmq_host, $port, $rabbitmq_user, $rabbitmq_password);
47		$client->setPrefetchCount(1);
48		return $client;
49		}
50
51		protected function init($port = null)
52		{
53		$this->client = $this->makeClient($port);
54		$this->exchange = new Exchange($this->client, 'test_exchange', 'fanout');
55		$this->queue = new Queue($this->client, 'test_queue', [
56		new Consumer(function(AMQPMessage $msg) {
57		$this->msgReceived = $msg;
58		if ($this->triggerException) {
59		throw new \Exception('boom!');
60		}
61		}, new NullLogger())
62		]);
63		$this->queue->setDurable(true);
64
65		$binding = new Binding($this->exchange, $this->queue);
66		$this->client->register($binding);
67
68
69		$this->deadLetterExchange = new Exchange($this->client, 'test_dead_letter_exchange', 'fanout');
70
71		$this->deadLetterQueue = new Queue($this->client, 'test_dead_letter_queue', [
72		new Consumer(function(AMQPMessage $msg) {
73		$this->deadLetterMsgReceived = $msg;
74		}, new NullLogger())
75		]);
76		$this->deadLetterQueue->setDurable(true);
77
78		$this->queue->setDeadLetterExchange($this->deadLetterExchange);
79
80		$binding = new Binding($this->deadLetterExchange, $this->deadLetterQueue);
81		$this->client->register($binding);
82		}
83
84		public function testExchange()
85		{
86		$this->init();
87		$this->exchange->publish(new Message('my message'), 'key');
88		$this->assertTrue(true);
89		}
90
91		/**
92		* @depends testExchange
93		*/
94		public function testQueue()
95		{
96		$this->init();
97
98		$consumerService = new ConsumerService($this->client, [
99		$this->queue
100		]);
101
102		$consumerService->run(true);
103
104		$this->assertEquals('my message', $this->msgReceived->getBody());
105		}
106
107		/**
108		* @depends testExchange
109		*/
110		public function testDeadLetterQueue()
111		{
112		$this->init();
113
114		$this->exchange->publish(new Message('my other message'), 'key');
115
116		$this->triggerException = true;
117
118		$consumerService = new ConsumerService($this->client, [
119		$this->queue,
120		$this->deadLetterQueue
121		]);
122
123		$consumerService->run(true);
124		$consumerService->run(true);
125
126		$this->assertEquals('my other message', $this->msgReceived->getBody());
127		$this->assertEquals('my other message', $this->deadLetterMsgReceived->getBody());
128		}
129
130		public function testExceptionOnExchangeEmptyName()
131		{
132		$client = $this->makeClient();
133		$this->expectException(\InvalidArgumentException::class);
134		new Exchange($client, '', 'direct');
135		}
136
137	View Code Duplication	public function testDefaultExchange()
		0 ignored issues – show Duplication introduced 2018-01-15 14:30 UTC by Report Bug Copy Issue Report This method seems to be duplicated in your project. Duplicated code is one of the most pungent code smells. If you need to duplicate the same code in three or more different places, we strongly encourage you to look into extracting the code into a single class or operation. You can also find more detailed suggestions in the “Code” section of your repository. Loading history...
138		{
139		$client = $this->makeClient();
140		// Let's send a message on RabbitMQ default exchange (named "")
141		$exchange = new DefaultExchange($client);
142		$queue = new Queue($client, 'test_direct_queue', [
143		new Consumer(function(AMQPMessage $msg) {
144		$this->msgReceived = $msg;
145		}, new NullLogger())
146		]);
147
148		// The key is the name of the queue.
149		$exchange->publish(new Message('hello'), 'test_direct_queue');
150
151		$consumerService = new ConsumerService($client, [
152		$queue
153		]);
154
155		$consumerService->run(true);
156
157		$this->assertEquals('hello', $this->msgReceived->getBody());
158		}
159
160	View Code Duplication	public function testPublishToQueue()
		0 ignored issues – show Duplication introduced 2018-01-15 14:30 UTC by Report Bug Copy Issue Report This method seems to be duplicated in your project. Duplicated code is one of the most pungent code smells. If you need to duplicate the same code in three or more different places, we strongly encourage you to look into extracting the code into a single class or operation. You can also find more detailed suggestions in the “Code” section of your repository. Loading history...
161		{
162		$client = $this->makeClient();
163		$queue = new Queue($client, 'test_direct_queue', [
164		new Consumer(function (AMQPMessage $msg) {
165		$this->msgReceived = $msg;
166		}, new NullLogger())
167		]);
168
169		// The key is the name of the queue.
170		$queue->publish(new Message('hello'));
171
172		$consumerService = new ConsumerService($client, [
173		$queue
174		]);
175
176		$consumerService->run(true);
177
178		$this->assertEquals('hello', $this->msgReceived->getBody());
179		}
180
181		/**
182		* @expectedException \Mouf\AmqpClient\Exception\ConnectionException
183		*/
184		public function testConnectionException()
185		{
186		$this->init(1242000042);
187		$this->client->getChannel();
188		}
189		}
190

thecodingmachine / oo-amqp-client

Push — 1.1 ( be0fbd...d8480c )

ClientTest::testConnectionException() A

Complexity

Size

Duplication

Importance

1. Pass all data via parameters

2. Create a class that maintains your state

1. Pass all data via parameters

2. Create a class that maintains your state

1. Pass all data via parameters

2. Create a class that maintains your state

1. Pass all data via parameters

2. Create a class that maintains your state

Duplication Side-by-Side

Filter issues like