feat(tracer-context): 添加scope方法以支持追踪异步错误
新增scope方法用于包裹异步或同步代码块,自动捕获错误并记录到上下文中。同时将dump方法重命名为flush以更准确描述其行为(清空并输出指令序列)。重构内部数据结构,将commands和error统一管理在scopeResult对象中。
This commit is contained in:
@@ -1,35 +1,74 @@
|
|||||||
import type { TracerCommand } from '../types';
|
import type { TracerCommand } from '../types';
|
||||||
|
|
||||||
const createTracerContext = () => {
|
type Error = {
|
||||||
const commands: TracerCommand[] = [];
|
stack?: string;
|
||||||
|
};
|
||||||
|
|
||||||
// if (typeof process !== 'undefined' && typeof process.on === 'function') {
|
type ScopeResult = {
|
||||||
// process.on('exit', () => {
|
// 记录指令序列
|
||||||
// if (commands.length > 0) {
|
commands: TracerCommand[];
|
||||||
// console.log(commands);
|
// 记录错误信息
|
||||||
// }
|
error: Error;
|
||||||
// });
|
// 检查是否多次调用scope
|
||||||
// }
|
scoping: boolean;
|
||||||
|
};
|
||||||
|
|
||||||
|
const createTracerContext = () => {
|
||||||
|
const scopeResult: ScopeResult = {
|
||||||
|
commands: [],
|
||||||
|
error: {},
|
||||||
|
scoping: false,
|
||||||
|
};
|
||||||
|
|
||||||
|
const command = (command: TracerCommand) => {
|
||||||
|
scopeResult.commands.push(command);
|
||||||
|
};
|
||||||
|
|
||||||
|
// TODO: 输出指令序列和错误信息
|
||||||
|
const flush = () => {
|
||||||
|
console.log('输出指令序列');
|
||||||
|
const { commands, error } = scopeResult;
|
||||||
|
console.log(JSON.stringify({ commands, error }, null, 2));
|
||||||
|
scopeResult.commands.length = 0;
|
||||||
|
scopeResult.error.stack = undefined;
|
||||||
|
};
|
||||||
|
|
||||||
const getTracerContext = () => {
|
const getTracerContext = () => {
|
||||||
const command = (command: TracerCommand) => {
|
|
||||||
commands.push(command);
|
|
||||||
};
|
|
||||||
|
|
||||||
// TODO: 输出指令序列
|
|
||||||
const dump = () => {
|
|
||||||
return commands;
|
|
||||||
};
|
|
||||||
|
|
||||||
return {
|
return {
|
||||||
command,
|
command,
|
||||||
dump,
|
flush,
|
||||||
};
|
};
|
||||||
};
|
};
|
||||||
|
|
||||||
|
const scope = (routine: () => void | PromiseLike<void>) => {
|
||||||
|
if (scopeResult.scoping) {
|
||||||
|
throw new Error('[TracerContext] Detect multiple scope.');
|
||||||
|
}
|
||||||
|
scopeResult.scoping = true;
|
||||||
|
// 如果routine是同步函数,那可能会抛出同步错误,所以需要用try-catch包裹
|
||||||
|
try {
|
||||||
|
const promise = Promise.resolve(routine());
|
||||||
|
promise
|
||||||
|
.catch((err) => {
|
||||||
|
console.log('异步错误');
|
||||||
|
console.error(err);
|
||||||
|
scopeResult.error.stack = (err as Error).stack;
|
||||||
|
})
|
||||||
|
.finally(() => {
|
||||||
|
flush();
|
||||||
|
});
|
||||||
|
} catch (err) {
|
||||||
|
console.log('同步错误');
|
||||||
|
console.error(err);
|
||||||
|
scopeResult.error.stack = (err as Error).stack;
|
||||||
|
flush();
|
||||||
|
}
|
||||||
|
};
|
||||||
|
|
||||||
return {
|
return {
|
||||||
getTracerContext,
|
getTracerContext,
|
||||||
|
scope,
|
||||||
};
|
};
|
||||||
};
|
};
|
||||||
|
|
||||||
export const { getTracerContext } = createTracerContext();
|
export const { getTracerContext, scope } = createTracerContext();
|
||||||
|
|||||||
Reference in New Issue
Block a user