You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.

VersioningTest.php 33KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928
  1. <?php
  2. /**
  3. * @copyright Copyright (c) 2016, ownCloud, Inc.
  4. *
  5. * @author Arthur Schiwon <blizzz@arthur-schiwon.de>
  6. * @author Björn Schießle <bjoern@schiessle.org>
  7. * @author Georg Ehrke <oc.list@georgehrke.com>
  8. * @author Joas Schilling <coding@schilljs.com>
  9. * @author Jörn Friedrich Dreyer <jfd@butonic.de>
  10. * @author Lukas Reschke <lukas@statuscode.ch>
  11. * @author Morris Jobke <hey@morrisjobke.de>
  12. * @author Robin Appelman <robin@icewind.nl>
  13. * @author Roeland Jago Douma <roeland@famdouma.nl>
  14. * @author Stefan Weil <sw@weilnetz.de>
  15. * @author Thomas Müller <thomas.mueller@tmit.eu>
  16. * @author Vincent Petry <pvince81@owncloud.com>
  17. *
  18. * @license AGPL-3.0
  19. *
  20. * This code is free software: you can redistribute it and/or modify
  21. * it under the terms of the GNU Affero General Public License, version 3,
  22. * as published by the Free Software Foundation.
  23. *
  24. * This program is distributed in the hope that it will be useful,
  25. * but WITHOUT ANY WARRANTY; without even the implied warranty of
  26. * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
  27. * GNU Affero General Public License for more details.
  28. *
  29. * You should have received a copy of the GNU Affero General Public License, version 3,
  30. * along with this program. If not, see <http://www.gnu.org/licenses/>
  31. *
  32. */
  33. namespace OCA\Files_Versions\Tests;
  34. require_once __DIR__ . '/../appinfo/app.php';
  35. use OC\Files\Storage\Temporary;
  36. use OCP\IConfig;
  37. use OCP\Share\IShare;
  38. /**
  39. * Class Test_Files_versions
  40. * this class provide basic files versions test
  41. *
  42. * @group DB
  43. */
  44. class VersioningTest extends \Test\TestCase {
  45. const TEST_VERSIONS_USER = 'test-versions-user';
  46. const TEST_VERSIONS_USER2 = 'test-versions-user2';
  47. const USERS_VERSIONS_ROOT = '/test-versions-user/files_versions';
  48. /**
  49. * @var \OC\Files\View
  50. */
  51. private $rootView;
  52. public static function setUpBeforeClass(): void {
  53. parent::setUpBeforeClass();
  54. $application = new \OCA\Files_Sharing\AppInfo\Application();
  55. // create test user
  56. self::loginHelper(self::TEST_VERSIONS_USER2, true);
  57. self::loginHelper(self::TEST_VERSIONS_USER, true);
  58. }
  59. public static function tearDownAfterClass(): void {
  60. // cleanup test user
  61. $user = \OC::$server->getUserManager()->get(self::TEST_VERSIONS_USER);
  62. if ($user !== null) { $user->delete(); }
  63. $user = \OC::$server->getUserManager()->get(self::TEST_VERSIONS_USER2);
  64. if ($user !== null) { $user->delete(); }
  65. parent::tearDownAfterClass();
  66. }
  67. protected function setUp(): void {
  68. parent::setUp();
  69. $config = \OC::$server->getConfig();
  70. $mockConfig = $this->createMock(IConfig::class);
  71. $mockConfig->expects($this->any())
  72. ->method('getSystemValue')
  73. ->will($this->returnCallback(function ($key, $default) use ($config) {
  74. if ($key === 'filesystem_check_changes') {
  75. return \OC\Files\Cache\Watcher::CHECK_ONCE;
  76. } else {
  77. return $config->getSystemValue($key, $default);
  78. }
  79. }));
  80. $this->overwriteService('AllConfig', $mockConfig);
  81. // clear hooks
  82. \OC_Hook::clear();
  83. \OC::registerShareHooks();
  84. \OCA\Files_Versions\Hooks::connectHooks();
  85. self::loginHelper(self::TEST_VERSIONS_USER);
  86. $this->rootView = new \OC\Files\View();
  87. if (!$this->rootView->file_exists(self::USERS_VERSIONS_ROOT)) {
  88. $this->rootView->mkdir(self::USERS_VERSIONS_ROOT);
  89. }
  90. }
  91. protected function tearDown(): void {
  92. $this->restoreService('AllConfig');
  93. if ($this->rootView) {
  94. $this->rootView->deleteAll(self::TEST_VERSIONS_USER . '/files/');
  95. $this->rootView->deleteAll(self::TEST_VERSIONS_USER2 . '/files/');
  96. $this->rootView->deleteAll(self::TEST_VERSIONS_USER . '/files_versions/');
  97. $this->rootView->deleteAll(self::TEST_VERSIONS_USER2 . '/files_versions/');
  98. }
  99. \OC_Hook::clear();
  100. parent::tearDown();
  101. }
  102. /**
  103. * @medium
  104. * test expire logic
  105. * @dataProvider versionsProvider
  106. */
  107. public function testGetExpireList($versions, $sizeOfAllDeletedFiles) {
  108. // last interval end at 2592000
  109. $startTime = 5000000;
  110. $testClass = new VersionStorageToTest();
  111. list($deleted, $size) = $testClass->callProtectedGetExpireList($startTime, $versions);
  112. // we should have deleted 16 files each of the size 1
  113. $this->assertEquals($sizeOfAllDeletedFiles, $size);
  114. // the deleted array should only contain versions which should be deleted
  115. foreach($deleted as $key => $path) {
  116. unset($versions[$key]);
  117. $this->assertEquals("delete", substr($path, 0, strlen("delete")));
  118. }
  119. // the versions array should only contain versions which should be kept
  120. foreach ($versions as $version) {
  121. $this->assertEquals("keep", $version['path']);
  122. }
  123. }
  124. public function versionsProvider() {
  125. return array(
  126. // first set of versions uniformly distributed versions
  127. array(
  128. array(
  129. // first slice (10sec) keep one version every 2 seconds
  130. array("version" => 4999999, "path" => "keep", "size" => 1),
  131. array("version" => 4999998, "path" => "delete", "size" => 1),
  132. array("version" => 4999997, "path" => "keep", "size" => 1),
  133. array("version" => 4999995, "path" => "keep", "size" => 1),
  134. array("version" => 4999994, "path" => "delete", "size" => 1),
  135. //next slice (60sec) starts at 4999990 keep one version every 10 secons
  136. array("version" => 4999988, "path" => "keep", "size" => 1),
  137. array("version" => 4999978, "path" => "keep", "size" => 1),
  138. array("version" => 4999975, "path" => "delete", "size" => 1),
  139. array("version" => 4999972, "path" => "delete", "size" => 1),
  140. array("version" => 4999967, "path" => "keep", "size" => 1),
  141. array("version" => 4999958, "path" => "delete", "size" => 1),
  142. array("version" => 4999957, "path" => "keep", "size" => 1),
  143. //next slice (3600sec) start at 4999940 keep one version every 60 seconds
  144. array("version" => 4999900, "path" => "keep", "size" => 1),
  145. array("version" => 4999841, "path" => "delete", "size" => 1),
  146. array("version" => 4999840, "path" => "keep", "size" => 1),
  147. array("version" => 4999780, "path" => "keep", "size" => 1),
  148. array("version" => 4996401, "path" => "keep", "size" => 1),
  149. // next slice (86400sec) start at 4996400 keep one version every 3600 seconds
  150. array("version" => 4996350, "path" => "delete", "size" => 1),
  151. array("version" => 4992800, "path" => "keep", "size" => 1),
  152. array("version" => 4989800, "path" => "delete", "size" => 1),
  153. array("version" => 4989700, "path" => "delete", "size" => 1),
  154. array("version" => 4989200, "path" => "keep", "size" => 1),
  155. // next slice (2592000sec) start at 4913600 keep one version every 86400 seconds
  156. array("version" => 4913600, "path" => "keep", "size" => 1),
  157. array("version" => 4852800, "path" => "delete", "size" => 1),
  158. array("version" => 4827201, "path" => "delete", "size" => 1),
  159. array("version" => 4827200, "path" => "keep", "size" => 1),
  160. array("version" => 4777201, "path" => "delete", "size" => 1),
  161. array("version" => 4777501, "path" => "delete", "size" => 1),
  162. array("version" => 4740000, "path" => "keep", "size" => 1),
  163. // final slice starts at 2408000 keep one version every 604800 secons
  164. array("version" => 2408000, "path" => "keep", "size" => 1),
  165. array("version" => 1803201, "path" => "delete", "size" => 1),
  166. array("version" => 1803200, "path" => "keep", "size" => 1),
  167. array("version" => 1800199, "path" => "delete", "size" => 1),
  168. array("version" => 1800100, "path" => "delete", "size" => 1),
  169. array("version" => 1198300, "path" => "keep", "size" => 1),
  170. ),
  171. 16 // size of all deleted files (every file has the size 1)
  172. ),
  173. // second set of versions, here we have only really old versions
  174. array(
  175. array(
  176. // first slice (10sec) keep one version every 2 seconds
  177. // next slice (60sec) starts at 4999990 keep one version every 10 secons
  178. // next slice (3600sec) start at 4999940 keep one version every 60 seconds
  179. // next slice (86400sec) start at 4996400 keep one version every 3600 seconds
  180. array("version" => 4996400, "path" => "keep", "size" => 1),
  181. array("version" => 4996350, "path" => "delete", "size" => 1),
  182. array("version" => 4996350, "path" => "delete", "size" => 1),
  183. array("version" => 4992800, "path" => "keep", "size" => 1),
  184. array("version" => 4989800, "path" => "delete", "size" => 1),
  185. array("version" => 4989700, "path" => "delete", "size" => 1),
  186. array("version" => 4989200, "path" => "keep", "size" => 1),
  187. // next slice (2592000sec) start at 4913600 keep one version every 86400 seconds
  188. array("version" => 4913600, "path" => "keep", "size" => 1),
  189. array("version" => 4852800, "path" => "delete", "size" => 1),
  190. array("version" => 4827201, "path" => "delete", "size" => 1),
  191. array("version" => 4827200, "path" => "keep", "size" => 1),
  192. array("version" => 4777201, "path" => "delete", "size" => 1),
  193. array("version" => 4777501, "path" => "delete", "size" => 1),
  194. array("version" => 4740000, "path" => "keep", "size" => 1),
  195. // final slice starts at 2408000 keep one version every 604800 secons
  196. array("version" => 2408000, "path" => "keep", "size" => 1),
  197. array("version" => 1803201, "path" => "delete", "size" => 1),
  198. array("version" => 1803200, "path" => "keep", "size" => 1),
  199. array("version" => 1800199, "path" => "delete", "size" => 1),
  200. array("version" => 1800100, "path" => "delete", "size" => 1),
  201. array("version" => 1198300, "path" => "keep", "size" => 1),
  202. ),
  203. 11 // size of all deleted files (every file has the size 1)
  204. ),
  205. // third set of versions, with some gaps between
  206. array(
  207. array(
  208. // first slice (10sec) keep one version every 2 seconds
  209. array("version" => 4999999, "path" => "keep", "size" => 1),
  210. array("version" => 4999998, "path" => "delete", "size" => 1),
  211. array("version" => 4999997, "path" => "keep", "size" => 1),
  212. array("version" => 4999995, "path" => "keep", "size" => 1),
  213. array("version" => 4999994, "path" => "delete", "size" => 1),
  214. //next slice (60sec) starts at 4999990 keep one version every 10 secons
  215. array("version" => 4999988, "path" => "keep", "size" => 1),
  216. array("version" => 4999978, "path" => "keep", "size" => 1),
  217. //next slice (3600sec) start at 4999940 keep one version every 60 seconds
  218. // next slice (86400sec) start at 4996400 keep one version every 3600 seconds
  219. array("version" => 4989200, "path" => "keep", "size" => 1),
  220. // next slice (2592000sec) start at 4913600 keep one version every 86400 seconds
  221. array("version" => 4913600, "path" => "keep", "size" => 1),
  222. array("version" => 4852800, "path" => "delete", "size" => 1),
  223. array("version" => 4827201, "path" => "delete", "size" => 1),
  224. array("version" => 4827200, "path" => "keep", "size" => 1),
  225. array("version" => 4777201, "path" => "delete", "size" => 1),
  226. array("version" => 4777501, "path" => "delete", "size" => 1),
  227. array("version" => 4740000, "path" => "keep", "size" => 1),
  228. // final slice starts at 2408000 keep one version every 604800 secons
  229. array("version" => 2408000, "path" => "keep", "size" => 1),
  230. array("version" => 1803201, "path" => "delete", "size" => 1),
  231. array("version" => 1803200, "path" => "keep", "size" => 1),
  232. array("version" => 1800199, "path" => "delete", "size" => 1),
  233. array("version" => 1800100, "path" => "delete", "size" => 1),
  234. array("version" => 1198300, "path" => "keep", "size" => 1),
  235. ),
  236. 9 // size of all deleted files (every file has the size 1)
  237. ),
  238. );
  239. }
  240. public function testRename() {
  241. \OC\Files\Filesystem::file_put_contents("test.txt", "test file");
  242. $t1 = time();
  243. // second version is two weeks older, this way we make sure that no
  244. // version will be expired
  245. $t2 = $t1 - 60 * 60 * 24 * 14;
  246. // create some versions
  247. $v1 = self::USERS_VERSIONS_ROOT . '/test.txt.v' . $t1;
  248. $v2 = self::USERS_VERSIONS_ROOT . '/test.txt.v' . $t2;
  249. $v1Renamed = self::USERS_VERSIONS_ROOT . '/test2.txt.v' . $t1;
  250. $v2Renamed = self::USERS_VERSIONS_ROOT . '/test2.txt.v' . $t2;
  251. $this->rootView->file_put_contents($v1, 'version1');
  252. $this->rootView->file_put_contents($v2, 'version2');
  253. // execute rename hook of versions app
  254. \OC\Files\Filesystem::rename("test.txt", "test2.txt");
  255. $this->runCommands();
  256. $this->assertFalse($this->rootView->file_exists($v1), 'version 1 of old file does not exist');
  257. $this->assertFalse($this->rootView->file_exists($v2), 'version 2 of old file does not exist');
  258. $this->assertTrue($this->rootView->file_exists($v1Renamed), 'version 1 of renamed file exists');
  259. $this->assertTrue($this->rootView->file_exists($v2Renamed), 'version 2 of renamed file exists');
  260. }
  261. public function testRenameInSharedFolder() {
  262. \OC\Files\Filesystem::mkdir('folder1');
  263. \OC\Files\Filesystem::mkdir('folder1/folder2');
  264. \OC\Files\Filesystem::file_put_contents("folder1/test.txt", "test file");
  265. $t1 = time();
  266. // second version is two weeks older, this way we make sure that no
  267. // version will be expired
  268. $t2 = $t1 - 60 * 60 * 24 * 14;
  269. $this->rootView->mkdir(self::USERS_VERSIONS_ROOT . '/folder1');
  270. // create some versions
  271. $v1 = self::USERS_VERSIONS_ROOT . '/folder1/test.txt.v' . $t1;
  272. $v2 = self::USERS_VERSIONS_ROOT . '/folder1/test.txt.v' . $t2;
  273. $v1Renamed = self::USERS_VERSIONS_ROOT . '/folder1/folder2/test.txt.v' . $t1;
  274. $v2Renamed = self::USERS_VERSIONS_ROOT . '/folder1/folder2/test.txt.v' . $t2;
  275. $this->rootView->file_put_contents($v1, 'version1');
  276. $this->rootView->file_put_contents($v2, 'version2');
  277. $node = \OC::$server->getUserFolder(self::TEST_VERSIONS_USER)->get('folder1');
  278. $share = \OC::$server->getShareManager()->newShare();
  279. $share->setNode($node)
  280. ->setShareType(\OCP\Share::SHARE_TYPE_USER)
  281. ->setSharedBy(self::TEST_VERSIONS_USER)
  282. ->setSharedWith(self::TEST_VERSIONS_USER2)
  283. ->setPermissions(\OCP\Constants::PERMISSION_ALL);
  284. $share = \OC::$server->getShareManager()->createShare($share);
  285. \OC::$server->getShareManager()->acceptShare($share, self::TEST_VERSIONS_USER2);
  286. self::loginHelper(self::TEST_VERSIONS_USER2);
  287. $this->assertTrue(\OC\Files\Filesystem::file_exists('folder1/test.txt'));
  288. // execute rename hook of versions app
  289. \OC\Files\Filesystem::rename('/folder1/test.txt', '/folder1/folder2/test.txt');
  290. $this->runCommands();
  291. self::loginHelper(self::TEST_VERSIONS_USER);
  292. $this->assertFalse($this->rootView->file_exists($v1), 'version 1 of old file does not exist');
  293. $this->assertFalse($this->rootView->file_exists($v2), 'version 2 of old file does not exist');
  294. $this->assertTrue($this->rootView->file_exists($v1Renamed), 'version 1 of renamed file exists');
  295. $this->assertTrue($this->rootView->file_exists($v2Renamed), 'version 2 of renamed file exists');
  296. \OC::$server->getShareManager()->deleteShare($share);
  297. }
  298. public function testMoveFolder() {
  299. \OC\Files\Filesystem::mkdir('folder1');
  300. \OC\Files\Filesystem::mkdir('folder2');
  301. \OC\Files\Filesystem::file_put_contents('folder1/test.txt', 'test file');
  302. $t1 = time();
  303. // second version is two weeks older, this way we make sure that no
  304. // version will be expired
  305. $t2 = $t1 - 60 * 60 * 24 * 14;
  306. // create some versions
  307. $this->rootView->mkdir(self::USERS_VERSIONS_ROOT . '/folder1');
  308. $v1 = self::USERS_VERSIONS_ROOT . '/folder1/test.txt.v' . $t1;
  309. $v2 = self::USERS_VERSIONS_ROOT . '/folder1/test.txt.v' . $t2;
  310. $v1Renamed = self::USERS_VERSIONS_ROOT . '/folder2/folder1/test.txt.v' . $t1;
  311. $v2Renamed = self::USERS_VERSIONS_ROOT . '/folder2/folder1/test.txt.v' . $t2;
  312. $this->rootView->file_put_contents($v1, 'version1');
  313. $this->rootView->file_put_contents($v2, 'version2');
  314. // execute rename hook of versions app
  315. \OC\Files\Filesystem::rename('folder1', 'folder2/folder1');
  316. $this->runCommands();
  317. $this->assertFalse($this->rootView->file_exists($v1));
  318. $this->assertFalse($this->rootView->file_exists($v2));
  319. $this->assertTrue($this->rootView->file_exists($v1Renamed));
  320. $this->assertTrue($this->rootView->file_exists($v2Renamed));
  321. }
  322. public function testMoveFileIntoSharedFolderAsRecipient() {
  323. \OC\Files\Filesystem::mkdir('folder1');
  324. $fileInfo = \OC\Files\Filesystem::getFileInfo('folder1');
  325. $node = \OC::$server->getUserFolder(self::TEST_VERSIONS_USER)->get('folder1');
  326. $share = \OC::$server->getShareManager()->newShare();
  327. $share->setNode($node)
  328. ->setShareType(\OCP\Share::SHARE_TYPE_USER)
  329. ->setSharedBy(self::TEST_VERSIONS_USER)
  330. ->setSharedWith(self::TEST_VERSIONS_USER2)
  331. ->setPermissions(\OCP\Constants::PERMISSION_ALL);
  332. $share = \OC::$server->getShareManager()->createShare($share);
  333. \OC::$server->getShareManager()->acceptShare($share, self::TEST_VERSIONS_USER2);
  334. self::loginHelper(self::TEST_VERSIONS_USER2);
  335. $versionsFolder2 = '/' . self::TEST_VERSIONS_USER2 . '/files_versions';
  336. \OC\Files\Filesystem::file_put_contents('test.txt', 'test file');
  337. $t1 = time();
  338. // second version is two weeks older, this way we make sure that no
  339. // version will be expired
  340. $t2 = $t1 - 60 * 60 * 24 * 14;
  341. $this->rootView->mkdir($versionsFolder2);
  342. // create some versions
  343. $v1 = $versionsFolder2 . '/test.txt.v' . $t1;
  344. $v2 = $versionsFolder2 . '/test.txt.v' . $t2;
  345. $this->rootView->file_put_contents($v1, 'version1');
  346. $this->rootView->file_put_contents($v2, 'version2');
  347. // move file into the shared folder as recipient
  348. \OC\Files\Filesystem::rename('/test.txt', '/folder1/test.txt');
  349. $this->assertFalse($this->rootView->file_exists($v1));
  350. $this->assertFalse($this->rootView->file_exists($v2));
  351. self::loginHelper(self::TEST_VERSIONS_USER);
  352. $versionsFolder1 = '/' . self::TEST_VERSIONS_USER . '/files_versions';
  353. $v1Renamed = $versionsFolder1 . '/folder1/test.txt.v' . $t1;
  354. $v2Renamed = $versionsFolder1 . '/folder1/test.txt.v' . $t2;
  355. $this->assertTrue($this->rootView->file_exists($v1Renamed));
  356. $this->assertTrue($this->rootView->file_exists($v2Renamed));
  357. \OC::$server->getShareManager()->deleteShare($share);
  358. }
  359. public function testMoveFolderIntoSharedFolderAsRecipient() {
  360. \OC\Files\Filesystem::mkdir('folder1');
  361. $node = \OC::$server->getUserFolder(self::TEST_VERSIONS_USER)->get('folder1');
  362. $share = \OC::$server->getShareManager()->newShare();
  363. $share->setNode($node)
  364. ->setShareType(\OCP\Share::SHARE_TYPE_USER)
  365. ->setSharedBy(self::TEST_VERSIONS_USER)
  366. ->setSharedWith(self::TEST_VERSIONS_USER2)
  367. ->setPermissions(\OCP\Constants::PERMISSION_ALL);
  368. $share = \OC::$server->getShareManager()->createShare($share);
  369. \OC::$server->getShareManager()->acceptShare($share, self::TEST_VERSIONS_USER2);
  370. self::loginHelper(self::TEST_VERSIONS_USER2);
  371. $versionsFolder2 = '/' . self::TEST_VERSIONS_USER2 . '/files_versions';
  372. \OC\Files\Filesystem::mkdir('folder2');
  373. \OC\Files\Filesystem::file_put_contents('folder2/test.txt', 'test file');
  374. $t1 = time();
  375. // second version is two weeks older, this way we make sure that no
  376. // version will be expired
  377. $t2 = $t1 - 60 * 60 * 24 * 14;
  378. $this->rootView->mkdir($versionsFolder2);
  379. $this->rootView->mkdir($versionsFolder2 . '/folder2');
  380. // create some versions
  381. $v1 = $versionsFolder2 . '/folder2/test.txt.v' . $t1;
  382. $v2 = $versionsFolder2 . '/folder2/test.txt.v' . $t2;
  383. $this->rootView->file_put_contents($v1, 'version1');
  384. $this->rootView->file_put_contents($v2, 'version2');
  385. // move file into the shared folder as recipient
  386. \OC\Files\Filesystem::rename('/folder2', '/folder1/folder2');
  387. $this->assertFalse($this->rootView->file_exists($v1));
  388. $this->assertFalse($this->rootView->file_exists($v2));
  389. self::loginHelper(self::TEST_VERSIONS_USER);
  390. $versionsFolder1 = '/' . self::TEST_VERSIONS_USER . '/files_versions';
  391. $v1Renamed = $versionsFolder1 . '/folder1/folder2/test.txt.v' . $t1;
  392. $v2Renamed = $versionsFolder1 . '/folder1/folder2/test.txt.v' . $t2;
  393. $this->assertTrue($this->rootView->file_exists($v1Renamed));
  394. $this->assertTrue($this->rootView->file_exists($v2Renamed));
  395. \OC::$server->getShareManager()->deleteShare($share);
  396. }
  397. public function testRenameSharedFile() {
  398. \OC\Files\Filesystem::file_put_contents("test.txt", "test file");
  399. $t1 = time();
  400. // second version is two weeks older, this way we make sure that no
  401. // version will be expired
  402. $t2 = $t1 - 60 * 60 * 24 * 14;
  403. $this->rootView->mkdir(self::USERS_VERSIONS_ROOT);
  404. // create some versions
  405. $v1 = self::USERS_VERSIONS_ROOT . '/test.txt.v' . $t1;
  406. $v2 = self::USERS_VERSIONS_ROOT . '/test.txt.v' . $t2;
  407. // the renamed versions should not exist! Because we only moved the mount point!
  408. $v1Renamed = self::USERS_VERSIONS_ROOT . '/test2.txt.v' . $t1;
  409. $v2Renamed = self::USERS_VERSIONS_ROOT . '/test2.txt.v' . $t2;
  410. $this->rootView->file_put_contents($v1, 'version1');
  411. $this->rootView->file_put_contents($v2, 'version2');
  412. $node = \OC::$server->getUserFolder(self::TEST_VERSIONS_USER)->get('test.txt');
  413. $share = \OC::$server->getShareManager()->newShare();
  414. $share->setNode($node)
  415. ->setShareType(\OCP\Share::SHARE_TYPE_USER)
  416. ->setSharedBy(self::TEST_VERSIONS_USER)
  417. ->setSharedWith(self::TEST_VERSIONS_USER2)
  418. ->setPermissions(\OCP\Constants::PERMISSION_READ | \OCP\Constants::PERMISSION_UPDATE | \OCP\Constants::PERMISSION_SHARE);
  419. $share = \OC::$server->getShareManager()->createShare($share);
  420. \OC::$server->getShareManager()->acceptShare($share, self::TEST_VERSIONS_USER2);
  421. self::loginHelper(self::TEST_VERSIONS_USER2);
  422. $this->assertTrue(\OC\Files\Filesystem::file_exists('test.txt'));
  423. // execute rename hook of versions app
  424. \OC\Files\Filesystem::rename('test.txt', 'test2.txt');
  425. self::loginHelper(self::TEST_VERSIONS_USER);
  426. $this->runCommands();
  427. $this->assertTrue($this->rootView->file_exists($v1));
  428. $this->assertTrue($this->rootView->file_exists($v2));
  429. $this->assertFalse($this->rootView->file_exists($v1Renamed));
  430. $this->assertFalse($this->rootView->file_exists($v2Renamed));
  431. \OC::$server->getShareManager()->deleteShare($share);
  432. }
  433. public function testCopy() {
  434. \OC\Files\Filesystem::file_put_contents("test.txt", "test file");
  435. $t1 = time();
  436. // second version is two weeks older, this way we make sure that no
  437. // version will be expired
  438. $t2 = $t1 - 60 * 60 * 24 * 14;
  439. // create some versions
  440. $v1 = self::USERS_VERSIONS_ROOT . '/test.txt.v' . $t1;
  441. $v2 = self::USERS_VERSIONS_ROOT . '/test.txt.v' . $t2;
  442. $v1Copied = self::USERS_VERSIONS_ROOT . '/test2.txt.v' . $t1;
  443. $v2Copied = self::USERS_VERSIONS_ROOT . '/test2.txt.v' . $t2;
  444. $this->rootView->file_put_contents($v1, 'version1');
  445. $this->rootView->file_put_contents($v2, 'version2');
  446. // execute copy hook of versions app
  447. \OC\Files\Filesystem::copy("test.txt", "test2.txt");
  448. $this->runCommands();
  449. $this->assertTrue($this->rootView->file_exists($v1), 'version 1 of original file exists');
  450. $this->assertTrue($this->rootView->file_exists($v2), 'version 2 of original file exists');
  451. $this->assertTrue($this->rootView->file_exists($v1Copied), 'version 1 of copied file exists');
  452. $this->assertTrue($this->rootView->file_exists($v2Copied), 'version 2 of copied file exists');
  453. }
  454. /**
  455. * test if we find all versions and if the versions array contain
  456. * the correct 'path' and 'name'
  457. */
  458. public function testGetVersions() {
  459. $t1 = time();
  460. // second version is two weeks older, this way we make sure that no
  461. // version will be expired
  462. $t2 = $t1 - 60 * 60 * 24 * 14;
  463. // create some versions
  464. $v1 = self::USERS_VERSIONS_ROOT . '/subfolder/test.txt.v' . $t1;
  465. $v2 = self::USERS_VERSIONS_ROOT . '/subfolder/test.txt.v' . $t2;
  466. $this->rootView->mkdir(self::USERS_VERSIONS_ROOT . '/subfolder/');
  467. $this->rootView->file_put_contents($v1, 'version1');
  468. $this->rootView->file_put_contents($v2, 'version2');
  469. // execute copy hook of versions app
  470. $versions = \OCA\Files_Versions\Storage::getVersions(self::TEST_VERSIONS_USER, '/subfolder/test.txt');
  471. $this->assertCount(2, $versions);
  472. foreach ($versions as $version) {
  473. $this->assertSame('/subfolder/test.txt', $version['path']);
  474. $this->assertSame('test.txt', $version['name']);
  475. }
  476. //cleanup
  477. $this->rootView->deleteAll(self::USERS_VERSIONS_ROOT . '/subfolder');
  478. }
  479. /**
  480. * test if we find all versions and if the versions array contain
  481. * the correct 'path' and 'name'
  482. */
  483. public function testGetVersionsEmptyFile() {
  484. // execute copy hook of versions app
  485. $versions = \OCA\Files_Versions\Storage::getVersions(self::TEST_VERSIONS_USER, '');
  486. $this->assertCount(0, $versions);
  487. $versions = \OCA\Files_Versions\Storage::getVersions(self::TEST_VERSIONS_USER, null);
  488. $this->assertCount(0, $versions);
  489. }
  490. public function testExpireNonexistingFile() {
  491. $this->logout();
  492. // needed to have a FS setup (the background job does this)
  493. \OC_Util::setupFS(self::TEST_VERSIONS_USER);
  494. $this->assertFalse(\OCA\Files_Versions\Storage::expire('/void/unexist.txt', self::TEST_VERSIONS_USER));
  495. }
  496. public function testExpireNonexistingUser() {
  497. $this->expectException(\OC\User\NoUserException::class);
  498. $this->logout();
  499. // needed to have a FS setup (the background job does this)
  500. \OC_Util::setupFS(self::TEST_VERSIONS_USER);
  501. \OC\Files\Filesystem::file_put_contents("test.txt", "test file");
  502. $this->assertFalse(\OCA\Files_Versions\Storage::expire('test.txt', 'unexist'));
  503. }
  504. public function testRestoreSameStorage() {
  505. \OC\Files\Filesystem::mkdir('sub');
  506. $this->doTestRestore();
  507. }
  508. public function testRestoreCrossStorage() {
  509. $storage2 = new Temporary(array());
  510. \OC\Files\Filesystem::mount($storage2, array(), self::TEST_VERSIONS_USER . '/files/sub');
  511. $this->doTestRestore();
  512. }
  513. public function testRestoreNoPermission() {
  514. $this->loginAsUser(self::TEST_VERSIONS_USER);
  515. $userHome = \OC::$server->getUserFolder(self::TEST_VERSIONS_USER);
  516. $node = $userHome->newFolder('folder');
  517. $file = $node->newFile('test.txt');
  518. $share = \OC::$server->getShareManager()->newShare();
  519. $share->setNode($node)
  520. ->setShareType(\OCP\Share::SHARE_TYPE_USER)
  521. ->setSharedBy(self::TEST_VERSIONS_USER)
  522. ->setSharedWith(self::TEST_VERSIONS_USER2)
  523. ->setPermissions(\OCP\Constants::PERMISSION_READ);
  524. $share = \OC::$server->getShareManager()->createShare($share);
  525. \OC::$server->getShareManager()->acceptShare($share, self::TEST_VERSIONS_USER2);
  526. $versions = $this->createAndCheckVersions(
  527. \OC\Files\Filesystem::getView(),
  528. 'folder/test.txt'
  529. );
  530. $file->putContent('test file');
  531. $this->loginAsUser(self::TEST_VERSIONS_USER2);
  532. $firstVersion = current($versions);
  533. $this->assertFalse(\OCA\Files_Versions\Storage::rollback('folder/test.txt', $firstVersion['version']), 'Revert did not happen');
  534. $this->loginAsUser(self::TEST_VERSIONS_USER);
  535. \OC::$server->getShareManager()->deleteShare($share);
  536. $this->assertEquals('test file', $file->getContent(), 'File content has not changed');
  537. }
  538. /**
  539. * @param string $hookName name of hook called
  540. * @param string $params variable to receive parameters provided by hook
  541. */
  542. private function connectMockHooks($hookName, &$params) {
  543. if ($hookName === null) {
  544. return;
  545. }
  546. $eventHandler = $this->getMockBuilder(\stdclass::class)
  547. ->setMethods(['callback'])
  548. ->getMock();
  549. $eventHandler->expects($this->any())
  550. ->method('callback')
  551. ->will($this->returnCallback(
  552. function($p) use (&$params) {
  553. $params = $p;
  554. }
  555. ));
  556. \OCP\Util::connectHook(
  557. '\OCP\Versions',
  558. $hookName,
  559. $eventHandler,
  560. 'callback'
  561. );
  562. }
  563. private function doTestRestore() {
  564. $filePath = self::TEST_VERSIONS_USER . '/files/sub/test.txt';
  565. $this->rootView->file_put_contents($filePath, 'test file');
  566. $t0 = $this->rootView->filemtime($filePath);
  567. // not exactly the same timestamp as the file
  568. $t1 = time() - 60;
  569. // second version is two weeks older
  570. $t2 = $t1 - 60 * 60 * 24 * 14;
  571. // create some versions
  572. $v1 = self::USERS_VERSIONS_ROOT . '/sub/test.txt.v' . $t1;
  573. $v2 = self::USERS_VERSIONS_ROOT . '/sub/test.txt.v' . $t2;
  574. $this->rootView->mkdir(self::USERS_VERSIONS_ROOT . '/sub');
  575. $this->rootView->file_put_contents($v1, 'version1');
  576. $this->rootView->file_put_contents($v2, 'version2');
  577. $oldVersions = \OCA\Files_Versions\Storage::getVersions(
  578. self::TEST_VERSIONS_USER, '/sub/test.txt'
  579. );
  580. $this->assertCount(2, $oldVersions);
  581. $this->assertEquals('test file', $this->rootView->file_get_contents($filePath));
  582. $info1 = $this->rootView->getFileInfo($filePath);
  583. $params = array();
  584. $this->connectMockHooks('rollback', $params);
  585. $this->assertTrue(\OCA\Files_Versions\Storage::rollback('sub/test.txt', $t2));
  586. $expectedParams = array(
  587. 'path' => '/sub/test.txt',
  588. );
  589. $this->assertEquals($expectedParams['path'], $params['path']);
  590. $this->assertTrue(array_key_exists('revision', $params));
  591. $this->assertTrue($params['revision'] > 0);
  592. $this->assertEquals('version2', $this->rootView->file_get_contents($filePath));
  593. $info2 = $this->rootView->getFileInfo($filePath);
  594. $this->assertNotEquals(
  595. $info2['etag'],
  596. $info1['etag'],
  597. 'Etag must change after rolling back version'
  598. );
  599. $this->assertEquals(
  600. $info2['fileid'],
  601. $info1['fileid'],
  602. 'File id must not change after rolling back version'
  603. );
  604. $this->assertEquals(
  605. $info2['mtime'],
  606. $t2,
  607. 'Restored file has mtime from version'
  608. );
  609. $newVersions = \OCA\Files_Versions\Storage::getVersions(
  610. self::TEST_VERSIONS_USER, '/sub/test.txt'
  611. );
  612. $this->assertTrue(
  613. $this->rootView->file_exists(self::USERS_VERSIONS_ROOT . '/sub/test.txt.v' . $t0),
  614. 'A version file was created for the file before restoration'
  615. );
  616. $this->assertTrue(
  617. $this->rootView->file_exists($v1),
  618. 'Untouched version file is still there'
  619. );
  620. $this->assertFalse(
  621. $this->rootView->file_exists($v2),
  622. 'Restored version file gone from files_version folder'
  623. );
  624. $this->assertCount(2, $newVersions, 'Additional version created');
  625. $this->assertTrue(
  626. isset($newVersions[$t0 . '#' . 'test.txt']),
  627. 'A version was created for the file before restoration'
  628. );
  629. $this->assertTrue(
  630. isset($newVersions[$t1 . '#' . 'test.txt']),
  631. 'Untouched version is still there'
  632. );
  633. $this->assertFalse(
  634. isset($newVersions[$t2 . '#' . 'test.txt']),
  635. 'Restored version is not in the list any more'
  636. );
  637. }
  638. /**
  639. * Test whether versions are created when overwriting as owner
  640. */
  641. public function testStoreVersionAsOwner() {
  642. $this->loginAsUser(self::TEST_VERSIONS_USER);
  643. $this->createAndCheckVersions(
  644. \OC\Files\Filesystem::getView(),
  645. 'test.txt'
  646. );
  647. }
  648. /**
  649. * Test whether versions are created when overwriting as share recipient
  650. */
  651. public function testStoreVersionAsRecipient() {
  652. $this->loginAsUser(self::TEST_VERSIONS_USER);
  653. \OC\Files\Filesystem::mkdir('folder');
  654. \OC\Files\Filesystem::file_put_contents('folder/test.txt', 'test file');
  655. $node = \OC::$server->getUserFolder(self::TEST_VERSIONS_USER)->get('folder');
  656. $share = \OC::$server->getShareManager()->newShare();
  657. $share->setNode($node)
  658. ->setShareType(\OCP\Share::SHARE_TYPE_USER)
  659. ->setSharedBy(self::TEST_VERSIONS_USER)
  660. ->setSharedWith(self::TEST_VERSIONS_USER2)
  661. ->setPermissions(\OCP\Constants::PERMISSION_ALL);
  662. $share = \OC::$server->getShareManager()->createShare($share);
  663. \OC::$server->getShareManager()->acceptShare($share, self::TEST_VERSIONS_USER2);
  664. $this->loginAsUser(self::TEST_VERSIONS_USER2);
  665. $this->createAndCheckVersions(
  666. \OC\Files\Filesystem::getView(),
  667. 'folder/test.txt'
  668. );
  669. \OC::$server->getShareManager()->deleteShare($share);
  670. }
  671. /**
  672. * Test whether versions are created when overwriting anonymously.
  673. *
  674. * When uploading through a public link or publicwebdav, no user
  675. * is logged in. File modification must still be able to find
  676. * the owner and create versions.
  677. */
  678. public function testStoreVersionAsAnonymous() {
  679. $this->logout();
  680. // note: public link upload does this,
  681. // needed to make the hooks fire
  682. \OC_Util::setupFS(self::TEST_VERSIONS_USER);
  683. $userView = new \OC\Files\View('/' . self::TEST_VERSIONS_USER . '/files');
  684. $this->createAndCheckVersions(
  685. $userView,
  686. 'test.txt'
  687. );
  688. }
  689. /**
  690. * @param \OC\Files\View $view
  691. * @param string $path
  692. */
  693. private function createAndCheckVersions(\OC\Files\View $view, $path) {
  694. $view->file_put_contents($path, 'test file');
  695. $view->file_put_contents($path, 'version 1');
  696. $view->file_put_contents($path, 'version 2');
  697. $this->loginAsUser(self::TEST_VERSIONS_USER);
  698. // need to scan for the versions
  699. list($rootStorage,) = $this->rootView->resolvePath(self::TEST_VERSIONS_USER . '/files_versions');
  700. $rootStorage->getScanner()->scan('files_versions');
  701. $versions = \OCA\Files_Versions\Storage::getVersions(
  702. self::TEST_VERSIONS_USER, '/' . $path
  703. );
  704. // note: we cannot predict how many versions are created due to
  705. // test run timing
  706. $this->assertGreaterThan(0, count($versions));
  707. return $versions;
  708. }
  709. /**
  710. * @param string $user
  711. * @param bool $create
  712. */
  713. public static function loginHelper($user, $create = false) {
  714. if ($create) {
  715. $backend = new \Test\Util\User\Dummy();
  716. $backend->createUser($user, $user);
  717. \OC::$server->getUserManager()->registerBackend($backend);
  718. }
  719. $storage = new \ReflectionClass('\OCA\Files_Sharing\SharedStorage');
  720. $isInitialized = $storage->getProperty('initialized');
  721. $isInitialized->setAccessible(true);
  722. $isInitialized->setValue($storage, false);
  723. $isInitialized->setAccessible(false);
  724. \OC_Util::tearDownFS();
  725. \OC_User::setUserId('');
  726. \OC\Files\Filesystem::tearDown();
  727. \OC_User::setUserId($user);
  728. \OC_Util::setupFS($user);
  729. \OC::$server->getUserFolder($user);
  730. }
  731. }
  732. // extend the original class to make it possible to test protected methods
  733. class VersionStorageToTest extends \OCA\Files_Versions\Storage {
  734. /**
  735. * @param integer $time
  736. */
  737. public function callProtectedGetExpireList($time, $versions) {
  738. return self::getExpireList($time, $versions);
  739. }
  740. }