backend-base/dist/Thread.js

"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
const logger_1 = require("./logger");
let currentThread = undefined;
async function thread(fn) {
    currentThread = {};
    await fn();
    currentThread = undefined;
}
exports.thread = thread;
function getCurrentThread() {
    if (currentThread === undefined)
        throw new Error('CurrentThread is undefined');
    return currentThread;
}
exports.getCurrentThread = getCurrentThread;
function threadPause(val) {
    currentThread = undefined;
    return val;
}
exports.threadPause = threadPause;
function threadContinue(thread, val) {
    currentThread = thread;
    return val;
}
exports.threadContinue = threadContinue;
function setDataToCurrentThread(key, val) {
    const thread = getCurrentThread();
    thread[key] = val;
}
exports.setDataToCurrentThread = setDataToCurrentThread;
function getDataFromCurrentThread(key) {
    const thread = getCurrentThread();
    return thread[key];
}
exports.getDataFromCurrentThread = getDataFromCurrentThread;
const callSymbol = Symbol('Call');
function getParentId() {
    const parentId = getDataFromCurrentThread(callSymbol);
    return parentId;
}
function enter(name) {
    const parentId = getParentId();
    const currentId = logger_1.logger.trace('call', { name, timestamp: Date.now() });
    setDataToCurrentThread(callSymbol, currentId);
    return parentId;
}
function exit(parentId, val) {
    setDataToCurrentThread(callSymbol, parentId);
    return val;
}
async function foo(_x) {
    const parentId = enter('foo');
    1 + 2;
    if (Math) {
        throw 1;
    }
    exit(parentId);
}
async function x() {
    const thread = getCurrentThread();
    const parentId = enter('x');
    try {
        const y = threadContinue(thread, await threadPause(foo(1)));
        return exit(parentId, y);
    }
    catch (e) { }
    return exit(parentId, 123);
}
thread(async () => {
    await x();
});
//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoiVGhyZWFkLmpzIiwic291cmNlUm9vdCI6IiIsInNvdXJjZXMiOlsiLi4vc3JjL1RocmVhZC50cyJdLCJuYW1lcyI6W10sIm1hcHBpbmdzIjoiOztBQUFBLHFDQUFrQztBQUlsQyxJQUFJLGFBQWEsR0FBdUIsU0FBUyxDQUFDO0FBQzNDLEtBQUssVUFBVSxNQUFNLENBQUMsRUFBdUI7SUFDbkQsYUFBYSxHQUFHLEVBQVksQ0FBQztJQUM3QixNQUFNLEVBQUUsRUFBRSxDQUFDO0lBQ1gsYUFBYSxHQUFHLFNBQVMsQ0FBQztBQUMzQixDQUFDO0FBSkQsd0JBSUM7QUFDRCxTQUFnQixnQkFBZ0I7SUFDL0IsSUFBSSxhQUFhLEtBQUssU0FBUztRQUFFLE1BQU0sSUFBSSxLQUFLLENBQUMsNEJBQTRCLENBQUMsQ0FBQztJQUMvRSxPQUFPLGFBQWEsQ0FBQztBQUN0QixDQUFDO0FBSEQsNENBR0M7QUFDRCxTQUFnQixXQUFXLENBQUksR0FBTTtJQUNwQyxhQUFhLEdBQUcsU0FBUyxDQUFDO0lBQzFCLE9BQU8sR0FBRyxDQUFDO0FBQ1osQ0FBQztBQUhELGtDQUdDO0FBQ0QsU0FBZ0IsY0FBYyxDQUFJLE1BQWMsRUFBRSxHQUFNO0lBQ3ZELGFBQWEsR0FBRyxNQUFNLENBQUM7SUFDdkIsT0FBTyxHQUFHLENBQUM7QUFDWixDQUFDO0FBSEQsd0NBR0M7QUFDRCxTQUFnQixzQkFBc0IsQ0FBQyxHQUFXLEVBQUUsR0FBWTtJQUMvRCxNQUFNLE1BQU0sR0FBRyxnQkFBZ0IsRUFBRSxDQUFDO0lBQ2xDLE1BQU0sQ0FBQyxHQUFZLENBQUMsR0FBRyxHQUFZLENBQUM7QUFDckMsQ0FBQztBQUhELHdEQUdDO0FBQ0QsU0FBZ0Isd0JBQXdCLENBQUksR0FBVztJQUN0RCxNQUFNLE1BQU0sR0FBRyxnQkFBZ0IsRUFBRSxDQUFDO0lBQ2xDLE9BQU8sTUFBTSxDQUFDLEdBQVksQ0FBa0IsQ0FBQztBQUM5QyxDQUFDO0FBSEQsNERBR0M7QUFFRCxNQUFNLFVBQVUsR0FBRyxNQUFNLENBQUMsTUFBTSxDQUFDLENBQUM7QUFFbEMsU0FBUyxXQUFXO0lBQ25CLE1BQU0sUUFBUSxHQUFHLHdCQUF3QixDQUFTLFVBQVUsQ0FBQyxDQUFDO0lBQzlELE9BQU8sUUFBUSxDQUFDO0FBQ2pCLENBQUM7QUFFRCxTQUFTLEtBQUssQ0FBQyxJQUFZO0lBQzFCLE1BQU0sUUFBUSxHQUFHLFdBQVcsRUFBRSxDQUFDO0lBQy9CLE1BQU0sU0FBUyxHQUFHLGVBQU0sQ0FBQyxLQUFLLENBQUMsTUFBTSxFQUFFLEVBQUUsSUFBSSxFQUFFLFNBQVMsRUFBRSxJQUFJLENBQUMsR0FBRyxFQUFFLEVBQUUsQ0FBQyxDQUFDO0lBQ3hFLHNCQUFzQixDQUFDLFVBQVUsRUFBRSxTQUFTLENBQUMsQ0FBQztJQUM5QyxPQUFPLFFBQVEsQ0FBQztBQUNqQixDQUFDO0FBRUQsU0FBUyxJQUFJLENBQUksUUFBNEIsRUFBRSxHQUFPO0lBQ3JELHNCQUFzQixDQUFDLFVBQVUsRUFBRSxRQUFRLENBQUMsQ0FBQztJQUM3QyxPQUFPLEdBQUcsQ0FBQztBQUNaLENBQUM7QUFDRCxLQUFLLFVBQVUsR0FBRyxDQUFDLEVBQVU7SUFDNUIsTUFBTSxRQUFRLEdBQUcsS0FBSyxDQUFDLEtBQUssQ0FBQyxDQUFDO0lBQzlCLENBQUMsR0FBRyxDQUFDLENBQUM7SUFDTixJQUFJLElBQUksRUFBRTtRQUNULE1BQU0sQ0FBQyxDQUFDO0tBQ1I7SUFDRCxJQUFJLENBQUMsUUFBUSxDQUFDLENBQUM7QUFDaEIsQ0FBQztBQUVELEtBQUssVUFBVSxDQUFDO0lBQ2YsTUFBTSxNQUFNLEdBQUcsZ0JBQWdCLEVBQUUsQ0FBQztJQUNsQyxNQUFNLFFBQVEsR0FBRyxLQUFLLENBQUMsR0FBRyxDQUFDLENBQUM7SUFDNUIsSUFBSTtRQUNILE1BQU0sQ0FBQyxHQUFHLGNBQWMsQ0FBQyxNQUFNLEVBQUUsTUFBTSxXQUFXLENBQUMsR0FBRyxDQUFDLENBQUMsQ0FBQyxDQUFDLENBQUMsQ0FBQztRQUM1RCxPQUFPLElBQUksQ0FBQyxRQUFRLEVBQUUsQ0FBQyxDQUFDLENBQUM7S0FDekI7SUFBQyxPQUFPLENBQUMsRUFBRSxHQUFFO0lBQ2QsT0FBTyxJQUFJLENBQUMsUUFBUSxFQUFFLEdBQUcsQ0FBQyxDQUFDO0FBQzVCLENBQUM7QUFDRCxNQUFNLENBQUMsS0FBSyxJQUFJLEVBQUU7SUFDakIsTUFBTSxDQUFDLEVBQUUsQ0FBQztBQUNYLENBQUMsQ0FBQyxDQUFDIn0=