Spiral\Queue\Interceptor\Consume\Core

Complexity

Total Complexity

3

Size/Duplication

Total Lines	42
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	dispatchEvent()	0	9	1
A	__construct()	0	4	1
A	callAction()	0	16	1

<?php

declare(strict_types=1);

namespace Spiral\Queue\Interceptor\Consume;

use Psr\EventDispatcher\EventDispatcherInterface;
use Spiral\Core\CoreInterface;
use Spiral\Queue\Event\JobProcessed;
use Spiral\Queue\Event\JobProcessing;
use Spiral\Queue\HandlerRegistryInterface;

/**
 * @internal
 * @psalm-type TParameters = array{
 *     driver: non-empty-string,
 *     queue: non-empty-string,
 *     id: non-empty-string,
 *     payload: mixed,
 *     headers: array
 * }
 */
final class Core implements CoreInterface
{
    public function __construct(
        private readonly HandlerRegistryInterface $registry,
        private readonly ?EventDispatcherInterface $dispatcher = null
    ) {
    }

    /**
     * @param-assert TParameters $parameters
     */
    public function callAction(string $controller, string $action, array $parameters = []): mixed
    {
        \assert(\is_string($parameters['driver']));
        \assert(\is_string($parameters['queue']));
        \assert(\is_string($parameters['id']));

        $this->dispatchEvent(JobProcessing::class, $controller, $parameters);

        /** @psalm-suppress TooManyArguments */
        $this->registry
            ->getHandler($controller)
            ->handle($controller, $parameters['id'], $parameters['payload'], $parameters['headers'] ?? []);

The call to Spiral\Queue\HandlerInterface::handle() has too many arguments starting with $parameters['headers'] ?? array().

        $this->dispatchEvent(JobProcessed::class, $controller, $parameters);

        return null;
    }

    /**
     * @param class-string $event

The doc comment class-string at position 0 could not be parsed: Unknown type name 'class-string' at position 0 in class-string.

     * @param-assert TParameters $parameters
     */
    private function dispatchEvent(string $event, string $name, array $parameters): void
    {
        $this->dispatcher?->dispatch(new $event(
            name: $name,
            driver: $parameters['driver'],
            queue: $parameters['queue'],
            id: $parameters['id'],
            payload: $parameters['payload'],
            headers: $parameters['headers'] ?? []
        ));
    }
}