stix/dist/Library/EventManager/EventManager.js

"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
const events_1 = require("events");
const Event_1 = require("./Event");
const debug_1 = require("../../debug");
const debug = debug_1.createDebugLogger('eventManager');
class EventManager extends events_1.EventEmitter {
    constructor(sharedEventManager = null) {
        super();
        this.hooks = {};
        this.sharedEventManager = sharedEventManager;
    }
    async trigger(eventName, target, payload) {
        debug(`Triggering event: ${eventName}.`);
        if (!this.hooks[eventName]) {
            debug('No listeners attached.');
            return false;
        }
        const callbacks = this.hooks[eventName];
        let triggered = 0;
        let detached = 0;
        let remaining = callbacks.length;
        for (let i = 0; i < remaining; i++) {
            const callback = callbacks[i];
            await callback(new Event_1.Event(eventName, target, payload));
            if (callback._isSelfDestructingCallback) {
                callbacks.splice(i, 1);
                detached++;
                remaining--;
                i--;
            }
            triggered++;
        }
        if (!remaining) {
            delete this.hooks[eventName];
        }
        debug(`Called ${triggered} listeners for: ${eventName} (detached ${detached} one-time listeners).`);
        return true;
    }
    has(event, callback) {
        return this.hooks[event] && this.hooks[event].indexOf(callback) > -1;
    }
    attachOnce(eventName, callback, index) {
        callback._isSelfDestructingCallback = true;
        this.attach(eventName, callback, index);
    }
    attach(event, callback, index) {
        this.hooks[event] = this.hooks[event] || [];
        if (index) {
            this.hooks[event].splice(index, 0, callback);
        }
        else {
            this.hooks[event].push(callback);
        }
        return this;
    }
    attachAt(index, event, callback) {
        return this.attach(event, callback, index);
    }
    detach(event, callback) {
        if (!this.hooks[event]) {
            return this;
        }
        const hookIndex = this.hooks[event].indexOf(callback);
        if (hookIndex === -1) {
            return this;
        }
        this.hooks[event].splice(hookIndex, 1);
        if (this.hooks[event].length === 0) {
            delete this.hooks[event];
        }
        return this;
    }
    getSharedEventManager() {
        return this.sharedEventManager;
    }
}
exports.EventManager = EventManager;
//# sourceMappingURL=EventManager.js.map