src/Component/Console/Listener/ConsoleEventListener.php line 31

Open in your IDE?
  1. <?php
  3. namespace App\Component\Console\Listener;
  5. use App\Component\Console\Output\ConsoleLogOutput;
  6. use App\Component\Traits\Service\EmailerServiceTrait;
  7. use Symfony\Component\Console\Event\ConsoleCommandEvent;
  8. use Symfony\Component\Console\Event\ConsoleErrorEvent;
  9. use Symfony\Component\Console\Event\ConsoleTerminateEvent;
  10. use Symfony\Component\Console\Input\ArgvInput;
  11. use Symfony\Component\Console\Input\InputArgument;
  12. use Symfony\Component\Filesystem\Filesystem;
  13. use Symfony\Component\HttpKernel\KernelInterface;
  14. use Symfony\Component\Mailer\Exception\TransportExceptionInterface;
  16. class ConsoleEventListener
  17. {
  18. use EmailerServiceTrait;
  20. protected $kernel;
  22. public function __construct(KernelInterface $kernel)
  23. {
  24. $this->kernel = $kernel;
  25. }
  27. /**
  28. * @param ConsoleCommandEvent $event
  29. * @throws \Exception
  30. */
  31. public function onConsoleCommand(ConsoleCommandEvent $event)
  32. {
  33. /** @var ArgvInput $input */
  34. $input = $event->getInput();
  35. $event->getOutput()->writeln('START ' . $this->getDisplayedName($input));
  37. /** @var ConsoleLogOutput $output */
  38. $output = $event->getOutput();
  39. set_error_handler(function ($errno, $errstr, $errfile, $errline/*, $errContext*/) use ($output) {
  41. $file = $this->getRelativePath($errfile);
  42. $message = $errstr . ' in ' . $file . ':' . $errline;
  44. $trace = (new \Exception)->getTraceAsString();
  45. // Remove first item from backtrace as it's this function which is redundant.
  46. $trace = preg_replace('/^#0.+' . 'ConsoleEventListener' . "[^\n]*\n/", '', $trace, 1);
  48. switch ($errno) {
  49. case E_WARNING:
  50. case E_USER_WARNING:
  51. $output->addWarning($message, $trace, $errno);
  52. break;
  53. case E_NOTICE:
  54. case E_USER_NOTICE:
  55. $output->addNotice($message, $trace, $errno);
  56. break;
  57. case E_DEPRECATED:
  58. case E_USER_DEPRECATED:
  59. // pas de log des "deprecated"
  60. return true;
  61. default:
  62. $output->addError($message, $trace, $errno);
  63. }
  65. return true;
  66. });
  67. }
  69. /**
  70. * @param ConsoleTerminateEvent $event
  71. * @throws \Exception
  72. * @throws TransportExceptionInterface
  73. */
  74. public function onConsoleTerminate(ConsoleTerminateEvent $event)
  75. {
  76. /** @var ArgvInput $input */
  77. $input = $event->getInput();
  78. $event->getOutput()->writeln('END ' . $this->getDisplayedName($input));
  80. if (method_exists($event->getOutput(), 'getErrors') && !empty($event->getOutput()->getErrors())) {
  81. $this->emailerService
  82. ->setTo($this->kernel->getContainer()->getParameter('app.default_recipient'))
  83. ->setSubject('Erreur de CRON (' . $event->getCommand()->getName() . ')')
  84. ->setTemplate('email/console-error.html.twig')
  85. ->setParameters([
  86. 'cron' => $this->getDisplayedName($input),
  87. 'date' => new \DateTime(),
  88. 'erreurs' => $event->getOutput()->getErrors(),
  89. ])
  90. ->send();
  91. }
  93. // // On supprime le fichier si rien n'est loggé
  94. // $a = $event->getCommand()->getApplication();
  95. // if ($a instanceof ConsoleApplication) {
  96. // $f = $a->logFile;
  97. // $c = file_get_contents($f);
  98. // $l = substr_count($c, "\n");
  99. // if ($l === 2) {
  100. // (new Filesystem())->remove($f);
  101. // }
  102. // }
  103. }
  105. /**
  106. * @param ConsoleErrorEvent $event
  107. */
  108. public function onConsoleError(ConsoleErrorEvent $event)
  109. {
  110. $error = $event->getError();
  111. /** @var ConsoleLogOutput $output */
  112. $output = $event->getOutput();
  113. $output->addError($error->getMessage(), $error->getTraceAsString(), $error->getCode());
  114. }
  116. /**
  117. * @param ArgvInput|InputArgument $input
  118. * @return string
  119. */
  120. protected function getDisplayedName($input)
  121. {
  122. $args = $input->__toString();
  123. return trim(str_replace('"', '', $args));
  124. }
  126. /**
  127. * @param string $file
  128. * @return string
  129. */
  130. protected function getRelativePath($file)
  131. {
  132. $filesystem = new Filesystem();
  133. return $filesystem->makePathRelative(dirname($file), $this->kernel->getProjectDir()) . basename($file);
  134. }
  135. }