mbk-lab
/
nextcloud
2
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Restrict query when searching for versions of trashbin files 

Signed-off-by: Julius Härtl <jus@bitgrid.net>
This commit is contained in:
Julius Härtl 2020-09-29 17:02:53 +02:00 committed by backportbot[bot]
parent cc6e63e558
commit ea23f0d920
1 changed files with 43 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

57
apps/files_trashbin/lib/Trashbin.php
View File

@ -43,6 +43,9 @@
namespace OCA\Files_Trashbin; namespace OCA\Files_Trashbin;
use OC\Files\Cache\Cache;
use OC\Files\Cache\CacheEntry;
use OC\Files\Cache\CacheQueryBuilder;
use OC\Files\Filesystem; use OC\Files\Filesystem;
use OC\Files\ObjectStore\ObjectStoreStorage; use OC\Files\ObjectStore\ObjectStoreStorage;
use OC\Files\View; use OC\Files\View;
@ -917,33 +920,59 @@ class Trashbin {
$view = new View('/' . $user . '/files_trashbin/versions'); $view = new View('/' . $user . '/files_trashbin/versions');
$versions = []; $versions = [];
/** @var \OC\Files\Storage\Storage $storage */
[$storage,] = $view->resolvePath('/');
//force rescan of versions, local storage may not have updated the cache //force rescan of versions, local storage may not have updated the cache
if (!self::$scannedVersions) { if (!self::$scannedVersions) {
/** @var \OC\Files\Storage\Storage $storage */
[$storage,] = $view->resolvePath('/');
$storage->getScanner()->scan('files_trashbin/versions'); $storage->getScanner()->scan('files_trashbin/versions');
self::$scannedVersions = true; self::$scannedVersions = true;
} }
$pattern = \OC::$server->getDatabaseConnection()->escapeLikeParameter(basename($filename));
if ($timestamp) { if ($timestamp) {
// fetch for old versions // fetch for old versions
$matches = $view->searchRaw($filename . '.v%.d' . $timestamp); $escapedTimestamp = \OC::$server->getDatabaseConnection()->escapeLikeParameter($timestamp);
$offset = -strlen($timestamp) - 2; $pattern .= '.v%.d' . $escapedTimestamp;
$offset = -strlen($escapedTimestamp) - 2;
} else { } else {
$matches = $view->searchRaw($filename . '.v%'); $pattern .= '.v%';
} }
if (is_array($matches)) { // Manually fetch all versions from the file cache to be able to filter them by their parent
foreach ($matches as $ma) { $cache = $storage->getCache('');
if ($timestamp) { $query = new CacheQueryBuilder(
$parts = explode('.v', substr($ma['path'], 0, $offset)); \OC::$server->getDatabaseConnection(),
$versions[] = end($parts); \OC::$server->getSystemConfig(),
} else { \OC::$server->getLogger(),
$parts = explode('.v', $ma); $cache
$versions[] = end($parts); );
} $normalizedParentPath = ltrim(Filesystem::normalizePath(dirname('files_trashbin/versions/'. $filename)), '/');
$parentId = $cache->getId($normalizedParentPath);
if ($parentId === -1) {
return [];
}
$query->selectFileCache()
->whereStorageId()
->andWhere($query->expr()->eq('parent', $query->createNamedParameter($parentId)))
->andWhere($query->expr()->iLike('name', $query->createNamedParameter($pattern)));
/** @var CacheEntry[] $matches */
$matches = array_map(function (array $data) {
return Cache::cacheEntryFromData($data, \OC::$server->getMimeTypeLoader());
}, $query->execute()->fetchAll());
foreach ($matches as $ma) {
if ($timestamp) {
$parts = explode('.v', substr($ma['path'], 0, $offset));
$versions[] = end($parts);
} else {
$parts = explode('.v', $ma['path']);
$versions[] = end($parts);
} }
} }
return $versions; return $versions;
} }