Comodojo\Extender\Queue\Manager

Complexity

Total Complexity

12

Size/Duplication

Total Lines	121
Duplicated Lines	0 %

Importance

Changes

0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	doAddRequest()	0	10	1
A	__construct()	0	18	2
A	get()	0	5	1
A	__destruct()	0	6	2
A	flush()	0	11	2
A	add()	0	9	1
A	addBulk()	0	13	3

<?php namespace Comodojo\Extender\Queue;

use \Comodojo\Foundation\Base\Configuration;
use \Comodojo\Foundation\Base\ConfigurationTrait;
use \Comodojo\Foundation\Events\Manager as EventsManager;
use \Comodojo\Foundation\Logging\LoggerTrait;
use \Comodojo\Foundation\Events\EventsTrait;
use \Comodojo\Extender\Components\Database;
use \Comodojo\Extender\Traits\EntityManagerTrait;
use \Comodojo\Extender\Task\Request;
use \Comodojo\Extender\Orm\Entities\Queue;
use \Comodojo\Extender\Events\QueueEvent;
use \Doctrine\ORM\EntityManager;
use \Psr\Log\LoggerInterface;
use \Exception;

/**
* @package     Comodojo Extender
* @author      Marco Giovinazzi <marco.giovinazzi@comodojo.org>
* @license     MIT
*
* LICENSE:
*
* THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
* IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
* FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
* AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
* LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
* OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
* THE SOFTWARE.
 */

class Manager {

    use ConfigurationTrait;
    use LoggerTrait;
    use EventsTrait;
    use EntityManagerTrait;

    /**
     * If true, $em will be destroyed at shutdown
     *
     * @var bool
     */
    private $destroy_em = true;

    /**
     * Class constructor
     *
     * @param Configuration $configuration
     * @param LoggerInterface $logger
     * @param EventsManager $events
     * @param EntityManager $em
     */
    public function __construct(
        Configuration $configuration,
        LoggerInterface $logger,
        EventsManager $events,
        EntityManager $em = null
    ) {

        $this->setConfiguration($configuration);
        $this->setLogger($logger);
        $this->setEvents($events);

        if ( is_null($em) ) {
            $this->setEntityManager(
                Database::init($configuration)->getEntityManager()
            );
        } else {
            $this->setEntityManager($em);
            $this->destroy_em = false;
        }

        // $logger->debug("Tasks Manager online", array(

70% of this comment could be valid code. Did you maybe forget this after debugging?

        //     'lagger_timeout' => $this->lagger_timeout,

56% of this comment could be valid code. Did you maybe forget this after debugging?

        //     'multithread' => $this->multithread,

56% of this comment could be valid code. Did you maybe forget this after debugging?

        //     'max_runtime' => $this->max_runtime,

56% of this comment could be valid code. Did you maybe forget this after debugging?

        //     'max_childs' => $this->max_childs

50% of this comment could be valid code. Did you maybe forget this after debugging?

        // ));

75% of this comment could be valid code. Did you maybe forget this after debugging?

    }

    public function __destruct() {

        if ($this->destroy_em) {
            $em = $this->getEntityManager();
            $em->getConnection()->close();
            $em->close();
        }

    }

    public function get() {

        $em = $this->getEntityManager();

        return $em->getRepository('Comodojo\Extender\Orm\Entities\Queue')->findAll();

    }

    public function flush(array $queue) {

        $this->getEvents()->emit( new QueueEvent('flush', null, $queue) );

        $em = $this->getEntityManager();

        foreach ($queue as $record) {
            $em->remove($record);
        }

        $em->flush();

    }

    public function add(Request $request) {

        $em = $this->getEntityManager();

        $uid = $this->doAddRequest($request, $em);

        $em->flush();

        return $uid;

    }

    public function addBulk(array $queue) {

        $em = $this->getEntityManager();

        $records = [];

        foreach ($queue as $name => $request) {
            $records[] = $request instanceof Request ? $this->doAddRequest($request, $em) : false;
        }

        $em->flush();

        return $records;

    }

    protected function doAddRequest(Request $request, EntityManager $em) {

        $this->getEvents()->emit( new QueueEvent('add', $request) );

        $record = new Queue();
        $record->setName($request->getName())->setRequest($request);

        $em->persist($record);

        return $request->getUid();

    }

}