[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_144":145,"_146":147},"routes/_app.x.$handle.$name",{"_16":17,"_20":21,"_82":65,"_83":31,"_63":-7,"_84":-5,"_13":85,"_86":87,"_11":88,"_89":90,"_91":92,"_93":-5,"_94":-5,"_95":-5,"_96":26,"_97":98,"_99":26,"_100":-5,"_101":-5,"_102":103},"routes/_app.x.$handle.$name.search.$(branch)",{"_11":12,"_13":14,"_15":-5,"_16":17},"files",[],"project",{"_18":19,"_20":21,"_22":23,"_24":-5,"_25":26,"_27":28,"_29":28,"_30":31,"_32":-5,"_33":34,"_35":-5,"_36":26,"_37":-5,"_38":-5,"_39":40,"_41":42,"_43":-5,"_44":-5,"_45":-5,"_46":-5,"_47":48,"_49":48,"_50":51,"_52":51,"_53":51,"_54":48,"_55":48,"_56":57,"_58":59,"_60":61,"_62":26},"query","handle","atdhub","id","a646183e-0bce-4cd2-b5e7-f8ab97ab3e06","name","yqbNotify","createdAt",["D",1784819077610],"deletedAt","legacyEnvVars",false,"privacy","public","httpPrivacy","description","","imageUrl","userId","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",{"_16":17,"_81":77},"org",{"_16":17,"_75":-5,"_76":77,"_33":34,"_78":79,"_80":26},"branch",{"_63":64,"_20":65,"_18":66,"_67":19,"_68":-5,"_69":-5,"_70":-5,"_71":-5,"_72":-5,"_73":21,"_74":17},"isOwned","version",6,"main","57461b04-f36b-49fd-82e6-f4f5ddd56208","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","avatar","https://img.clerk.com/eyJ0eXBlIjoicHJveHkiLCJzcmMiOiJodHRwczovL2ltYWdlcy5jbGVyay5kZXYvb2F1dGhfZ2l0aHViL2ltZ18zQkl3MUt2bEhJeW0zdmNzYkRQRm5kMGhwbUkifQ","tier","free","canRestrictVals","profileImageUrl","branchName","path","adoptOrgId",{"_18":19,"_20":21,"_22":140,"_24":-5,"_25":26,"_27":28,"_29":28,"_30":31,"_32":-5,"_33":34,"_35":-5,"_36":26,"_37":-5,"_38":-5,"_39":40,"_41":42,"_43":-5,"_44":-5,"_45":-5,"_46":-5,"_47":48,"_49":48,"_50":51,"_52":51,"_53":51,"_54":48,"_55":48,"_56":141,"_58":142,"_60":143,"_62":26},"tree",[135],[135],"counts",{"_124":40,"_125":126,"_127":40,"_128":129,"_130":131},"contents",[104],"file","upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_18":105,"_20":106,"_107":108,"_109":-5,"_110":66,"_111":112,"_113":114,"_22":115,"_63":116,"_117":118,"_119":120,"_121":26,"_122":-5,"_83":123},"6bce8e58-38b3-4381-9c64-70f7c651919b","main.ts","fileId","d29c3062-86a7-11f1-8337-1607ee4eb77e","parentId","branchId","branchVersion",4,"latest",true,["D",1784899321923],3,"fileType","interval","content","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","deleted","label",[106],"pulls","branches",1,"forks","envVars",{"_132":116,"_134":40},"connections",{"_132":40,"_133":40},"count","unfilledCount","emptyCount",{"_18":105,"_20":106,"_107":108,"_109":-5,"_110":66,"_111":112,"_113":114,"_22":136,"_63":116,"_117":118,"_119":120,"_121":26,"_122":-5,"_137":138,"_83":139},["D",1784899321923],"children",[],[106],["D",1784819077610],{"_16":17,"_81":77},{"_16":17,"_75":-5,"_76":77,"_33":34,"_78":79,"_80":26},{"_63":64,"_20":65,"_18":66,"_67":19,"_68":-5,"_69":-5,"_70":-5,"_71":-5,"_72":-5,"_73":21,"_74":17},"ctx",{"_56":-5,"_101":177,"_178":179,"_180":181,"_182":26,"_183":26,"_184":26,"_185":114,"_186":-5,"_187":-7,"_188":-7,"_189":40,"_190":26,"_191":26,"_192":-5,"_193":26,"_194":26,"_195":26,"_196":-5},"ENV",{"_148":149,"_150":151,"_152":65,"_153":154,"_155":156,"_157":158,"_159":160,"_161":162,"_163":164,"_165":166,"_167":168,"_169":170,"_171":172,"_173":174,"_175":176},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e8c4b7030cb7600e4eb0736b15f422c8b8bd130f","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"]

Search