SirSova\Webhooks\MessageProcessor

Complexity

Total Complexity

5

Size/Duplication

Total Lines	39
Duplicated Lines	0 %

Importance

Changes	3
Bugs	1	Features	0

2 Methods

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

<?php


namespace SirSova\Webhooks;

use Illuminate\Contracts\Bus\Dispatcher;
use Illuminate\Contracts\Bus\QueueingDispatcher;
use SirSova\Webhooks\Contracts\SubscriberRepository;
use SirSova\Webhooks\Contracts\MessageProcessor as ProcessorContract;
use SirSova\Webhooks\Jobs\ProcessWebhook;

class MessageProcessor implements ProcessorContract
{
    /**
     * @var SubscriberRepository
     */
    private $subscriberRepository;
    /**
     * @var Dispatcher
     */
    private $dispatcher;
    /**
     * @var string|null
     */
    private $queue;
    
    public function __construct(SubscriberRepository $subscriberRepository, Dispatcher $dispatcher, ?string $queue = null)
    {
        $this->subscriberRepository = $subscriberRepository;
        $this->dispatcher = $dispatcher;
        $this->queue = $queue;
    }

    /**
     * @param Message $message
     *
     * @return void
     */
    public function process(Message $message): void
    {
        $subscribers = $this->subscriberRepository->findAllByEvent($message->type(), true);
        
        foreach ($subscribers as $subscriber) {
            $job = new ProcessWebhook(new Webhook($message, $subscriber->url()));

            if ($this->dispatcher instanceof QueueingDispatcher && $this->queue) {
                $job->onQueue($this->queue);
                $this->dispatcher->dispatchToQueue($job);
            } else {
                $this->dispatcher->dispatch($job);
            }
        }
    }
}