[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_193":194,"_195":196},"routes/_app.x.$handle.$name",{"_16":17,"_20":21,"_83":65,"_84":85,"_63":-7,"_86":-5,"_13":87,"_88":89,"_11":90,"_91":92,"_93":94,"_95":-5,"_96":-5,"_97":-5,"_98":26,"_99":100,"_101":26,"_102":-5,"_103":-5,"_104":105},"routes/_app.x.$handle.$name.search.$(branch)",{"_11":12,"_13":14,"_15":-5,"_16":17},"files",[],"project",{"_18":19,"_20":21,"_22":23,"_24":-5,"_25":26,"_27":28,"_29":28,"_30":31,"_32":-5,"_33":34,"_35":-5,"_36":26,"_37":-5,"_38":-5,"_39":40,"_41":42,"_43":-5,"_44":-5,"_45":-5,"_46":-5,"_47":48,"_49":48,"_50":51,"_52":51,"_53":51,"_54":48,"_55":48,"_56":57,"_58":59,"_60":61,"_62":26},"query","handle","cricks_unmixed4u","id","9d37c6fa-1f6b-4e6c-b37d-362632a15818","name","effect-utrecht-meetup","createdAt",["D",1784809347061],"deletedAt","legacyEnvVars",false,"privacy","public","httpPrivacy","description","Demo code from the Effect-TS Meetup Utrecht talk","imageUrl","userId","0b86c720-ddc6-11ef-94bf-d1c3ffb48162","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","7018ec7d-7a8e-4e8f-93d1-ab6a7334ca50","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_16":17,"_82":78},"org",{"_16":17,"_75":76,"_77":78,"_33":34,"_79":80,"_81":26},"branch",{"_63":64,"_20":65,"_18":66,"_67":19,"_68":-5,"_69":-5,"_70":-5,"_71":-5,"_72":-5,"_73":21,"_74":17},"isOwned","version",9,"main","1b4f9e5b-2b97-4454-af55-2b8d4937cd3c","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","ozan","avatar","https://img.clerk.com/eyJ0eXBlIjoiZGVmYXVsdCIsImlpZCI6Imluc18yTm10cGhQUklwU0tqZHNiOHNnNGd2ZjJURFUiLCJyaWQiOiJ1c2VyXzJzSEJuSGdYT2dQSmprejVnU0VqalpDaWhKUSJ9","tier","pro","canRestrictVals","profileImageUrl","branchName","path","","adoptOrgId",{"_18":19,"_20":21,"_22":189,"_24":-5,"_25":26,"_27":28,"_29":28,"_30":31,"_32":-5,"_33":34,"_35":-5,"_36":26,"_37":-5,"_38":-5,"_39":40,"_41":42,"_43":-5,"_44":-5,"_45":-5,"_46":-5,"_47":48,"_49":48,"_50":51,"_52":51,"_53":51,"_54":48,"_55":48,"_56":190,"_58":191,"_60":192,"_62":26},"tree",[168,169,170,171,172],[168,169,170,171,172],"counts",{"_157":40,"_158":159,"_160":40,"_161":162,"_163":164},"contents",[106,107,108,109,110],"file","upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_18":150,"_20":151,"_113":152,"_115":-5,"_116":66,"_117":153,"_119":120,"_22":154,"_63":40,"_122":123,"_124":155,"_126":26,"_127":-5,"_84":156},{"_18":143,"_20":144,"_113":145,"_115":-5,"_116":66,"_117":146,"_119":120,"_22":147,"_63":40,"_122":123,"_124":148,"_126":26,"_127":-5,"_84":149},{"_18":136,"_20":137,"_113":138,"_115":-5,"_116":66,"_117":139,"_119":120,"_22":140,"_63":40,"_122":123,"_124":141,"_126":26,"_127":-5,"_84":142},{"_18":129,"_20":130,"_113":131,"_115":-5,"_116":66,"_117":132,"_119":120,"_22":133,"_63":40,"_122":123,"_124":134,"_126":26,"_127":-5,"_84":135},{"_18":111,"_20":112,"_113":114,"_115":-5,"_116":66,"_117":118,"_119":120,"_22":121,"_63":40,"_122":123,"_124":125,"_126":26,"_127":-5,"_84":128},"9bf274e7-a055-4524-9382-12812fd90493","trace-tree.ts","fileId","49b5bc84-8691-11f1-b267-1607ee4eb77e","parentId","branchId","branchVersion",4,"latest",true,["D",1784809399012],"fileType","script","content","/**\n * A tiny SpanExporter that, instead of dumping raw OTel JSON, records spans\n * in memory so we can print them as an indented ASCII tree: parent/child\n * nesting and sibling concurrency made visible at a glance, for live demos.\n */\n\nexport interface RecordedSpan {\n readonly traceId: string\n readonly spanId: string\n readonly parentSpanId: string | undefined\n readonly name: string\n readonly startMs: number\n readonly durationMs: number\n readonly ok: boolean\n readonly errorMessage: string | undefined\n}\n\nexport const recordedSpans: RecordedSpan[] = []\n\nexport class TreeSpanExporter {\n export(spans: ReadonlyArray, resultCallback: (result: { code: number }) => void): void {\n for (const span of spans) {\n const [startSec, startNanoRemainder] = span.startTime\n recordedSpans.push({\n traceId: span.spanContext().traceId,\n spanId: span.spanContext().spanId,\n parentSpanId: span.parentSpanContext?.spanId,\n name: span.name,\n startMs: startSec * 1000 + startNanoRemainder / 1e6,\n durationMs: span.duration[0] * 1000 + span.duration[1] / 1e6,\n ok: span.status.code !== 2,\n errorMessage: span.status.message,\n })\n }\n resultCallback({ code: 0 })\n }\n\n shutdown(): Promise {\n return Promise.resolve()\n }\n\n forceFlush(): Promise {\n return Promise.resolve()\n }\n}\n\nexport function printTraceTrees(spans: ReadonlyArray = recordedSpans): void {\n const byTrace = new Map()\n for (const s of spans) {\n const group = byTrace.get(s.traceId) ?? []\n group.push(s)\n byTrace.set(s.traceId, group)\n }\n\n for (const [traceId, group] of byTrace) {\n const byParent = new Map()\n for (const s of group) {\n const siblings = byParent.get(s.parentSpanId) ?? []\n siblings.push(s)\n byParent.set(s.parentSpanId, siblings)\n }\n\n const traceStart = Math.min(...group.map((s) => s.startMs))\n const maxDuration = Math.max(...group.map((s) => s.durationMs))\n const barWidth = 24\n\n console.log(`\\ntrace ${traceId.slice(0, 8)}`)\n\n const printNode = (span: RecordedSpan, prefix: string, isLast: boolean): void => {\n const children = (byParent.get(span.spanId) ?? []).sort((a, b) => a.startMs - b.startMs)\n const connector = isLast ? \"└─ \" : \"├─ \"\n const filled = Math.max(1, Math.round((span.durationMs / maxDuration) * barWidth))\n const bar = \"#\".repeat(filled).padEnd(barWidth, \" \")\n const offset = Math.round(span.startMs - traceStart)\n const status = span.ok ? \"\" : ` ✗ ${span.errorMessage ?? \"failed\"}`\n console.log(\n `${prefix}${connector}${span.name.padEnd(24)} [${bar}] ${Math.round(span.durationMs)}ms @+${offset}ms${status}`,\n )\n const childPrefix = prefix + (isLast ? \" \" : \"│ \")\n children.forEach((child, i) => printNode(child, childPrefix, i === children.length - 1))\n }\n\n const roots = (byParent.get(undefined) ?? []).sort((a, b) => a.startMs - b.startMs)\n roots.forEach((root, i) => printNode(root, \"\", i === roots.length - 1))\n }\n}\n","deleted","label",[112],"03331f6e-acb3-4202-b66d-ca442e9a5924","run-demo.ts","5b38fe58-8691-11f1-9e90-1607ee4eb77e",7,["D",1784809428382],"/**\n * Standalone runner for articles-demo.ts and nesting-demo.ts: exercises the\n * success path, the induced-failure path, and a fork-free auto-nesting\n * example, without going through main.ts / Val Town. Prints each trace as an\n * ASCII tree instead of raw OTel JSON.\n */\nimport { runArticleDemo } from \"./articles-demo.ts\"\nimport { runNestingDemo } from \"./nesting-demo.ts\"\nimport { printTraceTrees } from \"./trace-tree.ts\"\n\nconsole.log(\"=== success: article.create + notification ===\")\nawait runArticleDemo({ title: \"Effect makes spans free\", body: \"Traced automatically.\" })\n\nconsole.log(\"\\n=== failure: notification unreachable (request still succeeds) ===\")\nawait runArticleDemo({\n title: \"Tenant demo\",\n failNotification: true,\n tenant: { id: \"acme\", region: \"us-east\" },\n})\n\nconsole.log(\"\\n=== auto nesting: sequential + concurrent siblings, no fork ===\")\nawait runNestingDemo()\n\n// The forked notification fibers finish ~400ms after their parent request\n// returns; wait for them to land before drawing the trees.\nawait new Promise((resolve) => setTimeout(resolve, 600))\n\nconsole.log(\"\\n--- trace trees ---\")\nprintTraceTrees()\n",[130],"6deb8d96-74e1-4c67-b5b2-8c3109432a58","nesting-demo.ts","570f960c-8691-11f1-a97c-1607ee4eb77e",6,["D",1784809421369],"/**\n * Minimal \"auto nesting\" demo: no forking, no fire-and-forget, just plain\n * sequential and concurrent Effect composition. Spans land in the same tree\n * with zero manual span or context plumbing.\n */\nimport { Duration, Effect, ManagedRuntime } from \"https://esm.sh/effect@4.0.0-beta.101\"\nimport * as NodeSdk from \"https://esm.sh/@effect/opentelemetry@4.0.0-beta.101/NodeSdk\"\nimport { SimpleSpanProcessor } from \"https://esm.sh/@opentelemetry/sdk-trace-base@2\"\nimport { TreeSpanExporter } from \"./trace-tree.ts\"\n\nconst NodeSdkLive = NodeSdk.layer(() => ({\n resource: { serviceName: \"nesting-demo\" },\n spanProcessor: new SimpleSpanProcessor(new TreeSpanExporter()),\n}))\n\nconst step = (name: string, ms: number) => Effect.sleep(Duration.millis(ms)).pipe(Effect.withSpan(name))\n\n// Wraps a sequence of child effects in their own parent span. Still nothing\n// but plain yield* — the nesting falls out of the code shape, any depth.\nconst nested = (name: string, children: Effect.Effect[]) =>\n Effect.gen(function* () {\n for (const child of children) yield* child\n }).pipe(Effect.withSpan(name))\n\n// validate goes three levels deep: validate -> validate.rules -> validate.rules.fraud\nconst validate = nested(\"validate\", [\n step(\"validate.schema\", 10),\n nested(\"validate.rules\", [\n step(\"validate.rules.limits\", 8),\n step(\"validate.rules.fraud\", 12),\n ]),\n])\n\n// email goes one level deep: email -> email.render -> email.send, sequential.\nconst email = nested(\"email\", [\n step(\"email.render\", 20),\n step(\"email.send\", 30),\n])\n\n// Sequential: each step is a plain yield*, nothing threads a span by hand.\nconst sequentialDemo = Effect.gen(function* () {\n yield* validate\n yield* step(\"charge\", 80)\n yield* step(\"persist\", 40)\n}).pipe(Effect.withSpan(\"process.sequential\"))\n\n// Concurrent: same nesting, siblings just run in parallel via Effect.all.\nconst concurrentDemo = Effect.gen(function* () {\n yield* Effect.all(\n [email, step(\"warehouse\", 90), step(\"analytics\", 40)],\n { concurrency: \"unbounded\" },\n )\n}).pipe(Effect.withSpan(\"process.concurrent\"))\n\nconst runtime = ManagedRuntime.make(NodeSdkLive)\n\nexport const runNestingDemo = () => runtime.runPromise(Effect.all([sequentialDemo, concurrentDemo]))\n",[137],"68117cdd-8f7f-4988-be3b-ebc18f02e13f","articles-effect.ts","418e886a-8691-11f1-9d1e-1607ee4eb77e",3,["D",1784809385337],"/**\n * Effect version of `createArticle` — line-for-line against the OTel/async\n * original. Same behavior: root span, attributes, fire-and-forget\n * notification that must not fail the request, error recorded on the span.\n *\n * What does NOT exist in this file, because the runtime owns it:\n * - tracer.startActiveSpan / span.end / finally (span = fiber scope)\n * - span.setStatus(OK|ERROR) / span.recordException (Exit → span status)\n * - try/catch + `throw error` re-raise (typed error channel)\n * - `.catch((err) => console.error(...))` (fork + tapCause)\n * - `error as Error` casts (errors are values)\n *\n * Requires Effect v4 (Context.Service): pinned below to the v4 beta that\n * matches @effect/opentelemetry's v4 beta tag used in articles-demo.ts.\n */\nimport {\n Context,\n Data,\n Effect,\n Layer,\n} from \"https://esm.sh/effect@4.0.0-beta.101\";\n\n// --- Dependencies as services (stand-ins for drizzle + the job queue) -------\n\nexport class ArticleInsertError extends Data.TaggedError(\"ArticleInsertError\")<{\n readonly slug: string;\n readonly cause: unknown;\n}> {}\n\ninterface ArticleRow {\n readonly id: number;\n readonly slug: string;\n readonly title: string;\n readonly authorId: number;\n}\n\nexport class Database extends Context.Service<\n Database,\n {\n readonly insertArticle: (values: {\n readonly slug: string;\n readonly title: string;\n readonly description: string | null;\n readonly body: string;\n readonly authorId: number;\n }) => Effect.Effect;\n }\n>()(\"app/Database\") {}\n\nexport class Notifications extends Context.Service<\n Notifications,\n {\n readonly articleCreated: (input: {\n readonly articleId: number;\n readonly articleSlug: string;\n readonly authorId: number;\n readonly title: string;\n }) => Effect.Effect;\n }\n>()(\"app/Notifications\") {}\n\nconst generateSlug = (title: string) =>\n title.toLowerCase().replace(/[^a-z0-9]+/g, \"-\").replace(/^-|-$/g, \"\");\n\nexport class Articles extends Context.Service()(\"app/Articles\", {\n make: Effect.gen(function* () {\n const db = yield* Database;\n const notifications = yield* Notifications;\n\n const create = Effect.fn(\"article.create\")(\n function* (\n authorId: number,\n input: { title: string; description?: string; body: string },\n ) {\n const slug = generateSlug(input.title);\n\n const article = yield* db.insertArticle({\n slug,\n title: input.title,\n description: input.description ?? null,\n body: input.body,\n authorId,\n });\n\n yield* Effect.annotateCurrentSpan({\n \"user.id\": authorId,\n \"article.id\": article.id,\n });\n\n // Fire-and-forget, but NOT invisible: the forked fiber inherits the\n // trace, gets its own child span, and failures land on that span's\n // exit + the logs — instead of a floating promise with .catch(console.error).\n yield* notifications\n .articleCreated({\n articleId: article.id,\n articleSlug: article.slug,\n authorId,\n title: article.title,\n })\n .pipe(\n Effect.withSpan(\"notification.articleCreated\"),\n Effect.tapCause((cause) =>\n Effect.logWarning(\"Failed to enqueue notification\", cause)\n ),\n Effect.forkDetach,\n );\n\n return article;\n },\n );\n\n return { create } as const;\n }),\n}) {\n static readonly layerNoDeps = Layer.effect(this, this.make);\n}\n\n// --- Tenant attribution: the multi-tenant / single-tenant switch -------------\n//\n// In the OTel version, tenant attributes on every span require a custom\n// SpanProcessor wired into the SDK, or setAttribute calls sprinkled into\n// every service. Here it's `Effect.annotateSpans` — a combinator applied at\n// whatever scope owns the tenancy decision. The service code above never\n// changes.\n\n// Single-tenant deployment: annotate at the composition root, once, at boot.\n// Every span in the entire app carries the attributes.\nexport const annotateDeployment = (app: Effect.Effect) =>\n Effect.annotateSpans(app, {\n \"app.tenant_id\": \"org_school_001\",\n \"app.data_region\": \"eu-west\",\n });\n\n// Multi-tenant api-proxy: annotate at the request boundary. Every span under\n// this request — including the forked notification fiber, which inherits the\n// annotations — carries the authenticated tenant.\nexport const handleRequest = (\n tenant: { id: string; region: string },\n authorId: number,\n input: { title: string; body: string },\n) =>\n Effect.gen(function* () {\n const articles = yield* Articles;\n return yield* articles.create(authorId, input);\n }).pipe(\n Effect.annotateSpans({\n \"app.tenant_id\": tenant.id,\n \"app.data_region\": tenant.region,\n }),\n );\n",[144],"be1150e6-b9b2-4bad-8495-e62bf5223e08","articles-demo.ts","50fc6998-8691-11f1-a028-1607ee4eb77e",5,["D",1784809411130],"/**\n * Runnable harness for articles-effect.ts: mock Database/Notifications, a\n * standalone Effect v4 + OTel runtime, and an HTTP-friendly entry point.\n *\n * Deliberately a separate Effect major version from main.ts (which runs\n * effect@3.22.0 for the writing-assistant demo). Effect v3 and v4 values\n * cannot cross a pipe/provide boundary, so this file owns its own\n * ManagedRuntime end to end; only the resulting Promise crosses into main.ts.\n */\nimport { Duration, Effect, Layer, LogLevel, ManagedRuntime, References } from \"https://esm.sh/effect@4.0.0-beta.101\"\nimport * as NodeSdk from \"https://esm.sh/@effect/opentelemetry@4.0.0-beta.101/NodeSdk\"\nimport { SimpleSpanProcessor } from \"https://esm.sh/@opentelemetry/sdk-trace-base@2\"\nimport { Articles, Database, handleRequest, Notifications } from \"./articles-effect.ts\"\nimport { TreeSpanExporter } from \"./trace-tree.ts\"\n\nconst NodeSdkLive = NodeSdk.layer(() => ({\n resource: { serviceName: \"articles-effect-demo\" },\n spanProcessor: new SimpleSpanProcessor(new TreeSpanExporter()),\n}))\n\n// In-memory stand-in for drizzle: an incrementing id, a small artificial delay.\nlet nextId = 1\nconst DatabaseDemo = Layer.succeed(Database, {\n insertArticle: (values) =>\n Effect.succeed({ id: nextId++, slug: values.slug, title: values.title, authorId: values.authorId }).pipe(\n Effect.delay(Duration.millis(120)),\n ),\n})\n\n// `fail` lets the presenter trigger the notification-failure path live,\n// on demand, instead of leaving it to chance.\nconst notificationsLayer = (fail: boolean) =>\n Layer.succeed(Notifications, {\n articleCreated: () =>\n (fail ? Effect.fail(new Error(\"notification service unreachable\")) : Effect.void).pipe(\n Effect.delay(Duration.millis(400)),\n ),\n })\n\n// The ✗ on a failed span already shows the failure in the trace tree; the\n// console WARN from Effect.logWarning would just be noise on top of it.\nconst runtime = ManagedRuntime.make(\n Layer.merge(NodeSdkLive, Layer.succeed(References.MinimumLogLevel, LogLevel.None)),\n)\n\nexport interface ArticleDemoInput {\n readonly title: string\n readonly body?: string\n readonly authorId?: number\n readonly failNotification?: boolean\n readonly tenant?: { id: string; region: string }\n}\n\nexport function runArticleDemo(input: ArticleDemoInput) {\n const tenant = input.tenant ?? { id: \"demo-tenant\", region: \"eu-west\" }\n const ArticlesLive = Articles.layerNoDeps.pipe(\n Layer.provide(Layer.merge(DatabaseDemo, notificationsLayer(!!input.failNotification))),\n )\n\n return runtime.runPromise(\n handleRequest(tenant, input.authorId ?? 1, { title: input.title, body: input.body ?? \"\" }).pipe(\n Effect.provide(ArticlesLive),\n Effect.withSpan(\"http /demo/article\"),\n ),\n )\n}\n",[151],"pulls","branches",1,"forks","envVars",{"_165":40,"_167":40},"connections",{"_165":40,"_166":40},"count","unfilledCount","emptyCount",{"_18":150,"_20":151,"_113":152,"_115":-5,"_116":66,"_117":153,"_119":120,"_22":186,"_63":40,"_122":123,"_124":155,"_126":26,"_127":-5,"_174":187,"_84":188},{"_18":143,"_20":144,"_113":145,"_115":-5,"_116":66,"_117":146,"_119":120,"_22":183,"_63":40,"_122":123,"_124":148,"_126":26,"_127":-5,"_174":184,"_84":185},{"_18":136,"_20":137,"_113":138,"_115":-5,"_116":66,"_117":139,"_119":120,"_22":180,"_63":40,"_122":123,"_124":141,"_126":26,"_127":-5,"_174":181,"_84":182},{"_18":129,"_20":130,"_113":131,"_115":-5,"_116":66,"_117":132,"_119":120,"_22":177,"_63":40,"_122":123,"_124":134,"_126":26,"_127":-5,"_174":178,"_84":179},{"_18":111,"_20":112,"_113":114,"_115":-5,"_116":66,"_117":118,"_119":120,"_22":173,"_63":40,"_122":123,"_124":125,"_126":26,"_127":-5,"_174":175,"_84":176},["D",1784809399012],"children",[],[112],["D",1784809428382],[],[130],["D",1784809421369],[],[137],["D",1784809385337],[],[144],["D",1784809411130],[],[151],["D",1784809347061],{"_16":17,"_82":78},{"_16":17,"_75":76,"_77":78,"_33":34,"_79":80,"_81":26},{"_63":64,"_20":65,"_18":66,"_67":19,"_68":-5,"_69":-5,"_70":-5,"_71":-5,"_72":-5,"_73":21,"_74":17},"ctx",{"_56":-5,"_103":226,"_227":228,"_229":230,"_231":26,"_232":26,"_233":26,"_234":120,"_235":-5,"_236":-7,"_237":-7,"_238":40,"_239":26,"_240":26,"_241":-5,"_242":26,"_243":26,"_244":26,"_245":-5},"ENV",{"_197":198,"_199":200,"_201":65,"_202":203,"_204":205,"_206":207,"_208":209,"_210":211,"_212":213,"_214":215,"_216":217,"_218":219,"_220":221,"_222":223,"_224":225},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Search