dotfiles/gnome/.local/share/gnome-shell/extensions/blur-my-shell@aunetx/conveniences/connections.js

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}`);
    }
};