Version 1

[yaffs-website] / vendor / drupal / console / src / Command / ServerCommand.php

diff --git a/vendor/drupal/console/src/Command/ServerCommand.php b/vendor/drupal/console/src/Command/ServerCommand.php
new file mode 100644 (file)
index 0000000..1d7fcb5
--- /dev/null
+++ b/vendor/drupal/console/src/Command/ServerCommand.php
@@ -0,0 +1,158 @@
+<?php
+
+/**
+ * @file
+ * Contains \Drupal\Console\Command\ServerCommand.
+ */
+
+namespace Drupal\Console\Command;
+
+use Symfony\Component\Console\Input\InputInterface;
+use Symfony\Component\Console\Output\OutputInterface;
+use Symfony\Component\Console\Input\InputArgument;
+use Symfony\Component\Process\ProcessBuilder;
+use Symfony\Component\Process\PhpExecutableFinder;
+use Symfony\Component\Console\Command\Command;
+use Drupal\Console\Core\Command\Shared\CommandTrait;
+use Drupal\Console\Core\Style\DrupalStyle;
+
+/**
+ * Class ServerCommand
+ *
+ * @package Drupal\Console\Command
+ */
+class ServerCommand extends Command
+{
+    use CommandTrait;
+
+    protected $appRoot;
+
+    protected $configurationManager;
+
+    /**
+     * ServerCommand constructor.
+     *
+     * @param $appRoot
+     * @param $configurationManager
+     */
+    public function __construct($appRoot, $configurationManager)
+    {
+        $this->appRoot = $appRoot;
+        $this->configurationManager = $configurationManager;
+
+        parent::__construct();
+    }
+
+    /**
+     * {@inheritdoc}
+     */
+    protected function configure()
+    {
+        $this
+            ->setName('server')
+            ->setDescription($this->trans('commands.server.description'))
+            ->addArgument(
+                'address',
+                InputArgument::OPTIONAL,
+                $this->trans('commands.server.arguments.address'),
+                '127.0.0.1:8088'
+            );
+    }
+
+    /**
+     * {@inheritdoc}
+     */
+    protected function execute(InputInterface $input, OutputInterface $output)
+    {
+        $io = new DrupalStyle($input, $output);
+        $learning = $input->hasOption('learning')?$input->getOption('learning'):false;
+        $address = $this->validatePort($input->getArgument('address'));
+
+        $finder = new PhpExecutableFinder();
+        if (false === $binary = $finder->find()) {
+            $io->error($this->trans('commands.server.errors.binary'));
+            return;
+        }
+
+        $router = $this->getRouterPath();
+        $processBuilder = new ProcessBuilder([$binary, '-S', $address, $router]);
+        $processBuilder->setTimeout(null);
+        $processBuilder->setWorkingDirectory($this->appRoot);
+        $process = $processBuilder->getProcess();
+
+        $io->success(
+            sprintf(
+                $this->trans('commands.server.messages.executing'),
+                $binary
+            )
+        );
+
+        $io->commentBlock(
+            sprintf(
+                $this->trans('commands.server.messages.listening'),
+                $address
+            )
+        );
+
+        // Use the process helper to copy process output to console output.
+        $this->getHelper('process')->run($output, $process, null, null);
+
+        if (!$process->isSuccessful()) {
+            $io->error($process->getErrorOutput());
+        }
+    }
+
+    /**
+     * @return null|string
+     */
+    private function getRouterPath()
+    {
+        $router = sprintf(
+            '%s/.console/router.php',
+            $this->configurationManager->getHomeDirectory()
+        );
+
+        if (file_exists($router)) {
+            return $router;
+        }
+
+        $router = sprintf(
+            '%s/config/dist/router.php',
+            $this->configurationManager->getApplicationDirectory()
+        );
+
+        if (file_exists($router)) {
+            return $router;
+        }
+
+        return null;
+    }
+
+    /**
+     * @param string $address
+     * @return string
+     */
+    private function validatePort($address)
+    {
+        if (false === strpos($address, ':')) {
+            $host = $address;
+            $port = '8088';
+        } else {
+            $host = explode(':', $address)[0];
+            $port = explode(':', $address)[1];
+        }
+
+        if (fsockopen($host, $port)) {
+            $port = rand(8888, 9999);
+            $address = sprintf(
+                '%s:%s',
+                $host,
+                $port
+            );
+
+            $address = $this->validatePort($address);
+        }
+
+        return $address;
+    }
+}