Fetching...

[{"_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",233,"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 \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n

Status	Step	Result
⚪️	Converting ${url}
⚪️	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}

Status	Step	Result
⚪️	Converting ${url}
⚪️	Extracting
⚪️	Inserting

\n \n `\n )\n})\n\nexport default app.fetch;","createdAt",["D",1757476862848],"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},"c49f3942-8dfa-11f0-a1c9-0224a6c84d84","parentId","latest",["D",1757476862848],226,"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",1757476862848],"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 · v233