* @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\Service\ActivityPub\DocumentService; use OCA\Social\Service\ActivityPub\PersonService; use OCA\Social\Service\ActorService; use OCA\Social\Service\ConfigService; use OCA\Social\Service\MiscService; use Symfony\Component\Console\Input\InputInterface; use Symfony\Component\Console\Output\OutputInterface; class CacheRefresh extends Base { /** @var ActorService */ private $actorService; /** @var PersonService */ private $personService; /** @var DocumentService */ private $documentService; /** @var ConfigService */ private $configService; /** @var MiscService */ private $miscService; /** * CacheUpdate constructor. * * @param ActorService $actorService * @param PersonService $personService * @param DocumentService $documentService * @param ConfigService $configService * @param MiscService $miscService */ public function __construct( ActorService $actorService, PersonService $personService, DocumentService $documentService, ConfigService $configService, MiscService $miscService ) { parent::__construct(); $this->actorService = $actorService; $this->personService = $personService; $this->documentService = $documentService; $this->configService = $configService; $this->miscService = $miscService; } /** * */ protected function configure() { parent::configure(); $this->setName('social:cache:refresh') ->setDescription('Update the cache'); } /** * @param InputInterface $input * @param OutputInterface $output * * @throws Exception */ protected function execute(InputInterface $input, OutputInterface $output) { $result = $this->actorService->manageCacheLocalActors(); $output->writeLn($result . ' local accounts regenerated'); $result = $this->personService->missingCacheRemoteActors(); $output->writeLn($result . ' remote accounts created'); $result = $this->personService->manageCacheRemoteActors(); $output->writeLn($result . ' remote accounts updated'); $result = $this->documentService->manageCacheDocuments(); $output->writeLn($result . ' documents cached'); } }