[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8},"actionData","errors","root",{"_102":103,"_104":105},"routes/embed.x.$handle.$name.$",{"_9":10,"_11":12,"_13":14,"_15":16,"_17":18,"_19":20,"_21":-5},"handle","emozh","name","gyg-bookings","path","main.ts","project",{"_22":45,"_11":12,"_33":46,"_47":-5,"_48":42,"_49":50,"_51":50,"_52":-5,"_53":-5,"_54":55,"_56":57,"_58":32,"_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":42},"file",{"_22":23,"_11":14,"_24":25,"_26":-5,"_27":28,"_29":30,"_31":32,"_33":34,"_35":36,"_37":38,"_39":40,"_41":42,"_43":-5,"_13":44},"permalink","https://www.val.town/x/emozh/gyg-bookings/code/main.ts","extension","id","be9250b4-2ff9-4ecf-9488-15fa1e833022","fileId","3168b706-b145-11f1-976a-1607ee4eb77e","parentId","branchId","8b86a9c6-fe40-41da-b557-89612b01f8b1","branchVersion",10,"latest",true,"createdAt",["D",1789508004766],"version",6,"fileType","interval","content","// 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 (comma-separated chat ids)\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\": \"eks\" };\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 // TG_CHAT_ID may hold several ids, comma-separated (owner + Olga).\n for (const chat_id of env(\"TG_CHAT_ID\").split(\",\").map((s) => s.trim()).filter(Boolean)) {\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, text: html, parse_mode: \"HTML\", disable_web_page_preview: true }),\n });\n const j = await r.json();\n if (!j.ok) console.error(\"telegram\", chat_id, JSON.stringify(j).slice(0, 200));\n }\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)}` : `${money(b.amount)} ${b.currency.toLowerCase()} ($${money(b.usd)})`;\n lines.push(\n `booking #${positions.get(b.msg_id) ?? \"?\"}, ${b.account}`,\n esc(b.tour),\n `${amount}, commission $${money(b.usd * COMMISSION)}`,\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)}, commission $${money(sum * COMMISSION)} (ot $${money(by(\"ot\"))}, eks $${money(by(\"eks\"))})`);\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","deleted",false,"label",[14],"9360f2b1-dcfc-4c30-8316-f47643ca6eea",["D",1789504616159],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","imageUrl","userId","159ec370-beca-4817-8fff-86948c62b68c","pinnedFileId","fe07116c-b146-11f1-8f52-1607ee4eb77e","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","01a0465b-a310-7790-a32f-8b6426eb6648","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_9":10,"_101":97},"org",{"_9":10,"_94":95,"_96":97,"_54":55,"_98":99,"_100":42},"branch",{"_35":30,"_11":85,"_22":28,"_86":45,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":12,"_93":10},"isOwned","main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","E Mozh","avatar","https://lh3.googleusercontent.com/a/ACg8ocLxwnoJwJmE9vXG2JGoSATvN3fLUGTJl0pIFoYjPTg2Qai5jQ=s96-c","tier","free","canRestrictVals","profileImageUrl","ctx",{"_78":-5,"_135":136,"_137":138,"_139":140,"_141":42,"_142":42,"_143":42,"_144":32,"_145":-5,"_146":-7,"_147":-7,"_148":62,"_149":42,"_150":42,"_151":-5,"_152":42,"_153":42,"_154":42,"_155":-5},"ENV",{"_106":107,"_108":109,"_110":85,"_111":112,"_113":114,"_115":116,"_117":118,"_119":120,"_121":122,"_123":124,"_125":126,"_127":128,"_129":130,"_131":132,"_133":134},"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","orgs",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]