[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_184":185,"_186":187},"routes/_app.x.$handle.$name",{"_11":12,"_13":14,"_15":16,"_123":124,"_34":-7,"_125":-5,"_17":126,"_127":128,"_129":130,"_131":132,"_133":134,"_48":-5,"_135":-5,"_136":-5,"_137":24,"_138":139,"_140":141,"_142":-5,"_143":-5,"_144":145},"routes/_app.x.$handle.$name.branch.$branch.history",{"_11":12,"_13":14,"_15":16,"_17":18,"_19":20,"_21":22,"_23":24,"_25":-5},"handle","devdoshi","name","webpoke_s2_probe","branchName","main","project",{"_28":76,"_13":14,"_32":77,"_78":-5,"_79":24,"_80":81,"_82":81,"_83":84,"_85":-5,"_25":63,"_86":-5,"_87":24,"_88":-5,"_89":-5,"_90":20,"_36":37,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":96,"_97":96,"_98":99,"_100":99,"_101":99,"_102":96,"_103":96,"_46":104,"_105":106,"_107":108,"_109":24},"page",0,"history",[26,27],"hasNext",false,"userId",{"_28":66,"_30":31,"_32":67,"_34":68,"_36":37,"_38":29,"_39":-5,"_40":-5,"_41":-5,"_42":-5,"_43":-5,"_44":-5,"_45":-5,"_46":69,"_48":70,"_50":-5,"_51":-5,"_52":-5,"_53":-5,"_54":71},{"_28":29,"_30":31,"_32":33,"_34":35,"_36":37,"_38":-5,"_39":-5,"_40":-5,"_41":-5,"_42":-5,"_43":-5,"_44":-5,"_45":-5,"_46":47,"_48":49,"_50":-5,"_51":-5,"_52":-5,"_53":-5,"_54":55},"id","114052ce-ee06-4f47-b887-39d39d0b1131","branchId","7fc931f6-af9c-469a-a887-b5acc86dd684","createdAt",["D",1781381612767],"version",1,"orgId","efaf76f0-0509-4f61-99e7-4d9e2d1a202a","parentId","incomingCommitId","aiChatMessageId","aiChatThreadId","aiChatThreadUserId","aiChatThreadTitle","source","clientLabel","user",{"_28":63,"_36":37,"_11":12,"_64":65},"file",{"_57":58,"_13":59,"_60":61,"_62":24},"pull","merge","revert","multiple","commits",[56],{"_28":29,"_30":31,"_32":33,"_34":35,"_36":37,"_38":-5,"_39":-5,"_40":-5,"_41":-5,"_42":-5,"_43":-5,"_44":-5,"_45":-5,"_46":47,"_48":49,"_50":-5,"_51":-5,"_52":-5},"fileId","59e54896-6764-11f1-863e-1607ee4eb77e","main.ts","fileType","http","deleted","1d223401-2709-4d51-8314-0ca7611e9d9a","avatar","https://secure.gravatar.com/avatar/08f709e5b52546fbf4413cdceb625fc7&d=identicon","ad65c316-8d9a-4230-bf6a-908ad2db4481",["D",1781381628952],2,{"_28":63,"_36":37,"_11":12,"_64":65},{"_57":73,"_13":74,"_60":75,"_62":24},[72],{"_28":66,"_30":31,"_32":67,"_34":68,"_36":37,"_38":29,"_39":-5,"_40":-5,"_41":-5,"_42":-5,"_43":-5,"_44":-5,"_45":-5,"_46":69,"_48":70,"_50":-5,"_51":-5,"_52":-5},"638cd3fa-6764-11f1-b7d9-1607ee4eb77e","s2-client.ts","script","a5d99828-882e-462f-b098-b2d41f3346a4",["D",1781381612753],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Portability probe: real RestStream against S2 cloud on Deno","imageUrl","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm",{"_11":12,"_122":65},"org",{"_11":12,"_118":-5,"_64":65,"_25":63,"_119":120,"_121":24},"branch",{"_34":68,"_13":16,"_28":31,"_110":76,"_111":-5,"_112":-5,"_113":-5,"_114":-5,"_115":-5,"_116":14,"_117":12},"isOwned","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","tier","free","canRestrictVals","profileImageUrl","path","","adoptOrgId",{"_28":76,"_13":14,"_32":180,"_78":-5,"_79":24,"_80":81,"_82":81,"_83":84,"_85":-5,"_25":63,"_86":-5,"_87":24,"_88":-5,"_89":-5,"_90":20,"_36":37,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":96,"_97":96,"_98":99,"_100":99,"_101":99,"_102":96,"_103":96,"_46":181,"_105":182,"_107":183,"_109":24},"tree",[171,172],"files",[171,172],"counts",{"_160":20,"_161":35,"_162":20,"_163":164,"_165":166},"contents",[146,147],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles",true,"grants","orgs","customDomains",{},{"_28":156,"_13":59,"_57":58,"_38":-5,"_30":31,"_149":35,"_150":141,"_32":157,"_34":20,"_60":61,"_152":158,"_62":24,"_154":-5,"_123":159},{"_28":148,"_13":74,"_57":73,"_38":-5,"_30":31,"_149":68,"_150":141,"_32":151,"_34":20,"_60":75,"_152":153,"_62":24,"_154":-5,"_123":155},"34685428-fddc-401f-bb12-0ca57d04fcec","branchVersion","latest",["D",1781381628952],"content","// The REAL RestStream from webpoke-demo/src/lib/s2-client.ts, verbatim except\n// the two `import type` lines are inlined here so the probe has zero imports.\n// Runtime logic is identical — that's what we're testing on Deno.\n\ninterface S2Config {\n endpoint: string;\n token: string;\n basin: string;\n stream: string;\n}\n\nexport interface LedgerRecord {\n seqNum: number;\n body: string;\n}\nexport interface AppendResult {\n start: number;\n end: number;\n tail: number;\n}\nexport interface ReadResult {\n records: LedgerRecord[];\n nextSeq: number;\n tail: number;\n}\n\nexport interface S2Stream {\n append(bodies: string[], opts?: { matchSeqNum?: number }): Promise;\n read(opts: { since: number; limit: number }): Promise;\n tail(): Promise;\n}\n\nexport function openStream(cfg: S2Config): S2Stream {\n return new RestStream(cfg);\n}\n\ntype StreamPosition = { seq_num: number; timestamp: number };\n\nclass RestStream implements S2Stream {\n private base: string;\n private basinHeader?: string;\n constructor(private cfg: S2Config) {\n let root = cfg.endpoint.replace(/\\/+$/, \"\");\n if (root.includes(\"{basin}\")) {\n root = root.replace(\"{basin}\", encodeURIComponent(cfg.basin));\n } else {\n this.basinHeader = cfg.basin;\n }\n this.base = `${root}/v1/streams/${encodeURIComponent(cfg.stream)}`;\n }\n private headers(): Record {\n const h: Record = {\n authorization: `Bearer ${this.cfg.token}`,\n \"s2-format\": \"raw\",\n \"content-type\": \"application/json\",\n };\n if (this.basinHeader) h[\"s2-basin\"] = this.basinHeader;\n return h;\n }\n async append(bodies: string[], opts: { matchSeqNum?: number } = {}): Promise {\n const payload: Record = { records: bodies.map((body) => ({ body })) };\n if (typeof opts.matchSeqNum === \"number\") payload.match_seq_num = opts.matchSeqNum;\n const res = await fetch(`${this.base}/records`, {\n method: \"POST\",\n headers: this.headers(),\n body: JSON.stringify(payload),\n });\n if (!res.ok) throw new Error(`s2 append ${res.status}: ${await res.text()}`);\n const ack = (await res.json()) as { start: StreamPosition; end: StreamPosition; tail: StreamPosition };\n return { start: ack.start.seq_num, end: ack.end.seq_num, tail: ack.tail.seq_num };\n }\n async read(opts: { since: number; limit: number }): Promise {\n const u = new URL(`${this.base}/records`);\n u.searchParams.set(\"seq_num\", String(opts.since));\n u.searchParams.set(\"count\", String(opts.limit));\n const res = await fetch(u, { headers: this.headers() });\n if (res.status === 416) {\n const body = (await res.json().catch(() => ({}))) as { tail?: StreamPosition };\n return { records: [], nextSeq: opts.since, tail: body.tail?.seq_num ?? opts.since };\n }\n if (!res.ok) throw new Error(`s2 read ${res.status}: ${await res.text()}`);\n const batch = (await res.json()) as { records: { seq_num: number; body: string }[]; tail?: StreamPosition };\n const records = batch.records.map((r) => ({ seqNum: r.seq_num, body: r.body }));\n const last = records[records.length - 1];\n const nextSeq = last ? last.seqNum + 1 : opts.since;\n return { records, nextSeq, tail: batch.tail?.seq_num ?? nextSeq };\n }\n async tail(): Promise {\n const res = await fetch(`${this.base}/records/tail`, { headers: this.headers() });\n if (!res.ok) throw new Error(`s2 tail ${res.status}: ${await res.text()}`);\n return ((await res.json()) as { tail: StreamPosition }).tail.seq_num;\n }\n}\n","label",[74],"320613f1-a8f2-49b1-87ef-2fbe59e0902c",["D",1781381612767],"import { openStream } from \"./s2-client.ts\";\n\n// Portability probe: does val.town's Deno run the real RestStream, and can it\n// reach the real S2 cloud stream? GET = tail+read; ?append=1 = append one.\nexport default async function (req: Request): Promise {\n const cfg = {\n endpoint: Deno.env.get(\"S2_ENDPOINT\")!,\n token: Deno.env.get(\"S2_TOKEN\")!,\n basin: Deno.env.get(\"S2_BASIN\")!,\n stream: Deno.env.get(\"S2_STREAM\")!,\n };\n try {\n const s2 = openStream(cfg);\n const url = new URL(req.url);\n if (url.searchParams.get(\"append\")) {\n const appended = await s2.append([JSON.stringify({ probe: true, t: Date.now() })]);\n return Response.json({ ok: true, runtime: \"deno\", appended });\n }\n const tail = await s2.tail();\n const read = await s2.read({ since: 0, limit: 10 });\n return Response.json({ ok: true, runtime: \"deno\", tail, nextSeq: read.nextSeq, readTail: read.tail, count: read.records.length, sample: read.records.slice(0, 3) });\n } catch (err) {\n return Response.json({ ok: false, error: String(err) }, { status: 500 });\n }\n}\n",[59],"pulls","branches","forks","envVars",{"_167":169,"_170":20},"connections",{"_167":20,"_168":20},"count","unfilledCount",4,"emptyCount",{"_28":156,"_13":59,"_57":58,"_38":-5,"_30":31,"_149":35,"_150":141,"_32":177,"_34":20,"_60":61,"_152":158,"_62":24,"_154":-5,"_174":178,"_123":179},{"_28":148,"_13":74,"_57":73,"_38":-5,"_30":31,"_149":68,"_150":141,"_32":173,"_34":20,"_60":75,"_152":153,"_62":24,"_154":-5,"_174":175,"_123":176},["D",1781381628952],"children",[],[74],["D",1781381612767],[],[59],["D",1781381612753],{"_11":12,"_122":65},{"_11":12,"_118":-5,"_64":65,"_25":63,"_119":120,"_121":24},{"_34":68,"_13":16,"_28":31,"_110":76,"_111":-5,"_112":-5,"_113":-5,"_114":-5,"_115":-5,"_116":14,"_117":12},"ctx",{"_46":-5,"_143":217,"_218":219,"_220":221,"_222":24,"_223":24,"_224":24,"_225":141,"_226":-5,"_227":-7,"_228":-7,"_229":20,"_230":24,"_231":24,"_232":-5,"_233":24,"_234":24,"_235":24,"_236":-5},"ENV",{"_188":189,"_190":191,"_192":16,"_193":194,"_195":196,"_197":198,"_199":200,"_201":202,"_203":204,"_205":206,"_207":208,"_209":210,"_211":212,"_213":214,"_215":216},"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"]

History