Spiral\Jobs\JobQueue

Complexity

Total Complexity

5

Size/Duplication

Total Lines	36
Duplicated Lines	0 %

Importance

Changes	1
Bugs	1	Features	0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	push()	0	12	4

<?php

/**
 * Spiral Framework.
 *
 * @license   MIT
 * @author    Anton Titov (Wolfy-J)
 */

declare(strict_types=1);

namespace Spiral\Jobs;

use Spiral\Goridge\RPC;

/**
 * Provides the ability to automatically specify the job pipeline.
 */
final class JobQueue implements QueueInterface
{
    /** @var Queue */
    private $queue;

    /** @var JobRegistry */
    private $registry;

    /**
     * @param RPC $rpc
     * @param JobRegistry $registry
     */
    public function __construct(RPC $rpc, JobRegistry $registry)
    {
        $this->queue = new Queue($rpc, $registry);
        $this->registry = $registry;
    }

    /**
     * @param string $jobType
     * @param array $payload
     * @param Options|null $options
     * @return string
     */
    public function push(string $jobType, array $payload = [], Options $options = null): string
    {
        if ($options === null) {
            $options = new Options();
        }

        $pipeline = $this->registry->getPipeline($jobType);
        if ($pipeline !== null && $options->getPipeline() === null) {
            $options = $options->withPipeline($pipeline);
        }

        return $this->queue->push($jobType, $payload, $options);
    }
}