Cmobi\RabbitmqBundle\Rpc\Request\RpcRequestCollection

Complexity

Total Complexity

16

Size/Duplication

Total Lines	104
Duplicated Lines	10.58 %

Coupling/Cohesion

Components	2
Dependencies	1

Importance

Changes	7
Bugs	1	Features	2

12 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	getIterator()	0	4	1
A	count()	0	4	1
A	add()	11	11	2
A	all()	0	4	1
A	get()	0	8	2
A	getRequestIndex()	0	4	1
A	remove()	0	4	1
A	addCollection()	0	7	2
A	changePriority()	0	9	2
A	clear()	0	4	1
A	getPriority()	0	4	1

<?php

namespace Cmobi\RabbitmqBundle\Rpc\Request;


class RpcRequestCollection implements RpcRequestCollectionInterface, \IteratorAggregate, \Countable
{
    private $priority;
    public $requests = [];

    public function __construct($priority = RpcRequestCollectionInterface::PRIORITY_LOW)
    {
        $this->priority = $this->changePriority($priority);
    }

    public function getIterator()
    {
        return new \ArrayIterator($this->requests);
    }

    public function count()
    {
        return count($this->requests);
    }

    public function add(RpcRequestInterface $request)

This method seems to be duplicated in your project.

    {
        if (!is_null($request)) {
            unset($this->requests[$request->getId()]);
            $this->requests[$request->getId()] = $request;
        } else {
            $key = array_search($request, $this->requests, true);
            unset($this->requests[$key]);
            $this->requests[] = $request;
        }
    }

    public function all()
    {
        return $this->requests;
    }

    public function get($id)
    {
        if (isset($this->requests[$id])) {
            return $this->requests[$id];
        }

        return null;
    }

    /**
     * @param RpcRequest $request
     * @return string|int|null
     */
    public function getRequestIndex(RpcRequest $request)
    {
        return array_search($request, $this->requests);
    }

    /**
     * @param $id
     */
    public function remove($id)
    {
        unset($this->requests[$id]);
    }

    /**
     * @param RpcRequestCollection $collection
     */
    public function addCollection(RpcRequestCollection $collection)
    {
        foreach ($collection->all() as $id => $request) {
            unset($this->requests[$id]);
            $this->requests[$id] = $request;
        }
    }

    /**
     * @param $priorityNumber
     * @return string
     */
    public function changePriority($priorityNumber)
    {
        if (!decoct(octdec($priorityNumber) == $priorityNumber)) {
            $priorityNumber = decoct($priorityNumber);
        }
        $this->priority = $priorityNumber;

        return $this->priority;
    }


    public function clear()
    {
        $this->requests = [];
    }

    /**
     * Return octect priority
     *
     * @return int
     */
    public function getPriority()
    {
        return $this->priority;
    }
}