Dtc\QueueBundle\Model\MessageableJob

Complexity

Total Complexity

23

Size/Duplication

Total Lines	101
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	2

Test Coverage

Coverage

100%

Importance

Changes

0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	toMessage()	0	4	1
A	fromMessage()	0	7	2
A	__construct()	0	7	2
A	toMessageArray()	0	19	2
D	fromMessageArray()	0	29	9
B	fromMessagearrayRetries()	0	21	7

<?php

namespace Dtc\QueueBundle\Model;

use Dtc\QueueBundle\Util\Util;

abstract class MessageableJob extends RetryableJob
{
    public function __construct(Worker $worker = null, $batch = false, $priority = 10, \DateTime $whenAt = null)
    {
        parent::__construct($worker, $batch, $priority, $whenAt);
        if (!$this->getWhenAt()) {
            $this->setWhenAt(Util::getMicrotimeDateTime());
        }
    }

    protected function toMessageArray()
    {
        return array(
            'worker' => $this->getWorkerName(),
            'args' => $this->getArgs(),
            'method' => $this->getMethod(),
            'priority' => $this->getPriority(),
            'whenAt' => $this->getWhenAt()->format('U.u'),
            'createdAt' => $this->getCreatedAt()->format('U.u'),
            'updatedAt' => $this->getUpdatedAt()->format('U.u'),
            'expiresAt' => ($expiresAt = $this->getExpiresAt()) ? $expiresAt->format('U.u') : null,
            'retries' => $this->getRetries(),
            'maxRetries' => $this->getMaxRetries(),
            'failures' => $this->getFailures(),
            'maxFailures' => $this->getMaxFailures(),
            'exceptions' => $this->getExceptions(),
            'maxExceptions' => $this->getMaxExceptions(),
        );
    }

    /**
     * @return string A json_encoded version of a queueable version of the object
     */
    public function toMessage()
    {
        return json_encode($this->toMessageArray());
    }

    /**
     * @param string $message a json_encoded version of the object
     */
    public function fromMessage($message)
    {
        $arr = json_decode($message, true);
        if (is_array($arr)) {
            $this->fromMessageArray($arr);
        }
    }

    protected function fromMessageArray(array $arr)
    {
        if (isset($arr['worker'])) {
            $this->setWorkerName($arr['worker']);
        }
        if (isset($arr['args'])) {
            $this->setArgs($arr['args']);
        }
        if (isset($arr['method'])) {
            $this->setMethod($arr['method']);
        }
        if (isset($arr['priority'])) {
            $this->setPriority($arr['priority']);
        }

        $this->fromMessageArrayRetries($arr);
        foreach (['expiresAt', 'createdAt', 'updatedAt', 'whenAt'] as $dateField) {
            if (isset($arr[$dateField])) {
                $timeStr = $arr[$dateField];
                if ($timeStr) {
                    $dateTime = \DateTime::createFromFormat('U.u', $timeStr);
                    if ($dateTime) {
                        $method = 'set'.ucfirst($dateField);
                        $this->$method($dateTime);
                    }
                }
            }
        }
    }

    protected function fromMessagearrayRetries(array $arr)
    {
        if (isset($arr['retries'])) {
            $this->setRetries($arr['retries']);
        }
        if (isset($arr['maxRetries'])) {
            $this->setMaxRetries($arr['maxRetries']);
        }
        if (isset($arr['failures'])) {
            $this->setFailures($arr['failures']);
        }
        if (isset($arr['maxFailures'])) {
            $this->setMaxFailures($arr['maxFailures']);
        }
        if (isset($arr['exceptions'])) {
            $this->setExceptions($arr['exceptions']);
        }
        if (isset($arr['maxExceptions'])) {
            $this->setMaxExceptions($arr['maxExceptions']);
        }
    }
}