app/Plugin/Api42/Service/WebHookService.php line 63

Open in your IDE?
  1. <?php
  3. /*
  4.  * This file is part of EC-CUBE
  5.  *
  6.  * Copyright(c) EC-CUBE CO.,LTD. All Rights Reserved.
  7.  *
  8.  * http://www.ec-cube.co.jp/
  9.  *
  10.  * For the full copyright and license information, please view the LICENSE
  11.  * file that was distributed with this source code.
  12.  */
  14. namespace Plugin\Api42\Service;
  16. use Eccube\Util\StringUtil;
  17. use GuzzleHttp\Client;
  18. use GuzzleHttp\Exception\TransferException;
  19. use GuzzleHttp\Pool;
  20. use GuzzleHttp\Psr7\Request;
  21. use GuzzleHttp\Psr7\Response;
  22. use Plugin\Api42\Entity\WebHook;
  23. use Plugin\Api42\Repository\WebHookRepository;
  24. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  25. use Symfony\Component\HttpKernel\Event\ResponseEvent ;
  26. use Symfony\Component\HttpKernel\KernelEvents;
  27. use Symfony\Component\Routing\RouterInterface;
  29. class WebHookService implements EventSubscriberInterface
  30. {
  31.     /**
  32.      * @var RouterInterface
  33.      */
  34.     private $router;
  36.     /**
  37.      * @var WebHookRepository
  38.      */
  39.     private $webHookRepository;
  41.     /**
  42.      * @var WebHookEvents
  43.      */
  44.     private $webHookEvents;
  46.     /**
  47.      * WebHookService constructor.
  48.      */
  49.     public function __construct(RouterInterface $router, WebHookRepository $webHookRepository, WebHookEvents $webHookEvents)
  50.     {
  51.         $this->router = $router;
  52.         $this->webHookRepository = $webHookRepository;
  53.         $this->webHookEvents = $webHookEvents;
  54.     }
  56.     public static function getSubscribedEvents()
  57.     {
  58.         return [
  59.             KernelEvents::RESPONSE => 'fire',
  60.         ];
  61.     }
  63.     public function fire(ResponseEvent $event)
  64.     {
  65.         if (!$event->isMainRequest()) {
  66.             return;
  67.         }
  69.         $events = $this->webHookEvents->toArray();
  71.         if ($events) {
  72.             $payload = json_encode($events);
  74.             /** @var WebHook[] $availableWebHooks */
  75.             $availableWebHooks = $this->webHookRepository->findBy(['enabled' => true]);
  77.             $requests = array_map(function (WebHook $WebHook) use ($payload) {
  78.                 return $this->createRequest($payload, $WebHook);
  79.             }, $availableWebHooks);
  81.             $client = new Client();
  82.             $pool = new Pool($client, $requests, [
  83.                 'concurrency' => 5,
  84.                 'options' => [
  85.                     'connect_timeout' => 1,
  86.                     'timeout' => 5,
  87.                     'allow_redirects' => false,
  88.                 ],
  89.                 'fulfilled' => function (Response $reason, $index) use ($availableWebHooks) {
  90.                     log_info('WebHook request successful.', ['Payload URL' => $availableWebHooks[$index]->getPayloadUrl()]);
  91.                 },
  92.                 'rejected' => function (TransferException $e, $index) use ($availableWebHooks) {
  93.                     log_error($e->getMessage(), ['Payload URL' => $availableWebHooks[$index]->getPayloadUrl()]);
  94.                 },
  95.             ]);
  96.             $p = $pool->promise();
  97.             $p->wait();
  98.         }
  99.     }
  101.     private function createRequest($payload, $WebHook)
  102.     {
  103.         $headers = [
  104.             'Content-Type' => 'application/json',
  105.             'X-ECCUBE-URL' => $this->router->generate('homepage', [], RouterInterface::ABSOLUTE_URL),
  106.         ];
  107.         if (StringUtil::isNotBlank($WebHook->getSecret())) {
  108.             $headers['X-ECCUBE-Signature'] = hash_hmac('sha256', $payload, $WebHook->getSecret());
  109.         }
  111.         return new Request('POST', $WebHook->getPayloadUrl(), $headers, $payload);
  112.     }
  113. }