testsyncfilestatustracker.cpp 30 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517
  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 "csync_exclude.h"
  10. using namespace OCC;
  11. class StatusPushSpy : public QSignalSpy
  12. {
  13. SyncEngine &_syncEngine;
  14. public:
  15. StatusPushSpy(SyncEngine &syncEngine)
  16. : QSignalSpy(&syncEngine.syncFileStatusTracker(), SIGNAL(fileStatusChanged(const QString&, SyncFileStatus)))
  17. , _syncEngine(syncEngine)
  18. { }
  19. SyncFileStatus statusOf(const QString &relativePath) const {
  20. QFileInfo file(_syncEngine.localPath(), relativePath);
  21. auto locPath = _syncEngine.localPath();
  22. // Start from the end to get the latest status
  23. for (int i = size() - 1; i >= 0; --i) {
  24. if (QFileInfo(at(i)[0].toString()) == file)
  25. return at(i)[1].value<SyncFileStatus>();
  26. }
  27. return {};
  28. }
  29. bool statusEmittedBefore(const QString &firstPath, const QString &secondPath) const {
  30. QFileInfo firstFile(_syncEngine.localPath(), firstPath);
  31. QFileInfo secondFile(_syncEngine.localPath(), secondPath);
  32. // Start from the end to get the latest status
  33. int i = size() - 1;
  34. for (; i >= 0; --i) {
  35. if (QFileInfo(at(i)[0].toString()) == secondFile)
  36. break;
  37. else if (QFileInfo(at(i)[0].toString()) == firstFile)
  38. return false;
  39. }
  40. for (; i >= 0; --i) {
  41. if (QFileInfo(at(i)[0].toString()) == firstFile)
  42. return true;
  43. }
  44. return false;
  45. }
  46. };
  47. class TestSyncFileStatusTracker : public QObject
  48. {
  49. Q_OBJECT
  50. void verifyThatPushMatchesPull(const FakeFolder &fakeFolder, const StatusPushSpy &statusSpy) {
  51. QString root = fakeFolder.localPath();
  52. QDirIterator it(root, QDir::AllEntries | QDir::NoDotAndDotDot, QDirIterator::Subdirectories);
  53. while (it.hasNext()) {
  54. QString filePath = it.next().mid(root.size());
  55. SyncFileStatus pushedStatus = statusSpy.statusOf(filePath);
  56. if (pushedStatus != SyncFileStatus())
  57. QCOMPARE(fakeFolder.syncEngine().syncFileStatusTracker().fileStatus(filePath), pushedStatus);
  58. }
  59. }
  60. private slots:
  61. void parentsGetSyncStatusUploadDownload() {
  62. FakeFolder fakeFolder{FileInfo::A12_B12_C12_S12()};
  63. fakeFolder.localModifier().appendByte("B/b1");
  64. fakeFolder.remoteModifier().appendByte("C/c1");
  65. StatusPushSpy statusSpy(fakeFolder.syncEngine());
  66. fakeFolder.scheduleSync();
  67. fakeFolder.execUntilBeforePropagation();
  68. verifyThatPushMatchesPull(fakeFolder, statusSpy);
  69. QCOMPARE(statusSpy.statusOf(""), SyncFileStatus(SyncFileStatus::StatusSync));
  70. QCOMPARE(statusSpy.statusOf("B"), SyncFileStatus(SyncFileStatus::StatusSync));
  71. QCOMPARE(statusSpy.statusOf("B/b1"), SyncFileStatus(SyncFileStatus::StatusSync));
  72. QCOMPARE(statusSpy.statusOf("C"), SyncFileStatus(SyncFileStatus::StatusSync));
  73. QCOMPARE(statusSpy.statusOf("C/c1"), SyncFileStatus(SyncFileStatus::StatusSync));
  74. QCOMPARE(fakeFolder.syncEngine().syncFileStatusTracker().fileStatus("A"), SyncFileStatus(SyncFileStatus::StatusUpToDate));
  75. QCOMPARE(fakeFolder.syncEngine().syncFileStatusTracker().fileStatus("A/a1"), SyncFileStatus(SyncFileStatus::StatusUpToDate));
  76. QCOMPARE(fakeFolder.syncEngine().syncFileStatusTracker().fileStatus("B/b2"), SyncFileStatus(SyncFileStatus::StatusUpToDate));
  77. QCOMPARE(fakeFolder.syncEngine().syncFileStatusTracker().fileStatus("C/c2"), SyncFileStatus(SyncFileStatus::StatusUpToDate));
  78. statusSpy.clear();
  79. fakeFolder.execUntilFinished();
  80. verifyThatPushMatchesPull(fakeFolder, statusSpy);
  81. QCOMPARE(statusSpy.statusOf(""), SyncFileStatus(SyncFileStatus::StatusUpToDate));
  82. QCOMPARE(statusSpy.statusOf("B"), SyncFileStatus(SyncFileStatus::StatusUpToDate));
  83. QCOMPARE(statusSpy.statusOf("B/b1"), SyncFileStatus(SyncFileStatus::StatusUpToDate));
  84. QCOMPARE(statusSpy.statusOf("C"), SyncFileStatus(SyncFileStatus::StatusUpToDate));
  85. QCOMPARE(statusSpy.statusOf("C/c1"), SyncFileStatus(SyncFileStatus::StatusUpToDate));
  86. QCOMPARE(fakeFolder.currentLocalState(), fakeFolder.currentRemoteState());
  87. }
  88. void parentsGetSyncStatusNewFileUploadDownload() {
  89. FakeFolder fakeFolder{FileInfo::A12_B12_C12_S12()};
  90. fakeFolder.localModifier().insert("B/b0");
  91. fakeFolder.remoteModifier().insert("C/c0");
  92. StatusPushSpy statusSpy(fakeFolder.syncEngine());
  93. fakeFolder.scheduleSync();
  94. fakeFolder.execUntilBeforePropagation();
  95. verifyThatPushMatchesPull(fakeFolder, statusSpy);
  96. QCOMPARE(statusSpy.statusOf(""), SyncFileStatus(SyncFileStatus::StatusSync));
  97. QCOMPARE(statusSpy.statusOf("B"), SyncFileStatus(SyncFileStatus::StatusSync));
  98. QCOMPARE(statusSpy.statusOf("B/b0"), SyncFileStatus(SyncFileStatus::StatusSync));
  99. QCOMPARE(statusSpy.statusOf("C"), SyncFileStatus(SyncFileStatus::StatusSync));
  100. QCOMPARE(statusSpy.statusOf("C/c0"), SyncFileStatus(SyncFileStatus::StatusSync));
  101. QCOMPARE(fakeFolder.syncEngine().syncFileStatusTracker().fileStatus("A"), SyncFileStatus(SyncFileStatus::StatusUpToDate));
  102. QCOMPARE(fakeFolder.syncEngine().syncFileStatusTracker().fileStatus("A/a1"), SyncFileStatus(SyncFileStatus::StatusUpToDate));
  103. QCOMPARE(fakeFolder.syncEngine().syncFileStatusTracker().fileStatus("B/b1"), SyncFileStatus(SyncFileStatus::StatusUpToDate));
  104. QCOMPARE(fakeFolder.syncEngine().syncFileStatusTracker().fileStatus("C/c1"), SyncFileStatus(SyncFileStatus::StatusUpToDate));
  105. statusSpy.clear();
  106. fakeFolder.execUntilFinished();
  107. verifyThatPushMatchesPull(fakeFolder, statusSpy);
  108. QCOMPARE(statusSpy.statusOf(""), SyncFileStatus(SyncFileStatus::StatusUpToDate));
  109. QCOMPARE(statusSpy.statusOf("B"), SyncFileStatus(SyncFileStatus::StatusUpToDate));
  110. QCOMPARE(statusSpy.statusOf("B/b0"), SyncFileStatus(SyncFileStatus::StatusUpToDate));
  111. QCOMPARE(statusSpy.statusOf("C"), SyncFileStatus(SyncFileStatus::StatusUpToDate));
  112. QCOMPARE(statusSpy.statusOf("C/c0"), SyncFileStatus(SyncFileStatus::StatusUpToDate));
  113. QCOMPARE(fakeFolder.currentLocalState(), fakeFolder.currentRemoteState());
  114. }
  115. void parentsGetSyncStatusNewDirDownload() {
  116. FakeFolder fakeFolder{FileInfo::A12_B12_C12_S12()};
  117. fakeFolder.remoteModifier().mkdir("D");
  118. fakeFolder.remoteModifier().insert("D/d0");
  119. StatusPushSpy statusSpy(fakeFolder.syncEngine());
  120. fakeFolder.scheduleSync();
  121. fakeFolder.execUntilBeforePropagation();
  122. verifyThatPushMatchesPull(fakeFolder, statusSpy);
  123. QCOMPARE(statusSpy.statusOf(""), SyncFileStatus(SyncFileStatus::StatusSync));
  124. QCOMPARE(statusSpy.statusOf("D"), SyncFileStatus(SyncFileStatus::StatusSync));
  125. QCOMPARE(statusSpy.statusOf("D/d0"), SyncFileStatus(SyncFileStatus::StatusSync));
  126. fakeFolder.execUntilItemCompleted("D");
  127. verifyThatPushMatchesPull(fakeFolder, statusSpy);
  128. QCOMPARE(statusSpy.statusOf(""), SyncFileStatus(SyncFileStatus::StatusSync));
  129. QCOMPARE(statusSpy.statusOf("D"), SyncFileStatus(SyncFileStatus::StatusSync));
  130. QCOMPARE(statusSpy.statusOf("D/d0"), SyncFileStatus(SyncFileStatus::StatusSync));
  131. fakeFolder.execUntilFinished();
  132. verifyThatPushMatchesPull(fakeFolder, statusSpy);
  133. QCOMPARE(statusSpy.statusOf(""), SyncFileStatus(SyncFileStatus::StatusUpToDate));
  134. QCOMPARE(statusSpy.statusOf("D"), SyncFileStatus(SyncFileStatus::StatusUpToDate));
  135. QCOMPARE(statusSpy.statusOf("D/d0"), SyncFileStatus(SyncFileStatus::StatusUpToDate));
  136. QCOMPARE(fakeFolder.currentLocalState(), fakeFolder.currentRemoteState());
  137. }
  138. void parentsGetSyncStatusNewDirUpload() {
  139. FakeFolder fakeFolder{FileInfo::A12_B12_C12_S12()};
  140. fakeFolder.localModifier().mkdir("D");
  141. fakeFolder.localModifier().insert("D/d0");
  142. StatusPushSpy statusSpy(fakeFolder.syncEngine());
  143. fakeFolder.scheduleSync();
  144. fakeFolder.execUntilBeforePropagation();
  145. verifyThatPushMatchesPull(fakeFolder, statusSpy);
  146. QCOMPARE(statusSpy.statusOf(""), SyncFileStatus(SyncFileStatus::StatusSync));
  147. QCOMPARE(statusSpy.statusOf("D"), SyncFileStatus(SyncFileStatus::StatusSync));
  148. QCOMPARE(statusSpy.statusOf("D/d0"), SyncFileStatus(SyncFileStatus::StatusSync));
  149. fakeFolder.execUntilItemCompleted("D");
  150. verifyThatPushMatchesPull(fakeFolder, statusSpy);
  151. QCOMPARE(statusSpy.statusOf(""), SyncFileStatus(SyncFileStatus::StatusSync));
  152. QCOMPARE(statusSpy.statusOf("D"), SyncFileStatus(SyncFileStatus::StatusSync));
  153. QCOMPARE(statusSpy.statusOf("D/d0"), SyncFileStatus(SyncFileStatus::StatusSync));
  154. fakeFolder.execUntilFinished();
  155. verifyThatPushMatchesPull(fakeFolder, statusSpy);
  156. QCOMPARE(statusSpy.statusOf(""), SyncFileStatus(SyncFileStatus::StatusUpToDate));
  157. QCOMPARE(statusSpy.statusOf("D"), SyncFileStatus(SyncFileStatus::StatusUpToDate));
  158. QCOMPARE(statusSpy.statusOf("D/d0"), SyncFileStatus(SyncFileStatus::StatusUpToDate));
  159. QCOMPARE(fakeFolder.currentLocalState(), fakeFolder.currentRemoteState());
  160. }
  161. void parentsGetSyncStatusDeleteUpDown() {
  162. FakeFolder fakeFolder{FileInfo::A12_B12_C12_S12()};
  163. fakeFolder.remoteModifier().remove("B/b1");
  164. fakeFolder.localModifier().remove("C/c1");
  165. StatusPushSpy statusSpy(fakeFolder.syncEngine());
  166. fakeFolder.scheduleSync();
  167. fakeFolder.execUntilBeforePropagation();
  168. verifyThatPushMatchesPull(fakeFolder, statusSpy);
  169. QCOMPARE(statusSpy.statusOf(""), SyncFileStatus(SyncFileStatus::StatusSync));
  170. QCOMPARE(statusSpy.statusOf("B"), SyncFileStatus(SyncFileStatus::StatusSync));
  171. // Discovered as remotely removed, pending for local removal.
  172. QCOMPARE(statusSpy.statusOf("B/b1"), SyncFileStatus(SyncFileStatus::StatusSync));
  173. QCOMPARE(statusSpy.statusOf("C"), SyncFileStatus(SyncFileStatus::StatusSync));
  174. QCOMPARE(fakeFolder.syncEngine().syncFileStatusTracker().fileStatus("A"), SyncFileStatus(SyncFileStatus::StatusUpToDate));
  175. QCOMPARE(fakeFolder.syncEngine().syncFileStatusTracker().fileStatus("B/b2"), SyncFileStatus(SyncFileStatus::StatusUpToDate));
  176. QCOMPARE(fakeFolder.syncEngine().syncFileStatusTracker().fileStatus("C/c2"), SyncFileStatus(SyncFileStatus::StatusUpToDate));
  177. statusSpy.clear();
  178. fakeFolder.execUntilFinished();
  179. verifyThatPushMatchesPull(fakeFolder, statusSpy);
  180. QCOMPARE(statusSpy.statusOf(""), SyncFileStatus(SyncFileStatus::StatusUpToDate));
  181. QCOMPARE(statusSpy.statusOf("B"), SyncFileStatus(SyncFileStatus::StatusUpToDate));
  182. QCOMPARE(statusSpy.statusOf("C"), SyncFileStatus(SyncFileStatus::StatusUpToDate));
  183. QCOMPARE(fakeFolder.currentLocalState(), fakeFolder.currentRemoteState());
  184. }
  185. void warningStatusForExcludedFile() {
  186. FakeFolder fakeFolder{FileInfo::A12_B12_C12_S12()};
  187. fakeFolder.syncEngine().excludedFiles().addManualExclude("A/a1");
  188. fakeFolder.syncEngine().excludedFiles().addManualExclude("B");
  189. fakeFolder.localModifier().appendByte("A/a1");
  190. fakeFolder.localModifier().appendByte("B/b1");
  191. StatusPushSpy statusSpy(fakeFolder.syncEngine());
  192. fakeFolder.scheduleSync();
  193. fakeFolder.execUntilBeforePropagation();
  194. verifyThatPushMatchesPull(fakeFolder, statusSpy);
  195. QCOMPARE(statusSpy.statusOf("A/a1"), SyncFileStatus(SyncFileStatus::StatusExcluded));
  196. QCOMPARE(statusSpy.statusOf("B"), SyncFileStatus(SyncFileStatus::StatusExcluded));
  197. QEXPECT_FAIL("", "csync will stop at ignored directories without traversing children, so we don't currently push the status for newly ignored children of an ignored directory.", Continue);
  198. QCOMPARE(statusSpy.statusOf("B/b1"), SyncFileStatus(SyncFileStatus::StatusExcluded));
  199. fakeFolder.execUntilFinished();
  200. verifyThatPushMatchesPull(fakeFolder, statusSpy);
  201. QCOMPARE(statusSpy.statusOf("A/a1"), SyncFileStatus(SyncFileStatus::StatusExcluded));
  202. QCOMPARE(statusSpy.statusOf("B"), SyncFileStatus(SyncFileStatus::StatusExcluded));
  203. QEXPECT_FAIL("", "csync will stop at ignored directories without traversing children, so we don't currently push the status for newly ignored children of an ignored directory.", Continue);
  204. QCOMPARE(statusSpy.statusOf("B/b1"), SyncFileStatus(SyncFileStatus::StatusExcluded));
  205. QEXPECT_FAIL("", "csync will stop at ignored directories without traversing children, so we don't currently push the status for newly ignored children of an ignored directory.", Continue);
  206. QCOMPARE(statusSpy.statusOf("B/b2"), SyncFileStatus(SyncFileStatus::StatusExcluded));
  207. QCOMPARE(fakeFolder.syncEngine().syncFileStatusTracker().fileStatus(""), SyncFileStatus(SyncFileStatus::StatusUpToDate));
  208. QCOMPARE(fakeFolder.syncEngine().syncFileStatusTracker().fileStatus("A"), SyncFileStatus(SyncFileStatus::StatusUpToDate));
  209. statusSpy.clear();
  210. // Clears the exclude expr above
  211. fakeFolder.syncEngine().excludedFiles().clearManualExcludes();
  212. fakeFolder.scheduleSync();
  213. fakeFolder.execUntilBeforePropagation();
  214. QCOMPARE(statusSpy.statusOf(""), SyncFileStatus(SyncFileStatus::StatusSync));
  215. QCOMPARE(statusSpy.statusOf("A"), SyncFileStatus(SyncFileStatus::StatusSync));
  216. QCOMPARE(statusSpy.statusOf("A/a1"), SyncFileStatus(SyncFileStatus::StatusSync));
  217. QCOMPARE(statusSpy.statusOf("B"), SyncFileStatus(SyncFileStatus::StatusSync));
  218. QCOMPARE(statusSpy.statusOf("B/b1"), SyncFileStatus(SyncFileStatus::StatusSync));
  219. statusSpy.clear();
  220. fakeFolder.execUntilFinished();
  221. verifyThatPushMatchesPull(fakeFolder, statusSpy);
  222. QCOMPARE(statusSpy.statusOf(""), SyncFileStatus(SyncFileStatus::StatusUpToDate));
  223. QCOMPARE(statusSpy.statusOf("A"), SyncFileStatus(SyncFileStatus::StatusUpToDate));
  224. QCOMPARE(statusSpy.statusOf("A/a1"), SyncFileStatus(SyncFileStatus::StatusUpToDate));
  225. QCOMPARE(statusSpy.statusOf("B"), SyncFileStatus(SyncFileStatus::StatusUpToDate));
  226. QCOMPARE(statusSpy.statusOf("B/b1"), SyncFileStatus(SyncFileStatus::StatusUpToDate));
  227. QCOMPARE(fakeFolder.currentLocalState(), fakeFolder.currentRemoteState());
  228. }
  229. void warningStatusForExcludedFile_CasePreserving() {
  230. FakeFolder fakeFolder{FileInfo::A12_B12_C12_S12()};
  231. fakeFolder.syncEngine().excludedFiles().addManualExclude("B");
  232. fakeFolder.serverErrorPaths().append("A/a1");
  233. fakeFolder.localModifier().appendByte("A/a1");
  234. fakeFolder.syncOnce();
  235. QCOMPARE(fakeFolder.syncEngine().syncFileStatusTracker().fileStatus(""), SyncFileStatus(SyncFileStatus::StatusWarning));
  236. QCOMPARE(fakeFolder.syncEngine().syncFileStatusTracker().fileStatus("A"), SyncFileStatus(SyncFileStatus::StatusWarning));
  237. QCOMPARE(fakeFolder.syncEngine().syncFileStatusTracker().fileStatus("A/a1"), SyncFileStatus(SyncFileStatus::StatusError));
  238. QCOMPARE(fakeFolder.syncEngine().syncFileStatusTracker().fileStatus("B"), SyncFileStatus(SyncFileStatus::StatusExcluded));
  239. // Should still get the status for different casing on macOS and Windows.
  240. QCOMPARE(fakeFolder.syncEngine().syncFileStatusTracker().fileStatus("a"), SyncFileStatus(Utility::fsCasePreserving() ? SyncFileStatus::StatusWarning : SyncFileStatus::StatusNone));
  241. QCOMPARE(fakeFolder.syncEngine().syncFileStatusTracker().fileStatus("A/A1"), SyncFileStatus(Utility::fsCasePreserving() ? SyncFileStatus::StatusError : SyncFileStatus::StatusNone));
  242. QCOMPARE(fakeFolder.syncEngine().syncFileStatusTracker().fileStatus("b"), SyncFileStatus(Utility::fsCasePreserving() ? SyncFileStatus::StatusExcluded : SyncFileStatus::StatusNone));
  243. }
  244. void parentsGetWarningStatusForError() {
  245. FakeFolder fakeFolder{FileInfo::A12_B12_C12_S12()};
  246. fakeFolder.serverErrorPaths().append("A/a1");
  247. fakeFolder.serverErrorPaths().append("B/b0");
  248. fakeFolder.localModifier().appendByte("A/a1");
  249. fakeFolder.localModifier().insert("B/b0");
  250. StatusPushSpy statusSpy(fakeFolder.syncEngine());
  251. fakeFolder.scheduleSync();
  252. fakeFolder.execUntilBeforePropagation();
  253. verifyThatPushMatchesPull(fakeFolder, statusSpy);
  254. QCOMPARE(statusSpy.statusOf(""), SyncFileStatus(SyncFileStatus::StatusSync));
  255. QCOMPARE(statusSpy.statusOf("A"), SyncFileStatus(SyncFileStatus::StatusSync));
  256. QCOMPARE(statusSpy.statusOf("A/a1"), SyncFileStatus(SyncFileStatus::StatusSync));
  257. QCOMPARE(statusSpy.statusOf("B"), SyncFileStatus(SyncFileStatus::StatusSync));
  258. QCOMPARE(statusSpy.statusOf("B/b0"), SyncFileStatus(SyncFileStatus::StatusSync));
  259. statusSpy.clear();
  260. fakeFolder.execUntilFinished();
  261. verifyThatPushMatchesPull(fakeFolder, statusSpy);
  262. QCOMPARE(statusSpy.statusOf(""), SyncFileStatus(SyncFileStatus::StatusWarning));
  263. QCOMPARE(statusSpy.statusOf("A"), SyncFileStatus(SyncFileStatus::StatusWarning));
  264. QCOMPARE(statusSpy.statusOf("A/a1"), SyncFileStatus(SyncFileStatus::StatusError));
  265. QCOMPARE(fakeFolder.syncEngine().syncFileStatusTracker().fileStatus("A/a2"), SyncFileStatus(SyncFileStatus::StatusUpToDate));
  266. QCOMPARE(statusSpy.statusOf("B"), SyncFileStatus(SyncFileStatus::StatusWarning));
  267. QCOMPARE(statusSpy.statusOf("B/b0"), SyncFileStatus(SyncFileStatus::StatusError));
  268. statusSpy.clear();
  269. // Remove the error and start a second sync, the blacklist should kick in
  270. fakeFolder.serverErrorPaths().clear();
  271. fakeFolder.scheduleSync();
  272. fakeFolder.execUntilBeforePropagation();
  273. verifyThatPushMatchesPull(fakeFolder, statusSpy);
  274. // A/a1 and B/b0 should be on the black list for the next few seconds
  275. QCOMPARE(statusSpy.statusOf(""), SyncFileStatus(SyncFileStatus::StatusWarning));
  276. QCOMPARE(statusSpy.statusOf("A"), SyncFileStatus(SyncFileStatus::StatusWarning));
  277. QCOMPARE(statusSpy.statusOf("A/a1"), SyncFileStatus(SyncFileStatus::StatusError));
  278. QCOMPARE(statusSpy.statusOf("B"), SyncFileStatus(SyncFileStatus::StatusWarning));
  279. QCOMPARE(statusSpy.statusOf("B/b0"), SyncFileStatus(SyncFileStatus::StatusError));
  280. statusSpy.clear();
  281. fakeFolder.execUntilFinished();
  282. verifyThatPushMatchesPull(fakeFolder, statusSpy);
  283. QCOMPARE(statusSpy.statusOf(""), SyncFileStatus(SyncFileStatus::StatusWarning));
  284. QCOMPARE(statusSpy.statusOf("A"), SyncFileStatus(SyncFileStatus::StatusWarning));
  285. QCOMPARE(statusSpy.statusOf("A/a1"), SyncFileStatus(SyncFileStatus::StatusError));
  286. QCOMPARE(fakeFolder.syncEngine().syncFileStatusTracker().fileStatus("A/a2"), SyncFileStatus(SyncFileStatus::StatusUpToDate));
  287. QCOMPARE(statusSpy.statusOf("B"), SyncFileStatus(SyncFileStatus::StatusWarning));
  288. QCOMPARE(statusSpy.statusOf("B/b0"), SyncFileStatus(SyncFileStatus::StatusError));
  289. statusSpy.clear();
  290. // Start a third sync, this time together with a real file to sync
  291. fakeFolder.localModifier().appendByte("C/c1");
  292. fakeFolder.scheduleSync();
  293. fakeFolder.execUntilBeforePropagation();
  294. verifyThatPushMatchesPull(fakeFolder, statusSpy);
  295. // The root should show SYNC even though there is an error underneath,
  296. // since C/c1 is syncing and the SYNC status has priority.
  297. QCOMPARE(statusSpy.statusOf(""), SyncFileStatus(SyncFileStatus::StatusSync));
  298. QCOMPARE(statusSpy.statusOf("A"), SyncFileStatus(SyncFileStatus::StatusWarning));
  299. QCOMPARE(statusSpy.statusOf("A/a1"), SyncFileStatus(SyncFileStatus::StatusError));
  300. QCOMPARE(statusSpy.statusOf("B"), SyncFileStatus(SyncFileStatus::StatusWarning));
  301. QCOMPARE(statusSpy.statusOf("B/b0"), SyncFileStatus(SyncFileStatus::StatusError));
  302. QCOMPARE(statusSpy.statusOf("C"), SyncFileStatus(SyncFileStatus::StatusSync));
  303. QCOMPARE(statusSpy.statusOf("C/c1"), SyncFileStatus(SyncFileStatus::StatusSync));
  304. statusSpy.clear();
  305. fakeFolder.execUntilFinished();
  306. verifyThatPushMatchesPull(fakeFolder, statusSpy);
  307. QCOMPARE(statusSpy.statusOf(""), SyncFileStatus(SyncFileStatus::StatusWarning));
  308. QCOMPARE(statusSpy.statusOf("A"), SyncFileStatus(SyncFileStatus::StatusWarning));
  309. QCOMPARE(statusSpy.statusOf("A/a1"), SyncFileStatus(SyncFileStatus::StatusError));
  310. QCOMPARE(fakeFolder.syncEngine().syncFileStatusTracker().fileStatus("A/a2"), SyncFileStatus(SyncFileStatus::StatusUpToDate));
  311. QCOMPARE(statusSpy.statusOf("B"), SyncFileStatus(SyncFileStatus::StatusWarning));
  312. QCOMPARE(statusSpy.statusOf("B/b0"), SyncFileStatus(SyncFileStatus::StatusError));
  313. QCOMPARE(statusSpy.statusOf("C"), SyncFileStatus(SyncFileStatus::StatusUpToDate));
  314. QCOMPARE(statusSpy.statusOf("C/c1"), SyncFileStatus(SyncFileStatus::StatusUpToDate));
  315. statusSpy.clear();
  316. // Another sync after clearing the blacklist entry, everything should return to order.
  317. fakeFolder.syncEngine().journal()->wipeErrorBlacklistEntry("A/a1");
  318. fakeFolder.syncEngine().journal()->wipeErrorBlacklistEntry("B/b0");
  319. fakeFolder.scheduleSync();
  320. fakeFolder.execUntilBeforePropagation();
  321. verifyThatPushMatchesPull(fakeFolder, statusSpy);
  322. QCOMPARE(statusSpy.statusOf(""), SyncFileStatus(SyncFileStatus::StatusSync));
  323. QCOMPARE(statusSpy.statusOf("A"), SyncFileStatus(SyncFileStatus::StatusSync));
  324. QCOMPARE(statusSpy.statusOf("A/a1"), SyncFileStatus(SyncFileStatus::StatusSync));
  325. QCOMPARE(statusSpy.statusOf("B"), SyncFileStatus(SyncFileStatus::StatusSync));
  326. QCOMPARE(statusSpy.statusOf("B/b0"), SyncFileStatus(SyncFileStatus::StatusSync));
  327. statusSpy.clear();
  328. fakeFolder.execUntilFinished();
  329. verifyThatPushMatchesPull(fakeFolder, statusSpy);
  330. QCOMPARE(statusSpy.statusOf(""), SyncFileStatus(SyncFileStatus::StatusUpToDate));
  331. QCOMPARE(statusSpy.statusOf("A"), SyncFileStatus(SyncFileStatus::StatusUpToDate));
  332. QCOMPARE(statusSpy.statusOf("A/a1"), SyncFileStatus(SyncFileStatus::StatusUpToDate));
  333. QCOMPARE(statusSpy.statusOf("B"), SyncFileStatus(SyncFileStatus::StatusUpToDate));
  334. QCOMPARE(statusSpy.statusOf("B/b0"), SyncFileStatus(SyncFileStatus::StatusUpToDate));
  335. QCOMPARE(fakeFolder.currentLocalState(), fakeFolder.currentRemoteState());
  336. }
  337. void parentsGetWarningStatusForError_SibblingStartsWithPath() {
  338. // A is a parent of A/a1, but A/a is not even if it's a substring of A/a1
  339. FakeFolder fakeFolder{{QString{},{
  340. {QStringLiteral("A"), {
  341. {QStringLiteral("a"), 4},
  342. {QStringLiteral("a1"), 4}
  343. }}}}};
  344. fakeFolder.serverErrorPaths().append("A/a1");
  345. fakeFolder.localModifier().appendByte("A/a1");
  346. fakeFolder.scheduleSync();
  347. fakeFolder.execUntilBeforePropagation();
  348. // The SyncFileStatusTraker won't push any status for all of them, test with a pull.
  349. QCOMPARE(fakeFolder.syncEngine().syncFileStatusTracker().fileStatus(""), SyncFileStatus(SyncFileStatus::StatusSync));
  350. QCOMPARE(fakeFolder.syncEngine().syncFileStatusTracker().fileStatus("A"), SyncFileStatus(SyncFileStatus::StatusSync));
  351. QCOMPARE(fakeFolder.syncEngine().syncFileStatusTracker().fileStatus("A/a1"), SyncFileStatus(SyncFileStatus::StatusSync));
  352. QCOMPARE(fakeFolder.syncEngine().syncFileStatusTracker().fileStatus("A/a"), SyncFileStatus(SyncFileStatus::StatusUpToDate));
  353. fakeFolder.execUntilFinished();
  354. // We use string matching for paths in the implementation,
  355. // an error should affect only parents and not every path that starts with the problem path.
  356. QCOMPARE(fakeFolder.syncEngine().syncFileStatusTracker().fileStatus(""), SyncFileStatus(SyncFileStatus::StatusWarning));
  357. QCOMPARE(fakeFolder.syncEngine().syncFileStatusTracker().fileStatus("A"), SyncFileStatus(SyncFileStatus::StatusWarning));
  358. QCOMPARE(fakeFolder.syncEngine().syncFileStatusTracker().fileStatus("A/a1"), SyncFileStatus(SyncFileStatus::StatusError));
  359. QCOMPARE(fakeFolder.syncEngine().syncFileStatusTracker().fileStatus("A/a"), SyncFileStatus(SyncFileStatus::StatusUpToDate));
  360. }
  361. // Even for status pushes immediately following each other, macOS
  362. // can sometimes have 1s delays between updates, so make sure that
  363. // children are marked as OK before their parents do.
  364. void childOKEmittedBeforeParent() {
  365. FakeFolder fakeFolder{FileInfo::A12_B12_C12_S12()};
  366. fakeFolder.localModifier().appendByte("B/b1");
  367. fakeFolder.remoteModifier().appendByte("C/c1");
  368. StatusPushSpy statusSpy(fakeFolder.syncEngine());
  369. fakeFolder.syncOnce();
  370. verifyThatPushMatchesPull(fakeFolder, statusSpy);
  371. QVERIFY(statusSpy.statusEmittedBefore("B/b1", "B"));
  372. QVERIFY(statusSpy.statusEmittedBefore("C/c1", "C"));
  373. QVERIFY(statusSpy.statusEmittedBefore("B", ""));
  374. QVERIFY(statusSpy.statusEmittedBefore("C", ""));
  375. QCOMPARE(statusSpy.statusOf(""), SyncFileStatus(SyncFileStatus::StatusUpToDate));
  376. QCOMPARE(statusSpy.statusOf("B"), SyncFileStatus(SyncFileStatus::StatusUpToDate));
  377. QCOMPARE(statusSpy.statusOf("B/b1"), SyncFileStatus(SyncFileStatus::StatusUpToDate));
  378. QCOMPARE(statusSpy.statusOf("C"), SyncFileStatus(SyncFileStatus::StatusUpToDate));
  379. QCOMPARE(statusSpy.statusOf("C/c1"), SyncFileStatus(SyncFileStatus::StatusUpToDate));
  380. }
  381. void sharedStatus() {
  382. SyncFileStatus sharedUpToDateStatus(SyncFileStatus::StatusUpToDate);
  383. sharedUpToDateStatus.setShared(true);
  384. FakeFolder fakeFolder{FileInfo::A12_B12_C12_S12()};
  385. fakeFolder.remoteModifier().insert("S/s0");
  386. fakeFolder.remoteModifier().appendByte("S/s1");
  387. fakeFolder.remoteModifier().insert("B/b3");
  388. fakeFolder.remoteModifier().find("B/b3")->extraDavProperties = "<oc:share-types><oc:share-type>0</oc:share-type></oc:share-types>";
  389. fakeFolder.remoteModifier().find("A/a1")->isShared = true; // becomes shared
  390. fakeFolder.remoteModifier().find("A", true); // change the etags of the parent
  391. StatusPushSpy statusSpy(fakeFolder.syncEngine());
  392. fakeFolder.scheduleSync();
  393. fakeFolder.execUntilBeforePropagation();
  394. verifyThatPushMatchesPull(fakeFolder, statusSpy);
  395. QCOMPARE(statusSpy.statusOf(""), SyncFileStatus(SyncFileStatus::StatusSync));
  396. // We don't care about the shared flag for the sync status,
  397. // Mac and Windows won't show it and we can't know it for new files.
  398. QCOMPARE(statusSpy.statusOf("S").tag(), SyncFileStatus::StatusSync);
  399. QCOMPARE(statusSpy.statusOf("S/s0").tag(), SyncFileStatus::StatusSync);
  400. QCOMPARE(statusSpy.statusOf("S/s1").tag(), SyncFileStatus::StatusSync);
  401. fakeFolder.execUntilFinished();
  402. verifyThatPushMatchesPull(fakeFolder, statusSpy);
  403. QCOMPARE(statusSpy.statusOf(""), SyncFileStatus(SyncFileStatus::StatusUpToDate));
  404. QCOMPARE(statusSpy.statusOf("S"), sharedUpToDateStatus);
  405. QEXPECT_FAIL("", "We currently only know if a new file is shared on the second sync, after a PROPFIND.", Continue);
  406. QCOMPARE(statusSpy.statusOf("S/s0"), sharedUpToDateStatus);
  407. QCOMPARE(statusSpy.statusOf("S/s1"), sharedUpToDateStatus);
  408. QCOMPARE(statusSpy.statusOf("B/b1").shared(), false);
  409. QCOMPARE(statusSpy.statusOf("B/b3"), sharedUpToDateStatus);
  410. QCOMPARE(statusSpy.statusOf("A/a1"), sharedUpToDateStatus);
  411. QCOMPARE(fakeFolder.currentLocalState(), fakeFolder.currentRemoteState());
  412. }
  413. void renameError() {
  414. // when rename has failed - the old file name must be restored
  415. FakeFolder fakeFolder{FileInfo::A12_B12_C12_S12()};
  416. fakeFolder.serverErrorPaths().append("A/a1");
  417. fakeFolder.localModifier().rename("A/a1", "A/a1m");
  418. fakeFolder.localModifier().rename("B/b1", "B/b1m");
  419. StatusPushSpy statusSpy(fakeFolder.syncEngine());
  420. fakeFolder.scheduleSync();
  421. fakeFolder.execUntilBeforePropagation();
  422. verifyThatPushMatchesPull(fakeFolder, statusSpy);
  423. QCOMPARE(statusSpy.statusOf("A/a1m"), SyncFileStatus(SyncFileStatus::StatusSync));
  424. QCOMPARE(statusSpy.statusOf("A/a1"), statusSpy.statusOf("A/a1notexist"));
  425. QCOMPARE(statusSpy.statusOf("A"), SyncFileStatus(SyncFileStatus::StatusSync));
  426. QCOMPARE(statusSpy.statusOf(""), SyncFileStatus(SyncFileStatus::StatusSync));
  427. QCOMPARE(statusSpy.statusOf("B"), SyncFileStatus(SyncFileStatus::StatusSync));
  428. QCOMPARE(statusSpy.statusOf("B/b1m"), SyncFileStatus(SyncFileStatus::StatusSync));
  429. fakeFolder.execUntilFinished();
  430. verifyThatPushMatchesPull(fakeFolder, statusSpy);
  431. QCOMPARE(statusSpy.statusOf("A/a1m"), SyncFileStatus(SyncFileStatus::StatusError));
  432. QCOMPARE(statusSpy.statusOf("A/a1"), SyncFileStatus(SyncFileStatus::StatusUpToDate));
  433. QCOMPARE(statusSpy.statusOf("A"), SyncFileStatus(SyncFileStatus::StatusWarning));
  434. QCOMPARE(statusSpy.statusOf(""), SyncFileStatus(SyncFileStatus::StatusWarning));
  435. QCOMPARE(statusSpy.statusOf("B"), SyncFileStatus(SyncFileStatus::StatusUpToDate));
  436. QCOMPARE(statusSpy.statusOf("B/b1m"), SyncFileStatus(SyncFileStatus::StatusUpToDate));
  437. statusSpy.clear();
  438. QVERIFY(fakeFolder.syncOnce());
  439. verifyThatPushMatchesPull(fakeFolder, statusSpy);
  440. statusSpy.clear();
  441. QVERIFY(fakeFolder.syncOnce());
  442. verifyThatPushMatchesPull(fakeFolder, statusSpy);
  443. QCOMPARE(statusSpy.statusOf("A/a1m"), SyncFileStatus(SyncFileStatus::StatusNone));
  444. QCOMPARE(statusSpy.statusOf("A/a1"), statusSpy.statusOf("A/a1notexist"));
  445. QCOMPARE(statusSpy.statusOf("A"), SyncFileStatus(SyncFileStatus::StatusNone));
  446. QCOMPARE(statusSpy.statusOf(""), SyncFileStatus(SyncFileStatus::StatusUpToDate));
  447. QCOMPARE(statusSpy.statusOf("B"), SyncFileStatus(SyncFileStatus::StatusNone));
  448. QCOMPARE(statusSpy.statusOf("B/b1m"), SyncFileStatus(SyncFileStatus::StatusNone));
  449. statusSpy.clear();
  450. }
  451. };
  452. QTEST_GUILESS_MAIN(TestSyncFileStatusTracker)
  453. #include "testsyncfilestatustracker.moc"