Merge pull request #17 from prooph/commands

add new commands

bin/micro.php

@@ -26,4 +26,7 @@
 
 $application = new Application('Prooph-Micro CLI');
 $application->add(new Command\SetupCommand());
+$application->add(new Command\CreateMySqlCommand());
+$application->add(new Command\CreatePostgresCommand());
+$application->add(new Command\CreatePhpServiceCommand());
 $application->run();

composer.json

@@ -29,7 +29,10 @@
         "prooph/php-cs-fixer-config": "^0.1.1",
         "beberlei/assert": "^2.7",
         "symfony/console": "^3.2.2",
-        "symfony/yaml": "^3.2.2"
+        "symfony/filesystem": "^3.2.2",
+        "symfony/yaml": "^3.2.2",
+        "madkom/nginx-configurator": "dev-master",
+        "ferno/loco": "dev-master"
     },
     "require-dev": {
         "phpunit/phpunit": "^5.7",

gateway/README.md

@@ -0,0 +1,5 @@
+# Gateway directory
+
+Here comes the nginx configuration file `www.conf`
+
+Start with `./bin/micro micro:setup` to create the initial configuration.

service/README.md

@@ -0,0 +1,7 @@
+# Server directory
+
+Put your microservices here
+
+Start with `./bin/micro micro:setup` to create the initial configuration.
+
+Call `./bin/micro micro:create:php-service` to create a new php service skeletton along with nginx config.

src/Command/AbstractCommand.php

@@ -0,0 +1,42 @@
+<?php
+/**
+ * This file is part of the prooph/micro.
+ * (c) 2017-2017 prooph software GmbH <contact@prooph.de>
+ * (c) 2017-2017 Sascha-Oliver Prolic <saschaprolic@googlemail.com>
+ *
+ * For the full copyright and license information, please view the LICENSE
+ * file that was distributed with this source code.
+ */
+
+declare(strict_types=1);
+
+namespace Prooph\Micro\Command;
+
+use Symfony\Component\Console\Command\Command;
+use Symfony\Component\Yaml\Yaml;
+
+abstract class AbstractCommand extends Command
+{
+    protected function getRootDir(): string
+    {
+        if (file_exists(__DIR__ . '/../../vendor/autoload.php')) {
+            return realpath(__DIR__ . '/../../');
+        } elseif (file_exists(__DIR__ . '/../../../../autoload.php')) {
+            return realpath(__DIR__ . '/../../../../../');
+        }
+    }
+
+    protected function updateConfig(string $serviceName, array $config): void
+    {
+        $configFileName = $this->getRootDir() . '/docker-compose.yml';
+        $configFile = file_get_contents($configFileName);
+
+        $oldConfig = Yaml::parse($configFile);
+
+        if (array_key_exists($serviceName, $oldConfig['services'])) {
+            throw new \RuntimeException('The requested service name "' . $serviceName . '" exists already.');
+        }
+
+        file_put_contents($configFileName, Yaml::dump(array_merge_recursive($oldConfig, $config), 10, 2));
+    }
+}

src/Command/CreateMySqlCommand.php

@@ -0,0 +1,227 @@
+<?php
+/**
+ * This file is part of the prooph/micro.
+ * (c) 2017-2017 prooph software GmbH <contact@prooph.de>
+ * (c) 2017-2017 Sascha-Oliver Prolic <saschaprolic@googlemail.com>
+ *
+ * For the full copyright and license information, please view the LICENSE
+ * file that was distributed with this source code.
+ */
+
+declare(strict_types=1);
+
+namespace Prooph\Micro\Command;
+
+use Symfony\Component\Console\Command\LockableTrait;
+use Symfony\Component\Console\Input\InputInterface;
+use Symfony\Component\Console\Output\OutputInterface;
+use Symfony\Component\Console\Question\ChoiceQuestion;
+use Symfony\Component\Console\Question\Question;
+use Symfony\Component\Console\Style\SymfonyStyle;
+
+class CreateMySqlCommand extends AbstractCommand
+{
+    use LockableTrait;
+
+    protected function configure()
+    {
+        $this
+            ->setName('micro:create:mysql')
+            ->setDescription('Setup a MySQL database')
+            ->setHelp('This command creates a MySQL database as service');
+    }
+
+    protected function execute(InputInterface $input, OutputInterface $output)
+    {
+        $io = new SymfonyStyle($input, $output);
+
+        if (! $this->lock()) {
+            $io->warning('The command is already running in another process. Aborted.');
+
+            return 1;
+        }
+
+        if (! file_exists($this->getRootDir() . '/docker-compose.yml')) {
+            $io->warning('docker-compose.yml does not exist. Run ./bin/micro micro:setup. Aborted.');
+
+            $this->release();
+
+            return 1;
+        }
+
+        $question = new Question('Name of the service (f.e. mysql): ');
+        $question->setValidator(function ($answer) {
+            if (! is_string($answer) || ! preg_match('/^[a-z-0-9]+$/', $answer)) {
+                throw new \RuntimeException(
+                    'Invalid service name'
+                );
+            }
+
+            return $answer;
+        });
+        $question->setMaxAttempts(2);
+
+        $serviceName = $io->askQuestion($question);
+        $configMessages[] = '<info>Service name:</info> '.$serviceName;
+
+        $question = new ChoiceQuestion('Which MySQL image to use?', [
+            'mysql:5.7',
+            'mysql:5.6',
+            'mysql:5.5',
+        ]);
+        $question->setMaxAttempts(2);
+
+        $image = $io->askQuestion($question);
+        $configMessages[] = '<info>MySQL image:</info> '.$image;
+
+        $question = new Question('Database name: ', false);
+        $question->setValidator(function ($answer) {
+            if (! is_string($answer) || strlen($answer) === 0) {
+                throw new \RuntimeException(
+                    'Database name cannot be empty'
+                );
+            }
+
+            return $answer;
+        });
+        $question->setMaxAttempts(2);
+
+        $dbName = $io->askQuestion($question);
+        $configMessages[] = '<info>Database name:</info> '.$dbName;
+
+        $question = new Question('MySQL port: ', 'random');
+        $question->setValidator(function ($answer) {
+            if ('random' === $answer) {
+                return '';
+            }
+
+            if (! is_int((int) $answer) || 0 === (int) $answer) {
+                throw new \RuntimeException(
+                    'Invalid MySQL port'
+                );
+            }
+
+            return $answer;
+        });
+        $question->setMaxAttempts(2);
+
+        $dbPort = $io->askQuestion($question);
+        $configMessages[] = '<info>Database port:</info> '.($dbPort ?: 'random');
+
+        $question = new Question('MySQL root password: ', '');
+        $question->setValidator(function ($answer) {
+            if (! is_string($answer)) {
+                throw new \RuntimeException(
+                    'Invalid password'
+                );
+            }
+
+            return $answer;
+        });
+        $question->setMaxAttempts(2);
+
+        $mysqlRoot = $io->askQuestion($question);
+        $configMessages[] = '<info>MySQL root password:</info> ' . $mysqlRoot;
+
+        $answer = $io->confirm('Do you want to create antoher MySQL user?', false);
+
+        if ($answer) {
+            $question = new Question('MySQL user: ', '');
+            $question->setValidator(function ($answer) {
+                if (! is_string($answer) || strlen($answer) === 0) {
+                    throw new \RuntimeException(
+                        'Invalid user'
+                    );
+                }
+
+                return $answer;
+            });
+            $question->setMaxAttempts(2);
+
+            $userName = $io->askQuestion($question);
+            $configMessages[] = '<info>MySQL user:</info> ' . $userName;
+
+            $question = new Question('MySQL password: ', '');
+            $question->setValidator(function ($answer) {
+                if (! is_string($answer) || strlen($answer) === 0) {
+                    throw new \RuntimeException(
+                        'Invalid password'
+                    );
+                }
+
+                return $answer;
+            });
+            $question->setMaxAttempts(2);
+
+            $password = $io->askQuestion($question);
+            $configMessages[] = '<info>MySQL password:</info> '.$password;
+        }
+
+        $question = new Question('Mount docker-entrypoint-initdb.d (optional): ', null);
+        $question->setValidator(function ($answer) {
+            return $answer;
+        });
+
+        $initDb = $io->askQuestion($question);
+        $configMessages[] = '<info>docker-entrypoint-initdb.d:</info> '.$initDb;
+
+        $io->section('Setup will be done with the following configuration:');
+        $io->listing($configMessages);
+
+        if (! $io->confirm('Are those settings correct?', false)) {
+            $io->writeln('<comment>Aborted</comment>');
+
+            $this->release();
+
+            return 1;
+        }
+
+        $config = [
+            'services' => [
+                $serviceName => [
+                    'image' => $image,
+                    'environment' => [
+                        "MYSQL_ROOT_PASSWORD=$mysqlRoot",
+                        "MYSQL_DATABASE=$dbName",
+                    ],
+                    'labels' => [
+                        'prooph-pdo' => true,
+                    ],
+                ],
+            ],
+        ];
+
+        if ($dbPort === 'random') {
+            $config['services'][$serviceName]['ports'] = [
+                '3306',
+            ];
+        }
+
+        if ($dbPort !== '3306') {
+            $config['services'][$serviceName]['ports'] = [
+                "$dbPort:3306",
+            ];
+        }
+
+        if ($answer) {
+            $config['services'][$serviceName]['environment'][] = "MYSQL_USER=$userName";
+            $config['services'][$serviceName]['environment'][] = "MYSQL_PASSWORD=$password";
+        }
+
+        if (empty($mysqlRoot)) {
+            $config['services'][$serviceName]['environment'][] = 'MYSQL_ALLOW_EMPTY_PASSWORD=yes';
+        }
+
+        if (null !== $initDb) {
+            $config['services'][$serviceName]['volumes'][] = "$initDb:/docker-entrypoint-initdb.d";
+        }
+
+        $this->updateConfig($serviceName, $config);
+
+        $io->success('Successfully updated microservice settings');
+
+        $this->release();
+
+        return 0;
+    }
+}