增加dirWatcher中部分兼容老版本的逻辑

This commit is contained in:
iaom 2023-04-08 11:45:59 +08:00
parent a526b7d2ab
commit 734ecf2189
6 changed files with 114 additions and 29 deletions

View File

@ -2,6 +2,7 @@
#include <QDir> #include <QDir>
#include <QUrl> #include <QUrl>
#include <mutex> #include <mutex>
#include <QFile>
static const QString HOME_PATH = QDir::homePath(); static const QString HOME_PATH = QDir::homePath();
static const QString CURRENT_INDEXABLE_DIR_SETTINGS = HOME_PATH + "/.config/org.ukui/ukui-search/ukui-search-current-indexable-dir.conf"; static const QString CURRENT_INDEXABLE_DIR_SETTINGS = HOME_PATH + "/.config/org.ukui/ukui-search/ukui-search-current-indexable-dir.conf";
@ -10,29 +11,35 @@ static const QString CONFIG_VERSION_KEY = "ConfigVersion";
static const QString CONFIG_VERSION = "1.0"; static const QString CONFIG_VERSION = "1.0";
static const QString GLOBAL_BLACK_LIST_KEY = "GlobalBlackList"; static const QString GLOBAL_BLACK_LIST_KEY = "GlobalBlackList";
static const QStringList GLOBAL_BLACK_LIST{"/proc", "/sys", "/dev", "/tmp", "/run"}; static const QStringList GLOBAL_BLACK_LIST{"/proc", "/sys", "/dev", "/tmp", "/run"};
static const QString GLOBAL_SETTINGS_GROUP = "GlobalSettings";
static const QString SEARCH_DIRS_GROUP = "SearchDirs";
static std::once_flag flag; static std::once_flag flag;
static Config *global_intance = nullptr; static Config *global_instance = nullptr;
Config *Config::self() Config *Config::self()
{ {
std::call_once(flag, [ & ] { std::call_once(flag, [ & ] {
global_intance = new Config(); global_instance = new Config();
}); });
return global_intance; return global_instance;
} }
void Config::addDir(const SearchDir &dir) void Config::addDir(const SearchDir &dir)
{ {
m_settings->setValue(dir.getPath(), dir.getBlackList()); m_searchDirs.append(dir);
m_settings->beginGroup(SEARCH_DIRS_GROUP);
m_settings->setValue(QUrl::fromLocalFile(dir.getPath()).toString(), dir.getBlackList());
m_settings->endGroup();
m_settings->sync(); m_settings->sync();
} }
QStringList Config::removeDir(const SearchDir &dir) QStringList Config::removeDir(const SearchDir &dir)
{ {
QString url = QUrl::fromLocalFile(dir.getPath()).toString(); QString url = QUrl::fromLocalFile(dir.getPath()).toString();
QStringList blackDirs = m_settings->value(url).toStringList(); QStringList blackDirs = m_settings->value(SEARCH_DIRS_GROUP + "/" + url).toStringList();
m_settings->remove(url); removeDir(url);
m_settings->sync(); m_searchDirs.removeOne(dir);
return blackDirs; return blackDirs;
} }
@ -41,31 +48,47 @@ bool Config::isCompatibilityMode()
return m_compatibilityMode; return m_compatibilityMode;
} }
QStringList Config::searchDirs() const QStringList Config::searchDirs()
{ {
QStringList tmp; QStringList tmp;
for(const SearchDir& dir : m_searchDirs) { for(const SearchDir& dir : m_searchDirs) {
tmp.append(dir.getPath()); if(QFile::exists(dir.getPath())) {
tmp.append(dir.getPath());
} else {
m_searchDirs.removeOne(dir);
removeDir(QUrl::fromLocalFile(dir.getPath()).toString());
}
} }
return tmp; return tmp;
} }
QStringList Config::blackDirs() const QStringList Config::blackDirs()
{ {
QStringList tmp; QStringList tmp;
for(const SearchDir& dir : m_searchDirs) { for(const SearchDir& dir : m_searchDirs) {
tmp.append(dir.getBlackList()); if(QFile::exists(dir.getPath())) {
tmp.append(dir.getBlackList());
} else {
m_searchDirs.removeOne(dir);
removeDir(QUrl::fromLocalFile(dir.getPath()).toString());
}
} }
return tmp; return tmp;
} }
QStringList Config::globalBlackList() const QStringList Config::globalBlackList() const
{ {
return m_settings->value(GLOBAL_BLACK_LIST_KEY).toStringList(); return m_settings->value(GLOBAL_SETTINGS_GROUP + "/" + GLOBAL_BLACK_LIST_KEY).toStringList();
} }
QVector<SearchDir> Config::searchDirObjects() const QVector<SearchDir> Config::searchDirObjects()
{ {
for(const SearchDir& dir : m_searchDirs) {
if(!QFile::exists(dir.getPath())) {
m_searchDirs.removeOne(dir);
removeDir(QUrl::fromLocalFile(dir.getPath()).toString());
}
}
return m_searchDirs; return m_searchDirs;
} }
@ -74,22 +97,62 @@ Config::Config()
m_settings = new QSettings(CURRENT_INDEXABLE_DIR_SETTINGS, QSettings::IniFormat); m_settings = new QSettings(CURRENT_INDEXABLE_DIR_SETTINGS, QSettings::IniFormat);
if(!(m_settings->value(CONFIG_VERSION_KEY).toString() == CONFIG_VERSION)) { if(!(m_settings->value(CONFIG_VERSION_KEY).toString() == CONFIG_VERSION)) {
m_compatibilityMode = true; m_compatibilityMode = true;
for(const QString& path : m_settings->value(INDEXABLE_DIR_KEY).toStringList()) { for(const QString& path : m_settings->value(INDEXABLE_DIR_KEY + "/" + INDEXABLE_DIR_KEY).toStringList()) {
SearchDir dir(QUrl::fromLocalFile(path).toString()); if(QFile::exists(path)) {
m_searchDirs.append(dir); SearchDir dir(path, false);
m_settings->setValue(QUrl::fromLocalFile(path).toString(), dir.getBlackList()); m_compatibleCache.append(dir);
}
} }
m_settings->remove(INDEXABLE_DIR_KEY); m_settings->remove(INDEXABLE_DIR_KEY);
m_settings->beginGroup(GLOBAL_SETTINGS_GROUP);
m_settings->setValue(CONFIG_VERSION_KEY, CONFIG_VERSION); m_settings->setValue(CONFIG_VERSION_KEY, CONFIG_VERSION);
m_settings->endGroup();
} else { } else {
m_settings->beginGroup(SEARCH_DIRS_GROUP);
for(const QString& urlStr : m_settings->allKeys()) { for(const QString& urlStr : m_settings->allKeys()) {
SearchDir dir(QUrl(urlStr).toString(), false); QString path = QUrl(urlStr).toLocalFile();
dir.setBlackList(m_settings->value(urlStr).toStringList()); if(QFile::exists(path)) {
m_searchDirs.append(dir); SearchDir dir(path, false);
dir.setBlackList(m_settings->value(urlStr).toStringList());
m_searchDirs.append(dir);
} else {
removeDir(urlStr);
}
} }
m_settings->endGroup();
} }
m_settings->beginGroup(GLOBAL_SETTINGS_GROUP);
if(m_settings->value(GLOBAL_BLACK_LIST_KEY).isNull()) { if(m_settings->value(GLOBAL_BLACK_LIST_KEY).isNull()) {
m_settings->setValue(GLOBAL_BLACK_LIST_KEY, GLOBAL_BLACK_LIST); m_settings->setValue(GLOBAL_BLACK_LIST_KEY, GLOBAL_BLACK_LIST);
} }
m_settings->endGroup();
m_settings->sync(); m_settings->sync();
} }
void Config::removeDir(const QString &url)
{
m_settings->beginGroup(SEARCH_DIRS_GROUP);
m_settings->remove(url);
m_settings->endGroup();
m_settings->sync();
}
void Config::processCompatibleCache()
{
if(this->isCompatibilityMode()) {
m_settings->beginGroup(SEARCH_DIRS_GROUP);
for(SearchDir dir : m_compatibleCache) {
dir.generateBlackList();
if(dir.error() == SearchDir::ErrorInfo::Successful) {
m_searchDirs.append(dir);
m_settings->setValue(QUrl::fromLocalFile(dir.getPath()).toString(), dir.getBlackList());
}
}
m_settings->endGroup();
m_settings->sync();
m_compatibleCache.clear();
m_compatibilityMode = false;
}
}

View File

@ -11,21 +11,25 @@ public:
static Config *self(); static Config *self();
void addDir(const SearchDir& dir); void addDir(const SearchDir& dir);
QStringList removeDir(const SearchDir& dir); QStringList removeDir(const SearchDir& dir);
/** /**
* @brief * @brief
* @return
*/ */
bool isCompatibilityMode(); void processCompatibleCache();
QVector<SearchDir> searchDirObjects() const; QVector<SearchDir> searchDirObjects();
QStringList searchDirs() const; QStringList searchDirs();
QStringList blackDirs() const; QStringList blackDirs();
QStringList globalBlackList() const; QStringList globalBlackList() const;
private: private:
Config(); Config();
void removeDir(const QString& url);
bool isCompatibilityMode();
QSettings *m_settings = nullptr; QSettings *m_settings = nullptr;
bool m_compatibilityMode = false; bool m_compatibilityMode = false;
QVector<SearchDir> m_searchDirs; QVector<SearchDir> m_searchDirs;
QVector<SearchDir> m_compatibleCache;
}; };
#endif // CONFIG_H #endif // CONFIG_H

View File

@ -19,6 +19,9 @@ QMutex DirWatcher::s_mutex;
DirWatcher::DirWatcher(QObject *parent) : QObject(parent) DirWatcher::DirWatcher(QObject *parent) : QObject(parent)
{ {
//兼容旧版配置
// Config::self()->processCompatibleCache();
m_qSettings = new QSettings(CURRENT_INDEXABLE_DIR_SETTINGS, QSettings::IniFormat); m_qSettings = new QSettings(CURRENT_INDEXABLE_DIR_SETTINGS, QSettings::IniFormat);
this->currentIndexableDir(); this->currentIndexableDir();
if (m_indexableDirList.isEmpty()) { if (m_indexableDirList.isEmpty()) {

View File

@ -8,6 +8,11 @@ SearchDir::SearchDir(const QString &path, bool generateBlackList)
} }
} }
bool SearchDir::operator ==(const SearchDir &rhs) const
{
return (m_path == rhs.m_path);
}
SearchDir::ErrorInfo SearchDir::error() SearchDir::ErrorInfo SearchDir::error()
{ {
return m_error; return m_error;
@ -45,3 +50,8 @@ QStringList SearchDir::getBlackList() const
{ {
return m_blackList; return m_blackList;
} }
void SearchDir::generateBlackList()
{
//生成黑名单
}

View File

@ -13,11 +13,16 @@ public:
NotExists NotExists
}; };
SearchDir(const QString& path, bool generateBlackList = true); SearchDir(const QString& path, bool generateBlackList = true);
bool operator == (const SearchDir& rhs) const;
ErrorInfo error(); ErrorInfo error();
QString errorString(); QString errorString();
QString getPath() const; QString getPath() const;
void setBlackList(const QStringList& blackList); void setBlackList(const QStringList& blackList);
QStringList getBlackList() const; QStringList getBlackList() const;
/**
* @brief
*/
void generateBlackList();
private: private:
QString m_path; QString m_path;
QStringList m_blackList; QStringList m_blackList;

View File

@ -3,7 +3,7 @@
#include <QMutexLocker> #include <QMutexLocker>
#include <QDebug> #include <QDebug>
static std::once_flag flag; static std::once_flag flag;
static VolumeManager *global_intance = nullptr; static VolumeManager *global_instance = nullptr;
Volume::Volume() Volume::Volume()
{ {
@ -62,9 +62,9 @@ void Volume::addMountPoint(const QString &mountPoint, const QString &subVolume)
VolumeManager *VolumeManager::self() VolumeManager *VolumeManager::self()
{ {
std::call_once(flag, [ & ] { std::call_once(flag, [ & ] {
global_intance = new VolumeManager(); global_instance = new VolumeManager();
}); });
return global_intance; return global_instance;
} }
VolumeManager::VolumeManager(QObject *parent) VolumeManager::VolumeManager(QObject *parent)