Core\Queue\Job\JobResult

Complexity

Total Complexity

21

Size/Duplication

Total Lines	188
Duplicated Lines	0 %

Test Coverage

Coverage

0%

Importance

Changes

0

17 Methods

Rating	Name	Duplication	Size	Complexity
A	failure()	0	7	1
A	withExtra()	0	5	1
A	getReason()	0	3	1
A	isSuccess()	0	3	1
A	recoverable()	0	5	1
A	getDelay()	0	3	1
A	withDate()	0	3	1
A	withReason()	0	5	1
A	getResult()	0	3	1
A	getDate()	0	3	1
A	getExtra()	0	3	1
A	create()	0	18	5
A	isRecoverable()	0	3	1
A	__construct()	0	3	1
A	withDelay()	0	5	1
A	success()	0	7	1
A	isFailure()	0	3	1

<?php
/**
 * YAWIK
 *
 * @filesource
 * @license MIT
 * @copyright  2013 - 2019 Cross Solution <http://cross-solution.de>
 */

declare(strict_types=1);

/** */
namespace Core\Queue\Job;

use SlmQueue\Worker\Event\ProcessJobEvent;

/**
 * ${CARET}
 * 
 * @author Mathias Gelhausen <gelhausen@cross-solution.de>
 * @todo write test 
 */
class JobResult
{
    /**
     *
     *
     * @var int
     */
    protected $result;

    /**
     *
     *
     * @var string
     */
    protected $reason;

    /**
     *
     *
     * @var array
     */
    protected $extra;

    /**
     *
     *
     * @var string|int|\DateInterval
     */
    protected $delay;

    /**
     *
     *
     * @var string|int|\DateTime
     */
    protected $scheduled;

    public static function success(?string $reason = null, ?array $extra = null) : self
    {
        return static::create(
            ProcessJobEvent::JOB_STATUS_SUCCESS,
            [
                'reason' => $reason,
                'extra'  => $extra,
            ]
        );
    }

    public static function failure(string $reason, ?array $extra = null) : self
    {
        return static::create(
            ProcessJobEvent::JOB_STATUS_FAILURE,
            [
                'reason' => $reason,
                'extra'  => $extra,
            ]
        );
    }

    public static function recoverable(string $reason, array $options = []) : self
    {
        return static::create(
            ProcessJobEvent::JOB_STATUS_FAILURE_RECOVERABLE,
            [ 'reason' => $reason ] + $options
        );
    }

    public static function create(int $code, $options)
    {
        $result = new static($code);

        if (is_string($options)) {
            $options = ['reason' => $options];
        }

        foreach ($options as $key => $value) {
            if (!$value) { continue; }

            $callback = [$result, "with$key"];
            if (is_callable($callback)) {
                $callback($value);
            }
        }

        return $result;
    }

    public function __construct(int $result)
    {
        $this->result = $result;
    }

    public function getResult() : int
    {
        return $this->result;
    }

    public function isSuccess() : bool
    {
        return ProcessJobEvent::JOB_STATUS_SUCCESS == $this->result;
    }

    public function isFailure() : bool
    {
        return ProcessJobEvent::JOB_STATUS_FAILURE == $this->result;
    }

    public function isRecoverable() : bool
    {
        return ProcessJobEvent::JOB_STATUS_FAILURE_RECOVERABLE == $this->result;
    }

    /**
     * @return string
     */
    public function getReason(): ?string
    {
        return $this->reason;
    }

    /**
     * @param string $message
     *
     * @return self
     */
    public function withReason($reason) : self
    {
        $this->reason = $reason;

        return $this;
    }

    /**
     * @return array
     */
    public function getExtra(): ?array
    {
        return $this->extra;
    }

    /**
     * @param array $extra
     *
     * @return self
     */
    public function withExtra(array $extra) : self
    {
        $this->extra = $extra;

        return $this;
    }

    /**
     * @return \DateInterval|int|string
     */
    public function getDelay()
    {
        return $this->delay;
    }

    /**
     * @param \DateInterval|int|string $delay
     *
     * @return self
     */
    public function withDelay($delay) : self
    {
        $this->delay = $delay;

        return $this;
    }

    /**
     * @return \DateTime|int|string
     */
    public function getDate()
    {
        return $this->scheduled;
    }

    /**
     * @param \DateTime|int|string $scheduled
     *
     * @return self
     */
    public function withDate($scheduled) : self
    {
        $this->scheduled = $scheduled;

In this branch, the function will implicitly return null which is incompatible with the type-hinted return Core\Queue\Job\JobResult. Consider adding a return statement or allowing null as return value.

    }
}