src/FMT/Application/Listener/DwollaEventListener.php line 41

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace FMT\Application\Listener;
  7. use DateTime;
  8. use FMT\Data\Entity\DwollaEvent;
  9. use FMT\Domain\Repository\BookstoreTransferRepositoryInterface;
  10. use FMT\Domain\Repository\DwollaEventRepositoryInterface;
  11. use FMT\Infrastructure\Service\Payments\Dwolla\Item\Webhook;
  12. use Symfony\Component\HttpFoundation\Response;
  13. use Symfony\Component\HttpKernel\Event\ControllerEvent;
  15. /**
  16.  * Class DwollaEventListener
  17.  */
  18. class DwollaEventListener
  19. {
  20.     /**
  21.      * @var DwollaEventRepositoryInterface
  22.      */
  23.     protected $dwollaEventRepository;
  25.     protected BookstoreTransferRepositoryInterface $bookstoreTransferRepository;
  27.     /**
  28.      * @param DwollaEventRepositoryInterface $dwollaEventRepository
  29.      */
  30.     public function __construct(
  31.         DwollaEventRepositoryInterface $dwollaEventRepository,
  32.         BookstoreTransferRepositoryInterface $bookstoreTransferRepository
  33.     ) {
  34.         $this->dwollaEventRepository = $dwollaEventRepository;
  35.         $this->bookstoreTransferRepository = $bookstoreTransferRepository;
  36.     }
  38.     /**
  39.      * @param ControllerEvent $event
  40.      */
  41.     public function onController(ControllerEvent $event)
  42.     {
  43.         $request = $event->getRequest();
  45.         if (!$request->attributes->has('_dwolla_webhook') || !$request->attributes->has('webhook')) {
  46.             return;
  47.         }
  49.         /** @var Webhook $webhook */
  50.         $webhook = $request->attributes->get('webhook');
  51.         $dwollaEvent = $this->dwollaEventRepository->findById($webhook->getId());
  52.         $bookstoreTransfer = $this->bookstoreTransferRepository->findByResourceId($webhook->getResourceId());
  54.         if ($dwollaEvent instanceof DwollaEvent) {
  55.             $event->setController(function () {
  56.                 return new Response();
  57.             });
  59.             return;
  60.         }
  62.         $dwollaEvent = new DwollaEvent();
  63.         $dwollaEvent
  64.             ->setId($webhook->getId())
  65.             ->setCreated($webhook->getCreated())
  66.             ->setReceived(new DateTime())
  67.             ->setTopic($webhook->getTopic())
  68.             ->setBookstoreTransfer($bookstoreTransfer)
  69.         ;
  71.         $this->dwollaEventRepository->add($dwollaEvent);
  72.         $this->dwollaEventRepository->save($dwollaEvent);
  73.     }
  74. }