/* * Copyright (C) by Klaas Freitag * * 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. */ #ifndef FOLDERMAN_H #define FOLDERMAN_H #include #include #include #include "folder.h" #include "folderwatcher.h" #include "navigationpanehelper.h" #include "syncfileitem.h" class TestFolderMan; namespace OCC { class Application; class SyncResult; class SocketApi; class LockWatcher; /** * @brief The FolderMan class * @ingroup gui * * The FolderMan knows about all loaded folders and is responsible for * scheduling them when necessary. * * A folder is scheduled if: * - The configured force-sync-interval has expired * (_timeScheduler and slotScheduleFolderByTime()) * * - A folder watcher receives a notification about a file change * (_folderWatchers and Folder::slotWatchedPathChanged()) * * - The folder etag on the server has changed * (_etagPollTimer) * * - The locks of a monitored file are released * (_lockWatcher and slotWatchedFileUnlocked()) * * - There was a sync error or a follow-up sync is requested * (_timeScheduler and slotScheduleFolderByTime() * and Folder::slotSyncFinished()) */ class FolderMan : public QObject { Q_OBJECT public: ~FolderMan(); static FolderMan *instance(); int setupFolders(); int setupFoldersMigration(); OCC::Folder::Map map(); /** Adds a folder for an account, ensures the journal is gone and saves it in the settings. */ Folder *addFolder(AccountState *accountState, const FolderDefinition &folderDefinition); /** Removes a folder */ void removeFolder(Folder *); /** Returns the folder which the file or directory stored in path is in */ Folder *folderForPath(const QString &path); /** * returns a list of local files that exist on the local harddisk for an * incoming relative server path. The method checks with all existing sync * folders. */ QStringList findFileInLocalFolders(const QString &relPath, const AccountPtr acc); /** Returns the folder by alias or NULL if no folder with the alias exists. */ Folder *folder(const QString &); /** * Migrate accounts from owncloud < 2.0 * Creates a folder for a specific configuration, identified by alias. */ Folder *setupFolderFromOldConfigFile(const QString &, AccountState *account); /** * Ensures that a given directory does not contain a sync journal file. * * @returns false if the journal could not be removed, true otherwise. */ static bool ensureJournalGone(const QString &journalDbFile); /** Creates a new and empty local directory. */ bool startFromScratch(const QString &); /// Produce text for use in the tray tooltip static QString trayTooltipStatusString(SyncResult::Status syncStatus, bool hasUnresolvedConflicts, bool paused); /// Compute status summarizing multiple folders static void trayOverallStatus(const QList &folders, SyncResult::Status *status, bool *unresolvedConflicts); // Escaping of the alias which is used in QSettings AND the file // system, thus need to be escaped. static QString escapeAlias(const QString &); static QString unescapeAlias(const QString &); SocketApi *socketApi(); NavigationPaneHelper &navigationPaneHelper() { return _navigationPaneHelper; } /** * Check if @a path is a valid path for a new folder considering the already sync'ed items. * Make sure that this folder, or any subfolder is not sync'ed already. * * Note that different accounts are allowed to sync to the same folder. * * @returns an empty string if it is allowed, or an error if it is not allowed */ QString checkPathValidityForNewFolder(const QString &path, const QUrl &serverUrl = QUrl()) const; /** * Attempts to find a non-existing, acceptable path for creating a new sync folder. * * Uses \a basePath as the baseline. It'll return this path if it's acceptable. * * Note that this can fail. If someone syncs ~ and \a basePath is ~/ownCloud, no * subfolder of ~ would be a good candidate. When that happens \a basePath * is returned. */ QString findGoodPathForNewSyncFolder(const QString &basePath, const QUrl &serverUrl) const; /** * While ignoring hidden files can theoretically be switched per folder, * it's currently a global setting that users can only change for all folders * at once. * These helper functions can be removed once it's properly per-folder. */ bool ignoreHiddenFiles() const; void setIgnoreHiddenFiles(bool ignore); /** * Access to the current queue of scheduled folders. */ QQueue scheduleQueue() const; /** * Access to the currently syncing folder. */ Folder *currentSyncFolder() const; /** Removes all folders */ int unloadAndDeleteAllFolders(); /** * If enabled is set to false, no new folders will start to sync. * The current one will finish. */ void setSyncEnabled(bool); /** Queues a folder for syncing. */ void scheduleFolder(Folder *); /** Puts a folder in the very front of the queue. */ void scheduleFolderNext(Folder *); /** Queues all folders for syncing. */ void scheduleAllFolders(); void setDirtyProxy(); void setDirtyNetworkLimits(); /** * Terminates the current folder sync. * * It does not switch the folder to paused state. */ void terminateSyncProcess(); signals: /** * signal to indicate a folder has changed its sync state. * * Attention: The folder may be zero. Do a general update of the state then. */ void folderSyncStateChange(Folder *); /** * Indicates when the schedule queue changes. */ void scheduleQueueChanged(); /** * Emitted whenever the list of configured folders changes. */ void folderListChanged(const Folder::Map &); public slots: /** * Schedules folders of newly connected accounts, terminates and * de-schedules folders of disconnected accounts. */ void slotAccountStateChanged(); /** * restart the client as soon as it is possible, ie. no folders syncing. */ void slotScheduleAppRestart(); /** * Triggers a sync run once the lock on the given file is removed. * * Automatically detemines the folder that's responsible for the file. * See slotWatchedFileUnlocked(). */ void slotSyncOnceFileUnlocks(const QString &path); // slot to schedule an ETag job (from Folder only) void slotScheduleETagJob(const QString &alias, RequestEtagJob *job); private slots: void slotFolderSyncPaused(Folder *, bool paused); void slotFolderCanSyncChanged(); void slotFolderSyncStarted(); void slotFolderSyncFinished(const SyncResult &); void slotRunOneEtagJob(); void slotEtagJobDestroyed(QObject *); // slot to take the next folder from queue and start syncing. void slotStartScheduledFolderSync(); void slotEtagPollTimerTimeout(); void slotRemoveFoldersForAccount(AccountState *accountState); // Wraps the Folder::syncStateChange() signal into the // FolderMan::folderSyncStateChange(Folder*) signal. void slotForwardFolderSyncStateChange(); void slotServerVersionChanged(Account *account); /** * A file whose locks were being monitored has become unlocked. * * This schedules the folder for synchronization that contains * the file with the given path. */ void slotWatchedFileUnlocked(const QString &path); /** * Schedules folders whose time to sync has come. * * Either because a long time has passed since the last sync or * because of previous failures. */ void slotScheduleFolderByTime(); private: /** Adds a new folder, does not add it to the account settings and * does not set an account on the new folder. */ Folder *addFolderInternal(FolderDefinition folderDefinition, AccountState *accountState); /* unloads a folder object, does not delete it */ void unloadFolder(Folder *); /** Will start a sync after a bit of delay. */ void startScheduledSyncSoon(); // finds all folder configuration files // and create the folders QString getBackupName(QString fullPathName) const; // makes the folder known to the socket api void registerFolderWithSocketApi(Folder *folder); // restarts the application (Linux only) void restartApplication(); void setupFoldersHelper(QSettings &settings, AccountStatePtr account, bool backwardsCompatible); QSet _disabledFolders; Folder::Map _folderMap; QString _folderConfigPath; Folder *_currentSyncFolder; QPointer _lastSyncFolder; bool _syncEnabled; /// Starts regular etag query jobs QTimer _etagPollTimer; /// The currently running etag query QPointer _currentEtagJob; /// Watches files that couldn't be synced due to locks QScopedPointer _lockWatcher; /// Occasionally schedules folders QTimer _timeScheduler; /// Scheduled folders that should be synced as soon as possible QQueue _scheduledFolders; /// Picks the next scheduled folder and starts the sync QTimer _startScheduledSyncTimer; QScopedPointer _socketApi; NavigationPaneHelper _navigationPaneHelper; bool _appRestartRequired; static FolderMan *_instance; explicit FolderMan(QObject *parent = nullptr); friend class OCC::Application; friend class ::TestFolderMan; }; } // namespace OCC #endif // FOLDERMAN_H