testsyncengine.cpp 28 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628
  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. bool itemDidComplete(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->_instruction != CSYNC_INSTRUCTION_NONE && item->_instruction != CSYNC_INSTRUCTION_UPDATE_METADATA;
  17. }
  18. return false;
  19. }
  20. bool itemDidCompleteSuccessfully(const QSignalSpy &spy, const QString &path)
  21. {
  22. for(const QList<QVariant> &args : spy) {
  23. auto item = args[0].value<SyncFileItemPtr>();
  24. if (item->destination() == path)
  25. return item->_status == SyncFileItem::Success;
  26. }
  27. return false;
  28. }
  29. class TestSyncEngine : public QObject
  30. {
  31. Q_OBJECT
  32. private slots:
  33. void testFileDownload() {
  34. FakeFolder fakeFolder{FileInfo::A12_B12_C12_S12()};
  35. QSignalSpy completeSpy(&fakeFolder.syncEngine(), SIGNAL(itemCompleted(const SyncFileItemPtr &)));
  36. fakeFolder.remoteModifier().insert("A/a0");
  37. fakeFolder.syncOnce();
  38. QVERIFY(itemDidCompleteSuccessfully(completeSpy, "A/a0"));
  39. QCOMPARE(fakeFolder.currentLocalState(), fakeFolder.currentRemoteState());
  40. }
  41. void testFileUpload() {
  42. FakeFolder fakeFolder{FileInfo::A12_B12_C12_S12()};
  43. QSignalSpy completeSpy(&fakeFolder.syncEngine(), SIGNAL(itemCompleted(const SyncFileItemPtr &)));
  44. fakeFolder.localModifier().insert("A/a0");
  45. fakeFolder.syncOnce();
  46. QVERIFY(itemDidCompleteSuccessfully(completeSpy, "A/a0"));
  47. QCOMPARE(fakeFolder.currentLocalState(), fakeFolder.currentRemoteState());
  48. }
  49. void testDirDownload() {
  50. FakeFolder fakeFolder{FileInfo::A12_B12_C12_S12()};
  51. QSignalSpy completeSpy(&fakeFolder.syncEngine(), SIGNAL(itemCompleted(const SyncFileItemPtr &)));
  52. fakeFolder.remoteModifier().mkdir("Y");
  53. fakeFolder.remoteModifier().mkdir("Z");
  54. fakeFolder.remoteModifier().insert("Z/d0");
  55. fakeFolder.syncOnce();
  56. QVERIFY(itemDidCompleteSuccessfully(completeSpy, "Y"));
  57. QVERIFY(itemDidCompleteSuccessfully(completeSpy, "Z"));
  58. QVERIFY(itemDidCompleteSuccessfully(completeSpy, "Z/d0"));
  59. QCOMPARE(fakeFolder.currentLocalState(), fakeFolder.currentRemoteState());
  60. }
  61. void testDirUpload() {
  62. FakeFolder fakeFolder{FileInfo::A12_B12_C12_S12()};
  63. QSignalSpy completeSpy(&fakeFolder.syncEngine(), SIGNAL(itemCompleted(const SyncFileItemPtr &)));
  64. fakeFolder.localModifier().mkdir("Y");
  65. fakeFolder.localModifier().mkdir("Z");
  66. fakeFolder.localModifier().insert("Z/d0");
  67. fakeFolder.syncOnce();
  68. QVERIFY(itemDidCompleteSuccessfully(completeSpy, "Y"));
  69. QVERIFY(itemDidCompleteSuccessfully(completeSpy, "Z"));
  70. QVERIFY(itemDidCompleteSuccessfully(completeSpy, "Z/d0"));
  71. QCOMPARE(fakeFolder.currentLocalState(), fakeFolder.currentRemoteState());
  72. }
  73. void testLocalDelete() {
  74. FakeFolder fakeFolder{FileInfo::A12_B12_C12_S12()};
  75. QSignalSpy completeSpy(&fakeFolder.syncEngine(), SIGNAL(itemCompleted(const SyncFileItemPtr &)));
  76. fakeFolder.remoteModifier().remove("A/a1");
  77. fakeFolder.syncOnce();
  78. QVERIFY(itemDidCompleteSuccessfully(completeSpy, "A/a1"));
  79. QCOMPARE(fakeFolder.currentLocalState(), fakeFolder.currentRemoteState());
  80. }
  81. void testRemoteDelete() {
  82. FakeFolder fakeFolder{FileInfo::A12_B12_C12_S12()};
  83. QSignalSpy completeSpy(&fakeFolder.syncEngine(), SIGNAL(itemCompleted(const SyncFileItemPtr &)));
  84. fakeFolder.localModifier().remove("A/a1");
  85. fakeFolder.syncOnce();
  86. QVERIFY(itemDidCompleteSuccessfully(completeSpy, "A/a1"));
  87. QCOMPARE(fakeFolder.currentLocalState(), fakeFolder.currentRemoteState());
  88. }
  89. void testEmlLocalChecksum() {
  90. FakeFolder fakeFolder{FileInfo{}};
  91. fakeFolder.localModifier().insert("a1.eml", 64, 'A');
  92. fakeFolder.localModifier().insert("a2.eml", 64, 'A');
  93. fakeFolder.localModifier().insert("a3.eml", 64, 'A');
  94. fakeFolder.localModifier().insert("b3.txt", 64, 'A');
  95. // Upload and calculate the checksums
  96. // fakeFolder.syncOnce();
  97. fakeFolder.syncOnce();
  98. auto getDbChecksum = [&](QString path) {
  99. SyncJournalFileRecord record;
  100. fakeFolder.syncJournal().getFileRecord(path, &record);
  101. return record._checksumHeader;
  102. };
  103. // printf 'A%.0s' {1..64} | sha1sum -
  104. QByteArray referenceChecksum("SHA1:30b86e44e6001403827a62c58b08893e77cf121f");
  105. QCOMPARE(getDbChecksum("a1.eml"), referenceChecksum);
  106. QCOMPARE(getDbChecksum("a2.eml"), referenceChecksum);
  107. QCOMPARE(getDbChecksum("a3.eml"), referenceChecksum);
  108. QCOMPARE(getDbChecksum("b3.txt"), referenceChecksum);
  109. QSignalSpy completeSpy(&fakeFolder.syncEngine(), SIGNAL(itemCompleted(const SyncFileItemPtr &)));
  110. // Touch the file without changing the content, shouldn't upload
  111. fakeFolder.localModifier().setContents("a1.eml", 'A');
  112. // Change the content/size
  113. fakeFolder.localModifier().setContents("a2.eml", 'B');
  114. fakeFolder.localModifier().appendByte("a3.eml");
  115. fakeFolder.localModifier().appendByte("b3.txt");
  116. fakeFolder.syncOnce();
  117. QCOMPARE(getDbChecksum("a1.eml"), referenceChecksum);
  118. QCOMPARE(getDbChecksum("a2.eml"), QByteArray("SHA1:84951fc23a4dafd10020ac349da1f5530fa65949"));
  119. QCOMPARE(getDbChecksum("a3.eml"), QByteArray("SHA1:826b7e7a7af8a529ae1c7443c23bf185c0ad440c"));
  120. QCOMPARE(getDbChecksum("b3.eml"), getDbChecksum("a3.txt"));
  121. QVERIFY(!itemDidComplete(completeSpy, "a1.eml"));
  122. QVERIFY(itemDidCompleteSuccessfully(completeSpy, "a2.eml"));
  123. QVERIFY(itemDidCompleteSuccessfully(completeSpy, "a3.eml"));
  124. QCOMPARE(fakeFolder.currentLocalState(), fakeFolder.currentRemoteState());
  125. }
  126. void testSelectiveSyncBug() {
  127. // issue owncloud/enterprise#1965: files from selective-sync ignored
  128. // folders are uploaded anyway is some circumstances.
  129. FakeFolder fakeFolder{FileInfo{ QString(), {
  130. FileInfo { QStringLiteral("parentFolder"), {
  131. FileInfo{ QStringLiteral("subFolderA"), {
  132. { QStringLiteral("fileA.txt"), 400 },
  133. { QStringLiteral("fileB.txt"), 400, 'o' },
  134. FileInfo { QStringLiteral("subsubFolder"), {
  135. { QStringLiteral("fileC.txt"), 400 },
  136. { QStringLiteral("fileD.txt"), 400, 'o' }
  137. }},
  138. FileInfo{ QStringLiteral("anotherFolder"), {
  139. FileInfo { QStringLiteral("emptyFolder"), { } },
  140. FileInfo { QStringLiteral("subsubFolder"), {
  141. { QStringLiteral("fileE.txt"), 400 },
  142. { QStringLiteral("fileF.txt"), 400, 'o' }
  143. }}
  144. }}
  145. }},
  146. FileInfo{ QStringLiteral("subFolderB"), {} }
  147. }}
  148. }}};
  149. QCOMPARE(fakeFolder.currentLocalState(), fakeFolder.currentRemoteState());
  150. auto expectedServerState = fakeFolder.currentRemoteState();
  151. // Remove subFolderA with selectiveSync:
  152. fakeFolder.syncEngine().journal()->setSelectiveSyncList(SyncJournalDb::SelectiveSyncBlackList,
  153. {"parentFolder/subFolderA/"});
  154. fakeFolder.syncEngine().journal()->avoidReadFromDbOnNextSync(QByteArrayLiteral("parentFolder/subFolderA/"));
  155. // But touch local file before the next sync, such that the local folder
  156. // can't be removed
  157. fakeFolder.localModifier().setContents("parentFolder/subFolderA/fileB.txt", 'n');
  158. fakeFolder.localModifier().setContents("parentFolder/subFolderA/subsubFolder/fileD.txt", 'n');
  159. fakeFolder.localModifier().setContents("parentFolder/subFolderA/anotherFolder/subsubFolder/fileF.txt", 'n');
  160. // Several follow-up syncs don't change the state at all,
  161. // in particular the remote state doesn't change and fileB.txt
  162. // isn't uploaded.
  163. for (int i = 0; i < 3; ++i) {
  164. fakeFolder.syncOnce();
  165. {
  166. // Nothing changed on the server
  167. QCOMPARE(fakeFolder.currentRemoteState(), expectedServerState);
  168. // The local state should still have subFolderA
  169. auto local = fakeFolder.currentLocalState();
  170. QVERIFY(local.find("parentFolder/subFolderA"));
  171. QVERIFY(!local.find("parentFolder/subFolderA/fileA.txt"));
  172. QVERIFY(local.find("parentFolder/subFolderA/fileB.txt"));
  173. QVERIFY(!local.find("parentFolder/subFolderA/subsubFolder/fileC.txt"));
  174. QVERIFY(local.find("parentFolder/subFolderA/subsubFolder/fileD.txt"));
  175. QVERIFY(!local.find("parentFolder/subFolderA/anotherFolder/subsubFolder/fileE.txt"));
  176. QVERIFY(local.find("parentFolder/subFolderA/anotherFolder/subsubFolder/fileF.txt"));
  177. QVERIFY(!local.find("parentFolder/subFolderA/anotherFolder/emptyFolder"));
  178. QVERIFY(local.find("parentFolder/subFolderB"));
  179. }
  180. }
  181. }
  182. void abortAfterFailedMkdir() {
  183. FakeFolder fakeFolder{FileInfo{}};
  184. QSignalSpy finishedSpy(&fakeFolder.syncEngine(), SIGNAL(finished(bool)));
  185. fakeFolder.serverErrorPaths().append("NewFolder");
  186. fakeFolder.localModifier().mkdir("NewFolder");
  187. // This should be aborted and would otherwise fail in FileInfo::create.
  188. fakeFolder.localModifier().insert("NewFolder/NewFile");
  189. fakeFolder.syncOnce();
  190. QCOMPARE(finishedSpy.size(), 1);
  191. QCOMPARE(finishedSpy.first().first().toBool(), false);
  192. }
  193. void testDirDownloadWithError() {
  194. FakeFolder fakeFolder{FileInfo::A12_B12_C12_S12()};
  195. QSignalSpy completeSpy(&fakeFolder.syncEngine(), SIGNAL(itemCompleted(const SyncFileItemPtr &)));
  196. fakeFolder.remoteModifier().mkdir("Y");
  197. fakeFolder.remoteModifier().mkdir("Y/Z");
  198. fakeFolder.remoteModifier().insert("Y/Z/d0");
  199. fakeFolder.remoteModifier().insert("Y/Z/d1");
  200. fakeFolder.remoteModifier().insert("Y/Z/d2");
  201. fakeFolder.remoteModifier().insert("Y/Z/d3");
  202. fakeFolder.remoteModifier().insert("Y/Z/d4");
  203. fakeFolder.remoteModifier().insert("Y/Z/d5");
  204. fakeFolder.remoteModifier().insert("Y/Z/d6");
  205. fakeFolder.remoteModifier().insert("Y/Z/d7");
  206. fakeFolder.remoteModifier().insert("Y/Z/d8");
  207. fakeFolder.remoteModifier().insert("Y/Z/d9");
  208. fakeFolder.serverErrorPaths().append("Y/Z/d2", 503); // 503 is a fatal error
  209. fakeFolder.serverErrorPaths().append("Y/Z/d3", 503); // 503 is a fatal error
  210. QVERIFY(!fakeFolder.syncOnce());
  211. QCoreApplication::processEvents(); // should not crash
  212. QSet<QString> seen;
  213. for(const QList<QVariant> &args : completeSpy) {
  214. auto item = args[0].value<SyncFileItemPtr>();
  215. qDebug() << item->_file << item->isDirectory() << item->_status;
  216. QVERIFY(!seen.contains(item->_file)); // signal only sent once per item
  217. seen.insert(item->_file);
  218. if (item->_file == "Y/Z/d2") {
  219. QVERIFY(item->_status == SyncFileItem::FatalError);
  220. } else if(item->_file == "Y/Z/d3") {
  221. QVERIFY(item->_status != SyncFileItem::Success);
  222. }
  223. QVERIFY(item->_file != "Y/Z/d9"); // we should have aborted the sync before d9 starts
  224. }
  225. }
  226. void testFakeConflict_data()
  227. {
  228. QTest::addColumn<bool>("sameMtime");
  229. QTest::addColumn<QByteArray>("checksums");
  230. QTest::addColumn<int>("expectedGET");
  231. QTest::newRow("Same mtime, but no server checksum -> ignored in reconcile")
  232. << true << QByteArray()
  233. << 0;
  234. QTest::newRow("Same mtime, weak server checksum differ -> downloaded")
  235. << true << QByteArray("Adler32:bad")
  236. << 1;
  237. QTest::newRow("Same mtime, matching weak checksum -> skipped")
  238. << true << QByteArray("Adler32:2a2010d")
  239. << 0;
  240. QTest::newRow("Same mtime, strong server checksum differ -> downloaded")
  241. << true << QByteArray("SHA1:bad")
  242. << 1;
  243. QTest::newRow("Same mtime, matching strong checksum -> skipped")
  244. << true << QByteArray("SHA1:56900fb1d337cf7237ff766276b9c1e8ce507427")
  245. << 0;
  246. QTest::newRow("mtime changed, but no server checksum -> download")
  247. << false << QByteArray()
  248. << 1;
  249. QTest::newRow("mtime changed, weak checksum match -> download anyway")
  250. << false << QByteArray("Adler32:2a2010d")
  251. << 1;
  252. QTest::newRow("mtime changed, strong checksum match -> skip")
  253. << false << QByteArray("SHA1:56900fb1d337cf7237ff766276b9c1e8ce507427")
  254. << 0;
  255. }
  256. void testFakeConflict()
  257. {
  258. QFETCH(bool, sameMtime);
  259. QFETCH(QByteArray, checksums);
  260. QFETCH(int, expectedGET);
  261. FakeFolder fakeFolder{ FileInfo::A12_B12_C12_S12() };
  262. int nGET = 0;
  263. fakeFolder.setServerOverride([&](QNetworkAccessManager::Operation op, const QNetworkRequest &, QIODevice *) {
  264. if (op == QNetworkAccessManager::GetOperation)
  265. ++nGET;
  266. return nullptr;
  267. });
  268. // For directly editing the remote checksum
  269. FileInfo &remoteInfo = dynamic_cast<FileInfo &>(fakeFolder.remoteModifier());
  270. // Base mtime with no ms content (filesystem is seconds only)
  271. auto mtime = QDateTime::currentDateTimeUtc().addDays(-4);
  272. mtime.setMSecsSinceEpoch(mtime.toMSecsSinceEpoch() / 1000 * 1000);
  273. fakeFolder.localModifier().setContents("A/a1", 'C');
  274. fakeFolder.localModifier().setModTime("A/a1", mtime);
  275. fakeFolder.remoteModifier().setContents("A/a1", 'C');
  276. if (!sameMtime)
  277. mtime = mtime.addDays(1);
  278. fakeFolder.remoteModifier().setModTime("A/a1", mtime);
  279. remoteInfo.find("A/a1")->checksums = checksums;
  280. QVERIFY(fakeFolder.syncOnce());
  281. QCOMPARE(nGET, expectedGET);
  282. // check that mtime in journal and filesystem agree
  283. QString a1path = fakeFolder.localPath() + "A/a1";
  284. SyncJournalFileRecord a1record;
  285. fakeFolder.syncJournal().getFileRecord(QByteArray("A/a1"), &a1record);
  286. QCOMPARE(a1record._modtime, (qint64)FileSystem::getModTime(a1path));
  287. // Extra sync reads from db, no difference
  288. QVERIFY(fakeFolder.syncOnce());
  289. QCOMPARE(nGET, expectedGET);
  290. }
  291. /**
  292. * Checks whether SyncFileItems have the expected properties before start
  293. * of propagation.
  294. */
  295. void testSyncFileItemProperties()
  296. {
  297. auto initialMtime = QDateTime::currentDateTimeUtc().addDays(-7);
  298. auto changedMtime = QDateTime::currentDateTimeUtc().addDays(-4);
  299. auto changedMtime2 = QDateTime::currentDateTimeUtc().addDays(-3);
  300. // Base mtime with no ms content (filesystem is seconds only)
  301. initialMtime.setMSecsSinceEpoch(initialMtime.toMSecsSinceEpoch() / 1000 * 1000);
  302. changedMtime.setMSecsSinceEpoch(changedMtime.toMSecsSinceEpoch() / 1000 * 1000);
  303. changedMtime2.setMSecsSinceEpoch(changedMtime2.toMSecsSinceEpoch() / 1000 * 1000);
  304. // Ensure the initial mtimes are as expected
  305. auto initialFileInfo = FileInfo::A12_B12_C12_S12();
  306. initialFileInfo.setModTime("A/a1", initialMtime);
  307. initialFileInfo.setModTime("B/b1", initialMtime);
  308. initialFileInfo.setModTime("C/c1", initialMtime);
  309. FakeFolder fakeFolder{ initialFileInfo };
  310. // upload a
  311. fakeFolder.localModifier().appendByte("A/a1");
  312. fakeFolder.localModifier().setModTime("A/a1", changedMtime);
  313. // download b
  314. fakeFolder.remoteModifier().appendByte("B/b1");
  315. fakeFolder.remoteModifier().setModTime("B/b1", changedMtime);
  316. // conflict c
  317. fakeFolder.localModifier().appendByte("C/c1");
  318. fakeFolder.localModifier().appendByte("C/c1");
  319. fakeFolder.localModifier().setModTime("C/c1", changedMtime);
  320. fakeFolder.remoteModifier().appendByte("C/c1");
  321. fakeFolder.remoteModifier().setModTime("C/c1", changedMtime2);
  322. connect(&fakeFolder.syncEngine(), &SyncEngine::aboutToPropagate, [&](SyncFileItemVector &items) {
  323. SyncFileItemPtr a1, b1, c1;
  324. for (auto &item : items) {
  325. if (item->_file == "A/a1")
  326. a1 = item;
  327. if (item->_file == "B/b1")
  328. b1 = item;
  329. if (item->_file == "C/c1")
  330. c1 = item;
  331. }
  332. // a1: should have local size and modtime
  333. QVERIFY(a1);
  334. QCOMPARE(a1->_instruction, CSYNC_INSTRUCTION_SYNC);
  335. QCOMPARE(a1->_direction, SyncFileItem::Up);
  336. QCOMPARE(a1->_size, quint64(5));
  337. QCOMPARE(Utility::qDateTimeFromTime_t(a1->_modtime), changedMtime);
  338. QCOMPARE(a1->_previousSize, quint64(4));
  339. QCOMPARE(Utility::qDateTimeFromTime_t(a1->_previousModtime), initialMtime);
  340. // b2: should have remote size and modtime
  341. QVERIFY(b1);
  342. QCOMPARE(b1->_instruction, CSYNC_INSTRUCTION_SYNC);
  343. QCOMPARE(b1->_direction, SyncFileItem::Down);
  344. QCOMPARE(b1->_size, quint64(17));
  345. QCOMPARE(Utility::qDateTimeFromTime_t(b1->_modtime), changedMtime);
  346. QCOMPARE(b1->_previousSize, quint64(16));
  347. QCOMPARE(Utility::qDateTimeFromTime_t(b1->_previousModtime), initialMtime);
  348. // c1: conflicts are downloads, so remote size and modtime
  349. QVERIFY(c1);
  350. QCOMPARE(c1->_instruction, CSYNC_INSTRUCTION_CONFLICT);
  351. QCOMPARE(c1->_direction, SyncFileItem::None);
  352. QCOMPARE(c1->_size, quint64(25));
  353. QCOMPARE(Utility::qDateTimeFromTime_t(c1->_modtime), changedMtime2);
  354. QCOMPARE(c1->_previousSize, quint64(26));
  355. QCOMPARE(Utility::qDateTimeFromTime_t(c1->_previousModtime), changedMtime);
  356. });
  357. QVERIFY(fakeFolder.syncOnce());
  358. }
  359. /**
  360. * Checks whether subsequent large uploads are skipped after a 507 error
  361. */
  362. void testInsufficientRemoteStorage()
  363. {
  364. FakeFolder fakeFolder{ FileInfo::A12_B12_C12_S12() };
  365. // Disable parallel uploads
  366. SyncOptions syncOptions;
  367. syncOptions._parallelNetworkJobs = false;
  368. fakeFolder.syncEngine().setSyncOptions(syncOptions);
  369. // Produce an error based on upload size
  370. int remoteQuota = 1000;
  371. int n507 = 0, nPUT = 0;
  372. auto parent = new QObject;
  373. fakeFolder.setServerOverride([&](QNetworkAccessManager::Operation op, const QNetworkRequest &request, QIODevice *) -> QNetworkReply * {
  374. if (op == QNetworkAccessManager::PutOperation) {
  375. nPUT++;
  376. if (request.rawHeader("OC-Total-Length").toInt() > remoteQuota) {
  377. n507++;
  378. return new FakeErrorReply(op, request, parent, 507);
  379. }
  380. }
  381. return nullptr;
  382. });
  383. fakeFolder.localModifier().insert("A/big", 800);
  384. QVERIFY(fakeFolder.syncOnce());
  385. QCOMPARE(nPUT, 1);
  386. QCOMPARE(n507, 0);
  387. nPUT = 0;
  388. fakeFolder.localModifier().insert("A/big1", 500); // ok
  389. fakeFolder.localModifier().insert("A/big2", 1200); // 507 (quota guess now 1199)
  390. fakeFolder.localModifier().insert("A/big3", 1200); // skipped
  391. fakeFolder.localModifier().insert("A/big4", 1500); // skipped
  392. fakeFolder.localModifier().insert("A/big5", 1100); // 507 (quota guess now 1099)
  393. fakeFolder.localModifier().insert("A/big6", 900); // ok (quota guess now 199)
  394. fakeFolder.localModifier().insert("A/big7", 200); // skipped
  395. fakeFolder.localModifier().insert("A/big8", 199); // ok (quota guess now 0)
  396. fakeFolder.localModifier().insert("B/big8", 1150); // 507
  397. QVERIFY(!fakeFolder.syncOnce());
  398. QCOMPARE(nPUT, 6);
  399. QCOMPARE(n507, 3);
  400. }
  401. // Checks whether downloads with bad checksums are accepted
  402. void testChecksumValidation()
  403. {
  404. FakeFolder fakeFolder{ FileInfo::A12_B12_C12_S12() };
  405. QObject parent;
  406. QByteArray checksumValue;
  407. QByteArray contentMd5Value;
  408. fakeFolder.setServerOverride([&](QNetworkAccessManager::Operation op, const QNetworkRequest &request, QIODevice *) -> QNetworkReply * {
  409. if (op == QNetworkAccessManager::GetOperation) {
  410. auto reply = new FakeGetReply(fakeFolder.remoteModifier(), op, request, &parent);
  411. if (!checksumValue.isNull())
  412. reply->setRawHeader("OC-Checksum", checksumValue);
  413. if (!contentMd5Value.isNull())
  414. reply->setRawHeader("Content-MD5", contentMd5Value);
  415. return reply;
  416. }
  417. return nullptr;
  418. });
  419. // Basic case
  420. fakeFolder.remoteModifier().create("A/a3", 16, 'A');
  421. QVERIFY(fakeFolder.syncOnce());
  422. QCOMPARE(fakeFolder.currentLocalState(), fakeFolder.currentRemoteState());
  423. // Bad OC-Checksum
  424. checksumValue = "SHA1:bad";
  425. fakeFolder.remoteModifier().create("A/a4", 16, 'A');
  426. QVERIFY(!fakeFolder.syncOnce());
  427. // Good OC-Checksum
  428. checksumValue = "SHA1:19b1928d58a2030d08023f3d7054516dbc186f20"; // printf 'A%.0s' {1..16} | sha1sum -
  429. QVERIFY(fakeFolder.syncOnce());
  430. QCOMPARE(fakeFolder.currentLocalState(), fakeFolder.currentRemoteState());
  431. checksumValue = QByteArray();
  432. // Bad Content-MD5
  433. contentMd5Value = "bad";
  434. fakeFolder.remoteModifier().create("A/a5", 16, 'A');
  435. QVERIFY(!fakeFolder.syncOnce());
  436. // Good Content-MD5
  437. contentMd5Value = "d8a73157ce10cd94a91c2079fc9a92c8"; // printf 'A%.0s' {1..16} | md5sum -
  438. QVERIFY(fakeFolder.syncOnce());
  439. QCOMPARE(fakeFolder.currentLocalState(), fakeFolder.currentRemoteState());
  440. // Invalid OC-Checksum is ignored
  441. checksumValue = "garbage";
  442. // contentMd5Value is still good
  443. fakeFolder.remoteModifier().create("A/a6", 16, 'A');
  444. QVERIFY(fakeFolder.syncOnce());
  445. contentMd5Value = "bad";
  446. fakeFolder.remoteModifier().create("A/a7", 16, 'A');
  447. QVERIFY(!fakeFolder.syncOnce());
  448. contentMd5Value.clear();
  449. QVERIFY(fakeFolder.syncOnce());
  450. QCOMPARE(fakeFolder.currentLocalState(), fakeFolder.currentRemoteState());
  451. // OC-Checksum contains Unsupported checksums
  452. checksumValue = "Unsupported:XXXX SHA1:invalid Invalid:XxX";
  453. fakeFolder.remoteModifier().create("A/a8", 16, 'A');
  454. QVERIFY(!fakeFolder.syncOnce()); // Since the supported SHA1 checksum is invalid, no download
  455. checksumValue = "Unsupported:XXXX SHA1:19b1928d58a2030d08023f3d7054516dbc186f20 Invalid:XxX";
  456. QVERIFY(fakeFolder.syncOnce()); // The supported SHA1 checksum is valid now, so the file are downloaded
  457. QCOMPARE(fakeFolder.currentLocalState(), fakeFolder.currentRemoteState());
  458. }
  459. // Tests the behavior of invalid filename detection
  460. void testInvalidFilenameRegex()
  461. {
  462. FakeFolder fakeFolder{ FileInfo::A12_B12_C12_S12() };
  463. #ifndef Q_OS_WIN // We can't have local file with these character
  464. // For current servers, no characters are forbidden
  465. fakeFolder.syncEngine().account()->setServerVersion("10.0.0");
  466. fakeFolder.localModifier().insert("A/\\:?*\"<>|.txt");
  467. QVERIFY(fakeFolder.syncOnce());
  468. QCOMPARE(fakeFolder.currentLocalState(), fakeFolder.currentRemoteState());
  469. // For legacy servers, some characters were forbidden by the client
  470. fakeFolder.syncEngine().account()->setServerVersion("8.0.0");
  471. fakeFolder.localModifier().insert("B/\\:?*\"<>|.txt");
  472. QVERIFY(fakeFolder.syncOnce());
  473. QVERIFY(!fakeFolder.currentRemoteState().find("B/\\:?*\"<>|.txt"));
  474. #endif
  475. // We can override that by setting the capability
  476. fakeFolder.syncEngine().account()->setCapabilities({ { "dav", QVariantMap{ { "invalidFilenameRegex", "" } } } });
  477. QVERIFY(fakeFolder.syncOnce());
  478. QCOMPARE(fakeFolder.currentLocalState(), fakeFolder.currentRemoteState());
  479. // Check that new servers also accept the capability
  480. fakeFolder.syncEngine().account()->setServerVersion("10.0.0");
  481. fakeFolder.syncEngine().account()->setCapabilities({ { "dav", QVariantMap{ { "invalidFilenameRegex", "my[fgh]ile" } } } });
  482. fakeFolder.localModifier().insert("C/myfile.txt");
  483. QVERIFY(fakeFolder.syncOnce());
  484. QVERIFY(!fakeFolder.currentRemoteState().find("C/myfile.txt"));
  485. }
  486. // Check correct behavior when local discovery is partially drawn from the db
  487. void testLocalDiscoveryStyle()
  488. {
  489. FakeFolder fakeFolder{ FileInfo::A12_B12_C12_S12() };
  490. // More subdirectories are useful for testing
  491. fakeFolder.localModifier().mkdir("A/X");
  492. fakeFolder.localModifier().mkdir("A/Y");
  493. fakeFolder.localModifier().insert("A/X/x1");
  494. fakeFolder.localModifier().insert("A/Y/y1");
  495. QVERIFY(fakeFolder.syncOnce());
  496. QCOMPARE(fakeFolder.currentLocalState(), fakeFolder.currentRemoteState());
  497. // Test begins
  498. fakeFolder.localModifier().insert("A/a3");
  499. fakeFolder.localModifier().insert("A/X/x2");
  500. fakeFolder.localModifier().insert("A/Y/y2");
  501. fakeFolder.localModifier().insert("B/b3");
  502. fakeFolder.remoteModifier().insert("C/c3");
  503. fakeFolder.syncEngine().setLocalDiscoveryOptions(LocalDiscoveryStyle::DatabaseAndFilesystem, { "A/X" });
  504. QVERIFY(fakeFolder.syncOnce());
  505. QVERIFY(fakeFolder.currentRemoteState().find("A/a3"));
  506. QVERIFY(fakeFolder.currentRemoteState().find("A/X/x2"));
  507. QVERIFY(!fakeFolder.currentRemoteState().find("A/Y/y2"));
  508. QVERIFY(!fakeFolder.currentRemoteState().find("B/b3"));
  509. QVERIFY(fakeFolder.currentLocalState().find("C/c3"));
  510. QCOMPARE(fakeFolder.syncEngine().lastLocalDiscoveryStyle(), LocalDiscoveryStyle::DatabaseAndFilesystem);
  511. QVERIFY(fakeFolder.syncOnce());
  512. QCOMPARE(fakeFolder.currentLocalState(), fakeFolder.currentRemoteState());
  513. QCOMPARE(fakeFolder.syncEngine().lastLocalDiscoveryStyle(), LocalDiscoveryStyle::FilesystemOnly);
  514. }
  515. void testDiscoveryHiddenFile()
  516. {
  517. FakeFolder fakeFolder{ FileInfo::A12_B12_C12_S12() };
  518. QVERIFY(fakeFolder.syncOnce());
  519. QCOMPARE(fakeFolder.currentLocalState(), fakeFolder.currentRemoteState());
  520. // We can't depend on currentLocalState for hidden files since
  521. // it should rightfully skip things like download temporaries
  522. auto localFileExists = [&](QString name) {
  523. return QFileInfo(fakeFolder.localPath() + name).exists();
  524. };
  525. fakeFolder.syncEngine().setIgnoreHiddenFiles(true);
  526. fakeFolder.remoteModifier().insert("A/.hidden");
  527. fakeFolder.localModifier().insert("B/.hidden");
  528. QVERIFY(fakeFolder.syncOnce());
  529. QVERIFY(!localFileExists("A/.hidden"));
  530. QVERIFY(!fakeFolder.currentRemoteState().find("B/.hidden"));
  531. fakeFolder.syncEngine().setIgnoreHiddenFiles(false);
  532. fakeFolder.syncJournal().forceRemoteDiscoveryNextSync();
  533. QVERIFY(fakeFolder.syncOnce());
  534. QVERIFY(localFileExists("A/.hidden"));
  535. QVERIFY(fakeFolder.currentRemoteState().find("B/.hidden"));
  536. }
  537. };
  538. QTEST_GUILESS_MAIN(TestSyncEngine)
  539. #include "testsyncengine.moc"