Core\Queue\Job\MongoJob

Complexity

Total Complexity

6

Size/Duplication

Total Lines	37
Duplicated Lines	0 %

Test Coverage

Coverage

0%

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	success()	0	5	1
A	failure()	0	5	1
A	recoverable()	0	5	1
A	getResult()	0	7	2
A	setResult()	0	3	1

<?php
/**
 * YAWIK
 *
 * @filesource
 * @license MIT
 * @copyright  2013 - 2019 Cross Solution <http://cross-solution.de>
 */
  
/** */
namespace Core\Queue\Job;

use SlmQueue\Job\AbstractJob;
use SlmQueue\Worker\Event\ProcessJobEvent;

/**
 * ${CARET}
 * 
 * @author Mathias Gelhausen <gelhausen@cross-solution.de>
 * @todo write test 
 */
abstract class MongoJob extends AbstractJob implements ResultProviderInterface
{
    protected $result;

    public function setResult(JobResult $result) : void
    {
        $this->result = $result;
    }

    public function getResult() : JobResult
    {
        if (!$this->result) {
            $this->setResult(new JobResult(ProcessJobEvent::JOB_STATUS_UNKNOWN));
        }

        return $this->result;
    }

    protected function failure(string $message, ?array $extra = null) : int
    {
        $this->setResult(JobResult::failure($message, $extra));

        return ProcessJobEvent::JOB_STATUS_FAILURE;
    }

    protected function recoverable(string $message, array $options = []) : int
    {
        $this->setResult(JobResult::recoverable($message, $options));

        return ProcessJobEvent::JOB_STATUS_FAILURE_RECOVERABLE;
    }

    protected function success(?string $message = null, ?array $extra = null) : int
    {
        $this->setResult(JobResult::success($message, $extra));

        return ProcessJobEvent::JOB_STATUS_SUCCESS;
    }
}