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;",[],[155,182],{"_103":189,"_95":190,"_156":191,"_158":157,"_159":137,"_160":136,"_161":162,"_105":192,"_100":32,"_164":176,"_166":193,"_167":22,"_168":-5,"_169":194,"_98":195},"50cbb66e-6cc4-11f0-9c02-0224a6c84d84","traces.ts","0198581f-0f5d-7518-9e9d-e6477c9ee666",["D",1753825087257],"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;",[],[155,190],{"_103":197,"_95":198,"_156":199,"_158":157,"_159":137,"_160":136,"_161":162,"_105":200,"_100":32,"_164":176,"_166":201,"_167":22,"_168":-5,"_169":202,"_98":203},"50cbc582-6cc4-11f0-9c02-0224a6c84d84","types.ts","0198581f-0f5d-7518-9e9d-eab7d6299158",["D",1753825087257],"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 };",[],[155,198],[155],{"_103":206,"_95":207,"_156":208,"_158":-5,"_159":137,"_160":136,"_161":162,"_105":209,"_100":32,"_164":165,"_166":-5,"_167":22,"_168":-5,"_169":210,"_98":258},"50cbd306-6cc4-11f0-9c02-0224a6c84d84","db","0198581f-0f5d-7518-9e9e-08137f710255",["D",1753825087257],[211,219,227,235,243,251],{"_103":212,"_95":213,"_156":214,"_158":208,"_159":137,"_160":136,"_161":162,"_105":215,"_100":32,"_164":176,"_166":216,"_167":22,"_168":-5,"_169":217,"_98":218},"50cbc938-6cc4-11f0-9c02-0224a6c84d84","client.ts","0198581f-0f5d-7518-9e9d-f2e0adcbd0c5",["D",1753825087257],"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});",[],[207,213],{"_103":220,"_95":221,"_156":222,"_158":208,"_159":137,"_160":136,"_161":162,"_105":223,"_100":32,"_164":176,"_166":224,"_167":22,"_168":-5,"_169":225,"_98":226},"50cbcadc-6cc4-11f0-9c02-0224a6c84d84","constants.ts","0198581f-0f5d-7518-9e9d-f7020f3afc1a",["D",1753825087257],"/**\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\";",[],[207,221],{"_103":228,"_95":229,"_156":230,"_158":208,"_159":137,"_160":136,"_161":162,"_105":231,"_100":32,"_164":176,"_166":232,"_167":22,"_168":-5,"_169":233,"_98":234},"50cbcc76-6cc4-11f0-9c02-0224a6c84d84","migrate.ts","0198581f-0f5d-7518-9e9d-f9b7a1326e41",["D",1753825087257],"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};",[],[207,229],{"_103":236,"_95":237,"_156":238,"_158":208,"_159":137,"_160":136,"_161":162,"_105":239,"_100":32,"_164":176,"_166":240,"_167":22,"_168":-5,"_169":241,"_98":242},"50cbce38-6cc4-11f0-9c02-0224a6c84d84","queries.ts","0198581f-0f5d-7518-9e9d-fcf8bd6a7499",["D",1753825087257],"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}",[],[207,237],{"_103":244,"_95":245,"_156":246,"_158":208,"_159":137,"_160":136,"_161":162,"_105":247,"_100":32,"_164":176,"_166":248,"_167":22,"_168":-5,"_169":249,"_98":250},"50cbcfd2-6cc4-11f0-9c02-0224a6c84d84","schema.ts","0198581f-0f5d-7518-9e9e-027538822757",["D",1753825087257],"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});",[],[207,245],{"_103":252,"_95":198,"_156":253,"_158":208,"_159":137,"_160":136,"_161":162,"_105":254,"_100":32,"_164":176,"_166":255,"_167":22,"_168":-5,"_169":256,"_98":257},"50cbd16c-6cc4-11f0-9c02-0224a6c84d84","0198581f-0f5d-7518-9e9e-059f3134176a",["D",1753825087257],"import type { LibSQLDatabase } from \"../deps/drizzle.ts\";\nimport type * as schema from \"./schema\";\n\nexport type DBType = LibSQLDatabase;",[],[207,198],[207],{"_103":260,"_95":261,"_156":262,"_158":-5,"_159":137,"_160":136,"_161":162,"_105":263,"_100":32,"_164":165,"_166":-5,"_167":22,"_168":-5,"_169":264,"_98":289},"50cbd928-6cc4-11f0-9c02-0224a6c84d84","deps","0198581f-0f5d-7518-9e9e-18baf24df3e5",["D",1753825087257],[265,273,281],{"_103":266,"_95":267,"_156":268,"_158":262,"_159":137,"_160":136,"_161":162,"_105":269,"_100":32,"_164":176,"_166":270,"_167":22,"_168":-5,"_169":271,"_98":272},"50cbd496-6cc4-11f0-9c02-0224a6c84d84","drizzle.ts","0198581f-0f5d-7518-9e9e-0eb2432a2a9e",["D",1753825087257],"// 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 };",[],[261,267],{"_103":274,"_95":275,"_156":276,"_158":262,"_159":137,"_160":136,"_161":162,"_105":277,"_100":32,"_164":176,"_166":278,"_167":22,"_168":-5,"_169":279,"_98":280},"50cbd63a-6cc4-11f0-9c02-0224a6c84d84","fiberplane.ts","0198581f-0f5d-7518-9e9e-1194c1e75a19",["D",1753825087257],"// 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 };",[],[261,275],{"_103":282,"_95":283,"_156":284,"_158":262,"_159":137,"_160":136,"_161":162,"_105":285,"_100":32,"_164":176,"_166":286,"_167":22,"_168":-5,"_169":287,"_98":288},"50cbd7b6-6cc4-11f0-9c02-0224a6c84d84","hono.ts","0198581f-0f5d-7518-9e9e-1561d6f2d10d",["D",1753825087257],"/**\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 };",[],[261,283],[261],{"_103":291,"_95":292,"_156":293,"_158":-5,"_159":137,"_160":136,"_161":162,"_105":294,"_100":32,"_164":165,"_166":-5,"_167":22,"_168":-5,"_169":295,"_98":319},"50cbf5f2-6cc4-11f0-9c02-0224a6c84d84","otel","0198581f-0f5d-7518-9e9e-297122ad77b3",["D",1753825087257],[296,304,312],{"_103":297,"_95":298,"_156":299,"_158":293,"_159":137,"_160":136,"_161":162,"_105":300,"_100":32,"_164":176,"_166":301,"_167":22,"_168":-5,"_169":302,"_98":303},"50cbda9a-6cc4-11f0-9c02-0224a6c84d84","schemas.ts","0198581f-0f5d-7518-9e9e-1c8b4d307b19",["D",1753825087257],"// 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 };",[],[292,298],{"_103":305,"_95":306,"_156":307,"_158":293,"_159":137,"_160":136,"_161":162,"_105":308,"_100":32,"_164":176,"_166":309,"_167":22,"_168":-5,"_169":310,"_98":311},"50cbe72e-6cc4-11f0-9c02-0224a6c84d84","transformExport.ts","0198581f-0f5d-7518-9e9e-207e7aa8f744",["D",1753825087257],"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};",[],[292,306],{"_103":313,"_95":198,"_156":314,"_158":293,"_159":137,"_160":136,"_161":162,"_105":315,"_100":32,"_164":176,"_166":316,"_167":22,"_168":-5,"_169":317,"_98":318},"50cbf3ae-6cc4-11f0-9c02-0224a6c84d84","0198581f-0f5d-7518-9e9e-2696dc9efbe7",["D",1753825087257],"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}",[],[292,198],[292],{"_103":321,"_95":322,"_156":323,"_158":-5,"_159":137,"_160":136,"_161":162,"_105":324,"_100":32,"_164":325,"_166":326,"_167":22,"_168":-5,"_169":327,"_98":328},"50cbf71e-6cc4-11f0-9c02-0224a6c84d84","README.md","0198581f-0f5d-7518-9e9e-2ed787a1a16e",["D",1753825087257],"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",[],[322],{"_103":330,"_95":331,"_156":332,"_158":-5,"_159":137,"_160":136,"_161":162,"_105":333,"_100":32,"_164":334,"_166":335,"_167":22,"_168":-5,"_169":336,"_98":337},"50cbfab6-6cc4-11f0-9c02-0224a6c84d84","index.ts","0198581f-0f5d-7518-9e9e-311ee2043d6c",["D",1753825087257],"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}",[],[331],{"_103":339,"_95":340,"_156":341,"_158":-5,"_159":137,"_160":136,"_161":162,"_105":342,"_100":32,"_164":176,"_166":343,"_167":22,"_168":-5,"_169":344,"_98":345},"50cbfca0-6cc4-11f0-9c02-0224a6c84d84","logger.ts","0198581f-0f5d-7518-9e9e-3638bda647db",["D",1753825087257],"/**\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};",[],[340],{"_103":347,"_95":348,"_156":349,"_158":-5,"_159":137,"_160":136,"_161":162,"_105":350,"_100":32,"_164":176,"_166":351,"_167":22,"_168":-5,"_169":352,"_98":353},"50cbfeb2-6cc4-11f0-9c02-0224a6c84d84","openapi.ts","0198581f-0f5d-7518-9e9e-398773966a70",["D",1753825087257],"/**\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}",[],[348],"files",[153,171,180,188,196,205,211,219,227,235,243,251,259,265,273,281,290,296,304,312,320,329,338,346],"counts",{"_358":32,"_359":136,"_360":32,"_361":362},"pulls","branches","forks","envVars",{"_363":136,"_364":32},"count","emptyCount","contents",[],{"_103":212,"_95":213,"_156":214,"_158":208,"_159":137,"_160":136,"_161":162,"_105":368,"_100":32,"_164":176,"_166":216,"_167":22,"_168":-5,"_98":369},["D",1753825087257],[207,213],"upstreamProject",{"_103":145,"_95":96,"_111":372,"_112":-5,"_109":110,"_23":373},"Receive traces from @fiberplane/hono-otel, and store in sqlite",{"_93":374,"_129":375},"fiberplane","https://img.clerk.com/eyJ0eXBlIjoicHJveHkiLCJzcmMiOiJodHRwczovL2ltYWdlcy5jbGVyay5kZXYvdXBsb2FkZWQvaW1nXzJ0OXJLaXVodjZKMUU4QnFhODNCVkJ4aVRQSyJ9","upstreamBranch",{"_103":140,"_105":378,"_379":380,"_95":43,"_138":145,"_100":142,"_139":-5,"_141":-5,"_381":382,"_107":-5,"_150":22,"_109":110,"_149":374,"_16":147,"_148":96},["D",1740805324568],"updatedAt",["D",1740836480150],"lockfileKey","1755613386658-esm.town_v_fiberplane_OpenTelemetryCollector@277-main","emptyEnvVars","isNew","flags",[],"routes/_app.x.$handle.$name.branch.$branch.history_.$",{"_93":94,"_95":96,"_97":43,"_98":99,"_101":389,"_325":394,"_397":398,"_401":402,"_405":-7,"_406":32,"_407":22},{"_103":104,"_95":96,"_105":390,"_107":-5,"_108":22,"_109":110,"_111":-5,"_112":-5,"_14":113,"_114":-5,"_115":22,"_116":-5,"_117":32,"_16":118,"_119":120,"_121":120,"_122":123,"_124":123,"_125":123,"_126":120,"_127":120,"_23":391,"_131":392,"_134":393,"_150":22},["D",1753825087257],{"_93":94,"_129":130},{"_93":94,"_133":130},{"_100":136,"_95":43,"_103":137,"_138":104,"_139":140,"_141":142,"_143":110,"_144":145,"_146":147,"_148":96,"_149":94},{"_103":212,"_95":213,"_156":214,"_158":208,"_159":137,"_160":136,"_161":162,"_105":395,"_100":32,"_164":176,"_166":216,"_167":22,"_168":-5,"_98":396},["D",1753825087257],[207,213],"history",[399],{"_103":212,"_159":137,"_156":214,"_95":213,"_166":216,"_164":176,"_100":32,"_158":208,"_105":400,"_160":136,"_168":-5},["D",1753825087257],"versions",[403],{"_325":399,"_404":-5},"previous","versionNumber","page","hasNext","actionData","errors"]

virtuallyvivek

OpenTelemetryCollector

History for client.ts