app/Service/EventSubscriber/ApmMetadataSubscriber.php line 43

Open in your IDE?
  1. <?php
  3. namespace Sq\Service\EventSubscriber;
  5. use Psr\Container\ContainerInterface;
  6. use Sq\Entity\Apm\TransactionInterface;
  7. use Sq\Event\Kernel\InitialiseContainerEvent;
  8. use Sq\Service\Apm\ApmInterface;
  9. use Sq\Service\Log\LogBuilder;
  10. use Sq\Service\Log\LogBuilderInterface;
  11. use Symfony\Component\DependencyInjection\ParameterBag\ParameterBagInterface;
  12. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  14. class ApmMetadataSubscriber implements EventSubscriberInterface
  15. {
  16.     private ApmInterface $apm;
  18.     private ContainerInterface $container;
  20.     private LogBuilderInterface $logBuilder;
  22.     private ParameterBagInterface $parameterBag;
  24.     public function __construct(ParameterBagInterface $parameterBag, ContainerInterface $container, ApmInterface $apm, LogBuilderInterface $logBuilder)
  25.     {
  26.         $this->apm = $apm;
  27.         $this->container = $container;
  28.         $this->logBuilder = $logBuilder;
  29.         $this->parameterBag = $parameterBag;
  30.     }
  32.     /** @inheritDoc */
  33.     public static function getSubscribedEvents()
  34.     {
  35.         return [
  36.             InitialiseContainerEvent::class => ['onInitializeContainer'],
  37.         ];
  38.     }
  40.     /**
  41.      * @param \Sq\Event\Kernel\InitialiseContainerEvent $event
  42.      */
  43.     public function onInitializeContainer(InitialiseContainerEvent $event): void
  44.     {
  45.         if ($this->apm->isTracking())
  46.         {
  47.             $transaction = $this->apm->getCurrentTransaction();
  48.             $this->addScriptId($transaction);
  49.             $transaction->addAttribute('instance_id', $this->parameterBag->get('instance.identifier'));
  50.             $transaction->addAttribute('app_name', $this->parameterBag->get('kernel.app_name'));
  51.             $transaction->addAttribute('app_type', $this->parameterBag->get('kernel.app_type'));
  52.         }
  53.     }
  55.     protected function addScriptId(TransactionInterface $transaction)
  56.     {
  57.         if ($this->logBuilder instanceof LogBuilder)
  58.         {
  59.             $transaction->addAttribute("script_id", $this->logBuilder->getProcessId());
  60.         }
  61.     }
  62. }