BsbPostponableJobStrategy\Job\PostponableJobTrait

Complexity

Total Complexity

9

Size/Duplication

Total Lines	68
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	2

Test Coverage

Coverage

100%

Importance

Changes	2
Bugs	0	Features	1

4 Methods

Rating	Name	Duplication	Size	Complexity
C	postponeUntil()	0	30	8
A	addPostponeUntil()	0	11	1
	setMetadata()	0	1	?
	getMetadata()	0	1	?

<?php

namespace BsbPostponableJobStrategy\Job;

use SlmQueue\Exception\RuntimeException;
use SlmQueue\Job\JobInterface;
use Traversable;

trait PostponableJobTrait
{
    /**
     * @inheritdoc
     */
    public function postponeUntil($spec, $releaseDelay = null)
    {
        $added = 0;

        if (is_integer($spec)) {
            $added += $this->addPostponeUntil($spec);
        }

        if ($spec instanceof JobInterface) {
            if (!$spec->getId()) {
                throw new RuntimeException(
                    "JobInterface does not have an id. You should push it to a queue first."
                );
            }

            $added += $this->addPostponeUntil($spec->getId());
        }

        if (is_array($spec) || $spec instanceof Traversable) {
            foreach ($spec as $value) {
                $added += $this->postponeUntil($value);
            }
        }

        if ((int) $releaseDelay) {
            $this->setMetadata('__postponeReleaseDelay', (int) $releaseDelay);
        }

        return $added;
    }

    /**
     * @param int $jobId An id of a job
     * @return int the number of the id's added
     */
    private function addPostponeUntil($jobId)
    {
        $postpone   = $this->getMetadata('__postponeUntil', []);
        $count      = count($postpone);
        $postpone[] = (int) $jobId;
        $postpone   = array_unique($postpone);

        $this->setMetadata('__postponeUntil', $postpone);

        return count($postpone) - $count;
    }

    /**
     * Set metadata
     *
     * @param  string|int|array|\Traversable $spec
     * @param  mixed $value
     */
    abstract function setMetadata($spec, $value = null);

It is generally recommended to explicitly declare the visibility for methods.

    /**
     * Get metadata
     *
     * @param  null|string|int $key
     * @return mixed
     */
    abstract function getMetadata($key = null, $default = null);

It is generally recommended to explicitly declare the visibility for methods.

}