125 lines
3.9 KiB
PHP
125 lines
3.9 KiB
PHP
<?php
|
|
/**
|
|
* Copyright (c) 2012 Robin Appelman <icewind@owncloud.com>
|
|
* This file is licensed under the Affero General Public License version 3 or
|
|
* later.
|
|
* See the COPYING-README file.
|
|
*/
|
|
|
|
namespace Test\Files\Cache;
|
|
|
|
use OC\Files\Storage\Temporary;
|
|
use OCP\Files\Cache\ICacheEntry;
|
|
use OCP\Files\Storage\IStorage;
|
|
use Test\TestCase;
|
|
|
|
/**
|
|
* @group DB
|
|
*/
|
|
class PropagatorTest extends TestCase {
|
|
/** @var IStorage */
|
|
private $storage;
|
|
|
|
public function setUp() {
|
|
parent::setUp();
|
|
$this->storage = new Temporary();
|
|
$this->storage->mkdir('foo/bar');
|
|
$this->storage->file_put_contents('foo/bar/file.txt', 'bar');
|
|
$this->storage->getScanner()->scan('');
|
|
}
|
|
|
|
/**
|
|
* @param $paths
|
|
* @return ICacheEntry[]
|
|
*/
|
|
private function getFileInfos($paths) {
|
|
$values = array_map(function ($path) {
|
|
return $this->storage->getCache()->get($path);
|
|
}, $paths);
|
|
return array_combine($paths, $values);
|
|
}
|
|
|
|
public function testEtagPropagation() {
|
|
$paths = ['', 'foo', 'foo/bar'];
|
|
$oldInfos = $this->getFileInfos($paths);
|
|
$this->storage->getPropagator()->propagateChange('foo/bar/file.txt', time());
|
|
$newInfos = $this->getFileInfos($paths);
|
|
|
|
foreach ($oldInfos as $i => $oldInfo) {
|
|
$this->assertNotEquals($oldInfo->getEtag(), $newInfos[$i]->getEtag());
|
|
}
|
|
}
|
|
|
|
public function testTimePropagation() {
|
|
$paths = ['', 'foo', 'foo/bar'];
|
|
$oldTime = time() - 200;
|
|
$targetTime = time() - 100;
|
|
$now = time();
|
|
$cache = $this->storage->getCache();
|
|
$cache->put('', ['mtime' => $now]);
|
|
$cache->put('foo', ['mtime' => $now]);
|
|
$cache->put('foo/bar', ['mtime' => $oldTime]);
|
|
$cache->put('foo/bar/file.txt', ['mtime' => $oldTime]);
|
|
$this->storage->getPropagator()->propagateChange('foo/bar/file.txt', $targetTime);
|
|
$newInfos = $this->getFileInfos($paths);
|
|
|
|
$this->assertEquals($targetTime, $newInfos['foo/bar']->getMTime());
|
|
|
|
// dont lower mtimes
|
|
$this->assertEquals($now, $newInfos['foo']->getMTime());
|
|
$this->assertEquals($now, $newInfos['']->getMTime());
|
|
}
|
|
|
|
public function testSizePropagation() {
|
|
$paths = ['', 'foo', 'foo/bar'];
|
|
$oldInfos = $this->getFileInfos($paths);
|
|
$this->storage->getPropagator()->propagateChange('foo/bar/file.txt', time(), 10);
|
|
$newInfos = $this->getFileInfos($paths);
|
|
|
|
foreach ($oldInfos as $i => $oldInfo) {
|
|
$this->assertEquals($oldInfo->getSize() + 10, $newInfos[$i]->getSize());
|
|
}
|
|
}
|
|
|
|
public function testBatchedPropagation() {
|
|
$this->storage->mkdir('foo/baz');
|
|
$this->storage->mkdir('asd');
|
|
$this->storage->file_put_contents('asd/file.txt', 'bar');
|
|
$this->storage->file_put_contents('foo/baz/file.txt', 'bar');
|
|
$this->storage->getScanner()->scan('');
|
|
|
|
$paths = ['', 'foo', 'foo/bar', 'asd', 'foo/baz'];
|
|
|
|
$oldInfos = $this->getFileInfos($paths);
|
|
$propagator = $this->storage->getPropagator();
|
|
|
|
$propagator->beginBatch();
|
|
$propagator->propagateChange('asd/file.txt', time(), 10);
|
|
$propagator->propagateChange('foo/bar/file.txt', time(), 2);
|
|
|
|
$newInfos = $this->getFileInfos($paths);
|
|
|
|
// no changes until we finish the batch
|
|
foreach ($oldInfos as $i => $oldInfo) {
|
|
$this->assertEquals($oldInfo->getSize(), $newInfos[$i]->getSize());
|
|
$this->assertEquals($oldInfo->getEtag(), $newInfos[$i]->getEtag());
|
|
$this->assertEquals($oldInfo->getMTime(), $newInfos[$i]->getMTime());
|
|
}
|
|
|
|
$propagator->commitBatch();
|
|
|
|
$newInfos = $this->getFileInfos($paths);
|
|
|
|
foreach ($oldInfos as $i => $oldInfo) {
|
|
if ($oldInfo->getPath() !== 'foo/baz') {
|
|
$this->assertNotEquals($oldInfo->getEtag(), $newInfos[$i]->getEtag());
|
|
}
|
|
}
|
|
|
|
$this->assertEquals($oldInfos['']->getSize() + 12, $newInfos['']->getSize());
|
|
$this->assertEquals($oldInfos['asd']->getSize() + 10, $newInfos['asd']->getSize());
|
|
$this->assertEquals($oldInfos['foo']->getSize() + 2, $newInfos['foo']->getSize());
|
|
$this->assertEquals($oldInfos['foo/bar']->getSize() + 2, $newInfos['foo/bar']->getSize());
|
|
$this->assertEquals($oldInfos['foo/baz']->getSize(), $newInfos['foo/baz']->getSize());
|
|
}
|
|
}
|