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

<?php
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
    {
        $subject = $event->getSubject();
        if (!$subject instanceof ArticlePreview::class) {

This code did not parse for me. Apparently, there is an error somewhere around this line:

Syntax error, unexpected T_CLASS, expecting T_VARIABLE or '$'

            return;
        }
 
        $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(),
        ];

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