` : \"\"}\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",[141],"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",[150],"pulls","branches",1,"forks","envVars",{"_164":42,"_166":42},"connections",{"_164":42,"_165":42},"count","unfilledCount","emptyCount",{"_18":149,"_20":150,"_117":36,"_119":-5,"_120":71,"_121":151,"_123":38,"_22":181,"_68":42,"_126":153,"_128":154,"_130":26,"_131":-5,"_172":182,"_89":183},{"_18":140,"_20":141,"_117":142,"_119":-5,"_120":71,"_121":143,"_123":38,"_22":178,"_68":145,"_126":146,"_128":147,"_130":26,"_131":-5,"_172":179,"_89":180},{"_18":133,"_20":134,"_117":135,"_119":-5,"_120":71,"_121":136,"_123":38,"_22":175,"_68":42,"_126":127,"_128":138,"_130":26,"_131":-5,"_172":176,"_89":177},{"_18":115,"_20":116,"_117":118,"_119":-5,"_120":71,"_121":122,"_123":38,"_22":171,"_68":125,"_126":127,"_128":129,"_130":26,"_131":-5,"_172":173,"_89":174},["D",1784061113356],"children",[],[116],["D",1784060799639],[],[134],["D",1784061154002],[],[141],["D",1784061143134],[],[150],["D",1784060691062],["D",1789473046147],{"_16":17,"_87":83},{"_16":17,"_80":81,"_82":83,"_33":34,"_84":85,"_86":26},{"_68":69,"_20":70,"_18":71,"_72":19,"_73":-5,"_74":-5,"_75":-5,"_76":-5,"_77":-5,"_78":21,"_79":17},"ctx",{"_61":-5,"_108":222,"_223":224,"_225":226,"_227":26,"_228":26,"_229":26,"_230":38,"_231":-5,"_232":-7,"_233":-7,"_234":42,"_235":26,"_236":26,"_237":-5,"_238":26,"_239":26,"_240":26,"_241":-5},"ENV",{"_193":194,"_195":196,"_197":70,"_198":199,"_200":201,"_202":203,"_204":205,"_206":207,"_208":209,"_210":211,"_212":213,"_214":215,"_216":217,"_218":219,"_220":221},"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"]

Search