[^<]*(?:corvette|vette)/gi) || []).length; } catch { return null; } };\n const c4a = priced(\"C4\", \"auto\"), c5a = priced(\"C5\", \"auto\");\n await sqlite.execute({ sql: `insert or replace into season_log (week, active, in_band, p25_c4_auto, med_c4_auto, p25_c5_auto, med_c5_auto, drops_share, firm_share, storage_share, cl300, cl350, ts) values (?,?,?,?,?,?,?,?,?,?,?,?,?)`,\n args: [week, rows.length, rows.filter((r) => r.price != null && r.price >= 8000 && r.price <= 14500).length, p25(c4a), med(c4a), p25(c5a), med(c5a), share((r) => /DROP \\$/.test(String(r.flags))), share((r) => FIRM_RE.test(String(r.raw || \"\"))), share((r) => MOTIVE_RE.test(String(r.raw || \"\"))), await cl(300), await cl(350), new Date().toISOString()] });\n await setState(\"season_week\", week);\n return { week };\n}\n\nexport default async function run(opts: { force?: boolean; step?: string } = {}) {\n const started = Date.now();\n await ensureSchema();\n const results: Record = {};\n const want = (s: string) => !opts.step || opts.step === s;\n const step = async (name: string, fn: () => Promise) => {\n if (!want(name)) return;\n try { const r = await fn(); results[name] = r; await logPoll(`enrich:${name}`, true, {}, JSON.stringify(r).slice(0, 500)); }\n catch (e) { results[name] = { error: String(e).slice(0, 200) }; await logPoll(`enrich:${name}`, false, {}, String(e).slice(0, 500)); }\n };\n await step(\"queue\", releaseQueue);\n if (Date.now() - started < TIME_BUDGET_MS) await step(\"verify\", () => verifyStep(started, !!opts.force && opts.step === \"verify\"));\n if (Date.now() - started < TIME_BUDGET_MS) await step(\"decode\", () => decodeStep(started));\n if (Date.now() - started < TIME_BUDGET_MS) await step(\"recalls\", recallsStep);\n if (Date.now() - started < TIME_BUDGET_MS) await step(\"geocode\", () => geocodeStep(started));\n if (Date.now() - started < TIME_BUDGET_MS) await step(\"drive\", () => driveStep(started));\n if (Date.now() - started < TIME_BUDGET_MS) await step(\"vdp\", () => vdpStep(started));\n if (Date.now() - started < TIME_BUDGET_MS) await step(\"price\", () => priceStep(started));\n if (Date.now() - started < TIME_BUDGET_MS) await step(\"season\", () => seasonStep(!!opts.force));\n const summary = { seconds: Math.round((Date.now() - started) / 1000), results };\n console.log(\"enrich\", JSON.stringify(summary).slice(0, 1500));\n return summary;\n}\n",[19,62],"9a28d761-cfb4-4b16-87af-db351ad947bf","digest.ts","8a8cd03a-af86-11f1-b110-1607ee4eb77e",77,["D",1789472824547],3,"// Daily digest email (cron). Schedule as `0 12,13 * * *` (UTC) - the handler only sends when it is 8 AM in\r\n// America/New_York, so EDT/EST both land at 8:00 ET. Pass force=true (admin ?job=digest) to send regardless.\r\n// Sections: NEW 24H, HOT (score >= 9), NEGOTIATION TARGETS (STALE/MOTIVATED with price trail),\r\n// AUCTION COMPS THIS WEEK, SOURCES health line, PIPELINE 24h.\r\nimport { email } from \"https://esm.town/v/std/email\";\r\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\r\nimport { ensureSchema, logPoll, rowToListing, allIn, fmtMiles, fmtUsd, PUSH_THRESHOLD } from \"../lib/core.ts\";\r\nimport { etHour, fmtTrail } from \"../lib/enrich.ts\";\r\n\r\nconst fmt = (r: any) => {\r\n const l = rowToListing(r);\r\n const car = `${l.year ?? \"?\"} ${l.gen !== \"unknown\" ? l.gen : \"\"}${l.trim ? \" \" + l.trim : \"\"} ${l.trans} ${l.body !== \"unknown\" ? l.body : \"\"}`.replace(/\\s+/g, \" \").trim();\r\n const flags = l.flags.filter((f) => !/^(STRETCH|FAR)$/.test(f)).join(\", \");\r\n return `[${String(l.score).padStart(2)}] ${fmtUsd(l.price).padStart(8)} (all-in ${fmtUsd(l.allin)}) ${fmtMiles(l.miles).padStart(5)} mi ${car} ${l.seller} ${l.drive != null ? l.drive + \" drive mi\" : \"dist ?\"}${l.band !== \"core\" ? \" \" + l.band.toUpperCase() : \"\"} ${l.title}${l.vin ? \" \" + l.vin : \" NO VIN\"}${flags ? \" [\" + flags + \"]\" : \"\"}\\n ${l.loc ? l.loc + \" \" : \"\"}${l.url}`;\r\n};\r\n\r\nexport async function sendDigest(force = false) {\r\n await ensureSchema();\r\n if (!force && etHour(new Date()) !== 8) { console.log(\"digest: not 8 AM ET, skipping\"); return { skipped: true }; }\r\n const since = new Date(Date.now() - 24 * 3600 * 1000).toISOString().slice(0, 10);\r\n const newRows = await sqlite.execute({ sql: `select * from listings where first_seen >= ? order by status='dead', score desc, price asc`, args: [since] });\r\n const hot = await sqlite.execute(`select * from listings where score >= ${PUSH_THRESHOLD} and status <> 'dead' and last_seen >= date('now','-14 day') order by score desc, first_seen desc limit 20`);\r\n const nego = await sqlite.execute(`select *, cast(julianday('now') - julianday(coalesce(posted_at, first_seen)) as integer) age_days from listings\r\n where score >= 6 and status <> 'dead' and last_seen >= date('now','-14 day') and (motivated = 1 or drops > 0 or reposts > 0 or julianday('now') - julianday(coalesce(posted_at, first_seen)) >= 25)\r\n order by motivated desc, drops desc, reposts desc, age_days desc limit 15`);\r\n const trailFor = async (rowid: number) => { const t = await sqlite.execute({ sql: `select price from price_history where rowid_pk=? order by id`, args: [rowid] }); return fmtTrail((t.rows as any[]).map((x) => x.price == null ? null : Number(x.price))); };\r\n const comps = await sqlite.execute(`select * from comps where sold_price is not null and sold_date between date('now','-7 day') and date('now') order by sold_date desc, year desc limit 25`); // sold this week only (Mecum also lists future lots)\r\n const upcoming = await sqlite.execute(`select count(*) n, min(sold_date) first from comps where sold_price is null and sold_date > date('now') and year between 1992 and 2004`);\r\n const compStats = await sqlite.execute(`select gen, trans, count(*) n, round(avg(sold_price)) avg, min(sold_price) lo, max(sold_price) hi from comps where sold_date >= date('now','-180 day') and sold_price is not null group by gen, trans order by gen, trans`);\r\n // expansion-plan fix 19: from Nov 1 anchor on the Oct-Dec cohort (base C4 automatics hammer 20-35% lower Oct-Dec than January)\r\n const cohort = await sqlite.execute(`select gen, trans, count(*) n, round(avg(sold_price)) avg from comps where sold_price is not null and cast(strftime('%m', sold_date) as integer) in (10,11,12) and year between 1992 and 2004 group by gen, trans order by gen, trans`);\r\n const season = await sqlite.execute(`select week, active, in_band, p25_c4_auto, med_c4_auto, p25_c5_auto, med_c5_auto, drops_share, firm_share, storage_share, cl300, cl350 from season_log order by week desc limit 5`);\r\n const health = await sqlite.execute(`select source, fail_count, last_ok, last_run from source_state order by fail_count desc, source`);\r\n const inProgress = await sqlite.execute(`select * from listings where status in ('contacted','ppi','offer') order by score desc`);\r\n const gone = await sqlite.execute(`select * from listings where (missed >= 3 or gone_at is not null) and status not in ('dead','new') order by gone_at desc, missed desc limit 10`);\r\n const goneNew = await sqlite.execute(`select id, year, gen, trans, price, source, gone_at, flags, url from listings where gone_at >= date('now','-1 day') and status = 'dead' order by score desc limit 15`);\r\n const counts = await sqlite.execute(`select count(*) total, sum(first_seen >= date('now','-1 day')) new24, sum(score>=${PUSH_THRESHOLD} and status<>'dead') hot, sum(status='dead') dead, sum(vin is not null) with_vin, sum(pushed) pushed from listings`);\r\n const polls = await sqlite.execute(`select job, count(*) n, sum(ok) ok, sum(inserted) ins, sum(pushed) pushed, max(ts) last from poll_log where ts >= datetime('now','-1 day') group by job order by job`);\r\n const anomalies = await sqlite.execute(`select * from listings where anomaly = 1 and status <> 'dead' and last_seen >= date('now','-14 day') order by score desc limit 10`);\r\n\r\n const c: any = counts.rows[0] || {};\r\n const lines: string[] = [];\r\n lines.push(`CORVETTE DIGEST - ${new Date().toLocaleDateString(\"en-US\", { timeZone: \"America/New_York\", weekday: \"short\", month: \"short\", day: \"numeric\" })}`);\r\n const hs = health.rows as any[]; const failing = hs.filter((r) => Number(r.fail_count) >= 1); const stuck = hs.filter((r) => Number(r.fail_count) >= 3);\r\n lines.push(`Tracked ${c.total ?? 0} | new 24h ${c.new24 ?? 0} | score>=${PUSH_THRESHOLD} ${c.hot ?? 0} | with VIN ${c.with_vin ?? 0} | dead ${c.dead ?? 0} | pushed ${c.pushed ?? 0}`);\r\n lines.push(`Sources: ${hs.length - failing.length} ok / ${failing.length} failing${stuck.length ? ` - 3+ consecutive failures: ${stuck.map((r) => r.source).join(\", \")}` : \"\"}`);\r\n lines.push(\"\");\r\n lines.push(`NEW IN LAST 24H (${newRows.rows.length})`);\r\n lines.push(newRows.rows.length ? (newRows.rows as any[]).map((r) => (r.status === \"dead\" ? \" DEAD \" : \"\") + fmt(r)).join(\"\\n\") : \" none\");\r\n lines.push(\"\");\r\n lines.push(`HOT - ACTIVE SCORE >= ${PUSH_THRESHOLD} (${hot.rows.length})`);\r\n lines.push(hot.rows.length ? (hot.rows as any[]).map(fmt).join(\"\\n\") : \" none\");\r\n if (inProgress.rows.length) { lines.push(\"\"); lines.push(\"IN PROGRESS\"); lines.push((inProgress.rows as any[]).map((r) => ` ${r.status.toUpperCase()} ${fmt(r)}`).join(\"\\n\")); }\r\n if (gone.rows.length) { lines.push(\"\"); lines.push(\"IN-PROGRESS LISTINGS NO LONGER APPEARING (follow up: 'if it falls through')\"); lines.push((gone.rows as any[]).map((r) => ` ${r.id} - ${r.status}, ${r.gone_at ? \"gone \" + r.gone_at + \" (\" + (String(r.flags || \"\").split(\"|\").find((f: string) => f.startsWith(\"GONE\")) || \"GONE\") + \")\" : \"missed \" + r.missed + \" polls\"} - ${r.url}`).join(\"\\n\")); }\r\n if (goneNew.rows.length) { lines.push(\"\"); lines.push(`GONE IN LAST 24H (${goneNew.rows.length}) - removed from the tracker`); lines.push((goneNew.rows as any[]).map((r) => ` ${r.year ?? \"?\"} ${r.gen} ${r.trans} ${r.price != null ? \"$\" + Number(r.price).toLocaleString(\"en-US\") : \"$?\"} ${r.source} - ${(String(r.flags || \"\").split(\"|\").find((f: string) => f.startsWith(\"GONE\")) || \"gone\").toLowerCase()}`).join(\"\\n\")); }\r\n if (nego.rows.length) {\r\n lines.push(\"\"); lines.push(\"NEGOTIATION TARGETS - MOTIVATED first, then price drops, then 25+ days (anchor on comps; offer curve minus 8-12%)\");\r\n const out: string[] = [];\r\n for (const r of nego.rows as any[]) out.push(` [${String(r.score).padStart(2)}] ${fmtUsd(r.price)} ${r.age_days}d${r.posted_at ? \"\" : \" (since first seen)\"}${r.motivated ? \" MOTIVATED\" : \"\"}${Number(r.reposts) > 0 ? \" REPOST x\" + r.reposts : \"\"}${Number(r.drops) > 0 ? \" \" + await trailFor(Number(r.rowid_pk)) : \"\"} ${r.year} ${r.gen} ${r.trans} ${fmtMiles(r.miles)} mi ${r.seller}\\n ${r.url}`);\r\n lines.push(out.join(\"\\n\"));\r\n }\r\n if (anomalies.rows.length) { lines.push(\"\"); lines.push(\"PRICE ANOMALIES (< 75% of the rolling P25 for the year band x trans - scam gate before contact)\"); lines.push((anomalies.rows as any[]).map(fmt).join(\"\\n\")); }\r\n lines.push(\"\"); lines.push(`AUCTION COMPS THIS WEEK (${comps.rows.length})`);\r\n lines.push(comps.rows.length ? (comps.rows as any[]).map((k) => ` ${k.sold_date || \"?\"} ${fmtUsd(k.sold_price).padStart(8)} ${k.year} ${k.gen || \"\"} ${k.trans || \"\"} ${fmtMiles(k.miles)} mi ${String(k.title || \"\").slice(0, 60)} ${k.source}\\n ${k.url}`).join(\"\\n\") : \" none yet\");\r\n if (compStats.rows.length) lines.push(\" 180-day comps: \" + (compStats.rows as any[]).map((s) => `${s.gen} ${s.trans} n=${s.n} avg ${fmtUsd(s.avg)} (${fmtUsd(s.lo)}-${fmtUsd(s.hi)})`).join(\" | \"));\r\n { const u: any = upcoming.rows[0] || {}; if (Number(u.n)) lines.push(` Upcoming Mecum 1992-2004 lots: ${u.n} (first ${u.first}) - comps only, never bids`); }\r\n if (cohort.rows.length) lines.push(\" Oct-Dec cohort (the trough; anchor here from Nov 1): \" + (cohort.rows as any[]).map((s) => `${s.gen} ${s.trans} n=${s.n} avg ${fmtUsd(s.avg)}`).join(\" | \"));\r\n if (season.rows.length) { const w: any = season.rows[0]; const prev: any = season.rows[Math.min(4, season.rows.length - 1)]; lines.push(` Season log ${w.week}: active ${w.active} (in band ${w.in_band}) | C4 auto P25 ${fmtUsd(w.p25_c4_auto)} med ${fmtUsd(w.med_c4_auto)} | C5 auto P25 ${fmtUsd(w.p25_c5_auto)} med ${fmtUsd(w.med_c5_auto)} | drops ${w.drops_share} firm ${w.firm_share} storage ${w.storage_share} | CL density 300/350 mi ${w.cl300}/${w.cl350}${prev && prev.week !== w.week ? ` (vs ${prev.week}: C4 auto P25 ${fmtUsd(prev.p25_c4_auto)}, CL350 ${prev.cl350})` : \"\"}`); }\r\n lines.push(\"\"); lines.push(\"PIPELINE (24h)\");\r\n lines.push(polls.rows.length ? (polls.rows as any[]).map((p) => ` ${p.job}: ${p.ok}/${p.n} ok, ${p.ins} inserted, ${p.pushed} pushed, last ${String(p.last).slice(0, 16)}Z`).join(\"\\n\") : \" no polls logged - check cron schedules\");\r\n lines.push(\"\"); lines.push(\"Rules: PPI by an independent shop before any money. Title in the seller's name, VIN plate photo, no deposits to hold, no wire/Zelle. Notary at transfer.\");\r\n\r\n const text = lines.join(\"\\n\");\r\n const subject = `Corvette digest: ${newRows.rows.length} new, ${hot.rows.length} hot, ${comps.rows.length} comps`;\r\n await email({ subject, text });\r\n await logPoll(\"digest\", true, { fetched: newRows.rows.length }, subject);\r\n console.log(\"digest sent:\", subject);\r\n return { sent: true, subject, text };\r\n}\r\n\r\nexport default async function () { return await sendDigest(false); }\r\n",[19,69],"663ba0d7-2bcc-446d-82e4-828b7e316eda","craigslist.ts","381ffdd6-af86-11f1-ae73-1607ee4eb77e",57,["D",1789344885891],5,"// Craigslist poller (cron, every 20 min). Public search URLs, no login.\r\n// Finding from 2026-09-13 (scripts/fixtures/cl-unified-search.html): the unified\r\n// https://www.craigslist.org/search/city/new-castle-pa?cat=cta&postal=16105&radius=350 search returns\r\n// static

rows from EVERY regional site inside the radius (result hrefs are\r\n// www.craigslist.org/view/d//), so one request replaces the ~40 per-site queries in the plan. The\r\n// per-site URLs (pittsburgh.craigslist.org/search/cta?...&postal=16105&search_distance=350) return the same page.\r\n// Detail pages expose structured attrs (VIN, odometer, title status, transmission, type, paint, condition),\r\n// data-latitude/longitude, and 'categoryAbbr': \"cto\" (by-owner) | \"ctd\" (dealer).\r\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\r\nimport {\r\n ensureSchema, upsertListing, logPoll, inferYear, inferTrans, inferBody, inferTitle, inferSeller, inferMiles, inferTrim, parsePrice, parseMiles,\r\n findVin, decodeEntities, stripTags, distFrom16105, today, UA, NAV_HEADERS, sleep, PRICE_MIN, PRICE_MAX, YEAR_MIN, YEAR_MAX, MAX_INGEST_MI, type Trans, type Body, type Title, type Seller,\r\n} from \"../lib/core.ts\";\r\nimport { applyMissed } from \"../lib/enrich.ts\";\r\n\r\n// CL_RADIUS: 350 during calibration; set the env var to 500 on Nov 1 if nothing has passed PPI (expansion-plan 2b, FAR band)\r\nconst RADIUS = Number(Deno.env.get(\"CL_RADIUS\") || 350);\r\nconst BASE = `https://www.craigslist.org/search/city/new-castle-pa?cat=cta&query=corvette&postal=16105&radius=${RADIUS}`;\r\nexport const QUERIES = [\r\n `${BASE}&min_auto_year=${YEAR_MIN}&max_auto_year=${YEAR_MAX}`, // year attr set, any price (catches \"call for price\")\r\n `${BASE}&min_price=${PRICE_MIN}&max_price=${PRICE_MAX}&srchType=T`, // price in band, TITLE-only match (47 rows / 91 KB instead of 120 rows / 280 KB of dealer spam)\r\n];\r\n// step 0: the sapi JSON behind the search page - odometer, lat/lon, site, owner/dealer and posted time for every row in ~35-75 KB (verified 200 from val.town 2026-09-13)\r\nexport const SAPI = [\r\n `https://sapi.craigslist.org/web/v8/postings/search/full?batch=706-0-360-0-0&cc=US&lang=en&query=corvette&searchPath=cta&min_auto_year=${YEAR_MIN}&max_auto_year=${YEAR_MAX}&postal=16105&search_distance=${RADIUS}`,\r\n `https://sapi.craigslist.org/web/v8/postings/search/full?batch=706-0-360-0-0&cc=US&lang=en&query=corvette&searchPath=cta&min_price=${PRICE_MIN}&max_price=${PRICE_MAX}&postal=16105&search_distance=${RADIUS}`,\r\n];\r\n// Craigslist sites whose territory touches the 350 mi ring (source-inventory CL-4). A reply host outside this set is a relocation scam\r\n// (the Toms River convertible was posted from the honolulu site) -> stored with OUT-OF-REGION SITE, never pushed.\r\nexport const IN_RADIUS_CL_SITES = new Set([\"pittsburgh\", \"youngstown\", \"cleveland\", \"akroncanton\", \"erie\", \"columbus\", \"toledo\", \"dayton\", \"cincinnati\", \"buffalo\", \"rochester\", \"syracuse\", \"ithaca\", \"binghamton\", \"elmira\", \"chautauqua\", \"utica\", \"fingerlakes\", \"twintiers\", \"morgantown\", \"wheeling\", \"parkersburg\", \"charlestonwv\", \"huntington\", \"martinsburg\", \"altoona\", \"statecollege\", \"harrisburg\", \"williamsport\", \"lancaster\", \"york\", \"chambersburg\", \"poconos\", \"scranton\", \"reading\", \"allentown\", \"philadelphia\", \"westmd\", \"smd\", \"baltimore\", \"annapolis\", \"easternshore\", \"frederick\", \"washingtondc\", \"fredericksburg\", \"richmond\", \"charlottesville\", \"harrisonburg\", \"winchester\", \"lynchburg\", \"roanoke\", \"danville\", \"blacksburg\", \"detroit\", \"annarbor\", \"lansing\", \"flint\", \"saginaw\", \"jxn\", \"monroemi\", \"battlecreek\", \"kalamazoo\", \"grandrapids\", \"swmi\", \"centralmi\", \"thumb\", \"fortwayne\", \"indianapolis\", \"muncie\", \"richmondin\", \"kokomo\", \"southbend\", \"bloomington\", \"terrehaute\", \"lexington\", \"louisville\", \"eastky\", \"ashland\", \"delaware\", \"southjersey\", \"cnj\", \"jerseyshore\", \"newyork\", \"hudsonvalley\", \"mansfield\", \"ashtabula\", \"meadville\", \"sandusky\", \"limaohio\", \"zanesville\", \"chillicothe\", \"athensohio\", \"tuscarawas\", \"raleigh\", \"greensboro\", \"winstonsalem\", \"hickory\", \"boone\", \"wv\", \"newjersey\", \"albany\", \"longisland\", \"catskills\", \"oneonta\", \"watertown\", \"plattsburgh\", \"hartford\", \"newhaven\", \"providence\", \"boston\", \"worcester\", \"springfield\", \"westernmass\", \"charlotte\", \"asheville\", \"knoxville\", \"chattanooga\", \"nashville\", \"clarksville\", \"bowlinggreen\", \"owensboro\", \"evansville\", \"lafayette\", \"chicago\", \"peoria\", \"rockford\", \"milwaukee\", \"madison\", \"chambana\", \"columbiamo\"]);\r\n// other-make titles never need a detail fetch; bare titles (\"2000\", \"Corvette\") still do (expansion-plan fix 1: the Easton MD 2000 C5 hid behind a bare title)\r\nexport const OTHER_MAKE_RE = /\\b(jeep|toyota|ford|mustang|camaro|gmc|dodge|chrysler|ram|honda|nissan|hyundai|kia|subaru|mazda|bmw|mercedes|audi|volkswagen|vw|porsche|lexus|acura|infiniti|cadillac|buick|pontiac|oldsmobile|saturn|lincoln|mercury|volvo|jaguar|mini|fiat|tesla|silverado|sierra|tahoe|suburban|equinox|malibu|impala|cruze|trailblazer|blazer|colorado|avalanche|f-?150|f-?250|wrangler|firebird|challenger|charger|viper|miata|boxster|911|c6|c7|c8)\\b/i;\r\nconst TIME_BUDGET_MS = 45_000;\r\nconst MAX_DETAILS_PER_RUN = 20;\r\nconst SEARCH_DELAY_MS = 1500;\r\nconst DETAIL_DELAY_MS = 900;\r\nexport const CORVETTE_TITLE_RE = /corvette|\\bvette\\b|\\bc[45]\\b/i;\r\n\r\nexport interface SearchHit { extId: string; url: string; title: string; price: number | null; location: string; miles?: number | null; lat?: number | null; lon?: number | null; site?: string | null; owner?: boolean | null; posted?: string | null }\r\n\r\n// sapi item: [postingId-min, postedTs-min, categoryId (145 owner / 146 dealer), price, \"locIdx:descIdx~lat~lon\", imgKey, [13, opaqueId], [4, imgs...], [6, slug], [9, odometer], [10, \"$str\"], title]\r\nexport function parseSapi(json: string): SearchHit[] {\r\n let j: any; try { j = JSON.parse(json); } catch { return []; }\r\n const d = j?.data; if (!d || !Array.isArray(d.items)) return [];\r\n const locs: any[] = d.decode?.locations || []; const descs: string[] = d.decode?.locationDescriptions || [];\r\n const minPosted = Number(d.decode?.minPostedDate || 0);\r\n const out: SearchHit[] = [];\r\n for (const it of d.items.slice(0, Number(d.totalResultCount) || d.items.length)) {\r\n if (!Array.isArray(it)) continue;\r\n const title = String(it[it.length - 1] || \"\");\r\n const tagged: Record = {};\r\n for (const x of it) if (Array.isArray(x) && typeof x[0] === \"number\") tagged[x[0]] = x;\r\n const opaque = tagged[13]?.[1]; const slug = tagged[6]?.[1]; if (!opaque || !slug) continue;\r\n const locStr = typeof it[4] === \"string\" ? it[4] : \"\";\r\n const lm = locStr.match(/^(\\d+):(\\d+)~(-?[\\d.]+)~(-?[\\d.]+)/);\r\n const site = lm ? (Array.isArray(locs[Number(lm[1])]) ? String(locs[Number(lm[1])][1]) : null) : null;\r\n const desc = lm ? String(descs[Number(lm[2])] || \"\") : \"\";\r\n const rawPrice = typeof it[3] === \"number\" && it[3] > 0 ? it[3] : parsePrice(tagged[10]?.[1]);\r\n const price = rawPrice != null && rawPrice >= 1000 ? rawPrice : null; // \"$14\" placeholders are not prices\r\n out.push({ extId: String(opaque), url: `https://www.craigslist.org/view/d/${slug}/${opaque}`, title, price, location: desc,\r\n miles: tagged[9] ? Number(tagged[9][1]) || null : null, lat: lm ? Number(lm[3]) : null, lon: lm ? Number(lm[4]) : null, site,\r\n owner: it[2] === 145 ? true : it[2] === 146 ? false : null, posted: minPosted && typeof it[1] === \"number\" ? new Date((minPosted + it[1]) * 1000).toISOString() : null });\r\n }\r\n return out;\r\n}\r\n\r\nasync function fetchText(url: string): Promise<{ status: number; text: string }> {\r\n const res = await fetch(url, { headers: { \"user-agent\": UA, ...NAV_HEADERS } });\r\n return { status: res.status, text: res.ok ? await res.text() : \"\" };\r\n}\r\n\r\nexport function parseSearch(html: string): SearchHit[] {\r\n const out: SearchHit[] = [];\r\n const re = /

]*>([\\s\\S]*?)<\\/li>/g;\r\n let m: RegExpExecArray | null;\r\n while ((m = re.exec(html))) {\r\n const li = m[1];\r\n const href = (li.match(/href=\"([^\"]+)\"/) || [])[1];\r\n if (!href) continue;\r\n const extId = (href.match(/\\/([A-Za-z0-9_-]{8,})\\/?$/) || [])[1] || href;\r\n const title = decodeEntities((li.match(/

([\\s\\S]*?)<\\/div>/) || [, \"\"])[1].trim());\r\n const price = parsePrice((li.match(/

([\\s\\S]*?)<\\/div>/) || [, \"\"])[1]);\r\n const location = decodeEntities((li.match(/

([\\s\\S]*?)<\\/div>/) || [, \"\"])[1]).replace(/\\s+/g, \" \").trim();\r\n out.push({ extId, url: href, title, price, location });\r\n }\r\n return out;\r\n}\r\n\r\nexport interface Detail {\r\n title: string; price: number | null; year: number | null; makemodel: string; vin: string | null; miles: number | null; titleStatus: Title; trans: Trans; body: Body;\r\n paint: string | null; condition: string | null; fuel: string | null; drive: string | null; cylinders: string | null;\r\n lat: number | null; lon: number | null; mapaddress: string | null; posted: string | null; postId: string | null; category: string | null; area: string | null; body_text: string; attrs: Record;\r\n}\r\nexport function parseDetail(html: string): Detail {\r\n const g = (re: RegExp) => (html.match(re) || [])[1];\r\n const title = decodeEntities(g(/([\\s\\S]*?)<\\/span>/) || \"\").trim();\r\n const price = parsePrice(g(/([\\s\\S]*?)<\\/span>/));\r\n const attrs: Record = {};\r\n for (const m of html.matchAll(/

([\\s\\S]*?)<\\/div>/g)) attrs[m[1]] = stripTags(m[2]).replace(/^[^:]*:\\s*/, \"\").trim();\r\n const year = attrs.important ? Number((attrs.important.match(/\\b(19\\d\\d|20\\d\\d)\\b/) || [])[1]) || null : Number(g(/(\\d{4})<\\/span>/)) || null;\r\n const makemodel = stripTags(g(/([\\s\\S]*?)<\\/span>/) || \"\");\r\n const vinRaw = attrs.auto_vin || null;\r\n const rawAddr = stripTags(g(/class=\"mapaddress\">([\\s\\S]*?)<\\/div>/) || \"\").replace(/\\bgoogle map\\b/i, \"\").replace(/\\s+/g, \" \").trim();\r\n const lat = g(/data-latitude=\"([^\"]+)\"/); const lon = g(/data-longitude=\"([^\"]+)\"/);\r\n const bodyText = stripTags((g(/

([\\s\\S]*?)<\\/section>/) || \"\").replace(/