github/oneuptime
1
1
Fork 0
mirror of https://github.com/OneUptime/oneuptime.git synced 2026-04-06 00:32:12 +02:00
Code Issues 193 Packages Projects Releases Wiki Activity

refactor: enhance protobuf handling in OpenTelemetryRequestMiddleware

Browse Source
This commit is contained in:
Nawaz Dhandala
2026-03-05 16:17:10 +00:00
parent ac94cd5fae
commit 2e07165c27
1 changed files with 10 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
Telemetry/Middleware/OtelRequestMiddleware.ts
View File

@@ -40,22 +40,31 @@ export default class OpenTelemetryRequestMiddleware {
try {
let productType: ProductType;
const isProtobuf: boolean = req.body instanceof Uint8Array;
const contentType: string | undefined = req.headers["content-type"];
const isProtobuf: boolean =
req.body instanceof Uint8Array &&
(!contentType || contentType.includes("application/x-protobuf") || contentType.includes("application/protobuf"));
if (req.url.includes("/otlp/v1/traces")) {
if (isProtobuf) {
req.body = TracesData.decode(req.body);
} else if (req.body instanceof Uint8Array) {
req.body = JSON.parse(req.body.toString("utf-8"));
}
productType = ProductType.Traces;
} else if (req.url.includes("/otlp/v1/logs")) {
if (isProtobuf) {
req.body = LogsData.decode(req.body);
} else if (req.body instanceof Uint8Array) {
req.body = JSON.parse(req.body.toString("utf-8"));
}
productType = ProductType.Logs;
} else if (req.url.includes("/otlp/v1/metrics")) {
if (isProtobuf) {
req.body = MetricsData.decode(req.body);
} else if (req.body instanceof Uint8Array) {
req.body = JSON.parse(req.body.toString("utf-8"));
}
productType = ProductType.Metrics;
} else {