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;",[],[149,179],{"_106":187,"_99":188,"_150":189,"_152":151,"_153":139,"_154":190,"_156":121,"_108":191,"_103":192,"_159":173,"_161":193,"_162":27,"_163":-5,"_164":194,"_102":195},"35479f96-f679-11ef-a77c-569c3dd06744","traces.ts","4340ac56-f669-11ef-97cc-569c3dd06744",261,["D",1740818591704],9,"import * as schema from \"../db/schema.ts\";\nimport { and, desc, relations, sql } from \"../deps/drizzle.ts\";\nimport { Hono } from \"../deps/hono.ts\";\nimport { logger } from \"../logger.ts\";\nimport { OtelSpanSchema } from \"../otel/schemas.ts\";\nimport { transformExport } from \"../otel/transformExport.ts\";\nimport type { IExportTraceServiceRequest } from \"../otel/types.ts\";\nimport { authenticate } from \"./auth.ts\";\nimport type { AppType, TraceDetailSpansResponse, TraceListResponse } from \"./types.ts\";\n\nconst app = new Hono();\n\n/**\n * Set up token based authentication for all tracing routes\n */\napp.use(authenticate);\n\n/**\n * Fetch all traces.\n *\n * Limits response to 1000 most recent spans\n *\n * @TODO - Move grouping logic to sql query, similar to the otel-worker\n */\napp.get(\"/\", 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\n/**\n * Fetch all spans for a given trace.\n *\n * @TODO - Use similar sql query as the otel-worker\n */\napp.get(\"/: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(\"/\", async (ctx) => {\n const db = ctx.get(\"db\");\n const body: IExportTraceServiceRequest = await ctx.req.json();\n\n try {\n const tracesPayload = (await transformExport(body)).map(\n (span) =>\n ({\n inner: OtelSpanSchema.parse(span),\n spanId: span.span_id,\n traceId: span.trace_id,\n }) satisfies typeof schema.otelSpans.$inferInsert,\n );\n\n try {\n if (tracesPayload.length > 0) {\n await db.insert(schema.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\nexport default app;",[],[149,188],{"_106":197,"_99":198,"_150":199,"_152":151,"_153":139,"_154":138,"_156":121,"_108":200,"_103":201,"_159":173,"_161":202,"_162":27,"_163":-5,"_164":203,"_102":204},"db9fedfc-f6a2-11ef-a502-569c3dd06744","types.ts","969af970-f663-11ef-b4b9-569c3dd06744",["D",1740836480150],16,"import type {\n TraceDetailSpansResponse,\n TraceListResponse,\n} from \"../deps/fiberplane.ts\";\nimport type { MiddlewareHandler } from \"../deps/hono.ts\";\nimport type { DBType } from \"../db/types.ts\";\n\n/**\n * Our Hono app type\n * \n * Optimisitically types the values we expect in our environment and context:\n *\n * - `Bindings` determines env vars, accessed via `c.env.NAME_OF_VAR` in api handlers\n * - `Variables` determines context vars, accessed via `c.get(\"NAME_OF_VAR\")` in api handlers\n */\nexport type AppType = {\n Bindings: {\n /**\n * Bearer token used to authenticate requests\n */\n AUTH_TOKEN: string;\n };\n Variables: {\n db: DBType;\n };\n};\n\nexport type AppMiddleware = MiddlewareHandler;\n\nexport type { TraceDetailSpansResponse, TraceListResponse };",[],[149,198],[149],{"_106":207,"_99":208,"_150":209,"_152":-5,"_153":139,"_154":172,"_156":121,"_108":210,"_103":158,"_159":160,"_161":-5,"_162":27,"_163":-5,"_164":211,"_102":271},"9cbeff30-f65a-11ef-9281-569c3dd06744","db","9a42da06-f65a-11ef-b0ab-569c3dd06744",["D",1740805450893],[212,222,232,242,252,262],{"_106":213,"_99":214,"_150":215,"_152":209,"_153":139,"_154":216,"_156":121,"_108":217,"_103":218,"_159":173,"_161":219,"_162":27,"_163":-5,"_164":220,"_102":221},"2cecd774-f667-11ef-afd0-569c3dd06744","client.ts","18435d20-f65d-11ef-9799-569c3dd06744",174,["D",1740810846746],7,"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});",[],[208,214],{"_106":223,"_99":224,"_150":225,"_152":209,"_153":139,"_154":226,"_156":121,"_108":227,"_103":228,"_159":173,"_161":229,"_162":27,"_163":-5,"_164":230,"_102":231},"06742192-f667-11ef-a5e2-569c3dd06744","constants.ts","0282266c-f660-11ef-b120-569c3dd06744",173,["D",1740810782202],3,"/**\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\";",[],[208,224],{"_106":233,"_99":234,"_150":235,"_152":209,"_153":139,"_154":236,"_156":121,"_108":237,"_103":238,"_159":173,"_161":239,"_162":27,"_163":-5,"_164":240,"_102":241},"fb07b1ce-f662-11ef-a384-569c3dd06744","migrate.ts","91ab864e-f65b-11ef-991f-569c3dd06744",115,["D",1740809045049],6,"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};",[],[208,234],{"_106":243,"_99":244,"_150":245,"_152":209,"_153":139,"_154":246,"_156":121,"_108":247,"_103":248,"_159":173,"_161":249,"_162":27,"_163":-5,"_164":250,"_102":251},"f7797bfa-f662-11ef-8dca-569c3dd06744","queries.ts","3445b1cc-f661-11ef-82f2-569c3dd06744",114,["D",1740809039083],4,"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}",[],[208,244],{"_106":253,"_99":254,"_150":255,"_152":209,"_153":139,"_154":256,"_156":121,"_108":257,"_103":258,"_159":173,"_161":259,"_162":27,"_163":-5,"_164":260,"_102":261},"524e2984-f6a1-11ef-aa65-569c3dd06744","schema.ts","a0be8c54-f65a-11ef-9281-569c3dd06744",276,["D",1740835820270],10,"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});",[],[208,254],{"_106":263,"_99":198,"_150":264,"_152":209,"_153":139,"_154":265,"_156":121,"_108":266,"_103":267,"_159":173,"_161":268,"_162":27,"_163":-5,"_164":269,"_102":270},"d4100252-f666-11ef-a600-569c3dd06744","f7b0986c-f65b-11ef-9265-569c3dd06744",172,["D",1740810697660],5,"import type { LibSQLDatabase } from \"../deps/drizzle.ts\";\nimport type * as schema from \"./schema\";\n\nexport type DBType = LibSQLDatabase;",[],[208,198],[208],{"_106":273,"_99":274,"_150":275,"_152":-5,"_153":139,"_154":276,"_156":121,"_108":277,"_103":158,"_159":160,"_161":-5,"_162":27,"_163":-5,"_164":278,"_102":306},"ce734080-f665-11ef-8cf9-569c3dd06744","deps","cbb2c0fa-f665-11ef-9ae5-569c3dd06744",153,["D",1740810258747],[279,288,297],{"_106":280,"_99":281,"_150":282,"_152":275,"_153":139,"_154":283,"_156":121,"_108":284,"_103":218,"_159":173,"_161":285,"_162":27,"_163":-5,"_164":286,"_102":287},"7d57442a-f666-11ef-9e63-569c3dd06744","drizzle.ts","dea14cc2-f665-11ef-950d-569c3dd06744",169,["D",1740810552164],"// 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 };",[],[274,281],{"_106":289,"_99":290,"_150":291,"_152":275,"_153":139,"_154":292,"_156":121,"_108":293,"_103":238,"_159":173,"_161":294,"_162":27,"_163":-5,"_164":295,"_102":296},"01d614ba-f66c-11ef-b844-569c3dd06744","fiberplane.ts","f4da52f4-f66a-11ef-99d2-569c3dd06744",219,["D",1740812921933],"// 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 };",[],[274,290],{"_106":298,"_99":299,"_150":300,"_152":275,"_153":139,"_154":301,"_156":121,"_108":302,"_103":267,"_159":173,"_161":303,"_162":27,"_163":-5,"_164":304,"_102":305},"861b4dbc-f667-11ef-b307-569c3dd06744","hono.ts","60d5cb7e-f665-11ef-a5af-569c3dd06744",175,["D",1740810996367],"/**\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 };",[],[274,299],[274],{"_106":308,"_99":309,"_150":310,"_152":-5,"_153":139,"_154":311,"_156":121,"_108":312,"_103":158,"_159":160,"_161":-5,"_162":27,"_163":-5,"_164":313,"_102":341},"5862d856-f660-11ef-8789-569c3dd06744","otel","55ff6bba-f660-11ef-8e91-569c3dd06744",96,["D",1740807913185],[314,323,332],{"_106":315,"_99":316,"_150":317,"_152":310,"_153":139,"_154":318,"_156":121,"_108":319,"_103":248,"_159":173,"_161":320,"_162":27,"_163":-5,"_164":321,"_102":322},"326df9a8-f66c-11ef-a80f-569c3dd06744","schemas.ts","5d7d8e6e-f663-11ef-a6e9-569c3dd06744",223,["D",1740813003464],"// 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 };",[],[309,316],{"_106":324,"_99":325,"_150":326,"_152":310,"_153":139,"_154":327,"_156":121,"_108":328,"_103":192,"_159":173,"_161":329,"_162":27,"_163":-5,"_164":330,"_102":331},"64f9186e-f679-11ef-93b4-569c3dd06744","transformExport.ts","5c3a99c8-f660-11ef-8e90-569c3dd06744",265,["D",1740818671720],"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};",[],[309,325],{"_106":333,"_99":198,"_150":334,"_152":310,"_153":139,"_154":335,"_156":121,"_108":336,"_103":337,"_159":173,"_161":338,"_162":27,"_163":-5,"_164":339,"_102":340},"43f17e7c-f679-11ef-91f4-569c3dd06744","856869fc-f65a-11ef-a3bf-569c3dd06744",262,["D",1740818616306],11,"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}",[],[309,198],[309],{"_106":343,"_99":344,"_150":345,"_152":-5,"_153":139,"_154":346,"_156":121,"_108":347,"_103":348,"_159":349,"_161":350,"_162":27,"_163":-5,"_164":351,"_102":352},"6b2856cc-f69d-11ef-bb94-569c3dd06744","README.md","6605e5a0-f66c-11ef-b844-569c3dd06744",273,["D",1740834143978],14,"file","## 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",[],[344],{"_106":354,"_99":355,"_150":119,"_152":-5,"_153":139,"_154":356,"_156":121,"_108":357,"_103":358,"_159":359,"_161":360,"_162":27,"_163":-5,"_164":361,"_102":362},"5fd517e6-f671-11ef-9054-569c3dd06744","index.ts",259,["D",1740815227116],71,"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}",[],[355],{"_106":364,"_99":365,"_150":366,"_152":-5,"_153":139,"_154":367,"_156":121,"_108":368,"_103":228,"_159":173,"_161":369,"_162":27,"_163":-5,"_164":370,"_102":371},"11b02446-f66e-11ef-ac05-569c3dd06744","logger.ts","342552e0-f65e-11ef-9ddd-569c3dd06744",240,["D",1740813807527],"/**\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};",[],[365],{"_106":373,"_99":374,"_150":375,"_152":-5,"_153":139,"_154":376,"_156":121,"_108":377,"_103":192,"_159":173,"_161":378,"_162":27,"_163":-5,"_164":379,"_102":380},"6dd888f8-f66e-11ef-95b1-569c3dd06744","openapi.ts","f007451e-f65d-11ef-a23c-569c3dd06744",242,["D",1740813962142],"/**\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}",[],[374],"files",[147,166,177,186,196,206,212,222,232,242,252,262,272,279,288,297,307,314,323,332,342,353,363,372],"counts",{"_385":33,"_386":158,"_387":33,"_388":158},"pulls","branches","forks","envVars","contents",[391,394,397,400,403,406,409,412],{"_106":148,"_99":149,"_150":151,"_152":-5,"_153":139,"_154":155,"_156":121,"_108":392,"_103":158,"_159":160,"_161":-5,"_162":27,"_163":-5,"_102":393},["D",1740809298190],[149],{"_106":207,"_99":208,"_150":209,"_152":-5,"_153":139,"_154":172,"_156":121,"_108":395,"_103":158,"_159":160,"_161":-5,"_162":27,"_163":-5,"_102":396},["D",1740805450893],[208],{"_106":273,"_99":274,"_150":275,"_152":-5,"_153":139,"_154":276,"_156":121,"_108":398,"_103":158,"_159":160,"_161":-5,"_162":27,"_163":-5,"_102":399},["D",1740810258747],[274],{"_106":308,"_99":309,"_150":310,"_152":-5,"_153":139,"_154":311,"_156":121,"_108":401,"_103":158,"_159":160,"_161":-5,"_162":27,"_163":-5,"_102":402},["D",1740807913185],[309],{"_106":343,"_99":344,"_150":345,"_152":-5,"_153":139,"_154":346,"_156":121,"_108":404,"_103":348,"_159":349,"_161":350,"_162":27,"_163":-5,"_102":405},["D",1740834143978],[344],{"_106":354,"_99":355,"_150":119,"_152":-5,"_153":139,"_154":356,"_156":121,"_108":407,"_103":358,"_159":359,"_161":360,"_162":27,"_163":-5,"_102":408},["D",1740815227116],[355],{"_106":364,"_99":365,"_150":366,"_152":-5,"_153":139,"_154":367,"_156":121,"_108":410,"_103":228,"_159":173,"_161":369,"_162":27,"_163":-5,"_102":411},["D",1740813807527],[365],{"_106":373,"_99":374,"_150":375,"_152":-5,"_153":139,"_154":376,"_156":121,"_108":413,"_103":192,"_159":173,"_161":378,"_162":27,"_163":-5,"_102":414},["D",1740813962142],[374],"upstream","screenshots","emptyEnvVars","routes/_app.x.$handle.$name.branch.$branch.history",{"_97":98,"_99":100,"_101":43,"_104":420,"_424":425,"_658":33,"_659":121},{"_106":107,"_99":100,"_108":421,"_110":-5,"_111":27,"_112":113,"_114":115,"_116":-5,"_12":117,"_118":119,"_120":121,"_122":-5,"_123":33,"_124":125,"_126":125,"_127":128,"_129":128,"_130":128,"_131":125,"_132":27,"_21":422,"_136":423},["D",1740805324568],{"_97":98,"_134":135},{"_103":138,"_99":43,"_106":139,"_140":107,"_141":-5,"_142":-5,"_143":-5,"_144":-5},"history",[426,431,436,441,449,454,463,471,479,487,495,504,512,517,524,532,537,542,549,554,559,566,574,583,591,600,608,616,624,632,640,649],{"_150":199,"_103":138,"_108":427,"_153":139,"_381":428},["D",1740836480150],[429],{"_106":197,"_153":139,"_150":199,"_99":198,"_161":202,"_159":173,"_103":201,"_152":151,"_108":427,"_154":138,"_163":-5,"_156":121,"_162":27,"_102":430},[149,198],{"_150":255,"_103":256,"_108":432,"_153":139,"_381":433},["D",1740835820270],[434],{"_106":253,"_153":139,"_150":255,"_99":254,"_161":259,"_159":173,"_103":258,"_152":209,"_108":432,"_154":256,"_163":-5,"_156":121,"_162":27,"_102":435},[208,254],{"_150":169,"_103":170,"_108":437,"_153":139,"_381":438},["D",1740834483467],[439],{"_106":167,"_153":139,"_150":169,"_99":168,"_161":174,"_159":173,"_103":172,"_152":151,"_108":437,"_154":170,"_163":-5,"_156":121,"_162":27,"_102":440},[149,168],{"_150":169,"_103":442,"_108":443,"_153":139,"_381":444},274,["D",1740834281569],[445],{"_106":446,"_153":139,"_150":169,"_99":168,"_161":447,"_159":173,"_103":337,"_152":151,"_108":443,"_154":442,"_163":-5,"_156":27,"_162":27,"_102":448},"bd2bb338-f69d-11ef-8a03-569c3dd06744","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 = token === ctx.env.AUTH_TOKEN;\n if (!isValid) {\n throw new HTTPException(401, {\n message: \"Invalid token\",\n });\n }\n\n await next();\n};",[149,168],{"_150":345,"_103":346,"_108":450,"_153":139,"_381":451},["D",1740834143978],[452],{"_106":343,"_153":139,"_150":345,"_99":344,"_161":350,"_159":349,"_103":348,"_152":-5,"_108":450,"_154":346,"_163":-5,"_156":121,"_162":27,"_102":453},[344],{"_150":345,"_103":455,"_108":456,"_153":139,"_381":457},272,["D",1740834101877],[458],{"_106":459,"_153":139,"_150":345,"_99":344,"_161":460,"_159":349,"_103":461,"_152":-5,"_108":456,"_154":455,"_163":-5,"_156":27,"_162":27,"_102":462},"521096f4-f69d-11ef-941e-569c3dd06744","## 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\n**TODO**\n- [x] Link to the Val honoAppWithTracing\n- [x] Explain configuration\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",13,[344],{"_150":345,"_103":464,"_108":465,"_153":139,"_381":466},271,["D",1740834072693],[467],{"_106":468,"_153":139,"_150":345,"_99":344,"_161":469,"_159":349,"_103":172,"_152":-5,"_108":465,"_154":464,"_163":-5,"_156":27,"_162":27,"_102":470},"40ab2d98-f69d-11ef-bb5e-569c3dd06744","## 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 sets up HTTP endpoints for receiving and querying traces,\nand we mount a Fiberplane API Playground to be able test the routes ourselves\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\n**TODO**\n- [x] Link to the Val honoAppWithTracing\n- [x] Explain configuration\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",[344],{"_150":345,"_103":472,"_108":473,"_153":139,"_381":474},270,["D",1740834040703],[475],{"_106":476,"_153":139,"_150":345,"_99":344,"_161":477,"_159":349,"_103":337,"_152":-5,"_108":473,"_154":472,"_163":-5,"_156":27,"_162":27,"_102":478},"2d99e334-f69d-11ef-93b6-569c3dd06744","## 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 sets up HTTP endpoints for receiving and querying traces,\nand we mount a Fiberplane API Playground to be able test the routes ourselves\n\n## Deploying this service\n\nAll you gotta do is:\n\n1. Fork this project\n2. Add a secure token the environment variable `AUTH_TOKEN`\n\n## Connecting a Service\n\n**TODO**\n- [x] Link to the Val honoAppWithTracing\n- [x] Explain configuration\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",[344],{"_150":345,"_103":480,"_108":481,"_153":139,"_381":482},269,["D",1740834031114],[483],{"_106":484,"_153":139,"_150":345,"_99":344,"_161":485,"_159":349,"_103":258,"_152":-5,"_108":481,"_154":480,"_163":-5,"_156":27,"_162":27,"_102":486},"27e2b808-f69d-11ef-80c8-569c3dd06744","> **WIP** — A simple service that can receive OpenTelemetry traces from a Hono api instrumented with `@fiberplane/hono-otel`\n\n## 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 sets up HTTP endpoints for receiving and querying traces,\nand we mount a Fiberplane API Playground to be able test the routes ourselves\n\n## Deploying this service\n\nAll you gotta do is:\n\n1. Fork this project\n2. Add a secure token the environment variable `AUTH_TOKEN`\n\n## Connecting a Service\n\n**TODO**\n- [x] Link to the Val honoAppWithTracing\n- [x] Explain configuration\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",[344],{"_150":345,"_103":488,"_108":489,"_153":139,"_381":490},268,["D",1740833988869],[491],{"_106":492,"_153":139,"_150":345,"_99":344,"_161":493,"_159":349,"_103":192,"_152":-5,"_108":489,"_154":488,"_163":-5,"_156":27,"_162":27,"_102":494},"0eb494e6-f69d-11ef-b2b9-569c3dd06744","> **WIP** — A simple service that can receive OpenTelemetry traces from a Hono api instrumented with `@fiberplane/hono-otel`\n\n## What is this?\n\nYou're looking at a self-hosted tracing service 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 sets up HTTP endpoints for receiving and querying traces,\nand we mount a Fiberplane API Playground to be able test the routes ourselves\n\n## Deploying this service\n\nAll you gotta do is:\n\n1. Fork this project\n2. Add a secure token the environment variable `AUTH_TOKEN`\n\n## Connecting a Service\n\n**TODO**\n- [x] Link to the Val honoAppWithTracing\n- [x] Explain configuration\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",[344],{"_150":345,"_103":496,"_108":497,"_153":139,"_381":498},267,["D",1740833986590],[499],{"_106":500,"_153":139,"_150":345,"_99":344,"_161":501,"_159":349,"_103":502,"_152":-5,"_108":497,"_154":496,"_163":-5,"_156":27,"_162":27,"_102":503},"0d58bc26-f69d-11ef-8e29-569c3dd06744","> **WIP** — A simple service that can receive OpenTelemetry traces from a Hono api instrumented with `@fiberplane/hono-otel`\n\n## What is this?\n\nYou're looking at a self-hosted tracing service 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 store on ValTown.\n\nA Hono api sets up HTTP endpoints for receiving and querying traces,\nand we mount a Fiberplane API Playground to be able test the routes ourselves\n\n## Deploying this service\n\nAll you gotta do is:\n\n1. Fork this project\n2. Add a secure token the environment variable `AUTH_TOKEN`\n\n## Connecting a Service\n\n**TODO**\n- [x] Link to the Val honoAppWithTracing\n- [x] Explain configuration\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",8,[344],{"_150":345,"_103":505,"_108":506,"_153":139,"_381":507},266,["D",1740833979448],[508],{"_106":509,"_153":139,"_150":345,"_99":344,"_161":510,"_159":349,"_103":218,"_152":-5,"_108":506,"_154":505,"_163":-5,"_156":27,"_162":27,"_102":511},"09174a60-f69d-11ef-b512-569c3dd06744","> **WIP** — A simple service that can receive OpenTelemetry traces from a Hono api instrumented with `@fiberplane/hono-otel`\n\n## What is this?\n\nYou're looking at a self-hosted tracing service 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 ValTown sqlite.\n\nA Hono api sets up HTTP endpoints for receiving and querying traces,\nand we mount a Fiberplane API Playground to be able test the routes ourselves\n\n## Deploying this service\n\nAll you gotta do is:\n\n1. Fork this project\n2. Add a secure token the environment variable `AUTH_TOKEN`\n\n## Connecting a Service\n\n**TODO**\n- [x] Link to the Val honoAppWithTracing\n- [x] Explain configuration\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",[344],{"_150":326,"_103":327,"_108":513,"_153":139,"_381":514},["D",1740818671720],[515],{"_106":324,"_153":139,"_150":326,"_99":325,"_161":329,"_159":173,"_103":192,"_152":310,"_108":513,"_154":327,"_163":-5,"_156":121,"_162":27,"_102":516},[309,325],{"_150":326,"_103":518,"_108":519,"_153":139,"_381":520},264,["D",1740818669645],[521],{"_106":522,"_153":139,"_150":326,"_99":325,"_161":329,"_159":173,"_103":502,"_152":310,"_108":519,"_154":518,"_163":-5,"_156":27,"_162":27,"_102":523},"63bc4958-f679-11ef-81ca-569c3dd06744",[309,325],{"_150":326,"_103":525,"_108":526,"_153":139,"_381":527},263,["D",1740818665579],[528],{"_106":529,"_153":139,"_150":326,"_99":325,"_161":530,"_159":173,"_103":218,"_152":310,"_108":526,"_154":525,"_163":-5,"_156":27,"_162":27,"_102":531},"614fe1ac-f679-11ef-9687-569c3dd06744","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 * 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};",[309,325],{"_150":334,"_103":335,"_108":533,"_153":139,"_381":534},["D",1740818616306],[535],{"_106":333,"_153":139,"_150":334,"_99":198,"_161":338,"_159":173,"_103":337,"_152":310,"_108":533,"_154":335,"_163":-5,"_156":121,"_162":27,"_102":536},[309,198],{"_150":189,"_103":190,"_108":538,"_153":139,"_381":539},["D",1740818591704],[540],{"_106":187,"_153":139,"_150":189,"_99":188,"_161":193,"_159":173,"_103":192,"_152":151,"_108":538,"_154":190,"_163":-5,"_156":121,"_162":27,"_102":541},[149,188],{"_150":189,"_103":543,"_108":544,"_153":139,"_381":545},260,["D",1740818546748],[546],{"_106":547,"_153":139,"_150":189,"_99":188,"_161":193,"_159":173,"_103":502,"_152":151,"_108":544,"_154":543,"_163":-5,"_156":27,"_162":27,"_102":548},"1a7cfec2-f679-11ef-81ca-569c3dd06744",[149,188],{"_150":119,"_103":356,"_108":550,"_153":139,"_381":551},["D",1740815227116],[552],{"_106":354,"_153":139,"_150":119,"_99":355,"_161":360,"_159":359,"_103":358,"_152":-5,"_108":550,"_154":356,"_163":-5,"_156":121,"_162":27,"_102":553},[355],{"_150":180,"_103":181,"_108":555,"_153":139,"_381":556},["D",1740815202628],[557],{"_106":178,"_153":139,"_150":180,"_99":179,"_161":183,"_159":173,"_103":94,"_152":151,"_108":555,"_154":181,"_163":-5,"_156":121,"_162":27,"_102":558},[149,179],{"_150":180,"_103":560,"_108":561,"_153":139,"_381":562},257,["D",1740815155220],[563],{"_106":564,"_153":139,"_150":180,"_99":179,"_161":70,"_159":173,"_103":158,"_152":151,"_108":561,"_154":560,"_163":-5,"_156":27,"_162":27,"_102":565},"34fb43f6-f671-11ef-b64a-569c3dd06744",[149,179],{"_150":180,"_103":567,"_108":568,"_153":139,"_381":569},256,["D",1740815148970],[570],{"_106":571,"_153":139,"_150":180,"_99":572,"_161":70,"_159":173,"_103":33,"_152":151,"_108":568,"_154":567,"_163":-5,"_156":27,"_162":27,"_102":573},"313f7dfe-f671-11ef-8c49-569c3dd06744","endearingPinkEagle",[149,572],{"_150":119,"_103":575,"_108":576,"_153":139,"_381":577},255,["D",1740815139761],[578],{"_106":579,"_153":139,"_150":119,"_99":355,"_161":580,"_159":359,"_103":581,"_152":-5,"_108":576,"_154":575,"_163":-5,"_156":27,"_162":27,"_102":582},"2bc31ba6-f671-11ef-bbd3-569c3dd06744","import 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.get(\"/\", async ctx => {\n return ctx.html(`\n\n\n\n \n \n \n\n\n

Fiberplane OpenTelemetry Trace Collector on ValTown

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

\n\n\n\n`.trim());\n});\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}",70,[355],{"_150":119,"_103":584,"_108":585,"_153":139,"_381":586},254,["D",1740815138018],[587],{"_106":588,"_153":139,"_150":119,"_99":355,"_161":580,"_159":359,"_103":589,"_152":-5,"_108":585,"_154":584,"_163":-5,"_156":27,"_162":27,"_102":590},"2ab91238-f671-11ef-994f-569c3dd06744",69,[355],{"_150":119,"_103":592,"_108":593,"_153":139,"_381":594},253,["D",1740815039197],[595],{"_106":596,"_153":139,"_150":119,"_99":355,"_161":597,"_159":359,"_103":598,"_152":-5,"_108":593,"_154":592,"_163":-5,"_156":27,"_162":27,"_102":599},"efd22344-f670-11ef-a690-569c3dd06744","import 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.get(\"/\", async ctx => {\n return ctx.html(`\n\n\n\nThis is the Fiberplane OpenTelemetry Trace Collector on ValTown!\n\n

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

\n\n\n`.trim());\n});\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}",68,[355],{"_150":345,"_103":601,"_108":602,"_153":139,"_381":603},252,["D",1740814863343],[604],{"_106":605,"_153":139,"_150":345,"_99":344,"_161":606,"_159":349,"_103":238,"_152":-5,"_108":602,"_154":601,"_163":-5,"_156":27,"_162":27,"_102":607},"87010498-f670-11ef-a5e2-569c3dd06744","> **WIP** — A simple service that can receive OpenTelemetry traces from a Hono api instrumented with `@fiberplane/hono-otel`\n\n## What is this?\n\nYou're looking at a self-hosted tracing service 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 client to receive traces,\nand ValTown sqlite to persist the traces.\n\nA Hono api sets up HTTP endpoints for receiving and querying traces,\nand we mount a Fiberplane API Playground to be able test the routes ourselves\n\n## Deploying this service\n\nAll you gotta do is:\n\n1. Fork this project\n2. Add the environment variable: `AUTH_TOKEN`\n\n## Connecting a Service\n\n**TODO**\n- [ ] Link to the Val honoAppWithTracing\n- [ ] Explain configuration\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",[344],{"_150":345,"_103":609,"_108":610,"_153":139,"_381":611},251,["D",1740814775661],[612],{"_106":613,"_153":139,"_150":345,"_99":344,"_161":614,"_159":349,"_103":267,"_152":-5,"_108":610,"_154":609,"_163":-5,"_156":27,"_162":27,"_102":615},"52bda4ca-f670-11ef-9cc0-569c3dd06744","> **WIP** — A simple service that can receive OpenTelemetry traces from a Hono api instrumented with `@fiberplane/hono-otel`\n\n## What is this?\n\nYou're looking at a self-hosted tracing service 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 client to receive traces,\nand ValTown sqlite to persist the traces.\n\nA Hono api sets up HTTP endpoints for receiving and querying traces,\nand we mount a Fiberplane API Playground to be able test the routes ourselves\n\n## Deploying this service\n\nAll you gotta do is:\n\n1. Fork this project\n2. Add the environment variable: `AUTH_TOKEN`\n\n## Connecting an API\n\n**TODO**\n- [ ] Link to the Val honoAppWithTracing\n- [ ] Explain configuration",[344],{"_150":345,"_103":617,"_108":618,"_153":139,"_381":619},250,["D",1740814756696],[620],{"_106":621,"_153":139,"_150":345,"_99":344,"_161":622,"_159":349,"_103":248,"_152":-5,"_108":618,"_154":617,"_163":-5,"_156":27,"_162":27,"_102":623},"476fddcc-f670-11ef-835a-569c3dd06744","> **WIP** — A simple service that can receive OpenTelemetry traces from a Hono api instrumented with `@fiberplane/hono-otel`\n\n## What is this?\n\nYou're looking at a self-hosted tracing service 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 client to receive traces,\nand ValTown sqlite to persist the traces.\n\nA simple Hono api sets up HTTP endpoints for receiving and querying traces,\nand we mount a Fiberplane API Playground to be able test the routes ourselves\n\n## Deploying this service\n\nAll you gotta do is:\n\n1. Fork this project\n2. Add the environment variable: `AUTH_TOKEN`\n\n## Connecting an API\n\n**TODO**\n- [ ] Link to the Val honoAppWithTracing\n- [ ] Explain configuration",[344],{"_150":345,"_103":625,"_108":626,"_153":139,"_381":627},249,["D",1740814639172],[628],{"_106":629,"_153":139,"_150":345,"_99":344,"_161":630,"_159":349,"_103":228,"_152":-5,"_108":626,"_154":625,"_163":-5,"_156":27,"_162":27,"_102":631},"01631952-f670-11ef-a10a-569c3dd06744","> **WIP** — A simple service that can receive OpenTelemetry traces from a Hono api instrumented with `@fiberplane/hono-otel`\n\n## What is this?\n\nYou're looking at a self-hosted tracing service 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\n## Deploying this service\n\nAll you gotta do is:\n\n1. Fork this project\n2. Add the environment variable: `AUTH_TOKEN`\n\n## Connecting an API\n\n**TODO**\n- [ ] Link to the Val honoAppWithTracing\n- [ ] Explain configuration",[344],{"_150":169,"_103":633,"_108":634,"_153":139,"_381":635},248,["D",1740814587065],[636],{"_106":637,"_153":139,"_150":169,"_99":168,"_161":638,"_159":173,"_103":258,"_152":151,"_108":634,"_154":633,"_163":-5,"_156":27,"_162":27,"_102":639},"e25458dc-f66f-11ef-a53a-569c3dd06744","import { 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 = token === ctx.env.AUTH_TOKEN;\n if (!isValid) {\n throw new HTTPException(401, {\n message: \"Invalid token\",\n });\n }\n\n await next();\n};",[149,168],{"_150":119,"_103":641,"_108":642,"_153":139,"_381":643},247,["D",1740814541100],[644],{"_106":645,"_153":139,"_150":119,"_99":355,"_161":646,"_159":359,"_103":647,"_152":-5,"_108":642,"_154":641,"_163":-5,"_156":27,"_162":27,"_102":648},"c6ee68da-f66f-11ef-a4d7-569c3dd06744","import 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.get(\"/\", async ctx => {\n return ctx.text(\"This is the Fiberplane OpenTelemetry Trace Collector on ValTown!\");\n});\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}",67,[355],{"_150":119,"_103":650,"_108":651,"_153":139,"_381":652},246,["D",1740814450038],[653],{"_106":654,"_153":139,"_150":119,"_99":355,"_161":655,"_159":359,"_103":656,"_152":-5,"_108":651,"_154":650,"_163":-5,"_156":27,"_162":27,"_102":657},"90a78b08-f66f-11ef-a8de-569c3dd06744","import 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\n * 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/**\n * Welcome message\n */\napp.get(\"/\", async ctx => {\n return ctx.text(\"This is the Fiberplane OpenTelemetry Trace Collector on ValTown!\");\n});\n\n/**\n * Mount the routes that handle tracing exports and queries\n */\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\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}",66,[355],"page","hasNext","routes/_app","actionData","errors"]

History