src/Wallabag/CoreBundle/Command/InstallCommand.php

   1 <?php
   2
   3 namespace Wallabag\CoreBundle\Command;
   4
   5 use Symfony\Bundle\FrameworkBundle\Command\ContainerAwareCommand;
   6 use Symfony\Component\Console\Helper\Table;
   7 use Symfony\Component\Console\Input\ArrayInput;
   8 use Symfony\Component\Console\Input\InputInterface;
   9 use Symfony\Component\Console\Input\InputOption;
  10 use Symfony\Component\Console\Output\NullOutput;
  11 use Symfony\Component\Console\Output\OutputInterface;
  12 use Symfony\Component\Console\Question\ConfirmationQuestion;
  13 use Symfony\Component\Console\Question\Question;
  14 use Wallabag\CoreBundle\Entity\Config;
  15
  16 class InstallCommand extends ContainerAwareCommand
  17 {
  18     /**
  19      * @var InputInterface
  20      */
  21     protected $defaultInput;
  22
  23     /**
  24      * @var OutputInterface
  25      */
  26     protected $defaultOutput;
  27
  28     protected function configure()
  29     {
  30         $this
  31             ->setName('wallabag:install')
  32             ->setDescription('Wallabag installer.')
  33             ->addOption(
  34                'reset',
  35                null,
  36                InputOption::VALUE_NONE,
  37                'Reset current database'
  38             )
  39         ;
  40     }
  41
  42     protected function execute(InputInterface $input, OutputInterface $output)
  43     {
  44         $this->defaultInput = $input;
  45         $this->defaultOutput = $output;
  46
  47         $output->writeln('<info>Installing Wallabag...</info>');
  48         $output->writeln('');
  49
  50         $this
  51             ->checkRequirements()
  52             ->setupDatabase()
  53             ->setupAdmin()
  54             ->setupAsset()
  55         ;
  56
  57         $output->writeln('<info>Wallabag has been successfully installed.</info>');
  58         $output->writeln('<comment>Just execute `php bin/console server:run` for using wallabag: http://localhost:8000</comment>');
  59     }
  60
  61     protected function checkRequirements()
  62     {
  63         $this->defaultOutput->writeln('<info><comment>Step 1 of 4.</comment> Checking system requirements.</info>');
  64
  65         $fulfilled = true;
  66
  67         $label = '<comment>PCRE</comment>';
  68         if (extension_loaded('pcre')) {
  69             $status = '<info>OK!</info>';
  70             $help = '';
  71         } else {
  72             $fulfilled = false;
  73             $status = '<error>ERROR!</error>';
  74             $help = 'You should enabled PCRE extension';
  75         }
  76         $rows[] = array($label, $status, $help);
  77
  78         $label = '<comment>DOM</comment>';
  79         if (extension_loaded('DOM')) {
  80             $status = '<info>OK!</info>';
  81             $help = '';
  82         } else {
  83             $fulfilled = false;
  84             $status = '<error>ERROR!</error>';
  85             $help = 'You should enabled DOM extension';
  86         }
  87         $rows[] = array($label, $status, $help);
  88
  89         $table = new Table($this->defaultOutput);
  90         $table
  91             ->setHeaders(array('Checked', 'Status', 'Recommendation'))
  92             ->setRows($rows)
  93             ->render();
  94
  95         if (!$fulfilled) {
  96             throw new \RuntimeException('Some system requirements are not fulfilled. Please check output messages and fix them.');
  97         }
  98
  99         $this->defaultOutput->writeln('<info>Success! Your system can run Wallabag properly.</info>');
 100
 101         $this->defaultOutput->writeln('');
 102
 103         return $this;
 104     }
 105
 106     protected function setupDatabase()
 107     {
 108         $this->defaultOutput->writeln('<info><comment>Step 2 of 4.</comment> Setting up database.</info>');
 109
 110         // user want to reset everything? Don't care about what is already here
 111         if (true === $this->defaultInput->getOption('reset')) {
 112             $this->defaultOutput->writeln('Droping database, creating database and schema, clearing the cache');
 113
 114             $this
 115                 ->runCommand('doctrine:database:drop', array('--force' => true))
 116                 ->runCommand('doctrine:database:create')
 117                 ->runCommand('doctrine:schema:create')
 118                 ->runCommand('cache:clear')
 119             ;
 120
 121             $this->defaultOutput->writeln('');
 122
 123             return $this;
 124         }
 125
 126         if (!$this->isDatabasePresent()) {
 127             $this->defaultOutput->writeln('Creating database and schema, clearing the cache');
 128
 129             $this
 130                 ->runCommand('doctrine:database:create')
 131                 ->runCommand('doctrine:schema:create')
 132                 ->runCommand('cache:clear')
 133             ;
 134
 135             $this->defaultOutput->writeln('');
 136
 137             return $this;
 138         }
 139
 140         $questionHelper = $this->getHelper('question');
 141         $question = new ConfirmationQuestion('It appears that your database already exists. Would you like to reset it? (y/N)', false);
 142
 143         if ($questionHelper->ask($this->defaultInput, $this->defaultOutput, $question)) {
 144             $this->defaultOutput->writeln('Droping database, creating database and schema');
 145
 146             $this
 147                 ->runCommand('doctrine:database:drop', array('--force' => true))
 148                 ->runCommand('doctrine:database:create')
 149                 ->runCommand('doctrine:schema:create')
 150             ;
 151         } elseif ($this->isSchemaPresent()) {
 152             $question = new ConfirmationQuestion('Seems like your database contains schema. Do you want to reset it? (y/N)', false);
 153             if ($questionHelper->ask($this->defaultInput, $this->defaultOutput, $question)) {
 154                 $this->defaultOutput->writeln('Droping schema and creating schema');
 155
 156                 $this
 157                     ->runCommand('doctrine:schema:drop', array('--force' => true))
 158                     ->runCommand('doctrine:schema:create')
 159                 ;
 160             }
 161         } else {
 162             $this->defaultOutput->writeln('Creating schema');
 163
 164             $this
 165                 ->runCommand('doctrine:schema:create')
 166             ;
 167         }
 168
 169         $this->defaultOutput->writeln('Clearing the cache');
 170         $this->runCommand('cache:clear');
 171
 172         $this->defaultOutput->writeln('');
 173
 174         return $this;
 175     }
 176
 177     protected function setupAdmin()
 178     {
 179         $this->defaultOutput->writeln('<info><comment>Step 3 of 4.</comment> Administration setup.</info>');
 180
 181         $questionHelper = $this->getHelperSet()->get('question');
 182         $question = new ConfirmationQuestion('Would you like to create a new user ? (y/N)', false);
 183
 184         if (!$questionHelper->ask($this->defaultInput, $this->defaultOutput, $question)) {
 185             return $this;
 186         }
 187
 188         $em = $this->getContainer()->get('doctrine.orm.entity_manager');
 189
 190         $userManager = $this->getContainer()->get('fos_user.user_manager');
 191         $user = $userManager->createUser();
 192
 193         $question = new Question('Username (default: wallabag) :', 'wallabag');
 194         $user->setUsername($questionHelper->ask($this->defaultInput, $this->defaultOutput, $question));
 195
 196         $question = new Question('Password (default: wallabag) :', 'wallabag');
 197         $user->setPlainPassword($questionHelper->ask($this->defaultInput, $this->defaultOutput, $question));
 198
 199         $question = new Question('Email:', '');
 200         $user->setEmail($questionHelper->ask($this->defaultInput, $this->defaultOutput, $question));
 201
 202         $user->setEnabled(true);
 203
 204         $em->persist($user);
 205
 206         $config = new Config($user);
 207         $config->setTheme($this->getContainer()->getParameter('theme'));
 208         $config->setItemsPerPage($this->getContainer()->getParameter('items_on_page'));
 209         $config->setRssLimit($this->getContainer()->getParameter('rss_limit'));
 210         $config->setLanguage($this->getContainer()->getParameter('language'));
 211
 212         $em->persist($config);
 213
 214         $em->flush();
 215
 216         $this->defaultOutput->writeln('');
 217
 218         return $this;
 219     }
 220
 221     protected function setupAsset()
 222     {
 223         $this->defaultOutput->writeln('<info><comment>Step 4 of 4.</comment> Installing assets.</info>');
 224
 225         $this
 226             ->runCommand('assets:install')
 227             ->runCommand('assetic:dump')
 228         ;
 229
 230         $this->defaultOutput->writeln('');
 231
 232         return $this;
 233     }
 234
 235     /**
 236      * Run a command.
 237      *
 238      * @param string $command
 239      * @param array  $parameters Parameters to this command (usually 'force' => true)
 240      */
 241     protected function runCommand($command, $parameters = array())
 242     {
 243         $parameters = array_merge(
 244             array('command' => $command),
 245             $parameters,
 246             array(
 247                 '--no-debug' => true,
 248                 '--env' => $this->defaultInput->getOption('env') ?: 'dev',
 249             )
 250         );
 251
 252         if ($this->defaultInput->getOption('no-interaction')) {
 253             $parameters = array_merge($parameters, array('--no-interaction' => true));
 254         }
 255
 256         $this->getApplication()->setAutoExit(false);
 257         $exitCode = $this->getApplication()->run(new ArrayInput($parameters), new NullOutput());
 258
 259         if (0 !== $exitCode) {
 260             $this->getApplication()->setAutoExit(true);
 261
 262             $errorMessage = sprintf('The command "%s" terminated with an error code: %u.', $command, $exitCode);
 263             $this->defaultOutput->writeln("<error>$errorMessage</error>");
 264             $exception = new \Exception($errorMessage, $exitCode);
 265
 266             throw $exception;
 267         }
 268
 269         // PDO does not always close the connection after Doctrine commands.
 270         // See https://github.com/symfony/symfony/issues/11750.
 271         $this->getContainer()->get('doctrine')->getManager()->getConnection()->close();
 272
 273         return $this;
 274     }
 275
 276     /**
 277      * Check if the database already exists.
 278      *
 279      * @return bool
 280      */
 281     private function isDatabasePresent()
 282     {
 283         $connection = $this->getContainer()->get('doctrine')->getManager()->getConnection();
 284         $databaseName = $connection->getDatabase();
 285
 286         try {
 287             $schemaManager = $connection->getSchemaManager();
 288         } catch (\Exception $exception) {
 289             // mysql & sqlite
 290             if (false !== strpos($exception->getMessage(), sprintf("Unknown database '%s'", $databaseName))) {
 291                 return false;
 292             }
 293
 294             // pgsql
 295             if (false !== strpos($exception->getMessage(), sprintf('database "%s" does not exist', $databaseName))) {
 296                 return false;
 297             }
 298
 299             throw $exception;
 300         }
 301
 302         // custom verification for sqlite, since `getListDatabasesSQL` doesn't work for sqlite
 303         if ('sqlite' == $schemaManager->getDatabasePlatform()->getName()) {
 304             $params = $this->getContainer()->get('doctrine.dbal.default_connection')->getParams();
 305
 306             if (isset($params['path']) && file_exists($params['path'])) {
 307                 return true;
 308             }
 309
 310             return false;
 311         }
 312
 313         return in_array($databaseName, $schemaManager->listDatabases());
 314     }
 315
 316     /**
 317      * Check if the schema is already created.
 318      * If we found at least oen table, it means the schema exists.
 319      *
 320      * @return bool
 321      */
 322     private function isSchemaPresent()
 323     {
 324         $schemaManager = $this->getContainer()->get('doctrine')->getManager()->getConnection()->getSchemaManager();
 325
 326         return count($schemaManager->listTableNames()) > 0 ? true : false;
 327     }
 328 }