\n \n \n \n",[],[180,245],"11598834-55ea-11f1-9899-ee650bb23af1","favicon.svg","019e5013-9af2-7410-b348-0d76706a1ef9",["D",1779459922585],"\n",[],[180,252],"b827d526-55ea-11f1-a8d0-ee650bb23af1","pages","b827d5c6-55ea-11f1-a8d0-ee650bb23af1",9,["D",1779460202532],[],[180,259],"b917a434-55ea-11f1-a4f1-ee650bb23af1",["D",1779460204113],[],[180,38],"b877d09e-55ea-11f1-a4f1-ee650bb23af1","contexts","b877d198-55ea-11f1-a4f1-ee650bb23af1",10,["D",1779460203060],[],[180,270],"11597e0c-55ea-11f1-9899-ee650bb23af1","Counter.tsx","019e5013-9af2-7410-b348-0417e0c0ad1c","019e5013-9af2-7410-b348-081fa6ae7764",["D",1779459922585],"/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport { useState } from \"https://esm.sh/react@18.2.0\";\n\nexport function Counter() {\n const [count, setCount] = useState(0);\n return (\n

\n Clicked\n setCount((c) => c + 1)}\n class=\"bg-blue-500 hover:bg-blue-600 text-white font-medium px-4 py-2 rounded-lg transition-colors cursor-pointer\"\n >\n {count}\n \n times\n

\n );\n}\n",[],[180,284,277],"components","11595e04-55ea-11f1-9899-ee650bb23af1","App.tsx","019e5013-9af2-7410-b348-01a6c13d4f00",["D",1779459922585],"/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport { Counter } from \"./Counter.tsx\";\n\nexport function App() {\n return (\n

React + Hono Starter

\n \n

\n View source\n

\n );\n}\n",[],[180,284,286],"11598596-55ea-11f1-9899-ee650bb23af1",["D",1779459922585],[206,207],[180,284],["D",1779459922585],[205,208,209,210,211,212,213],[180],"7c6c1290-55ea-11f1-972f-ee650bb23af1","db.ts","7c6c1358-55ea-11f1-972f-ee650bb23af1",5,["D",1779460102303],"// Project-scoped SQLite helpers. All queries go through here.\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport type {\n Address,\n CartItem,\n Category,\n Order,\n OrderItem,\n Product,\n Review,\n User,\n} from \"../shared/types.ts\";\n\ntype Row = Record;\n\n// --- Users ---\n\nexport async function getUser(id: string): Promise {\n const r = await sqlite.execute({\n sql: \"SELECT * FROM users WHERE id = ?\",\n args: [id],\n });\n return (r.rows[0] as User | undefined) ?? null;\n}\n\nexport async function upsertUser(u: {\n id: string;\n handle: string;\n display_name?: string | null;\n avatar_url?: string | null;\n}): Promise {\n const existing = await getUser(u.id);\n if (existing) {\n await sqlite.execute({\n sql: \"UPDATE users SET handle = ?, display_name = ?, avatar_url = ? WHERE id = ?\",\n args: [u.handle, u.display_name ?? null, u.avatar_url ?? null, u.id],\n });\n return (await getUser(u.id))!;\n }\n await sqlite.execute({\n sql:\n \"INSERT INTO users (id, handle, display_name, avatar_url, role) VALUES (?, ?, ?, ?, 'customer')\",\n args: [u.id, u.handle, u.display_name ?? null, u.avatar_url ?? null],\n });\n return (await getUser(u.id))!;\n}\n\nexport async function setUserRole(\n id: string,\n role: \"customer\" | \"seller\" | \"admin\",\n): Promise {\n await sqlite.execute({\n sql: \"UPDATE users SET role = ? WHERE id = ?\",\n args: [role, id],\n });\n}\n\nexport async function listUsers(): Promise {\n const r = await sqlite.execute(\n \"SELECT * FROM users ORDER BY created_at DESC\",\n );\n return r.rows as unknown as User[];\n}\n\n// --- Categories ---\n\nexport async function listCategories(): Promise {\n const r = await sqlite.execute(\n \"SELECT * FROM categories ORDER BY name ASC\",\n );\n return r.rows as unknown as Category[];\n}\n\n// --- Products ---\n\nconst PRODUCT_SELECT = `\n SELECT p.*,\n c.name AS category_name,\n c.slug AS category_slug,\n u.handle AS seller_handle,\n u.display_name AS seller_name\n FROM products p\n LEFT JOIN categories c ON c.id = p.category_id\n LEFT JOIN users u ON u.id = p.seller_id\n`;\n\nexport interface ProductQuery {\n search?: string;\n category?: string;\n minPrice?: number;\n maxPrice?: number;\n sort?: \"newest\" | \"price_asc\" | \"price_desc\" | \"rating\";\n status?: \"pending\" | \"approved\" | \"rejected\" | \"all\";\n sellerId?: string;\n limit?: number;\n offset?: number;\n}\n\nexport async function listProducts(q: ProductQuery = {}): Promise {\n const where: string[] = [];\n const args: unknown[] = [];\n if (q.status && q.status !== \"all\") {\n where.push(\"p.status = ?\");\n args.push(q.status);\n } else if (!q.status) {\n where.push(\"p.status = 'approved'\");\n }\n if (q.search) {\n where.push(\"(p.name LIKE ? OR p.brand LIKE ? OR p.description LIKE ?)\");\n const term = `%${q.search}%`;\n args.push(term, term, term);\n }\n if (q.category) {\n where.push(\"c.slug = ?\");\n args.push(q.category);\n }\n if (q.minPrice != null) {\n where.push(\"p.price_cents >= ?\");\n args.push(q.minPrice);\n }\n if (q.maxPrice != null) {\n where.push(\"p.price_cents <= ?\");\n args.push(q.maxPrice);\n }\n if (q.sellerId) {\n where.push(\"p.seller_id = ?\");\n args.push(q.sellerId);\n }\n\n let order = \"p.created_at DESC\";\n if (q.sort === \"price_asc\") order = \"p.price_cents ASC\";\n else if (q.sort === \"price_desc\") order = \"p.price_cents DESC\";\n else if (q.sort === \"rating\") order = \"p.avg_rating DESC, p.review_count DESC\";\n\n const limit = Math.min(q.limit ?? 100, 200);\n const offset = q.offset ?? 0;\n\n const sql = `${PRODUCT_SELECT} ${\n where.length ? \"WHERE \" + where.join(\" AND \") : \"\"\n } ORDER BY ${order} LIMIT ? OFFSET ?`;\n args.push(limit, offset);\n\n const r = await sqlite.execute({ sql, args });\n return r.rows as unknown as Product[];\n}\n\nexport async function getProduct(id: number): Promise {\n const r = await sqlite.execute({\n sql: `${PRODUCT_SELECT} WHERE p.id = ?`,\n args: [id],\n });\n return (r.rows[0] as Product | undefined) ?? null;\n}\n\nexport async function getProductBySlug(slug: string): Promise {\n const r = await sqlite.execute({\n sql: `${PRODUCT_SELECT} WHERE p.slug = ?`,\n args: [slug],\n });\n return (r.rows[0] as Product | undefined) ?? null;\n}\n\nexport async function createProduct(p: {\n seller_id: string;\n category_id: number;\n name: string;\n brand: string | null;\n description: string | null;\n price_cents: number;\n stock: number;\n image_url: string | null;\n specs_json: string | null;\n}): Promise {\n const slug = p.name\n .toLowerCase()\n .replace(/[^a-z0-9]+/g, \"-\")\n .replace(/^-+|-+$/g, \"\") +\n \"-\" +\n Math.random().toString(36).slice(2, 6);\n const r = await sqlite.execute({\n sql:\n \"INSERT INTO products (seller_id, category_id, name, slug, brand, description, price_cents, stock, image_url, specs_json, status) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, 'pending')\",\n args: [\n p.seller_id,\n p.category_id,\n p.name,\n slug,\n p.brand,\n p.description,\n p.price_cents,\n p.stock,\n p.image_url,\n p.specs_json,\n ],\n });\n return (await getProduct(Number(r.lastInsertRowid)))!;\n}\n\nexport async function updateProduct(\n id: number,\n sellerId: string | null,\n patch: Partial<{\n name: string;\n brand: string | null;\n description: string | null;\n price_cents: number;\n stock: number;\n image_url: string | null;\n specs_json: string | null;\n category_id: number;\n status: \"pending\" | \"approved\" | \"rejected\";\n }>,\n): Promise {\n const fields: string[] = [];\n const args: unknown[] = [];\n for (const [k, v] of Object.entries(patch)) {\n fields.push(`${k} = ?`);\n args.push(v);\n }\n if (!fields.length) return getProduct(id);\n let sql = `UPDATE products SET ${fields.join(\", \")} WHERE id = ?`;\n args.push(id);\n if (sellerId) {\n sql += \" AND seller_id = ?\";\n args.push(sellerId);\n }\n await sqlite.execute({ sql, args });\n return getProduct(id);\n}\n\nexport async function deleteProduct(\n id: number,\n sellerId: string | null,\n): Promise {\n if (sellerId) {\n await sqlite.execute({\n sql: \"DELETE FROM products WHERE id = ? AND seller_id = ?\",\n args: [id, sellerId],\n });\n } else {\n await sqlite.execute({\n sql: \"DELETE FROM products WHERE id = ?\",\n args: [id],\n });\n }\n}\n\n// --- Cart ---\n\nexport async function getCart(userId: string): Promise {\n const r = await sqlite.execute({\n sql: `SELECT ci.*, p.name AS p_name, p.slug AS p_slug, p.price_cents AS p_price_cents,\n p.image_url AS p_image_url, p.stock AS p_stock, p.brand AS p_brand\n FROM cart_items ci\n JOIN products p ON p.id = ci.product_id\n WHERE ci.user_id = ?\n ORDER BY ci.created_at DESC`,\n args: [userId],\n });\n return (r.rows as Row[]).map((row) => ({\n id: row.id as number,\n user_id: row.user_id as string,\n product_id: row.product_id as number,\n quantity: row.quantity as number,\n product: {\n id: row.product_id as number,\n name: row.p_name as string,\n slug: row.p_slug as string,\n price_cents: row.p_price_cents as number,\n image_url: (row.p_image_url as string) ?? null,\n stock: row.p_stock as number,\n brand: (row.p_brand as string) ?? null,\n } as Product,\n }));\n}\n\nexport async function addToCart(\n userId: string,\n productId: number,\n quantity: number,\n): Promise {\n await sqlite.execute({\n sql:\n `INSERT INTO cart_items (user_id, product_id, quantity) VALUES (?, ?, ?)\n ON CONFLICT(user_id, product_id) DO UPDATE SET quantity = quantity + excluded.quantity`,\n args: [userId, productId, quantity],\n });\n}\n\nexport async function updateCartItem(\n userId: string,\n itemId: number,\n quantity: number,\n): Promise {\n if (quantity <= 0) {\n await sqlite.execute({\n sql: \"DELETE FROM cart_items WHERE id = ? AND user_id = ?\",\n args: [itemId, userId],\n });\n } else {\n await sqlite.execute({\n sql: \"UPDATE cart_items SET quantity = ? WHERE id = ? AND user_id = ?\",\n args: [quantity, itemId, userId],\n });\n }\n}\n\nexport async function removeCartItem(\n userId: string,\n itemId: number,\n): Promise {\n await sqlite.execute({\n sql: \"DELETE FROM cart_items WHERE id = ? AND user_id = ?\",\n args: [itemId, userId],\n });\n}\n\nexport async function clearCart(userId: string): Promise {\n await sqlite.execute({\n sql: \"DELETE FROM cart_items WHERE user_id = ?\",\n args: [userId],\n });\n}\n\n// --- Wishlist ---\n\nexport async function getWishlist(userId: string) {\n const r = await sqlite.execute({\n sql: `SELECT w.id, w.user_id, w.product_id, p.*\n FROM wishlists w\n JOIN products p ON p.id = w.product_id\n WHERE w.user_id = ?\n ORDER BY w.created_at DESC`,\n args: [userId],\n });\n return r.rows as unknown as (Product & { user_id: string })[];\n}\n\nexport async function toggleWishlist(\n userId: string,\n productId: number,\n): Promise {\n const existing = await sqlite.execute({\n sql: \"SELECT id FROM wishlists WHERE user_id = ? AND product_id = ?\",\n args: [userId, productId],\n });\n if (existing.rows.length) {\n await sqlite.execute({\n sql: \"DELETE FROM wishlists WHERE user_id = ? AND product_id = ?\",\n args: [userId, productId],\n });\n return false;\n }\n await sqlite.execute({\n sql: \"INSERT INTO wishlists (user_id, product_id) VALUES (?, ?)\",\n args: [userId, productId],\n });\n return true;\n}\n\n// --- Reviews ---\n\nexport async function listReviews(productId: number): Promise {\n const r = await sqlite.execute({\n sql: `SELECT r.*, u.handle AS user_handle, u.display_name AS user_name\n FROM reviews r\n JOIN users u ON u.id = r.user_id\n WHERE r.product_id = ?\n ORDER BY r.created_at DESC`,\n args: [productId],\n });\n return r.rows as unknown as Review[];\n}\n\nexport async function upsertReview(r: {\n product_id: number;\n user_id: string;\n rating: number;\n title: string | null;\n body: string | null;\n}): Promise {\n await sqlite.execute({\n sql:\n `INSERT INTO reviews (product_id, user_id, rating, title, body) VALUES (?, ?, ?, ?, ?)\n ON CONFLICT(product_id, user_id) DO UPDATE SET rating=excluded.rating, title=excluded.title, body=excluded.body`,\n args: [r.product_id, r.user_id, r.rating, r.title, r.body],\n });\n await recomputeProductRating(r.product_id);\n}\n\nasync function recomputeProductRating(productId: number): Promise {\n const r = await sqlite.execute({\n sql:\n \"SELECT AVG(rating) AS avg, COUNT(*) AS cnt FROM reviews WHERE product_id = ?\",\n args: [productId],\n });\n const row = r.rows[0] as { avg: number | null; cnt: number };\n await sqlite.execute({\n sql:\n \"UPDATE products SET avg_rating = ?, review_count = ? WHERE id = ?\",\n args: [row.avg ?? 0, row.cnt ?? 0, productId],\n });\n}\n\n// --- Addresses ---\n\nexport async function listAddresses(userId: string): Promise {\n const r = await sqlite.execute({\n sql: \"SELECT * FROM addresses WHERE user_id = ? ORDER BY is_default DESC, id DESC\",\n args: [userId],\n });\n return r.rows as unknown as Address[];\n}\n\nexport async function createAddress(\n userId: string,\n a: Omit,\n): Promise

{\n if (a.is_default) {\n await sqlite.execute({\n sql: \"UPDATE addresses SET is_default = 0 WHERE user_id = ?\",\n args: [userId],\n });\n }\n const r = await sqlite.execute({\n sql:\n \"INSERT INTO addresses (user_id, label, full_name, line1, line2, city, state, postal_code, country, phone, is_default) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)\",\n args: [\n userId,\n a.label,\n a.full_name,\n a.line1,\n a.line2,\n a.city,\n a.state,\n a.postal_code,\n a.country,\n a.phone,\n a.is_default ? 1 : 0,\n ],\n });\n const created = await sqlite.execute({\n sql: \"SELECT * FROM addresses WHERE id = ?\",\n args: [Number(r.lastInsertRowid)],\n });\n return created.rows[0] as unknown as Address;\n}\n\nexport async function deleteAddress(\n userId: string,\n addressId: number,\n): Promise {\n await sqlite.execute({\n sql: \"DELETE FROM addresses WHERE id = ? AND user_id = ?\",\n args: [addressId, userId],\n });\n}\n\n// --- Orders ---\n\nexport async function createOrder(\n userId: string,\n address: Record,\n): Promise {\n const cart = await getCart(userId);\n if (!cart.length) throw new Error(\"Cart is empty\");\n\n // Verify stock\n for (const item of cart) {\n if (!item.product || item.product.stock < item.quantity) {\n throw new Error(`Insufficient stock for ${item.product?.name}`);\n }\n }\n\n const total = cart.reduce(\n (sum, it) => sum + (it.product?.price_cents ?? 0) * it.quantity,\n 0,\n );\n\n const orderResult = await sqlite.execute({\n sql:\n \"INSERT INTO orders (user_id, total_cents, status, address_json) VALUES (?, ?, 'paid', ?)\",\n args: [userId, total, JSON.stringify(address)],\n });\n const orderId = Number(orderResult.lastInsertRowid);\n\n // Insert items + decrement stock\n for (const item of cart) {\n const p = item.product!;\n await sqlite.execute({\n sql:\n \"INSERT INTO order_items (order_id, product_id, seller_id, quantity, unit_price_cents, product_snapshot_json) VALUES (?, ?, (SELECT seller_id FROM products WHERE id = ?), ?, ?, ?)\",\n args: [\n orderId,\n p.id,\n p.id,\n item.quantity,\n p.price_cents,\n JSON.stringify(p),\n ],\n });\n await sqlite.execute({\n sql: \"UPDATE products SET stock = stock - ? WHERE id = ?\",\n args: [item.quantity, p.id],\n });\n }\n\n await clearCart(userId);\n return (await getOrder(orderId, userId))!;\n}\n\nexport async function getOrder(\n orderId: number,\n userId: string | null,\n): Promise {\n const sql = userId\n ? \"SELECT * FROM orders WHERE id = ? AND user_id = ?\"\n : \"SELECT * FROM orders WHERE id = ?\";\n const args = userId ? [orderId, userId] : [orderId];\n const r = await sqlite.execute({ sql, args });\n const order = r.rows[0] as Order | undefined;\n if (!order) return null;\n const items = await sqlite.execute({\n sql: \"SELECT * FROM order_items WHERE order_id = ?\",\n args: [orderId],\n });\n order.items = items.rows as unknown as OrderItem[];\n return order;\n}\n\nexport async function listUserOrders(userId: string): Promise {\n const r = await sqlite.execute({\n sql: \"SELECT * FROM orders WHERE user_id = ? ORDER BY created_at DESC\",\n args: [userId],\n });\n return r.rows as unknown as Order[];\n}\n\nexport async function listSellerOrders(sellerId: string): Promise {\n const r = await sqlite.execute({\n sql: `SELECT DISTINCT o.* FROM orders o\n JOIN order_items oi ON oi.order_id = o.id\n WHERE oi.seller_id = ?\n ORDER BY o.created_at DESC`,\n args: [sellerId],\n });\n const orders = r.rows as unknown as Order[];\n for (const o of orders) {\n const items = await sqlite.execute({\n sql: \"SELECT * FROM order_items WHERE order_id = ? AND seller_id = ?\",\n args: [o.id, sellerId],\n });\n o.items = items.rows as unknown as OrderItem[];\n }\n return orders;\n}\n\nexport async function listAllOrders(): Promise {\n const r = await sqlite.execute(\n \"SELECT * FROM orders ORDER BY created_at DESC LIMIT 200\",\n );\n return r.rows as unknown as Order[];\n}\n\nexport async function updateOrderStatus(\n orderId: number,\n status: Order[\"status\"],\n): Promise {\n await sqlite.execute({\n sql: \"UPDATE orders SET status = ? WHERE id = ?\",\n args: [status, orderId],\n });\n}\n\n// --- Recently viewed ---\n\nexport async function trackView(\n userId: string,\n productId: number,\n): Promise {\n await sqlite.execute({\n sql:\n `INSERT INTO recently_viewed (user_id, product_id) VALUES (?, ?)\n ON CONFLICT(user_id, product_id) DO UPDATE SET viewed_at = CURRENT_TIMESTAMP`,\n args: [userId, productId],\n });\n}\n\nexport async function listRecentlyViewed(userId: string): Promise {\n const r = await sqlite.execute({\n sql: `${PRODUCT_SELECT}\n JOIN recently_viewed rv ON rv.product_id = p.id\n WHERE rv.user_id = ?\n ORDER BY rv.viewed_at DESC\n LIMIT 12`,\n args: [userId],\n });\n return r.rows as unknown as Product[];\n}\n\n// --- Analytics ---\n\nexport async function adminAnalytics() {\n const [users, products, orders, revenue, topProducts, recentOrders] =\n await Promise.all([\n sqlite.execute(\n \"SELECT role, COUNT(*) AS n FROM users GROUP BY role\",\n ),\n sqlite.execute(\n \"SELECT status, COUNT(*) AS n FROM products GROUP BY status\",\n ),\n sqlite.execute(\"SELECT COUNT(*) AS n FROM orders\"),\n sqlite.execute(\n \"SELECT COALESCE(SUM(total_cents),0) AS revenue FROM orders WHERE status != 'cancelled'\",\n ),\n sqlite.execute(\n `SELECT p.id, p.name, p.image_url, SUM(oi.quantity) AS units, SUM(oi.unit_price_cents * oi.quantity) AS revenue\n FROM order_items oi\n JOIN products p ON p.id = oi.product_id\n GROUP BY p.id\n ORDER BY units DESC\n LIMIT 5`,\n ),\n sqlite.execute(\n `SELECT DATE(created_at) AS day, COUNT(*) AS orders, SUM(total_cents) AS revenue\n FROM orders\n GROUP BY DATE(created_at)\n ORDER BY day DESC\n LIMIT 14`,\n ),\n ]);\n return {\n userCounts: users.rows,\n productCounts: products.rows,\n orderCount: (orders.rows[0] as { n: number }).n,\n revenueCents: (revenue.rows[0] as { revenue: number }).revenue,\n topProducts: topProducts.rows,\n dailyOrders: recentOrders.rows,\n };\n}\n\nexport async function sellerAnalytics(sellerId: string) {\n const [products, orders, revenue, top] = await Promise.all([\n sqlite.execute({\n sql: \"SELECT COUNT(*) AS n FROM products WHERE seller_id = ?\",\n args: [sellerId],\n }),\n sqlite.execute({\n sql:\n \"SELECT COUNT(DISTINCT order_id) AS n FROM order_items WHERE seller_id = ?\",\n args: [sellerId],\n }),\n sqlite.execute({\n sql:\n \"SELECT COALESCE(SUM(unit_price_cents * quantity),0) AS revenue FROM order_items WHERE seller_id = ?\",\n args: [sellerId],\n }),\n sqlite.execute({\n sql:\n `SELECT p.id, p.name, p.image_url, SUM(oi.quantity) AS units, SUM(oi.unit_price_cents * oi.quantity) AS revenue\n FROM order_items oi\n JOIN products p ON p.id = oi.product_id\n WHERE oi.seller_id = ?\n GROUP BY p.id\n ORDER BY units DESC\n LIMIT 5`,\n args: [sellerId],\n }),\n ]);\n return {\n productCount: (products.rows[0] as { n: number }).n,\n orderCount: (orders.rows[0] as { n: number }).n,\n revenueCents: (revenue.rows[0] as { revenue: number }).revenue,\n topProducts: top.rows,\n };\n}\n\n// --- AI Logs ---\n\nexport async function logAI(\n userId: string | null,\n kind: string,\n prompt: string,\n response: string,\n): Promise {\n await sqlite.execute({\n sql:\n \"INSERT INTO ai_logs (user_id, kind, prompt, response) VALUES (?, ?, ?, ?)\",\n args: [userId, kind, prompt, response],\n });\n}\n\nexport async function listUserAILogs(userId: string) {\n const r = await sqlite.execute({\n sql:\n \"SELECT id, kind, prompt, response, created_at FROM ai_logs WHERE user_id = ? ORDER BY id DESC LIMIT 30\",\n args: [userId],\n });\n return r.rows;\n}\n",[],[185,300],"915117fa-55ea-11f1-bdf4-ee650bb23af1","auth.ts","915118b8-55ea-11f1-bdf4-ee650bb23af1",7,["D",1779460137352],"// Auth helpers: read OAuth session, sync to local users table, enforce roles.\nimport { getOAuthUserData } from \"https://esm.town/v/std/oauth/middleware.ts\";\nimport { getUser, upsertUser } from \"./db.ts\";\nimport type { User } from \"../shared/types.ts\";\n\nexport async function getCurrentUser(req: Request): Promise {\n const session = await getOAuthUserData(req);\n if (!session?.user) return null;\n const handle = session.user.username || `user-${session.user.id.slice(0, 6)}`;\n // Upsert into local users table so we have role + linkable data.\n const u = await upsertUser({\n id: session.user.id,\n handle,\n display_name: session.user.username,\n avatar_url: session.user.links?.profileImageUrl ?? null,\n });\n return u;\n}\n\nexport async function requireUser(req: Request): Promise {\n const u = await getCurrentUser(req);\n if (!u) throw new HttpError(401, \"Login required\");\n return u;\n}\n\nexport async function requireRole(\n req: Request,\n roles: (\"customer\" | \"seller\" | \"admin\")[],\n): Promise {\n const u = await requireUser(req);\n if (!roles.includes(u.role)) {\n throw new HttpError(403, `Requires role: ${roles.join(\" or \")}`);\n }\n return u;\n}\n\nexport class HttpError extends Error {\n constructor(public status: number, message: string) {\n super(message);\n }\n}\n\nexport { getUser };\n",[],[185,308],"8d071e10-55ea-11f1-b744-ee650bb23af1","ai.ts","8d071eec-55ea-11f1-b744-ee650bb23af1",6,["D",1779460130185],"// Gemini AI service — all calls happen server-side; the API key never leaves the server.\nimport type { Product } from \"../shared/types.ts\";\n\nconst MODEL = \"gemini-2.0-flash\";\nconst ENDPOINT =\n `https://generativelanguage.googleapis.com/v1beta/models/${MODEL}:generateContent`;\n\nfunction getKey(): string {\n const k = Deno.env.get(\"GEMINI_API_KEY\");\n if (!k || k === \"REPLACE_WITH_YOUR_GEMINI_API_KEY\") {\n throw new Error(\n \"GEMINI_API_KEY is not set. Add it in the val's Environment Variables.\",\n );\n }\n return k;\n}\n\nasync function callGemini(\n prompt: string,\n opts: { json?: boolean; system?: string } = {},\n): Promise {\n const key = getKey();\n const body: Record = {\n contents: [{ role: \"user\", parts: [{ text: prompt }] }],\n generationConfig: {\n temperature: 0.7,\n maxOutputTokens: 1024,\n ...(opts.json ? { responseMimeType: \"application/json\" } : {}),\n },\n };\n if (opts.system) {\n body.systemInstruction = { parts: [{ text: opts.system }] };\n }\n const res = await fetch(`${ENDPOINT}?key=${key}`, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify(body),\n });\n if (!res.ok) {\n const text = await res.text();\n throw new Error(`Gemini API error ${res.status}: ${text.slice(0, 200)}`);\n }\n const data = await res.json();\n const text = data?.candidates?.[0]?.content?.parts?.[0]?.text;\n if (typeof text !== \"string\") {\n throw new Error(\"Gemini returned no text\");\n }\n return text;\n}\n\nfunction productSummary(p: Product): string {\n return `#${p.id} ${p.brand ?? \"\"} ${p.name} — ₹${\n (p.price_cents / 100).toFixed(0)\n } — ${(p.description ?? \"\").slice(0, 140)}`;\n}\n\n// --- 1. Smart recommendations based on user interests + catalog ---\n\nexport async function recommendGadgets(\n interest: string,\n catalog: Product[],\n): Promise<{ productId: number; reason: string }[]> {\n const lines = catalog.slice(0, 40).map(productSummary).join(\"\\n\");\n const prompt = `User interest: \"${interest}\"\n\nCatalog:\n${lines}\n\nPick the 4 most relevant products and explain WHY each fits the user's interest.\nReturn ONLY JSON array with this exact shape:\n[{\"productId\": number, \"reason\": \"one sentence reason\"}]`;\n const text = await callGemini(prompt, { json: true });\n try {\n const parsed = JSON.parse(text);\n if (Array.isArray(parsed)) return parsed.slice(0, 4);\n } catch {\n // try to extract JSON from text\n const m = text.match(/\\[[\\s\\S]*\\]/);\n if (m) return JSON.parse(m[0]).slice(0, 4);\n }\n return [];\n}\n\n// --- 2. Product summary ---\n\nexport async function summarizeProduct(p: Product): Promise {\n const prompt =\n `Write a clear, friendly 3-sentence summary of this gadget for a shopper. Highlight what makes it special and who would love it. Avoid marketing fluff.\n\nProduct: ${p.brand} ${p.name}\nPrice: ₹${(p.price_cents / 100).toFixed(0)}\nDescription: ${p.description ?? \"\"}\nSpecs: ${p.specs_json ?? \"n/a\"}`;\n return await callGemini(prompt);\n}\n\n// --- 3. Smart comparison ---\n\nexport async function compareProducts(a: Product, b: Product): Promise {\n const prompt = `Compare these two gadgets honestly. Use markdown with:\n- A short verdict (which is better for whom)\n- A bullet list of key differences\n- One recommendation paragraph\n\nProduct A: ${a.brand} ${a.name} — ₹${(a.price_cents / 100).toFixed(0)}\n${a.description}\nSpecs: ${a.specs_json}\n\nProduct B: ${b.brand} ${b.name} — ₹${(b.price_cents / 100).toFixed(0)}\n${b.description}\nSpecs: ${b.specs_json}`;\n return await callGemini(prompt);\n}\n\n// --- 4. Shopping assistant chat ---\n\nexport async function shoppingAssistant(\n message: string,\n history: { role: \"user\" | \"assistant\"; content: string }[],\n catalog: Product[],\n): Promise {\n const ctx = catalog.slice(0, 20).map(productSummary).join(\"\\n\");\n const system =\n `You are GadgetGenie, a helpful AI shopping assistant for an online smart-gadgets store.\nYou can reference the catalog below to recommend specific products by name.\nKeep replies concise (2-4 sentences), friendly, and practical. If the user asks about something outside gadgets, gently steer back to shopping.\n\nCatalog:\n${ctx}`;\n const historyText = history.slice(-6).map((m) =>\n `${m.role === \"user\" ? \"User\" : \"Assistant\"}: ${m.content}`\n ).join(\"\\n\");\n const prompt = `${historyText}\\nUser: ${message}\\nAssistant:`;\n return await callGemini(prompt, { system });\n}\n\n// --- 5. Search suggestions ---\n\nexport async function searchSuggestions(query: string): Promise {\n if (!query.trim()) return [];\n const prompt = `A user is searching for smart gadgets and typed: \"${query}\"\nSuggest 5 short, useful related search queries (under 6 words each).\nReturn ONLY a JSON array of strings, no prose.`;\n const text = await callGemini(prompt, { json: true });\n try {\n const parsed = JSON.parse(text);\n if (Array.isArray(parsed)) return parsed.slice(0, 5).map(String);\n } catch {\n const m = text.match(/\\[[\\s\\S]*\\]/);\n if (m) return JSON.parse(m[0]).slice(0, 5).map(String);\n }\n return [];\n}\n",[],[185,316],["D",1779460012296],[201,202,203],[185],["D",1779459922585],["D",1789494036282],{"_108":107,"_115":111},{"_108":107,"_109":-5,"_110":111,"_19":59,"_112":113,"_114":30},{"_13":93,"_37":94,"_47":46,"_95":48,"_96":97,"_98":99,"_100":54,"_101":102,"_103":104,"_105":49,"_106":107},"ctx",{"_86":-5,"_137":364,"_365":366,"_367":368,"_369":30,"_370":30,"_371":30,"_372":63,"_373":-5,"_374":-7,"_375":-7,"_376":67,"_377":30,"_378":30,"_379":-5,"_380":30,"_381":30,"_382":30,"_383":-5},"ENV",{"_335":336,"_337":338,"_339":94,"_340":341,"_342":343,"_344":345,"_346":347,"_348":349,"_350":351,"_352":353,"_354":355,"_356":357,"_358":359,"_360":361,"_362":363},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Diff · v11