72 lines
2.0 KiB
TypeScript

/**
* Copyright (c) Microsoft Corporation.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
import { captureRawStack } from './stackTrace';
class ZoneManager {
lastZoneId = 0;
readonly _zones = new Map<number, Zone>();
constructor() {
}
async run<T, R>(type: string, data: T, func: () => Promise<R>): Promise<R> {
const zone = new Zone(this, ++this.lastZoneId, type, data);
this._zones.set(zone.id, zone);
return zone.run(func);
}
zoneData<T>(type: string, rawStack?: string): T | null {
const stack = rawStack || captureRawStack();
for (const line of stack.split('\n')) {
const index = line.indexOf('__PWZONE__[');
if (index !== -1) {
const zoneId = + line.substring(index + '__PWZONE__['.length, line.indexOf(']', index));
const zone = this._zones.get(zoneId);
if (zone && zone.type === type)
return zone.data;
}
}
return null;
}
}
class Zone {
private _manager: ZoneManager;
readonly id: number;
readonly type: string;
readonly data: any = {};
constructor(manager: ZoneManager, id: number, type: string, data: any) {
this._manager = manager;
this.id = id;
this.type = type;
this.data = data;
}
async run<R>(func: () => Promise<R>): Promise<R> {
Object.defineProperty(func, 'name', { value: `__PWZONE__[${this.id}]` });
try {
return await func();
} finally {
this._manager._zones.delete(this.id);
}
}
}
export const zones = new ZoneManager();