95 lines
2.1 KiB
C++
95 lines
2.1 KiB
C++
#include "tickingservice.hpp"
|
|
#include <QFile>
|
|
#include <QDir>
|
|
#include <QJsonDocument>
|
|
#include <QJsonObject>
|
|
#include <QJsonValue>
|
|
#include <QFileSystemWatcher>
|
|
#include <QTimer>
|
|
|
|
namespace ZShell::services {
|
|
|
|
TickingService::TickingService(QObject* parent)
|
|
: Service(parent), m_timer(new QTimer(this)) {
|
|
m_timer->setSingleShot(false);
|
|
QObject::connect(m_timer, &QTimer::timeout, this, [this] { tick(); });
|
|
|
|
QString configPath =
|
|
QDir::homePath() + QStringLiteral("/.config/zshell/config.json");
|
|
|
|
auto reloadConfig = [this, configPath]() {
|
|
QFile file(configPath);
|
|
if (!file.open(QIODevice::ReadOnly)) {
|
|
return;
|
|
}
|
|
QJsonDocument doc = QJsonDocument::fromJson(file.readAll());
|
|
if (doc.isNull()) {
|
|
return;
|
|
}
|
|
QJsonObject dashboard = doc.object().value("dashboard").toObject();
|
|
if (dashboard.contains("resourceUpdateInterval")) {
|
|
applyInterval(
|
|
dashboard.value("resourceUpdateInterval").toInt(1000));
|
|
}
|
|
};
|
|
|
|
reloadConfig();
|
|
|
|
static auto* watcher = new QFileSystemWatcher();
|
|
if (!watcher->files().contains(configPath)) {
|
|
QObject::connect(
|
|
watcher,
|
|
&QFileSystemWatcher::fileChanged,
|
|
this,
|
|
[this, configPath]() {
|
|
QTimer::singleShot(100, this, [this, configPath]() {
|
|
QFile file(configPath);
|
|
if (!file.exists()) {
|
|
return;
|
|
}
|
|
QJsonDocument doc = QJsonDocument::fromJson(file.readAll());
|
|
if (doc.isNull()) {
|
|
return;
|
|
}
|
|
QJsonObject dashboard =
|
|
doc.object().value("dashboard").toObject();
|
|
if (dashboard.contains("resourceUpdateInterval")) {
|
|
applyInterval(dashboard.value("resourceUpdateInterval")
|
|
.toInt(1000));
|
|
}
|
|
});
|
|
});
|
|
watcher->addPath(configPath);
|
|
}
|
|
}
|
|
|
|
int TickingService::updateInterval() const {
|
|
return m_interval;
|
|
}
|
|
|
|
void TickingService::start() {
|
|
m_running = true;
|
|
if (m_interval > 0) {
|
|
m_timer->start(m_interval);
|
|
}
|
|
tick();
|
|
}
|
|
|
|
void TickingService::stop() {
|
|
m_running = false;
|
|
m_timer->stop();
|
|
}
|
|
|
|
void TickingService::applyInterval(int ms) {
|
|
if (ms <= 0 || ms == m_interval) {
|
|
return;
|
|
}
|
|
m_interval = ms;
|
|
if (m_running) {
|
|
m_timer->start(m_interval);
|
|
}
|
|
Q_EMIT updateIntervalChanged();
|
|
}
|
|
|
|
} // namespace ZShell::services
|