diff options
Diffstat (limited to 'lib/Command')
-rw-r--r-- | lib/Command/Debug/FeedRead.php | 85 | ||||
-rw-r--r-- | lib/Command/Debug/FolderRead.php | 84 | ||||
-rw-r--r-- | lib/Command/Debug/ItemRead.php | 87 |
3 files changed, 256 insertions, 0 deletions
diff --git a/lib/Command/Debug/FeedRead.php b/lib/Command/Debug/FeedRead.php new file mode 100644 index 000000000..eaf7f6b14 --- /dev/null +++ b/lib/Command/Debug/FeedRead.php @@ -0,0 +1,85 @@ +<?php +declare(strict_types=1); + +namespace OCA\News\Command\Debug; + +use OCA\News\Controller\ApiPayloadTrait; +use OCA\News\Db\ListType; +use OCA\News\Service\Exceptions\ServiceConflictException; +use OCA\News\Service\Exceptions\ServiceNotFoundException; +use OCA\News\Service\FeedServiceV2; +use OCA\News\Service\FolderServiceV2; +use OCA\News\Service\ItemServiceV2; +use Symfony\Component\Console\Command\Command; +use Symfony\Component\Console\Input\InputArgument; +use Symfony\Component\Console\Input\InputInterface; +use Symfony\Component\Console\Input\InputOption; +use Symfony\Component\Console\Output\OutputInterface; + +/** + * Class ItemRead + * + * @package OCA\News\Command + */ +class FeedRead extends Command +{ + /** + * @var FeedServiceV2 service for the folders. + */ + protected $feedService; + + /** + * @var ItemServiceV2 service for the items. + */ + protected $itemService; + + public function __construct(FeedServiceV2 $feedService, ItemServiceV2 $itemService) + { + parent::__construct(); + + $this->feedService = $feedService; + $this->itemService = $itemService; + } + + /** + * Configure command + * + * @return void + */ + protected function configure() + { + $this->setName('news:feed:read') + ->setDescription('Read feed') + ->addArgument('user-id', InputArgument::REQUIRED, 'User to modify the feed for') + ->addArgument('id', InputArgument::REQUIRED, 'Feed ID'); + } + + /** + * Execute command + * + * @param InputInterface $input + * @param OutputInterface $output + * + * @return int|void + */ + protected function execute(InputInterface $input, OutputInterface $output) + { + $user = $input->getArgument('user-id'); + + $id = $input->getArgument('id'); + if (!is_numeric($id)) { + $output->writeln('Invalid id!'); + return 255; + } + + try { + $read = $this->feedService->read($user, intval($id)); + $output->writeln("Marked $read items as read", $output::VERBOSITY_VERBOSE); + } catch (ServiceConflictException | ServiceNotFoundException $e) { + $output->writeln('Failed: ' . $e->getMessage()); + return 0; + } + + return 0; + } +} diff --git a/lib/Command/Debug/FolderRead.php b/lib/Command/Debug/FolderRead.php new file mode 100644 index 000000000..a259aceb6 --- /dev/null +++ b/lib/Command/Debug/FolderRead.php @@ -0,0 +1,84 @@ +<?php +declare(strict_types=1); + +namespace OCA\News\Command\Debug; + +use OCA\News\Controller\ApiPayloadTrait; +use OCA\News\Db\ListType; +use OCA\News\Service\Exceptions\ServiceConflictException; +use OCA\News\Service\Exceptions\ServiceNotFoundException; +use OCA\News\Service\FolderServiceV2; +use OCA\News\Service\ItemServiceV2; +use Symfony\Component\Console\Command\Command; +use Symfony\Component\Console\Input\InputArgument; +use Symfony\Component\Console\Input\InputInterface; +use Symfony\Component\Console\Input\InputOption; +use Symfony\Component\Console\Output\OutputInterface; + +/** + * Class ItemRead + * + * @package OCA\News\Command + */ +class FolderRead extends Command +{ + /** + * @var FolderServiceV2 service for the folders. + */ + protected $folderService; + + /** + * @var ItemServiceV2 service for the items. + */ + protected $itemService; + + public function __construct(FolderServiceV2 $folderService, ItemServiceV2 $itemService) + { + parent::__construct(); + + $this->folderService = $folderService; + $this->itemService = $itemService; + } + + /** + * Configure command + * + * @return void + */ + protected function configure() + { + $this->setName('news:folder:read') + ->setDescription('Read folder') + ->addArgument('user-id', InputArgument::REQUIRED, 'User to modify the folder for') + ->addArgument('id', InputArgument::REQUIRED, 'Folder ID'); + } + + /** + * Execute command + * + * @param InputInterface $input + * @param OutputInterface $output + * + * @return int|void + */ + protected function execute(InputInterface $input, OutputInterface $output) + { + $user = $input->getArgument('user-id'); + + $id = $input->getArgument('id'); + if (!is_numeric($id)) { + $output->writeln('Invalid id!'); + return 255; + } + + try { + $read = $this->folderService->read($user, intval($id)); + $output->writeln("Marked $read items as read", $output::VERBOSITY_VERBOSE); + } catch (ServiceConflictException | ServiceNotFoundException $e) { + $output->writeln('Failed: ' . $e->getMessage()); + return 0; + } + + return 0; + } +} diff --git a/lib/Command/Debug/ItemRead.php b/lib/Command/Debug/ItemRead.php new file mode 100644 index 000000000..a36efe3ec --- /dev/null +++ b/lib/Command/Debug/ItemRead.php @@ -0,0 +1,87 @@ +<?php +declare(strict_types=1); + +namespace OCA\News\Command\Debug; + +use OCA\News\Controller\ApiPayloadTrait; +use OCA\News\Db\ListType; +use OCA\News\Service\Exceptions\ServiceConflictException; +use OCA\News\Service\Exceptions\ServiceNotFoundException; +use OCA\News\Service\ItemServiceV2; +use Symfony\Component\Console\Command\Command; +use Symfony\Component\Console\Input\InputArgument; +use Symfony\Component\Console\Input\InputInterface; +use Symfony\Component\Console\Input\InputOption; +use Symfony\Component\Console\Output\OutputInterface; + +/** + * Class ItemRead + * + * @package OCA\News\Command + */ +class ItemRead extends Command +{ + use ApiPayloadTrait; + + /** + * @var ItemServiceV2 service for the items. + */ + protected $itemService; + + public function __construct(ItemServiceV2 $itemService) + { + parent::__construct(); + + $this->itemService = $itemService; + } + + /** + * Configure command + * + * @return void + */ + protected function configure() + { + $this->setName('news:item:read') + ->setDescription('Read item') + ->addArgument('user-id', InputArgument::REQUIRED, 'User to modify the item for') + ->addOption('id', 'i', InputOption::VALUE_REQUIRED, 'Item ID') + ->addOption('read', 'r', InputOption::VALUE_NONE, 'Item read state'); + } + + /** + * Execute command + * + * @param InputInterface $input + * @param OutputInterface $output + * + * @return int|void + */ + protected function execute(InputInterface $input, OutputInterface $output) + { + $user = $input->getArgument('user-id'); + $read = $input->getOption('read'); + + $id = $input->getOption('id'); + if (!is_null($id) && !is_numeric($id)) { + $output->writeln('Invalid id!'); + return 255; + } + + + try { + if (is_null($id)) { + $readItems = $this->itemService->readAll($user, $this->itemService->newest($user)->getId()); + $output->writeln("Marked $readItems items as read", $output::VERBOSITY_VERBOSE); + } else { + $items = $this->itemService->read($user, intval($id), $read); + $output->writeln(json_encode($this->serialize($items), JSON_PRETTY_PRINT)); + } + } catch (ServiceConflictException | ServiceNotFoundException $e) { + $output->writeln('Failed: ' . $e->getMessage()); + return 1; + } + + return 0; + } +} |