[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_171":172,"_173":174},"routes/_app.x.$handle.$name",{"_11":12,"_13":14,"_15":16,"_18":19,"_17":-7,"_129":-5,"_20":130,"_22":131,"_132":133,"_134":135,"_25":136,"_24":-5,"_137":-5,"_138":-5,"_139":54,"_140":141,"_142":45,"_143":-5,"_144":-5,"_145":146},"routes/_app.x.$handle.$name.branch.$branch.code.$",{"_11":12,"_13":14,"_15":16,"_17":-7,"_18":19,"_20":21,"_22":23,"_24":-7,"_25":26,"_27":-5,"_28":-5,"_29":-5,"_30":-5,"_31":-5},"handle","roop","name","sseFaffing","branchName","main","version","path","","project",{"_34":74,"_13":14,"_46":75,"_76":-5,"_77":54,"_78":79,"_80":79,"_81":82,"_83":-5,"_84":85,"_86":59,"_87":45,"_88":45,"_89":-5,"_90":91,"_92":93,"_94":-5,"_95":-5,"_96":-5,"_97":-5,"_98":99,"_100":99,"_101":102,"_103":102,"_104":102,"_105":99,"_106":99,"_107":108,"_109":110,"_111":112,"_113":54},"tree",[65,66],"file","contents",[32,33],"upstream","pull","ahead","behind","envVars",{"_34":57,"_13":58,"_37":59,"_39":-5,"_40":41,"_42":60,"_44":45,"_46":61,"_17":62,"_49":50,"_51":63,"_53":54,"_55":-5,"_18":64},{"_34":35,"_13":36,"_37":38,"_39":-5,"_40":41,"_42":43,"_44":45,"_46":47,"_17":48,"_49":50,"_51":52,"_53":54,"_55":-5,"_18":56},"id","6de7a032-8e4d-11f0-abf4-0224a6c84d84","honoStreaming.ts","fileId","371d3cde-8d20-11f0-bea8-0224a6c84d84","parentId","branchId","dc3bc424-8d11-11f0-aedd-0224a6c84d84","branchVersion",302,"latest",true,"createdAt",["D",1757512365588],295,"fileType","http","content","/** @jsxImportSource https://esm.sh/react */\n\n// adapted from https://hono.dev/docs/helpers/streaming\n\nimport { Hono } from \"npm:hono@4\";\nimport {\n SSEStreamingApi,\n stream,\n streamSSE,\n streamText,\n} from \"npm:hono@4/streaming\";\nimport { html, raw } from \"npm:hono@4/html\";\n\nconst app = new Hono();\n\napp.get(\"/stream\", (c) => {\n return stream(c, async (stream) => {\n // Write a process to be executed when aborted.\n stream.onAbort(() => {\n console.log(\"Aborted!\");\n });\n\n // Write a Uint8Array.\n await stream.write(new Uint8Array([0x48, 0x65, 0x6c, 0x6c, 0x6c, 0x6f]));\n\n // Pipe a readable stream.\n // await stream.pipe(anotherReadableStream);\n });\n});\n\napp.get(\"/streamText\", (c) => {\n return streamText(c, async (stream) => {\n await stream.writeln(\"Hello\");\n await stream.sleep(500);\n await stream.writeln(\"there…\");\n await stream.sleep(1000);\n await stream.write(`Hono!`);\n });\n});\n\nlet id = 0;\n\napp.get(\"/sse\", async (c) => {\n return streamSSE(c, async (stream) => {\n while (true) {\n const time = new Date().toISOString();\n const message = `It is ${time}`;\n await stream.writeSSE({\n data: JSON.stringify({ time, message }),\n event: \"ping\",\n id: String(id++),\n });\n await stream.sleep(2000);\n }\n });\n});\n\nfunction update(stream: SSEStreamingApi, payload: any) {\n return stream.writeSSE({\n event: \"update\",\n data: JSON.stringify({\n time: new Date().toISOString(),\n ...payload,\n }),\n });\n}\n\nfunction complete(\n stream: SSEStreamingApi,\n state: \"success\" | \"error\",\n) {\n return stream.writeSSE({\n event: \"complete\",\n data: JSON.stringify({\n time: new Date().toISOString(),\n state,\n }),\n });\n}\n\nfunction fail(\n stream: SSEStreamingApi,\n message?: string,\n) {\n return stream.writeSSE({\n event: \"fail\",\n data: JSON.stringify({\n time: new Date().toISOString(),\n message,\n }),\n });\n}\n\napp.get(\"/process-import\", (c) => {\n /*\n const params = new URL(req.url).searchParams;\n\n // prepare a log entry for the result\n const result = {\n url: \"\",\n data: \"\",\n response: \"\",\n status: \"\",\n };\n\n // validate url\n const requestedUrl = params.get(\"url\");\n result.url = requestedUrl;\n\n if (!requestedUrl?.length) {\n result.status = \"400\";\n return Response.json({ error: \"Missing URL\" }, { status: 400 });\n }\n\n if (!URL.canParse(requestedUrl)) {\n result.status = \"422\";\n return Response.json({ error: `Invalid URL: ${requestedUrl}` }, {\n status: 422,\n });\n }\n\n\n */\n return streamSSE(c, async (stream) => {\n // validate token\n const apiToken = c.req.query(\"token\");\n if (apiToken !== process.env.API_TOKEN) {\n await fail(stream, \"Unauthorized\");\n return stream.close();\n }\n\n // prepare a log entry for the result\n const result = {\n url: \"\",\n data: \"\",\n response: \"\",\n status: \"\",\n };\n\n // validate url\n const requestedUrl = c.req.query(\"url\");\n result.url = requestedUrl;\n\n console.log(requestedUrl, requestedUrl?.length);\n if (!requestedUrl?.length) {\n result.status = \"400\";\n c.status(400);\n await fail(stream, \"Missing URL\");\n return stream.close();\n }\n\n if (!URL.canParse(requestedUrl)) {\n result.status = \"422\";\n c.status(422);\n await fail(stream, \"Invalid URL\");\n return stream.close();\n }\n\n await update(stream, { step: \"convert\", state: \"started\" });\n await stream.sleep(2000); // convert to markdown\n await update(stream, {\n step: \"convert\",\n state: \"completed\",\n result: \"4242 bytes\",\n });\n\n await update(stream, { step: \"extract\", state: \"started\" });\n await stream.sleep(2000); // extract structured data\n await update(stream, {\n step: \"extract\",\n state: \"completed\",\n result: JSON.stringify({ \"wtf\": \"jkjk\" }),\n });\n // await complete(stream, \"error\")\n\n await update(stream, { step: \"insert\", state: \"started\" });\n await stream.sleep(2000); // insert into Notion\n await update(stream, {\n step: \"insert\",\n state: \"completed\",\n result: \"https://example.com\",\n });\n\n await complete(stream, \"success\");\n });\n});\n\napp.get(\"/import\", (c) => {\n const url = c.req.query(\"url\");\n\n return c.html(\n html`\n \n \n Test Site\n \n\n \n \n \n

${url}

\n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n

⚪️	Converting
⚪️	Extracting
⚪️	Inserting

\n \n \n `,\n );\n});\n\nexport default app.fetch;","deleted",false,"label",[36],"7ecb190c-8d20-11f0-bbc6-0224a6c84d84","helloHono.ts","dc3e2930-8d11-11f0-aedd-0224a6c84d84",13,["D",1757383115408],5,"import { Hono } from \"npm:hono@4.9.6\";\n\nconst app = new Hono();\n\napp.get(\"/\", (c) => c.text(\"Hono!\"));\n\nexport default app.fetch;",[58],{"_34":57,"_13":58,"_37":59,"_39":-5,"_40":41,"_42":60,"_44":45,"_46":71,"_17":62,"_49":50,"_51":63,"_53":54,"_55":-5,"_68":72,"_18":73},{"_34":35,"_13":36,"_37":38,"_39":-5,"_40":41,"_42":43,"_44":45,"_46":67,"_17":48,"_49":50,"_51":52,"_53":54,"_55":-5,"_68":69,"_18":70},["D",1757512365588],"children",[],[36],["D",1757383115408],[],[58],"dc3b5f84-8d11-11f0-aedd-0224a6c84d84",["D",1757376829727],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Hono makes it easy","imageUrl","userId","04c94255-9480-4d0c-b730-c99ed982472a","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","8b7cc5d0-214c-4bc0-a329-3308ef74efe2","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_11":12,"_128":124},"org",{"_11":12,"_122":-5,"_123":124,"_84":85,"_125":126,"_127":54},"branch",{"_17":43,"_13":16,"_34":41,"_114":74,"_115":-5,"_116":-5,"_117":-5,"_118":-5,"_119":-5,"_120":14,"_121":12},"isOwned","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","avatar","https://avatars.githubusercontent.com/u/140521?v=4","tier","free","canRestrictVals","profileImageUrl","adoptOrgId",{"_34":74,"_13":14,"_46":167,"_76":-5,"_77":54,"_78":79,"_80":79,"_81":82,"_83":-5,"_84":85,"_86":59,"_87":45,"_88":45,"_89":-5,"_90":91,"_92":93,"_94":-5,"_95":-5,"_96":-5,"_97":-5,"_98":99,"_100":99,"_101":102,"_103":102,"_104":102,"_105":99,"_106":99,"_107":168,"_109":169,"_111":170,"_113":54},[161,162],"files",[161,162],"counts",{"_151":91,"_152":153,"_154":91,"_31":155,"_156":157},[147,148],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_34":57,"_13":58,"_37":59,"_39":-5,"_40":41,"_42":60,"_44":45,"_46":61,"_17":62,"_49":50,"_51":63,"_53":54,"_55":-5,"_18":150},{"_34":35,"_13":36,"_37":38,"_39":-5,"_40":41,"_42":43,"_44":45,"_46":47,"_17":48,"_49":50,"_51":52,"_53":54,"_55":-5,"_18":149},[36],[58],"pulls","branches",1,"forks",{"_158":91,"_160":91},"connections",{"_158":91,"_159":91},"count","unfilledCount","emptyCount",{"_34":57,"_13":58,"_37":59,"_39":-5,"_40":41,"_42":60,"_44":45,"_46":71,"_17":62,"_49":50,"_51":63,"_53":54,"_55":-5,"_68":165,"_18":166},{"_34":35,"_13":36,"_37":38,"_39":-5,"_40":41,"_42":43,"_44":45,"_46":67,"_17":48,"_49":50,"_51":52,"_53":54,"_55":-5,"_68":163,"_18":164},[],[36],[],[58],["D",1757376829727],{"_11":12,"_128":124},{"_11":12,"_122":-5,"_123":124,"_84":85,"_125":126,"_127":54},{"_17":43,"_13":16,"_34":41,"_114":74,"_115":-5,"_116":-5,"_117":-5,"_118":-5,"_119":-5,"_120":14,"_121":12},"ctx",{"_107":-5,"_144":204,"_205":206,"_207":208,"_209":54,"_210":54,"_211":54,"_212":45,"_213":-5,"_214":-7,"_215":-7,"_216":91,"_217":54,"_218":54,"_219":-5,"_220":54,"_221":54,"_222":54,"_223":-5},"ENV",{"_175":176,"_177":178,"_179":16,"_180":181,"_182":183,"_184":185,"_186":187,"_188":189,"_190":191,"_192":193,"_194":195,"_196":197,"_198":199,"_200":201,"_202":203},"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"]

Code