[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_154":155,"_156":157},"routes/_app.x.$handle.$name",{"_96":95,"_32":45,"_105":86,"_27":53,"_13":14,"_106":-5,"_11":107,"_108":109,"_110":111,"_112":113,"_114":115,"_20":-5,"_116":-5,"_117":-5,"_118":25,"_119":120,"_121":58,"_122":-5,"_123":-5,"_124":125},"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":31,"_57":58,"_59":-5,"_60":-5,"_61":62,"_63":64,"_65":-5,"_66":-5,"_67":-5,"_68":-5,"_69":70,"_71":70,"_72":73,"_74":73,"_75":73,"_76":70,"_77":70,"_78":79,"_80":81,"_82":83,"_84":25},"version",6,"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","new-file-5543.ts","latestPath","fileId","6097466e-9caa-11f1-80db-1607ee4eb77e","name","fileType","http","content","import { blob } from \"https://esm.town/v/std/blob\";\n\nconst SA = JSON.parse(Deno.env.get(\"KONSTAI_SA\") || \"{}\");\nconst PROJECT = SA.project_id;\n\nconst norm = (h: string) => String(h || \"\").replace(/\\D/g, \"\").slice(-9);\n\nasync function getTok(k: string): Promise {\n try {\n return (await blob.getJSON(`konstai_tok_${k}`)) as string;\n } catch {\n return null;\n }\n}\nasync function setTok(k: string, t: string) {\n await blob.setJSON(`konstai_tok_${k}`, t);\n}\n\nconst rate: Record = {};\n\nfunction pemToArrayBuffer(pem: string): ArrayBuffer {\n const b64 = pem.replace(/-----BEGIN PRIVATE KEY-----/, \"\")\n .replace(/-----END PRIVATE KEY-----/, \"\")\n .replace(/\\s+/g, \"\");\n const bin = atob(b64);\n const buf = new Uint8Array(bin.length);\n for (let i = 0; i < bin.length; i++) buf[i] = bin.charCodeAt(i);\n return buf.buffer;\n}\nconst b64url = (bytes: Uint8Array) =>\n btoa(String.fromCharCode(...bytes)).replace(/\\+/g, \"-\").replace(/\\//g, \"_\")\n .replace(/=+$/, \"\");\nconst b64urlStr = (s: string) => b64url(new TextEncoder().encode(s));\n\nlet cachedTok: string | null = null;\nlet cachedExp = 0;\n\nasync function getAccessToken(): Promise {\n const now = Math.floor(Date.now() / 1000);\n if (cachedTok && now < cachedExp - 60) return cachedTok;\n const header = b64urlStr(JSON.stringify({ alg: \"RS256\", typ: \"JWT\" }));\n const claim = b64urlStr(JSON.stringify({\n iss: SA.client_email,\n scope: \"https://www.googleapis.com/auth/firebase.messaging\",\n aud: SA.token_uri,\n iat: now,\n exp: now + 3600,\n }));\n const input = header + \".\" + claim;\n const key = await crypto.subtle.importKey(\n \"pkcs8\",\n pemToArrayBuffer(SA.private_key),\n { name: \"RSASSA-PKCS1-v1_5\", hash: \"SHA-256\" },\n false,\n [\"sign\"],\n );\n const sig = new Uint8Array(\n await crypto.subtle.sign(\n \"RSASSA-PKCS1-v1_5\",\n key,\n new TextEncoder().encode(input),\n ),\n );\n const assertion = input + \".\" + b64url(sig);\n const r = await fetch(SA.token_uri, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/x-www-form-urlencoded\" },\n body: \"grant_type=urn:ietf:params:oauth:grant-type:jwt-bearer&assertion=\" +\n assertion,\n });\n const j = await r.json();\n if (!j.access_token) throw new Error(\"no access_token: \" + JSON.stringify(j));\n cachedTok = j.access_token as string;\n cachedExp = now + (j.expires_in || 3600);\n return cachedTok;\n}\n\nasync function sendPush(token: string, data: Record) {\n const access = await getAccessToken();\n const r = await fetch(\n `https://fcm.googleapis.com/v1/projects/${PROJECT}/messages:send`,\n {\n method: \"POST\",\n headers: {\n \"Authorization\": \"Bearer \" + access,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({\n message: { token, data, android: { priority: \"high\" } },\n }),\n },\n );\n return { status: r.status, body: await r.text() };\n}\n\nconst json = (obj: unknown, status = 200) =>\n new Response(JSON.stringify(obj), {\n status,\n headers: { \"Content-Type\": \"application/json\" },\n });\n\nexport default async function (req: Request): Promise {\n const url = new URL(req.url);\n\n if (req.method === \"GET\" && url.pathname === \"/\") {\n return json({ ok: true, service: \"KonstAI\" });\n }\n\n if (req.method === \"POST\" && url.pathname === \"/register\") {\n const b = await req.json().catch(() => ({}));\n const k = norm(b.handle);\n if (!k || !b.token) {\n return json({ ok: false, error: \"handle y token requeridos\" }, 400);\n }\n await setTok(k, b.token);\n return json({ ok: true, handle: k });\n }\n\n if (req.method === \"POST\" && url.pathname === \"/notify\") {\n const b = await req.json().catch(() => ({}));\n const k = norm(b.toHandle);\n const token = await getTok(k);\n if (!token) {\n return json(\n { ok: false, error: \"destinatario no registrado\", handle: k },\n 404,\n );\n }\n const now = Date.now();\n rate[k] = (rate[k] || []).filter((t) => now - t < 60000);\n if (rate[k].length >= 5) {\n return json({ ok: false, error: \"demasiados avisos\" }, 429);\n }\n rate[k].push(now);\n const data: Record = {\n label: String(b.label || \"\"),\n number: String(b.number || b.from || \"\"),\n from: String(b.from || \"\"),\n payload: String(b.payload || \"\"),\n sig: String(b.sig || \"\"),\n };\n const r = await sendPush(token, data);\n return json(\n { ok: r.status === 200, fcm: r.status },\n r.status === 200 ? 200 : 502,\n );\n }\n\n return json({ ok: false, error: \"not found\" }, 404);\n}","import { blob } from \"https://esm.town/v/std/blob\";\n\nconst SA = JSON.parse(Deno.env.get(\"KONSTAI_SA\") || \"{}\");\nconst PROJECT = SA.project_id;\n\nconst norm = (h: string) => String(h || \"\").replace(/\\D/g, \"\").slice(-9);\n\nasync function getTok(k: string): Promise {\n try {\n return (await blob.getJSON(`konstai_tok_${k}`)) as string;\n } catch {\n return null;\n }\n}\nasync function setTok(k: string, t: string) {\n await blob.setJSON(`konstai_tok_${k}`, t);\n}\n\nconst rate: Record = {};\n\nfunction pemToArrayBuffer(pem: string): ArrayBuffer {\n const b64 = pem.replace(/-----BEGIN PRIVATE KEY-----/, \"\")\n .replace(/-----END PRIVATE KEY-----/, \"\")\n .replace(/\\\\n/g, \"\")\n .replace(/[^A-Za-z0-9+/=]/g, \"\");\n const bin = atob(b64);\n const buf = new Uint8Array(bin.length);\n for (let i = 0; i < bin.length; i++) buf[i] = bin.charCodeAt(i);\n return buf.buffer;\n}\nconst b64url = (bytes: Uint8Array) =>\n btoa(String.fromCharCode(...bytes)).replace(/\\+/g, \"-\").replace(/\\//g, \"_\")\n .replace(/=+$/, \"\");\nconst b64urlStr = (s: string) => b64url(new TextEncoder().encode(s));\n\nlet cachedTok: string | null = null;\nlet cachedExp = 0;\n\nasync function getAccessToken(): Promise {\n const now = Math.floor(Date.now() / 1000);\n if (cachedTok && now < cachedExp - 60) return cachedTok;\n const header = b64urlStr(JSON.stringify({ alg: \"RS256\", typ: \"JWT\" }));\n const claim = b64urlStr(JSON.stringify({\n iss: SA.client_email,\n scope: \"https://www.googleapis.com/auth/firebase.messaging\",\n aud: SA.token_uri,\n iat: now,\n exp: now + 3600,\n }));\n const input = header + \".\" + claim;\n const key = await crypto.subtle.importKey(\n \"pkcs8\",\n pemToArrayBuffer(SA.private_key),\n { name: \"RSASSA-PKCS1-v1_5\", hash: \"SHA-256\" },\n false,\n [\"sign\"],\n );\n const sig = new Uint8Array(\n await crypto.subtle.sign(\n \"RSASSA-PKCS1-v1_5\",\n key,\n new TextEncoder().encode(input),\n ),\n );\n const assertion = input + \".\" + b64url(sig);\n const r = await fetch(SA.token_uri, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/x-www-form-urlencoded\" },\n body: \"grant_type=urn:ietf:params:oauth:grant-type:jwt-bearer&assertion=\" +\n assertion,\n });\n const j = await r.json();\n if (!j.access_token) throw new Error(\"no access_token: \" + JSON.stringify(j));\n cachedTok = j.access_token as string;\n cachedExp = now + (j.expires_in || 3600);\n return cachedTok;\n}\n\nasync function sendPush(token: string, data: Record) {\n const access = await getAccessToken();\n const r = await fetch(\n `https://fcm.googleapis.com/v1/projects/${PROJECT}/messages:send`,\n {\n method: \"POST\",\n headers: {\n \"Authorization\": \"Bearer \" + access,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({\n message: { token, data, android: { priority: \"high\" } },\n }),\n },\n );\n return { status: r.status, body: await r.text() };\n}\n\nconst json = (obj: unknown, status = 200) =>\n new Response(JSON.stringify(obj), {\n status,\n headers: { \"Content-Type\": \"application/json\" },\n });\n\nexport default async function (req: Request): Promise {\n try {\n const url = new URL(req.url);\n\n if (req.method === \"GET\" && url.pathname === \"/\") {\n return json({ ok: true, service: \"KonstAI\" });\n }\n\n if (req.method === \"GET\" && url.pathname === \"/debug\") {\n try {\n await getAccessToken();\n return json({\n ok: true,\n sa: !!SA.client_email,\n project: PROJECT,\n tokenOk: true,\n });\n } catch (e) {\n return json({\n ok: false,\n sa: !!SA.client_email,\n project: PROJECT,\n error: String((e as Error).message || e),\n });\n }\n }\n\n if (req.method === \"POST\" && url.pathname === \"/register\") {\n const b = await req.json().catch(() => ({}));\n const k = norm(b.handle);\n if (!k || !b.token) {\n return json({ ok: false, error: \"handle y token requeridos\" }, 400);\n }\n await setTok(k, b.token);\n return json({ ok: true, handle: k });\n }\n\n if (req.method === \"POST\" && url.pathname === \"/notify\") {\n const b = await req.json().catch(() => ({}));\n const k = norm(b.toHandle);\n const token = await getTok(k);\n if (!token) {\n return json({\n ok: false,\n error: \"destinatario no registrado\",\n handle: k,\n }, 404);\n }\n const now = Date.now();\n rate[k] = (rate[k] || []).filter((t) => now - t < 60000);\n if (rate[k].length >= 5) {\n return json({ ok: false, error: \"demasiados avisos\" }, 429);\n }\n rate[k].push(now);\n const data: Record = {\n label: String(b.label || \"\"),\n number: String(b.number || b.from || \"\"),\n from: String(b.from || \"\"),\n payload: String(b.payload || \"\"),\n sig: String(b.sig || \"\"),\n };\n const r = await sendPush(token, data);\n return json({\n ok: r.status === 200,\n fcm: r.status,\n body: r.body.slice(0, 300),\n }, 200);\n }\n\n return json({ ok: false, error: \"not found\" }, 404);\n } catch (e) {\n return json({ ok: false, error: String((e as Error).message || e) }, 200);\n }\n}","createdAt",["D",1787239464778],"branchVersion","branchId","fe321492-8f91-4d0d-975c-cb3573f7ce1c","id","9f22b944-e907-4abc-bcea-f71b3515daaf","KonstAI",["D",1787238273342],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","","imageUrl","f438816c-0bcb-436e-89fa-0a25876ac3ba","pinnedFileId","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","01a01faf-dd13-7316-b4da-9b1cb1edc8d6","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_96":95,"_104":100},"org",{"_96":95,"_97":98,"_99":100,"_18":55,"_101":102,"_103":25},"branch",{"_13":85,"_32":86,"_43":42,"_87":44,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":45,"_94":95},"isOwned",24,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","obelux8","handle","displayName","Obelux8","avatar","https://avatars.githubusercontent.com/u/260928148?v=4","tier","free","canRestrictVals","profileImageUrl","branchName","adoptOrgId",{"_43":44,"_32":45,"_38":150,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":31,"_57":58,"_59":-5,"_60":-5,"_61":62,"_63":64,"_65":-5,"_66":-5,"_67":-5,"_68":-5,"_69":70,"_71":70,"_72":73,"_74":73,"_75":73,"_76":70,"_77":70,"_78":151,"_80":152,"_82":153,"_84":25},"tree",[145],"files",[145],"counts",{"_134":62,"_135":136,"_137":62,"_138":139,"_140":141},"contents",[126],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_43":127,"_32":28,"_30":31,"_128":-5,"_41":42,"_40":14,"_129":25,"_38":130,"_13":131,"_33":34,"_35":37,"_24":25,"_132":-5,"_27":133},"c2c6e7cb-5771-4953-8ca1-e4e84b52c754","parentId","latest",["D",1787239464778],2,"label",[28],"pulls","branches",1,"forks","envVars",{"_142":136,"_144":62},"connections",{"_142":62,"_143":62},"count","unfilledCount","emptyCount",{"_43":127,"_32":28,"_30":31,"_128":-5,"_41":42,"_40":14,"_129":25,"_38":146,"_13":131,"_33":34,"_35":37,"_24":25,"_132":-5,"_147":148,"_27":149},["D",1787239464778],"children",[],[28],["D",1787238273342],{"_96":95,"_104":100},{"_96":95,"_97":98,"_99":100,"_18":55,"_101":102,"_103":25},{"_13":85,"_32":86,"_43":42,"_87":44,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":45,"_94":95},"ctx",{"_78":-5,"_123":187,"_188":189,"_190":191,"_192":25,"_193":25,"_194":25,"_195":58,"_196":-5,"_197":-7,"_198":-7,"_199":62,"_200":25,"_201":25,"_202":-5,"_203":25,"_204":25,"_205":25,"_206":-5},"ENV",{"_158":159,"_160":161,"_162":86,"_163":164,"_165":166,"_167":168,"_169":170,"_171":172,"_173":174,"_175":176,"_177":178,"_179":180,"_181":182,"_183":184,"_185":186},"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 · v6