[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_156":157,"_158":159},"routes/_app.x.$handle.$name",{"_94":93,"_32":44,"_102":84,"_27":53,"_13":14,"_103":-5,"_11":104,"_105":106,"_107":108,"_109":110,"_111":112,"_20":-5,"_113":-5,"_114":-5,"_115":48,"_116":117,"_118":48,"_119":-5,"_120":-5,"_121":122},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_42":43,"_32":44,"_37":45,"_46":-5,"_47":48,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":-5,"_57":48,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":-5,"_65":-5,"_66":-5,"_67":-5,"_68":69,"_70":69,"_71":72,"_73":72,"_74":72,"_75":69,"_76":69,"_77":78,"_79":80,"_81":82,"_83":48},"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":36,"_37":38,"_39":14,"_40":41,"_24":25},"previous",{"_30":31,"_32":28,"_33":34,"_35":36},"deleted",true,"deletedHere","path","trigger.ts","latestPath","fileId","e3ddcd82-8764-11f1-b903-1607ee4eb77e","name","fileType","http","content","import { blob } from \"https://esm.town/v/std/blob\";\n// @ts-ignore\nimport webpush from \"npm:web-push\";\n\nconst PUB = import.meta.env?.VAPID_PUBLIC_KEY ?? Deno.env.get(\"VAPID_PUBLIC_KEY\") ?? \"\";\nconst PRIV = import.meta.env?.VAPID_PRIVATE_KEY ?? Deno.env.get(\"VAPID_PRIVATE_KEY\") ?? \"\";\n\nexport default async function(req: Request): Promise {\n if (!PUB || !PRIV) return Response.json({ ok: false, error: \"VAPID keys missing on notify project\" });\n webpush.setVapidDetails(\"mailto:62djzmqmsg@privaterelay.appleid.com\", PUB, PRIV);\n const subs: any[] = (await blob.getJSON(\"yqb-subs\")) || [];\n const results: any[] = [];\n for (const s of subs) {\n try {\n await webpush.sendNotification(s.subscription, JSON.stringify({ title: \"YQB cron keys\", body: \"Notify project VAPID OK\", flight: \"TEST2\" }));\n results.push({ ok: true, ep: s.subscription.endpoint.slice(-15) });\n } catch(e: any) {\n results.push({ ok: false, status: e?.statusCode, msg: String(e).slice(0, 100), ep: s.subscription.endpoint.slice(-15) });\n }\n }\n return Response.json({ ok: true, results });\n}","createdAt",["D",1784900310203],"branchVersion","branchId","57461b04-f36b-49fd-82e6-f4f5ddd56208","id","a646183e-0bce-4cd2-b5e7-f8ab97ab3e06","yqbNotify",["D",1784819077610],"deletedAt","legacyEnvVars",false,"privacy","public","httpPrivacy","description","","imageUrl","019d15f2-110b-77f2-9e89-c8f64fc44dd0","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","019d15f2-110c-737a-b77c-f6f2d5abe74a","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_94":93,"_101":97},"org",{"_94":93,"_95":-5,"_96":97,"_18":55,"_98":99,"_100":48},"branch",{"_13":14,"_32":84,"_42":41,"_85":43,"_86":-5,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":44,"_92":93},"isOwned","main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","atdhub","handle","displayName","avatar","https://img.clerk.com/eyJ0eXBlIjoicHJveHkiLCJzcmMiOiJodHRwczovL2ltYWdlcy5jbGVyay5kZXYvb2F1dGhfZ2l0aHViL2ltZ18zQkl3MUt2bEhJeW0zdmNzYkRQRm5kMGhwbUkifQ","tier","free","canRestrictVals","profileImageUrl","branchName","adoptOrgId",{"_42":43,"_32":44,"_37":152,"_46":-5,"_47":48,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":-5,"_57":48,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":-5,"_65":-5,"_66":-5,"_67":-5,"_68":69,"_70":69,"_71":72,"_73":72,"_74":72,"_75":69,"_76":69,"_77":153,"_79":154,"_81":155,"_83":48},"tree",[147],"files",[147],"counts",{"_136":61,"_137":138,"_139":61,"_140":141,"_142":143},"contents",[123],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_42":124,"_32":125,"_30":126,"_127":-5,"_40":41,"_39":128,"_129":25,"_37":130,"_13":131,"_33":132,"_35":133,"_24":48,"_134":-5,"_27":135},"6bce8e58-38b3-4381-9c64-70f7c651919b","main.ts","d29c3062-86a7-11f1-8337-1607ee4eb77e","parentId",4,"latest",["D",1784899321923],3,"interval","import { blob } from \"https://esm.town/v/std/blob\";\n// @ts-ignore\nimport webpush from \"npm:web-push\";\n\nconst VAPID_PUBLIC_KEY = import.meta.env?.VAPID_PUBLIC_KEY ?? Deno.env.get(\"VAPID_PUBLIC_KEY\") ?? \"\";\nconst VAPID_PRIVATE_KEY = import.meta.env?.VAPID_PRIVATE_KEY ?? Deno.env.get(\"VAPID_PRIVATE_KEY\") ?? \"\";\nconst FWI_URL = \"https://atdhub--69d65eac25fb11f1a82842dde27851f2.web.val.run\";\n\nwebpush.setVapidDetails(\n \"mailto:62djzmqmsg@privaterelay.appleid.com\",\n VAPID_PUBLIC_KEY,\n VAPID_PRIVATE_KEY,\n);\n\n// Returns today's date string in Eastern Time (EDT=UTC-4, EST=UTC-5)\nfunction easternDate(): string {\n const now = new Date();\n const month = now.getUTCMonth(); // 0=Jan\n const offset = (month >= 2 && month <= 10) ? -4 : -5; // rough DST\n const et = new Date(now.getTime() + offset * 3600000);\n return et.toISOString().split(\"T\")[0];\n}\n\nfunction xt(src: string, tag: string): string {\n const r = src.match(new RegExp(`<${tag}>([^<]+)<\\\\/${tag}>`));\n return r ? r[1].trim() : \"\";\n}\n\nfunction xmlTime(raw: string): string {\n const p = (raw || \"\").split(\"T\");\n return p.length > 1 ? p[1].slice(0, 5) : \"\";\n}\n\nfunction normStatus(s: string): string {\n s = s.toLowerCase();\n if (s.includes(\"arriv\") || s.includes(\"atterr\") || s.includes(\"land\")) return \"Arrived\";\n if (s.includes(\"board\")) return \"Boarding\";\n if (s.includes(\"depart\") || s.includes(\"parti\") || s.includes(\"décoll\") || s.includes(\"decoll\")) return \"Departed\";\n if (s.includes(\"cancel\") || s.includes(\"annul\")) return \"Cancelled\";\n if (s.includes(\"delay\") || s.includes(\"retard\")) return \"Delayed\";\n if (s.includes(\"on time\") || s.includes(\"à l'heure\") || s.includes(\"heure\")) return \"On Time\";\n return s || \"Unknown\";\n}\n\ntype FlightInfo = { number: string; status: string; dest: string; mode: \"arrivals\" | \"departures\" };\n\nfunction parseFlights(xml: string, targetDate: string): Record {\n const result: Record = {};\n\n const modes: Array<[string, boolean]> = [[\"arrivalFlight\", true], [\"departureFlight\", false]];\n for (const [tag, isArr] of modes) {\n const re = new RegExp(`<${tag}[\\\\s\\\\S]*?<\\\\/${tag}>`, \"g\");\n let m: RegExpExecArray | null;\n while ((m = re.exec(xml)) !== null) {\n const b = m[0];\n const ref = isArr ? (xt(b, \"sta\") || xt(b, \"eta\")) : (xt(b, \"std\") || xt(b, \"etd\"));\n if (!ref || ref.split(\"T\")[0] !== targetDate) continue;\n\n const iata = xt(b, \"airline-iataCode\");\n const num = xt(b, \"flightNumber\");\n if (!iata || !num) continue;\n\n const fn = (iata + num).toUpperCase().replace(/\\s+/g, \"\");\n const city = isArr ? xt(b, \"origin-airportCityName\") : xt(b, \"destination-airportCityName\");\n const code = isArr ? xt(b, \"origin-iataCode\") : xt(b, \"destination-iataCode\");\n\n result[fn] = {\n number: iata + \" \" + num,\n status: normStatus(xt(b, isArr ? \"arrivalStatus\" : \"departureStatus\")),\n dest: city || code,\n mode: isArr ? \"arrivals\" : \"departures\",\n };\n }\n }\n return result;\n}\n\nexport default async function() {\n const today = easternDate();\n\n // Fetch live flight XML\n let xml: string;\n try {\n const res = await fetch(FWI_URL + \"?_cb=\" + Date.now());\n if (!res.ok) return;\n xml = await res.text();\n if (!xml || xml.length < 200 || !xml.includes(\"Flight\")) return;\n } catch { return; }\n\n const current = parseFlights(xml, today);\n const prevMap: Record = (await blob.getJSON(\"yqb-prev-statuses\")) || {};\n\n let subs: Array<{ subscription: any; watchedFlights: Record }> =\n (await blob.getJSON(\"yqb-subs\")) || [];\n\n let subsChanged = false;\n const deadEndpoints = new Set();\n\n for (let i = 0; i < subs.length; i++) {\n const sub = subs[i];\n const watched = sub.watchedFlights || {};\n const toRemove: string[] = [];\n\n for (const fn of Object.keys(watched)) {\n const flight = current[fn];\n if (!flight) continue;\n\n const prev = prevMap[fn];\n // Skip if no previous reading (first run) or status unchanged\n if (!prev || prev === flight.status) continue;\n\n const isDone = flight.mode === \"departures\"\n ? flight.status === \"Departed\"\n : flight.status === \"Arrived\";\n\n const body = isDone\n ? (flight.mode === \"departures\"\n ? \"Departed — have a great flight!\"\n : \"Landed — head to baggage claim!\")\n : \"Status changed to: \" + flight.status;\n\n try {\n await webpush.sendNotification(\n sub.subscription,\n JSON.stringify({ title: flight.number + \" · \" + flight.dest, body, flight: fn }),\n );\n } catch (e: any) {\n // 410 = subscription expired/unsubscribed; 404 = unknown endpoint\n if (e?.statusCode === 410 || e?.statusCode === 404) {\n deadEndpoints.add(sub.subscription.endpoint);\n }\n }\n\n if (isDone) toRemove.push(fn);\n }\n\n for (const fn of toRemove) {\n delete watched[fn];\n subsChanged = true;\n }\n }\n\n // Remove dead subscriptions\n if (deadEndpoints.size > 0) {\n subs = subs.filter((s) => !deadEndpoints.has(s.subscription.endpoint));\n subsChanged = true;\n }\n\n // Persist updated subscriber list\n if (subsChanged) {\n await blob.setJSON(\"yqb-subs\", subs);\n }\n\n // Save current flight statuses as the new \"previous\" baseline\n const newPrev: Record = {};\n for (const [fn, f] of Object.entries(current)) {\n newPrev[fn] = f.status;\n }\n await blob.setJSON(\"yqb-prev-statuses\", newPrev);\n}\n","label",[125],"pulls","branches",1,"forks","envVars",{"_144":131,"_146":61},"connections",{"_144":61,"_145":61},"count","unfilledCount","emptyCount",{"_42":124,"_32":125,"_30":126,"_127":-5,"_40":41,"_39":128,"_129":25,"_37":148,"_13":131,"_33":132,"_35":133,"_24":48,"_134":-5,"_149":150,"_27":151},["D",1784899321923],"children",[],[125],["D",1784819077610],{"_94":93,"_101":97},{"_94":93,"_95":-5,"_96":97,"_18":55,"_98":99,"_100":48},{"_13":14,"_32":84,"_42":41,"_85":43,"_86":-5,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":44,"_92":93},"ctx",{"_77":-5,"_120":189,"_190":191,"_192":193,"_194":48,"_195":48,"_196":48,"_197":25,"_198":-5,"_199":-7,"_200":-7,"_201":61,"_202":48,"_203":48,"_204":-5,"_205":48,"_206":48,"_207":48,"_208":-5},"ENV",{"_160":161,"_162":163,"_164":84,"_165":166,"_167":168,"_169":170,"_171":172,"_173":174,"_175":176,"_177":178,"_179":180,"_181":182,"_183":184,"_185":186,"_187":188},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","899124c68db8496248a17ee95f074b807335ea7b","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