diff --git a/appinfo/info.xml b/appinfo/info.xml
index 6520f085..8e0f467e 100644
--- a/appinfo/info.xml
+++ b/appinfo/info.xml
@@ -47,6 +47,7 @@
OCA\Social\Command\CacheRefresh
OCA\Social\Command\NoteCreate
+ OCA\Social\Command\Reset
OCA\Social\Command\QueueStatus
OCA\Social\Command\QueueProcess
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 @@
+
+ * @copyright 2018, Maxence Lange
+ * @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 .
+ *
+ */
+
+
+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(
+ 'Beware, this operation will delete all content from the Social App.'
+ );
+ $output->writeln('');
+ $question = new ConfirmationQuestion(
+ 'Do you confirm this operation? (y/N) ', false, '/^(y|Y)/i'
+ );
+ if (!$helper->ask($input, $output, $question)) {
+ return;
+ }
+
+ $question = new ConfirmationQuestion(
+ 'Operation is destructive. Are you sure about this? (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('done');
+ } catch (Exception $e) {
+ $output->writeln('fail');
+
+ return;
+ }
+
+ $output->writeln('');
+
+ $cloudAddress = $this->configService->getCloudAddress();
+ $question = new Question(
+ 'Now is a good time to change the base address of your cloud: ('
+ . $cloudAddress . ') ',
+ $cloudAddress
+ );
+
+ $newCloudAddress = $helper->ask($input, $output, $question);
+
+ if ($newCloudAddress === $cloudAddress) {
+ return;
+ }
+
+ $this->configService->setCloudAddress($newCloudAddress);
+ $output->writeln('');
+ $output->writeln('New address: ' . $newCloudAddress . '');
+ }
+
+
+}
+
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();
+ }
+ }
+
}