QueueToEventDispatcher::fire() - Code Metrics - SmoothPhp/CQRS-ES-Framework-Laravel - Measure and Improve Code Quality continuously with Scrutinizer

QueueToEventDispatcher::fire() A
last analyzed 2018-07-17 11:42 UTC

↳ Parent: QueueToEventDispatcher

Complexity

Conditions	1
Paths	1

Size

Total Lines

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
cc	1
nc	1
nop	2
dl	0
loc	14
rs	9.7998
c	0
b	0
f	0

<?php declare(strict_types=1);

namespace SmoothPhp\LaravelAdapter\EventBus;

use SmoothPhp\Contracts\EventDispatcher\EventDispatcher;
use SmoothPhp\Contracts\Serialization\Serializer;

/**
 * Class QueueToEventDispatcher
 * @package SmoothPhp\LaravelAdapter\EventBus
 * @author Simon Bennett <[email protected]>
 */
final class QueueToEventDispatcher
{
    /** @var EventDispatcher */
    private $eventDispatcher;

    /** @var Serializer */
    private $serializer;

    /**
     * QueueToEventDispatcher constructor.
     * @param EventDispatcher $eventDispatcher
     * @param Serializer $serializer
     */
    public function __construct(EventDispatcher $eventDispatcher, Serializer $serializer)
    {
        $this->eventDispatcher = $eventDispatcher;
        $this->serializer = $serializer;
    }

    /**
     * @param $job
     * @param $data
     * @return mixed
     */
    public function fire($job, $data)
    {
        $payload = (json_decode($data['payload'],true));

        $event = call_user_func([
                                    str_replace('.', '\\', $data['type']),
                                    'deserialize'
                                ],
                                $payload['payload']);

        $this->eventDispatcher->dispatch($data['type'], [$event]);

        return $job->delete();
    }

}

1			<?php declare(strict_types=1);
2
3			namespace SmoothPhp\LaravelAdapter\EventBus;
4
5			use SmoothPhp\Contracts\EventDispatcher\EventDispatcher;
6			use SmoothPhp\Contracts\Serialization\Serializer;
7
8			/**
9			* Class QueueToEventDispatcher
10			* @package SmoothPhp\LaravelAdapter\EventBus
11			* @author Simon Bennett <[email protected]>
12			*/
13			final class QueueToEventDispatcher
14			{
15			/** @var EventDispatcher */
16			private $eventDispatcher;
17
18			/** @var Serializer */
19			private $serializer;
20
21			/**
22			* QueueToEventDispatcher constructor.
23			* @param EventDispatcher $eventDispatcher
24			* @param Serializer $serializer
25			*/
26			public function __construct(EventDispatcher $eventDispatcher, Serializer $serializer)
27			{
28			$this->eventDispatcher = $eventDispatcher;
29			$this->serializer = $serializer;
30			}
31
32			/**
33			* @param $job
34			* @param $data
35			* @return mixed
36			*/
37			public function fire($job, $data)
38			{
39			$payload = (json_decode($data['payload'],true));
40
41			$event = call_user_func([
42			str_replace('.', '\\', $data['type']),
43			'deserialize'
44			],
45			$payload['payload']);
46
47			$this->eventDispatcher->dispatch($data['type'], [$event]);
48
49			return $job->delete();
50			}
51
52			}

SmoothPhp / CQRS-ES-Framework-Laravel

GitHub Access Token became invalid

QueueToEventDispatcher::fire() A last analyzed 2018-07-17 11:42 UTC

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like

QueueToEventDispatcher::fire() A
last analyzed 2018-07-17 11:42 UTC