vendor/elements/process-manager-bundle/src/SystemEventsListener.php line 42

Open in your IDE?
  1. <?php
  3. /**
  4.  * Elements.at
  5.  *
  6.  * This source file is available under two different licenses:
  7.  * - GNU General Public License version 3 (GPLv3)
  8.  * - Pimcore Enterprise License (PEL)
  9.  * Full copyright and license information is available in
  10.  * LICENSE.md which is distributed with this source code.
  11.  *
  12.  *  @copyright  Copyright (c) elements.at New Media Solutions GmbH (https://www.elements.at)
  13.  *  @license    http://www.pimcore.org/license     GPLv3 and PEL
  14.  */
  16. namespace Elements\Bundle\ProcessManagerBundle;
  18. use Elements\Bundle\ProcessManagerBundle\Model\Configuration;
  19. use Elements\Bundle\ProcessManagerBundle\Model\MonitoringItem;
  20. use Symfony\Component\Console\ConsoleEvents;
  21. use Symfony\Component\Console\Event\ConsoleErrorEvent;
  22. use Symfony\Component\Console\Event\ConsoleTerminateEvent;
  23. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  25. class SystemEventsListener implements EventSubscriberInterface
  26. {
  27.     /**
  28.      * @return array
  29.      */
  30.     public static function getSubscribedEvents()
  31.     {
  32.         return [
  33.             ConsoleEvents::ERROR => 'onConsoleError',
  34.             ConsoleEvents::TERMINATE => 'onConsoleTerminate',
  36.         ];
  37.     }
  39.     /**
  40.      * @param ConsoleErrorEvent $e
  41.      */
  42.     public function onConsoleError(ConsoleErrorEvent $e)
  43.     {
  44.         if (!\Pimcore::isInstalled() || !ElementsProcessManagerBundle::isInstalled()) {
  45.             return;
  46.         }
  48.         if ($monitoringItem = ElementsProcessManagerBundle::getMonitoringItem()) {
  49.             $error = $e->getError();
  50.             $monitoringItem->setMessage('ERROR: ' . $error->getMessage());
  51.             $monitoringItem->getLogger()->error($error);
  52.             $monitoringItem->setPid(null)->setStatus($monitoringItem::STATUS_FAILED)->save();
  53.         }
  54.     }
  56.     /**
  57.      * @param ConsoleTerminateEvent $e
  58.      */
  59.     public function onConsoleTerminate(ConsoleTerminateEvent $e)
  60.     {
  61.         if (!\Pimcore::isInstalled() || !ElementsProcessManagerBundle::isInstalled()) {
  62.             return;
  63.         }
  65.         if ($monitoringItem = ElementsProcessManagerBundle::getMonitoringItem()) {
  66.             Helper::executeMonitoringItemLoggerShutdown($monitoringItem);
  67.         }
  69.         if ($e->getExitCode() == 0) {
  70.             if ($monitoringItem = ElementsProcessManagerBundle::getMonitoringItem()) {
  71.                 if ($config = Configuration::getById($monitoringItem->getConfigurationId())) {
  72.                     $versions = $config->getKeepVersions();
  73.                     if (is_numeric($versions)) {
  74.                         $list = new MonitoringItem\Listing();
  75.                         $list->setOrder('DESC')->setOrderKey('id')->setOffset((int)$versions)->setLimit(
  76.                             100000000000
  77.                         ); //a limit has to defined otherwise the offset wont work
  78.                         $list->setCondition(
  79.                             'status ="finished" AND configurationId=? AND IFNULL(pid,0) != ? AND parentId IS NULL ',
  80.                             [$config->getId(), $monitoringItem->getPid()]
  81.                         );
  83.                         $items = $list->load();
  84.                         foreach ($items as $item) {
  85.                             $item->delete();
  86.                         }
  87.                     }
  88.                 }
  89.                 if (!$monitoringItem->getMessage()) {
  90.                     $monitoringItem->setMessage('finished');
  91.                 }
  92.                 $monitoringItem->setCompleted();
  93.                 $monitoringItem->setPid(null)->save();
  94.             }
  95.         }
  96.     }
  97. }