mirror of
https://github.com/lxsang/antos-frontend.git
synced 2025-07-19 15:29:51 +02:00
Switch from coffee script to typescrit
- Better tooling support - Stronger type checking - Unit test with jest - JSDocc support
This commit is contained in:
Xuan Sang LE
292
src/core/Announcerment.ts
Normal file
292
src/core/Announcerment.ts
Normal file
@ -0,0 +1,292 @@
|
||||
/*
|
||||
* decaffeinate suggestions:
|
||||
* DS101: Remove unnecessary use of Array.from
|
||||
* DS102: Remove unnecessary code created because of implicit returns
|
||||
* DS205: Consider reworking code to avoid use of IIFEs
|
||||
* Full docs: https://github.com/decaffeinate/decaffeinate/blob/master/docs/suggestions.md
|
||||
*/
|
||||
// Copyright 2017-2018 Xuan Sang LE <xsang.le AT gmail DOT com>
|
||||
|
||||
// AnTOS Web desktop is is licensed under the GNU General Public
|
||||
// License v3.0, see the LICENCE file for more information
|
||||
|
||||
// This program is free software: you can redistribute it and/or
|
||||
// modify it under the terms of the GNU General Public License as
|
||||
// published by the Free Software Foundation, either version 3 of
|
||||
// the License, or (at your option) any later version.
|
||||
|
||||
// This program is distributed in the hope that it will be useful,
|
||||
// but WITHOUT ANY WARRANTY; without even the implied warranty of
|
||||
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
|
||||
// General Public License for more details.
|
||||
|
||||
// You should have received a copy of the GNU General Public License
|
||||
//along with this program. If not, see https://www.gnu.org/licenses/.
|
||||
|
||||
namespace OS {
|
||||
export namespace API {
|
||||
/**
|
||||
*
|
||||
*
|
||||
* @export
|
||||
* @interface ObservableEntryType
|
||||
*/
|
||||
export interface ObservableEntryType {
|
||||
one: Set<(d: any) => void>;
|
||||
many: Set<(d: any) => void>;
|
||||
}
|
||||
|
||||
/**
|
||||
*
|
||||
*
|
||||
* @export
|
||||
* @interface AnnouncerListenerType
|
||||
*/
|
||||
export interface AnnouncerListenerType {
|
||||
[index: number]: {
|
||||
e: string;
|
||||
f: (d: any) => void;
|
||||
}[];
|
||||
}
|
||||
|
||||
/**
|
||||
*
|
||||
*
|
||||
* @export
|
||||
* @class Announcer
|
||||
*/
|
||||
export class Announcer {
|
||||
observable: GenericObject<ObservableEntryType>;
|
||||
enable: boolean;
|
||||
constructor() {
|
||||
this.observable = {};
|
||||
this.enable = true;
|
||||
}
|
||||
|
||||
/**
|
||||
*
|
||||
*
|
||||
* @returns
|
||||
* @memberof Announcer
|
||||
*/
|
||||
disable() {
|
||||
this.off("*");
|
||||
return (this.enable = false);
|
||||
}
|
||||
|
||||
/**
|
||||
*
|
||||
*
|
||||
* @param {string} evtName
|
||||
* @param {(d: any) => void} callback
|
||||
* @returns {void}
|
||||
* @memberof Announcer
|
||||
*/
|
||||
on(evtName: string, callback: (d: any) => void): void {
|
||||
if (!this.enable) {
|
||||
return;
|
||||
}
|
||||
if (!this.observable[evtName]) {
|
||||
this.observable[evtName] = {
|
||||
one: new Set(),
|
||||
many: new Set(),
|
||||
};
|
||||
}
|
||||
this.observable[evtName].many.add(callback);
|
||||
}
|
||||
|
||||
/**
|
||||
*
|
||||
*
|
||||
* @param {string} evtName
|
||||
* @param {(d: any) => void} callback
|
||||
* @returns {void}
|
||||
* @memberof Announcer
|
||||
*/
|
||||
one(evtName: string, callback: (d: any) => void): void {
|
||||
if (!this.enable) {
|
||||
return;
|
||||
}
|
||||
if (!this.observable[evtName]) {
|
||||
this.observable[evtName] = {
|
||||
one: new Set(),
|
||||
many: new Set(),
|
||||
};
|
||||
}
|
||||
this.observable[evtName].one.add(callback);
|
||||
}
|
||||
|
||||
/**
|
||||
*
|
||||
*
|
||||
* @param {string} evtName
|
||||
* @param {(d: any) => void} [callback]
|
||||
* @memberof Announcer
|
||||
*/
|
||||
off(evtName: string, callback?: (d: any) => void): void {
|
||||
const fn = (evt: string, cb: (d: any) => void) => {
|
||||
if (!this.observable[evt]) {
|
||||
return;
|
||||
}
|
||||
if (cb) {
|
||||
this.observable[evt].one.delete(cb);
|
||||
return this.observable[evt].many.delete(cb);
|
||||
} else {
|
||||
if (this.observable[evt]) {
|
||||
return delete this.observable[evt];
|
||||
}
|
||||
}
|
||||
};
|
||||
if (evtName === "*") {
|
||||
for (let k in this.observable) {
|
||||
fn(k, callback);
|
||||
}
|
||||
} else {
|
||||
fn(evtName, callback);
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
*
|
||||
*
|
||||
* @param {string} evtName
|
||||
* @param {*} data
|
||||
* @returns {void}
|
||||
* @memberof Announcer
|
||||
*/
|
||||
trigger(evtName: string, data: any): void {
|
||||
const trig = (name: string, d: any) => {
|
||||
const names = [name, "*"];
|
||||
for (let evt of Array.from(names)) {
|
||||
if (!this.observable[evt]) {
|
||||
continue;
|
||||
}
|
||||
this.observable[evt].one.forEach((f) => f(d));
|
||||
this.observable[evt].one = new Set();
|
||||
this.observable[evt].many.forEach((f) => f(d));
|
||||
}
|
||||
};
|
||||
if (evtName === "*") {
|
||||
for (let k in this.observable) {
|
||||
const v = this.observable[k];
|
||||
if (k !== "*") {
|
||||
trig(k, data);
|
||||
}
|
||||
}
|
||||
} else {
|
||||
return trig(evtName, data);
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
export namespace announcer {
|
||||
export var observable: API.Announcer = new API.Announcer();
|
||||
export var quota: 0;
|
||||
export var listeners: API.AnnouncerListenerType = {};
|
||||
|
||||
/**
|
||||
*
|
||||
*
|
||||
* @export
|
||||
* @param {string} e
|
||||
* @param {(d: any) => void} f
|
||||
* @param {GUI.BaseModel} a
|
||||
*/
|
||||
export function on(
|
||||
e: string,
|
||||
f: (d: any) => void,
|
||||
a: BaseModel
|
||||
): void {
|
||||
if (!announcer.listeners[a.pid]) {
|
||||
announcer.listeners[a.pid] = [];
|
||||
}
|
||||
announcer.listeners[a.pid].push({ e, f });
|
||||
announcer.observable.on(e, f);
|
||||
}
|
||||
|
||||
/**
|
||||
*
|
||||
*
|
||||
* @export
|
||||
* @param {string} e
|
||||
* @param {*} d
|
||||
*/
|
||||
export function trigger(e: string, d: any): void {
|
||||
announcer.observable.trigger(e, d);
|
||||
}
|
||||
|
||||
/**
|
||||
*
|
||||
*
|
||||
* @export
|
||||
* @param {(string | FormatedString)} m
|
||||
* @param {Error} e
|
||||
*/
|
||||
export function osfail(m: string | FormatedString, e: Error): void {
|
||||
announcer.ostrigger("fail", { m, e });
|
||||
}
|
||||
|
||||
/**
|
||||
*
|
||||
*
|
||||
* @export
|
||||
* @param {(string | FormatedString)} m
|
||||
* @param {Error} e
|
||||
*/
|
||||
export function oserror(m: string | FormatedString, e: Error): void {
|
||||
announcer.ostrigger("error", { m, e });
|
||||
}
|
||||
|
||||
/**
|
||||
*
|
||||
*
|
||||
* @export
|
||||
* @param {(string | FormatedString)} m
|
||||
*/
|
||||
export function osinfo(m: string | FormatedString): void {
|
||||
announcer.ostrigger("info", { m, e: null });
|
||||
}
|
||||
|
||||
/**
|
||||
*
|
||||
*
|
||||
* @export
|
||||
* @param {string} e
|
||||
* @param {*} d
|
||||
*/
|
||||
export function ostrigger(e: string, d: any): void {
|
||||
announcer.trigger(e, { id: 0, data: d, name: "OS" });
|
||||
}
|
||||
|
||||
/**
|
||||
*
|
||||
*
|
||||
* @export
|
||||
* @param {GUI.BaseModel} app
|
||||
* @returns {void}
|
||||
*/
|
||||
export function unregister(app: BaseModel): void {
|
||||
if (
|
||||
!announcer.listeners[app.pid] ||
|
||||
!(announcer.listeners[app.pid].length > 0)
|
||||
) {
|
||||
return;
|
||||
}
|
||||
for (let i of Array.from(announcer.listeners[app.pid])) {
|
||||
announcer.observable.off(i.e, i.f);
|
||||
}
|
||||
delete announcer.listeners[app.pid];
|
||||
}
|
||||
|
||||
/**
|
||||
*
|
||||
*
|
||||
* @export
|
||||
* @returns {number}
|
||||
*/
|
||||
export function getMID(): number {
|
||||
announcer.quota += 1;
|
||||
return announcer.quota;
|
||||
}
|
||||
}
|
||||
}
|
||||
Reference in New Issue
Block a user