diff options
author | Robin Appelman <robin@icewind.nl> | 2018-06-28 16:09:25 +0200 |
---|---|---|
committer | Robin Appelman <robin@icewind.nl> | 2018-06-28 16:09:25 +0200 |
commit | b9e685236f7933e6b83bcbe6738ca764a6bfd820 (patch) | |
tree | bfdd0bb25c1bd8ba2ec4c0c7c866e5938a725355 | |
parent | 388ea2234f96be1fc774d4dc02b71e7d67d31910 (diff) | |
download | nextcloud-server-b9e685236f7933e6b83bcbe6738ca764a6bfd820.tar.gz nextcloud-server-b9e685236f7933e6b83bcbe6738ca764a6bfd820.zip |
Add option to only scan the home storage
Signed-off-by: Robin Appelman <robin@icewind.nl>
-rw-r--r-- | apps/files/lib/Command/Scan.php | 16 | ||||
-rw-r--r-- | lib/private/Files/Utils/Scanner.php | 11 |
2 files changed, 21 insertions, 6 deletions
diff --git a/apps/files/lib/Command/Scan.php b/apps/files/lib/Command/Scan.php index fed7eb25653..36fa39e043d 100644 --- a/apps/files/lib/Command/Scan.php +++ b/apps/files/lib/Command/Scan.php @@ -32,6 +32,7 @@ use Doctrine\DBAL\Connection; use OC\Core\Command\Base; use OC\Core\Command\InterruptedException; use OC\ForbiddenException; +use OCP\Files\Mount\IMountPoint; use OCP\Files\NotFoundException; use OCP\Files\StorageNotAvailableException; use OCP\IDBConnection; @@ -102,6 +103,11 @@ class Scan extends Base { null, InputOption::VALUE_NONE, 'do not scan folders recursively' + )->addOption( + 'home-only', + null, + InputOption::VALUE_NONE, + 'only scan the home storage, ignoring any mounted external storage or share' ); } @@ -114,7 +120,7 @@ class Scan extends Base { } } - protected function scanFiles($user, $path, $verbose, OutputInterface $output, $backgroundScan = false, $recursive = true) { + protected function scanFiles($user, $path, $verbose, OutputInterface $output, $backgroundScan = false, $recursive = true, $homeOnly = false) { $connection = $this->reconnectToDatabase($output); $scanner = new \OC\Files\Utils\Scanner($user, $connection, \OC::$server->getLogger()); # check on each file/folder if there was a user interrupt (ctrl-c) and throw an exception @@ -163,7 +169,7 @@ class Scan extends Base { if ($backgroundScan) { $scanner->backgroundScan($path); } else { - $scanner->scan($path, $recursive); + $scanner->scan($path, $recursive, $homeOnly ? [$this, 'filterHomeMount'] : null); } } catch (ForbiddenException $e) { $output->writeln("<error>Home storage for user $user not writable</error>"); @@ -179,6 +185,10 @@ class Scan extends Base { } } + public function filterHomeMount(IMountPoint $mountPoint) { + // any mountpoint inside '/$user/files/' + return substr_count($mountPoint->getMountPoint(), '/') <= 3; + } protected function execute(InputInterface $input, OutputInterface $output) { $inputPath = $input->getOption('path'); @@ -236,7 +246,7 @@ class Scan extends Base { } $output->writeln("Starting scan for user $user_count out of $users_total ($user)"); # full: printout data if $verbose was set - $this->scanFiles($user, $path, $verbose, $output, $input->getOption('unscanned'), ! $input->getOption('shallow')); + $this->scanFiles($user, $path, $verbose, $output, $input->getOption('unscanned'), ! $input->getOption('shallow'), $input->getOption('home-only')); } else { $output->writeln("<error>Unknown user $user_count $user</error>"); } diff --git a/lib/private/Files/Utils/Scanner.php b/lib/private/Files/Utils/Scanner.php index f91696e77bb..fe2bf4ccb58 100644 --- a/lib/private/Files/Utils/Scanner.php +++ b/lib/private/Files/Utils/Scanner.php @@ -182,15 +182,20 @@ class Scanner extends PublicEmitter { /** * @param string $dir - * @throws \OC\ForbiddenException - * @throws \OCP\Files\NotFoundException + * @param $recursive + * @param callable|null $mountFilter + * @throws ForbiddenException + * @throws NotFoundException */ - public function scan($dir = '', $recursive = \OC\Files\Cache\Scanner::SCAN_RECURSIVE) { + public function scan($dir = '', $recursive = \OC\Files\Cache\Scanner::SCAN_RECURSIVE, callable $mountFilter = null) { if (!Filesystem::isValidPath($dir)) { throw new \InvalidArgumentException('Invalid path to scan'); } $mounts = $this->getMounts($dir); foreach ($mounts as $mount) { + if ($mountFilter && !$mountFilter($mount)) { + continue; + } $storage = $mount->getStorage(); if (is_null($storage)) { continue; |