[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_197":198,"_199":200},"routes/_app.x.$handle.$name",{"_98":97,"_32":45,"_106":88,"_27":107,"_13":14,"_108":-5,"_11":109,"_110":111,"_112":113,"_114":115,"_116":117,"_20":-5,"_118":-5,"_119":-5,"_120":25,"_121":122,"_123":124,"_125":-5,"_126":-5,"_127":128},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_43":44,"_32":45,"_38":46,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":-5,"_57":25,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":65,"_66":67,"_68":69,"_70":-5,"_71":72,"_73":72,"_74":75,"_76":75,"_77":75,"_78":72,"_79":72,"_80":81,"_82":83,"_84":85,"_86":25},"version",17,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":34,"_35":37,"_38":39,"_40":14,"_41":42,"_24":25},"previous",{"_30":31,"_32":28,"_33":34,"_35":36},"deleted",false,"deletedHere","path","cron.ts","latestPath","fileId","e40edd76-64b6-11f1-9f7c-1607ee4eb77e","name","fileType","interval","content","// apple-refurb-tracker — Interval entrypoint\n// Val Town runs this on schedule (set in the VT editor). Polls refurb pages,\n// detects stock changes, persists events, and dispatches alerts.\n\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { email } from \"https://esm.town/v/std/email\";\n\nimport {\n STORE_CONFIGS,\n DEFAULT_ALERT_RULES,\n getStoreConfig,\n ensureSchema,\n fetchStoreStock,\n detectChanges,\n upsertCurrentStock,\n removeCurrentStock,\n getActivePartNumbers,\n insertEvent,\n insertRun,\n updateRunCompletion,\n updateRunError,\n matchRules,\n buildAlertSubject,\n buildAlertText,\n} from \"./apple-refurb-tracker-lib.mjs\";\n\nexport default async function appleRefurbTrackerCron(interval: Interval) {\n await ensureSchema(sqlite);\n\n const rules = DEFAULT_ALERT_RULES;\n let totalEvents = 0;\n\n for (const store of STORE_CONFIGS) {\n const now = new Date().toISOString();\n const runId = await insertRun(sqlite, {\n storeId: store.id,\n triggeredAt: now,\n completedAt: null,\n status: \"ok\",\n tilesFound: 0,\n eventsDetected: 0,\n error: null,\n });\n\n try {\n const candidates = await fetchStoreStock(store, fetch);\n const events = await detectChanges(store.id, candidates, sqlite);\n\n // Persist current state: upsert all, remove disappeared.\n for (const candidate of candidates) {\n await upsertCurrentStock(sqlite, candidate, now);\n }\n\n const currentPns = new Set(candidates.map((c) => c.partNumber));\n const previousPns = await getActivePartNumbers(sqlite, store.id);\n for (const pn of previousPns) {\n if (!currentPns.has(pn)) {\n await removeCurrentStock(sqlite, store.id, pn);\n }\n }\n\n // Persist events and dispatch alerts.\n for (const event of events) {\n await insertEvent(sqlite, {\n ...event,\n detectedAt: now,\n });\n\n const candidate = event.candidate ?? candidates.find((c) => c.partNumber === event.partNumber);\n if (candidate) {\n const matched = matchRules(candidate, event, rules);\n if (matched.length > 0) {\n const channels = new Set(matched.flatMap((r) => r.channels));\n\n if (channels.has(\"email\")) {\n await email({\n subject: buildAlertSubject(candidate, event, store),\n text: buildAlertText(candidate, event, store, matched),\n });\n }\n\n if (channels.has(\"webhook\")) {\n const webhookUrl = Deno.env.get(\"ALERT_WEBHOOK_URL\");\n if (webhookUrl) {\n await fetch(webhookUrl, {\n method: \"POST\",\n headers: { \"content-type\": \"application/json\" },\n body: JSON.stringify({\n candidate,\n event: { ...event, candidate: undefined },\n rules: matched.map((r) => r.name),\n store: { id: store.id, label: store.label },\n }),\n });\n }\n }\n }\n }\n }\n\n totalEvents += events.length;\n await updateRunCompletion(sqlite, runId, new Date().toISOString(), events.length);\n\n console.log(JSON.stringify({\n store: store.id,\n ok: true,\n tilesFound: candidates.length,\n events: events.length,\n eventKinds: events.map((e) => e.kind),\n }));\n } catch (error) {\n await updateRunError(sqlite, runId, String(error?.message ?? error));\n console.error(JSON.stringify({\n store: store.id,\n ok: false,\n error: String(error?.message ?? error),\n }));\n }\n }\n\n console.log(JSON.stringify({\n ok: true,\n stores: STORE_CONFIGS.length,\n totalEvents,\n lastRunAt: interval.lastRunAt?.toISOString() ?? null,\n }));\n}\n","// apple-refurb-tracker — Interval entrypoint\n// Val Town runs this on schedule (set in the VT editor). Polls refurb pages,\n// detects stock changes, persists events, and dispatches alerts.\n\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { email } from \"https://esm.town/v/std/email\";\n\nimport {\n STORE_CONFIGS,\n DEFAULT_ALERT_RULES,\n getStoreConfig,\n ensureSchema,\n fetchStoreStock,\n detectChanges,\n upsertCurrentStock,\n removeCurrentStock,\n getActivePartNumbers,\n insertEvent,\n insertRun,\n updateRunCompletion,\n updateRunError,\n matchRules,\n buildAlertSubject,\n buildAlertText,\n} from \"./apple-refurb-tracker-lib.mjs\";\n\nexport default async function appleRefurbTrackerCron(interval: Interval) {\n await ensureSchema(sqlite);\n\n const rules = DEFAULT_ALERT_RULES;\n let totalEvents = 0;\n\n for (const store of STORE_CONFIGS) {\n const now = new Date().toISOString();\n const runId = await insertRun(sqlite, {\n storeId: store.id,\n triggeredAt: now,\n completedAt: null,\n status: \"ok\",\n tilesFound: 0,\n eventsDetected: 0,\n error: null,\n });\n\n try {\n const candidates = await fetchStoreStock(store, fetch);\n const events = await detectChanges(store.id, candidates, sqlite);\n\n // Persist current state: upsert all, remove disappeared.\n for (const candidate of candidates) {\n await upsertCurrentStock(sqlite, candidate, now);\n }\n\n const currentPns = new Set(candidates.map((c) => c.partNumber));\n const previousPns = await getActivePartNumbers(sqlite, store.id);\n for (const pn of previousPns) {\n if (!currentPns.has(pn)) {\n await removeCurrentStock(sqlite, store.id, pn);\n }\n }\n\n // Persist events and dispatch alerts.\n for (const event of events) {\n await insertEvent(sqlite, {\n ...event,\n detectedAt: now,\n });\n\n const candidate = event.candidate ?? candidates.find((c) => c.partNumber === event.partNumber);\n if (candidate) {\n const matched = matchRules(candidate, event, rules);\n if (matched.length > 0) {\n const channels = new Set(matched.flatMap((r) => r.channels));\n\n if (channels.has(\"email\")) {\n await email({\n subject: buildAlertSubject(candidate, event, store),\n text: buildAlertText(candidate, event, store, matched),\n });\n }\n\n if (channels.has(\"webhook\")) {\n const webhookUrl = Deno.env.get(\"ALERT_WEBHOOK_URL\");\n if (webhookUrl) {\n await fetch(webhookUrl, {\n method: \"POST\",\n headers: { \"content-type\": \"application/json\" },\n body: JSON.stringify({\n candidate,\n event: { ...event, candidate: undefined },\n rules: matched.map((r) => r.name),\n store: { id: store.id, label: store.label },\n }),\n });\n }\n }\n }\n }\n }\n\n totalEvents += events.length;\n await updateRunCompletion(sqlite, runId, new Date().toISOString(), candidates.length, events.length);\n\n console.log(JSON.stringify({\n store: store.id,\n ok: true,\n tilesFound: candidates.length,\n events: events.length,\n eventKinds: events.map((e) => e.kind),\n }));\n } catch (error) {\n await updateRunError(sqlite, runId, String(error?.message ?? error));\n console.error(JSON.stringify({\n store: store.id,\n ok: false,\n error: String(error?.message ?? error),\n }));\n }\n }\n\n console.log(JSON.stringify({\n ok: true,\n stores: STORE_CONFIGS.length,\n totalEvents,\n lastRunAt: interval.lastRunAt?.toISOString() ?? null,\n }));\n}\n","createdAt",["D",1781089157525],"branchVersion","branchId","44ad09b8-588d-41e1-9d53-5eddb754519f","id","b1335dd3-8ea8-46c8-acb3-46d184db0310","apple-refurb-tracker",["D",1781087208661],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Configurable Apple refurb stock tracker with multi-store alerts.","imageUrl","d16a6380-388d-11f0-8bf7-1b413b1612ec","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","e023be7f-3034-444e-bc8e-f83cfc68553a","tursoName","b1335dd38ea846c8acb346d184db0310","tursoHostname","b1335dd38ea846c8acb346d184db0310-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789530642963],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_98":97,"_105":101},"org",{"_98":97,"_99":-5,"_100":101,"_18":55,"_102":103,"_104":25},"branch",{"_13":87,"_32":88,"_43":42,"_89":44,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":45,"_96":97},"isOwned",21,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","bazh","handle","displayName","avatar","https://img.clerk.com/eyJ0eXBlIjoicHJveHkiLCJzcmMiOiJodHRwczovL2ltYWdlcy5jbGVyay5kZXYvb2F1dGhfZ2l0aHViL2ltZ18yeFhWNDBJb01ReUlzVU9VMlhJcHRCanN0TkkifQ","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_43":44,"_32":45,"_38":192,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":-5,"_57":25,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":65,"_66":67,"_68":193,"_70":-5,"_71":72,"_73":72,"_74":75,"_76":75,"_77":75,"_78":72,"_79":72,"_80":194,"_82":195,"_84":196,"_86":25},"tree",[175,176,177,178],"files",[175,176,177,178],"counts",{"_164":61,"_165":166,"_167":61,"_168":169,"_170":171},"contents",[129,130,131,132],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles",true,"grants","orgs","customDomains",{},{"_43":158,"_32":159,"_30":160,"_136":-5,"_41":42,"_40":140,"_138":124,"_38":161,"_13":61,"_33":20,"_35":162,"_24":25,"_143":-5,"_27":163},{"_43":149,"_32":150,"_30":151,"_136":-5,"_41":42,"_40":152,"_138":25,"_38":153,"_13":154,"_33":155,"_35":156,"_24":25,"_143":-5,"_27":157},{"_43":145,"_32":28,"_30":31,"_136":-5,"_41":42,"_40":14,"_138":25,"_38":146,"_13":147,"_33":34,"_35":37,"_24":25,"_143":-5,"_27":148},{"_43":133,"_32":134,"_30":135,"_136":-5,"_41":42,"_40":137,"_138":124,"_38":139,"_13":140,"_33":141,"_35":142,"_24":25,"_143":-5,"_27":144},"ac90c90a-c38a-40d3-8d55-e2bd0d07b809","main.ts","e3bc8634-64b6-11f1-8d00-1607ee4eb77e","parentId",13,"latest",["D",1781088989449],4,"http","// apple-refurb-tracker — HTTP API entrypoint\n// Hono-based query API for current stock, history, cadence, dwell, batches, health.\n// All endpoints gated by ?key= matching API_KEY env var.\n\nimport { Hono } from \"npm:hono\";\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nimport {\n STORE_CONFIGS,\n ensureSchema,\n} from \"./apple-refurb-tracker-lib.mjs\";\n\nconst app = new Hono();\n\n// Ensure schema on first request.\nlet schemaReady = false;\nasync function requireSchema() {\n if (!schemaReady) {\n await ensureSchema(sqlite);\n schemaReady = true;\n }\n}\n\n// Auth middleware.\napp.use(\"/*\", async (c, next) => {\n const expected = Deno.env.get(\"API_KEY\");\n if (expected) {\n const provided = c.req.query(\"key\") ?? c.req.header(\"x-key\") ?? \"\";\n if (provided !== expected) {\n return c.json({ ok: false, error: \"unauthorized\" }, 401);\n }\n }\n await next();\n});\n\n// Full error stack traces.\napp.onError((err) => Promise.reject(err));\n\n// Landing page.\napp.get(\"/\", async (c) => {\n const stores = STORE_CONFIGS.map((s) => ` - ${s.id}: ${s.label} (${s.currency})`).join(\"\\n\");\n return c.text(\n `apple-refurb-tracker\n\nConfigurable Apple Certified Refurbished stock tracker.\n\nStores:\\n${stores}\n\nEndpoints:\n GET /snapshot — Current stock (params: store, model)\n GET /history — Change events (params: store, part, kind, since, until, limit)\n GET /cadence — Appearances by hour/day-of-week (params: store)\n GET /dwell — Time-in-stock before sellout (params: store)\n GET /batches — Runs with 3+ simultaneous arrivals (params: store, min)\n GET /health — Last run per store, 24h success/fail counts\n\nAll endpoints require ?key= if API_KEY env var is set.\n`,\n 200,\n { \"content-type\": \"text/plain; charset=utf-8\" },\n );\n});\n\n// Current stock.\napp.get(\"/snapshot\", async (c) => {\n await requireSchema();\n const storeFilter = c.req.query(\"store\");\n const modelFilter = c.req.query(\"model\");\n\n let sql = \"SELECT * FROM current_stock WHERE 1=1\";\n const args: unknown[] = [];\n if (storeFilter) { sql += \" AND store_id = ?\"; args.push(storeFilter); }\n if (modelFilter) { sql += \" AND model LIKE ?\"; args.push(`%${modelFilter}%`); }\n sql += \" ORDER BY store_id, model, memory_gb DESC, storage_gb DESC\";\n\n const result = await sqlite.execute({ sql, args });\n const rows = mapRows(result);\n\n // Group by store.\n const byStore: Record = {};\n for (const row of rows) {\n const key = row.store_id as string;\n if (!byStore[key]) byStore[key] = [];\n byStore[key].push(row);\n }\n\n return c.json({\n ok: true,\n fetchedAt: new Date().toISOString(),\n totalInStock: rows.length,\n stores: byStore,\n });\n});\n\n// Change events.\napp.get(\"/history\", async (c) => {\n await requireSchema();\n const storeFilter = c.req.query(\"store\");\n const partFilter = c.req.query(\"part\");\n const kindFilter = c.req.query(\"kind\");\n const since = c.req.query(\"since\");\n const until = c.req.query(\"until\");\n const limit = Math.min(Number(c.req.query(\"limit\") ?? \"100\"), 500);\n\n let sql = \"SELECT * FROM events WHERE 1=1\";\n const args: unknown[] = [];\n if (storeFilter) { sql += \" AND store_id = ?\"; args.push(storeFilter); }\n if (partFilter) { sql += \" AND part_number = ?\"; args.push(partFilter); }\n if (kindFilter) { sql += \" AND kind = ?\"; args.push(kindFilter); }\n if (since) { sql += \" AND detected_at >= ?\"; args.push(since); }\n if (until) { sql += \" AND detected_at <= ?\"; args.push(until); }\n sql += \" ORDER BY detected_at DESC LIMIT ?\";\n args.push(limit);\n\n const result = await sqlite.execute({ sql, args });\n return c.json({ ok: true, count: result.rows.length, events: mapRows(result) });\n});\n\n// Cadence analysis.\napp.get(\"/cadence\", async (c) => {\n await requireSchema();\n const storeFilter = c.req.query(\"store\");\n const storeClause = storeFilter ? \"AND store_id = ?\" : \"\";\n const storeArgs = storeFilter ? [storeFilter] : [];\n\n const hourResult = await sqlite.execute({\n sql: `SELECT CAST(strftime('%H', detected_at) AS INTEGER) AS hour, COUNT(*) AS count\n FROM events WHERE kind = 'appeared' ${storeClause}\n GROUP BY hour ORDER BY hour`,\n args: storeArgs,\n });\n const dowResult = await sqlite.execute({\n sql: `SELECT CAST(strftime('%w', detected_at) AS INTEGER) AS dow, COUNT(*) AS count\n FROM events WHERE kind = 'appeared' ${storeClause}\n GROUP BY dow ORDER BY dow`,\n args: [...storeArgs],\n });\n\n return c.json({\n ok: true,\n store: storeFilter ?? \"all\",\n appearancesByHourUTC: mapRows(hourResult),\n appearancesByDayOfWeekUTC: mapRows(dowResult),\n });\n});\n\n// Dwell time.\napp.get(\"/dwell\", async (c) => {\n await requireSchema();\n const storeFilter = c.req.query(\"store\");\n const storeClause = storeFilter ? \"AND a.store_id = ?\" : \"\";\n const storeArgs = storeFilter ? [storeFilter, storeFilter] : [];\n\n const result = await sqlite.execute({\n sql: `SELECT a.part_number, a.store_id, a.title,\n a.detected_at AS appeared_at,\n d.detected_at AS disappeared_at,\n CAST((julianday(d.detected_at) - julianday(a.detected_at)) * 86400 AS INTEGER) AS dwell_seconds\n FROM events a\n JOIN events d ON a.part_number = d.part_number\n AND a.store_id = d.store_id\n AND d.kind = 'disappeared'\n AND d.detected_at > a.detected_at\n WHERE a.kind = 'appeared' ${storeClause}\n AND NOT EXISTS (\n SELECT 1 FROM events e\n WHERE e.part_number = a.part_number\n AND e.store_id = a.store_id\n AND e.kind = 'appeared'\n AND e.detected_at > a.detected_at\n AND e.detected_at < d.detected_at\n )\n ORDER BY dwell_seconds DESC`,\n args: storeArgs,\n });\n\n const rows = mapRows(result);\n const dwellSeconds = rows\n .map((r) => Number(r.dwell_seconds))\n .filter((n) => Number.isFinite(n) && n >= 0)\n .sort((a, b) => a - b);\n\n return c.json({\n ok: true,\n store: storeFilter ?? \"all\",\n soldOutCount: rows.length,\n percentilesSeconds: percentiles(dwellSeconds),\n rows,\n });\n});\n\n// Batch arrivals.\napp.get(\"/batches\", async (c) => {\n await requireSchema();\n const storeFilter = c.req.query(\"store\");\n const minBatch = Number(c.req.query(\"min\") ?? \"3\");\n const storeClause = storeFilter ? \"AND store_id = ?\" : \"\";\n const storeArgs = storeFilter ? [storeFilter, minBatch] : [minBatch];\n\n const result = await sqlite.execute({\n sql: `SELECT store_id, part_number, title, detected_at, kind\n FROM events\n WHERE kind = 'appeared' ${storeClause}\n ORDER BY detected_at DESC`,\n args: storeArgs,\n });\n\n // Group events by proximity (same minute = same batch).\n const allEvents = mapRows(result);\n const batches: unknown[][] = [];\n let current: unknown[] = [];\n let lastDetected: string | null = null;\n\n for (const ev of allEvents) {\n const ts = ev.detected_at as string;\n if (lastDetected && !sameMinute(ts, lastDetected)) {\n if (current.length >= minBatch) batches.push(current);\n current = [];\n }\n current.push(ev);\n lastDetected = ts;\n }\n if (current.length >= minBatch) batches.push(current);\n\n return c.json({\n ok: true,\n minBatchSize: minBatch,\n batchCount: batches.length,\n batches: batches.map((b) => ({\n count: b.length,\n detectedAt: (b[0] as Record).detected_at,\n storeId: (b[0] as Record).store_id,\n items: b,\n })),\n });\n});\n\n// Health.\napp.get(\"/health\", async (c) => {\n await requireSchema();\n\n const lastRuns = await sqlite.execute({\n sql: \"SELECT * FROM runs WHERE id IN (SELECT MAX(id) FROM runs GROUP BY store_id)\",\n args: [],\n });\n const last24h = await sqlite.execute({\n sql: `SELECT store_id, status, COUNT(*) AS count\n FROM runs WHERE triggered_at > datetime('now', '-1 day')\n GROUP BY store_id, status`,\n args: [],\n });\n const eventsTotal = await sqlite.execute({\n sql: \"SELECT COUNT(*) AS c FROM events\",\n args: [],\n });\n const stockNow = await sqlite.execute({\n sql: \"SELECT COUNT(*) AS c FROM current_stock\",\n args: [],\n });\n\n return c.json({\n ok: true,\n lastRuns: mapRows(lastRuns),\n last24h: mapRows(last24h),\n eventsTotal: Number(mapRows(eventsTotal)[0]?.c ?? 0),\n inStockNow: Number(mapRows(stockNow)[0]?.c ?? 0),\n });\n});\n\n// Helpers.\nfunction mapRows(result: { columns: string[]; rows: Record[] }): Record[] {\n // Val Town's std/sqlite/main.ts returns rows as objects keyed by column name.\n return result.rows;\n}\n\nfunction sameMinute(a: string, b: string): boolean {\n return a.slice(0, 16) === b.slice(0, 16);\n}\n\nfunction percentiles(sorted: number[]): Record {\n if (sorted.length === 0) return { p25: null, p50: null, p75: null, p90: null, max: null };\n const at = (p: number) => sorted[Math.min(sorted.length - 1, Math.floor((sorted.length - 1) * p))];\n return { p25: at(0.25), p50: at(0.5), p75: at(0.75), p90: at(0.9), max: sorted[sorted.length - 1] };\n}\n\nexport default app.fetch;\n","label",[134],"971c1635-012a-481b-9b4d-7cf7301f9cf6",["D",1781089157525],2,[28],"d1ad0abd-2400-4498-a2c7-758edef02f19","apple-refurb-tracker-lib.mjs","e447a548-64b6-11f1-8d00-1607ee4eb77e",16,["D",1781089039457],7,"script","// apple-refurb-tracker-lib.mjs\n// Core library for configurable Apple Certified Refurbished stock tracker.\n// Pure functions — testable from Node, importable from Val Town .ts files.\n\n// ─── Store Configs ────────────────────────────────────────────────────\n\nexport const STORE_CONFIGS = [\n {\n id: \"ie\",\n label: \"Apple Ireland\",\n region: \"IE\",\n baseUrl: \"https://www.apple.com\",\n refurbPath: \"/ie/shop/refurbished/mac\",\n currency: \"EUR\",\n vatRate: 0.23,\n },\n {\n id: \"us\",\n label: \"Apple US\",\n region: \"US\",\n baseUrl: \"https://www.apple.com\",\n refurbPath: \"/shop/refurbished/mac\",\n currency: \"USD\",\n vatRate: 0,\n },\n {\n id: \"uk\",\n label: \"Apple UK\",\n region: \"GB\",\n baseUrl: \"https://www.apple.com\",\n refurbPath: \"/uk/shop/refurbished/mac\",\n currency: \"GBP\",\n vatRate: 0.20,\n },\n];\n\nexport function getStoreConfig(storeId) {\n return STORE_CONFIGS.find((s) => s.id === storeId);\n}\n\nexport function getStoreRefurbUrl(store) {\n return `${store.baseUrl}${store.refurbPath}`;\n}\n\n// ─── Alert Rules ──────────────────────────────────────────────────────\n\n// Users fork the val and edit this array to customize their alerts.\n// match: {} → catch-all (matches every event).\nexport const DEFAULT_ALERT_RULES = [\n {\n name: \"Any refurb MacBook appeared\",\n match: {},\n alertOn: \"appeared\",\n channels: [\"email\"],\n },\n];\n\n// ─── Refurb Bootstrap Parsing ─────────────────────────────────────────\n\nconst REFURB_BOOTSTRAP_NEEDLE = \"window.REFURB_GRID_BOOTSTRAP = \";\n\nexport function extractRefurbGridBootstrap(html) {\n const start = html.indexOf(REFURB_BOOTSTRAP_NEEDLE);\n if (start === -1) {\n throw new Error(\"REFURB_GRID_BOOTSTRAP not found in Apple page\");\n }\n const jsonStart = start + REFURB_BOOTSTRAP_NEEDLE.length;\n const jsonEnd = findBalancedObjectEnd(html, jsonStart);\n return JSON.parse(html.slice(jsonStart, jsonEnd));\n}\n\nfunction findBalancedObjectEnd(text, objectStart) {\n let depth = 0;\n let inString = false;\n let escaping = false;\n\n for (let index = objectStart; index < text.length; index += 1) {\n const char = text[index];\n\n if (inString) {\n if (escaping) {\n escaping = false;\n } else if (char === \"\\\\\") {\n escaping = true;\n } else if (char === '\"') {\n inString = false;\n }\n continue;\n }\n\n if (char === '\"') {\n inString = true;\n continue;\n }\n\n if (char === \"{\") {\n depth += 1;\n continue;\n }\n\n if (char === \"}\") {\n depth -= 1;\n if (depth === 0) {\n return index + 1;\n }\n }\n }\n\n throw new Error(\"Unbalanced REFURB_GRID_BOOTSTRAP payload\");\n}\n\n// ─── Tile Normalization ───────────────────────────────────────────────\n// Primary source: dimension fields from REFURB_GRID_BOOTSTRAP (structured, reliable).\n// Enrichment: parseMacSpecs on title text for chip details that dimensions lack.\n\nexport function normalizeTile(tile, store) {\n const dimensions = tile?.filters?.dimensions ?? {};\n const title = normalizeText(tile?.title ?? \"\");\n const productUrl = normalizeAppleUrl(\n tile?.productDetailsUrl ?? \"\",\n store.baseUrl,\n );\n\n // Parse specs from title text for chip extraction and any missing fields.\n const titleSpecs = parseMacSpecs(title);\n\n // Primary: dimension fields. Fallback: title-parsed specs.\n const model = normalizeModel(dimensions.refurbClearModel) ?? titleSpecs.model;\n const memoryGb = memoryDimensionToGb(dimensions.tsMemorySize) ?? titleSpecs.memoryGb;\n const storageGb = storageDimensionToGb(dimensions.dimensionCapacity) ?? titleSpecs.storageGb;\n const storageLabel = storageGb ? formatStorageLabel(storageGb) : titleSpecs.storage?.label ?? null;\n const screenInches = screenDimensionToInches(dimensions.dimensionScreensize) ?? titleSpecs.screenInches;\n const color = normalizeText(dimensions.dimensionColor) || titleSpecs.color || null;\n const year = dimensions.dimensionRelYear ?? null;\n const chip = titleSpecs.chip; // Chip info only comes from title text.\n const cpuCores = titleSpecs.cpuCores;\n const gpuCores = titleSpecs.gpuCores;\n\n const priceCents = moneyToCents(tile?.price?.currentPrice?.raw_amount ?? null);\n const previousPriceCents = moneyToCents(tile?.price?.previousPrice?.raw_amount ?? null);\n\n return {\n storeId: store.id,\n partNumber: tile?.partNumber ?? null,\n title: cleanAppleTitle(title),\n productUrl,\n condition: \"refurbished\",\n model,\n family: familyFromModel(model),\n screenInches,\n chip,\n cpuCores,\n gpuCores,\n memoryGb,\n storageGb,\n storageLabel,\n color,\n year,\n priceCents,\n previousPriceCents,\n currency: store.currency,\n };\n}\n\nfunction memoryDimensionToGb(dim) {\n if (!dim) return null;\n const match = normalizeText(dim).match(/(\\d+)\\s*gb/i);\n return match ? Number(match[1]) : null;\n}\n\nfunction storageDimensionToGb(dim) {\n if (!dim) return null;\n const text = normalizeText(dim);\n const tb = text.match(/(\\d+(?:\\.\\d+)?)\\s*tb/i);\n if (tb) return Number(tb[1]) * 1024;\n const gb = text.match(/(\\d+)\\s*gb/i);\n return gb ? Number(gb[1]) : null;\n}\n\nfunction screenDimensionToInches(dim) {\n if (!dim) return null;\n const match = normalizeText(dim).match(/(\\d+)\\s*inch/i);\n return match ? Number(match[1]) : null;\n}\n\nfunction formatStorageLabel(gb) {\n if (gb >= 1024 && gb % 1024 === 0) return `${gb / 1024}TB`;\n return `${gb}GB`;\n}\n\nfunction cleanAppleTitle(title) {\n return normalizeText(title).replace(/\\s+-\\s+Apple\\s+\$\\w+\$$/i, \"\");\n}\n\n// ─── Fetch & Parse ────────────────────────────────────────────────────\n\nexport async function fetchStoreStock(store, fetchImpl = fetch) {\n const url = getStoreRefurbUrl(store);\n const response = await fetchImpl(url, {\n headers: {\n \"user-agent\": \"AppleRefurbTracker/1.0 (+https://val.town)\",\n accept: \"text/html,application/xhtml+xml\",\n },\n });\n if (!response.ok) {\n throw new Error(`Apple ${store.id} returned ${response.status} for ${url}`);\n }\n const html = await response.text();\n const bootstrap = extractRefurbGridBootstrap(html);\n const tiles = Array.isArray(bootstrap?.tiles) ? bootstrap.tiles : [];\n\n return tiles\n .filter((tile) => /macbook/i.test(`${tile?.title ?? \"\"} ${tile?.filters?.dimensions?.refurbClearModel ?? \"\"}`))\n .map((tile) => normalizeTile(tile, store))\n .filter((candidate) => candidate.model);\n}\n\n// ─── SQLite Schema ────────────────────────────────────────────────────\n\nexport const SCHEMA_STATEMENTS = [\n \"CREATE TABLE IF NOT EXISTS current_stock (store_id TEXT NOT NULL, part_number TEXT NOT NULL, title TEXT NOT NULL, product_url TEXT NOT NULL, model TEXT, family TEXT, screen_inches INTEGER, chip_label TEXT, cpu_cores INTEGER, gpu_cores INTEGER, memory_gb INTEGER, storage_gb INTEGER, storage_label TEXT, color TEXT, year TEXT, price_cents INTEGER, previous_price_cents INTEGER, currency TEXT NOT NULL, first_seen_at TEXT NOT NULL, last_seen_at TEXT NOT NULL, PRIMARY KEY (store_id, part_number))\",\n \"CREATE TABLE IF NOT EXISTS events (id INTEGER PRIMARY KEY AUTOINCREMENT, store_id TEXT NOT NULL, part_number TEXT NOT NULL, kind TEXT NOT NULL CHECK (kind IN ('appeared','disappeared','price_change')), title TEXT NOT NULL, model TEXT, screen_inches INTEGER, chip_label TEXT, memory_gb INTEGER, storage_gb INTEGER, price_cents INTEGER, previous_price_cents INTEGER, detected_at TEXT NOT NULL)\",\n \"CREATE TABLE IF NOT EXISTS runs (id INTEGER PRIMARY KEY AUTOINCREMENT, store_id TEXT NOT NULL, triggered_at TEXT NOT NULL, completed_at TEXT, status TEXT NOT NULL CHECK (status IN ('ok','error')), tiles_found INTEGER DEFAULT 0, events_detected INTEGER DEFAULT 0, error TEXT)\",\n \"CREATE INDEX IF NOT EXISTS idx_events_store_detected ON events (store_id, detected_at DESC)\",\n \"CREATE INDEX IF NOT EXISTS idx_events_part ON events (part_number, detected_at DESC)\",\n \"CREATE INDEX IF NOT EXISTS idx_events_kind ON events (kind, detected_at DESC)\",\n \"CREATE INDEX IF NOT EXISTS idx_runs_store ON runs (store_id, triggered_at DESC)\",\n];\n\nexport async function ensureSchema(db) {\n for (const sql of SCHEMA_STATEMENTS) {\n await db.execute(sql);\n }\n}\n\nexport async function getActivePartNumbers(db, storeId) {\n const result = await db.execute({\n sql: \"SELECT part_number FROM current_stock WHERE store_id = ?\",\n args: [storeId],\n });\n return new Set(result.rows.map((row) => row.part_number));\n}\n\nexport async function getCurrentStockRow(db, storeId, partNumber) {\n const result = await db.execute({\n sql: \"SELECT price_cents FROM current_stock WHERE store_id = ? AND part_number = ?\",\n args: [storeId, partNumber],\n });\n return result.rows[0] ?? null;\n}\n\nexport async function upsertCurrentStock(db, candidate, now) {\n await db.execute({\n sql: \"INSERT INTO current_stock (store_id, part_number, title, product_url, model, family, screen_inches, chip_label, cpu_cores, gpu_cores, memory_gb, storage_gb, storage_label, color, year, price_cents, previous_price_cents, currency, first_seen_at, last_seen_at) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?) ON CONFLICT (store_id, part_number) DO UPDATE SET title = excluded.title, product_url = excluded.product_url, model = excluded.model, family = excluded.family, screen_inches = excluded.screen_inches, chip_label = excluded.chip_label, cpu_cores = excluded.cpu_cores, gpu_cores = excluded.gpu_cores, memory_gb = excluded.memory_gb, storage_gb = excluded.storage_gb, storage_label = excluded.storage_label, color = excluded.color, year = excluded.year, price_cents = excluded.price_cents, previous_price_cents = excluded.previous_price_cents, last_seen_at = excluded.last_seen_at\",\n args: [\n candidate.storeId, candidate.partNumber, candidate.title,\n candidate.productUrl, candidate.model, candidate.family,\n candidate.screenInches, candidate.chip?.label ?? null,\n candidate.cpuCores, candidate.gpuCores, candidate.memoryGb,\n candidate.storageGb, candidate.storageLabel, candidate.color,\n candidate.year, candidate.priceCents, candidate.previousPriceCents,\n candidate.currency, now, now,\n ],\n });\n}\n\nexport async function removeCurrentStock(db, storeId, partNumber) {\n await db.execute({\n sql: \"DELETE FROM current_stock WHERE store_id = ? AND part_number = ?\",\n args: [storeId, partNumber],\n });\n}\n\nexport async function insertEvent(db, event) {\n await db.execute({\n sql: \"INSERT INTO events (store_id, part_number, kind, title, model, screen_inches, chip_label, memory_gb, storage_gb, price_cents, previous_price_cents, detected_at) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)\",\n args: [\n event.storeId, event.partNumber, event.kind, event.title,\n event.model, event.screenInches, event.chipLabel,\n event.memoryGb, event.storageGb, event.priceCents,\n event.previousPriceCents, event.detectedAt,\n ],\n });\n}\n\nexport async function insertRun(db, run) {\n const result = await db.execute({\n sql: \"INSERT INTO runs (store_id, triggered_at, completed_at, status, tiles_found, events_detected, error) VALUES (?, ?, ?, ?, ?, ?, ?)\",\n args: [\n run.storeId, run.triggeredAt, run.completedAt, run.status,\n run.tilesFound, run.eventsDetected, run.error,\n ],\n });\n return result.lastInsertRowid;\n}\n\nexport async function updateRunCompletion(db, runId, completedAt, eventsDetected) {\n await db.execute({\n sql: \"UPDATE runs SET completed_at = ?, events_detected = ? WHERE id = ?\",\n args: [completedAt, eventsDetected, runId],\n });\n}\n\nexport async function updateRunError(db, runId, error) {\n await db.execute({\n sql: \"UPDATE runs SET completed_at = ?, status = 'error', error = ? WHERE id = ?\",\n args: [new Date().toISOString(), String(error), runId],\n });\n}\n\n// ─── Change Detection ─────────────────────────────────────────────────\n\nexport async function detectChanges(storeId, candidates, db) {\n const activePns = await getActivePartNumbers(db, storeId);\n const candidateMap = new Map(candidates.map((c) => [c.partNumber, c]));\n const candidatePns = new Set(candidateMap.keys());\n\n const events = [];\n\n // Appeared: in candidates but not in current_stock.\n for (const [pn, candidate] of candidateMap) {\n if (!activePns.has(pn)) {\n events.push({\n storeId,\n partNumber: pn,\n kind: \"appeared\",\n title: candidate.title,\n model: candidate.model,\n screenInches: candidate.screenInches,\n chipLabel: candidate.chip?.label ?? null,\n memoryGb: candidate.memoryGb,\n storageGb: candidate.storageGb,\n priceCents: candidate.priceCents,\n previousPriceCents: candidate.previousPriceCents,\n candidate, // Attach for alert matching.\n });\n }\n }\n\n // Disappeared: in current_stock but not in candidates.\n for (const pn of activePns) {\n if (!candidatePns.has(pn)) {\n events.push({\n storeId,\n partNumber: pn,\n kind: \"disappeared\",\n title: null,\n model: null,\n screenInches: null,\n chipLabel: null,\n memoryGb: null,\n storageGb: null,\n priceCents: null,\n previousPriceCents: null,\n });\n }\n }\n\n // Price changed: in both, but price differs.\n for (const [pn, candidate] of candidateMap) {\n if (!activePns.has(pn)) continue;\n const row = await getCurrentStockRow(db, storeId, pn);\n if (!row) continue;\n const existingPrice = row.price_cents;\n if (candidate.priceCents != null && existingPrice != null && candidate.priceCents !== existingPrice) {\n events.push({\n storeId,\n partNumber: pn,\n kind: \"price_change\",\n title: candidate.title,\n model: candidate.model,\n screenInches: candidate.screenInches,\n chipLabel: candidate.chip?.label ?? null,\n memoryGb: candidate.memoryGb,\n storageGb: candidate.storageGb,\n priceCents: candidate.priceCents,\n previousPriceCents: existingPrice,\n candidate,\n });\n }\n }\n\n return events;\n}\n\n// ─── Alert Rule Matching ──────────────────────────────────────────────\n\nexport function matchRules(candidate, event, rules) {\n return rules.filter((rule) => {\n if (rule.alertOn !== \"all\" && rule.alertOn !== event.kind) return false;\n\n const m = rule.match;\n\n // Store filter.\n if (m.storeIds?.length && !m.storeIds.includes(candidate.storeId)) return false;\n\n // Model substring match.\n if (m.model && !(candidate.model ?? \"\").toLowerCase().includes(m.model.toLowerCase())) return false;\n\n // Min memory.\n if (m.minMemoryGb && (candidate.memoryGb ?? 0) < m.minMemoryGb) return false;\n\n // Min storage.\n if (m.minStorageGb && (candidate.storageGb ?? 0) < m.minStorageGb) return false;\n\n // Screen sizes (match any).\n if (m.screenInches?.length && !m.screenInches.includes(candidate.screenInches ?? 0)) return false;\n\n // Chip substring.\n if (m.chip && !(candidate.chip?.label ?? \"\").toLowerCase().includes(m.chip.toLowerCase())) return false;\n\n // Max price.\n if (m.maxPriceCents && (candidate.priceCents ?? Infinity) > m.maxPriceCents) return false;\n\n // Part number patterns (simple substring).\n if (m.partNumberPatterns?.length) {\n const matched = m.partNumberPatterns.some((pattern) =>\n (candidate.partNumber ?? \"\").toUpperCase().includes(pattern.replace(/\\*/g, \"\").toUpperCase()),\n );\n if (!matched) return false;\n }\n\n return true;\n });\n}\n\nexport function buildAlertSubject(candidate, event, store) {\n const verb = event.kind === \"appeared\" ? \"appeared\" : event.kind === \"disappeared\" ? \"sold out\" : \"price change\";\n const storeLabel = store?.label ?? candidate.storeId;\n return `Apple ${storeLabel} refurb: ${candidate.title ?? event.partNumber} ${verb}`;\n}\n\nexport function buildAlertText(candidate, event, store, matchedRules) {\n const storeLabel = store?.label ?? candidate.storeId;\n const verb = event.kind === \"appeared\" ? \"appeared\" : event.kind === \"disappeared\" ? \"sold out\" : \"price changed\";\n\n const lines = [\n `${candidate.title ?? event.partNumber} ${verb} on ${storeLabel}.`,\n \"\",\n `Part number: ${candidate.partNumber}`,\n ];\n\n if (candidate.model) lines.push(`Model: ${candidate.model}`);\n if (candidate.screenInches) lines.push(`Screen: ${candidate.screenInches}-inch`);\n if (candidate.chip) lines.push(`Chip: ${candidate.chip.label}`);\n if (candidate.cpuCores || candidate.gpuCores) {\n lines.push(`CPU/GPU: ${candidate.cpuCores ?? \"?\"}C / ${candidate.gpuCores ?? \"?\"}C`);\n }\n if (candidate.memoryGb) lines.push(`Memory: ${candidate.memoryGb}GB`);\n if (candidate.storageGb) lines.push(`Storage: ${candidate.storageLabel ?? `${candidate.storageGb}GB`}`);\n if (candidate.color) lines.push(`Color: ${candidate.color}`);\n if (candidate.year) lines.push(`Year: ${candidate.year}`);\n\n if (candidate.priceCents != null) {\n lines.push(`Price: ${formatMoney(candidate.priceCents, candidate.currency)}`);\n }\n if (event.previousPriceCents != null) {\n lines.push(`Previous price: ${formatMoney(event.previousPriceCents, candidate.currency)}`);\n }\n\n if (candidate.productUrl) {\n lines.push(\"\");\n lines.push(`Buy link: ${candidate.productUrl}`);\n }\n\n if (matchedRules?.length) {\n lines.push(\"\");\n lines.push(`Matched rules: ${matchedRules.map((r) => r.name).join(\", \")}`);\n }\n\n return lines.join(\"\\n\").trim();\n}\n\n// ─── Spec Parsing Helpers (from apple-mac-buying-context-lib.mjs) ─────\n\nfunction parseMacSpecs(text) {\n const normalized = normalizeSpecText(text);\n const model = normalizeModel(normalized);\n const screenInches = numberMatch(normalized, /\\b(1[3-6])\\s*(?:-| )?\\s*inch\\b/i);\n const cpuCores = numberMatch(normalized, /\\b(\\d+)\\s*(?:-| )\\s*core\\s+cpu\\b/i);\n const gpuCores = numberMatch(normalized, /\\b(\\d+)\\s*(?:-| )\\s*core\\s+gpu\\b/i);\n const memoryGb =\n numberMatch(normalized, /\\b(\\d+)\\s*gb\\s+(?:unified\\s+)?memory\\b/i) ??\n numberMatch(normalized, /\\b(24|32|36|48|64|96|128|192)\\s*gb\\b/i);\n const storage = parseStorage(normalized);\n const chip = normalizeChip(parseChipText(normalized));\n\n return {\n model,\n family: familyFromModel(model),\n screenInches,\n chip,\n cpuCores,\n gpuCores,\n memoryGb,\n storage,\n storageGb: storage?.gb ?? null,\n color: parseColor(normalized),\n };\n}\n\nfunction parseChipText(text) {\n const chipMatch =\n text.match(/\\bapple\\s+(m\\d{1,2}(?:\\s+(?:pro|max|ultra))?)\\s+chip\\b/i) ??\n text.match(/\\b(m\\d{1,2}(?:\\s+(?:pro|max|ultra))?)\\s+chip\\b/i) ??\n text.match(/\\b(m\\d{1,2}(?:\\s+(?:pro|max|ultra))?)\\b/i);\n return chipMatch?.[1] ?? null;\n}\n\nfunction normalizeChip(chip) {\n if (!chip) return null;\n\n if (typeof chip === \"object\" && chip.label) {\n return {\n label: chip.label,\n generation: chip.generation ?? chipGeneration(chip.label),\n tier: chip.tier ?? chipTier({ label: chip.label }),\n };\n }\n\n const raw = normalizeText(String(chip));\n const generation = chipGeneration(raw);\n const suffix = raw.match(/\\b(pro|max|ultra)\\b/i)?.[1]?.toLowerCase() ?? \"\";\n const suffixLabel = suffix ? ` ${suffix[0].toUpperCase()}${suffix.slice(1)}` : \"\";\n const label = generation ? `M${generation}${suffixLabel}` : raw;\n\n return { label, generation, tier: chipTier({ label }) };\n}\n\nfunction chipGeneration(chipLabel) {\n return Number(String(chipLabel ?? \"\").match(/\\bm(\\d{1,2})\\b/i)?.[1] ?? 0);\n}\n\nfunction chipTier(chip) {\n const label = chip?.label ?? \"\";\n const generation = chipGeneration(label);\n const suffixScore = /\\bUltra\\b/i.test(label) ? 3\n : /\\bMax\\b/i.test(label) ? 2\n : /\\bPro\\b/i.test(label) ? 1\n : 0;\n return generation * 10 + suffixScore;\n}\n\nfunction parseStorage(text) {\n const match =\n text.match(/\\b(\\d+(?:\\.\\d+)?)\\s*(tb|gb)\\s+storage\\b/i) ??\n [...text.matchAll(/\\b(\\d+(?:\\.\\d+)?)\\s*(tb|gb)\\b/gi)].find((candidate) => {\n const amount = Number(candidate[1]);\n const unit = candidate[2].toUpperCase();\n return unit === \"TB\" || amount >= 256;\n });\n if (!match) return null;\n\n const amount = Number(match[1]);\n const unit = match[2].toUpperCase();\n const gb = unit === \"TB\" ? amount * 1024 : amount;\n return { label: `${amount % 1 === 0 ? amount.toFixed(0) : amount}${unit}`, gb };\n}\n\nfunction parseColor(text) {\n const knownColors = [\n \"space black\", \"space grey\", \"space gray\",\n \"midnight\", \"starlight\", \"silver\", \"sky blue\",\n ];\n const lower = text.toLowerCase();\n return knownColors.find((color) => lower.includes(color)) ?? null;\n}\n\nfunction normalizeModel(text) {\n const value = normalizeText(String(text ?? \"\"));\n const match = value.match(/\\bMacBook\\s+(Air|Pro|Neo)\\b/i);\n if (!match) {\n if (/macbookair/i.test(value)) return \"MacBook Air\";\n if (/macbookpro/i.test(value)) return \"MacBook Pro\";\n return null;\n }\n return `MacBook ${match[1][0].toUpperCase()}${match[1].slice(1).toLowerCase()}`;\n}\n\nfunction familyFromModel(model) {\n if (model === \"MacBook Air\") return \"macbook-air\";\n if (model === \"MacBook Pro\") return \"macbook-pro\";\n if (model === \"MacBook Neo\") return \"macbook-neo\";\n return null;\n}\n\nfunction moneyToCents(value) {\n if (value == null || value === \"\") return null;\n const cleaned = String(value).replace(/[^\\d.,-]/g, \"\");\n if (!cleaned) return null;\n const normalized =\n cleaned.includes(\".\") || cleaned.match(/,\\d{3}(?:\\D|$)/)\n ? cleaned.replace(/,/g, \"\")\n : cleaned.replace(\",\", \".\");\n const number = Number(normalized);\n return Number.isFinite(number) ? Math.round(number * 100) : null;\n}\n\nfunction formatMoney(cents, currency = \"EUR\") {\n if (cents == null || !Number.isFinite(cents)) return \"unknown\";\n const value = cents / 100;\n const rounded = Math.round(value);\n return `${currency} ${rounded.toLocaleString(\"en-US\")}`;\n}\n\nfunction normalizeAppleUrl(rawHref, baseUrl = \"https://www.apple.com\") {\n if (!rawHref) return null;\n const cleanedHref = decodeHtml(String(rawHref)).replace(/\\s+/g, \"\").trim();\n if (!cleanedHref || cleanedHref.startsWith(\"#\") || cleanedHref.startsWith(\"javascript:\")) return null;\n try {\n const parsed = new URL(cleanedHref, baseUrl);\n if (!parsed.hostname.endsWith(\"apple.com\")) return null;\n parsed.hash = \"\";\n parsed.search = \"\";\n return parsed.toString();\n } catch {\n return null;\n }\n}\n\n// ─── Text Helpers ─────────────────────────────────────────────────────\n\nfunction normalizeSpecText(text) {\n return normalizeText(text)\n .replace(/[‐-―]/g, \"-\")\n .replace(/(\\d+)\\s*gb\\b/gi, \"$1GB\")\n .replace(/(\\d+)\\s*tb\\b/gi, \"$1TB\")\n .replace(/\\s+/g, \" \")\n .trim();\n}\n\nfunction normalizeText(text) {\n return decodeHtml(String(text ?? \"\"))\n .replace(/ /g, \" \")\n .replace(/\\s+/g, \" \")\n .trim();\n}\n\nfunction decodeHtml(text) {\n return String(text ?? \"\")\n .replace(/ /g, \" \")\n .replace(/&/g, \"&\")\n .replace(/"/g, '\"')\n .replace(/'/g, \"'\")\n .replace(/'/g, \"'\")\n .replace(/</g, \"<\")\n .replace(/>/g, \">\")\n .replace(/&#x([0-9a-f]+);/gi, (_match, hex) => String.fromCodePoint(Number.parseInt(hex, 16)))\n .replace(/&#(\\d+);/g, (_match, decimal) => String.fromCodePoint(Number.parseInt(decimal, 10)));\n}\n\nfunction numberMatch(text, pattern) {\n const match = text.match(pattern);\n return match ? Number(match[1]) : null;\n}",[150],"adfc42a8-604e-4017-a6a8-3e7fee101180","README.md","e481caac-64b6-11f1-9361-1607ee4eb77e",["D",1781087210564],"# apple-refurb-tracker\n\nConfigurable Apple Certified Refurbished stock tracker. Polls multiple Apple storefronts, detects stock changes, and alerts via email + webhook.\n\n## How It Works\n\n```\ncron.ts (every 15 min)\n └─▸ For each store (IE, US, UK):\n ├─ Fetch refurb page\n ├─ Parse REFURB_GRID_BOOTSTRAP tiles\n ├─ Diff against last known state\n ├─ Store events in SQLite\n └─ Dispatch alerts (email + webhook)\n\nmain.ts (HTTP API)\n └─▸ /snapshot /history /cadence /dwell /batches /health\n```\n\n## File Structure\n\n```\nmain.ts — HTTP API (Hono). Serves stock data and analytics.\ncron.ts — Interval entrypoint. Polls stores, detects changes, alerts.\ntracker-lib.mjs — Core logic: store configs, parsers, schema, alerts.\nREADME.md — This file.\n```\n\n## Setup After Deploy\n\n1. **Set the interval schedule** — Open `cron.ts` in the Val Town editor and set the Cron trigger. Recommended: **every 15 minutes** (free tier minimum).\n2. **Set env vars** (optional):\n - `API_KEY` — Gates the HTTP API. If unset, the API is open.\n - `ALERT_WEBHOOK_URL` — Webhook URL for Slack/Discord/custom. Only needed if you use `channels: [\"webhook\"]` in alert rules.\n3. **Customize alert rules** — Edit `DEFAULT_ALERT_RULES` in `tracker-lib.mjs` to match the specs you care about.\n\n## Adding a New Storefront\n\nAdd a config object to `STORE_CONFIGS` in `tracker-lib.mjs`:\n\n```js\n{\n id: \"de\",\n label: \"Apple Germany\",\n region: \"DE\",\n baseUrl: \"https://www.apple.com\",\n refurbPath: \"/de/shop/refurbished/mac\",\n currency: \"EUR\",\n vatRate: 0.19,\n}\n```\n\nNo other code changes needed.\n\n## Alert Rules\n\nRules are defined in `DEFAULT_ALERT_RULES` (in `tracker-lib.mjs`). Each rule has:\n\n| Field | Description |\n|-------|-------------|\n| `name` | Human-readable name |\n| `match` | Filter object — see below |\n| `alertOn` | `\"appeared\"`, `\"disappeared\"`, `\"price_change\"`, or `\"all\"` |\n| `channels` | `[\"email\"]`, `[\"webhook\"]`, or both |\n\n### Match fields\n\n| Field | Type | Example |\n|-------|------|---------|\n| `storeIds` | `string[]` | `[\"ie\"]` — only IE store |\n| `model` | `string` | `\"MacBook Pro\"` — substring match |\n| `minMemoryGb` | `number` | `24` |\n| `minStorageGb` | `number` | `512` |\n| `screenInches` | `number[]` | `[14, 15, 16]` |\n| `chip` | `string` | `\"M4 Pro\"` — substring match |\n| `maxPriceCents` | `number` | `200000` — price ceiling |\n| `partNumberPatterns` | `string[]` | `[\"FW*\"]` — substring match |\n\nAn empty `match: {}` catches everything — useful as a catch-all.\n\n### Example rules\n\n```js\n// Any MacBook appearing → email.\n{ name: \"Any MacBook\", match: {}, alertOn: \"appeared\", channels: [\"email\"] }\n\n// 24GB+ MacBook Pro 14/15-inch → email + Slack.\n{ name: \"Pro 24GB+\", match: { model: \"MacBook Pro\", minMemoryGb: 24, screenInches: [14, 15] },\n alertOn: \"appeared\", channels: [\"email\", \"webhook\"] }\n\n// Anything under €1,500 → webhook only.\n{ name: \"Budget picks\", match: { maxPriceCents: 150000 }, alertOn: \"appeared\", channels: [\"webhook\"] }\n```\n\n## HTTP API Endpoints\n\nAll endpoints require `?key=` if the `API_KEY` env var is set.\n\n| Endpoint | Description | Key params |\n|----------|-------------|------------|\n| `GET /` | This README | — |\n| `GET /snapshot` | Current stock | `store`, `model` |\n| `GET /history` | Change events | `store`, `part`, `kind`, `since`, `until`, `limit` |\n| `GET /cadence` | Appearances by hour/day | `store` |\n| `GET /dwell` | Time-in-stock stats | `store` |\n| `GET /batches` | Batch arrivals (3+ items) | `store`, `min` |\n| `GET /health` | Run health per store | — |\n\n## Environment Variables\n\n| Variable | Required | Purpose |\n|----------|----------|---------|\n| `API_KEY` | No | Gates HTTP API |\n| `ALERT_WEBHOOK_URL` | No | Webhook URL for alert dispatch |\n",[159],"pulls","branches",1,"forks","envVars",{"_172":61,"_174":61},"connections",{"_172":61,"_173":61},"count","unfilledCount","emptyCount",{"_43":158,"_32":159,"_30":160,"_136":-5,"_41":42,"_40":140,"_138":124,"_38":189,"_13":61,"_33":20,"_35":162,"_24":25,"_143":-5,"_180":190,"_27":191},{"_43":149,"_32":150,"_30":151,"_136":-5,"_41":42,"_40":152,"_138":25,"_38":186,"_13":154,"_33":155,"_35":156,"_24":25,"_143":-5,"_180":187,"_27":188},{"_43":145,"_32":28,"_30":31,"_136":-5,"_41":42,"_40":14,"_138":25,"_38":183,"_13":147,"_33":34,"_35":37,"_24":25,"_143":-5,"_180":184,"_27":185},{"_43":133,"_32":134,"_30":135,"_136":-5,"_41":42,"_40":137,"_138":124,"_38":179,"_13":140,"_33":141,"_35":142,"_24":25,"_143":-5,"_180":181,"_27":182},["D",1781088989449],"children",[],[134],["D",1781089157525],[],[28],["D",1781089039457],[],[150],["D",1781087210564],[],[159],["D",1781087208661],["D",1789530642963],{"_98":97,"_105":101},{"_98":97,"_99":-5,"_100":101,"_18":55,"_102":103,"_104":25},{"_13":87,"_32":88,"_43":42,"_89":44,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":45,"_96":97},"ctx",{"_80":-5,"_126":230,"_231":232,"_233":234,"_235":25,"_236":25,"_237":25,"_238":124,"_239":-5,"_240":-7,"_241":-7,"_242":61,"_243":25,"_244":25,"_245":-5,"_246":25,"_247":25,"_248":25,"_249":-5},"ENV",{"_201":202,"_203":204,"_205":88,"_206":207,"_208":209,"_210":211,"_212":213,"_214":215,"_216":217,"_218":219,"_220":221,"_222":223,"_224":225,"_226":227,"_228":229},"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 · v17