Implemented ShellAdapter

Author: zeroSal-le

src/Adapter/Shell/ShellAdapter.php

@@ -0,0 +1,67 @@
+<?php
+
+namespace Sal\Seven\Adapter\Shell;
+
+use Psr\Log\LoggerInterface;
+use Psr\Log\NullLogger;
+use Sal\Seven\Model\CommandResult;
+use Symfony\Component\Process\Exception\ProcessTimedOutException;
+use Symfony\Component\Process\Process;
+
+class ShellAdapter implements ShellAdapterInterface
+{
+    private LoggerInterface $logger;
+
+    public function __construct(
+        ?LoggerInterface $logger = null,
+    ) {
+        $this->logger = $logger ?? new NullLogger();
+    }
+
+    public function setLogger(LoggerInterface $logger): void
+    {
+        $this->logger = $logger;
+    }
+
+    public function getLogger(): LoggerInterface
+    {
+        return $this->logger;
+    }
+
+    /**
+     * Runs a command on the local shell providing $pipedInput in command STDIN.
+     * The process will be killed when $timeout seconds are reached.
+     * If the timeout is null, then no timeout is set to the process.
+     *
+     * @param mixed[] $command
+     *
+     * @return CommandResult the command result
+     *
+     * @throws \RuntimeException
+     * @throws ProcessTimedOutException
+     */
+    public function runCommand(
+        array $command,
+        ?string $pipedInput = null,
+        ?int $timeout = null,
+        ?\Closure $outCallback = null,
+    ): CommandResult {
+        $proc = new Process($command);
+
+        $this->logger->debug($proc->getCommandLine());
+
+        if (null !== $pipedInput) {
+            $proc->setInput($pipedInput);
+        }
+
+        $proc->setTimeout($timeout);
+        $code = $proc->run($outCallback);
+
+        return new CommandResult(
+            $code,
+            $proc->getOutput(),
+            $proc->getErrorOutput(),
+            $proc->getCommandLine(),
+        );
+    }
+}

src/Adapter/Shell/ShellAdapterInterface.php

@@ -0,0 +1,25 @@
+<?php
+
+namespace Sal\Seven\Adapter\Shell;
+
+use Psr\Log\LoggerAwareInterface;
+use Sal\Seven\Model\CommandResult;
+use Symfony\Component\Process\Exception\ProcessTimedOutException;
+
+interface ShellAdapterInterface extends LoggerAwareInterface
+{
+    /**
+     * @param mixed[] $command
+     *
+     * @return CommandResult the command result
+     *
+     * @throws \RuntimeException
+     * @throws ProcessTimedOutException
+     */
+    public function runCommand(
+        array $command,
+        ?string $pipedInput = null,
+        ?int $timeout = null,
+        ?\Closure $outCallback = null,
+    ): CommandResult;
+}

src/Adapter/Ssh/SshAdapterInterface.php

@@ -2,15 +2,14 @@
 
 namespace Sal\Seven\Adapter\Ssh;
 
-use Psr\Log\LoggerAwareInterface;
-use Sal\Seven\Model\CommandResult;
+use Sal\Seven\Adapter\Shell\ShellAdapterInterface;
 use Sal\Seven\Model\File;
 use Symfony\Component\Process\Exception\ProcessTimedOutException;
 
 /**
  * @author Luca Saladino <sal65535@protonmail.com>
  */
-interface SshAdapterInterface extends LoggerAwareInterface
+interface SshAdapterInterface extends ShellAdapterInterface
 {
     public function setHost(string $host): void;
 
@@ -26,26 +25,6 @@ public function getTimeout(): ?int;
 
     public function waitForSshLogin(): void;
 
-    /**
-     * Runs a command via SSH providing $pipedInput in command STDIN.
-     * The process will be killed when $timeout seconds are reached.
-     * If the timeout is null, then no timeout is set to the process.
-     * Executes: ssh -o <option> user@host $command | $pipedInput.
-     *
-     * @param mixed[] $command
-     *
-     * @return CommandResult the command result
-     *
-     * @throws \RuntimeException
-     * @throws ProcessTimedOutException
-     */
-    public function runCommand(
-        array $command,
-        ?string $pipedInput = null,
-        ?int $timeout = null,
-        ?\Closure $outCallback = null,
-    ): CommandResult;
-
     /**
      * Uploads a file via SCP killing the process when $timeout seconds are reached.
      * If the timeout is null, then no timeout is set to the upload process.