RabbitMQManagementApiClient::call() - Code Metrics - Inspection of "Tables counts (#24)" - lulco/uniman - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — master ( f5adf6...a90a41 )

by Michal

created 2018-08-13 21:35 UTC

RabbitMQManagementApiClient::call() A

↳ Parent: RabbitMQManagementApiClient

Complexity

Conditions	4
Paths	6

Size

Total Lines

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	13
CRAP Score	4.2084

Importance

Changes

Metric	Value
dl	0
loc	21
ccs	13
cts	17
cp	0.7647
rs	9.584
c	0
b	0
f	0
cc	4
nc	6
nop	3
crap	4.2084

<?php

namespace UniMan\Drivers\RabbitMQ;

use UniMan\Core\Exception\ConnectException;

class RabbitMQManagementApiClient
{
    private $baseUrl;

    public function __construct($host = 'localhost', $port = '15672', $user = 'guest', $password = 'guest')
    {
        $this->baseUrl = 'http://' . $user . ':' . $password . '@' . $host . ':' . $port;
    }

    /**
     * @return just for check if user authorised
     */
    public function overview()
    {
        return $this->call('/api/overview');
    }

    /**
     * returns list of vhosts visible for user
     * @param string|null $user
     * @return array
     */
    public function getVhosts($user = null)
    {
        $result = $this->call('/api/vhosts');
        $vhosts = [];
        foreach ($result as $item) {
            if ($user === null) {
                $vhosts[] = $item;
                continue;
            }
            $permissions = $this->call('/api/vhosts/' . urlencode($item['name']) . '/permissions');
            foreach ($permissions as $permission) {
                if ($permission['user'] == $user) {
                    $vhosts[] = $item;
                    continue;
                }
            }
        }
        return $vhosts;
    }

    /**
     * returns list of queues for vhost
     * @param string|null $vhost
     * @return array
     */
    public function getQueues($vhost = null)
    {
        $endpoint = '/api/queues';
        if ($vhost) {
''   == false // true
''   == null  // true
'ab' == false // false
'ab' == null  // false

// It is often better to use strict comparison
'' === false // false
'' === null  // false
            $endpoint .= '/' . urlencode($vhost);
        }
        $queues = $this->call($endpoint);
        return $queues;
    }

    public function getMessages($vhost, $queue)
    {
        $count = 0;
        foreach ($this->getQueues($vhost) as $vhostQueue) {
            if ($vhostQueue['name'] == $queue) {
                $count = $vhostQueue['messages'];
                break;
            }
        }
        if ($count == 0) {
            return [];
        }

        $endpoint = '/api/queues/' . urlencode($vhost) . '/' . urlencode($queue) . '/get';
        $params = [
            'count' => $count,
            'requeue' => true,
            'encoding' => 'auto',
        ];
        $result = $this->call($endpoint, 'POST', json_encode($params));
        return $result;
    }

    private function call($endpoint, $method = 'GET', $params = null)
    {
        $ch = curl_init($this->baseUrl . $endpoint);
        curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
        curl_setopt($ch, CURLOPT_FOLLOWLOCATION, true);
        curl_setopt($ch, CURLOPT_CUSTOMREQUEST, $method);
        if ($params) {
            curl_setopt($ch, CURLOPT_POSTFIELDS, $params);
        }
        curl_setopt($ch, CURLOPT_TIMEOUT, 3);
        $response = curl_exec($ch);
        curl_close($ch);
        if (!$response) {
            return [];
        }
        $result = json_decode((string)$response, true);
        if (isset($result['error'])) {
            throw new ConnectException($result['reason']);
        }
        return $result;
    }
}


1		<?php
2
3		namespace UniMan\Drivers\RabbitMQ;
4
5		use UniMan\Core\Exception\ConnectException;
6
7		class RabbitMQManagementApiClient
8		{
9		private $baseUrl;
10
11	2	public function __construct($host = 'localhost', $port = '15672', $user = 'guest', $password = 'guest')
12		{
13	2	$this->baseUrl = 'http://' . $user . ':' . $password . '@' . $host . ':' . $port;
14	2	}
15
16		/**
17		* @return just for check if user authorised
18		*/
19	2	public function overview()
20		{
21	2	return $this->call('/api/overview');
22		}
23
24		/**
25		* returns list of vhosts visible for user
26		* @param string\|null $user
27		* @return array
28		*/
29		public function getVhosts($user = null)
30		{
31		$result = $this->call('/api/vhosts');
32		$vhosts = [];
33		foreach ($result as $item) {
34		if ($user === null) {
35		$vhosts[] = $item;
36		continue;
37		}
38		$permissions = $this->call('/api/vhosts/' . urlencode($item['name']) . '/permissions');
39		foreach ($permissions as $permission) {
40		if ($permission['user'] == $user) {
41		$vhosts[] = $item;
42		continue;
43		}
44		}
45		}
46		return $vhosts;
47		}
48
49		/**
50		* returns list of queues for vhost
51		* @param string\|null $vhost
52		* @return array
53		*/
54		public function getQueues($vhost = null)
55		{
56		$endpoint = '/api/queues';
57		if ($vhost) {
		0 ignored issues – show Bug Best Practice introduced 2016-12-19 15:38 UTC by Report Bug Copy Issue Report The expression `$vhost` of type `string\|null` is loosely compared to `true`; this is ambiguous if the string can be empty. You might want to explicitly use `!== null` instead. In PHP, under loose comparison (like `==`, or `!=`, or `switch` conditions), values of different types might be equal. For `string` values, the empty string `''` is a special case, in particular the following results might be unexpected: '' == false // true '' == null // true 'ab' == false // false 'ab' == null // false // It is often better to use strict comparison '' === false // false '' === null // false Loading history...
58		$endpoint .= '/' . urlencode($vhost);
59		}
60		$queues = $this->call($endpoint);
61		return $queues;
62		}
63
64		public function getMessages($vhost, $queue)
65		{
66		$count = 0;
67		foreach ($this->getQueues($vhost) as $vhostQueue) {
68		if ($vhostQueue['name'] == $queue) {
69		$count = $vhostQueue['messages'];
70		break;
71		}
72		}
73		if ($count == 0) {
74		return [];
75		}
76
77		$endpoint = '/api/queues/' . urlencode($vhost) . '/' . urlencode($queue) . '/get';
78		$params = [
79		'count' => $count,
80		'requeue' => true,
81		'encoding' => 'auto',
82		];
83		$result = $this->call($endpoint, 'POST', json_encode($params));
84		return $result;
85		}
86
87	2	private function call($endpoint, $method = 'GET', $params = null)
88		{
89	2	$ch = curl_init($this->baseUrl . $endpoint);
90	2	curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
91	2	curl_setopt($ch, CURLOPT_FOLLOWLOCATION, true);
92	2	curl_setopt($ch, CURLOPT_CUSTOMREQUEST, $method);
93	2	if ($params) {
94		curl_setopt($ch, CURLOPT_POSTFIELDS, $params);
95		}
96	2	curl_setopt($ch, CURLOPT_TIMEOUT, 3);
97	2	$response = curl_exec($ch);
98	2	curl_close($ch);
99	2	if (!$response) {
100		return [];
101		}
102	2	$result = json_decode((string)$response, true);
103	2	if (isset($result['error'])) {
104		throw new ConnectException($result['reason']);
105		}
106	2	return $result;
107		}
108		}
109

lulco / uniman

Push — master ( f5adf6...a90a41 )

RabbitMQManagementApiClient::call() A

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like