src/EventListener/USTServiceEventListener.php line 28

Open in your IDE?
  1. <?php
  3. namespace App\EventListener;
  5. use App\Event\USTServicePayloadEvent;
  6. use App\Logger\UstServiceTrafficLogger;
  7. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  8. use Symfony\Component\HttpKernel\Event\RequestEvent;
  10. class USTServiceEventListener implements EventSubscriberInterface
  11. {
  12.     private $trafficLoggingEnabled;
  13.     private $logger;
  15.     public function __construct(bool $trafficLoggingEnabled, UstServiceTrafficLogger $logger)
  16.     {
  17.         $this->trafficLoggingEnabled = $trafficLoggingEnabled;
  18.         $this->logger = $logger;
  19.     }
  21.     /**
  22.      * Logs traffic sent from mobile devices and UST service automatically.
  23.      *
  24.      * Note: If the route name is changed it should also be reflected here.
  25.      *
  26.      * @param RequestEvent $event
  27.      */
  28.     public function onKernelRequest(RequestEvent $event)
  29.     {
  30.         if (!$event->isMasterRequest()) {
  31.             // don't do anything if it's not the master request
  32.             return;
  33.         }
  35.         $request = $event->getRequest();
  36.         $route = $request->attributes->get('_route');
  38.         // Update package, called by mobile devices
  39.         if ($route == 'app_api_ibeaconlastseen_package') {
  40.             $this->logTrafficContent('package_log', $request->getContent());
  41.         }
  43.         // Update package, called by UST service
  44.         if ($route == 'app_api_ibeaconlastseen_update') {
  45.             $decoded = base64_decode($request->getContent());
  46.             $packages = json_decode($decoded, true);
  48.             $payload = json_encode($packages, JSON_PRETTY_PRINT | JSON_UNESCAPED_UNICODE);
  49.             $this->logTrafficContent('update_request_log', $payload);
  50.         }
  52.         // Update post test completetion status, called by google form submission
  53.         if ($route == 'app_api_posttestcompletion_update') {
  54.             $this->logTrafficContent('test_update_request_log', $request->getContent());
  55.         }
  56.     }
  58.     /**
  59.      * Logs UST service traffic event raised by application code.
  60.      *
  61.      * @param USTServicePayloadEvent $event
  62.      */
  63.     public function onPayloadEvent(USTServicePayloadEvent $event)
  64.     {
  65.         if ($this->trafficLoggingEnabled) {
  66.             $this->logTrafficContent(
  67.                 $event->getCategory(),
  68.                 $event->getPayload()
  69.             );
  70.         }
  71.     }
  73.     private function logTrafficContent($category, $payload)
  74.     {
  75.         if ($this->trafficLoggingEnabled) {
  76.             $this->logger->write($category, $payload);
  77.         }
  78.     }
  80.     public static function getSubscribedEvents()
  81.     {
  82.         return [
  83.             RequestEvent::class => 'onKernelRequest',
  84.             USTServicePayloadEvent::class => 'onPayloadEvent',
  85.         ];
  86.     }
  87. }