[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8},"actionData","errors","root",{"_106":107,"_108":109},"routes/embed.x.$handle.$name.$",{"_9":10,"_11":12,"_13":14,"_15":16,"_17":18,"_19":20,"_21":-5},"handle","odeik","name","form-handler-infinitepay-sqlite-resend","path","db.ts","project",{"_22":45,"_11":12,"_33":46,"_47":-5,"_48":42,"_49":50,"_51":50,"_52":53,"_54":-5,"_55":56,"_57":58,"_59":32,"_60":-5,"_61":-5,"_62":63,"_64":65,"_66":67,"_68":69,"_70":71,"_72":-5,"_73":74,"_75":74,"_76":77,"_78":77,"_79":77,"_80":74,"_81":74,"_82":83,"_84":85,"_86":87,"_88":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/odeik/form-handler-infinitepay-sqlite-resend/code/db.ts","extension","id","948ad8f5-7602-4111-adec-207c0adefdd3","fileId","0fc96a8c-afb0-11f1-a2b2-1607ee4eb77e","parentId","branchId","1b502c53-2456-4abd-b47d-8024fbca1832","branchVersion",24,"latest",true,"createdAt",["D",1789334266671],"version",5,"fileType","script","content","/**\n * SQLite helpers for the InfinitePay checkout.\n *\n * The schema lives in ./schema.sql and nowhere else — run it once by hand in the\n * Val Town SQLite console. This file deliberately does not create tables: doing\n * that on cold start meant five DDL writes before any request could be served,\n * and a second copy of the DDL to keep in sync. A missing table now surfaces as\n * a fast \"no such table\" error rather than a hang.\n */\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\n/** A book priced for a specific quantity. */\nexport interface Bundle {\n book_slug: string;\n title: string;\n units: number;\n /** Per copy at this quantity: the bundle discount if one exists, else the base. */\n unit_price_cents: number;\n /** True when a bundle_discounts row applied. */\n discounted: boolean;\n}\n\nexport interface Order {\n order_nsu: string;\n created_at: string;\n book_slug: string;\n quantity: number;\n amount_cents: number;\n customer_name: string;\n customer_email: string;\n customer_phone: string | null;\n dedicatoria: string | null;\n cep: string | null;\n street: string | null;\n neighborhood: string | null;\n number: string | null;\n complement: string | null;\n city: string | null;\n state: string | null;\n referral: string | null;\n checkout_url: string | null;\n status: \"pending\" | \"paid\";\n paid_at: string | null;\n paid_amount_cents: number | null;\n installments: number | null;\n capture_method: string | null;\n transaction_nsu: string | null;\n invoice_slug: string | null;\n receipt_url: string | null;\n seller_email_sent_at: string | null;\n buyer_email_sent_at: string | null;\n}\n\n/** std/sqlite returns rows as arrays plus a `columns` list; zip them up. */\nfunction toObjects(result: { columns: string[]; rows: unknown[][] }): T[] {\n return result.rows.map((row) => {\n const obj: Record = {};\n result.columns.forEach((col, i) => (obj[col] = row[i]));\n return obj as T;\n });\n}\n\nasync function query(sql: string, args: unknown[] = []): Promise {\n const result = await sqlite.execute({ sql, args });\n return toObjects(result as { columns: string[]; rows: unknown[][] });\n}\n\nasync function run(sql: string, args: unknown[] = []): Promise {\n await sqlite.execute({ sql, args });\n}\n\n/** Smallest possible round trip, for the health check's ?db=1 probe. */\nexport async function selectOne(): Promise {\n await run(`SELECT 1`);\n}\n\n/* ----------------------------------------------------------------- catalog */\n\n/**\n * Price `units` copies of a book.\n *\n * bundle_discounts is an override, not a catalogue: a quantity with no row\n * there is still sellable at the product's base price. The LEFT JOIN is what\n * makes that work — COALESCE picks the discount when one exists.\n */\nexport async function getBundle(\n bookSlug: string,\n units: number,\n): Promise {\n const rows = await query(\n `SELECT p.book_slug,\n p.title,\n ? AS units,\n COALESCE(d.unit_price_cents, p.unit_price_cents) AS unit_price_cents,\n d.unit_price_cents IS NOT NULL AS discounted\n FROM products p\n LEFT JOIN bundle_discounts d\n ON d.book_slug = p.book_slug AND d.units = ? AND d.active = 1\n WHERE p.book_slug = ? AND p.active = 1\n LIMIT 1`,\n [units, units, bookSlug],\n );\n const row = rows[0];\n return row ? { ...row, discounted: Boolean(row.discounted) } : null;\n}\n\n/* ------------------------------------------------------------------ orders */\n\nexport async function insertOrder(order: {\n order_nsu: string;\n book_slug: string;\n quantity: number;\n amount_cents: number;\n customer_name: string;\n customer_email: string;\n customer_phone: string | null;\n dedicatoria: string | null;\n cep: string | null;\n street: string | null;\n neighborhood: string | null;\n number: string | null;\n complement: string | null;\n city: string | null;\n state: string | null;\n referral: string | null;\n}): Promise {\n await run(\n `INSERT INTO orders (\n order_nsu, book_slug, quantity, amount_cents,\n customer_name, customer_email, customer_phone, dedicatoria,\n cep, street, neighborhood, number, complement, city, state, referral\n ) VALUES (?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)`,\n [\n order.order_nsu,\n order.book_slug,\n order.quantity,\n order.amount_cents,\n order.customer_name,\n order.customer_email,\n order.customer_phone,\n order.dedicatoria,\n order.cep,\n order.street,\n order.neighborhood,\n order.number,\n order.complement,\n order.city,\n order.state,\n order.referral,\n ],\n );\n}\n\nexport async function setCheckoutUrl(\n orderNsu: string,\n url: string,\n): Promise {\n await run(`UPDATE orders SET checkout_url = ? WHERE order_nsu = ?`, [\n url,\n orderNsu,\n ]);\n}\n\nexport async function getOrder(orderNsu: string): Promise {\n const rows = await query(\n `SELECT * FROM orders WHERE order_nsu = ? LIMIT 1`,\n [orderNsu],\n );\n return rows[0] ?? null;\n}\n\n/**\n * Move an order to `paid`. The `status = 'pending'` guard makes this idempotent:\n * a replayed webhook updates zero rows, so no duplicate email is ever queued.\n */\nexport async function markPaid(orderNsu: string, payment: {\n paid_amount_cents: number | null;\n installments: number | null;\n capture_method: string | null;\n transaction_nsu: string | null;\n invoice_slug: string | null;\n receipt_url: string | null;\n}): Promise {\n await run(\n `UPDATE orders\n SET status = 'paid',\n paid_at = datetime('now'),\n paid_amount_cents = ?,\n installments = ?,\n capture_method = ?,\n transaction_nsu = ?,\n invoice_slug = ?,\n receipt_url = ?\n WHERE order_nsu = ? AND status = 'pending'`,\n [\n payment.paid_amount_cents,\n payment.installments,\n payment.capture_method,\n payment.transaction_nsu,\n payment.invoice_slug,\n payment.receipt_url,\n orderNsu,\n ],\n );\n}\n\n/** Paid orders still waiting on one of the two notification emails. */\nexport function ordersNeedingEmail(\n column: \"seller_email_sent_at\" | \"buyer_email_sent_at\",\n limit = 10,\n): Promise {\n return query(\n `SELECT * FROM orders\n WHERE status = 'paid' AND ${column} IS NULL\n ORDER BY paid_at ASC\n LIMIT ?`,\n [limit],\n );\n}\n\nexport async function markEmailSent(\n orderNsu: string,\n column: \"seller_email_sent_at\" | \"buyer_email_sent_at\",\n): Promise {\n await run(\n `UPDATE orders SET ${column} = datetime('now') WHERE order_nsu = ?`,\n [orderNsu],\n );\n}","deleted",false,"label",[14],"639ca8a8-1138-4d2c-8f90-70d7c3fd0872",["D",1789320759226],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Handles a web form, and sends a Resend confirmation email.","imageUrl","userId","019c60b1-a4d0-7731-935c-3d10ad61d034","pinnedFileId","1df4ed5a-af99-11f1-b5cd-1607ee4eb77e","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","019c60b1-a4d0-7731-935c-42775a719a84","tursoName","639ca8a811384d2c8f9070d7c3fd0872","tursoHostname","639ca8a811384d2c8f9070d7c3fd0872-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789494690166],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_9":10,"_105":101},"org",{"_9":10,"_99":-5,"_100":101,"_55":56,"_102":103,"_104":42},"branch",{"_35":89,"_11":90,"_22":28,"_91":45,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":-5,"_97":12,"_98":10},"isOwned",28,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","avatar","https://img.clerk.com/eyJ0eXBlIjoicHJveHkiLCJzcmMiOiJodHRwczovL2ltYWdlcy5jbGVyay5kZXYvb2F1dGhfZ2l0aHViL2ltZ18zOWhXUmxoUktmbGZNZFRQWnhlYWJFeWpGSjAifQ","tier","free","canRestrictVals","profileImageUrl","ctx",{"_82":-5,"_139":140,"_141":142,"_143":144,"_145":42,"_146":42,"_147":42,"_148":32,"_149":-5,"_150":-7,"_151":-7,"_152":63,"_153":42,"_154":42,"_155":-5,"_156":42,"_157":42,"_158":42,"_159":-5},"ENV",{"_110":111,"_112":113,"_114":90,"_115":116,"_117":118,"_119":120,"_121":122,"_123":124,"_125":126,"_127":128,"_129":130,"_131":132,"_133":134,"_135":136,"_137":138},"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"]