#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