summaryrefslogtreecommitdiff
path: root/sowatchd/daemon.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'sowatchd/daemon.cpp')
-rw-r--r--sowatchd/daemon.cpp71
1 files changed, 66 insertions, 5 deletions
diff --git a/sowatchd/daemon.cpp b/sowatchd/daemon.cpp
index a2d7b5a..3d9c05c 100644
--- a/sowatchd/daemon.cpp
+++ b/sowatchd/daemon.cpp
@@ -11,14 +11,18 @@ Daemon::Daemon(QObject *parent) :
QObject(parent)
{
loadDrivers();
- loadWatches();
- loadWatchlets();
+ loadProviders();
+ initWatches();
}
void Daemon::loadDrivers()
{
QDir dir(SOWATCH_DRIVERS_DIR);
foreach (QString file, dir.entryList(QDir::Files)) {
+#if defined(Q_OS_UNIX)
+ // Temporary workaround for QtC deploy plugin issues
+ if (!file.endsWith(".so")) continue;
+#endif
QPluginLoader loader(dir.absoluteFilePath(file));
QObject *pluginObj = loader.instance();
if (pluginObj) {
@@ -28,16 +32,50 @@ void Daemon::loadDrivers()
foreach (const QString& driver, drivers) {
_drivers[driver] = plugin;
}
+ } else {
+ qWarning() << "Invalid plugin" << file;
+ loader.unload();
}
} else {
qWarning() << "Invalid plugin" << file;
+ loader.unload();
}
}
qDebug() << "loaded drivers" << _drivers.keys();
}
-void Daemon::loadWatches()
+void Daemon::loadProviders()
+{
+ QDir dir(SOWATCH_NOTIFICATIONS_DIR);
+ foreach (QString file, dir.entryList(QDir::Files)) {
+#if defined(Q_OS_UNIX)
+ // Temporary workaround for QtC deploy plugin issues
+ if (!file.endsWith(".so")) continue;
+#endif
+ QPluginLoader loader(dir.absoluteFilePath(file));
+ QObject *pluginObj = loader.instance();
+ if (pluginObj) {
+ NotificationPluginInterface *plugin = qobject_cast<NotificationPluginInterface*>(pluginObj);
+ if (plugin) {
+ QStringList providers = plugin->providers();
+ foreach (const QString& provider, providers) {
+ _providers[provider] = plugin;
+ }
+ } else {
+ qWarning() << "Invalid plugin" << file;
+ loader.unload();
+ }
+ } else {
+ qWarning() << "Invalid plugin" << file;
+ loader.unload();
+ }
+ }
+
+ qDebug() << "loaded providers" << _providers;
+}
+
+void Daemon::initWatches()
{
QSettings settings;
int size = settings.beginReadArray("watches");
@@ -49,7 +87,7 @@ void Daemon::loadWatches()
if (plugin) {
Watch *watch = plugin->getWatch(driver, settings, this);
if (watch) {
- _watches.append(watch);
+ initWatch(watch, settings);
} else {
qWarning() << "Driver" << driver << "refused to getWatch";
}
@@ -59,7 +97,30 @@ void Daemon::loadWatches()
}
settings.endArray();
- qDebug() << "handling" << _watches.size() << "watches";
+ qDebug() << "handling" << _servers.size() << "watches";
+}
+
+void Daemon::initWatch(Watch* watch, QSettings& settings)
+{
+ int size;
+
+ // Create the server
+ WatchServer* server = new WatchServer(watch, this);
+ _servers.append(server);
+
+ // Initialize providers
+ size = settings.beginReadArray("notifications");
+ for (int i = 0; i < size; i++) {
+ settings.setArrayIndex(i);
+ QString id = settings.value("provider").toString().toLower();
+ NotificationPluginInterface *plugin = _providers[id];
+ if (plugin) {
+ NotificationProvider *provider = plugin->getProvider(id, settings, server);
+ server->addProvider(provider);
+ }
+ }
+
+ settings.endArray();
}
void Daemon::loadWatchlets()