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
94 lines
4.3 KiB
JavaScript
94 lines
4.3 KiB
JavaScript
/*
|
|
* Copyright The OpenTelemetry Authors
|
|
*
|
|
* 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
|
|
*
|
|
* https://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 { baggageUtils } from '@opentelemetry/core';
|
|
import { diag } from '@opentelemetry/api';
|
|
import { getSharedConfigurationFromEnvironment } from './shared-env-configuration';
|
|
import { wrapStaticHeadersInFunction } from './shared-configuration';
|
|
function getStaticHeadersFromEnv(signalIdentifier) {
|
|
var _a, _b;
|
|
const signalSpecificRawHeaders = (_a = process.env[`OTEL_EXPORTER_OTLP_${signalIdentifier}_HEADERS`]) === null || _a === void 0 ? void 0 : _a.trim();
|
|
const nonSignalSpecificRawHeaders = (_b = process.env['OTEL_EXPORTER_OTLP_HEADERS']) === null || _b === void 0 ? void 0 : _b.trim();
|
|
const signalSpecificHeaders = baggageUtils.parseKeyPairsIntoRecord(signalSpecificRawHeaders);
|
|
const nonSignalSpecificHeaders = baggageUtils.parseKeyPairsIntoRecord(nonSignalSpecificRawHeaders);
|
|
if (Object.keys(signalSpecificHeaders).length === 0 &&
|
|
Object.keys(nonSignalSpecificHeaders).length === 0) {
|
|
return undefined;
|
|
}
|
|
// headers are combined instead of overwritten, with the specific headers taking precedence over
|
|
// the non-specific ones.
|
|
return Object.assign({}, baggageUtils.parseKeyPairsIntoRecord(nonSignalSpecificRawHeaders), baggageUtils.parseKeyPairsIntoRecord(signalSpecificRawHeaders));
|
|
}
|
|
function appendRootPathToUrlIfNeeded(url) {
|
|
try {
|
|
const parsedUrl = new URL(url);
|
|
// This will automatically append '/' if there's no root path.
|
|
return parsedUrl.toString();
|
|
}
|
|
catch (_a) {
|
|
diag.warn(`Configuration: Could not parse environment-provided export URL: '${url}', falling back to undefined`);
|
|
return undefined;
|
|
}
|
|
}
|
|
function appendResourcePathToUrl(url, path) {
|
|
try {
|
|
// just try to parse, if it fails we catch and warn.
|
|
new URL(url);
|
|
}
|
|
catch (_a) {
|
|
diag.warn(`Configuration: Could not parse environment-provided export URL: '${url}', falling back to undefined`);
|
|
return undefined;
|
|
}
|
|
if (!url.endsWith('/')) {
|
|
url = url + '/';
|
|
}
|
|
url += path;
|
|
try {
|
|
// just try to parse, if it fails we catch and warn.
|
|
new URL(url);
|
|
}
|
|
catch (_b) {
|
|
diag.warn(`Configuration: Provided URL appended with '${path}' is not a valid URL, using 'undefined' instead of '${url}'`);
|
|
return undefined;
|
|
}
|
|
return url;
|
|
}
|
|
function getNonSpecificUrlFromEnv(signalResourcePath) {
|
|
var _a;
|
|
const envUrl = (_a = process.env.OTEL_EXPORTER_OTLP_ENDPOINT) === null || _a === void 0 ? void 0 : _a.trim();
|
|
if (envUrl == null || envUrl === '') {
|
|
return undefined;
|
|
}
|
|
return appendResourcePathToUrl(envUrl, signalResourcePath);
|
|
}
|
|
function getSpecificUrlFromEnv(signalIdentifier) {
|
|
var _a;
|
|
const envUrl = (_a = process.env[`OTEL_EXPORTER_OTLP_${signalIdentifier}_ENDPOINT`]) === null || _a === void 0 ? void 0 : _a.trim();
|
|
if (envUrl == null || envUrl === '') {
|
|
return undefined;
|
|
}
|
|
return appendRootPathToUrlIfNeeded(envUrl);
|
|
}
|
|
/**
|
|
* Reads and returns configuration from the environment
|
|
*
|
|
* @param signalIdentifier all caps part in environment variables that identifies the signal (e.g.: METRICS, TRACES, LOGS)
|
|
* @param signalResourcePath signal resource path to append if necessary (e.g.: v1/metrics, v1/traces, v1/logs)
|
|
*/
|
|
export function getHttpConfigurationFromEnvironment(signalIdentifier, signalResourcePath) {
|
|
var _a;
|
|
return Object.assign(Object.assign({}, getSharedConfigurationFromEnvironment(signalIdentifier)), { url: (_a = getSpecificUrlFromEnv(signalIdentifier)) !== null && _a !== void 0 ? _a : getNonSpecificUrlFromEnv(signalResourcePath), headers: wrapStaticHeadersInFunction(getStaticHeadersFromEnv(signalIdentifier)) });
|
|
}
|
|
//# sourceMappingURL=otlp-http-env-configuration.js.map
|