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()