1 files changed, 67 insertions, 2 deletions

diff --git a/src/lib/DBus.ts b/src/lib/DBus.ts
index bbff405c4..530e30c85 100644
--- a/src/lib/DBus.ts
+++ b/src/lib/DBus.ts
@@ -1,28 +1,92 @@
+import { ipcMain } from 'electron';
+import { comparer } from 'mobx';
+
 import { MessageBus, sessionBus } from 'dbus-next';
 import { isLinux } from '../environment';
 import TrayIcon from './Tray';
+import Ferdium, { type UnreadServices } from './dbus/Ferdium';
 
 export default class DBus {
-  bus: MessageBus | null = null;
+  private bus: MessageBus | null = null;
 
   trayIcon: TrayIcon;
 
+  private ferdium: Ferdium | null = null;
+
+  muted = false;
+
+  unreadDirectMessageCount = 0;
+
+  unreadIndirectMessageCount = 0;
+
+  unreadServices: UnreadServices = [];
+
   constructor(trayIcon: TrayIcon) {
     this.trayIcon = trayIcon;
+    ipcMain.on('initialAppSettings', (_, appSettings) => {
+      this.updateSettings(appSettings);
+    });
+    ipcMain.on('updateAppSettings', (_, appSettings) => {
+      this.updateSettings(appSettings);
+    });
+    ipcMain.on(
+      'updateDBusUnread',
+      (
+        _,
+        unreadDirectMessageCount,
+        unreadIndirectMessageCount,
+        unreadServices,
+      ) => {
+        this.setUnread(
+          unreadDirectMessageCount,
+          unreadIndirectMessageCount,
+          unreadServices,
+        );
+      },
+    );
+  }
+
+  private updateSettings(appSettings): void {
+    const muted = !!appSettings.data.isAppMuted;
+    if (this.muted !== muted) {
+      this.muted = muted;
+      this.ferdium?.emitMutedChanged();
+    }
   }
 
-  start() {
+  private setUnread(
+    unreadDirectMessageCount: number,
+    unreadIndirectMessageCount: number,
+    unreadServices: UnreadServices,
+  ): void {
+    if (
+      this.unreadDirectMessageCount !== unreadDirectMessageCount ||
+      this.unreadIndirectMessageCount !== unreadIndirectMessageCount ||
+      !comparer.structural(this.unreadServices, unreadServices)
+    ) {
+      this.unreadDirectMessageCount = unreadDirectMessageCount;
+      this.unreadIndirectMessageCount = unreadIndirectMessageCount;
+      this.unreadServices = unreadServices;
+      this.ferdium?.emitUnreadChanged();
+    }
+  }
+
+  async start() {
     if (!isLinux || this.bus) {
       return;
     }
 
     try {
       this.bus = sessionBus();
+      await this.bus.requestName('org.ferdium.Ferdium', 0);
     } catch {
       // Error connecting to the bus.
       return;
     }
 
+    this.ferdium = new Ferdium(this);
+    this.bus.export('/org/ferdium', this.ferdium);
+
     // HACK Hook onto the MessageBus to track StatusNotifierWatchers
     // @ts-expect-error Property '_addMatch' does not exist on type 'MessageBus'.
     this.bus._addMatch(
@@ -56,5 +120,6 @@ export default class DBus {
 
     this.bus.disconnect();
     this.bus = null;
+    this.ferdium = null;
   }
 }