1 files changed, 72 insertions, 1 deletions

diff --git a/src/indicator-printers-service.c b/src/indicator-printers-service.c
index 58644ab..5daf697 100644
--- a/src/indicator-printers-service.c
+++ b/src/indicator-printers-service.c
@@ -19,6 +19,7 @@
 #include <libindicator/indicator-service.h>
 #include <libdbusmenu-glib/dbusmenu-glib.h>
 #include <gtk/gtk.h>
+#include <cups/cups.h>
 #include "dbus-names.h"
 
 #include "cups-notifier.h"
@@ -26,10 +27,77 @@
 #include "indicator-printer-state-notifier.h"
 
 
+static int
+create_subscription ()
+{
+    ipp_t *req;
+    ipp_t *resp;
+    ipp_attribute_t *attr;
+    int id = 0;
+
+    req = ippNewRequest (IPP_CREATE_PRINTER_SUBSCRIPTION);
+    ippAddString (req, IPP_TAG_OPERATION, IPP_TAG_URI,
+                  "printer-uri", NULL, "/");
+    ippAddString (req, IPP_TAG_SUBSCRIPTION, IPP_TAG_KEYWORD,
+                  "notify-events", NULL, "all");
+    ippAddString (req, IPP_TAG_SUBSCRIPTION, IPP_TAG_URI,
+                  "notify-recipient-uri", NULL, "dbus://");
+    ippAddInteger (req, IPP_TAG_SUBSCRIPTION, IPP_TAG_INTEGER,
+                   "notify-lease-duration", 0);
+
+    resp = cupsDoRequest (CUPS_HTTP_DEFAULT, req, "/");
+    if (!resp || cupsLastError() != IPP_OK) {
+        g_warning ("Error subscribing to CUPS notifications: %s\n",
+                   cupsLastErrorString ());
+        return 0;
+    }
+
+    attr = ippFindAttribute (resp, "notify-subscription-id", IPP_TAG_INTEGER);
+    if (attr)
+        id = attr->values[0].integer;
+    else
+        g_warning ("ipp-create-printer-subscription response doesn't contain "
+                   "subscription id.\n");
+
+    ippDelete (resp);
+    return id;
+}
+
+
+void
+cancel_subscription (int id)
+{
+    ipp_t *req;
+    ipp_t *resp;
+
+    if (id <= 0)
+        return;
+
+    req = ippNewRequest (IPP_CANCEL_SUBSCRIPTION);
+    ippAddString (req, IPP_TAG_OPERATION, IPP_TAG_URI,
+                  "printer-uri", NULL, "/");
+    ippAddInteger (req, IPP_TAG_OPERATION, IPP_TAG_INTEGER,
+                   "notify-subscription-id", id);
+
+    resp = cupsDoRequest (CUPS_HTTP_DEFAULT, req, "/");
+    if (!resp || cupsLastError() != IPP_OK) {
+        g_warning ("Error subscribing to CUPS notifications: %s\n",
+                   cupsLastErrorString ());
+        return;
+    }
+
+    ippDelete (resp);
+}
+
+
 static void
 service_shutdown (IndicatorService *service, gpointer user_data)
 {
+    int subscription_id = GPOINTER_TO_INT (user_data);
+
     g_debug("Shutting down indicator-printers-service");
+
+    cancel_subscription (subscription_id);
     gtk_main_quit ();
 }
 
@@ -42,15 +110,18 @@ int main (int argc, char *argv[])
     IndicatorPrintersMenu *menu;
     IndicatorPrinterStateNotifier *state_notifier;
     GError *error = NULL;
+    int subscription_id;
 
     gtk_init (&argc, &argv);
 
+    subscription_id = create_subscription ();
+
     service = indicator_service_new_version (INDICATOR_PRINTERS_DBUS_NAME,
                                              INDICATOR_PRINTERS_DBUS_VERSION);
     g_signal_connect (service,
                       "shutdown",
                       G_CALLBACK (service_shutdown),
-                      NULL);
+                      GINT_TO_POINTER (subscription_id));
 
     cups_notifier = cups_notifier_proxy_new_for_bus_sync (G_BUS_TYPE_SYSTEM,
                                                           0,