nextcloud/lib/private/Files/Utils/Scanner.php

282 lines
8.5 KiB
PHP
Raw Normal View History

2013-07-19 18:44:47 +04:00
<?php
/**
2016-07-21 18:07:57 +03:00
* @copyright Copyright (c) 2016, ownCloud, Inc.
*
2015-03-26 13:44:34 +03:00
* @author Jörn Friedrich Dreyer <jfd@butonic.de>
* @author Morris Jobke <hey@morrisjobke.de>
2015-10-05 21:54:56 +03:00
* @author Olivier Paroz <github@oparoz.com>
2016-07-21 19:13:36 +03:00
* @author Robin Appelman <robin@icewind.nl>
* @author Roeland Jago Douma <roeland@famdouma.nl>
2015-03-26 13:44:34 +03:00
* @author Thomas Müller <thomas.mueller@tmit.eu>
* @author Vincent Petry <pvince81@owncloud.com>
2015-03-26 13:44:34 +03:00
*
* @license AGPL-3.0
*
* This code is free software: you can redistribute it and/or modify
* it under the terms of the GNU Affero General Public License, version 3,
* as published by the Free Software Foundation.
*
* 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, version 3,
* along with this program. If not, see <http://www.gnu.org/licenses/>
*
2013-07-19 18:44:47 +04:00
*/
2013-07-19 18:44:47 +04:00
namespace OC\Files\Utils;
use OC\Files\Cache\Cache;
2013-07-19 18:44:47 +04:00
use OC\Files\Filesystem;
use OC\Files\Storage\FailedStorage;
use OC\ForbiddenException;
use OC\Hooks\PublicEmitter;
use OC\Lock\DBLockingProvider;
use OCA\Files_Sharing\SharedStorage;
use OCP\Files\NotFoundException;
use OCP\Files\Storage\IStorage;
2015-11-27 16:02:50 +03:00
use OCP\Files\StorageNotAvailableException;
use OCP\ILogger;
2013-07-19 18:44:47 +04:00
/**
* Class Scanner
*
* Hooks available in scope \OC\Utils\Scanner
* - scanFile(string $absolutePath)
* - scanFolder(string $absolutePath)
*
* @package OC\Files\Utils
*/
class Scanner extends PublicEmitter {
2017-03-28 20:18:58 +03:00
const MAX_ENTRIES_TO_COMMIT = 10000;
2013-07-19 18:44:47 +04:00
/**
* @var string $user
*/
private $user;
/**
* @var \OCP\IDBConnection
*/
protected $db;
2015-11-27 16:02:50 +03:00
/**
* @var ILogger
*/
protected $logger;
2017-03-28 20:18:58 +03:00
/**
* Whether to use a DB transaction
*
* @var bool
*/
protected $useTransaction;
/**
* Number of entries scanned to commit
*
* @var int
*/
protected $entriesToCommit;
2013-07-19 18:44:47 +04:00
/**
* @param string $user
* @param \OCP\IDBConnection $db
2015-11-27 16:02:50 +03:00
* @param ILogger $logger
2013-07-19 18:44:47 +04:00
*/
2015-11-27 16:02:50 +03:00
public function __construct($user, $db, ILogger $logger) {
$this->logger = $logger;
2013-07-19 18:44:47 +04:00
$this->user = $user;
$this->db = $db;
2017-04-03 12:49:30 +03:00
// when DB locking is used, no DB transactions will be used
2017-03-28 20:18:58 +03:00
$this->useTransaction = !(\OC::$server->getLockingProvider() instanceof DBLockingProvider);
2013-07-19 18:44:47 +04:00
}
/**
* get all storages for $dir
*
* @param string $dir
* @return \OC\Files\Mount\MountPoint[]
2013-07-19 18:44:47 +04:00
*/
protected function getMounts($dir) {
//TODO: move to the node based fileapi once that's done
\OC_Util::tearDownFS();
\OC_Util::setupFS($this->user);
$mountManager = Filesystem::getMountManager();
$mounts = $mountManager->findIn($dir);
$mounts[] = $mountManager->find($dir);
2013-07-19 18:44:47 +04:00
$mounts = array_reverse($mounts); //start with the mount of $dir
return $mounts;
}
/**
* attach listeners to the scanner
*
* @param \OC\Files\Mount\MountPoint $mount
2013-07-19 18:44:47 +04:00
*/
protected function attachListener($mount) {
$scanner = $mount->getStorage()->getScanner();
$emitter = $this;
$scanner->listen('\OC\Files\Cache\Scanner', 'scanFile', function ($path) use ($mount, $emitter) {
$emitter->emit('\OC\Files\Utils\Scanner', 'scanFile', array($mount->getMountPoint() . $path));
2013-07-19 18:44:47 +04:00
});
$scanner->listen('\OC\Files\Cache\Scanner', 'scanFolder', function ($path) use ($mount, $emitter) {
$emitter->emit('\OC\Files\Utils\Scanner', 'scanFolder', array($mount->getMountPoint() . $path));
2013-07-19 18:44:47 +04:00
});
$scanner->listen('\OC\Files\Cache\Scanner', 'postScanFile', function ($path) use ($mount, $emitter) {
$emitter->emit('\OC\Files\Utils\Scanner', 'postScanFile', array($mount->getMountPoint() . $path));
});
$scanner->listen('\OC\Files\Cache\Scanner', 'postScanFolder', function ($path) use ($mount, $emitter) {
$emitter->emit('\OC\Files\Utils\Scanner', 'postScanFolder', array($mount->getMountPoint() . $path));
});
2013-07-19 18:44:47 +04:00
}
/**
* @param string $dir
*/
2013-07-19 18:44:47 +04:00
public function backgroundScan($dir) {
$mounts = $this->getMounts($dir);
foreach ($mounts as $mount) {
$storage = $mount->getStorage();
if (is_null($storage)) {
2013-09-15 22:38:57 +04:00
continue;
}
// don't bother scanning failed storages (shortcut for same result)
if ($storage->instanceOfStorage(FailedStorage::class)) {
continue;
}
// don't scan received local shares, these can be scanned when scanning the owner's storage
if ($storage->instanceOfStorage(SharedStorage::class)) {
continue;
}
$scanner = $storage->getScanner();
2013-07-19 18:44:47 +04:00
$this->attachListener($mount);
$scanner->listen('\OC\Files\Cache\Scanner', 'removeFromCache', function ($path) use ($storage) {
$this->triggerPropagator($storage, $path);
});
$scanner->listen('\OC\Files\Cache\Scanner', 'updateCache', function ($path) use ($storage) {
$this->triggerPropagator($storage, $path);
});
$scanner->listen('\OC\Files\Cache\Scanner', 'addToCache', function ($path) use ($storage) {
$this->triggerPropagator($storage, $path);
});
$propagator = $storage->getPropagator();
$propagator->beginBatch();
2013-07-19 18:44:47 +04:00
$scanner->backgroundScan();
$propagator->commitBatch();
2013-07-19 18:44:47 +04:00
}
}
/**
* @param string $dir
* @param $recursive
* @param callable|null $mountFilter
* @throws ForbiddenException
* @throws NotFoundException
*/
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');
}
2013-07-19 18:44:47 +04:00
$mounts = $this->getMounts($dir);
foreach ($mounts as $mount) {
if ($mountFilter && !$mountFilter($mount)) {
continue;
}
$storage = $mount->getStorage();
if (is_null($storage)) {
2013-09-15 22:38:57 +04:00
continue;
}
// don't bother scanning failed storages (shortcut for same result)
if ($storage->instanceOfStorage(FailedStorage::class)) {
continue;
}
// if the home storage isn't writable then the scanner is run as the wrong user
if ($storage->instanceOfStorage('\OC\Files\Storage\Home') and
(!$storage->isCreatable('') or !$storage->isCreatable('files'))
) {
if ($storage->file_exists('') or $storage->getCache()->inCache('')) {
throw new ForbiddenException();
} else {// if the root exists in neither the cache nor the storage the user isn't setup yet
break;
}
}
// don't scan received local shares, these can be scanned when scanning the owner's storage
if ($storage->instanceOfStorage(SharedStorage::class)) {
continue;
}
2014-12-10 13:04:17 +03:00
$relativePath = $mount->getInternalPath($dir);
$scanner = $storage->getScanner();
2014-09-10 16:47:03 +04:00
$scanner->setUseTransactions(false);
2013-07-19 18:44:47 +04:00
$this->attachListener($mount);
$scanner->listen('\OC\Files\Cache\Scanner', 'removeFromCache', function ($path) use ($storage) {
2017-03-28 20:18:58 +03:00
$this->postProcessEntry($storage, $path);
});
$scanner->listen('\OC\Files\Cache\Scanner', 'updateCache', function ($path) use ($storage) {
2017-03-28 20:18:58 +03:00
$this->postProcessEntry($storage, $path);
});
$scanner->listen('\OC\Files\Cache\Scanner', 'addToCache', function ($path) use ($storage) {
2017-03-28 20:18:58 +03:00
$this->postProcessEntry($storage, $path);
});
if (!$storage->file_exists($relativePath)) {
throw new NotFoundException($dir);
}
2017-03-28 20:18:58 +03:00
if ($this->useTransaction) {
$this->db->beginTransaction();
}
2015-11-27 16:02:50 +03:00
try {
$propagator = $storage->getPropagator();
$propagator->beginBatch();
$scanner->scan($relativePath, $recursive, \OC\Files\Cache\Scanner::REUSE_ETAG | \OC\Files\Cache\Scanner::REUSE_SIZE);
$cache = $storage->getCache();
if ($cache instanceof Cache) {
// only re-calculate for the root folder we scanned, anything below that is taken care of by the scanner
$cache->correctFolderSize($relativePath);
}
$propagator->commitBatch();
2015-11-27 16:02:50 +03:00
} catch (StorageNotAvailableException $e) {
$this->logger->error('Storage ' . $storage->getId() . ' not available');
2015-11-27 16:28:15 +03:00
$this->logger->logException($e);
2015-11-27 16:02:50 +03:00
$this->emit('\OC\Files\Utils\Scanner', 'StorageNotAvailable', [$e]);
}
2017-03-28 20:18:58 +03:00
if ($this->useTransaction) {
$this->db->commit();
}
2013-07-19 18:44:47 +04:00
}
}
private function triggerPropagator(IStorage $storage, $internalPath) {
$storage->getPropagator()->propagateChange($internalPath, time());
}
2017-03-28 20:18:58 +03:00
private function postProcessEntry(IStorage $storage, $internalPath) {
$this->triggerPropagator($storage, $internalPath);
if ($this->useTransaction) {
2017-04-03 12:49:30 +03:00
$this->entriesToCommit++;
2017-03-28 20:18:58 +03:00
if ($this->entriesToCommit >= self::MAX_ENTRIES_TO_COMMIT) {
2017-04-03 12:49:30 +03:00
$propagator = $storage->getPropagator();
2017-03-28 20:18:58 +03:00
$this->entriesToCommit = 0;
$this->db->commit();
$propagator->commitBatch();
$this->db->beginTransaction();
$propagator->beginBatch();
}
}
}
2013-07-19 18:44:47 +04:00
}