Webhook\Bundle\Service\WebhookConsumer

Complexity

Total Complexity

10

Size/Duplication

Total Lines	96
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	6

Importance

Changes

0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	9	1
A	consume()	0	30	5
A	notifyFail()	0	4	1
A	notify()	0	4	1
A	notifyRetry()	0	4	1
A	notifyDone()	0	4	1

<?php
declare(strict_types=1);


namespace Webhook\Bundle\Service;

use Symfony\Component\EventDispatcher\EventDispatcherInterface;
use Webhook\Bundle\Event\WebhookEvent;
use Webhook\Bundle\WebhookEvents;
use Webhook\Domain\Infrastructure\HandlerInterface;
use Webhook\Domain\Infrastructure\RequestResult;
use Webhook\Domain\Model\Webhook;
use Webhook\Domain\Repository\WebhookRepositoryInterface;

/**
 * Class WebhookConsumer
 *
 * @package Webhook\Domain\Infrastructure
 */
final class WebhookConsumer
{
    /** @var HandlerInterface */
    private $handler;

    /** @var WebhookRepositoryInterface */
    private $repository;
    /**
     * @var EventDispatcherInterface
     */
    private $dispatcher;

    /**
     * @param HandlerInterface $handler
     * @param WebhookRepositoryInterface $repository
     * @param EventDispatcherInterface $dispatcher
     */
    public function __construct(
        HandlerInterface $handler,
        WebhookRepositoryInterface $repository,
        EventDispatcherInterface $dispatcher
    ) {
        $this->handler = $handler;
        $this->repository = $repository;
        $this->dispatcher = $dispatcher;
    }

    /**
     * @param $id
     *
     * @return void
     */
    public function consume($id)
    {
        $webhook = $this->repository->get($id);

        if (null === $webhook) {
            return;
        }
        try {
            if ($webhook->getStatus() === Webhook::STATUS_FAILED) {
                $this->notifyFail($webhook);
                return;
            }
            /** @var RequestResult $r */
            $r = $this->handler->handle($webhook);
            $webhook->setStatusDetails($r->getDetails());

            if (!$r->isSuccess()) {
                $webhook->retry();
                $this->notifyRetry($webhook);
            } else {
                $webhook->done();
                $this->notifyDone($webhook);
            }
        } catch (\Throwable $exception) {
            $webhook->setStatus(Webhook::STATUS_FAILED);
            $webhook->setStatusDetails($exception->getMessage());
        }

        $this->repository->update($webhook);
    }

    /**
     * @param Webhook $webhook
     */
    private function notifyFail(Webhook $webhook)
    {
        $this->notify(WebhookEvents::WEBHOOK_FAIL, $webhook);
    }

    /**
     * @param string $event
     * @param Webhook $webhook
     */
    private function notify(string $event, Webhook $webhook)
    {
        $this->dispatcher->dispatch($event, new WebhookEvent($webhook));
    }

    /**
     * @param Webhook $webhook
     */
    private function notifyRetry(Webhook $webhook)
    {
        $this->notify(WebhookEvents::WEBHOOK_RETRY, $webhook);
    }

    /**
     * @param Webhook $webhook
     */
    private function notifyDone(Webhook $webhook)
    {
        $this->notify(WebhookEvents::WEBHOOK_DONE, $webhook);
    }
}