[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_361":362,"_363":364},"routes/_app.x.$handle.$name",{"_11":12,"_13":14,"_15":16,"_17":18,"_43":-7,"_172":-5,"_19":173,"_174":175,"_176":177,"_178":179,"_180":181,"_21":182,"_183":-5,"_184":-5,"_185":24,"_186":187,"_188":131,"_189":-5,"_190":-5,"_191":192},"routes/_app.x.$handle.$name.branch.$branch.history_.$",{"_11":12,"_13":14,"_15":16,"_17":18,"_19":20,"_21":22,"_23":24,"_25":26,"_27":28,"_29":24,"_30":-5},"handle","logan1","name","corvette","branchName","main","path","lib/core.ts","project",{"_37":118,"_13":14,"_41":119,"_120":-5,"_121":24,"_122":123,"_124":123,"_125":126,"_127":-5,"_30":74,"_128":129,"_130":131,"_132":-5,"_133":-5,"_134":26,"_45":46,"_135":136,"_137":138,"_139":140,"_141":-5,"_142":143,"_144":143,"_145":146,"_147":146,"_148":146,"_149":143,"_150":143,"_58":151,"_152":153,"_154":155,"_156":24},"file",{"_68":69,"_13":70,"_71":72,"_73":24,"_117":-5},"isDirectory",false,"page",0,"history",[31,32,33,34,35,36],"hasNext","userId",{"_37":109,"_39":40,"_41":110,"_43":111,"_45":46,"_47":112,"_49":-5,"_50":-5,"_51":-5,"_52":-5,"_53":-5,"_54":55,"_56":57,"_58":113,"_21":114,"_61":-5,"_62":-5,"_63":-5,"_64":-5,"_65":115},{"_37":101,"_39":40,"_41":102,"_43":103,"_45":46,"_47":104,"_49":-5,"_50":-5,"_51":-5,"_52":-5,"_53":-5,"_54":55,"_56":57,"_58":105,"_21":106,"_61":-5,"_62":-5,"_63":-5,"_64":-5,"_65":107},{"_37":93,"_39":40,"_41":94,"_43":95,"_45":46,"_47":96,"_49":-5,"_50":-5,"_51":-5,"_52":-5,"_53":-5,"_54":55,"_56":57,"_58":97,"_21":98,"_61":-5,"_62":-5,"_63":-5,"_64":-5,"_65":99},{"_37":85,"_39":40,"_41":86,"_43":87,"_45":46,"_47":88,"_49":-5,"_50":-5,"_51":-5,"_52":-5,"_53":-5,"_54":55,"_56":57,"_58":89,"_21":90,"_61":-5,"_62":-5,"_63":-5,"_64":-5,"_65":91},{"_37":77,"_39":40,"_41":78,"_43":79,"_45":46,"_47":80,"_49":-5,"_50":-5,"_51":-5,"_52":-5,"_53":-5,"_54":55,"_56":57,"_58":81,"_21":82,"_61":-5,"_62":-5,"_63":-5,"_64":-5,"_65":83},{"_37":38,"_39":40,"_41":42,"_43":44,"_45":46,"_47":48,"_49":-5,"_50":-5,"_51":-5,"_52":-5,"_53":-5,"_54":55,"_56":57,"_58":59,"_21":60,"_61":-5,"_62":-5,"_63":-5,"_64":-5,"_65":66},"id","a718ca92-1f92-4406-baf5-555baa483e8f","branchId","86e98f95-71bb-401c-ac30-44ee51ed36fc","createdAt",["D",1789312606420],"version",5,"orgId","01a09786-a61b-74b5-8910-af3116d3de5c","parentId","d25acd32-5bba-4c31-a9dd-878304cfa30f","incomingCommitId","aiChatMessageId","aiChatThreadId","aiChatThreadUserId","aiChatThreadTitle","source","mcp","clientLabel","Claude Code (plugin:valtown:valtown)","user",{"_37":74,"_45":46,"_11":12,"_75":76},{"_68":69,"_13":70,"_71":72,"_73":24},"pull","merge","revert","multiple","commits",[67],{"_37":38,"_39":40,"_41":42,"_43":44,"_45":46,"_47":48,"_49":-5,"_50":-5,"_51":-5,"_52":-5,"_53":-5,"_54":55,"_56":57,"_58":59,"_21":60,"_61":-5,"_62":-5,"_63":-5},"fileId","227e10c6-af86-11f1-8b05-1607ee4eb77e","core.ts","fileType","script","deleted","87445237-7d14-45c7-b3a2-72e031f10ec1","avatar","https://lh3.googleusercontent.com/a/ACg8ocIFxddfJftSiTFZN49YShT3nY7q8GOQ7dXYM2vJ6XkajnQMGA=s96-c","e839651f-e67a-485a-8af9-18d640d476b9",["D",1789314965001],17,"7356f859-698b-4446-8884-1779f059b008",{"_37":74,"_45":46,"_11":12,"_75":76},{"_68":69,"_13":70,"_71":72,"_73":24},[84],{"_37":77,"_39":40,"_41":78,"_43":79,"_45":46,"_47":80,"_49":-5,"_50":-5,"_51":-5,"_52":-5,"_53":-5,"_54":55,"_56":57,"_58":81,"_21":82,"_61":-5,"_62":-5,"_63":-5},"1d4e17ae-6aea-4c11-8b47-9cf15e7bd0f7",["D",1789316223367],29,"ab8a7eba-367a-4d9d-9445-9d8d204a84ae",{"_37":74,"_45":46,"_11":12,"_75":76},{"_68":69,"_13":70,"_71":72,"_73":24},[92],{"_37":85,"_39":40,"_41":86,"_43":87,"_45":46,"_47":88,"_49":-5,"_50":-5,"_51":-5,"_52":-5,"_53":-5,"_54":55,"_56":57,"_58":89,"_21":90,"_61":-5,"_62":-5,"_63":-5},"e181420a-cc76-4a6d-8471-576752c544a8",["D",1789323176735],37,"b02c58cc-35fe-4caf-af0a-db86f025706f",{"_37":74,"_45":46,"_11":12,"_75":76},{"_68":69,"_13":70,"_71":72,"_73":24},[100],{"_37":93,"_39":40,"_41":94,"_43":95,"_45":46,"_47":96,"_49":-5,"_50":-5,"_51":-5,"_52":-5,"_53":-5,"_54":55,"_56":57,"_58":97,"_21":98,"_61":-5,"_62":-5,"_63":-5},"728aca65-b2a5-4213-bd2d-31aadf765b74",["D",1789343927277],45,"fcf43549-f91f-441c-b10c-b222a6c40224",{"_37":74,"_45":46,"_11":12,"_75":76},{"_68":69,"_13":70,"_71":72,"_73":24},[108],{"_37":101,"_39":40,"_41":102,"_43":103,"_45":46,"_47":104,"_49":-5,"_50":-5,"_51":-5,"_52":-5,"_53":-5,"_54":55,"_56":57,"_58":105,"_21":106,"_61":-5,"_62":-5,"_63":-5},"bf209839-e21d-45f9-a626-166560ebed66",["D",1789344876314],55,"58bf616a-8a8a-47da-b8d4-b8ba14a914c2",{"_37":74,"_45":46,"_11":12,"_75":76},{"_68":69,"_13":70,"_71":72,"_73":24},[116],{"_37":109,"_39":40,"_41":110,"_43":111,"_45":46,"_47":112,"_49":-5,"_50":-5,"_51":-5,"_52":-5,"_53":-5,"_54":55,"_56":57,"_58":113,"_21":114,"_61":-5,"_62":-5,"_63":-5},"deletedAtVersion","00cc23ab-c212-43f5-a7c5-1ba797ecaa18",["D",1789312547277],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","C4/C5 Corvette search pipeline (CL, forums, auctions, comps)","imageUrl","pinnedFileId","2b16e0f0-af8b-11f1-8152-1607ee4eb77e","pinPreview",true,"pinMigrated","screenshotVersion","likeCount","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",{"_11":12,"_171":76},"org",{"_11":12,"_166":167,"_75":76,"_30":74,"_168":169,"_170":24},"branch",{"_43":157,"_13":16,"_37":40,"_158":118,"_159":-5,"_160":-5,"_161":-5,"_162":-5,"_163":-5,"_164":14,"_165":12},"isOwned",79,"projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","Logan","tier","free","canRestrictVals","profileImageUrl","adoptOrgId",{"_37":118,"_13":14,"_41":356,"_120":-5,"_121":24,"_122":123,"_124":123,"_125":126,"_127":-5,"_30":74,"_128":129,"_130":131,"_132":-5,"_133":-5,"_134":26,"_45":46,"_135":136,"_137":138,"_139":357,"_141":-5,"_142":143,"_144":143,"_145":146,"_147":146,"_148":146,"_149":143,"_150":143,"_58":358,"_152":359,"_154":360,"_156":24},"tree",[214,219,224,226,230],"files",[214,215,216,217,218,219,220,221,222,223,224,225,226,227,228,229,230],"counts",{"_203":26,"_204":205,"_206":26,"_207":208,"_209":210},"contents",[],{"_37":193,"_13":70,"_68":69,"_47":194,"_39":40,"_195":111,"_196":131,"_41":197,"_43":44,"_71":72,"_198":199,"_73":24,"_200":-5,"_17":201},"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},"3cfa9dee-2d27-4b15-a3bb-acd9b7e270a1","16dfa00e-af86-11f1-9559-1607ee4eb77e","branchVersion","latest",["D",1789344876314],"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","label",[202,70],"lib","pulls","branches",1,"forks","envVars",{"_211":44,"_213":26},"connections",{"_211":26,"_212":26},"count","unfilledCount","emptyCount",{"_37":352,"_13":328,"_68":321,"_47":-5,"_39":40,"_195":302,"_196":131,"_41":353,"_43":26,"_71":262,"_198":-5,"_73":24,"_200":-5,"_236":354,"_17":355},{"_37":344,"_13":345,"_68":346,"_47":321,"_39":40,"_195":347,"_196":131,"_41":348,"_43":253,"_71":324,"_198":349,"_73":24,"_200":-5,"_236":350,"_17":351},{"_37":336,"_13":337,"_68":338,"_47":321,"_39":40,"_195":339,"_196":131,"_41":340,"_43":253,"_71":324,"_198":341,"_73":24,"_200":-5,"_236":342,"_17":343},{"_37":329,"_13":330,"_68":129,"_47":321,"_39":40,"_195":331,"_196":131,"_41":332,"_43":26,"_71":324,"_198":333,"_73":24,"_200":-5,"_236":334,"_17":335},{"_37":318,"_13":319,"_68":320,"_47":321,"_39":40,"_195":322,"_196":131,"_41":323,"_43":302,"_71":324,"_198":325,"_73":24,"_200":-5,"_236":326,"_17":327},{"_37":314,"_13":290,"_68":282,"_47":-5,"_39":40,"_195":285,"_196":131,"_41":315,"_43":26,"_71":262,"_198":-5,"_73":24,"_200":-5,"_236":316,"_17":317},{"_37":306,"_13":307,"_68":308,"_47":282,"_39":40,"_195":309,"_196":131,"_41":310,"_43":44,"_71":286,"_198":311,"_73":24,"_200":-5,"_236":312,"_17":313},{"_37":297,"_13":298,"_68":299,"_47":282,"_39":40,"_195":300,"_196":131,"_41":301,"_43":302,"_71":286,"_198":303,"_73":24,"_200":-5,"_236":304,"_17":305},{"_37":291,"_13":249,"_68":292,"_47":282,"_39":40,"_195":157,"_196":131,"_41":293,"_43":285,"_71":286,"_198":294,"_73":24,"_200":-5,"_236":295,"_17":296},{"_37":280,"_13":240,"_68":281,"_47":282,"_39":40,"_195":283,"_196":131,"_41":284,"_43":285,"_71":286,"_198":287,"_73":24,"_200":-5,"_236":288,"_17":289},{"_37":275,"_13":271,"_68":268,"_47":-5,"_39":40,"_195":276,"_196":131,"_41":277,"_43":26,"_71":262,"_198":-5,"_73":24,"_200":-5,"_236":278,"_17":279},{"_37":265,"_13":266,"_68":267,"_47":268,"_39":40,"_195":269,"_196":131,"_41":270,"_43":26,"_71":271,"_198":272,"_73":24,"_200":-5,"_236":273,"_17":274},{"_37":260,"_13":202,"_68":194,"_47":-5,"_39":40,"_195":253,"_196":131,"_41":261,"_43":26,"_71":262,"_198":-5,"_73":24,"_200":-5,"_236":263,"_17":264},{"_37":193,"_13":70,"_68":69,"_47":194,"_39":40,"_195":111,"_196":131,"_41":257,"_43":44,"_71":72,"_198":199,"_73":24,"_200":-5,"_236":258,"_17":259},{"_37":248,"_13":249,"_68":250,"_47":194,"_39":40,"_195":251,"_196":131,"_41":252,"_43":253,"_71":72,"_198":254,"_73":24,"_200":-5,"_236":255,"_17":256},{"_37":239,"_13":240,"_68":241,"_47":194,"_39":40,"_195":242,"_196":131,"_41":243,"_43":244,"_71":72,"_198":245,"_73":24,"_200":-5,"_236":246,"_17":247},{"_37":231,"_13":232,"_68":233,"_47":-5,"_39":40,"_195":205,"_196":131,"_41":234,"_43":26,"_71":21,"_198":235,"_73":24,"_200":-5,"_236":237,"_17":238},"00ad9da4-0577-4814-8519-02511a2d4430","README.md","ff70c39e-af85-11f1-9411-1607ee4eb77e",["D",1789312547547],"# corvette\n\nC4 (1994-96) / C5 (1997-2004) Corvette search pipeline for 16105. Forked from logan1/housing. See lib/core.ts.\n","children",[],[232],"6ee78f10-cbd9-4ac8-b0e0-b14c1c7f3465","sources.ts","30edcbe2-af86-11f1-9d05-1607ee4eb77e",68,["D",1789422556949],15,"// Multi-source registry + one parser per platform. Pure functions (text -> hits) so they are unit-testable against\n// scripts/fixtures/*. The cron (cron/sources.ts) does the fetching, rotation, dedupe and upsert. Adding a source =\n// one REGISTRY entry (+ a parser if the platform is new). Per-source gotchas live in valtown/SOURCES.md; verified\n// evidence for every entry is in ../source-inventory.md / .json.\nimport { decodeEntities, stripTags, inferYear, inferTrans, inferBody, inferTitle, inferMiles, inferPrice, inferTrim, findVin, parsePrice, parseMiles, genFor, YEAR_MIN, YEAR_MAX, type Trans, type Body, type Title, type Seller } from \"./core.ts\";\n\nexport type Kind = \"listing\" | \"comp\";\nexport interface Hit {\n extId: string; url: string; title: string; text: string;\n year?: number | null; price?: number | null; miles?: number | null; vin?: string | null;\n trans?: Trans; body?: Body; titleStatus?: Title; seller?: Seller; loc?: string; lat?: number | null; lon?: number | null;\n posted?: string | number | null; auctionDate?: string | null; note?: string; dist?: number | null; // dist = source-reported distance when no coordinates\n soldPrice?: number | null; soldDate?: string | null; // comps\n}\nexport interface ParseResult { hits: Hit[]; more?: boolean }\nexport type Parser = (text: string, ctx: { url: string }) => ParseResult;\nexport interface Source {\n key: string; parser: keyof typeof PARSERS; urls: string[]; every: number; seller: Seller; kind?: Kind;\n push?: boolean; pushMin?: number; enabled?: boolean; headers?: Record; accept?: \"html\" | \"json\" | \"xml\";\n pageUrl?: (base: string, n: number) => string; maxPages?: number; spacingMs?: number; group?: string; full?: boolean; // full = complete inventory (missed logic)\n method?: \"GET\" | \"POST\"; body?: (url: string) => string; // POST APIs (Mecum Algolia)\n}\n\nconst clean = (s: string) => decodeEntities(s).replace(/\\s+/g, \" \").trim();\nconst pipeText = (html: string) => decodeEntities(html.replace(//g, \"\").replace(/|/gi, \"\").replace(/<[^>]+>/g, \" | \")).replace(/\\s+/g, \" \").replace(/(\\s*\\|\\s*)+/g, \" | \").trim();\nexport const CORVETTE_RE = /corvette|\\bvette\\b/i;\nconst yearOk = (y: number | null | undefined) => y != null && y >= YEAR_MIN && y <= YEAR_MAX;\n// fill the structured fields a listing hit lacks from its text (parsers pass what the page gives, this does the rest)\nexport function enrichHit(h: Hit): Hit {\n const t = `${h.title} \\n ${h.text}`;\n return {\n ...h, year: h.year ?? inferYear(t), price: h.price ?? inferPrice(t), miles: h.miles ?? inferMiles(t), vin: h.vin ?? findVin(t),\n trans: h.trans ?? inferTrans(t), body: h.body ?? inferBody(t), titleStatus: h.titleStatus ?? inferTitle(t),\n };\n}\n\n// ---------- RSS / Atom (vBulletin external.php?type=RSS2&forumids=N, XenForo index.rss, Reddit new.rss, Hemmings) ----------\nexport const rss: Parser = (xml, ctx) => {\n const hits: Hit[] = [];\n const items = xml.includes(\"\") || xml.includes(\"]/).slice(1) : xml.split(\"\").slice(1);\n for (const it of items) {\n const g = (re: RegExp) => (it.match(re) || [])[1];\n const title = clean(stripTags((g(/]*>([\\s\\S]*?)<\\/title>/) || \"\").replace(/^$/g, \"\")));\n const link = g(/]*href=\"([^\"]+)\"/) || clean(g(/([\\s\\S]*?)<\\/link>/) || \"\");\n const id = clean(g(/([\\s\\S]*?)<\\/id>/) || g(/]*>([\\s\\S]*?)<\\/guid>/) || link);\n const body = stripTags((g(/([\\s\\S]*?)<\\/content:encoded>/) || g(/]*>([\\s\\S]*?)<\\/content>/) || g(/([\\s\\S]*?)<\\/description>/) || \"\").replace(//g, \"\"));\n const date = g(/([\\s\\S]*?)<\\/pubDate>/) || g(/([\\s\\S]*?)<\\/published>/) || g(/([\\s\\S]*?)<\\/updated>/) || g(/([\\s\\S]*?)<\\/dc:date>/) || \"\";\n if (!link) continue;\n if (date && Number.isFinite(Date.parse(date)) && Date.now() - Date.parse(date) > 90 * 86400000) continue; // XenForo index.rss includes years-old stickies/archived threads\n const text = `${title} \\n ${body}`;\n if (!CORVETTE_RE.test(text) && !/\\bc[45]\\b/i.test(title)) continue;\n if (/reddit\\.com/.test(ctx.url) && !/\\bfor sale\\b|\\bfs\\b|\\bselling\\b|\\bwts\\b|\\$\\s?\\d/i.test(text)) continue; // r/Corvette is mostly discussion; keep only sale posts\n if (/\\bwtb\\b|\\bwanted\\b|\\biso\\b|looking for|\\bparts?\\b.*for sale|\\bwheels?\\b|\\btires?\\b|\\bseats?\\b|\\bhood\\b|\\bexhaust\\b/i.test(title) && !/\\b(19\\d\\d|200\\d)\\b[^|]*\\b(corvette|vette)\\b/i.test(title)) continue;\n const h = enrichHit({ extId: id, url: link, title, text: text.slice(0, 5000), posted: date || null, note: `${ctx.url.replace(/^https?:\\/\\/(www\\.)?/, \"\").split(\"/\")[0]}: ${title.slice(0, 80)}` });\n if (!yearOk(h.year)) continue;\n hits.push(h);\n }\n return { hits };\n};\n\n// ---------- vBulletin forum thread list (CorvetteForum) - fallback when the RSS is blocked ----------\nexport const vbulletin: Parser = (html, ctx) => {\n const hits: Hit[] = [];\n for (const m of html.matchAll(/id=\"td_threadtitle_(\\d+)\"[^>]*title=\"([^\"]*)\"[\\s\\S]*?]*>([\\s\\S]*?)<\\/a>/g)) {\n const [, id, preview, url, t] = m;\n const title = clean(stripTags(t)); const text = `${title} \\n ${clean(preview)}`;\n if (/sticky/i.test(html.slice(Math.max(0, m.index! - 400), m.index!)) && /how to|rules|read (this|first)/i.test(title)) continue;\n if (!CORVETTE_RE.test(text) && !/\\bc[45]\\b/i.test(title)) continue;\n if (/\\bwtb\\b|\\bwanted\\b|\\biso\\b|\\bsold\\b/i.test(title)) continue;\n const h = enrichHit({ extId: id, url, title, text, note: `${ctx.url.replace(/^https?:\\/\\/(www\\.)?/, \"\").split(\"/\")[0]}: ${title.slice(0, 80)}` });\n if (!yearOk(h.year)) continue;\n hits.push(h);\n }\n return { hits };\n};\n\n// ---------- Bring a Trailer model pages: `var auctionsCompletedInitialData = {...}` (24 most recent completed) -> comps ----------\nexport const bat: Parser = (html, ctx) => {\n const hits: Hit[] = [];\n const i = html.indexOf(\"var auctionsCompletedInitialData = \"); if (i < 0) return { hits };\n const j = html.indexOf(\"/* ]]> */\", i); const raw = html.slice(i + \"var auctionsCompletedInitialData = \".length, j > 0 ? j : undefined).trim().replace(/;\\s*$/, \"\");\n let d: any; try { d = JSON.parse(raw); } catch { return { hits }; }\n for (const it of d.items || []) {\n const sold = /Sold for/i.test(String(it.sold_text || \"\"));\n const title = clean(String(it.title || \"\")); const excerpt = clean(stripTags(String(it.excerpt || \"\")));\n const year = inferYear(title); if (!yearOk(year)) continue;\n const miles = (title.match(/\\b(\\d{1,3})k-Mile/i) || [])[1] ? Number((title.match(/\\b(\\d{1,3})k-Mile/i) || [])[1]) * 1000 : inferMiles(`${title} ${excerpt}`);\n const soldDate = it.timestamp_end ? new Date(Number(it.timestamp_end) * 1000).toISOString().slice(0, 10) : null;\n hits.push({ extId: String(it.id), url: String(it.url), title, text: `${title} \\n ${excerpt}`, year, miles, price: null,\n trans: /6-speed|six-speed|manual/i.test(`${title} ${excerpt}`) ? \"manual\" : /automatic|four-speed auto|4l60/i.test(`${title} ${excerpt}`) ? \"auto\" : \"unknown\",\n body: inferBody(title), soldPrice: sold ? Number(it.current_bid) || null : null, soldDate, note: sold ? String(it.sold_text).replace(/<[^>]+>/g, \"\").trim() : `reserve not met - bid to $${it.current_bid}` });\n }\n return { hits };\n};\n\n// ---------- Cars & Bids past auctions (server-rendered cards or __NEXT_DATA__) -> comps ----------\nexport const carsandbids: Parser = (html, ctx) => {\n const hits: Hit[] = [];\n const nd = html.match(/\r\n\r\n\r\n`;\r\n\r\nexport default async function (req: Request): Promise {\r\n if (req.method !== \"GET\") return json({ error: \"GET only\" }, 405);\r\n if (!checkToken(req)) return new Response(\"unauthorized: open the tracker link that includes ?token=\", { status: 401 });\r\n return new Response(HTML, { headers: { \"content-type\": \"text/html; charset=utf-8\", \"cache-control\": \"no-store\", \"x-robots-tag\": \"noindex\" } });\r\n}\r\n",[],[328,319],"api","cd618113-b94e-4d68-bdbc-3d77cca4c359","feed.ts",13,["D",1789314768331],"// corvette-feed: JSON feed of tracked listings (GET). The tracker page pulls this on open.\n// Token via X-Corvette-Token header or ?token=. Returns a bare JSON array of\n// { id, vin, year, gen, model, trim, trans, body, miles, price, allin, title, seller, loc, dist, stretch, url, src, note, fs, lv, status, missed, score, flags }.\n//\n// ?days=N window on last_seen (default 60)\n// ?v=2 adds price_trail, age_days, posted_at, drops, motivated, anomaly, lat, lon, gone_at, auction_date, decode, decode_mismatch, pushed\n// ?alive=1 exclude dead rows (default includes them - they carry price context and show greyed in the tracker)\n// ?stats=1 stats object instead of the array\n// ?comps=1 the comps table (auction results) instead of listings\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { ensureSchema, activeListings, checkToken, json, CORS, PUSH_THRESHOLD } from \"../lib/core.ts\";\n\nexport default async function (req: Request): Promise {\n if (req.method === \"OPTIONS\") return new Response(null, { status: 204, headers: CORS });\n if (req.method !== \"GET\") return json({ error: \"GET only\" }, 405);\n if (!checkToken(req)) return json({ error: \"unauthorized\" }, 401);\n await ensureSchema();\n const url = new URL(req.url);\n if (url.searchParams.get(\"stats\")) {\n const bySrc = await sqlite.execute(`select source, count(*) n, sum(status='dead') dead, max(last_seen) last from listings group by source`);\n const byGen = await sqlite.execute(`select gen, trans, count(*) n, round(avg(price)) avg_price, min(price) min_price from listings where status<>'dead' group by gen, trans`);\n const recent = await sqlite.execute(`select ts, job, ok, fetched, inserted, updated, pushed, substr(detail,1,300) detail from poll_log order by id desc limit 15`);\n const total = await sqlite.execute(`select count(*) n, sum(score>=${PUSH_THRESHOLD}) hot, sum(pushed) pushed, sum(status='dead') dead, sum(vin is not null) with_vin from listings`);\n const comps = await sqlite.execute(`select source, count(*) n, min(sold_date) oldest, max(sold_date) newest from comps group by source`);\n return json({ total: total.rows[0], bySource: bySrc.rows, byGenTrans: byGen.rows, comps: comps.rows, recentPolls: recent.rows });\n }\n if (url.searchParams.get(\"comps\")) {\n const r = await sqlite.execute(`select source, external_id, year, gen, trans, body, miles, sold_price, sold_date, url, title, vin from comps order by sold_date desc limit 500`);\n return json(r.rows, 200, { \"cache-control\": \"no-store\" });\n }\n const days = Math.min(365, Math.max(1, Number(url.searchParams.get(\"days\") || 60)));\n const list = await activeListings(days, Number(url.searchParams.get(\"v\") || 1), !url.searchParams.get(\"alive\"));\n return json(list, 200, { \"cache-control\": \"no-store\" });\n}\n",[],[328,330],"33dae6bd-7997-40cb-81a3-ce8f73eb5f97","admin.ts","411cebc4-af8b-11f1-871a-1607ee4eb77e",76,["D",1789472822843],"// corvette-admin: token-checked maintenance endpoint for validation and manual runs.\n// GET ?job=craigslist | sources | enrich | digest run a job now (digest sends immediately)\n// ?job=sources&only= ?job=sources&force=1 one source / ignore the `every` interval\n// ?job=enrich[&force=1][&step=queue|decode|recalls|geocode|price]\n// ?job=rescore recompute score/flags for every active row (after a rule change)\n// GET ?sql=select ... read-only query (SELECT only)\n// GET ?testpush=1 send a full test Discord embed\n// GET ?pushpending=1 push every active score>=threshold row never alerted (webhook was down)\n// POST { id, status[, gone: true|reason] } set a listing's status (new|contacted|ppi|offer|dead); gone -> gone_at + GONE flag\n// GET ?job=enrich&step=verify[&force=1] re-fetch listing URLs now and mark gone ones (force: 30 rows, ignore the 12 h cadence)\n// POST { delete: { id? | rowid? | source? | url_like? | before? } }\n// POST { comps: [...] } load auction comps pulled locally (scripts/pull_comps.ts)\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { ensureSchema, checkToken, json, CORS, STATUS, pushDiscord, actionLinks, rowToPush, pushThresholdFor, score, flagsFor, decorateNotes, ageDays, conditionPoints, genFor } from \"../lib/core.ts\";\nimport craigslist from \"../cron/craigslist.ts\";\nimport sources from \"../cron/sources.ts\";\nimport enrich, { markGone } from \"../cron/enrich.ts\";\nimport { sendDigest } from \"../cron/digest.ts\";\n\nexport default async function (req: Request): Promise {\n if (req.method === \"OPTIONS\") return new Response(null, { status: 204, headers: CORS });\n if (!checkToken(req)) return json({ error: \"unauthorized\" }, 401);\n await ensureSchema();\n const url = new URL(req.url);\n\n if (req.method === \"POST\") {\n const b = await req.json().catch(() => ({}));\n if (b.delete && typeof b.delete === \"object\") {\n const w: string[] = []; const a: any[] = [];\n if (b.delete.id != null) { w.push(\"id=?\"); a.push(b.delete.id); }\n if (b.delete.rowid != null) { w.push(\"rowid_pk=?\"); a.push(Number(b.delete.rowid)); }\n if (b.delete.source) { w.push(\"source=?\"); a.push(b.delete.source); }\n if (b.delete.url_like) { w.push(\"url like ?\"); a.push(b.delete.url_like); }\n if (b.delete.before) { w.push(\"first_seen k.source && k.external_id && k.url);\n let inserted = 0;\n for (const k of rows) {\n const ex = await sqlite.execute({ sql: `select 1 from comps where source=? and external_id=?`, args: [String(k.source), String(k.external_id)] });\n await sqlite.execute({ sql: `insert into comps (source, external_id, year, gen, trans, body, miles, sold_price, sold_date, url, title, vin, added) values (?,?,?,?,?,?,?,?,?,?,?,?,date('now'))\n on conflict(source, external_id) do update set sold_price=coalesce(excluded.sold_price, comps.sold_price), sold_date=coalesce(excluded.sold_date, comps.sold_date), miles=coalesce(excluded.miles, comps.miles), trans=case when excluded.trans<>'unknown' then excluded.trans else comps.trans end`,\n args: [String(k.source), String(k.external_id), k.year ?? null, k.gen || genFor(k.year ?? null), k.trans || \"unknown\", k.body || \"unknown\", k.miles ?? null, k.sold_price ?? null, k.sold_date ?? null, String(k.url), String(k.title || \"\").slice(0, 200), k.vin || null] });\n if (!ex.rows.length) inserted++;\n }\n const n = await sqlite.execute(`select source, count(*) n from comps group by source`);\n return json({ ok: true, received: rows.length, inserted, totals: n.rows });\n }\n if (!b.id || !STATUS.includes(b.status)) return json({ error: `need id and status in ${STATUS.join(\"|\")}` }, 400);\n if (b.gone) { // tracker \"Gone\" button (Facebook rows the verify step cannot fetch): dead + gone_at + GONE flag in one call\n const cur = await sqlite.execute({ sql: `select rowid_pk, status, flags, notes from listings where id=?`, args: [b.id] });\n const row: any = cur.rows[0]; if (!row) return json({ error: \"no such id\" }, 404);\n await markGone(Number(row.rowid_pk), String(b.gone === true ? \"marked in tracker\" : b.gone).slice(0, 40), row);\n if (b.status !== \"dead\") await sqlite.execute({ sql: `update listings set status=? where id=?`, args: [b.status, b.id] });\n return json({ ok: true, gone: true });\n }\n const r = await sqlite.execute({ sql: `update listings set status=?, gone_at=case when ?='dead' then gone_at else null end where id=?`, args: [b.status, b.status, b.id] }); // reviving a row clears gone_at\n return json({ ok: true, rowsAffected: r.rowsAffected });\n }\n\n const job = url.searchParams.get(\"job\");\n if (job === \"craigslist\") return json(await craigslist());\n if (job === \"sources\") return json(await sources({ only: url.searchParams.get(\"only\") || undefined, force: !!url.searchParams.get(\"force\") }));\n if (job === \"enrich\") return json(await enrich({ force: !!url.searchParams.get(\"force\"), step: url.searchParams.get(\"step\") || undefined }));\n if (job === \"digest\") return json(await sendDigest(true));\n if (job === \"rescore\") {\n const rows = await sqlite.execute(`select * from listings where last_seen >= date('now','-60 day')`);\n let changed = 0;\n for (const r of rows.rows as any[]) {\n const text = [r.raw, r.notes].filter(Boolean).join(\" \");\n const s = score({ year: r.year == null ? null : Number(r.year), gen: r.gen, trans: r.trans, miles: r.miles == null ? null : Number(r.miles), seller: r.seller, price: r.price == null ? null : Number(r.price), dist: r.dist == null ? null : Number(r.dist), title: r.title, vin: r.vin, conditionPts: conditionPoints(text, r.gen) });\n const keep = String(r.flags || \"\").split(\"|\").filter((f: string) => /^(DEAD |VIN MISMATCH|PRICE ANOMALY|DROP |MOTIVATED)/.test(f));\n const fl = [...keep, ...flagsFor({ vin: r.vin, trim: String(r.trim || \"\"), trans: r.trans, text: String(r.raw || \"\"), dist: r.dist == null ? null : Number(r.dist), ageDays: ageDays(r.posted_at, r.first_seen) })];\n const flags = [...new Set(fl)].join(\"|\");\n if (s !== Number(r.score) || flags !== r.flags) { await sqlite.execute({ sql: `update listings set score=?, flags=?, notes=? where rowid_pk=?`, args: [s, flags, decorateNotes(String(r.notes || \"\"), flags.split(\"|\").filter(Boolean)), r.rowid_pk] }); changed++; }\n }\n return json({ rows: rows.rows.length, changed });\n }\n\n if (url.searchParams.get(\"pushpending\")) {\n const r = await sqlite.execute(`select * from listings where pushed = 0 and status <> 'dead' and last_seen >= date('now','-14 day') and julianday('now') - julianday(coalesce(posted_at, first_seen)) <= 45 order by score desc`);\n const out: any[] = [];\n for (const row of r.rows as any[]) {\n if (Number(row.score) < pushThresholdFor(row.dist == null ? null : Number(row.dist), row.seller)) continue;\n const ok = await pushDiscord(rowToPush(row));\n if (ok) await sqlite.execute({ sql: `update listings set pushed=1 where rowid_pk=?`, args: [row.rowid_pk] });\n out.push({ id: row.id, score: row.score, pushed: ok });\n }\n return json({ pending: out.length, results: out });\n }\n\n if (url.searchParams.get(\"testpush\")) {\n const l = { id: \"1G1YY22G215100001\", rowid: null, vin: \"1G1YY22G215100001\", year: 2001, gen: \"C5\" as const, trim: \"\", trans: \"auto\" as const, body: \"coupe\" as const, miles: 78500, price: 11500, title: \"clean\" as const, seller: \"private\" as const,\n loc: \"Boardman, OH - CL youngstown\", lat: 41.0242, lon: -80.6629, dist: 18, url: \"https://example.com/test-corvette\", source: \"test\", score: 11, flags: [\"MOTIVATED\", \"DROP $500\"], notes: \"Pipeline test; ignore. Service records, column lock recall done.\", trail: [12500, 12000, 11500], ageDays: 12 };\n const ok = await pushDiscord(l);\n return json({ pushed: ok, links: actionLinks(l) });\n }\n\n const sql = url.searchParams.get(\"sql\");\n if (sql) {\n if (!/^\\s*select\\b/i.test(sql)) return json({ error: \"SELECT only\" }, 400);\n const r = await sqlite.execute(sql);\n return json({ columns: r.columns, rows: r.rows });\n }\n return json({ usage: \"?job=craigslist|sources[&only=key][&force=1]|enrich[&step=..]|digest|rescore ?sql=select... ?testpush=1 ?pushpending=1 POST {id,status} POST {delete:{...}}\" });\n}\n",[],[328,337],"4e8a0f88-b47d-4b43-86fa-affd72346a91","add.ts","38cdf558-af8b-11f1-8c3c-1607ee4eb77e",21,["D",1789314991805],"// corvette-add: manual ingestion endpoint (POST). Claude in Chrome and Logan post FB Marketplace / FB group /\n// portal finds here. Shared-secret header X-Corvette-Token (or ?token=).\n//\n// Body (JSON, single object or array <= 50):\n// { url, src, vin?, year?, trans?, body?, miles?, price?, title?, seller?, loc?, lat?, lon?, note?, text?, posted?, external_id?, auction_date? }\n// `text` is the listing body; any field left blank is inferred from it. Returns the upsert result per item\n// (action inserted|updated|merged, id = VIN or \"SRC extId\", score, pushed, dead reason if any).\nimport {\n TRANS, BODY, TITLE, SELLER, ensureSchema, upsertListing, inferYear, inferTrans, inferBody, inferTitle, inferSeller, inferMiles, inferPrice, inferTrim,\n parsePrice, parseMiles, findVin, normalizeVin, validVin, checkToken, json, CORS, YEAR_MIN, YEAR_MAX, type Seller,\n} from \"../lib/core.ts\";\n\nexport default async function (req: Request): Promise {\n if (req.method === \"OPTIONS\") return new Response(null, { status: 204, headers: CORS });\n if (req.method !== \"POST\") return json({ error: \"POST only\" }, 405);\n if (!checkToken(req)) return json({ error: \"unauthorized\" }, 401);\n let body: any;\n try { body = await req.json(); } catch { return json({ error: \"invalid JSON\" }, 400); }\n const items: any[] = Array.isArray(body) ? body : [body];\n if (items.length === 0 || items.length > 50) return json({ error: \"1-50 listings per request\" }, 400);\n await ensureSchema();\n const results: any[] = [];\n for (const it of items) {\n const text = [it.title, it.loc, it.note, it.text].filter(Boolean).join(\" \\n \");\n const url = String(it.url || \"\").trim();\n const src = String(it.src || it.source || \"manual\").toLowerCase().trim();\n if (!url) { results.push({ error: \"need url\", input: it }); continue; }\n const vinIn = it.vin ? normalizeVin(it.vin) : null;\n if (it.vin && !validVin(vinIn)) results.push({ warning: `VIN ${it.vin} failed validation (17 chars, no I/O/Q, check digit); stored without it` });\n const vin = validVin(vinIn) ? vinIn : findVin(text);\n const year = it.year != null && it.year !== \"\" ? Number(it.year) : inferYear(text);\n if (year != null && (year < YEAR_MIN || year > YEAR_MAX)) { results.push({ skipped: `year ${year} outside ${YEAR_MIN}-${YEAR_MAX}`, input: it }); continue; }\n const trans = TRANS.includes(it.trans) ? it.trans : /^a/i.test(String(it.trans || \"\")) ? \"auto\" : /^m/i.test(String(it.trans || \"\")) ? \"manual\" : inferTrans(text);\n const bodyT = BODY.includes(it.body) ? it.body : inferBody(text);\n const title = TITLE.includes(it.title_status || it.title) ? (it.title_status || it.title) : inferTitle(text);\n const sellerDefault: Seller = [\"fb\", \"fbm\", \"facebook\", \"craigslist\", \"forum\", \"manual\", \"sign\"].includes(src) ? \"private\" : [\"autotrader\", \"cars\", \"cargurus\", \"carsforsale\", \"dealer\"].includes(src) ? \"dealer-small\" : \"unknown\";\n const seller = SELLER.includes(it.seller) ? it.seller : inferSeller(text, sellerDefault);\n const miles = it.miles != null && it.miles !== \"\" ? parseMiles(it.miles) : inferMiles(text);\n const price = it.price != null && it.price !== \"\" ? parsePrice(it.price) : inferPrice(text);\n const r = await upsertListing({\n vin, year, trim: inferTrim(String(it.title || it.trim || \"\")), trans, body: bodyT, miles, price, title, seller, loc: String(it.loc || it.location || \"\").trim(),\n lat: it.lat != null ? Number(it.lat) : null, lon: it.lon != null ? Number(it.lon) : null,\n source: src, externalId: it.external_id || it.externalId || (url.match(/(\\d{6,})/) || [])[1] || null, url,\n notes: String(it.note || \"\").trim(), raw: it.text ? String(it.text) : undefined, text, postedAt: it.posted || it.posted_at || null, auctionDate: it.auction_date || null,\n }, { push: true });\n results.push(r);\n }\n return json({ ok: true, results });\n}\n",[],[328,345],"b2a361ad-ea6d-43f1-bc22-2eaa212050a7",["D",1789312590546],[215,216,217,218],[328],["D",1789312547277],["D",1789486866837],{"_11":12,"_171":76},{"_11":12,"_166":167,"_75":76,"_30":74,"_168":169,"_170":24},{"_43":157,"_13":16,"_37":40,"_158":118,"_159":-5,"_160":-5,"_161":-5,"_162":-5,"_163":-5,"_164":14,"_165":12},"ctx",{"_58":-5,"_190":394,"_395":396,"_397":398,"_399":24,"_400":24,"_401":24,"_402":131,"_403":-5,"_404":-7,"_405":-7,"_406":26,"_407":24,"_408":24,"_409":-5,"_410":24,"_411":24,"_412":24,"_413":-5},"ENV",{"_365":366,"_367":368,"_369":16,"_370":371,"_372":373,"_374":375,"_376":377,"_378":379,"_380":381,"_382":383,"_384":385,"_386":387,"_388":389,"_390":391,"_392":393},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

History · core.ts