diff options
author | David Baucum <david@baucum.me> | 2021-06-01 23:51:34 -0400 |
---|---|---|
committer | Benjamin Brahmer <info@b-brahmer.de> | 2021-07-24 18:17:31 +0200 |
commit | 21203dbf6386e72ef780d0b5d4b81a7e25e94485 (patch) | |
tree | c50e5be017c3a6630b63e37c3292566839dea622 /lib/Command | |
parent | 65c15dac38358d5c3a619379b57bd498c070ea6f (diff) |
Update all feeds from command
Closes #1359
Signed-off-by: David Baucum <david@baucum.me>
Diffstat (limited to 'lib/Command')
-rw-r--r-- | lib/Command/Updater/UpdateUser.php | 70 |
1 files changed, 70 insertions, 0 deletions
diff --git a/lib/Command/Updater/UpdateUser.php b/lib/Command/Updater/UpdateUser.php new file mode 100644 index 000000000..050641972 --- /dev/null +++ b/lib/Command/Updater/UpdateUser.php @@ -0,0 +1,70 @@ +<?php +/** + * Nextcloud - News + * + * This file is licensed under the Affero General Public License version 3 or + * later. See the COPYING file. + */ + +namespace OCA\News\Command\Updater; + +use Exception; +use OCA\News\Service\FeedServiceV2; +use Symfony\Component\Console\Command\Command; +use Symfony\Component\Console\Input\InputArgument; +use Symfony\Component\Console\Input\InputInterface; +use Symfony\Component\Console\Output\OutputInterface; + +class UpdateUser extends Command +{ + /** + * @var FeedServiceV2 Feed service + */ + private $feedService; + + public function __construct(FeedServiceV2 $feedService) + { + parent::__construct(); + $this->feedService = $feedService; + } + + /** + * @return void + */ + protected function configure() + { + $this->setName('news:updater:update-user') + ->addArgument( + 'user-id', + InputArgument::REQUIRED, + 'user id of a user, string' + ) + ->setDescription('Console API for updating a single user\'s feed'); + } + + protected function execute(InputInterface $input, OutputInterface $output): int + { + $userId = $input->getArgument('user-id'); + $feeds = $this->feedService->findAllForUser($userId); + $updateErrors = false; + foreach ($feeds as $feed) { + try { + $updated_feed = $this->feedService->fetch($feed); + if ($updated_feed->getUpdateErrorCount() !== 0) { + $output->writeln($updated_feed->getLastUpdateError()); + $updateErrors = true; + } + } catch (Exception $e) { + $output->writeln( + '<error>Could not update feed with id ' . $feed->getId() . + '. ' . $e->getMessage() . '</error> ' + ); + return 1; + } + } + if ($updateErrors) { + return 255; + } + return 0; + } +} |