[{"_1":2,"_169":-5,"_170":-5},"loaderData",{"_3":4,"_91":92},"root",{"_5":6,"_34":35,"_64":65},"ctx",{"_7":8,"_23":-5,"_24":25,"_26":27,"_28":20,"_29":20,"_30":20,"_31":32,"_33":20},"auth",{"_9":-5,"_10":-5,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":20,"_21":22},"sessionClaims","sessionId","sessionStatus","userId","actor","orgId","orgRole","orgSlug","orgPermissions","factorVerificationAge","isAuthenticated",false,"tokenType","session_token","user","preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","notificationCount",0,"flagDenols","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,"_62":63},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","VAL_RUNTIME_NAME","prod","RENDER_GIT_COMMIT","40390002a9f23719e5ece4788ed87655b391d648","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/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","API_URL","https://api.val.town","clerkState",{"_66":67},"__internal_clerk_state",{"_68":69,"_70":45,"_71":72,"_73":72,"_74":20,"_75":72,"_76":72,"_77":72,"_78":72,"_79":80,"_89":20,"_90":20},"__clerk_ssr_state",{"_21":22,"_9":-5,"_10":-5,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":20},"__publishableKey","__proxyUrl","","__domain","__isSatellite","__signInUrl","__signUpUrl","__afterSignInUrl","__afterSignUpUrl","__clerk_debug",{"_81":20,"_19":20,"_82":72,"_83":84,"_85":72,"_86":45,"_87":20,"_88":72},"isSignedIn","proxyUrl","reason","session-token-and-uat-missing","message","publishableKey","isSatellite","domain","__telemetryDisabled","__telemetryDebug","routes/embed.x.$handle.$name.$",{"_93":94,"_95":96,"_97":98,"_99":100,"_148":149,"_166":167,"_168":-5},"handle","saolsen","name","tracing","path","main.tsx","project",{"_101":102,"_95":96,"_103":104,"_105":-5,"_106":107,"_108":109,"_110":-5,"_111":-5,"_12":112,"_113":-5,"_114":107,"_115":-5,"_116":117,"_14":118,"_119":120,"_121":120,"_122":123,"_124":123,"_125":123,"_126":120,"_127":120,"_23":128,"_131":132,"_134":135,"_147":20},"id","e2dd04e8-27ac-11f0-9edc-569c3dd06744","createdAt",["D",1746228394245],"deletedAt","legacyEnvVars",true,"privacy","public","description","imageUrl","e1269f9c-67ab-446c-9c3f-debdc882a7b8","pinnedFileId","pinPreview","screenshotVersion","likeCount",3,"6af58753-71c6-4397-9d5b-2473eb888976","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm",{"_93":94,"_129":130},"profileImageUrl","https://images.clerk.dev/oauth_github/img_2QtXHzN3gDPhKsBOvKsst8LTxC5.png","org",{"_93":94,"_133":130},"avatar","branch",{"_136":137,"_95":43,"_101":138,"_139":102,"_140":-5,"_141":-5,"_142":-5,"_143":-5,"_144":-5,"_145":96,"_146":94},"version",137,"e2dd5218-27ac-11f0-9edc-569c3dd06744","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","isOwned","file",{"_101":150,"_95":98,"_151":152,"_153":-5,"_154":138,"_155":137,"_156":107,"_103":157,"_136":158,"_159":160,"_161":162,"_163":20,"_164":-5,"_97":165},"e5a4116c-27ac-11f0-9edc-569c3dd06744","fileId","e2df6e4a-27ac-11f0-9edc-569c3dd06744","parentId","branchId","branchVersion","latest",["D",1704479649426],136,"fileType","script","content","import \"https://deno.land/x/xhr@0.1.0/mod.ts\";\nimport \"node:async_hooks\";\nimport { context, propagation, SpanStatusCode, trace } from \"https://cdn.skypack.dev/@opentelemetry/api\";\nimport { OTLPTraceExporter } from \"https://cdn.skypack.dev/@opentelemetry/exporter-trace-otlp-http\";\nimport { B3Propagator } from \"https://cdn.skypack.dev/@opentelemetry/propagator-b3\";\nimport { Resource } from \"https://cdn.skypack.dev/@opentelemetry/resources\";\nimport {\n ConsoleSpanExporter,\n SimpleSpanProcessor,\n WebTracerProvider,\n} from \"https://cdn.skypack.dev/@opentelemetry/sdk-trace-web\";\nimport { SemanticResourceAttributes } from \"https://cdn.skypack.dev/@opentelemetry/semantic-conventions\";\nimport { AsyncLocalStorageContextManager } from \"npm:@opentelemetry/context-async-hooks\";\n\nexport function get_tracer() {\n return trace.getTracer(\"valtown\");\n}\n\n/**\n * Initializes opentelemetry tracing.\n */\nexport function init(service_name: string, console_log: bool = false): undefined {\n const provider = new WebTracerProvider({\n resource: new Resource({\n [SemanticResourceAttributes.SERVICE_NAME]: service_name,\n }),\n });\n\n // Log traces to console if console_log is set.\n if (console_log) {\n provider.addSpanProcessor(new SimpleSpanProcessor(new ConsoleSpanExporter()));\n }\n\n // Send traces to honeycomb if HONEYCOMB_API_KEY key is set.\n const honeycomb_api_key = Deno.env.get(\"HONEYCOMB_API_KEY\");\n if (honeycomb_api_key) {\n provider.addSpanProcessor(\n new SimpleSpanProcessor(\n new OTLPTraceExporter({\n url: \"https://api.honeycomb.io/v1/traces\",\n headers: {\n \"x-honeycomb-team\": honeycomb_api_key,\n },\n }),\n ),\n );\n }\n provider.register({\n contextManager: new AsyncLocalStorageContextManager(),\n propagator: new B3Propagator(),\n });\n}\n\n/**\n * Wrapper for fetch that traces the request. It also passes a propagation header\n * so if you are calling another val that uses traced_handler their traces will\n * be tied together.\n */\nexport async function traced_fetch(\n input: string | URL,\n init?: RequestInit,\n): Promise {\n return await get_tracer().startActiveSpan(`fetch`, async (span) => {\n const prop_output: { b3: string } = { b3: \"\" };\n propagation.inject(context.active(), prop_output);\n try {\n const resp: Response = await fetch(input, {\n ...init,\n headers: {\n b3: prop_output.b3,\n ...(init?.headers ?? {}),\n },\n });\n span.setAttributes({\n \"http.url\": resp.url,\n \"response.status_code\": resp.status,\n });\n if (resp.ok && resp.status >= 200 && resp.status < 400) {\n span.setStatus({ code: SpanStatusCode.OK });\n } else {\n span.setStatus({\n code: SpanStatusCode.ERROR,\n message: await resp.clone().text(),\n });\n }\n return resp;\n } catch (error) {\n span.setStatus({\n code: SpanStatusCode.ERROR,\n message: error.message,\n });\n throw new Error(error);\n } finally {\n span.end();\n }\n });\n}\n\n/**\n * Wrapper to trace a function.\n */\n// deno-lint-ignore no-explicit-any\nexport const traced = any>(\n name: string,\n fn: F,\n) => {\n return async (...args: Parameters): Promise>> => {\n return await get_tracer().startActiveSpan(name, async (span) => {\n try {\n const result = await fn(...args);\n if (span.isRecording()) {\n span.setStatus({ code: SpanStatusCode.OK });\n }\n return result;\n } catch (error) {\n if (span.isRecording()) {\n span.setStatus({\n code: SpanStatusCode.ERROR,\n message: error.message,\n });\n }\n throw new Error(error);\n } finally {\n span.end();\n }\n });\n };\n};\n\n/**\n * Takes an http handler and returns a new handler that\n * traces the request.\n * @returns {Function} A new handler that traces the request.\n */\nexport function traced_handler(\n handler: (req: Request) => Promise,\n): (req: Request) => Promise {\n async function _traced_hander(req: Request): Promise {\n let active_context = null;\n const prop_header = req.headers.get(\"b3\");\n if (prop_header) {\n active_context = propagation.extract(context.active(), {\n b3: prop_header,\n });\n }\n\n return await get_tracer().startActiveSpan(\n `${req.method} ${req.url}`,\n {},\n active_context,\n async (span) => {\n try {\n const resp: Response = await handler(req);\n span.setAttributes({\n \"http.method\": req.method,\n \"http.url\": req.url,\n \"response.status_code\": resp.status,\n });\n if (resp.ok && resp.status >= 200 && resp.status < 400) {\n span.setStatus({ code: SpanStatusCode.OK });\n } else {\n span.setStatus({\n code: SpanStatusCode.ERROR,\n message: await resp.clone().text(),\n });\n }\n return resp;\n } catch (error) {\n span.setStatus({\n code: SpanStatusCode.ERROR,\n message: error.message,\n });\n throw new Error(error);\n } finally {\n span.end();\n }\n },\n );\n }\n return _traced_hander;\n}","deleted","label",[98],"permalink","https://www.val.town/x/saolsen/tracing/code/main.tsx","extension","actionData","errors"]