Canvas\Jobs\PendingDispatch

Complexity

Total Complexity

3

Size/Duplication

Total Lines	46
Duplicated Lines	0 %

Importance

Changes	1
Bugs	1	Features	1

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	3	1
A	__destruct()	0	9	1
A	onQueue()	0	4	1

<?php

declare(strict_types=1);

namespace Canvas\Jobs;

use Canvas\Contracts\Queue\QueueableJobInterface;
use Canvas\Queue\Queue;
use Phalcon\Di;

class PendingDispatch
{
    /**
     * The job.
     *
     * @var mixed
     */
    protected $job;

    /**
     * Create a new pending job dispatch.
     *
     * @param  QueueableJobInterface  $job
     * @return void
     */
    public function __construct(QueueableJobInterface $job)
    {
        $this->job = $job;
    }

    /**
     * Set the desired queue for the job.
     *
     * @param  string  $queue
     * @return $this
     */
    public function onQueue(string $queue)
    {
        $this->job->onQueue($queue);
        return $this;
    }

    /**
     * Handle the object's destruction.
     *
     * @return void
     */
    public function __destruct()
    {
        $jobData = [
            'userData' => Di::getDefault()->getUserData(),
            'class' => get_class($this->job),
            'job' => $this->job
        ];

        return Queue::send($this->job->queue, serialize($jobData));

The expression return Canvas\Queue\Queue::send($this->job->queue, serialize($jobData)) returns the type true which is incompatible with the documented return type void.

    }
}