875c7f9b91
- Add full Telegram bot functionality with Z.AI API integration
- Implement 4 tools: Bash, FileEdit, WebSearch, Git
- Add 3 agents: Code Reviewer, Architect, DevOps Engineer
- Add 6 skills for common coding tasks
- Add systemd service file for 24/7 operation
- Add nginx configuration for HTTPS webhook
- Add comprehensive documentation
- Implement WebSocket server for real-time updates
- Add logging system with Winston
- Add environment validation
🤖 zCode CLI X - Agentic coder with Z.AI + Telegram integration
106 lines
3.2 KiB
JavaScript
106 lines
3.2 KiB
JavaScript
"use strict";
|
|
/*
|
|
* Copyright The OpenTelemetry Authors
|
|
* SPDX-License-Identifier: Apache-2.0
|
|
*/
|
|
Object.defineProperty(exports, "__esModule", { value: true });
|
|
exports.AsyncHooksContextManager = void 0;
|
|
const api_1 = require("@opentelemetry/api");
|
|
const asyncHooks = require("async_hooks");
|
|
const AbstractAsyncHooksContextManager_1 = require("./AbstractAsyncHooksContextManager");
|
|
/**
|
|
* @deprecated Use AsyncLocalStorageContextManager instead.
|
|
*/
|
|
class AsyncHooksContextManager extends AbstractAsyncHooksContextManager_1.AbstractAsyncHooksContextManager {
|
|
_asyncHook;
|
|
_contexts = new Map();
|
|
_stack = [];
|
|
constructor() {
|
|
super();
|
|
this._asyncHook = asyncHooks.createHook({
|
|
init: this._init.bind(this),
|
|
before: this._before.bind(this),
|
|
after: this._after.bind(this),
|
|
destroy: this._destroy.bind(this),
|
|
promiseResolve: this._destroy.bind(this),
|
|
});
|
|
}
|
|
active() {
|
|
return this._stack[this._stack.length - 1] ?? api_1.ROOT_CONTEXT;
|
|
}
|
|
with(context, fn, thisArg, ...args) {
|
|
this._enterContext(context);
|
|
try {
|
|
return fn.call(thisArg, ...args);
|
|
}
|
|
finally {
|
|
this._exitContext();
|
|
}
|
|
}
|
|
enable() {
|
|
this._asyncHook.enable();
|
|
return this;
|
|
}
|
|
disable() {
|
|
this._asyncHook.disable();
|
|
this._contexts.clear();
|
|
this._stack = [];
|
|
return this;
|
|
}
|
|
/**
|
|
* Init hook will be called when userland create a async context, setting the
|
|
* context as the current one if it exist.
|
|
* @param uid id of the async context
|
|
* @param type the resource type
|
|
*/
|
|
_init(uid, type) {
|
|
// ignore TIMERWRAP as they combine timers with same timeout which can lead to
|
|
// false context propagation. TIMERWRAP has been removed in node 11
|
|
// every timer has it's own `Timeout` resource anyway which is used to propagate
|
|
// context.
|
|
if (type === 'TIMERWRAP')
|
|
return;
|
|
const context = this._stack[this._stack.length - 1];
|
|
if (context !== undefined) {
|
|
this._contexts.set(uid, context);
|
|
}
|
|
}
|
|
/**
|
|
* Destroy hook will be called when a given context is no longer used so we can
|
|
* remove its attached context.
|
|
* @param uid uid of the async context
|
|
*/
|
|
_destroy(uid) {
|
|
this._contexts.delete(uid);
|
|
}
|
|
/**
|
|
* Before hook is called just before executing a async context.
|
|
* @param uid uid of the async context
|
|
*/
|
|
_before(uid) {
|
|
const context = this._contexts.get(uid);
|
|
if (context !== undefined) {
|
|
this._enterContext(context);
|
|
}
|
|
}
|
|
/**
|
|
* After hook is called just after completing the execution of a async context.
|
|
*/
|
|
_after() {
|
|
this._exitContext();
|
|
}
|
|
/**
|
|
* Set the given context as active
|
|
*/
|
|
_enterContext(context) {
|
|
this._stack.push(context);
|
|
}
|
|
/**
|
|
* Remove the context at the root of the stack
|
|
*/
|
|
_exitContext() {
|
|
this._stack.pop();
|
|
}
|
|
}
|
|
exports.AsyncHooksContextManager = AsyncHooksContextManager;
|
|
//# sourceMappingURL=AsyncHooksContextManager.js.map
|