[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_167":168,"_169":170},"routes/_app.x.$handle.$name",{"_97":96,"_32":45,"_105":87,"_27":106,"_13":14,"_107":-5,"_11":108,"_109":110,"_111":112,"_113":114,"_115":116,"_20":-5,"_117":-5,"_118":-5,"_119":25,"_120":121,"_122":59,"_123":-5,"_124":-5,"_125":126},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_43":44,"_32":45,"_38":46,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":57,"_58":59,"_60":59,"_61":-5,"_62":63,"_64":65,"_66":-5,"_67":-5,"_68":-5,"_69":-5,"_70":71,"_72":71,"_73":74,"_75":74,"_76":74,"_77":71,"_78":71,"_79":80,"_81":82,"_83":84,"_85":25},"version",242,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":34,"_35":37,"_38":39,"_40":14,"_41":42,"_24":25},"previous",{"_30":31,"_32":28,"_33":34,"_35":36},"deleted",false,"deletedHere","path","honoStreaming.ts","latestPath","fileId","371d3cde-8d20-11f0-bea8-0224a6c84d84","name","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 { stream, streamSSE, streamText, SSEStreamingApi } 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\napp.get(\"/\", (c) => {\n return stream(c, async (stream) => {\n await stream.writeln(\"\");\n await stream.writeln(\"\");\n await stream.writeln(\"Fetching...\");\n await stream.writeln(\n ``,\n );\n await stream.writeln(\"\");\n await stream.writeln(\"\");\n\n // Safari requires ~1024 bytes before it starts streaming\n // Add padding comment to reach the threshold\n await stream.writeln(``);\n await stream.sleep(100); // Small delay to ensure the chunk is sent\n\n try {\n await stream.write(\n \"

Fetching https://venue.com/some-event-webpage...

\",\n );\n await stream.sleep(1500);\n await stream.writeln(\"

Done.

\");\n\n await stream.writeln(\n \"

Parsing structured data from webpage...

\",\n );\n await stream.sleep(1500);\n await stream.writeln(\"

Done.

\");\n\n await stream.writeln(\n \"

Inserting data into Events database...

\",\n );\n\n if (Math.random() < 0.5) throw new Error(\"A fake db error!\");\n\n await stream.sleep(1500);\n await stream.writeln(\"

Done.

\");\n\n await stream.writeln(\n ``,\n );\n } catch (error) {\n await stream.writeln(`

${error}

`);\n await stream.writeln(\n ``,\n );\n } finally {\n await stream.writeln(\"\");\n await stream.writeln(\"\");\n }\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(stream: SSEStreamingApi, state: \"success\" | \"error\") {\n return stream.writeSSE({\n event: \"complete\",\n data: JSON.stringify({\n time: new Date().toISOString(),\n state,\n }),\n });\n}\n\napp.get(\"/process-import\", c => {\n return streamSSE(c, async (stream) => {\n \n await update(stream, { step: \"convert\", state: \"started\" });\n await stream.sleep(2000); // convert to markdown\n await update(stream, { step: \"convert\", state: \"completed\", result: {\"omg\": \"lol\"} });\n \n await stream.sleep(500);\n \n await update(stream, { step: \"extract\", state: \"started\" });\n await stream.sleep(2000); // extract structured data\n await update(stream, { step: \"extract\", state: \"completed\", result: {\"wtf\": \"jkjk\"} });\n // await complete(stream, \"error\")\n \n await stream.sleep(500);\n \n await update(stream, { step: \"insert\", state: \"started\" });\n await stream.sleep(2000); // insert into Notion\n await update(stream, { step: \"insert\", state: \"completed\", result: {\"lmao\": \"idk\"} });\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 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\nexport default app.fetch;","/** @jsxImportSource https://esm.sh/react */\n\n// adapted from https://hono.dev/docs/helpers/streaming\n\nimport { Hono } from \"npm:hono@4\";\nimport { stream, streamSSE, streamText, SSEStreamingApi } 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\napp.get(\"/\", (c) => {\n return stream(c, async (stream) => {\n await stream.writeln(\"\");\n await stream.writeln(\"\");\n await stream.writeln(\"Fetching...\");\n await stream.writeln(\n ``,\n );\n await stream.writeln(\"\");\n await stream.writeln(\"\");\n\n // Safari requires ~1024 bytes before it starts streaming\n // Add padding comment to reach the threshold\n await stream.writeln(``);\n await stream.sleep(100); // Small delay to ensure the chunk is sent\n\n try {\n await stream.write(\n \"

Fetching https://venue.com/some-event-webpage...

\",\n );\n await stream.sleep(1500);\n await stream.writeln(\"

Done.

\");\n\n await stream.writeln(\n \"

Parsing structured data from webpage...

\",\n );\n await stream.sleep(1500);\n await stream.writeln(\"

Done.

\");\n\n await stream.writeln(\n \"

Inserting data into Events database...

\",\n );\n\n if (Math.random() < 0.5) throw new Error(\"A fake db error!\");\n\n await stream.sleep(1500);\n await stream.writeln(\"

Done.

\");\n\n await stream.writeln(\n ``,\n );\n } catch (error) {\n await stream.writeln(`

${error}

${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\nexport default app.fetch;","createdAt",["D",1757477123016],"branchVersion","branchId","dc3bc424-8d11-11f0-aedd-0224a6c84d84","id","dc3b5f84-8d11-11f0-aedd-0224a6c84d84","sseFaffing",["D",1757376829727],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Hono makes it easy","imageUrl","04c94255-9480-4d0c-b730-c99ed982472a","pinnedFileId","dc3e2930-8d11-11f0-aedd-0224a6c84d84","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","8b7cc5d0-214c-4bc0-a329-3308ef74efe2","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_97":96,"_104":100},"org",{"_97":96,"_98":-5,"_99":100,"_18":55,"_101":102,"_103":25},"branch",{"_13":86,"_32":87,"_43":42,"_88":44,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":45,"_95":96},"isOwned",302,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","roop","handle","displayName","avatar","https://avatars.githubusercontent.com/u/140521?v=4","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_43":44,"_32":45,"_38":163,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":57,"_58":59,"_60":59,"_61":-5,"_62":63,"_64":65,"_66":-5,"_67":-5,"_68":-5,"_69":-5,"_70":71,"_72":71,"_73":74,"_75":74,"_76":74,"_77":71,"_78":71,"_79":164,"_81":165,"_83":166,"_85":25},"tree",[154,155],"files",[154,155],"counts",{"_143":63,"_144":145,"_146":63,"_147":148,"_149":150},"contents",[127,128],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_43":136,"_32":137,"_30":57,"_130":-5,"_41":42,"_40":138,"_131":59,"_38":139,"_13":140,"_33":34,"_35":141,"_24":25,"_134":-5,"_27":142},{"_43":129,"_32":28,"_30":31,"_130":-5,"_41":42,"_40":14,"_131":25,"_38":132,"_13":133,"_33":34,"_35":37,"_24":25,"_134":-5,"_27":135},"5fb21cf6-8dfb-11f0-8762-0224a6c84d84","parentId","latest",["D",1757477123016],235,"label",[28],"7ecb190c-8d20-11f0-bbc6-0224a6c84d84","helloHono.ts",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;",[137],"pulls","branches",1,"forks","envVars",{"_151":63,"_153":63},"connections",{"_151":63,"_152":63},"count","unfilledCount","emptyCount",{"_43":136,"_32":137,"_30":57,"_130":-5,"_41":42,"_40":138,"_131":59,"_38":160,"_13":140,"_33":34,"_35":141,"_24":25,"_134":-5,"_157":161,"_27":162},{"_43":129,"_32":28,"_30":31,"_130":-5,"_41":42,"_40":14,"_131":25,"_38":156,"_13":133,"_33":34,"_35":37,"_24":25,"_134":-5,"_157":158,"_27":159},["D",1757477123016],"children",[],[28],["D",1757383115408],[],[137],["D",1757376829727],{"_97":96,"_104":100},{"_97":96,"_98":-5,"_99":100,"_18":55,"_101":102,"_103":25},{"_13":86,"_32":87,"_43":42,"_88":44,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":45,"_95":96},"ctx",{"_79":-5,"_124":200,"_201":202,"_203":204,"_205":25,"_206":25,"_207":25,"_208":59,"_209":-5,"_210":-7,"_211":-7,"_212":63,"_213":25,"_214":25,"_215":-5,"_216":25,"_217":25,"_218":25,"_219":-5},"ENV",{"_171":172,"_173":174,"_175":87,"_176":177,"_178":179,"_180":181,"_182":183,"_184":185,"_186":187,"_188":189,"_190":191,"_192":193,"_194":195,"_196":197,"_198":199},"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 · v242