SWP\Bundle\CoreBundle\EventSubscriber\PreviewWebhookEventSubscriber

Complexity

Total Complexity

8

Size/Duplication

Total Lines	76
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	7

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	10	1
A	getSubscribedEvents()	0	6	1
B	processEvent()	0	45	5
A	isUrlValid()	0	4	1

<?php

declare(strict_types=1);

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

namespace SWP\Bundle\CoreBundle\EventSubscriber;

use GuzzleHttp\Client;
use SWP\Bundle\ContentBundle\ArticleEvents;
use SWP\Bundle\CoreBundle\Model\ArticlePreview;
use SWP\Bundle\CoreBundle\Repository\WebhookRepositoryInterface;
use SWP\Bundle\CoreBundle\Webhook\WebhookEvents;
use SWP\Bundle\WebhookBundle\Model\WebhookInterface;
use SWP\Component\Common\Serializer\SerializerInterface;
use SWP\Component\MultiTenancy\Context\TenantContextInterface;
use SWP\Component\MultiTenancy\Repository\TenantRepositoryInterface;
use Symfony\Component\EventDispatcher\EventDispatcherInterface;
use Symfony\Component\EventDispatcher\GenericEvent;
use Webmozart\Assert\Assert;

final class PreviewWebhookEventSubscriber extends AbstractWebhookEventSubscriber
{
    /**
     * @var SerializerInterface
     */
    private $serializer;

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

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

    public static function getSubscribedEvents()
    {
        return [
            ArticleEvents::PREVIEW => 'processEvent',
        ];
    }

    public function processEvent(GenericEvent $event, string $dispatcherEventName, EventDispatcherInterface $dispatcher): void

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

    {
        $subject = $event->getSubject();
        Assert::isInstanceOf($subject, ArticlePreview::class);
        $article = $subject->getArticle();

        $webhooks = $this->getWebhooks($article, WebhookEvents::PREVIEW_EVENT, $dispatcher);
        $headers = [];

        if (!isset($webhooks[0])) {
            return;
        }

        /** @var WebhookInterface $webhook */
        $webhook = $webhooks[0];

        $metadata = [
                'event' => WebhookEvents::PREVIEW_EVENT,
                'tenant' => $webhook->getTenantCode(),

It seems like you code against a concrete implementation and not the interface SWP\Bundle\WebhookBundle\Model\WebhookInterface as the method getTenantCode() does only exist in the following implementations of said interface: SWP\Bundle\CoreBundle\Model\Webhook.

            ];

        foreach ($metadata as $header => $value) {
            $headers['X-WEBHOOK-'.\strtoupper($header)] = $value;
        }

        $client = new Client();
        $requestOptions = [
                'headers' => $headers,
                'body' => $this->serializer->serialize($article, 'json'),
            ];

        /** @var \GuzzleHttp\Psr7\Response $response */
        $response = $client->post($webhook->getUrl(), $requestOptions);
        $content = $response->getBody()->getContents();

        $content = json_decode($content, true);

        if (!isset($content['url'])) {
            return;
        }

        if ($this->isUrlValid($content['url'])) {
            $subject->setPreviewUrl($content['url']);
        }
    }

    private function isUrlValid(string $url): bool
    {
        return false !== filter_var($url, FILTER_VALIDATE_URL);
    }
}