From d31b3b068fa7ee2d7b8d1f58b5714991da14559f Mon Sep 17 00:00:00 2001 From: Matthieu Gallien Date: Fri, 13 Sep 2024 12:25:29 +0200 Subject: [PATCH] count the files deletion and warn if threshold is exceeded Signed-off-by: Matthieu Gallien --- src/libsync/configfile.cpp | 17 +++++++++++- src/libsync/configfile.h | 3 +++ src/libsync/syncengine.cpp | 55 +++++++++++++++++++++++++++++--------- src/libsync/syncengine.h | 2 ++ 4 files changed, 63 insertions(+), 14 deletions(-) diff --git a/src/libsync/configfile.cpp b/src/libsync/configfile.cpp index d79bbd51f..f5efd8eb1 100644 --- a/src/libsync/configfile.cpp +++ b/src/libsync/configfile.cpp @@ -54,6 +54,7 @@ static constexpr char fullLocalDiscoveryIntervalC[] = "fullLocalDiscoveryInterva static constexpr char notificationRefreshIntervalC[] = "notificationRefreshInterval"; static constexpr char monoIconsC[] = "monoIcons"; static constexpr char promptDeleteC[] = "promptDeleteAllFiles"; +static constexpr char deleteFilesThresholdC[] = "deleteFilesThreshold"; static constexpr char crashReporterC[] = "crashReporter"; static constexpr char optionalServerNotificationsC[] = "optionalServerNotifications"; static constexpr char showCallNotificationsC[] = "showCallNotifications"; @@ -112,6 +113,8 @@ static const QStringList defaultUpdateChannelsList { QStringLiteral("stable"), Q static const QString defaultUpdateChannelName = "stable"; static const QStringList enterpriseUpdateChannelsList { QStringLiteral("stable"), QStringLiteral("enterprise") }; static const QString defaultEnterpriseChannel = "enterprise"; + +static constexpr int deleteFilesThresholdDefaultValue = 100; } namespace OCC { @@ -1038,7 +1041,7 @@ bool ConfigFile::showMainDialogAsNormalWindow() const { bool ConfigFile::promptDeleteFiles() const { QSettings settings(configFile(), QSettings::IniFormat); - return settings.value(QLatin1String(promptDeleteC), false).toBool(); + return settings.value(QLatin1String(promptDeleteC), true).toBool(); } void ConfigFile::setPromptDeleteFiles(bool promptDeleteFiles) @@ -1047,6 +1050,18 @@ void ConfigFile::setPromptDeleteFiles(bool promptDeleteFiles) settings.setValue(QLatin1String(promptDeleteC), promptDeleteFiles); } +int ConfigFile::deleteFilesThreshold() const +{ + QSettings settings(configFile(), QSettings::IniFormat); + return settings.value(QLatin1String(deleteFilesThresholdC), deleteFilesThresholdDefaultValue).toInt(); +} + +void ConfigFile::setDeleteFilesThreshold(int thresholdValue) +{ + QSettings settings(configFile(), QSettings::IniFormat); + settings.setValue(QLatin1String(deleteFilesThresholdC), thresholdValue); +} + bool ConfigFile::monoIcons() const { QSettings settings(configFile(), QSettings::IniFormat); diff --git a/src/libsync/configfile.h b/src/libsync/configfile.h index 86963df53..ff289b1fe 100644 --- a/src/libsync/configfile.h +++ b/src/libsync/configfile.h @@ -93,6 +93,9 @@ public: [[nodiscard]] bool promptDeleteFiles() const; void setPromptDeleteFiles(bool promptDeleteFiles); + [[nodiscard]] int deleteFilesThreshold() const; + void setDeleteFilesThreshold(int thresholdValue); + [[nodiscard]] bool crashReporter() const; void setCrashReporter(bool enabled); diff --git a/src/libsync/syncengine.cpp b/src/libsync/syncengine.cpp index 61b6f0c5a..58aad760b 100644 --- a/src/libsync/syncengine.cpp +++ b/src/libsync/syncengine.cpp @@ -802,19 +802,7 @@ void SyncEngine::slotDiscoveryFinished() _progressInfo->_status = ProgressInfo::Reconcile; emit transmissionProgress(*_progressInfo); - const auto displayDialog = ConfigFile().promptDeleteFiles() && !_syncOptions.isCmd(); - if (!_hasNoneFiles && _hasRemoveFile && displayDialog) { - qCInfo(lcEngine) << "All the files are going to be changed, asking the user"; - int side = 0; // > 0 means more deleted on the server. < 0 means more deleted on the client - for (const auto &it : _syncItems) { - if (it->_instruction == CSYNC_INSTRUCTION_REMOVE) { - side += it->_direction == SyncFileItem::Down ? 1 : -1; - } - } - - promptUserBeforePropagation([this, side](auto &&callback){ - emit aboutToRemoveAllFiles(side >= 0 ? SyncFileItem::Down : SyncFileItem::Up, callback); - }); + if (handleMassDeletion()) { return; } @@ -1106,6 +1094,47 @@ void SyncEngine::finishSync() qCInfo(lcEngine) << "#### Post-Reconcile end #################################################### " << _stopWatch.addLapTime(QStringLiteral("Post-Reconcile Finished")) << "ms"; } +bool SyncEngine::handleMassDeletion() +{ + const auto displayDialog = ConfigFile().promptDeleteFiles() && !_syncOptions.isCmd(); + const auto allFilesDeleted = !_hasNoneFiles && _hasRemoveFile; + + auto deletionCounter = 0; + for (const auto &oneItem : qAsConst(_syncItems)) { + if (oneItem->_instruction == CSYNC_INSTRUCTION_REMOVE) { + if (oneItem->isDirectory()) { + const auto result = _journal->listFilesInPath(oneItem->_file.toUtf8(), [&deletionCounter] (const auto &oneRecord) { + if (oneRecord.isFile()) { + ++deletionCounter; + } + }); + if (!result) { + qCDebug(lcEngine()) << "unable to find the number of files within a deleted folder:" << oneItem->_file; + } + } else { + ++deletionCounter; + } + } + } + const auto filesDeletedThresholdExceeded = deletionCounter > ConfigFile().deleteFilesThreshold(); + + if ((allFilesDeleted || filesDeletedThresholdExceeded) && displayDialog) { + qCInfo(lcEngine) << "All the files are going to be changed, asking the user"; + int side = 0; // > 0 means more deleted on the server. < 0 means more deleted on the client + for (const auto &it : qAsConst(_syncItems)) { + if (it->_instruction == CSYNC_INSTRUCTION_REMOVE) { + side += it->_direction == SyncFileItem::Down ? 1 : -1; + } + } + + promptUserBeforePropagation([this, side](auto &&callback){ + emit aboutToRemoveAllFiles(side >= 0 ? SyncFileItem::Down : SyncFileItem::Up, callback); + }); + return true; + } + return false; +} + void SyncEngine::handleRemnantReadOnlyFolders() { promptUserBeforePropagation([this](auto &&callback) { diff --git a/src/libsync/syncengine.h b/src/libsync/syncengine.h index 2d824f331..63ab0a787 100644 --- a/src/libsync/syncengine.h +++ b/src/libsync/syncengine.h @@ -369,6 +369,8 @@ private: void finishSync(); + bool handleMassDeletion(); + void handleRemnantReadOnlyFolders(); template