[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8},"actionData","errors","root",{"_110":111,"_112":113},"routes/embed.x.$handle.$name.$",{"_9":10,"_11":12,"_13":14,"_15":16,"_17":18,"_19":20,"_21":-5},"handle","logan1","name","corvette","path","lib/core.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/lib/core.ts","extension","id","3cfa9dee-2d27-4b15-a3bb-acd9b7e270a1","core.ts","fileId","227e10c6-af86-11f1-8b05-1607ee4eb77e","parentId","16dfa00e-af86-11f1-9559-1607ee4eb77e","branchId","86e98f95-71bb-401c-ac30-44ee51ed36fc","branchVersion",55,"latest",true,"createdAt",["D",1789344876314],"version",5,"fileType","script","content","// Shared core for the Corvette search pipeline (forked from logan1/housing lib/core.ts):\n// schema, VIN validation, attribute inference, scoring, dedupe/upsert, feed mapping, Discord push.\n// Imported by every other file. Everything that calls an external API lives in cron/enrich.ts.\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { ensureEnrichSchema, p25For, isAnomaly, recordPrice, trailStats, motivatedFlag, stripPrefixes, buildPrefix, fmtTrail, isQuietHour, queuePush } from \"./enrich.ts\";\n\n// ---------- constants (plan Section 10) ----------\nexport const CENTER = { lat: 41.0037, lon: -80.3470 }; // 16105 New Castle, PA\nexport const CORE_MI = 300; // straight-line, legacy STRETCH flag boundary (kept for the tracker)\nexport const STRETCH_MI = 350; // straight-line ingest ring for the unified Craigslist search\nexport const MAX_INGEST_MI = 510; // straight-line: ~600 drive miles - beyond this nothing is stored\n// distance bands by DRIVE miles (expansion-plan 2b). Drive miles = OSRM value from cron/enrich.ts when present, else straight-line x 1.18.\nexport const DRIVE_FACTOR = 1.18;\nexport const BAND_CORE_MAX = 350, BAND_STRETCH_MAX = 425, BAND_FAR_MAX = 600;\nexport const FAR_FROM = \"2026-11-01\"; // FAR band (425-600 drive mi) pushes only from this date if nothing has passed PPI\nexport type Band = \"core\" | \"stretch\" | \"far\" | \"out\";\nexport function driveMiles(dist: number | null | undefined, drive?: number | null): number | null {\n if (drive != null && Number.isFinite(Number(drive))) return Math.round(Number(drive));\n return dist == null ? null : Math.round(Number(dist) * DRIVE_FACTOR);\n}\nexport function bandFor(driveMi: number | null): Band {\n if (driveMi == null) return \"core\"; // unknown location counts as core for scoring; the NO LOC gap is handled by pushMin on those sources\n if (driveMi <= BAND_CORE_MAX) return \"core\";\n if (driveMi <= BAND_STRETCH_MAX) return \"stretch\";\n if (driveMi <= BAND_FAR_MAX) return \"far\";\n return \"out\";\n}\n// travel cost per band (expansion-plan 2a): bus/flight + fuel home + hotel, cash only; PPI is $250 local (<= 250 drive mi) or $330 remote\nexport const BAND_TRAVEL: Record = { core: 223, stretch: 288, far: 455, out: 720 };\nexport function ppiCost(driveMi: number | null): number { return driveMi != null && driveMi > 250 ? 330 : 250; }\nexport const PRICE_MIN = 8000;\nexport const PRICE_MAX = 14500;\nexport const PRICE_POINT = 10600; // asking <= ceiling - 15% -> +1\nexport const PUSH_THRESHOLD = 9;\nexport const STRETCH_PUSH_THRESHOLD = 10;\nexport const YEAR_MIN = 1992;\nexport const YEAR_MAX = 2004;\nexport const GEN = [\"C4\", \"C5\", \"unknown\"] as const;\nexport const TRANS = [\"auto\", \"manual\", \"unknown\"] as const;\nexport const BODY = [\"coupe\", \"convertible\", \"frc\", \"hardtop\", \"unknown\"] as const;\nexport const TITLE = [\"clean\", \"rebuilt\", \"salvage\", \"unknown\"] as const;\nexport const SELLER = [\"private\", \"dealer-small\", \"dealer-franchise\", \"auction\", \"unknown\"] as const;\nexport const STATUS = [\"new\", \"contacted\", \"ppi\", \"offer\", \"dead\"] as const;\nexport type Gen = typeof GEN[number]; export type Trans = typeof TRANS[number]; export type Body = typeof BODY[number];\nexport type Title = typeof TITLE[number]; export type Seller = typeof SELLER[number];\n\n// all-in estimate = asking x 1.06 (PA sales tax) + $150 title/tag + $250 PPI + $1,500 first-year reserve\nexport function allIn(price: number | null, driveMi: number | null = null): number | null {\n if (price == null) return null;\n const travel = driveMi == null || driveMi <= 120 ? 0 : BAND_TRAVEL[bandFor(driveMi)];\n return Math.round(price * 1.06 + 150 + 1500 + ppiCost(driveMi) + travel);\n}\n\nexport interface Listing {\n id: string; vin: string | null; year: number | null; gen: Gen; model: string; trim: string; trans: Trans; body: Body;\n miles: number | null; price: number | null; allin: number | null; title: Title; seller: Seller; loc: string; dist: number | null;\n stretch: boolean; band: Band; drive: number | null; url: string; src: string; note: string; fs: string; lv: string; status: typeof STATUS[number]; missed: number;\n score: number; flags: string[]; reposts: number;\n}\n\n// ---------- schema ----------\nexport async function ensureSchema() {\n await sqlite.batch([\n `create table if not exists listings (\n rowid_pk integer primary key autoincrement,\n id text not null,\n vin text,\n year integer, gen text not null default 'unknown', model text not null default 'Corvette', trim text not null default '',\n trans text not null default 'unknown', body text not null default 'unknown',\n miles integer, price integer,\n title text not null default 'unknown', seller text not null default 'unknown',\n loc text not null default '', lat real, lon real, dist real, stretch integer not null default 0,\n source text not null, external_id text, url text not null,\n score integer not null default 0, flags text not null default '',\n first_seen text not null, last_seen text not null, posted_at text,\n status text not null default 'new', missed integer not null default 0, pushed integer not null default 0,\n notes text not null default '', raw text,\n anomaly integer not null default 0, drops integer not null default 0, motivated integer not null default 0, gone_at text,\n decode text, decode_at text, decode_mismatch text, geocode_src text, auction_date text\n )`,\n `create index if not exists listings_vin on listings(vin)`,\n `create index if not exists listings_id on listings(id)`,\n `create index if not exists listings_ext on listings(source, external_id)`,\n `create index if not exists listings_seen on listings(last_seen)`,\n `create table if not exists skips (source text not null, external_id text not null, reason text, ts text not null, primary key (source, external_id))`,\n `create table if not exists source_state (source text primary key, last_run text, last_ok text, fail_count integer not null default 0, runs integer not null default 0, inserted_total integer not null default 0, detail text)`,\n `create table if not exists poll_log (id integer primary key autoincrement, ts text not null, job text not null, ok integer not null, fetched integer default 0, inserted integer default 0, updated integer default 0, pushed integer default 0, detail text)`,\n `create table if not exists comps (id integer primary key autoincrement, source text not null, external_id text not null, year integer, gen text, trans text, body text, miles integer, sold_price integer, sold_date text, url text, title text, vin text, added text not null, unique(source, external_id))`,\n `create table if not exists recalls (year integer primary key, count integer not null, summary text, fetched text not null)`,\n ]);\n const cols = new Set(((await sqlite.execute(`pragma table_info(listings)`)).rows as any[]).map((r) => String(r.name)));\n const add = async (c: string, ddl: string) => { if (!cols.has(c)) await sqlite.execute(`alter table listings add column ${c} ${ddl}`); };\n await add(\"drive_mi\", \"integer\"); // OSRM drive miles from 16105 (cron/enrich.ts), null until routed\n await add(\"band\", \"text not null default 'core'\");\n await add(\"reposts\", \"integer not null default 0\"); // dedupe merges from a different external id (relists) - a negotiation lever, never a suppression\n await sqlite.execute(`create table if not exists season_log (week text primary key, active integer, in_band integer, p25_c4_auto integer, med_c4_auto integer, p25_c5_auto integer, med_c5_auto integer, drops_share real, firm_share real, storage_share real, cl300 integer, cl350 integer, ts text not null)`);\n await ensureEnrichSchema();\n}\n\nexport function today(): string { return new Date().toISOString().slice(0, 10); }\n\n// ---------- VIN ----------\nconst VIN_MAP: Record = { A: 1, B: 2, C: 3, D: 4, E: 5, F: 6, G: 7, H: 8, J: 1, K: 2, L: 3, M: 4, N: 5, P: 7, R: 9, S: 2, T: 3, U: 4, V: 5, W: 6, X: 7, Y: 8, Z: 9 };\nconst VIN_WEIGHTS = [8, 7, 6, 5, 4, 3, 2, 10, 0, 9, 8, 7, 6, 5, 4, 3, 2];\nexport function normalizeVin(v: unknown): string | null {\n if (v == null) return null;\n const s = String(v).toUpperCase().replace(/[^A-Z0-9]/g, \"\");\n return s.length === 17 ? s : null;\n}\n// 17 chars, no I/O/Q, North-American check digit (position 9) must verify\nexport function validVin(v: string | null | undefined): boolean {\n const s = normalizeVin(v); if (!s) return false;\n if (/[IOQ]/.test(s)) return false;\n let sum = 0;\n for (let i = 0; i < 17; i++) { const c = s[i]; const n = /\\d/.test(c) ? Number(c) : VIN_MAP[c]; if (n == null) return false; sum += n * VIN_WEIGHTS[i]; }\n const chk = sum % 11; const want = chk === 10 ? \"X\" : String(chk);\n return s[8] === want;\n}\n// model year from the 10th VIN character (1992-2004 window only)\nconst VIN_YEAR: Record = { N: 1992, P: 1993, R: 1994, S: 1995, T: 1996, V: 1997, W: 1998, X: 1999, Y: 2000, \"1\": 2001, \"2\": 2002, \"3\": 2003, \"4\": 2004 };\nexport function vinYear(v: string | null): number | null { const s = normalizeVin(v); return s ? VIN_YEAR[s[9]] ?? null : null; }\nexport function findVin(text: string): string | null {\n for (const m of (text || \"\").toUpperCase().matchAll(/\\b(1G1Y[A-HJ-NPR-Z0-9]{13})\\b/g)) if (validVin(m[1])) return m[1]; // Corvette WMI 1G1Y\n for (const m of (text || \"\").toUpperCase().matchAll(/\\b([A-HJ-NPR-Z0-9]{17})\\b/g)) if (validVin(m[1])) return m[1];\n return null;\n}\n\n// ---------- geography ----------\nexport function haversineMi(lat1: number, lon1: number, lat2: number, lon2: number): number {\n const R = 3958.8, toR = (d: number) => d * Math.PI / 180;\n const dLat = toR(lat2 - lat1), dLon = toR(lon2 - lon1);\n const a = Math.sin(dLat / 2) ** 2 + Math.cos(toR(lat1)) * Math.cos(toR(lat2)) * Math.sin(dLon / 2) ** 2;\n return R * 2 * Math.atan2(Math.sqrt(a), Math.sqrt(1 - a));\n}\nexport function distFrom16105(lat: number | null | undefined, lon: number | null | undefined): number | null {\n if (lat == null || lon == null || !Number.isFinite(Number(lat)) || !Number.isFinite(Number(lon))) return null;\n return Math.round(haversineMi(CENTER.lat, CENTER.lon, Number(lat), Number(lon)));\n}\n// coarse metro centroids for listings that only carry a city name (Census geocoder fills exact coords in cron/enrich.ts)\nexport const METROS: [RegExp, number, number][] = [\n [/\\bnew castle\\b|\\bellwood\\b|\\bgrove city\\b|\\bbutler\\b|\\bbeaver\\b/i, 41.0037, -80.347],\n [/\\bpittsburgh\\b|\\bcranberry\\b|\\bmonroeville\\b|\\bwashington,? pa\\b|\\bgreensburg\\b|\\bmckeesport\\b/i, 40.4406, -79.9959],\n [/\\byoungstown\\b|\\bwarren,? oh\\b|\\bboardman\\b|\\baustintown\\b|\\bniles\\b|\\bhubbard\\b/i, 41.0998, -80.6495],\n [/\\bcleveland\\b|\\bparma\\b|\\blakewood\\b|\\bmentor\\b|\\bstrongsville\\b|\\bwilloughby\\b/i, 41.4993, -81.6944],\n [/\\bakron\\b|\\bcanton\\b|\\bmassillon\\b|\\bkent,? oh\\b|\\bmedina\\b|\\bcuyahoga falls\\b/i, 41.0814, -81.519],\n [/\\berie,? pa\\b|\\berie\\b/i, 42.1292, -80.0851],\n [/\\bcolumbus\\b|\\bdublin,? oh\\b|\\bwesterville\\b|\\bgrove city,? oh\\b|\\bhilliard\\b/i, 39.9612, -82.9988],\n [/\\btoledo\\b|\\bperrysburg\\b/i, 41.6528, -83.5379],\n [/\\bdayton\\b|\\bkettering\\b|\\bspringfield,? oh\\b/i, 39.7589, -84.1916],\n [/\\bcincinnati\\b|\\bmason,? oh\\b|\\bwest chester,? oh\\b|\\bcovington,? ky\\b|\\bflorence,? ky\\b/i, 39.1031, -84.512],\n [/\\bbuffalo\\b|\\bamherst,? ny\\b|\\bcheektowaga\\b|\\bhamburg,? ny\\b|\\bniagara\\b/i, 42.8864, -78.8784],\n [/\\brochester,? ny\\b|\\brochester\\b/i, 43.1566, -77.6088],\n [/\\bsyracuse\\b/i, 43.0481, -76.1474],\n [/\\bmorgantown\\b|\\bfairmont,? wv\\b/i, 39.6295, -79.9559],\n [/\\bwheeling\\b|\\bsteubenville\\b|\\bweirton\\b/i, 40.064, -80.7209],\n [/\\bparkersburg\\b|\\bmarietta\\b/i, 39.2667, -81.5615],\n [/\\bcharleston,? wv\\b/i, 38.3498, -81.6326],\n [/\\bhuntington,? wv\\b|\\bashland,? ky\\b/i, 38.4192, -82.4452],\n [/\\baltoona\\b|\\bjohnstown\\b|\\bstate college\\b|\\bindiana,? pa\\b/i, 40.5187, -78.3947],\n [/\\bharrisburg\\b|\\bmechanicsburg\\b|\\bcarlisle\\b|\\byork,? pa\\b|\\blancaster,? pa\\b/i, 40.2732, -76.8867],\n [/\\bwilliamsport\\b|\\bscranton\\b|\\bwilkes[- ]barre\\b/i, 41.2412, -77.0011],\n [/\\bphiladelphia\\b|\\bking of prussia\\b|\\ballentown\\b|\\breading,? pa\\b/i, 39.9526, -75.1652],\n [/\\bbaltimore\\b|\\btowson\\b|\\bglen burnie\\b|\\bcolumbia,? md\\b/i, 39.2904, -76.6122],\n [/\\bwashington,? dc\\b|\\barlington,? va\\b|\\balexandria,? va\\b|\\bfairfax\\b|\\bsilver spring\\b|\\brockville\\b/i, 38.9072, -77.0369],\n [/\\bhagerstown\\b|\\bfrederick,? md\\b|\\bcumberland,? md\\b|\\bmartinsburg\\b|\\bwinchester,? va\\b/i, 39.6418, -77.72],\n [/\\bdetroit\\b|\\bdearborn\\b|\\blivonia\\b|\\btroy,? mi\\b|\\bsterling heights\\b|\\bwarren,? mi\\b|\\bmacomb\\b|\\bnovi\\b/i, 42.3314, -83.0458],\n [/\\bann arbor\\b|\\bypsilanti\\b/i, 42.2808, -83.743],\n [/\\blansing\\b|\\bflint\\b|\\bsaginaw\\b|\\bjackson,? mi\\b/i, 42.7325, -84.5555],\n [/\\bfort wayne\\b/i, 41.0793, -85.1394],\n [/\\bindianapolis\\b|\\bcarmel,? in\\b|\\bfishers\\b/i, 39.7684, -86.1581],\n [/\\blexington,? ky\\b/i, 38.0406, -84.5037],\n [/\\bmansfield,? oh\\b|\\bmansfield\\b/i, 40.7584, -82.5154],\n [/\\bsandusky\\b|\\blorain\\b|\\belyria\\b/i, 41.4489, -82.7079],\n [/\\bzanesville\\b|\\bcambridge,? oh\\b/i, 39.9403, -82.0132],\n [/\\bathens,? oh\\b|\\bchillicothe\\b/i, 39.3292, -82.1013],\n [/\\blima,? oh\\b|\\bfindlay\\b/i, 40.7426, -84.1052],\n [/\\bashtabula\\b|\\bmeadville\\b|\\bconneaut\\b/i, 41.8651, -80.7898],\n [/\\bbinghamton\\b|\\belmira\\b|\\bithaca\\b/i, 42.0987, -75.918],\n [/\\btrenton,? nj\\b|\\bprinceton\\b/i, 40.2171, -74.7429],\n [/\\balbany,? ny\\b|\\bsaratoga\\b|\\bschenectady\\b|\\bglenville,? ny\\b/i, 42.6526, -73.7562],\n [/\\bcentervill?e,? in\\b|\\brichmond,? in\\b/i, 39.8289, -84.8902],\n];\nexport function metroCoords(loc: string): { lat: number; lon: number } | null {\n for (const [re, lat, lon] of METROS) if (re.test(loc || \"\")) return { lat, lon };\n return null;\n}\n// same-metro test for fuzzy dedupe: within ~40 mi when both have coordinates, else the same normalized city token\nexport function sameMetro(a: { lat?: number | null; lon?: number | null; loc?: string }, b: { lat?: number | null; lon?: number | null; loc?: string }): boolean {\n if (a.lat != null && a.lon != null && b.lat != null && b.lon != null) return haversineMi(Number(a.lat), Number(a.lon), Number(b.lat), Number(b.lon)) <= 40;\n const na = (a.loc || \"\").toLowerCase().replace(/[^a-z ]/g, \"\").trim(), nb = (b.loc || \"\").toLowerCase().replace(/[^a-z ]/g, \"\").trim();\n return !!na && na === nb;\n}\n\n// ---------- attribute inference (shared by CL, forums, dealer pages, add endpoint) ----------\nexport function inferYear(text: string): number | null {\n const t = text || \"\";\n const m = t.match(/\\b(19(?:8[4-9]|9\\d)|20(?:0\\d|1\\d|2\\d))\\b(?=[^\\d]{0,40}(?:corvette|vette|chevrolet|chevy|c[45]\\b))/i) || t.match(/(?:corvette|vette|c[45])\\b[^\\d]{0,20}\\b(19(?:8[4-9]|9\\d)|20(?:0\\d|1\\d|2\\d))\\b/i) || t.match(/\\b(19(?:8[4-9]|9\\d)|20(?:0\\d|1\\d|2\\d))\\b/);\n return m ? Number(m[1]) : null;\n}\nexport function genFor(year: number | null): Gen {\n if (year == null) return \"unknown\";\n if (year >= 1984 && year <= 1996) return \"C4\";\n if (year >= 1997 && year <= 2004) return \"C5\";\n return \"unknown\";\n}\nexport function inferTrans(text: string): Trans {\n const t = (text || \"\").toLowerCase().replace(/\\b(owner'?s?|service|shop|repair|factory|assembly|original)\\s+manuals?\\b|manuals?\\s+(seats?|windows?|locks?|top|mirrors?|steering)|\\bmanual\\s+(and|&)\\s+(books?|records|receipts)/g, \" \"); // \"comes with owners manual\" is not a gearbox\n if (/\\b(6|six)[- ]?(speed|spd)\\b|\\bmanual\\b|\\bstick\\b|\\bstandard trans|\\bzf\\b|\\bt56\\b|\\bt-56\\b|\\bmanual transmission\\b/.test(t)) return \"manual\";\n if (/\\bautomatic\\b|\\bauto\\b(?!\\s*(?:dealer|sales|group|mall|plaza|center|body))|\\b4l60\\b|\\b4l60e\\b|\\ba\\/t\\b/.test(t)) return \"auto\";\n return \"unknown\";\n}\nexport function inferBody(text: string): Body {\n const t = (text || \"\").toLowerCase();\n if (/\\bfrc\\b|fixed[- ]roof|\\bhardtop\\b|\\bhard top\\b/.test(t)) return /\\bfrc\\b|fixed[- ]roof/.test(t) ? \"frc\" : \"hardtop\";\n if (/\\bconvertible\\b|\\bconv\\b|\\broadster\\b|\\bdrop[- ]?top\\b|\\bvert\\b/.test(t)) return \"convertible\";\n if (/\\bcoupe\\b|\\btarga\\b|\\bt-top|\\bhatchback\\b|\\bglass top\\b|\\bremovable (roof|top)/.test(t)) return \"coupe\";\n return \"unknown\";\n}\nexport function inferTitle(text: string): Title {\n const t = (text || \"\").toLowerCase();\n if (/\\bsalvage\\b|\\bflood\\b|\\bjunk title\\b|\\bparts only\\b/.test(t)) return \"salvage\";\n if (/\\brebuilt\\b|\\breconstructed\\b|\\br[- ]title\\b|\\bbranded title\\b|\\bprior salvage\\b/.test(t)) return \"rebuilt\";\n if (/title status:?\\s*clean|\\bclean title\\b|\\bclear title\\b|\\btitle in hand\\b|\\bclean (pa|oh|wv|ny|mi|md|va|in|ky) title\\b|\\btitle is clean\\b/.test(t)) return \"clean\";\n return \"unknown\";\n}\n// dead-on-sight conditions (plan Section 1 / 3): kept for price context, never pushed\nexport function deadReason(text: string, title: Title): string | null {\n const t = (text || \"\").toLowerCase();\n if (title === \"rebuilt\" || title === \"salvage\") return `title ${title}`;\n if (/\\bno title\\b(?! (status|issue|problem|brand))|\\bwithout (a )?title\\b|\\blost (the )?title\\b|\\bmissing title\\b|\\btitle (is )?(lost|missing)\\b/.test(t)) return \"no title\";\n if (/bill of sale only|\\bbos only\\b|\\bbill of sale\\b(?! and title)/.test(t)) return \"bill of sale only\";\n if (/title status:?\\s*lien\\b|\\blien (title|on the title|sale)\\b|\\bmechanic'?s lien\\b/.test(t)) return \"lien title\";\n if (/ran when parked|\\bnot running\\b|\\bdoes not run\\b|\\bdoesn'?t run\\b|\\bneeds (an )?engine\\b|\\bblown (engine|motor)\\b|\\bno engine\\b(?! (light|code|noise|leak|issue|problem))/.test(t)) return \"not running\";\n if (/\\bzr-?1\\b/.test(t.slice(0, 150)) && !/\\bnot (a )?zr-?1\\b|zr-?1 (wheels|rims|style|look)/.test(t)) return \"ZR-1\"; // title only - \"ZR-1 wheels\" in a body is not a ZR-1\n if (/\\bparts car\\b|\\bfor parts\\b|\\bparting out\\b|\\broller\\b/.test(t)) return \"parts car\";\n return null;\n}\nexport function inferSeller(text: string, srcDefault: Seller): Seller {\n const t = (text || \"\").toLowerCase();\n if (/\\bcarmax\\b|\\bcarvana\\b|\\bvroom\\b|\\bautonation\\b|\\bdrivetime\\b|\\benterprise car sales\\b|\\bhertz car sales\\b|\\bpenske\\b|\\blithia\\b|\\bsonic automotive\\b/.test(t)) return \"dealer-franchise\";\n if (/\\bchevrolet\\b[^.]{0,30}\\b(dealer|dealership)\\b|\\b(ford|toyota|honda|nissan|hyundai|kia|subaru|chevy|chevrolet|buick|gmc|dodge|jeep|ram) of \\w+/.test(t) && /\\bdealer|\\bdealership|\\bfinanc|\\bapply\\b/.test(t)) return \"dealer-franchise\";\n if (/\\bdealer\\b|\\bdealership\\b|\\bmotors\\b|\\bauto sales\\b|\\bautos\\b|\\bauto group\\b|\\bauto mall\\b|\\bmotorcars\\b|\\bmotor cars\\b|\\bfinancing available\\b|\\bwe finance\\b|\\bbuy here pay here\\b|\\bdoc fee\\b|\\bdocumentation fee\\b|\\btrade[- ]ins? welcome\\b|\\bcall or text .*sales\\b|\\bstock ?#|\\bstock number\\b/.test(t)) return \"dealer-small\";\n if (/\\bby owner\\b|\\bprivate (party|sale|seller|owner)\\b|\\bi am (the )?(original |second |2nd )?owner\\b|\\bowned (it |this car )?(for|since)\\b|\\bmy (car|vette|corvette|baby|garage)\\b|\\bno dealers\\b|\\bselling my\\b|\\bi'?ve owned\\b|\\bwe'?ve owned\\b|\\bgarage kept\\b/.test(t)) return \"private\";\n return srcDefault;\n}\nexport function inferMiles(text: string): number | null {\n const t = (text || \"\").replace(/,/g, \"\");\n const m = t.match(/odometer:?\\s*(\\d{4,6})\\b/i) || t.match(/\\b(\\d{2,3})\\s*k\\s*(?:miles|mi\\b|original miles)/i) || t.match(/\\b(\\d{4,6})\\s*(?:original |actual |documented )?(?:miles|mi\\b|mls)/i) || t.match(/\\bmileage:?\\s*(\\d{4,6})\\b/i) || t.match(/\\b(\\d{2,3})k\\b(?=[^.]{0,20}(?:mile|mi\\b))/i);\n if (!m) return null;\n let n = Number(m[1]);\n if (/\\bk\\b|k\\s*(miles|mi)/i.test(m[0]) && n < 1000) n *= 1000;\n return n >= 1000 && n <= 400000 ? n : null;\n}\nexport function inferPrice(text: string): number | null {\n const t = (text || \"\").replace(/ /g, \" \");\n const cands: number[] = [];\n for (const m of t.matchAll(/\\$\\s?(\\d{1,3}(?:,\\d{3})+|\\d{4,6})(?!\\d)/g)) cands.push(Number(m[1].replace(/,/g, \"\")));\n for (const m of t.matchAll(/\\b(\\d{1,2}(?:,\\d{3})|\\d{4,5})\\s*(?:obo|or best offer|firm|asking)\\b/gi)) cands.push(Number(m[1].replace(/,/g, \"\")));\n for (const m of t.matchAll(/\\b(\\d{1,2}(?:\\.\\d)?)\\s*k\\b(?=[^.]{0,15}(?:obo|firm|asking|cash|\\$))/gi)) cands.push(Math.round(Number(m[1]) * 1000));\n const ok = cands.filter((n) => n >= 2000 && n <= 60000);\n return ok.length ? ok[0] : null;\n}\nexport function parsePrice(s: string | number | null | undefined): number | null {\n if (s == null || s === \"\") return null;\n if (typeof s === \"number\") return Number.isFinite(s) ? Math.round(s) : null;\n const m = String(s).replace(/,/g, \"\").match(/\\$?\\s*(\\d{4,6})(?!\\d)/);\n return m ? parseInt(m[1], 10) : null;\n}\nexport function parseMiles(s: string | number | null | undefined): number | null {\n if (s == null || s === \"\") return null;\n if (typeof s === \"number\") return Number.isFinite(s) ? Math.round(s) : null;\n const str = String(s).replace(/,/g, \"\");\n const k = str.match(/^\\s*(\\d{1,3}(?:\\.\\d)?)\\s*k/i); if (k) return Math.round(Number(k[1]) * 1000);\n const m = str.match(/(\\d{3,6})/); return m ? parseInt(m[1], 10) : null;\n}\nexport function inferTrim(text: string): string {\n const t = (text || \"\").toLowerCase();\n if (/\\bz06\\b/.test(t)) return \"Z06\";\n if (/\\bzr-?1\\b/.test(t)) return \"ZR-1\";\n if (/\\bgrand sport\\b/.test(t)) return \"Grand Sport\";\n if (/\\blt4\\b/.test(t)) return \"LT4\";\n if (/\\bcollector'?s? edition\\b/.test(t)) return \"Collector Edition\";\n if (/\\b50th\\b|\\b50 ?ae\\b|anniversary/.test(t)) return \"Anniversary\";\n if (/\\bcommemorative\\b/.test(t)) return \"Commemorative\";\n if (/\\bpace car\\b/.test(t)) return \"Pace Car\";\n return \"\";\n}\nexport const RECORDS_RE = /service records|all receipts|maintenance records|\\breceipts\\b|fully documented|documented|service history|records (available|included)|folder of/i;\nexport const C4_FIX_RE = /opti[- ]?spark[^.]{0,40}(replaced|new|done|rebuilt|upgraded)|(replaced|new|done|rebuilt)[^.]{0,40}opti[- ]?spark|water pump[^.]{0,40}(replaced|new|done)|(replaced|new)[^.]{0,30}water pump/i;\nexport const C5_FIX_RE = /column[- ]lock[^.]{0,40}(fix|bypass|done|replaced|recall|disabled|eliminat)|(fix|bypass|recall)[^.]{0,30}column[- ]lock|harmonic balancer[^.]{0,40}(replaced|new|done)|(replaced|new)[^.]{0,30}harmonic balancer/i;\nexport function conditionPoints(text: string, gen: Gen): number {\n let p = 0;\n if (RECORDS_RE.test(text || \"\")) p += 1;\n if ((gen === \"C4\" && C4_FIX_RE.test(text || \"\")) || (gen === \"C5\" && C5_FIX_RE.test(text || \"\"))) p += 1;\n return p;\n}\nexport const DEALER_FEE_RE = /doc(umentation)? fee|dealer fee|processing fee|plus (tax|tt&l|tax,? title)|\\+ ?ttl\\b|\\bttl\\b|fees? (not included|extra|additional)/i;\n// expansion-plan fix 17: informational seller signals (never score) and the SCAM? gate\nexport const SCAM_RE = /\\b(hospital|deployed|military base|overseas|divorce forces|passed away and)\\b[\\s\\S]{0,200}\\b(ship|shipping|delivery|deliver)\\b|shipping (is )?(free|included)|\\bebay (motors )?(protection|buyer protection|vehicle purchase)|\\bescrow\\b|\\bzelle\\b[^.]{0,40}\\bdeposit|\\bwestern union\\b|\\bmoneygram\\b|\\bgift cards?\\b/i;\nexport const MOTIVE_RE = /winter storage|storing it|no (room|space|garage)|need (the )?(garage |extra )?(room|space|money|cash)|must sell|need gone|moving|relocat|divorce|estate|passed away|health|medical|surgery|too many (cars|toys)|new baby|deployment|downsiz/i;\nexport const FIRM_RE = /\\bfirm\\b|no (low ?ball|lowballers|low ballers)|not negotiable|price is (set|final)|don'?t ask (me )?(if|what)/i;\nexport function flagsFor(l: { vin: string | null; trim: string; trans: Trans; text?: string; dist: number | null; drive?: number | null; ageDays?: number; anomaly?: boolean; motivated?: boolean; lastDrop?: number; reposts?: number; outOfRegionSite?: boolean }): string[] {\n const f: string[] = [];\n const band = bandFor(driveMiles(l.dist, l.drive));\n if (l.text && SCAM_RE.test(l.text.slice(0, 1500))) f.push(\"SCAM?\");\n if (l.outOfRegionSite) f.push(\"OUT-OF-REGION SITE\");\n if (!l.vin) f.push(\"NO VIN\");\n if (l.anomaly) f.push(\"PRICE ANOMALY\");\n if (l.ageDays != null && l.ageDays > STALE_DAYS) f.push(`STALE ${l.ageDays}d`);\n if (l.lastDrop && l.lastDrop > 0) f.push(`DROP $${l.lastDrop.toLocaleString(\"en-US\")}`);\n if (l.motivated) f.push(\"MOTIVATED\");\n if (l.text && DEALER_FEE_RE.test(l.text)) f.push(\"DEALER FEE?\");\n if (/^(Z06|LT4|Grand Sport|ZR-1)$/.test(l.trim) && l.trans === \"auto\") f.push(\"MANUAL-ONLY MODEL\"); // Z06/LT4/GS never came with an automatic -> VIN/engine check\n if (l.reposts && l.reposts > 0) f.push(`REPOST x${l.reposts}`);\n if (l.text && MOTIVE_RE.test(l.text)) f.push(\"SELLER MOTIVE\");\n if (l.text && FIRM_RE.test(l.text)) f.push(\"FIRM\");\n if (band === \"stretch\") f.push(\"STRETCH\");\n else if (band === \"far\") f.push(\"FAR\");\n else if (band === \"out\") f.push(\"OUT OF RANGE\");\n else if (l.dist != null && l.dist > CORE_MI) f.push(\"STRETCH\"); // straight-line 300-350 but short drive (e.g. Philadelphia): keep the tracker's legacy flag\n return f;\n}\n\n// ---------- scoring (plan Section 3, literal; max 15) ----------\nexport interface ScoreInput { year: number | null; gen: Gen; trans: Trans; miles: number | null; seller: Seller; price: number | null; dist: number | null; title: Title; vin: string | null; text?: string; conditionPts?: number }\nexport function score(l: ScoreInput): number {\n let s = 0;\n const y = l.year;\n if (l.gen === \"C5\" && y != null) s += y >= 1999 ? 3 : 2;\n else if (l.gen === \"C4\" && y != null) s += y >= 1995 ? 3 : y === 1994 ? 2 : y >= 1992 ? 1 : 0;\n if (l.trans === \"auto\") s += 2; else if (l.trans === \"manual\") s += 1;\n if (l.miles != null) s += l.miles < 60000 ? 3 : l.miles <= 100000 ? 2 : l.miles <= 140000 ? 1 : 0;\n if (l.seller === \"private\") s += 2; else if (l.seller === \"dealer-small\" || l.seller === \"auction\") s += 1;\n s += Math.min(2, l.conditionPts ?? conditionPoints(l.text || \"\", l.gen));\n if (l.price != null && l.price <= PRICE_POINT) s += 1;\n if (l.dist != null && l.dist <= 120) s += 1;\n if (l.title === \"clean\" && l.vin) s += 1;\n return s;\n}\nexport function pushThresholdFor(dist: number | null, seller: Seller, drive?: number | null): number {\n let t = PUSH_THRESHOLD;\n const band = bandFor(driveMiles(dist, drive));\n if (band === \"stretch\" || (dist != null && dist > CORE_MI)) t = Math.max(t, STRETCH_PUSH_THRESHOLD);\n if (band === \"far\") t = Math.max(t, 11);\n if (band === \"out\") t = 99;\n if (seller === \"auction\") t = Math.max(t, STRETCH_PUSH_THRESHOLD);\n return t;\n}\n// expansion-plan 2b: STRETCH pushes need an automatic; FAR pushes need automatic + (records or < 80k) + asking <= $11,500 and the FAR window open;\n// unicorns (score >= 13, < 60k, private, clean + VIN, <= $11,500) push from any band any time.\nexport function bandAllows(l: { band: Band; trans: Trans; miles: number | null; price: number | null; seller: Seller; title: Title; vin: string | null; score: number; text?: string; flags?: string[] }): boolean {\n if ((l.flags || []).some((f) => f === \"SCAM?\" || f === \"OUT-OF-REGION SITE\")) return false;\n const unicorn = l.score >= 13 && l.miles != null && l.miles < 60000 && l.seller === \"private\" && l.title === \"clean\" && !!l.vin && l.price != null && l.price <= 11500;\n if (unicorn) return l.band !== \"out\";\n if (l.band === \"core\") return true;\n if (l.band === \"stretch\") return l.trans === \"auto\";\n if (l.band === \"far\") return today() >= FAR_FROM && l.trans === \"auto\" && (RECORDS_RE.test(l.text || \"\") || (l.miles != null && l.miles < 80000)) && l.price != null && l.price <= 11500;\n return false;\n}\n\n// ---------- age / staleness ----------\nexport const STALE_DAYS = 45;\nexport function ageDays(postedAt: string | null | undefined, firstSeen: string | null | undefined, ref = today()): number {\n const base = postedAt || firstSeen; if (!base) return 0;\n return Math.max(0, Math.round((Date.parse(ref) - Date.parse(String(base).slice(0, 10))) / 86400000));\n}\nexport function toIsoDate(v: unknown): string | null {\n if (v == null || v === \"\") return null;\n const t = typeof v === \"number\" ? v : Date.parse(String(v));\n if (!Number.isFinite(t)) return null;\n const d = new Date(t).toISOString().slice(0, 10);\n return d < \"2015-01-01\" || d > today() ? null : d;\n}\nconst earliest = (a: string | null | undefined, b: string | null | undefined) => (a && b ? (a < b ? a : b) : a || b || null);\nexport function decorateNotes(notes: string, flags: string[]): string {\n const n = stripPrefixes(notes || \"\");\n return (buildPrefix(flags) + n).replace(/ \\| $/, \"\");\n}\n\n// ---------- dedupe / upsert ----------\nexport interface UpsertInput {\n vin?: string | null; year: number | null; gen?: Gen; trim?: string; trans: Trans; body: Body; miles: number | null; price: number | null;\n title: Title; seller: Seller; loc: string; lat?: number | null; lon?: number | null; dist?: number | null; // dist only when the source reports one and no coordinates exist\n source: string; externalId?: string | null; url: string; notes?: string; raw?: string; text?: string;\n postedAt?: string | number | null; auctionDate?: string | null; dead?: string | null;\n outOfRegionSite?: boolean; // Craigslist reply host outside the 350 mi site list (relocation scams) - never pushes\n}\nexport interface UpsertResult { action: \"inserted\" | \"updated\" | \"merged\" | \"skipped\"; rowid: number; id: string; score: number; pushed: boolean; dead?: string | null }\n\nasync function priceFlags(rowid: number, price: number | null, year: number | null, trans: Trans, age: number) {\n const p = price != null ? await p25For(year, trans) : { p25: null as number | null, basis: \"\" };\n const anomaly = isAnomaly(price, p.p25);\n const trail = await recordPrice(rowid, price);\n const ts = trailStats(trail);\n return { anomaly, trail, drops: ts.drops, lastDrop: ts.lastDrop, motivated: motivatedFlag(ts.drops, age) };\n}\n\nexport async function upsertListing(inp: UpsertInput, opts: { push?: boolean; pushMin?: number } = {}): Promise {\n const now = today();\n const vin = validVin(inp.vin) ? normalizeVin(inp.vin) : null;\n const year = inp.year ?? vinYear(vin);\n const gen = inp.gen && inp.gen !== \"unknown\" ? inp.gen : genFor(year);\n const text = inp.text || [inp.notes, inp.raw].filter(Boolean).join(\" \\n \");\n const trim = inp.trim ?? inferTrim(text.slice(0, 150)); // trim claims count only from the title, not \"Z06 wheels\" in the body\n const lat = inp.lat ?? metroCoords(inp.loc)?.lat ?? null;\n const lon = inp.lon ?? metroCoords(inp.loc)?.lon ?? null;\n const geocodeSrc = inp.lat != null ? \"source\" : lat != null ? \"metro\" : null;\n const dist = distFrom16105(lat, lon) ?? inp.dist ?? null;\n const dead = inp.dead ?? deadReason(text, inp.title);\n const extId = inp.externalId || null;\n const id = vin || `${inp.source.toUpperCase()} ${extId || crypto.randomUUID().slice(0, 8)}`;\n\n // 1) exact VIN\n let existing: any = null;\n if (vin) { const r = await sqlite.execute({ sql: `select * from listings where vin=? limit 1`, args: [vin] }); existing = r.rows[0] || null; }\n // 2) same source + external id (a re-fetched post; may be a synthetic row that now has a VIN -> merge)\n let byExt: any = null;\n if (extId) { const r = await sqlite.execute({ sql: `select * from listings where source=? and external_id=? limit 1`, args: [inp.source, extId] }); byExt = r.rows[0] || null; }\n if (!existing && byExt) existing = byExt;\n // 3) fuzzy: same year + gen + trans, miles within 5%, price within 5%, same metro\n if (!existing && year != null) {\n const r = await sqlite.execute({ sql: `select * from listings where year=? and gen=? and trans=? and status<>'dead' and last_seen >= date('now','-60 day')`, args: [year, gen, inp.trans] });\n for (const row of r.rows as any[]) {\n const m1 = row.miles == null ? null : Number(row.miles), p1 = row.price == null ? null : Number(row.price);\n const milesClose = m1 != null && inp.miles != null && Math.abs(m1 - inp.miles) <= 0.05 * Math.max(m1, inp.miles);\n const priceClose = p1 != null && inp.price != null && Math.abs(p1 - inp.price) <= 0.05 * Math.max(p1, inp.price);\n if (milesClose && priceClose && sameMetro({ lat: row.lat, lon: row.lon, loc: row.loc }, { lat, lon, loc: inp.loc })) { existing = row; break; }\n }\n }\n let merged: any = null; // a second row (synthetic, by ext id) that folds into the VIN row\n if (existing && byExt && Number(byExt.rowid_pk) !== Number(existing.rowid_pk)) merged = byExt;\n\n const better = (a: T, b: T, unknown: T) => (a === unknown || a == null ? b : a);\n if (existing) {\n const rowid = Number(existing.rowid_pk);\n if (merged) { // union notes + price history into the VIN row, keep the earliest first_seen, drop the synthetic row\n await sqlite.execute({ sql: `update price_history set rowid_pk=? where rowid_pk=?`, args: [rowid, merged.rowid_pk] });\n await sqlite.execute({ sql: `update listings set first_seen=min(first_seen, ?), posted_at=coalesce(min(posted_at, ?), posted_at, ?), notes=case when instr(notes, ?)>0 or ?='' then notes else notes || char(10) || ? end, pushed=max(pushed, ?) where rowid_pk=?`,\n args: [merged.first_seen, merged.posted_at, merged.posted_at, stripPrefixes(String(merged.notes || \"\")), stripPrefixes(String(merged.notes || \"\")), stripPrefixes(String(merged.notes || \"\")), Number(merged.pushed || 0), rowid] });\n await sqlite.execute({ sql: `delete from listings where rowid_pk=?`, args: [merged.rowid_pk] });\n existing = (await sqlite.execute({ sql: `select * from listings where rowid_pk=?`, args: [rowid] })).rows[0];\n }\n const m = {\n vin: vin || existing.vin || null,\n year: year ?? (existing.year == null ? null : Number(existing.year)),\n gen: better(gen, existing.gen as Gen, \"unknown\"),\n trim: trim || String(existing.trim || \"\"),\n trans: better(inp.trans, existing.trans as Trans, \"unknown\"),\n body: better(inp.body, existing.body as Body, \"unknown\"),\n miles: inp.miles ?? (existing.miles == null ? null : Number(existing.miles)),\n price: inp.price ?? (existing.price == null ? null : Number(existing.price)),\n title: better(inp.title, existing.title as Title, \"unknown\"),\n seller: better(inp.seller, existing.seller as Seller, \"unknown\"),\n loc: inp.loc || String(existing.loc || \"\"),\n lat: inp.lat ?? existing.lat ?? lat, lon: inp.lon ?? existing.lon ?? lon,\n };\n const mDist = distFrom16105(m.lat, m.lon) ?? inp.dist ?? (existing.dist == null ? null : Number(existing.dist));\n const mDrive = driveMiles(mDist, existing.drive_mi);\n const mBand = bandFor(mDrive);\n const reposts = Number(existing.reposts || 0) + (extId && existing.external_id && existing.external_id !== extId && existing.source === inp.source ? 1 : 0) + (merged ? 1 : 0);\n const allText = [text, existing.raw, existing.notes].filter(Boolean).join(\" \\n \");\n const newScore = score({ year: m.year, gen: m.gen, trans: m.trans, miles: m.miles, seller: m.seller, price: m.price, dist: mDist, title: m.title, vin: m.vin, text: allText });\n const postedAt = earliest(toIsoDate(inp.postedAt), existing.posted_at);\n const age = ageDays(postedAt, existing.first_seen, now);\n const pf = await priceFlags(rowid, m.price, m.year, m.trans, age);\n const isDead = existing.status === \"dead\" || !!dead;\n const flags = flagsFor({ vin: m.vin, trim: m.trim, trans: m.trans, text: allText, dist: mDist, drive: existing.drive_mi, ageDays: age, anomaly: pf.anomaly, motivated: pf.motivated, lastDrop: pf.lastDrop, reposts, outOfRegionSite: inp.outOfRegionSite || String(existing.flags || \"\").includes(\"OUT-OF-REGION SITE\") });\n if (dead && !flags.includes(`DEAD ${dead}`)) flags.unshift(`DEAD ${dead}`);\n const note = inp.notes || \"\";\n let notes = stripPrefixes(String(existing.notes || \"\"));\n if (note && !notes.includes(note)) notes = notes ? `${notes}\\n${note}` : note;\n notes = decorateNotes(notes, flags);\n const newId = m.vin || existing.id;\n await sqlite.execute({\n sql: `update listings set id=?, vin=?, year=?, gen=?, trim=?, trans=?, body=?, miles=?, price=?, title=?, seller=?, loc=?, lat=?, lon=?, dist=?, stretch=?, band=?, reposts=?, score=?, flags=?, last_seen=?, missed=0, posted_at=?,\n url=case when ?<>'' then ? else url end, notes=?, anomaly=?, drops=?, motivated=?, status=case when ?<>'' and status='new' then 'dead' else status end, auction_date=coalesce(?, auction_date), geocode_src=coalesce(geocode_src, ?)\n where rowid_pk=?`,\n args: [newId, m.vin, m.year, m.gen, m.trim, m.trans, m.body, m.miles, m.price, m.title, m.seller, m.loc, m.lat, m.lon, mDist, mBand !== \"core\" || (mDist != null && mDist > CORE_MI) ? 1 : 0, mBand, reposts, newScore, flags.join(\"|\"), now, postedAt,\n inp.url || \"\", inp.url || \"\", notes, pf.anomaly ? 1 : 0, pf.drops, pf.motivated ? 1 : 0, dead || \"\", inp.auctionDate || null, geocodeSrc, rowid],\n });\n let pushed = false;\n const threshold = Math.max(opts.pushMin ?? 0, pushThresholdFor(mDist, m.seller, existing.drive_mi));\n const allowed = bandAllows({ band: mBand, trans: m.trans, miles: m.miles, price: m.price, seller: m.seller, title: m.title, vin: m.vin, score: newScore, text: allText, flags });\n if (opts.push && !existing.pushed && !isDead && allowed && newScore >= threshold && age <= STALE_DAYS && !auctionTooSoon(inp.auctionDate || existing.auction_date)) {\n pushed = await sendOrQueue({ ...m, id: newId, rowid, score: newScore, dist: mDist, url: inp.url || existing.url, source: inp.source, flags, notes, trail: pf.trail, ageDays: age });\n if (pushed) await sqlite.execute({ sql: `update listings set pushed=1 where rowid_pk=?`, args: [rowid] });\n }\n return { action: merged ? \"merged\" : \"updated\", rowid, id: newId, score: newScore, pushed, dead: dead || (existing.status === \"dead\" ? \"dead\" : null) };\n }\n\n const sc = score({ year, gen, trans: inp.trans, miles: inp.miles, seller: inp.seller, price: inp.price, dist, title: inp.title, vin, text });\n const postedIn = toIsoDate(inp.postedAt);\n const age = ageDays(postedIn, now, now);\n const r = await sqlite.execute({\n sql: `insert into listings (id, vin, year, gen, trim, trans, body, miles, price, title, seller, loc, lat, lon, dist, stretch, source, external_id, url, score, flags, first_seen, last_seen, posted_at, status, missed, pushed, notes, raw, auction_date, geocode_src)\n values (?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,0,0,?,?,?,?)`,\n args: [id, vin, year, gen, trim, inp.trans, inp.body, inp.miles, inp.price, inp.title, inp.seller, inp.loc || \"\", lat, lon, dist, dist != null && dist > CORE_MI ? 1 : 0, inp.source, extId, inp.url, sc, \"\", now, now, postedIn,\n dead ? \"dead\" : \"new\", inp.notes || \"\", (inp.raw || text || \"\").slice(0, 20000), inp.auctionDate || null, geocodeSrc],\n });\n const rowid = Number(r.lastInsertRowid);\n const pf = await priceFlags(rowid, inp.price, year, inp.trans, age);\n const band = bandFor(driveMiles(dist));\n const flags = flagsFor({ vin, trim, trans: inp.trans, text, dist, ageDays: age, anomaly: pf.anomaly, motivated: pf.motivated, lastDrop: pf.lastDrop, outOfRegionSite: inp.outOfRegionSite });\n if (dead) flags.unshift(`DEAD ${dead}`);\n const notes = decorateNotes(inp.notes || \"\", flags);\n await sqlite.execute({ sql: `update listings set notes=?, flags=?, anomaly=?, drops=?, motivated=?, band=?, stretch=? where rowid_pk=?`, args: [notes, flags.join(\"|\"), pf.anomaly ? 1 : 0, pf.drops, pf.motivated ? 1 : 0, band, band !== \"core\" || (dist != null && dist > CORE_MI) ? 1 : 0, rowid] });\n let pushed = false;\n const threshold = Math.max(opts.pushMin ?? 0, pushThresholdFor(dist, inp.seller));\n const allowed = bandAllows({ band, trans: inp.trans, miles: inp.miles, price: inp.price, seller: inp.seller, title: inp.title, vin, score: sc, text, flags });\n if (opts.push && !dead && allowed && sc >= threshold && age <= STALE_DAYS && !auctionTooSoon(inp.auctionDate)) {\n pushed = await sendOrQueue({ vin, year, gen, trim, trans: inp.trans, body: inp.body, miles: inp.miles, price: inp.price, title: inp.title, seller: inp.seller, loc: inp.loc || \"\", lat, lon, dist, id, rowid, score: sc, url: inp.url, source: inp.source, flags, notes, trail: pf.trail, ageDays: age });\n if (pushed) await sqlite.execute({ sql: `update listings set pushed=1 where rowid_pk=?`, args: [rowid] });\n }\n return { action: \"inserted\", rowid, id, score: sc, pushed, dead };\n}\n// estate/consignment lots push only when the sale is more than 5 days out (time to arrange a PPI/inspection day)\nexport function auctionTooSoon(auctionDate: string | null | undefined, ref = today()): boolean {\n if (!auctionDate) return false;\n const d = toIsoDate(auctionDate) || String(auctionDate).slice(0, 10);\n return (Date.parse(d) - Date.parse(ref)) / 86400000 <= 5;\n}\n\n// quiet hours: pushes between 23:00 and 07:00 ET are queued and released by cron/enrich.ts after 07:00\nexport async function sendOrQueue(l: PushInput): Promise {\n if (isQuietHour()) { await queuePush(l.rowid ?? null, l); return true; }\n return await pushDiscord(l);\n}\n\n// ---------- feed mapping ----------\nexport function rowToListing(row: any): Listing {\n const flags = String(row.flags || \"\").split(\"|\").filter(Boolean);\n return {\n id: row.id, vin: row.vin ?? null, year: row.year == null ? null : Number(row.year), gen: row.gen, model: row.model || \"Corvette\", trim: row.trim || \"\",\n trans: row.trans, body: row.body, miles: row.miles == null ? null : Number(row.miles), price: row.price == null ? null : Number(row.price),\n allin: allIn(row.price == null ? null : Number(row.price), driveMiles(row.dist, row.drive_mi)), title: row.title, seller: row.seller, loc: row.loc || \"\",\n dist: row.dist == null ? null : Number(row.dist), stretch: !!row.stretch, band: (row.band || bandFor(driveMiles(row.dist, row.drive_mi))) as Band, drive: driveMiles(row.dist, row.drive_mi), url: row.url, src: row.source,\n note: stripPrefixes(String(row.notes || \"\")), fs: row.first_seen, lv: row.last_seen, status: row.status, missed: Number(row.missed || 0),\n score: Number(row.score || 0), flags, reposts: Number(row.reposts || 0),\n };\n}\nexport async function activeListings(days = 60, v = 1, includeDead = true): Promise {\n const cutoff = new Date(Date.now() - days * 86400000).toISOString().slice(0, 10);\n const r = await sqlite.execute({ sql: `select * from listings where last_seen >= ?${includeDead ? \"\" : \" and status<>'dead'\"} order by score desc, last_seen desc`, args: [cutoff] });\n if (v < 2) return (r.rows as any[]).map(rowToListing);\n const ids = (r.rows as any[]).map((row) => Number(row.rowid_pk));\n const trails = new Map();\n if (ids.length) {\n const ph = await sqlite.execute({ sql: `select rowid_pk, price from price_history where rowid_pk in (${ids.map(() => \"?\").join(\",\")}) order by rowid_pk, id`, args: ids });\n for (const x of ph.rows as any[]) { const k = Number(x.rowid_pk); if (!trails.has(k)) trails.set(k, []); trails.get(k)!.push(x.price == null ? null : Number(x.price)); }\n }\n return (r.rows as any[]).map((row) => {\n const k = Number(row.rowid_pk);\n let decode: any = null; try { decode = row.decode ? JSON.parse(row.decode) : null; } catch { /* ignore */ }\n return {\n ...rowToListing(row), age_days: ageDays(row.posted_at, row.first_seen), posted_at: row.posted_at ?? null,\n price_trail: trails.get(k) || (row.price != null ? [Number(row.price)] : []), drops: Number(row.drops || 0), motivated: !!row.motivated, anomaly: !!row.anomaly,\n lat: row.lat ?? null, lon: row.lon ?? null, gone_at: row.gone_at ?? null, auction_date: row.auction_date ?? null,\n decode, decode_mismatch: row.decode_mismatch ?? null, pushed: !!row.pushed,\n };\n });\n}\n\n// ---------- notify ----------\nexport type PushInput = {\n id: string; rowid?: number | null; vin: string | null; year: number | null; gen: Gen; trim?: string; trans: Trans; body: Body; miles: number | null; price: number | null;\n title: Title; seller: Seller; loc: string; lat?: number | null; lon?: number | null; dist: number | null; url: string; source: string; score: number;\n flags?: string[]; notes?: string; trail?: (number | null)[]; ageDays?: number; drive?: number | null;\n};\nexport const TRACKER_URL = Deno.env.get(\"CORVETTE_TRACKER_URL\") || \"https://logan1--corvette-tracker.web.val.run\"; // overwritten by deploy (see README)\nexport function actionLinks(l: { vin: string | null; lat?: number | null; lon?: number | null; loc?: string; id: string; url: string }): string {\n const links: string[] = [`[Listing](${l.url})`];\n if (l.vin) {\n links.push(`[NHTSA decode](https://vpic.nhtsa.dot.gov/decoder/Decoder?VIN=${l.vin})`);\n links.push(`[Google VIN](https://www.google.com/search?q=${encodeURIComponent(`\"${l.vin}\"`)})`);\n }\n if (l.lat != null && l.lon != null) links.push(`[Street View](https://www.google.com/maps/@?api=1&map_action=pano&viewpoint=${l.lat},${l.lon})`);\n else if (l.loc) links.push(`[Map](https://www.google.com/maps/search/?api=1&query=${encodeURIComponent(l.loc)})`);\n const tok = Deno.env.get(\"CORVETTE_TOKEN\") || \"\";\n links.push(`[Tracker](${TRACKER_URL}/?token=${tok}#${encodeURIComponent(l.id)})`);\n return links.join(\" - \");\n}\nexport const fmtMiles = (m: number | null) => (m == null ? \"?\" : m >= 1000 ? `${Math.round(m / 1000)}k` : String(m));\nexport const fmtUsd = (p: number | null) => (p == null ? \"$?\" : `$${p.toLocaleString(\"en-US\")}`);\nexport async function pushDiscord(l: PushInput, opts: { hookOverride?: string } = {}): Promise {\n const hook = opts.hookOverride || Deno.env.get(\"DISCORD_WEBHOOK_URL\");\n if (!hook) { console.warn(\"DISCORD_WEBHOOK_URL not set; skipping push for\", l.id); return false; }\n const trail = (l.trail || []).filter((p) => p != null);\n const car = `${l.year ?? \"?\"} ${l.gen !== \"unknown\" ? l.gen : \"\"} Corvette${l.trim ? \" \" + l.trim : \"\"}`.replace(/\\s+/g, \" \").trim();\n const flags = (l.flags || []).filter((f) => !/^STRETCH$/.test(f));\n const stretch = l.dist != null && l.dist > CORE_MI;\n const fields = [\n { name: \"Asking\", value: `${fmtUsd(l.price)}${trail.length > 1 ? `\\n${fmtTrail(trail)}` : \"\"}`, inline: true },\n { name: \"All-in est.\", value: `${fmtUsd(allIn(l.price, driveMiles(l.dist, l.drive)))}${l.drive != null || l.dist != null ? ` (${bandFor(driveMiles(l.dist, l.drive))}, ~${driveMiles(l.dist, l.drive)} drive mi)` : \"\"}`, inline: true },\n { name: \"Miles\", value: fmtMiles(l.miles), inline: true },\n { name: \"Trans / body\", value: `${l.trans} / ${l.body}`, inline: true },\n { name: \"Distance\", value: `${l.dist != null ? `${l.dist} mi` : \"?\"}${stretch ? \" - STRETCH\" : \"\"}${l.loc ? `\\n${l.loc}` : \"\"}`, inline: true },\n { name: \"Seller\", value: `${l.seller} (${l.source})`, inline: true },\n { name: \"Title\", value: l.title, inline: true },\n { name: \"VIN\", value: l.vin ? `\\`${l.vin}\\`` : \"NONE - ask\", inline: true },\n { name: \"Age\", value: `${l.ageDays != null ? `${l.ageDays}d` : \"?\"}`, inline: true },\n { name: \"Flags\", value: flags.length ? flags.join(\", \") : \"none\", inline: false },\n { name: \"Check\", value: actionLinks(l), inline: false },\n ];\n const body = {\n username: \"Corvette Search\",\n content: `**Score ${l.score}** - ${car} - ${fmtUsd(l.price)} - ${fmtMiles(l.miles)} mi - ${l.trans} - ${l.dist != null ? `${l.dist} mi` : \"dist ?\"}${stretch ? \" (STRETCH)\" : \"\"}`,\n embeds: [{\n title: car, url: l.url,\n color: flags.some((f) => /ANOMALY|MANUAL-ONLY/.test(f)) ? 0xe74c3c : l.score >= 12 ? 0x2ecc71 : 0xf1c40f,\n fields,\n footer: { text: stripPrefixes(l.notes || \"\").slice(0, 200) || \"PPI before purchase. No deposits to hold. Title must be in the seller's name.\" },\n }],\n };\n try {\n const res = await fetch(hook, { method: \"POST\", headers: { \"content-type\": \"application/json\" }, body: JSON.stringify(body) });\n if (!res.ok) { console.error(\"discord push failed\", res.status, await res.text()); return false; }\n return true;\n } catch (e) { console.error(\"discord push error\", e); return false; }\n}\nexport async function discordText(content: string): Promise {\n const hook = Deno.env.get(\"DISCORD_WEBHOOK_URL\"); if (!hook) return false;\n const res = await fetch(hook, { method: \"POST\", headers: { \"content-type\": \"application/json\" }, body: JSON.stringify({ username: \"Corvette Search\", content }) });\n return res.ok;\n}\nexport function rowToPush(row: any): PushInput {\n return { id: row.id, rowid: row.rowid_pk, vin: row.vin ?? null, year: row.year == null ? null : Number(row.year), gen: row.gen, trim: row.trim || \"\", trans: row.trans, body: row.body,\n miles: row.miles == null ? null : Number(row.miles), price: row.price == null ? null : Number(row.price), title: row.title, seller: row.seller, loc: row.loc || \"\", lat: row.lat, lon: row.lon,\n dist: row.dist == null ? null : Number(row.dist), drive: row.drive_mi ?? null, url: row.url, source: row.source, score: Number(row.score || 0), flags: String(row.flags || \"\").split(\"|\").filter(Boolean), notes: row.notes, ageDays: ageDays(row.posted_at, row.first_seen) };\n}\n\n// ---------- misc ----------\nexport async function logPoll(job: string, ok: boolean, stats: { fetched?: number; inserted?: number; updated?: number; pushed?: number }, detail = \"\") {\n await sqlite.execute({ sql: `insert into poll_log (ts, job, ok, fetched, inserted, updated, pushed, detail) values (?,?,?,?,?,?,?,?)`,\n args: [new Date().toISOString(), job, ok ? 1 : 0, stats.fetched || 0, stats.inserted || 0, stats.updated || 0, stats.pushed || 0, detail.slice(0, 2000)] });\n}\nexport function checkToken(req: Request): boolean {\n const expected = Deno.env.get(\"CORVETTE_TOKEN\");\n if (!expected) return false;\n const url = new URL(req.url);\n const got = req.headers.get(\"x-corvette-token\") || (req.headers.get(\"authorization\") || \"\").replace(/^Bearer\\s+/i, \"\") || url.searchParams.get(\"token\") || \"\";\n return got.length > 0 && got === expected;\n}\nexport const CORS = { \"access-control-allow-origin\": \"*\", \"access-control-allow-methods\": \"GET, POST, OPTIONS\", \"access-control-allow-headers\": \"content-type, x-corvette-token, authorization\" };\nexport function json(data: unknown, status = 200, extra: Record = {}) {\n return new Response(JSON.stringify(data, null, 2), { status, headers: { \"content-type\": \"application/json\", ...CORS, ...extra } });\n}\nexport function decodeEntities(s: string): string {\n return s.replace(/&/g, \"&\").replace(/</g, \"<\").replace(/>/g, \">\").replace(/"/g, '\"').replace(/�?39;/g, \"'\").replace(/’/g, \"'\").replace(/“|”/g, '\"').replace(/–|—/g, \"-\").replace(/ /g, \" \").replace(/&#(\\d+);/g, (_, n) => String.fromCharCode(Number(n)));\n}\nexport function stripTags(s: string): string {\n return decodeEntities(s.replace(/|/gi, \"\").replace(/<[^>]+>/g, \" \")).replace(/\\s+/g, \" \").trim();\n}\nexport const UA = \"Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/128.0 Safari/537.36\";\nexport const NAV_HEADERS = { \"accept\": \"text/html,application/xhtml+xml,application/xml;q=0.9,*/*;q=0.8\", \"accept-language\": \"en-US,en;q=0.9\", \"upgrade-insecure-requests\": \"1\", \"sec-fetch-mode\": \"navigate\", \"sec-fetch-dest\": \"document\", \"sec-fetch-site\": \"none\" };\nexport const sleep = (ms: number) => new Promise((r) => setTimeout(r, ms));\n","deleted",false,"label",[47,24],"lib","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,"_109":105},"org",{"_9":10,"_102":103,"_104":105,"_58":59,"_106":107,"_108":44},"branch",{"_37":92,"_11":93,"_22":30,"_94":48,"_95":-5,"_96":-5,"_97":-5,"_98":-5,"_99":-5,"_100":12,"_101":10},"isOwned",79,"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,"_143":144,"_145":146,"_147":148,"_149":44,"_150":44,"_151":44,"_152":34,"_153":-5,"_154":-7,"_155":-7,"_156":66,"_157":44,"_158":44,"_159":-5,"_160":44,"_161":44,"_162":44,"_163":-5},"ENV",{"_114":115,"_116":117,"_118":93,"_119":120,"_121":122,"_123":124,"_125":126,"_127":128,"_129":130,"_131":132,"_133":134,"_135":136,"_137":138,"_139":140,"_141":142},"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"]