Merge pull request #252 from alebastr/tray-items-refresh

Process tray icon updates

include/modules/sni/item.hpp

@@ -2,12 +2,14 @@
 
 #include <dbus-status-notifier-item.h>
 #include <glibmm/refptr.h>
+#include <giomm/dbusproxy.h>
 #include <gtkmm/eventbox.h>
 #include <gtkmm/image.h>
 #include <gtkmm/icontheme.h>
 #include <gtkmm/menu.h>
 #include <json/json.h>
 #include <libdbusmenu-gtk/dbusmenu-gtk.h>
+#include <sigc++/trackable.h>
 #ifdef FILESYSTEM_EXPERIMENTAL
 #include <experimental/filesystem>
 #else
@@ -16,7 +18,7 @@
 
 namespace waybar::modules::SNI {
 
-class Item {
+class Item : public sigc::trackable {
 public:
   Item(std::string, std::string, const Json::Value&);
   ~Item() = default;
@@ -46,8 +48,12 @@ public:
   bool item_is_menu;
 
 private:
-  static void proxyReady(GObject *obj, GAsyncResult *res, gpointer data);
+  void proxyReady(Glib::RefPtr<Gio::AsyncResult>& result);
-  static void getAll(GObject *obj, GAsyncResult *res, gpointer data);
+  void setProperty(const Glib::ustring& name, Glib::VariantBase& value);
+  void getUpdatedProperties();
+  void processUpdatedProperties(Glib::RefPtr<Gio::AsyncResult>& result);
+  void onSignal(const Glib::ustring& sender_name, const Glib::ustring& signal_name,
+      const Glib::VariantContainerBase& arguments);
 
   void updateImage();
   Glib::RefPtr<Gdk::Pixbuf> extractPixBuf(GVariant *variant);
@@ -56,8 +62,9 @@ private:
   bool makeMenu(GdkEventButton *const &ev);
   bool handleClick(GdkEventButton *const & /*ev*/);
 
-  GCancellable *cancellable_ = nullptr;
+  Glib::RefPtr<Gio::Cancellable> cancellable_;
-  SnItem *proxy_ = nullptr;
+  Glib::RefPtr<Gio::DBus::Proxy> proxy_;
+  bool update_pending_;
 };
 
 } // namespace waybar::modules::SNI

src/modules/sni/item.cpp

@@ -1,10 +1,16 @@
 #include "modules/sni/item.hpp"
 
 #include <iostream>
+#include <glibmm/main.h>
+
+using namespace Glib;
+
+static const ustring SNI_INTERFACE_NAME = sn_item_interface_info()->name;
+static const unsigned UPDATE_DEBOUNCE_TIME = 10;
 
 waybar::modules::SNI::Item::Item(std::string bn, std::string op, const Json::Value& config)
-    : bus_name(bn), object_path(op), icon_size(16), effective_icon_size(0)
+    : bus_name(bn), object_path(op), icon_size(16), effective_icon_size(0),
-{
+    update_pending_(false) {
   if (config["icon-size"].isUInt()) {
     icon_size = config["icon-size"].asUInt();
   }
@@ -12,107 +18,148 @@ waybar::modules::SNI::Item::Item(std::string bn, std::string op, const Json::Val
   event_box.add_events(Gdk::BUTTON_PRESS_MASK);
   event_box.signal_button_press_event().connect(
       sigc::mem_fun(*this, &Item::handleClick));
-  cancellable_ = g_cancellable_new();
+
-  sn_item_proxy_new_for_bus(
+  cancellable_ = Gio::Cancellable::create();
-      G_BUS_TYPE_SESSION, G_DBUS_PROXY_FLAGS_NONE, bus_name.c_str(),
+
-      object_path.c_str(), cancellable_, &Item::proxyReady, this);
+  auto interface = Glib::wrap(sn_item_interface_info(), true);
+  Gio::DBus::Proxy::create_for_bus(Gio::DBus::BusType::BUS_TYPE_SESSION, bus_name,
+      object_path, SNI_INTERFACE_NAME, sigc::mem_fun(*this, &Item::proxyReady),
+      cancellable_, interface);
 }
 
-void waybar::modules::SNI::Item::proxyReady(GObject *obj, GAsyncResult *res,
+void waybar::modules::SNI::Item::proxyReady(Glib::RefPtr<Gio::AsyncResult>& result) {
-                                            gpointer data) {
+  try {
-  GError *error = nullptr;
+    this->proxy_ = Gio::DBus::Proxy::create_for_bus_finish(result);
-  SnItem *proxy = sn_item_proxy_new_for_bus_finish(res, &error);
+    /* Properties are already cached during object creation */
-  if (g_error_matches(error, G_IO_ERROR, G_IO_ERROR_CANCELLED)) {
+    auto cached_properties = this->proxy_->get_cached_property_names();
-    g_error_free(error);
+    for (const auto& name: cached_properties) {
-    return;
+      Glib::VariantBase value;
-  }
+      this->proxy_->get_cached_property(value, name);
-  auto item = static_cast<SNI::Item *>(data);
+      setProperty(name, value);
-  item->proxy_ = proxy;
-  if (error) {
-    std::cerr << error->message << std::endl;
-    g_error_free(error);
-    return;
-  }
-  auto conn = g_dbus_proxy_get_connection(G_DBUS_PROXY(proxy));
-
-  g_dbus_connection_call(conn, item->bus_name.c_str(),
-    item->object_path.c_str(), "org.freedesktop.DBus.Properties", "GetAll",
-    g_variant_new("(s)", "org.kde.StatusNotifierItem"),
-    G_VARIANT_TYPE("(a{sv})"), G_DBUS_CALL_FLAGS_NONE, -1, item->cancellable_,
-    &Item::getAll, data);
     }
 
-void waybar::modules::SNI::Item::getAll(GObject *obj, GAsyncResult *res,
+    this->proxy_->signal_signal().connect(sigc::mem_fun(*this, &Item::onSignal));
-                                        gpointer data) {
+
-  GError *error = nullptr;
+    if (this->id.empty() || this->category.empty() || this->status.empty()) {
-  auto conn = G_DBUS_CONNECTION(obj);
+      std::cerr << "Invalid Status Notifier Item: " + this->bus_name + "," +
-  GVariant *properties = g_dbus_connection_call_finish(conn, res, &error);
+        this->object_path << std::endl;
-  if (g_error_matches(error, G_IO_ERROR, G_IO_ERROR_CANCELLED)) {
-    g_error_free(error);
       return;
     }
-  auto item = static_cast<SNI::Item *>(data);
+    if (!this->icon_theme_path.empty()) {
-  if (error) {
+      Glib::RefPtr<Gtk::IconTheme> icon_theme = Gtk::IconTheme::get_default();
-    std::cerr << error->message << std::endl;
+      icon_theme->append_search_path(this->icon_theme_path);
-    g_error_free(error);
-    return;
     }
-  GVariantIter *it = nullptr;
+    this->updateImage();
-  g_variant_get(properties, "(a{sv})", &it);
+    // this->event_box.set_tooltip_text(this->title);
-  gchar *key;
+
-  GVariant *value;
+  } catch (const Glib::Error& err) {
-  while (g_variant_iter_next(it, "{sv}", &key, &value)) {
+    g_error("Failed to create DBus Proxy for %s %s: %s", bus_name.c_str(),
-    if (g_strcmp0(key, "Category") == 0) {
+        object_path.c_str(), err.what().c_str());
-      item->category = g_variant_dup_string(value, nullptr);
+  } catch (const std::exception& err) {
-    } else if (g_strcmp0(key, "Id") == 0) {
+    g_error("Failed to create DBus Proxy for %s %s: %s", bus_name.c_str(),
-      item->id = g_variant_dup_string(value, nullptr);
+        object_path.c_str(), err.what());
-    } else if (g_strcmp0(key, "Title") == 0) {
+  }
-      item->title = g_variant_dup_string(value, nullptr);
+}
-    } else if (g_strcmp0(key, "Status") == 0) {
+
-      item->status = g_variant_dup_string(value, nullptr);
+template<typename T>
-    } else if (g_strcmp0(key, "WindowId") == 0) {
+T get_variant(VariantBase& value) {
-      item->window_id = g_variant_get_int32(value);
+    return VariantBase::cast_dynamic<Variant<T>>(value).get();
-    } else if (g_strcmp0(key, "IconName") == 0) {
+}
-      item->icon_name = g_variant_dup_string(value, nullptr);
+
-    } else if (g_strcmp0(key, "IconPixmap") == 0) {
+void
-      item->icon_pixmap = item->extractPixBuf(value);
+waybar::modules::SNI::Item::setProperty(const ustring& name,
-    } else if (g_strcmp0(key, "OverlayIconName") == 0) {
+    VariantBase& value) {
-      item->overlay_icon_name = g_variant_dup_string(value, nullptr);
+  if (name == "Category") {
-    } else if (g_strcmp0(key, "OverlayIconPixmap") == 0) {
+    category = get_variant<std::string>(value);
+  } else if (name == "Id") {
+    id = get_variant<std::string>(value);
+  } else if (name == "Title") {
+    title = get_variant<std::string>(value);
+  } else if (name == "Status") {
+    status = get_variant<std::string>(value);
+  } else if (name == "WindowId") {
+    window_id = get_variant<int32_t>(value);
+  } else if (name == "IconName") {
+    icon_name = get_variant<std::string>(value);
+  } else if (name == "IconPixmap") {
+    icon_pixmap = this->extractPixBuf(value.gobj());
+  } else if (name == "OverlayIconName") {
+    overlay_icon_name = get_variant<std::string>(value);
+  } else if (name == "OverlayIconPixmap") {
     // TODO: overlay_icon_pixmap
-    } else if (g_strcmp0(key, "AttentionIconName") == 0) {
+  } else if (name == "AttentionIconName") {
-      item->attention_icon_name = g_variant_dup_string(value, nullptr);
+    attention_icon_name = get_variant<std::string>(value);
-    } else if (g_strcmp0(key, "AttentionIconPixmap") == 0) {
+  } else if (name == "AttentionIconPixmap") {
     // TODO: attention_icon_pixmap
-    } else if (g_strcmp0(key, "AttentionMovieName") == 0) {
+  } else if (name == "AttentionMovieName") {
-      item->attention_movie_name = g_variant_dup_string(value, nullptr);
+    attention_movie_name = get_variant<std::string>(value);
-    } else if (g_strcmp0(key, "ToolTip") == 0) {
+  } else if (name == "ToolTip") {
     // TODO: tooltip
-    } else if (g_strcmp0(key, "IconThemePath") == 0) {
+  } else if (name == "IconThemePath") {
-      item->icon_theme_path = g_variant_dup_string(value, nullptr);
+    icon_theme_path = get_variant<std::string>(value);
-    } else if (g_strcmp0(key, "Menu") == 0) {
+  } else if (name == "Menu") {
-      item->menu = g_variant_dup_string(value, nullptr);
+    menu = get_variant<std::string>(value);
-    } else if (g_strcmp0(key, "ItemIsMenu") == 0) {
+  } else if (name == "ItemIsMenu") {
-      item->item_is_menu = g_variant_get_boolean(value);
+    item_is_menu = get_variant<bool>(value);
   }
-    g_variant_unref(value);
-    g_free(key);
 }
-  g_variant_iter_free(it);
+
-  g_variant_unref(properties);
+void
-  if (item->id.empty() || item->category.empty() || item->status.empty()) {
+waybar::modules::SNI::Item::getUpdatedProperties() {
-    std::cerr << "Invalid Status Notifier Item: " + item->bus_name + "," +
+  update_pending_ = false;
-      item->object_path << std::endl;
+
-    return;
+  auto params = VariantContainerBase::create_tuple({
+    Variant<ustring>::create(SNI_INTERFACE_NAME)
+  });
+  proxy_->call("org.freedesktop.DBus.Properties.GetAll",
+      sigc::mem_fun(*this, &Item::processUpdatedProperties), params);
+};
+
+void
+waybar::modules::SNI::Item::processUpdatedProperties(
+    Glib::RefPtr<Gio::AsyncResult>& _result) {
+  try {
+    auto result = proxy_->call_finish(_result);
+    // extract "a{sv}" from VariantContainerBase
+    Variant<std::map<ustring, VariantBase>> properties_variant;
+    result.get_child(properties_variant);
+    auto properties = properties_variant.get();
+
+    for (const auto& [name, value]: properties) {
+      VariantBase old_value;
+      proxy_->get_cached_property(old_value, name);
+      if (!value.equal(old_value)) {
+        proxy_->set_cached_property(name, value);
+        setProperty(name, const_cast<VariantBase&>(value));
       }
-  if (!item->icon_theme_path.empty()) {
-    GtkIconTheme *icon_theme = gtk_icon_theme_get_default();
-    gtk_icon_theme_append_search_path(icon_theme,
-      item->icon_theme_path.c_str());
     }
-  item->updateImage();
+
-  // item->event_box.set_tooltip_text(item->title);
+    this->updateImage();
-  // TODO: handle change
+    // this->event_box.set_tooltip_text(this->title);
+  } catch (const Glib::Error& err) {
+    g_warning("Failed to update properties: %s", err.what().c_str());
+  } catch (const std::exception& err) {
+    g_warning("Failed to update properties: %s", err.what());
+  }
+}
+
+void
+waybar::modules::SNI::Item::onSignal(const ustring& sender_name,
+    const ustring& signal_name, const VariantContainerBase& arguments) {
+  if (!update_pending_ && signal_name.compare(0, 3, "New") == 0) {
+    /* Debounce signals and schedule update of all properties.
+     * Based on behavior of Plasma dataengine for StatusNotifierItem.
+     */
+    update_pending_ = true;
+    Glib::signal_timeout().connect_once(
+        sigc::mem_fun(*this, &Item::getUpdatedProperties), UPDATE_DEBOUNCE_TIME);
+  }
+}
+
+
+static void
+pixbuf_data_deleter(const guint8* data) {
+  g_free((void*) data);
 }
 
 Glib::RefPtr<Gdk::Pixbuf>
@@ -158,7 +205,8 @@ waybar::modules::SNI::Item::extractPixBuf(GVariant *variant) {
       array[i + 3] = alpha;
     }
     return Gdk::Pixbuf::create_from_data(array, Gdk::Colorspace::COLORSPACE_RGB,
-                                         true, 8, lwidth, lheight, 4 * lwidth);
+                                         true, 8, lwidth, lheight, 4 * lwidth,
+                                         &pixbuf_data_deleter);
   }
   return Glib::RefPtr<Gdk::Pixbuf>{};
 }
@@ -251,15 +299,21 @@ bool waybar::modules::SNI::Item::makeMenu(GdkEventButton *const &ev)
 }
 
 bool waybar::modules::SNI::Item::handleClick(GdkEventButton *const &ev) {
+  auto parameters = VariantContainerBase::create_tuple({
+    Variant<int>::create(ev->x),
+    Variant<int>::create(ev->y)
+  });
   if ((ev->button == 1 && item_is_menu) || ev->button == 3) {
     if (!makeMenu(ev)) {
-      return sn_item_call_context_menu_sync(proxy_, ev->x, ev->y, nullptr, nullptr);
+      proxy_->call("ContextMenu", parameters);
+      return true;
     }
   } else if (ev->button == 1) {
-    return sn_item_call_activate_sync(proxy_, ev->x, ev->y, nullptr, nullptr);
+    proxy_->call("Activate", parameters);
+    return true;
   } else if (ev->button == 2) {
-    return sn_item_call_secondary_activate_sync(proxy_, ev->x, ev->y,
+    proxy_->call("SecondaryActivate", parameters);
-      nullptr, nullptr);
+    return true;
   }
   return false;
 }