testsyncvirtualfiles.cpp 92 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807180818091810181118121813181418151816181718181819182018211822182318241825182618271828182918301831183218331834183518361837183818391840184118421843184418451846184718481849185018511852185318541855185618571858185918601861186218631864186518661867186818691870187118721873187418751876187718781879188018811882188318841885188618871888188918901891189218931894189518961897189818991900190119021903190419051906190719081909191019111912
  1. /*
  2. * This software is in the public domain, furnished "as is", without technical
  3. * support, and with no warranty, express or implied, as to its usefulness for
  4. * any purpose.
  5. *
  6. */
  7. #include <QtTest>
  8. #include "syncenginetestutils.h"
  9. #include "common/vfs.h"
  10. #include "config.h"
  11. #include <syncengine.h>
  12. using namespace OCC;
  13. namespace {
  14. QStringList findCaseClashConflicts(const FileInfo &dir)
  15. {
  16. QStringList conflicts;
  17. for (const auto &item : dir.children) {
  18. if (item.name.contains("(case clash from")) {
  19. conflicts.append(item.path());
  20. }
  21. }
  22. return conflicts;
  23. }
  24. bool expectConflict(FileInfo state, const QString path)
  25. {
  26. PathComponents pathComponents(path);
  27. auto base = state.find(pathComponents.parentDirComponents());
  28. if (!base)
  29. return false;
  30. for (const auto &item : qAsConst(base->children)) {
  31. if (item.name.startsWith(pathComponents.fileName()) && item.name.contains("(case clash from")) {
  32. return true;
  33. }
  34. }
  35. return false;
  36. }
  37. }
  38. #define DVSUFFIX APPLICATION_DOTVIRTUALFILE_SUFFIX
  39. bool itemInstruction(const ItemCompletedSpy &spy, const QString &path, const SyncInstructions instr)
  40. {
  41. auto item = spy.findItem(path);
  42. return item->_instruction == instr;
  43. }
  44. SyncJournalFileRecord dbRecord(FakeFolder &folder, const QString &path)
  45. {
  46. SyncJournalFileRecord record;
  47. [[maybe_unused]] const auto result = folder.syncJournal().getFileRecord(path, &record);
  48. return record;
  49. }
  50. void triggerDownload(FakeFolder &folder, const QByteArray &path)
  51. {
  52. auto &journal = folder.syncJournal();
  53. SyncJournalFileRecord record;
  54. if (!journal.getFileRecord(path + DVSUFFIX, &record) || !record.isValid()) {
  55. return;
  56. }
  57. record._type = ItemTypeVirtualFileDownload;
  58. QVERIFY(journal.setFileRecord(record));
  59. journal.schedulePathForRemoteDiscovery(record._path);
  60. }
  61. void markForDehydration(FakeFolder &folder, const QByteArray &path)
  62. {
  63. auto &journal = folder.syncJournal();
  64. SyncJournalFileRecord record;
  65. if (!journal.getFileRecord(path, &record) || !record.isValid()) {
  66. return;
  67. }
  68. record._type = ItemTypeVirtualFileDehydration;
  69. QVERIFY(journal.setFileRecord(record));
  70. journal.schedulePathForRemoteDiscovery(record._path);
  71. }
  72. QSharedPointer<Vfs> setupVfs(FakeFolder &folder)
  73. {
  74. auto suffixVfs = QSharedPointer<Vfs>(createVfsFromPlugin(Vfs::WithSuffix).release());
  75. folder.switchToVfs(suffixVfs);
  76. // Using this directly doesn't recursively unpin everything and instead leaves
  77. // the files in the hydration that that they start with
  78. folder.syncJournal().internalPinStates().setForPath("", PinState::Unspecified);
  79. return suffixVfs;
  80. }
  81. class TestSyncVirtualFiles : public QObject
  82. {
  83. Q_OBJECT
  84. private slots:
  85. void testVirtualFileLifecycle_data()
  86. {
  87. QTest::addColumn<bool>("doLocalDiscovery");
  88. QTest::newRow("full local discovery") << true;
  89. QTest::newRow("skip local discovery") << false;
  90. }
  91. void testVirtualFileLifecycle()
  92. {
  93. QFETCH(bool, doLocalDiscovery);
  94. FakeFolder fakeFolder{ FileInfo() };
  95. setupVfs(fakeFolder);
  96. QCOMPARE(fakeFolder.currentLocalState(), fakeFolder.currentRemoteState());
  97. ItemCompletedSpy completeSpy(fakeFolder);
  98. auto cleanup = [&]() {
  99. completeSpy.clear();
  100. if (!doLocalDiscovery)
  101. fakeFolder.syncEngine().setLocalDiscoveryOptions(LocalDiscoveryStyle::DatabaseAndFilesystem);
  102. };
  103. cleanup();
  104. // Create a virtual file for a new remote file
  105. fakeFolder.remoteModifier().mkdir("A");
  106. fakeFolder.remoteModifier().insert("A/a1", 64);
  107. auto someDate = QDateTime(QDate(1984, 07, 30), QTime(1,3,2));
  108. fakeFolder.remoteModifier().setModTime("A/a1", someDate);
  109. QVERIFY(fakeFolder.syncOnce());
  110. QVERIFY(!fakeFolder.currentLocalState().find("A/a1"));
  111. QVERIFY(fakeFolder.currentLocalState().find("A/a1" DVSUFFIX));
  112. QCOMPARE(QFileInfo(fakeFolder.localPath() + "A/a1" DVSUFFIX).lastModified(), someDate);
  113. QVERIFY(fakeFolder.currentRemoteState().find("A/a1"));
  114. QVERIFY(itemInstruction(completeSpy, "A/a1" DVSUFFIX, CSYNC_INSTRUCTION_NEW));
  115. QCOMPARE(dbRecord(fakeFolder, "A/a1" DVSUFFIX)._type, ItemTypeVirtualFile);
  116. cleanup();
  117. // Another sync doesn't actually lead to changes
  118. QVERIFY(fakeFolder.syncOnce());
  119. QVERIFY(!fakeFolder.currentLocalState().find("A/a1"));
  120. QVERIFY(fakeFolder.currentLocalState().find("A/a1" DVSUFFIX));
  121. QCOMPARE(QFileInfo(fakeFolder.localPath() + "A/a1" DVSUFFIX).lastModified(), someDate);
  122. QVERIFY(fakeFolder.currentRemoteState().find("A/a1"));
  123. QCOMPARE(dbRecord(fakeFolder, "A/a1" DVSUFFIX)._type, ItemTypeVirtualFile);
  124. QVERIFY(completeSpy.isEmpty());
  125. cleanup();
  126. // Not even when the remote is rediscovered
  127. fakeFolder.syncJournal().forceRemoteDiscoveryNextSync();
  128. QVERIFY(fakeFolder.syncOnce());
  129. QVERIFY(!fakeFolder.currentLocalState().find("A/a1"));
  130. QVERIFY(fakeFolder.currentLocalState().find("A/a1" DVSUFFIX));
  131. QCOMPARE(QFileInfo(fakeFolder.localPath() + "A/a1" DVSUFFIX).lastModified(), someDate);
  132. QVERIFY(fakeFolder.currentRemoteState().find("A/a1"));
  133. QCOMPARE(dbRecord(fakeFolder, "A/a1" DVSUFFIX)._type, ItemTypeVirtualFile);
  134. QVERIFY(completeSpy.isEmpty());
  135. cleanup();
  136. // Neither does a remote change
  137. fakeFolder.remoteModifier().appendByte("A/a1");
  138. QVERIFY(fakeFolder.syncOnce());
  139. QVERIFY(!fakeFolder.currentLocalState().find("A/a1"));
  140. QVERIFY(fakeFolder.currentLocalState().find("A/a1" DVSUFFIX));
  141. QVERIFY(fakeFolder.currentRemoteState().find("A/a1"));
  142. QVERIFY(itemInstruction(completeSpy, "A/a1" DVSUFFIX, CSYNC_INSTRUCTION_UPDATE_METADATA));
  143. QCOMPARE(dbRecord(fakeFolder, "A/a1" DVSUFFIX)._type, ItemTypeVirtualFile);
  144. QCOMPARE(dbRecord(fakeFolder, "A/a1" DVSUFFIX)._fileSize, 65);
  145. cleanup();
  146. // If the local virtual file file is removed, it'll just be recreated
  147. if (!doLocalDiscovery)
  148. fakeFolder.syncEngine().setLocalDiscoveryOptions(LocalDiscoveryStyle::DatabaseAndFilesystem, { "A" });
  149. fakeFolder.localModifier().remove("A/a1" DVSUFFIX);
  150. QVERIFY(fakeFolder.syncOnce());
  151. QVERIFY(!fakeFolder.currentLocalState().find("A/a1"));
  152. QVERIFY(fakeFolder.currentLocalState().find("A/a1" DVSUFFIX));
  153. QVERIFY(fakeFolder.currentRemoteState().find("A/a1"));
  154. QVERIFY(itemInstruction(completeSpy, "A/a1" DVSUFFIX, CSYNC_INSTRUCTION_NEW));
  155. QCOMPARE(dbRecord(fakeFolder, "A/a1" DVSUFFIX)._type, ItemTypeVirtualFile);
  156. QCOMPARE(dbRecord(fakeFolder, "A/a1" DVSUFFIX)._fileSize, 65);
  157. cleanup();
  158. // Remote rename is propagated
  159. fakeFolder.remoteModifier().rename("A/a1", "A/a1m");
  160. QVERIFY(fakeFolder.syncOnce());
  161. QVERIFY(!fakeFolder.currentLocalState().find("A/a1"));
  162. QVERIFY(!fakeFolder.currentLocalState().find("A/a1m"));
  163. QVERIFY(!fakeFolder.currentLocalState().find("A/a1" DVSUFFIX));
  164. QVERIFY(fakeFolder.currentLocalState().find("A/a1m" DVSUFFIX));
  165. QVERIFY(!fakeFolder.currentRemoteState().find("A/a1"));
  166. QVERIFY(fakeFolder.currentRemoteState().find("A/a1m"));
  167. QVERIFY(
  168. itemInstruction(completeSpy, "A/a1m" DVSUFFIX, CSYNC_INSTRUCTION_RENAME)
  169. || (itemInstruction(completeSpy, "A/a1m" DVSUFFIX, CSYNC_INSTRUCTION_NEW)
  170. && itemInstruction(completeSpy, "A/a1" DVSUFFIX, CSYNC_INSTRUCTION_REMOVE)));
  171. QCOMPARE(dbRecord(fakeFolder, "A/a1m" DVSUFFIX)._type, ItemTypeVirtualFile);
  172. cleanup();
  173. // Remote remove is propagated
  174. fakeFolder.remoteModifier().remove("A/a1m");
  175. QVERIFY(fakeFolder.syncOnce());
  176. QVERIFY(!fakeFolder.currentLocalState().find("A/a1m" DVSUFFIX));
  177. QVERIFY(!fakeFolder.currentRemoteState().find("A/a1m"));
  178. QVERIFY(itemInstruction(completeSpy, "A/a1m" DVSUFFIX, CSYNC_INSTRUCTION_REMOVE));
  179. QVERIFY(!dbRecord(fakeFolder, "A/a1" DVSUFFIX).isValid());
  180. QVERIFY(!dbRecord(fakeFolder, "A/a1m" DVSUFFIX).isValid());
  181. cleanup();
  182. // Edge case: Local virtual file but no db entry for some reason
  183. fakeFolder.remoteModifier().insert("A/a2", 64);
  184. fakeFolder.remoteModifier().insert("A/a3", 64);
  185. QVERIFY(fakeFolder.syncOnce());
  186. QVERIFY(fakeFolder.currentLocalState().find("A/a2" DVSUFFIX));
  187. QVERIFY(fakeFolder.currentLocalState().find("A/a3" DVSUFFIX));
  188. cleanup();
  189. QVERIFY(fakeFolder.syncEngine().journal()->deleteFileRecord("A/a2" DVSUFFIX));
  190. QVERIFY(fakeFolder.syncEngine().journal()->deleteFileRecord("A/a3" DVSUFFIX));
  191. fakeFolder.remoteModifier().remove("A/a3");
  192. fakeFolder.syncEngine().setLocalDiscoveryOptions(LocalDiscoveryStyle::FilesystemOnly);
  193. QVERIFY(fakeFolder.syncOnce());
  194. QVERIFY(fakeFolder.currentLocalState().find("A/a2" DVSUFFIX));
  195. QVERIFY(itemInstruction(completeSpy, "A/a2" DVSUFFIX, CSYNC_INSTRUCTION_UPDATE_METADATA));
  196. QVERIFY(dbRecord(fakeFolder, "A/a2" DVSUFFIX).isValid());
  197. QVERIFY(!fakeFolder.currentLocalState().find("A/a3" DVSUFFIX));
  198. QVERIFY(itemInstruction(completeSpy, "A/a3" DVSUFFIX, CSYNC_INSTRUCTION_REMOVE));
  199. QVERIFY(!dbRecord(fakeFolder, "A/a3" DVSUFFIX).isValid());
  200. cleanup();
  201. }
  202. void testVirtualFileConflict()
  203. {
  204. FakeFolder fakeFolder{ FileInfo() };
  205. setupVfs(fakeFolder);
  206. QCOMPARE(fakeFolder.currentLocalState(), fakeFolder.currentRemoteState());
  207. ItemCompletedSpy completeSpy(fakeFolder);
  208. auto cleanup = [&]() {
  209. completeSpy.clear();
  210. };
  211. cleanup();
  212. // Create a virtual file for a new remote file
  213. fakeFolder.remoteModifier().mkdir("A");
  214. fakeFolder.remoteModifier().insert("A/a1", 64);
  215. fakeFolder.remoteModifier().insert("A/a2", 64);
  216. fakeFolder.remoteModifier().mkdir("B");
  217. fakeFolder.remoteModifier().insert("B/b1", 64);
  218. fakeFolder.remoteModifier().insert("B/b2", 64);
  219. fakeFolder.remoteModifier().mkdir("C");
  220. fakeFolder.remoteModifier().insert("C/c1", 64);
  221. QVERIFY(fakeFolder.syncOnce());
  222. QVERIFY(fakeFolder.currentLocalState().find("A/a1" DVSUFFIX));
  223. QVERIFY(fakeFolder.currentLocalState().find("B/b2" DVSUFFIX));
  224. cleanup();
  225. // A: the correct file and a conflicting file are added, virtual files stay
  226. // B: same setup, but the virtual files are deleted by the user
  227. // C: user adds a *directory* locally
  228. fakeFolder.localModifier().insert("A/a1", 64);
  229. fakeFolder.localModifier().insert("A/a2", 30);
  230. fakeFolder.localModifier().insert("B/b1", 64);
  231. fakeFolder.localModifier().insert("B/b2", 30);
  232. fakeFolder.localModifier().remove("B/b1" DVSUFFIX);
  233. fakeFolder.localModifier().remove("B/b2" DVSUFFIX);
  234. fakeFolder.localModifier().mkdir("C/c1");
  235. fakeFolder.localModifier().insert("C/c1/foo");
  236. QVERIFY(fakeFolder.syncOnce());
  237. // Everything is CONFLICT since mtimes are different even for a1/b1
  238. QVERIFY(itemInstruction(completeSpy, "A/a1", CSYNC_INSTRUCTION_CONFLICT));
  239. QVERIFY(itemInstruction(completeSpy, "A/a2", CSYNC_INSTRUCTION_CONFLICT));
  240. QVERIFY(itemInstruction(completeSpy, "B/b1", CSYNC_INSTRUCTION_CONFLICT));
  241. QVERIFY(itemInstruction(completeSpy, "B/b2", CSYNC_INSTRUCTION_CONFLICT));
  242. QVERIFY(itemInstruction(completeSpy, "C/c1", CSYNC_INSTRUCTION_CONFLICT));
  243. // no virtual file files should remain
  244. QVERIFY(!fakeFolder.currentLocalState().find("A/a1" DVSUFFIX));
  245. QVERIFY(!fakeFolder.currentLocalState().find("A/a2" DVSUFFIX));
  246. QVERIFY(!fakeFolder.currentLocalState().find("B/b1" DVSUFFIX));
  247. QVERIFY(!fakeFolder.currentLocalState().find("B/b2" DVSUFFIX));
  248. QVERIFY(!fakeFolder.currentLocalState().find("C/c1" DVSUFFIX));
  249. // conflict files should exist
  250. QCOMPARE(fakeFolder.syncJournal().conflictRecordPaths().size(), 3);
  251. // nothing should have the virtual file tag
  252. QCOMPARE(dbRecord(fakeFolder, "A/a1")._type, ItemTypeFile);
  253. QCOMPARE(dbRecord(fakeFolder, "A/a2")._type, ItemTypeFile);
  254. QCOMPARE(dbRecord(fakeFolder, "B/b1")._type, ItemTypeFile);
  255. QCOMPARE(dbRecord(fakeFolder, "B/b2")._type, ItemTypeFile);
  256. QCOMPARE(dbRecord(fakeFolder, "C/c1")._type, ItemTypeFile);
  257. QVERIFY(!dbRecord(fakeFolder, "A/a1" DVSUFFIX).isValid());
  258. QVERIFY(!dbRecord(fakeFolder, "A/a2" DVSUFFIX).isValid());
  259. QVERIFY(!dbRecord(fakeFolder, "B/b1" DVSUFFIX).isValid());
  260. QVERIFY(!dbRecord(fakeFolder, "B/b2" DVSUFFIX).isValid());
  261. QVERIFY(!dbRecord(fakeFolder, "C/c1" DVSUFFIX).isValid());
  262. cleanup();
  263. }
  264. void testWithNormalSync()
  265. {
  266. FakeFolder fakeFolder{ FileInfo::A12_B12_C12_S12() };
  267. setupVfs(fakeFolder);
  268. QCOMPARE(fakeFolder.currentLocalState(), fakeFolder.currentRemoteState());
  269. ItemCompletedSpy completeSpy(fakeFolder);
  270. auto cleanup = [&]() {
  271. completeSpy.clear();
  272. };
  273. cleanup();
  274. // No effect sync
  275. QVERIFY(fakeFolder.syncOnce());
  276. QCOMPARE(fakeFolder.currentLocalState(), fakeFolder.currentRemoteState());
  277. cleanup();
  278. // Existing files are propagated just fine in both directions
  279. fakeFolder.localModifier().appendByte("A/a1");
  280. fakeFolder.localModifier().insert("A/a3");
  281. fakeFolder.remoteModifier().appendByte("A/a2");
  282. QVERIFY(fakeFolder.syncOnce());
  283. QCOMPARE(fakeFolder.currentLocalState(), fakeFolder.currentRemoteState());
  284. cleanup();
  285. // New files on the remote create virtual files
  286. fakeFolder.remoteModifier().insert("A/new");
  287. QVERIFY(fakeFolder.syncOnce());
  288. QVERIFY(!fakeFolder.currentLocalState().find("A/new"));
  289. QVERIFY(fakeFolder.currentLocalState().find("A/new" DVSUFFIX));
  290. QVERIFY(fakeFolder.currentRemoteState().find("A/new"));
  291. QVERIFY(itemInstruction(completeSpy, "A/new" DVSUFFIX, CSYNC_INSTRUCTION_NEW));
  292. QCOMPARE(dbRecord(fakeFolder, "A/new" DVSUFFIX)._type, ItemTypeVirtualFile);
  293. cleanup();
  294. }
  295. void testVirtualFileDownload()
  296. {
  297. FakeFolder fakeFolder{ FileInfo() };
  298. setupVfs(fakeFolder);
  299. QCOMPARE(fakeFolder.currentLocalState(), fakeFolder.currentRemoteState());
  300. ItemCompletedSpy completeSpy(fakeFolder);
  301. auto cleanup = [&]() {
  302. completeSpy.clear();
  303. };
  304. cleanup();
  305. // Create a virtual file for remote files
  306. fakeFolder.remoteModifier().mkdir("A");
  307. fakeFolder.remoteModifier().insert("A/a1");
  308. fakeFolder.remoteModifier().insert("A/a2");
  309. fakeFolder.remoteModifier().insert("A/a3");
  310. fakeFolder.remoteModifier().insert("A/a4");
  311. fakeFolder.remoteModifier().insert("A/a5");
  312. fakeFolder.remoteModifier().insert("A/a6");
  313. fakeFolder.remoteModifier().insert("A/a7");
  314. fakeFolder.remoteModifier().insert("A/b1");
  315. fakeFolder.remoteModifier().insert("A/b2");
  316. fakeFolder.remoteModifier().insert("A/b3");
  317. fakeFolder.remoteModifier().insert("A/b4");
  318. QVERIFY(fakeFolder.syncOnce());
  319. QVERIFY(fakeFolder.currentLocalState().find("A/a1" DVSUFFIX));
  320. QVERIFY(fakeFolder.currentLocalState().find("A/a2" DVSUFFIX));
  321. QVERIFY(fakeFolder.currentLocalState().find("A/a3" DVSUFFIX));
  322. QVERIFY(fakeFolder.currentLocalState().find("A/a4" DVSUFFIX));
  323. QVERIFY(fakeFolder.currentLocalState().find("A/a5" DVSUFFIX));
  324. QVERIFY(fakeFolder.currentLocalState().find("A/a6" DVSUFFIX));
  325. QVERIFY(fakeFolder.currentLocalState().find("A/a7" DVSUFFIX));
  326. QVERIFY(fakeFolder.currentLocalState().find("A/b1" DVSUFFIX));
  327. QVERIFY(fakeFolder.currentLocalState().find("A/b2" DVSUFFIX));
  328. QVERIFY(fakeFolder.currentLocalState().find("A/b3" DVSUFFIX));
  329. QVERIFY(fakeFolder.currentLocalState().find("A/b4" DVSUFFIX));
  330. cleanup();
  331. // Download by changing the db entry
  332. triggerDownload(fakeFolder, "A/a1");
  333. triggerDownload(fakeFolder, "A/a2");
  334. triggerDownload(fakeFolder, "A/a3");
  335. triggerDownload(fakeFolder, "A/a4");
  336. triggerDownload(fakeFolder, "A/a5");
  337. triggerDownload(fakeFolder, "A/a6");
  338. triggerDownload(fakeFolder, "A/a7");
  339. // Download by renaming locally
  340. fakeFolder.localModifier().rename("A/b1" DVSUFFIX, "A/b1");
  341. fakeFolder.localModifier().rename("A/b2" DVSUFFIX, "A/b2");
  342. fakeFolder.localModifier().rename("A/b3" DVSUFFIX, "A/b3");
  343. fakeFolder.localModifier().rename("A/b4" DVSUFFIX, "A/b4");
  344. // Remote complications
  345. fakeFolder.remoteModifier().appendByte("A/a2");
  346. fakeFolder.remoteModifier().remove("A/a3");
  347. fakeFolder.remoteModifier().rename("A/a4", "A/a4m");
  348. fakeFolder.remoteModifier().appendByte("A/b2");
  349. fakeFolder.remoteModifier().remove("A/b3");
  350. fakeFolder.remoteModifier().rename("A/b4", "A/b4m");
  351. // Local complications
  352. fakeFolder.localModifier().insert("A/a5");
  353. fakeFolder.localModifier().insert("A/a6");
  354. fakeFolder.localModifier().remove("A/a6" DVSUFFIX);
  355. fakeFolder.localModifier().rename("A/a7" DVSUFFIX, "A/a7");
  356. QVERIFY(fakeFolder.syncOnce());
  357. QVERIFY(itemInstruction(completeSpy, "A/a1", CSYNC_INSTRUCTION_SYNC));
  358. QCOMPARE(completeSpy.findItem("A/a1")->_type, ItemTypeVirtualFileDownload);
  359. QVERIFY(itemInstruction(completeSpy, "A/a1" DVSUFFIX, CSYNC_INSTRUCTION_NONE));
  360. QVERIFY(itemInstruction(completeSpy, "A/a2", CSYNC_INSTRUCTION_SYNC));
  361. QCOMPARE(completeSpy.findItem("A/a2")->_type, ItemTypeVirtualFileDownload);
  362. QVERIFY(itemInstruction(completeSpy, "A/a2" DVSUFFIX, CSYNC_INSTRUCTION_NONE));
  363. QVERIFY(itemInstruction(completeSpy, "A/a3" DVSUFFIX, CSYNC_INSTRUCTION_REMOVE));
  364. QVERIFY(itemInstruction(completeSpy, "A/a4m", CSYNC_INSTRUCTION_NEW));
  365. QVERIFY(itemInstruction(completeSpy, "A/a4" DVSUFFIX, CSYNC_INSTRUCTION_REMOVE));
  366. QVERIFY(itemInstruction(completeSpy, "A/a5", CSYNC_INSTRUCTION_CONFLICT));
  367. QVERIFY(itemInstruction(completeSpy, "A/a5" DVSUFFIX, CSYNC_INSTRUCTION_REMOVE));
  368. QVERIFY(itemInstruction(completeSpy, "A/a6", CSYNC_INSTRUCTION_CONFLICT));
  369. QVERIFY(itemInstruction(completeSpy, "A/a7", CSYNC_INSTRUCTION_SYNC));
  370. QVERIFY(itemInstruction(completeSpy, "A/b1", CSYNC_INSTRUCTION_SYNC));
  371. QVERIFY(itemInstruction(completeSpy, "A/b2", CSYNC_INSTRUCTION_SYNC));
  372. QVERIFY(itemInstruction(completeSpy, "A/b3", CSYNC_INSTRUCTION_REMOVE));
  373. QVERIFY(itemInstruction(completeSpy, "A/b4m" DVSUFFIX, CSYNC_INSTRUCTION_NEW));
  374. QVERIFY(itemInstruction(completeSpy, "A/b4", CSYNC_INSTRUCTION_REMOVE));
  375. QCOMPARE(dbRecord(fakeFolder, "A/a1")._type, ItemTypeFile);
  376. QVERIFY(!dbRecord(fakeFolder, "A/a1" DVSUFFIX).isValid());
  377. QCOMPARE(dbRecord(fakeFolder, "A/a2")._type, ItemTypeFile);
  378. QVERIFY(!dbRecord(fakeFolder, "A/a3").isValid());
  379. QCOMPARE(dbRecord(fakeFolder, "A/a4m")._type, ItemTypeFile);
  380. QCOMPARE(dbRecord(fakeFolder, "A/a5")._type, ItemTypeFile);
  381. QCOMPARE(dbRecord(fakeFolder, "A/a6")._type, ItemTypeFile);
  382. QCOMPARE(dbRecord(fakeFolder, "A/a7")._type, ItemTypeFile);
  383. QCOMPARE(dbRecord(fakeFolder, "A/b1")._type, ItemTypeFile);
  384. QVERIFY(!dbRecord(fakeFolder, "A/b1" DVSUFFIX).isValid());
  385. QCOMPARE(dbRecord(fakeFolder, "A/b2")._type, ItemTypeFile);
  386. QVERIFY(!dbRecord(fakeFolder, "A/b3").isValid());
  387. QCOMPARE(dbRecord(fakeFolder, "A/b4m" DVSUFFIX)._type, ItemTypeVirtualFile);
  388. QVERIFY(!dbRecord(fakeFolder, "A/a1" DVSUFFIX).isValid());
  389. QVERIFY(!dbRecord(fakeFolder, "A/a2" DVSUFFIX).isValid());
  390. QVERIFY(!dbRecord(fakeFolder, "A/a3" DVSUFFIX).isValid());
  391. QVERIFY(!dbRecord(fakeFolder, "A/a4" DVSUFFIX).isValid());
  392. QVERIFY(!dbRecord(fakeFolder, "A/a5" DVSUFFIX).isValid());
  393. QVERIFY(!dbRecord(fakeFolder, "A/a6" DVSUFFIX).isValid());
  394. QVERIFY(!dbRecord(fakeFolder, "A/a7" DVSUFFIX).isValid());
  395. QVERIFY(!dbRecord(fakeFolder, "A/b1" DVSUFFIX).isValid());
  396. QVERIFY(!dbRecord(fakeFolder, "A/b2" DVSUFFIX).isValid());
  397. QVERIFY(!dbRecord(fakeFolder, "A/b3" DVSUFFIX).isValid());
  398. QVERIFY(!dbRecord(fakeFolder, "A/b4" DVSUFFIX).isValid());
  399. triggerDownload(fakeFolder, "A/b4m");
  400. QVERIFY(fakeFolder.syncOnce());
  401. QCOMPARE(fakeFolder.currentLocalState(), fakeFolder.currentRemoteState());
  402. }
  403. void testVirtualFileDownloadResume()
  404. {
  405. FakeFolder fakeFolder{ FileInfo() };
  406. setupVfs(fakeFolder);
  407. QCOMPARE(fakeFolder.currentLocalState(), fakeFolder.currentRemoteState());
  408. ItemCompletedSpy completeSpy(fakeFolder);
  409. auto cleanup = [&]() {
  410. completeSpy.clear();
  411. QVERIFY(fakeFolder.syncJournal().wipeErrorBlacklist() != -1);
  412. };
  413. cleanup();
  414. // Create a virtual file for remote files
  415. fakeFolder.remoteModifier().mkdir("A");
  416. fakeFolder.remoteModifier().insert("A/a1");
  417. QVERIFY(fakeFolder.syncOnce());
  418. QVERIFY(fakeFolder.currentLocalState().find("A/a1" DVSUFFIX));
  419. cleanup();
  420. // Download by changing the db entry
  421. triggerDownload(fakeFolder, "A/a1");
  422. fakeFolder.serverErrorPaths().append("A/a1", 500);
  423. QVERIFY(!fakeFolder.syncOnce());
  424. QVERIFY(itemInstruction(completeSpy, "A/a1", CSYNC_INSTRUCTION_SYNC));
  425. QVERIFY(itemInstruction(completeSpy, "A/a1" DVSUFFIX, CSYNC_INSTRUCTION_NONE));
  426. QVERIFY(fakeFolder.currentLocalState().find("A/a1" DVSUFFIX));
  427. QVERIFY(!fakeFolder.currentLocalState().find("A/a1"));
  428. QCOMPARE(dbRecord(fakeFolder, "A/a1" DVSUFFIX)._type, ItemTypeVirtualFileDownload);
  429. QVERIFY(!dbRecord(fakeFolder, "A/a1").isValid());
  430. cleanup();
  431. fakeFolder.serverErrorPaths().clear();
  432. QVERIFY(fakeFolder.syncOnce());
  433. QVERIFY(itemInstruction(completeSpy, "A/a1", CSYNC_INSTRUCTION_SYNC));
  434. QVERIFY(itemInstruction(completeSpy, "A/a1" DVSUFFIX, CSYNC_INSTRUCTION_NONE));
  435. QCOMPARE(fakeFolder.currentLocalState(), fakeFolder.currentRemoteState());
  436. QCOMPARE(dbRecord(fakeFolder, "A/a1")._type, ItemTypeFile);
  437. QVERIFY(!dbRecord(fakeFolder, "A/a1" DVSUFFIX).isValid());
  438. }
  439. void testNewFilesNotVirtual()
  440. {
  441. FakeFolder fakeFolder{ FileInfo() };
  442. setupVfs(fakeFolder);
  443. QCOMPARE(fakeFolder.currentLocalState(), fakeFolder.currentRemoteState());
  444. fakeFolder.remoteModifier().mkdir("A");
  445. fakeFolder.remoteModifier().insert("A/a1");
  446. QVERIFY(fakeFolder.syncOnce());
  447. QVERIFY(fakeFolder.currentLocalState().find("A/a1" DVSUFFIX));
  448. fakeFolder.syncJournal().internalPinStates().setForPath("", PinState::AlwaysLocal);
  449. // Create a new remote file, it'll not be virtual
  450. fakeFolder.remoteModifier().insert("A/a2");
  451. QVERIFY(fakeFolder.syncOnce());
  452. QVERIFY(fakeFolder.currentLocalState().find("A/a2"));
  453. QVERIFY(!fakeFolder.currentLocalState().find("A/a2" DVSUFFIX));
  454. }
  455. void testDownloadRecursive()
  456. {
  457. FakeFolder fakeFolder{ FileInfo() };
  458. setupVfs(fakeFolder);
  459. QCOMPARE(fakeFolder.currentLocalState(), fakeFolder.currentRemoteState());
  460. // Create a virtual file for remote files
  461. fakeFolder.remoteModifier().mkdir("A");
  462. fakeFolder.remoteModifier().mkdir("A/Sub");
  463. fakeFolder.remoteModifier().mkdir("A/Sub/SubSub");
  464. fakeFolder.remoteModifier().mkdir("A/Sub2");
  465. fakeFolder.remoteModifier().mkdir("B");
  466. fakeFolder.remoteModifier().mkdir("B/Sub");
  467. fakeFolder.remoteModifier().insert("A/a1");
  468. fakeFolder.remoteModifier().insert("A/a2");
  469. fakeFolder.remoteModifier().insert("A/Sub/a3");
  470. fakeFolder.remoteModifier().insert("A/Sub/a4");
  471. fakeFolder.remoteModifier().insert("A/Sub/SubSub/a5");
  472. fakeFolder.remoteModifier().insert("A/Sub2/a6");
  473. fakeFolder.remoteModifier().insert("B/b1");
  474. fakeFolder.remoteModifier().insert("B/Sub/b2");
  475. QVERIFY(fakeFolder.syncOnce());
  476. QVERIFY(fakeFolder.currentLocalState().find("A/a1" DVSUFFIX));
  477. QVERIFY(fakeFolder.currentLocalState().find("A/a2" DVSUFFIX));
  478. QVERIFY(fakeFolder.currentLocalState().find("A/Sub/a3" DVSUFFIX));
  479. QVERIFY(fakeFolder.currentLocalState().find("A/Sub/a4" DVSUFFIX));
  480. QVERIFY(fakeFolder.currentLocalState().find("A/Sub/SubSub/a5" DVSUFFIX));
  481. QVERIFY(fakeFolder.currentLocalState().find("A/Sub2/a6" DVSUFFIX));
  482. QVERIFY(fakeFolder.currentLocalState().find("B/b1" DVSUFFIX));
  483. QVERIFY(fakeFolder.currentLocalState().find("B/Sub/b2" DVSUFFIX));
  484. QVERIFY(!fakeFolder.currentLocalState().find("A/a1"));
  485. QVERIFY(!fakeFolder.currentLocalState().find("A/a2"));
  486. QVERIFY(!fakeFolder.currentLocalState().find("A/Sub/a3"));
  487. QVERIFY(!fakeFolder.currentLocalState().find("A/Sub/a4"));
  488. QVERIFY(!fakeFolder.currentLocalState().find("A/Sub/SubSub/a5"));
  489. QVERIFY(!fakeFolder.currentLocalState().find("A/Sub2/a6"));
  490. QVERIFY(!fakeFolder.currentLocalState().find("B/b1"));
  491. QVERIFY(!fakeFolder.currentLocalState().find("B/Sub/b2"));
  492. // Download All file in the directory A/Sub
  493. // (as in Folder::downloadVirtualFile)
  494. fakeFolder.syncJournal().markVirtualFileForDownloadRecursively("A/Sub");
  495. QVERIFY(fakeFolder.syncOnce());
  496. QVERIFY(fakeFolder.currentLocalState().find("A/a1" DVSUFFIX));
  497. QVERIFY(fakeFolder.currentLocalState().find("A/a2" DVSUFFIX));
  498. QVERIFY(!fakeFolder.currentLocalState().find("A/Sub/a3" DVSUFFIX));
  499. QVERIFY(!fakeFolder.currentLocalState().find("A/Sub/a4" DVSUFFIX));
  500. QVERIFY(!fakeFolder.currentLocalState().find("A/Sub/SubSub/a5" DVSUFFIX));
  501. QVERIFY(fakeFolder.currentLocalState().find("A/Sub2/a6" DVSUFFIX));
  502. QVERIFY(fakeFolder.currentLocalState().find("B/b1" DVSUFFIX));
  503. QVERIFY(fakeFolder.currentLocalState().find("B/Sub/b2" DVSUFFIX));
  504. QVERIFY(!fakeFolder.currentLocalState().find("A/a1"));
  505. QVERIFY(!fakeFolder.currentLocalState().find("A/a2"));
  506. QVERIFY(fakeFolder.currentLocalState().find("A/Sub/a3"));
  507. QVERIFY(fakeFolder.currentLocalState().find("A/Sub/a4"));
  508. QVERIFY(fakeFolder.currentLocalState().find("A/Sub/SubSub/a5"));
  509. QVERIFY(!fakeFolder.currentLocalState().find("A/Sub2/a6"));
  510. QVERIFY(!fakeFolder.currentLocalState().find("B/b1"));
  511. QVERIFY(!fakeFolder.currentLocalState().find("B/Sub/b2"));
  512. // Add a file in a subfolder that was downloaded
  513. // Currently, this continue to add it as a virtual file.
  514. fakeFolder.remoteModifier().insert("A/Sub/SubSub/a7");
  515. QVERIFY(fakeFolder.syncOnce());
  516. QVERIFY(fakeFolder.currentLocalState().find("A/Sub/SubSub/a7" DVSUFFIX));
  517. QVERIFY(!fakeFolder.currentLocalState().find("A/Sub/SubSub/a7"));
  518. // Now download all files in "A"
  519. fakeFolder.syncJournal().markVirtualFileForDownloadRecursively("A");
  520. QVERIFY(fakeFolder.syncOnce());
  521. QVERIFY(!fakeFolder.currentLocalState().find("A/a1" DVSUFFIX));
  522. QVERIFY(!fakeFolder.currentLocalState().find("A/a2" DVSUFFIX));
  523. QVERIFY(!fakeFolder.currentLocalState().find("A/Sub/a3" DVSUFFIX));
  524. QVERIFY(!fakeFolder.currentLocalState().find("A/Sub/a4" DVSUFFIX));
  525. QVERIFY(!fakeFolder.currentLocalState().find("A/Sub/SubSub/a5" DVSUFFIX));
  526. QVERIFY(!fakeFolder.currentLocalState().find("A/Sub2/a6" DVSUFFIX));
  527. QVERIFY(!fakeFolder.currentLocalState().find("A/Sub/SubSub/a7" DVSUFFIX));
  528. QVERIFY(fakeFolder.currentLocalState().find("B/b1" DVSUFFIX));
  529. QVERIFY(fakeFolder.currentLocalState().find("B/Sub/b2" DVSUFFIX));
  530. QVERIFY(fakeFolder.currentLocalState().find("A/a1"));
  531. QVERIFY(fakeFolder.currentLocalState().find("A/a2"));
  532. QVERIFY(fakeFolder.currentLocalState().find("A/Sub/a3"));
  533. QVERIFY(fakeFolder.currentLocalState().find("A/Sub/a4"));
  534. QVERIFY(fakeFolder.currentLocalState().find("A/Sub/SubSub/a5"));
  535. QVERIFY(fakeFolder.currentLocalState().find("A/Sub2/a6"));
  536. QVERIFY(fakeFolder.currentLocalState().find("A/Sub/SubSub/a7"));
  537. QVERIFY(!fakeFolder.currentLocalState().find("B/b1"));
  538. QVERIFY(!fakeFolder.currentLocalState().find("B/Sub/b2"));
  539. // Now download remaining files in "B"
  540. fakeFolder.syncJournal().markVirtualFileForDownloadRecursively("B");
  541. QVERIFY(fakeFolder.syncOnce());
  542. QCOMPARE(fakeFolder.currentLocalState(), fakeFolder.currentRemoteState());
  543. }
  544. void testRenameToVirtual()
  545. {
  546. FakeFolder fakeFolder{ FileInfo::A12_B12_C12_S12() };
  547. setupVfs(fakeFolder);
  548. QCOMPARE(fakeFolder.currentLocalState(), fakeFolder.currentRemoteState());
  549. ItemCompletedSpy completeSpy(fakeFolder);
  550. auto cleanup = [&]() {
  551. completeSpy.clear();
  552. };
  553. cleanup();
  554. // If a file is renamed to <name>.owncloud, it becomes virtual
  555. fakeFolder.localModifier().rename("A/a1", "A/a1" DVSUFFIX);
  556. // If a file is renamed to <random>.owncloud, the rename propagates but the
  557. // file isn't made virtual the first sync run.
  558. fakeFolder.localModifier().rename("A/a2", "A/rand" DVSUFFIX);
  559. // dangling virtual files are removed
  560. fakeFolder.localModifier().insert("A/dangling" DVSUFFIX, 1, ' ');
  561. QVERIFY(fakeFolder.syncOnce());
  562. QVERIFY(!fakeFolder.currentLocalState().find("A/a1"));
  563. QVERIFY(fakeFolder.currentLocalState().find("A/a1" DVSUFFIX));
  564. QVERIFY(fakeFolder.currentLocalState().find("A/a1" DVSUFFIX)->size <= 1);
  565. QVERIFY(fakeFolder.currentRemoteState().find("A/a1"));
  566. QVERIFY(itemInstruction(completeSpy, "A/a1" DVSUFFIX, CSYNC_INSTRUCTION_SYNC));
  567. QCOMPARE(dbRecord(fakeFolder, "A/a1" DVSUFFIX)._type, ItemTypeVirtualFile);
  568. QVERIFY(!dbRecord(fakeFolder, "A/a1").isValid());
  569. QVERIFY(!fakeFolder.currentLocalState().find("A/a2"));
  570. QVERIFY(!fakeFolder.currentLocalState().find("A/a2" DVSUFFIX));
  571. QVERIFY(fakeFolder.currentLocalState().find("A/rand"));
  572. QVERIFY(!fakeFolder.currentRemoteState().find("A/a2"));
  573. QVERIFY(fakeFolder.currentRemoteState().find("A/rand"));
  574. QVERIFY(itemInstruction(completeSpy, "A/rand", CSYNC_INSTRUCTION_RENAME));
  575. QVERIFY(dbRecord(fakeFolder, "A/rand")._type == ItemTypeFile);
  576. QVERIFY(!fakeFolder.currentLocalState().find("A/dangling" DVSUFFIX));
  577. cleanup();
  578. }
  579. void testRenameVirtual()
  580. {
  581. FakeFolder fakeFolder{ FileInfo() };
  582. setupVfs(fakeFolder);
  583. QCOMPARE(fakeFolder.currentLocalState(), fakeFolder.currentRemoteState());
  584. ItemCompletedSpy completeSpy(fakeFolder);
  585. auto cleanup = [&]() {
  586. completeSpy.clear();
  587. };
  588. cleanup();
  589. fakeFolder.remoteModifier().insert("file1", 128, 'C');
  590. fakeFolder.remoteModifier().insert("file2", 256, 'C');
  591. fakeFolder.remoteModifier().insert("file3", 256, 'C');
  592. QVERIFY(fakeFolder.syncOnce());
  593. QVERIFY(fakeFolder.currentLocalState().find("file1" DVSUFFIX));
  594. QVERIFY(fakeFolder.currentLocalState().find("file2" DVSUFFIX));
  595. QVERIFY(fakeFolder.currentLocalState().find("file3" DVSUFFIX));
  596. cleanup();
  597. fakeFolder.localModifier().rename("file1" DVSUFFIX, "renamed1" DVSUFFIX);
  598. fakeFolder.localModifier().rename("file2" DVSUFFIX, "renamed2" DVSUFFIX);
  599. triggerDownload(fakeFolder, "file2");
  600. triggerDownload(fakeFolder, "file3");
  601. QVERIFY(fakeFolder.syncOnce());
  602. QVERIFY(!fakeFolder.currentLocalState().find("file1" DVSUFFIX));
  603. QVERIFY(fakeFolder.currentLocalState().find("renamed1" DVSUFFIX));
  604. QVERIFY(!fakeFolder.currentRemoteState().find("file1"));
  605. QVERIFY(fakeFolder.currentRemoteState().find("renamed1"));
  606. QVERIFY(itemInstruction(completeSpy, "renamed1" DVSUFFIX, CSYNC_INSTRUCTION_RENAME));
  607. QVERIFY(dbRecord(fakeFolder, "renamed1" DVSUFFIX).isValid());
  608. // file2 has a conflict between the download request and the rename:
  609. // the rename wins, the download is ignored
  610. QVERIFY(!fakeFolder.currentLocalState().find("file2"));
  611. QVERIFY(!fakeFolder.currentLocalState().find("file2" DVSUFFIX));
  612. QVERIFY(fakeFolder.currentLocalState().find("renamed2" DVSUFFIX));
  613. QVERIFY(fakeFolder.currentRemoteState().find("renamed2"));
  614. QVERIFY(itemInstruction(completeSpy, "renamed2" DVSUFFIX, CSYNC_INSTRUCTION_RENAME));
  615. QVERIFY(dbRecord(fakeFolder, "renamed2" DVSUFFIX)._type == ItemTypeVirtualFile);
  616. QVERIFY(itemInstruction(completeSpy, "file3", CSYNC_INSTRUCTION_SYNC));
  617. QVERIFY(dbRecord(fakeFolder, "file3")._type == ItemTypeFile);
  618. cleanup();
  619. // Test rename while adding/removing vfs suffix
  620. fakeFolder.localModifier().rename("renamed1" DVSUFFIX, "R1");
  621. // Contents of file2 could also change at the same time...
  622. fakeFolder.localModifier().rename("file3", "R3" DVSUFFIX);
  623. QVERIFY(fakeFolder.syncOnce());
  624. cleanup();
  625. }
  626. void testRenameVirtual2()
  627. {
  628. FakeFolder fakeFolder{ FileInfo() };
  629. setupVfs(fakeFolder);
  630. ItemCompletedSpy completeSpy(fakeFolder);
  631. auto cleanup = [&]() {
  632. completeSpy.clear();
  633. };
  634. cleanup();
  635. fakeFolder.remoteModifier().insert("case3", 128, 'C');
  636. fakeFolder.remoteModifier().insert("case4", 256, 'C');
  637. fakeFolder.remoteModifier().insert("case5", 256, 'C');
  638. fakeFolder.remoteModifier().insert("case6", 256, 'C');
  639. QVERIFY(fakeFolder.syncOnce());
  640. triggerDownload(fakeFolder, "case4");
  641. triggerDownload(fakeFolder, "case6");
  642. QVERIFY(fakeFolder.syncOnce());
  643. QVERIFY(fakeFolder.currentLocalState().find("case3" DVSUFFIX));
  644. QVERIFY(fakeFolder.currentLocalState().find("case4"));
  645. QVERIFY(fakeFolder.currentLocalState().find("case5" DVSUFFIX));
  646. QVERIFY(fakeFolder.currentLocalState().find("case6"));
  647. cleanup();
  648. // Case 1: foo -> bar (tested elsewhere)
  649. // Case 2: foo.oc -> bar.oc (tested elsewhere)
  650. // Case 3: foo.oc -> bar (db unchanged)
  651. fakeFolder.localModifier().rename("case3" DVSUFFIX, "case3-rename");
  652. // Case 4: foo -> bar.oc (db unchanged)
  653. fakeFolder.localModifier().rename("case4", "case4-rename" DVSUFFIX);
  654. // Case 5: foo.oc -> bar.oc (db hydrate)
  655. fakeFolder.localModifier().rename("case5" DVSUFFIX, "case5-rename" DVSUFFIX);
  656. triggerDownload(fakeFolder, "case5");
  657. // Case 6: foo -> bar (db dehydrate)
  658. fakeFolder.localModifier().rename("case6", "case6-rename");
  659. markForDehydration(fakeFolder, "case6");
  660. QVERIFY(fakeFolder.syncOnce());
  661. // Case 3: the rename went though, hydration is forgotten
  662. QVERIFY(!fakeFolder.currentLocalState().find("case3"));
  663. QVERIFY(!fakeFolder.currentLocalState().find("case3" DVSUFFIX));
  664. QVERIFY(!fakeFolder.currentLocalState().find("case3-rename"));
  665. QVERIFY(fakeFolder.currentLocalState().find("case3-rename" DVSUFFIX));
  666. QVERIFY(!fakeFolder.currentRemoteState().find("case3"));
  667. QVERIFY(fakeFolder.currentRemoteState().find("case3-rename"));
  668. QVERIFY(itemInstruction(completeSpy, "case3-rename" DVSUFFIX, CSYNC_INSTRUCTION_RENAME));
  669. QVERIFY(dbRecord(fakeFolder, "case3-rename" DVSUFFIX)._type == ItemTypeVirtualFile);
  670. // Case 4: the rename went though, dehydration is forgotten
  671. QVERIFY(!fakeFolder.currentLocalState().find("case4"));
  672. QVERIFY(!fakeFolder.currentLocalState().find("case4" DVSUFFIX));
  673. QVERIFY(fakeFolder.currentLocalState().find("case4-rename"));
  674. QVERIFY(!fakeFolder.currentLocalState().find("case4-rename" DVSUFFIX));
  675. QVERIFY(!fakeFolder.currentRemoteState().find("case4"));
  676. QVERIFY(fakeFolder.currentRemoteState().find("case4-rename"));
  677. QVERIFY(itemInstruction(completeSpy, "case4-rename", CSYNC_INSTRUCTION_RENAME));
  678. QVERIFY(dbRecord(fakeFolder, "case4-rename")._type == ItemTypeFile);
  679. // Case 5: the rename went though, hydration is forgotten
  680. QVERIFY(!fakeFolder.currentLocalState().find("case5"));
  681. QVERIFY(!fakeFolder.currentLocalState().find("case5" DVSUFFIX));
  682. QVERIFY(!fakeFolder.currentLocalState().find("case5-rename"));
  683. QVERIFY(fakeFolder.currentLocalState().find("case5-rename" DVSUFFIX));
  684. QVERIFY(!fakeFolder.currentRemoteState().find("case5"));
  685. QVERIFY(fakeFolder.currentRemoteState().find("case5-rename"));
  686. QVERIFY(itemInstruction(completeSpy, "case5-rename" DVSUFFIX, CSYNC_INSTRUCTION_RENAME));
  687. QVERIFY(dbRecord(fakeFolder, "case5-rename" DVSUFFIX)._type == ItemTypeVirtualFile);
  688. // Case 6: the rename went though, dehydration is forgotten
  689. QVERIFY(!fakeFolder.currentLocalState().find("case6"));
  690. QVERIFY(!fakeFolder.currentLocalState().find("case6" DVSUFFIX));
  691. QVERIFY(fakeFolder.currentLocalState().find("case6-rename"));
  692. QVERIFY(!fakeFolder.currentLocalState().find("case6-rename" DVSUFFIX));
  693. QVERIFY(!fakeFolder.currentRemoteState().find("case6"));
  694. QVERIFY(fakeFolder.currentRemoteState().find("case6-rename"));
  695. QVERIFY(itemInstruction(completeSpy, "case6-rename", CSYNC_INSTRUCTION_RENAME));
  696. QVERIFY(dbRecord(fakeFolder, "case6-rename")._type == ItemTypeFile);
  697. }
  698. void testCreateFileWithTrailingSpaces_acceptAndRejectInvalidFileName()
  699. {
  700. FakeFolder fakeFolder{ FileInfo() };
  701. setupVfs(fakeFolder);
  702. QCOMPARE(fakeFolder.currentLocalState(), fakeFolder.currentRemoteState());
  703. const QString fileWithSpaces1(" foo");
  704. const QString fileWithSpaces2(" bar ");
  705. const QString fileWithSpaces3("bla ");
  706. const QString fileWithSpaces4("A/ foo");
  707. const QString fileWithSpaces5("A/ bar ");
  708. const QString fileWithSpaces6("A/bla ");
  709. fakeFolder.localModifier().insert(fileWithSpaces1);
  710. fakeFolder.localModifier().insert(fileWithSpaces2);
  711. fakeFolder.localModifier().insert(fileWithSpaces3);
  712. fakeFolder.localModifier().mkdir("A");
  713. fakeFolder.localModifier().insert(fileWithSpaces4);
  714. fakeFolder.localModifier().insert(fileWithSpaces5);
  715. fakeFolder.localModifier().insert(fileWithSpaces6);
  716. ItemCompletedSpy completeSpy(fakeFolder);
  717. completeSpy.clear();
  718. QVERIFY(fakeFolder.syncOnce());
  719. QCOMPARE(completeSpy.findItem(fileWithSpaces1)->_status, SyncFileItem::Status::FileNameInvalid);
  720. QCOMPARE(completeSpy.findItem(fileWithSpaces2)->_status, SyncFileItem::Status::FileNameInvalid);
  721. QCOMPARE(completeSpy.findItem(fileWithSpaces3)->_status, SyncFileItem::Status::FileNameInvalid);
  722. QCOMPARE(completeSpy.findItem(fileWithSpaces4)->_status, SyncFileItem::Status::FileNameInvalid);
  723. QCOMPARE(completeSpy.findItem(fileWithSpaces5)->_status, SyncFileItem::Status::FileNameInvalid);
  724. QCOMPARE(completeSpy.findItem(fileWithSpaces6)->_status, SyncFileItem::Status::FileNameInvalid);
  725. fakeFolder.syncEngine().addAcceptedInvalidFileName(fakeFolder.localPath() + fileWithSpaces1);
  726. fakeFolder.syncEngine().addAcceptedInvalidFileName(fakeFolder.localPath() + fileWithSpaces2);
  727. fakeFolder.syncEngine().addAcceptedInvalidFileName(fakeFolder.localPath() + fileWithSpaces3);
  728. fakeFolder.syncEngine().addAcceptedInvalidFileName(fakeFolder.localPath() + fileWithSpaces4);
  729. fakeFolder.syncEngine().addAcceptedInvalidFileName(fakeFolder.localPath() + fileWithSpaces5);
  730. fakeFolder.syncEngine().addAcceptedInvalidFileName(fakeFolder.localPath() + fileWithSpaces6);
  731. completeSpy.clear();
  732. QVERIFY(fakeFolder.syncOnce());
  733. QCOMPARE(completeSpy.findItem(fileWithSpaces1)->_status, SyncFileItem::Status::Success);
  734. QCOMPARE(completeSpy.findItem(fileWithSpaces2)->_status, SyncFileItem::Status::Success);
  735. QCOMPARE(completeSpy.findItem(fileWithSpaces3)->_status, SyncFileItem::Status::Success);
  736. QCOMPARE(completeSpy.findItem(fileWithSpaces4)->_status, SyncFileItem::Status::Success);
  737. QCOMPARE(completeSpy.findItem(fileWithSpaces5)->_status, SyncFileItem::Status::Success);
  738. QCOMPARE(completeSpy.findItem(fileWithSpaces6)->_status, SyncFileItem::Status::Success);
  739. }
  740. void testCreateFileWithTrailingSpaces_remoteDontGetRenamedAutomatically()
  741. {
  742. // On Windows we can't create files/folders with leading/trailing spaces locally. So, we have to fail those items. On other OSs - we just sync them down normally.
  743. FakeFolder fakeFolder{ FileInfo() };
  744. setupVfs(fakeFolder);
  745. QCOMPARE(fakeFolder.currentLocalState(), fakeFolder.currentRemoteState());
  746. const QString fileWithSpaces4("A/ foo");
  747. const QString fileWithSpaces5("A/ bar ");
  748. const QString fileWithSpaces6("A/bla ");
  749. const QString fileWithSpacesVirtual4(fileWithSpaces4 + DVSUFFIX);
  750. const QString fileWithSpacesVirtual5(fileWithSpaces5 + DVSUFFIX);
  751. const QString fileWithSpacesVirtual6(fileWithSpaces6 + DVSUFFIX);
  752. fakeFolder.remoteModifier().mkdir("A");
  753. fakeFolder.remoteModifier().insert(fileWithSpaces4);
  754. fakeFolder.remoteModifier().insert(fileWithSpaces5);
  755. fakeFolder.remoteModifier().insert(fileWithSpaces6);
  756. ItemCompletedSpy completeSpy(fakeFolder);
  757. completeSpy.clear();
  758. QVERIFY(fakeFolder.syncOnce());
  759. if (Utility::isWindows()) {
  760. QCOMPARE(completeSpy.findItem(fileWithSpaces4)->_status, SyncFileItem::Status::FileNameInvalid);
  761. QCOMPARE(completeSpy.findItem(fileWithSpaces5)->_status, SyncFileItem::Status::FileNameInvalid);
  762. QCOMPARE(completeSpy.findItem(fileWithSpaces6)->_status, SyncFileItem::Status::FileNameInvalid);
  763. } else {
  764. QCOMPARE(completeSpy.findItem(fileWithSpacesVirtual4)->_status, SyncFileItem::Status::Success);
  765. QCOMPARE(completeSpy.findItem(fileWithSpacesVirtual5)->_status, SyncFileItem::Status::Success);
  766. QCOMPARE(completeSpy.findItem(fileWithSpacesVirtual6)->_status, SyncFileItem::Status::Success);
  767. }
  768. }
  769. void testCreateFileWithTrailingSpaces_remoteGetRenamedManually()
  770. {
  771. // On Windows we can't create files/folders with leading/trailing spaces locally. So, we have to fail those items. On other OSs - we just sync them down normally.
  772. FakeFolder fakeFolder{FileInfo()};
  773. setupVfs(fakeFolder);
  774. QCOMPARE(fakeFolder.currentLocalState(), fakeFolder.currentRemoteState());
  775. const QString fileWithSpaces4("A/ foo");
  776. const QString fileWithSpaces5("A/ bar ");
  777. const QString fileWithSpaces6("A/bla ");
  778. const QString fileWithSpacesVirtual4(fileWithSpaces4 + DVSUFFIX);
  779. const QString fileWithSpacesVirtual5(fileWithSpaces5 + DVSUFFIX);
  780. const QString fileWithSpacesVirtual6(fileWithSpaces6 + DVSUFFIX);
  781. const QString fileWithoutSpaces4("A/foo");
  782. const QString fileWithoutSpaces5("A/bar");
  783. const QString fileWithoutSpaces6("A/bla");
  784. const QString fileWithoutSpacesVirtual4(fileWithoutSpaces4 + DVSUFFIX);
  785. const QString fileWithoutSpacesVirtual5(fileWithoutSpaces5 + DVSUFFIX);
  786. const QString fileWithoutSpacesVirtual6(fileWithoutSpaces6 + DVSUFFIX);
  787. fakeFolder.remoteModifier().mkdir("A");
  788. fakeFolder.remoteModifier().insert(fileWithSpaces4);
  789. fakeFolder.remoteModifier().insert(fileWithSpaces5);
  790. fakeFolder.remoteModifier().insert(fileWithSpaces6);
  791. ItemCompletedSpy completeSpy(fakeFolder);
  792. completeSpy.clear();
  793. QVERIFY(fakeFolder.syncOnce());
  794. if (Utility::isWindows()) {
  795. QCOMPARE(completeSpy.findItem(fileWithSpaces4)->_status, SyncFileItem::Status::FileNameInvalid);
  796. QCOMPARE(completeSpy.findItem(fileWithSpaces5)->_status, SyncFileItem::Status::FileNameInvalid);
  797. QCOMPARE(completeSpy.findItem(fileWithSpaces6)->_status, SyncFileItem::Status::FileNameInvalid);
  798. } else {
  799. QCOMPARE(completeSpy.findItem(fileWithSpacesVirtual4)->_status, SyncFileItem::Status::Success);
  800. QCOMPARE(completeSpy.findItem(fileWithSpacesVirtual5)->_status, SyncFileItem::Status::Success);
  801. QCOMPARE(completeSpy.findItem(fileWithSpacesVirtual6)->_status, SyncFileItem::Status::Success);
  802. }
  803. fakeFolder.remoteModifier().rename(fileWithSpaces4, fileWithoutSpaces4);
  804. fakeFolder.remoteModifier().rename(fileWithSpaces5, fileWithoutSpaces5);
  805. fakeFolder.remoteModifier().rename(fileWithSpaces6, fileWithoutSpaces6);
  806. completeSpy.clear();
  807. QVERIFY(fakeFolder.syncOnce());
  808. if (Utility::isWindows()) {
  809. QCOMPARE(completeSpy.findItem(fileWithoutSpaces4 + DVSUFFIX)->_status, SyncFileItem::Status::Success);
  810. QCOMPARE(completeSpy.findItem(fileWithoutSpaces5 + DVSUFFIX)->_status, SyncFileItem::Status::Success);
  811. QCOMPARE(completeSpy.findItem(fileWithoutSpaces6 + DVSUFFIX)->_status, SyncFileItem::Status::Success);
  812. } else {
  813. QCOMPARE(completeSpy.findItem(fileWithoutSpacesVirtual4)->_status, SyncFileItem::Status::Success);
  814. QCOMPARE(completeSpy.findItem(fileWithoutSpacesVirtual5)->_status, SyncFileItem::Status::Success);
  815. QCOMPARE(completeSpy.findItem(fileWithoutSpacesVirtual6)->_status, SyncFileItem::Status::Success);
  816. }
  817. }
  818. // Dehydration via sync works
  819. void testSyncDehydration()
  820. {
  821. FakeFolder fakeFolder{ FileInfo::A12_B12_C12_S12() };
  822. setupVfs(fakeFolder);
  823. QVERIFY(fakeFolder.syncOnce());
  824. QCOMPARE(fakeFolder.currentLocalState(), fakeFolder.currentRemoteState());
  825. ItemCompletedSpy completeSpy(fakeFolder);
  826. auto cleanup = [&]() {
  827. completeSpy.clear();
  828. };
  829. cleanup();
  830. //
  831. // Mark for dehydration and check
  832. //
  833. markForDehydration(fakeFolder, "A/a1");
  834. markForDehydration(fakeFolder, "A/a2");
  835. fakeFolder.remoteModifier().appendByte("A/a2");
  836. // expect: normal dehydration
  837. markForDehydration(fakeFolder, "B/b1");
  838. fakeFolder.remoteModifier().remove("B/b1");
  839. // expect: local removal
  840. markForDehydration(fakeFolder, "B/b2");
  841. fakeFolder.remoteModifier().rename("B/b2", "B/b3");
  842. // expect: B/b2 is gone, B/b3 is NEW placeholder
  843. markForDehydration(fakeFolder, "C/c1");
  844. fakeFolder.localModifier().appendByte("C/c1");
  845. // expect: no dehydration, upload of c1
  846. markForDehydration(fakeFolder, "C/c2");
  847. fakeFolder.localModifier().appendByte("C/c2");
  848. fakeFolder.remoteModifier().appendByte("C/c2");
  849. fakeFolder.remoteModifier().appendByte("C/c2");
  850. // expect: no dehydration, conflict
  851. QVERIFY(fakeFolder.syncOnce());
  852. auto isDehydrated = [&](const QString &path) {
  853. QString placeholder = path + DVSUFFIX;
  854. return !fakeFolder.currentLocalState().find(path)
  855. && fakeFolder.currentLocalState().find(placeholder);
  856. };
  857. auto hasDehydratedDbEntries = [&](const QString &path) {
  858. SyncJournalFileRecord normal, suffix;
  859. return (!fakeFolder.syncJournal().getFileRecord(path, &normal) || !normal.isValid())
  860. && fakeFolder.syncJournal().getFileRecord(path + DVSUFFIX, &suffix) && suffix.isValid()
  861. && suffix._type == ItemTypeVirtualFile;
  862. };
  863. QVERIFY(isDehydrated("A/a1"));
  864. QVERIFY(hasDehydratedDbEntries("A/a1"));
  865. QVERIFY(itemInstruction(completeSpy, "A/a1" DVSUFFIX, CSYNC_INSTRUCTION_SYNC));
  866. QCOMPARE(completeSpy.findItem("A/a1" DVSUFFIX)->_type, ItemTypeVirtualFileDehydration);
  867. QCOMPARE(completeSpy.findItem("A/a1" DVSUFFIX)->_file, QStringLiteral("A/a1"));
  868. QCOMPARE(completeSpy.findItem("A/a1" DVSUFFIX)->_renameTarget, QStringLiteral("A/a1" DVSUFFIX));
  869. QVERIFY(isDehydrated("A/a2"));
  870. QVERIFY(hasDehydratedDbEntries("A/a2"));
  871. QVERIFY(itemInstruction(completeSpy, "A/a2" DVSUFFIX, CSYNC_INSTRUCTION_SYNC));
  872. QCOMPARE(completeSpy.findItem("A/a2" DVSUFFIX)->_type, ItemTypeVirtualFileDehydration);
  873. QVERIFY(!fakeFolder.currentLocalState().find("B/b1"));
  874. QVERIFY(!fakeFolder.currentRemoteState().find("B/b1"));
  875. QVERIFY(itemInstruction(completeSpy, "B/b1", CSYNC_INSTRUCTION_REMOVE));
  876. QVERIFY(!fakeFolder.currentLocalState().find("B/b2"));
  877. QVERIFY(!fakeFolder.currentRemoteState().find("B/b2"));
  878. QVERIFY(isDehydrated("B/b3"));
  879. QVERIFY(hasDehydratedDbEntries("B/b3"));
  880. QVERIFY(itemInstruction(completeSpy, "B/b2", CSYNC_INSTRUCTION_REMOVE));
  881. QVERIFY(itemInstruction(completeSpy, "B/b3" DVSUFFIX, CSYNC_INSTRUCTION_NEW));
  882. QCOMPARE(fakeFolder.currentRemoteState().find("C/c1")->size, 25);
  883. QVERIFY(itemInstruction(completeSpy, "C/c1", CSYNC_INSTRUCTION_SYNC));
  884. QCOMPARE(fakeFolder.currentRemoteState().find("C/c2")->size, 26);
  885. QVERIFY(itemInstruction(completeSpy, "C/c2", CSYNC_INSTRUCTION_CONFLICT));
  886. cleanup();
  887. auto expectedLocalState = fakeFolder.currentLocalState();
  888. auto expectedRemoteState = fakeFolder.currentRemoteState();
  889. QVERIFY(fakeFolder.syncOnce());
  890. QCOMPARE(fakeFolder.currentLocalState(), expectedLocalState);
  891. QCOMPARE(fakeFolder.currentRemoteState(), expectedRemoteState);
  892. }
  893. void testWipeVirtualSuffixFiles()
  894. {
  895. FakeFolder fakeFolder{ FileInfo{} };
  896. setupVfs(fakeFolder);
  897. // Create a suffix-vfs baseline
  898. fakeFolder.remoteModifier().mkdir("A");
  899. fakeFolder.remoteModifier().mkdir("A/B");
  900. fakeFolder.remoteModifier().insert("f1");
  901. fakeFolder.remoteModifier().insert("A/a1");
  902. fakeFolder.remoteModifier().insert("A/a3");
  903. fakeFolder.remoteModifier().insert("A/B/b1");
  904. fakeFolder.localModifier().mkdir("A");
  905. fakeFolder.localModifier().mkdir("A/B");
  906. fakeFolder.localModifier().insert("f2");
  907. fakeFolder.localModifier().insert("A/a2");
  908. fakeFolder.localModifier().insert("A/B/b2");
  909. QVERIFY(fakeFolder.syncOnce());
  910. QVERIFY(fakeFolder.currentLocalState().find("f1" DVSUFFIX));
  911. QVERIFY(fakeFolder.currentLocalState().find("A/a1" DVSUFFIX));
  912. QVERIFY(fakeFolder.currentLocalState().find("A/a3" DVSUFFIX));
  913. QVERIFY(fakeFolder.currentLocalState().find("A/B/b1" DVSUFFIX));
  914. // Make local changes to a3
  915. fakeFolder.localModifier().remove("A/a3" DVSUFFIX);
  916. fakeFolder.localModifier().insert("A/a3" DVSUFFIX, 100);
  917. // Now wipe the virtuals
  918. SyncEngine::wipeVirtualFiles(fakeFolder.localPath(), fakeFolder.syncJournal(), *fakeFolder.syncEngine().syncOptions()._vfs);
  919. QVERIFY(!fakeFolder.currentLocalState().find("f1" DVSUFFIX));
  920. QVERIFY(!fakeFolder.currentLocalState().find("A/a1" DVSUFFIX));
  921. QVERIFY(fakeFolder.currentLocalState().find("A/a3" DVSUFFIX));
  922. QVERIFY(!fakeFolder.currentLocalState().find("A/B/b1" DVSUFFIX));
  923. fakeFolder.switchToVfs(QSharedPointer<Vfs>(new VfsOff));
  924. QVERIFY(fakeFolder.syncOnce());
  925. QVERIFY(fakeFolder.currentRemoteState().find("A/a3" DVSUFFIX)); // regular upload
  926. QCOMPARE(fakeFolder.currentLocalState(), fakeFolder.currentRemoteState());
  927. }
  928. void testNewVirtuals()
  929. {
  930. FakeFolder fakeFolder{ FileInfo() };
  931. setupVfs(fakeFolder);
  932. QCOMPARE(fakeFolder.currentLocalState(), fakeFolder.currentRemoteState());
  933. auto setPin = [&] (const QByteArray &path, PinState state) {
  934. fakeFolder.syncJournal().internalPinStates().setForPath(path, state);
  935. };
  936. fakeFolder.remoteModifier().mkdir("local");
  937. fakeFolder.remoteModifier().mkdir("online");
  938. fakeFolder.remoteModifier().mkdir("unspec");
  939. QVERIFY(fakeFolder.syncOnce());
  940. QCOMPARE(fakeFolder.currentLocalState(), fakeFolder.currentRemoteState());
  941. setPin("local", PinState::AlwaysLocal);
  942. setPin("online", PinState::OnlineOnly);
  943. setPin("unspec", PinState::Unspecified);
  944. // Test 1: root is Unspecified
  945. fakeFolder.remoteModifier().insert("file1");
  946. fakeFolder.remoteModifier().insert("online/file1");
  947. fakeFolder.remoteModifier().insert("local/file1");
  948. fakeFolder.remoteModifier().insert("unspec/file1");
  949. QVERIFY(fakeFolder.syncOnce());
  950. QVERIFY(fakeFolder.currentLocalState().find("file1" DVSUFFIX));
  951. QVERIFY(fakeFolder.currentLocalState().find("online/file1" DVSUFFIX));
  952. QVERIFY(fakeFolder.currentLocalState().find("local/file1"));
  953. QVERIFY(fakeFolder.currentLocalState().find("unspec/file1" DVSUFFIX));
  954. // Test 2: change root to AlwaysLocal
  955. setPin("", PinState::AlwaysLocal);
  956. fakeFolder.remoteModifier().insert("file2");
  957. fakeFolder.remoteModifier().insert("online/file2");
  958. fakeFolder.remoteModifier().insert("local/file2");
  959. fakeFolder.remoteModifier().insert("unspec/file2");
  960. QVERIFY(fakeFolder.syncOnce());
  961. QVERIFY(fakeFolder.currentLocalState().find("file2"));
  962. QVERIFY(fakeFolder.currentLocalState().find("online/file2" DVSUFFIX));
  963. QVERIFY(fakeFolder.currentLocalState().find("local/file2"));
  964. QVERIFY(fakeFolder.currentLocalState().find("unspec/file2" DVSUFFIX));
  965. // root file1 was hydrated due to its new pin state
  966. QVERIFY(fakeFolder.currentLocalState().find("file1"));
  967. // file1 is unchanged in the explicitly pinned subfolders
  968. QVERIFY(fakeFolder.currentLocalState().find("online/file1" DVSUFFIX));
  969. QVERIFY(fakeFolder.currentLocalState().find("local/file1"));
  970. QVERIFY(fakeFolder.currentLocalState().find("unspec/file1" DVSUFFIX));
  971. // Test 3: change root to OnlineOnly
  972. setPin("", PinState::OnlineOnly);
  973. fakeFolder.remoteModifier().insert("file3");
  974. fakeFolder.remoteModifier().insert("online/file3");
  975. fakeFolder.remoteModifier().insert("local/file3");
  976. fakeFolder.remoteModifier().insert("unspec/file3");
  977. QVERIFY(fakeFolder.syncOnce());
  978. QVERIFY(fakeFolder.currentLocalState().find("file3" DVSUFFIX));
  979. QVERIFY(fakeFolder.currentLocalState().find("online/file3" DVSUFFIX));
  980. QVERIFY(fakeFolder.currentLocalState().find("local/file3"));
  981. QVERIFY(fakeFolder.currentLocalState().find("unspec/file3" DVSUFFIX));
  982. // root file1 was dehydrated due to its new pin state
  983. QVERIFY(fakeFolder.currentLocalState().find("file1" DVSUFFIX));
  984. // file1 is unchanged in the explicitly pinned subfolders
  985. QVERIFY(fakeFolder.currentLocalState().find("online/file1" DVSUFFIX));
  986. QVERIFY(fakeFolder.currentLocalState().find("local/file1"));
  987. QVERIFY(fakeFolder.currentLocalState().find("unspec/file1" DVSUFFIX));
  988. }
  989. // Check what happens if vfs-suffixed files exist on the server or locally
  990. // while the file is hydrated
  991. void testSuffixFilesWhileLocalHydrated()
  992. {
  993. FakeFolder fakeFolder{ FileInfo() };
  994. ItemCompletedSpy completeSpy(fakeFolder);
  995. auto cleanup = [&]() {
  996. completeSpy.clear();
  997. };
  998. cleanup();
  999. // suffixed files are happily synced with Vfs::Off
  1000. fakeFolder.remoteModifier().mkdir("A");
  1001. fakeFolder.remoteModifier().insert("A/test1" DVSUFFIX, 10, 'A');
  1002. fakeFolder.remoteModifier().insert("A/test2" DVSUFFIX, 20, 'A');
  1003. fakeFolder.remoteModifier().insert("A/file1" DVSUFFIX, 30, 'A');
  1004. fakeFolder.remoteModifier().insert("A/file2", 40, 'A');
  1005. fakeFolder.remoteModifier().insert("A/file2" DVSUFFIX, 50, 'A');
  1006. fakeFolder.remoteModifier().insert("A/file3", 60, 'A');
  1007. fakeFolder.remoteModifier().insert("A/file3" DVSUFFIX, 70, 'A');
  1008. fakeFolder.remoteModifier().insert("A/file3" DVSUFFIX DVSUFFIX, 80, 'A');
  1009. fakeFolder.remoteModifier().insert("A/remote1" DVSUFFIX, 30, 'A');
  1010. fakeFolder.remoteModifier().insert("A/remote2", 40, 'A');
  1011. fakeFolder.remoteModifier().insert("A/remote2" DVSUFFIX, 50, 'A');
  1012. fakeFolder.remoteModifier().insert("A/remote3", 60, 'A');
  1013. fakeFolder.remoteModifier().insert("A/remote3" DVSUFFIX, 70, 'A');
  1014. fakeFolder.remoteModifier().insert("A/remote3" DVSUFFIX DVSUFFIX, 80, 'A');
  1015. QVERIFY(fakeFolder.syncOnce());
  1016. QCOMPARE(fakeFolder.currentLocalState(), fakeFolder.currentRemoteState());
  1017. cleanup();
  1018. // Enable suffix vfs
  1019. setupVfs(fakeFolder);
  1020. // A simple sync removes the files that are now ignored (?)
  1021. QVERIFY(fakeFolder.syncOnce());
  1022. QVERIFY(itemInstruction(completeSpy, "A/file1" DVSUFFIX, CSYNC_INSTRUCTION_IGNORE));
  1023. QVERIFY(itemInstruction(completeSpy, "A/file2" DVSUFFIX, CSYNC_INSTRUCTION_IGNORE));
  1024. QVERIFY(itemInstruction(completeSpy, "A/file3" DVSUFFIX, CSYNC_INSTRUCTION_IGNORE));
  1025. QVERIFY(itemInstruction(completeSpy, "A/file3" DVSUFFIX DVSUFFIX, CSYNC_INSTRUCTION_IGNORE));
  1026. cleanup();
  1027. // Add a real file where the suffixed file exists
  1028. fakeFolder.localModifier().insert("A/test1", 11, 'A');
  1029. fakeFolder.remoteModifier().insert("A/test2", 21, 'A');
  1030. QVERIFY(fakeFolder.syncOnce());
  1031. QVERIFY(itemInstruction(completeSpy, "A/test1", CSYNC_INSTRUCTION_NEW));
  1032. // this isn't fully good since some code requires size == 1 for placeholders
  1033. // (when renaming placeholder to real file). But the alternative would mean
  1034. // special casing this to allow CONFLICT at virtual file creation level. Ew.
  1035. QVERIFY(itemInstruction(completeSpy, "A/test2" DVSUFFIX, CSYNC_INSTRUCTION_UPDATE_METADATA));
  1036. cleanup();
  1037. // Local changes of suffixed file do nothing
  1038. fakeFolder.localModifier().setContents("A/file1" DVSUFFIX, 'B');
  1039. fakeFolder.localModifier().setContents("A/file2" DVSUFFIX, 'B');
  1040. fakeFolder.localModifier().setContents("A/file3" DVSUFFIX, 'B');
  1041. fakeFolder.localModifier().setContents("A/file3" DVSUFFIX DVSUFFIX, 'B');
  1042. QVERIFY(fakeFolder.syncOnce());
  1043. QVERIFY(itemInstruction(completeSpy, "A/file1" DVSUFFIX, CSYNC_INSTRUCTION_IGNORE));
  1044. QVERIFY(itemInstruction(completeSpy, "A/file2" DVSUFFIX, CSYNC_INSTRUCTION_IGNORE));
  1045. QVERIFY(itemInstruction(completeSpy, "A/file3" DVSUFFIX, CSYNC_INSTRUCTION_IGNORE));
  1046. QVERIFY(itemInstruction(completeSpy, "A/file3" DVSUFFIX DVSUFFIX, CSYNC_INSTRUCTION_IGNORE));
  1047. cleanup();
  1048. // Remote changes don't do anything either
  1049. fakeFolder.remoteModifier().setContents("A/file1" DVSUFFIX, 'C');
  1050. fakeFolder.remoteModifier().setContents("A/file2" DVSUFFIX, 'C');
  1051. fakeFolder.remoteModifier().setContents("A/file3" DVSUFFIX, 'C');
  1052. fakeFolder.remoteModifier().setContents("A/file3" DVSUFFIX DVSUFFIX, 'C');
  1053. QVERIFY(fakeFolder.syncOnce());
  1054. QVERIFY(itemInstruction(completeSpy, "A/file1" DVSUFFIX, CSYNC_INSTRUCTION_IGNORE));
  1055. QVERIFY(itemInstruction(completeSpy, "A/file2" DVSUFFIX, CSYNC_INSTRUCTION_IGNORE));
  1056. QVERIFY(itemInstruction(completeSpy, "A/file3" DVSUFFIX, CSYNC_INSTRUCTION_IGNORE));
  1057. QVERIFY(itemInstruction(completeSpy, "A/file3" DVSUFFIX DVSUFFIX, CSYNC_INSTRUCTION_IGNORE));
  1058. cleanup();
  1059. // Local removal: when not querying server
  1060. fakeFolder.localModifier().remove("A/file1" DVSUFFIX);
  1061. fakeFolder.localModifier().remove("A/file2" DVSUFFIX);
  1062. fakeFolder.localModifier().remove("A/file3" DVSUFFIX);
  1063. fakeFolder.localModifier().remove("A/file3" DVSUFFIX DVSUFFIX);
  1064. QVERIFY(fakeFolder.syncOnce());
  1065. QVERIFY(completeSpy.findItem("A/file1" DVSUFFIX)->isEmpty());
  1066. QVERIFY(completeSpy.findItem("A/file2" DVSUFFIX)->isEmpty());
  1067. QVERIFY(completeSpy.findItem("A/file3" DVSUFFIX)->isEmpty());
  1068. QVERIFY(completeSpy.findItem("A/file3" DVSUFFIX DVSUFFIX)->isEmpty());
  1069. cleanup();
  1070. // Local removal: when querying server
  1071. fakeFolder.remoteModifier().setContents("A/file1" DVSUFFIX, 'D');
  1072. QVERIFY(fakeFolder.syncOnce());
  1073. QVERIFY(itemInstruction(completeSpy, "A/file1" DVSUFFIX, CSYNC_INSTRUCTION_IGNORE));
  1074. QVERIFY(itemInstruction(completeSpy, "A/file2" DVSUFFIX, CSYNC_INSTRUCTION_IGNORE));
  1075. QVERIFY(itemInstruction(completeSpy, "A/file3" DVSUFFIX, CSYNC_INSTRUCTION_IGNORE));
  1076. QVERIFY(itemInstruction(completeSpy, "A/file3" DVSUFFIX DVSUFFIX, CSYNC_INSTRUCTION_IGNORE));
  1077. cleanup();
  1078. // Remote removal
  1079. fakeFolder.remoteModifier().remove("A/remote1" DVSUFFIX);
  1080. fakeFolder.remoteModifier().remove("A/remote2" DVSUFFIX);
  1081. fakeFolder.remoteModifier().remove("A/remote3" DVSUFFIX);
  1082. fakeFolder.remoteModifier().remove("A/remote3" DVSUFFIX DVSUFFIX);
  1083. QVERIFY(fakeFolder.syncOnce());
  1084. QVERIFY(itemInstruction(completeSpy, "A/remote1" DVSUFFIX, CSYNC_INSTRUCTION_IGNORE));
  1085. QVERIFY(itemInstruction(completeSpy, "A/remote2" DVSUFFIX, CSYNC_INSTRUCTION_IGNORE));
  1086. QVERIFY(itemInstruction(completeSpy, "A/remote3" DVSUFFIX, CSYNC_INSTRUCTION_IGNORE));
  1087. QVERIFY(itemInstruction(completeSpy, "A/remote3" DVSUFFIX DVSUFFIX, CSYNC_INSTRUCTION_IGNORE));
  1088. cleanup();
  1089. // New files with a suffix aren't propagated downwards in the first place
  1090. fakeFolder.remoteModifier().insert("A/new1" DVSUFFIX);
  1091. QVERIFY(fakeFolder.syncOnce());
  1092. QVERIFY(itemInstruction(completeSpy, "A/new1" DVSUFFIX, CSYNC_INSTRUCTION_IGNORE));
  1093. QVERIFY(fakeFolder.currentRemoteState().find("A/new1" DVSUFFIX));
  1094. QVERIFY(!fakeFolder.currentLocalState().find("A/new1"));
  1095. QVERIFY(!fakeFolder.currentLocalState().find("A/new1" DVSUFFIX));
  1096. QVERIFY(!fakeFolder.currentLocalState().find("A/new1" DVSUFFIX DVSUFFIX));
  1097. cleanup();
  1098. }
  1099. // Check what happens if vfs-suffixed files exist on the server or in the db
  1100. void testExtraFilesLocalDehydrated()
  1101. {
  1102. FakeFolder fakeFolder{ FileInfo() };
  1103. setupVfs(fakeFolder);
  1104. ItemCompletedSpy completeSpy(fakeFolder);
  1105. auto cleanup = [&]() {
  1106. completeSpy.clear();
  1107. };
  1108. cleanup();
  1109. // create a bunch of local virtual files, in some instances
  1110. // ignore remote files
  1111. fakeFolder.remoteModifier().mkdir("A");
  1112. fakeFolder.remoteModifier().insert("A/file1", 30, 'A');
  1113. fakeFolder.remoteModifier().insert("A/file2", 40, 'A');
  1114. fakeFolder.remoteModifier().insert("A/file3", 60, 'A');
  1115. fakeFolder.remoteModifier().insert("A/file3" DVSUFFIX, 70, 'A');
  1116. fakeFolder.remoteModifier().insert("A/file4", 80, 'A');
  1117. fakeFolder.remoteModifier().insert("A/file4" DVSUFFIX, 90, 'A');
  1118. fakeFolder.remoteModifier().insert("A/file4" DVSUFFIX DVSUFFIX, 100, 'A');
  1119. fakeFolder.remoteModifier().insert("A/file5", 110, 'A');
  1120. fakeFolder.remoteModifier().insert("A/file6", 120, 'A');
  1121. QVERIFY(fakeFolder.syncOnce());
  1122. QVERIFY(!fakeFolder.currentLocalState().find("A/file1"));
  1123. QVERIFY(fakeFolder.currentLocalState().find("A/file1" DVSUFFIX));
  1124. QVERIFY(!fakeFolder.currentLocalState().find("A/file2"));
  1125. QVERIFY(fakeFolder.currentLocalState().find("A/file2" DVSUFFIX));
  1126. QVERIFY(!fakeFolder.currentLocalState().find("A/file3"));
  1127. QVERIFY(fakeFolder.currentLocalState().find("A/file3" DVSUFFIX));
  1128. QVERIFY(!fakeFolder.currentLocalState().find("A/file4"));
  1129. QVERIFY(fakeFolder.currentLocalState().find("A/file4" DVSUFFIX));
  1130. QVERIFY(!fakeFolder.currentLocalState().find("A/file4" DVSUFFIX DVSUFFIX));
  1131. QVERIFY(itemInstruction(completeSpy, "A/file1" DVSUFFIX, CSYNC_INSTRUCTION_NEW));
  1132. QVERIFY(itemInstruction(completeSpy, "A/file2" DVSUFFIX, CSYNC_INSTRUCTION_NEW));
  1133. QVERIFY(itemInstruction(completeSpy, "A/file3" DVSUFFIX, CSYNC_INSTRUCTION_IGNORE));
  1134. QVERIFY(itemInstruction(completeSpy, "A/file4" DVSUFFIX, CSYNC_INSTRUCTION_IGNORE));
  1135. QVERIFY(itemInstruction(completeSpy, "A/file4" DVSUFFIX DVSUFFIX, CSYNC_INSTRUCTION_IGNORE));
  1136. cleanup();
  1137. // Create odd extra files locally and remotely
  1138. fakeFolder.localModifier().insert("A/file1", 10, 'A');
  1139. fakeFolder.localModifier().insert("A/file2" DVSUFFIX DVSUFFIX, 10, 'A');
  1140. fakeFolder.remoteModifier().insert("A/file5" DVSUFFIX, 10, 'A');
  1141. fakeFolder.localModifier().insert("A/file6", 10, 'A');
  1142. fakeFolder.remoteModifier().insert("A/file6" DVSUFFIX, 10, 'A');
  1143. QVERIFY(fakeFolder.syncOnce());
  1144. QVERIFY(itemInstruction(completeSpy, "A/file1", CSYNC_INSTRUCTION_CONFLICT));
  1145. QVERIFY(itemInstruction(completeSpy, "A/file1" DVSUFFIX, CSYNC_INSTRUCTION_REMOVE)); // it's now a pointless real virtual file
  1146. QVERIFY(itemInstruction(completeSpy, "A/file2" DVSUFFIX DVSUFFIX, CSYNC_INSTRUCTION_IGNORE));
  1147. QVERIFY(itemInstruction(completeSpy, "A/file5" DVSUFFIX, CSYNC_INSTRUCTION_IGNORE));
  1148. QVERIFY(itemInstruction(completeSpy, "A/file6", CSYNC_INSTRUCTION_CONFLICT));
  1149. QVERIFY(itemInstruction(completeSpy, "A/file6" DVSUFFIX, CSYNC_INSTRUCTION_IGNORE));
  1150. cleanup();
  1151. }
  1152. void testAvailability()
  1153. {
  1154. FakeFolder fakeFolder{ FileInfo() };
  1155. auto vfs = setupVfs(fakeFolder);
  1156. QCOMPARE(fakeFolder.currentLocalState(), fakeFolder.currentRemoteState());
  1157. auto setPin = [&] (const QByteArray &path, PinState state) {
  1158. fakeFolder.syncJournal().internalPinStates().setForPath(path, state);
  1159. };
  1160. fakeFolder.remoteModifier().mkdir("local");
  1161. fakeFolder.remoteModifier().mkdir("local/sub");
  1162. fakeFolder.remoteModifier().mkdir("online");
  1163. fakeFolder.remoteModifier().mkdir("online/sub");
  1164. fakeFolder.remoteModifier().mkdir("unspec");
  1165. QVERIFY(fakeFolder.syncOnce());
  1166. QCOMPARE(fakeFolder.currentLocalState(), fakeFolder.currentRemoteState());
  1167. setPin("local", PinState::AlwaysLocal);
  1168. setPin("online", PinState::OnlineOnly);
  1169. setPin("unspec", PinState::Unspecified);
  1170. fakeFolder.remoteModifier().insert("file1");
  1171. fakeFolder.remoteModifier().insert("online/file1");
  1172. fakeFolder.remoteModifier().insert("online/file2");
  1173. fakeFolder.remoteModifier().insert("local/file1");
  1174. fakeFolder.remoteModifier().insert("local/file2");
  1175. fakeFolder.remoteModifier().insert("unspec/file1");
  1176. QVERIFY(fakeFolder.syncOnce());
  1177. // root is unspecified
  1178. QCOMPARE(*vfs->availability("file1" DVSUFFIX), VfsItemAvailability::AllDehydrated);
  1179. QCOMPARE(*vfs->availability("local"), VfsItemAvailability::AlwaysLocal);
  1180. QCOMPARE(*vfs->availability("local/file1"), VfsItemAvailability::AlwaysLocal);
  1181. QCOMPARE(*vfs->availability("online"), VfsItemAvailability::OnlineOnly);
  1182. QCOMPARE(*vfs->availability("online/file1" DVSUFFIX), VfsItemAvailability::OnlineOnly);
  1183. QCOMPARE(*vfs->availability("unspec"), VfsItemAvailability::AllDehydrated);
  1184. QCOMPARE(*vfs->availability("unspec/file1" DVSUFFIX), VfsItemAvailability::AllDehydrated);
  1185. // Subitem pin states can ruin "pure" availabilities
  1186. setPin("local/sub", PinState::OnlineOnly);
  1187. QCOMPARE(*vfs->availability("local"), VfsItemAvailability::AllHydrated);
  1188. setPin("online/sub", PinState::Unspecified);
  1189. QCOMPARE(*vfs->availability("online"), VfsItemAvailability::AllDehydrated);
  1190. triggerDownload(fakeFolder, "unspec/file1");
  1191. setPin("local/file2", PinState::OnlineOnly);
  1192. setPin("online/file2" DVSUFFIX, PinState::AlwaysLocal);
  1193. QVERIFY(fakeFolder.syncOnce());
  1194. QCOMPARE(*vfs->availability("unspec"), VfsItemAvailability::AllHydrated);
  1195. QCOMPARE(*vfs->availability("local"), VfsItemAvailability::Mixed);
  1196. QCOMPARE(*vfs->availability("online"), VfsItemAvailability::Mixed);
  1197. QVERIFY(vfs->setPinState("local", PinState::AlwaysLocal));
  1198. QVERIFY(vfs->setPinState("online", PinState::OnlineOnly));
  1199. QVERIFY(fakeFolder.syncOnce());
  1200. QCOMPARE(*vfs->availability("online"), VfsItemAvailability::OnlineOnly);
  1201. QCOMPARE(*vfs->availability("local"), VfsItemAvailability::AlwaysLocal);
  1202. auto r = vfs->availability("nonexistent");
  1203. QVERIFY(!r);
  1204. QCOMPARE(r.error(), Vfs::AvailabilityError::NoSuchItem);
  1205. }
  1206. void testPinStateLocals()
  1207. {
  1208. FakeFolder fakeFolder{ FileInfo() };
  1209. auto vfs = setupVfs(fakeFolder);
  1210. QCOMPARE(fakeFolder.currentLocalState(), fakeFolder.currentRemoteState());
  1211. auto setPin = [&] (const QByteArray &path, PinState state) {
  1212. fakeFolder.syncJournal().internalPinStates().setForPath(path, state);
  1213. };
  1214. fakeFolder.remoteModifier().mkdir("local");
  1215. fakeFolder.remoteModifier().mkdir("online");
  1216. fakeFolder.remoteModifier().mkdir("unspec");
  1217. QVERIFY(fakeFolder.syncOnce());
  1218. QCOMPARE(fakeFolder.currentLocalState(), fakeFolder.currentRemoteState());
  1219. setPin("local", PinState::AlwaysLocal);
  1220. setPin("online", PinState::OnlineOnly);
  1221. setPin("unspec", PinState::Unspecified);
  1222. fakeFolder.localModifier().insert("file1");
  1223. fakeFolder.localModifier().insert("online/file1");
  1224. fakeFolder.localModifier().insert("online/file2");
  1225. fakeFolder.localModifier().insert("local/file1");
  1226. fakeFolder.localModifier().insert("unspec/file1");
  1227. QVERIFY(fakeFolder.syncOnce());
  1228. QCOMPARE(fakeFolder.currentLocalState(), fakeFolder.currentRemoteState());
  1229. // root is unspecified
  1230. QCOMPARE(*vfs->pinState("file1" DVSUFFIX), PinState::Unspecified);
  1231. QCOMPARE(*vfs->pinState("local/file1"), PinState::AlwaysLocal);
  1232. QCOMPARE(*vfs->pinState("online/file1"), PinState::Unspecified);
  1233. QCOMPARE(*vfs->pinState("unspec/file1"), PinState::Unspecified);
  1234. // Sync again: bad pin states of new local files usually take effect on second sync
  1235. QVERIFY(fakeFolder.syncOnce());
  1236. QCOMPARE(fakeFolder.currentLocalState(), fakeFolder.currentRemoteState());
  1237. // When a file in an online-only folder is renamed, it retains its pin
  1238. fakeFolder.localModifier().rename("online/file1", "online/file1rename");
  1239. fakeFolder.remoteModifier().rename("online/file2", "online/file2rename");
  1240. QVERIFY(fakeFolder.syncOnce());
  1241. QCOMPARE(*vfs->pinState("online/file1rename"), PinState::Unspecified);
  1242. QCOMPARE(*vfs->pinState("online/file2rename"), PinState::Unspecified);
  1243. // When a folder is renamed, the pin states inside should be retained
  1244. fakeFolder.localModifier().rename("online", "onlinerenamed1");
  1245. QVERIFY(fakeFolder.syncOnce());
  1246. QCOMPARE(*vfs->pinState("onlinerenamed1"), PinState::OnlineOnly);
  1247. QCOMPARE(*vfs->pinState("onlinerenamed1/file1rename"), PinState::Unspecified);
  1248. fakeFolder.remoteModifier().rename("onlinerenamed1", "onlinerenamed2");
  1249. QVERIFY(fakeFolder.syncOnce());
  1250. QCOMPARE(*vfs->pinState("onlinerenamed2"), PinState::OnlineOnly);
  1251. QCOMPARE(*vfs->pinState("onlinerenamed2/file1rename"), PinState::Unspecified);
  1252. QCOMPARE(fakeFolder.currentLocalState(), fakeFolder.currentRemoteState());
  1253. // When a file is deleted and later a new file has the same name, the old pin
  1254. // state isn't preserved.
  1255. QCOMPARE(*vfs->pinState("onlinerenamed2/file1rename"), PinState::Unspecified);
  1256. fakeFolder.remoteModifier().remove("onlinerenamed2/file1rename");
  1257. QVERIFY(fakeFolder.syncOnce());
  1258. QCOMPARE(*vfs->pinState("onlinerenamed2/file1rename"), PinState::OnlineOnly);
  1259. fakeFolder.remoteModifier().insert("onlinerenamed2/file1rename");
  1260. QVERIFY(fakeFolder.syncOnce());
  1261. QCOMPARE(*vfs->pinState("onlinerenamed2/file1rename"), PinState::OnlineOnly);
  1262. QCOMPARE(*vfs->pinState("onlinerenamed2/file1rename" DVSUFFIX), PinState::OnlineOnly);
  1263. // When a file is hydrated or dehydrated due to pin state it retains its pin state
  1264. QVERIFY(vfs->setPinState("onlinerenamed2/file1rename" DVSUFFIX, PinState::AlwaysLocal));
  1265. QVERIFY(fakeFolder.syncOnce());
  1266. QVERIFY(fakeFolder.currentLocalState().find("onlinerenamed2/file1rename"));
  1267. QCOMPARE(*vfs->pinState("onlinerenamed2/file1rename"), PinState::AlwaysLocal);
  1268. QVERIFY(vfs->setPinState("onlinerenamed2", PinState::Unspecified));
  1269. QVERIFY(vfs->setPinState("onlinerenamed2/file1rename", PinState::OnlineOnly));
  1270. QVERIFY(fakeFolder.syncOnce());
  1271. QVERIFY(fakeFolder.currentLocalState().find("onlinerenamed2/file1rename" DVSUFFIX));
  1272. QCOMPARE(*vfs->pinState("onlinerenamed2/file1rename" DVSUFFIX), PinState::OnlineOnly);
  1273. }
  1274. void testIncompatiblePins()
  1275. {
  1276. FakeFolder fakeFolder{ FileInfo() };
  1277. auto vfs = setupVfs(fakeFolder);
  1278. QCOMPARE(fakeFolder.currentLocalState(), fakeFolder.currentRemoteState());
  1279. auto setPin = [&] (const QByteArray &path, PinState state) {
  1280. fakeFolder.syncJournal().internalPinStates().setForPath(path, state);
  1281. };
  1282. fakeFolder.remoteModifier().mkdir("local");
  1283. fakeFolder.remoteModifier().mkdir("online");
  1284. QVERIFY(fakeFolder.syncOnce());
  1285. QCOMPARE(fakeFolder.currentLocalState(), fakeFolder.currentRemoteState());
  1286. setPin("local", PinState::AlwaysLocal);
  1287. setPin("online", PinState::OnlineOnly);
  1288. fakeFolder.localModifier().insert("local/file1");
  1289. fakeFolder.localModifier().insert("online/file1");
  1290. QVERIFY(fakeFolder.syncOnce());
  1291. markForDehydration(fakeFolder, "local/file1");
  1292. triggerDownload(fakeFolder, "online/file1");
  1293. // the sync sets the changed files pin states to unspecified
  1294. QVERIFY(fakeFolder.syncOnce());
  1295. QVERIFY(fakeFolder.currentLocalState().find("online/file1"));
  1296. QVERIFY(fakeFolder.currentLocalState().find("local/file1" DVSUFFIX));
  1297. QCOMPARE(*vfs->pinState("online/file1"), PinState::Unspecified);
  1298. QCOMPARE(*vfs->pinState("local/file1" DVSUFFIX), PinState::Unspecified);
  1299. // no change on another sync
  1300. QVERIFY(fakeFolder.syncOnce());
  1301. QVERIFY(fakeFolder.currentLocalState().find("online/file1"));
  1302. QVERIFY(fakeFolder.currentLocalState().find("local/file1" DVSUFFIX));
  1303. }
  1304. void testPlaceHolderExist() {
  1305. FakeFolder fakeFolder{ FileInfo::A12_B12_C12_S12() };
  1306. fakeFolder.remoteModifier().insert("A/a1" DVSUFFIX, 111);
  1307. fakeFolder.remoteModifier().insert("A/hello" DVSUFFIX, 222);
  1308. QVERIFY(fakeFolder.syncOnce());
  1309. auto vfs = setupVfs(fakeFolder);
  1310. ItemCompletedSpy completeSpy(fakeFolder);
  1311. auto cleanup = [&]() { completeSpy.clear(); };
  1312. cleanup();
  1313. QVERIFY(fakeFolder.syncOnce());
  1314. QCOMPARE(fakeFolder.currentLocalState(), fakeFolder.currentRemoteState());
  1315. QVERIFY(itemInstruction(completeSpy, "A/a1" DVSUFFIX, CSYNC_INSTRUCTION_IGNORE));
  1316. QVERIFY(itemInstruction(completeSpy, "A/hello" DVSUFFIX, CSYNC_INSTRUCTION_IGNORE));
  1317. fakeFolder.remoteModifier().insert("A/a2" DVSUFFIX);
  1318. fakeFolder.remoteModifier().insert("A/hello", 12);
  1319. fakeFolder.localModifier().insert("A/igno" DVSUFFIX, 123);
  1320. cleanup();
  1321. QVERIFY(fakeFolder.syncOnce());
  1322. QVERIFY(itemInstruction(completeSpy, "A/a1" DVSUFFIX, CSYNC_INSTRUCTION_IGNORE));
  1323. QVERIFY(itemInstruction(completeSpy, "A/igno" DVSUFFIX, CSYNC_INSTRUCTION_IGNORE));
  1324. // verify that the files are still present
  1325. QCOMPARE(fakeFolder.currentLocalState().find("A/hello" DVSUFFIX)->size, 222);
  1326. QCOMPARE(*fakeFolder.currentLocalState().find("A/hello" DVSUFFIX),
  1327. *fakeFolder.currentRemoteState().find("A/hello" DVSUFFIX));
  1328. QCOMPARE(fakeFolder.currentLocalState().find("A/igno" DVSUFFIX)->size, 123);
  1329. cleanup();
  1330. // Dehydrate
  1331. QVERIFY(vfs->setPinState(QString(), PinState::OnlineOnly));
  1332. QVERIFY(!fakeFolder.syncOnce());
  1333. QVERIFY(itemInstruction(completeSpy, "A/igno" DVSUFFIX, CSYNC_INSTRUCTION_IGNORE));
  1334. // verify that the files are still present
  1335. QCOMPARE(fakeFolder.currentLocalState().find("A/a1" DVSUFFIX)->size, 111);
  1336. QCOMPARE(fakeFolder.currentLocalState().find("A/hello" DVSUFFIX)->size, 222);
  1337. QCOMPARE(*fakeFolder.currentLocalState().find("A/hello" DVSUFFIX),
  1338. *fakeFolder.currentRemoteState().find("A/hello" DVSUFFIX));
  1339. QCOMPARE(*fakeFolder.currentLocalState().find("A/a1"),
  1340. *fakeFolder.currentRemoteState().find("A/a1"));
  1341. QCOMPARE(fakeFolder.currentLocalState().find("A/igno" DVSUFFIX)->size, 123);
  1342. // Now disable vfs and check that all files are still there
  1343. cleanup();
  1344. SyncEngine::wipeVirtualFiles(fakeFolder.localPath(), fakeFolder.syncJournal(), *vfs);
  1345. fakeFolder.switchToVfs(QSharedPointer<Vfs>(new VfsOff));
  1346. QVERIFY(fakeFolder.syncOnce());
  1347. QCOMPARE(fakeFolder.currentLocalState(), fakeFolder.currentRemoteState());
  1348. QCOMPARE(fakeFolder.currentLocalState().find("A/a1" DVSUFFIX)->size, 111);
  1349. QCOMPARE(fakeFolder.currentLocalState().find("A/hello")->size, 12);
  1350. QCOMPARE(fakeFolder.currentLocalState().find("A/hello" DVSUFFIX)->size, 222);
  1351. QCOMPARE(fakeFolder.currentLocalState().find("A/igno" DVSUFFIX)->size, 123);
  1352. }
  1353. void testUpdateMetadataErrorManagement()
  1354. {
  1355. FakeFolder fakeFolder{FileInfo{}};
  1356. setupVfs(fakeFolder);
  1357. QCOMPARE(fakeFolder.currentLocalState(), fakeFolder.currentRemoteState());
  1358. // Existing files are propagated just fine in both directions
  1359. fakeFolder.remoteModifier().mkdir(QStringLiteral("aaa"));
  1360. fakeFolder.remoteModifier().mkdir(QStringLiteral("aaa/subfolder"));
  1361. fakeFolder.remoteModifier().insert(QStringLiteral("aaa/subfolder/bar"));
  1362. QVERIFY(fakeFolder.syncOnce());
  1363. // New files on the remote create virtual files
  1364. fakeFolder.remoteModifier().setModTime(QStringLiteral("aaa/subfolder/bar"), QDateTime::fromSecsSinceEpoch(0));
  1365. QVERIFY(!fakeFolder.syncOnce());
  1366. QVERIFY(!fakeFolder.syncOnce());
  1367. }
  1368. void testInvalidFutureMtimeRecovery()
  1369. {
  1370. constexpr auto FUTURE_MTIME = 0xFFFFFFFF;
  1371. constexpr auto CURRENT_MTIME = 1646057277;
  1372. FakeFolder fakeFolder{FileInfo{}};
  1373. setupVfs(fakeFolder);
  1374. QCOMPARE(fakeFolder.currentLocalState(), fakeFolder.currentRemoteState());
  1375. const QString fooFileRootFolder("foo");
  1376. const QString barFileRootFolder("bar");
  1377. const QString fooFileSubFolder("subfolder/foo");
  1378. const QString barFileSubFolder("subfolder/bar");
  1379. const QString fooFileAaaSubFolder("aaa/subfolder/foo");
  1380. const QString barFileAaaSubFolder("aaa/subfolder/bar");
  1381. fakeFolder.remoteModifier().insert(fooFileRootFolder);
  1382. fakeFolder.remoteModifier().insert(barFileRootFolder);
  1383. fakeFolder.remoteModifier().mkdir(QStringLiteral("subfolder"));
  1384. fakeFolder.remoteModifier().insert(fooFileSubFolder);
  1385. fakeFolder.remoteModifier().insert(barFileSubFolder);
  1386. fakeFolder.remoteModifier().mkdir(QStringLiteral("aaa"));
  1387. fakeFolder.remoteModifier().mkdir(QStringLiteral("aaa/subfolder"));
  1388. fakeFolder.remoteModifier().insert(fooFileAaaSubFolder);
  1389. fakeFolder.remoteModifier().insert(barFileAaaSubFolder);
  1390. QVERIFY(fakeFolder.syncOnce());
  1391. fakeFolder.remoteModifier().setModTimeKeepEtag(fooFileRootFolder, QDateTime::fromSecsSinceEpoch(CURRENT_MTIME));
  1392. fakeFolder.remoteModifier().setModTimeKeepEtag(barFileRootFolder, QDateTime::fromSecsSinceEpoch(CURRENT_MTIME));
  1393. fakeFolder.remoteModifier().setModTimeKeepEtag(fooFileSubFolder, QDateTime::fromSecsSinceEpoch(CURRENT_MTIME));
  1394. fakeFolder.remoteModifier().setModTimeKeepEtag(barFileSubFolder, QDateTime::fromSecsSinceEpoch(CURRENT_MTIME));
  1395. fakeFolder.remoteModifier().setModTimeKeepEtag(fooFileAaaSubFolder, QDateTime::fromSecsSinceEpoch(CURRENT_MTIME));
  1396. fakeFolder.remoteModifier().setModTimeKeepEtag(barFileAaaSubFolder, QDateTime::fromSecsSinceEpoch(CURRENT_MTIME));
  1397. fakeFolder.localModifier().setModTime(fooFileRootFolder + DVSUFFIX, QDateTime::fromSecsSinceEpoch(FUTURE_MTIME));
  1398. fakeFolder.localModifier().setModTime(barFileRootFolder + DVSUFFIX, QDateTime::fromSecsSinceEpoch(FUTURE_MTIME));
  1399. fakeFolder.localModifier().setModTime(fooFileSubFolder + DVSUFFIX, QDateTime::fromSecsSinceEpoch(FUTURE_MTIME));
  1400. fakeFolder.localModifier().setModTime(barFileSubFolder + DVSUFFIX, QDateTime::fromSecsSinceEpoch(FUTURE_MTIME));
  1401. fakeFolder.localModifier().setModTime(fooFileAaaSubFolder + DVSUFFIX, QDateTime::fromSecsSinceEpoch(FUTURE_MTIME));
  1402. fakeFolder.localModifier().setModTime(barFileAaaSubFolder + DVSUFFIX, QDateTime::fromSecsSinceEpoch(FUTURE_MTIME));
  1403. QVERIFY(fakeFolder.syncOnce());
  1404. QVERIFY(fakeFolder.syncOnce());
  1405. }
  1406. void testInvalidMtimeLocalDiscovery()
  1407. {
  1408. constexpr auto INVALID_MTIME1 = 0;
  1409. constexpr auto INVALID_MTIME2 = 0xFFFFFFFF;
  1410. constexpr auto CURRENT_MTIME = 1646057277;
  1411. FakeFolder fakeFolder{FileInfo{}};
  1412. setupVfs(fakeFolder);
  1413. QCOMPARE(fakeFolder.currentLocalState(), fakeFolder.currentRemoteState());
  1414. QSignalSpy statusSpy(&fakeFolder.syncEngine().syncFileStatusTracker(), &SyncFileStatusTracker::fileStatusChanged);
  1415. const QString fooFileRootFolder("foo");
  1416. const QString barFileRootFolder("bar");
  1417. const QString fooFileSubFolder("subfolder/foo");
  1418. const QString barFileSubFolder("subfolder/bar");
  1419. const QString fooFileAaaSubFolder("aaa/subfolder/foo");
  1420. const QString barFileAaaSubFolder("aaa/subfolder/bar");
  1421. auto checkStatus = [&]() -> SyncFileStatus::SyncFileStatusTag {
  1422. auto file = QFileInfo{fakeFolder.syncEngine().localPath(), barFileAaaSubFolder};
  1423. auto locPath = fakeFolder.syncEngine().localPath();
  1424. auto itemFound = false;
  1425. // Start from the end to get the latest status
  1426. for (int i = statusSpy.size() - 1; i >= 0 && !itemFound; --i) {
  1427. if (QFileInfo(statusSpy.at(i)[0].toString()) == file) {
  1428. itemFound = true;
  1429. return statusSpy.at(i)[1].value<SyncFileStatus>().tag();
  1430. }
  1431. }
  1432. return {};
  1433. };
  1434. fakeFolder.localModifier().insert(fooFileRootFolder);
  1435. fakeFolder.localModifier().insert(barFileRootFolder);
  1436. fakeFolder.localModifier().mkdir(QStringLiteral("subfolder"));
  1437. fakeFolder.localModifier().insert(fooFileSubFolder);
  1438. fakeFolder.localModifier().insert(barFileSubFolder);
  1439. fakeFolder.localModifier().mkdir(QStringLiteral("aaa"));
  1440. fakeFolder.localModifier().mkdir(QStringLiteral("aaa/subfolder"));
  1441. fakeFolder.localModifier().insert(fooFileAaaSubFolder);
  1442. fakeFolder.localModifier().insert(barFileAaaSubFolder);
  1443. fakeFolder.localModifier().setModTime(barFileAaaSubFolder, QDateTime::fromSecsSinceEpoch(INVALID_MTIME1));
  1444. fakeFolder.scheduleSync();
  1445. fakeFolder.execUntilBeforePropagation();
  1446. QCOMPARE(checkStatus(), SyncFileStatus::StatusError);
  1447. fakeFolder.execUntilFinished();
  1448. fakeFolder.localModifier().setModTime(barFileAaaSubFolder, QDateTime::fromSecsSinceEpoch(CURRENT_MTIME));
  1449. QVERIFY(fakeFolder.syncOnce());
  1450. fakeFolder.localModifier().appendByte(barFileAaaSubFolder);
  1451. fakeFolder.localModifier().setModTime(barFileAaaSubFolder, QDateTime::fromSecsSinceEpoch(INVALID_MTIME1));
  1452. fakeFolder.scheduleSync();
  1453. fakeFolder.execUntilBeforePropagation();
  1454. QCOMPARE(checkStatus(), SyncFileStatus::StatusError);
  1455. fakeFolder.execUntilFinished();
  1456. fakeFolder.localModifier().setModTime(barFileAaaSubFolder, QDateTime::fromSecsSinceEpoch(CURRENT_MTIME));
  1457. QVERIFY(fakeFolder.syncOnce());
  1458. fakeFolder.localModifier().appendByte(barFileAaaSubFolder);
  1459. fakeFolder.localModifier().setModTime(barFileAaaSubFolder, QDateTime::fromSecsSinceEpoch(INVALID_MTIME2));
  1460. fakeFolder.scheduleSync();
  1461. fakeFolder.execUntilBeforePropagation();
  1462. QCOMPARE(checkStatus(), SyncFileStatus::StatusError);
  1463. fakeFolder.execUntilFinished();
  1464. }
  1465. void testServer_caseClash_createConflict()
  1466. {
  1467. constexpr auto testLowerCaseFile = "test";
  1468. constexpr auto testUpperCaseFile = "TEST";
  1469. #if defined Q_OS_LINUX
  1470. constexpr auto shouldHaveCaseClashConflict = false;
  1471. #else
  1472. constexpr auto shouldHaveCaseClashConflict = true;
  1473. #endif
  1474. FakeFolder fakeFolder{FileInfo{}};
  1475. setupVfs(fakeFolder);
  1476. fakeFolder.remoteModifier().insert("otherFile.txt");
  1477. fakeFolder.remoteModifier().insert(testLowerCaseFile);
  1478. fakeFolder.remoteModifier().insert(testUpperCaseFile);
  1479. fakeFolder.syncEngine().setLocalDiscoveryOptions(OCC::LocalDiscoveryStyle::DatabaseAndFilesystem);
  1480. QVERIFY(fakeFolder.syncOnce());
  1481. auto conflicts = findCaseClashConflicts(fakeFolder.currentLocalState());
  1482. QCOMPARE(conflicts.size(), shouldHaveCaseClashConflict ? 1 : 0);
  1483. const auto hasConflict = expectConflict(fakeFolder.currentLocalState(), testLowerCaseFile);
  1484. QCOMPARE(hasConflict, shouldHaveCaseClashConflict ? true : false);
  1485. fakeFolder.syncEngine().setLocalDiscoveryOptions(OCC::LocalDiscoveryStyle::DatabaseAndFilesystem);
  1486. QVERIFY(fakeFolder.syncOnce());
  1487. conflicts = findCaseClashConflicts(fakeFolder.currentLocalState());
  1488. QCOMPARE(conflicts.size(), shouldHaveCaseClashConflict ? 1 : 0);
  1489. }
  1490. void testServer_subFolderCaseClash_createConflict()
  1491. {
  1492. constexpr auto testLowerCaseFile = "a/b/test";
  1493. constexpr auto testUpperCaseFile = "a/b/TEST";
  1494. #if defined Q_OS_LINUX
  1495. constexpr auto shouldHaveCaseClashConflict = false;
  1496. #else
  1497. constexpr auto shouldHaveCaseClashConflict = true;
  1498. #endif
  1499. FakeFolder fakeFolder{ FileInfo{} };
  1500. setupVfs(fakeFolder);
  1501. fakeFolder.remoteModifier().mkdir("a");
  1502. fakeFolder.remoteModifier().mkdir("a/b");
  1503. fakeFolder.remoteModifier().insert("a/b/otherFile.txt");
  1504. fakeFolder.remoteModifier().insert(testLowerCaseFile);
  1505. fakeFolder.remoteModifier().insert(testUpperCaseFile);
  1506. fakeFolder.syncEngine().setLocalDiscoveryOptions(OCC::LocalDiscoveryStyle::DatabaseAndFilesystem);
  1507. QVERIFY(fakeFolder.syncOnce());
  1508. auto conflicts = findCaseClashConflicts(*fakeFolder.currentLocalState().find("a/b"));
  1509. QCOMPARE(conflicts.size(), shouldHaveCaseClashConflict ? 1 : 0);
  1510. const auto hasConflict = expectConflict(fakeFolder.currentLocalState(), testLowerCaseFile);
  1511. QCOMPARE(hasConflict, shouldHaveCaseClashConflict ? true : false);
  1512. fakeFolder.syncEngine().setLocalDiscoveryOptions(OCC::LocalDiscoveryStyle::DatabaseAndFilesystem);
  1513. QVERIFY(fakeFolder.syncOnce());
  1514. conflicts = findCaseClashConflicts(*fakeFolder.currentLocalState().find("a/b"));
  1515. QCOMPARE(conflicts.size(), shouldHaveCaseClashConflict ? 1 : 0);
  1516. }
  1517. void testServer_caseClash_createConflictOnMove()
  1518. {
  1519. constexpr auto testLowerCaseFile = "test";
  1520. constexpr auto testUpperCaseFile = "TEST2";
  1521. constexpr auto testUpperCaseFileAfterMove = "TEST";
  1522. #if defined Q_OS_LINUX
  1523. constexpr auto shouldHaveCaseClashConflict = false;
  1524. #else
  1525. constexpr auto shouldHaveCaseClashConflict = true;
  1526. #endif
  1527. FakeFolder fakeFolder{ FileInfo{} };
  1528. setupVfs(fakeFolder);
  1529. fakeFolder.remoteModifier().insert("otherFile.txt");
  1530. fakeFolder.remoteModifier().insert(testLowerCaseFile);
  1531. fakeFolder.remoteModifier().insert(testUpperCaseFile);
  1532. fakeFolder.syncEngine().setLocalDiscoveryOptions(OCC::LocalDiscoveryStyle::DatabaseAndFilesystem);
  1533. QVERIFY(fakeFolder.syncOnce());
  1534. auto conflicts = findCaseClashConflicts(fakeFolder.currentLocalState());
  1535. QCOMPARE(conflicts.size(), 0);
  1536. const auto hasConflict = expectConflict(fakeFolder.currentLocalState(), testLowerCaseFile);
  1537. QCOMPARE(hasConflict, false);
  1538. fakeFolder.remoteModifier().rename(testUpperCaseFile, testUpperCaseFileAfterMove);
  1539. fakeFolder.syncEngine().setLocalDiscoveryOptions(OCC::LocalDiscoveryStyle::DatabaseAndFilesystem);
  1540. QVERIFY(fakeFolder.syncOnce());
  1541. conflicts = findCaseClashConflicts(fakeFolder.currentLocalState());
  1542. QCOMPARE(conflicts.size(), shouldHaveCaseClashConflict ? 1 : 0);
  1543. const auto hasConflictAfterMove = expectConflict(fakeFolder.currentLocalState(), testUpperCaseFileAfterMove);
  1544. QCOMPARE(hasConflictAfterMove, shouldHaveCaseClashConflict ? true : false);
  1545. fakeFolder.syncEngine().setLocalDiscoveryOptions(OCC::LocalDiscoveryStyle::DatabaseAndFilesystem);
  1546. QVERIFY(fakeFolder.syncOnce());
  1547. conflicts = findCaseClashConflicts(fakeFolder.currentLocalState());
  1548. QCOMPARE(conflicts.size(), shouldHaveCaseClashConflict ? 1 : 0);
  1549. }
  1550. void testServer_subFolderCaseClash_createConflictOnMove()
  1551. {
  1552. constexpr auto testLowerCaseFile = "a/b/test";
  1553. constexpr auto testUpperCaseFile = "a/b/TEST2";
  1554. constexpr auto testUpperCaseFileAfterMove = "a/b/TEST";
  1555. #if defined Q_OS_LINUX
  1556. constexpr auto shouldHaveCaseClashConflict = false;
  1557. #else
  1558. constexpr auto shouldHaveCaseClashConflict = true;
  1559. #endif
  1560. FakeFolder fakeFolder{ FileInfo{} };
  1561. setupVfs(fakeFolder);
  1562. fakeFolder.remoteModifier().mkdir("a");
  1563. fakeFolder.remoteModifier().mkdir("a/b");
  1564. fakeFolder.remoteModifier().insert("a/b/otherFile.txt");
  1565. fakeFolder.remoteModifier().insert(testLowerCaseFile);
  1566. fakeFolder.remoteModifier().insert(testUpperCaseFile);
  1567. fakeFolder.syncEngine().setLocalDiscoveryOptions(OCC::LocalDiscoveryStyle::DatabaseAndFilesystem);
  1568. QVERIFY(fakeFolder.syncOnce());
  1569. auto conflicts = findCaseClashConflicts(*fakeFolder.currentLocalState().find("a/b"));
  1570. QCOMPARE(conflicts.size(), 0);
  1571. const auto hasConflict = expectConflict(fakeFolder.currentLocalState(), testLowerCaseFile);
  1572. QCOMPARE(hasConflict, false);
  1573. fakeFolder.remoteModifier().rename(testUpperCaseFile, testUpperCaseFileAfterMove);
  1574. fakeFolder.syncEngine().setLocalDiscoveryOptions(OCC::LocalDiscoveryStyle::DatabaseAndFilesystem);
  1575. QVERIFY(fakeFolder.syncOnce());
  1576. conflicts = findCaseClashConflicts(*fakeFolder.currentLocalState().find("a/b"));
  1577. QCOMPARE(conflicts.size(), shouldHaveCaseClashConflict ? 1 : 0);
  1578. const auto hasConflictAfterMove = expectConflict(fakeFolder.currentLocalState(), testUpperCaseFileAfterMove);
  1579. QCOMPARE(hasConflictAfterMove, shouldHaveCaseClashConflict ? true : false);
  1580. fakeFolder.syncEngine().setLocalDiscoveryOptions(OCC::LocalDiscoveryStyle::DatabaseAndFilesystem);
  1581. QVERIFY(fakeFolder.syncOnce());
  1582. conflicts = findCaseClashConflicts(*fakeFolder.currentLocalState().find("a/b"));
  1583. QCOMPARE(conflicts.size(), shouldHaveCaseClashConflict ? 1 : 0);
  1584. }
  1585. void testDataFingerPrint()
  1586. {
  1587. FakeFolder fakeFolder{ FileInfo{} };
  1588. setupVfs(fakeFolder);
  1589. fakeFolder.remoteModifier().mkdir("a");
  1590. fakeFolder.remoteModifier().mkdir("a/b");
  1591. fakeFolder.remoteModifier().mkdir("a/b/d");
  1592. fakeFolder.remoteModifier().insert("a/b/otherFile.txt");
  1593. //Server support finger print, but none is set.
  1594. fakeFolder.remoteModifier().extraDavProperties = "<oc:data-fingerprint></oc:data-fingerprint>";
  1595. fakeFolder.syncEngine().setLocalDiscoveryOptions(OCC::LocalDiscoveryStyle::DatabaseAndFilesystem);
  1596. QVERIFY(fakeFolder.syncOnce());
  1597. fakeFolder.remoteModifier().remove("a/b/otherFile.txt");
  1598. fakeFolder.remoteModifier().remove("a/b/d");
  1599. fakeFolder.remoteModifier().extraDavProperties = "<oc:data-fingerprint>initial_finger_print</oc:data-fingerprint>";
  1600. fakeFolder.syncEngine().setLocalDiscoveryOptions(OCC::LocalDiscoveryStyle::DatabaseAndFilesystem);
  1601. QVERIFY(fakeFolder.syncOnce());
  1602. QCOMPARE(fakeFolder.currentLocalState(), fakeFolder.currentRemoteState());
  1603. }
  1604. };
  1605. QTEST_GUILESS_MAIN(TestSyncVirtualFiles)
  1606. #include "testsyncvirtualfiles.moc"