[{"_1":2,"_360":-5,"_361":-5},"loaderData",{"_3":4,"_91":92,"_347":348,"_359":-5},"root",{"_5":6,"_32":33,"_58":59,"_89":90},"ctx",{"_7":8,"_18":19,"_20":-5,"_21":22,"_23":24,"_25":26,"_27":26,"_28":29,"_30":31},"auth",{"_9":-5,"_10":-5,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5},"sessionClaims","sessionId","userId","actor","orgId","orgRole","orgSlug","orgPermissions","factorVerificationAge","environmentVariableKeys",[],"user","preferences_keybindings","default","preferences_theme","light","preferences_fixers",false,"preferences_copilot","preferences_model","claude-3-5-haiku-20241022","notification_count",0,"ENV",{"_34":35,"_36":37,"_38":39,"_40":41,"_42":43,"_44":45,"_46":47,"_48":49,"_50":51,"_52":53,"_54":55,"_56":57},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","VAL_RUNTIME_NAME","prod","RENDER_GIT_COMMIT","fa80b67e1f763bfb4b247c3f5ca4f0b0730f3f5c","RENDER_GIT_BRANCH","main","CLERK_PUBLISHABLE_KEY","pk_live_Y2xlcmsudmFsLnRvd24k","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","API_URL","https://api.val.town","WORKER_FINGERPRINT","799d99f2805306c2714a7cfefbeae178","clerkState",{"_60":61},"__internal_clerk_state",{"_62":63,"_64":43,"_65":66,"_67":66,"_68":26,"_69":66,"_70":66,"_71":66,"_72":66,"_73":66,"_74":66,"_75":66,"_76":66,"_77":78,"_87":26,"_88":26},"__clerk_ssr_state",{"_9":-5,"_10":-5,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5},"__publishableKey","__proxyUrl","","__domain","__isSatellite","__signInUrl","__signUpUrl","__afterSignInUrl","__afterSignUpUrl","__signInForceRedirectUrl","__signUpForceRedirectUrl","__signInFallbackRedirectUrl","__signUpFallbackRedirectUrl","__clerk_debug",{"_79":26,"_80":66,"_81":82,"_83":66,"_84":43,"_85":26,"_86":66},"isSignedIn","proxyUrl","reason","session-token-and-uat-missing","message","publishableKey","isSatellite","domain","__telemetryDisabled","__telemetryDebug","remixVersion",2,"routes/_app.v.$handle.$name",{"_93":94,"_95":96,"_94":97,"_342":-5,"_343":-5,"_344":345,"_130":131,"_138":139,"_100":101,"_98":99,"_118":-7,"_50":51,"_346":26},"type","val","author","2e4c600e-54f8-4143-aaf8-90b0837c05d4",{"_98":99,"_95":96,"_100":101,"_102":-5,"_103":-5,"_104":105,"_106":107,"_108":109,"_110":111,"_112":26,"_113":111,"_114":115,"_116":117,"_118":119,"_120":26,"_121":122,"_123":31,"_124":31,"_125":122,"_126":31,"_127":31,"_128":-5,"_20":129,"_134":-5,"_135":-7,"_136":137,"_138":139,"_140":141},"name","VOTelCollector","valNameId","bd9f6d6a-e9cc-11ef-a85b-e6cdfca9ef9f","parentFolderId","isOwned","privacy","public","readme","This is a WIP proof of concept for setting up an OTel collector for traces emitted by @fiberplane/hono-otel\n\nOpenSource Tracing on ValTown backed by sqlite! Woo! WOOOOOOO!","valType","http","currentVersion","96444226-e9dc-11ef-aaf8-e6cdfca9ef9f","legacyPrivate","id","code","import {\n type OtelSpan,\n OtelSpanSchema,\n type TraceDetailSpansResponse,\n type TraceListResponse,\n} from \"https://esm.sh/@fiberplane/fpx-types@0.0.13\";\nimport { createFiberplane } from \"https://esm.sh/@fiberplane/hono@0.4.1\";\nimport type {\n ESpanKind,\n EStatusCode,\n IAnyValue,\n IEvent,\n IExportTraceServiceRequest,\n IKeyValue,\n ILink,\n IStatus,\n} from \"https://esm.sh/@opentelemetry/otlp-transformer@0.55.0\";\nimport { and, desc, relations, sql } from \"https://esm.sh/drizzle-orm@0.39.3\";\nimport { drizzle, type LibSQLDatabase } from \"https://esm.sh/drizzle-orm@0.39.3/libsql\";\nimport { integer, sqliteTable, text } from \"https://esm.sh/drizzle-orm@0.39.3/sqlite-core\";\nimport { Hono } from \"https://esm.sh/hono@4.7.0\";\nimport { cors } from \"https://esm.sh/hono@4.7.0/cors\";\nimport { sqlite } from \"https://esm.town/v/std/sqlite\";\nimport { randomBytes } from \"node:crypto\";\n\n/******************************************************************\n * Database and Drizzle setup\n * ****************************************************************/\n\nconst otelSpans = sqliteTable(\"otel_spans\", {\n inner: text(\"inner\", { mode: \"json\" }).$type().notNull(),\n spanId: text(\"span_id\").notNull(),\n traceId: text(\"trace_id\").notNull(),\n});\n\nconst schema = { otelSpans };\n\n// TODO - Use valtowns suggested way of handling migrations\n// (remember to remove \"IF NOT EXISTS\")\n// https://docs.val.town/std/sqlite/migrations/\nconst migrateDatabase = async () => {\n await sqlite.execute(`\nCREATE TABLE IF NOT EXISTS \\`otel_spans\\` (\n \\`inner\\` text NOT NULL,\n\t\\`span_id\\` text NOT NULL,\n\t\\`trace_id\\` text NOT NULL\n);\n`);\n};\n\n// HACK - Migrate database on startup\nawait migrateDatabase();\n\n/******************************************************************\n * API for receiving / returning traces from @fiberplane/hono-otel\n * ****************************************************************/\n\ntype AppType = {\n Bindings: {\n // TODO - Add secrets here\n };\n Variables: {\n db: LibSQLDatabase;\n };\n};\n\nconst app = new Hono();\n\n/**\n * Middleware for setting up the database\n * and storing it on the Hono app's context\n */\napp.use(async (ctx, next) => {\n const db = drizzle(sqlite as any, {\n schema,\n });\n ctx.set(\"db\", db);\n await next();\n});\n\napp.get(\"/\", async ctx => {\n return ctx.text(\"Hello, VOTel!\");\n});\n\napp.get(\"/v1/traces\", async ctx => {\n const db = ctx.get(\"db\");\n\n const spans = await db.query.otelSpans.findMany({\n where: sql`inner->>'scope_name' = 'fpx-tracer'`,\n orderBy: desc(sql`inner->>'end_time'`),\n limit: 1000,\n });\n\n const traceMap = new Map>();\n for (const span of spans) {\n const traceId = span.inner.trace_id;\n if (!traceId) {\n continue;\n }\n if (!traceMap.has(traceId)) {\n traceMap.set(traceId, []);\n }\n traceMap.get(traceId)?.push(span);\n }\n\n const traces = Array.from(traceMap.entries()).map(([traceId, spans]) => ({\n traceId,\n spans,\n }));\n\n const response: TraceListResponse = traces.map(({ traceId, spans }) => ({\n traceId,\n spans: spans.map(({ inner }) => OtelSpanSchema.parse(inner)),\n }));\n\n return ctx.json(response);\n});\n\napp.get(\"/v1/traces/:traceId/spans\", async ctx => {\n const traceId = ctx.req.param(\"traceId\");\n\n const db = ctx.get(\"db\");\n const traces = await db\n .select()\n .from(otelSpans)\n .where(\n and(\n sql`inner->>'scope_name' = 'fpx-tracer'`,\n sql`inner->>'trace_id' = ${traceId}`,\n ),\n );\n\n const response: TraceDetailSpansResponse = traces.map(({ inner }) => OtelSpanSchema.parse(inner));\n\n return ctx.json(response);\n});\n\n/**\n * Expects a JSON payload from @fiberplane/hono-otel\n */\napp.post(\"/v1/traces\", async (ctx) => {\n const db = ctx.get(\"db\");\n const body: IExportTraceServiceRequest = await ctx.req.json();\n\n // TODO - set up auth headers\n // TODO - optionally forward to a Fiberplane service\n const headers = {};\n // const headers: Record = fpxWorker.bearerToken\n // ? { Authorization: `Bearer ${fpxWorker.bearerToken}` }\n // : {};\n\n try {\n const tracesPayload = (await fromCollectorRequest(body)).map(\n (span) =>\n ({\n inner: OtelSpanSchema.parse(span),\n spanId: span.span_id,\n traceId: span.trace_id,\n }) satisfies typeof otelSpans.$inferInsert,\n );\n\n try {\n if (tracesPayload.length > 0) {\n await db.insert(otelSpans).values(tracesPayload);\n }\n } catch (error) {\n logger.error(\"Error inserting trace\", error);\n return ctx.text(\"Error inserting trace\", 500);\n }\n\n return ctx.text(\"OK\");\n } catch (error) {\n logger.error(\"Error parsing trace data\", error);\n return ctx.text(\"Error parsing trace data\", 400);\n }\n});\n\napp.use(\n \"/fp/*\",\n createFiberplane({\n openapi: { content: JSON.stringify(getOpenAPISpec()) },\n apiKey: \"123\",\n fpxEndpoint: Deno.env.get(\"FPX_ENDPOINT\"),\n }),\n);\n\nexport default app.fetch;\n\n/***************************************************************\n * Helpers\n ****************************************************************/\n\n/**\n * HACK - To be able to use the Fiberplane library with an OpenAPI spec\n */\nfunction getOpenAPISpec() {\n return {\n openapi: \"3.0.0\",\n info: {\n title: \"VOTel\",\n version: \"1.0.0\",\n },\n paths: {\n \"/v1/traces\": {\n post: {\n summary: \"Export traces\",\n description: \"Export traces\",\n requestBody: {\n required: true,\n content: {\n \"application/json\": {\n schema: {\n /* any, for simplicity */\n type: \"object\",\n additionalProperties: true,\n },\n // This is what SHOULD allow us to easily send\n // an example payload in the Fiberplane UI,\n // but that doesn't work right now bc there is not a valid schema definition\n example: getExampleTracePayload(),\n },\n },\n },\n responses: {\n 200: {\n description: \"OK\",\n },\n },\n },\n get: {\n summary: \"Get traces\",\n description: \"Get traces\",\n responses: {\n 200: {\n description: \"OK\",\n },\n },\n },\n },\n \"/v1/traces/{traceId}/spans\": {\n get: {\n summary: \"Get spans\",\n description: \"Get spans\",\n responses: {\n 200: {\n description: \"OK\",\n },\n },\n },\n },\n },\n };\n}\n\nfunction getExampleTracePayload() {\n return {\n \"resourceSpans\": [\n {\n \"resource\": {\n \"attributes\": [\n {\n \"key\": \"service.name\",\n \"value\": {\n \"stringValue\": \"unknown\",\n },\n },\n {\n \"key\": \"telemetry.sdk.language\",\n \"value\": {\n \"stringValue\": \"webjs\",\n },\n },\n {\n \"key\": \"telemetry.sdk.name\",\n \"value\": {\n \"stringValue\": \"opentelemetry\",\n },\n },\n {\n \"key\": \"telemetry.sdk.version\",\n \"value\": {\n \"stringValue\": \"1.28.0\",\n },\n },\n ],\n \"droppedAttributesCount\": 0,\n },\n \"scopeSpans\": [\n {\n \"scope\": {\n \"name\": \"fpx-tracer\",\n },\n \"spans\": [\n {\n \"traceId\": \"97dde7f861b4284fb670c439f9050f97\",\n \"spanId\": \"df9353752a11e3a2\",\n \"parentSpanId\": \"009c3ccc4058dc69\",\n \"name\": \"request\",\n \"kind\": 2,\n \"startTimeUnixNano\": \"1739429184265000000\",\n \"endTimeUnixNano\": \"1739429184266000000\",\n \"attributes\": [\n {\n \"key\": \"http.request.method\",\n \"value\": {\n \"stringValue\": \"GET\",\n },\n },\n {\n \"key\": \"url.full\",\n \"value\": {\n \"stringValue\": \"http://localhost:8787/\",\n },\n },\n {\n \"key\": \"fpx.http.request.pathname\",\n \"value\": {\n \"stringValue\": \"/\",\n },\n },\n {\n \"key\": \"fpx.http.request.search\",\n \"value\": {\n \"stringValue\": \"\",\n },\n },\n {\n \"key\": \"fpx.http.request.scheme\",\n \"value\": {\n \"stringValue\": \"http\",\n },\n },\n {\n \"key\": \"fpx.http.request.env\",\n \"value\": {\n \"stringValue\":\n \"{\\\"OPENAI_API_KEY\\\":\\\"sk-proj-uoRQ71Oaz16IbDJRJXY5T3BlbkFJgqSSf3Xglg0V0V2FhFrO\\\",\\\"ANTHROPIC_API_KEY\\\":\\\"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\\\",\\\"DATABASE_URL\\\":\\\"postgresql://neondb_owner:XaenL6g5WApI@ep-proud-grass-a5r8g74c.us-east-2.aws.neon.tech/neondb?sslmode=require\\\",\\\"FPX_ENDPOINT\\\":\\\"http://localhost:8788/v1/traces\\\",\\\"FPX_LOG_LEVEL\\\":\\\"debug\\\",\\\"GOOSE_AVATARS\\\":{}}\",\n },\n },\n {\n \"key\": \"http.request.header.accept\",\n \"value\": {\n \"stringValue\": \"*/*\",\n },\n },\n {\n \"key\": \"http.request.header.accept-encoding\",\n \"value\": {\n \"stringValue\": \"br, gzip\",\n },\n },\n {\n \"key\": \"http.request.header.accept-language\",\n \"value\": {\n \"stringValue\": \"*\",\n },\n },\n {\n \"key\": \"http.request.header.host\",\n \"value\": {\n \"stringValue\": \"localhost:8787\",\n },\n },\n {\n \"key\": \"http.request.header.sec-fetch-mode\",\n \"value\": {\n \"stringValue\": \"cors\",\n },\n },\n {\n \"key\": \"http.request.header.user-agent\",\n \"value\": {\n \"stringValue\": \"node\",\n },\n },\n {\n \"key\": \"http.request.header.x-fpx-trace-id\",\n \"value\": {\n \"stringValue\": \"97dde7f861b4284fb670c439f9050f97\",\n },\n },\n {\n \"key\": \"http.response.status_code\",\n \"value\": {\n \"stringValue\": \"200\",\n },\n },\n {\n \"key\": \"http.scheme\",\n \"value\": {\n \"stringValue\": \"\",\n },\n },\n {\n \"key\": \"fpx.http.response.body\",\n \"value\": {\n \"stringValue\": \"Hello Goose Quotes!\",\n },\n },\n {\n \"key\": \"http.response.header.content-type\",\n \"value\": {\n \"stringValue\": \"text/plain;charset=UTF-8\",\n },\n },\n ],\n \"droppedAttributesCount\": 0,\n \"events\": [\n {\n \"attributes\": [\n {\n \"key\": \"message\",\n \"value\": {\n \"stringValue\": \"\\\"Home page accessed. Honk: \\\"\",\n },\n },\n {\n \"key\": \"messageType\",\n \"value\": {\n \"stringValue\": \"string\",\n },\n },\n {\n \"key\": \"level\",\n \"value\": {\n \"stringValue\": \"info\",\n },\n },\n {\n \"key\": \"arguments\",\n \"value\": {\n \"stringValue\": \"[]\",\n },\n },\n ],\n \"name\": \"log\",\n \"timeUnixNano\": \"1739429184265000000\",\n \"droppedAttributesCount\": 0,\n },\n {\n \"attributes\": [],\n \"name\": \"first-response\",\n \"timeUnixNano\": \"1739429184265000000\",\n \"droppedAttributesCount\": 0,\n },\n ],\n \"droppedEventsCount\": 0,\n \"status\": {\n \"code\": 1,\n },\n \"links\": [],\n \"droppedLinksCount\": 0,\n },\n ],\n },\n ],\n },\n ],\n };\n}\n\n/**\n * Logging interface, v simple\n */\nfunction logger() {\n return {\n info: console.log.bind(console),\n warn: console.warn.bind(console),\n error: console.error.bind(console),\n };\n}\n\n/**\n * Port of the Fiberplane rust code that massages traces into the format we use in the Fiberplane UI.\n *\n * A few differences:\n *\n * - The otel js library does not expose `traceFlags` or `flags` from what I can tell,\n * so that field is always blank.\n *\n * - `mapAttributes` simply returns the value, instead of an object whose key describes the attribute data type.\n * By convention, we only use string and number values. Complex values are serialized.\n */\nasync function fromCollectorRequest(\n tracesData: IExportTraceServiceRequest,\n): Promise> {\n const result: Array = [];\n\n for (const resourceSpan of tracesData.resourceSpans ?? []) {\n const resourceAttributes = resourceSpan.resource\n ? await mapAttributes(resourceSpan.resource.attributes)\n : null;\n\n for (const scopeSpan of resourceSpan.scopeSpans ?? []) {\n let scopeName: string | null = null;\n let scopeVersion: string | null = null;\n\n if (scopeSpan.scope) {\n scopeName = scopeSpan.scope.name ?? null;\n scopeVersion = scopeSpan.scope.version ?? null;\n }\n\n const scopeAttributes = scopeSpan.scope\n ? await mapAttributes(scopeSpan.scope.attributes ?? [])\n : null;\n\n for (const span of scopeSpan.spans ?? []) {\n const kind = convertToSpanKind(span.kind);\n\n const attributes = await mapAttributes(span.attributes);\n\n const startTime = new Date(Number(span.startTimeUnixNano) / 1e6);\n const endTime = new Date(Number(span.endTimeUnixNano) / 1e6);\n\n const parentSpanId = span.parentSpanId\n ? stringOrUintToString(span.parentSpanId)\n : null;\n\n const events = await Promise.all(\n span.events.map((event) => mapEvent(event)),\n );\n const links = await Promise.all(\n span.links.map((link) => mapLink(link)),\n );\n\n const traceId = stringOrUintToString(span.traceId);\n const spanId = stringOrUintToString(span.spanId);\n\n const name = span.name;\n const traceState = span.traceState;\n\n const spanInstance = OtelSpanSchema.parse(\n {\n trace_id: traceId,\n span_id: spanId,\n parent_span_id: parentSpanId,\n name,\n trace_state: traceState,\n kind,\n scope_name: scopeName,\n scope_version: scopeVersion,\n start_time: startTime,\n end_time: endTime,\n attributes,\n scope_attributes: scopeAttributes,\n resource_attributes: resourceAttributes,\n status: span.status ? mapStatus(span.status) : undefined,\n events,\n links,\n } satisfies MizuSpan,\n );\n\n result.push(spanInstance);\n }\n }\n }\n\n return result;\n}\n\ntype AttributeValuePrimitive = null | boolean | number | string | Uint8Array;\ntype AttributeValue =\n | AttributeValuePrimitive\n | AttributeValuePrimitive[]\n | Record;\n\nasync function mapAttributeValue(value: IAnyValue): Promise {\n if (!value) {\n return null;\n }\n if (value.stringValue !== undefined) {\n return value.stringValue;\n }\n if (value.boolValue !== undefined) {\n return value.boolValue;\n }\n if (value.intValue !== undefined) {\n return value.intValue;\n }\n if (value.doubleValue !== undefined) {\n return value.doubleValue;\n }\n if (value.bytesValue !== undefined) {\n return value.bytesValue;\n }\n if (value.arrayValue !== undefined) {\n // @ts-expect-error - By convention we don't actually nest values so don't need a recursive type\n return Promise.all(value.arrayValue.values.map(mapAttributeValue));\n }\n if (value.kvlistValue !== undefined) {\n // @ts-expect-error - By convention we don't actually nest values so don't need a recursive type\n return mapAttributes(value.kvlistValue.values);\n }\n return null;\n}\n\nasync function mapAttributes(\n attributes: IKeyValue[],\n): Promise> {\n const result: Record = {};\n for (const kv of attributes) {\n if (kv.key === \"exception.stacktrace\") {\n // HACK - convert stack trace if possible\n const value = kv.value ? await mapAttributeValue(kv.value) : null;\n if (typeof value === \"string\") {\n result[kv.key] = await transformStack(value);\n } else {\n result[kv.key] = value;\n }\n } else {\n result[kv.key] = kv.value ? await mapAttributeValue(kv.value) : null;\n }\n }\n\n return result;\n}\n\nasync function mapEvent(event: IEvent) {\n return {\n name: event.name,\n timestamp: new Date(Number(event.timeUnixNano) / 1e6),\n attributes: await mapAttributes(event.attributes),\n };\n}\n\nasync function mapLink(link: ILink) {\n return {\n trace_id: stringOrUintToString(link.traceId),\n span_id: stringOrUintToString(link.spanId),\n trace_state: link.traceState,\n attributes: await mapAttributes(link.attributes),\n };\n}\n\nfunction stringOrUintToString(id: string | Uint8Array) {\n return id instanceof Uint8Array\n ? Buffer.from(id).toString(\"hex\")\n : Buffer.from(id, \"hex\").toString(\"hex\");\n}\n\nfunction mapStatus(status: IStatus) {\n return {\n code: status.code,\n message: status.message ?? statusCodeToString(status.code),\n };\n}\n\nfunction statusCodeToString(statusCode: EStatusCode) {\n switch (statusCode) {\n case 0:\n return \"STATUS_CODE_UNSET\";\n case 1:\n return \"STATUS_CODE_OK\";\n case 2:\n return \"STATUS_CODE_ERROR\";\n default:\n return \"\";\n }\n}\n\n// Function to convert ESpanKind to SpanKind\nfunction convertToSpanKind(spanKind: ESpanKind): string {\n switch (spanKind) {\n case 1:\n return SpanKind.INTERNAL;\n case 2:\n return SpanKind.SERVER;\n case 3:\n return SpanKind.CLIENT;\n case 4:\n return SpanKind.PRODUCER;\n case 5:\n return SpanKind.CONSUMER;\n default:\n return \"Unspecified\";\n }\n}\n\n// NOTE - Copy-pasted\nconst SpanKind = {\n /** Default value. Indicates that the span is used internally. */\n INTERNAL: \"Internal\",\n /**\n * Indicates that the span covers server-side handling of an RPC or other\n * remote request.\n */\n SERVER: \"Server\",\n /**\n * Indicates that the span covers the client-side wrapper around an RPC or\n * other remote request.\n */\n CLIENT: \"Client\",\n /**\n * Indicates that the span describes producer sending a message to a\n * broker. Unlike client and server, there is no direct critical path latency\n * relationship between producer and consumer spans.\n */\n PRODUCER: \"Producer\",\n /**\n * Indicates that the span describes consumer receiving a message from a\n * broker. Unlike client and server, there is no direct critical path latency\n * relationship between producer and consumer spans.\n */\n CONSUMER: \"Consumer\",\n};\n\nconst EXAMPLE_TRACE_PAYLOAD = `{\n \"resourceSpans\": [\n {\n \"resource\": {\n \"attributes\": [\n {\n \"key\": \"service.name\",\n \"value\": {\n \"stringValue\": \"unknown\"\n }\n },\n {\n \"key\": \"telemetry.sdk.language\",\n \"value\": {\n \"stringValue\": \"webjs\"\n }\n },\n {\n \"key\": \"telemetry.sdk.name\",\n \"value\": {\n \"stringValue\": \"opentelemetry\"\n }\n },\n {\n \"key\": \"telemetry.sdk.version\",\n \"value\": {\n \"stringValue\": \"1.28.0\"\n }\n }\n ],\n \"droppedAttributesCount\": 0\n },\n \"scopeSpans\": [\n {\n \"scope\": {\n \"name\": \"fpx-tracer\"\n },\n \"spans\": [\n {\n \"traceId\": \"97dde7f861b4284fb670c439f9050f97\",\n \"spanId\": \"df9353752a11e3a2\",\n \"parentSpanId\": \"009c3ccc4058dc69\",\n \"name\": \"request\",\n \"kind\": 2,\n \"startTimeUnixNano\": \"1739429184265000000\",\n \"endTimeUnixNano\": \"1739429184266000000\",\n \"attributes\": [\n {\n \"key\": \"http.request.method\",\n \"value\": {\n \"stringValue\": \"GET\"\n }\n },\n {\n \"key\": \"url.full\",\n \"value\": {\n \"stringValue\": \"http://localhost:8787/\"\n }\n },\n {\n \"key\": \"fpx.http.request.pathname\",\n \"value\": {\n \"stringValue\": \"/\"\n }\n },\n {\n \"key\": \"fpx.http.request.search\",\n \"value\": {\n \"stringValue\": \"\"\n }\n },\n {\n \"key\": \"fpx.http.request.scheme\",\n \"value\": {\n \"stringValue\": \"http\"\n }\n },\n {\n \"key\": \"fpx.http.request.env\",\n \"value\": {\n \"stringValue\": \"{\\\"OPENAI_API_KEY\\\":\\\"sk-proj-uoRQ71Oaz16IbDJRJXY5T3BlbkFJgqSSf3Xglg0V0V2FhFrO\\\",\\\"ANTHROPIC_API_KEY\\\":\\\"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\\\",\\\"DATABASE_URL\\\":\\\"postgresql://neondb_owner:XaenL6g5WApI@ep-proud-grass-a5r8g74c.us-east-2.aws.neon.tech/neondb?sslmode=require\\\",\\\"FPX_ENDPOINT\\\":\\\"http://localhost:8788/v1/traces\\\",\\\"FPX_LOG_LEVEL\\\":\\\"debug\\\",\\\"GOOSE_AVATARS\\\":{}}\"\n }\n },\n {\n \"key\": \"http.request.header.accept\",\n \"value\": {\n \"stringValue\": \"*/*\"\n }\n },\n {\n \"key\": \"http.request.header.accept-encoding\",\n \"value\": {\n \"stringValue\": \"br, gzip\"\n }\n },\n {\n \"key\": \"http.request.header.accept-language\",\n \"value\": {\n \"stringValue\": \"*\"\n }\n },\n {\n \"key\": \"http.request.header.host\",\n \"value\": {\n \"stringValue\": \"localhost:8787\"\n }\n },\n {\n \"key\": \"http.request.header.sec-fetch-mode\",\n \"value\": {\n \"stringValue\": \"cors\"\n }\n },\n {\n \"key\": \"http.request.header.user-agent\",\n \"value\": {\n \"stringValue\": \"node\"\n }\n },\n {\n \"key\": \"http.request.header.x-fpx-trace-id\",\n \"value\": {\n \"stringValue\": \"97dde7f861b4284fb670c439f9050f97\"\n }\n },\n {\n \"key\": \"http.response.status_code\",\n \"value\": {\n \"stringValue\": \"200\"\n }\n },\n {\n \"key\": \"http.scheme\",\n \"value\": {\n \"stringValue\": \"\"\n }\n },\n {\n \"key\": \"fpx.http.response.body\",\n \"value\": {\n \"stringValue\": \"Hello Goose Quotes!\"\n }\n },\n {\n \"key\": \"http.response.header.content-type\",\n \"value\": {\n \"stringValue\": \"text/plain;charset=UTF-8\"\n }\n }\n ],\n \"droppedAttributesCount\": 0,\n \"events\": [\n {\n \"attributes\": [\n {\n \"key\": \"message\",\n \"value\": {\n \"stringValue\": \"\\\"Home page accessed. Honk: \\\"\"\n }\n },\n {\n \"key\": \"messageType\",\n \"value\": {\n \"stringValue\": \"string\"\n }\n },\n {\n \"key\": \"level\",\n \"value\": {\n \"stringValue\": \"info\"\n }\n },\n {\n \"key\": \"arguments\",\n \"value\": {\n \"stringValue\": \"[]\"\n }\n }\n ],\n \"name\": \"log\",\n \"timeUnixNano\": \"1739429184265000000\",\n \"droppedAttributesCount\": 0\n },\n {\n \"attributes\": [],\n \"name\": \"first-response\",\n \"timeUnixNano\": \"1739429184265000000\",\n \"droppedAttributesCount\": 0\n }\n ],\n \"droppedEventsCount\": 0,\n \"status\": {\n \"code\": 1\n },\n \"links\": [],\n \"droppedLinksCount\": 0\n }\n ]\n }\n ]\n }\n ]\n}`.trim();","createdAt",["D",1739431909470],"version",50,"currentUserHasLiked","likeCount",1,"forkCount","referenceCount","dependencyCount","commentCount","prCount","mergedPr",{"_130":131,"_132":133},"handle","boots","profileImageUrl","https://img.clerk.com/eyJ0eXBlIjoicHJveHkiLCJzcmMiOiJodHRwczovL2ltYWdlcy5jbGVyay5kZXYvb2F1dGhfZ2l0aHViL2ltZ18yaGhkR24wd2dSR2J4cER2NWlzQmpQem1LZ3gifQ","forkedVal","interval","slug","boots/VOTelCollector","description","This is a WIP proof of concept for setting up an OTel collector for traces emitted by @fiberplane/hono-otel OpenSource Tracing on ValTown backed by sqlite! Woo! WOOOOOOO!","versions",[142,145,149,153,157,161,165,169,173,177,181,185,189,193,197,201,205,209,213,217,221,225,229,233,237,241,245,249,253,257,261,265,269,273,277,281,285,289,293,297,301,305,309,313,317,321,325,329,333,336,339],{"_118":119,"_143":-5,"_116":144,"_113":111},"prId",["D",1739431909470],{"_118":146,"_143":-5,"_116":147,"_113":148},49,["D",1739431687739],"1225003e-e9dc-11ef-b286-e6cdfca9ef9f",{"_118":150,"_143":-5,"_116":151,"_113":152},48,["D",1739431591101],"d87fae9c-e9db-11ef-8e27-e6cdfca9ef9f",{"_118":154,"_143":-5,"_116":155,"_113":156},47,["D",1739431535376],"b74dc5a6-e9db-11ef-982c-e6cdfca9ef9f",{"_118":158,"_143":-5,"_116":159,"_113":160},46,["D",1739430080676],"5439828c-e9d8-11ef-a83b-e6cdfca9ef9f",{"_118":162,"_143":-5,"_116":163,"_113":164},45,["D",1739430033309],"37fb4222-e9d8-11ef-b794-e6cdfca9ef9f",{"_118":166,"_143":-5,"_116":167,"_113":168},44,["D",1739429976233],"15f8d31a-e9d8-11ef-a247-e6cdfca9ef9f",{"_118":170,"_143":-5,"_116":171,"_113":172},43,["D",1739429840115],"c4d4c782-e9d7-11ef-a6cd-e6cdfca9ef9f",{"_118":174,"_143":-5,"_116":175,"_113":176},42,["D",1739429625662],"4502e0de-e9d7-11ef-9668-e6cdfca9ef9f",{"_118":178,"_143":-5,"_116":179,"_113":180},41,["D",1739429478623],"ed5e68f8-e9d6-11ef-91a0-e6cdfca9ef9f",{"_118":182,"_143":-5,"_116":183,"_113":184},40,["D",1739428979697],"c3fb36ea-e9d5-11ef-83c5-e6cdfca9ef9f",{"_118":186,"_143":-5,"_116":187,"_113":188},39,["D",1739428785462],"503686c4-e9d5-11ef-a8e6-e6cdfca9ef9f",{"_118":190,"_143":-5,"_116":191,"_113":192},38,["D",1739428747835],"39c9bd52-e9d5-11ef-969f-e6cdfca9ef9f",{"_118":194,"_143":-5,"_116":195,"_113":196},37,["D",1739428725957],"2cbe8cfa-e9d5-11ef-85bb-e6cdfca9ef9f",{"_118":198,"_143":-5,"_116":199,"_113":200},36,["D",1739428718552],"28551be8-e9d5-11ef-9efc-e6cdfca9ef9f",{"_118":202,"_143":-5,"_116":203,"_113":204},35,["D",1739428717808],"27e332f8-e9d5-11ef-960a-e6cdfca9ef9f",{"_118":206,"_143":-5,"_116":207,"_113":208},34,["D",1739428320729],"3b3610f6-e9d4-11ef-822b-e6cdfca9ef9f",{"_118":210,"_143":-5,"_116":211,"_113":212},33,["D",1739428312009],"360277f0-e9d4-11ef-ad66-e6cdfca9ef9f",{"_118":214,"_143":-5,"_116":215,"_113":216},32,["D",1739428264034],"19700472-e9d4-11ef-9502-e6cdfca9ef9f",{"_118":218,"_143":-5,"_116":219,"_113":220},31,["D",1739428235030],"0823f98a-e9d4-11ef-8267-e6cdfca9ef9f",{"_118":222,"_143":-5,"_116":223,"_113":224},30,["D",1739428218563],"fe4f65d4-e9d3-11ef-a10f-e6cdfca9ef9f",{"_118":226,"_143":-5,"_116":227,"_113":228},29,["D",1739428216647],"fd2c25f2-e9d3-11ef-8930-e6cdfca9ef9f",{"_118":230,"_143":-5,"_116":231,"_113":232},28,["D",1739428152021],"d6a80dce-e9d3-11ef-aecd-e6cdfca9ef9f",{"_118":234,"_143":-5,"_116":235,"_113":236},27,["D",1739428035430],"9128c34c-e9d3-11ef-9afa-e6cdfca9ef9f",{"_118":238,"_143":-5,"_116":239,"_113":240},26,["D",1739427955865],"61bbeec2-e9d3-11ef-bd33-e6cdfca9ef9f",{"_118":242,"_143":-5,"_116":243,"_113":244},25,["D",1739427900061],"407a71f2-e9d3-11ef-9f58-e6cdfca9ef9f",{"_118":246,"_143":-5,"_116":247,"_113":248},24,["D",1739427761162],"edad7ed8-e9d2-11ef-b930-e6cdfca9ef9f",{"_118":250,"_143":-5,"_116":251,"_113":252},23,["D",1739427756676],"eb024f92-e9d2-11ef-b930-e6cdfca9ef9f",{"_118":254,"_143":-5,"_116":255,"_113":256},22,["D",1739427525591],"6148f47c-e9d2-11ef-8738-e6cdfca9ef9f",{"_118":258,"_143":-5,"_116":259,"_113":260},21,["D",1739427383180],"0c61ff1c-e9d2-11ef-b4f0-e6cdfca9ef9f",{"_118":262,"_143":-5,"_116":263,"_113":264},20,["D",1739427290511],"d5261b5a-e9d1-11ef-8791-e6cdfca9ef9f",{"_118":266,"_143":-5,"_116":267,"_113":268},19,["D",1739427247376],"bb706b34-e9d1-11ef-a6a5-e6cdfca9ef9f",{"_118":270,"_143":-5,"_116":271,"_113":272},18,["D",1739427066161],"4f6e455a-e9d1-11ef-8078-e6cdfca9ef9f",{"_118":274,"_143":-5,"_116":275,"_113":276},17,["D",1739427007245],"2c50e532-e9d1-11ef-832c-e6cdfca9ef9f",{"_118":278,"_143":-5,"_116":279,"_113":280},16,["D",1739426848016],"cd67defe-e9d0-11ef-af0b-e6cdfca9ef9f",{"_118":282,"_143":-5,"_116":283,"_113":284},15,["D",1739426806249],"b481ac62-e9d0-11ef-91d3-e6cdfca9ef9f",{"_118":286,"_143":-5,"_116":287,"_113":288},14,["D",1739426490090],"f8108bca-e9cf-11ef-84e3-e6cdfca9ef9f",{"_118":290,"_143":-5,"_116":291,"_113":292},13,["D",1739426474010],"ee7aa474-e9cf-11ef-aac6-e6cdfca9ef9f",{"_118":294,"_143":-5,"_116":295,"_113":296},12,["D",1739426451812],"e1400812-e9cf-11ef-8395-e6cdfca9ef9f",{"_118":298,"_143":-5,"_116":299,"_113":300},11,["D",1739426426908],"d267a1ce-e9cf-11ef-a1c7-e6cdfca9ef9f",{"_118":302,"_143":-5,"_116":303,"_113":304},10,["D",1739426402607],"c3eb93b2-e9cf-11ef-8c37-e6cdfca9ef9f",{"_118":306,"_143":-5,"_116":307,"_113":308},9,["D",1739426357805],"a93b4b02-e9cf-11ef-bb3a-e6cdfca9ef9f",{"_118":310,"_143":-5,"_116":311,"_113":312},8,["D",1739426336226],"9c5cac14-e9cf-11ef-932c-e6cdfca9ef9f",{"_118":314,"_143":-5,"_116":315,"_113":316},7,["D",1739426051203],"f2783e98-e9ce-11ef-b5f8-e6cdfca9ef9f",{"_118":318,"_143":-5,"_116":319,"_113":320},6,["D",1739425782224],"52274f88-e9ce-11ef-a9e7-e6cdfca9ef9f",{"_118":322,"_143":-5,"_116":323,"_113":324},5,["D",1739425775737],"4e46d38e-e9ce-11ef-96d0-e6cdfca9ef9f",{"_118":326,"_143":-5,"_116":327,"_113":328},4,["D",1739425492008],"a52b0a2c-e9cd-11ef-a025-e6cdfca9ef9f",{"_118":330,"_143":-5,"_116":331,"_113":332},3,["D",1739425374585],"5f2bf090-e9cd-11ef-a4f6-e6cdfca9ef9f",{"_118":90,"_143":-5,"_116":334,"_113":335},["D",1739425357118],"54c8ef4a-e9cd-11ef-8d85-e6cdfca9ef9f",{"_118":122,"_143":-5,"_116":337,"_113":338},["D",1739425323412],"40ab7078-e9cd-11ef-ad12-e6cdfca9ef9f",{"_118":31,"_143":-5,"_116":340,"_113":341},["D",1739425103567],"bda2909e-e9cc-11ef-a85b-e6cdfca9ef9f","recentThread","breadcrumbs","comments",[],"isOwner","routes/_app.v.$handle.$name.versions.$(version)",{"_93":349,"_350":351,"_94":352},"single","redirect","/v/boots/VOTelCollector/versions",{"_113":148,"_114":353,"_118":146,"_116":354,"_355":99,"_100":101,"_108":109,"_130":131,"_11":96,"_356":-5,"_357":-5,"_358":-5,"_346":26,"_136":137},"import {\n type OtelSpan,\n OtelSpanSchema,\n type TraceDetailSpansResponse,\n type TraceListResponse,\n} from \"https://esm.sh/@fiberplane/fpx-types@0.0.13\";\nimport { createFiberplane } from \"https://esm.sh/@fiberplane/hono@0.4.1\";\nimport type {\n ESpanKind,\n EStatusCode,\n IAnyValue,\n IEvent,\n IExportTraceServiceRequest,\n IKeyValue,\n ILink,\n IStatus,\n} from \"https://esm.sh/@opentelemetry/otlp-transformer@0.55.0\";\nimport { and, desc, relations, sql } from \"https://esm.sh/drizzle-orm@0.39.3\";\nimport { drizzle, type LibSQLDatabase } from \"https://esm.sh/drizzle-orm@0.39.3/libsql\";\nimport { integer, sqliteTable, text } from \"https://esm.sh/drizzle-orm@0.39.3/sqlite-core\";\nimport { Hono } from \"https://esm.sh/hono@4.7.0\";\nimport { cors } from \"https://esm.sh/hono@4.7.0/cors\";\nimport { sqlite } from \"https://esm.town/v/std/sqlite\";\nimport { randomBytes } from \"node:crypto\";\n\n/******************************************************************\n * Database and Drizzle setup\n * ****************************************************************/\n\nconst otelSpans = sqliteTable(\"otel_spans\", {\n inner: text(\"inner\", { mode: \"json\" }).$type().notNull(),\n spanId: text(\"span_id\").notNull(),\n traceId: text(\"trace_id\").notNull(),\n});\n\nconst schema = { otelSpans };\n\n// TODO - Use valtowns suggested way of handling migrations\n// (remember to remove \"IF NOT EXISTS\")\n// https://docs.val.town/std/sqlite/migrations/\nconst migrateDatabase = async () => {\n await sqlite.execute(`\nCREATE TABLE IF NOT EXISTS \\`otel_spans\\` (\n \\`inner\\` text NOT NULL,\n\t\\`span_id\\` text NOT NULL,\n\t\\`trace_id\\` text NOT NULL\n);\n`);\n};\n\n// HACK - Migrate database on startup\nawait migrateDatabase();\n\n/******************************************************************\n * API for receiving / returning traces from @fiberplane/hono-otel\n * ****************************************************************/\n\ntype AppType = {\n Bindings: {\n // TODO - Add secrets here\n };\n Variables: {\n db: LibSQLDatabase;\n };\n};\n\nconst app = new Hono();\n\n/**\n * Middleware for setting up the database\n * and storing it on the Hono app's context\n */\napp.use(async (ctx, next) => {\n const db = drizzle(sqlite as any, {\n schema,\n });\n ctx.set(\"db\", db);\n await next();\n});\n\napp.get(\"/\", async ctx => {\n return ctx.text(\"Hello, VOTel!\");\n});\n\napp.get(\"/v1/traces\", async ctx => {\n const db = ctx.get(\"db\");\n\n const spans = await db.query.otelSpans.findMany({\n where: sql`inner->>'scope_name' = 'fpx-tracer'`,\n orderBy: desc(sql`inner->>'end_time'`),\n limit: 1000,\n });\n\n const traceMap = new Map>();\n for (const span of spans) {\n const traceId = span.inner.trace_id;\n if (!traceId) {\n continue;\n }\n if (!traceMap.has(traceId)) {\n traceMap.set(traceId, []);\n }\n traceMap.get(traceId)?.push(span);\n }\n\n const traces = Array.from(traceMap.entries()).map(([traceId, spans]) => ({\n traceId,\n spans,\n }));\n\n const response: TraceListResponse = traces.map(({ traceId, spans }) => ({\n traceId,\n spans: spans.map(({ inner }) => OtelSpanSchema.parse(inner)),\n }));\n\n return ctx.json(response);\n});\n\napp.get(\"/v1/traces/:traceId/spans\", async ctx => {\n return c.text(\"NYI\");\n});\n\n/**\n * Expects a JSON payload from @fiberplane/hono-otel\n */\napp.post(\"/v1/traces\", async (ctx) => {\n const db = ctx.get(\"db\");\n const body: IExportTraceServiceRequest = await ctx.req.json();\n\n // TODO - set up auth headers\n // TODO - optionally forward to a Fiberplane service\n const headers = {};\n // const headers: Record = fpxWorker.bearerToken\n // ? { Authorization: `Bearer ${fpxWorker.bearerToken}` }\n // : {};\n\n try {\n const tracesPayload = (await fromCollectorRequest(body)).map(\n (span) =>\n ({\n inner: OtelSpanSchema.parse(span),\n spanId: span.span_id,\n traceId: span.trace_id,\n }) satisfies typeof otelSpans.$inferInsert,\n );\n\n try {\n if (tracesPayload.length > 0) {\n await db.insert(otelSpans).values(tracesPayload);\n }\n } catch (error) {\n logger.error(\"Error inserting trace\", error);\n return ctx.text(\"Error inserting trace\", 500);\n }\n\n return ctx.text(\"OK\");\n } catch (error) {\n logger.error(\"Error parsing trace data\", error);\n return ctx.text(\"Error parsing trace data\", 400);\n }\n});\n\napp.use(\n \"/fp/*\",\n createFiberplane({\n openapi: { content: JSON.stringify(getOpenAPISpec()) },\n apiKey: \"123\",\n fpxEndpoint: Deno.env.get(\"FPX_ENDPOINT\"),\n }),\n);\n\nexport default app.fetch;\n\n/***************************************************************\n * Helpers\n ****************************************************************/\n\n/**\n * HACK - To be able to use the Fiberplane library with an OpenAPI spec\n */\nfunction getOpenAPISpec() {\n return {\n openapi: \"3.0.0\",\n info: {\n title: \"VOTel\",\n version: \"1.0.0\",\n },\n paths: {\n \"/v1/traces\": {\n post: {\n summary: \"Export traces\",\n description: \"Export traces\",\n requestBody: {\n required: true,\n content: {\n \"application/json\": {\n schema: {\n /* any, for simplicity */\n type: \"object\",\n additionalProperties: true,\n },\n // This is what SHOULD allow us to easily send\n // an example payload in the Fiberplane UI,\n // but that doesn't work right now bc there is not a valid schema definition\n example: getExampleTracePayload(),\n },\n },\n },\n responses: {\n 200: {\n description: \"OK\",\n },\n },\n },\n get: {\n summary: \"Get traces\",\n description: \"Get traces\",\n responses: {\n 200: {\n description: \"OK\",\n },\n },\n },\n },\n \"/v1/traces/{traceId}/spans\": {\n get: {\n summary: \"Get spans\",\n description: \"Get spans\",\n responses: {\n 200: {\n description: \"OK\",\n },\n },\n },\n },\n },\n };\n}\n\nfunction getExampleTracePayload() {\n return {\n \"resourceSpans\": [\n {\n \"resource\": {\n \"attributes\": [\n {\n \"key\": \"service.name\",\n \"value\": {\n \"stringValue\": \"unknown\",\n },\n },\n {\n \"key\": \"telemetry.sdk.language\",\n \"value\": {\n \"stringValue\": \"webjs\",\n },\n },\n {\n \"key\": \"telemetry.sdk.name\",\n \"value\": {\n \"stringValue\": \"opentelemetry\",\n },\n },\n {\n \"key\": \"telemetry.sdk.version\",\n \"value\": {\n \"stringValue\": \"1.28.0\",\n },\n },\n ],\n \"droppedAttributesCount\": 0,\n },\n \"scopeSpans\": [\n {\n \"scope\": {\n \"name\": \"fpx-tracer\",\n },\n \"spans\": [\n {\n \"traceId\": \"97dde7f861b4284fb670c439f9050f97\",\n \"spanId\": \"df9353752a11e3a2\",\n \"parentSpanId\": \"009c3ccc4058dc69\",\n \"name\": \"request\",\n \"kind\": 2,\n \"startTimeUnixNano\": \"1739429184265000000\",\n \"endTimeUnixNano\": \"1739429184266000000\",\n \"attributes\": [\n {\n \"key\": \"http.request.method\",\n \"value\": {\n \"stringValue\": \"GET\",\n },\n },\n {\n \"key\": \"url.full\",\n \"value\": {\n \"stringValue\": \"http://localhost:8787/\",\n },\n },\n {\n \"key\": \"fpx.http.request.pathname\",\n \"value\": {\n \"stringValue\": \"/\",\n },\n },\n {\n \"key\": \"fpx.http.request.search\",\n \"value\": {\n \"stringValue\": \"\",\n },\n },\n {\n \"key\": \"fpx.http.request.scheme\",\n \"value\": {\n \"stringValue\": \"http\",\n },\n },\n {\n \"key\": \"fpx.http.request.env\",\n \"value\": {\n \"stringValue\":\n \"{\\\"OPENAI_API_KEY\\\":\\\"sk-proj-uoRQ71Oaz16IbDJRJXY5T3BlbkFJgqSSf3Xglg0V0V2FhFrO\\\",\\\"ANTHROPIC_API_KEY\\\":\\\"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\\\",\\\"DATABASE_URL\\\":\\\"postgresql://neondb_owner:XaenL6g5WApI@ep-proud-grass-a5r8g74c.us-east-2.aws.neon.tech/neondb?sslmode=require\\\",\\\"FPX_ENDPOINT\\\":\\\"http://localhost:8788/v1/traces\\\",\\\"FPX_LOG_LEVEL\\\":\\\"debug\\\",\\\"GOOSE_AVATARS\\\":{}}\",\n },\n },\n {\n \"key\": \"http.request.header.accept\",\n \"value\": {\n \"stringValue\": \"*/*\",\n },\n },\n {\n \"key\": \"http.request.header.accept-encoding\",\n \"value\": {\n \"stringValue\": \"br, gzip\",\n },\n },\n {\n \"key\": \"http.request.header.accept-language\",\n \"value\": {\n \"stringValue\": \"*\",\n },\n },\n {\n \"key\": \"http.request.header.host\",\n \"value\": {\n \"stringValue\": \"localhost:8787\",\n },\n },\n {\n \"key\": \"http.request.header.sec-fetch-mode\",\n \"value\": {\n \"stringValue\": \"cors\",\n },\n },\n {\n \"key\": \"http.request.header.user-agent\",\n \"value\": {\n \"stringValue\": \"node\",\n },\n },\n {\n \"key\": \"http.request.header.x-fpx-trace-id\",\n \"value\": {\n \"stringValue\": \"97dde7f861b4284fb670c439f9050f97\",\n },\n },\n {\n \"key\": \"http.response.status_code\",\n \"value\": {\n \"stringValue\": \"200\",\n },\n },\n {\n \"key\": \"http.scheme\",\n \"value\": {\n \"stringValue\": \"\",\n },\n },\n {\n \"key\": \"fpx.http.response.body\",\n \"value\": {\n \"stringValue\": \"Hello Goose Quotes!\",\n },\n },\n {\n \"key\": \"http.response.header.content-type\",\n \"value\": {\n \"stringValue\": \"text/plain;charset=UTF-8\",\n },\n },\n ],\n \"droppedAttributesCount\": 0,\n \"events\": [\n {\n \"attributes\": [\n {\n \"key\": \"message\",\n \"value\": {\n \"stringValue\": \"\\\"Home page accessed. Honk: \\\"\",\n },\n },\n {\n \"key\": \"messageType\",\n \"value\": {\n \"stringValue\": \"string\",\n },\n },\n {\n \"key\": \"level\",\n \"value\": {\n \"stringValue\": \"info\",\n },\n },\n {\n \"key\": \"arguments\",\n \"value\": {\n \"stringValue\": \"[]\",\n },\n },\n ],\n \"name\": \"log\",\n \"timeUnixNano\": \"1739429184265000000\",\n \"droppedAttributesCount\": 0,\n },\n {\n \"attributes\": [],\n \"name\": \"first-response\",\n \"timeUnixNano\": \"1739429184265000000\",\n \"droppedAttributesCount\": 0,\n },\n ],\n \"droppedEventsCount\": 0,\n \"status\": {\n \"code\": 1,\n },\n \"links\": [],\n \"droppedLinksCount\": 0,\n },\n ],\n },\n ],\n },\n ],\n };\n}\n\n/**\n * Logging interface, v simple\n */\nfunction logger() {\n return {\n info: console.log.bind(console),\n warn: console.warn.bind(console),\n error: console.error.bind(console),\n };\n}\n\n/**\n * Port of the Fiberplane rust code that massages traces into the format we use in the Fiberplane UI.\n *\n * A few differences:\n *\n * - The otel js library does not expose `traceFlags` or `flags` from what I can tell,\n * so that field is always blank.\n *\n * - `mapAttributes` simply returns the value, instead of an object whose key describes the attribute data type.\n * By convention, we only use string and number values. Complex values are serialized.\n */\nasync function fromCollectorRequest(\n tracesData: IExportTraceServiceRequest,\n): Promise> {\n const result: Array = [];\n\n for (const resourceSpan of tracesData.resourceSpans ?? []) {\n const resourceAttributes = resourceSpan.resource\n ? await mapAttributes(resourceSpan.resource.attributes)\n : null;\n\n for (const scopeSpan of resourceSpan.scopeSpans ?? []) {\n let scopeName: string | null = null;\n let scopeVersion: string | null = null;\n\n if (scopeSpan.scope) {\n scopeName = scopeSpan.scope.name ?? null;\n scopeVersion = scopeSpan.scope.version ?? null;\n }\n\n const scopeAttributes = scopeSpan.scope\n ? await mapAttributes(scopeSpan.scope.attributes ?? [])\n : null;\n\n for (const span of scopeSpan.spans ?? []) {\n const kind = convertToSpanKind(span.kind);\n\n const attributes = await mapAttributes(span.attributes);\n\n const startTime = new Date(Number(span.startTimeUnixNano) / 1e6);\n const endTime = new Date(Number(span.endTimeUnixNano) / 1e6);\n\n const parentSpanId = span.parentSpanId\n ? stringOrUintToString(span.parentSpanId)\n : null;\n\n const events = await Promise.all(\n span.events.map((event) => mapEvent(event)),\n );\n const links = await Promise.all(\n span.links.map((link) => mapLink(link)),\n );\n\n const traceId = stringOrUintToString(span.traceId);\n const spanId = stringOrUintToString(span.spanId);\n\n const name = span.name;\n const traceState = span.traceState;\n\n const spanInstance = OtelSpanSchema.parse(\n {\n trace_id: traceId,\n span_id: spanId,\n parent_span_id: parentSpanId,\n name,\n trace_state: traceState,\n kind,\n scope_name: scopeName,\n scope_version: scopeVersion,\n start_time: startTime,\n end_time: endTime,\n attributes,\n scope_attributes: scopeAttributes,\n resource_attributes: resourceAttributes,\n status: span.status ? mapStatus(span.status) : undefined,\n events,\n links,\n } satisfies MizuSpan,\n );\n\n result.push(spanInstance);\n }\n }\n }\n\n return result;\n}\n\ntype AttributeValuePrimitive = null | boolean | number | string | Uint8Array;\ntype AttributeValue =\n | AttributeValuePrimitive\n | AttributeValuePrimitive[]\n | Record;\n\nasync function mapAttributeValue(value: IAnyValue): Promise {\n if (!value) {\n return null;\n }\n if (value.stringValue !== undefined) {\n return value.stringValue;\n }\n if (value.boolValue !== undefined) {\n return value.boolValue;\n }\n if (value.intValue !== undefined) {\n return value.intValue;\n }\n if (value.doubleValue !== undefined) {\n return value.doubleValue;\n }\n if (value.bytesValue !== undefined) {\n return value.bytesValue;\n }\n if (value.arrayValue !== undefined) {\n // @ts-expect-error - By convention we don't actually nest values so don't need a recursive type\n return Promise.all(value.arrayValue.values.map(mapAttributeValue));\n }\n if (value.kvlistValue !== undefined) {\n // @ts-expect-error - By convention we don't actually nest values so don't need a recursive type\n return mapAttributes(value.kvlistValue.values);\n }\n return null;\n}\n\nasync function mapAttributes(\n attributes: IKeyValue[],\n): Promise> {\n const result: Record = {};\n for (const kv of attributes) {\n if (kv.key === \"exception.stacktrace\") {\n // HACK - convert stack trace if possible\n const value = kv.value ? await mapAttributeValue(kv.value) : null;\n if (typeof value === \"string\") {\n result[kv.key] = await transformStack(value);\n } else {\n result[kv.key] = value;\n }\n } else {\n result[kv.key] = kv.value ? await mapAttributeValue(kv.value) : null;\n }\n }\n\n return result;\n}\n\nasync function mapEvent(event: IEvent) {\n return {\n name: event.name,\n timestamp: new Date(Number(event.timeUnixNano) / 1e6),\n attributes: await mapAttributes(event.attributes),\n };\n}\n\nasync function mapLink(link: ILink) {\n return {\n trace_id: stringOrUintToString(link.traceId),\n span_id: stringOrUintToString(link.spanId),\n trace_state: link.traceState,\n attributes: await mapAttributes(link.attributes),\n };\n}\n\nfunction stringOrUintToString(id: string | Uint8Array) {\n return id instanceof Uint8Array\n ? Buffer.from(id).toString(\"hex\")\n : Buffer.from(id, \"hex\").toString(\"hex\");\n}\n\nfunction mapStatus(status: IStatus) {\n return {\n code: status.code,\n message: status.message ?? statusCodeToString(status.code),\n };\n}\n\nfunction statusCodeToString(statusCode: EStatusCode) {\n switch (statusCode) {\n case 0:\n return \"STATUS_CODE_UNSET\";\n case 1:\n return \"STATUS_CODE_OK\";\n case 2:\n return \"STATUS_CODE_ERROR\";\n default:\n return \"\";\n }\n}\n\n// Function to convert ESpanKind to SpanKind\nfunction convertToSpanKind(spanKind: ESpanKind): string {\n switch (spanKind) {\n case 1:\n return SpanKind.INTERNAL;\n case 2:\n return SpanKind.SERVER;\n case 3:\n return SpanKind.CLIENT;\n case 4:\n return SpanKind.PRODUCER;\n case 5:\n return SpanKind.CONSUMER;\n default:\n return \"Unspecified\";\n }\n}\n\n// NOTE - Copy-pasted\nconst SpanKind = {\n /** Default value. Indicates that the span is used internally. */\n INTERNAL: \"Internal\",\n /**\n * Indicates that the span covers server-side handling of an RPC or other\n * remote request.\n */\n SERVER: \"Server\",\n /**\n * Indicates that the span covers the client-side wrapper around an RPC or\n * other remote request.\n */\n CLIENT: \"Client\",\n /**\n * Indicates that the span describes producer sending a message to a\n * broker. Unlike client and server, there is no direct critical path latency\n * relationship between producer and consumer spans.\n */\n PRODUCER: \"Producer\",\n /**\n * Indicates that the span describes consumer receiving a message from a\n * broker. Unlike client and server, there is no direct critical path latency\n * relationship between producer and consumer spans.\n */\n CONSUMER: \"Consumer\",\n};\n\nconst EXAMPLE_TRACE_PAYLOAD = `{\n \"resourceSpans\": [\n {\n \"resource\": {\n \"attributes\": [\n {\n \"key\": \"service.name\",\n \"value\": {\n \"stringValue\": \"unknown\"\n }\n },\n {\n \"key\": \"telemetry.sdk.language\",\n \"value\": {\n \"stringValue\": \"webjs\"\n }\n },\n {\n \"key\": \"telemetry.sdk.name\",\n \"value\": {\n \"stringValue\": \"opentelemetry\"\n }\n },\n {\n \"key\": \"telemetry.sdk.version\",\n \"value\": {\n \"stringValue\": \"1.28.0\"\n }\n }\n ],\n \"droppedAttributesCount\": 0\n },\n \"scopeSpans\": [\n {\n \"scope\": {\n \"name\": \"fpx-tracer\"\n },\n \"spans\": [\n {\n \"traceId\": \"97dde7f861b4284fb670c439f9050f97\",\n \"spanId\": \"df9353752a11e3a2\",\n \"parentSpanId\": \"009c3ccc4058dc69\",\n \"name\": \"request\",\n \"kind\": 2,\n \"startTimeUnixNano\": \"1739429184265000000\",\n \"endTimeUnixNano\": \"1739429184266000000\",\n \"attributes\": [\n {\n \"key\": \"http.request.method\",\n \"value\": {\n \"stringValue\": \"GET\"\n }\n },\n {\n \"key\": \"url.full\",\n \"value\": {\n \"stringValue\": \"http://localhost:8787/\"\n }\n },\n {\n \"key\": \"fpx.http.request.pathname\",\n \"value\": {\n \"stringValue\": \"/\"\n }\n },\n {\n \"key\": \"fpx.http.request.search\",\n \"value\": {\n \"stringValue\": \"\"\n }\n },\n {\n \"key\": \"fpx.http.request.scheme\",\n \"value\": {\n \"stringValue\": \"http\"\n }\n },\n {\n \"key\": \"fpx.http.request.env\",\n \"value\": {\n \"stringValue\": \"{\\\"OPENAI_API_KEY\\\":\\\"sk-proj-uoRQ71Oaz16IbDJRJXY5T3BlbkFJgqSSf3Xglg0V0V2FhFrO\\\",\\\"ANTHROPIC_API_KEY\\\":\\\"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\\\",\\\"DATABASE_URL\\\":\\\"postgresql://neondb_owner:XaenL6g5WApI@ep-proud-grass-a5r8g74c.us-east-2.aws.neon.tech/neondb?sslmode=require\\\",\\\"FPX_ENDPOINT\\\":\\\"http://localhost:8788/v1/traces\\\",\\\"FPX_LOG_LEVEL\\\":\\\"debug\\\",\\\"GOOSE_AVATARS\\\":{}}\"\n }\n },\n {\n \"key\": \"http.request.header.accept\",\n \"value\": {\n \"stringValue\": \"*/*\"\n }\n },\n {\n \"key\": \"http.request.header.accept-encoding\",\n \"value\": {\n \"stringValue\": \"br, gzip\"\n }\n },\n {\n \"key\": \"http.request.header.accept-language\",\n \"value\": {\n \"stringValue\": \"*\"\n }\n },\n {\n \"key\": \"http.request.header.host\",\n \"value\": {\n \"stringValue\": \"localhost:8787\"\n }\n },\n {\n \"key\": \"http.request.header.sec-fetch-mode\",\n \"value\": {\n \"stringValue\": \"cors\"\n }\n },\n {\n \"key\": \"http.request.header.user-agent\",\n \"value\": {\n \"stringValue\": \"node\"\n }\n },\n {\n \"key\": \"http.request.header.x-fpx-trace-id\",\n \"value\": {\n \"stringValue\": \"97dde7f861b4284fb670c439f9050f97\"\n }\n },\n {\n \"key\": \"http.response.status_code\",\n \"value\": {\n \"stringValue\": \"200\"\n }\n },\n {\n \"key\": \"http.scheme\",\n \"value\": {\n \"stringValue\": \"\"\n }\n },\n {\n \"key\": \"fpx.http.response.body\",\n \"value\": {\n \"stringValue\": \"Hello Goose Quotes!\"\n }\n },\n {\n \"key\": \"http.response.header.content-type\",\n \"value\": {\n \"stringValue\": \"text/plain;charset=UTF-8\"\n }\n }\n ],\n \"droppedAttributesCount\": 0,\n \"events\": [\n {\n \"attributes\": [\n {\n \"key\": \"message\",\n \"value\": {\n \"stringValue\": \"\\\"Home page accessed. Honk: \\\"\"\n }\n },\n {\n \"key\": \"messageType\",\n \"value\": {\n \"stringValue\": \"string\"\n }\n },\n {\n \"key\": \"level\",\n \"value\": {\n \"stringValue\": \"info\"\n }\n },\n {\n \"key\": \"arguments\",\n \"value\": {\n \"stringValue\": \"[]\"\n }\n }\n ],\n \"name\": \"log\",\n \"timeUnixNano\": \"1739429184265000000\",\n \"droppedAttributesCount\": 0\n },\n {\n \"attributes\": [],\n \"name\": \"first-response\",\n \"timeUnixNano\": \"1739429184265000000\",\n \"droppedAttributesCount\": 0\n }\n ],\n \"droppedEventsCount\": 0,\n \"status\": {\n \"code\": 1\n },\n \"links\": [],\n \"droppedLinksCount\": 0\n }\n ]\n }\n ]\n }\n ]\n}`.trim();",["D",1739431687739],"valName","deletedAt","messageId","threadId","routes/_app","actionData","errors"]

VOTelCollector

Version 49