Fiberplane OpenTelemetry Trace Collector on ValTown

\n Visit /fp to view the Fiberplane API explorer.\n

\n\n\n\n`.trim());\n});\n\nexport default app;",[19,89],"7114d72a-56a3-11f0-b69c-f69ea79377d9","auth.ts","c050f892-bdf4-49dc-be11-063f2ab584fb",["D",1751392042447],"import { timingSafeEqual } from \"https://deno.land/std/crypto/mod.ts\";\n\nimport { HTTPException } from \"../deps/hono.ts\";\nimport type { AppMiddleware } from \"./types.ts\";\n\n/**\n * Middleware that authenticates requests with a Bearer token.\n * Assumes that `AUTH_TOKEN` is set in the environment.\n *\n * @TODO - Improve token comparison.\n * Simple string comparison is not very secure against timing attacks.\n */\nexport const authenticate: AppMiddleware = async (ctx, next) => {\n const authHeader = ctx.req.header(\"Authorization\");\n\n if (!authHeader?.startsWith(\"Bearer \")) {\n throw new HTTPException(401, {\n message: \"Missing or invalid bearer token\",\n });\n }\n\n const token = authHeader.slice(7);\n\n const isValid = timingSafeTokenComparison(token, ctx.env.AUTH_TOKEN);\n\n if (!isValid) {\n throw new HTTPException(401, {\n message: \"Invalid token\",\n });\n }\n\n await next();\n};\n\n/**\n * Token comparison that mitigates against timing based attacks\n */\nfunction timingSafeTokenComparison(userToken: string, appToken: string) {\n const userTokenByes = new TextEncoder().encode(userToken);\n const appTokenBytes = new TextEncoder().encode(appToken);\n \n // Check if lengths match (this is considered acceptable to reveal)\n if (userTokenByes.length !== appTokenBytes.length) {\n return false;\n }\n \n // Perform constant-time comparison\n const isValid = timingSafeEqual(userTokenByes, appTokenBytes);\n\n return isValid;\n}",[19,95],"7114e6fc-56a3-11f0-b69c-f69ea79377d9",["D",1751392042447],"directory",[19],{"_36":100,"_13":19,"_65":68,"_67":-5,"_69":70,"_71":32,"_72":73,"_38":254,"_17":34,"_75":102,"_77":-5,"_79":51,"_80":-5,"_117":255,"_18":256},{"_36":201,"_13":202,"_65":203,"_67":-5,"_69":70,"_71":32,"_72":73,"_38":204,"_17":34,"_75":102,"_77":-5,"_79":51,"_80":-5,"_117":205,"_18":206},{"_36":171,"_13":172,"_65":173,"_67":-5,"_69":70,"_71":32,"_72":73,"_38":174,"_17":34,"_75":102,"_77":-5,"_79":51,"_80":-5,"_117":175,"_18":176},{"_36":142,"_13":143,"_65":144,"_67":-5,"_69":70,"_71":32,"_72":73,"_38":145,"_17":34,"_75":102,"_77":-5,"_79":51,"_80":-5,"_117":146,"_18":147},{"_36":135,"_13":136,"_65":137,"_67":-5,"_69":70,"_71":32,"_72":73,"_38":138,"_17":34,"_75":24,"_77":139,"_79":51,"_80":-5,"_117":140,"_18":141},{"_36":127,"_13":128,"_65":129,"_67":-5,"_69":70,"_71":32,"_72":73,"_38":130,"_17":34,"_75":131,"_77":132,"_79":51,"_80":-5,"_117":133,"_18":134},{"_36":120,"_13":121,"_65":122,"_67":-5,"_69":70,"_71":32,"_72":73,"_38":123,"_17":34,"_75":76,"_77":124,"_79":51,"_80":-5,"_117":125,"_18":126},{"_36":112,"_13":113,"_65":114,"_67":-5,"_69":70,"_71":32,"_72":73,"_38":115,"_17":34,"_75":76,"_77":116,"_79":51,"_80":-5,"_117":118,"_18":119},"7115158c-56a3-11f0-b69c-f69ea79377d9","openapi.ts","0130e156-9801-4c4c-8ac6-6d1cdcbe3ce1",["D",1751392042447],"/**\n * A manually generated OpenAPI spec, to be able to use the Fiberplane library \n * with a better experience\n */\nexport function getOpenAPISpec() {\n return {\n openapi: \"3.0.0\",\n info: {\n title: \"Fiberplane OpenTelemetry Collector\",\n version: \"1.0.0\",\n },\n // TODO - Add auth scheme\n paths: {\n \"/v1/traces\": {\n get: {\n summary: \"Get traces\",\n description: \"Get traces\",\n responses: {\n 200: {\n description: \"OK\",\n },\n },\n },\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 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: { ... }\n },\n },\n },\n responses: {\n 200: {\n description: \"OK\",\n },\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}","children",[],[113],"7115141a-56a3-11f0-b69c-f69ea79377d9","logger.ts","e3735549-23a8-40f3-8f22-1cb95ee63d88",["D",1751392042447],"/**\n * Logging interface, v simple\n */\nexport const logger = {\n info: console.log.bind(console),\n warn: console.warn.bind(console),\n error: console.error.bind(console),\n};",[],[121],"71151226-56a3-11f0-b69c-f69ea79377d9","index.ts","3e2763e1-b6d3-4dcd-84d3-f05db0444f49",["D",1751392042447],"http","import home from \"./app/home.ts\";\nimport traces from \"./app/traces.ts\";\nimport type { AppType } from \"./app/types.ts\";\nimport { db } from \"./db/client.ts\";\nimport { migrateDatabase } from \"./db/migrate.ts\";\nimport { createFiberplane } from \"./deps/fiberplane.ts\";\nimport { Hono, HTTPException } from \"./deps/hono.ts\";\nimport { getOpenAPISpec } from \"./openapi.ts\";\n\n// Migrate database on startup to make sure the proper table exists to store spans\nawait migrateDatabase();\n\nconst app = new Hono();\n\n/**\n * Middleware for setting up the database and storing it on the Hono app's context\n */\napp.use(async (ctx, next) => {\n ctx.set(\"db\", db);\n await next();\n});\n\n/** Mount the routes that handle tracing exports and queries */\napp.route(\"/v1/traces\", traces);\n\n/**\n * Mount the Fiberplane api playground\n * Visit /fp to view the UI\n */\napp.use(\n \"/fp/*\",\n createFiberplane({\n openapi: { content: JSON.stringify(getOpenAPISpec()) },\n }),\n);\n\napp.route(\"/\", home);\n\n// Unwrap and rethrow Hono errors as the original error\n// If you delete this, all errors will be \"Internal Server Error\"\napp.onError((err: unknown) => {\n if (err instanceof HTTPException) {\n return err.getResponse();\n }\n throw err;\n});\n\n/**\n * Export a function that wraps the incoming request,\n * then injects the Deno env vars into the Hono app befoe\n * executing the api entrypoint (`app.fetch`)\n */\nexport default async function(req: Request): Promise {\n const env = Deno.env.toObject();\n // NOTE - Adding the entire env object will also expose the following values to your api handlers:\n //\n // * `valtown`\n // * `VAL_TOWN_API_KEY`\n // * `VALTOWN_API_URL`\n //\n // If you don't want those values, remove them from the env object\n return app.fetch(req, env);\n}",[],[128],"71150f56-56a3-11f0-b69c-f69ea79377d9","README.md","6638b57a-22d9-48f3-918c-7a8f38b89ba8",["D",1751392042447],"## What is this?\n\nYou're looking at a self-hosted OpenTelemetry tracing collector on ValTown, my friend!\n\nMore specifically, this is a service you can fork and run that receives traces from Hono APIs\nthat have been instrumented with `@fiberplane/hono-otel`.\n\nUnder the hood, it uses OpenTelemetry's javascript libraries to receive traces,\nthen it transforms and stores the tracing data in a sqlite db on ValTown.\n\nA Hono api exposes HTTP endpoints for receiving and querying traces,\nand we mount a Fiberplane API Playground to be able test the routes out.\n\n## Deploying this service\n\nAll you gotta do is:\n\n1. Fork this project\n2. Add a secure token to the environment variable `AUTH_TOKEN`\n\n## Connecting a Service\n\nCreate a Hono app, or fork the sample here:\n\nhttps://www.val.town/v/fiberplane/fiberplaneHonoTracingStarter\n\nThen, in your service, you'll just need to configure environment variables to point to your instance of the OpenTelemetry collector.\n\n```sh\nFIBERPLANE_OTEL_ENDPOINT=https://fiberplane--63a45c54f65a11efa403569c3dd06744.web.val.run/v1/traces\nFIBERPLANE_OTEL_TOKEN=secret-token-for-valtown-fiberplane-otel-collector\n```\n\n> The `FIBERPLANE_OTEL_TOKEN` in your connected service should be the same value that you configured as the `AUTH_TOKEN` in the collector.\n\n## Rough Edges\n\nDeno support can vary with OpenTelemetry's javascript libraries. We're working on improving things, but here are a few issues we've noticed:\n\n- Log statements are recorded twice",[],[136],"71150dd0-56a3-11f0-b69c-f69ea79377d9","otel","06588540-1980-4e3f-9905-facb9abab7f9",["D",1751392042447],[148,149,150],[143],{"_36":164,"_13":165,"_65":166,"_67":144,"_69":70,"_71":32,"_72":73,"_38":167,"_17":34,"_75":76,"_77":168,"_79":51,"_80":-5,"_117":169,"_18":170},{"_36":157,"_13":158,"_65":159,"_67":144,"_69":70,"_71":32,"_72":73,"_38":160,"_17":34,"_75":76,"_77":161,"_79":51,"_80":-5,"_117":162,"_18":163},{"_36":151,"_13":64,"_65":152,"_67":144,"_69":70,"_71":32,"_72":73,"_38":153,"_17":34,"_75":76,"_77":154,"_79":51,"_80":-5,"_117":155,"_18":156},"71150c40-56a3-11f0-b69c-f69ea79377d9","f73ae594-5d36-4883-93ee-809501ef8105",["D",1751392042447],"import type { OtelSpan } from \"../deps/fiberplane\";\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\";\n\nexport type { OtelSpan };\nexport type { ESpanKind, EStatusCode, IAnyValue, IEvent, IExportTraceServiceRequest, IKeyValue, ILink, IStatus };\nexport type {\n ESpanKind,\n EStatusCode,\n IAnyValue,\n IEvent,\n IExportTraceServiceRequest,\n IKeyValue,\n ILink,\n IStatus,\n}",[],[143,64],"71150312-56a3-11f0-b69c-f69ea79377d9","transformExport.ts","c25bc439-8db2-4960-816f-71b878562dd4",["D",1751392042447],"import type {\n ESpanKind,\n EStatusCode,\n IAnyValue,\n IEvent,\n IExportTraceServiceRequest,\n IKeyValue,\n ILink,\n IStatus,\n OtelSpan,\n} from \"../types.ts\";\nimport { OtelSpanSchema } from \"./schemas.ts\";\n\n/**\n * Port of the Fiberplane rust code that transforms traces into the format we use in the Fiberplane UI.\n * (See: https://github.com/fiberplane/otel-worker)\n *\n * A few differences between this and the Rust version of the fiberplane/otel-worker:\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 */\nexport async function transformExport(\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};",[],[143,158],"71150150-56a3-11f0-b69c-f69ea79377d9","schemas.ts","99bb9e44-9692-4952-abbc-d72716040081",["D",1751392042447],"// NOTE - Import fpx-types with `npm:` specified because exports don't _seem_ to\n// get picked up properly by typescript when using esm.sh\nimport { OtelSpanSchema } from \"../deps/fiberplane.ts\";\n\nexport { OtelSpanSchema };",[],[143,165],"7114fff2-56a3-11f0-b69c-f69ea79377d9","deps","f1924f9c-a445-4b05-9e09-78db6c1d473f",["D",1751392042447],[177,178,179],[172],{"_36":194,"_13":195,"_65":196,"_67":173,"_69":70,"_71":32,"_72":73,"_38":197,"_17":34,"_75":76,"_77":198,"_79":51,"_80":-5,"_117":199,"_18":200},{"_36":187,"_13":188,"_65":189,"_67":173,"_69":70,"_71":32,"_72":73,"_38":190,"_17":34,"_75":76,"_77":191,"_79":51,"_80":-5,"_117":192,"_18":193},{"_36":180,"_13":181,"_65":182,"_67":173,"_69":70,"_71":32,"_72":73,"_38":183,"_17":34,"_75":76,"_77":184,"_79":51,"_80":-5,"_117":185,"_18":186},"7114fdc2-56a3-11f0-b69c-f69ea79377d9","hono.ts","aec78afb-0a08-429a-898e-81325d219aa2",["D",1751392042447],"/**\n * Module that centralizes all Hono deps, to avoid using multiple imports of the library\n *\n * \"Why?\", you might ask.\n *\n * Well, Hono's type system freaks out if you import it multiple times,\n * so this avoids the case where one file accidentally imports a different version \n * (from esm.sh or npm)\n */\n\nimport { Hono, type MiddlewareHandler } from \"https://esm.sh/hono@4.7.0\";\nimport { cors } from \"https://esm.sh/hono@4.7.0/cors\";\nimport { HTTPException } from \"https://esm.sh/hono@4.7.0/http-exception\";\n\nexport { Hono, cors, type MiddlewareHandler, HTTPException };",[],[172,181],"7114f5b6-56a3-11f0-b69c-f69ea79377d9","fiberplane.ts","6b8946cc-8cc6-4d6a-bab8-b18161492c08",["D",1751392042447],"// NOTE - Import fpx-types with `npm:` specified because exports don't _seem_ to\n// get picked up properly by typescript when using esm.sh\nimport {\n type OtelSpan,\n OtelSpanSchema,\n type TraceDetailSpansResponse,\n type TraceListResponse,\n} from \"npm:@fiberplane/fpx-types@0.0.13\";\n\nimport { createFiberplane } from \"https://esm.sh/@fiberplane/hono@0.4.4\";\n\nexport { OtelSpanSchema };\nexport type { OtelSpan, TraceDetailSpansResponse, TraceListResponse };\nexport { createFiberplane };",[],[172,188],"7114f43a-56a3-11f0-b69c-f69ea79377d9","drizzle.ts","676ca88a-79c6-4c89-be28-0e9fbc861991",["D",1751392042447],"// Import drizzle deps with npm: specifier because exports don't get picked up properly by typescript when using esm.sh\nimport { drizzle, type LibSQLDatabase } from \"npm:drizzle-orm@0.39.3/libsql\";\nimport { and, desc, relations, sql } from \"npm:drizzle-orm@0.39.3\";\nimport { integer, sqliteTable, text } from \"npm:drizzle-orm@0.39.3/sqlite-core\";\n\nexport { drizzle };\nexport type { LibSQLDatabase };\nexport { and, desc, relations, sql };\nexport { integer, sqliteTable, text };",[],[172,195],"7114f2be-56a3-11f0-b69c-f69ea79377d9","db","2a150777-2d03-4223-8c1d-8ddd8e1acbff",["D",1751392042447],[207,208,209,210,211,212],[202],{"_36":247,"_13":248,"_65":249,"_67":203,"_69":70,"_71":32,"_72":73,"_38":250,"_17":34,"_75":76,"_77":251,"_79":51,"_80":-5,"_117":252,"_18":253},{"_36":240,"_13":241,"_65":242,"_67":203,"_69":70,"_71":32,"_72":73,"_38":243,"_17":34,"_75":76,"_77":244,"_79":51,"_80":-5,"_117":245,"_18":246},{"_36":233,"_13":234,"_65":235,"_67":203,"_69":70,"_71":32,"_72":73,"_38":236,"_17":34,"_75":76,"_77":237,"_79":51,"_80":-5,"_117":238,"_18":239},{"_36":226,"_13":227,"_65":228,"_67":203,"_69":70,"_71":32,"_72":73,"_38":229,"_17":34,"_75":76,"_77":230,"_79":51,"_80":-5,"_117":231,"_18":232},{"_36":219,"_13":220,"_65":221,"_67":203,"_69":70,"_71":32,"_72":73,"_38":222,"_17":34,"_75":76,"_77":223,"_79":51,"_80":-5,"_117":224,"_18":225},{"_36":213,"_13":64,"_65":214,"_67":203,"_69":70,"_71":32,"_72":73,"_38":215,"_17":34,"_75":76,"_77":216,"_79":51,"_80":-5,"_117":217,"_18":218},"7114f156-56a3-11f0-b69c-f69ea79377d9","905a3654-33ce-417f-bea6-3e349ff349b3",["D",1751392042447],"import type { LibSQLDatabase } from \"../deps/drizzle.ts\";\nimport type * as schema from \"./schema\";\n\nexport type DBType = LibSQLDatabase;",[],[202,64],"7114ef58-56a3-11f0-b69c-f69ea79377d9","schema.ts","d28b6dfe-0e07-42e0-bfd6-1d0b49d6120d",["D",1751392042447],"import { integer, sqliteTable, text } from \"../deps/drizzle.ts\";\nimport { SPAN_TABLE_NAME } from \"./constants.ts\";\nimport { OtelSpan } from \"../otel/schemas.ts\";\n\nexport const otelSpans = sqliteTable(SPAN_TABLE_NAME, {\n inner: text(\"inner\", { mode: \"json\" }).$type().notNull(),\n spanId: text(\"span_id\").notNull(),\n traceId: text(\"trace_id\").notNull(),\n});",[],[202,220],"7114edaa-56a3-11f0-b69c-f69ea79377d9","queries.ts","54ddb07c-b633-4e42-956b-4057a4b61819",["D",1751392042447],"import type { DBType } from \"./types.ts\";\n\n/**\n * NOT IN USE\n *\n * @TODO - Implement query helper for grouping spans by trace_id and sorting by end_time\n *\n * @TODO - Need to implement `end_time` column for this query to work\n */\nexport function findTraces(db: DBType) {\n const REFERENCE QUERY = `\nSELECT trace_id, MAX(end_time) as end_time\nFROM spans\n{where_clause}\nGROUP BY trace_id\nORDER BY end_time DESC\nLIMIT {limit}\n`;\n}",[],[202,227],"7114ec10-56a3-11f0-b69c-f69ea79377d9","migrate.ts","149360de-a2a1-4882-9ce8-5e35411e7198",["D",1751392042447],"import { sqlite } from \"https://esm.town/v/std/sqlite\";\nimport { SPAN_TABLE_NAME } from \"./constants.ts\";\n\n/**\n * @NOTE - It is not straightforward how to use drizzle-kit to generate and apply migrations on ValTown\n * For this reason, we need to manually create the span table.\n *\n * @TODO - Add `start_time` and `end_time` columns\n */\nexport const migrateDatabase = async () => {\n await sqlite.execute(`\nCREATE TABLE IF NOT EXISTS \\`${SPAN_TABLE_NAME}\\` (\n \\`inner\\` text NOT NULL,\n\t\\`span_id\\` text NOT NULL,\n\t\\`trace_id\\` text NOT NULL\n);\n`);\n};",[],[202,234],"7114ea12-56a3-11f0-b69c-f69ea79377d9","constants.ts","4da20035-44ed-4a1c-b179-42742eae0c07",["D",1751392042447],"/**\n * Since we can't rely on drizzle-kit to generate and apply migrations,\n * we centralize the table name for spans here, to reference it in both \n * the `schema.ts` file and the `migrate.ts` file.\n */\nexport const SPAN_TABLE_NAME = \"otel_spans\";",[],[202,241],"7114e88c-56a3-11f0-b69c-f69ea79377d9","client.ts","2c8c576e-83b5-429f-ac20-487a60f78be8",["D",1751392042447],"import { sqlite } from \"https://esm.town/v/std/sqlite\";\nimport { drizzle } from \"../deps/drizzle.ts\";\nimport * as schema from \"./schema.ts\";\nimport type { DBType } from \"./types.ts\";\n\n/**\n * The typed database client, allowing us to construct sql queries and\n * use Drizzle's ORM features against the ValTown sqlite database\n */\nexport const db: DBType = drizzle(sqlite as any, {\n schema,\n});",[],[202,248],["D",1751392042447],[257,258,259,260],[19],{"_36":94,"_13":95,"_65":96,"_67":68,"_69":70,"_71":32,"_72":73,"_38":270,"_17":34,"_75":76,"_77":98,"_79":51,"_80":-5,"_117":271,"_18":272},{"_36":88,"_13":89,"_65":90,"_67":68,"_69":70,"_71":32,"_72":73,"_38":267,"_17":34,"_75":76,"_77":92,"_79":51,"_80":-5,"_117":268,"_18":269},{"_36":82,"_13":83,"_65":84,"_67":68,"_69":70,"_71":32,"_72":73,"_38":264,"_17":34,"_75":76,"_77":86,"_79":51,"_80":-5,"_117":265,"_18":266},{"_36":63,"_13":64,"_65":66,"_67":68,"_69":70,"_71":32,"_72":73,"_38":261,"_17":34,"_75":76,"_77":78,"_79":51,"_80":-5,"_117":262,"_18":263},["D",1751392042447],[],[19,64],["D",1751392042447],[],[19,83],["D",1751392042447],[],[19,89],["D",1751392042447],[],[19,95],"710bcdb0-56a3-11f0-b69c-f69ea79377d9",["D",1751392042447],"legacyEnvVars","httpPrivacy","description","imageUrl","userId","5f1bc9c0-56a3-11f0-b531-9587892f9129","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount","c4375f8b-60ac-443a-b5e5-43fad7424908","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_11":12,"_315":311},"org",{"_11":12,"_309":-5,"_310":311,"_279":280,"_312":313,"_314":51},"branch",{"_17":32,"_13":16,"_36":70,"_42":273,"_45":37,"_46":44,"_306":53,"_307":43,"_308":57,"_58":14,"_54":12},"forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","displayName","avatar","https://img.clerk.com/eyJ0eXBlIjoicHJveHkiLCJzcmMiOiJodHRwczovL2ltYWdlcy5jbGVyay5kZXYvb2F1dGhfZ2l0aHViL2ltZ18yekhkWWdpOGhJVEhNa1g2WXdNNnlSUEVMZ3oifQ","tier","free","canRestrictVals","profileImageUrl","adoptOrgId",{"_36":273,"_13":14,"_38":432,"_49":-5,"_275":51,"_52":53,"_276":53,"_277":-5,"_278":-5,"_279":280,"_281":129,"_282":73,"_283":73,"_284":-5,"_285":34,"_56":286,"_287":-5,"_288":-5,"_289":-5,"_290":-5,"_291":292,"_293":292,"_294":295,"_296":295,"_297":295,"_298":292,"_299":292,"_300":433,"_302":434,"_304":435,"_50":51},[360,365,372,376,380,381,382,383],"files",[360,361,362,363,364,365,366,367,368,369,370,371,372,373,374,375,376,377,378,379,380,381,382,383],"counts",{"_351":34,"_352":32,"_353":34,"_35":354,"_355":356},[343,344,345,346],{"_36":100,"_13":19,"_65":68,"_67":-5,"_69":70,"_71":32,"_72":73,"_38":101,"_17":34,"_75":102,"_77":-5,"_79":51,"_80":-5,"_18":342},"upstreamProject",{"_36":43,"_13":14,"_277":339,"_278":-5,"_52":53,"_300":340},"upstreamBranch",{"_36":37,"_38":337,"_40":338,"_13":16,"_42":43,"_17":44,"_45":-5,"_46":-5,"_47":48,"_49":-5,"_50":51,"_52":53,"_54":55,"_56":57,"_58":14},"emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},["D",1740805324568],["D",1740836480150],"Receive traces from @fiberplane/hono-otel, and store in sqlite",{"_11":55,"_315":341},"https://img.clerk.com/eyJ0eXBlIjoicHJveHkiLCJzcmMiOiJodHRwczovL2ltYWdlcy5jbGVyay5kZXYvdXBsb2FkZWQvaW1nXzJ0OXJLaXVodjZKMUU4QnFhODNCVkJ4aVRQSyJ9",[19],{"_36":94,"_13":95,"_65":96,"_67":68,"_69":70,"_71":32,"_72":73,"_38":97,"_17":34,"_75":76,"_77":98,"_79":51,"_80":-5,"_18":350},{"_36":88,"_13":89,"_65":90,"_67":68,"_69":70,"_71":32,"_72":73,"_38":91,"_17":34,"_75":76,"_77":92,"_79":51,"_80":-5,"_18":349},{"_36":82,"_13":83,"_65":84,"_67":68,"_69":70,"_71":32,"_72":73,"_38":85,"_17":34,"_75":76,"_77":86,"_79":51,"_80":-5,"_18":348},{"_36":63,"_13":64,"_65":66,"_67":68,"_69":70,"_71":32,"_72":73,"_38":74,"_17":34,"_75":76,"_77":78,"_79":51,"_80":-5,"_18":347},[19,64],[19,83],[19,89],[19,95],"pulls","branches","forks",{"_357":32,"_359":32},"connections",{"_357":34,"_358":34},"count","unfilledCount","emptyCount",{"_36":100,"_13":19,"_65":68,"_67":-5,"_69":70,"_71":32,"_72":73,"_38":254,"_17":34,"_75":102,"_77":-5,"_79":51,"_80":-5,"_117":430,"_18":431},{"_36":94,"_13":95,"_65":96,"_67":68,"_69":70,"_71":32,"_72":73,"_38":270,"_17":34,"_75":76,"_77":98,"_79":51,"_80":-5,"_117":428,"_18":429},{"_36":88,"_13":89,"_65":90,"_67":68,"_69":70,"_71":32,"_72":73,"_38":267,"_17":34,"_75":76,"_77":92,"_79":51,"_80":-5,"_117":426,"_18":427},{"_36":82,"_13":83,"_65":84,"_67":68,"_69":70,"_71":32,"_72":73,"_38":264,"_17":34,"_75":76,"_77":86,"_79":51,"_80":-5,"_117":424,"_18":425},{"_36":63,"_13":64,"_65":66,"_67":68,"_69":70,"_71":32,"_72":73,"_38":261,"_17":34,"_75":76,"_77":78,"_79":51,"_80":-5,"_117":422,"_18":423},{"_36":201,"_13":202,"_65":203,"_67":-5,"_69":70,"_71":32,"_72":73,"_38":204,"_17":34,"_75":102,"_77":-5,"_79":51,"_80":-5,"_117":420,"_18":421},{"_36":247,"_13":248,"_65":249,"_67":203,"_69":70,"_71":32,"_72":73,"_38":250,"_17":34,"_75":76,"_77":251,"_79":51,"_80":-5,"_117":418,"_18":419},{"_36":240,"_13":241,"_65":242,"_67":203,"_69":70,"_71":32,"_72":73,"_38":243,"_17":34,"_75":76,"_77":244,"_79":51,"_80":-5,"_117":416,"_18":417},{"_36":233,"_13":234,"_65":235,"_67":203,"_69":70,"_71":32,"_72":73,"_38":236,"_17":34,"_75":76,"_77":237,"_79":51,"_80":-5,"_117":414,"_18":415},{"_36":226,"_13":227,"_65":228,"_67":203,"_69":70,"_71":32,"_72":73,"_38":229,"_17":34,"_75":76,"_77":230,"_79":51,"_80":-5,"_117":412,"_18":413},{"_36":219,"_13":220,"_65":221,"_67":203,"_69":70,"_71":32,"_72":73,"_38":222,"_17":34,"_75":76,"_77":223,"_79":51,"_80":-5,"_117":410,"_18":411},{"_36":213,"_13":64,"_65":214,"_67":203,"_69":70,"_71":32,"_72":73,"_38":215,"_17":34,"_75":76,"_77":216,"_79":51,"_80":-5,"_117":408,"_18":409},{"_36":171,"_13":172,"_65":173,"_67":-5,"_69":70,"_71":32,"_72":73,"_38":174,"_17":34,"_75":102,"_77":-5,"_79":51,"_80":-5,"_117":406,"_18":407},{"_36":194,"_13":195,"_65":196,"_67":173,"_69":70,"_71":32,"_72":73,"_38":197,"_17":34,"_75":76,"_77":198,"_79":51,"_80":-5,"_117":404,"_18":405},{"_36":187,"_13":188,"_65":189,"_67":173,"_69":70,"_71":32,"_72":73,"_38":190,"_17":34,"_75":76,"_77":191,"_79":51,"_80":-5,"_117":402,"_18":403},{"_36":180,"_13":181,"_65":182,"_67":173,"_69":70,"_71":32,"_72":73,"_38":183,"_17":34,"_75":76,"_77":184,"_79":51,"_80":-5,"_117":400,"_18":401},{"_36":142,"_13":143,"_65":144,"_67":-5,"_69":70,"_71":32,"_72":73,"_38":145,"_17":34,"_75":102,"_77":-5,"_79":51,"_80":-5,"_117":398,"_18":399},{"_36":164,"_13":165,"_65":166,"_67":144,"_69":70,"_71":32,"_72":73,"_38":167,"_17":34,"_75":76,"_77":168,"_79":51,"_80":-5,"_117":396,"_18":397},{"_36":157,"_13":158,"_65":159,"_67":144,"_69":70,"_71":32,"_72":73,"_38":160,"_17":34,"_75":76,"_77":161,"_79":51,"_80":-5,"_117":394,"_18":395},{"_36":151,"_13":64,"_65":152,"_67":144,"_69":70,"_71":32,"_72":73,"_38":153,"_17":34,"_75":76,"_77":154,"_79":51,"_80":-5,"_117":392,"_18":393},{"_36":135,"_13":136,"_65":137,"_67":-5,"_69":70,"_71":32,"_72":73,"_38":138,"_17":34,"_75":24,"_77":139,"_79":51,"_80":-5,"_117":390,"_18":391},{"_36":127,"_13":128,"_65":129,"_67":-5,"_69":70,"_71":32,"_72":73,"_38":130,"_17":34,"_75":131,"_77":132,"_79":51,"_80":-5,"_117":388,"_18":389},{"_36":120,"_13":121,"_65":122,"_67":-5,"_69":70,"_71":32,"_72":73,"_38":123,"_17":34,"_75":76,"_77":124,"_79":51,"_80":-5,"_117":386,"_18":387},{"_36":112,"_13":113,"_65":114,"_67":-5,"_69":70,"_71":32,"_72":73,"_38":115,"_17":34,"_75":76,"_77":116,"_79":51,"_80":-5,"_117":384,"_18":385},[],[113],[],[121],[],[128],[],[136],[],[143,64],[],[143,158],[],[143,165],[377,378,379],[143],[],[172,181],[],[172,188],[],[172,195],[373,374,375],[172],[],[202,64],[],[202,220],[],[202,227],[],[202,234],[],[202,241],[],[202,248],[366,367,368,369,370,371],[202],[],[19,64],[],[19,83],[],[19,89],[],[19,95],[361,362,363,364],[19],["D",1751392042447],{"_11":12,"_315":311},{"_11":12,"_309":-5,"_310":311,"_279":280,"_312":313,"_314":51},{"_17":32,"_13":16,"_36":70,"_42":273,"_45":37,"_46":44,"_306":53,"_307":43,"_308":57,"_58":14,"_54":12},"ctx",{"_300":-5,"_334":469,"_470":471,"_472":473,"_474":51,"_475":51,"_476":51,"_477":73,"_478":-5,"_479":-7,"_480":-7,"_481":34,"_482":51,"_483":51,"_484":-5,"_485":51,"_486":51,"_487":51,"_488":-5},"ENV",{"_440":441,"_442":443,"_444":16,"_445":446,"_447":448,"_449":450,"_451":452,"_453":454,"_455":456,"_457":458,"_459":460,"_461":462,"_463":464,"_465":466,"_467":468},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","c73f21da490985bff19c279eb0e09db24d688e4f","RENDER_GIT_BRANCH","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","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]