Updated CreateDatabaseCommand to create the empty database if it does not exist

config/autoload/installer.global.php

@@ -36,4 +36,13 @@ return [
         ],
     ],
 
+    'installation_commands' => [
+        'db_create_schema' => [
+            'command' => 'bin/cli db:create',
+        ],
+//        'db_migrate' => [
+//            'command' => 'bin/cli db:migrate',
+//        ],
+    ],
+
 ];

module/CLI/config/dependencies.config.php

@@ -3,6 +3,7 @@ declare(strict_types=1);
 
 namespace Shlinkio\Shlink\CLI;
 
+use Doctrine\DBAL\Connection;
 use GeoIp2\Database\Reader;
 use Shlinkio\Shlink\CLI\Util\GeolocationDbUpdater;
 use Shlinkio\Shlink\Common\IpGeolocation\GeoLite2\DbUpdater;
@@ -83,6 +84,7 @@ return [
             Locker::class,
             SymfonyCli\Helper\ProcessHelper::class,
             PhpExecutableFinder::class,
+            Connection::class,
         ],
     ],
 

module/CLI/src/Command/Db/AbstractDatabaseCommand.php

@@ -0,0 +1,33 @@
+<?php
+declare(strict_types=1);
+
+namespace Shlinkio\Shlink\CLI\Command\Db;
+
+use Shlinkio\Shlink\CLI\Command\Util\AbstractLockedCommand;
+use Symfony\Component\Console\Helper\ProcessHelper;
+use Symfony\Component\Console\Output\OutputInterface;
+use Symfony\Component\Lock\Factory as Locker;
+use Symfony\Component\Process\PhpExecutableFinder;
+
+use function array_unshift;
+
+abstract class AbstractDatabaseCommand extends AbstractLockedCommand
+{
+    /** @var ProcessHelper */
+    private $processHelper;
+    /** @var string */
+    private $phpBinary;
+
+    public function __construct(Locker $locker, ProcessHelper $processHelper, PhpExecutableFinder $phpFinder)
+    {
+        parent::__construct($locker);
+        $this->processHelper = $processHelper;
+        $this->phpBinary = $phpFinder->find(false) ?: 'php';
+    }
+
+    protected function runPhpCommand(OutputInterface $output, array $command): void
+    {
+        array_unshift($command, $this->phpBinary);
+        $this->processHelper->run($output, $command);
+    }
+}

module/CLI/src/Command/Db/CreateDatabaseCommand.php

@@ -3,7 +3,7 @@ declare(strict_types=1);
 
 namespace Shlinkio\Shlink\CLI\Command\Db;
 
-use Shlinkio\Shlink\CLI\Command\Util\AbstractLockedCommand;
+use Doctrine\DBAL\Connection;
 use Shlinkio\Shlink\CLI\Command\Util\LockedCommandConfig;
 use Shlinkio\Shlink\CLI\Util\ExitCodes;
 use Symfony\Component\Console\Helper\ProcessHelper;
@@ -13,22 +13,25 @@ use Symfony\Component\Console\Style\SymfonyStyle;
 use Symfony\Component\Lock\Factory as Locker;
 use Symfony\Component\Process\PhpExecutableFinder;
 
-class CreateDatabaseCommand extends AbstractLockedCommand
+use function Functional\contains;
+
+class CreateDatabaseCommand extends AbstractDatabaseCommand
 {
     public const NAME = 'db:create';
     private const DOCTRINE_HELPER_SCRIPT = 'vendor/doctrine/orm/bin/doctrine.php';
     private const DOCTRINE_HELPER_COMMAND = 'orm:schema-tool:create';
 
-    /** @var ProcessHelper */
-    private $processHelper;
-    /** @var string */
-    private $phpBinary;
+    /** @var Connection */
+    private $conn;
 
-    public function __construct(Locker $locker, ProcessHelper $processHelper, PhpExecutableFinder $phpFinder)
-    {
-        parent::__construct($locker);
-        $this->processHelper = $processHelper;
-        $this->phpBinary = $phpFinder->find(false) ?: 'php';
+    public function __construct(
+        Locker $locker,
+        ProcessHelper $processHelper,
+        PhpExecutableFinder $phpFinder,
+        Connection $conn
+    ) {
+        parent::__construct($locker, $processHelper, $phpFinder);
+        $this->conn = $conn;
     }
 
     protected function configure(): void
@@ -44,34 +47,34 @@ class CreateDatabaseCommand extends AbstractLockedCommand
     {
         $io = new SymfonyStyle($input, $output);
 
-        if ($this->dbExistsAndIsPopulated()) {
+        $this->checkDbExists();
+
+        if ($this->schemaExists()) {
             $io->success('Database already exists.');
             return ExitCodes::EXIT_SUCCESS;
         }
 
-        if (! $this->schemaExists()) {
-            // TODO Create empty database
-        }
-
         // Create database
         $io->writeln('Creating database tables...');
-        $command = [$this->phpBinary, self::DOCTRINE_HELPER_SCRIPT, self::DOCTRINE_HELPER_COMMAND];
-        $this->processHelper->run($output, $command);
+        $this->runPhpCommand($output, [self::DOCTRINE_HELPER_SCRIPT, self::DOCTRINE_HELPER_COMMAND]);
         $io->success('Database properly created!');
 
         return ExitCodes::EXIT_SUCCESS;
     }
 
-    private function dbExistsAndIsPopulated(): bool
+    private function checkDbExists(): void
     {
-        // TODO Implement
-        return false;
+        $schemaManager = $this->conn->getSchemaManager();
+        $databases = $schemaManager->listDatabases();
+        if (! contains($databases, '')) {
+            $schemaManager->createDatabase($this->conn->getDatabase());
+        }
     }
 
     private function schemaExists(): bool
     {
         // TODO Implement
-        return true;
+        return false;
     }
 
     protected function getLockConfig(): LockedCommandConfig

module/Common/config/doctrine.config.php

@@ -3,6 +3,7 @@ declare(strict_types=1);
 
 namespace Shlinkio\Shlink\Common;
 
+use Doctrine\DBAL\Connection;
 use Doctrine\ORM\EntityManager;
 
 return [
@@ -18,6 +19,7 @@ return [
     'dependencies' => [
         'factories' => [
             EntityManager::class => Doctrine\EntityManagerFactory::class,
+            Connection::class => Doctrine\ConnectionFactory::class,
         ],
         'aliases' => [
             'em' => EntityManager::class,

module/Common/src/Doctrine/ConnectionFactory.php

@@ -0,0 +1,17 @@
+<?php
+declare(strict_types=1);
+
+namespace Shlinkio\Shlink\Common\Doctrine;
+
+use Doctrine\DBAL\Connection;
+use Doctrine\ORM\EntityManager;
+use Psr\Container\ContainerInterface;
+
+class ConnectionFactory
+{
+    public function __invoke(ContainerInterface $container): Connection
+    {
+        $em = $container->get(EntityManager::class);
+        return $em->getConnection();
+    }
+}

module/Common/test/Doctrine/ConnectionFactoryTest.php

@@ -0,0 +1,44 @@
+<?php
+declare(strict_types=1);
+
+namespace ShlinkioTest\Shlink\Common\Doctrine;
+
+use Doctrine\DBAL\Connection;
+use Doctrine\ORM\EntityManager;
+use Doctrine\ORM\EntityManagerInterface;
+use PHPUnit\Framework\TestCase;
+use Prophecy\Prophecy\ObjectProphecy;
+use Psr\Container\ContainerInterface;
+use Shlinkio\Shlink\Common\Doctrine\ConnectionFactory;
+
+class ConnectionFactoryTest extends TestCase
+{
+    /** @var ConnectionFactory */
+    private $factory;
+    /** @var ObjectProphecy */
+    private $container;
+    /** @var ObjectProphecy */
+    private $em;
+
+    public function setUp(): void
+    {
+        $this->container = $this->prophesize(ContainerInterface::class);
+        $this->em = $this->prophesize(EntityManagerInterface::class);
+        $this->container->get(EntityManager::class)->willReturn($this->em->reveal());
+
+        $this->factory = new ConnectionFactory();
+    }
+
+    /** @test */
+    public function properServiceFallbackOccursWhenInvoked(): void
+    {
+        $connection = $this->prophesize(Connection::class)->reveal();
+        $getConnection = $this->em->getConnection()->willReturn($connection);
+
+        $result = ($this->factory)($this->container->reveal());
+
+        $this->assertSame($connection, $result);
+        $getConnection->shouldHaveBeenCalledOnce();
+        $this->container->get(EntityManager::class)->shouldHaveBeenCalledOnce();
+    }
+}