mirror of
https://github.com/nextcloud/server.git
synced 2026-05-28 04:32:30 -04:00
Merge pull request #50804 from nextcloud/backport/48651/stable30
[stable30] fix(files): Correctly copy the cache information during copy operations
This commit is contained in:
commit
0c7ddb3dab
5 changed files with 57 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;
|
||||
}
|
||||
|
|
@ -181,14 +210,8 @@ class Updater implements IUpdater {
|
|||
$targetIsTrash = preg_match("/^d\d+$/", $targetExtension);
|
||||
|
||||
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);
|
||||
}
|
||||
|
||||
$isDir = $sourceInfo->getMimeType() === FileInfo::MIMETYPE_FOLDER;
|
||||
|
|
|
|||
|
|
@ -770,7 +770,6 @@ class Encryption extends Wrapper {
|
|||
$info->getUnencryptedSize()
|
||||
);
|
||||
}
|
||||
$this->updateEncryptedVersion($sourceStorage, $sourceInternalPath, $targetInternalPath, $isRename, true);
|
||||
}
|
||||
return $result;
|
||||
}
|
||||
|
|
|
|||
|
|
@ -277,6 +277,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
|
||||
|
|
@ -964,7 +970,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;
|
||||
}
|
||||
|
|
|
|||
|
|
@ -2371,6 +2371,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);
|
||||
|
|
@ -2815,4 +2816,12 @@ class ViewTest extends \Test\TestCase {
|
|||
$this->assertEquals('foo.png', $folderData[1]['name']);
|
||||
$this->assertEquals('foo.txt', $folderData[2]['name']);
|
||||
}
|
||||
|
||||
public function testCopyPreservesContent() {
|
||||
$viewUser1 = new View('/' . 'userId' . '/files');
|
||||
$viewUser1->mkdir('');
|
||||
$viewUser1->file_put_contents('foo.txt', 'foo');
|
||||
$viewUser1->copy('foo.txt', 'bar.txt');
|
||||
$this->assertEquals('foo', $viewUser1->file_get_contents('bar.txt'));
|
||||
}
|
||||
}
|
||||
|
|
|
|||
Loading…
Reference in a new issue