nixos-configs/hosts/wim/config/ags/services/pointers.js

import { App, Service, Utils } from '../imports.js';
import GUdev from 'gi://GUdev';

const UDEV_POINTERS = [
    'ID_INPUT_MOUSE',
    'ID_INPUT_POINTINGSTICK',
    'ID_INPUT_TOUCHPAD',
    'ID_INPUT_TOUCHSCREEN',
    'ID_INPUT_TABLET',
];
const ON_RELEASE_TRIGGERS = [
    'released',
    'TOUCH_UP',
    'HOLD_END',
];
const ON_CLICK_TRIGGERS = [
    'pressed',
    'TOUCH_DOWN',
];


class Pointers extends Service {
    static {
        Service.register(this, {
            'proc-started': ['boolean'],
            'proc-destroyed': ['boolean'],
            'device-fetched': ['boolean'],
            'new-line': ['string'],
            'released': ['string'],
            'clicked': ['string'],
        });
    }

    proc = undefined;
    output = '';
    devices = [];
    udevClient = GUdev.Client.new(['input']);

    get process()  { return this.proc; }
    get lastLine() { return this.output; }
    get pointers() { return this.devices; }

    constructor() {
        super();
        this.initUdevConnection();
        this.initAppConnection();
    }

    // FIXME: logitech mouse screws everything up on disconnect
    initUdevConnection() {
        this.getDevices();
        this.udevClient.connect('uevent', (_, action) => {
            if (action === 'add' || action === 'remove') {
                this.getDevices();
                if (this.proc) {
                    this.killProc();
                    this.startProc();
                }
            }
        });
    }

    getDevices() {
        this.devices = [];
        this.udevClient.query_by_subsystem('input').forEach(dev => {
            const isPointer = UDEV_POINTERS.some(p => dev.has_property(p));
            if (isPointer) {
                const hasEventFile = dev.has_property('DEVNAME') &&
                                     dev.get_property('DEVNAME').includes('event');
                if (hasEventFile)
                    this.devices.push(dev.get_property('DEVNAME'));
            }
        });

        this.emit('device-fetched', true);
    }

    startProc() {
        if (this.proc)
            return;

        const args = [];
        this.devices.forEach(dev => {
            args.push('--device');
            args.push(dev);
        });

        this.proc = Utils.subprocess(
            ['libinput', 'debug-events', ...args],
            output => {
                if (output.includes('cancelled'))
                    return;

                if (ON_RELEASE_TRIGGERS.some(p => output.includes(p))) {
                    this.output = output;
                    this.detectClickedOutside('released');
                    this.emit('released', output);
                    this.emit('new-line', output);
                }

                if (ON_CLICK_TRIGGERS.some(p => output.includes(p))) {
                    this.output = output;
                    this.detectClickedOutside('clicked');
                    this.emit('clicked', output);
                    this.emit('new-line', output);
                }
            },
            err => logError(err),
        );
        this.emit('proc-started', true);
    }

    killProc() {
        if (this.proc) {
            this.proc.force_exit();
            this.proc = undefined;
            this.emit('proc-destroyed', true);
        }
    }

    initAppConnection() {
        App.connect('window-toggled', () => {
            const anyVisibleAndClosable = Array.from(App.windows).some(w => {
                const closable = (w[1].closeOnUnfocus &&
                                  w[1].closeOnUnfocus !== 'none');

                return w[1].visible && closable;
            });

            if (anyVisibleAndClosable)
                this.startProc();

            else
                this.killProc();
        });
    }

    detectClickedOutside(clickStage) {
        const toClose = Array.from(App.windows).some(w => {
            const closable = (w[1].closeOnUnfocus &&
                              w[1].closeOnUnfocus === clickStage);

            return w[1].visible && closable;
        });
        if (!toClose)
            return;

        Utils.execAsync('hyprctl layers -j').then(layers => {
            layers = JSON.parse(layers);

            Utils.execAsync('hyprctl cursorpos -j').then(pos => {
                pos = JSON.parse(pos);

                Object.values(layers).forEach(key => {
                    const bar = key['levels']['3']
                        .find(n => n.namespace === 'bar');

                    const widgets = key['levels']['3'].filter(n => {
                        const window = App.getWindow(n.namespace);
                        return window.closeOnUnfocus &&
                               window.closeOnUnfocus === clickStage;
                    });

                    if (pos.x > bar.x && pos.x < bar.x + bar.w &&
                        pos.y > bar.y && pos.y < bar.y + bar.h) {

                        // don't handle clicks when on bar
                        // TODO: make this configurable
                    }
                    else {
                        widgets.forEach(w => {
                            if (!(pos.x > w.x && pos.x < w.x + w.w &&
                                  pos.y > w.y && pos.y < w.y + w.h))
                                App.closeWindow(w.namespace);
                        });
                    }
                });
            }).catch(print);
        }).catch(print);
    }
}

const pointersService = new Pointers();
export default pointersService;