[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_150":151,"_152":153},"routes/_app.x.$handle.$name",{"_11":12,"_13":14,"_88":-7,"_89":90,"_29":-7,"_91":-5,"_15":92,"_93":94,"_95":96,"_97":98,"_99":100,"_101":-5,"_102":-5,"_103":-5,"_104":38,"_105":106,"_107":108,"_109":-5,"_110":-5,"_111":112},"routes/_app.x.$handle.$name.branches",{"_11":12,"_13":14,"_15":16,"_17":18},"handle","buolur","name","playTelegram","project",{"_20":28,"_13":14,"_22":36,"_35":-5,"_37":38,"_39":40,"_41":40,"_42":43,"_44":-5,"_45":46,"_47":-5,"_48":38,"_49":-5,"_50":-5,"_51":52,"_53":54,"_55":-5,"_56":-5,"_57":-5,"_58":-5,"_59":60,"_61":60,"_62":63,"_64":63,"_65":63,"_66":60,"_67":60,"_68":69,"_70":71,"_72":73,"_74":38},"branches",[19],{"_20":21,"_22":23,"_24":25,"_13":26,"_27":28,"_29":30,"_31":-5,"_32":-5,"_33":34,"_35":-5},"id","e7c53a26-bfb1-42ec-98f8-6a76c549027c","createdAt",["D",1782230376932],"updatedAt",["D",1782240517210],"main","projectId","9875681e-64d2-4721-9adf-45ad06555f07","version",5,"forkedBranchId","forkedBranchVersion","lockfileKey","1782240517326-esm.town_v_buolur_playTelegram@5-main","deletedAt",["D",1782230376927],"legacyEnvVars",false,"privacy","public","httpPrivacy","description","Google Play RTDN to Telegram relay","imageUrl","userId","890dea22-23c9-4af8-91f2-af0c40bbbfef","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","019ef501-c31f-7482-a891-28bac1726bce","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_11":12,"_87":83},"org",{"_11":12,"_80":81,"_82":83,"_45":46,"_84":85,"_86":38},"branch",{"_29":30,"_13":26,"_20":21,"_27":28,"_31":-5,"_32":-5,"_75":-5,"_76":-5,"_77":-5,"_78":14,"_79":12},"isOwned","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","Bu Olur","avatar","https://lh3.googleusercontent.com/a/ACg8ocIAzRARfcdP_cpx0j8J7gYEcjysozQMGauyzDC1r98gaYBOHA=s96-c","tier","free","canRestrictVals","profileImageUrl","branchName","path","","adoptOrgId",{"_20":28,"_13":14,"_22":146,"_35":-5,"_37":38,"_39":40,"_41":40,"_42":43,"_44":-5,"_45":46,"_47":-5,"_48":38,"_49":-5,"_50":-5,"_51":52,"_53":54,"_55":-5,"_56":-5,"_57":-5,"_58":-5,"_59":60,"_61":60,"_62":63,"_64":63,"_65":63,"_66":60,"_67":60,"_68":147,"_70":148,"_72":149,"_74":38},"tree",[141],"files",[141],"counts",{"_131":52,"_17":132,"_133":52,"_134":135,"_136":137},"contents",[113],"file","upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles",true,"grants","orgs","customDomains",{},{"_20":114,"_13":115,"_116":117,"_118":-5,"_119":21,"_120":30,"_121":108,"_22":122,"_29":123,"_124":125,"_126":127,"_128":38,"_129":-5,"_89":130},"eeee82b2-6d60-437b-874d-6c24f3b5835a","main.ts","fileId","88c4f818-6f1c-11f1-bf92-1607ee4eb77e","parentId","branchId","branchVersion","latest",["D",1782240517210],4,"fileType","http","content","// ============================================================================\n// Google Play Real-time Developer Notifications (RTDN) → Telegram relay\n// Deploy as an HTTP val on Val.town (https://www.val.town)\n//\n// Companion to appstore-to-telegram.ts — posts to the SAME Telegram bot/chat.\n//\n// Required environment variables (set in Val.town \"Environment Variables\"):\n// TELEGRAM_BOT_TOKEN - bot token from @BotFather (same as Apple val)\n// TELEGRAM_CHAT_ID - numeric chat ID (same as Apple val)\n// WEBHOOK_SECRET - random string; must appear in the URL path,\n// e.g. /9xk2... — requests without it get 403\n// GOOGLE_SERVICE_ACCOUNT_JSON - the full service-account JSON key (one line).\n// Used to call the Play Developer API so we can\n// enrich the message with product + price +\n// expiry, like the Apple relay does.\n//\n// How it works: Google Cloud Pub/Sub POSTs a \"push\" message:\n// { \"message\": { \"data\": \"\", \"messageId\": \"...\" }, ... }\n// We base64-decode message.data → the RTDN JSON (packageName, eventTimeMillis,\n// and one of subscriptionNotification / oneTimeProductNotification /\n// voidedPurchaseNotification / testNotification). For subscription & one-time\n// events we call the Play Developer API with the purchaseToken to fetch\n// product/price/expiry, then post a formatted message to Telegram.\n// We always return 200 so Pub/Sub marks delivery successful and won't retry.\n// ============================================================================\n\n// ---------------------------------------------------------------------------\n// Notification-type maps (Google sends integer codes, not strings like Apple)\n// ---------------------------------------------------------------------------\nconst SUB_TYPE_LABELS: Record = {\n 1: \"🟢 Subscription recovered\",\n 2: \"🔁 Subscription renewed\",\n 3: \"🚫 Subscription canceled\",\n 4: \"🎉 New subscription\",\n 5: \"⏸️ Subscription on hold\",\n 6: \"⏳ Subscription in grace period\",\n 7: \"🔄 Subscription restarted\",\n 8: \"💲 Price change confirmed\",\n 9: \"📅 Subscription deferred\",\n 10: \"⏯️ Subscription paused\",\n 11: \"🛠️ Pause schedule changed\",\n 12: \"🔒 Subscription revoked\",\n 13: \"❌ Subscription expired\",\n 20: \"🚫 Pending purchase canceled\",\n};\n\n// One-line plain-English explanation of what each subscription event means.\nconst SUB_TYPE_NOTES: Record = {\n 1: \"A user re-subscribed after being on hold / canceled.\",\n 2: \"An existing subscription auto-renewed and was charged.\",\n 3: \"The user turned off auto-renew — access lasts until it expires.\",\n 4: \"A brand-new subscriber just signed up.\",\n 5: \"Payment failed; Google is retrying (no access right now).\",\n 6: \"Payment failed but the user still has access while Google retries.\",\n 7: \"A canceled subscription was resubscribed from the Play Store.\",\n 8: \"The user accepted a price change for the next renewal.\",\n 9: \"The next renewal date was pushed back (deferred).\",\n 10: \"The user paused their subscription.\",\n 11: \"The user changed when the pause takes effect.\",\n 12: \"Access was revoked immediately (e.g. refund).\",\n 13: \"The subscription ended — the user no longer has access.\",\n 20: \"A purchase that was pending (e.g. cash/3-D Secure) was canceled.\",\n};\n\nconst ONETIME_TYPE_LABELS: Record = {\n 1: \"🛒 One-time purchase\",\n 2: \"🚫 One-time purchase canceled\",\n};\n\n// Plain-English explanation for one-time (non-subscription) events.\nconst ONETIME_TYPE_NOTES: Record = {\n 1: \"A user bought a one-time (non-subscription) product.\",\n 2: \"A pending one-time purchase was canceled before completing.\",\n};\n\n// purchases.subscriptions.paymentState\nconst PAYMENT_STATE_LABELS: Record = {\n 0: \"Payment pending\",\n 1: \"Payment received\",\n 2: \"Free trial\",\n 3: \"Pending deferred upgrade/downgrade\",\n};\n\n// purchases.subscriptions.cancelReason\nconst CANCEL_REASON_LABELS: Record = {\n 0: \"Canceled by the user\",\n 1: \"Canceled by the system (e.g. billing problem)\",\n 2: \"Replaced by a new subscription\",\n 3: \"Canceled by the developer\",\n};\n\n// purchases.products.purchaseState\nconst PRODUCT_STATE_LABELS: Record = {\n 0: \"Purchased\",\n 1: \"Canceled\",\n 2: \"Pending\",\n};\n\n// purchaseType is only set for non-standard purchases — these never charge real money.\nconst PURCHASE_TYPE_LABELS: Record = {\n 0: \"🧪 Test purchase (license tester — no real charge)\",\n 1: \"🎟️ Promo code (no charge)\",\n 2: \"🎬 Rewarded (ad-funded — no charge)\",\n};\n\n// Optional: friendly app names per packageName. Add entries as you add apps.\nconst PACKAGE_NAMES: Record = {\n // \"com.worldmap.countries\": \"World Map & Countries\",\n};\n\n// ---------------------------------------------------------------------------\n// Helpers\n// ---------------------------------------------------------------------------\nfunction b64decodeToString(b64: string): string {\n const bin = atob(b64);\n const bytes = Uint8Array.from(bin, (c) => c.charCodeAt(0));\n return new TextDecoder().decode(bytes);\n}\n\nfunction esc(s: string): string {\n return s.replace(/&/g, \"&\").replace(//g, \">\");\n}\n\nfunction fmtDateMs(ms?: number | string): string | null {\n if (ms == null) return null;\n const n = typeof ms === \"string\" ? Number(ms) : ms;\n if (!n || Number.isNaN(n)) return null;\n return new Date(n).toISOString().slice(0, 16).replace(\"T\", \" \") + \" UTC\";\n}\n\n// Google sends price in micros (1,000,000 micros = 1 unit)\nfunction fmtMoneyMicros(\n micros?: string | number,\n currency?: string,\n): string | null {\n if (micros == null) return null;\n const n = typeof micros === \"string\" ? Number(micros) : micros;\n if (Number.isNaN(n)) return null;\n const amount = (n / 1_000_000).toFixed(2);\n return `${amount}${currency ? \" \" + currency : \"\"}`;\n}\n\n// ISO 3166-1 alpha-2 country code → flag emoji (e.g. \"US\" → 🇺🇸). Best-effort.\nfunction flagEmoji(cc?: string): string {\n if (!cc || cc.length !== 2 || !/^[A-Za-z]{2}$/.test(cc)) return \"\";\n const base = 0x1f1e6;\n const up = cc.toUpperCase();\n return (\n String.fromCodePoint(base + up.charCodeAt(0) - 65) +\n String.fromCodePoint(base + up.charCodeAt(1) - 65)\n );\n}\n\nfunction regionLine(cc?: string): string | null {\n if (!cc) return null;\n const f = flagEmoji(cc);\n return `Region: ${f ? f + \" \" : \"\"}${esc(String(cc).toUpperCase())}`;\n}\n\n// Time remaining until a future timestamp, as a short human string.\nfunction relativeFromNow(ms?: number | string): string | null {\n if (ms == null) return null;\n const n = typeof ms === \"string\" ? Number(ms) : ms;\n if (!n || Number.isNaN(n)) return null;\n const diff = n - Date.now();\n const abs = Math.abs(diff);\n const day = 86_400_000, hour = 3_600_000, min = 60_000;\n let out: string;\n if (abs >= day) out = `${Math.round(abs / day)}d`;\n else if (abs >= hour) out = `${Math.round(abs / hour)}h`;\n else out = `${Math.max(1, Math.round(abs / min))}m`;\n return diff >= 0 ? `in ${out}` : `${out} ago`;\n}\n\n// ---------------------------------------------------------------------------\n// Google service-account OAuth (JWT bearer → access token), RS256 via WebCrypto\n// ---------------------------------------------------------------------------\nfunction pemToArrayBuffer(pem: string): ArrayBuffer {\n const b64 = pem\n .replace(/-----BEGIN PRIVATE KEY-----/, \"\")\n .replace(/-----END PRIVATE KEY-----/, \"\")\n .replace(/\\s+/g, \"\");\n const bin = atob(b64);\n const bytes = Uint8Array.from(bin, (c) => c.charCodeAt(0));\n return bytes.buffer;\n}\n\nfunction b64url(bytes: Uint8Array): string {\n let bin = \"\";\n for (const b of bytes) bin += String.fromCharCode(b);\n return btoa(bin).replace(/\\+/g, \"-\").replace(/\\//g, \"_\").replace(/=+$/, \"\");\n}\n\nlet cachedToken: { token: string; exp: number } | null = null;\n\nasync function getAccessToken(): Promise {\n const raw = Deno.env.get(\"GOOGLE_SERVICE_ACCOUNT_JSON\");\n if (!raw) return null;\n // Re-use a cached token while it's still valid (minus 60s safety margin)\n if (cachedToken && cachedToken.exp - 60 > Math.floor(Date.now() / 1000)) {\n return cachedToken.token;\n }\n let sa: any;\n try {\n sa = JSON.parse(raw);\n } catch {\n console.error(\"GOOGLE_SERVICE_ACCOUNT_JSON is not valid JSON\");\n return null;\n }\n const now = Math.floor(Date.now() / 1000);\n const exp = now + 3600;\n const header = { alg: \"RS256\", typ: \"JWT\" };\n const claim = {\n iss: sa.client_email,\n scope: \"https://www.googleapis.com/auth/androidpublisher\",\n aud: \"https://oauth2.googleapis.com/token\",\n iat: now,\n exp,\n };\n const enc = new TextEncoder();\n const headerB64 = b64url(enc.encode(JSON.stringify(header)));\n const claimB64 = b64url(enc.encode(JSON.stringify(claim)));\n const signingInput = `${headerB64}.${claimB64}`;\n\n try {\n const key = await crypto.subtle.importKey(\n \"pkcs8\",\n pemToArrayBuffer(sa.private_key),\n { name: \"RSASSA-PKCS1-v1_5\", hash: \"SHA-256\" },\n false,\n [\"sign\"],\n );\n const sig = await crypto.subtle.sign(\n \"RSASSA-PKCS1-v1_5\",\n key,\n enc.encode(signingInput),\n );\n const jwt = `${signingInput}.${b64url(new Uint8Array(sig))}`;\n\n const res = await fetch(\"https://oauth2.googleapis.com/token\", {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/x-www-form-urlencoded\" },\n body: new URLSearchParams({\n grant_type: \"urn:ietf:params:oauth:grant-type:jwt-bearer\",\n assertion: jwt,\n }),\n });\n const json = await res.json();\n if (!json.access_token) {\n console.error(\"Token exchange failed:\", JSON.stringify(json));\n return null;\n }\n cachedToken = { token: json.access_token, exp };\n return json.access_token;\n } catch (e) {\n console.error(\"getAccessToken failed:\", e);\n return null;\n }\n}\n\n// ---------------------------------------------------------------------------\n// Play Developer API lookups\n// ---------------------------------------------------------------------------\n// Subscriptions: the legacy v3 purchases.subscriptions.get returns price,\n// currency, expiry and auto-renew directly — the closest match to Apple's fields.\nasync function getSubscription(\n pkg: string,\n subId: string,\n token: string,\n): Promise {\n const at = await getAccessToken();\n if (!at) return null;\n const url =\n `https://androidpublisher.googleapis.com/androidpublisher/v3/applications/` +\n `${encodeURIComponent(pkg)}/purchases/subscriptions/` +\n `${encodeURIComponent(subId)}/tokens/${encodeURIComponent(token)}`;\n try {\n const res = await fetch(url, {\n headers: { Authorization: `Bearer ${at}` },\n });\n if (!res.ok) {\n console.error(\"subscriptions.get\", res.status, await res.text());\n return null;\n }\n return await res.json();\n } catch (e) {\n console.error(\"subscriptions.get failed:\", e);\n return null;\n }\n}\n\nasync function getProduct(\n pkg: string,\n productId: string,\n token: string,\n): Promise {\n const at = await getAccessToken();\n if (!at) return null;\n const url =\n `https://androidpublisher.googleapis.com/androidpublisher/v3/applications/` +\n `${encodeURIComponent(pkg)}/purchases/products/` +\n `${encodeURIComponent(productId)}/tokens/${encodeURIComponent(token)}`;\n try {\n const res = await fetch(url, {\n headers: { Authorization: `Bearer ${at}` },\n });\n if (!res.ok) {\n console.error(\"products.get\", res.status, await res.text());\n return null;\n }\n return await res.json();\n } catch (e) {\n console.error(\"products.get failed:\", e);\n return null;\n }\n}\n\n// ---------------------------------------------------------------------------\n// Telegram\n// ---------------------------------------------------------------------------\nasync function sendTelegram(text: string) {\n const TOKEN = Deno.env.get(\"TELEGRAM_BOT_TOKEN\");\n const CHAT_ID = Deno.env.get(\"TELEGRAM_CHAT_ID\");\n if (!TOKEN || !CHAT_ID) {\n console.error(\"Missing TELEGRAM_BOT_TOKEN or TELEGRAM_CHAT_ID\");\n return;\n }\n try {\n await fetch(`https://api.telegram.org/bot${TOKEN}/sendMessage`, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({\n chat_id: CHAT_ID,\n text,\n parse_mode: \"HTML\",\n disable_web_page_preview: true,\n }),\n });\n } catch (e) {\n console.error(\"Telegram send failed:\", e);\n }\n}\n\nfunction appLabel(pkg?: string): string {\n if (!pkg) return \"\";\n const name = PACKAGE_NAMES[pkg];\n return name ? `${esc(name)} (${esc(pkg)})` : esc(pkg);\n}\n\nconst DIVIDER = \"──────────\";\n\n// ---------------------------------------------------------------------------\n// HTTP handler\n// ---------------------------------------------------------------------------\nexport default async function (req: Request): Promise {\n const SECRET = Deno.env.get(\"WEBHOOK_SECRET\");\n const url = new URL(req.url);\n\n // ---- Secret check: the secret must be in the path or ?key= -------------\n if (SECRET) {\n const inPath = url.pathname.replace(/\\//g, \"\") === SECRET;\n const inQuery = url.searchParams.get(\"key\") === SECRET;\n if (!inPath && !inQuery) return new Response(\"Forbidden\", { status: 403 });\n }\n\n // ---- A GET is handy for a quick \"is it alive?\" browser check -----------\n if (req.method !== \"POST\") {\n return new Response(\"Play Store → Telegram relay is live. ✅\", {\n status: 200,\n });\n }\n\n let body: any = null;\n try {\n body = await req.json();\n } catch {\n return new Response(\"Bad JSON\", { status: 400 });\n }\n\n // Pub/Sub push envelope: { message: { data, messageId, ... }, subscription }\n const msg = body?.message;\n if (!msg?.data) {\n // Could be a Pub/Sub verification ping or empty body — ack anyway.\n return new Response(\"OK\", { status: 200 });\n }\n\n let rtdn: any = null;\n try {\n rtdn = JSON.parse(b64decodeToString(msg.data));\n } catch (e) {\n console.error(\"Failed to decode message.data:\", e);\n return new Response(\"OK\", { status: 200 }); // ack so Pub/Sub stops retrying\n }\n\n const pkg: string | undefined = rtdn.packageName;\n const eventTime = fmtDateMs(rtdn.eventTimeMillis);\n const lines: string[] = [];\n\n if (rtdn.testNotification) {\n lines.push(\"✅ Play test notification\");\n lines.push(\"Your Google Play → Telegram relay is wired up correctly.\");\n if (pkg) lines.push(`App: ${appLabel(pkg)}`);\n } else if (rtdn.subscriptionNotification) {\n const n = rtdn.subscriptionNotification;\n const type: number = n.notificationType;\n const label = SUB_TYPE_LABELS[type] || `🔔 Subscription event ${type}`;\n const note = SUB_TYPE_NOTES[type];\n const subId: string = n.subscriptionId;\n const tokenStr: string = n.purchaseToken;\n\n lines.push(`${label}`);\n if (note) lines.push(`${esc(note)}`);\n lines.push(DIVIDER);\n if (pkg) lines.push(`App: ${appLabel(pkg)}`);\n if (subId) lines.push(`Product: ${esc(subId)}`);\n\n // Enrich via the Play Developer API (best-effort)\n if (pkg && subId && tokenStr) {\n const sub = await getSubscription(pkg, subId, tokenStr);\n if (sub) {\n // Price — annotate during a free trial so a price that is NOT being\n // charged right now can't be misread as an immediate charge.\n const onTrial = sub.paymentState === 2;\n const money = fmtMoneyMicros(\n sub.priceAmountMicros,\n sub.priceCurrencyCode,\n );\n if (money) {\n lines.push(\n `Price: ${esc(money)}${\n onTrial ? \" (after free trial)\" : \"\"\n }`,\n );\n }\n\n if (sub.introductoryPriceInfo) {\n const ip = sub.introductoryPriceInfo;\n const introMoney = fmtMoneyMicros(\n ip.introductoryPriceAmountMicros,\n ip.introductoryPriceCurrencyCode,\n );\n if (introMoney) {\n const cycles = ip.introductoryPriceCycles\n ? ` ×${ip.introductoryPriceCycles}`\n : \"\";\n lines.push(`Intro price: ${esc(introMoney)}${cycles}`);\n }\n }\n\n // Payment state — surfaces free trial vs. paid, pending, etc.\n if (sub.paymentState != null) {\n const ps = PAYMENT_STATE_LABELS[sub.paymentState];\n if (ps) lines.push(`Status: ${ps}`);\n }\n\n // Started\n const started = fmtDateMs(sub.startTimeMillis);\n if (started) lines.push(`Started: ${started}`);\n\n // Renews vs. Expires depends on auto-renew, which is clearer than a\n // bare \"Expires\" for an active, renewing subscription.\n const expires = fmtDateMs(sub.expiryTimeMillis);\n if (expires) {\n const rel = relativeFromNow(sub.expiryTimeMillis);\n const relTxt = rel ? ` (${rel})` : \"\";\n if (sub.autoRenewing) lines.push(`Renews: ${expires}${relTxt}`);\n else lines.push(`Expires: ${expires}${relTxt}`);\n }\n\n if (sub.autoRenewing != null) {\n lines.push(`Auto-renew: ${sub.autoRenewing ? \"✅ ON\" : \"⛔ OFF\"}`);\n }\n\n // Why it was canceled (only present on cancellations)\n if (sub.cancelReason != null) {\n const cr = CANCEL_REASON_LABELS[sub.cancelReason];\n if (cr) lines.push(`Cancel reason: ${esc(cr)}`);\n const ct = fmtDateMs(sub.userCancellationTimeMillis);\n if (ct) lines.push(`Canceled at: ${ct}`);\n }\n\n const region = regionLine(sub.countryCode);\n if (region) lines.push(region);\n\n // Test / promo / rewarded — flags purchases that aren't real revenue.\n if (sub.purchaseType != null) {\n const pt = PURCHASE_TYPE_LABELS[sub.purchaseType];\n if (pt) lines.push(pt);\n }\n\n if (sub.orderId) {\n lines.push(`Order: ${esc(String(sub.orderId))}`);\n }\n } else {\n lines.push(\"(price/expiry lookup unavailable — see val logs)\");\n }\n }\n } else if (rtdn.oneTimeProductNotification) {\n const n = rtdn.oneTimeProductNotification;\n const type: number = n.notificationType;\n const label = ONETIME_TYPE_LABELS[type] || `🔔 One-time event ${type}`;\n const note = ONETIME_TYPE_NOTES[type];\n const sku: string = n.sku;\n const tokenStr: string = n.purchaseToken;\n\n lines.push(`${label}`);\n if (note) lines.push(`${esc(note)}`);\n lines.push(DIVIDER);\n if (pkg) lines.push(`App: ${appLabel(pkg)}`);\n if (sku) lines.push(`Product: ${esc(sku)}`);\n\n if (pkg && sku && tokenStr) {\n const prod = await getProduct(pkg, sku, tokenStr);\n if (prod) {\n if (prod.purchaseState != null) {\n const st = PRODUCT_STATE_LABELS[prod.purchaseState];\n if (st) lines.push(`Status: ${st}`);\n }\n if (prod.quantity != null && prod.quantity !== 1) {\n lines.push(`Quantity: ${esc(String(prod.quantity))}`);\n }\n const purchased = fmtDateMs(prod.purchaseTimeMillis);\n if (purchased) lines.push(`Purchased: ${purchased}`);\n const region = regionLine(prod.regionCode);\n if (region) lines.push(region);\n if (prod.purchaseType != null) {\n const pt = PURCHASE_TYPE_LABELS[prod.purchaseType];\n if (pt) lines.push(pt);\n }\n if (prod.orderId) {\n lines.push(`Order: ${esc(String(prod.orderId))}`);\n }\n } else {\n lines.push(\"(product lookup unavailable — see val logs)\");\n }\n }\n } else if (rtdn.voidedPurchaseNotification) {\n const n = rtdn.voidedPurchaseNotification;\n const refundType = n.refundType === 1\n ? \"full refund\"\n : n.refundType === 2\n ? \"partial refund\"\n : \"refund\";\n const prodType = n.productType === 1\n ? \"subscription\"\n : n.productType === 2\n ? \"one-time product\"\n : \"purchase\";\n lines.push(\"💸 Purchase voided / refunded\");\n lines.push(\"Money was returned to the user for this purchase.\");\n lines.push(DIVIDER);\n if (pkg) lines.push(`App: ${appLabel(pkg)}`);\n lines.push(`Type: ${esc(prodType)} · ${esc(refundType)}`);\n if (n.orderId) lines.push(`Order: ${esc(String(n.orderId))}`);\n } else {\n lines.push(\"🔔 Play notification\");\n lines.push(\"Unrecognized event type — raw payload below.\");\n if (pkg) lines.push(`App: ${appLabel(pkg)}`);\n lines.push(`${esc(JSON.stringify(rtdn).slice(0, 300))}`);\n }\n\n // Footer: event time (app is already shown in the body above)\n if (eventTime) {\n lines.push(DIVIDER);\n lines.push(`🕒 Event time: ${eventTime}`);\n }\n\n await sendTelegram(lines.join(\"\\n\"));\n\n // Always 200 so Pub/Sub marks the message delivered and stops retrying.\n return new Response(\"OK\", { status: 200 });\n}","deleted","label",[115],"pulls",1,"forks","envVars",{"_138":123,"_140":52},"connections",{"_138":52,"_139":52},"count","unfilledCount","emptyCount",{"_20":114,"_13":115,"_116":117,"_118":-5,"_119":21,"_120":30,"_121":108,"_22":142,"_29":123,"_124":125,"_126":127,"_128":38,"_129":-5,"_143":144,"_89":145},["D",1782240517210],"children",[],[115],["D",1782230376927],{"_11":12,"_87":83},{"_11":12,"_80":81,"_82":83,"_45":46,"_84":85,"_86":38},{"_29":30,"_13":26,"_20":21,"_27":28,"_31":-5,"_32":-5,"_75":-5,"_76":-5,"_77":-5,"_78":14,"_79":12},"ctx",{"_68":-5,"_110":183,"_184":185,"_186":187,"_188":38,"_189":38,"_190":38,"_191":108,"_192":-5,"_193":-7,"_194":-7,"_195":52,"_196":38,"_197":38,"_198":-5,"_199":38,"_200":38,"_201":38,"_202":-5},"ENV",{"_154":155,"_156":157,"_158":26,"_159":160,"_161":162,"_163":164,"_165":166,"_167":168,"_169":170,"_171":172,"_173":174,"_175":176,"_177":178,"_179":180,"_181":182},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","811aa22498c9b0b5a47e8d778de579cdb990f332","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