${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\nasync function processOrders() {\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}\n\n// HTTP val entry point. Val Town HTTP vals must return a Response — this is\n// what the earlier plain-object return was missing, causing the 400s in\n// the logs. Runs the same processing logic either way; call this val's URL\n// manually to trigger a run, or set up a Cron Trigger on it in Val Town's\n// val settings (Cron Triggers work on HTTP vals — no need to recreate this\n// as a separate val type) to run it automatically, e.g. every 15 minutes.\nexport default async function (req: Request): Promise {\n try {\n const result = await processOrders();\n return new Response(JSON.stringify(result), {\n status: 200,\n headers: { \"Content-Type\": \"application/json\" },\n });\n } catch (err) {\n console.error(err);\n return new Response(\n JSON.stringify({ error: String(err) }),\n { status: 500, headers: { \"Content-Type\": \"application/json\" } },\n );\n }\n}","label",[126],"pulls","branches",1,"forks","envVars",{"_145":147,"_148":61},"connections",{"_145":61,"_146":61},"count","unfilledCount",2,"emptyCount",{"_42":125,"_32":126,"_30":127,"_128":-5,"_40":41,"_39":129,"_130":48,"_37":150,"_13":132,"_33":133,"_35":134,"_24":48,"_135":-5,"_151":152,"_27":153},["D",1788471098891],"children",[],[126],["D",1788469719673],{"_95":94,"_102":98},{"_95":94,"_96":-5,"_97":98,"_18":55,"_99":100,"_101":48},{"_13":84,"_32":85,"_42":41,"_86":43,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":44,"_93":94},"ctx",{"_77":-5,"_121":191,"_192":193,"_194":195,"_196":48,"_197":48,"_198":48,"_199":25,"_200":-5,"_201":-7,"_202":-7,"_203":61,"_204":48,"_205":48,"_206":-5,"_207":48,"_208":48,"_209":48,"_210":-5},"ENV",{"_162":163,"_164":165,"_166":85,"_167":168,"_169":170,"_171":172,"_173":174,"_175":176,"_177":178,"_179":180,"_181":182,"_183":184,"_185":186,"_187":188,"_189":190},"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 · v11