diff options
author | Maxence Lange <maxence@artificial-owl.com> | 2018-12-20 12:20:52 -0100 |
---|---|---|
committer | Maxence Lange <maxence@artificial-owl.com> | 2018-12-20 12:20:52 -0100 |
commit | 87629329f4e655c0a88941294fa3220bf5eb933c (patch) | |
tree | 7461bb2d3723fefeb17a6d20d0dcefafe633b6f1 /lib | |
parent | 596e7371798d4cd02eb50d07ccae44c00778522f (diff) |
./occ social:reset
Signed-off-by: Maxence Lange <maxence@artificial-owl.com>
Diffstat (limited to 'lib')
-rw-r--r-- | lib/Command/Reset.php | 147 | ||||
-rw-r--r-- | lib/Db/CoreRequestBuilder.php | 22 |
2 files changed, 169 insertions, 0 deletions
diff --git a/lib/Command/Reset.php b/lib/Command/Reset.php new file mode 100644 index 00000000..d3f9e459 --- /dev/null +++ b/lib/Command/Reset.php @@ -0,0 +1,147 @@ +<?php +declare(strict_types=1); + + +/** + * Nextcloud - Social Support + * + * This file is licensed under the Affero General Public License version 3 or + * later. See the COPYING file. + * + * @author Maxence Lange <maxence@artificial-owl.com> + * @copyright 2018, Maxence Lange <maxence@artificial-owl.com> + * @license GNU AGPL version 3 or any later version + * + * This program is free software: you can redistribute it and/or modify + * it under the terms of the GNU Affero General Public License as + * published by the Free Software Foundation, either version 3 of the + * License, or (at your option) any later version. + * + * This program is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + * GNU Affero General Public License for more details. + * + * You should have received a copy of the GNU Affero General Public License + * along with this program. If not, see <http://www.gnu.org/licenses/>. + * + */ + + +namespace OCA\Social\Command; + + +use Exception; +use OC\Core\Command\Base; +use OCA\Social\Db\CoreRequestBuilder; +use OCA\Social\Service\ConfigService; +use OCA\Social\Service\MiscService; +use Symfony\Component\Console\Input\InputInterface; +use Symfony\Component\Console\Output\OutputInterface; +use Symfony\Component\Console\Question\ConfirmationQuestion; +use Symfony\Component\Console\Question\Question; + + +class Reset extends Base { + + + private $coreRequestBuilder; + + /** @var ConfigService */ + private $configService; + + /** @var MiscService */ + private $miscService; + + + /** + * CacheUpdate constructor. + * + * @param CoreRequestBuilder $coreRequestBuilder + * @param ConfigService $configService + * @param MiscService $miscService + */ + public function __construct( + CoreRequestBuilder $coreRequestBuilder, ConfigService $configService, + MiscService $miscService + ) { + parent::__construct(); + + $this->coreRequestBuilder = $coreRequestBuilder; + $this->configService = $configService; + $this->miscService = $miscService; + } + + + /** + * + */ + protected function configure() { + parent::configure(); + $this->setName('social:reset') + ->setDescription('Reset ALL data related to the Social App'); + } + + + /** + * @param InputInterface $input + * @param OutputInterface $output + * + * @throws Exception + */ + protected function execute(InputInterface $input, OutputInterface $output) { + + $helper = $this->getHelper('question'); + $output->writeln( + '<error>Beware, this operation will delete all content from the Social App.</error>' + ); + $output->writeln(''); + $question = new ConfirmationQuestion( + '<info>Do you confirm this operation?</info> (y/N) ', false, '/^(y|Y)/i' + ); + if (!$helper->ask($input, $output, $question)) { + return; + } + + $question = new ConfirmationQuestion( + '<info>Operation is destructive. Are you sure about this?</info> (y/N) ', false, + '/^(y|Y)/i' + ); + if (!$helper->ask($input, $output, $question)) { + return; + } + + $output->writeln(''); + $output->write('flushing data... '); + try { + $this->coreRequestBuilder->emptyAll(); + $output->writeln('<info>done</info>'); + } catch (Exception $e) { + $output->writeln('<error>fail</error>'); + + return; + } + + $output->writeln(''); + + $cloudAddress = $this->configService->getCloudAddress(); + $question = new Question( + '<info>Now is a good time to change the base address of your cloud: </info> (' + . $cloudAddress . ') ', + $cloudAddress + ); + + $newCloudAddress = $helper->ask($input, $output, $question); + + if ($newCloudAddress === $cloudAddress) { + return; + } + + $this->configService->setCloudAddress($newCloudAddress); + $output->writeln(''); + $output->writeln('New address: <info>' . $newCloudAddress . '</info>'); + } + + +} + diff --git a/lib/Db/CoreRequestBuilder.php b/lib/Db/CoreRequestBuilder.php index 1e96b620..15d20119 100644 --- a/lib/Db/CoreRequestBuilder.php +++ b/lib/Db/CoreRequestBuilder.php @@ -776,5 +776,27 @@ class CoreRequestBuilder { } } + + /** + * this just empty all tables from the app. + */ + public function emptyAll() { + $tables = [ + self::TABLE_REQUEST_QUEUE, + self::TABLE_SERVER_ACTORS, + self::TABLE_SERVER_NOTES, + self::TABLE_SERVER_FOLLOWS, + self::TABLE_CACHE_ACTORS, + self::TABLE_CACHE_DOCUMENTS + ]; + + foreach ($tables as $table) { + $qb = $this->dbConnection->getQueryBuilder(); + $qb->delete($table); + + $qb->execute(); + } + } + } |