mirror of
https://github.com/nextcloud/desktop.git
synced 2024-10-28 16:13:53 +03:00
b99c8fe28b
FolderDefinition::save and load escapes the alias. We also need to escape it when we remove it. New folder can't be created with alias that needs escaping, but old folder from old config may still exist, and we must allow user to delete them.
1061 lines
36 KiB
C++
1061 lines
36 KiB
C++
/*
|
|
* Copyright (C) by Duncan Mac-Vicar P. <duncan@kde.org>
|
|
* Copyright (C) by Daniel Molkentin <danimo@owncloud.com>
|
|
* Copyright (C) by Klaas Freitag <freitag@owncloud.com>
|
|
*
|
|
* This program is free software; you can redistribute it and/or modify
|
|
* it under the terms of the GNU General Public License as published by
|
|
* the Free Software Foundation; either version 2 of the License, or
|
|
* (at your option) any later version.
|
|
*
|
|
* This program is distributed in the hope that it will be useful, but
|
|
* WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY
|
|
* or FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License
|
|
* for more details.
|
|
*/
|
|
#include "config.h"
|
|
|
|
#include "account.h"
|
|
#include "accountstate.h"
|
|
#include "folder.h"
|
|
#include "folderman.h"
|
|
#include "logger.h"
|
|
#include "configfile.h"
|
|
#include "networkjobs.h"
|
|
#include "syncjournalfilerecord.h"
|
|
#include "syncresult.h"
|
|
#include "utility.h"
|
|
#include "clientproxy.h"
|
|
#include "syncengine.h"
|
|
#include "syncrunfilelog.h"
|
|
#include "socketapi.h"
|
|
#include "theme.h"
|
|
#include "filesystem.h"
|
|
#include "excludedfiles.h"
|
|
|
|
#include "creds/abstractcredentials.h"
|
|
|
|
#include <QDebug>
|
|
#include <QTimer>
|
|
#include <QUrl>
|
|
#include <QDir>
|
|
#include <QSettings>
|
|
|
|
#include <QMessageBox>
|
|
#include <QPushButton>
|
|
|
|
namespace OCC {
|
|
|
|
static void csyncLogCatcher(int /*verbosity*/,
|
|
const char */*function*/,
|
|
const char *buffer,
|
|
void */*userdata*/)
|
|
{
|
|
Logger::instance()->csyncLog( QString::fromUtf8(buffer) );
|
|
}
|
|
|
|
|
|
Folder::Folder(const FolderDefinition& definition,
|
|
AccountState* accountState,
|
|
QObject* parent)
|
|
: QObject(parent)
|
|
, _accountState(accountState)
|
|
, _definition(definition)
|
|
, _csyncError(false)
|
|
, _csyncUnavail(false)
|
|
, _wipeDb(false)
|
|
, _proxyDirty(true)
|
|
, _lastSyncDuration(0)
|
|
, _forceSyncOnPollTimeout(false)
|
|
, _consecutiveFailingSyncs(0)
|
|
, _consecutiveFollowUpSyncs(0)
|
|
, _journal(definition.localPath)
|
|
{
|
|
qRegisterMetaType<SyncFileItemVector>("SyncFileItemVector");
|
|
qRegisterMetaType<SyncFileItem::Direction>("SyncFileItem::Direction");
|
|
|
|
qsrand(QTime::currentTime().msec());
|
|
_timeSinceLastSyncStart.start();
|
|
_timeSinceLastSyncDone.start();
|
|
|
|
SyncResult::Status status = SyncResult::NotYetStarted;
|
|
if (definition.paused) {
|
|
status = SyncResult::Paused;
|
|
}
|
|
_syncResult.setStatus(status);
|
|
|
|
// check if the local path exists
|
|
checkLocalPath();
|
|
|
|
_syncResult.setFolder(_definition.alias);
|
|
|
|
_engine.reset(new SyncEngine(_accountState->account(), path(), remoteUrl(), remotePath(), &_journal));
|
|
// pass the setting if hidden files are to be ignored, will be read in csync_update
|
|
_engine->setIgnoreHiddenFiles(_definition.ignoreHiddenFiles);
|
|
|
|
if (!setIgnoredFiles())
|
|
qWarning("Could not read system exclude file");
|
|
|
|
connect(_accountState.data(), SIGNAL(isConnectedChanged()), this, SIGNAL(canSyncChanged()));
|
|
connect(_engine.data(), SIGNAL(rootEtag(QString)), this, SLOT(etagRetreivedFromSyncEngine(QString)));
|
|
connect(_engine.data(), SIGNAL(treeWalkResult(const SyncFileItemVector&)),
|
|
this, SLOT(slotThreadTreeWalkResult(const SyncFileItemVector&)), Qt::QueuedConnection);
|
|
|
|
connect(_engine.data(), SIGNAL(started()), SLOT(slotSyncStarted()), Qt::QueuedConnection);
|
|
connect(_engine.data(), SIGNAL(finished(bool)), SLOT(slotSyncFinished(bool)), Qt::QueuedConnection);
|
|
connect(_engine.data(), SIGNAL(csyncError(QString)), SLOT(slotSyncError(QString)), Qt::QueuedConnection);
|
|
connect(_engine.data(), SIGNAL(csyncUnavailable()), SLOT(slotCsyncUnavailable()), Qt::QueuedConnection);
|
|
|
|
//direct connection so the message box is blocking the sync.
|
|
connect(_engine.data(), SIGNAL(aboutToRemoveAllFiles(SyncFileItem::Direction,bool*)),
|
|
SLOT(slotAboutToRemoveAllFiles(SyncFileItem::Direction,bool*)));
|
|
connect(_engine.data(), SIGNAL(aboutToRestoreBackup(bool*)),
|
|
SLOT(slotAboutToRestoreBackup(bool*)));
|
|
connect(_engine.data(), SIGNAL(folderDiscovered(bool,QString)), this, SLOT(slotFolderDiscovered(bool,QString)));
|
|
connect(_engine.data(), SIGNAL(transmissionProgress(ProgressInfo)), this, SLOT(slotTransmissionProgress(ProgressInfo)));
|
|
connect(_engine.data(), SIGNAL(itemCompleted(const SyncFileItem &, const PropagatorJob &)),
|
|
this, SLOT(slotItemCompleted(const SyncFileItem &, const PropagatorJob &)));
|
|
connect(_engine.data(), SIGNAL(newBigFolder(QString)), this, SLOT(slotNewBigFolderDiscovered(QString)));
|
|
connect(_engine.data(), SIGNAL(seenLockedFile(QString)), FolderMan::instance(), SLOT(slotSyncOnceFileUnlocks(QString)));
|
|
}
|
|
|
|
Folder::~Folder()
|
|
{
|
|
}
|
|
|
|
void Folder::checkLocalPath()
|
|
{
|
|
const QFileInfo fi(_definition.localPath);
|
|
|
|
if( fi.isDir() && fi.isReadable() ) {
|
|
qDebug() << "Checked local path ok";
|
|
} else {
|
|
// Check directory again
|
|
if( !FileSystem::fileExists(_definition.localPath, fi) ) {
|
|
_syncResult.setErrorString(tr("Local folder %1 does not exist.").arg(_definition.localPath));
|
|
_syncResult.setStatus( SyncResult::SetupError );
|
|
} else if( !fi.isDir() ) {
|
|
_syncResult.setErrorString(tr("%1 should be a folder but is not.").arg(_definition.localPath));
|
|
_syncResult.setStatus( SyncResult::SetupError );
|
|
} else if( !fi.isReadable() ) {
|
|
_syncResult.setErrorString(tr("%1 is not readable.").arg(_definition.localPath));
|
|
_syncResult.setStatus( SyncResult::SetupError );
|
|
}
|
|
}
|
|
}
|
|
|
|
QString Folder::shortGuiRemotePathOrAppName() const
|
|
{
|
|
if (remotePath().length() > 0 && remotePath() != QLatin1String("/")) {
|
|
QString a = QFile(remotePath()).fileName();
|
|
if (a.startsWith('/')) {
|
|
a = a.remove(0, 1);
|
|
}
|
|
return a;
|
|
} else {
|
|
return Theme::instance()->appNameGUI();
|
|
}
|
|
}
|
|
|
|
QString Folder::alias() const
|
|
{
|
|
return _definition.alias;
|
|
}
|
|
|
|
QString Folder::path() const
|
|
{
|
|
QString p(_definition.localPath);
|
|
if( ! p.endsWith('/') ) {
|
|
p.append('/');
|
|
}
|
|
return p;
|
|
}
|
|
|
|
QString Folder::shortGuiLocalPath() const
|
|
{
|
|
QString p = _definition.localPath;
|
|
QString home = QDir::homePath();
|
|
if( ! home.endsWith('/') ) {
|
|
home.append('/');
|
|
}
|
|
if (p.startsWith(home)) {
|
|
p = p.mid(home.length());
|
|
}
|
|
if (p.length() > 1 && p.endsWith('/')) {
|
|
p.chop(1);
|
|
}
|
|
return QDir::toNativeSeparators(p);
|
|
}
|
|
|
|
|
|
bool Folder::ignoreHiddenFiles()
|
|
{
|
|
bool re(_definition.ignoreHiddenFiles);
|
|
return re;
|
|
}
|
|
|
|
void Folder::setIgnoreHiddenFiles(bool ignore)
|
|
{
|
|
_definition.ignoreHiddenFiles = ignore;
|
|
}
|
|
|
|
QString Folder::cleanPath()
|
|
{
|
|
QString cleanedPath = QDir::cleanPath(_definition.localPath);
|
|
|
|
if(cleanedPath.length() == 3 && cleanedPath.endsWith(":/"))
|
|
cleanedPath.remove(2,1);
|
|
|
|
return cleanedPath;
|
|
}
|
|
|
|
bool Folder::isBusy() const
|
|
{
|
|
return _engine->isSyncRunning();
|
|
}
|
|
|
|
QString Folder::remotePath() const
|
|
{
|
|
return _definition.targetPath;
|
|
}
|
|
|
|
QUrl Folder::remoteUrl() const
|
|
{
|
|
return Account::concatUrlPath(_accountState->account()->davUrl(), remotePath());
|
|
}
|
|
|
|
bool Folder::syncPaused() const
|
|
{
|
|
return _definition.paused;
|
|
}
|
|
|
|
bool Folder::canSync() const
|
|
{
|
|
return !syncPaused() && accountState()->isConnected();
|
|
}
|
|
|
|
void Folder::setSyncPaused( bool paused )
|
|
{
|
|
if (paused == _definition.paused) {
|
|
return;
|
|
}
|
|
|
|
_definition.paused = paused;
|
|
saveToSettings();
|
|
|
|
if( !paused ) {
|
|
setSyncState(SyncResult::NotYetStarted);
|
|
} else {
|
|
setSyncState(SyncResult::Paused);
|
|
}
|
|
emit syncPausedChanged(this, paused);
|
|
emit syncStateChange();
|
|
emit canSyncChanged();
|
|
}
|
|
|
|
void Folder::setSyncState(SyncResult::Status state)
|
|
{
|
|
_syncResult.setStatus(state);
|
|
}
|
|
|
|
SyncResult Folder::syncResult() const
|
|
{
|
|
return _syncResult;
|
|
}
|
|
|
|
void Folder::prepareToSync()
|
|
{
|
|
_syncResult.setStatus( SyncResult::NotYetStarted );
|
|
_syncResult.clearErrors();
|
|
}
|
|
|
|
void Folder::slotRunEtagJob()
|
|
{
|
|
qDebug() << "* Trying to check" << remoteUrl().toString() << "for changes via ETag check. (time since last sync:" << (_timeSinceLastSyncDone.elapsed() / 1000) << "s)";
|
|
|
|
AccountPtr account = _accountState->account();
|
|
|
|
if (!_requestEtagJob.isNull()) {
|
|
qDebug() << Q_FUNC_INFO << remoteUrl().toString() << "has ETag job queued, not trying to sync";
|
|
return;
|
|
}
|
|
|
|
if (!canSync()) {
|
|
qDebug() << "Not syncing. :" << remoteUrl().toString() << _definition.paused << AccountState::stateString(_accountState->state());
|
|
return;
|
|
}
|
|
|
|
bool forceSyncIntervalExpired =
|
|
quint64(_timeSinceLastSyncDone.elapsed()) > ConfigFile().forceSyncInterval();
|
|
bool syncAgainAfterFail = _consecutiveFailingSyncs > 0 && _consecutiveFailingSyncs < 3;
|
|
|
|
// There are several conditions under which we trigger a full-discovery sync:
|
|
// * When a suitably long time has passed since the last sync finished
|
|
// * When the last sync failed (only a couple of times)
|
|
// * When the last sync requested another sync to be done (only a couple of times)
|
|
//
|
|
// Note that the etag check (see below) and the file watcher may also trigger
|
|
// syncs.
|
|
if (forceSyncIntervalExpired
|
|
|| _forceSyncOnPollTimeout
|
|
|| syncAgainAfterFail) {
|
|
|
|
if (forceSyncIntervalExpired) {
|
|
qDebug() << "** Force Sync, because it has been " << _timeSinceLastSyncDone.elapsed() << "ms "
|
|
<< "since the last sync";
|
|
}
|
|
if (_forceSyncOnPollTimeout) {
|
|
qDebug() << "** Force Sync, because it was requested";
|
|
}
|
|
if (syncAgainAfterFail) {
|
|
qDebug() << "** Force Sync, because the last"
|
|
<< _consecutiveFailingSyncs << "syncs failed, last status:"
|
|
<< _syncResult.statusString();
|
|
}
|
|
_forceSyncOnPollTimeout = false;
|
|
emit scheduleToSync(this);
|
|
|
|
} else {
|
|
// Do the ordinary etag check for the root folder and only schedule a real
|
|
// sync if it's different.
|
|
|
|
_requestEtagJob = new RequestEtagJob(account, remotePath(), this);
|
|
_requestEtagJob->setTimeout(60*1000);
|
|
// check if the etag is different
|
|
QObject::connect(_requestEtagJob, SIGNAL(etagRetreived(QString)), this, SLOT(etagRetreived(QString)));
|
|
FolderMan::instance()->slotScheduleETagJob(alias(), _requestEtagJob);
|
|
// The _requestEtagJob is auto deleting itself on finish. Our guard pointer _requestEtagJob will then be null.
|
|
}
|
|
}
|
|
|
|
void Folder::etagRetreived(const QString& etag)
|
|
{
|
|
//qDebug() << "* Compare etag with previous etag: last:" << _lastEtag << ", received:" << etag;
|
|
|
|
// re-enable sync if it was disabled because network was down
|
|
FolderMan::instance()->setSyncEnabled(true);
|
|
|
|
if (_lastEtag != etag) {
|
|
qDebug() << "* Compare etag with previous etag: last:" << _lastEtag << ", received:" << etag << "-> CHANGED";
|
|
_lastEtag = etag;
|
|
emit scheduleToSync(this);
|
|
}
|
|
|
|
_accountState->tagLastSuccessfullETagRequest();
|
|
}
|
|
|
|
void Folder::etagRetreivedFromSyncEngine(const QString& etag)
|
|
{
|
|
qDebug() << "Root etag from during sync:" << etag;
|
|
accountState()->tagLastSuccessfullETagRequest();
|
|
_lastEtag = etag;
|
|
}
|
|
|
|
|
|
void Folder::bubbleUpSyncResult()
|
|
{
|
|
// count new, removed and updated items
|
|
int newItems = 0;
|
|
int removedItems = 0;
|
|
int updatedItems = 0;
|
|
int ignoredItems = 0;
|
|
int renamedItems = 0;
|
|
int conflictItems = 0;
|
|
int errorItems = 0;
|
|
|
|
SyncFileItemPtr firstItemNew;
|
|
SyncFileItemPtr firstItemDeleted;
|
|
SyncFileItemPtr firstItemUpdated;
|
|
SyncFileItemPtr firstItemRenamed;
|
|
SyncFileItemPtr firstConflictItem;
|
|
SyncFileItemPtr firstItemError;
|
|
|
|
SyncRunFileLog syncFileLog;
|
|
|
|
syncFileLog.start(path(), _engine->isSyncRunning() ? _engine->stopWatch() : Utility::StopWatch() );
|
|
|
|
QElapsedTimer timer;
|
|
timer.start();
|
|
|
|
foreach (const SyncFileItemPtr &item, _syncResult.syncFileItemVector() ) {
|
|
// Log the item
|
|
syncFileLog.logItem( *item );
|
|
|
|
// and process the item to the gui
|
|
if( item->_status == SyncFileItem::FatalError || item->_status == SyncFileItem::NormalError ) {
|
|
//: this displays an error string (%2) for a file %1
|
|
slotSyncError( tr("%1: %2").arg(item->_file, item->_errorString) );
|
|
errorItems++;
|
|
if (!firstItemError) {
|
|
firstItemError = item;
|
|
}
|
|
} else if( item->_status == SyncFileItem::FileIgnored ) {
|
|
// ignored files don't show up in notifications
|
|
continue;
|
|
} else if( item->_status == SyncFileItem::Conflict ) {
|
|
conflictItems++;
|
|
if (!firstConflictItem) {
|
|
firstConflictItem = item;
|
|
}
|
|
} else {
|
|
// add new directories or remove gone away dirs to the watcher
|
|
if (item->_isDirectory && item->_instruction == CSYNC_INSTRUCTION_NEW ) {
|
|
FolderMan::instance()->addMonitorPath( alias(), path()+item->_file );
|
|
}
|
|
if (item->_isDirectory && item->_instruction == CSYNC_INSTRUCTION_REMOVE ) {
|
|
FolderMan::instance()->removeMonitorPath( alias(), path()+item->_file );
|
|
}
|
|
|
|
if (!item->hasErrorStatus() && item->_direction == SyncFileItem::Down) {
|
|
switch (item->_instruction) {
|
|
case CSYNC_INSTRUCTION_NEW:
|
|
case CSYNC_INSTRUCTION_TYPE_CHANGE:
|
|
newItems++;
|
|
if (!firstItemNew)
|
|
firstItemNew = item;
|
|
break;
|
|
case CSYNC_INSTRUCTION_REMOVE:
|
|
removedItems++;
|
|
if (!firstItemDeleted)
|
|
firstItemDeleted = item;
|
|
break;
|
|
case CSYNC_INSTRUCTION_SYNC:
|
|
if (!item->_isDirectory) {
|
|
updatedItems++;
|
|
if (!firstItemUpdated)
|
|
firstItemUpdated = item;
|
|
}
|
|
break;
|
|
case CSYNC_INSTRUCTION_ERROR:
|
|
qDebug() << "Got Instruction ERROR. " << _syncResult.errorString();
|
|
break;
|
|
case CSYNC_INSTRUCTION_RENAME:
|
|
if (!firstItemRenamed) {
|
|
firstItemRenamed = item;
|
|
}
|
|
renamedItems++;
|
|
break;
|
|
default:
|
|
// nothing.
|
|
break;
|
|
}
|
|
} else if( item->_direction == SyncFileItem::None ) { // ignored files counting.
|
|
if( item->_instruction == CSYNC_INSTRUCTION_IGNORE ) {
|
|
ignoredItems++;
|
|
}
|
|
}
|
|
}
|
|
}
|
|
syncFileLog.close();
|
|
|
|
qDebug() << "Processing result list and logging took " << timer.elapsed() << " Milliseconds.";
|
|
_syncResult.setWarnCount(ignoredItems);
|
|
|
|
if( firstItemNew ) {
|
|
createGuiLog( firstItemNew->_file, LogStatusNew, newItems );
|
|
}
|
|
if( firstItemDeleted ) {
|
|
createGuiLog( firstItemDeleted->_file, LogStatusRemove, removedItems );
|
|
}
|
|
if( firstItemUpdated ) {
|
|
createGuiLog( firstItemUpdated->_file, LogStatusUpdated, updatedItems );
|
|
}
|
|
|
|
if( firstItemRenamed ) {
|
|
LogStatus status(LogStatusRename);
|
|
// if the path changes it's rather a move
|
|
QDir renTarget = QFileInfo(firstItemRenamed->_renameTarget).dir();
|
|
QDir renSource = QFileInfo(firstItemRenamed->_file).dir();
|
|
if(renTarget != renSource) {
|
|
status = LogStatusMove;
|
|
}
|
|
createGuiLog( firstItemRenamed->_originalFile, status, renamedItems, firstItemRenamed->_renameTarget );
|
|
}
|
|
|
|
if( firstConflictItem ) {
|
|
createGuiLog( firstConflictItem->_file, LogStatusConflict, conflictItems );
|
|
}
|
|
createGuiLog( firstItemError->_file, LogStatusError, errorItems );
|
|
|
|
qDebug() << "OO folder slotSyncFinished: result: " << int(_syncResult.status());
|
|
}
|
|
|
|
void Folder::createGuiLog( const QString& filename, LogStatus status, int count,
|
|
const QString& renameTarget )
|
|
{
|
|
if(count > 0) {
|
|
Logger *logger = Logger::instance();
|
|
|
|
QString file = QDir::toNativeSeparators(filename);
|
|
QString text;
|
|
|
|
switch (status) {
|
|
case LogStatusRemove:
|
|
if( count > 1 ) {
|
|
text = tr("%1 and %n other file(s) have been removed.", "", count-1).arg(file);
|
|
} else {
|
|
text = tr("%1 has been removed.", "%1 names a file.").arg(file);
|
|
}
|
|
break;
|
|
case LogStatusNew:
|
|
if( count > 1 ) {
|
|
text = tr("%1 and %n other file(s) have been downloaded.", "", count-1).arg(file);
|
|
} else {
|
|
text = tr("%1 has been downloaded.", "%1 names a file.").arg(file);
|
|
}
|
|
break;
|
|
case LogStatusUpdated:
|
|
if( count > 1 ) {
|
|
text = tr("%1 and %n other file(s) have been updated.", "", count-1).arg(file);
|
|
} else {
|
|
text = tr("%1 has been updated.", "%1 names a file.").arg(file);
|
|
}
|
|
break;
|
|
case LogStatusRename:
|
|
if( count > 1 ) {
|
|
text = tr("%1 has been renamed to %2 and %n other file(s) have been renamed.", "", count-1).arg(file).arg(renameTarget);
|
|
} else {
|
|
text = tr("%1 has been renamed to %2.", "%1 and %2 name files.").arg(file).arg(renameTarget);
|
|
}
|
|
break;
|
|
case LogStatusMove:
|
|
if( count > 1 ) {
|
|
text = tr("%1 has been moved to %2 and %n other file(s) have been moved.", "", count-1).arg(file).arg(renameTarget);
|
|
} else {
|
|
text = tr("%1 has been moved to %2.").arg(file).arg(renameTarget);
|
|
}
|
|
break;
|
|
case LogStatusConflict:
|
|
if( count > 1 ) {
|
|
text = tr("%1 has and %n other file(s) have sync conflicts.", "", count-1).arg(file);
|
|
} else {
|
|
text = tr("%1 has a sync conflict. Please check the conflict file!").arg(file);
|
|
}
|
|
break;
|
|
case LogStatusError:
|
|
if( count > 1 ) {
|
|
text = tr("%1 and %n other file(s) could not be synced due to errors. See the log for details.", "", count-1).arg(file);
|
|
} else {
|
|
text = tr("%1 could not be synced due to an error. See the log for details.").arg(file);
|
|
}
|
|
break;
|
|
}
|
|
|
|
if( !text.isEmpty() ) {
|
|
logger->postOptionalGuiLog( tr("Sync Activity"), text );
|
|
}
|
|
}
|
|
}
|
|
|
|
int Folder::slotDiscardDownloadProgress()
|
|
{
|
|
// Delete from journal and from filesystem.
|
|
QDir folderpath(_definition.localPath);
|
|
QSet<QString> keep_nothing;
|
|
const QVector<SyncJournalDb::DownloadInfo> deleted_infos =
|
|
_journal.getAndDeleteStaleDownloadInfos(keep_nothing);
|
|
foreach (const SyncJournalDb::DownloadInfo & deleted_info, deleted_infos) {
|
|
const QString tmppath = folderpath.filePath(deleted_info._tmpfile);
|
|
qDebug() << "Deleting temporary file: " << tmppath;
|
|
FileSystem::remove(tmppath);
|
|
}
|
|
return deleted_infos.size();
|
|
}
|
|
|
|
int Folder::downloadInfoCount()
|
|
{
|
|
return _journal.downloadInfoCount();
|
|
}
|
|
|
|
int Folder::errorBlackListEntryCount()
|
|
{
|
|
return _journal.errorBlackListEntryCount();
|
|
}
|
|
|
|
int Folder::slotWipeErrorBlacklist()
|
|
{
|
|
return _journal.wipeErrorBlacklist();
|
|
}
|
|
|
|
void Folder::slotWatchedPathChanged(const QString& path)
|
|
{
|
|
// The folder watcher fires a lot of bogus notifications during
|
|
// a sync operation, both for actual user files and the database
|
|
// and log. Therefore we check notifications against operations
|
|
// the sync is doing to filter out our own changes.
|
|
#ifdef Q_OS_MAC
|
|
Q_UNUSED(path)
|
|
// On OSX the folder watcher does not report changes done by our
|
|
// own process. Therefore nothing needs to be done here!
|
|
#else
|
|
// Use the path to figure out whether it was our own change
|
|
const auto maxNotificationDelay = 15*1000;
|
|
qint64 time = _engine->timeSinceFileTouched(path);
|
|
if (time != -1 && time < maxNotificationDelay) {
|
|
return;
|
|
}
|
|
#endif
|
|
|
|
// Check that the mtime actually changed.
|
|
if (path.startsWith(this->path())) {
|
|
auto relativePath = path.mid(this->path().size());
|
|
auto record = _journal.getFileRecord(relativePath);
|
|
if (record.isValid() && !FileSystem::fileChanged(path, record._fileSize,
|
|
Utility::qDateTimeToTime_t(record._modtime))) {
|
|
qDebug() << "Ignoring spurious notification for file" << relativePath;
|
|
return; // probably a spurious notification
|
|
}
|
|
}
|
|
|
|
emit watchedFileChangedExternally(path);
|
|
emit scheduleToSync(this);
|
|
}
|
|
|
|
void Folder::slotThreadTreeWalkResult(const SyncFileItemVector& items)
|
|
{
|
|
_syncResult.setSyncFileItemVector(items);
|
|
}
|
|
|
|
|
|
void Folder::saveToSettings() const
|
|
{
|
|
auto settings = _accountState->settings();
|
|
settings->beginGroup(QLatin1String("Folders"));
|
|
FolderDefinition::save(*settings, _definition);
|
|
|
|
settings->sync();
|
|
qDebug() << "Saved folder" << _definition.alias << "to settings, status" << settings->status();
|
|
}
|
|
|
|
void Folder::removeFromSettings() const
|
|
{
|
|
auto settings = _accountState->settings();
|
|
settings->beginGroup(QLatin1String("Folders"));
|
|
settings->remove(FolderMan::escapeAlias(_definition.alias));
|
|
}
|
|
|
|
bool Folder::isFileExcludedAbsolute(const QString& fullPath) const
|
|
{
|
|
return _engine->excludedFiles().isExcluded(fullPath, path(), _definition.ignoreHiddenFiles);
|
|
}
|
|
|
|
bool Folder::isFileExcludedRelative(const QString& relativePath) const
|
|
{
|
|
return _engine->excludedFiles().isExcluded(path() + relativePath, path(), _definition.ignoreHiddenFiles);
|
|
}
|
|
|
|
void Folder::slotTerminateSync()
|
|
{
|
|
qDebug() << "folder " << alias() << " Terminating!";
|
|
|
|
if( _engine->isSyncRunning() ) {
|
|
_engine->abort();
|
|
|
|
// Do not display an error message, user knows his own actions.
|
|
// _errors.append( tr("The CSync thread terminated.") );
|
|
// _csyncError = true;
|
|
setSyncState(SyncResult::SyncAbortRequested);
|
|
}
|
|
}
|
|
|
|
// This removes the csync File database
|
|
// This is needed to provide a clean startup again in case another
|
|
// local folder is synced to the same ownCloud.
|
|
void Folder::wipe()
|
|
{
|
|
QString stateDbFile = path()+QLatin1String(".csync_journal.db");
|
|
|
|
// Delete files that have been partially downloaded.
|
|
slotDiscardDownloadProgress();
|
|
|
|
//Unregister the socket API so it does not keep the .sync_journal file open
|
|
FolderMan::instance()->socketApi()->slotUnregisterPath(alias());
|
|
_journal.close(); // close the sync journal
|
|
|
|
QFile file(stateDbFile);
|
|
if( file.exists() ) {
|
|
if( !file.remove()) {
|
|
qDebug() << "WRN: Failed to remove existing csync StateDB " << stateDbFile;
|
|
} else {
|
|
qDebug() << "wipe: Removed csync StateDB " << stateDbFile;
|
|
}
|
|
} else {
|
|
qDebug() << "WRN: statedb is empty, can not remove.";
|
|
}
|
|
|
|
// Also remove other db related files
|
|
QFile::remove( stateDbFile + ".ctmp" );
|
|
QFile::remove( stateDbFile + "-shm" );
|
|
QFile::remove( stateDbFile + "-wal" );
|
|
QFile::remove( stateDbFile + "-journal" );
|
|
|
|
if (canSync())
|
|
FolderMan::instance()->socketApi()->slotRegisterPath(alias());
|
|
}
|
|
|
|
bool Folder::setIgnoredFiles()
|
|
{
|
|
ConfigFile cfg;
|
|
QString systemList = cfg.excludeFile(ConfigFile::SystemScope);
|
|
if( QFile::exists(systemList) ) {
|
|
qDebug() << "==== adding system ignore list to csync:" << systemList;
|
|
_engine->excludedFiles().addExcludeFilePath(systemList);
|
|
}
|
|
QString userList = cfg.excludeFile(ConfigFile::UserScope);
|
|
if( QFile::exists(userList) ) {
|
|
qDebug() << "==== adding user defined ignore list to csync:" << userList;
|
|
_engine->excludedFiles().addExcludeFilePath(userList);
|
|
}
|
|
|
|
return _engine->excludedFiles().reloadExcludes();
|
|
}
|
|
|
|
void Folder::setProxyDirty(bool value)
|
|
{
|
|
_proxyDirty = value;
|
|
}
|
|
|
|
bool Folder::proxyDirty()
|
|
{
|
|
return _proxyDirty;
|
|
}
|
|
|
|
void Folder::startSync(const QStringList &pathList)
|
|
{
|
|
Q_UNUSED(pathList)
|
|
if (proxyDirty()) {
|
|
setProxyDirty(false);
|
|
}
|
|
csync_set_log_callback( csyncLogCatcher );
|
|
csync_set_log_level( Logger::instance()->isNoop() ? 0 : 11 );
|
|
|
|
if (isBusy()) {
|
|
qCritical() << "* ERROR csync is still running and new sync requested.";
|
|
return;
|
|
}
|
|
_errors.clear();
|
|
_csyncError = false;
|
|
_csyncUnavail = false;
|
|
|
|
_timeSinceLastSyncStart.restart();
|
|
_syncResult.clearErrors();
|
|
_syncResult.setStatus( SyncResult::SyncPrepare );
|
|
_syncResult.setSyncFileItemVector(SyncFileItemVector());
|
|
emit syncStateChange();
|
|
|
|
qDebug() << "*** Start syncing " << remoteUrl().toString() << " - client version"
|
|
<< qPrintable(Theme::instance()->version());
|
|
|
|
if (!setIgnoredFiles())
|
|
{
|
|
slotSyncError(tr("Could not read system exclude file"));
|
|
QMetaObject::invokeMethod(this, "slotSyncFinished", Qt::QueuedConnection, Q_ARG(bool, false));
|
|
return;
|
|
}
|
|
|
|
setDirtyNetworkLimits();
|
|
|
|
ConfigFile cfgFile;
|
|
auto newFolderLimit = cfgFile.newBigFolderSizeLimit();
|
|
quint64 limit = newFolderLimit.first ? newFolderLimit.second * 1000 * 1000 : -1; // convert from MB to B
|
|
_engine->setNewBigFolderSizeLimit(limit);
|
|
|
|
_engine->setIgnoreHiddenFiles(_definition.ignoreHiddenFiles);
|
|
|
|
QMetaObject::invokeMethod(_engine.data(), "startSync", Qt::QueuedConnection);
|
|
|
|
// disable events until syncing is done
|
|
// _watcher->setEventsEnabled(false);
|
|
emit syncStarted();
|
|
}
|
|
|
|
void Folder::setDirtyNetworkLimits()
|
|
{
|
|
ConfigFile cfg;
|
|
int downloadLimit = -75; // 75%
|
|
int useDownLimit = cfg.useDownloadLimit();
|
|
if (useDownLimit >= 1) {
|
|
downloadLimit = cfg.downloadLimit() * 1000;
|
|
} else if (useDownLimit == 0) {
|
|
downloadLimit = 0;
|
|
}
|
|
|
|
int uploadLimit = -75; // 75%
|
|
int useUpLimit = cfg.useUploadLimit();
|
|
if ( useUpLimit >= 1) {
|
|
uploadLimit = cfg.uploadLimit() * 1000;
|
|
} else if (useUpLimit == 0) {
|
|
uploadLimit = 0;
|
|
}
|
|
|
|
_engine->setNetworkLimits(uploadLimit, downloadLimit);
|
|
}
|
|
|
|
|
|
void Folder::slotSyncError(const QString& err)
|
|
{
|
|
_errors.append( err );
|
|
_csyncError = true;
|
|
}
|
|
|
|
void Folder::slotSyncStarted()
|
|
{
|
|
qDebug() << "#### Propagation start #################################################### >>";
|
|
_syncResult.setStatus(SyncResult::SyncRunning);
|
|
emit syncStateChange();
|
|
}
|
|
|
|
void Folder::slotCsyncUnavailable()
|
|
{
|
|
_csyncUnavail = true;
|
|
}
|
|
|
|
void Folder::slotSyncFinished(bool success)
|
|
{
|
|
qDebug() << " - client version" << qPrintable(Theme::instance()->version())
|
|
<< " Qt" << qVersion()
|
|
#if QT_VERSION >= QT_VERSION_CHECK(5,0,0)
|
|
<< " SSL " << QSslSocket::sslLibraryVersionString().toUtf8().data()
|
|
#endif
|
|
;
|
|
|
|
|
|
if( _csyncError ) {
|
|
qDebug() << "-> SyncEngine finished with ERROR, warn count is" << _syncResult.warnCount();
|
|
} else {
|
|
qDebug() << "-> SyncEngine finished without problem.";
|
|
}
|
|
bubbleUpSyncResult();
|
|
|
|
bool anotherSyncNeeded = _engine->isAnotherSyncNeeded();
|
|
// _watcher->setEventsEnabledDelayed(2000);
|
|
|
|
|
|
|
|
if (_csyncError) {
|
|
_syncResult.setStatus(SyncResult::Error);
|
|
qDebug() << " ** error Strings: " << _errors;
|
|
_syncResult.setErrorStrings( _errors );
|
|
qDebug() << " * owncloud csync thread finished with error";
|
|
} else if (_csyncUnavail) {
|
|
_syncResult.setStatus(SyncResult::Error);
|
|
qDebug() << " ** csync not available.";
|
|
} else if( _syncResult.warnCount() > 0 ) {
|
|
// there have been warnings on the way.
|
|
_syncResult.setStatus(SyncResult::Problem);
|
|
} else {
|
|
_syncResult.setStatus(SyncResult::Success);
|
|
}
|
|
|
|
// Count the number of syncs that have failed in a row.
|
|
if (_syncResult.status() == SyncResult::Success
|
|
|| _syncResult.status() == SyncResult::Problem)
|
|
{
|
|
_consecutiveFailingSyncs = 0;
|
|
}
|
|
else
|
|
{
|
|
_consecutiveFailingSyncs++;
|
|
qDebug() << "the last" << _consecutiveFailingSyncs << "syncs failed";
|
|
}
|
|
|
|
if (_syncResult.status() == SyncResult::Success && success) {
|
|
// Clear the white list as all the folders that should be on that list are sync-ed
|
|
journalDb()->setSelectiveSyncList(SyncJournalDb::SelectiveSyncWhiteList, QStringList());
|
|
}
|
|
|
|
emit syncStateChange();
|
|
|
|
// The syncFinished result that is to be triggered here makes the folderman
|
|
// clear the current running sync folder marker.
|
|
// Lets wait a bit to do that because, as long as this marker is not cleared,
|
|
// file system change notifications are ignored for that folder. And it takes
|
|
// some time under certain conditions to make the file system notifications
|
|
// all come in.
|
|
QTimer::singleShot(200, this, SLOT(slotEmitFinishedDelayed() ));
|
|
|
|
_lastSyncDuration = _timeSinceLastSyncStart.elapsed();
|
|
_timeSinceLastSyncDone.restart();
|
|
|
|
// Increment the follow-up sync counter if necessary.
|
|
if (anotherSyncNeeded) {
|
|
_consecutiveFollowUpSyncs++;
|
|
qDebug() << "another sync was requested by the finished sync, this has"
|
|
<< "happened" << _consecutiveFollowUpSyncs << "times";
|
|
} else {
|
|
_consecutiveFollowUpSyncs = 0;
|
|
}
|
|
|
|
// Maybe force a follow-up sync to take place, but only a couple of times.
|
|
if (anotherSyncNeeded && _consecutiveFollowUpSyncs <= 3)
|
|
{
|
|
_forceSyncOnPollTimeout = true;
|
|
// We will make sure that the poll timer occurs soon enough.
|
|
// delay 1s, 4s, 9s
|
|
int c = _consecutiveFollowUpSyncs;
|
|
QTimer::singleShot(c*c * 1000, this, SLOT(slotRunEtagJob() ));
|
|
}
|
|
}
|
|
|
|
void Folder::slotEmitFinishedDelayed()
|
|
{
|
|
emit syncFinished( _syncResult );
|
|
}
|
|
|
|
|
|
void Folder::slotFolderDiscovered(bool, QString folderName)
|
|
{
|
|
ProgressInfo pi;
|
|
pi._currentDiscoveredFolder = folderName;
|
|
emit progressInfo(pi);
|
|
ProgressDispatcher::instance()->setProgressInfo(alias(), pi);
|
|
}
|
|
|
|
|
|
// the progress comes without a folder and the valid path set. Add that here
|
|
// and hand the result over to the progress dispatcher.
|
|
void Folder::slotTransmissionProgress(const ProgressInfo &pi)
|
|
{
|
|
if( !pi.isUpdatingEstimates() ) {
|
|
// this is the beginning of a sync, set the warning level to 0
|
|
_syncResult.setWarnCount(0);
|
|
}
|
|
emit progressInfo(pi);
|
|
ProgressDispatcher::instance()->setProgressInfo(alias(), pi);
|
|
}
|
|
|
|
// a item is completed: count the errors and forward to the ProgressDispatcher
|
|
void Folder::slotItemCompleted(const SyncFileItem &item, const PropagatorJob& job)
|
|
{
|
|
if (Progress::isWarningKind(item._status)) {
|
|
// Count all error conditions.
|
|
_syncResult.setWarnCount(_syncResult.warnCount()+1);
|
|
}
|
|
emit ProgressDispatcher::instance()->itemCompleted(alias(), item, job);
|
|
}
|
|
|
|
void Folder::slotNewBigFolderDiscovered(const QString &newF)
|
|
{
|
|
auto newFolder = newF;
|
|
if (!newFolder.endsWith(QLatin1Char('/'))) {
|
|
newFolder += QLatin1Char('/');
|
|
}
|
|
auto journal = journalDb();
|
|
|
|
// Add the entry to the blacklist if it is neither in the blacklist or whitelist already
|
|
bool ok1, ok2;
|
|
auto blacklist = journal->getSelectiveSyncList(SyncJournalDb::SelectiveSyncBlackList, &ok1);
|
|
auto whitelist = journal->getSelectiveSyncList(SyncJournalDb::SelectiveSyncWhiteList, &ok2);
|
|
if (ok1 && ok2 && !blacklist.contains(newFolder) && !whitelist.contains(newFolder)) {
|
|
blacklist.append(newFolder);
|
|
journal->setSelectiveSyncList(SyncJournalDb::SelectiveSyncBlackList, blacklist);
|
|
}
|
|
|
|
// And add the entry to the undecided list and signal the UI
|
|
auto undecidedList = journal->getSelectiveSyncList(SyncJournalDb::SelectiveSyncUndecidedList, &ok1);
|
|
if( ok1 ) {
|
|
if (!undecidedList.contains(newFolder)) {
|
|
undecidedList.append(newFolder);
|
|
journal->setSelectiveSyncList(SyncJournalDb::SelectiveSyncUndecidedList, undecidedList);
|
|
emit newBigFolderDiscovered(newFolder);
|
|
}
|
|
QString message = tr("A new folder larger than %1 MB has been added: %2.\n"
|
|
"Please go in the settings to select it if you wish to download it.")
|
|
.arg(ConfigFile().newBigFolderSizeLimit().second).arg(newF);
|
|
|
|
auto logger = Logger::instance();
|
|
logger->postOptionalGuiLog(Theme::instance()->appNameGUI(), message);
|
|
}
|
|
}
|
|
|
|
|
|
|
|
void Folder::slotAboutToRemoveAllFiles(SyncFileItem::Direction, bool *cancel)
|
|
{
|
|
ConfigFile cfgFile;
|
|
if (!cfgFile.promptDeleteFiles())
|
|
return;
|
|
|
|
QString msg =
|
|
tr("This sync would remove all the files in the sync folder '%1'.\n"
|
|
"This might be because the folder was silently reconfigured, or that all "
|
|
"the files were manually removed.\n"
|
|
"Are you sure you want to perform this operation?");
|
|
QMessageBox msgBox(QMessageBox::Warning, tr("Remove All Files?"),
|
|
msg.arg(shortGuiLocalPath()));
|
|
msgBox.addButton(tr("Remove all files"), QMessageBox::DestructiveRole);
|
|
QPushButton* keepBtn = msgBox.addButton(tr("Keep files"), QMessageBox::AcceptRole);
|
|
if (msgBox.exec() == -1) {
|
|
*cancel = true;
|
|
return;
|
|
}
|
|
*cancel = msgBox.clickedButton() == keepBtn;
|
|
if (*cancel) {
|
|
wipe();
|
|
// speed up next sync
|
|
_lastEtag.clear();
|
|
_forceSyncOnPollTimeout = true;
|
|
QTimer::singleShot(50, this, SLOT(slotRunEtagJob()));
|
|
}
|
|
}
|
|
|
|
void Folder::slotAboutToRestoreBackup(bool *restore)
|
|
{
|
|
QString msg =
|
|
tr("This sync would reset the files to an erlier time in the sync folder '%1'.\n"
|
|
"This might be because a backup was restored on the server.\n"
|
|
"Continuing the sync as normal will cause all your files to be overwritten by an older "
|
|
"file in an earlier state. "
|
|
"Do you want to keep your local most recent files as conflict files?");
|
|
QMessageBox msgBox(QMessageBox::Warning, tr("Backup detected"),
|
|
msg.arg(shortGuiLocalPath()));
|
|
msgBox.addButton(tr("Normal Synchronisation"), QMessageBox::DestructiveRole);
|
|
QPushButton* keepBtn = msgBox.addButton(tr("Keep Local Files as Conflict"), QMessageBox::AcceptRole);
|
|
|
|
if (msgBox.exec() == -1) {
|
|
*restore = true;
|
|
return;
|
|
}
|
|
*restore = msgBox.clickedButton() == keepBtn;
|
|
}
|
|
|
|
|
|
void FolderDefinition::save(QSettings& settings, const FolderDefinition& folder)
|
|
{
|
|
settings.beginGroup(FolderMan::escapeAlias(folder.alias));
|
|
settings.setValue(QLatin1String("localPath"), folder.localPath);
|
|
settings.setValue(QLatin1String("targetPath"), folder.targetPath);
|
|
settings.setValue(QLatin1String("paused"), folder.paused);
|
|
settings.setValue(QLatin1String("ignoreHiddenFiles"), folder.ignoreHiddenFiles);
|
|
settings.endGroup();
|
|
}
|
|
|
|
bool FolderDefinition::load(QSettings& settings, const QString& alias,
|
|
FolderDefinition* folder)
|
|
{
|
|
settings.beginGroup(alias);
|
|
folder->alias = FolderMan::unescapeAlias(alias);
|
|
folder->localPath = settings.value(QLatin1String("localPath")).toString();
|
|
folder->targetPath = settings.value(QLatin1String("targetPath")).toString();
|
|
folder->paused = settings.value(QLatin1String("paused")).toBool();
|
|
folder->ignoreHiddenFiles = settings.value(QLatin1String("ignoreHiddenFiles"), QVariant(true)).toBool();
|
|
settings.endGroup();
|
|
|
|
// Old settings can contain paths with native separators. In the rest of the
|
|
// code we assum /, so clean it up now.
|
|
folder->localPath = prepareLocalPath(folder->localPath);
|
|
|
|
return true;
|
|
}
|
|
|
|
QString FolderDefinition::prepareLocalPath(const QString& path)
|
|
{
|
|
QString p = QDir::fromNativeSeparators(path);
|
|
if (!p.endsWith(QLatin1Char('/'))) {
|
|
p.append(QLatin1Char('/'));
|
|
}
|
|
return p;
|
|
}
|
|
|
|
} // namespace OCC
|
|
|