[FEATURE] provide BeforeProcessRunnerExecutesCommandsEvent

Author: achimfritz

Classes/Domain/Service/ProcessRunner.php

@@ -13,15 +13,18 @@
  */
 
 use B13\ContentSync\Domain\Model\Configuration;
+use B13\ContentSync\Event\BeforeProcessRunnerExecutesCommandsEvent;
 use B13\ContentSync\Exception;
+use Psr\EventDispatcher\EventDispatcherInterface;
 use Psr\Log\LoggerInterface;
 use Symfony\Component\Process\Process;
 
 final readonly class ProcessRunner
 {
     public function __construct(
         private DatabaseParameterBuilder $databaseParameterBuilder,
-        private LoggerInterface $logger
+        private LoggerInterface $logger,
+        private EventDispatcherInterface $eventDispatcher
     ) {}
 
     public function localToRemote(Configuration $configuration): void
@@ -42,8 +45,11 @@ public function localToRemote(Configuration $configuration): void
             $file = rtrim($file, '/');
             $commands[] = 'rsync -a --delete --omit-dir-times --no-owner --no-group ' . $localNode->getBasePath() . $file . '/ ' . $remoteNode->getConnection() . ':' . $remoteNode->getBasePath() . $file;
         }
+        $beforeProcessRunnnerExecuteCommands = new BeforeProcessRunnerExecutesCommandsEvent($configuration, $commands);
+        $this->eventDispatcher->dispatch($beforeProcessRunnnerExecuteCommands);
+        $commands = $beforeProcessRunnnerExecuteCommands->commands;
         foreach ($commands as $command) {
-            $this->exec($command);
+            $this->exec($command, $beforeProcessRunnnerExecuteCommands->timeoutPerProcess);
         }
     }
 
@@ -65,15 +71,18 @@ public function remoteToLocal(Configuration $configuration): void
             $file = rtrim($file, '/');
             $commands[] = 'rsync -a --delete --omit-dir-times --no-owner --no-group ' . $remoteNode->getConnection() . ':' . $remoteNode->getBasePath() . $file . '/ ' . $localNode->getBasePath() . $file;
         }
+        $beforeProcessRunnnerExecuteCommands = new BeforeProcessRunnerExecutesCommandsEvent($configuration, $commands);
+        $this->eventDispatcher->dispatch($beforeProcessRunnnerExecuteCommands);
+        $commands = $beforeProcessRunnnerExecuteCommands->commands;
         foreach ($commands as $command) {
-            $this->exec($command);
+            $this->exec($command, $beforeProcessRunnnerExecuteCommands->timeoutPerProcess);
         }
     }
 
-    private function exec(string $cmd): void
+    private function exec(string $cmd, int $timeout): void
     {
         $this->logger->debug($cmd);
-        $process = Process::fromShellCommandline($cmd);
+        $process = Process::fromShellCommandline(command: $cmd, timeout: $timeout);
         $process->run();
         if (!$process->isSuccessful()) {
             throw new Exception('cannot exec command ' . $cmd . ' with error ' . $process->getErrorOutput(), 1600757440);

Classes/Event/BeforeProcessRunnerExecutesCommandsEvent.php

@@ -0,0 +1,25 @@
+<?php
+
+declare(strict_types=1);
+
+namespace B13\ContentSync\Event;
+
+/*
+ * This file is part of TYPO3 CMS-based extension "content-sync" by b13.
+ *
+ * It is free software; you can redistribute it and/or modify it under
+ * the terms of the GNU General Public License, either version 2
+ * of the License, or any later version.
+ */
+
+use B13\ContentSync\Domain\Model\Configuration;
+
+final class BeforeProcessRunnerExecutesCommandsEvent
+{
+    public int $timeoutPerProcess = 60;
+
+    public function  __construct(
+        public readonly Configuration $configuration,
+        public array $commands
+    ) {}
+}