src/Centralstage/DeviceBundle/EventSubscriber/DeviceSummarySubscriber.php line 17

Open in your IDE?
  1. <?php
  3. namespace App\Centralstage\DeviceBundle\EventSubscriber;
  5. use App\Centralstage\CoreBundle\Service\LogService;
  6. use App\Centralstage\DeviceBundle\Event\DeviceSummaryEvent as Devicesummary;
  7. use App\Centralstage\DeviceBundle\Models\DeviceDataModel;
  8. use App\Centralstage\CoreBundle\Utils\FileHelper;
  9. use App\Centralstage\ProductionMonitoringBundle\Service\PreGenerateDataService;
  10. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  11. use Symfony\Component\Process\Process;
  12. use App\Centralstage\CoreBundle\Service\SecretsService;
  14. class DeviceSummarySubscriber implements EventSubscriberInterface
  15. {
  17.     public function onDeviceSummary(Devicesummary $Devicesummary): void
  18.     {   
  19.         try{
  20.             //DATA
  21.             $EventData       = $Devicesummary->getData();
  22.             $rawData         = base64_encode($EventData["rawData"]);
  23.             $orgID           = $EventData["orgID"];
  25.             // $phpExecutable  = $_ENV['PHP_EXECUTABLE_PATH']; 
  26.             $phpExecutable  = SecretsService::get('PHP_EXECUTABLE_PATH', 'php'); 
  27.             $projectRoot    = PreGenerateDataService::ProjectPhpBinPath();
  28.             if(!empty($rawData) && !empty($orgID)){
  29.                 $command        = [$phpExecutable,"$projectRoot/bin/console",'app:summaryV2',$rawData,$orgID];
  30.                 $process        = new Process($command);
  31.                 $process->start();
  32.                 while ($process->isRunning()) {
  33.                 }
  34.             }else{
  35.                 // LogService::log("error message missing arguments orgID:$orgID rawData:$rawData ", "pushMissingArguments");
  36.             }
  37.             
  38.             unset($EventData); //free memory
  40.         }catch (\Exception $exception) { $error = $exception->getMessage(); }
  41.     }
  43.     public static function getSubscribedEvents(): array
  44.     {
  45.         return [
  46.             'device.summary.process' => 'onDeviceSummary'
  47.         ];
  48.     }
  49. }