diff options
| -rw-r--r-- | appinfo/info.xml | 1 | ||||
| -rw-r--r-- | lib/Command/Scan.php | 107 |
2 files changed, 108 insertions, 0 deletions
diff --git a/appinfo/info.xml b/appinfo/info.xml index 939ca086..87f84206 100644 --- a/appinfo/info.xml +++ b/appinfo/info.xml @@ -40,6 +40,7 @@ Note: encrypting the contents of group folders is currently not supported.]]></d <command>OCA\GroupFolders\Command\Create</command> <command>OCA\GroupFolders\Command\Rename</command> <command>OCA\GroupFolders\Command\Delete</command> + <command>OCA\GroupFolders\Command\Scan</command> </commands> <background-jobs> diff --git a/lib/Command/Scan.php b/lib/Command/Scan.php new file mode 100644 index 00000000..05c94b4c --- /dev/null +++ b/lib/Command/Scan.php @@ -0,0 +1,107 @@ +<?php declare(strict_types=1); +/** + * @copyright Copyright (c) 2018 Robin Appelman <robin@icewind.nl> + * + * @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\GroupFolders\Command; + +use OC\Core\Command\Base; +use OCA\GroupFolders\Folder\FolderManager; +use OCA\GroupFolders\Mount\MountProvider; +use OCP\Files\IRootFolder; +use Symfony\Component\Console\Helper\Table; +use Symfony\Component\Console\Input\InputArgument; +use Symfony\Component\Console\Input\InputInterface; +use Symfony\Component\Console\Output\OutputInterface; + +class Scan extends Base { + private $folderManager; + private $rootFolder; + private $mountProvider; + private $foldersCounter = 0; + private $filesCounter = 0; + + public function __construct(FolderManager $folderManager, IRootFolder $rootFolder, MountProvider $mountProvider) { + parent::__construct(); + $this->folderManager = $folderManager; + $this->rootFolder = $rootFolder; + $this->mountProvider = $mountProvider; + } + + protected function configure() { + $this + ->setName('groupfolders:scan') + ->setDescription('Scan a group folder for outside changes') + ->addArgument('folder_id', InputArgument::REQUIRED, 'Id of the folder to configure'); + parent::configure(); + } + + protected function execute(InputInterface $input, OutputInterface $output) { + $folderId = $input->getArgument('folder_id'); + $folder = $this->folderManager->getFolder($folderId, $this->rootFolder->getMountPoint()->getNumericStorageId()); + if ($folder) { + $mount = $this->mountProvider->getMount($folder['id'], '/' . $folder['mount_point'], $folder['permissions'], $folder['quota']); + $scanner = $mount->getStorage()->getScanner(); + + $scanner->listen('\OC\Files\Cache\Scanner', 'scanFile', function ($path) use ($output) { + $output->writeln("\tFile\t<info>$path</info>", OutputInterface::VERBOSITY_VERBOSE); + ++$this->filesCounter; + $this->abortIfInterrupted(); + }); + + $scanner->listen('\OC\Files\Cache\Scanner', 'scanFolder', function ($path) use ($output) { + $output->writeln("\tFolder\t<info>$path</info>", OutputInterface::VERBOSITY_VERBOSE); + ++$this->foldersCounter; + $this->abortIfInterrupted(); + }); + + $start = microtime(true); + + $scanner->setUseTransactions(false); + $scanner->scan(''); + + $end = microtime(true); + + $headers = [ + 'Folders', 'Files', 'Elapsed time' + ]; + + $this->showSummary($headers, null, $output, $end - $start); + } else { + $output->writeln('<error>Folder not found: ' . $folderId . '</error>'); + return -1; + } + } + + protected function showSummary($headers, $rows, OutputInterface $output, float $duration) { + $niceDate = date('H:i:s', (int)$duration); + if (!$rows) { + $rows = [ + $this->foldersCounter, + $this->filesCounter, + $niceDate, + ]; + } + $table = new Table($output); + $table + ->setHeaders($headers) + ->setRows([$rows]); + $table->render(); + } +} |