[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8},"actionData","errors","root",{"_109":110,"_111":112},"routes/embed.x.$handle.$name.$",{"_9":10,"_11":12,"_13":14,"_15":16,"_17":18,"_19":20,"_21":-5},"handle","logan1","name","corvette","path","cron/enrich.ts","project",{"_22":48,"_11":12,"_35":49,"_50":-5,"_51":44,"_52":53,"_54":53,"_55":56,"_57":-5,"_58":59,"_60":61,"_62":34,"_63":-5,"_64":-5,"_65":66,"_67":68,"_69":70,"_71":72,"_73":74,"_75":-5,"_76":77,"_78":77,"_79":80,"_81":80,"_82":80,"_83":77,"_84":77,"_85":86,"_87":88,"_89":90,"_91":44},"file",{"_22":23,"_11":24,"_25":26,"_27":28,"_29":30,"_31":32,"_33":34,"_35":36,"_37":38,"_39":40,"_41":42,"_43":44,"_45":-5,"_13":46},"permalink","https://www.val.town/x/logan1/corvette/code/cron/enrich.ts","extension","id","609d0c57-2d1f-44c9-a158-027ccd505fdd","enrich.ts","fileId","466804f6-af86-11f1-8153-1607ee4eb77e","parentId","1b0a73f2-af86-11f1-b58b-1607ee4eb77e","branchId","86e98f95-71bb-401c-ac30-44ee51ed36fc","branchVersion",79,"latest",true,"createdAt",["D",1789473245260],"version",4,"fileType","interval","content","// Enrichment cron (every 30 min). Steps, each logged to poll_log as enrich::\n// queue release quiet-hours pushes after 07:00 ET (\"Overnight: N listings\" + the individual embeds)\n// verify re-fetch active listing URLs (oldest verified_at first, 8/run, 12 h cadence) and mark gone rows: 404 / Craigslist removal\n// banner / SOLD thread title kill on sight, soft body-text signals need two sightings; auction lots go at auction_date + 1.\n// status 'new' -> dead + gone_at; in-progress rows keep their status, get gone_at + GONE flag (digest lists them).\n// decode NHTSA vPIC DecodeVinValues for rows with a VIN and no decode yet (cap 15/run): stores year/model/body/plant/engine,\n// flags VIN MISMATCH when the listing's year/model/body/trim disagree with the VIN (also from the VIN's own engine/body chars)\n// recalls NHTSA recalls by make/model/year, cached per model year in `recalls` (refreshed weekly)\n// geocode Census onelineaddress for street addresses, Nominatim for \"City, ST\" (cached in geocache; 1 req/s), fills lat/lon/dist/STRETCH\n// drive OSRM drive miles from 16105 for rows with coordinates (bands are drive-based: core <= 350, STRETCH 350-425, FAR 425-600)\n// vdp ClassicCars.com / JK's Galleria detail pages for rows missing miles/VIN/price (cap 3/run)\n// price re-derive age-driven flags (STALE / MOTIVATED / PRICE ANOMALY / SELLER MOTIVE / FIRM / REPOST) and the flags column for active rows\n// season Sundays: one season_log row (active count, P25/median by gen x trans, drop/firm/storage shares, CL density at 300/350)\n// Admin: ?job=enrich[&force=1][&step=queue|verify|decode|recalls|geocode|drive|vdp|price|season] (force on verify: 30 rows, ignore the 12 h cadence)\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { ensureSchema, logPoll, pushDiscord, discordText, ageDays, today, decorateNotes, flagsFor, distFrom16105, CORE_MI, CENTER, PRICE_MIN, PRICE_MAX, UA, sleep, normalizeVin, bandFor, driveMiles, findVin, parseMiles, parsePrice, inferTrans, upsertListing, score, conditionPoints, MOTIVE_RE, FIRM_RE, type Gen, type Trans, type Body } from \"../lib/core.ts\";\nimport { getState, setState, pendingQueue, markReleased, isQuietHour, priceTrail, trailStats, motivatedFlag, p25For, isAnomaly, stripPrefixes, p25, goneSignal } from \"../lib/enrich.ts\";\n\nconst TIME_BUDGET_MS = 40_000;\nconst DECODE_CAP = 15;\nconst GEOCODE_CAP = 20;\nconst VERIFY_CAP = 8;\nconst VERIFY_EVERY_H = 12;\n\nexport async function releaseQueue(): Promise<{ released: number }> {\n if (isQuietHour()) return { released: 0 };\n const q = await pendingQueue();\n if (!q.length) return { released: 0 };\n await discordText(`**Overnight: ${q.length} listing${q.length === 1 ? \"\" : \"s\"}** queued between 23:00 and 07:00 ET`);\n const done: number[] = [];\n for (const item of q) { const ok = await pushDiscord(item.payload); if (ok) done.push(item.id); await sleep(400); }\n await markReleased(done);\n return { released: done.length };\n}\n\n// ---------- verify: is the ad still up? (the missed counter only covers sources that return their full inventory) ----------\nexport async function markGone(rowid: number, reason: string, opts: { status: string; flags: string; notes: string }) {\n const flags = String(opts.flags || \"\").split(\"|\").filter((f) => f && !f.startsWith(\"GONE\"));\n flags.unshift(`GONE ${reason}`.slice(0, 60));\n const notes = decorateNotes(String(opts.notes || \"\"), flags);\n await sqlite.execute({ sql: `update listings set status=case when status='new' then 'dead' else status end, gone_at=coalesce(gone_at, ?), verified_at=?, verify_fails=0, flags=?, notes=? where rowid_pk=?`,\n args: [today(), new Date().toISOString(), flags.join(\"|\"), notes, rowid] });\n}\nasync function verifyStep(started: number, force = false): Promise<{ checked: number; gone: number; soft: number; auctionsEnded: number; errors: number; goneIds: string[] }> {\n const out = { checked: 0, gone: 0, soft: 0, auctionsEnded: 0, errors: 0, goneIds: [] as string[] };\n // 1. auction lots whose sale date has passed: gone without a fetch (the lot page stays up for months with the result on it)\n const ended = await sqlite.execute(`select rowid_pk, id, flags, notes from listings where gone_at is null and status <> 'dead' and auction_date is not null and auction_date < date('now','-1 day')`);\n for (const r of ended.rows as any[]) { await markGone(Number(r.rowid_pk), `auction ended`, r); out.auctionsEnded++; out.goneIds.push(String(r.id)); }\n // 2. re-fetch the rest, least recently verified first; Facebook needs a logged-in browser (tracker 'Gone' button / Chrome sweep)\n const cap = force ? 30 : VERIFY_CAP;\n const rows = await sqlite.execute({ sql: `select rowid_pk, id, url, source, status, flags, notes, verify_fails from listings where gone_at is null and status <> 'dead' and last_seen >= date('now','-60 day')\n and url not like '%facebook.com%' and url not like '%fb.com%' and (verified_at is null or verified_at < ? or ?) order by verified_at is not null, verified_at, score desc limit ${cap}`,\n args: [new Date(Date.now() - VERIFY_EVERY_H * 3600000).toISOString(), force ? 1 : 0] });\n for (const r of rows.rows as any[]) {\n if (Date.now() - started > (force ? TIME_BUDGET_MS : TIME_BUDGET_MS / 2)) break; // runs first: leave half the budget for decode/geocode/drive/price\n out.checked++;\n let sig: ReturnType = null; let status = 0;\n try {\n const res = await fetch(String(r.url), { headers: { \"user-agent\": UA, accept: \"text/html,*/*\" }, redirect: \"follow\", signal: AbortSignal.timeout(12000) });\n status = res.status; const html = await res.text();\n sig = goneSignal(String(r.url), status, html, res.url);\n } catch (e) { out.errors++; console.warn(\"verify\", r.id, String(e).slice(0, 80)); await sleep(300); continue; } // network error: no verdict, try again next run\n if (!sig) { await sqlite.execute({ sql: `update listings set verified_at=?, verify_fails=0 where rowid_pk=?`, args: [new Date().toISOString(), r.rowid_pk] }); }\n else if (sig.sure || Number(r.verify_fails || 0) + 1 >= 2) { await markGone(Number(r.rowid_pk), sig.reason, r); out.gone++; out.goneIds.push(String(r.id)); }\n else { await sqlite.execute({ sql: `update listings set verified_at=?, verify_fails=verify_fails+1 where rowid_pk=?`, args: [new Date().toISOString(), r.rowid_pk] }); out.soft++; }\n await sleep(700);\n }\n return out;\n}\n\n// ---------- VIN structure (C4/C5 Corvette: 1G1YY 2/3 x 5 ) ----------\nexport const VIN_ENGINE: Record = { P: \"LT1 5.7\", J: \"LT4 5.7\", Z: \"LT5 5.7 (ZR-1)\", G: \"LS1 5.7\", S: \"LS6 5.7 (Z06)\", \"8\": \"L98 5.7\" };\nexport function vinBody(vin: string | null, year: number | null): Body {\n const v = normalizeVin(vin); if (!v) return \"unknown\";\n const c = v[5];\n if (c === \"3\") return \"convertible\";\n if (c === \"2\") return \"coupe\";\n if (c === \"1\") return year != null && year >= 2001 ? \"hardtop\" : \"frc\"; // 1999-2000 FRC; 2001-04 Z06 hardtop\n return \"unknown\";\n}\nexport function vinEngine(vin: string | null): string | null { const v = normalizeVin(vin); return v ? VIN_ENGINE[v[7]] ?? null : null; }\nexport interface DecodeSummary { year: number | null; make: string; model: string; body: string; plant: string; engine: string | null; series: string; trim: string; error: string; api: boolean }\nexport function summarizeDecode(vin: string, r: Record): DecodeSummary {\n return {\n year: r.ModelYear ? Number(r.ModelYear) : null, make: r.Make || \"\", model: r.Model || \"\", body: r.BodyClass || \"\", plant: [r.PlantCity, r.PlantState].filter(Boolean).join(\", \"),\n engine: r.EngineModel || vinEngine(vin), series: r.Series || \"\", trim: r.Trim || \"\", error: r.ErrorCode || \"\", api: true,\n };\n}\n// pure: compare the listing with the VIN decode; returns mismatch strings (empty = consistent)\nexport function decodeMismatch(l: { year: number | null; body: Body; trans: Trans; trim: string; vin: string | null }, d: DecodeSummary): string[] {\n const out: string[] = [];\n if (d.year != null && l.year != null && d.year !== l.year) out.push(`year ${l.year} vs VIN ${d.year}`);\n if (d.model && !/corvette/i.test(d.model)) out.push(`VIN is a ${d.make} ${d.model}`);\n const vb = vinBody(l.vin, d.year ?? l.year);\n if (l.body !== \"unknown\" && vb !== \"unknown\" && l.body !== vb && !(l.body === \"hardtop\" && vb === \"frc\") && !(l.body === \"frc\" && vb === \"hardtop\")) out.push(`body ${l.body} vs VIN ${vb}`);\n const eng = vinEngine(l.vin) || \"\";\n if (/Z06/i.test(l.trim) && eng && !/LS6/.test(eng)) out.push(`Z06 claimed, VIN engine ${eng}`);\n if (/LT4/i.test(l.trim) && eng && !/LT4/.test(eng)) out.push(`LT4 claimed, VIN engine ${eng}`);\n if (/ZR-?1/i.test(l.trim) && eng && !/LT5/.test(eng)) out.push(`ZR-1 claimed, VIN engine ${eng}`);\n if (!/Z06/i.test(l.trim) && /LS6/.test(eng) && l.trans === \"auto\") out.push(`VIN says Z06 (LS6) - never automatic`);\n return out;\n}\n\nasync function decodeStep(started: number): Promise<{ decoded: number; mismatched: number; errors: number }> {\n const out = { decoded: 0, mismatched: 0, errors: 0 };\n const rows = await sqlite.execute(`select rowid_pk, vin, year, body, trans, trim, notes, flags from listings where vin is not null and decode is null order by score desc, last_seen desc limit ${DECODE_CAP}`);\n for (const r of rows.rows as any[]) {\n if (Date.now() - started > TIME_BUDGET_MS) break;\n try {\n const res = await fetch(`https://vpic.nhtsa.dot.gov/api/vehicles/DecodeVinValues/${r.vin}?format=json`, { headers: { \"user-agent\": UA, accept: \"application/json\" } });\n if (!res.ok) { out.errors++; continue; }\n const j = await res.json(); const d = summarizeDecode(String(r.vin), (j.Results && j.Results[0]) || {});\n const mm = decodeMismatch({ year: r.year == null ? null : Number(r.year), body: r.body, trans: r.trans, trim: String(r.trim || \"\"), vin: r.vin }, d);\n let flags = String(r.flags || \"\").split(\"|\").filter((f: string) => f && !f.startsWith(\"VIN MISMATCH\"));\n if (mm.length) { flags.push(`VIN MISMATCH ${mm.join(\"; \")}`.slice(0, 120)); out.mismatched++; }\n const notes = decorateNotes(String(r.notes || \"\"), flags);\n await sqlite.execute({ sql: `update listings set decode=?, decode_at=?, decode_mismatch=?, flags=?, notes=?, year=coalesce(year, ?), body=case when body='unknown' then ? else body end where rowid_pk=?`,\n args: [JSON.stringify(d), today(), mm.length ? mm.join(\"; \") : null, flags.join(\"|\"), notes, d.year, vinBody(r.vin, d.year), r.rowid_pk] });\n out.decoded++;\n } catch (e) { out.errors++; console.warn(\"decode\", r.vin, String(e).slice(0, 100)); }\n await sleep(500);\n }\n return out;\n}\n\nasync function recallsStep(): Promise<{ years: number[] }> {\n const stale = await sqlite.execute(`select y.year from (select distinct year from listings where year between 1992 and 2004) y left join recalls r on r.year=y.year where r.year is null or r.fetched < date('now','-7 day') limit 4`);\n const done: number[] = [];\n for (const row of stale.rows as any[]) {\n const y = Number(row.year);\n try {\n const res = await fetch(`https://api.nhtsa.gov/recalls/recallsByVehicle?make=chevrolet&model=corvette&modelYear=${y}`, { headers: { \"user-agent\": UA, accept: \"application/json\" } });\n if (!res.ok) continue;\n const j = await res.json();\n const items: any[] = (j.results || []).filter((x: any) => /general motors|chevrolet/i.test(String(x.Manufacturer || \"\"))); // drop aftermarket-part recalls\n const summary = items.map((x) => `${x.NHTSACampaignNumber} ${String(x.Component || \"\").slice(0, 40)}: ${String(x.Summary || \"\").slice(0, 120)}`).join(\"\\n\");\n await sqlite.execute({ sql: `insert or replace into recalls (year, count, summary, fetched) values (?,?,?,?)`, args: [y, items.length, summary.slice(0, 4000), today()] });\n done.push(y);\n } catch (e) { console.warn(\"recalls\", y, String(e).slice(0, 80)); }\n await sleep(400);\n }\n return { years: done };\n}\n\n// ---------- geocoding ----------\nexport async function ensureGeocache() { await sqlite.execute(`create table if not exists geocache (q text primary key, lat real, lon real, src text, ts text not null)`); }\nasync function geocodeOne(q: string): Promise<{ lat: number; lon: number; src: string } | null> {\n const c = await sqlite.execute({ sql: `select lat, lon, src from geocache where q=?`, args: [q] });\n if (c.rows.length) { const r: any = c.rows[0]; return r.lat == null ? null : { lat: Number(r.lat), lon: Number(r.lon), src: String(r.src) }; }\n let hit: { lat: number; lon: number; src: string } | null = null;\n try {\n if (/^\\d+\\s+\\S+/.test(q)) { // street address -> Census\n const res = await fetch(`https://geocoding.geo.census.gov/geocoder/locations/onelineaddress?address=${encodeURIComponent(q)}&benchmark=Public_AR_Current&format=json`, { headers: { \"user-agent\": UA } });\n const j = res.ok ? await res.json() : null; const m = j?.result?.addressMatches?.[0];\n if (m) hit = { lat: Number(m.coordinates.y), lon: Number(m.coordinates.x), src: \"census\" };\n }\n if (!hit) { // city -> Nominatim (1 req/s, identify ourselves)\n await sleep(1100);\n const res = await fetch(`https://nominatim.openstreetmap.org/search?q=${encodeURIComponent(q)}&format=json&limit=1&countrycodes=us`, { headers: { \"user-agent\": \"corvette-search-pipeline/1.0 (val.town cron; loganjtaylor1999@gmail.com)\" } });\n const j = res.ok ? await res.json() : null;\n if (Array.isArray(j) && j[0]) hit = { lat: Number(j[0].lat), lon: Number(j[0].lon), src: \"nominatim\" };\n }\n } catch (e) { console.warn(\"geocode\", q, String(e).slice(0, 80)); return null; }\n await sqlite.execute({ sql: `insert or replace into geocache (q, lat, lon, src, ts) values (?,?,?,?,?)`, args: [q, hit?.lat ?? null, hit?.lon ?? null, hit?.src ?? \"none\", today()] });\n return hit;\n}\n// clean \"336 Route 130 - CL newyork\" / \"Boardman, OH\" style loc strings into something a geocoder understands\nexport function geocodeQuery(loc: string): string | null {\n let q = (loc || \"\").replace(/\\s*-\\s*CL \\w+$/i, \"\").replace(/^CL \\w+$/i, \"\").trim();\n if (!q) return null;\n if (/^\\d+\\s+\\S+/.test(q) && !/,/.test(q)) return null; // bare street with no city - the metro fallback already placed it\n return q.slice(0, 100);\n}\nasync function geocodeStep(started: number): Promise<{ tried: number; filled: number }> {\n await ensureGeocache();\n const out = { tried: 0, filled: 0 };\n const rows = await sqlite.execute(`select rowid_pk, loc, flags, notes from listings where (lat is null or geocode_src='metro') and loc <> '' and status <> 'dead' and last_seen >= date('now','-30 day') order by score desc limit ${GEOCODE_CAP}`);\n for (const r of rows.rows as any[]) {\n if (Date.now() - started > TIME_BUDGET_MS) break;\n const q = geocodeQuery(String(r.loc)); if (!q) { await sqlite.execute({ sql: `update listings set geocode_src=coalesce(geocode_src,'none') where rowid_pk=?`, args: [r.rowid_pk] }); continue; }\n out.tried++;\n const hit = await geocodeOne(q);\n if (!hit) { await sqlite.execute({ sql: `update listings set geocode_src=case when geocode_src='metro' then 'metro' else 'none' end where rowid_pk=?`, args: [r.rowid_pk] }); continue; }\n const dist = distFrom16105(hit.lat, hit.lon);\n let flags = String(r.flags || \"\").split(\"|\").filter((f: string) => f && f !== \"STRETCH\");\n if (dist != null && dist > CORE_MI) flags.push(\"STRETCH\");\n await sqlite.execute({ sql: `update listings set lat=?, lon=?, dist=?, stretch=?, geocode_src=?, flags=?, notes=? where rowid_pk=?`, args: [hit.lat, hit.lon, dist, dist != null && dist > CORE_MI ? 1 : 0, hit.src, flags.join(\"|\"), decorateNotes(String(r.notes || \"\"), flags), r.rowid_pk] });\n out.filled++;\n }\n return out;\n}\n\n// re-derive age-driven flags for active rows; score is recomputed only for the dist point when coordinates arrived\nasync function priceStep(started: number): Promise<{ rows: number; motivated: number; anomaly: number; stale: number }> {\n const out = { rows: 0, motivated: 0, anomaly: 0, stale: 0 };\n const rows = await sqlite.execute(`select rowid_pk, vin, year, trans, trim, price, dist, drive_mi, reposts, notes, flags, posted_at, first_seen, drops, motivated, anomaly, raw from listings where status <> 'dead' and last_seen >= date('now','-30 day')`);\n const cache = new Map();\n for (const r of rows.rows as any[]) {\n if (Date.now() - started > TIME_BUDGET_MS) break;\n const age = ageDays(r.posted_at, r.first_seen);\n const trail = await priceTrail(Number(r.rowid_pk));\n if (!trail.length && r.price != null) { await sqlite.execute({ sql: `insert into price_history (rowid_pk, price, seen) values (?,?,?)`, args: [r.rowid_pk, r.price, r.first_seen] }); trail.push(Number(r.price)); }\n const ts = trailStats(trail);\n const motivated = motivatedFlag(ts.drops, age);\n const key = `${r.year}|${r.trans}`;\n if (!cache.has(key)) cache.set(key, (await p25For(r.year == null ? null : Number(r.year), String(r.trans))).p25);\n const anomaly = isAnomaly(r.price == null ? null : Number(r.price), cache.get(key) ?? null);\n const keep = String(r.flags || \"\").split(\"|\").filter((f: string) => /^(DEAD |VIN MISMATCH|GONE)/.test(f));\n const oor = String(r.flags || \"\").includes(\"OUT-OF-REGION SITE\");\n const flags = [...keep, ...flagsFor({ vin: r.vin, trim: String(r.trim || \"\"), trans: r.trans, text: String(r.raw || \"\"), dist: r.dist == null ? null : Number(r.dist), drive: r.drive_mi, ageDays: age, anomaly, motivated, lastDrop: ts.lastDrop, reposts: Number(r.reposts || 0), outOfRegionSite: oor })];\n const notes = decorateNotes(String(r.notes || \"\"), flags);\n const band = bandFor(driveMiles(r.dist == null ? null : Number(r.dist), r.drive_mi));\n if (notes !== r.notes || flags.join(\"|\") !== r.flags || motivated !== !!r.motivated || anomaly !== !!r.anomaly || ts.drops !== Number(r.drops)) {\n await sqlite.execute({ sql: `update listings set notes=?, flags=?, drops=?, motivated=?, anomaly=?, band=?, stretch=? where rowid_pk=?`, args: [notes, flags.join(\"|\"), ts.drops, motivated ? 1 : 0, anomaly ? 1 : 0, band, band !== \"core\" || (r.dist != null && Number(r.dist) > CORE_MI) ? 1 : 0, r.rowid_pk] });\n }\n out.rows++; if (motivated) out.motivated++; if (anomaly) out.anomaly++; if (age > 45) out.stale++;\n }\n return out;\n}\n\n// ---------- drive miles via the public OSRM demo server (expansion-plan 2b): bands are drive-based, not straight-line ----------\nasync function driveStep(started: number): Promise<{ routed: number; failed: number }> {\n const out = { routed: 0, failed: 0 };\n const rows = await sqlite.execute(`select rowid_pk, lat, lon, dist from listings where lat is not null and lon is not null and drive_mi is null and status <> 'dead' and last_seen >= date('now','-30 day') order by score desc limit 12`);\n for (const r of rows.rows as any[]) {\n if (Date.now() - started > TIME_BUDGET_MS) break;\n try {\n const res = await fetch(`https://router.project-osrm.org/route/v1/driving/${CENTER.lon},${CENTER.lat};${r.lon},${r.lat}?overview=false`, { headers: { \"user-agent\": UA }, signal: AbortSignal.timeout(15000) });\n const j = res.ok ? await res.json() : null;\n const m = j?.routes?.[0]?.distance;\n if (!m) { out.failed++; continue; }\n const drive = Math.round(Number(m) / 1609.344);\n const band = bandFor(drive);\n await sqlite.execute({ sql: `update listings set drive_mi=?, band=?, stretch=? where rowid_pk=?`, args: [drive, band, band !== \"core\" || (r.dist != null && Number(r.dist) > CORE_MI) ? 1 : 0, r.rowid_pk] });\n out.routed++;\n } catch (e) { out.failed++; console.warn(\"osrm\", r.rowid_pk, String(e).slice(0, 80)); }\n await sleep(600);\n }\n return out;\n}\n\n// ---------- VDP enrichment: ClassicCars.com JSON-LD (miles, VIN, transmission) and JK's Galleria DealerCarSearch VDPs (price, miles, VIN) ----------\nasync function vdpStep(started: number): Promise<{ fetched: number; filled: number }> {\n const out = { fetched: 0, filled: 0 };\n const rows = await sqlite.execute(`select rowid_pk, source, external_id, url, year, gen, trans, body, miles, price, title, seller, loc, lat, lon, notes, raw from listings\n where status <> 'dead' and last_seen >= date('now','-30 day') and ((source='classiccars' and (miles is null or vin is null)) or (source='jkgalleria' and price is null)) and (notes not like '%VDP checked%') order by score desc limit 3`);\n for (const r of rows.rows as any[]) {\n if (Date.now() - started > TIME_BUDGET_MS) break;\n out.fetched++;\n try {\n const res = await fetch(String(r.url), { headers: { \"user-agent\": UA, accept: \"text/html,*/*\" }, signal: AbortSignal.timeout(15000) });\n const html = res.ok ? await res.text() : \"\";\n if (!html) { await sqlite.execute({ sql: `update listings set notes=notes || ' | VDP checked http ' || ? where rowid_pk=?`, args: [res.status, r.rowid_pk] }); continue; }\n const miles = parseMiles((html.match(/\"mileageFromOdometer\"[\\s\\S]{0,80}?\"value\":\\s*\"?(\\d+)/) || html.match(/Mileage:?<\\/[a-z]+>\\s*<[^>]+>\\s*([\\d,]+)/i) || html.match(/([\\d,]{5,7})\\s*(?:miles|mi\\b)/i) || [])[1]);\n const vin = findVin((html.match(/\"vehicleIdentificationNumber\":\\s*\"([A-Z0-9]{17})\"/) || [])[1] || \"\") || findVin(html.slice(0, 200000));\n const transM = html.match(/Transmission:?<\\/span>\\s*]*>\\s*(Automatic|Manual)/i) || html.match(/\"vehicleTransmission\":\\s*\"([^\"]+)\"/);\n const trans = transM ? inferTrans(transM[1]) : r.trans;\n const price = r.price ?? parsePrice((html.match(/\"price\":\\s*\"?(\\d{4,6})/) || html.match(/\\$\\s?([\\d,]{5,7})/) || [])[1]);\n if (price != null && (price < PRICE_MIN || price > PRICE_MAX)) { // the list page had no price; the VDP says it is outside the band\n await sqlite.execute({ sql: `update listings set price=?, status=case when status='new' then 'dead' else status end, notes=notes || ' | VDP checked ' || ? || ' price $' || ? || ' out of band' where rowid_pk=?`, args: [price, today(), price, r.rowid_pk] });\n continue;\n }\n const up = await upsertListing({ vin: vin || null, year: r.year, gen: r.gen, trans: trans === \"unknown\" ? r.trans : trans, body: r.body, miles: miles ?? r.miles, price, title: r.title, seller: r.seller, loc: r.loc, lat: r.lat, lon: r.lon,\n source: r.source, externalId: r.external_id, url: r.url, notes: `VDP checked ${today()}${vin ? \" VIN \" + vin : \"\"}${miles ? \" \" + miles + \" mi\" : \"\"}` }, { push: true });\n if (up) out.filled++;\n } catch (e) { console.warn(\"vdp\", r.rowid_pk, String(e).slice(0, 80)); await sqlite.execute({ sql: `update listings set notes=notes || ' | VDP checked error' where rowid_pk=?`, args: [r.rowid_pk] }); }\n await sleep(2500);\n }\n return out;\n}\n\n// ---------- weekly season_log (Sundays): measured seasonality for this radius (expansion-plan fix 18) ----------\nasync function seasonStep(force = false): Promise<{ week?: string; skipped?: string }> {\n const d = new Date(); const week = d.toISOString().slice(0, 10);\n const isSunday = new Intl.DateTimeFormat(\"en-US\", { timeZone: \"America/New_York\", weekday: \"short\" }).format(d) === \"Sun\";\n const done = await getState(\"season_week\");\n if (!force && (!isSunday || done === week)) return { skipped: done === week ? `logged ${done}` : \"not Sunday\" };\n const act = await sqlite.execute(`select gen, trans, price, flags, raw from listings where status <> 'dead' and last_seen >= date('now','-7 day') and band in ('core','stretch')`);\n const rows = act.rows as any[];\n const priced = (g: string, t: string) => rows.filter((r) => r.gen === g && r.trans === t && r.price != null).map((r) => Number(r.price));\n const med = (v: number[]) => v.length ? v.slice().sort((a, b) => a - b)[Math.floor(v.length / 2)] : null;\n const share = (fn: (r: any) => boolean) => rows.length ? Math.round(100 * rows.filter(fn).length / rows.length) / 100 : null;\n const cl = async (radius: number) => { try { const res = await fetch(`https://www.craigslist.org/search/city/new-castle-pa?cat=cta&query=corvette&postal=16105&radius=${radius}&min_auto_year=1992&max_auto_year=2004`, { headers: { \"user-agent\": UA }, signal: AbortSignal.timeout(15000) }); const t = res.ok ? await res.text() : \"\"; return (t.match(/

[^<]*(?: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","deleted",false,"label",[47,24],"cron","00cc23ab-c212-43f5-a7c5-1ba797ecaa18",["D",1789312547277],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","C4/C5 Corvette search pipeline (CL, forums, auctions, comps)","imageUrl","userId","87445237-7d14-45c7-b3a2-72e031f10ec1","pinnedFileId","2b16e0f0-af8b-11f1-8152-1607ee4eb77e","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","01a09786-a61b-74b5-8910-af3116d3de5c","tursoName","00cc23abc21243f5a7c51ba797ecaa18","tursoHostname","00cc23abc21243f5a7c51ba797ecaa18-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789486866837],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_9":10,"_108":104},"org",{"_9":10,"_101":102,"_103":104,"_58":59,"_105":106,"_107":44},"branch",{"_37":32,"_11":92,"_22":30,"_93":48,"_94":-5,"_95":-5,"_96":-5,"_97":-5,"_98":-5,"_99":12,"_100":10},"isOwned","main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","Logan","avatar","https://lh3.googleusercontent.com/a/ACg8ocIFxddfJftSiTFZN49YShT3nY7q8GOQ7dXYM2vJ6XkajnQMGA=s96-c","tier","free","canRestrictVals","profileImageUrl","ctx",{"_85":-5,"_142":143,"_144":145,"_146":147,"_148":44,"_149":44,"_150":44,"_151":34,"_152":-5,"_153":-7,"_154":-7,"_155":66,"_156":44,"_157":44,"_158":-5,"_159":44,"_160":44,"_161":44,"_162":-5},"ENV",{"_113":114,"_115":116,"_117":92,"_118":119,"_120":121,"_122":123,"_124":125,"_126":127,"_128":129,"_130":131,"_132":133,"_134":135,"_136":137,"_138":139,"_140":141},"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","orgs",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]