-
Notifications
You must be signed in to change notification settings - Fork 1
/
Service.ts
111 lines (100 loc) · 3.01 KB
/
Service.ts
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
import { AsyncEventEmitter } from '../_internal/AsyncEventEmitter';
import { v4 as uuidv4 } from 'uuid';
import { SerializableMember, SerializableObject } from '../data/decorators';
/**
* Service is accessible by each {@link Node} inside the {@link Model}
*/
@SerializableObject()
export abstract class Service extends AsyncEventEmitter {
/**
* Service name
*/
@SerializableMember()
uid: string;
private _ready = false;
/**
* Model shape
*/
model: any;
constructor(options: ServiceOptions = {}) {
super();
this.uid = options.uid ?? this.constructor.name;
this.prependOnceListener('ready', () => {
this._ready = true;
});
}
protected generateUUID(): string {
return uuidv4();
}
setUID(uid: string): this {
this.uid = uid;
return this;
}
isReady(): boolean {
return this._ready;
}
emit(name: string | symbol, ...args: any[]): boolean;
/**
* Service ready
* @param {string} name ready
*/
emit(name: 'ready'): boolean;
/**
* Destroy the service
* @param {string} name destroy
*/
emit(name: 'destroy'): boolean;
emit(name: string | symbol, ...args: any[]): boolean {
return super.emit(name, ...args);
}
once(name: string | symbol, listener: (...args: any[]) => void): this;
/**
* Event called when service is destroyed
* @param {string} name destroy
* @param {Function} listener Event callback
*/
once(name: 'destroy', listener: () => void | Promise<void>): this;
/**
* Event called when service is build
* @param {string} name build
* @param {Function} listener Event callback
*/
once(name: 'build', listener: () => void | Promise<void>): this;
/**
* Event called when service is ready
* @param {string} name ready
* @param {Function} listener Event callback
*/
once(name: 'ready', listener: () => void | Promise<void>): this;
once(name: string | symbol, listener: (...args: any[]) => void): this {
if (name === 'ready' && this.isReady()) {
listener();
return this;
}
return super.once(name, listener);
}
logger(level: 'debug', message: string, data?: any): void;
logger(level: 'info', message: string, data?: any): void;
logger(level: 'warn', message: string, data?: any): void;
logger(level: 'error', message: string, error?: Error): void;
/**
* @deprecated
* @param {string} level Logging level
* @param {any} log Logging data or message
*/
logger(level: string, log: any): void;
/**
* Graph logger
* @param {string} level Logging level
* @param {string} message Message
* @param {any} data Data to include in log
*/
logger(level: string, message: string, data?: any): void {
if (this.model) {
this.model.logger(level, message, data);
}
}
}
export interface ServiceOptions {
uid?: string;
}