Kuroi\Cluster\Queues\Adapters\IronMQ

Complexity

Total Complexity

3

Size/Duplication

Total Lines	49
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	1

Importance

Changes	4
Bugs	0	Features	0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	count()	0	9	1
A	clear()	0	6	1
A	setHeaders()	0	6	1

<?php

namespace PeterColes\Cluster\Queues\Adapters;

use PeterColes\Cluster\Contracts\Adapter;
use PeterColes\Cluster\Contracts\QueueAdapterInterface;

class IronMQ extends Adapter implements QueueAdapterInterface
{
    /**
     * The endpoint for all API calls to Digital Ocean (currently at v2)
     */
    // @todo support for all regions
    protected $apiEndpoint = 'https://mq-aws-us-east-1.iron.io/1';

    /**
     * List details for an indexed server, or all servers if id is null.
     *
     * @param string $queue
     * @return integer
     */
    public function count($queue)
    {
        // @todo remove hard-coded project
        $response = $this->client->request->get(
            $this->apiEndpoint.'/projects/'.$this->params['project'].'/queues/'.$queue
        );

        return $this->client->getBody($response);
    }

    /**
     * Receives the name of a queue and clears it.
     *
     * @param string $queue
     * @return void
     */
    public function clear($queue)
    {
        $this->client->request->post(
            $this->apiEndpoint.'/projects/'.$this->params['project'].'/queues/'.$queue.'/clear'
        );
    }

    /**
     * Construct http client request headers.
     *
     * @return void
     */
    protected function setHeaders()
    {
        parent::setHeaders();

        $this->headers['headers']['Authorization'] = 'OAuth '.$this->params['token'];
    }
}