[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_163":164,"_165":166},"routes/_app.x.$handle.$name",{"_94":93,"_32":44,"_103":84,"_27":104,"_13":14,"_105":-5,"_11":106,"_107":108,"_109":110,"_111":112,"_113":114,"_20":-5,"_115":-5,"_116":-5,"_117":26,"_118":119,"_120":24,"_121":-5,"_122":-5,"_123":124},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_42":43,"_32":44,"_37":45,"_46":-5,"_47":26,"_48":49,"_50":49,"_51":52,"_53":-5,"_18":54,"_55":-5,"_56":26,"_57":-5,"_58":-5,"_59":60,"_61":62,"_63":-5,"_64":-5,"_65":-5,"_66":-5,"_67":68,"_69":68,"_70":71,"_72":71,"_73":71,"_74":68,"_75":68,"_76":77,"_78":79,"_80":81,"_82":26},"version",2,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":-7,"_23":24,"_25":26,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":34,"_35":36,"_37":38,"_39":14,"_40":41,"_23":26},"previous","deleted",true,"deletedHere",false,"path","main.before.ts","latestPath","fileId","376ccc7a-8691-11f1-911d-1607ee4eb77e","name","fileType","http","content","import { serveFile } from \"https://esm.town/v/std/utils/index.ts\";\n\nconst GREENPT_BASE_URL = \"https://api.greenpt.ai/v1\";\nconst GREENPT_TAKEOVER_MODEL = \"green-l-raw\"; // Mistral Small 3.2, fast, non-reasoning\nconst GREENPT_SUGGEST_MODEL = \"qwen3-coder-30b-a3b-instruct\"; // completion-tuned\n\nfunction log(level: \"info\" | \"error\" | \"debug\", msg: string, data?: unknown) {\n const entry = JSON.stringify({ ts: new Date().toISOString(), level, msg, ...(data !== undefined && { data }) });\n if (level === \"error\") console.error(entry);\n else console.log(entry);\n}\n\nasync function greenptChat(model: string, system: string, user: string, maxTokens: number): Promise {\n const apiKey = Deno.env.get(\"GREENPT_API_KEY\");\n if (!apiKey) throw new Error(\"GREENPT_API_KEY is not set\");\n\n log(\"info\", \"greenpt request\", { model, maxTokens });\n const t0 = Date.now();\n const res = await fetch(`${GREENPT_BASE_URL}/chat/completions`, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\", Authorization: `Bearer ${apiKey}` },\n body: JSON.stringify({\n model,\n max_tokens: maxTokens,\n temperature: 0.7,\n messages: [\n { role: \"system\", content: system },\n { role: \"user\", content: user },\n ],\n }),\n });\n\n if (!res.ok) {\n const detail = await res.text();\n log(\"error\", \"greenpt error\", { model, status: res.status, durationMs: Date.now() - t0, detail: detail.slice(0, 300) });\n throw new Error(`GreenPT ${res.status}: ${detail.slice(0, 300)}`);\n }\n\n const raw = await res.json();\n log(\"debug\", \"greenpt raw\", { model, raw });\n const content = raw?.choices?.[0]?.message?.content ?? \"\";\n log(\"info\", \"greenpt done\", { model, contentLen: content.length, durationMs: Date.now() - t0, usage: raw?.usage });\n return content;\n}\n\nasync function continueText(text: string): Promise {\n const snippet = text.slice(-1500);\n return greenptChat(\n GREENPT_TAKEOVER_MODEL,\n \"You are an AI that hijacks a piece of in-progress writing the moment its human author stops typing. \" +\n \"Continue their text from exactly where it left off, matching their tone, topic, and language. \" +\n \"Write 1-2 short sentences only. Do not repeat what is already there, do not add quotation marks, \" +\n \"labels, or commentary — output only the continuation, starting with a leading space if the text \" +\n \"does not already end with whitespace.\",\n snippet || \"Begin a short piece of reflective writing.\",\n 150,\n );\n}\n\nasync function buildContext(text: string): Promise {\n const snippet = text.slice(-1200);\n return greenptChat(\n GREENPT_TAKEOVER_MODEL,\n \"You are a context extractor for a writing assistant. Given in-progress text, produce a short \" +\n \"plain-text context block (3-6 sentences max) covering: the topic and tone, any implicit \" +\n \"questions or requests the writer seems to be building toward, and key facts or entities \" +\n \"established so far. Be concise and factual. Do not add opinions or complete the writing.\",\n snippet || \"(empty)\",\n 200,\n );\n}\n\nasync function suggestCompletion(text: string): Promise {\n const snippet = text.slice(-800);\n\n const context = await buildContext(text);\n log(\"debug\", \"suggestCompletion context\", { context });\n\n const systemPrompt =\n 'You are an inline writing completion assistant. Given the tail of an in-progress piece, ' +\n 'return a JSON object {\"completion\":\"...\"} with a short inline completion that finishes the ' +\n \"current sentence without starting a new one — unless there is a clear question or request in \" +\n \"the text that you can answer directly, in which case answer it concisely as the completion. \" +\n 'If nothing is needed, return {\"completion\":\"\"}. Output only valid JSON, no markdown, no code fences.\\n\\n' +\n `\\n${context}\\n`;\n\n const raw = await greenptChat(GREENPT_SUGGEST_MODEL, systemPrompt, snippet || \"I\", 100);\n\n try {\n const cleaned = raw.replace(/^```(?:json)?\\s*/i, \"\").replace(/\\s*```$/, \"\").trim();\n const parsed = JSON.parse(cleaned);\n return typeof parsed.completion === \"string\" ? parsed.completion : \"\";\n } catch {\n log(\"error\", \"suggestCompletion parse failed\", { raw });\n return \"\";\n }\n}\n\nexport default async function (req: Request): Promise {\n const url = new URL(req.url);\n\n if (req.method === \"POST\" && url.pathname === \"/ai/continue\") {\n const t0 = Date.now();\n try {\n const { text } = await req.json();\n log(\"info\", \"POST /ai/continue\", { textLen: typeof text === \"string\" ? text.length : null });\n const continuation = await continueText(typeof text === \"string\" ? text : \"\");\n log(\"info\", \"POST /ai/continue done\", { durationMs: Date.now() - t0 });\n return Response.json({ continuation });\n } catch (err) {\n log(\"error\", \"POST /ai/continue failed\", { error: String(err), durationMs: Date.now() - t0 });\n return Response.json({ error: String(err) }, { status: 500 });\n }\n }\n\n if (req.method === \"POST\" && url.pathname === \"/ai/context\") {\n const t0 = Date.now();\n try {\n const { text } = await req.json();\n log(\"info\", \"POST /ai/context\", { textLen: typeof text === \"string\" ? text.length : null });\n const context = await buildContext(typeof text === \"string\" ? text : \"\");\n log(\"info\", \"POST /ai/context done\", { durationMs: Date.now() - t0 });\n return Response.json({ context });\n } catch (err) {\n log(\"error\", \"POST /ai/context failed\", { error: String(err), durationMs: Date.now() - t0 });\n return Response.json({ error: String(err) }, { status: 500 });\n }\n }\n\n if (req.method === \"POST\" && url.pathname === \"/ai/suggest\") {\n const t0 = Date.now();\n try {\n const { text } = await req.json();\n log(\"info\", \"POST /ai/suggest\", { textLen: typeof text === \"string\" ? text.length : null });\n const completion = await suggestCompletion(typeof text === \"string\" ? text : \"\");\n log(\"info\", \"POST /ai/suggest done\", { durationMs: Date.now() - t0 });\n return Response.json({ completion });\n } catch (err) {\n log(\"error\", \"POST /ai/suggest failed\", { error: String(err), durationMs: Date.now() - t0 });\n return Response.json({ completion: \"\" }); // soft-fail: don't surface to user\n }\n }\n\n switch (url.pathname) {\n case \"/style.css\": return serveFile(\"/style.css\", import.meta.url);\n case \"/client.js\": return serveFile(\"/client.js\", import.meta.url);\n case \"/tiny-lm.js\": return serveFile(\"/tiny-lm.js\", import.meta.url);\n case \"/debug.js\": return serveFile(\"/debug.js\", import.meta.url);\n case \"/llm.html\": return serveFile(\"/llm.html\", import.meta.url);\n case \"/llm.js\": return serveFile(\"/llm.js\", import.meta.url);\n case \"/\":\n case \"/index.html\": return serveFile(\"/index.html\", import.meta.url);\n default: return new Response(\"Not found\", { status: 404 });\n }\n}\n","createdAt",["D",1784809368274],"branchVersion","branchId","1b4f9e5b-2b97-4454-af55-2b8d4937cd3c","id","9d37c6fa-1f6b-4e6c-b37d-362632a15818","effect-utrecht-meetup",["D",1784809347061],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Demo code from the Effect-TS Meetup Utrecht talk","imageUrl","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",{"_94":93,"_102":98},"org",{"_94":93,"_95":96,"_97":98,"_18":54,"_99":100,"_101":26},"branch",{"_13":83,"_32":84,"_42":41,"_85":43,"_86":-5,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":44,"_92":93},"isOwned",9,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","cricks_unmixed4u","handle","displayName","ozan","avatar","https://img.clerk.com/eyJ0eXBlIjoiZGVmYXVsdCIsImlpZCI6Imluc18yTm10cGhQUklwU0tqZHNiOHNnNGd2ZjJURFUiLCJyaWQiOiJ1c2VyXzJzSEJuSGdYT2dQSmprejVnU0VqalpDaWhKUSJ9","tier","pro","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_42":43,"_32":44,"_37":159,"_46":-5,"_47":26,"_48":49,"_50":49,"_51":52,"_53":-5,"_18":54,"_55":-5,"_56":26,"_57":-5,"_58":-5,"_59":60,"_61":62,"_63":-5,"_64":-5,"_65":-5,"_66":-5,"_67":68,"_69":68,"_70":71,"_72":71,"_73":71,"_74":68,"_75":68,"_76":160,"_78":161,"_80":162,"_82":26},"tree",[150,151],"files",[150,151],"counts",{"_140":60,"_141":131,"_142":60,"_143":144,"_145":146},"contents",[125,126],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_42":137,"_32":28,"_30":31,"_130":-5,"_40":41,"_39":14,"_132":26,"_37":138,"_13":60,"_33":34,"_35":36,"_23":26,"_135":-5,"_27":139},{"_42":127,"_32":128,"_30":129,"_130":-5,"_40":41,"_39":131,"_132":26,"_37":133,"_13":60,"_33":34,"_35":134,"_23":26,"_135":-5,"_27":136},"80cf747e-bdc3-4aad-90bd-f3eef08f8e00","main.ts","2acb14b8-8691-11f1-9e90-1607ee4eb77e","parentId",1,"latest",["D",1784809347112],"import { serveFile } from \"https://esm.town/v/std/utils/index.ts\";\nimport { Data, Duration, Effect, ManagedRuntime, Schedule, Schema } from \"https://esm.sh/effect@3.22.0\";\nimport * as NodeSdk from \"https://esm.sh/@effect/opentelemetry@0.64.0/NodeSdk\";\nimport { ConsoleSpanExporter, SimpleSpanProcessor } from \"https://esm.sh/@opentelemetry/sdk-trace-base@2\";\nimport { runArticleDemo } from \"./articles-demo.ts\";\n\nconst GREENPT_BASE_URL = \"https://api.greenpt.ai/v1\";\nconst GREENPT_TAKEOVER_MODEL = \"green-l-raw\"; // Mistral Small 3.2, fast, non-reasoning\nconst GREENPT_SUGGEST_MODEL = \"qwen3-coder-30b-a3b-instruct\"; // completion-tuned\n\n// Real OTel spans, exported over the same standard pipe Langfuse/any collector already reads\n// (ConsoleSpanExporter + SimpleSpanProcessor here so spans flush per-request for the demo;\n// swap for an OTLP exporter + BatchSpanProcessor to ship elsewhere).\nconst NodeSdkLive = NodeSdk.layer(() => ({\n resource: { serviceName: \"effect-ts-talk\" },\n spanProcessor: new SimpleSpanProcessor(new ConsoleSpanExporter()),\n}));\nconst runtime = ManagedRuntime.make(NodeSdkLive);\n\nclass GreenptApiError extends Data.TaggedError(\"GreenptApiError\")<{ status: number; detail: string }> {}\nclass GreenptTimeout extends Data.TaggedError(\"GreenptTimeout\")<{}> {}\n\nconst CompletionResponse = Schema.Struct({ completion: Schema.String });\nconst decodeCompletion = Schema.decodeUnknown(Schema.parseJson(CompletionResponse));\n\nfunction greenptChat(model: string, system: string, user: string, maxTokens: number) {\n return Effect.gen(function* () {\n const apiKey = Deno.env.get(\"GREENPT_API_KEY\");\n if (!apiKey) return yield* Effect.die(new Error(\"GREENPT_API_KEY is not set\"));\n\n const res = yield* Effect.tryPromise({\n try: (signal) =>\n fetch(`${GREENPT_BASE_URL}/chat/completions`, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\", Authorization: `Bearer ${apiKey}` },\n body: JSON.stringify({\n model,\n max_tokens: maxTokens,\n temperature: 0.7,\n messages: [\n { role: \"system\", content: system },\n { role: \"user\", content: user },\n ],\n }),\n signal,\n }),\n catch: (cause) => new GreenptApiError({ status: 0, detail: String(cause) }),\n });\n\n if (!res.ok) {\n const detail = yield* Effect.promise(() => res.text());\n return yield* Effect.fail(new GreenptApiError({ status: res.status, detail: detail.slice(0, 300) }));\n }\n\n const raw = yield* Effect.promise(() => res.json());\n const content = raw?.choices?.[0]?.message?.content ?? \"\";\n yield* Effect.annotateCurrentSpan({ contentLen: content.length, usage: raw?.usage });\n return content as string;\n }).pipe(\n Effect.timeoutFail({ duration: Duration.seconds(20), onTimeout: () => new GreenptTimeout() }),\n Effect.retry({\n schedule: Schedule.exponential(Duration.millis(300)).pipe(Schedule.intersect(Schedule.recurs(2))),\n while: (e) => e._tag === \"GreenptTimeout\" || (e._tag === \"GreenptApiError\" && e.status >= 500),\n }),\n Effect.withSpan(\"greenpt.chat\", { attributes: { model, maxTokens } }),\n );\n}\n\nfunction continueText(text: string) {\n const snippet = text.slice(-1500);\n return greenptChat(\n GREENPT_TAKEOVER_MODEL,\n \"You are an AI that hijacks a piece of in-progress writing the moment its human author stops typing. \" +\n \"Continue their text from exactly where it left off, matching their tone, topic, and language. \" +\n \"Write 1-2 short sentences only. Do not repeat what is already there, do not add quotation marks, \" +\n \"labels, or commentary — output only the continuation, starting with a leading space if the text \" +\n \"does not already end with whitespace.\",\n snippet || \"Begin a short piece of reflective writing.\",\n 150,\n ).pipe(Effect.withSpan(\"continueText\"));\n}\n\nfunction buildContext(text: string) {\n const snippet = text.slice(-1200);\n return greenptChat(\n GREENPT_TAKEOVER_MODEL,\n \"You are a context extractor for a writing assistant. Given in-progress text, produce a short \" +\n \"plain-text context block (3-6 sentences max) covering: the topic and tone, any implicit \" +\n \"questions or requests the writer seems to be building toward, and key facts or entities \" +\n \"established so far. Be concise and factual. Do not add opinions or complete the writing.\",\n snippet || \"(empty)\",\n 200,\n ).pipe(Effect.withSpan(\"buildContext\"));\n}\n\nfunction suggestCompletion(text: string) {\n const snippet = text.slice(-800);\n return Effect.gen(function* () {\n const context = yield* buildContext(text);\n\n const systemPrompt =\n 'You are an inline writing completion assistant. Given the tail of an in-progress piece, ' +\n 'return a JSON object {\"completion\":\"...\"} with a short inline completion that finishes the ' +\n \"current sentence without starting a new one — unless there is a clear question or request in \" +\n \"the text that you can answer directly, in which case answer it concisely as the completion. \" +\n 'If nothing is needed, return {\"completion\":\"\"}. Output only valid JSON, no markdown, no code fences.\\n\\n' +\n `\\n${context}\\n`;\n\n const raw = yield* greenptChat(GREENPT_SUGGEST_MODEL, systemPrompt, snippet || \"I\", 100);\n const cleaned = raw.replace(/^```(?:json)?\\s*/i, \"\").replace(/\\s*```$/, \"\").trim();\n\n const { completion } = yield* decodeCompletion(cleaned).pipe(\n Effect.catchTag(\"ParseError\", () => Effect.succeed({ completion: \"\" })),\n );\n return completion;\n }).pipe(Effect.withSpan(\"suggestCompletion\"));\n}\n\nfunction jsonRoute(\n req: Request,\n routeName: string,\n handler: (text: string) => Effect.Effect,\n onError: (error: GreenptApiError | GreenptTimeout) => Response,\n) {\n return Effect.gen(function* () {\n const { text } = yield* Effect.promise(() => req.json());\n const body = yield* handler(typeof text === \"string\" ? text : \"\");\n return Response.json(body);\n }).pipe(\n Effect.withSpan(`http ${routeName}`),\n Effect.catchTags({\n GreenptApiError: (e) => Effect.succeed(onError(e)),\n GreenptTimeout: (e) => Effect.succeed(onError(e)),\n }),\n );\n}\n\nconst upstreamError = (e: GreenptApiError | GreenptTimeout) =>\n Response.json({ error: e._tag === \"GreenptTimeout\" ? \"timeout\" : e.detail }, { status: 502 });\n\nexport default async function (req: Request): Promise {\n const url = new URL(req.url);\n\n if (req.method === \"POST\" && url.pathname === \"/ai/continue\") {\n return runtime.runPromise(\n jsonRoute(req, \"/ai/continue\", (text) => continueText(text).pipe(Effect.map((continuation) => ({ continuation }))), upstreamError),\n );\n }\n\n if (req.method === \"POST\" && url.pathname === \"/ai/context\") {\n return runtime.runPromise(\n jsonRoute(req, \"/ai/context\", (text) => buildContext(text).pipe(Effect.map((context) => ({ context }))), upstreamError),\n );\n }\n\n if (req.method === \"POST\" && url.pathname === \"/ai/suggest\") {\n return runtime.runPromise(\n jsonRoute(\n req,\n \"/ai/suggest\",\n (text) => suggestCompletion(text).pipe(Effect.map((completion) => ({ completion }))),\n () => Response.json({ completion: \"\" }), // soft-fail: don't surface to user\n ),\n );\n }\n\n if (req.method === \"POST\" && url.pathname === \"/demo/article\") {\n // Runs on its own Effect v4 runtime (articles-demo.ts); v3 and v4 Effect\n // values can't cross a pipe/provide boundary, only this Promise does.\n try {\n const body = await req.json();\n const article = await runArticleDemo(body);\n return Response.json(article);\n } catch (cause) {\n return Response.json({ error: String(cause) }, { status: 500 });\n }\n }\n\n switch (url.pathname) {\n case \"/style.css\": return serveFile(\"/style.css\", import.meta.url);\n case \"/client.js\": return serveFile(\"/client.js\", import.meta.url);\n case \"/tiny-lm.js\": return serveFile(\"/tiny-lm.js\", import.meta.url);\n case \"/debug.js\": return serveFile(\"/debug.js\", import.meta.url);\n case \"/llm.html\": return serveFile(\"/llm.html\", import.meta.url);\n case \"/llm.js\": return serveFile(\"/llm.js\", import.meta.url);\n case \"/\":\n case \"/index.html\": return serveFile(\"/index.html\", import.meta.url);\n default: return new Response(\"Not found\", { status: 404 });\n }\n}\n","label",[128],"8a589874-16c2-4aa9-bbd0-9f4281c28b03",["D",1784809368274],[28],"pulls","branches","forks","envVars",{"_147":60,"_149":60},"connections",{"_147":60,"_148":60},"count","unfilledCount","emptyCount",{"_42":137,"_32":28,"_30":31,"_130":-5,"_40":41,"_39":14,"_132":26,"_37":156,"_13":60,"_33":34,"_35":36,"_23":26,"_135":-5,"_153":157,"_27":158},{"_42":127,"_32":128,"_30":129,"_130":-5,"_40":41,"_39":131,"_132":26,"_37":152,"_13":60,"_33":34,"_35":134,"_23":26,"_135":-5,"_153":154,"_27":155},["D",1784809347112],"children",[],[128],["D",1784809368274],[],[28],["D",1784809347061],{"_94":93,"_102":98},{"_94":93,"_95":96,"_97":98,"_18":54,"_99":100,"_101":26},{"_13":83,"_32":84,"_42":41,"_85":43,"_86":-5,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":44,"_92":93},"ctx",{"_76":-5,"_122":196,"_197":198,"_199":200,"_201":26,"_202":26,"_203":26,"_204":24,"_205":-5,"_206":-7,"_207":-7,"_208":60,"_209":26,"_210":26,"_211":-5,"_212":26,"_213":26,"_214":26,"_215":-5},"ENV",{"_167":168,"_169":170,"_171":84,"_172":173,"_174":175,"_176":177,"_178":179,"_180":181,"_182":183,"_184":185,"_186":187,"_188":189,"_190":191,"_192":193,"_194":195},"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"]

Diff · v2