` : \"\"}\n ${d.title}\n $${d.oldPrice}\n $${d.newPrice}\n View\n `\n ).join(\"\");\n\n await email({\n subject: `📉 Temu price drop — ${drops.length} product${drops.length > 1 ? \"s\" : \"\"}`,\n html: `

📉 ירידת מחיר ב-Temu!

\n \n \n \n \n \n \n \n \n ${rows}\n

	מוצר	מחיר ישן	מחיר חדש

`,\n });\n console.log(`Email sent for ${drops.length} drops!`);\n } else {\n console.log(\"No price drops detected\");\n }\n}\n",[147],"e79e98c4-8e33-4667-b4c6-e6ba06147424","api.ts",15,["D",1784061143134],"http","import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { scrapeProduct } from \"./scrape.ts\";\n\n// Setup DB\nasync function initDB() {\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS tracked_products (\n url TEXT PRIMARY KEY,\n title TEXT,\n image TEXT,\n last_price REAL,\n last_checked TEXT,\n added_at TEXT DEFAULT (datetime('now'))\n )\n `);\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS price_history (\n url TEXT,\n price REAL,\n checked_at TEXT DEFAULT (datetime('now')),\n PRIMARY KEY (url, checked_at)\n )\n `);\n}\n\nexport default async function (req: Request): Promise {\n await initDB();\n const url = new URL(req.url);\n const path = url.pathname;\n\n // API routes\n if (path === \"/api/products\" && req.method === \"GET\") {\n return await getProducts();\n }\n if (path === \"/api/products\" && req.method === \"POST\") {\n return await addProduct(req);\n }\n if (path.startsWith(\"/api/products/\") && req.method === \"DELETE\") {\n const productUrl = decodeURIComponent(path.replace(\"/api/products/\", \"\"));\n return await deleteProduct(productUrl);\n }\n if (path === \"/api/check\" && req.method === \"POST\") {\n return await checkAllPrices();\n }\n\n // Serve the UI\n return new Response(HTML_PAGE, {\n headers: { \"Content-Type\": \"text/html; charset=utf-8\" },\n });\n}\n\nasync function getProducts(): Promise {\n const result = await sqlite.execute(\n \"SELECT * FROM tracked_products ORDER BY added_at DESC\",\n );\n return Response.json(result.rows);\n}\n\nasync function addProduct(req: Request): Promise {\n const body = await req.json();\n const productUrl: string = body.url?.trim();\n\n if (!productUrl || !productUrl.includes(\"temu.com\")) {\n return Response.json({ error: \"Invalid URL — must be a temu.com link\" }, { status: 400 });\n }\n\n // Check if already tracked\n const existing = await sqlite.execute({\n sql: \"SELECT url FROM tracked_products WHERE url = ?\",\n args: [productUrl],\n });\n if (existing.rows.length > 0) {\n return Response.json({ error: \"Already tracking this product\" }, { status: 409 });\n }\n\n // Scrape initial data\n const product = await scrapeProduct(productUrl);\n if (!product) {\n // Add anyway with unknown price — we'll try again later\n await sqlite.execute({\n sql: \"INSERT INTO tracked_products (url, title, image, last_price, last_checked) VALUES (?, ?, ?, NULL, datetime('now'))\",\n args: [productUrl, extractTitleFromUrl(productUrl), null],\n });\n return Response.json({\n ok: true,\n message: \"Added! Will try to fetch price on next check.\",\n url: productUrl,\n title: extractTitleFromUrl(productUrl),\n price: null,\n });\n }\n\n await sqlite.execute({\n sql: \"INSERT INTO tracked_products (url, title, image, last_price, last_checked) VALUES (?, ?, ?, ?, datetime('now'))\",\n args: [productUrl, product.title, product.image ?? null, product.price],\n });\n\n await sqlite.execute({\n sql: \"INSERT INTO price_history (url, price, checked_at) VALUES (?, ?, datetime('now'))\",\n args: [productUrl, product.price],\n });\n\n return Response.json({\n ok: true,\n url: productUrl,\n title: product.title,\n price: product.price,\n image: product.image,\n });\n}\n\nasync function deleteProduct(productUrl: string): Promise {\n await sqlite.execute({\n sql: \"DELETE FROM tracked_products WHERE url = ?\",\n args: [productUrl],\n });\n return Response.json({ ok: true });\n}\n\nasync function checkAllPrices(): Promise {\n const products = await sqlite.execute(\"SELECT * FROM tracked_products\");\n const results: any[] = [];\n const drops: any[] = [];\n\n for (const row of products.rows) {\n const url = row.url as string;\n const oldPrice = row.last_price as number | null;\n const product = await scrapeProduct(url);\n\n if (!product) {\n results.push({ url, status: \"failed\" });\n continue;\n }\n\n await sqlite.execute({\n sql: \"UPDATE tracked_products SET last_price = ?, last_checked = datetime('now') WHERE url = ?\",\n args: [product.price, url],\n });\n\n await sqlite.execute({\n sql: \"INSERT INTO price_history (url, price, checked_at) VALUES (?, ?, datetime('now'))\",\n args: [url, product.price],\n });\n\n if (oldPrice !== null && product.price < oldPrice) {\n drops.push({\n url,\n title: product.title,\n oldPrice,\n newPrice: product.price,\n image: product.image,\n });\n }\n\n results.push({\n url,\n title: product.title,\n oldPrice,\n newPrice: product.price,\n status: \"ok\",\n dropped: oldPrice !== null && product.price < oldPrice,\n });\n }\n\n // Send email if drops\n if (drops.length > 0) {\n const { email } = await import(\"https://esm.town/v/std/email\");\n const rows = drops.map((d) =>\n `\n ${d.image ? `

📉 ירידת מחיר ב-Temu!

\n \n \n \n \n \n \n \n \n ${rows}\n

	מוצר	מחיר ישן	מחיר חדש

`,\n });\n }\n\n return Response.json({ results, drops });\n}\n\nfunction extractTitleFromUrl(url: string): string {\n const slug = url\n .replace(/https?:\\/\\/www\\.temu\\.com\\//, \"\")\n .replace(/\\.html.*$/, \"\")\n .replace(/^goods-\\d+$/, \"Temu Product\");\n return slug\n .replace(/-/g, \" \")\n .replace(/^\\d+\\s*pc[s]?\\s*/i, \"\")\n .trim()\n .replace(/\\b\\w/g, (c) => c.toUpperCase()) || \"Temu Product\";\n}\n\nconst HTML_PAGE = `\n\n\n \n \n Temu Price Tracker\n \n\n\n

🛒 Temu Price Tracker

\n \n

\n \n\n`;\n",[156],"pulls",1,"forks","envVars",{"_169":54,"_171":54},"connections",{"_169":54,"_170":54},"count","unfilledCount","emptyCount",{"_20":155,"_13":156,"_123":48,"_125":-5,"_126":21,"_127":157,"_129":50,"_22":186,"_29":54,"_132":159,"_134":160,"_136":38,"_137":-5,"_177":187,"_94":188},{"_20":146,"_13":147,"_123":148,"_125":-5,"_126":21,"_127":149,"_129":50,"_22":183,"_29":151,"_132":152,"_134":153,"_136":38,"_137":-5,"_177":184,"_94":185},{"_20":139,"_13":140,"_123":141,"_125":-5,"_126":21,"_127":142,"_129":50,"_22":180,"_29":54,"_132":133,"_134":144,"_136":38,"_137":-5,"_177":181,"_94":182},{"_20":121,"_13":122,"_123":124,"_125":-5,"_126":21,"_127":128,"_129":50,"_22":176,"_29":131,"_132":133,"_134":135,"_136":38,"_137":-5,"_177":178,"_94":179},["D",1784061113356],"children",[],[122],["D",1784060799639],[],[140],["D",1784061154002],[],[147],["D",1784061143134],[],[156],["D",1784060691062],["D",1789473046147],{"_11":12,"_92":88},{"_11":12,"_85":86,"_87":88,"_45":46,"_89":90,"_91":38},{"_29":30,"_13":26,"_20":21,"_27":28,"_31":-5,"_32":-5,"_80":-5,"_81":-5,"_82":-5,"_83":14,"_84":12},"ctx",{"_73":-5,"_114":227,"_228":229,"_230":231,"_232":38,"_233":38,"_234":38,"_235":50,"_236":-5,"_237":-7,"_238":-7,"_239":54,"_240":38,"_241":38,"_242":-5,"_243":38,"_244":38,"_245":38,"_246":-5},"ENV",{"_198":199,"_200":201,"_202":26,"_203":204,"_205":206,"_207":208,"_209":210,"_211":212,"_213":214,"_215":216,"_217":218,"_219":220,"_221":222,"_223":224,"_225":226},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Branches1

Branches
1