SWP\Bundle\CoreBundle\EventSubscriber\WebhookEventsSubscriber::getWebhooks()

Complexity

Conditions	6
Paths	4

Size

Total Lines

23

Duplication

Lines	0
Ratio	0 %

Importance

Changes

0

1 Method

Rating	Name	Duplication	Size	Complexity
A	WebhookEventsSubscriber::getSubject()	0	13	4

<?php

declare(strict_types=1);

/*
 * This file is part of the Superdesk Web Publisher Core Bundle.
 *
 * Copyright 2016 Sourcefabric z.ú. and contributors.
 *
 * For the full copyright and license information, please see the
 * AUTHORS and LICENSE files distributed with this source code.
 *
 * @copyright 2016 Sourcefabric z.ú
 * @license http://www.superdesk.org/license
 */

namespace SWP\Bundle\CoreBundle\EventSubscriber;

use JMS\Serializer\SerializerInterface;
use OldSound\RabbitMqBundle\RabbitMq\ProducerInterface;
use SWP\Bundle\ContentBundle\Event\ArticleEvent;
use SWP\Bundle\ContentBundle\Event\RouteEvent;
use SWP\Bundle\CoreBundle\Model\WebhookInterface;
use SWP\Bundle\CoreBundle\Repository\WebhookRepositoryInterface;
use SWP\Bundle\CoreBundle\Webhook\WebhookEvents;
use SWP\Bundle\MultiTenancyBundle\Context\TenantContext;
use SWP\Component\MultiTenancy\Repository\TenantRepositoryInterface;
use Symfony\Component\EventDispatcher\EventDispatcherInterface;
use Symfony\Component\EventDispatcher\Event;
use Symfony\Component\EventDispatcher\GenericEvent;

final class WebhookEventsSubscriber extends AbstractWebhookEventSubscriber
{
    private $producer;

    private $serializer;

    public function __construct(
        ProducerInterface $producer,
        SerializerInterface $serializer,
        WebhookRepositoryInterface $webhooksRepository,
        TenantContext $tenantContext,
        TenantRepositoryInterface $tenantRepository
    ) {
        $this->producer = $producer;
        $this->serializer = $serializer;

        parent::__construct($webhooksRepository, $tenantContext, $tenantRepository);
    }

    public static function getSubscribedEvents(): array
    {
        $subscribedEvents = [];
        foreach (WebhookEvents::EVENTS as $webhookEvent) {
            $subscribedEvents[$webhookEvent] = 'handleEvent';
        }

        return $subscribedEvents;
    }

    public function handleEvent(Event $event, string $dispatcherEventName, EventDispatcherInterface $dispatcher): void

The parameter $dispatcherEventName is not used and could be removed.

    {
        $webhookEventName = $this->getEventName($event);
        if (!is_string($webhookEventName)) {
            return;
        }

        $subject = $this->getSubject($event);
        $webhooks = $this->getWebhooks($subject, $webhookEventName, $dispatcher);

        /** @var WebhookInterface $webhook */
        foreach ($webhooks as $webhook) {
            $this->producer->publish($this->serializer->serialize([
                'url' => $webhook->getUrl(),
                'metadata' => [
                    'event' => $webhookEventName,
                    'tenant' => $webhook->getTenantCode(),
                ],
                'subject' => $subject,
            ], 'json'));
        }
    }

    private function getEventName(Event $event): ?string
    {
        if ($event instanceof GenericEvent) {
            $arguments = $event->getArguments();
            if (array_key_exists('eventName', $arguments)) {
                return array_search($arguments['eventName'], WebhookEvents::EVENTS);
            }
        } elseif (method_exists($event, 'getEventName')) {
            return array_search($event->getEventName(), WebhookEvents::EVENTS);

It seems like you code against a specific sub-type and not the parent class Symfony\Component\EventDispatcher\Event as the method getEventName() does only exist in the following sub-classes of Symfony\Component\EventDispatcher\Event: SWP\Bundle\ContentBundle\Event\ArticleEvent, SWP\Bundle\ContentBundle\Event\RouteEvent. Maybe you want to instanceof check for one of these explicitly?

        }

        return null;
    }

    private function getSubject(Event $event)
    {
        switch ($event) {
            case $event instanceof GenericEvent:
                return $event->getSubject();

It seems like you code against a specific sub-type and not the parent class Symfony\Component\EventDispatcher\Event as the method getSubject() does only exist in the following sub-classes of Symfony\Component\EventDispatcher\Event: SWP\Component\Common\Event\HttpCacheEvent, Symfony\Component\EventDispatcher\GenericEvent, Symfony\Component\Workflow\Event\Event, Symfony\Component\Workflow\Event\GuardEvent. Maybe you want to instanceof check for one of these explicitly?

            case $event instanceof ArticleEvent:
                return $event->getArticle();

It seems like you code against a specific sub-type and not the parent class Symfony\Component\EventDispatcher\Event as the method getArticle() does only exist in the following sub-classes of Symfony\Component\EventDispatcher\Event: SWP\Bundle\ContentBundle\Event\ArticleEvent. Maybe you want to instanceof check for one of these explicitly?

            case $event instanceof RouteEvent:
                return $event->getRoute();

It seems like you code against a specific sub-type and not the parent class Symfony\Component\EventDispatcher\Event as the method getRoute() does only exist in the following sub-classes of Symfony\Component\EventDispatcher\Event: SWP\Bundle\ContentBundle\Event\RouteEvent. Maybe you want to instanceof check for one of these explicitly?

            default:
                return null;
        }
    }
}