SmoothPhp\LaravelAdapter\StrongConsistency\PushEventThroughQueueWithCommandId

Complexity

Total Complexity

2

Size/Duplication

Total Lines	53
Duplicated Lines	30.19 %

Coupling/Cohesion

Components	1
Dependencies	4

Importance

Changes

0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	11	1
A	handle()	16	16	1

<?php declare(strict_types=1);

namespace SmoothPhp\LaravelAdapter\StrongConsistency;

use Illuminate\Contracts\Config\Repository;
use Illuminate\Contracts\Queue\Queue;
use SmoothPhp\Contracts\CommandBus\CommandBus;
use SmoothPhp\Contracts\Domain\DomainMessage;
use SmoothPhp\Contracts\EventBus\EventListener;
use SmoothPhp\Contracts\Serialization\Serializer;

/**
 * Class PushEventThroughQueueWithCommandId
 * @package SmoothPhp\LaravelAdapter\StrongConsistency
 * @author Simon Bennett <simon@pixelatedcrow.com>
 */
final class PushEventThroughQueueWithCommandId implements EventListener
{
    /** @var Queue */
    private $queue;

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

    /** @var NotificationsCommandBus */
    private $notificationsCommandBus;
    /** @var Repository */
    private $config;

    /**
     * PushEventsThroughQueue constructor.
     * @param Queue $queue
     * @param Serializer $serializer
     * @param StrongConsistencyCommandBusMiddleware|CommandBus $notificationsCommandBus
     * @param Repository $config
     */
    public function __construct(
        Queue $queue,
        Serializer $serializer,
        StrongConsistencyCommandBusMiddleware $notificationsCommandBus,
        Repository $config
    ) {
        $this->queue = $queue;
        $this->serializer = $serializer;
        $this->notificationsCommandBus = $notificationsCommandBus;

It seems like $notificationsCommandBus of type object<SmoothPhp\LaravelAdapter\StrongConsistency\StrongConsistencyCommandBusMiddleware> is incompatible with the declared type object<SmoothPhp\LaravelAdapter\StrongConsistency\NotificationsCommandBus> of property $notificationsCommandBus.

        $this->config = $config;
    }

    /**
     * @param DomainMessage $domainMessage
     * @return void
     */
    public function handle(DomainMessage $domainMessage)

This method seems to be duplicated in your project.

    {
        $this->queue->push(
            QueueToEventDispatcherWithCommandId::class,
            [
                'uuid'        => (string)$domainMessage->getId(),
                'playhead'    => $domainMessage->getPlayHead(),
                'metadata'    => json_encode($this->serializer->serialize($domainMessage->getMetadata())),
                'payload'     => json_encode($this->serializer->serialize($domainMessage->getPayload())),
                'recorded_on' => (string)$domainMessage->getRecordedOn(),
                'type'        => $domainMessage->getType(),
                'command_id'  => $this->notificationsCommandBus->getLastCommandId(),
            ],
            $this->config->get('cqrses.queue_name', 'default')
        );
    }
}