Sonata\NotificationBundle\Service\RabbitMQQueueStatusGuzzleProvider

Complexity

Total Complexity

3

Size/Duplication

Total Lines	29
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	1

Importance

Changes

0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	getApiQueueStatus()	0	16	2

<?php

/*
 * This file is part of the Sonata Project package.
 *
 * (c) Thomas Rabaix <thomas.rabaix@sonata-project.org>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

namespace Sonata\NotificationBundle\Service;

use Guzzle\Http\Client as GuzzleClient;
use Sonata\NotificationBundle\Exception\MonitoringException;

/**
 * @deprecated since version up 3.5.1 (created for BC). Use Sonata\NotificationBundle\Service\RabbitMQQueueStatusHttpProvider instead
 *
 * NEXT_MAJOR: remove this and use Sonata\NotificationBundle\Service\RabbitMQQueueStatusHttpProvider
 *
 * @author Nikolay Mitrofanov <mitrofanovnk@gmail.com>
 */
final class RabbitMQQueueStatusGuzzleProvider implements RabbitMQQueueStatusProviderInterface
{
    /**
     * @var array
     */
    private $connectionSettings;

    public function __construct(array $settings)
    {
        $this->connectionSettings = $settings;
    }

    public function getApiQueueStatus()
    {
        if (!class_exists(GuzzleClient::class)) {
            throw new MonitoringException(
                'The guzzle http client library is required to run rabbitmq health checks. '
                .'Make sure to add guzzlehttp/guzzle to your composer.json.'
            );
        }

        $client = new GuzzleClient();
        $client->setConfig(['curl.options' => [CURLOPT_CONNECTTIMEOUT_MS => 3000]]);
        $request = $client->get(sprintf('%s/queues', $this->connectionSettings['console_url']));
        $request->setAuth($this->connectionSettings['user'], $this->connectionSettings['pass']);

        return json_decode($request->send()->getBody(true), true);
    }
}