summaryrefslogtreecommitdiffhomepage
path: root/packages/cloud/function/src/log-processor.ts
diff options
context:
space:
mode:
Diffstat (limited to 'packages/cloud/function/src/log-processor.ts')
-rw-r--r--packages/cloud/function/src/log-processor.ts49
1 files changed, 0 insertions, 49 deletions
diff --git a/packages/cloud/function/src/log-processor.ts b/packages/cloud/function/src/log-processor.ts
deleted file mode 100644
index 70fcf5a44..000000000
--- a/packages/cloud/function/src/log-processor.ts
+++ /dev/null
@@ -1,49 +0,0 @@
-import { Resource } from "@opencode/cloud-resource"
-import type { TraceItem } from "@cloudflare/workers-types"
-
-export default {
- async tail(events: TraceItem[]) {
- for (const event of events) {
- if (!event.event) continue
- if (!("request" in event.event)) continue
- if (event.event.request.method !== "POST") continue
-
- const url = new URL(event.event.request.url)
- if (url.pathname !== "/zen/v1/chat/completions") return
-
- let metrics = {
- event_type: "completions",
- "cf.continent": event.event.request.cf?.continent,
- "cf.country": event.event.request.cf?.country,
- "cf.city": event.event.request.cf?.city,
- "cf.region": event.event.request.cf?.region,
- "cf.latitude": event.event.request.cf?.latitude,
- "cf.longitude": event.event.request.cf?.longitude,
- "cf.timezone": event.event.request.cf?.timezone,
- duration: event.wallTime,
- request_length: parseInt(event.event.request.headers["content-length"] ?? "0"),
- status: event.event.response?.status ?? 0,
- ip: event.event.request.headers["x-real-ip"],
- }
- for (const log of event.logs) {
- for (const message of log.message) {
- if (!message.startsWith("_metric:")) continue
- metrics = { ...metrics, ...JSON.parse(message.slice(8)) }
- }
- }
- console.log(JSON.stringify(metrics, null, 2))
-
- const ret = await fetch("https://api.honeycomb.io/1/events/zen", {
- method: "POST",
- headers: {
- "Content-Type": "application/json",
- "X-Honeycomb-Event-Time": (event.eventTimestamp ?? Date.now()).toString(),
- "X-Honeycomb-Team": Resource.HONEYCOMB_API_KEY.value,
- },
- body: JSON.stringify(metrics),
- })
- console.log(ret.status)
- console.log(await ret.text())
- }
- },
-}