[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_169":170,"_171":172},"routes/_app.x.$handle.$name",{"_95":94,"_32":45,"_104":85,"_27":105,"_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":57,"_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":-5,"_53":-5,"_18":54,"_55":31,"_56":57,"_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":25},"version",8,"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","run.ts","latestPath","fileId","fe07116c-b146-11f1-8f52-1607ee4eb77e","name","fileType","http","content","// Manual trigger for the hourly job: GET ?key=. Same code path as the interval.\n// GET ?key=&dump=1 prints the stored bookings (newest first).\nimport { sqlite } from \"https://esm.town/v/std/sqlite\";\nimport run from \"./main.ts\";\nexport default async function (req: Request): Promise {\n const u = new URL(req.url);\n const key = u.searchParams.get(\"key\");\n if (!key || key !== Deno.env.get(\"RUN_KEY\")) return new Response(\"forbidden\", { status: 403 });\n try {\n if (u.searchParams.get(\"dump\")) {\n const r = await sqlite.execute(\"SELECT day, ref, tour, tour_date, amount, currency, round(usd,2) usd FROM gyg_bookings ORDER BY received_at DESC LIMIT 100\");\n return new Response(r.rows.map((x: any[]) => x.join(\" | \")).join(\"\\n\"));\n }\n return new Response(await run());\n } catch (e) { return new Response(\"error: \" + (e instanceof Error ? e.message : String(e)), { status: 500 }); }\n}\n","// Manual trigger for the hourly job: GET ?key=. Same code path as the interval.\n// &dump=1 prints stored bookings; &resync=1 wipes and re-imports silently; &last=1 re-sends the latest booking.\nimport { sqlite } from \"https://esm.town/v/std/sqlite\";\nimport run, { notifyLatest, resync } from \"./main.ts\";\nexport default async function (req: Request): Promise {\n const u = new URL(req.url);\n const key = u.searchParams.get(\"key\");\n if (!key || key !== Deno.env.get(\"RUN_KEY\")) return new Response(\"forbidden\", { status: 403 });\n try {\n if (u.searchParams.get(\"dump\")) {\n const r = await sqlite.execute(\"SELECT day, account, tour, tour_date, amount, currency, round(usd,2) usd FROM gyg_bookings ORDER BY received_at DESC LIMIT 100\");\n return new Response(r.rows.map((x: any[]) => x.join(\" | \")).join(\"\\n\"));\n }\n if (u.searchParams.get(\"resync\")) return new Response(await resync());\n if (u.searchParams.get(\"last\")) return new Response(await notifyLatest());\n return new Response(await run());\n } catch (e) { return new Response(\"error: \" + (e instanceof Error ? e.message : String(e)), { status: 500 }); }\n}\n","createdAt",["D",1789507287523],"branchVersion","branchId","8b86a9c6-fe40-41da-b557-89612b01f8b1","id","9360f2b1-dcfc-4c30-8316-f47643ca6eea","gyg-bookings",["D",1789504616159],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","imageUrl","159ec370-beca-4817-8fff-86948c62b68c","pinnedFileId","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","01a0465b-a310-7790-a32f-8b6426eb6648","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_95":94,"_103":99},"org",{"_95":94,"_96":97,"_98":99,"_18":54,"_100":101,"_102":25},"branch",{"_13":84,"_32":85,"_43":42,"_86":44,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":45,"_93":94},"isOwned",10,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","emozh","handle","displayName","E Mozh","avatar","https://lh3.googleusercontent.com/a/ACg8ocLxwnoJwJmE9vXG2JGoSATvN3fLUGTJl0pIFoYjPTg2Qai5jQ=s96-c","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_43":44,"_32":45,"_38":165,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":-5,"_53":-5,"_18":54,"_55":31,"_56":57,"_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":166,"_79":167,"_81":168,"_83":25},"tree",[156,157],"files",[156,157],"counts",{"_144":61,"_145":146,"_147":61,"_148":149,"_150":151},"contents",[126,127],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_43":135,"_32":136,"_30":137,"_129":-5,"_41":42,"_40":138,"_130":25,"_38":139,"_13":140,"_33":141,"_35":142,"_24":25,"_133":-5,"_27":143},{"_43":128,"_32":28,"_30":31,"_129":-5,"_41":42,"_40":14,"_130":57,"_38":131,"_13":132,"_33":34,"_35":37,"_24":25,"_133":-5,"_27":134},"d684b59c-813d-4a3f-9705-260d967642bb","parentId","latest",["D",1789507287523],2,"label",[28],"a2e5c94c-c3e8-4f3d-b56f-e26c91666640","main.ts","3168b706-b145-11f1-976a-1607ee4eb77e",7,["D",1789507287025],4,"interval","// GYG booking counter — runs on val.town (Deno) every hour.\n// Reads \"New booking on GetYourGuide\" e-mails from Gmail via the Gmail API,\n// stores every booking once (by Gmail message id), and when something new\n// arrived sends one Telegram message: the new bookings + the running day total\n// (owner's local calendar day). Commission = 8 % of the booking price, converted to USD\n// at the ECB reference rate (via frankfurter, which republishes ECB data).\n// Nothing is sent when nothing changed. Days roll over on their own.\n//\n// Env vars (val.town → Environment variables):\n// GMAIL_CLIENT_ID, GMAIL_CLIENT_SECRET, GMAIL_REFRESH_TOKEN (scope gmail.readonly)\n// TG_BOT_TOKEN, TG_CHAT_ID\n// Source of truth: travel-builder/tools/gyg-bookings/main.ts — push with push.mjs.\n\nimport { sqlite } from \"https://esm.town/v/std/sqlite\";\n\nconst COMMISSION = 0.08;\nconst TZ = \"America/Vancouver\"; // owner's local day\nconst ACCOUNTS: Record = { \"tsegelnyk@gmail.com\": \"ot\", \"olga.eksaurova@gmail.com\": \"ek\" };\nconst GMAIL_QUERY = 'from:do-not-reply@notification.getyourguide.com subject:\"New booking\" newer_than:3d';\n\nconst env = (k: string) => {\n const v = Deno.env.get(k);\n if (!v) throw new Error(`env ${k} is not set`);\n return v.trim();\n};\n\n// ---------- storage ----------\nasync function ensureSchema() {\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS gyg_bookings (\n msg_id TEXT PRIMARY KEY,\n received_at INTEGER NOT NULL,\n day TEXT NOT NULL,\n ref TEXT,\n tour TEXT,\n tour_date TEXT,\n amount REAL NOT NULL,\n currency TEXT NOT NULL,\n usd REAL NOT NULL,\n notified INTEGER NOT NULL DEFAULT 0,\n account TEXT\n )`);\n try { await sqlite.execute(\"ALTER TABLE gyg_bookings ADD COLUMN account TEXT\"); } catch { /* exists */ }\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS gyg_fx (\n day TEXT PRIMARY KEY,\n rates TEXT NOT NULL\n )`);\n}\nconst rows = (r: any) => r.rows.map((row: any[]) => Object.fromEntries(r.columns.map((c: string, i: number) => [c, row[i]])));\n\n// ---------- helpers ----------\nfunction localDay(ms: number): string {\n // YYYY-MM-DD in TZ\n return new Intl.DateTimeFormat(\"sv-SE\", { timeZone: TZ, year: \"numeric\", month: \"2-digit\", day: \"2-digit\" }).format(new Date(ms));\n}\nfunction kyivPretty(day: string): string {\n const [, m, d] = day.split(\"-\").map(Number);\n const months = [\"jan\", \"feb\", \"mar\", \"apr\", \"may\", \"jun\", \"jul\", \"aug\", \"sep\", \"oct\", \"nov\", \"dec\"];\n return `${months[m - 1]} ${d}`;\n}\nconst money = (n: number) => n.toLocaleString(\"en-US\", { minimumFractionDigits: 1, maximumFractionDigits: 1 });\nconst whole = (n: number) => Math.round(n).toLocaleString(\"en-US\");\nconst esc = (s: string) => s.replace(/&/g, \"&\").replace(//g, \">\");\n\n// ---------- ECB rates (EUR base) ----------\nasync function ecbRates(day: string): Promise> {\n const cached = rows(await sqlite.execute({ sql: \"SELECT rates FROM gyg_fx WHERE day = ?\", args: [day] }));\n if (cached.length) return JSON.parse(cached[0].rates);\n const r = await fetch(\"https://api.frankfurter.dev/v1/latest?base=EUR\");\n if (!r.ok) throw new Error(`frankfurter ${r.status}`);\n const j = await r.json();\n const rates = { EUR: 1, ...j.rates };\n await sqlite.execute({ sql: \"INSERT OR REPLACE INTO gyg_fx (day, rates) VALUES (?, ?)\", args: [day, JSON.stringify(rates)] });\n return rates;\n}\nfunction toUsd(amount: number, currency: string, rates: Record): number {\n if (currency === \"USD\") return amount;\n const c = rates[currency];\n if (!c || !rates.USD) throw new Error(`no ECB rate for ${currency}`);\n return (amount / c) * rates.USD;\n}\n\n// ---------- Gmail ----------\nasync function gmailToken(): Promise {\n const r = await fetch(\"https://oauth2.googleapis.com/token\", {\n method: \"POST\",\n headers: { \"content-type\": \"application/x-www-form-urlencoded\" },\n body: new URLSearchParams({\n client_id: env(\"GMAIL_CLIENT_ID\"),\n client_secret: env(\"GMAIL_CLIENT_SECRET\"),\n refresh_token: env(\"GMAIL_REFRESH_TOKEN\"),\n grant_type: \"refresh_token\",\n }),\n });\n const j = await r.json();\n if (!j.access_token) throw new Error(\"gmail token: \" + JSON.stringify(j).slice(0, 200));\n return j.access_token;\n}\nasync function gmail(path: string, token: string) {\n const r = await fetch(`https://gmail.googleapis.com/gmail/v1/users/me/${path}`, { headers: { authorization: `Bearer ${token}` } });\n if (!r.ok) throw new Error(`gmail ${path}: ${r.status} ${(await r.text()).slice(0, 200)}`);\n return r.json();\n}\nfunction b64url(s: string): string {\n const bin = atob(s.replace(/-/g, \"+\").replace(/_/g, \"/\"));\n return new TextDecoder().decode(Uint8Array.from(bin, (c) => c.charCodeAt(0)));\n}\nfunction bodyText(payload: any): string {\n // Prefer text/plain, fall back to stripped HTML. Walk multipart trees.\n let plain = \"\", html = \"\";\n const walk = (p: any) => {\n if (!p) return;\n if (p.mimeType === \"text/plain\" && p.body?.data) plain += b64url(p.body.data);\n if (p.mimeType === \"text/html\" && p.body?.data) html += b64url(p.body.data);\n (p.parts || []).forEach(walk);\n };\n walk(payload);\n if (plain.trim()) return plain;\n return html\n .replace(//gi, \" \")\n .replace(//gi, \"\\n\").replace(/<\\/(p|div|tr|li|h\\d)>/gi, \"\\n\")\n .replace(/<[^>]+>/g, \" \")\n .replace(/ /g, \" \").replace(/&/g, \"&\").replace(/'/g, \"'\").replace(/"/g, '\"')\n .replace(/[ \\t]+/g, \" \");\n}\n\ntype Booking = { msg_id: string; received_at: number; ref: string; account: string; tour: string; tour_date: string; amount: number; currency: string };\n\nfunction parseBooking(msg: any): Booking | null {\n const headers = Object.fromEntries((msg.payload?.headers || []).map((h: any) => [h.name.toLowerCase(), h.value]));\n const subject: string = headers.subject || \"\";\n const ref = (subject.match(/\\b([A-Z]\\d{5,})\\b/) || [])[1] || \"\";\n const to = (headers.to || \"\").toLowerCase();\n const account = Object.entries(ACCOUNTS).find(([mail]) => to.includes(mail))?.[1] || \"?\";\n const text = bodyText(msg.payload);\n const price = text.match(/Price:\\s*([\\d.,]+)\\s*([A-Z]{3})/i);\n if (!price) return null;\n const amount = parseFloat(price[1].replace(/,/g, \"\"));\n const currency = price[2].toUpperCase();\n const tourDate = (text.match(/Date:\\s*(\\d{2}-\\d{2}-\\d{4})/) || [])[1] || \"\";\n // Tour name: the bold line between \"product:\" and \"Date:\"\n const m = text.match(/product:\\s*([\\s\\S]*?)\\s*Date:/i);\n const tour = (m ? m[1] : \"\").replace(/\\s+/g, \" \").trim() || \"(tour name not parsed)\";\n return { msg_id: msg.id, received_at: Number(msg.internalDate), ref, account, tour, tour_date: tourDate, amount, currency };\n}\n\n// ---------- Telegram ----------\nasync function tg(html: string) {\n const r = await fetch(`https://api.telegram.org/bot${env(\"TG_BOT_TOKEN\")}/sendMessage`, {\n method: \"POST\",\n headers: { \"content-type\": \"application/json\" },\n body: JSON.stringify({ chat_id: env(\"TG_CHAT_ID\"), text: html, parse_mode: \"HTML\", disable_web_page_preview: true }),\n });\n const j = await r.json();\n if (!j.ok) throw new Error(\"telegram: \" + JSON.stringify(j).slice(0, 200));\n}\n\nfunction fmtDate(d: string) { // 17-10-2026 → 17.10.2026\n return d ? d.replace(/-/g, \".\") : \"\";\n}\n\nfunction buildMessage(fresh: any[], dayRows: any[], day: string): string {\n const lines: string[] = [];\n const n = dayRows.length;\n const positions = new Map(dayRows.map((r, i) => [r.msg_id, i + 1]));\n for (const b of fresh) {\n const amount = b.currency === \"USD\" ? `${money(b.amount)} usd` : `${money(b.amount)} ${b.currency.toLowerCase()} (${money(b.usd)} usd)`;\n lines.push(\n `booking #${positions.get(b.msg_id) ?? \"?\"}, ${b.account}`,\n esc(b.tour),\n `${amount}, commission ${money(b.usd * COMMISSION)} usd`,\n \"\",\n );\n }\n const sum = dayRows.reduce((s, r) => s + r.usd, 0);\n const by = (acc: string) => dayRows.filter((r) => r.account === acc).reduce((s, r) => s + r.usd, 0) * COMMISSION;\n lines.push(`total: ${n} booking${n === 1 ? \"\" : \"s\"}, ${whole(sum)} usd, commission ${money(sum * COMMISSION)} usd (ot ${money(by(\"ot\"))}, ek ${money(by(\"ek\"))})`);\n return lines.join(\"\\n\");\n}\n\n// ---------- main ----------\nexport async function notifyLatest() {\n await ensureSchema();\n const last = rows(await sqlite.execute(\"SELECT * FROM gyg_bookings ORDER BY received_at DESC LIMIT 1\"));\n if (!last.length) return \"no bookings\";\n const dayRows = rows(await sqlite.execute({ sql: \"SELECT * FROM gyg_bookings WHERE day = ? ORDER BY received_at\", args: [last[0].day] }));\n await tg(buildMessage(last, dayRows, last[0].day));\n return \"sent latest\";\n}\n\nexport async function resync() {\n await ensureSchema();\n await sqlite.execute(\"DELETE FROM gyg_bookings\");\n return run({ notify: false });\n}\n\nexport default async function run(opts: { notify?: boolean } = {}) {\n const notify = opts.notify !== false;\n await ensureSchema();\n const token = await gmailToken();\n const list = await gmail(`messages?q=${encodeURIComponent(GMAIL_QUERY)}&maxResults=50`, token);\n const ids: string[] = (list.messages || []).map((m: any) => m.id);\n if (!ids.length) return \"no booking mails in the last 3 days\";\n\n const known = new Set(\n rows(await sqlite.execute({ sql: `SELECT msg_id FROM gyg_bookings WHERE msg_id IN (${ids.map(() => \"?\").join(\",\")})`, args: ids })).map((r: any) => r.msg_id),\n );\n const newIds = ids.filter((id) => !known.has(id));\n if (!newIds.length) return `nothing new (${ids.length} known)`;\n\n const today = localDay(Date.now());\n const rates = await ecbRates(today);\n const inserted: string[] = [];\n for (const id of newIds) {\n const msg = await gmail(`messages/${id}?format=full`, token);\n const b = parseBooking(msg);\n if (!b) { console.warn(\"unparsed mail\", id, msg.snippet); continue; }\n const day = localDay(b.received_at);\n const usd = toUsd(b.amount, b.currency, rates);\n await sqlite.execute({\n sql: `INSERT OR IGNORE INTO gyg_bookings (msg_id, received_at, day, ref, account, tour, tour_date, amount, currency, usd) VALUES (?,?,?,?,?,?,?,?,?,?)`,\n args: [b.msg_id, b.received_at, day, b.ref, b.account, b.tour, b.tour_date, b.amount, b.currency, usd],\n });\n inserted.push(id);\n }\n if (!inserted.length) return \"new mails but none parsed\";\n if (!notify) return `stored ${inserted.length} (silent)`;\n\n // Group the fresh bookings by their Kyiv day (a mail from 23:50 and one from 00:10 are two days).\n const fresh = rows(await sqlite.execute({\n sql: `SELECT * FROM gyg_bookings WHERE msg_id IN (${inserted.map(() => \"?\").join(\",\")}) ORDER BY received_at`,\n args: inserted,\n }));\n const days = [...new Set(fresh.map((r: any) => r.day))].sort();\n for (const day of days) {\n const dayRows = rows(await sqlite.execute({ sql: \"SELECT * FROM gyg_bookings WHERE day = ? ORDER BY received_at\", args: [day] }));\n await tg(buildMessage(fresh.filter((r: any) => r.day === day), dayRows, day));\n }\n await sqlite.execute({ sql: `UPDATE gyg_bookings SET notified = 1 WHERE msg_id IN (${inserted.map(() => \"?\").join(\",\")})`, args: inserted });\n return `sent ${inserted.length} new booking(s)`;\n}\n",[136],"pulls","branches",1,"forks","envVars",{"_152":154,"_155":61},"connections",{"_152":61,"_153":61},"count","unfilledCount",6,"emptyCount",{"_43":135,"_32":136,"_30":137,"_129":-5,"_41":42,"_40":138,"_130":25,"_38":162,"_13":140,"_33":141,"_35":142,"_24":25,"_133":-5,"_159":163,"_27":164},{"_43":128,"_32":28,"_30":31,"_129":-5,"_41":42,"_40":14,"_130":57,"_38":158,"_13":132,"_33":34,"_35":37,"_24":25,"_133":-5,"_159":160,"_27":161},["D",1789507287523],"children",[],[28],["D",1789507287025],[],[136],["D",1789504616159],{"_95":94,"_103":99},{"_95":94,"_96":97,"_98":99,"_18":54,"_100":101,"_102":25},{"_13":84,"_32":85,"_43":42,"_86":44,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":45,"_93":94},"ctx",{"_77":-5,"_123":202,"_203":204,"_205":206,"_207":25,"_208":25,"_209":25,"_210":57,"_211":-5,"_212":-7,"_213":-7,"_214":61,"_215":25,"_216":25,"_217":-5,"_218":25,"_219":25,"_220":25,"_221":-5},"ENV",{"_173":174,"_175":176,"_177":85,"_178":179,"_180":181,"_182":183,"_184":185,"_186":187,"_188":189,"_190":191,"_192":193,"_194":195,"_196":197,"_198":199,"_200":201},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","5015b8df46402d8bba4f485ecc37aec202b0e06b","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 · v8