[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_163":164,"_165":166},"routes/_app.x.$handle.$name",{"_11":12,"_13":14,"_89":-7,"_90":91,"_29":-7,"_92":-5,"_15":93,"_94":95,"_96":97,"_98":99,"_100":101,"_102":-5,"_103":-5,"_104":-5,"_105":38,"_106":107,"_108":49,"_109":-5,"_110":-5,"_111":112},"routes/_app.x.$handle.$name.branches",{"_11":12,"_13":14,"_15":16,"_17":18},"handle","emozh","name","gyg-bookings","project",{"_20":28,"_13":14,"_22":36,"_35":-5,"_37":38,"_39":40,"_41":40,"_42":-5,"_43":-5,"_44":45,"_46":47,"_48":49,"_50":-5,"_51":-5,"_52":53,"_54":55,"_56":-5,"_57":-5,"_58":-5,"_59":-5,"_60":61,"_62":61,"_63":64,"_65":64,"_66":64,"_67":61,"_68":61,"_69":70,"_71":72,"_73":74,"_75":38},"branches",[19],{"_20":21,"_22":23,"_24":25,"_13":26,"_27":28,"_29":30,"_31":-5,"_32":-5,"_33":34,"_35":-5},"id","8b86a9c6-fe40-41da-b557-89612b01f8b1","createdAt",["D",1789504616159],"updatedAt",["D",1789508004766],"main","projectId","9360f2b1-dcfc-4c30-8316-f47643ca6eea","version",10,"forkedBranchId","forkedBranchVersion","lockfileKey","1789508004898-esm.town_v_emozh_gyg-bookings@10-main","deletedAt",["D",1789504616159],"legacyEnvVars",false,"privacy","public","httpPrivacy","description","imageUrl","userId","159ec370-beca-4817-8fff-86948c62b68c","pinnedFileId","fe07116c-b146-11f1-8f52-1607ee4eb77e","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",{"_11":12,"_88":84},"org",{"_11":12,"_81":82,"_83":84,"_44":45,"_85":86,"_87":38},"branch",{"_29":30,"_13":26,"_20":21,"_27":28,"_31":-5,"_32":-5,"_76":-5,"_77":-5,"_78":-5,"_79":14,"_80":12},"isOwned","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","E Mozh","avatar","https://lh3.googleusercontent.com/a/ACg8ocLxwnoJwJmE9vXG2JGoSATvN3fLUGTJl0pIFoYjPTg2Qai5jQ=s96-c","tier","free","canRestrictVals","profileImageUrl","branchName","path","","adoptOrgId",{"_20":28,"_13":14,"_22":159,"_35":-5,"_37":38,"_39":40,"_41":40,"_42":-5,"_43":-5,"_44":45,"_46":47,"_48":49,"_50":-5,"_51":-5,"_52":53,"_54":55,"_56":-5,"_57":-5,"_58":-5,"_59":-5,"_60":61,"_62":61,"_63":64,"_65":64,"_66":64,"_67":61,"_68":61,"_69":160,"_71":161,"_73":162,"_75":38},"tree",[150,151],"files",[150,151],"counts",{"_140":53,"_17":141,"_142":53,"_143":144,"_145":146},"contents",[113,114],"file","upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_20":132,"_13":133,"_117":134,"_118":-5,"_119":21,"_120":30,"_122":49,"_22":135,"_29":136,"_125":137,"_127":138,"_129":38,"_130":-5,"_90":139},{"_20":115,"_13":116,"_117":47,"_118":-5,"_119":21,"_120":121,"_122":49,"_22":123,"_29":124,"_125":126,"_127":128,"_129":38,"_130":-5,"_90":131},"d684b59c-813d-4a3f-9705-260d967642bb","run.ts","fileId","parentId","branchId","branchVersion",8,"latest",["D",1789507287523],2,"fileType","http","content","// 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","deleted","label",[116],"be9250b4-2ff9-4ecf-9488-15fa1e833022","main.ts","3168b706-b145-11f1-976a-1607ee4eb77e",["D",1789508004766],6,"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 (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",[133],"pulls",1,"forks","envVars",{"_147":136,"_149":53},"connections",{"_147":53,"_148":53},"count","unfilledCount","emptyCount",{"_20":132,"_13":133,"_117":134,"_118":-5,"_119":21,"_120":30,"_122":49,"_22":156,"_29":136,"_125":137,"_127":138,"_129":38,"_130":-5,"_153":157,"_90":158},{"_20":115,"_13":116,"_117":47,"_118":-5,"_119":21,"_120":121,"_122":49,"_22":152,"_29":124,"_125":126,"_127":128,"_129":38,"_130":-5,"_153":154,"_90":155},["D",1789507287523],"children",[],[116],["D",1789508004766],[],[133],["D",1789504616159],{"_11":12,"_88":84},{"_11":12,"_81":82,"_83":84,"_44":45,"_85":86,"_87":38},{"_29":30,"_13":26,"_20":21,"_27":28,"_31":-5,"_32":-5,"_76":-5,"_77":-5,"_78":-5,"_79":14,"_80":12},"ctx",{"_69":-5,"_110":196,"_197":198,"_199":200,"_201":38,"_202":38,"_203":38,"_204":49,"_205":-5,"_206":-7,"_207":-7,"_208":53,"_209":38,"_210":38,"_211":-5,"_212":38,"_213":38,"_214":38,"_215":-5},"ENV",{"_167":168,"_169":170,"_171":26,"_172":173,"_174":175,"_176":177,"_178":179,"_180":181,"_182":183,"_184":185,"_186":187,"_188":189,"_190":191,"_192":193,"_194":195},"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"]

Branches1

Branches
1