${r}

`).join(\"\");\n const processedRows = rows(\n processed.map(\n (p) =>\n `${p.subject} — Order ${p.orderNumber}, £${\n p.total.toFixed(2)\n } — ` +\n `view in Breww`,\n ),\n );\n const reviewRows = rows(\n review.map((r) => `${r.subject} — needs manual review: ${r.reason}`),\n );\n\n const html = `\n

B2B order processing run — ${new Date().toISOString()}

\n ${\n processed.length\n ? `

Auto-accepted (${processed.length})

${processedRows}`\n : \"\"\n }\n ${\n review.length\n ? `

Needs manual review (${review.length})

${reviewRows}`\n : \"\"\n }\n `;\n\n await fetch(\n `https://graph.microsoft.com/v1.0/users/${NOTIFY_FROM}/sendMail`,\n {\n method: \"POST\",\n headers: {\n Authorization: `Bearer ${token}`,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({\n message: {\n subject:\n `B2B orders processed: ${processed.length} accepted, ${review.length} need review`,\n body: { contentType: \"HTML\", content: html },\n toRecipients: [{ emailAddress: { address: NOTIFY_TO } }],\n },\n saveToSentItems: true,\n }),\n },\n );\n}\n\nexport default async function () {\n const token = await getGraphToken();\n const processedIds: string[] =\n (await blob.getJSON(\"lifeblood_orders_processed\")) ?? [];\n // Learned map of sender email domain -> Breww customer ID, built up\n // automatically as orders are matched. Makes repeat senders instant and\n // resilient to their PO wording changing between orders.\n const domainCache: Record =\n (await blob.getJSON(\"lifeblood_customer_domain_cache\")) ?? {};\n const emails = await getUnreadOrderEmails(token);\n const allCustomers = await getAllBrewwCustomers();\n const customersById = new Map(allCustomers.map((c) => [c.id, c]));\n\n const processed: ProcessedItem[] = [];\n const review: ReviewItem[] = [];\n\n for (const email of emails) {\n if (processedIds.includes(email.id)) continue;\n\n const senderDomain =\n email.from?.emailAddress?.address?.split(\"@\")[1]?.toLowerCase() ?? \"\";\n if (IGNORE_SENDER_DOMAINS.includes(senderDomain)) continue;\n if (IGNORE_SUBJECT_PATTERNS.some((p) => p.test(email.subject))) continue;\n\n const poText = await getAttachmentText(token, email.id);\n if (!poText) {\n review.push({\n subject: email.subject,\n reason: \"No readable PDF attachment\",\n messageId: email.id,\n });\n continue;\n }\n\n // Fast path: we've matched this sender domain to a customer before.\n let account: BrewwCustomer | null = null;\n if (domainCache[senderDomain]) {\n account = customersById.get(domainCache[senderDomain]) ?? null;\n }\n // Otherwise, fuzzy-match against the live customer list. This is what\n // makes brand-new customers work with zero setup — no table to update.\n if (!account) {\n account = findCustomerInText(allCustomers, poText);\n if (account && senderDomain) {\n domainCache[senderDomain] = account.id; // learn it for next time\n }\n }\n\n if (!account) {\n review.push({\n subject: email.subject,\n reason:\n \"Could not confidently match a customer — either they're not in Breww yet, \" +\n \"or their name matched more than one record. Create/fix the customer record, \" +\n \"then re-forward or let the next run pick it up.\",\n messageId: email.id,\n });\n await markRead(token, email.id);\n processedIds.push(email.id);\n continue;\n }\n if (!account.price_book_in_use?.id) {\n review.push({\n subject: email.subject,\n reason:\n `Matched customer \"${account.name}\" but they have no price book set in Breww`,\n messageId: email.id,\n });\n await markRead(token, email.id);\n processedIds.push(email.id);\n continue;\n }\n\n const lines = extractLines(poText);\n if (lines.length === 0) {\n review.push({\n subject: email.subject,\n reason: \"Could not parse any order lines\",\n messageId: email.id,\n });\n await markRead(token, email.id);\n processedIds.push(email.id);\n continue;\n }\n\n const products = await getBrewwProducts();\n const orderLines: { product: number; quantity: number }[] = [];\n let allMatched = true;\n for (const line of lines) {\n const product = products.find((p: any) =>\n p.name?.toLowerCase().includes(line.flavour.toLowerCase()) &&\n p.name?.toLowerCase().includes(\"12 x 330ml\")\n );\n if (!product) {\n allMatched = false;\n break;\n }\n orderLines.push({ product: product.id, quantity: line.quantity });\n }\n\n if (!allMatched) {\n review.push({\n subject: email.subject,\n reason: \"One or more product lines could not be matched confidently\",\n messageId: email.id,\n });\n await markRead(token, email.id);\n processedIds.push(email.id);\n continue;\n }\n\n const poNumberMatch = poText.match(/Order number\\s*\\n?\\s*([\\w-]+)/i);\n const poNumber = poNumberMatch?.[1] ?? email.subject;\n\n const order = await createOrder(\n account.id,\n account.price_book_in_use!.id,\n poNumber,\n orderLines,\n );\n\n if (!order?.id) {\n review.push({\n subject: email.subject,\n reason: \"Breww order creation failed\",\n messageId: email.id,\n });\n await markRead(token, email.id);\n processedIds.push(email.id);\n continue;\n }\n\n // Sanity check: total should roughly match quantity * book price sum.\n // If Breww's returned value is 0 or wildly off, don't auto-accept.\n if (!order.value || order.value <= 0) {\n review.push({\n subject: email.subject,\n reason:\n `Order ${order.number} created but value looks wrong (£${order.value}) — left as Draft`,\n messageId: email.id,\n });\n } else {\n await acceptOrder(order.id);\n processed.push({\n subject: email.subject,\n orderNumber: order.number,\n orderId: order.id,\n total: order.value,\n breww_url: `https://app.breww.com/orders/${order.id}/`,\n });\n }\n\n await markRead(token, email.id);\n processedIds.push(email.id);\n }\n\n await blob.setJSON(\"lifeblood_orders_processed\", processedIds.slice(-500)); // keep log bounded\n await blob.setJSON(\"lifeblood_customer_domain_cache\", domainCache);\n await sendSummaryEmail(token, processed, review);\n\n return { processed: processed.length, review: review.length };\n}",[31],"pulls","branches","forks","envVars",{"_149":133,"_151":63},"connections",{"_149":63,"_150":63},"count","unfilledCount","emptyCount",{"_45":136,"_34":31,"_32":137,"_130":-5,"_43":44,"_42":133,"_131":27,"_40":158,"_13":139,"_35":36,"_37":140,"_24":27,"_134":-5,"_155":159,"_28":160},{"_45":129,"_34":29,"_32":33,"_130":-5,"_43":44,"_42":14,"_131":27,"_40":154,"_13":133,"_35":39,"_37":38,"_24":27,"_134":-5,"_155":156,"_28":157},["D",1788470786902],"children",[],[29],["D",1788469743554],[],[31],["D",1788469719673],{"_97":96,"_104":100},{"_97":96,"_98":-5,"_99":100,"_18":57,"_101":102,"_103":27},{"_13":86,"_34":87,"_45":44,"_88":46,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":47,"_95":96},"ctx",{"_79":-5,"_124":198,"_199":200,"_201":202,"_203":27,"_204":27,"_205":27,"_206":25,"_207":-5,"_208":-7,"_209":-7,"_210":63,"_211":27,"_212":27,"_213":-5,"_214":27,"_215":27,"_216":27,"_217":-5},"ENV",{"_169":170,"_171":172,"_173":87,"_174":175,"_176":177,"_178":179,"_180":181,"_182":183,"_184":185,"_186":187,"_188":189,"_190":191,"_192":193,"_194":195,"_196":197},"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"]

Diff · v5