One at a time: ${\n g.members.map(\n (m) =>\n `${\n escapeHtml(m.share.name)\n }`,\n ).join(\" \\xB7 \")\n }

`;\n return `\n

${\n escapeHtml(names)\n }

${escapeHtml(handles)}

\n Request $${\n escapeHtml(g.amount)\n }${alone ? \"\" : ` from ${g.members.length}`}\n ${fallback}\n

`;\n }).join(\"\");\n const tapCount = groups.length === 1 ? \"one tap\" : `${groups.length} taps`;\n return `\n\n\n

Google Fi \\u2014 ${\n escapeHtml(month)\n }

\n Bill ${formatCents(billTotalCents)} \\xB7 collecting ${\n formatCents(collecting)\n } \\xB7\n your share ${formatCents(owner.totalCents)}\n

\n ${banner}\n ${cards}\n

\n ${tapCount} to collect ${\n formatCents(collecting)\n }. Each button opens Venmo with the\n request prefilled \\u2014 nothing is sent until you confirm in the app.\n

\n\n`;\n}\nfunction renderBanner(changes, isFirstRun) {\n if (isFirstRun) {\n return `

\n First run \\u2014 nothing to compare against yet. From next month you'll see any amount that moved.\n

`;\n }\n if (changes.length === 0) return \"\";\n const items = changes.map((c) =>\n `

${escapeHtml(describeChange(c))}

`\n ).join(\"\");\n return `

Amounts changed since last month

${items}\n

`;\n}\nfunction renderEmailText(input) {\n const { month, charges, owner, billTotalCents, changes, isFirstRun } = input;\n const collecting = charges.reduce((sum, c) => sum + c.share.totalCents, 0);\n const lines = [\n `Google Fi \\u2014 ${month}`,\n `Bill ${formatCents(billTotalCents)} \\xB7 collecting ${\n formatCents(collecting)\n } \\xB7 your share ${formatCents(owner.totalCents)}`,\n \"\",\n ];\n if (isFirstRun) {\n lines.push(\"First run \\u2014 nothing to compare against yet.\", \"\");\n } else if (changes.length > 0) {\n lines.push(\"Amounts changed since last month:\");\n lines.push(...changes.map((c) => ` - ${describeChange(c)}`));\n lines.push(\"\");\n }\n for (const g of groupCharges(charges)) {\n const alone = g.members.length === 1;\n lines.push(\n `${listNames(g.members.map((m) => m.share.name))} \\u2014 $${g.amount}${\n alone ? \"\" : \" each\"\n }`,\n );\n lines.push(` ${g.link}`);\n if (!alone) {\n lines.push(\" One at a time:\");\n lines.push(...g.members.map((m) => ` ${m.share.name}: ${m.link}`));\n }\n lines.push(\"\");\n }\n lines.push(\n \"Each link opens Venmo with the request prefilled. Nothing is sent until you confirm.\",\n );\n return lines.join(\"\\n\");\n}\n\n// src/history.ts\nvar KEEP = 2;\nfunction updateHistory(history, current) {\n const records = history ?? [];\n const isRepeat = records.some((r) =>\n r.statementDate === current.statementDate\n );\n const baseline = records.find((r) =>\n r.statementDate !== current.statementDate\n );\n return {\n baseline,\n isRepeat,\n next: isRepeat ? records : [current, ...records].slice(0, KEEP),\n };\n}\n\n// src/process.ts\nvar FORWARDING_CONFIRMATION_SENDER = \"forwarding-noreply@google.com\";\nfunction addressOf(from) {\n const angled = /<([^>]+)>/.exec(from);\n return (angled?.[1] ?? from).trim().toLowerCase();\n}\nfunction findPdf(attachments) {\n const pdfs = attachments.filter(\n (a) => a.type === \"application/pdf\" || /\\.pdf$/i.test(a.name),\n );\n if (pdfs.length === 0) {\n throw new Error(\n \"No PDF attachment. The Fi statement carries the per-member breakdown as an attachment; the email body has only the total.\",\n );\n }\n if (pdfs.length > 1) {\n throw new Error(`Expected one PDF attachment, found ${pdfs.length}.`);\n }\n return pdfs[0];\n}\nasync function processStatement(message, deps2) {\n const sender = addressOf(message.from);\n if (sender === FORWARDING_CONFIRMATION_SENDER) {\n await deps2.send({\n subject: \"google-fi-group-repay: Gmail forwarding confirmation\",\n text: [\n \"Gmail sent a forwarding confirmation to the google-fi-group-repay address.\",\n \"Copy the code or link below into Gmail's forwarding settings.\",\n \"\",\n message.text ?? \"(no text body)\",\n ].join(\"\\n\"),\n });\n return { status: \"confirmation\" };\n }\n if (!deps2.allowedSenders.includes(sender)) {\n return { status: \"ignored\", reason: `sender ${sender} is not allowed` };\n }\n const pdf = findPdf(message.attachments);\n const { statementDate, ...bill } = await deps2.parsePdf(await pdf.bytes());\n const shares = computeShares(bill, deps2.config);\n const owner = shares.find((s) => s.isOwner);\n const charges = buildCharges(\n chargeable(shares),\n deps2.config.noteTemplate,\n bill.month,\n );\n const record = {\n statementDate,\n people: bill.people,\n total: bill.total,\n };\n const { baseline, isRepeat, next } = updateHistory(\n await deps2.getHistory(),\n record,\n );\n const changes = diffAmounts(baseline?.people, bill.people);\n const isFirstRun = baseline === void 0;\n const input = {\n month: bill.month,\n charges,\n owner,\n billTotalCents: shares.reduce((sum, s) => sum + s.totalCents, 0),\n changes,\n isFirstRun,\n };\n const subject = buildSubject(bill.month, bill.total, changes, isFirstRun);\n await deps2.send({\n subject: isRepeat ? `${subject} (repeat)` : subject,\n html: renderEmailHtml(input),\n text: renderEmailText(input),\n });\n if (!isRepeat) await deps2.saveHistory(next);\n return {\n status: \"sent\",\n month: bill.month,\n charged: charges.length,\n isRepeat,\n };\n}\n\n// src/val.ts\nvar BLOB_KEY = \"fi-group-repay:statements\";\nvar DEFAULT_SENDERS = [\"payments-noreply@google.com\"];\nfunction allowedSenders() {\n const configured = Deno.env.get(\"FI_GROUP_REPAY_ALLOWED_SENDERS\");\n if (!configured) return DEFAULT_SENDERS;\n return configured.split(\",\").map((s) => s.trim().toLowerCase()).filter(\n Boolean,\n );\n}\nfunction loadConfig() {\n const raw = Deno.env.get(\"FI_GROUP_REPAY_CONFIG\");\n if (!raw) {\n throw new Error(\n \"FI_GROUP_REPAY_CONFIG is not set. It should hold the contents of config.json.\",\n );\n }\n try {\n return JSON.parse(raw);\n } catch (error) {\n throw new Error(\n `FI_GROUP_REPAY_CONFIG is not valid JSON: ${\n error instanceof Error ? error.message : String(error)\n }`,\n );\n }\n}\nfunction adapt(message) {\n return {\n from: message.from,\n subject: message.subject,\n text: message.text,\n attachments: message.attachments.map((file) => ({\n name: file.name,\n type: file.type,\n bytes: async () => new Uint8Array(await file.arrayBuffer()),\n })),\n };\n}\nfunction deps() {\n return {\n config: loadConfig(),\n allowedSenders: allowedSenders(),\n parsePdf: parseStatementPdf,\n getHistory: () => blob.getJSON(BLOB_KEY),\n saveHistory: (next) => blob.setJSON(BLOB_KEY, next),\n send: async ({ subject, text, html }) => {\n await email(html ? { subject, text, html } : { subject, text });\n },\n };\n}\nasync function reportFailure(message, error) {\n const detail = error instanceof Error\n ? error.stack ?? error.message\n : String(error);\n console.error(detail);\n await email({\n subject: \"google-fi-group-repay failed to process a Google Fi statement\",\n text: [\n \"google-fi-group-repay could not turn the attached statement into charge links.\",\n \"\",\n `From: ${message.from}`,\n `Subject: ${message.subject ?? \"(none)\"}`,\n `Files: ${\n message.attachments.map((a) => a.name).join(\", \") || \"(none)\"\n }`,\n \"\",\n detail,\n \"\",\n \"The bill still needs collecting \\u2014 open the statement and request manually.\",\n ].join(\"\\n\"),\n });\n}\nasync function handleStatement(message) {\n try {\n const result = await processStatement(adapt(message), deps());\n console.log(JSON.stringify(result));\n } catch (error) {\n await reportFailure(message, error);\n }\n}\nexport { handleStatement as default };","label","fi-group-repay-dyflzlk0",[18],"pulls","branches","forks","envVars",{"_278":85,"_280":26},"connections",{"_278":26,"_279":26},"count","unfilledCount","emptyCount",{"_47":261,"_13":18,"_75":76,"_57":-5,"_49":50,"_262":184,"_263":264,"_51":282,"_53":177,"_77":90,"_266":267,"_79":24,"_268":269,"_283":284,"_17":285},["D",1787726523984],"children",[],[18],["D",1787558240601],["D",1789562426294],{"_11":12,"_239":82},{"_11":12,"_234":235,"_81":82,"_30":80,"_236":237,"_238":24},{"_53":184,"_13":16,"_47":50,"_226":190,"_227":-5,"_228":-5,"_229":-5,"_230":-5,"_231":-5,"_232":14,"_233":12},"ctx",{"_65":-5,"_258":324,"_325":326,"_327":328,"_329":24,"_330":24,"_331":24,"_332":264,"_333":-5,"_334":-7,"_335":-7,"_336":26,"_337":24,"_338":24,"_339":-5,"_340":24,"_341":24,"_342":24,"_343":-5},"ENV",{"_295":296,"_297":298,"_299":16,"_300":301,"_302":303,"_304":305,"_306":307,"_308":309,"_310":311,"_312":313,"_314":315,"_316":317,"_318":319,"_320":321,"_322":323},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","fdb67791413f4386b4dbf18f354029a617f6160f","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"]

History · main.ts