tidy code to fix review comments
authorMatthieu Gallien <matthieu.gallien@nextcloud.com>
Fri, 18 Nov 2022 08:11:41 +0000 (09:11 +0100)
committerMatthieu Gallien <matthieu_gallien@yahoo.fr>
Thu, 24 Nov 2022 11:07:59 +0000 (12:07 +0100)
Signed-off-by: Matthieu Gallien <matthieu.gallien@nextcloud.com>
src/libsync/propagatorjobs.cpp
src/libsync/propagatorjobs.h
src/libsync/syncengine.cpp

index 637634e73781eeb24a46c3324f65f25f6dc4e646..b003c2110cd5e8ece4e97a5b8fc76e1448e857d7 100644 (file)
@@ -258,31 +258,10 @@ void PropagateLocalRename::start()
         return;
     }
 
-    const auto deleteOldRecord = [this] (const QString &fileName) -> bool
-    {
-        SyncJournalFileRecord oldRecord;
-        if (!propagator()->_journal->getFileRecord(fileName, &oldRecord)) {
-            qCWarning(lcPropagateLocalRename) << "could not get file from local DB" << fileName;
-            done(SyncFileItem::NormalError, tr("could not get file %1 from local DB").arg(fileName));
-            return false;
-        }
-        if (!propagator()->_journal->deleteFileRecord(fileName)) {
-            qCWarning(lcPropagateLocalRename) << "could not delete file from local DB" << fileName;
-            done(SyncFileItem::NormalError, tr("Could not delete file record %1 from local DB").arg(fileName));
-            return false;
-        }
-
-        return true;
-    };
-
-    if (fileAlreadyMoved) {
-        if (!deleteOldRecord(previousNameInDb)) {
-            return;
-        }
-    } else {
-        if (!deleteOldRecord(_item->_originalFile)) {
-            return;
-        }
+    if (fileAlreadyMoved && !deleteOldDbRecord(previousNameInDb)) {
+        return;
+    } else if (!deleteOldDbRecord(_item->_originalFile)) {
+        return;
     }
 
     auto &vfs = propagator()->syncOptions()._vfs;
@@ -357,4 +336,21 @@ void PropagateLocalRename::start()
 
     done(SyncFileItem::Success);
 }
+
+bool PropagateLocalRename::deleteOldDbRecord(const QString &fileName)
+{
+    SyncJournalFileRecord oldRecord;
+    if (!propagator()->_journal->getFileRecord(fileName, &oldRecord)) {
+        qCWarning(lcPropagateLocalRename) << "could not get file from local DB" << fileName;
+        done(SyncFileItem::NormalError, tr("could not get file %1 from local DB").arg(fileName));
+        return false;
+    }
+    if (!propagator()->_journal->deleteFileRecord(fileName)) {
+        qCWarning(lcPropagateLocalRename) << "could not delete file from local DB" << fileName;
+        done(SyncFileItem::NormalError, tr("Could not delete file record %1 from local DB").arg(fileName));
+        return false;
+    }
+
+    return true;
+}
 }
index 3fa37ac03ce0c07b4b54584c3dd6fb534f902f9c..099286829398dfb14f8e758c51af6b6143d4b0d4 100644 (file)
@@ -89,5 +89,9 @@ public:
     PropagateLocalRename(OwncloudPropagator *propagator, const SyncFileItemPtr &item);
     void start() override;
     JobParallelism parallelism() override { return _item->isDirectory() ? WaitForFinished : FullParallelism; }
+
+private:
+    bool deleteOldDbRecord(const QString &fileName);
+
 };
 }
index 8f4025586755c854c7e37d836ef36a8e876da422..f4fb79062cc0ba45f91b807d50fa26e1ba02b271 100644 (file)
@@ -568,9 +568,9 @@ void SyncEngine::startSync()
     if (!_discoveryPhase->_remoteFolder.endsWith('/'))
         _discoveryPhase->_remoteFolder+='/';
     _discoveryPhase->_syncOptions = _syncOptions;
-    _discoveryPhase->_shouldDiscoverLocaly = [this](const QString &s) {
-        const auto result = shouldDiscoverLocally(s);
-        qCInfo(lcEngine) << "shouldDiscoverLocaly" << s << (result ? "true" : "false");
+    _discoveryPhase->_shouldDiscoverLocaly = [this](const QString &path) {
+        const auto result = shouldDiscoverLocally(path);
+        qCInfo(lcEngine) << "shouldDiscoverLocaly" << path << (result ? "true" : "false");
         return result;
     };
     _discoveryPhase->setSelectiveSyncBlackList(selectiveSyncBlackList);