Class EventBus

devui/theme/utils/event-bus.ts:3–99

import { IEventBus } from './interface';

export class EventBus implements IEventBus {
  private eventBusCore = [];

  private areFuncEqual(a, b) {
    return a.toString() === b.toString();
  }

  private isKeyValueObjInArr(arr, key, val) {
    const filteredArr = arr.filter((entry) => {
      return entry[key] === val;
    });
    return filteredArr.length > 0;
  }

  private removeFuncInFuncArr(arr, fn) {
    for (let z = 0; z < arr.length; z++) {
      if (this.areFuncEqual(arr[z], fn)) {
        arr.splice(z, 1);
      }
    }
    return arr;
  }

  private getKeyValueObjInArr(arr, key, val) {
    const filteredArr = arr.filter((entry) => {
      return entry[key] === val;
    });
    return filteredArr[0];
  }

  private addEvent(eventName, eventFunc) {
    if (!this.isKeyValueObjInArr(this.eventBusCore, 'eventName', eventName)) {
      this.eventBusCore.push({ eventName: eventName, eventFuncArr: [eventFunc] });
    } else {
      this.eventBusCore = this.eventBusCore.map((event) => {
        if (event.eventName === eventName) {
          event.eventFuncArr.push(eventFunc);
        }
        return event;
      });
    }
  }

  public add(...rest): void {
    const eventName = rest[0];
    const callbacks = rest[1];
    if (!eventName) {
      return;
    }
    if (typeof callbacks === 'function') {
      for (let i = 1; i < rest.length; i++) {
        this.addEvent(eventName, rest[i]);
      }
    }
    if (typeof callbacks === 'object' && callbacks.forEach) {
      callbacks.forEach((fn) => {
        this.addEvent(eventName, fn);
      });