diff --git a/core/Command/Upgrade.php b/core/Command/Upgrade.php
index 1001962c6a..d61acf0451 100644
--- a/core/Command/Upgrade.php
+++ b/core/Command/Upgrade.php
@@ -162,8 +162,59 @@ class Upgrade extends Command {
}
}
};
+ $repairListener = function($event) use ($progress, $output) {
+ if (!$event instanceof GenericEvent) {
+ return;
+ }
+ switch ($event->getSubject()) {
+ case '\OC\Repair::startProgress':
+ $progress->setMessage('Starting ...');
+ $output->writeln($event->getArgument(1));
+ $output->writeln('');
+ $progress->start($event->getArgument(0));
+ break;
+ case '\OC\Repair::advance':
+ $desc = $event->getArgument(1);
+ if (!empty($desc)) {
+ $progress->setMessage($desc);
+ }
+ $progress->advance($event->getArgument(0));
+
+ break;
+ case '\OC\Repair::finishProgress':
+ $progress->setMessage('Done');
+ $progress->finish();
+ $output->writeln('');
+ break;
+ case '\OC\Repair::step':
+ if(OutputInterface::VERBOSITY_NORMAL < $output->getVerbosity()) {
+ $output->writeln('Repair step: ' . $event->getArgument(0) . '');
+ }
+ break;
+ case '\OC\Repair::info':
+ if(OutputInterface::VERBOSITY_NORMAL < $output->getVerbosity()) {
+ $output->writeln('Repair info: ' . $event->getArgument(0) . '');
+ }
+ break;
+ case '\OC\Repair::warning':
+ $output->writeln('Repair warning: ' . $event->getArgument(0) . '');
+ break;
+ case '\OC\Repair::error':
+ $output->writeln('Repair error: ' . $event->getArgument(0) . '');
+ break;
+ }
+ };
+
$dispatcher->addListener('\OC\DB\Migrator::executeSql', $listener);
$dispatcher->addListener('\OC\DB\Migrator::checkTable', $listener);
+ $dispatcher->addListener('\OC\Repair::startProgress', $repairListener);
+ $dispatcher->addListener('\OC\Repair::advance', $repairListener);
+ $dispatcher->addListener('\OC\Repair::finishProgress', $repairListener);
+ $dispatcher->addListener('\OC\Repair::step', $repairListener);
+ $dispatcher->addListener('\OC\Repair::info', $repairListener);
+ $dispatcher->addListener('\OC\Repair::warning', $repairListener);
+ $dispatcher->addListener('\OC\Repair::error', $repairListener);
+
$updater->listen('\OC\Updater', 'maintenanceEnabled', function () use($output) {
$output->writeln('Turned on maintenance mode');
@@ -205,12 +256,6 @@ class Upgrade extends Command {
$updater->listen('\OC\Updater', 'upgradeAppStoreApp', function ($app) use($output) {
$output->writeln('Update 3rd-party app: ' . $app . '');
});
- $updater->listen('\OC\Updater', 'repairWarning', function ($app) use($output) {
- $output->writeln('Repair warning: ' . $app . '');
- });
- $updater->listen('\OC\Updater', 'repairError', function ($app) use($output) {
- $output->writeln('Repair error: ' . $app . '');
- });
$updater->listen('\OC\Updater', 'appUpgradeCheckBefore', function () use ($output) {
$output->writeln('Checking updates of apps');
});
@@ -242,15 +287,6 @@ class Upgrade extends Command {
$output->writeln("Finished code integrity check");
});
- if(OutputInterface::VERBOSITY_NORMAL < $output->getVerbosity()) {
- $updater->listen('\OC\Updater', 'repairInfo', function ($message) use($output) {
- $output->writeln('Repair info: ' . $message . '');
- });
- $updater->listen('\OC\Updater', 'repairStep', function ($message) use($output) {
- $output->writeln('Repair step: ' . $message . '');
- });
- }
-
$success = $updater->upgrade();
$this->postUpgradeCheck($input, $output);