MessageProcessor::process() - Code Metrics - SirSova/laravel-webhooks - Measure and Improve Code Quality continuously with Scrutinizer

MessageProcessor::process() A
last analyzed 2019-07-17 09:51 UTC

↳ Parent: MessageProcessor

Complexity

Conditions	4
Paths	3

Size

Total Lines	12
Code Lines	8

Duplication

Lines	0
Ratio	0 %

Importance

Changes	2
Bugs	0	Features	0

Metric	Value
cc	4
eloc	8
c	2
b	0
f	0
nc	3
nop	1
dl	0
loc	12
rs	10

<?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);
            }
        }
    }
}


1			<?php
2
3
4			namespace SirSova\Webhooks;
5
6			use Illuminate\Contracts\Bus\Dispatcher;
7			use Illuminate\Contracts\Bus\QueueingDispatcher;
8			use SirSova\Webhooks\Contracts\SubscriberRepository;
9			use SirSova\Webhooks\Contracts\MessageProcessor as ProcessorContract;
10			use SirSova\Webhooks\Jobs\ProcessWebhook;
11
12			class MessageProcessor implements ProcessorContract
13			{
14			/**
15			* @var SubscriberRepository
16			*/
17			private $subscriberRepository;
18			/**
19			* @var Dispatcher
20			*/
21			private $dispatcher;
22			/**
23			* @var string\|null
24			*/
25			private $queue;
26
27			public function __construct(SubscriberRepository $subscriberRepository, Dispatcher $dispatcher, ?string $queue = null)
28			{
29			$this->subscriberRepository = $subscriberRepository;
30			$this->dispatcher = $dispatcher;
31			$this->queue = $queue;
32			}
33
34			/**
35			* @param Message $message
36			*
37			* @return void
38			*/
39			public function process(Message $message): void
40			{
41			$subscribers = $this->subscriberRepository->findAllByEvent($message->type(), true);
42
43			foreach ($subscribers as $subscriber) {
44			$job = new ProcessWebhook(new Webhook($message, $subscriber->url()));
45
46			if ($this->dispatcher instanceof QueueingDispatcher && $this->queue) {
47			$job->onQueue($this->queue);
48			$this->dispatcher->dispatchToQueue($job);
49			} else {
50			$this->dispatcher->dispatch($job);
51			}
52			}
53			}
54			}
55

SirSova / laravel-webhooks

MessageProcessor::process() A last analyzed 2019-07-17 09:51 UTC

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like

MessageProcessor::process() A
last analyzed 2019-07-17 09:51 UTC