[{"_1":2,"_505":-5,"_506":-5},"loaderData",{"_3":4,"_95":96,"_408":409,"_504":-5},"root",{"_5":6,"_34":35,"_62":63,"_93":94},"ctx",{"_7":8,"_19":20,"_21":-5,"_22":23,"_24":25,"_26":27,"_28":27,"_29":27,"_30":31,"_32":33},"auth",{"_9":-5,"_10":-5,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5},"sessionClaims","sessionId","sessionStatus","userId","actor","orgId","orgRole","orgSlug","orgPermissions","factorVerificationAge","environmentVariableKeys",[],"user","preferences_keybindings","default","preferences_theme","light","preferences_fixers",false,"preferences_copilot","preferences_selection_ai","preferences_model","claude-3-5-haiku-20241022","notification_count",0,"ENV",{"_36":37,"_38":39,"_40":41,"_42":43,"_44":45,"_46":47,"_48":49,"_50":51,"_52":53,"_54":55,"_56":57,"_58":59,"_60":61},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","VAL_RUNTIME_NAME","prod","RENDER_GIT_COMMIT","dc7dbe6856acc56189715184ec2b4fe1f2a18600","RENDER_GIT_BRANCH","main","CLERK_PUBLISHABLE_KEY","pk_live_Y2xlcmsudmFsLnRvd24k","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","API_URL","https://api.val.town","WORKER_FINGERPRINT","fd7e47ba602df66e0f857b45e802b861","clerkState",{"_64":65},"__internal_clerk_state",{"_66":67,"_68":45,"_69":70,"_71":70,"_72":27,"_73":70,"_74":70,"_75":70,"_76":70,"_77":70,"_78":70,"_79":70,"_80":70,"_81":82,"_91":27,"_92":27},"__clerk_ssr_state",{"_9":-5,"_10":-5,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5},"__publishableKey","__proxyUrl","","__domain","__isSatellite","__signInUrl","__signUpUrl","__afterSignInUrl","__afterSignUpUrl","__signInForceRedirectUrl","__signUpForceRedirectUrl","__signInFallbackRedirectUrl","__signUpFallbackRedirectUrl","__clerk_debug",{"_83":27,"_84":70,"_85":86,"_87":70,"_88":45,"_89":27,"_90":70},"isSignedIn","proxyUrl","reason","session-token-and-uat-missing","message","publishableKey","isSatellite","domain","__telemetryDisabled","__telemetryDebug","remixVersion",2,"routes/_app.x.$handle.$name",{"_97":98,"_99":100,"_101":43,"_102":70,"_103":104,"_105":106,"_146":147,"_371":372,"_373":374,"_379":380,"_339":-5,"_405":-5,"_406":-5,"_407":27},"handle","fiberplane","name","OpenTelemetryCollector","branchName","path","version",249,"project",{"_107":108,"_99":100,"_109":110,"_111":-5,"_112":27,"_113":114,"_115":116,"_117":-5,"_12":118,"_119":120,"_121":122,"_123":-5,"_124":33,"_125":126,"_127":126,"_128":129,"_130":129,"_131":129,"_132":126,"_133":27,"_21":134,"_137":138},"id","517259dc-f65a-11ef-9da1-569c3dd06744","createdAt",["D",1740805324568],"deletedAt","legacyEnvVars","privacy","public","description","Receive traces from @fiberplane/hono-otel, and store in sqlite","imageUrl","42ee3ab0-ecfb-11ef-af12-67b5d5b0b458","pinnedFileId","63a45c54-f65a-11ef-a403-569c3dd06744","pinPreview",true,"screenshotVersion","likeCount","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","isOwned",{"_97":98,"_135":136},"profileImageUrl","https://img.clerk.com/eyJ0eXBlIjoicHJveHkiLCJzcmMiOiJodHRwczovL2ltYWdlcy5jbGVyay5kZXYvdXBsb2FkZWQvaW1nXzJ0OXJLaXVodjZKMUU4QnFhODNCVkJ4aVRQSyJ9","branch",{"_103":139,"_99":43,"_107":140,"_141":108,"_142":-5,"_143":-5,"_144":-5,"_145":-5},277,"5172ca66-f65a-11ef-9da1-569c3dd06744","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectUserId","tree",[148,199,265,300,334,343,353,362],{"_107":149,"_99":150,"_151":152,"_153":-5,"_154":140,"_155":156,"_157":122,"_109":158,"_103":159,"_160":161,"_162":-5,"_163":27,"_164":-5,"_165":166,"_102":198},"91e9fade-f663-11ef-ae19-569c3dd06744","app","fileId","900e46de-f663-11ef-96cc-569c3dd06744","parentId","branchId","branchVersion",126,"latest",["D",1740809298190],1,"fileType","directory","content","deleted","subdomain","children",[167,178,188],{"_107":168,"_99":169,"_151":170,"_153":152,"_154":140,"_155":171,"_157":27,"_109":172,"_103":173,"_160":174,"_162":175,"_163":27,"_164":-5,"_165":176,"_102":177},"e25458dc-f66f-11ef-a53a-569c3dd06744","auth.ts","4461a496-f664-11ef-8d95-569c3dd06744",248,["D",1740814587065],10,"script","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};",[],[150,169],{"_107":179,"_99":180,"_151":181,"_153":152,"_154":140,"_155":182,"_157":27,"_109":183,"_103":184,"_160":174,"_162":185,"_163":27,"_164":-5,"_165":186,"_102":187},"cfb7835e-f66d-11ef-80de-569c3dd06744","traces.ts","4340ac56-f669-11ef-97cc-569c3dd06744",238,["D",1740813696844],7,"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 fromCollectorRequest(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;",[],[150,180],{"_107":189,"_99":190,"_151":191,"_153":152,"_154":140,"_155":192,"_157":27,"_109":193,"_103":194,"_160":174,"_162":195,"_163":27,"_164":-5,"_165":196,"_102":197},"6cc95d78-f66b-11ef-818a-569c3dd06744","types.ts","969af970-f663-11ef-b4b9-569c3dd06744",213,["D",1740812671876],15,"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 FIBERPLANE_OTEL_OTKEN: string;\n };\n Variables: {\n db: DBType;\n };\n};\n\nexport type AppMiddleware = MiddlewareHandler;\n\nexport type { TraceDetailSpansResponse, TraceListResponse };",[],[150,190],[150],{"_107":200,"_99":201,"_151":202,"_153":-5,"_154":140,"_155":203,"_157":122,"_109":204,"_103":159,"_160":161,"_162":-5,"_163":27,"_164":-5,"_165":205,"_102":264},"9cbeff30-f65a-11ef-9281-569c3dd06744","db","9a42da06-f65a-11ef-b0ab-569c3dd06744",12,["D",1740805450893],[206,215,225,235,245,255],{"_107":207,"_99":208,"_151":209,"_153":202,"_154":140,"_155":210,"_157":122,"_109":211,"_103":184,"_160":174,"_162":212,"_163":27,"_164":-5,"_165":213,"_102":214},"2cecd774-f667-11ef-afd0-569c3dd06744","client.ts","18435d20-f65d-11ef-9799-569c3dd06744",174,["D",1740810846746],"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});",[],[201,208],{"_107":216,"_99":217,"_151":218,"_153":202,"_154":140,"_155":219,"_157":122,"_109":220,"_103":221,"_160":174,"_162":222,"_163":27,"_164":-5,"_165":223,"_102":224},"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\";",[],[201,217],{"_107":226,"_99":227,"_151":228,"_153":202,"_154":140,"_155":229,"_157":122,"_109":230,"_103":231,"_160":174,"_162":232,"_163":27,"_164":-5,"_165":233,"_102":234},"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};",[],[201,227],{"_107":236,"_99":237,"_151":238,"_153":202,"_154":140,"_155":239,"_157":122,"_109":240,"_103":241,"_160":174,"_162":242,"_163":27,"_164":-5,"_165":243,"_102":244},"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}",[],[201,237],{"_107":246,"_99":247,"_151":248,"_153":202,"_154":140,"_155":249,"_157":27,"_109":250,"_103":251,"_160":174,"_162":252,"_163":27,"_164":-5,"_165":253,"_102":254},"a0bdb624-f666-11ef-9d95-569c3dd06744","schema.ts","a0be8c54-f65a-11ef-9281-569c3dd06744",171,["D",1740810611553],9,"import { drizzle, type LibSQLDatabase, 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});",[],[201,247],{"_107":256,"_99":190,"_151":257,"_153":202,"_154":140,"_155":258,"_157":122,"_109":259,"_103":260,"_160":174,"_162":261,"_163":27,"_164":-5,"_165":262,"_102":263},"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;",[],[201,190],[201],{"_107":266,"_99":267,"_151":268,"_153":-5,"_154":140,"_155":269,"_157":122,"_109":270,"_103":159,"_160":161,"_162":-5,"_163":27,"_164":-5,"_165":271,"_102":299},"ce734080-f665-11ef-8cf9-569c3dd06744","deps","cbb2c0fa-f665-11ef-9ae5-569c3dd06744",153,["D",1740810258747],[272,281,290],{"_107":273,"_99":274,"_151":275,"_153":268,"_154":140,"_155":276,"_157":122,"_109":277,"_103":184,"_160":174,"_162":278,"_163":27,"_164":-5,"_165":279,"_102":280},"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 };",[],[267,274],{"_107":282,"_99":283,"_151":284,"_153":268,"_154":140,"_155":285,"_157":122,"_109":286,"_103":231,"_160":174,"_162":287,"_163":27,"_164":-5,"_165":288,"_102":289},"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 };",[],[267,283],{"_107":291,"_99":292,"_151":293,"_153":268,"_154":140,"_155":294,"_157":122,"_109":295,"_103":260,"_160":174,"_162":296,"_163":27,"_164":-5,"_165":297,"_102":298},"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 };",[],[267,292],[267],{"_107":301,"_99":302,"_151":303,"_153":-5,"_154":140,"_155":304,"_157":122,"_109":305,"_103":159,"_160":161,"_162":-5,"_163":27,"_164":-5,"_165":306,"_102":333},"5862d856-f660-11ef-8789-569c3dd06744","otel","55ff6bba-f660-11ef-8e91-569c3dd06744",96,["D",1740807913185],[307,316,325],{"_107":308,"_99":309,"_151":310,"_153":303,"_154":140,"_155":311,"_157":122,"_109":312,"_103":241,"_160":174,"_162":313,"_163":27,"_164":-5,"_165":314,"_102":315},"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 };",[],[302,309],{"_107":317,"_99":318,"_151":319,"_153":303,"_154":140,"_155":320,"_157":27,"_109":321,"_103":231,"_160":174,"_162":322,"_163":27,"_164":-5,"_165":323,"_102":324},"4bc1af8a-f66c-11ef-af93-569c3dd06744","transformExport.ts","5c3a99c8-f660-11ef-8e90-569c3dd06744",225,["D",1740813045952],"import type {\n ESpanKind,\n EStatusCode,\n IAnyValue,\n IEvent,\n IExportTraceServiceRequest,\n IKeyValue,\n ILink,\n IStatus,\n OtelSpan,\n} from \"../types.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};",[],[302,318],{"_107":326,"_99":190,"_151":327,"_153":303,"_154":140,"_155":328,"_157":27,"_109":329,"_103":173,"_160":174,"_162":330,"_163":27,"_164":-5,"_165":331,"_102":332},"ca579b9e-f66b-11ef-b797-569c3dd06744","856869fc-f65a-11ef-a3bf-569c3dd06744",217,["D",1740812828834],"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 };",[],[302,190],[302],{"_107":335,"_99":336,"_151":337,"_153":-5,"_154":140,"_155":104,"_157":27,"_109":338,"_103":221,"_160":339,"_162":340,"_163":27,"_164":-5,"_165":341,"_102":342},"01631952-f670-11ef-a10a-569c3dd06744","README.md","6605e5a0-f66c-11ef-b844-569c3dd06744",["D",1740814639172],"file","> **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",[],[336],{"_107":344,"_99":345,"_151":120,"_153":-5,"_154":140,"_155":346,"_157":27,"_109":347,"_103":348,"_160":349,"_162":350,"_163":27,"_164":-5,"_165":351,"_102":352},"c6ee68da-f66f-11ef-a4d7-569c3dd06744","index.ts",247,["D",1740814541100],67,"http","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}",[],[345],{"_107":354,"_99":355,"_151":356,"_153":-5,"_154":140,"_155":357,"_157":122,"_109":358,"_103":221,"_160":174,"_162":359,"_163":27,"_164":-5,"_165":360,"_102":361},"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};",[],[355],{"_107":363,"_99":364,"_151":365,"_153":-5,"_154":140,"_155":366,"_157":122,"_109":367,"_103":251,"_160":174,"_162":368,"_163":27,"_164":-5,"_165":369,"_102":370},"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}",[],[364],"files",[148,167,178,188,199,206,215,225,235,245,255,265,272,281,290,300,307,316,325,334,343,353,362],"counts",{"_375":33,"_376":159,"_377":33,"_378":159},"pulls","branches","forks","envVars","contents",[381,384,387,390,393,396,399,402],{"_107":149,"_99":150,"_151":152,"_153":-5,"_154":140,"_155":156,"_157":122,"_109":382,"_103":159,"_160":161,"_162":-5,"_163":27,"_164":-5,"_102":383},["D",1740809298190],[150],{"_107":200,"_99":201,"_151":202,"_153":-5,"_154":140,"_155":203,"_157":122,"_109":385,"_103":159,"_160":161,"_162":-5,"_163":27,"_164":-5,"_102":386},["D",1740805450893],[201],{"_107":266,"_99":267,"_151":268,"_153":-5,"_154":140,"_155":269,"_157":122,"_109":388,"_103":159,"_160":161,"_162":-5,"_163":27,"_164":-5,"_102":389},["D",1740810258747],[267],{"_107":301,"_99":302,"_151":303,"_153":-5,"_154":140,"_155":304,"_157":122,"_109":391,"_103":159,"_160":161,"_162":-5,"_163":27,"_164":-5,"_102":392},["D",1740807913185],[302],{"_107":335,"_99":336,"_151":337,"_153":-5,"_154":140,"_155":104,"_157":27,"_109":394,"_103":221,"_160":339,"_162":340,"_163":27,"_164":-5,"_102":395},["D",1740814639172],[336],{"_107":344,"_99":345,"_151":120,"_153":-5,"_154":140,"_155":346,"_157":27,"_109":397,"_103":348,"_160":349,"_162":350,"_163":27,"_164":-5,"_102":398},["D",1740814541100],[345],{"_107":354,"_99":355,"_151":356,"_153":-5,"_154":140,"_155":357,"_157":122,"_109":400,"_103":221,"_160":174,"_162":359,"_163":27,"_164":-5,"_102":401},["D",1740813807527],[355],{"_107":363,"_99":364,"_151":365,"_153":-5,"_154":140,"_155":366,"_157":122,"_109":403,"_103":251,"_160":174,"_162":368,"_163":27,"_164":-5,"_102":404},["D",1740813962142],[364],"upstream","screenshots","emptyEnvVars","routes/_app.x.$handle.$name.branch.$branch.version.$version.code.$",{"_97":98,"_99":100,"_101":43,"_103":104,"_102":70,"_105":410,"_146":414,"_371":484,"_339":-7,"_379":485,"_405":-5,"_502":27,"_503":-5},{"_107":108,"_99":100,"_109":411,"_111":-5,"_112":27,"_113":114,"_115":116,"_117":-5,"_12":118,"_119":120,"_121":122,"_123":-5,"_124":33,"_125":126,"_127":126,"_128":129,"_130":129,"_131":129,"_132":126,"_133":27,"_21":412,"_137":413},["D",1740805324568],{"_97":98,"_135":136},{"_103":139,"_99":43,"_107":140,"_141":108,"_142":-5,"_143":-5,"_144":-5,"_145":-5},[415,427,448,460,472,475,478,481],{"_107":149,"_99":150,"_151":152,"_153":-5,"_154":140,"_155":156,"_157":122,"_109":158,"_103":159,"_160":161,"_162":-5,"_163":27,"_164":-5,"_165":416,"_102":426},[417,420,423],{"_107":168,"_99":169,"_151":170,"_153":152,"_154":140,"_155":171,"_157":27,"_109":172,"_103":173,"_160":174,"_162":175,"_163":27,"_164":-5,"_165":418,"_102":419},[],[150,169],{"_107":179,"_99":180,"_151":181,"_153":152,"_154":140,"_155":182,"_157":27,"_109":183,"_103":184,"_160":174,"_162":185,"_163":27,"_164":-5,"_165":421,"_102":422},[],[150,180],{"_107":189,"_99":190,"_151":191,"_153":152,"_154":140,"_155":192,"_157":27,"_109":193,"_103":194,"_160":174,"_162":195,"_163":27,"_164":-5,"_165":424,"_102":425},[],[150,190],[150],{"_107":200,"_99":201,"_151":202,"_153":-5,"_154":140,"_155":203,"_157":122,"_109":204,"_103":159,"_160":161,"_162":-5,"_163":27,"_164":-5,"_165":428,"_102":447},[429,432,435,438,441,444],{"_107":207,"_99":208,"_151":209,"_153":202,"_154":140,"_155":210,"_157":122,"_109":211,"_103":184,"_160":174,"_162":212,"_163":27,"_164":-5,"_165":430,"_102":431},[],[201,208],{"_107":216,"_99":217,"_151":218,"_153":202,"_154":140,"_155":219,"_157":122,"_109":220,"_103":221,"_160":174,"_162":222,"_163":27,"_164":-5,"_165":433,"_102":434},[],[201,217],{"_107":226,"_99":227,"_151":228,"_153":202,"_154":140,"_155":229,"_157":122,"_109":230,"_103":231,"_160":174,"_162":232,"_163":27,"_164":-5,"_165":436,"_102":437},[],[201,227],{"_107":236,"_99":237,"_151":238,"_153":202,"_154":140,"_155":239,"_157":122,"_109":240,"_103":241,"_160":174,"_162":242,"_163":27,"_164":-5,"_165":439,"_102":440},[],[201,237],{"_107":246,"_99":247,"_151":248,"_153":202,"_154":140,"_155":249,"_157":27,"_109":250,"_103":251,"_160":174,"_162":252,"_163":27,"_164":-5,"_165":442,"_102":443},[],[201,247],{"_107":256,"_99":190,"_151":257,"_153":202,"_154":140,"_155":258,"_157":122,"_109":259,"_103":260,"_160":174,"_162":261,"_163":27,"_164":-5,"_165":445,"_102":446},[],[201,190],[201],{"_107":266,"_99":267,"_151":268,"_153":-5,"_154":140,"_155":269,"_157":122,"_109":270,"_103":159,"_160":161,"_162":-5,"_163":27,"_164":-5,"_165":449,"_102":459},[450,453,456],{"_107":273,"_99":274,"_151":275,"_153":268,"_154":140,"_155":276,"_157":122,"_109":277,"_103":184,"_160":174,"_162":278,"_163":27,"_164":-5,"_165":451,"_102":452},[],[267,274],{"_107":282,"_99":283,"_151":284,"_153":268,"_154":140,"_155":285,"_157":122,"_109":286,"_103":231,"_160":174,"_162":287,"_163":27,"_164":-5,"_165":454,"_102":455},[],[267,283],{"_107":291,"_99":292,"_151":293,"_153":268,"_154":140,"_155":294,"_157":122,"_109":295,"_103":260,"_160":174,"_162":296,"_163":27,"_164":-5,"_165":457,"_102":458},[],[267,292],[267],{"_107":301,"_99":302,"_151":303,"_153":-5,"_154":140,"_155":304,"_157":122,"_109":305,"_103":159,"_160":161,"_162":-5,"_163":27,"_164":-5,"_165":461,"_102":471},[462,465,468],{"_107":308,"_99":309,"_151":310,"_153":303,"_154":140,"_155":311,"_157":122,"_109":312,"_103":241,"_160":174,"_162":313,"_163":27,"_164":-5,"_165":463,"_102":464},[],[302,309],{"_107":317,"_99":318,"_151":319,"_153":303,"_154":140,"_155":320,"_157":27,"_109":321,"_103":231,"_160":174,"_162":322,"_163":27,"_164":-5,"_165":466,"_102":467},[],[302,318],{"_107":326,"_99":190,"_151":327,"_153":303,"_154":140,"_155":328,"_157":27,"_109":329,"_103":173,"_160":174,"_162":330,"_163":27,"_164":-5,"_165":469,"_102":470},[],[302,190],[302],{"_107":335,"_99":336,"_151":337,"_153":-5,"_154":140,"_155":104,"_157":27,"_109":338,"_103":221,"_160":339,"_162":340,"_163":27,"_164":-5,"_165":473,"_102":474},[],[336],{"_107":344,"_99":345,"_151":120,"_153":-5,"_154":140,"_155":346,"_157":27,"_109":347,"_103":348,"_160":349,"_162":350,"_163":27,"_164":-5,"_165":476,"_102":477},[],[345],{"_107":354,"_99":355,"_151":356,"_153":-5,"_154":140,"_155":357,"_157":122,"_109":358,"_103":221,"_160":174,"_162":359,"_163":27,"_164":-5,"_165":479,"_102":480},[],[355],{"_107":363,"_99":364,"_151":365,"_153":-5,"_154":140,"_155":366,"_157":122,"_109":367,"_103":251,"_160":174,"_162":368,"_163":27,"_164":-5,"_165":482,"_102":483},[],[364],[415,417,420,423,427,429,432,435,438,441,444,448,450,453,456,460,462,465,468,472,475,478,481],[486,488,490,492,494,496,498,500],{"_107":149,"_99":150,"_151":152,"_153":-5,"_154":140,"_155":156,"_157":122,"_109":382,"_103":159,"_160":161,"_162":-5,"_163":27,"_164":-5,"_102":487},[150],{"_107":200,"_99":201,"_151":202,"_153":-5,"_154":140,"_155":203,"_157":122,"_109":385,"_103":159,"_160":161,"_162":-5,"_163":27,"_164":-5,"_102":489},[201],{"_107":266,"_99":267,"_151":268,"_153":-5,"_154":140,"_155":269,"_157":122,"_109":388,"_103":159,"_160":161,"_162":-5,"_163":27,"_164":-5,"_102":491},[267],{"_107":301,"_99":302,"_151":303,"_153":-5,"_154":140,"_155":304,"_157":122,"_109":391,"_103":159,"_160":161,"_162":-5,"_163":27,"_164":-5,"_102":493},[302],{"_107":335,"_99":336,"_151":337,"_153":-5,"_154":140,"_155":104,"_157":27,"_109":394,"_103":221,"_160":339,"_162":340,"_163":27,"_164":-5,"_102":495},[336],{"_107":344,"_99":345,"_151":120,"_153":-5,"_154":140,"_155":346,"_157":27,"_109":397,"_103":348,"_160":349,"_162":350,"_163":27,"_164":-5,"_102":497},[345],{"_107":354,"_99":355,"_151":356,"_153":-5,"_154":140,"_155":357,"_157":122,"_109":400,"_103":221,"_160":174,"_162":359,"_163":27,"_164":-5,"_102":499},[355],{"_107":363,"_99":364,"_151":365,"_153":-5,"_154":140,"_155":366,"_157":122,"_109":403,"_103":251,"_160":174,"_162":368,"_163":27,"_164":-5,"_102":501},[364],"showCompareCallout","pull","routes/_app","actionData","errors"]