TraceSource.ts
147 lines
| 3.7 KiB
| video/mp2t
|
TypeScriptLexer
cin
|
r49 | import { Observable } from "../Observable"; | ||
|
cin
|
r53 | import { Registry } from "./Registry"; | ||
|
cin
|
r82 | import { TraceEventData } from "./TraceEventData"; | ||
|
cin
|
r115 | import { EventProvider } from "../EventProvider"; | ||
|
cin
|
r49 | |||
| export const DebugLevel = 400; | ||||
| export const LogLevel = 300; | ||||
| export const WarnLevel = 200; | ||||
| export const ErrorLevel = 100; | ||||
| export const SilentLevel = 0; | ||||
|
cin
|
r53 | export interface TraceEvent { | ||
|
cin
|
r49 | readonly source: TraceSource; | ||
| readonly level: number; | ||||
|
cin
|
r82 | readonly message: any; | ||
|
cin
|
r49 | |||
|
cin
|
r82 | readonly args?: any[]; | ||
|
cin
|
r65 | } | ||
|
cin
|
r49 | export class TraceSource { | ||
|
cin
|
r53 | readonly id: any; | ||
|
cin
|
r49 | |||
|
cin
|
r115 | level = 0; | ||
|
cin
|
r49 | |||
|
cin
|
r53 | readonly events: Observable<TraceEvent>; | ||
|
cin
|
r49 | |||
|
cin
|
r115 | private readonly _provider: EventProvider<TraceEvent>; | ||
|
cin
|
r49 | |||
|
cin
|
r115 | constructor(id?: any) { | ||
|
cin
|
r49 | |||
| this.id = id || new Object(); | ||||
|
cin
|
r115 | this._provider = new EventProvider(); | ||
| this.events = this._provider.getObservable(); | ||||
|
cin
|
r49 | } | ||
|
cin
|
r115 | protected emit(level: number, message: any, args: any[]) { | ||
| this._provider.post(new TraceEventData(this, level, message, args)); | ||||
|
cin
|
r49 | } | ||
| isDebugEnabled() { | ||||
| return this.level >= DebugLevel; | ||||
| } | ||||
|
cin
|
r82 | debug(data: any): void; | ||
| debug(msg: string, ...args: any[]): void; | ||||
|
cin
|
r49 | debug(msg: string, ...args: any[]) { | ||
| if (this.isEnabled(DebugLevel)) | ||||
|
cin
|
r82 | this.emit(DebugLevel, msg, args); | ||
|
cin
|
r49 | } | ||
| isLogEnabled() { | ||||
| return this.level >= LogLevel; | ||||
| } | ||||
|
cin
|
r82 | log(data: any): void; | ||
| log(msg: string, ...args: any[]): void; | ||||
|
cin
|
r49 | log(msg: string, ...args: any[]) { | ||
| if (this.isEnabled(LogLevel)) | ||||
|
cin
|
r82 | this.emit(LogLevel, msg, args); | ||
|
cin
|
r49 | } | ||
| isWarnEnabled() { | ||||
| return this.level >= WarnLevel; | ||||
| } | ||||
|
cin
|
r82 | warn(data: any): void; | ||
| warn(msg: string, ...args: any[]): void; | ||||
|
cin
|
r49 | warn(msg: string, ...args: any[]) { | ||
| if (this.isEnabled(WarnLevel)) | ||||
|
cin
|
r82 | this.emit(WarnLevel, msg, args); | ||
|
cin
|
r49 | } | ||
| /** | ||||
| * returns true if errors will be recorded. | ||||
| */ | ||||
| isErrorEnabled() { | ||||
| return this.level >= ErrorLevel; | ||||
| } | ||||
|
cin
|
r82 | /** Traces a error | ||
| * @param data The object which will be passed to the underlying listeners | ||||
| */ | ||||
| error(data: any): void; | ||||
|
cin
|
r49 | /** | ||
| * Traces a error. | ||||
|
cin
|
r53 | * | ||
|
cin
|
r49 | * @param msg the message. | ||
| * @param args parameters which will be substituted in the message. | ||||
| */ | ||||
|
cin
|
r82 | error(msg: string, ...args: any[]): void; | ||
|
cin
|
r49 | error(msg: string, ...args: any[]) { | ||
| if (this.isEnabled(ErrorLevel)) | ||||
|
cin
|
r82 | this.emit(ErrorLevel, msg, args); | ||
|
cin
|
r49 | } | ||
| /** | ||||
| * Checks whether the specified level is enabled for this | ||||
| * trace source. | ||||
|
cin
|
r53 | * | ||
|
cin
|
r49 | * @param level the trace level which should be checked. | ||
| */ | ||||
| isEnabled(level: number) { | ||||
| return (this.level >= level); | ||||
| } | ||||
| /** | ||||
| * Traces a raw event, passing data as it is to the underlying listeners | ||||
|
cin
|
r53 | * | ||
|
cin
|
r49 | * @param level the level of the event | ||
|
cin
|
r82 | * @param msg the data of the event, can be a simple string or any object. | ||
|
cin
|
r49 | */ | ||
|
cin
|
r82 | traceEvent(level: number, msg: any, ...args: any[]) { | ||
|
cin
|
r49 | if (this.isEnabled(level)) | ||
|
cin
|
r82 | this.emit(level, msg, args); | ||
|
cin
|
r49 | } | ||
| /** | ||||
| * Register the specified handler to be called for every new and already | ||||
| * created trace source. | ||||
|
cin
|
r53 | * | ||
|
cin
|
r49 | * @param handler the handler which will be called for each trace source | ||
| */ | ||||
| static on(handler: (source: TraceSource) => void) { | ||||
| return Registry.instance.on(handler); | ||||
| } | ||||
| /** | ||||
| * Creates or returns already created trace source for the specified id. | ||||
|
cin
|
r53 | * | ||
|
cin
|
r49 | * @param id the id for the trace source | ||
| */ | ||||
| static get(id: any) { | ||||
|
cin
|
r148 | if (!Registry.instance.has(id)) { | ||
| const trace = new TraceSource(id); | ||||
| Registry.instance.add(id, trace); | ||||
| return trace; | ||||
| } else { | ||||
| return Registry.instance.get(id); | ||||
| } | ||||
|
cin
|
r49 | } | ||
| } | ||||