fix(Adapters/Symfony/Process) correctly close pipes

lucatume · Dec 9, 2023 · 4f2344d · 4f2344d
1 parent 0d70b4d
commit 4f2344d
Showing 1 changed file with 24 additions and 19 deletions.
diff --git a/src/Adapters/Symfony/Component/Process/Process.php b/src/Adapters/Symfony/Component/Process/Process.php
@@ -3,14 +3,16 @@
 namespace lucatume\WPBrowser\Adapters\Symfony\Component\Process;
 
 use Symfony\Component\Process\Exception\LogicException;
+use Symfony\Component\Process\Pipes\PipesInterface;
 use Symfony\Component\Process\Process as SymfonyProcess;
 
 class Process extends SymfonyProcess
 {
     /**
-     * @var array<string,mixed>
+     * @var bool
      */
-    private $options = [];
+    private $createNewConsole = false;
+
     /**
      * @param string[] $command
      * @param array<string,mixed>|null $env
@@ -51,28 +53,31 @@ public function getStartTime(): float
         return $startTime;
     }
 
-    /**
-     * @param string $name
-     * @param array<mixed> $arguments
-     * @return void
-     */
-    public function __call(string $name, array $arguments)
+    public function __destruct()
     {
-        if ($name === 'setOptions') {
-            $this->options = $arguments[0] ?? [];
+        if ($this->createNewConsole) {
+            $processPipesProperty = new \ReflectionProperty(SymfonyProcess::class, 'processPipes');
+            $processPipesProperty->setAccessible(true);
+            /** @var PipesInterface $processPipes */
+            $processPipes = $processPipesProperty->getValue($this);
+            $processPipes->close();
+
+            return;
         }
-        return;
+
+        $this->stop(0);
     }
 
-    public function __destruct()
+    public function createNewConsole(): void
     {
-        if (($this->options['create_new_console'] ?? false) || method_exists($this, 'setOptions')) {
-            parent::__destruct();
-            return;
-        }
+        $this->createNewConsole = true;
 
-        $closeMethodReflection = new \ReflectionMethod(SymfonyProcess::class, 'close');
-        $closeMethodReflection->setAccessible(true);
-        $closeMethodReflection->invoke($this);
+        $optionsReflectionProperty = new \ReflectionProperty(SymfonyProcess::class, 'options');
+        $optionsReflectionProperty->setAccessible(true);
+        $options = $optionsReflectionProperty->getValue($this);
+        $options = is_array($options) ? $options : [];
+        $options['create_new_console'] = true;
+        $options['bypass_shell'] = true;
+        $optionsReflectionProperty->setValue($this, $options);
     }
 }