devtransition\jobbers\Pool

Complexity

Total Complexity

9

Size/Duplication

Total Lines	51
Duplicated Lines	39.22 %

Coupling/Cohesion

Components	1
Dependencies	2

Importance

Changes	1
Bugs	0	Features	0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	add()	0	9	2
A	remove()	8	8	2
A	get()	12	12	3
A	run()	0	8	2

<?php

namespace devtransition\jobbers;

use devtransition\jobbers\exception\DublciateException;

class Pool
{

    /**
     * @var Job[]
     */
    private $_jobs = [];
    private $_results = [];

    public function add(Job &$job)
    {
        if (isset($this->_jobs[$job->getId()])) {
            throw new DublciateException('job with given id already exists in pool');
        }
        $this->_jobs[$job->getId()] = $job;
        $this->_results[$job->getId()] = &$job->getResult();
        return true;
    }

    public function remove($id)

This method seems to be duplicated in your project.

    {
        if (!isset($this->_jobs[$id])) {
            throw new \InvalidArgumentException('id does not exist in pool');
        }
        unset($this->_jobs[$id]);
        return true;
    }

    public function &get($id = null)

This method seems to be duplicated in your project.

    {
        if ($id) {
            if (!isset($this->_jobs[$id])) {
                throw new \InvalidArgumentException('id does not exist in pool');
            }
            return $this->_results[$id];
        } else {
            // All
            return $this->_results;
        }
    }

    public function &run()
    {
        foreach ($this->_jobs as $id => $job) {
            $job->run();
        }

        return $this->_results;
    }

}