testsyncconflict.cpp 24 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562
  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 <syncengine.h>
  10. using namespace OCC;
  11. SyncFileItemPtr findItem(const QSignalSpy &spy, const QString &path)
  12. {
  13. for (const QList<QVariant> &args : spy) {
  14. auto item = args[0].value<SyncFileItemPtr>();
  15. if (item->destination() == path)
  16. return item;
  17. }
  18. return SyncFileItemPtr(new SyncFileItem);
  19. }
  20. bool itemSuccessful(const QSignalSpy &spy, const QString &path, const csync_instructions_e instr)
  21. {
  22. auto item = findItem(spy, path);
  23. return item->_status == SyncFileItem::Success && item->_instruction == instr;
  24. }
  25. bool itemConflict(const QSignalSpy &spy, const QString &path)
  26. {
  27. auto item = findItem(spy, path);
  28. return item->_status == SyncFileItem::Conflict && item->_instruction == CSYNC_INSTRUCTION_CONFLICT;
  29. }
  30. bool itemSuccessfulMove(const QSignalSpy &spy, const QString &path)
  31. {
  32. return itemSuccessful(spy, path, CSYNC_INSTRUCTION_RENAME);
  33. }
  34. QStringList findConflicts(const FileInfo &dir)
  35. {
  36. QStringList conflicts;
  37. for (const auto &item : dir.children) {
  38. if (item.name.contains("conflict")) {
  39. conflicts.append(item.path());
  40. }
  41. }
  42. return conflicts;
  43. }
  44. bool expectAndWipeConflict(FileModifier &local, FileInfo state, const QString path)
  45. {
  46. PathComponents pathComponents(path);
  47. auto base = state.find(pathComponents.parentDirComponents());
  48. if (!base)
  49. return false;
  50. for (const auto &item : base->children) {
  51. if (item.name.startsWith(pathComponents.fileName()) && item.name.contains("_conflict")) {
  52. local.remove(item.path());
  53. return true;
  54. }
  55. }
  56. return false;
  57. }
  58. class TestSyncConflict : public QObject
  59. {
  60. Q_OBJECT
  61. private slots:
  62. void testNoUpload()
  63. {
  64. FakeFolder fakeFolder{ FileInfo::A12_B12_C12_S12() };
  65. QCOMPARE(fakeFolder.currentLocalState(), fakeFolder.currentRemoteState());
  66. fakeFolder.localModifier().setContents("A/a1", 'L');
  67. fakeFolder.remoteModifier().setContents("A/a1", 'R');
  68. fakeFolder.localModifier().appendByte("A/a2");
  69. fakeFolder.remoteModifier().appendByte("A/a2");
  70. fakeFolder.remoteModifier().appendByte("A/a2");
  71. QVERIFY(fakeFolder.syncOnce());
  72. // Verify that the conflict names don't have the user name
  73. for (const auto &name : findConflicts(fakeFolder.currentLocalState().children["A"])) {
  74. QVERIFY(!name.contains(fakeFolder.syncEngine().account()->davDisplayName()));
  75. }
  76. QVERIFY(expectAndWipeConflict(fakeFolder.localModifier(), fakeFolder.currentLocalState(), "A/a1"));
  77. QVERIFY(expectAndWipeConflict(fakeFolder.localModifier(), fakeFolder.currentLocalState(), "A/a2"));
  78. QCOMPARE(fakeFolder.currentLocalState(), fakeFolder.currentRemoteState());
  79. }
  80. void testUploadAfterDownload()
  81. {
  82. FakeFolder fakeFolder{ FileInfo::A12_B12_C12_S12() };
  83. fakeFolder.syncEngine().account()->setCapabilities({ { "uploadConflictFiles", true } });
  84. QCOMPARE(fakeFolder.currentLocalState(), fakeFolder.currentRemoteState());
  85. QMap<QByteArray, QString> conflictMap;
  86. fakeFolder.setServerOverride([&](QNetworkAccessManager::Operation op, const QNetworkRequest &request, QIODevice *) -> QNetworkReply * {
  87. if (op == QNetworkAccessManager::PutOperation) {
  88. auto baseFileId = request.rawHeader("OC-ConflictBaseFileId");
  89. if (!baseFileId.isEmpty()) {
  90. auto components = request.url().toString().split('/');
  91. QString conflictFile = components.mid(components.size() - 2).join('/');
  92. conflictMap[baseFileId] = conflictFile;
  93. }
  94. }
  95. return nullptr;
  96. });
  97. fakeFolder.localModifier().setContents("A/a1", 'L');
  98. fakeFolder.remoteModifier().setContents("A/a1", 'R');
  99. fakeFolder.localModifier().appendByte("A/a2");
  100. fakeFolder.remoteModifier().appendByte("A/a2");
  101. fakeFolder.remoteModifier().appendByte("A/a2");
  102. QVERIFY(fakeFolder.syncOnce());
  103. auto local = fakeFolder.currentLocalState();
  104. auto remote = fakeFolder.currentRemoteState();
  105. QCOMPARE(local, remote);
  106. auto a1FileId = fakeFolder.remoteModifier().find("A/a1")->fileId;
  107. auto a2FileId = fakeFolder.remoteModifier().find("A/a2")->fileId;
  108. QVERIFY(conflictMap.contains(a1FileId));
  109. QVERIFY(conflictMap.contains(a2FileId));
  110. QCOMPARE(conflictMap.size(), 2);
  111. QCOMPARE(Utility::conflictFileBaseName(conflictMap[a1FileId].toUtf8()), QByteArray("A/a1"));
  112. // Check that the conflict file contains the username
  113. QVERIFY(conflictMap[a1FileId].contains(QString("-%1-").arg(fakeFolder.syncEngine().account()->davDisplayName())));
  114. QCOMPARE(remote.find(conflictMap[a1FileId])->contentChar, 'L');
  115. QCOMPARE(remote.find("A/a1")->contentChar, 'R');
  116. QCOMPARE(remote.find(conflictMap[a2FileId])->size, 5);
  117. QCOMPARE(remote.find("A/a2")->size, 6);
  118. }
  119. void testSeparateUpload()
  120. {
  121. FakeFolder fakeFolder{ FileInfo::A12_B12_C12_S12() };
  122. fakeFolder.syncEngine().account()->setCapabilities({ { "uploadConflictFiles", true } });
  123. QCOMPARE(fakeFolder.currentLocalState(), fakeFolder.currentRemoteState());
  124. QMap<QByteArray, QString> conflictMap;
  125. fakeFolder.setServerOverride([&](QNetworkAccessManager::Operation op, const QNetworkRequest &request, QIODevice *) -> QNetworkReply * {
  126. if (op == QNetworkAccessManager::PutOperation) {
  127. auto baseFileId = request.rawHeader("OC-ConflictBaseFileId");
  128. if (!baseFileId.isEmpty()) {
  129. auto components = request.url().toString().split('/');
  130. QString conflictFile = components.mid(components.size() - 2).join('/');
  131. conflictMap[baseFileId] = conflictFile;
  132. }
  133. }
  134. return nullptr;
  135. });
  136. // Explicitly add a conflict file to simulate the case where the upload of the
  137. // file didn't finish in the same sync run that the conflict was created.
  138. // To do that we need to create a mock conflict record.
  139. auto a1FileId = fakeFolder.remoteModifier().find("A/a1")->fileId;
  140. QString conflictName = QLatin1String("A/a1_conflict-me-1234");
  141. fakeFolder.localModifier().insert(conflictName, 64, 'L');
  142. ConflictRecord conflictRecord;
  143. conflictRecord.path = conflictName.toUtf8();
  144. conflictRecord.baseFileId = a1FileId;
  145. fakeFolder.syncJournal().setConflictRecord(conflictRecord);
  146. QVERIFY(fakeFolder.syncOnce());
  147. QCOMPARE(fakeFolder.currentLocalState(), fakeFolder.currentRemoteState());
  148. QCOMPARE(conflictMap.size(), 1);
  149. QCOMPARE(conflictMap[a1FileId], conflictName);
  150. QCOMPARE(fakeFolder.currentRemoteState().find(conflictMap[a1FileId])->contentChar, 'L');
  151. conflictMap.clear();
  152. // Now the user can locally alter the conflict file and it will be uploaded
  153. // as usual.
  154. fakeFolder.localModifier().setContents(conflictName, 'P');
  155. QVERIFY(fakeFolder.syncOnce());
  156. QCOMPARE(conflictMap.size(), 1);
  157. QCOMPARE(conflictMap[a1FileId], conflictName);
  158. QCOMPARE(fakeFolder.currentLocalState(), fakeFolder.currentRemoteState());
  159. conflictMap.clear();
  160. // Similarly, remote modifications of conflict files get propagated downwards
  161. fakeFolder.remoteModifier().setContents(conflictName, 'Q');
  162. QVERIFY(fakeFolder.syncOnce());
  163. QCOMPARE(fakeFolder.currentLocalState(), fakeFolder.currentRemoteState());
  164. QVERIFY(conflictMap.isEmpty());
  165. // Conflict files for conflict files!
  166. auto a1ConflictFileId = fakeFolder.remoteModifier().find(conflictName)->fileId;
  167. fakeFolder.remoteModifier().appendByte(conflictName);
  168. fakeFolder.remoteModifier().appendByte(conflictName);
  169. fakeFolder.localModifier().appendByte(conflictName);
  170. QVERIFY(fakeFolder.syncOnce());
  171. QCOMPARE(fakeFolder.currentLocalState(), fakeFolder.currentRemoteState());
  172. QCOMPARE(conflictMap.size(), 1);
  173. QVERIFY(conflictMap.contains(a1ConflictFileId));
  174. QCOMPARE(fakeFolder.currentRemoteState().find(conflictName)->size, 66);
  175. QCOMPARE(fakeFolder.currentRemoteState().find(conflictMap[a1ConflictFileId])->size, 65);
  176. conflictMap.clear();
  177. }
  178. // What happens if we download a conflict file? Is the metadata set up correctly?
  179. void testDownloadingConflictFile()
  180. {
  181. FakeFolder fakeFolder{ FileInfo::A12_B12_C12_S12() };
  182. fakeFolder.syncEngine().account()->setCapabilities({ { "uploadConflictFiles", true } });
  183. QCOMPARE(fakeFolder.currentLocalState(), fakeFolder.currentRemoteState());
  184. // With no headers from the server
  185. fakeFolder.remoteModifier().insert("A/a1_conflict-1234");
  186. QVERIFY(fakeFolder.syncOnce());
  187. QCOMPARE(fakeFolder.currentLocalState(), fakeFolder.currentRemoteState());
  188. auto conflictRecord = fakeFolder.syncJournal().conflictRecord("A/a1_conflict-1234");
  189. QVERIFY(conflictRecord.isValid());
  190. QCOMPARE(conflictRecord.baseFileId, fakeFolder.remoteModifier().find("A/a1")->fileId);
  191. // Now with server headers
  192. QObject parent;
  193. auto a2FileId = fakeFolder.remoteModifier().find("A/a2")->fileId;
  194. fakeFolder.setServerOverride([&](QNetworkAccessManager::Operation op, const QNetworkRequest &request, QIODevice *) -> QNetworkReply * {
  195. if (op == QNetworkAccessManager::GetOperation) {
  196. auto reply = new FakeGetReply(fakeFolder.remoteModifier(), op, request, &parent);
  197. reply->setRawHeader("OC-Conflict", "1");
  198. reply->setRawHeader("OC-ConflictBaseFileId", a2FileId);
  199. reply->setRawHeader("OC-ConflictBaseMtime", "1234");
  200. reply->setRawHeader("OC-ConflictBaseEtag", "etag");
  201. return reply;
  202. }
  203. return nullptr;
  204. });
  205. fakeFolder.remoteModifier().insert("A/really-a-conflict"); // doesn't look like a conflict, but headers say it is
  206. QVERIFY(fakeFolder.syncOnce());
  207. QCOMPARE(fakeFolder.currentLocalState(), fakeFolder.currentRemoteState());
  208. conflictRecord = fakeFolder.syncJournal().conflictRecord("A/really-a-conflict");
  209. QVERIFY(conflictRecord.isValid());
  210. QCOMPARE(conflictRecord.baseFileId, a2FileId);
  211. QCOMPARE(conflictRecord.baseModtime, 1234);
  212. QCOMPARE(conflictRecord.baseEtag, QByteArray("etag"));
  213. }
  214. // Check that conflict records are removed when the file is gone
  215. void testConflictRecordRemoval1()
  216. {
  217. FakeFolder fakeFolder{ FileInfo::A12_B12_C12_S12() };
  218. fakeFolder.syncEngine().account()->setCapabilities({ { "uploadConflictFiles", true } });
  219. QCOMPARE(fakeFolder.currentLocalState(), fakeFolder.currentRemoteState());
  220. // Make conflict records
  221. ConflictRecord conflictRecord;
  222. conflictRecord.path = "A/a1";
  223. fakeFolder.syncJournal().setConflictRecord(conflictRecord);
  224. conflictRecord.path = "A/a2";
  225. fakeFolder.syncJournal().setConflictRecord(conflictRecord);
  226. // A nothing-to-sync keeps them alive
  227. QVERIFY(fakeFolder.syncOnce());
  228. QCOMPARE(fakeFolder.currentLocalState(), fakeFolder.currentRemoteState());
  229. QVERIFY(fakeFolder.syncJournal().conflictRecord("A/a1").isValid());
  230. QVERIFY(fakeFolder.syncJournal().conflictRecord("A/a2").isValid());
  231. // When the file is removed, the record is removed too
  232. fakeFolder.localModifier().remove("A/a2");
  233. QVERIFY(fakeFolder.syncOnce());
  234. QCOMPARE(fakeFolder.currentLocalState(), fakeFolder.currentRemoteState());
  235. QVERIFY(fakeFolder.syncJournal().conflictRecord("A/a1").isValid());
  236. QVERIFY(!fakeFolder.syncJournal().conflictRecord("A/a2").isValid());
  237. }
  238. // Same test, but with uploadConflictFiles == false
  239. void testConflictRecordRemoval2()
  240. {
  241. FakeFolder fakeFolder{ FileInfo::A12_B12_C12_S12() };
  242. fakeFolder.syncEngine().account()->setCapabilities({ { "uploadConflictFiles", false } });
  243. QCOMPARE(fakeFolder.currentLocalState(), fakeFolder.currentRemoteState());
  244. // Create two conflicts
  245. fakeFolder.localModifier().appendByte("A/a1");
  246. fakeFolder.localModifier().appendByte("A/a1");
  247. fakeFolder.remoteModifier().appendByte("A/a1");
  248. fakeFolder.localModifier().appendByte("A/a2");
  249. fakeFolder.localModifier().appendByte("A/a2");
  250. fakeFolder.remoteModifier().appendByte("A/a2");
  251. QVERIFY(fakeFolder.syncOnce());
  252. auto conflicts = findConflicts(fakeFolder.currentLocalState().children["A"]);
  253. QByteArray a1conflict;
  254. QByteArray a2conflict;
  255. for (const auto & conflict : conflicts) {
  256. if (conflict.contains("a1"))
  257. a1conflict = conflict.toUtf8();
  258. if (conflict.contains("a2"))
  259. a2conflict = conflict.toUtf8();
  260. }
  261. // A nothing-to-sync keeps them alive
  262. QVERIFY(fakeFolder.syncOnce());
  263. QVERIFY(fakeFolder.syncJournal().conflictRecord(a1conflict).isValid());
  264. QVERIFY(fakeFolder.syncJournal().conflictRecord(a2conflict).isValid());
  265. // When the file is removed, the record is removed too
  266. fakeFolder.localModifier().remove(a2conflict);
  267. QVERIFY(fakeFolder.syncOnce());
  268. QVERIFY(fakeFolder.syncJournal().conflictRecord(a1conflict).isValid());
  269. QVERIFY(!fakeFolder.syncJournal().conflictRecord(a2conflict).isValid());
  270. }
  271. void testConflictFileBaseName_data()
  272. {
  273. QTest::addColumn<QString>("input");
  274. QTest::addColumn<QString>("output");
  275. QTest::newRow("")
  276. << "a/b/foo"
  277. << "";
  278. QTest::newRow("")
  279. << "a/b/foo.txt"
  280. << "";
  281. QTest::newRow("")
  282. << "a/b/foo_conflict"
  283. << "";
  284. QTest::newRow("")
  285. << "a/b/foo_conflict.txt"
  286. << "";
  287. QTest::newRow("")
  288. << "a/b/foo_conflict-123.txt"
  289. << "a/b/foo.txt";
  290. QTest::newRow("")
  291. << "a/b/foo_conflict-foo-123.txt"
  292. << "a/b/foo.txt";
  293. QTest::newRow("")
  294. << "a/b/foo_conflict-123"
  295. << "a/b/foo";
  296. QTest::newRow("")
  297. << "a/b/foo_conflict-foo-123"
  298. << "a/b/foo";
  299. // double conflict files
  300. QTest::newRow("")
  301. << "a/b/foo_conflict-123_conflict-456.txt"
  302. << "a/b/foo_conflict-123.txt";
  303. QTest::newRow("")
  304. << "a/b/foo_conflict-foo-123_conflict-bar-456.txt"
  305. << "a/b/foo_conflict-foo-123.txt";
  306. }
  307. void testConflictFileBaseName()
  308. {
  309. QFETCH(QString, input);
  310. QFETCH(QString, output);
  311. QCOMPARE(Utility::conflictFileBaseName(input.toUtf8()), output.toUtf8());
  312. }
  313. void testLocalDirRemoteFileConflict()
  314. {
  315. FakeFolder fakeFolder{ FileInfo::A12_B12_C12_S12() };
  316. fakeFolder.syncEngine().account()->setCapabilities({ { "uploadConflictFiles", true } });
  317. QSignalSpy completeSpy(&fakeFolder.syncEngine(), SIGNAL(itemCompleted(const SyncFileItemPtr &)));
  318. auto cleanup = [&]() {
  319. completeSpy.clear();
  320. };
  321. cleanup();
  322. // 1) a NEW/NEW conflict
  323. fakeFolder.localModifier().mkdir("Z");
  324. fakeFolder.localModifier().mkdir("Z/subdir");
  325. fakeFolder.localModifier().insert("Z/foo");
  326. fakeFolder.remoteModifier().insert("Z", 63);
  327. // 2) local file becomes a dir; remote file changes
  328. fakeFolder.localModifier().remove("A/a1");
  329. fakeFolder.localModifier().mkdir("A/a1");
  330. fakeFolder.localModifier().insert("A/a1/bar");
  331. fakeFolder.remoteModifier().appendByte("A/a1");
  332. // 3) local dir gets a new file; remote dir becomes a file
  333. fakeFolder.localModifier().insert("B/zzz");
  334. fakeFolder.remoteModifier().remove("B");
  335. fakeFolder.remoteModifier().insert("B", 31);
  336. QVERIFY(fakeFolder.syncOnce());
  337. auto conflicts = findConflicts(fakeFolder.currentLocalState());
  338. conflicts += findConflicts(fakeFolder.currentLocalState().children["A"]);
  339. QCOMPARE(conflicts.size(), 3);
  340. std::sort(conflicts.begin(), conflicts.end());
  341. auto conflictRecords = fakeFolder.syncJournal().conflictRecordPaths();
  342. QCOMPARE(conflictRecords.size(), 3);
  343. std::sort(conflictRecords.begin(), conflictRecords.end());
  344. // 1)
  345. QVERIFY(itemConflict(completeSpy, "Z"));
  346. QCOMPARE(fakeFolder.currentLocalState().find("Z")->size, 63);
  347. QVERIFY(conflicts[2].contains("Z"));
  348. QCOMPARE(conflicts[2].toUtf8(), conflictRecords[2]);
  349. QVERIFY(QFileInfo(fakeFolder.localPath() + conflicts[2]).isDir());
  350. QVERIFY(QFile::exists(fakeFolder.localPath() + conflicts[2] + "/foo"));
  351. // 2)
  352. QVERIFY(itemConflict(completeSpy, "A/a1"));
  353. QCOMPARE(fakeFolder.currentLocalState().find("A/a1")->size, 5);
  354. QVERIFY(conflicts[0].contains("A/a1"));
  355. QCOMPARE(conflicts[0].toUtf8(), conflictRecords[0]);
  356. QVERIFY(QFileInfo(fakeFolder.localPath() + conflicts[0]).isDir());
  357. QVERIFY(QFile::exists(fakeFolder.localPath() + conflicts[0] + "/bar"));
  358. // 3)
  359. QVERIFY(itemConflict(completeSpy, "B"));
  360. QCOMPARE(fakeFolder.currentLocalState().find("B")->size, 31);
  361. QVERIFY(conflicts[1].contains("B"));
  362. QCOMPARE(conflicts[1].toUtf8(), conflictRecords[1]);
  363. QVERIFY(QFileInfo(fakeFolder.localPath() + conflicts[1]).isDir());
  364. QVERIFY(QFile::exists(fakeFolder.localPath() + conflicts[1] + "/zzz"));
  365. // The contents of the conflict directories will only be uploaded after
  366. // another sync.
  367. QVERIFY(fakeFolder.syncEngine().isAnotherSyncNeeded() == ImmediateFollowUp);
  368. cleanup();
  369. QVERIFY(fakeFolder.syncOnce());
  370. QVERIFY(itemSuccessful(completeSpy, conflicts[0], CSYNC_INSTRUCTION_NEW));
  371. QVERIFY(itemSuccessful(completeSpy, conflicts[0] + "/bar", CSYNC_INSTRUCTION_NEW));
  372. QVERIFY(itemSuccessful(completeSpy, conflicts[1], CSYNC_INSTRUCTION_NEW));
  373. QVERIFY(itemSuccessful(completeSpy, conflicts[1] + "/zzz", CSYNC_INSTRUCTION_NEW));
  374. QVERIFY(itemSuccessful(completeSpy, conflicts[2], CSYNC_INSTRUCTION_NEW));
  375. QVERIFY(itemSuccessful(completeSpy, conflicts[2] + "/foo", CSYNC_INSTRUCTION_NEW));
  376. QCOMPARE(fakeFolder.currentLocalState(), fakeFolder.currentRemoteState());
  377. }
  378. void testLocalFileRemoteDirConflict()
  379. {
  380. FakeFolder fakeFolder{ FileInfo::A12_B12_C12_S12() };
  381. fakeFolder.syncEngine().account()->setCapabilities({ { "uploadConflictFiles", true } });
  382. QSignalSpy completeSpy(&fakeFolder.syncEngine(), SIGNAL(itemCompleted(const SyncFileItemPtr &)));
  383. // 1) a NEW/NEW conflict
  384. fakeFolder.remoteModifier().mkdir("Z");
  385. fakeFolder.remoteModifier().mkdir("Z/subdir");
  386. fakeFolder.remoteModifier().insert("Z/foo");
  387. fakeFolder.localModifier().insert("Z");
  388. // 2) local dir becomes file: remote dir adds file
  389. fakeFolder.localModifier().remove("A");
  390. fakeFolder.localModifier().insert("A", 63);
  391. fakeFolder.remoteModifier().insert("A/bar");
  392. // 3) local file changes; remote file becomes dir
  393. fakeFolder.localModifier().appendByte("B/b1");
  394. fakeFolder.remoteModifier().remove("B/b1");
  395. fakeFolder.remoteModifier().mkdir("B/b1");
  396. fakeFolder.remoteModifier().insert("B/b1/zzz");
  397. QVERIFY(fakeFolder.syncOnce());
  398. auto conflicts = findConflicts(fakeFolder.currentLocalState());
  399. conflicts += findConflicts(fakeFolder.currentLocalState().children["B"]);
  400. QCOMPARE(conflicts.size(), 3);
  401. std::sort(conflicts.begin(), conflicts.end());
  402. auto conflictRecords = fakeFolder.syncJournal().conflictRecordPaths();
  403. QCOMPARE(conflictRecords.size(), 3);
  404. std::sort(conflictRecords.begin(), conflictRecords.end());
  405. // 1)
  406. QVERIFY(itemConflict(completeSpy, "Z"));
  407. QVERIFY(conflicts[2].contains("Z"));
  408. QCOMPARE(conflicts[2].toUtf8(), conflictRecords[2]);
  409. // 2)
  410. QVERIFY(itemConflict(completeSpy, "A"));
  411. QVERIFY(conflicts[0].contains("A"));
  412. QCOMPARE(conflicts[0].toUtf8(), conflictRecords[0]);
  413. // 3)
  414. QVERIFY(itemConflict(completeSpy, "B/b1"));
  415. QVERIFY(conflicts[1].contains("B/b1"));
  416. QCOMPARE(conflicts[1].toUtf8(), conflictRecords[1]);
  417. // Also verifies that conflicts were uploaded
  418. QCOMPARE(fakeFolder.currentLocalState(), fakeFolder.currentRemoteState());
  419. }
  420. void testTypeConflictWithMove()
  421. {
  422. FakeFolder fakeFolder{ FileInfo::A12_B12_C12_S12() };
  423. QSignalSpy completeSpy(&fakeFolder.syncEngine(), SIGNAL(itemCompleted(const SyncFileItemPtr &)));
  424. // the remote becomes a file, but a file inside the dir has moved away!
  425. fakeFolder.remoteModifier().remove("A");
  426. fakeFolder.remoteModifier().insert("A");
  427. fakeFolder.localModifier().rename("A/a1", "a1");
  428. // same, but with a new file inside the dir locally
  429. fakeFolder.remoteModifier().remove("B");
  430. fakeFolder.remoteModifier().insert("B");
  431. fakeFolder.localModifier().rename("B/b1", "b1");
  432. fakeFolder.localModifier().insert("B/new");
  433. QVERIFY(fakeFolder.syncOnce());
  434. QVERIFY(itemSuccessful(completeSpy, "A", CSYNC_INSTRUCTION_TYPE_CHANGE));
  435. QVERIFY(itemConflict(completeSpy, "B"));
  436. auto conflicts = findConflicts(fakeFolder.currentLocalState());
  437. std::sort(conflicts.begin(), conflicts.end());
  438. QVERIFY(conflicts.size() == 2);
  439. QVERIFY(conflicts[0].contains("A_conflict"));
  440. QVERIFY(conflicts[1].contains("B_conflict"));
  441. for (auto conflict : conflicts)
  442. QDir(fakeFolder.localPath() + conflict).removeRecursively();
  443. QCOMPARE(fakeFolder.currentLocalState(), fakeFolder.currentRemoteState());
  444. // Currently a1 and b1 don't get moved, but redownloaded
  445. }
  446. void testTypeChange()
  447. {
  448. FakeFolder fakeFolder{ FileInfo::A12_B12_C12_S12() };
  449. QSignalSpy completeSpy(&fakeFolder.syncEngine(), SIGNAL(itemCompleted(const SyncFileItemPtr &)));
  450. // dir becomes file
  451. fakeFolder.remoteModifier().remove("A");
  452. fakeFolder.remoteModifier().insert("A");
  453. fakeFolder.localModifier().remove("B");
  454. fakeFolder.localModifier().insert("B");
  455. // file becomes dir
  456. fakeFolder.remoteModifier().remove("C/c1");
  457. fakeFolder.remoteModifier().mkdir("C/c1");
  458. fakeFolder.remoteModifier().insert("C/c1/foo");
  459. fakeFolder.localModifier().remove("C/c2");
  460. fakeFolder.localModifier().mkdir("C/c2");
  461. fakeFolder.localModifier().insert("C/c2/bar");
  462. QVERIFY(fakeFolder.syncOnce());
  463. QVERIFY(itemSuccessful(completeSpy, "A", CSYNC_INSTRUCTION_TYPE_CHANGE));
  464. QVERIFY(itemSuccessful(completeSpy, "B", CSYNC_INSTRUCTION_TYPE_CHANGE));
  465. QVERIFY(itemSuccessful(completeSpy, "C/c1", CSYNC_INSTRUCTION_TYPE_CHANGE));
  466. QVERIFY(itemSuccessful(completeSpy, "C/c2", CSYNC_INSTRUCTION_TYPE_CHANGE));
  467. // A becomes a conflict because we don't delete folders with files
  468. // inside of them!
  469. auto conflicts = findConflicts(fakeFolder.currentLocalState());
  470. QVERIFY(conflicts.size() == 1);
  471. QVERIFY(conflicts[0].contains("A_conflict"));
  472. for (auto conflict : conflicts)
  473. QDir(fakeFolder.localPath() + conflict).removeRecursively();
  474. QVERIFY(fakeFolder.syncEngine().isAnotherSyncNeeded() == ImmediateFollowUp);
  475. QVERIFY(fakeFolder.syncOnce());
  476. QCOMPARE(fakeFolder.currentLocalState(), fakeFolder.currentRemoteState());
  477. }
  478. };
  479. QTEST_GUILESS_MAIN(TestSyncConflict)
  480. #include "testsyncconflict.moc"