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
95 lines
3.0 KiB
JavaScript
95 lines
3.0 KiB
JavaScript
/*
|
|
* Copyright The OpenTelemetry Authors
|
|
* SPDX-License-Identifier: Apache-2.0
|
|
*/
|
|
/**
|
|
* Converting the unordered attributes into unique identifier string.
|
|
* @param attributes user provided unordered Attributes.
|
|
*/
|
|
export function hashAttributes(attributes) {
|
|
let keys = Object.keys(attributes);
|
|
if (keys.length === 0)
|
|
return '';
|
|
// Return a string that is stable on key orders.
|
|
keys = keys.sort();
|
|
return JSON.stringify(keys.map(key => [key, attributes[key]]));
|
|
}
|
|
/**
|
|
* Converting the instrumentation scope object to a unique identifier string.
|
|
* @param instrumentationScope
|
|
*/
|
|
export function instrumentationScopeId(instrumentationScope) {
|
|
return `${instrumentationScope.name}:${instrumentationScope.version ?? ''}:${instrumentationScope.schemaUrl ?? ''}`;
|
|
}
|
|
/**
|
|
* Error that is thrown on timeouts.
|
|
*/
|
|
export class TimeoutError extends Error {
|
|
constructor(message) {
|
|
super(message);
|
|
// manually adjust prototype to retain `instanceof` functionality when targeting ES5, see:
|
|
// https://github.com/Microsoft/TypeScript-wiki/blob/main/Breaking-Changes.md#extending-built-ins-like-error-array-and-map-may-no-longer-work
|
|
Object.setPrototypeOf(this, TimeoutError.prototype);
|
|
}
|
|
}
|
|
/**
|
|
* Adds a timeout to a promise and rejects if the specified timeout has elapsed. Also rejects if the specified promise
|
|
* rejects, and resolves if the specified promise resolves.
|
|
*
|
|
* <p> NOTE: this operation will continue even after it throws a {@link TimeoutError}.
|
|
*
|
|
* @param promise promise to use with timeout.
|
|
* @param timeout the timeout in milliseconds until the returned promise is rejected.
|
|
*/
|
|
export function callWithTimeout(promise, timeout) {
|
|
let timeoutHandle;
|
|
const timeoutPromise = new Promise(function timeoutFunction(_resolve, reject) {
|
|
timeoutHandle = setTimeout(function timeoutHandler() {
|
|
reject(new TimeoutError('Operation timed out.'));
|
|
}, timeout);
|
|
});
|
|
return Promise.race([promise, timeoutPromise]).then(result => {
|
|
clearTimeout(timeoutHandle);
|
|
return result;
|
|
}, reason => {
|
|
clearTimeout(timeoutHandle);
|
|
throw reason;
|
|
});
|
|
}
|
|
export function setEquals(lhs, rhs) {
|
|
if (lhs.size !== rhs.size) {
|
|
return false;
|
|
}
|
|
for (const item of lhs) {
|
|
if (!rhs.has(item)) {
|
|
return false;
|
|
}
|
|
}
|
|
return true;
|
|
}
|
|
/**
|
|
* Binary search the sorted array to the find upper bound for the value.
|
|
* @param arr
|
|
* @param value
|
|
* @returns
|
|
*/
|
|
export function binarySearchUB(arr, value) {
|
|
let lo = 0;
|
|
let hi = arr.length - 1;
|
|
let ret = arr.length;
|
|
while (hi >= lo) {
|
|
const mid = lo + Math.trunc((hi - lo) / 2);
|
|
if (arr[mid] < value) {
|
|
lo = mid + 1;
|
|
}
|
|
else {
|
|
ret = mid;
|
|
hi = mid - 1;
|
|
}
|
|
}
|
|
return ret;
|
|
}
|
|
export function equalsCaseInsensitive(lhs, rhs) {
|
|
return lhs.toLowerCase() === rhs.toLowerCase();
|
|
}
|
|
//# sourceMappingURL=utils.js.map
|