src/DataCollector/WebhookDataCollector.php line 43

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace App\DataCollector;
  7. use App\Event\Webhook\WebhookTriggeredEvent;
  8. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  9. use Symfony\Component\HttpFoundation\Request;
  10. use Symfony\Component\HttpFoundation\Response;
  11. use Symfony\Component\HttpKernel\DataCollector\DataCollector;
  13. class WebhookDataCollector extends DataCollector implements EventSubscriberInterface
  14. {
  15.     protected $data = [
  16.         'calls' => []
  17.     ];
  19.     public function collect(Request $request,
  20.                             Response $response,
  21.                             \Throwable $exception = null)
  22.     {
  23.         //nothing to do here, please look into onTriggered method
  24.     }
  26.     public function getName()
  27.     {
  28.         return 'webhook.collector';
  29.     }
  31.     public function reset()
  32.     {
  33.         // TODO: Implement reset() method.
  34.     }
  36.     public static function getSubscribedEvents()
  37.     {
  38.         return [
  39.             WebhookTriggeredEvent::class => 'onTriggered'
  40.         ];
  41.     }
  43.     public function onTriggered(WebhookTriggeredEvent $event) : void
  44.     {
  45.         $this->data['calls'][] = [
  46.             'webhookName' => $event->getWebhookName(),
  47.             'actionName' => $event->getAction(),
  48.             'date' => date('c'),
  49.             'data' => $event->getData(),
  50.             'data_json' => \json_encode($event->getData(), JSON_PRETTY_PRINT),
  51.         ];
  52.     }
  54.     /**
  55.      * Get all soap calls
  56.      * @return array
  57.      */
  58.     public function getCalls()
  59.     {
  60.         return $this->data['calls'];
  61.     }
  62. }