Merge 8439d2b into 1732508

src/Deployment/Connection/AbstractSSHConnectionAdapter.php

@@ -0,0 +1,155 @@
+<?php
+
+namespace Accompli\Deployment\Connection;
+
+/**
+ * AbstractSSHConnectionAdapter.
+ *
+ * @author Niels Nijens <nijens.niels@gmail.com>
+ */
+abstract class AbstractSSHConnectionAdapter implements ConnectionAdapterInterface
+{
+    /**
+     * The hostname to connect to.
+     *
+     * @var string
+     */
+    protected $hostname;
+
+    /**
+     * The username used for authentication.
+     *
+     * @var string
+     */
+    protected $authenticationUsername;
+
+    /**
+     * {@inheritdoc}
+     */
+    public function copy($remoteSource, $remoteDestination)
+    {
+        if ($this->isConnected()) {
+            $arguments = array(
+                '--recursive',
+                $remoteSource,
+                $remoteDestination,
+            );
+
+            return $this->executeCommand('cp', $arguments)->isSuccessful();
+        }
+
+        return false;
+    }
+
+    /**
+     * {@inheritdoc}
+     */
+    public function putContents($destinationFilename, $data)
+    {
+        if ($this->isConnected()) {
+            $data = preg_replace('/\n$/', '', $data);
+
+            return $this->executeCommand(sprintf("cat <<EOF > \"%s\"\n%s\nEOF\n", $destinationFilename, $data))->isSuccessful();
+        }
+
+        return false;
+    }
+
+    /**
+     * {@inheritdoc}
+     */
+    public function putFile($sourceFilename, $destinationFilename)
+    {
+        if ($this->isConnected()) {
+            $data = @file_get_contents($sourceFilename);
+            if ($data !== false) {
+                return $this->putContents($destinationFilename, $data);
+            }
+        }
+
+        return false;
+    }
+
+    /**
+     * Returns the username of the user executing the script.
+     *
+     * @return string
+     */
+    protected function getCurrentUsername()
+    {
+        return $_SERVER['USER'];
+    }
+
+    /**
+     * Returns the 'home' directory for the user.
+     *
+     * @return string|null
+     */
+    protected function getUserDirectory()
+    {
+        $userDirectory = null;
+        if (isset($_SERVER['HOME'])) {
+            $userDirectory = $_SERVER['HOME'];
+        } elseif (isset($_SERVER['USERPROFILE'])) {
+            $userDirectory = $_SERVER['USERPROFILE'];
+        }
+        $userDirectory = realpath($userDirectory.'/../');
+        $userDirectory .= '/'.$this->authenticationUsername;
+
+        return $userDirectory;
+    }
+
+    /**
+     * Returns the filtered output of the command.
+     * Removes the command echo and shell prompt from the output.
+     *
+     * @param string $output
+     * @param string $command
+     *
+     * @return string
+     */
+    protected function getFilteredOutput($output, $command)
+    {
+        $output = str_replace(array("\r\n", "\r"), array("\n", ''), $output);
+
+        $matches = array();
+        if (preg_match($this->getOutputFilterRegex($command), $output, $matches) === 1) {
+            $output = ltrim($matches[1]);
+        }
+
+        return $output;
+    }
+
+    /**
+     * Returns the output filter regex to filter the output.
+     *
+     * @param string $command
+     *
+     * @return string
+     */
+    protected function getOutputFilterRegex($command)
+    {
+        $commandCharacters = str_split(preg_quote($command, '/'));
+        $commandCharacterRegexWhitespaceFunction = function ($value) {
+            if ($value !== '\\') {
+                $value .= '\s?';
+            }
+
+            return $value;
+        };
+
+        $commandCharacters = array_map($commandCharacterRegexWhitespaceFunction, $commandCharacters);
+
+        return sprintf('/%s(.*)%s/s', implode('', $commandCharacters), substr($this->getShellPromptRegex(), 1, -1));
+    }
+
+    /**
+     * Returns the regex matching the shell prompt.
+     *
+     * @return string
+     */
+    protected function getShellPromptRegex()
+    {
+        return sprintf('/%s@.*[$|#]/', $this->authenticationUsername);
+    }
+}

src/Deployment/Connection/LocalConnectionAdapter.php

@@ -192,6 +192,10 @@ public function changePermissions($remoteTarget, $fileMode, $recursive = false)
      */
     public function putContents($remoteFilename, $data)
     {
+        if (substr($data, -1) !== "\n") {
+            $data .= "\n";
+        }
+
         $result = file_put_contents($remoteFilename, $data);
 
         return ($result !== false);