1 files changed, 106 insertions, 0 deletions
diff --git a/raveos-gnome-theme/theme-data/extensions/installed/blur-my-shell@aunetx/conveniences/connections.js b/raveos-gnome-theme/theme-data/extensions/installed/blur-my-shell@aunetx/conveniences/connections.js
new file mode 100644
index 0000000..0583db3
--- /dev/null
+++ b/raveos-gnome-theme/theme-data/extensions/installed/blur-my-shell@aunetx/conveniences/connections.js
@@ -0,0 +1,106 @@
+import GObject from 'gi://GObject';
+
+/// An object to easily manage signals.
+export const Connections = class Connections {
+    constructor() {
+        this.buffer = [];
+    }
+
+    /// Adds a connection.
+    ///
+    /// Takes as arguments:
+    /// - an actor, which fires the signal
+    /// - signal(s) (string or array of strings), which are watched for
+    /// - a callback, which is called when the signal is fired
+    connect(actor, signals, handler) {
+        if (signals instanceof Array) {
+            signals.forEach(signal => {
+                let id = actor.connect(signal, handler);
+                this.process_connection(actor, id);
+            });
+        } else {
+            let id = actor.connect(signals, handler);
+            this.process_connection(actor, id);
+        }
+
+    }
+
+    /// Process the given actor and id.
+    ///
+    /// This makes sure that the signal is disconnected when the actor is
+    /// destroyed, and that the signal can be managed through other Connections
+    /// methods.
+    process_connection(actor, id) {
+        let infos = {
+            actor: actor,
+            id: id
+        };
+
+        // remove the signal when the actor is destroyed
+        if (
+            actor.connect &&
+            (
+                !(actor instanceof GObject.Object) ||
+                GObject.signal_lookup('destroy', actor)
+            )
+        ) {
+            let destroy_id = actor.connect('destroy', () => {
+                actor.disconnect(id);
+                actor.disconnect(destroy_id);
+
+                let index = this.buffer.indexOf(infos);
+                if (index >= 0) {
+                    this.buffer.splice(index, 1);
+                }
+            });
+            infos.destroy_id = destroy_id;
+        }
+
+        this.buffer.push(infos);
+    }
+
+    /// Disconnects every connection found for an actor.
+    disconnect_all_for(actor) {
+        // get every connection stored for the actor
+        let actor_connections = this.buffer.filter(
+            infos => infos.actor === actor
+        );
+
+        // remove each of them
+        actor_connections.forEach(connection => {
+            // disconnect
+            try {
+                connection.actor.disconnect(connection.id);
+                if ('destroy_id' in connection)
+                    connection.actor.disconnect(connection.destroy_id);
+            } catch (e) {
+                this._warn(`error removing connection: ${e}; continuing`);
+            }
+
+            // remove from buffer
+            let index = this.buffer.indexOf(connection);
+            this.buffer.splice(index, 1);
+        });
+    }
+
+    /// Disconnect every connection for each actor.
+    disconnect_all() {
+        this.buffer.forEach(connection => {
+            // disconnect
+            try {
+                connection.actor.disconnect(connection.id);
+                if ('destroy_id' in connection)
+                    connection.actor.disconnect(connection.destroy_id);
+            } catch (e) {
+                this._warn(`error removing connection: ${e}; continuing`);
+            }
+        });
+
+        // reset buffer
+        this.buffer = [];
+    }
+
+    _warn(str) {
+        console.warn(`[Blur my Shell > connections]  ${str}`);
+    }
+};
+\ No newline at end of file