EZP-31967: Added logging to ezplatform:cron:run command

README.md

@@ -39,3 +39,19 @@ The tag takes the following arguments:
             - { name: console.command }
             - { name: ezplatform.cron.job, schedule: '* * * * *' }
 ```
+
+## Logging run command
+If you want to log outputs of commands processed by run command you have to add the monolog channel `cronjob` to your configuration.
+
+### Example
+```yml
+    monolog:
+        channels: [...,'cronjob']
+        handlers:    
+            cronjob:
+                bubble: false
+                level: info
+                type: stream
+                path: '%kernel.logs_dir%/cronjob.log'
+                channels: [cronjob]
+```

src/bundle/Command/CronRunCommand.php

@@ -1,7 +1,7 @@
 <?php
 
 /**
- * @copyright Copyright (C) eZ Systems AS. All rights reserved.
+ * @copyright Copyright (C) Ibexa AS. All rights reserved.
  * @license For full copyright and license information view LICENSE file distributed with this source code.
  */
 namespace EzSystems\EzPlatformCronBundle\Command;
@@ -13,9 +13,24 @@
 use Symfony\Component\Console\Input\InputInterface;
 use Symfony\Component\Console\Input\InputOption;
 use Symfony\Component\Console\Output\OutputInterface;
+use Psr\Log\LoggerInterface;
 
 class CronRunCommand extends ContainerAwareCommand
 {
+    /**
+     * @var \Psr\Log\LoggerInterface
+     */
+    private $logger;
+
+    /**
+     * @injectService $logger @logger
+     */
+    public function __construct(LoggerInterface $logger = null)
+    {
+        parent::__construct();
+        $this->logger = $logger;
+    }
+
     protected function configure()
     {
         $this
@@ -46,6 +61,31 @@ protected function execute(InputInterface $input, OutputInterface $output)
         $cron->setExecutor(new Executor());
         $cron->setResolver($resolver);
 
-        $cron->run();
+        $reports = $cron->run();
+
+        while ($cron->isRunning()) {
+            usleep(10000);
+        }
+
+        if ($this->logger) {
+            foreach ($reports->getReports() as $report) {
+                $process = $report->getJob()->getProcess();
+                $extraInfo = [
+                    'command' => $process->getCommandLine(),
+                    'exitCode' => $process->getExitCode(),
+                ];
+                foreach ($report->getOutput() as $reportOutput) {
+                    $this->logger->info($reportOutput, $extraInfo);
+                }
+                if (!$report->isSuccessful()) {
+                    foreach ($report->getError() as $reportError) {
+                        $reportError = trim($reportError);
+                        if (!empty($reportError)) {
+                            $this->logger->error($reportError, $extraInfo);
+                        }
+                    }
+                }
+            }
+        }
     }
 }

src/bundle/DependencyInjection/EzPlatformCronExtension.php

@@ -1,20 +1,22 @@
 <?php
 
 /**
- * @copyright Copyright (C) eZ Systems AS. All rights reserved.
+ * @copyright Copyright (C) Ibexa AS. All rights reserved.
  * @license For full copyright and license information view LICENSE file distributed with this source code.
  */
 namespace EzSystems\EzPlatformCronBundle\DependencyInjection;
 
 use Symfony\Component\Config\FileLocator;
 use Symfony\Component\DependencyInjection\ContainerBuilder;
+use Symfony\Component\DependencyInjection\Extension\PrependExtensionInterface;
 use Symfony\Component\DependencyInjection\Loader\YamlFileLoader;
 use Symfony\Component\HttpKernel\DependencyInjection\Extension;
+use Symfony\Component\Yaml\Yaml;
 
 /**
  * Loads and manages bundle configuration.
  */
-class EzPlatformCronExtension extends Extension
+class EzPlatformCronExtension extends Extension implements PrependExtensionInterface
 {
     /**
      * {@inheritdoc}
@@ -24,4 +26,15 @@ public function load(array $configs, ContainerBuilder $container)
         $loader = new YamlFileLoader($container, new FileLocator(__DIR__ . '/../Resources/config'));
         $loader->load('services.yml');
     }
+
+    /**
+     * Allow an extension to prepend the extension configurations.
+     *
+     * @param \Symfony\Component\DependencyInjection\ContainerBuilder $container
+     */
+    public function prepend(ContainerBuilder $container)
+    {
+        $config = Yaml::parse(file_get_contents(__DIR__ . '/../Resources/config/monolog.yml'));
+        $container->prependExtensionConfig('monolog', $config);
+    }
 }

src/bundle/Resources/config/monolog.yml

@@ -0,0 +1 @@
+channels: ['cronjob']

src/bundle/Resources/config/services.yml

@@ -1,9 +1,17 @@
 parameters:
     ezplatform.cron.registry.cronjobs.class: EzSystems\EzPlatformCronBundle\Registry\CronJobsRegistry
+    ezplatform.console.command.run.class: EzSystems\EzPlatformCronBundle\Command\CronRunCommand
 
 services:
     ezplatform.cron.registry.cronjobs:
         class: '%ezplatform.cron.registry.cronjobs.class%'
         arguments:
             - '%kernel.environment%'
             - '@ezpublish.siteaccess'
+
+    ezplatform.console.command.run:
+        class: '%ezplatform.console.command.run.class%'
+        arguments:
+            $logger: "@monolog.logger.cronjob"
+        tags:
+            - { name: console.command }