1 files changed, 39 insertions, 19 deletions

diff --git a/accounts/gkleen@sif/shell/quickshell/UnixIPC.qml b/accounts/gkleen@sif/shell/quickshell/UnixIPC.qml
index e7b7b673..05a40dbc 100644
--- a/accounts/gkleen@sif/shell/quickshell/UnixIPC.qml
+++ b/accounts/gkleen@sif/shell/quickshell/UnixIPC.qml
@@ -4,6 +4,7 @@ import Quickshell.Services.Pipewire
 import Quickshell.Services.Mpris
 import qs.Services
 import Custom as Custom
+import QtQml
 
 Scope {
   id: root
@@ -14,26 +15,32 @@ Scope {
     handler: Socket {
       parser: SplitParser {
         onRead: line => {
-          try {
-            const command = JSON.parse(line);
+          const command = (() => {
+            try {
+              return JSON.parse(line);
+            } catch (e) {
+              console.warn("UnixIPC: Failed to parse command:", line, e);
+            }
+          })();
+          if (!command)
+            return;
 
-            if (command.Volume)
-              root.onCommandVolume(command.Volume);
-            else if (command.Brightness)
-              root.onCommandBrightness(command.Brightness);
-            else if (command.LockSession)
-              Custom.Systemd.lockSession();
-            else if (command.Suspend)
-              Custom.Systemd.suspend();
-            else if (command.Hibernate)
-              Custom.Systemd.hibernate();
-            else if (command.Mpris)
-              root.onCommandMpris(command.Mpris);
-            else
-              console.warn("UnixIPC: Command not handled:", JSON.stringify(command));
-          } catch (e) {
-            console.warn("UnixIPC: Failed to parse command:", line, e);
-          }
+          if (command.Volume)
+            root.onCommandVolume(command.Volume);
+          else if (command.Brightness)
+            root.onCommandBrightness(command.Brightness);
+          else if (command.LockSession)
+            Custom.Systemd.lockSession();
+          else if (command.Suspend)
+            Custom.Systemd.suspend();
+          else if (command.Hibernate)
+            Custom.Systemd.hibernate();
+          else if (command.Mpris)
+            root.onCommandMpris(command.Mpris);
+          else if (command.Notifications)
+            root.onCommandNotifications(command.Notifications);
+          else
+            console.warn("UnixIPC: Command not handled:", JSON.stringify(command));
         }
       }
 
@@ -74,4 +81,17 @@ Scope {
           player.pause();
       });
   }
+  Component.onCompleted: { (_ => {})(MprisProxy.players); }
+
+  function onCommandNotifications(command) {
+    if (command.DismissGroup && NotificationManager.active) {
+      if (NotificationManager.groups.length > 0)
+        for (const notif of [...NotificationManager.groups[0]])
+          notif.dismiss();
+    }
+    if (command.DismissAll && NotificationManager.active) {
+      for (const notif of [...NotificationManager.trackedNotifications.values])
+        notif.dismiss();
+    }
+  }
 }