Spiral\Queue\Driver\SyncDriver

Complexity

Total Complexity

5

Size/Duplication

Total Lines	28
Duplicated Lines	0 %

Test Coverage

Coverage

93.33%

Importance

Changes

0

2 Methods

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

<?php

declare(strict_types=1);

namespace Spiral\Queue\Driver;

use Ramsey\Uuid\Uuid;
use Spiral\Queue\ExtendedOptionsInterface;
use Spiral\Queue\Interceptor\Consume\Handler;
use Spiral\Queue\OptionsInterface;
use Spiral\Queue\QueueInterface;
use Spiral\Queue\QueueTrait;

/**
 * Runs all the jobs in the same process.
 */
final class SyncDriver implements QueueInterface
{
    use QueueTrait;

    public function __construct(
        private readonly Handler $coreHandler
    ) {
    }

    /** @inheritdoc */
    public function push(string $name, mixed $payload = [], OptionsInterface $options = null): string
    {
        if ($options !== null && $options->getDelay()) {

The expression $options->getDelay() of type integer|null is loosely compared to true; this is ambiguous if the integer can be 0. You might want to explicitly use !== null instead.

            \sleep($options->getDelay());
        }

        $id = (string)Uuid::uuid4();

        $this->coreHandler->handle(
            name: $name,
            driver: 'sync',
            queue: 'default',
            id: $id,
            payload: $payload,
            headers: $options instanceof ExtendedOptionsInterface ? $options->getHeaders() : [],
        );

        return $id;
    }
}