${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\ninterface PendingItem {\n subject: string;\n reason: string;\n firstSeenAt: string; // ISO date — when we first couldn't resolve this\n lastNotifiedAt: string; // ISO date — throttles repeat notifications\n}\n\nconst RETRY_WINDOW_HOURS = 24; // how long to keep silently retrying before giving up\nconst RENOTIFY_HOURS = 4; // how often to re-include a still-unresolved item in the summary email\n\nfunction hoursSince(iso: string): number {\n return (Date.now() - new Date(iso).getTime()) / (1000 * 60 * 60);\n}\n\nasync function processOrders() {\n const token = await getGraphToken();\n // processedIds = emails that resulted in an actual Breww order (accepted\n // or deliberately left as draft) or were confirmed noise — these are\n // truly done and marked read, never revisited.\n const processedIds: string[] =\n (await blob.getJSON(\"lifeblood_orders_processed\")) ?? [];\n // pending = emails that look like an order but couldn't be resolved yet\n // (unmatched customer, missing price book, unparseable lines...). Left\n // UNREAD deliberately, so every run retries them automatically — if you\n // fix the underlying Breww record, the very next run picks it up without\n // you needing to do anything else. Only stops retrying after\n // RETRY_WINDOW_HOURS, so a genuinely bad email doesn't retry forever.\n const pending: Record =\n (await blob.getJSON(\"lifeblood_orders_pending\")) ?? {};\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 getRecentOrderEmails(token);\n const allCustomers = await getAllBrewwCustomers();\n const customersById = new Map(allCustomers.map((c) => [c.id, c]));\n const products = await getBrewwProducts();\n\n const processed: ProcessedItem[] = [];\n const review: ReviewItem[] = []; // only items to actually include in this run's email\n\n // Records an unresolved attempt: on first sighting, or once the retry\n // window has expired, or on cadence via RENOTIFY_HOURS, it's included in\n // this run's email; otherwise it retries silently in the background.\n async function markUnresolved(email: any, reason: string) {\n const existing = pending[email.id];\n const now = new Date().toISOString();\n\n if (!existing) {\n pending[email.id] = {\n subject: email.subject,\n reason,\n firstSeenAt: now,\n lastNotifiedAt: now,\n };\n review.push({\n subject: email.subject,\n reason: `${reason} (will keep retrying automatically)`,\n messageId: email.id,\n });\n return;\n }\n\n existing.reason = reason; // keep the latest reason, in case it changed\n if (hoursSince(existing.firstSeenAt) >= RETRY_WINDOW_HOURS) {\n // Given up — stop retrying, mark done, flag for a human definitively.\n review.push({\n subject: email.subject,\n reason:\n `${reason} — unresolved after ${RETRY_WINDOW_HOURS}h of retrying, needs manual handling in Breww`,\n messageId: email.id,\n });\n delete pending[email.id];\n await markRead(token, email.id);\n processedIds.push(email.id);\n return;\n }\n\n if (hoursSince(existing.lastNotifiedAt) >= RENOTIFY_HOURS) {\n existing.lastNotifiedAt = now;\n review.push({\n subject: email.subject,\n reason: `${reason} (still retrying)`,\n messageId: email.id,\n });\n }\n // else: still within the retry window and recently notified — retry\n // silently, no email noise this run.\n }\n\n for (const email of emails) {\n if (processedIds.includes(email.id)) continue;\n\n try {\n const receivedAgeDays =\n (Date.now() - new Date(email.receivedDateTime).getTime()) /\n (1000 * 60 * 60 * 24);\n if (receivedAgeDays > MAX_EMAIL_AGE_DAYS) {\n // Too old to safely auto-process — almost certainly already\n // handled manually before this automation existed. Mark done so\n // it's never reconsidered, but never act on it.\n delete pending[email.id];\n await markRead(token, email.id);\n processedIds.push(email.id);\n continue;\n }\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 orderText = await getOrderText(token, email);\n if (!orderText) continue; // nothing to read at all — skip silently, not worth flagging\n\n // Include the subject line in the text used for matching — customers\n // (and Chris's own tests) sometimes only reference who the order is\n // for in the subject (\"Order for Temple Clinic\") rather than the\n // body, and that's a genuine identifying signal that was previously\n // being ignored entirely.\n const matchText = `${email.subject ?? \"\"}. ${orderText}`;\n\n // Fast path: we've matched this sender domain to a customer before.\n // Guards against a previously-poisoned cache entry (e.g. an excluded\n // ID like Soda Fountain Ltd got cached before that exclusion\n // existed) by ignoring any cached match that's since been excluded.\n let account: BrewwCustomer | null = null;\n const senderEmail = email.from?.emailAddress?.address ?? \"\";\n\n // Most reliable signal first: does this exact sender email match a\n // customer's own recorded email address in Breww? This can't be\n // thrown off by casual wording or a signature block the way scanning\n // free text can.\n account = findCustomerByEmail(allCustomers, senderEmail);\n\n if (\n !account &&\n !NO_CACHE_DOMAINS.includes(senderDomain) &&\n domainCache[senderDomain] &&\n !EXCLUDED_CUSTOMER_IDS.includes(domainCache[senderDomain])\n ) {\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, matchText);\n if (\n account && senderDomain && !NO_CACHE_DOMAINS.includes(senderDomain)\n ) {\n domainCache[senderDomain] = account.id; // learn it for next time\n }\n }\n\n const lines = extractLines(matchText);\n\n // No customer AND no order lines found at all — this is almost\n // certainly not an order (a newsletter, a marketing email, general\n // correspondence). Skip silently and permanently, rather than\n // retrying inbox noise forever.\n if (!account && lines.length === 0) {\n delete pending[email.id];\n await markRead(token, email.id);\n processedIds.push(email.id);\n continue;\n }\n\n if (!account) {\n await markUnresolved(\n email,\n \"Found what looks like order quantities, but could not confidently match a customer — \" +\n \"either they're not in Breww yet, or their name matched more than one record.\",\n );\n continue;\n }\n if (!account.price_book_in_use?.id) {\n await markUnresolved(\n email,\n `Matched customer \"${account.name}\" but they have no price book set in Breww`,\n );\n continue;\n }\n if (lines.length === 0) {\n const preview = matchText.replace(/\\s+/g, \" \").trim().slice(0, 150);\n const diagnosis = diagnoseExtraction(matchText);\n await markUnresolved(\n email,\n `Matched customer \"${account.name}\" but could not parse any order lines. ` +\n `Text seen: \"${preview}\" | Per-flavour: ${diagnosis}`,\n );\n continue;\n }\n\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 await markUnresolved(\n email,\n \"One or more product lines could not be matched confidently\",\n );\n continue;\n }\n\n const poNumberMatch = orderText.match(/Order number\\s*\\n?\\s*([\\w-]+)/i);\n const realPoNumber = poNumberMatch?.[1] ?? null; // only set when genuinely found in the order text\n // Breww still needs *some* po_number value for the duplicate-guard to\n // key on, even for informal orders with no real PO reference — falls\n // back to a stable per-email identifier, never shown to the customer.\n const poNumberForBreww = realPoNumber ?? `email-${email.id}`;\n\n const order = await createOrder(\n account.id,\n account.price_book_in_use!.id,\n poNumberForBreww,\n orderLines,\n );\n\n if (!order?.id) {\n await markUnresolved(email, \"Breww order creation failed\");\n continue;\n }\n\n if (order._duplicate) {\n // Already exists in Breww (likely created manually before this val\n // existed, or before this dedup safeguard was added) — don't touch\n // it, just mark this email resolved so we stop re-checking it.\n delete pending[email.id];\n await markRead(token, email.id);\n processedIds.push(email.id);\n continue;\n }\n\n // From here on, an order genuinely exists in Breww — this email is\n // resolved either way (accepted or deliberately left draft), so it's\n // safe to mark done and never retry, whatever happens next.\n delete pending[email.id];\n\n // Sanity checks (apply regardless of test/real):\n // - value must be a real positive number\n // - every line we submitted must actually have been created (guards\n // against a partial order — e.g. only 2 of 4 lines saved — still\n // returning what looks like a valid positive total)\n // Separately: \"test\" in the subject means never auto-accept in Breww\n // (stays Draft), but the confirmation reply still sends either way —\n // that's the point, it's how the pipeline gets verified end to end\n // without a fake order landing as Accepted.\n const isTestOrder = /test/i.test(email.subject);\n const linesCreated = Array.isArray(order.order_lines)\n ? order.order_lines.length\n : orderLines.length;\n\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 if (linesCreated !== orderLines.length) {\n review.push({\n subject: email.subject,\n reason:\n `Order ${order.number} created but only ${linesCreated} of ${orderLines.length} lines were saved — left as Draft`,\n messageId: email.id,\n });\n } else if (isTestOrder) {\n review.push({\n subject: email.subject,\n reason:\n `Order ${order.number} matched cleanly (£${order.value}) but subject contains \"test\" — left as Draft, not auto-accepted`,\n messageId: email.id,\n });\n await sendCustomerConfirmation(\n token,\n email,\n order.number,\n realPoNumber,\n );\n } else {\n await acceptOrder(order.id);\n await sendCustomerConfirmation(\n token,\n email,\n order.number,\n realPoNumber,\n );\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 } catch (err) {\n // One bad email (malformed PDF, unexpected data, etc.) should never\n // take down the whole run — log it, flag it for review, and move on\n // to the next email rather than crashing the entire function.\n console.error(\n `Error processing email ${email.id} (${email.subject}):`,\n err,\n );\n review.push({\n subject: email.subject,\n reason: `Unexpected error while processing: ${String(err)}`,\n messageId: email.id,\n });\n }\n }\n\n await blob.setJSON(\"lifeblood_orders_processed\", processedIds.slice(-500)); // keep log bounded\n await blob.setJSON(\"lifeblood_orders_pending\", pending);\n await blob.setJSON(\"lifeblood_customer_domain_cache\", domainCache);\n await sendSummaryEmail(token, processed, review);\n\n return {\n processed: processed.length,\n review: review.length,\n stillPending: Object.keys(pending).length,\n };\n}\n\n// Cron val entry point. Val Town cron triggers call this with an Interval\n// object ({ lastRunAt: Date | undefined }) on the schedule set in the val's\n// Cron trigger settings, and ignore whatever is returned.\nexport default async function (interval: { lastRunAt?: Date }) {\n return await processOrders();\n}","deleted","label",[113],"pulls",1,"forks","envVars",{"_137":139,"_140":52},"connections",{"_137":52,"_138":52},"count","unfilledCount",2,"emptyCount",{"_20":112,"_13":113,"_114":115,"_116":-5,"_117":21,"_118":30,"_119":120,"_22":142,"_29":122,"_123":124,"_125":126,"_127":38,"_128":-5,"_143":144,"_88":145},["D",1788485986080],"children",[],[113],["D",1788469719673],{"_11":12,"_86":82},{"_11":12,"_80":-5,"_81":82,"_45":46,"_83":84,"_85":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,"_108":183,"_184":185,"_186":187,"_188":38,"_189":38,"_190":38,"_191":120,"_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","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"]

Branches1

Branches
1