mirror of
https://github.com/nextcloud/server.git
synced 2026-04-02 15:45:38 -04:00
fix(files): Correctly copy the cache information on copy operations
Needed to copy the `encrypted` flag of encrypted files when those files are two level down in a moved folder. Signed-off-by: Louis Chemineau <louis@chmn.me>
This commit is contained in:
parent
5ee4c9effa
commit
199b0bd4d9
5 changed files with 49 additions and 11 deletions
|
|
@ -9,6 +9,8 @@ namespace OC\Files\Cache;
|
|||
|
||||
use Doctrine\DBAL\Exception\DeadlockException;
|
||||
use OC\Files\FileInfo;
|
||||
use OC\Files\ObjectStore\ObjectStoreStorage;
|
||||
use OCP\Files\Cache\ICache;
|
||||
use OCP\Files\Cache\ICacheEntry;
|
||||
use OCP\Files\Cache\IUpdater;
|
||||
use OCP\Files\Storage\IStorage;
|
||||
|
|
@ -157,13 +159,40 @@ class Updater implements IUpdater {
|
|||
}
|
||||
|
||||
/**
|
||||
* Rename a file or folder in the cache and update the size, etag and mtime of the parent folders
|
||||
* Rename a file or folder in the cache.
|
||||
*
|
||||
* @param IStorage $sourceStorage
|
||||
* @param string $source
|
||||
* @param string $target
|
||||
*/
|
||||
public function renameFromStorage(IStorage $sourceStorage, $source, $target) {
|
||||
$this->copyOrRenameFromStorage($sourceStorage, $source, $target, function (ICache $sourceCache) use ($sourceStorage, $source, $target) {
|
||||
// Remove existing cache entry to no reuse the fileId.
|
||||
if ($this->cache->inCache($target)) {
|
||||
$this->cache->remove($target);
|
||||
}
|
||||
|
||||
if ($sourceStorage === $this->storage) {
|
||||
$this->cache->move($source, $target);
|
||||
} else {
|
||||
$this->cache->moveFromCache($sourceCache, $source, $target);
|
||||
}
|
||||
});
|
||||
}
|
||||
|
||||
/**
|
||||
* Copy a file or folder in the cache.
|
||||
*/
|
||||
public function copyFromStorage(IStorage $sourceStorage, string $source, string $target): void {
|
||||
$this->copyOrRenameFromStorage($sourceStorage, $source, $target, function (ICache $sourceCache, ICacheEntry $sourceInfo) use ($target) {
|
||||
$this->cache->copyFromCache($sourceCache, $sourceInfo, $target);
|
||||
});
|
||||
}
|
||||
|
||||
/**
|
||||
* Utility to copy or rename a file or folder in the cache and update the size, etag and mtime of the parent folders
|
||||
*/
|
||||
private function copyOrRenameFromStorage(IStorage $sourceStorage, string $source, string $target, callable $operation): void {
|
||||
if (!$this->enabled or Scanner::isPartialFile($source) or Scanner::isPartialFile($target)) {
|
||||
return;
|
||||
}
|
||||
|
|
@ -177,14 +206,8 @@ class Updater implements IUpdater {
|
|||
$sourceInfo = $sourceCache->get($source);
|
||||
|
||||
if ($sourceInfo !== false) {
|
||||
if ($this->cache->inCache($target)) {
|
||||
$this->cache->remove($target);
|
||||
}
|
||||
|
||||
if ($sourceStorage === $this->storage) {
|
||||
$this->cache->move($source, $target);
|
||||
} else {
|
||||
$this->cache->moveFromCache($sourceCache, $source, $target);
|
||||
if (!$this->storage->instanceOfStorage(ObjectStoreStorage::class)) {
|
||||
$operation($sourceCache, $sourceInfo);
|
||||
}
|
||||
|
||||
$sourceExtension = pathinfo($source, PATHINFO_EXTENSION);
|
||||
|
|
|
|||
|
|
@ -628,7 +628,6 @@ class Encryption extends Wrapper {
|
|||
$info->getUnencryptedSize()
|
||||
);
|
||||
}
|
||||
$this->updateEncryptedVersion($sourceStorage, $sourceInternalPath, $targetInternalPath, $isRename, true);
|
||||
}
|
||||
return $result;
|
||||
}
|
||||
|
|
|
|||
|
|
@ -273,6 +273,12 @@ class View {
|
|||
}
|
||||
}
|
||||
|
||||
protected function copyUpdate(Storage $sourceStorage, Storage $targetStorage, string $sourceInternalPath, string $targetInternalPath): void {
|
||||
if ($this->updaterEnabled) {
|
||||
$targetStorage->getUpdater()->copyFromStorage($sourceStorage, $sourceInternalPath, $targetInternalPath);
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* @param string $path
|
||||
* @return bool|mixed
|
||||
|
|
@ -898,7 +904,9 @@ class View {
|
|||
$result = $storage2->copyFromStorage($storage1, $internalPath1, $internalPath2);
|
||||
}
|
||||
|
||||
$this->writeUpdate($storage2, $internalPath2);
|
||||
if ($result) {
|
||||
$this->copyUpdate($storage1, $storage2, $internalPath1, $internalPath2);
|
||||
}
|
||||
|
||||
$this->changeLock($target, ILockingProvider::LOCK_SHARED);
|
||||
$lockTypePath2 = ILockingProvider::LOCK_SHARED;
|
||||
|
|
|
|||
|
|
@ -58,4 +58,11 @@ interface IUpdater {
|
|||
* @since 9.0.0
|
||||
*/
|
||||
public function renameFromStorage(IStorage $sourceStorage, $source, $target);
|
||||
|
||||
/**
|
||||
* Copy a file or folder in the cache and update the size, etag and mtime of the parent folders
|
||||
*
|
||||
* @since 31.0.0
|
||||
*/
|
||||
public function copyFromStorage(IStorage $sourceStorage, string $source, string $target): void;
|
||||
}
|
||||
|
|
|
|||
|
|
@ -2386,6 +2386,7 @@ class ViewTest extends \Test\TestCase {
|
|||
Filesystem::mount($storage2, [], $this->user . '/files/substorage');
|
||||
$storage->mkdir('files');
|
||||
$view->file_put_contents($sourcePath, 'meh');
|
||||
$storage2->getUpdater()->update('');
|
||||
|
||||
$storage->expects($this->never())
|
||||
->method($storageOperation);
|
||||
|
|
|
|||
Loading…
Reference in a new issue