[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_292":293,"_294":295},"routes/_app.x.$handle.$name",{"_105":104,"_38":51,"_113":95,"_33":107,"_13":14,"_114":-5,"_11":115,"_116":117,"_118":119,"_120":121,"_122":123,"_26":-5,"_124":-5,"_125":-5,"_126":31,"_127":128,"_129":64,"_130":-5,"_131":-5,"_132":133},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":18,"_19":-5},"project",{"_49":50,"_38":51,"_44":52,"_53":-5,"_54":31,"_55":56,"_57":56,"_58":59,"_60":-5,"_19":61,"_62":37,"_63":64,"_65":-5,"_66":-5,"_67":68,"_69":70,"_71":72,"_73":74,"_75":76,"_77":-5,"_78":79,"_80":79,"_81":82,"_83":82,"_84":82,"_85":79,"_86":79,"_87":88,"_89":90,"_91":92,"_93":31},"version",16,"changes",[25],"aiChatInfo",{"_20":21,"_22":-5,"_23":-5,"_24":-5},"userId","aiChatMessageId","1fb7f34a-d499-4cce-9f4b-43feae9176ed","aiChatThreadId","aiChatThreadUserId","aiChatThreadTitle",{"_26":27,"_28":29,"_30":31,"_32":31,"_33":34,"_35":34},"file",{"_36":37,"_38":34,"_39":40,"_41":43,"_44":45,"_46":14,"_47":48,"_30":31},"previous",{"_36":37,"_38":34,"_39":40,"_41":42},"deleted",false,"deletedHere","path","main.ts","latestPath","fileId","32bdfec6-85ae-11f1-94b9-1607ee4eb77e","name","fileType","http","content","/**\n * Multi-Tenant Commerce Engine\n * ─────────────────────────────\n * Single-file HTTP Val providing:\n * 1. Multi-tenant merchant isolation via Val Town SQLite\n * 2. Zero-cost contextual AI chatbot (/api/chat)\n * 3. Automated order booking with customer info extraction\n * 4. Supplier dispatch webhook notifications\n *\n * Every query is scoped by merchant_id — cross-tenant reads are\n * structurally impossible because the WHERE clause is always present.\n */\n\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\n// ═══════════════════════════════════════════════════════════════\n// TYPES\n// ═══════════════════════════════════════════════════════════════\n\ninterface Merchant {\n id: string;\n name: string;\n phone: string;\n country: string;\n webhook_url: string;\n api_key: string;\n created_at: string;\n}\n\ninterface Product {\n id: number;\n merchant_id: string;\n name: string;\n price: number;\n description: string;\n stock: number;\n category: string;\n image_url: string;\n created_at: string;\n}\n\ninterface Order {\n id: number;\n merchant_id: string;\n customer_name: string;\n customer_phone: string;\n customer_address: string;\n product_id: number;\n product_name: string;\n quantity: number;\n total_price: number;\n status: string;\n created_at: string;\n}\n\ninterface ChatSession {\n id: string;\n merchant_id: string;\n customer_name: string | null;\n customer_phone: string | null;\n customer_address: string | null;\n product_id: number | null;\n product_name: string | null;\n quantity: number | null;\n state: string;\n updated_at: string;\n}\n\ntype JsonResponse = Response;\n\n// ═══════════════════════════════════════════════════════════════\n// DATABASE INITIALIZATION\n// ═══════════════════════════════════════════════════════════════\n\nasync function initDatabase(): Promise {\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS merchants (\n id TEXT PRIMARY KEY,\n name TEXT NOT NULL,\n phone TEXT NOT NULL,\n country TEXT NOT NULL,\n webhook_url TEXT NOT NULL,\n api_key TEXT NOT NULL UNIQUE,\n created_at TEXT NOT NULL\n )\n `);\n\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS products (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n merchant_id TEXT NOT NULL,\n name TEXT NOT NULL,\n price REAL NOT NULL,\n description TEXT DEFAULT '',\n stock INTEGER DEFAULT 0,\n category TEXT DEFAULT 'general',\n image_url TEXT DEFAULT '',\n created_at TEXT NOT NULL,\n FOREIGN KEY (merchant_id) REFERENCES merchants(id)\n )\n `);\n\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS orders (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n merchant_id TEXT NOT NULL,\n customer_name TEXT NOT NULL,\n customer_phone TEXT NOT NULL,\n customer_address TEXT NOT NULL,\n product_id INTEGER NOT NULL,\n product_name TEXT NOT NULL,\n quantity INTEGER NOT NULL,\n total_price REAL NOT NULL,\n status TEXT DEFAULT 'booked',\n created_at TEXT NOT NULL,\n FOREIGN KEY (merchant_id) REFERENCES merchants(id),\n FOREIGN KEY (product_id) REFERENCES products(id)\n )\n `);\n\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS chat_sessions (\n id TEXT PRIMARY KEY,\n merchant_id TEXT NOT NULL,\n customer_name TEXT,\n customer_phone TEXT,\n customer_address TEXT,\n product_id INTEGER,\n product_name TEXT,\n quantity INTEGER,\n state TEXT DEFAULT 'browsing',\n updated_at TEXT NOT NULL,\n FOREIGN KEY (merchant_id) REFERENCES merchants(id)\n )\n `);\n\n await sqlite.execute(`\n CREATE INDEX IF NOT EXISTS idx_products_merchant ON products(merchant_id)\n `);\n await sqlite.execute(`\n CREATE INDEX IF NOT EXISTS idx_orders_merchant ON orders(merchant_id)\n `);\n await sqlite.execute(`\n CREATE INDEX IF NOT EXISTS idx_chat_sessions_merchant ON chat_sessions(merchant_id)\n `);\n}\n\n// ═══════════════════════════════════════════════════════════════\n// UTILITY FUNCTIONS\n// ═══════════════════════════════════════════════════════════════\n\nfunction json(data: unknown, status = 200): JsonResponse {\n return new Response(JSON.stringify(data), {\n status,\n headers: {\n \"Content-Type\": \"application/json\",\n \"Access-Control-Allow-Origin\": \"*\",\n \"Access-Control-Allow-Methods\": \"GET, POST, PUT, DELETE, OPTIONS\",\n \"Access-Control-Allow-Headers\": \"Content-Type, X-Merchant-Key\",\n },\n });\n}\n\nfunction errorResponse(message: string, status = 400): JsonResponse {\n return json({ error: message }, status);\n}\n\nfunction generateId(): string {\n return \"mrc_\" + crypto.randomUUID().replace(/-/g, \"\").slice(0, 16);\n}\n\nfunction generateApiKey(): string {\n const bytes = new Uint8Array(24);\n crypto.getRandomValues(bytes);\n return \"sk_\" + Array.from(bytes, (b) => b.toString(16).padStart(2, \"0\")).join(\"\");\n}\n\nfunction generateSessionId(): string {\n return \"ses_\" + crypto.randomUUID().replace(/-/g, \"\");\n}\n\nasync function authenticateMerchant(apiKey: string): Promise {\n if (!apiKey) return null;\n try {\n const result = await sqlite.execute({\n sql: \"SELECT * FROM merchants WHERE api_key = ?\",\n args: [apiKey],\n });\n if (result.rows.length === 0) return null;\n return result.rows[0] as unknown as Merchant;\n } catch {\n return null;\n }\n}\n\nasync function getMerchantById(merchantId: string): Promise {\n try {\n const result = await sqlite.execute({\n sql: \"SELECT * FROM merchants WHERE id = ?\",\n args: [merchantId],\n });\n if (result.rows.length === 0) return null;\n return result.rows[0] as unknown as Merchant;\n } catch {\n return null;\n }\n}\n\n// ═══════════════════════════════════════════════════════════════\n// MERCHANT MANAGEMENT\n// ═══════════════════════════════════════════════════════════════\n\nasync function registerMerchant(body: {\n name: string;\n phone: string;\n country: string;\n webhook_url: string;\n}): Promise {\n if (!body.name || !body.phone || !body.country || !body.webhook_url) {\n return errorResponse(\"Missing required fields: name, phone, country, webhook_url\", 422);\n }\n\n const id = generateId();\n const apiKey = generateApiKey();\n const createdAt = new Date().toISOString();\n\n try {\n await sqlite.execute({\n sql: `INSERT INTO merchants (id, name, phone, country, webhook_url, api_key, created_at)\n VALUES (?, ?, ?, ?, ?, ?, ?)`,\n args: [id, body.name, body.phone, body.country, body.webhook_url, apiKey, createdAt],\n });\n\n return json({\n merchant_id: id,\n api_key: apiKey,\n name: body.name,\n webhook_url: body.webhook_url,\n message: \"Merchant registered successfully. Store your API key securely.\",\n }, 201);\n } catch (err) {\n return errorResponse(`Merchant registration failed: ${(err as Error).message}`, 500);\n }\n}\n\nasync function getMerchantInfo(merchant: Merchant): Promise {\n return json({\n id: merchant.id,\n name: merchant.name,\n phone: merchant.phone,\n country: merchant.country,\n webhook_url: merchant.webhook_url,\n created_at: merchant.created_at,\n });\n}\n\n// ═══════════════════════════════════════════════════════════════\n// PRODUCT MANAGEMENT — every query includes merchant_id WHERE clause\n// ═══════════════════════════════════════════════════════════════\n\nasync function listProducts(merchantId: string): Promise {\n try {\n const result = await sqlite.execute({\n sql: \"SELECT * FROM products WHERE merchant_id = ? ORDER BY created_at DESC\",\n args: [merchantId],\n });\n return json({ products: result.rows, count: result.rows.length });\n } catch (err) {\n return errorResponse(`Failed to list products: ${(err as Error).message}`, 500);\n }\n}\n\nasync function addProduct(merchantId: string, body: {\n name: string;\n price: number;\n description?: string;\n stock?: number;\n category?: string;\n image_url?: string;\n}): Promise {\n if (!body.name || body.price === undefined) {\n return errorResponse(\"Missing required fields: name, price\", 422);\n }\n\n const createdAt = new Date().toISOString();\n\n try {\n await sqlite.execute({\n sql: `INSERT INTO products (merchant_id, name, price, description, stock, category, image_url, created_at)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?)`,\n args: [\n merchantId,\n body.name,\n body.price,\n body.description || \"\",\n body.stock ?? 0,\n body.category || \"general\",\n body.image_url || \"\",\n createdAt,\n ],\n });\n\n const result = await sqlite.execute({\n sql: \"SELECT * FROM products WHERE merchant_id = ? AND name = ? ORDER BY id DESC LIMIT 1\",\n args: [merchantId, body.name],\n });\n\n return json({ product: result.rows[0], message: \"Product added successfully\" }, 201);\n } catch (err) {\n return errorResponse(`Failed to add product: ${(err as Error).message}`, 500);\n }\n}\n\nasync function deleteProduct(merchantId: string, productId: number): Promise {\n try {\n const result = await sqlite.execute({\n sql: \"DELETE FROM products WHERE id = ? AND merchant_id = ?\",\n args: [productId, merchantId],\n });\n\n if (result.rowsAffected === 0) {\n return errorResponse(\"Product not found or not owned by this merchant\", 404);\n }\n\n return json({ message: \"Product deleted successfully\" });\n } catch (err) {\n return errorResponse(`Failed to delete product: ${(err as Error).message}`, 500);\n }\n}\n\n// ═══════════════════════════════════════════════════════════════\n// ORDER MANAGEMENT — every query includes merchant_id WHERE clause\n// ═══════════════════════════════════════════════════════════════\n\nasync function listOrders(merchantId: string): Promise {\n try {\n const result = await sqlite.execute({\n sql: \"SELECT * FROM orders WHERE merchant_id = ? ORDER BY created_at DESC\",\n args: [merchantId],\n });\n return json({ orders: result.rows, count: result.rows.length });\n } catch (err) {\n return errorResponse(`Failed to list orders: ${(err as Error).message}`, 500);\n }\n}\n\nasync function updateOrderStatus(merchantId: string, orderId: number, status: string): Promise {\n const validStatuses = [\"booked\", \"dispatched\", \"delivered\", \"cancelled\"];\n if (!validStatuses.includes(status)) {\n return errorResponse(`Invalid status. Must be one of: ${validStatuses.join(\", \")}`, 422);\n }\n\n try {\n const result = await sqlite.execute({\n sql: \"UPDATE orders SET status = ? WHERE id = ? AND merchant_id = ?\",\n args: [status, orderId, merchantId],\n });\n\n if (result.rowsAffected === 0) {\n return errorResponse(\"Order not found or not owned by this merchant\", 404);\n }\n\n return json({ message: \"Order status updated\", order_id: orderId, status });\n } catch (err) {\n return errorResponse(`Failed to update order: ${(err as Error).message}`, 500);\n }\n}\n\n// ═══════════════════════════════════════════════════════════════\n// AI CHATBOT ENGINE — zero-cost contextual NLP\n// ═══════════════════════════════════════════════════════════════\n\n// Intent detection keywords\nconst GREETING_WORDS = [\"hi\", \"hello\", \"hey\", \"greetings\", \"good morning\", \"good afternoon\", \"good evening\", \"salam\", \"hola\", \"namaste\"];\nconst PRODUCT_INQUIRY_WORDS = [\"what do you have\", \"show products\", \"catalog\", \"catalogue\", \"list products\", \"what can i buy\", \"what do you sell\", \"show me\", \"browse\", \"items\", \"what items\"];\nconst PRICE_WORDS = [\"price\", \"cost\", \"how much\", \"how many dollars\", \"rate\", \"pricing\"];\nconst AVAILABILITY_WORDS = [\"available\", \"in stock\", \"do you have\", \"got any\", \"is there\", \"still have\"];\nconst PURCHASE_WORDS = [\"buy\", \"order\", \"purchase\", \"want\", \"need\", \"get this\", \"ship to me\", \"deliver\", \"i'd like\", \"i would like\", \"take\", \"grab\", \"book\"];\nconst CONFIRM_WORDS = [\"yes\", \"confirm\", \"correct\", \"that's right\", \"thats right\", \"yeah\", \"yep\", \"sure\", \"ok\", \"okay\"];\nconst CANCEL_WORDS = [\"no\", \"cancel\", \"never mind\", \"nevermind\", \"stop\", \"abort\", \"exit\", \"quit\"];\n\n// Phone number regex — matches international and local formats\nconst PHONE_REGEX = /(\\+?\\d{1,3}[-.\\s]?)?\$?\\d{2,4}\$?[-.\\s]?\\d{3,5}[-.\\s]?\\d{3,5}/g;\n\n// Quantity extraction\nfunction extractQuantity(text: string): number | null {\n const lower = text.toLowerCase();\n const numberWords: Record = {\n \"one\": 1, \"two\": 2, \"three\": 3, \"four\": 4, \"five\": 5,\n \"six\": 6, \"seven\": 7, \"eight\": 8, \"nine\": 9, \"ten\": 10,\n \"a dozen\": 12, \"dozen\": 12,\n };\n\n // Check \"quantity: X\" or \"qty: X\" patterns\n const qtyPattern = /(?:quantity|qty)[:\\s]+(\\d+)/i;\n const qtyMatch = lower.match(qtyPattern);\n if (qtyMatch) return parseInt(qtyMatch[1]);\n\n // Check \"X units/pieces/items\"\n const unitPattern = /(\\d+)\\s*(?:units?|pieces?|items?|pcs)/i;\n const unitMatch = lower.match(unitPattern);\n if (unitMatch) return parseInt(unitMatch[1]);\n\n // Check number words\n for (const [word, num] of Object.entries(numberWords)) {\n if (lower.includes(word)) return num;\n }\n\n // Check standalone number\n const numMatch = text.match(/\\b(\\d+)\\b/);\n if (numMatch) return parseInt(numMatch[1]);\n\n return null;\n}\n\n// Extract phone number from text\nfunction extractPhone(text: string): string | null {\n const matches = text.match(PHONE_REGEX);\n if (matches && matches.length > 0) {\n const phone = matches[0].trim();\n // Validate minimum length (at least 7 digits)\n const digits = phone.replace(/\\D/g, \"\");\n if (digits.length >= 7) return phone;\n }\n return null;\n}\n\n// Check if text looks like an address\nfunction looksLikeAddress(text: string): boolean {\n const lower = text.toLowerCase();\n const addressIndicators = [\n \"street\", \"st\", \"avenue\", \"ave\", \"road\", \"rd\", \"lane\", \"ln\",\n \"block\", \"sector\", \"house\", \"apartment\", \"apt\", \"floor\", \"flat\",\n \"building\", \"city\", \"town\", \"district\", \"zone\", \"phase\",\n \"near\", \"opposite\", \"beside\", \"behind\", \"plot\", \"no.\", \"number\",\n ];\n const hasNumber = /\\d/.test(text);\n const hasIndicator = addressIndicators.some((ind) => lower.includes(ind));\n return (hasNumber && hasIndicator) || (hasNumber && text.split(/\\s+/).length >= 3) || (hasIndicator && text.split(/\\s+/).length >= 2);\n}\n\n// Match user message against product catalog\nfunction matchProducts(message: string, products: Product[]): Product[] {\n const lower = message.toLowerCase();\n const matches: Product[] = [];\n\n for (const product of products) {\n const productName = product.name.toLowerCase();\n const productDesc = product.description.toLowerCase();\n const productCategory = product.category.toLowerCase();\n\n // Exact name match\n if (lower.includes(productName)) {\n matches.push(product);\n continue;\n }\n\n // Match on individual words in the product name (for multi-word products)\n const nameWords = productName.split(/\\s+/).filter((w) => w.length > 3);\n const matchedWords = nameWords.filter((w) => lower.includes(w));\n if (matchedWords.length >= 1 && nameWords.length > 0) {\n matches.push(product);\n continue;\n }\n\n // Match on category\n if (productCategory !== \"general\" && lower.includes(productCategory)) {\n matches.push(product);\n continue;\n }\n\n // Match on description keywords\n if (productDesc && productDesc.length > 0) {\n const descWords = productDesc.split(/\\s+/).filter((w) => w.length > 4);\n const matchedDescWords = descWords.filter((w) => lower.includes(w));\n if (matchedDescWords.length >= 2) {\n matches.push(product);\n continue;\n }\n }\n }\n\n return matches;\n}\n\n// Check for purchase intent\nfunction hasPurchaseIntent(message: string): boolean {\n const lower = message.toLowerCase();\n return PURCHASE_WORDS.some((word) => lower.includes(word));\n}\n\n// Check for greeting\nfunction isGreeting(message: string): boolean {\n const lower = message.toLowerCase().trim();\n return GREETING_WORDS.some((word) => lower === word || lower.startsWith(word + \" \") || lower.startsWith(word + \"!\"));\n}\n\n// Check for product inquiry\nfunction isProductInquiry(message: string): boolean {\n const lower = message.toLowerCase();\n return PRODUCT_INQUIRY_WORDS.some((word) => lower.includes(word));\n}\n\n// Check for price inquiry\nfunction isPriceInquiry(message: string): boolean {\n const lower = message.toLowerCase();\n return PRICE_WORDS.some((word) => lower.includes(word));\n}\n\n// Check for availability inquiry\nfunction isAvailabilityInquiry(message: string): boolean {\n const lower = message.toLowerCase();\n return AVAILABILITY_WORDS.some((word) => lower.includes(word));\n}\n\n// Check for confirmation\nfunction isConfirmation(message: string): boolean {\n const lower = message.toLowerCase().trim();\n return CONFIRM_WORDS.some((word) => lower === word || lower.startsWith(word));\n}\n\n// Check for cancellation\nfunction isCancellation(message: string): boolean {\n const lower = message.toLowerCase().trim();\n return CANCEL_WORDS.some((word) => lower === word || lower.startsWith(word));\n}\n\n// Build product list text for chatbot responses\nfunction formatProductList(products: Product[]): string {\n if (products.length === 0) return \"I'm sorry, but this store currently has no products in the catalog. Please check back soon!\";\n\n let text = \"Here are the available products:\\n\\n\";\n for (const p of products) {\n const stockInfo = p.stock > 0 ? `✅ In stock (${p.stock} available)` : \"❌ Out of stock\";\n text += `📦 **${p.name}**\\n`;\n text += ` Price: $${p.price.toFixed(2)}\\n`;\n if (p.description) text += ` ${p.description}\\n`;\n text += ` ${stockInfo}\\n\\n`;\n }\n text += \"To place an order, just say 'I want to buy [product name]' and I'll help you check out!\";\n return text;\n}\n\n// Get or create chat session\nasync function getOrCreateSession(sessionId: string | undefined, merchantId: string): Promise {\n if (sessionId) {\n try {\n const result = await sqlite.execute({\n sql: \"SELECT * FROM chat_sessions WHERE id = ? AND merchant_id = ?\",\n args: [sessionId, merchantId],\n });\n if (result.rows.length > 0) {\n return result.rows[0] as unknown as ChatSession;\n }\n } catch {\n // fall through to create new\n }\n }\n\n const newId = sessionId || generateSessionId();\n const now = new Date().toISOString();\n\n await sqlite.execute({\n sql: `INSERT OR IGNORE INTO chat_sessions (id, merchant_id, state, updated_at)\n VALUES (?, ?, 'browsing', ?)`,\n args: [newId, merchantId, now],\n });\n\n return {\n id: newId,\n merchant_id: merchantId,\n customer_name: null,\n customer_phone: null,\n customer_address: null,\n product_id: null,\n product_name: null,\n quantity: null,\n state: \"browsing\",\n updated_at: now,\n };\n}\n\n// Update chat session\nasync function updateSession(session: ChatSession, updates: Partial): Promise {\n const now = new Date().toISOString();\n // Mutate the local session object so subsequent references in the\n // same request see the updated values (e.g. session.product_name).\n Object.assign(session, updates, { updated_at: now });\n\n await sqlite.execute({\n sql: `UPDATE chat_sessions\n SET customer_name = ?, customer_phone = ?, customer_address = ?,\n product_id = ?, product_name = ?, quantity = ?, state = ?, updated_at = ?\n WHERE id = ? AND merchant_id = ?`,\n args: [\n session.customer_name,\n session.customer_phone,\n session.customer_address,\n session.product_id,\n session.product_name,\n session.quantity,\n session.state,\n now,\n session.id,\n session.merchant_id,\n ],\n });\n}\n\n// Delete chat session after order completion\nasync function deleteSession(sessionId: string, merchantId: string): Promise {\n try {\n await sqlite.execute({\n sql: \"DELETE FROM chat_sessions WHERE id = ? AND merchant_id = ?\",\n args: [sessionId, merchantId],\n });\n } catch {\n // non-fatal\n }\n}\n\n// ═══════════════════════════════════════════════════════════════\n// ORDER BOOKING — atomic transaction within merchant scope\n// ═══════════════════════════════════════════════════════════════\n\nasync function bookOrder(\n merchantId: string,\n product: Product,\n customerName: string,\n customerPhone: string,\n customerAddress: string,\n quantity: number,\n): Promise<{ success: boolean; order?: Order; error?: string }> {\n const totalPrice = product.price * quantity;\n const createdAt = new Date().toISOString();\n\n try {\n // Atomic: insert order + decrement stock\n await sqlite.batch([\n {\n sql: `INSERT INTO orders (merchant_id, customer_name, customer_phone, customer_address, product_id, product_name, quantity, total_price, status, created_at)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?, 'booked', ?)`,\n args: [merchantId, customerName, customerPhone, customerAddress, product.id, product.name, quantity, totalPrice, createdAt],\n },\n {\n sql: \"UPDATE products SET stock = stock - ? WHERE id = ? AND merchant_id = ?\",\n args: [quantity, product.id, merchantId],\n },\n ]);\n\n const result = await sqlite.execute({\n sql: \"SELECT * FROM orders WHERE merchant_id = ? ORDER BY id DESC LIMIT 1\",\n args: [merchantId],\n });\n\n const order = result.rows[0] as unknown as Order;\n return { success: true, order };\n } catch (err) {\n return { success: false, error: (err as Error).message };\n }\n}\n\n// ═══════════════════════════════════════════════════════════════\n// SUPPLIER DISPATCH NOTIFICATION\n// ═══════════════════════════════════════════════════════════════\n\nasync function dispatchSupplierNotification(merchant: Merchant, order: Order): Promise<{ success: boolean; error?: string }> {\n const payload = {\n event: \"new_order\",\n merchant_id: merchant.id,\n merchant_name: merchant.name,\n order_id: order.id,\n message: `New Order Booked by AI Agent. Customer Name: ${order.customer_name}, Address: ${order.customer_address}, Item: ${order.product_name} (Qty: ${order.quantity}). ACTION REQUIRED: Please ship this order MANUALLY now.`,\n order_details: {\n customer_name: order.customer_name,\n customer_phone: order.customer_phone,\n customer_address: order.customer_address,\n product_name: order.product_name,\n quantity: order.quantity,\n total_price: order.total_price,\n order_id: order.id,\n created_at: order.created_at,\n },\n timestamp: new Date().toISOString(),\n };\n\n try {\n const response = await fetch(merchant.webhook_url, {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\",\n \"X-Order-Source\": \"AI-Agent\",\n \"X-Merchant-Id\": merchant.id,\n },\n body: JSON.stringify(payload),\n signal: AbortSignal.timeout(10000),\n });\n\n if (!response.ok) {\n return { success: false, error: `Webhook returned ${response.status}` };\n }\n\n return { success: true };\n } catch (err) {\n return { success: false, error: (err as Error).message };\n }\n}\n\n// ═══════════════════════════════════════════════════════════════\n// CHATBOT CONVERSATION PROCESSOR\n// ═══════════════════════════════════════════════════════════════\n\ninterface ChatResponse {\n reply: string;\n session_id: string;\n order_booked: boolean;\n order_id?: number;\n dispatch_sent?: boolean;\n dispatch_error?: string;\n}\n\nasync function processChatMessage(\n merchantId: string,\n message: string,\n sessionId?: string,\n): Promise {\n // Validate merchant exists\n const merchant = await getMerchantById(merchantId);\n if (!merchant) {\n return {\n reply: \"Error: This store is not available. Please contact support.\",\n session_id: sessionId || \"\",\n order_booked: false,\n };\n }\n\n // Load merchant's products\n let products: Product[] = [];\n try {\n const productResult = await sqlite.execute({\n sql: \"SELECT * FROM products WHERE merchant_id = ? ORDER BY name\",\n args: [merchantId],\n });\n products = productResult.rows as unknown as Product[];\n } catch {\n return {\n reply: \"I'm having trouble accessing the product catalog right now. Please try again in a moment.\",\n session_id: sessionId || \"\",\n order_booked: false,\n };\n }\n\n // Get or create session\n const session = await getOrCreateSession(sessionId, merchantId);\n\n const lowerMsg = message.toLowerCase().trim();\n\n // ── Handle cancellation ──────────────────────────────────────\n if (isCancellation(message) && session.state !== \"browsing\") {\n await deleteSession(session.id, merchantId);\n return {\n reply: \"Your order has been cancelled. Let me know if you'd like to browse or buy something else!\",\n session_id: generateSessionId(),\n order_booked: false,\n };\n }\n\n // ── State machine: BROWSING ──────────────────────────────────\n if (session.state === \"browsing\") {\n // Greeting\n if (isGreeting(message)) {\n const welcomeMsg = products.length > 0\n ? `Hello! Welcome to ${merchant.name}! 🛍️\\n\\n${formatProductList(products)}`\n : `Hello! Welcome to ${merchant.name}! 🛍️\\n\\nOur catalog is currently being updated. Please check back soon!`;\n return { reply: welcomeMsg, session_id: session.id, order_booked: false };\n }\n\n // Product inquiry\n if (isProductInquiry(message)) {\n return {\n reply: formatProductList(products),\n session_id: session.id,\n order_booked: false,\n };\n }\n\n // Price inquiry\n if (isPriceInquiry(message)) {\n const matched = matchProducts(message, products);\n if (matched.length > 0) {\n let reply = \"Here are the prices:\\n\\n\";\n for (const p of matched) {\n reply += `📦 ${p.name}: $${p.price.toFixed(2)}\\n`;\n if (p.stock > 0) reply += ` ✅ In stock (${p.stock} available)\\n`;\n else reply += ` ❌ Out of stock\\n`;\n }\n reply += \"\\nTo order, say 'I want to buy [product name]'.\";\n return { reply, session_id: session.id, order_booked: false };\n }\n return {\n reply: \"Which product are you asking about? Here's what we have:\\n\\n\" + formatProductList(products),\n session_id: session.id,\n order_booked: false,\n };\n }\n\n // Availability inquiry\n if (isAvailabilityInquiry(message)) {\n const matched = matchProducts(message, products);\n if (matched.length > 0) {\n let reply = \"Availability:\\n\\n\";\n for (const p of matched) {\n if (p.stock > 0) reply += `✅ ${p.name} — ${p.stock} in stock\\n`;\n else reply += `❌ ${p.name} — Out of stock\\n`;\n }\n return { reply, session_id: session.id, order_booked: false };\n }\n return {\n reply: \"Which product are you checking? Here's our catalog:\\n\\n\" + formatProductList(products),\n session_id: session.id,\n order_booked: false,\n };\n }\n\n // Purchase intent — start order flow\n if (hasPurchaseIntent(message)) {\n const matched = matchProducts(message, products);\n if (matched.length === 0) {\n return {\n reply: `I'd love to help you place an order! Which product would you like to buy? Here's what we have:\\n\\n${formatProductList(products)}`,\n session_id: session.id,\n order_booked: false,\n };\n }\n\n // Pick the first matched product\n const product = matched[0];\n if (product.stock <= 0) {\n return {\n reply: `I'm sorry, ${product.name} is currently out of stock. Would you like to see other available products?`,\n session_id: session.id,\n order_booked: false,\n };\n }\n\n // Try to extract all info from this first message\n const phone = extractPhone(message);\n const qty = extractQuantity(message) || 1;\n const hasName = lowerMsg.includes(\"name is\") || lowerMsg.includes(\"i'm\") || lowerMsg.includes(\"i am\") || lowerMsg.includes(\"my name\");\n const hasAddress = looksLikeAddress(message);\n\n // Extract name if present\n let extractedName: string | null = null;\n const nameMatch = message.match(/(?:name is|i am|i'm|my name is)\\s+([A-Za-z\\s]{2,40})/i);\n if (nameMatch) extractedName = nameMatch[1].trim();\n\n // Extract address if present — look for address keywords\n let extractedAddress: string | null = null;\n const addrMatch = message.match(/(?:address is|live at|deliver to|ship to|at)\\s+(.{5,120})/i);\n if (addrMatch) extractedAddress = addrMatch[1].trim();\n\n // Update session with product + any extracted info\n await updateSession(session, {\n product_id: product.id,\n product_name: product.name,\n quantity: qty,\n customer_name: extractedName,\n customer_phone: phone,\n customer_address: extractedAddress,\n state: \"ordering\",\n });\n\n // Check what's still missing\n if (!extractedName) {\n await updateSession(session, { state: \"awaiting_name\" });\n return {\n reply: `Great choice! You want to order ${product.name} (${qty} × $${product.price.toFixed(2)} = $${(product.price * qty).toFixed(2)}).\\n\\nTo complete your order, I'll need a few details.\\n\\nWhat is your full name?`,\n session_id: session.id,\n order_booked: false,\n };\n }\n\n if (!phone) {\n await updateSession(session, { state: \"awaiting_phone\" });\n return {\n reply: `Thank you, ${extractedName}! What is your phone number?`,\n session_id: session.id,\n order_booked: false,\n };\n }\n\n if (!extractedAddress) {\n await updateSession(session, { state: \"awaiting_address\" });\n return {\n reply: `Got it! What is your delivery address?`,\n session_id: session.id,\n order_booked: false,\n };\n }\n\n // All info present — confirm and book\n const updatedSession = { ...session, customer_name: extractedName, customer_phone: phone, customer_address: extractedAddress, product_id: product.id, product_name: product.name, quantity: qty };\n return await finalizeOrder(updatedSession as ChatSession, product, merchant);\n }\n\n // Try to match products even without explicit purchase/inquiry keywords\n const matched = matchProducts(message, products);\n if (matched.length > 0) {\n let reply = \"I found these products that match:\\n\\n\";\n for (const p of matched) {\n reply += `📦 ${p.name} — $${p.price.toFixed(2)}`;\n if (p.description) reply += ` (${p.description})`;\n reply += p.stock > 0 ? ` ✅\\n` : ` ❌ Out of stock\\n`;\n }\n reply += \"\\nWould you like to buy any of these? Just say 'I want to buy [product name]'.\";\n return { reply, session_id: session.id, order_booked: false };\n }\n\n // Default fallback\n return {\n reply: `I'm here to help you with your shopping at ${merchant.name}! You can:\\n• Ask \"what products do you have?\" to browse\\n• Ask about prices or availability\\n• Say \"I want to buy [product name]\" to place an order\\n\\nHow can I assist you today?`,\n session_id: session.id,\n order_booked: false,\n };\n }\n\n // ── State machine: AWAITING_NAME ─────────────────────────────\n if (session.state === \"awaiting_name\") {\n const name = message.trim().replace(/^(my name is|name is|i am|i'm)\\s+/i, \"\").trim();\n if (name.length < 2) {\n return {\n reply: \"Please provide a valid name (at least 2 characters). What is your full name?\",\n session_id: session.id,\n order_booked: false,\n };\n }\n\n await updateSession(session, { customer_name: name, state: \"awaiting_phone\" });\n\n // Try to extract phone from same message\n const phone = extractPhone(message);\n if (phone && phone !== name) {\n await updateSession(session, { customer_phone: phone, state: \"awaiting_address\" });\n return {\n reply: `Thank you, ${name}! I got your phone number: ${phone}. What is your delivery address?`,\n session_id: session.id,\n order_booked: false,\n };\n }\n\n return {\n reply: `Thank you, ${name}! What is your phone number?`,\n session_id: session.id,\n order_booked: false,\n };\n }\n\n // ── State machine: AWAITING_PHONE ────────────────────────────\n if (session.state === \"awaiting_phone\") {\n const phone = extractPhone(message);\n if (!phone) {\n return {\n reply: \"I couldn't detect a valid phone number. Please enter your phone number (e.g., +1234567890).\",\n session_id: session.id,\n order_booked: false,\n };\n }\n\n await updateSession(session, { customer_phone: phone, state: \"awaiting_address\" });\n\n // Try to extract address from same message\n const addrMatch = message.match(/(?:address is|live at|deliver to|ship to|at)\\s+(.{5,120})/i);\n if (addrMatch) {\n const address = addrMatch[1].trim();\n await updateSession(session, { customer_address: address, state: \"awaiting_quantity\" });\n return {\n reply: `Got your address! How many units of ${session.product_name} would you like to order? (Default: 1)`,\n session_id: session.id,\n order_booked: false,\n };\n }\n\n return {\n reply: `Got it! Your phone number is ${phone}. What is your delivery address?`,\n session_id: session.id,\n order_booked: false,\n };\n }\n\n // ── State machine: AWAITING_ADDRESS ──────────────────────────\n if (session.state === \"awaiting_address\") {\n const address = message.trim().replace(/^(my address is|address is|deliver to|ship to|at)\\s+/i, \"\").trim();\n if (address.length < 5) {\n return {\n reply: \"Please provide a complete delivery address (street, city, etc.). What is your address?\",\n session_id: session.id,\n order_booked: false,\n };\n }\n\n await updateSession(session, { customer_address: address, state: \"awaiting_quantity\" });\n\n return {\n reply: `Perfect! How many units of ${session.product_name} would you like to order? (Just type a number, or say '1' for one unit)`,\n session_id: session.id,\n order_booked: false,\n };\n }\n\n // ── State machine: AWAITING_QUANTITY ─────────────────────────\n if (session.state === \"awaiting_quantity\") {\n const qty = extractQuantity(message);\n const finalQty = qty || 1;\n\n if (qty && qty < 1) {\n return {\n reply: \"Please enter a valid quantity (1 or more). How many would you like?\",\n session_id: session.id,\n order_booked: false,\n };\n }\n\n // Load the product to check stock\n let product: Product | null = null;\n if (session.product_id) {\n try {\n const result = await sqlite.execute({\n sql: \"SELECT * FROM products WHERE id = ? AND merchant_id = ?\",\n args: [session.product_id, merchantId],\n });\n if (result.rows.length > 0) product = result.rows[0] as unknown as Product;\n } catch {\n // fall through\n }\n }\n\n if (!product) {\n await updateSession(session, { state: \"browsing\" });\n return {\n reply: \"Sorry, the product you selected is no longer available. Would you like to browse our catalog again?\",\n session_id: session.id,\n order_booked: false,\n };\n }\n\n if (finalQty > product.stock) {\n return {\n reply: `I'm sorry, we only have ${product.stock} units of ${product.name} in stock. Would you like to order ${product.stock} instead? (Type the quantity or say 'cancel')`,\n session_id: session.id,\n order_booked: false,\n };\n }\n\n await updateSession(session, { quantity: finalQty });\n const updatedSession = { ...session, quantity: finalQty };\n\n return await finalizeOrder(updatedSession as ChatSession, product, merchant);\n }\n\n // ── State machine: ORDERING (direct flow with all info) ──────\n if (session.state === \"ordering\") {\n // This shouldn't normally be reached, but handle gracefully\n await updateSession(session, { state: \"browsing\" });\n return {\n reply: \"It looks like something went wrong with your order. Let's start fresh — what would you like to do?\",\n session_id: session.id,\n order_booked: false,\n };\n }\n\n // ── Unknown state — reset ────────────────────────────────────\n await updateSession(session, { state: \"browsing\" });\n return {\n reply: \"How can I help you? You can browse products or place an order.\",\n session_id: session.id,\n order_booked: false,\n };\n}\n\n// Finalize order: book + dispatch notification\nasync function finalizeOrder(\n session: ChatSession,\n product: Product,\n merchant: Merchant,\n): Promise {\n const name = session.customer_name!;\n const phone = session.customer_phone!;\n const address = session.customer_address!;\n const qty = session.quantity || 1;\n\n // Book the order atomically\n const bookingResult = await bookOrder(merchant.id, product, name, phone, address, qty);\n\n if (!bookingResult.success || !bookingResult.order) {\n return {\n reply: `I'm sorry, there was an issue booking your order: ${bookingResult.error}. Please try again or contact ${merchant.name} directly at ${merchant.phone}.`,\n session_id: session.id,\n order_booked: false,\n };\n }\n\n // Dispatch supplier notification\n const dispatchResult = await dispatchSupplierNotification(merchant, bookingResult.order);\n\n // Clean up session\n await deleteSession(session.id, merchant.id);\n\n const orderConfirmation = `✅ **Order Booked Successfully!**\\n\\n` +\n `Order ID: #${bookingResult.order.id}\\n` +\n `Product: ${product.name}\\n` +\n `Quantity: ${qty}\\n` +\n `Total: $${(product.price * qty).toFixed(2)}\\n\\n` +\n `Delivery Details:\\n` +\n `Name: ${name}\\n` +\n `Phone: ${phone}\\n` +\n `Address: ${address}\\n\\n` +\n `${dispatchResult.success ? \"📦 Your order has been forwarded to the supplier for manual shipping. You'll be contacted soon!\" : \"⚠️ Your order is confirmed, but there was a delay notifying the supplier. The merchant has your order on record.\"}\\n\\n` +\n `Thank you for shopping with ${merchant.name}! 🛍️`;\n\n return {\n reply: orderConfirmation,\n session_id: generateSessionId(),\n order_booked: true,\n order_id: bookingResult.order.id,\n dispatch_sent: dispatchResult.success,\n dispatch_error: dispatchResult.success ? undefined : dispatchResult.error,\n };\n}\n\n// ═══════════════════════════════════════════════════════════════\n// HTTP ROUTER\n// ═══════════════════════════════════════════════════════════════\n\nasync function handleRequest(req: Request): Promise {\n const url = new URL(req.url);\n const path = url.pathname.replace(/\\/+$/, \"\");\n const method = req.method.toUpperCase();\n\n // Handle CORS preflight\n if (method === \"OPTIONS\") {\n return new Response(null, {\n status: 204,\n headers: {\n \"Access-Control-Allow-Origin\": \"*\",\n \"Access-Control-Allow-Methods\": \"GET, POST, PUT, DELETE, OPTIONS\",\n \"Access-Control-Allow-Headers\": \"Content-Type, X-Merchant-Key\",\n },\n });\n }\n\n // ── Health check ─────────────────────────────────────────────\n if (path === \"/\" || path === \"/api/health\") {\n return json({\n status: \"operational\",\n service: \"Multi-Tenant Commerce Engine\",\n version: \"1.0.0\",\n endpoints: {\n merchant_register: \"POST /api/merchant/register\",\n merchant_info: \"GET /api/merchant (requires X-Merchant-Key)\",\n products_list: \"GET /api/products (requires X-Merchant-Key)\",\n products_add: \"POST /api/products (requires X-Merchant-Key)\",\n products_delete: \"DELETE /api/products/:id (requires X-Merchant-Key)\",\n orders_list: \"GET /api/orders (requires X-Merchant-Key)\",\n orders_update: \"PATCH /api/orders/:id (requires X-Merchant-Key)\",\n chat: \"POST /api/chat\",\n },\n });\n }\n\n // ── Parse body for POST/PATCH/PUT ────────────────────────────\n let body: any = {};\n if (method === \"POST\" || method === \"PATCH\" || method === \"PUT\") {\n try {\n const text = await req.text();\n if (text) body = JSON.parse(text);\n } catch {\n return errorResponse(\"Invalid JSON body\", 400);\n }\n }\n\n // ═════════════════════════════════════════════════════════════\n // PUBLIC ENDPOINTS\n // ═════════════════════════════════════════════════════════════\n\n // ── POST /api/merchant/register ──────────────────────────────\n if (path === \"/api/merchant/register\" && method === \"POST\") {\n return await registerMerchant(body);\n }\n\n // ── POST /api/chat ───────────────────────────────────────────\n if (path === \"/api/chat\" && method === \"POST\") {\n if (!body.merchant_id || !body.message) {\n return errorResponse(\"Missing required fields: merchant_id, message\", 422);\n }\n\n try {\n const result = await processChatMessage(body.merchant_id, body.message, body.session_id);\n return json(result);\n } catch (err) {\n return errorResponse(`Chat processing error: ${(err as Error).message}`, 500);\n }\n }\n\n // ═════════════════════════════════════════════════════════════\n // AUTHENTICATED ENDPOINTS — require X-Merchant-Key header\n // ═════════════════════════════════════════════════════════════\n\n const apiKey = req.headers.get(\"X-Merchant-Key\");\n const merchant = await authenticateMerchant(apiKey || \"\");\n\n const protectedRoutes = [\n \"/api/merchant\",\n \"/api/products\",\n \"/api/orders\",\n ];\n\n const isProtected = protectedRoutes.some((r) => path === r || path.startsWith(r + \"/\"));\n\n if (isProtected && !merchant) {\n return errorResponse(\"Unauthorized: Valid X-Merchant-Key header required\", 401);\n }\n\n // ── GET /api/merchant ────────────────────────────────────────\n if (path === \"/api/merchant\" && method === \"GET\" && merchant) {\n return await getMerchantInfo(merchant);\n }\n\n // ── GET /api/products ────────────────────────────────────────\n if (path === \"/api/products\" && method === \"GET\" && merchant) {\n return await listProducts(merchant.id);\n }\n\n // ── POST /api/products ───────────────────────────────────────\n if (path === \"/api/products\" && method === \"POST\" && merchant) {\n return await addProduct(merchant.id, body);\n }\n\n // ── DELETE /api/products/:id ─────────────────────────────────\n const productDeleteMatch = path.match(/^\\/api\\/products\\/(\\d+)$/);\n if (productDeleteMatch && method === \"DELETE\" && merchant) {\n return await deleteProduct(merchant.id, parseInt(productDeleteMatch[1]));\n }\n\n // ── GET /api/orders ──────────────────────────────────────────\n if (path === \"/api/orders\" && method === \"GET\" && merchant) {\n return await listOrders(merchant.id);\n }\n\n // ── PATCH /api/orders/:id ────────────────────────────────────\n const orderPatchMatch = path.match(/^\\/api\\/orders\\/(\\d+)$/);\n if (orderPatchMatch && method === \"PATCH\" && merchant) {\n if (!body.status) {\n return errorResponse(\"Missing required field: status\", 422);\n }\n return await updateOrderStatus(merchant.id, parseInt(orderPatchMatch[1]), body.status);\n }\n\n // ── 404 ──────────────────────────────────────────────────────\n return errorResponse(`Route not found: ${method} ${path}`, 404);\n}\n\n// ═══════════════════════════════════════════════════════════════\n// MAIN HANDLER — initializes DB on first call, then routes\n// ═══════════════════════════════════════════════════════════════\n\nlet dbInitialized = false;\n\nexport default async function server(request: Request): Promise {\n try {\n if (!dbInitialized) {\n await initDatabase();\n dbInitialized = true;\n }\n return await handleRequest(request);\n } catch (err) {\n const message = err instanceof Error ? err.message : \"Unknown server error\";\n console.error(\"[FATAL]\", message, (err as Error)?.stack);\n return errorResponse(`Internal server error: ${message}`, 500);\n }\n}\n","/**\n * Multi-Tenant Commerce Engine — Val Town HTTP entrypoint\n * ─────────────────────────────────────────────────────────\n * Routes API requests and serves the storefront + dashboard UI.\n * Configures the Val Town SQLite adapter for the shared business logic.\n */\n\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { readFile } from \"https://esm.town/v/std/utils/index.ts\";\n\nimport { setDatabase } from \"./lib/storage.ts\";\nimport type { IDatabase } from \"./lib/types.ts\";\nimport { initDatabase } from \"./lib/db.ts\";\nimport {\n json, errorResponse, html, corsPreflight, authenticateMerchant,\n} from \"./lib/utils.ts\";\nimport {\n registerMerchant, getMerchantInfo, getPublicStoreInfo, getMerchantStats,\n} from \"./lib/merchants.ts\";\nimport {\n listProducts, addProduct, updateProduct, deleteProduct,\n} from \"./lib/products.ts\";\nimport { listOrders, updateOrderStatus } from \"./lib/orders.ts\";\nimport { processChatMessage } from \"./lib/chatbot.ts\";\n\n// ── Configure Val Town SQLite as the database adapter ──────────\nconst valTownAdapter: IDatabase = {\n async execute(sqlOrObj, args) {\n if (typeof sqlOrObj === \"string\") {\n if (args) return await sqlite.execute({ sql: sqlOrObj, args } as never);\n return await sqlite.execute(sqlOrObj as never);\n }\n return await sqlite.execute(sqlOrObj as never);\n },\n async batch(statements) {\n return await sqlite.batch(statements as never);\n },\n};\nsetDatabase(valTownAdapter);\n\n// ── Static file cache ──────────────────────────────────────────\nconst fileCache: Record = {};\n\nasync function serveStatic(path: string, contentType: string): Promise {\n if (!fileCache[path]) {\n try {\n fileCache[path] = await readFile(path);\n } catch {\n return errorResponse(\"File not found: \" + path, 404);\n }\n }\n return new Response(fileCache[path], {\n headers: {\n \"Content-Type\": contentType,\n \"Cache-Control\": \"public, max-age=300\",\n },\n });\n}\n\n// ── Router ─────────────────────────────────────────────────────\nasync function handleRequest(req: Request): Promise {\n const url = new URL(req.url);\n const path = url.pathname.replace(/\\/+$/, \"\");\n const method = req.method.toUpperCase();\n\n if (method === \"OPTIONS\") return corsPreflight();\n\n // ── Health check ─────────────────────────────────────────\n if (path === \"\" || path === \"/api/health\") {\n return json({\n status: \"operational\",\n service: \"Multi-Tenant Commerce Engine\",\n version: \"2.0.0\",\n docs: \"/dashboard\",\n endpoints: {\n register: \"POST /api/merchant/register\",\n chat: \"POST /api/chat\",\n store: \"GET /api/store/:merchantId\",\n merchant: \"GET /api/merchant (auth)\",\n products: \"GET/POST /api/products (auth)\",\n orders: \"GET /api/orders (auth)\",\n stats: \"GET /api/stats (auth)\",\n },\n });\n }\n\n // ── Static pages ─────────────────────────────────────────\n if (path === \"/dashboard\") {\n return await serveStatic(\"public/dashboard.html\", \"text/html; charset=utf-8\");\n }\n\n if (path === \"/api/widget.js\" || path === \"/widget.js\") {\n return await serveStatic(\"public/widget.js\", \"application/javascript\");\n }\n\n // Store page: /store/:merchantId — token-free storefront\n if (path.match(/^\\/store\\/.+$/) && method === \"GET\") {\n return await serveStatic(\"public/store.html\", \"text/html; charset=utf-8\");\n }\n\n // ── Parse body ───────────────────────────────────────────\n let body: Record = {};\n if ([\"POST\", \"PATCH\", \"PUT\"].includes(method)) {\n try {\n const text = await req.text();\n if (text) body = JSON.parse(text);\n } catch {\n return errorResponse(\"Invalid JSON body\", 400);\n }\n }\n\n // ════════════════════════════════════════════════════════════\n // PUBLIC ENDPOINTS — no authentication required\n // ════════════════════════════════════════════════════════════\n\n // Merchant registration\n if (path === \"/api/merchant/register\" && method === \"POST\") {\n return await registerMerchant(body as never);\n }\n\n // AI chatbot — buyers just need merchant_id, no API key\n if (path === \"/api/chat\" && method === \"POST\") {\n if (!body.merchant_id || !body.message) {\n return errorResponse(\"Missing required fields: merchant_id, message\", 422);\n }\n try {\n const result = await processChatMessage(\n body.merchant_id as string,\n body.message as string,\n body.session_id as string | undefined,\n );\n return json(result);\n } catch (err) {\n return errorResponse(`Chat processing error: ${(err as Error).message}`, 500);\n }\n }\n\n // Public store info — powers the token-free storefront\n const storeApiMatch = path.match(/^\\/api\\/store\\/(.+)$/);\n if (storeApiMatch && method === \"GET\") {\n return await getPublicStoreInfo(storeApiMatch[1]);\n }\n\n // ════════════════════════════════════════════════════════════\n // AUTHENTICATED ENDPOINTS — require X-Merchant-Key header\n // ════════════════════════════════════════════════════════════\n\n const protectedRoutes = [\"/api/merchant\", \"/api/products\", \"/api/orders\", \"/api/stats\"];\n const isProtected = protectedRoutes.some((r) => path === r || path.startsWith(r + \"/\"));\n\n if (isProtected) {\n const apiKey = req.headers.get(\"X-Merchant-Key\");\n const merchant = await authenticateMerchant(apiKey || \"\");\n if (!merchant) {\n return errorResponse(\"Unauthorized: Valid X-Merchant-Key header required\", 401);\n }\n\n // Merchant info\n if (path === \"/api/merchant\" && method === \"GET\") {\n return await getMerchantInfo(merchant);\n }\n\n // Dashboard stats\n if (path === \"/api/stats\" && method === \"GET\") {\n return await getMerchantStats(merchant);\n }\n\n // Products\n if (path === \"/api/products\" && method === \"GET\") {\n return await listProducts(merchant.id);\n }\n if (path === \"/api/products\" && method === \"POST\") {\n return await addProduct(merchant.id, body as never);\n }\n\n const productMatch = path.match(/^\\/api\\/products\\/(\\d+)$/);\n if (productMatch) {\n const productId = parseInt(productMatch[1]);\n if (method === \"PUT\") return await updateProduct(merchant.id, productId, body as never);\n if (method === \"DELETE\") return await deleteProduct(merchant.id, productId);\n }\n\n // Orders\n if (path === \"/api/orders\" && method === \"GET\") {\n return await listOrders(merchant.id);\n }\n const orderMatch = path.match(/^\\/api\\/orders\\/(\\d+)$/);\n if (orderMatch && method === \"PATCH\") {\n if (!body.status) return errorResponse(\"Missing required field: status\", 422);\n return await updateOrderStatus(merchant.id, parseInt(orderMatch[1]), body.status as string);\n }\n }\n\n // ── 404 ──────────────────────────────────────────────────\n return errorResponse(`Route not found: ${method} ${path}`, 404);\n}\n\n// ── Main handler ───────────────────────────────────────────────\nlet dbInitialized = false;\n\nexport default async function server(request: Request): Promise {\n try {\n if (!dbInitialized) {\n await initDatabase();\n dbInitialized = true;\n }\n return await handleRequest(request);\n } catch (err) {\n const message = err instanceof Error ? err.message : \"Unknown server error\";\n console.error(\"[FATAL]\", message, (err as Error)?.stack);\n return errorResponse(`Internal server error: ${message}`, 500);\n }\n}\n","createdAt",["D",1784916152206],"branchVersion","branchId","a336bfb1-1072-4277-b7fc-005e38ac2fe6","id","9de191f9-48f6-48da-aac9-14e998a3990a","multi-tenant-commerce-engine",["D",1784711864701],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Multi-tenant e-commerce with AI chatbot, storefront & dashboard","imageUrl","e6b73de9-15b6-4de0-855b-91420681c7c7","pinnedFileId","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","019f8918-ca48-713a-b13d-08dd6e21c61e","tursoName","9de191f948f648daaac914e998a3990a","tursoHostname","9de191f948f648daaac914e998a3990a-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789572079973],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_105":104,"_112":107},"org",{"_105":104,"_106":107,"_108":107,"_19":61,"_109":110,"_111":31},"branch",{"_13":94,"_38":95,"_49":48,"_96":50,"_97":-5,"_98":-5,"_99":-5,"_100":-5,"_101":-5,"_102":51,"_103":104},"isOwned",19,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","tokigo7440","handle","displayName","","avatar","tier","free","canRestrictVals","profileImageUrl","branchName","adoptOrgId",{"_49":50,"_38":51,"_44":287,"_53":-5,"_54":31,"_55":56,"_57":56,"_58":59,"_60":-5,"_19":61,"_62":37,"_63":64,"_65":-5,"_66":-5,"_67":68,"_69":70,"_71":72,"_73":74,"_75":288,"_77":-5,"_78":79,"_80":79,"_81":82,"_83":82,"_84":82,"_85":79,"_86":79,"_87":289,"_89":290,"_91":291,"_93":31},"tree",[167,177,181],"files",[167,168,169,170,171,172,173,174,175,176,177,178,179,180,181],"counts",{"_156":68,"_157":158,"_159":68,"_160":161,"_162":163},"contents",[134,135,136],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_49":150,"_38":151,"_36":152,"_138":-5,"_47":48,"_46":153,"_139":64,"_44":154,"_13":68,"_39":148,"_41":-5,"_30":31,"_142":-5,"_33":155},{"_49":144,"_38":56,"_36":145,"_138":-5,"_47":48,"_46":146,"_139":64,"_44":147,"_13":68,"_39":148,"_41":-5,"_30":31,"_142":-5,"_33":149},{"_49":137,"_38":34,"_36":37,"_138":-5,"_47":48,"_46":14,"_139":64,"_44":140,"_13":141,"_39":40,"_41":43,"_30":31,"_142":-5,"_33":143},"865d51c0-94e5-4516-96b1-063924def70c","parentId","latest",["D",1784916152206],3,"label",[34],"49823af4-1145-4c90-8ba3-d774515240e4","a0c76703-0abf-4f18-9323-1c64c80692b1",13,["D",1784915982133],"directory",[56],"5de464d3-7b28-4672-afcb-ef648aaf1e6d","lib","8391a2ad-4660-4274-aa7d-baf3ec4c023d",4,["D",1784915835212],[151],"pulls","branches",1,"forks","envVars",{"_164":68,"_166":68},"connections",{"_164":68,"_165":68},"count","unfilledCount","emptyCount",{"_49":150,"_38":151,"_36":152,"_138":-5,"_47":48,"_46":153,"_139":64,"_44":284,"_13":68,"_39":148,"_41":-5,"_30":31,"_142":-5,"_183":285,"_33":286},{"_49":276,"_38":277,"_36":278,"_138":152,"_47":48,"_46":279,"_139":64,"_44":280,"_13":68,"_39":191,"_41":281,"_30":31,"_142":-5,"_183":282,"_33":283},{"_49":268,"_38":269,"_36":270,"_138":152,"_47":48,"_46":271,"_139":64,"_44":272,"_13":68,"_39":191,"_41":273,"_30":31,"_142":-5,"_183":274,"_33":275},{"_49":260,"_38":261,"_36":262,"_138":152,"_47":48,"_46":263,"_139":64,"_44":264,"_13":68,"_39":191,"_41":265,"_30":31,"_142":-5,"_183":266,"_33":267},{"_49":252,"_38":253,"_36":254,"_138":152,"_47":48,"_46":255,"_139":64,"_44":256,"_13":68,"_39":191,"_41":257,"_30":31,"_142":-5,"_183":258,"_33":259},{"_49":244,"_38":245,"_36":246,"_138":152,"_47":48,"_46":247,"_139":64,"_44":248,"_13":68,"_39":191,"_41":249,"_30":31,"_142":-5,"_183":250,"_33":251},{"_49":236,"_38":237,"_36":238,"_138":152,"_47":48,"_46":239,"_139":64,"_44":240,"_13":68,"_39":191,"_41":241,"_30":31,"_142":-5,"_183":242,"_33":243},{"_49":228,"_38":229,"_36":230,"_138":152,"_47":48,"_46":231,"_139":64,"_44":232,"_13":68,"_39":191,"_41":233,"_30":31,"_142":-5,"_183":234,"_33":235},{"_49":221,"_38":222,"_36":223,"_138":152,"_47":48,"_46":153,"_139":64,"_44":224,"_13":68,"_39":191,"_41":225,"_30":31,"_142":-5,"_183":226,"_33":227},{"_49":213,"_38":214,"_36":215,"_138":152,"_47":48,"_46":216,"_139":64,"_44":217,"_13":68,"_39":191,"_41":218,"_30":31,"_142":-5,"_183":219,"_33":220},{"_49":144,"_38":56,"_36":145,"_138":-5,"_47":48,"_46":146,"_139":64,"_44":210,"_13":68,"_39":148,"_41":-5,"_30":31,"_142":-5,"_183":211,"_33":212},{"_49":202,"_38":203,"_36":204,"_138":145,"_47":48,"_46":205,"_139":64,"_44":206,"_13":68,"_39":26,"_41":207,"_30":31,"_142":-5,"_183":208,"_33":209},{"_49":195,"_38":196,"_36":197,"_138":145,"_47":48,"_46":146,"_139":64,"_44":198,"_13":68,"_39":26,"_41":199,"_30":31,"_142":-5,"_183":200,"_33":201},{"_49":186,"_38":187,"_36":188,"_138":145,"_47":48,"_46":189,"_139":64,"_44":190,"_13":68,"_39":191,"_41":192,"_30":31,"_142":-5,"_183":193,"_33":194},{"_49":137,"_38":34,"_36":37,"_138":-5,"_47":48,"_46":14,"_139":64,"_44":182,"_13":141,"_39":40,"_41":43,"_30":31,"_142":-5,"_183":184,"_33":185},["D",1784916152206],"children",[],[34],"0564cdd5-83db-4659-bbca-d38f92374233","widget.js","a25a18aa-8789-11f1-b579-1607ee4eb77e",15,["D",1784916062917],"script","/**\n * Embeddable Chat Widget for Multi-Tenant Commerce Engine\n * ───────────────────────────────────────────────────────\n * Usage: Add this script tag to any HTML page:\n * \n *\n * Creates a floating 💬 button that opens a chat window connected\n * to the merchant's AI shopping assistant. No API key needed —\n * buyers just chat and order.\n */\n(function () {\n var scriptTag = document.currentScript;\n var url = new URL(scriptTag.src);\n var merchantId = url.searchParams.get(\"merchant\") || \"\";\n var baseUrl = url.origin;\n\n if (!merchantId) {\n console.error(\"[CommerceWidget] Missing ?merchant= parameter\");\n return;\n }\n\n var sessionId = null;\n var isOpen = false;\n\n // ── Styles ──────────────────────────────────────────────\n var css = document.createElement(\"style\");\n css.textContent = [\n \".cw-fab{position:fixed;bottom:24px;right:24px;width:60px;height:60px;border-radius:50%\",\n \"background:#6366f1;border:none;cursor:pointer;font-size:1.6rem;color:#fff;z-index:99998;\",\n \"box-shadow:0 4px 20px rgba(99,102,241,.4);transition:transform .15s}\",\n \".cw-fab:hover{transform:scale(1.08)}\",\n \".cw-win{position:fixed;bottom:100px;right:24px;width:380px;max-width:calc(100vw - 48px)\",\n \"height:520px;max-height:calc(100vh - 140px);background:#1a1d27;border:1px solid #2a2d3a\",\n \"border-radius:12px;display:none;flex-direction:column;z-index:99999;font-family:inherit\",\n \"box-shadow:0 8px 40px rgba(0,0,0,.4)}\",\n \".cw-win.open{display:flex}\",\n \".cw-hdr{padding:16px 20px;background:#6366f1;border-radius:12px 12px 0 0;font-weight:600\",\n \"font-size:1rem;color:#fff;display:flex;justify-content:space-between;align-items:center}\",\n \".cw-hdr button{background:none;border:none;color:#fff;cursor:pointer;font-size:1.2rem}\",\n \".cw-msgs{flex:1;overflow-y:auto;padding:16px;display:flex;flex-direction:column;gap:10px}\",\n \".cw-msg{max-width:80%;padding:10px 14px;border-radius:14px;font-size:.88rem;line-height:1.45\",\n \"word-wrap:break-word}\",\n \".cw-bot{background:#0f1117;border:1px solid #2a2d3a;color:#e4e6eb;align-self:flex-start;border-bottom-left-radius:4px;white-space:pre-wrap}\",\n \".cw-user{background:#6366f1;color:#fff;align-self:flex-end;border-bottom-right-radius:4px;white-space:pre-wrap}\",\n \".cw-sys{background:rgba(34,197,94,.12);border:1px solid #22c55e;color:#22c55e;align-self:center;text-align:center;max-width:90%;font-size:.82rem}\",\n \".cw-in{padding:12px;display:flex;gap:8px;border-top:1px solid #2a2d3a}\",\n \".cw-in input{flex:1;padding:10px 14px;background:#0f1117;border:1px solid #2a2d3a\",\n \"border-radius:8px;color:#e4e6eb;font-size:.88rem;outline:none;font-family:inherit}\",\n \".cw-in input:focus{border-color:#6366f1}\",\n \".cw-in button{padding:10px 18px;background:#6366f1;border:none;border-radius:8px\",\n \"color:#fff;cursor:pointer;font-weight:600;font-family:inherit}\",\n \".cw-in button:hover{background:#4f46e5}\",\n \".cw-in button:disabled{opacity:.5}\",\n \".cw-typing{color:#8b8e98;font-size:.8rem;padding:4px 14px}\",\n ].join(\";\");\n document.head.appendChild(css);\n\n // ── DOM ─────────────────────────────────────────────────\n var fab = document.createElement(\"button\");\n fab.className = \"cw-fab\";\n fab.textContent = \"💬\";\n fab.onclick = toggle;\n document.body.appendChild(fab);\n\n var win = document.createElement(\"div\");\n win.className = \"cw-win\";\n win.innerHTML =\n '

💬 AI Shopping Assistant

' +\n '

';\n document.body.appendChild(win);\n\n win.querySelector(\"#cw-close\").onclick = toggle;\n var inputEl = win.querySelector(\"#cw-input\");\n var sendBtn = win.querySelector(\"#cw-send\");\n var msgsEl = win.querySelector(\"#cw-msgs\");\n inputEl.addEventListener(\"keydown\", function (e) { if (e.key === \"Enter\") send(); });\n sendBtn.onclick = send;\n\n // ── Chat logic ──────────────────────────────────────────\n function toggle() {\n isOpen = !isOpen;\n win.classList.toggle(\"open\", isOpen);\n if (isOpen) {\n inputEl.focus();\n if (!msgsEl.children.length) {\n addMsg(\"cw-bot\", \"👋 Hello! Ask me about products, prices, or say \\\"I want to buy [product]\\\" to place an order.\");\n }\n }\n }\n\n function addMsg(cls, text) {\n var d = document.createElement(\"div\");\n d.className = \"cw-msg \" + cls;\n d.textContent = text;\n msgsEl.appendChild(d);\n msgsEl.scrollTop = 999999;\n return d;\n }\n\n async function send() {\n var msg = inputEl.value.trim();\n if (!msg) return;\n inputEl.value = \"\";\n addMsg(\"cw-user\", msg);\n sendBtn.disabled = true;\n var typingEl = addMsg(\"cw-bot\", \"…\");\n typingEl.classList.add(\"cw-typing\");\n try {\n var res = await fetch(baseUrl + \"/api/chat\", {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ merchant_id: merchantId, message: msg, session_id: sessionId }),\n });\n var data = await res.json();\n typingEl.remove();\n if (data.session_id) sessionId = data.session_id;\n addMsg(\"cw-bot\", data.reply);\n if (data.order_booked) {\n var sys = document.createElement(\"div\");\n sys.className = \"cw-msg cw-sys\";\n sys.textContent = \"✅ Order #\" + data.order_id + \" booked! The merchant has been notified.\";\n msgsEl.appendChild(sys);\n msgsEl.scrollTop = 999999;\n }\n } catch (e) {\n typingEl.remove();\n addMsg(\"cw-bot\", \"⚠️ Connection error. Please try again.\");\n }\n sendBtn.disabled = false;\n inputEl.focus();\n }\n})();\n",[],[56,187],"f1591a7e-cfcc-49e4-98ac-e4f5c5af2844","store.html","72339bce-8789-11f1-ba4d-1607ee4eb77e",["D",1784915982133],"\n\n\n\n\nStore\n\n\n\n

Loading store…

\n\n\n\n

\n 💬 AI Shopping Assistant\n \n

\n \n \n

\n\n\n\n\n",[],[56,196],"fc66cea2-cf2f-44f3-adcd-ce2744116f9b","dashboard.html","94cf6adc-8789-11f1-a92b-1607ee4eb77e",14,["D",1784916039959],"\n\n\n\n\nMerchant Dashboard — Commerce Engine\n\n\n\n

\n\n\n

🏪 Commerce Engine

\n\n \n \n\n \n

Register Your Store

\n Store Name *\n \n

\n Phone *\n \n

\n Country *\n \n

\n Webhook URL * (for order notifications)\n \n

\n \n

\n Already registered? Login here\n

\n\n\n

🏪

\n \n

\n\n

\n \n \n \n \n

\n\n \n

Recent Orders

\n\n \n

Add Product

Name *

Price * ($)

Description

Stock

Your Products

\n\n \n

All Orders

\n\n \n \n

\n\n

\n\n\n\n\n",[],[56,203],["D",1784915982133],[178,179,180],[56],"14ae8848-8e4b-44c2-be86-0bb6c36c8ea1","utils.ts","270f37b6-8789-11f1-b06e-1607ee4eb77e",6,["D",1784915856065],"/**\n * Shared HTTP utilities: JSON responses, CORS, ID generation, auth.\n * Platform-agnostic — no Val Town-specific imports.\n */\n\nimport type { Merchant } from \"./types.ts\";\nimport { db } from \"./storage.ts\";\n\n// ── HTTP helpers ────────────────────────────────────────────────\n\nexport function json(data: unknown, status = 200): Response {\n return new Response(JSON.stringify(data), {\n status,\n headers: {\n \"Content-Type\": \"application/json\",\n \"Access-Control-Allow-Origin\": \"*\",\n \"Access-Control-Allow-Methods\": \"GET, POST, PUT, PATCH, DELETE, OPTIONS\",\n \"Access-Control-Allow-Headers\": \"Content-Type, X-Merchant-Key\",\n },\n });\n}\n\nexport function errorResponse(message: string, status = 400): Response {\n return json({ error: message }, status);\n}\n\nexport function html(content: string, status = 200): Response {\n return new Response(content, {\n status,\n headers: {\n \"Content-Type\": \"text/html; charset=utf-8\",\n \"Cache-Control\": \"no-cache\",\n },\n });\n}\n\nexport function corsPreflight(): Response {\n return new Response(null, {\n status: 204,\n headers: {\n \"Access-Control-Allow-Origin\": \"*\",\n \"Access-Control-Allow-Methods\": \"GET, POST, PUT, PATCH, DELETE, OPTIONS\",\n \"Access-Control-Allow-Headers\": \"Content-Type, X-Merchant-Key\",\n },\n });\n}\n\n// ── ID generators ───────────────────────────────────────────────\n\nexport function generateId(): string {\n return \"mrc_\" + crypto.randomUUID().replace(/-/g, \"\").slice(0, 16);\n}\n\nexport function generateApiKey(): string {\n const bytes = new Uint8Array(24);\n crypto.getRandomValues(bytes);\n return \"sk_\" +\n Array.from(bytes, (b) => b.toString(16).padStart(2, \"0\")).join(\"\");\n}\n\nexport function generateSessionId(): string {\n return \"ses_\" + crypto.randomUUID().replace(/-/g, \"\");\n}\n\n// ── Authentication ──────────────────────────────────────────────\n\nexport async function authenticateMerchant(\n apiKey: string,\n): Promise {\n if (!apiKey) return null;\n try {\n const result = await db().execute({\n sql: \"SELECT * FROM merchants WHERE api_key = ?\",\n args: [apiKey],\n });\n if (result.rows.length === 0) return null;\n return result.rows[0] as unknown as Merchant;\n } catch {\n return null;\n }\n}\n\nexport async function getMerchantById(\n merchantId: string,\n): Promise {\n try {\n const result = await db().execute({\n sql: \"SELECT * FROM merchants WHERE id = ?\",\n args: [merchantId],\n });\n if (result.rows.length === 0) return null;\n return result.rows[0] as unknown as Merchant;\n } catch {\n return null;\n }\n}\n",[],[151,214],"8098a05b-4d32-4186-a8c6-17623ed0b8a8","types.ts","1aa28078-8789-11f1-89ae-1607ee4eb77e",["D",1784915835212],"/**\n * Shared type definitions + database abstraction interface.\n * Used by both the Val Town server (main.ts) and the Termux/local\n * server (termux/server.ts) so business logic is platform-agnostic.\n */\n\nexport interface Merchant {\n id: string;\n name: string;\n phone: string;\n country: string;\n webhook_url: string;\n api_key: string;\n created_at: string;\n}\n\nexport interface Product {\n id: number;\n merchant_id: string;\n name: string;\n price: number;\n description: string;\n stock: number;\n category: string;\n image_url: string;\n created_at: string;\n}\n\nexport interface Order {\n id: number;\n merchant_id: string;\n customer_name: string;\n customer_phone: string;\n customer_address: string;\n product_id: number;\n product_name: string;\n quantity: number;\n total_price: number;\n status: string;\n created_at: string;\n}\n\nexport interface ChatSession {\n id: string;\n merchant_id: string;\n customer_name: string | null;\n customer_phone: string | null;\n customer_address: string | null;\n product_id: number | null;\n product_name: string | null;\n quantity: number | null;\n state: string;\n updated_at: string;\n}\n\nexport interface ChatResponse {\n reply: string;\n session_id: string;\n order_booked: boolean;\n order_id?: number;\n dispatch_sent?: boolean;\n dispatch_error?: string;\n}\n\n/** Result shape returned by IDatabase.execute() */\nexport interface QueryResult {\n rows: Record[];\n rowsAffected: number;\n lastInsertRowid: bigint | null;\n}\n\n/**\n * Platform-agnostic database interface.\n * Matches the Val Town sqlite API surface so the same\n * business-logic code works on Val Town (libSQL) and\n * locally on Termux (node:sqlite).\n */\nexport interface IDatabase {\n execute(\n sql: string | { sql: string; args?: unknown[] },\n args?: unknown[],\n ): Promise;\n batch(statements: { sql: string; args?: unknown[] }[]): Promise;\n}\n",[],[151,222],"71bb3b3c-127b-4241-adbc-89022d28f918","storage.ts","21cf6ec4-8789-11f1-8c02-1607ee4eb77e",5,["D",1784915847169],"/**\n * Storage singleton — the single point where database access is resolved.\n *\n * On Val Town: main.ts calls setDatabase() with a thin wrapper around\n * https://esm.town/v/std/sqlite/main.ts\n *\n * On Termux / local Deno: termux/server.ts calls setDatabase() with a\n * wrapper around node:sqlite (DatabaseSync).\n *\n * All other lib modules import { db } from here and never touch a\n * platform-specific import, keeping business logic 100% portable.\n */\n\nimport type { IDatabase } from \"./types.ts\";\n\nlet _db: IDatabase | null = null;\n\n/** Called once during server startup to inject the platform adapter. */\nexport function setDatabase(adapter: IDatabase): void {\n _db = adapter;\n}\n\n/** Returns the configured database. Throws if setDatabase() was never called. */\nexport function db(): IDatabase {\n if (!_db) {\n throw new Error(\n \"Database not configured. Call setDatabase() before using any DB operations.\",\n );\n }\n return _db;\n}\n",[],[151,229],"137a1e20-337a-4c66-8a82-63db965eb034","products.ts","34d90d22-8789-11f1-ab5b-1607ee4eb77e",9,["D",1784915879161],"/**\n * Product management — list, add, update, delete.\n * Every query includes merchant_id WHERE clause for tenant isolation.\n */\n\nimport type { Product } from \"./types.ts\";\nimport { db } from \"./storage.ts\";\nimport { json, errorResponse } from \"./utils.ts\";\n\nexport async function listProducts(merchantId: string): Promise {\n try {\n const result = await db().execute({\n sql: \"SELECT * FROM products WHERE merchant_id = ? ORDER BY created_at DESC\",\n args: [merchantId],\n });\n return json({ products: result.rows, count: result.rows.length });\n } catch (err) {\n return errorResponse(\n `Failed to list products: ${(err as Error).message}`,\n 500,\n );\n }\n}\n\nexport async function addProduct(\n merchantId: string,\n body: {\n name: string;\n price: number;\n description?: string;\n stock?: number;\n category?: string;\n image_url?: string;\n },\n): Promise {\n if (!body.name || body.price === undefined) {\n return errorResponse(\"Missing required fields: name, price\", 422);\n }\n\n if (body.price < 0) {\n return errorResponse(\"Price cannot be negative\", 422);\n }\n\n const createdAt = new Date().toISOString();\n\n try {\n await db().execute({\n sql: `INSERT INTO products (merchant_id, name, price, description, stock, category, image_url, created_at)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?)`,\n args: [\n merchantId,\n body.name,\n body.price,\n body.description || \"\",\n body.stock ?? 0,\n body.category || \"general\",\n body.image_url || \"\",\n createdAt,\n ],\n });\n\n const result = await db().execute({\n sql: \"SELECT * FROM products WHERE merchant_id = ? AND name = ? ORDER BY id DESC LIMIT 1\",\n args: [merchantId, body.name],\n });\n\n return json(\n { product: result.rows[0], message: \"Product added successfully\" },\n 201,\n );\n } catch (err) {\n return errorResponse(\n `Failed to add product: ${(err as Error).message}`,\n 500,\n );\n }\n}\n\nexport async function updateProduct(\n merchantId: string,\n productId: number,\n body: {\n name?: string;\n price?: number;\n description?: string;\n stock?: number;\n category?: string;\n image_url?: string;\n },\n): Promise {\n const fields: string[] = [];\n const args: unknown[] = [];\n\n if (body.name !== undefined) { fields.push(\"name = ?\"); args.push(body.name); }\n if (body.price !== undefined) { fields.push(\"price = ?\"); args.push(body.price); }\n if (body.description !== undefined) { fields.push(\"description = ?\"); args.push(body.description); }\n if (body.stock !== undefined) { fields.push(\"stock = ?\"); args.push(body.stock); }\n if (body.category !== undefined) { fields.push(\"category = ?\"); args.push(body.category); }\n if (body.image_url !== undefined) { fields.push(\"image_url = ?\"); args.push(body.image_url); }\n\n if (fields.length === 0) {\n return errorResponse(\"No fields to update\", 422);\n }\n\n args.push(productId, merchantId);\n\n try {\n const result = await db().execute({\n sql: `UPDATE products SET ${fields.join(\", \")} WHERE id = ? AND merchant_id = ?`,\n args,\n });\n\n if (result.rowsAffected === 0) {\n return errorResponse(\"Product not found or not owned by this merchant\", 404);\n }\n\n const updated = await db().execute({\n sql: \"SELECT * FROM products WHERE id = ? AND merchant_id = ?\",\n args: [productId, merchantId],\n });\n\n return json({ product: updated.rows[0], message: \"Product updated\" });\n } catch (err) {\n return errorResponse(\n `Failed to update product: ${(err as Error).message}`,\n 500,\n );\n }\n}\n\nexport async function deleteProduct(\n merchantId: string,\n productId: number,\n): Promise {\n try {\n const result = await db().execute({\n sql: \"DELETE FROM products WHERE id = ? AND merchant_id = ?\",\n args: [productId, merchantId],\n });\n\n if (result.rowsAffected === 0) {\n return errorResponse(\"Product not found or not owned by this merchant\", 404);\n }\n\n return json({ message: \"Product deleted successfully\" });\n } catch (err) {\n return errorResponse(\n `Failed to delete product: ${(err as Error).message}`,\n 500,\n );\n }\n}\n",[],[151,237],"4e973f43-bf2a-4a4b-9602-944a7db6d9d6","orders.ts","3b59fbca-8789-11f1-ba4d-1607ee4eb77e",10,["D",1784915890110],"/**\n * Order management — list, update status, atomic booking.\n * Every query includes merchant_id WHERE clause for tenant isolation.\n */\n\nimport type { Order, Product } from \"./types.ts\";\nimport { db } from \"./storage.ts\";\nimport { json, errorResponse } from \"./utils.ts\";\n\nexport async function listOrders(merchantId: string): Promise {\n try {\n const result = await db().execute({\n sql: \"SELECT * FROM orders WHERE merchant_id = ? ORDER BY created_at DESC\",\n args: [merchantId],\n });\n return json({ orders: result.rows, count: result.rows.length });\n } catch (err) {\n return errorResponse(\n `Failed to list orders: ${(err as Error).message}`,\n 500,\n );\n }\n}\n\nexport async function updateOrderStatus(\n merchantId: string,\n orderId: number,\n status: string,\n): Promise {\n const validStatuses = [\"booked\", \"dispatched\", \"delivered\", \"cancelled\"];\n if (!validStatuses.includes(status)) {\n return errorResponse(\n `Invalid status. Must be one of: ${validStatuses.join(\", \")}`,\n 422,\n );\n }\n\n try {\n const result = await db().execute({\n sql: \"UPDATE orders SET status = ? WHERE id = ? AND merchant_id = ?\",\n args: [status, orderId, merchantId],\n });\n\n if (result.rowsAffected === 0) {\n return errorResponse(\n \"Order not found or not owned by this merchant\",\n 404,\n );\n }\n\n return json({ message: \"Order status updated\", order_id: orderId, status });\n } catch (err) {\n return errorResponse(\n `Failed to update order: ${(err as Error).message}`,\n 500,\n );\n }\n}\n\n/**\n * Book an order atomically — inserts the order row and decrements\n * product stock in a single transaction.\n */\nexport async function bookOrder(\n merchantId: string,\n product: Product,\n customerName: string,\n customerPhone: string,\n customerAddress: string,\n quantity: number,\n): Promise<{ success: boolean; order?: Order; error?: string }> {\n const totalPrice = product.price * quantity;\n const createdAt = new Date().toISOString();\n\n try {\n await db().batch([\n {\n sql: `INSERT INTO orders (merchant_id, customer_name, customer_phone, customer_address, product_id, product_name, quantity, total_price, status, created_at)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?, 'booked', ?)`,\n args: [merchantId, customerName, customerPhone, customerAddress, product.id, product.name, quantity, totalPrice, createdAt],\n },\n {\n sql: \"UPDATE products SET stock = stock - ? WHERE id = ? AND merchant_id = ?\",\n args: [quantity, product.id, merchantId],\n },\n ]);\n\n const result = await db().execute({\n sql: \"SELECT * FROM orders WHERE merchant_id = ? ORDER BY id DESC LIMIT 1\",\n args: [merchantId],\n });\n\n const order = result.rows[0] as unknown as Order;\n return { success: true, order };\n } catch (err) {\n return { success: false, error: (err as Error).message };\n }\n}\n",[],[151,245],"5008cc6c-506a-4362-8a76-466a4203fae1","merchants.ts","34d51bea-8789-11f1-a92b-1607ee4eb77e",8,["D",1784915879160],"/**\n * Merchant management — registration, profile, stats.\n */\n\nimport type { Merchant } from \"./types.ts\";\nimport { db } from \"./storage.ts\";\nimport {\n json,\n errorResponse,\n generateId,\n generateApiKey,\n} from \"./utils.ts\";\n\nexport async function registerMerchant(body: {\n name: string;\n phone: string;\n country: string;\n webhook_url: string;\n}): Promise {\n if (!body.name || !body.phone || !body.country || !body.webhook_url) {\n return errorResponse(\n \"Missing required fields: name, phone, country, webhook_url\",\n 422,\n );\n }\n\n const id = generateId();\n const apiKey = generateApiKey();\n const createdAt = new Date().toISOString();\n\n try {\n await db().execute({\n sql: `INSERT INTO merchants (id, name, phone, country, webhook_url, api_key, created_at)\n VALUES (?, ?, ?, ?, ?, ?, ?)`,\n args: [id, body.name, body.phone, body.country, body.webhook_url, apiKey, createdAt],\n });\n\n return json({\n merchant_id: id,\n api_key: apiKey,\n name: body.name,\n webhook_url: body.webhook_url,\n message: \"Merchant registered successfully. Store your API key securely.\",\n }, 201);\n } catch (err) {\n return errorResponse(\n `Merchant registration failed: ${(err as Error).message}`,\n 500,\n );\n }\n}\n\nexport async function getMerchantInfo(merchant: Merchant): Promise {\n return json({\n id: merchant.id,\n name: merchant.name,\n phone: merchant.phone,\n country: merchant.country,\n webhook_url: merchant.webhook_url,\n created_at: merchant.created_at,\n });\n}\n\n/** Public store info for the token-free storefront — no API key needed. */\nexport async function getPublicStoreInfo(\n merchantId: string,\n): Promise {\n try {\n const merchantResult = await db().execute({\n sql: \"SELECT id, name, country FROM merchants WHERE id = ?\",\n args: [merchantId],\n });\n if (merchantResult.rows.length === 0) {\n return errorResponse(\"Store not found\", 404);\n }\n\n const productResult = await db().execute({\n sql: \"SELECT id, name, price, description, stock, category, image_url FROM products WHERE merchant_id = ? ORDER BY created_at DESC\",\n args: [merchantId],\n });\n\n const orderResult = await db().execute({\n sql: \"SELECT COUNT(*) as count FROM orders WHERE merchant_id = ?\",\n args: [merchantId],\n });\n\n return json({\n merchant: merchantResult.rows[0],\n products: productResult.rows,\n product_count: productResult.rows.length,\n total_orders: (orderResult.rows[0] as Record)?.count ?? 0,\n });\n } catch (err) {\n return errorResponse(\n `Failed to fetch store info: ${(err as Error).message}`,\n 500,\n );\n }\n}\n\n/** Dashboard stats for the authenticated merchant. */\nexport async function getMerchantStats(\n merchant: Merchant,\n): Promise {\n try {\n const [productResult, orderResult, pendingResult, revenueResult] =\n await Promise.all([\n db().execute({\n sql: \"SELECT COUNT(*) as count FROM products WHERE merchant_id = ?\",\n args: [merchant.id],\n }),\n db().execute({\n sql: \"SELECT COUNT(*) as count FROM orders WHERE merchant_id = ?\",\n args: [merchant.id],\n }),\n db().execute({\n sql: \"SELECT COUNT(*) as count FROM orders WHERE merchant_id = ? AND status = 'booked'\",\n args: [merchant.id],\n }),\n db().execute({\n sql: \"SELECT COALESCE(SUM(total_price), 0) as revenue FROM orders WHERE merchant_id = ? AND status != 'cancelled'\",\n args: [merchant.id],\n }),\n ]);\n\n return json({\n product_count: (productResult.rows[0] as Record)?.count ?? 0,\n total_orders: (orderResult.rows[0] as Record)?.count ?? 0,\n pending_orders: (pendingResult.rows[0] as Record)?.count ?? 0,\n revenue: (revenueResult.rows[0] as Record)?.revenue ?? 0,\n });\n } catch (err) {\n return errorResponse(\n `Failed to fetch stats: ${(err as Error).message}`,\n 500,\n );\n }\n}\n",[],[151,253],"89b40d6c-b740-4bca-8a92-76b9b6d906f2","dispatch.ts","3b609d5e-8789-11f1-a92b-1607ee4eb77e",11,["D",1784915890112],"/**\n * Supplier dispatch notifications — sends a webhook to the merchant's\n * configured webhook_url when a new order is booked by the AI chatbot.\n */\n\nimport type { Merchant, Order } from \"./types.ts\";\n\nexport async function dispatchSupplierNotification(\n merchant: Merchant,\n order: Order,\n): Promise<{ success: boolean; error?: string }> {\n const payload = {\n event: \"new_order\",\n merchant_id: merchant.id,\n merchant_name: merchant.name,\n order_id: order.id,\n message: `New Order Booked by AI Agent. Customer Name: ${order.customer_name}, Address: ${order.customer_address}, Item: ${order.product_name} (Qty: ${order.quantity}). ACTION REQUIRED: Please ship this order MANUALLY now.`,\n order_details: {\n customer_name: order.customer_name,\n customer_phone: order.customer_phone,\n customer_address: order.customer_address,\n product_name: order.product_name,\n quantity: order.quantity,\n total_price: order.total_price,\n order_id: order.id,\n created_at: order.created_at,\n },\n timestamp: new Date().toISOString(),\n };\n\n try {\n const response = await fetch(merchant.webhook_url, {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\",\n \"X-Order-Source\": \"AI-Agent\",\n \"X-Merchant-Id\": merchant.id,\n },\n body: JSON.stringify(payload),\n signal: AbortSignal.timeout(10000),\n });\n\n if (!response.ok) {\n return { success: false, error: `Webhook returned ${response.status}` };\n }\n\n return { success: true };\n } catch (err) {\n return { success: false, error: (err as Error).message };\n }\n}\n",[],[151,261],"4f23ea0c-4b95-4a42-b355-256e3bb3b3e0","db.ts","2aac0fb6-8789-11f1-a92b-1607ee4eb77e",7,["D",1784915862125],"/**\n * Database schema initialization.\n * Creates all tables and indexes if they don't exist.\n * Called once on server startup (idempotent).\n */\n\nimport { db } from \"./storage.ts\";\n\nexport async function initDatabase(): Promise {\n const database = db();\n\n await database.execute(`\n CREATE TABLE IF NOT EXISTS merchants (\n id TEXT PRIMARY KEY,\n name TEXT NOT NULL,\n phone TEXT NOT NULL,\n country TEXT NOT NULL,\n webhook_url TEXT NOT NULL,\n api_key TEXT NOT NULL UNIQUE,\n created_at TEXT NOT NULL\n )\n `);\n\n await database.execute(`\n CREATE TABLE IF NOT EXISTS products (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n merchant_id TEXT NOT NULL,\n name TEXT NOT NULL,\n price REAL NOT NULL,\n description TEXT DEFAULT '',\n stock INTEGER DEFAULT 0,\n category TEXT DEFAULT 'general',\n image_url TEXT DEFAULT '',\n created_at TEXT NOT NULL,\n FOREIGN KEY (merchant_id) REFERENCES merchants(id)\n )\n `);\n\n await database.execute(`\n CREATE TABLE IF NOT EXISTS orders (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n merchant_id TEXT NOT NULL,\n customer_name TEXT NOT NULL,\n customer_phone TEXT NOT NULL,\n customer_address TEXT NOT NULL,\n product_id INTEGER NOT NULL,\n product_name TEXT NOT NULL,\n quantity INTEGER NOT NULL,\n total_price REAL NOT NULL,\n status TEXT DEFAULT 'booked',\n created_at TEXT NOT NULL,\n FOREIGN KEY (merchant_id) REFERENCES merchants(id),\n FOREIGN KEY (product_id) REFERENCES products(id)\n )\n `);\n\n await database.execute(`\n CREATE TABLE IF NOT EXISTS chat_sessions (\n id TEXT PRIMARY KEY,\n merchant_id TEXT NOT NULL,\n customer_name TEXT,\n customer_phone TEXT,\n customer_address TEXT,\n product_id INTEGER,\n product_name TEXT,\n quantity INTEGER,\n state TEXT DEFAULT 'browsing',\n updated_at TEXT NOT NULL,\n FOREIGN KEY (merchant_id) REFERENCES merchants(id)\n )\n `);\n\n await database.execute(\n \"CREATE INDEX IF NOT EXISTS idx_products_merchant ON products(merchant_id)\",\n );\n await database.execute(\n \"CREATE INDEX IF NOT EXISTS idx_orders_merchant ON orders(merchant_id)\",\n );\n await database.execute(\n \"CREATE INDEX IF NOT EXISTS idx_chat_sessions_merchant ON chat_sessions(merchant_id)\",\n );\n}\n",[],[151,269],"20fa906a-ff34-4b8a-9b1b-bce2d1417bd6","chatbot.ts","59da5a9a-8789-11f1-b06e-1607ee4eb77e",12,["D",1784915941286],"/**\n * AI Chatbot Engine — zero-cost contextual NLP with conversation state machine.\n *\n * States: browsing → awaiting_name → awaiting_phone → awaiting_address →\n * awaiting_quantity → order finalized\n *\n * No external API calls. Intent detection, product matching, and info\n * extraction are all done with pattern matching heuristics.\n */\n\nimport type {\n Merchant,\n Product,\n ChatSession,\n ChatResponse,\n} from \"./types.ts\";\nimport { db } from \"./storage.ts\";\nimport {\n generateSessionId,\n getMerchantById,\n} from \"./utils.ts\";\nimport { bookOrder } from \"./orders.ts\";\nimport { dispatchSupplierNotification } from \"./dispatch.ts\";\n\n// ── Intent keywords ─────────────────────────────────────────────\n\nconst GREETING_WORDS = [\"hi\", \"hello\", \"hey\", \"greetings\", \"good morning\", \"good afternoon\", \"good evening\", \"salam\", \"hola\", \"namaste\"];\nconst PRODUCT_INQUIRY_WORDS = [\"what do you have\", \"show products\", \"catalog\", \"catalogue\", \"list products\", \"what can i buy\", \"what do you sell\", \"show me\", \"browse\", \"items\", \"what items\"];\nconst PRICE_WORDS = [\"price\", \"cost\", \"how much\", \"how many dollars\", \"rate\", \"pricing\"];\nconst AVAILABILITY_WORDS = [\"available\", \"in stock\", \"do you have\", \"got any\", \"is there\", \"still have\"];\nconst PURCHASE_WORDS = [\"buy\", \"order\", \"purchase\", \"want\", \"need\", \"get this\", \"ship to me\", \"deliver\", \"i'd like\", \"i would like\", \"take\", \"grab\", \"book\"];\nconst CONFIRM_WORDS = [\"yes\", \"confirm\", \"correct\", \"that's right\", \"thats right\", \"yeah\", \"yep\", \"sure\", \"ok\", \"okay\"];\nconst CANCEL_WORDS = [\"no\", \"cancel\", \"never mind\", \"nevermind\", \"stop\", \"abort\", \"exit\", \"quit\"];\n\nconst PHONE_REGEX = /(\\+?\\d{1,3}[-.\\s]?)?\$?\\d{2,4}\$?[-.\\s]?\\d{3,5}[-.\\s]?\\d{3,5}/g;\n\n// ── Extraction helpers ──────────────────────────────────────────\n\nfunction extractQuantity(text: string): number | null {\n const lower = text.toLowerCase();\n const numberWords: Record = {\n \"one\": 1, \"two\": 2, \"three\": 3, \"four\": 4, \"five\": 5,\n \"six\": 6, \"seven\": 7, \"eight\": 8, \"nine\": 9, \"ten\": 10,\n \"a dozen\": 12, \"dozen\": 12,\n };\n\n const qtyPattern = /(?:quantity|qty)[:\\s]+(\\d+)/i;\n const qtyMatch = lower.match(qtyPattern);\n if (qtyMatch) return parseInt(qtyMatch[1]);\n\n const unitPattern = /(\\d+)\\s*(?:units?|pieces?|items?|pcs)/i;\n const unitMatch = lower.match(unitPattern);\n if (unitMatch) return parseInt(unitMatch[1]);\n\n for (const [word, num] of Object.entries(numberWords)) {\n if (lower.includes(word)) return num;\n }\n\n const numMatch = text.match(/\\b(\\d+)\\b/);\n if (numMatch) return parseInt(numMatch[1]);\n\n return null;\n}\n\nfunction extractPhone(text: string): string | null {\n const matches = text.match(PHONE_REGEX);\n if (matches && matches.length > 0) {\n const phone = matches[0].trim();\n const digits = phone.replace(/\\D/g, \"\");\n if (digits.length >= 7) return phone;\n }\n return null;\n}\n\nfunction looksLikeAddress(text: string): boolean {\n const lower = text.toLowerCase();\n const addressIndicators = [\n \"street\", \"st\", \"avenue\", \"ave\", \"road\", \"rd\", \"lane\", \"ln\",\n \"block\", \"sector\", \"house\", \"apartment\", \"apt\", \"floor\", \"flat\",\n \"building\", \"city\", \"town\", \"district\", \"zone\", \"phase\",\n \"near\", \"opposite\", \"beside\", \"behind\", \"plot\", \"no.\", \"number\",\n ];\n const hasNumber = /\\d/.test(text);\n const hasIndicator = addressIndicators.some((ind) => lower.includes(ind));\n return (hasNumber && hasIndicator) || (hasNumber && text.split(/\\s+/).length >= 3) || (hasIndicator && text.split(/\\s+/).length >= 2);\n}\n\n// ── Product matching ────────────────────────────────────────────\n\nfunction matchProducts(message: string, products: Product[]): Product[] {\n const lower = message.toLowerCase();\n const matches: Product[] = [];\n\n for (const product of products) {\n const productName = product.name.toLowerCase();\n const productDesc = product.description.toLowerCase();\n const productCategory = product.category.toLowerCase();\n\n if (lower.includes(productName)) { matches.push(product); continue; }\n\n const nameWords = productName.split(/\\s+/).filter((w) => w.length > 3);\n const matchedWords = nameWords.filter((w) => lower.includes(w));\n if (matchedWords.length >= 1 && nameWords.length > 0) { matches.push(product); continue; }\n\n if (productCategory !== \"general\" && lower.includes(productCategory)) { matches.push(product); continue; }\n\n if (productDesc && productDesc.length > 0) {\n const descWords = productDesc.split(/\\s+/).filter((w) => w.length > 4);\n const matchedDescWords = descWords.filter((w) => lower.includes(w));\n if (matchedDescWords.length >= 2) { matches.push(product); continue; }\n }\n }\n return matches;\n}\n\n// ── Intent detection ────────────────────────────────────────────\n\nfunction hasPurchaseIntent(message: string): boolean {\n return PURCHASE_WORDS.some((w) => message.toLowerCase().includes(w));\n}\nfunction isGreeting(message: string): boolean {\n const lower = message.toLowerCase().trim();\n return GREETING_WORDS.some((w) => lower === w || lower.startsWith(w + \" \") || lower.startsWith(w + \"!\"));\n}\nfunction isProductInquiry(message: string): boolean {\n return PRODUCT_INQUIRY_WORDS.some((w) => message.toLowerCase().includes(w));\n}\nfunction isPriceInquiry(message: string): boolean {\n return PRICE_WORDS.some((w) => message.toLowerCase().includes(w));\n}\nfunction isAvailabilityInquiry(message: string): boolean {\n return AVAILABILITY_WORDS.some((w) => message.toLowerCase().includes(w));\n}\nfunction isCancellation(message: string): boolean {\n const lower = message.toLowerCase().trim();\n return CANCEL_WORDS.some((w) => lower === w || lower.startsWith(w));\n}\n\n// ── Formatting ──────────────────────────────────────────────────\n\nfunction formatProductList(products: Product[]): string {\n if (products.length === 0) return \"I'm sorry, but this store currently has no products in the catalog. Please check back soon!\";\n let text = \"Here are the available products:\\n\\n\";\n for (const p of products) {\n const stockInfo = p.stock > 0 ? `✅ In stock (${p.stock} available)` : \"❌ Out of stock\";\n text += `📦 **${p.name}**\\n Price: $${p.price.toFixed(2)}\\n`;\n if (p.description) text += ` ${p.description}\\n`;\n text += ` ${stockInfo}\\n\\n`;\n }\n text += \"To place an order, just say 'I want to buy [product name]' and I'll help you check out!\";\n return text;\n}\n\n// ── Session management ──────────────────────────────────────────\n\nasync function getOrCreateSession(\n sessionId: string | undefined,\n merchantId: string,\n): Promise {\n if (sessionId) {\n try {\n const result = await db().execute({\n sql: \"SELECT * FROM chat_sessions WHERE id = ? AND merchant_id = ?\",\n args: [sessionId, merchantId],\n });\n if (result.rows.length > 0) {\n return result.rows[0] as unknown as ChatSession;\n }\n } catch { /* fall through */ }\n }\n\n const newId = sessionId || generateSessionId();\n const now = new Date().toISOString();\n\n await db().execute({\n sql: `INSERT OR IGNORE INTO chat_sessions (id, merchant_id, state, updated_at) VALUES (?, ?, 'browsing', ?)`,\n args: [newId, merchantId, now],\n });\n\n return {\n id: newId, merchant_id: merchantId, customer_name: null,\n customer_phone: null, customer_address: null, product_id: null,\n product_name: null, quantity: null, state: \"browsing\", updated_at: now,\n };\n}\n\nasync function updateSession(\n session: ChatSession,\n updates: Partial,\n): Promise {\n const now = new Date().toISOString();\n Object.assign(session, updates, { updated_at: now });\n\n await db().execute({\n sql: `UPDATE chat_sessions SET customer_name = ?, customer_phone = ?, customer_address = ?, product_id = ?, product_name = ?, quantity = ?, state = ?, updated_at = ? WHERE id = ? AND merchant_id = ?`,\n args: [\n session.customer_name, session.customer_phone, session.customer_address,\n session.product_id, session.product_name, session.quantity,\n session.state, now, session.id, session.merchant_id,\n ],\n });\n}\n\nasync function deleteSession(sessionId: string, merchantId: string): Promise {\n try {\n await db().execute({\n sql: \"DELETE FROM chat_sessions WHERE id = ? AND merchant_id = ?\",\n args: [sessionId, merchantId],\n });\n } catch { /* non-fatal */ }\n}\n\n// ── Order finalization ──────────────────────────────────────────\n\nasync function finalizeOrder(\n session: ChatSession,\n product: Product,\n merchant: Merchant,\n): Promise {\n const name = session.customer_name!;\n const phone = session.customer_phone!;\n const address = session.customer_address!;\n const qty = session.quantity || 1;\n\n const bookingResult = await bookOrder(merchant.id, product, name, phone, address, qty);\n\n if (!bookingResult.success || !bookingResult.order) {\n return {\n reply: `I'm sorry, there was an issue booking your order: ${bookingResult.error}. Please try again or contact ${merchant.name} directly at ${merchant.phone}.`,\n session_id: session.id, order_booked: false,\n };\n }\n\n const dispatchResult = await dispatchSupplierNotification(merchant, bookingResult.order);\n await deleteSession(session.id, merchant.id);\n\n const orderConfirmation = `✅ **Order Booked Successfully!**\\n\\n` +\n `Order ID: #${bookingResult.order.id}\\n` +\n `Product: ${product.name}\\nQuantity: ${qty}\\n` +\n `Total: $${(product.price * qty).toFixed(2)}\\n\\n` +\n `Delivery Details:\\nName: ${name}\\nPhone: ${phone}\\nAddress: ${address}\\n\\n` +\n `${dispatchResult.success ? \"📦 Your order has been forwarded to the supplier for manual shipping. You'll be contacted soon!\" : \"⚠️ Your order is confirmed, but there was a delay notifying the supplier. The merchant has your order on record.\"}\\n\\n` +\n `Thank you for shopping with ${merchant.name}! 🛍️`;\n\n return {\n reply: orderConfirmation, session_id: generateSessionId(),\n order_booked: true, order_id: bookingResult.order.id,\n dispatch_sent: dispatchResult.success,\n dispatch_error: dispatchResult.success ? undefined : dispatchResult.error,\n };\n}\n\n// ── Main conversation processor ─────────────────────────────────\n\nexport async function processChatMessage(\n merchantId: string,\n message: string,\n sessionId?: string,\n): Promise {\n const merchant = await getMerchantById(merchantId);\n if (!merchant) {\n return { reply: \"Error: This store is not available. Please contact support.\", session_id: sessionId || \"\", order_booked: false };\n }\n\n let products: Product[] = [];\n try {\n const productResult = await db().execute({\n sql: \"SELECT * FROM products WHERE merchant_id = ? ORDER BY name\",\n args: [merchantId],\n });\n products = productResult.rows as unknown as Product[];\n } catch {\n return { reply: \"I'm having trouble accessing the product catalog right now. Please try again in a moment.\", session_id: sessionId || \"\", order_booked: false };\n }\n\n const session = await getOrCreateSession(sessionId, merchantId);\n\n // ── Cancellation ──────────────────────────────────────────────\n if (isCancellation(message) && session.state !== \"browsing\") {\n await deleteSession(session.id, merchantId);\n return { reply: \"Your order has been cancelled. Let me know if you'd like to browse or buy something else!\", session_id: generateSessionId(), order_booked: false };\n }\n\n // ── BROWSING state ────────────────────────────────────────────\n if (session.state === \"browsing\") {\n if (isGreeting(message)) {\n const welcomeMsg = products.length > 0\n ? `Hello! Welcome to ${merchant.name}! 🛍️\\n\\n${formatProductList(products)}`\n : `Hello! Welcome to ${merchant.name}! 🛍️\\n\\nOur catalog is currently being updated. Please check back soon!`;\n return { reply: welcomeMsg, session_id: session.id, order_booked: false };\n }\n\n if (isProductInquiry(message)) {\n return { reply: formatProductList(products), session_id: session.id, order_booked: false };\n }\n\n if (isPriceInquiry(message)) {\n const matched = matchProducts(message, products);\n if (matched.length > 0) {\n let reply = \"Here are the prices:\\n\\n\";\n for (const p of matched) {\n reply += `📦 ${p.name}: $${p.price.toFixed(2)}\\n`;\n reply += p.stock > 0 ? ` ✅ In stock (${p.stock} available)\\n` : ` ❌ Out of stock\\n`;\n }\n reply += \"\\nTo order, say 'I want to buy [product name]'.\";\n return { reply, session_id: session.id, order_booked: false };\n }\n return { reply: \"Which product are you asking about? Here's what we have:\\n\\n\" + formatProductList(products), session_id: session.id, order_booked: false };\n }\n\n if (isAvailabilityInquiry(message)) {\n const matched = matchProducts(message, products);\n if (matched.length > 0) {\n let reply = \"Availability:\\n\\n\";\n for (const p of matched) {\n reply += p.stock > 0 ? `✅ ${p.name} — ${p.stock} in stock\\n` : `❌ ${p.name} — Out of stock\\n`;\n }\n return { reply, session_id: session.id, order_booked: false };\n }\n return { reply: \"Which product are you checking? Here's our catalog:\\n\\n\" + formatProductList(products), session_id: session.id, order_booked: false };\n }\n\n if (hasPurchaseIntent(message)) {\n const matched = matchProducts(message, products);\n if (matched.length === 0) {\n return { reply: `I'd love to help you place an order! Which product would you like to buy? Here's what we have:\\n\\n${formatProductList(products)}`, session_id: session.id, order_booked: false };\n }\n\n const product = matched[0];\n if (product.stock <= 0) {\n return { reply: `I'm sorry, ${product.name} is currently out of stock. Would you like to see other available products?`, session_id: session.id, order_booked: false };\n }\n\n const phone = extractPhone(message);\n const qty = extractQuantity(message) || 1;\n const lowerMsg = message.toLowerCase().trim();\n\n let extractedName: string | null = null;\n const nameMatch = message.match(/(?:name is|i am|i'm|my name is)\\s+([A-Za-z\\s]{2,40})/i);\n if (nameMatch) extractedName = nameMatch[1].trim();\n\n let extractedAddress: string | null = null;\n const addrMatch = message.match(/(?:address is|live at|deliver to|ship to|at)\\s+(.{5,120})/i);\n if (addrMatch) extractedAddress = addrMatch[1].trim();\n\n await updateSession(session, {\n product_id: product.id, product_name: product.name, quantity: qty,\n customer_name: extractedName, customer_phone: phone,\n customer_address: extractedAddress, state: \"ordering\",\n });\n\n if (!extractedName) {\n await updateSession(session, { state: \"awaiting_name\" });\n return { reply: `Great choice! You want to order ${product.name} (${qty} × $${product.price.toFixed(2)} = $${(product.price * qty).toFixed(2)}).\\n\\nTo complete your order, I'll need a few details.\\n\\nWhat is your full name?`, session_id: session.id, order_booked: false };\n }\n if (!phone) {\n await updateSession(session, { state: \"awaiting_phone\" });\n return { reply: `Thank you, ${extractedName}! What is your phone number?`, session_id: session.id, order_booked: false };\n }\n if (!extractedAddress) {\n await updateSession(session, { state: \"awaiting_address\" });\n return { reply: `Got it! What is your delivery address?`, session_id: session.id, order_booked: false };\n }\n\n const updatedSession = { ...session, customer_name: extractedName, customer_phone: phone, customer_address: extractedAddress, product_id: product.id, product_name: product.name, quantity: qty };\n return await finalizeOrder(updatedSession as ChatSession, product, merchant);\n }\n\n const matched = matchProducts(message, products);\n if (matched.length > 0) {\n let reply = \"I found these products that match:\\n\\n\";\n for (const p of matched) {\n reply += `📦 ${p.name} — $${p.price.toFixed(2)}`;\n if (p.description) reply += ` (${p.description})`;\n reply += p.stock > 0 ? ` ✅\\n` : ` ❌ Out of stock\\n`;\n }\n reply += \"\\nWould you like to buy any of these? Just say 'I want to buy [product name]'.\";\n return { reply, session_id: session.id, order_booked: false };\n }\n\n return { reply: `I'm here to help you with your shopping at ${merchant.name}! You can:\\n• Ask \"what products do you have?\" to browse\\n• Ask about prices or availability\\n• Say \"I want to buy [product name]\" to place an order\\n\\nHow can I assist you today?`, session_id: session.id, order_booked: false };\n }\n\n // ── AWAITING_NAME state ───────────────────────────────────────\n if (session.state === \"awaiting_name\") {\n const name = message.trim().replace(/^(my name is|name is|i am|i'm)\\s+/i, \"\").trim();\n if (name.length < 2) {\n return { reply: \"Please provide a valid name (at least 2 characters). What is your full name?\", session_id: session.id, order_booked: false };\n }\n await updateSession(session, { customer_name: name, state: \"awaiting_phone\" });\n const phone = extractPhone(message);\n if (phone && phone !== name) {\n await updateSession(session, { customer_phone: phone, state: \"awaiting_address\" });\n return { reply: `Thank you, ${name}! I got your phone number: ${phone}. What is your delivery address?`, session_id: session.id, order_booked: false };\n }\n return { reply: `Thank you, ${name}! What is your phone number?`, session_id: session.id, order_booked: false };\n }\n\n // ── AWAITING_PHONE state ──────────────────────────────────────\n if (session.state === \"awaiting_phone\") {\n const phone = extractPhone(message);\n if (!phone) {\n return { reply: \"I couldn't detect a valid phone number. Please enter your phone number (e.g., +1234567890).\", session_id: session.id, order_booked: false };\n }\n await updateSession(session, { customer_phone: phone, state: \"awaiting_address\" });\n return { reply: `Got it! Your phone number is ${phone}. What is your delivery address?`, session_id: session.id, order_booked: false };\n }\n\n // ── AWAITING_ADDRESS state ────────────────────────────────────\n if (session.state === \"awaiting_address\") {\n const address = message.trim().replace(/^(my address is|address is|deliver to|ship to|at)\\s+/i, \"\").trim();\n if (address.length < 5) {\n return { reply: \"Please provide a complete delivery address (street, city, etc.). What is your address?\", session_id: session.id, order_booked: false };\n }\n await updateSession(session, { customer_address: address, state: \"awaiting_quantity\" });\n return { reply: `Perfect! How many units of ${session.product_name} would you like to order? (Just type a number, or say '1' for one unit)`, session_id: session.id, order_booked: false };\n }\n\n // ── AWAITING_QUANTITY state ───────────────────────────────────\n if (session.state === \"awaiting_quantity\") {\n const qty = extractQuantity(message);\n const finalQty = qty || 1;\n if (qty && qty < 1) {\n return { reply: \"Please enter a valid quantity (1 or more). How many would you like?\", session_id: session.id, order_booked: false };\n }\n\n let product: Product | null = null;\n if (session.product_id) {\n try {\n const result = await db().execute({\n sql: \"SELECT * FROM products WHERE id = ? AND merchant_id = ?\",\n args: [session.product_id, merchantId],\n });\n if (result.rows.length > 0) product = result.rows[0] as unknown as Product;\n } catch { /* fall through */ }\n }\n\n if (!product) {\n await updateSession(session, { state: \"browsing\" });\n return { reply: \"Sorry, the product you selected is no longer available. Would you like to browse our catalog again?\", session_id: session.id, order_booked: false };\n }\n\n if (finalQty > product.stock) {\n return { reply: `I'm sorry, we only have ${product.stock} units of ${product.name} in stock. Would you like to order ${product.stock} instead? (Type the quantity or say 'cancel')`, session_id: session.id, order_booked: false };\n }\n\n await updateSession(session, { quantity: finalQty });\n const updatedSession = { ...session, quantity: finalQty };\n return await finalizeOrder(updatedSession as ChatSession, product, merchant);\n }\n\n // ── ORDERING / unknown state — reset ──────────────────────────\n await updateSession(session, { state: \"browsing\" });\n return { reply: \"How can I help you? You can browse products or place an order.\", session_id: session.id, order_booked: false };\n}\n",[],[151,277],["D",1784915835212],[168,169,170,171,172,173,174,175,176],[151],["D",1784711864701],["D",1789572079973],{"_105":104,"_112":107},{"_105":104,"_106":107,"_108":107,"_19":61,"_109":110,"_111":31},{"_13":94,"_38":95,"_49":48,"_96":50,"_97":-5,"_98":-5,"_99":-5,"_100":-5,"_101":-5,"_102":51,"_103":104},"ctx",{"_87":-5,"_131":325,"_326":327,"_328":329,"_330":31,"_331":31,"_332":31,"_333":64,"_334":-5,"_335":-7,"_336":-7,"_337":68,"_338":31,"_339":31,"_340":-5,"_341":31,"_342":31,"_343":31,"_344":-5},"ENV",{"_296":297,"_298":299,"_300":95,"_301":302,"_303":304,"_305":306,"_307":308,"_309":310,"_311":312,"_313":314,"_315":316,"_317":318,"_319":320,"_321":322,"_323":324},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","fdb67791413f4386b4dbf18f354029a617f6160f","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"]

Loading store…

🏪 Commerce Engine

Login to Dashboard

Register Your Store

🏪

Recent Orders

Add Product

Your Products

All Orders

🔗 Your Store URL

📋 Embed Code

🔌 API Key

Diff · v16