1 files changed, 101 insertions, 0 deletions
diff --git a/module-volume-change-notify.c b/module-volume-change-notify.c
new file mode 100644
index 0000000..f204909
--- /dev/null
+++ b/module-volume-change-notify.c
@@ -0,0 +1,101 @@
+#include <config.h>
+
+#include <pulsecore/module.h>
+#include <pulsecore/core-subscribe.h>
+#include <pulse/introspect.h>
+
+#include <dbus/dbus.h>
+
+PA_MODULE_AUTHOR("Alexander Sulfrian");
+PA_MODULE_DESCRIPTION("Module that notify you on volume changes of sinks.");
+PA_MODULE_VERSION(PACKAGE_VERSION);
+PA_MODULE_USAGE("");
+
+struct userdata {
+    pa_core *core;
+    pa_module *module;
+    pa_subscription *subscription;
+
+    /* dbus stuff */
+    DBusError dbus_error;
+    DBusConnection *dbus_connection;
+};
+
+void sink_change_event_cb(pa_core *c, pa_subscription_event_type_t t,
+                          uint32_t idx, void *userdata)
+{
+    pa_sink *s;
+    char vol[PA_CVOLUME_SNPRINT_MAX];
+
+    if (PA_SUBSCRIPTION_EVENT_CHANGE & t == 0)
+        return;
+
+    s = pa_idxset_get_by_index(c->sinks, idx);
+    if (!s)
+        return;
+
+    pa_cvolume_snprint(vol, PA_CVOLUME_SNPRINT_MAX, &s->reference_volume);
+    pa_log("Volume: %s %s", s->name, vol);
+}
+
+void pa__done(pa_module *m)
+{
+    struct userdata *u;
+
+    if (!(u = m->userdata))
+        return;
+
+    pa_subscription_free(u->subscription);
+
+    if (u->dbus_connection)
+        dbus_connection_close(u->dbus_connection);
+
+    pa_xfree(u);
+}
+
+int pa__init(pa_module* m)
+{
+    struct userdata *u;
+    pa_subscription_mask_t mask;
+    int ret;
+
+    m->userdata = u = pa_xnew0(struct userdata, 1);
+    u->core = m->core;
+    u->module = m;
+
+    mask = PA_SUBSCRIPTION_EVENT_SOURCE_OUTPUT | PA_SUBSCRIPTION_EVENT_CHANGE;
+    u->subscription = pa_subscription_new(m->core, mask,
+                                          sink_change_event_cb, u);
+
+    /* initialize dbus */
+    dbus_error_init(&u->dbus_error);
+    u->dbus_connection = dbus_bus_get(DBUS_BUS_SESSION, &u->dbus_error);
+    if (dbus_error_is_set(&u->dbus_error)) {
+        pa_log("DBus Connection Error (%s)\n", u->dbus_error.message);
+        dbus_error_free(&u->dbus_error);
+    }
+
+    if (!u->dbus_connection)
+        goto fail;
+
+    /* request a name on the bus */
+    ret = dbus_bus_request_name(u->dbus_connection,
+                                "org.PulseAudio.VolumeNotification",
+                                DBUS_NAME_FLAG_REPLACE_EXISTING,
+                                &u->dbus_error);
+
+    if (dbus_error_is_set(&u->dbus_error)) {
+        pa_log("DBus Name Error (%s)\n", u->dbus_error.message);
+        dbus_error_free(&u->dbus_error);
+    }
+
+    if (DBUS_REQUEST_NAME_REPLY_PRIMARY_OWNER != ret) {
+        goto fail;
+    }
+
+    return 0;
+
+fail:
+    pa__done(m);
+    return -1;
+}