ACME Outdoors — Commerce Agent Demo

⛰️

\n ACME Outdoors — Ridge\n Claude commerce agent demo · modeled on anthropics/commerce-agents\n

\n \n \n view source\n

\n \n

\n \n \n \n \n

\n \n

\n \n \n\n\n",[],[209],"81a66c2f-c1cf-483a-8d5b-1301107656e1","frontend.ts","4548112e-a7d4-11f1-9f87-1607ee4eb77e",["D",1788467253259],"// frontend.ts\n// Vanilla client for the chat demo — no framework needed for a single chat\n// page. Talks to /api/chat, /api/reset, /api/forget. Renders the assistant's\n// text plus any \"events\" (present_products / view_cart / checkout) as cards,\n// in the order the agent produced them during the turn.\n\ninterface ProductCard {\n id: string;\n name: string;\n category: string;\n price: number;\n stock: number;\n attributes: Record;\n}\n\ninterface CartItem {\n product_id: string;\n name: string;\n category: string;\n price: number;\n quantity: number;\n line_total: number;\n}\n\ntype UiEvent =\n | { type: \"products\"; layout: \"carousel\" | \"list\"; message?: string; products: ProductCard[] }\n | { type: \"cart\"; items: CartItem[]; subtotal: number }\n | { type: \"checkout\"; items: CartItem[]; subtotal: number; note: string };\n\nconst SESSION_KEY = \"commerce-demo-session-id\";\n\n// Category → { icon, gradient } for the card art. Purely cosmetic — the\n// catalog has no real photography, so each category gets a distinct\n// gradient swatch and emoji instead of a broken .\nconst CATEGORY_STYLE: Record = {\n tent: { icon: \"⛺\", gradient: \"linear-gradient(135deg, #2f6fed, #1a3f8f)\" },\n backpack: { icon: \"🎒\", gradient: \"linear-gradient(135deg, #e8792a, #b6501a)\" },\n \"sleeping-bag\": { icon: \"🛏️\", gradient: \"linear-gradient(135deg, #7c53d6, #4a2a99)\" },\n footwear: { icon: \"🥾\", gradient: \"linear-gradient(135deg, #4a5568, #1f2733)\" },\n jacket: { icon: \"🧥\", gradient: \"linear-gradient(135deg, #0bb8a2, #067a6c)\" },\n cook: { icon: \"🔥\", gradient: \"linear-gradient(135deg, #e2483d, #a02318)\" },\n light: { icon: \"🔦\", gradient: \"linear-gradient(135deg, #f2b705, #c98a02)\" },\n water: { icon: \"💧\", gradient: \"linear-gradient(135deg, #1a9dff, #0b5fb0)\" },\n};\n\nfunction categoryStyle(cat: string) {\n return CATEGORY_STYLE[cat] ?? { icon: \"🏔️\", gradient: \"linear-gradient(135deg, #1a7fff, #005ebe)\" };\n}\n\nfunction getSessionId(): string {\n let id = localStorage.getItem(SESSION_KEY);\n if (!id) {\n id = crypto.randomUUID();\n localStorage.setItem(SESSION_KEY, id);\n }\n return id;\n}\n\nconst messagesEl = document.getElementById(\"messages\")!;\nconst inputEl = document.getElementById(\"input\") as HTMLInputElement;\nconst sendBtn = document.getElementById(\"send-btn\") as HTMLButtonElement;\nconst resetBtn = document.getElementById(\"reset-btn\") as HTMLButtonElement;\nconst forgetBtn = document.getElementById(\"forget-btn\") as HTMLButtonElement;\nconst debugEl = document.getElementById(\"debug\")!;\nconst suggestionsEl = document.getElementById(\"suggestions\")!;\n\nconst sessionId = getSessionId();\n\nfunction el(tag: string, className?: string): HTMLElement {\n const e = document.createElement(tag);\n if (className) e.className = className;\n return e;\n}\n\nfunction addBubble(role: \"user\" | \"assistant\" | \"system\", text: string): HTMLElement {\n const b = el(\"div\", `bubble ${role}`);\n b.textContent = text;\n messagesEl.appendChild(b);\n scrollToBottom();\n return b;\n}\n\nfunction addTyping(): HTMLElement {\n const b = el(\"div\", \"bubble assistant\");\n const dots = el(\"span\", \"typing-dots\");\n dots.innerHTML = \"\";\n b.appendChild(dots);\n messagesEl.appendChild(b);\n scrollToBottom();\n return b;\n}\n\nfunction fmtAttrKey(k: string): string {\n return k.replace(/_/g, \" \");\n}\n\nfunction fmtAttrValue(k: string, v: unknown): string {\n if (typeof v === \"boolean\") return v ? \"yes\" : \"no\";\n if (k.includes(\"weight_oz\")) return `${v} oz`;\n if (k.includes(\"waterproof_rating_mm\")) return `${v}mm`;\n if (k === \"capacity_people\") return `${v}p`;\n if (k === \"volume_l\") return `${v}L`;\n if (k === \"rating_f\") return `${v}°F`;\n return String(v);\n}\n\nfunction productCardEl(p: ProductCard): HTMLElement {\n const style = categoryStyle(p.category);\n const card = el(\"div\", \"card\") as HTMLDivElement;\n card.style.setProperty(\"--art-gradient\", style.gradient);\n\n const art = el(\"div\", \"card-art\");\n art.textContent = style.icon;\n const catChip = el(\"span\", \"cat-chip\");\n catChip.textContent = p.category.replace(/-/g, \" \");\n art.appendChild(catChip);\n\n const body = el(\"div\", \"card-body\");\n const h = el(\"h4\");\n h.textContent = p.name;\n\n const priceRow = el(\"div\", \"card-price-row\");\n const price = el(\"span\", \"price\");\n price.textContent = `$${p.price.toFixed(2)}`;\n const stock = el(\"span\", `stock-dot${p.stock > 0 ? \"\" : \" out\"}`);\n stock.textContent = p.stock > 0 ? `${p.stock} in stock` : \"out of stock\";\n priceRow.append(price, stock);\n\n const chipRow = el(\"div\", \"chip-row\");\n const attrs = Object.entries(p.attributes || {}).slice(0, 4);\n for (const [k, v] of attrs) {\n const chip = el(\"span\", \"chip\");\n chip.textContent = `${fmtAttrKey(k)}: ${fmtAttrValue(k, v)}`;\n chipRow.appendChild(chip);\n }\n\n const addBtn = el(\"button\", \"card-add\") as HTMLButtonElement;\n addBtn.textContent = p.stock > 0 ? \"+ Add to cart\" : \"Out of stock\";\n addBtn.disabled = p.stock <= 0;\n addBtn.addEventListener(\"click\", () => {\n addBtn.disabled = true;\n addBtn.textContent = \"Adding…\";\n sendMessage(`Add the ${p.name} to my cart`);\n });\n\n body.append(h, priceRow, chipRow, addBtn);\n card.append(art, body);\n return card;\n}\n\nfunction renderEvent(evt: UiEvent) {\n const wrap = el(\"div\", \"bubble event\");\n const head = el(\"div\", \"event-head\");\n\n if (evt.type === \"products\") {\n const chip = el(\"span\", \"tool-chip\");\n chip.textContent = \"present_products\";\n head.appendChild(chip);\n if (evt.message) {\n const cap = el(\"span\", \"caption\");\n cap.textContent = evt.message;\n head.appendChild(cap);\n }\n wrap.appendChild(head);\n const grid = el(\"div\", evt.layout === \"list\" ? \"list-layout\" : \"carousel\");\n for (const p of evt.products) grid.appendChild(productCardEl(p));\n wrap.appendChild(grid);\n } else if (evt.type === \"cart\") {\n const chip = el(\"span\", \"tool-chip\");\n chip.textContent = \"view_cart\";\n head.appendChild(chip);\n wrap.appendChild(head);\n wrap.appendChild(cartCard(evt.items, evt.subtotal));\n } else if (evt.type === \"checkout\") {\n const chip = el(\"span\", \"tool-chip\");\n chip.textContent = \"checkout\";\n head.appendChild(chip);\n wrap.appendChild(head);\n wrap.appendChild(cartCard(evt.items, evt.subtotal));\n const note = el(\"div\", \"checkout-note\");\n const tick = el(\"span\", \"tick\");\n tick.textContent = \"✓\";\n const text = document.createElement(\"span\");\n text.textContent = evt.note;\n note.append(tick, text);\n wrap.appendChild(note);\n }\n\n messagesEl.appendChild(wrap);\n scrollToBottom();\n}\n\nfunction cartCard(items: CartItem[], subtotal: number): HTMLElement {\n const wrap = el(\"div\", \"cart-card\");\n if (items.length === 0) {\n const empty = el(\"div\", \"empty-cart\");\n empty.textContent = \"Cart is empty.\";\n wrap.appendChild(empty);\n return wrap;\n }\n const table = document.createElement(\"table\");\n const thead = document.createElement(\"thead\");\n thead.innerHTML = \"ItemQtyPriceLine total\";\n table.appendChild(thead);\n const tbody = document.createElement(\"tbody\");\n for (const i of items) {\n const style = categoryStyle(i.category);\n const tr = document.createElement(\"tr\");\n const itemTd = document.createElement(\"td\");\n const lineItem = el(\"div\", \"line-item\");\n const icon = el(\"div\", \"line-icon\") as HTMLDivElement;\n icon.style.setProperty(\"--art-gradient\", style.gradient);\n icon.textContent = style.icon;\n const label = document.createElement(\"span\");\n label.textContent = i.name;\n lineItem.append(icon, label);\n itemTd.appendChild(lineItem);\n tr.appendChild(itemTd);\n tr.innerHTML += `${i.quantity}$${i.price.toFixed(2)}$${i.line_total.toFixed(2)}`;\n tbody.appendChild(tr);\n }\n table.appendChild(tbody);\n const tfoot = document.createElement(\"tfoot\");\n tfoot.innerHTML = `Subtotal$${subtotal.toFixed(2)}`;\n table.appendChild(tfoot);\n wrap.appendChild(table);\n return wrap;\n}\n\nfunction scrollToBottom() {\n messagesEl.scrollTop = messagesEl.scrollHeight;\n}\n\nfunction setBusy(busy: boolean) {\n inputEl.disabled = busy;\n sendBtn.disabled = busy;\n sendBtn.textContent = busy ? \"…\" : \"Send\";\n}\n\nasync function sendMessage(text: string) {\n if (!text.trim()) return;\n suggestionsEl.style.display = \"none\";\n addBubble(\"user\", text);\n setBusy(true);\n const typingEl = addTyping();\n try {\n const res = await fetch(\"/api/chat\", {\n method: \"POST\",\n headers: { \"content-type\": \"application/json\" },\n body: JSON.stringify({ session_id: sessionId, message: text }),\n });\n typingEl.remove();\n if (!res.ok) {\n const errText = await res.text().catch(() => res.statusText);\n addBubble(\"system\", `Error: ${errText}`);\n return;\n }\n const data = await res.json();\n for (const evt of data.events ?? []) renderEvent(evt);\n if (data.reply) addBubble(\"assistant\", data.reply);\n if (data.usage) {\n debugEl.textContent = `model calls: ${data.usage.model_calls} · input: ${data.usage.input_tokens} · output: ${data.usage.output_tokens} · cache read: ${data.usage.cache_read_input_tokens} · cache write: ${data.usage.cache_creation_input_tokens}`;\n }\n } catch (err) {\n typingEl.remove();\n addBubble(\"system\", `Request failed: ${(err as Error).message}`);\n } finally {\n setBusy(false);\n inputEl.focus();\n }\n}\n\nsendBtn.addEventListener(\"click\", () => {\n const text = inputEl.value;\n inputEl.value = \"\";\n sendMessage(text);\n});\n\ninputEl.addEventListener(\"keydown\", (e) => {\n if (e.key === \"Enter\") {\n const text = inputEl.value;\n inputEl.value = \"\";\n sendMessage(text);\n }\n});\n\nsuggestionsEl.addEventListener(\"click\", (e) => {\n const target = e.target as HTMLElement;\n const q = target.getAttribute(\"data-q\");\n if (q) sendMessage(q);\n});\n\nresetBtn.addEventListener(\"click\", async () => {\n await fetch(\"/api/reset\", {\n method: \"POST\",\n headers: { \"content-type\": \"application/json\" },\n body: JSON.stringify({ session_id: sessionId }),\n });\n messagesEl.innerHTML = \"\";\n suggestionsEl.style.display = \"flex\";\n debugEl.textContent = \"\";\n addBubble(\"system\", \"Started a new chat. Cart and conversation history were cleared; remembered preferences were kept.\");\n});\n\nforgetBtn.addEventListener(\"click\", async () => {\n await fetch(\"/api/forget\", {\n method: \"POST\",\n headers: { \"content-type\": \"application/json\" },\n body: JSON.stringify({ session_id: sessionId }),\n });\n addBubble(\"system\", \"Forgot all remembered preferences for this session.\");\n});\n\naddBubble(\n \"system\",\n \"Try: “I need a 2-person tent under $250”, “outfit me for a weekend backpacking trip”, or “what's your return policy?”\"\n);\n",[],[217],"bd965a82-339b-4e0a-8e68-bdd5cbd44894","db.ts","c58ea8e4-a7d3-11f1-895f-1607ee4eb77e",3,["D",1788466341931],"// db.ts\n// Session state for the demo: conversation history, the set of product IDs\n// the server has actually issued to a session (the provenance allow-list the\n// blog describes), the cart, and long-term memory facts. All per session_id,\n// which the client generates and keeps in localStorage.\n\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nlet initialized = false;\n\nexport async function initDb() {\n if (initialized) return;\n await sqlite.batch([\n `CREATE TABLE IF NOT EXISTS commerce_messages (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n session_id TEXT NOT NULL,\n turn INTEGER NOT NULL,\n role TEXT NOT NULL,\n content TEXT NOT NULL,\n created_at TEXT NOT NULL DEFAULT (datetime('now'))\n )`,\n `CREATE TABLE IF NOT EXISTS commerce_known_ids (\n session_id TEXT NOT NULL,\n product_id TEXT NOT NULL,\n created_at TEXT NOT NULL DEFAULT (datetime('now')),\n PRIMARY KEY (session_id, product_id)\n )`,\n `CREATE TABLE IF NOT EXISTS commerce_cart (\n session_id TEXT NOT NULL,\n product_id TEXT NOT NULL,\n quantity INTEGER NOT NULL,\n PRIMARY KEY (session_id, product_id)\n )`,\n `CREATE TABLE IF NOT EXISTS commerce_memory (\n session_id TEXT NOT NULL,\n key TEXT NOT NULL,\n value TEXT NOT NULL,\n category TEXT,\n updated_at TEXT NOT NULL DEFAULT (datetime('now')),\n PRIMARY KEY (session_id, key)\n )`,\n ]);\n initialized = true;\n}\n\n// ---------- messages (conversation history, Anthropic content-block JSON) ----------\n\nexport interface StoredMessage {\n role: \"user\" | \"assistant\";\n content: unknown; // Anthropic content block array\n}\n\nexport async function loadMessages(sessionId: string): Promise {\n const res = await sqlite.execute(\n `SELECT role, content FROM commerce_messages WHERE session_id = ? ORDER BY id ASC`,\n [sessionId]\n );\n return res.rows.map((r: any) => ({ role: r.role, content: JSON.parse(r.content) }));\n}\n\nexport async function appendMessage(sessionId: string, turn: number, msg: StoredMessage) {\n await sqlite.execute(\n `INSERT INTO commerce_messages (session_id, turn, role, content) VALUES (?, ?, ?, ?)`,\n [sessionId, turn, msg.role, JSON.stringify(msg.content)]\n );\n}\n\nexport async function nextTurnNumber(sessionId: string): Promise {\n const res = await sqlite.execute(\n `SELECT COALESCE(MAX(turn), -1) AS maxTurn FROM commerce_messages WHERE session_id = ?`,\n [sessionId]\n );\n const maxTurn = Number((res.rows[0] as any)?.maxTurn ?? -1);\n return maxTurn + 1;\n}\n\nexport async function clearSession(sessionId: string) {\n await sqlite.batch([\n { sql: `DELETE FROM commerce_messages WHERE session_id = ?`, args: [sessionId] },\n { sql: `DELETE FROM commerce_known_ids WHERE session_id = ?`, args: [sessionId] },\n { sql: `DELETE FROM commerce_cart WHERE session_id = ?`, args: [sessionId] },\n // memory intentionally survives a \"new chat\" so personalization can be\n // demoed across sessions with the same session_id kept, or wiped\n // explicitly by the client using /api/forget.\n ]);\n}\n\nexport async function forgetMemory(sessionId: string) {\n await sqlite.execute(`DELETE FROM commerce_memory WHERE session_id = ?`, [sessionId]);\n}\n\n// ---------- known/server-issued product IDs ----------\n\nexport async function markKnownIds(sessionId: string, productIds: string[]) {\n if (productIds.length === 0) return;\n const stmts = productIds.map((id) => ({\n sql: `INSERT OR IGNORE INTO commerce_known_ids (session_id, product_id) VALUES (?, ?)`,\n args: [sessionId, id],\n }));\n await sqlite.batch(stmts);\n}\n\nexport async function isKnownId(sessionId: string, productId: string): Promise {\n const res = await sqlite.execute(\n `SELECT 1 FROM commerce_known_ids WHERE session_id = ? AND product_id = ?`,\n [sessionId, productId]\n );\n return res.rows.length > 0;\n}\n\n// ---------- cart ----------\n\nexport interface CartLine {\n product_id: string;\n quantity: number;\n}\n\nexport async function getCart(sessionId: string): Promise {\n const res = await sqlite.execute(\n `SELECT product_id, quantity FROM commerce_cart WHERE session_id = ? ORDER BY product_id`,\n [sessionId]\n );\n return res.rows.map((r: any) => ({ product_id: r.product_id, quantity: Number(r.quantity) }));\n}\n\nexport async function setCartLine(sessionId: string, productId: string, quantity: number) {\n if (quantity <= 0) {\n await sqlite.execute(`DELETE FROM commerce_cart WHERE session_id = ? AND product_id = ?`, [\n sessionId,\n productId,\n ]);\n return;\n }\n await sqlite.execute(\n `INSERT INTO commerce_cart (session_id, product_id, quantity) VALUES (?, ?, ?)\n ON CONFLICT (session_id, product_id) DO UPDATE SET quantity = excluded.quantity`,\n [sessionId, productId, quantity]\n );\n}\n\nexport async function getCartQuantity(sessionId: string, productId: string): Promise {\n const res = await sqlite.execute(\n `SELECT quantity FROM commerce_cart WHERE session_id = ? AND product_id = ?`,\n [sessionId, productId]\n );\n return res.rows.length ? Number((res.rows[0] as any).quantity) : 0;\n}\n\nexport async function clearCart(sessionId: string) {\n await sqlite.execute(`DELETE FROM commerce_cart WHERE session_id = ?`, [sessionId]);\n}\n\n// ---------- long-term memory (per-session facts, extracted asynchronously) ----------\n\nexport interface MemoryFact {\n key: string;\n value: string;\n category: string | null;\n}\n\nexport async function getMemory(sessionId: string): Promise {\n const res = await sqlite.execute(\n `SELECT key, value, category FROM commerce_memory WHERE session_id = ? ORDER BY updated_at DESC`,\n [sessionId]\n );\n return res.rows.map((r: any) => ({ key: r.key, value: r.value, category: r.category }));\n}\n\nexport async function upsertMemory(sessionId: string, fact: MemoryFact) {\n await sqlite.execute(\n `INSERT INTO commerce_memory (session_id, key, value, category, updated_at)\n VALUES (?, ?, ?, ?, datetime('now'))\n ON CONFLICT (session_id, key) DO UPDATE SET value = excluded.value, category = excluded.category, updated_at = datetime('now')`,\n [sessionId, fact.key, fact.value, fact.category]\n );\n}\n\nexport async function deleteMemoryKey(sessionId: string, key: string) {\n await sqlite.execute(`DELETE FROM commerce_memory WHERE session_id = ? AND key = ?`, [sessionId, key]);\n}\n",[],[224],["D",1788466319768],[],[18],"8fb3e9cb-8e93-4bd2-b543-c90ba84809b7","agent.ts","0dbd7f0a-a7d4-11f1-8ae7-1607ee4eb77e",7,["D",1788466463046],"// agent.ts\n// The turn loop: one model in a standard agent loop, equipped with tools,\n// looping on tool_use until it produces a final answer. Implements the\n// caching layout from Part 2 of the blog (global system+tools prefix cached\n// with an ephemeral breakpoint; per-session memory facts appended after it,\n// uncached since they change) and the memory extraction pattern from Part 3\n// (a separate, smaller-model call that reads only user/assistant text, never\n// tool results, and writes facts asynchronously to the memory store).\n\nimport { SYSTEM_PROMPT } from \"./prompt.ts\";\nimport { TOOL_DEFS, executeTool, type UiEvent } from \"./tools.ts\";\nimport {\n appendMessage,\n getMemory,\n loadMessages,\n nextTurnNumber,\n upsertMemory,\n type StoredMessage,\n} from \"./db.ts\";\n\nconst MODEL = Deno.env.get(\"ANTHROPIC_MODEL\") || \"claude-sonnet-5\";\nconst MEMORY_MODEL = Deno.env.get(\"ANTHROPIC_MEMORY_MODEL\") || \"claude-haiku-4-5-20251001\";\nconst MAX_TOOL_ROUNDS = 8;\nconst API_URL = \"https://api.anthropic.com/v1/messages\";\n\nfunction apiKey(): string {\n const key = Deno.env.get(\"ANTHROPIC_API_KEY\");\n if (!key) {\n throw new Error(\n \"ANTHROPIC_API_KEY is not set on this val. Add it under this val's environment variables before chatting.\"\n );\n }\n return key;\n}\n\nasync function callMessagesApi(body: Record) {\n const res = await fetch(API_URL, {\n method: \"POST\",\n headers: {\n \"x-api-key\": apiKey(),\n \"anthropic-version\": \"2023-06-01\",\n \"content-type\": \"application/json\",\n },\n body: JSON.stringify(body),\n });\n if (!res.ok) {\n const text = await res.text().catch(() => \"\");\n throw new Error(`Anthropic API error ${res.status}: ${text.slice(0, 500)}`);\n }\n return res.json();\n}\n\ninterface TurnUsage {\n input_tokens: number;\n output_tokens: number;\n cache_creation_input_tokens: number;\n cache_read_input_tokens: number;\n model_calls: number;\n}\n\nexport interface TurnResult {\n reply: string;\n events: UiEvent[];\n usage: TurnUsage;\n}\n\nfunction memoryBlock(facts: Awaited>): string {\n if (facts.length === 0) return \"No stored preferences for this customer yet.\";\n const lines = facts.map((f) => `- ${f.key}: ${f.value}${f.category ? ` (${f.category})` : \"\"}`);\n return `Known preferences for this customer (from earlier sessions):\\n${lines.join(\"\\n\")}`;\n}\n\n/** Builds the system prompt as two blocks: the byte-identical global prefix\n * (cached) and the per-session memory facts (volatile, appended after the\n * cache breakpoint per the blog's caching layout). */\nasync function buildSystem(sessionId: string) {\n const facts = await getMemory(sessionId);\n return [\n { type: \"text\", text: SYSTEM_PROMPT, cache_control: { type: \"ephemeral\" } },\n { type: \"text\", text: memoryBlock(facts) },\n ];\n}\n\nfunction toolsWithCacheBreakpoint() {\n const defs = TOOL_DEFS.map((t) => ({ ...t }));\n (defs[defs.length - 1] as Record).cache_control = { type: \"ephemeral\" };\n return defs;\n}\n\nexport async function runTurn(sessionId: string, userText: string): Promise {\n const turn = await nextTurnNumber(sessionId);\n const userMsg: StoredMessage = { role: \"user\", content: [{ type: \"text\", text: userText }] };\n await appendMessage(sessionId, turn, userMsg);\n\n const history = await loadMessages(sessionId);\n const messages: Array<{ role: string; content: unknown }> = history.map((m) => ({\n role: m.role,\n content: m.content,\n }));\n\n const system = await buildSystem(sessionId);\n const tools = toolsWithCacheBreakpoint();\n\n const events: UiEvent[] = [];\n const usage: TurnUsage = {\n input_tokens: 0,\n output_tokens: 0,\n cache_creation_input_tokens: 0,\n cache_read_input_tokens: 0,\n model_calls: 0,\n };\n let finalText = \"\";\n\n for (let round = 0; round < MAX_TOOL_ROUNDS; round++) {\n const response = await callMessagesApi({\n model: MODEL,\n max_tokens: 1536,\n system,\n tools,\n messages,\n });\n\n usage.model_calls += 1;\n usage.input_tokens += response.usage?.input_tokens ?? 0;\n usage.output_tokens += response.usage?.output_tokens ?? 0;\n usage.cache_creation_input_tokens += response.usage?.cache_creation_input_tokens ?? 0;\n usage.cache_read_input_tokens += response.usage?.cache_read_input_tokens ?? 0;\n\n const content = response.content ?? [];\n const assistantMsg: StoredMessage = { role: \"assistant\", content };\n await appendMessage(sessionId, turn, assistantMsg);\n messages.push({ role: \"assistant\", content });\n\n const textBlocks = content.filter((b: any) => b.type === \"text\").map((b: any) => b.text);\n if (textBlocks.length) finalText = textBlocks.join(\"\\n\");\n\n if (response.stop_reason !== \"tool_use\") {\n break;\n }\n\n const toolUseBlocks = content.filter((b: any) => b.type === \"tool_use\");\n // Independent tool calls in a turn run in parallel — matching the\n // blog's \"fewer turns\" guidance — and their results return as a single\n // user message with one tool_result block per call, in order.\n const results = await Promise.all(\n toolUseBlocks.map(async (block: any) => {\n const result = await executeTool(sessionId, block.name, block.input);\n if (result.uiEvent) events.push(result.uiEvent);\n return {\n type: \"tool_result\",\n tool_use_id: block.id,\n content: result.toolResultText,\n ...(result.isError ? { is_error: true } : {}),\n };\n })\n );\n\n const toolResultMsg: StoredMessage = { role: \"user\", content: results };\n await appendMessage(sessionId, turn, toolResultMsg);\n messages.push({ role: \"user\", content: results });\n }\n\n // Fire-and-forget-ish memory extraction. Kept in the same request instead\n // of a truly separate background process (Val Town's HTTP isolate does\n // not outlive the response), but it still runs after the reply is\n // computed and never touches tool results, matching the extractor's\n // narrow read scope in the blog.\n try {\n await extractMemory(sessionId, userText, finalText);\n } catch (err) {\n console.error(\"memory extraction failed\", err);\n }\n\n return { reply: finalText, events, usage };\n}\n\nasync function extractMemory(sessionId: string, userText: string, assistantText: string) {\n const prompt = `Read only the customer message and assistant reply below from a shopping-assistant chat. Extract durable facts the CUSTOMER stated about themselves (size, budget, party size, preferred category, allergies, etc.) — never facts about products or catalog data. Reply with ONLY a JSON array, no prose, like [{\"key\":\"shoe_size\",\"value\":\"10\",\"category\":\"sizing\"}]. If there is nothing worth remembering, reply with [].\n\nCustomer: ${userText}\n\nAssistant: ${assistantText}`;\n\n const response = await callMessagesApi({\n model: MEMORY_MODEL,\n max_tokens: 300,\n messages: [{ role: \"user\", content: [{ type: \"text\", text: prompt }] }],\n });\n\n const text = (response.content ?? [])\n .filter((b: any) => b.type === \"text\")\n .map((b: any) => b.text)\n .join(\"\")\n .trim();\n\n const match = text.match(/\\[[\\s\\S]*\\]/);\n if (!match) return;\n\n let facts: Array<{ key: string; value: string; category?: string }>;\n try {\n facts = JSON.parse(match[0]);\n } catch {\n return;\n }\n if (!Array.isArray(facts)) return;\n\n for (const f of facts) {\n if (!f || typeof f.key !== \"string\" || typeof f.value !== \"string\") continue;\n await upsertMemory(sessionId, { key: f.key, value: f.value, category: f.category ?? null });\n }\n}\n",[],[235],"29214ee9-3235-44f9-9bf5-297c32008822","README.md","a35df770-a7d3-11f1-ac82-1607ee4eb77e",11,["D",1788466619763],"# Commerce Agent Demo — ACME Outdoors\n\nA small, runnable demo of the architecture in Anthropic's blog post\n[\"A guide to the anatomy of effective commerce agents\"](https://claude.com/blog/the-anatomy-of-effective-commerce-agents),\nbuilt on Val Town instead of the post's own Python/Node reference repo,\n[anthropics/commerce-agents](https://github.com/anthropics/commerce-agents).\n\nIt's a single Claude model in a standard agent loop, equipped with tools and\non-demand skills, shopping a small fictional outdoor-gear catalog. **Nothing\nhere is real** — no real products, no real payment, no real customer data.\n\n## Try it\n\n1. Add your key: open this val's environment variables page and add\n `ANTHROPIC_API_KEY`:\n `https://www.val.town/x/amotivv/commerce-agent-demo/environment-variables?key=ANTHROPIC_API_KEY`\n2. Open the val's HTTP endpoint (the `main.tsx` link) and chat with **Ridge**,\n the ACME Outdoors shopping assistant. Try:\n - \"I need a 2-person tent under $250\"\n - \"Outfit me for a 3-day backpacking trip for 2 people\"\n - \"Compare the Traverse Mid boot and the Fast Trail Runner\"\n - \"What's your return policy?\"\n - Tell it a preference (\"I'm usually a size 10\"), then click **New chat**\n and ask something size-related again — it remembers across chats,\n forgets nothing until you click **Forget me**.\n\nOptional env vars (both have working defaults):\n- `ANTHROPIC_MODEL` — defaults to `claude-sonnet-5` (the blog's own pick for\n latency-sensitive consumer agents; a merchant/analysis agent would default\n to Opus instead).\n- `ANTHROPIC_MEMORY_MODEL` — defaults to `claude-haiku-4-5-20251001`, a small\n fast model for the post-turn memory extraction pass.\n\n## What maps to what\n\n| Blog concept | This demo |\n|---|---|\n| One agent loop, not a router + subagents | `agent.ts` — a single `runTurn()` loop that calls the Messages API, executes any `tool_use` blocks, and loops until a final answer. No intent router, no domain subagents. |\n| Skills, not subagents | `skills.ts` has five skill bodies (`search-discovery`, `purchase-research`, `planning-goals`, `customer-care`, `memory-personalization`), loaded on demand via a `load_skill` tool — same five names the blog's own shopping agent uses. |\n| System prompt vs. skill, decided by frequency | `prompt.ts` holds only grounding, cart/checkout semantics, and presentation rules — the stuff nearly every turn touches. Everything else is a skill. |\n| Tools call systems you already run; results are shaped for the model | `tools.ts` / `catalog.ts` — `search_products` returns already-ranked, trimmed results; there's no reasoning logic duplicated inside a tool. |\n| The UI components are tools | `present_products` is a real tool call with typed args (`product_ids`, `layout`, `message`); the server validates and renders it as an event, never parsed from prose. Same for `view_cart` / `checkout`. |\n| Prompt caching layout (global → session → volatile) | `agent.ts` sends `system` as two blocks: the byte-identical prompt with an `ephemeral` cache breakpoint, then per-session memory facts appended after it (uncached, since they change). Tools carry their own trailing cache breakpoint. The chat UI's debug line shows `cache_read_input_tokens` / `cache_creation_input_tokens` per turn so you can watch the cache warm up on a repeat visit. |\n| Parallel tool calls | `agent.ts` executes all `tool_use` blocks in one model response with `Promise.all`, and returns their results as a single user message — matching the blog's \"fewer turns\" guidance. |\n| Writes and renders accept only server-issued IDs | `db.ts`'s `commerce_known_ids` table + `tools.ts`'s checks: `present_products`/`add_to_cart`/`update_cart_item` refuse any product ID the session hasn't actually seen from `search_products`/`get_product`. |\n| Caps enforced on resulting state | `add_to_cart` computes `min(current_qty + requested, stock)` — a repeated \"add 5 more\" can't stack past stock, the way the blog describes for ticket/promo caps. |\n| The model stages, a person/policy applies | `checkout` renders a summary only; there is no charge tool, no payment backend, matching the reference repo's own note that nothing in it \"places an order, charges a card, or changes a live listing.\" |\n| Third-party content is fenced | `prompt.ts#catalogFence` wraps every product description in `` tags with an instruction to treat it as data, never instructions — the blog's sanitizer pattern, simplified to fit a demo catalog with no real third-party text. |\n| Memory: store / write / read | `db.ts`'s `commerce_memory` table (typed key/value/category facts, not a markdown blob) + `agent.ts#extractMemory` (a separate, smaller-model pass that reads only the user's and assistant's text, never tool results) + a small always-in-context block injected into the system prompt each turn. |\n| Evals: snapshots, not conversations | Not implemented here — this is a single runnable demo, not a test suite. See \"What's different\" below. |\n\n## What's different from the reference repo (be aware of this)\n\nThis is a from-scratch reimplementation on Val Town's Deno/serverless\nruntime, not a port of the Python/Node repo. Some things the blog covers are\ndeliberately out of scope for a single demo val:\n\n- **No streaming / eager tool dispatch.** The Messages API call here is\n request/response, not streamed, so there's no token-level UI streaming or\n eager-dispatch-on-first-argument. The blog's biggest perceived-latency\n techniques (`eager_input_streaming`, progressive rendering) aren't\n represented.\n- **Memory extraction isn't truly asynchronous.** It runs after the reply is\n computed but inside the same HTTP request/response cycle, because a Val\n Town HTTP isolate doesn't outlive its response for a true background\n process. The blog's \"separate thread, zero latency added to the\n conversation\" claim doesn't fully hold here — this demo's memory pass adds\n a second small model call to each turn's total time.\n- **No eval suite, no CI, no multi-team ownership model.** Part 3's\n production-readiness material (SME-authored eval cases, CI gating,\n canary rollout) has no equivalent in a single demo val.\n- **One vertical, one skill body each.** The reference repo ships four\n verticals (retail, travel, telecom, entertainment) and both a shopping\n and a merchant agent. This demo is retail/shopping only, with fictional\n data invented for this val (ACME Outdoors), not copied from the repo.\n- **Memory has no deletion/retention UI beyond \"Forget me.\"** The blog's\n data-handling checklist (types of memory allowed, retention period,\n per-deployment on/off switch) isn't fully built out; \"Forget me\" covers\n the \"give users a way to delete\" requirement only.\n\n## Files\n\n- `catalog.ts` — fictional ACME Outdoors product data + a small ranking\n function standing in for a real search backend.\n- `db.ts` — sqlite-backed session state: conversation history, known/\n server-issued product IDs, cart, and long-term memory facts.\n- `skills.ts` — the five skill bodies, loaded on demand.\n- `prompt.ts` — the always-loaded system prompt + the ``\n fencing helper.\n- `tools.ts` — tool schemas (Anthropic tool-use format) and the executor\n that enforces every safety rule in one place.\n- `agent.ts` — the turn loop: calls the Messages API, executes tools,\n loops on `tool_use`, builds the cached system-prompt layout, and runs\n memory extraction after the reply.\n- `main.tsx` — the Hono HTTP app: serves the chat UI and the\n `/api/chat` / `/api/reset` / `/api/forget` / `/api/catalog` routes.\n- `index.html` / `frontend.ts` — the static chat UI (vanilla TS, no\n framework): message bubbles plus rendered cards for\n `present_products` / `view_cart` / `checkout` events, and a debug line\n showing per-turn token/cache usage.\n",[],[243],["D",1788466284516],["D",1789514495229],{"_11":12,"_124":70},{"_11":12,"_120":-5,"_69":70,"_30":68,"_121":122,"_123":24},{"_38":111,"_13":16,"_32":35,"_112":72,"_113":-5,"_114":-5,"_115":-5,"_116":-5,"_117":-5,"_118":14,"_119":12},"ctx",{"_53":-5,"_143":288,"_289":290,"_291":292,"_293":24,"_294":24,"_295":24,"_296":85,"_297":-5,"_298":-7,"_299":-7,"_300":26,"_301":24,"_302":24,"_303":-5,"_304":24,"_305":24,"_306":24,"_307":-5},"ENV",{"_259":260,"_261":262,"_263":16,"_264":265,"_266":267,"_268":269,"_270":271,"_272":273,"_274":275,"_276":277,"_278":279,"_280":281,"_282":283,"_284":285,"_286":287},"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"]

History · catalog.ts