[{"_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":22},"handle","logan1","name","housing","path","lib/core.ts","project",{"_23":48,"_11":12,"_36":49,"_50":-5,"_51":44,"_52":53,"_54":53,"_55":56,"_57":-5,"_58":59,"_60":61,"_62":35,"_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",{"_23":24,"_11":25,"_26":27,"_28":29,"_30":31,"_32":33,"_34":35,"_36":37,"_38":39,"_40":17,"_41":42,"_43":44,"_45":-5,"_13":46},"permalink","https://www.val.town/x/logan1/housing/code/lib/core.ts","extension","ts","id","482f432b-d020-44d0-9755-cc5cf91521ee","core.ts","fileId","04c30e2c-aef2-11f1-97fb-1607ee4eb77e","parentId","03892172-aef2-11f1-9a6d-1607ee4eb77e","branchId","a4c5838e-3adb-4640-ab71-e9f3d2b72f0a","branchVersion",64,"latest",true,"createdAt",["D",1789308405144],"version",11,"fileType","content","// Shared core for the DC housing pipeline: schema, normalization, scoring,\r\n// dedupe/upsert, feed mapping, Discord push. Imported by every other file.\r\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\r\nimport { ensureEnrichSchema, licenseFor, p25For, isAnomaly, scamGateBlocks, recordPrice, trailStats, motivatedFlag, stripPrefixes, buildPrefix, fmtTrail, isQuietHour, queuePush } from \"./enrich.ts\";\r\nimport { vibeForRow, ensureVibeSchema } from \"./vibe.ts\";\r\n\r\n// ---------- constants (must match the Listing Tracker artifact) ----------\r\nexport const AREAS = [\r\n \"Petworth\",\r\n \"Park View / 16th St Hts\",\r\n \"Brightwood\",\r\n \"Fairlington / Shirlington\",\r\n \"Columbia Pike\",\r\n \"Del Ray\",\r\n \"Hyattsville\",\r\n] as const;\r\nexport type Area = typeof AREAS[number];\r\nexport const PARK = [\"garage\", \"offstreet\", \"street\", \"unknown\"] as const;\r\nexport const HTYPE = [\"rowhouse\", \"basement\", \"condo\", \"apartment\", \"house\", \"unknown\"] as const;\r\nexport const LL = [\"individual\", \"pm\", \"unknown\"] as const;\r\nexport const STATUS = [\"new\", \"contacted\", \"touring\", \"applied\", \"dead\"] as const;\r\nexport const PUSH_THRESHOLD = 8;\r\nexport const PRICE_MIN = 1900;\r\nexport const PRICE_MAX = 2700;\r\n\r\nexport interface Listing {\r\n id: string; // normalized address (or \" \" when no address is known)\r\n addr: string;\r\n area: Area;\r\n price: number | null;\r\n beds: number; // 1 | 1.5 | 2 | 3\r\n park: typeof PARK[number];\r\n type: typeof HTYPE[number];\r\n ll: typeof LL[number];\r\n dog: boolean | null;\r\n url: string;\r\n src: string; // craigslist | popville | fb | fbm | zillow | apartments | zumper | sign | manual\r\n note: string;\r\n fs: string; // yyyy-mm-dd\r\n lv: string; // yyyy-mm-dd\r\n status: typeof STATUS[number];\r\n missed: number;\r\n}\r\n\r\n// ---------- schema ----------\r\nexport async function ensureSchema() {\r\n await sqlite.batch([\r\n `create table if not exists listings (\r\n rowid_pk integer primary key autoincrement,\r\n id text not null,\r\n address_norm text not null,\r\n addr text not null,\r\n unit text,\r\n area text not null,\r\n price integer,\r\n beds real not null,\r\n source text not null,\r\n external_id text,\r\n url text not null,\r\n parking_type text not null default 'unknown',\r\n htype text not null default 'unknown',\r\n pet_ok integer,\r\n landlord_type text not null default 'unknown',\r\n score integer not null default 0,\r\n first_seen text not null,\r\n last_seen text not null,\r\n status text not null default 'new',\r\n missed integer not null default 0,\r\n pushed integer not null default 0,\r\n notes text not null default '',\r\n lat real, lon real,\r\n raw text\r\n )`,\r\n `create index if not exists listings_addr on listings(address_norm)`,\r\n `create index if not exists listings_ext on listings(source, external_id)`,\r\n `create index if not exists listings_seen on listings(last_seen)`,\r\n `create table if not exists skips (\r\n source text not null, external_id text not null, reason text, ts text not null,\r\n primary key (source, external_id)\r\n )`,\r\n `create table if not exists targets (\r\n address_norm text primary key, addr text not null, area text not null, owner text, mailing text,\r\n garage_evidence text, units integer, beds integer, bbl integer not null default 0, rank integer, added text not null\r\n )`,\r\n `create table if not exists source_state (\r\n source text primary key, last_run text, last_ok text, fail_count integer not null default 0,\r\n runs integer not null default 0, inserted_total integer not null default 0, detail text\r\n )`,\r\n `create table if not exists poll_log (\r\n id integer primary key autoincrement,\r\n ts text not null,\r\n job text not null,\r\n ok integer not null,\r\n fetched integer default 0,\r\n inserted integer default 0,\r\n updated integer default 0,\r\n pushed integer default 0,\r\n detail text\r\n )`,\r\n ]);\r\n // column migrations (sqlite has no ADD COLUMN IF NOT EXISTS - guard with pragma table_info)\r\n const cols = async (t: string) => new Set(((await sqlite.execute(`pragma table_info(${t})`)).rows as any[]).map((r) => String(r.name)));\r\n const lc = await cols(\"listings\");\r\n if (!lc.has(\"posted_at\")) await sqlite.execute(`alter table listings add column posted_at text`);\r\n await sqlite.execute(`create index if not exists listings_posted on listings(posted_at)`);\r\n const tc = await cols(\"targets\");\r\n if (!tc.has(\"confidence\")) await sqlite.execute(`alter table targets add column confidence text not null default 'C'`);\r\n if (!tc.has(\"verified_at\")) await sqlite.execute(`alter table targets add column verified_at text`);\r\n await ensureEnrichSchema();\r\n await ensureVibeSchema();\r\n}\r\n\r\n// ---------- normalization (Section 3 contract, literal) ----------\r\n// Canonical form shared by listings.address_norm and targets.address_norm (Phase 3). Street line only:\r\n// callers pass the part before the first comma. Handles N.W./NORTHWEST -> NW, STREET -> ST, unit tokens,\r\n// zero-padded house numbers (\"004908\" -> \"4908\"). Keep this in sync with phase3/pull.ts normAddr.\r\nexport function normalizeAddress(a: string): string {\r\n let s = (a || \"\").toUpperCase();\r\n s = s.replace(/[.,#]/g, \"\");\r\n s = s.split(/\\s+/).filter((t) => t && ![\"UNIT\", \"APT\", \"STE\"].includes(t)).join(\" \");\r\n s = s.replace(/\\bSTREET\\b/g, \"ST\").replace(/\\bAVENUE\\b/g, \"AVE\").replace(/\\bDRIVE\\b/g, \"DR\")\r\n .replace(/\\bROAD\\b/g, \"RD\").replace(/\\bPLACE\\b/g, \"PL\").replace(/\\bCOURT\\b/g, \"CT\").replace(/\\bLANE\\b/g, \"LN\")\r\n .replace(/\\bBOULEVARD\\b/g, \"BLVD\").replace(/\\bTERRACE\\b/g, \"TER\").replace(/\\bCIRCLE\\b/g, \"CIR\")\r\n .replace(/\\bNORTHWEST\\b/g, \"NW\").replace(/\\bNORTHEAST\\b/g, \"NE\").replace(/\\bSOUTHWEST\\b/g, \"SW\").replace(/\\bSOUTHEAST\\b/g, \"SE\")\r\n .replace(/\\bNORTH\\b/g, \"N\").replace(/\\bSOUTH\\b/g, \"S\").replace(/\\bEAST\\b/g, \"E\").replace(/\\bWEST\\b/g, \"W\")\r\n .replace(/^0+(\\d)/, \"$1\");\r\n return s.replace(/\\s+/g, \" \").trim();\r\n}\r\n\r\nexport function today(): string {\r\n return new Date().toISOString().slice(0, 10);\r\n}\r\n\r\n// ---------- scoring (Section 4, literal) ----------\r\nexport function score(l: Pick): number {\r\n let s = 0;\r\n if (l.park === \"garage\") s += 4;\r\n else if (l.park === \"offstreet\") s += 2;\r\n if (l.type === \"rowhouse\" || l.type === \"basement\") s += 2;\r\n if (l.ll === \"individual\") s += 2;\r\n if (l.beds >= 2 || l.beds === 1.5) s += 2;\r\n if (l.price != null && l.price <= 2400) s += 1;\r\n if (l.dog === true) s += 1;\r\n else if (l.dog === false) s -= 3; // no-pets listing: keep the row for price context but never let it push\r\n if (l.area === \"Fairlington / Shirlington\" || l.area === \"Columbia Pike\") s += 1;\r\n return Math.max(0, s); // rules as written sum to a max of 13\r\n}\r\n\r\n// ---------- area inference ----------\r\nconst AREA_KEYWORDS: [RegExp, Area][] = [\r\n [/\\bpetworth\\b/i, \"Petworth\"],\r\n [/\\bpark\\s*view\\b|\\b16th\\s*st(reet)?\\s*h(eigh)?ts\\b|\\bsixteenth street heights\\b|\\bcolumbia heights\\b/i, \"Park View / 16th St Hts\"],\r\n [/\\bbrightwood\\b|\\btakoma\\b|\\bmanor park\\b|\\bshepherd park\\b/i, \"Brightwood\"],\r\n [/\\bfairlington\\b|\\bshirlington\\b/i, \"Fairlington / Shirlington\"],\r\n [/\\bcolumbia pike\\b|\\bpenrose\\b|\\bbarcroft\\b|\\barlington mill\\b|\\bdouglas park\\b/i, \"Columbia Pike\"],\r\n [/\\bdel ray\\b|\\barlandria\\b|\\brosemont\\b|\\bpotomac yard\\b/i, \"Del Ray\"],\r\n [/\\bhyattsville\\b|\\briverdale\\b|\\bmount rainier\\b|\\bmt\\.? rainier\\b|\\bbrentwood\\b/i, \"Hyattsville\"],\r\n];\r\nconst AREA_ZIPS: Record = {\r\n \"20011\": \"Petworth\", \"20010\": \"Park View / 16th St Hts\", \"20012\": \"Brightwood\",\r\n \"22206\": \"Fairlington / Shirlington\", \"22204\": \"Columbia Pike\",\r\n \"22301\": \"Del Ray\", \"22305\": \"Del Ray\", \"20781\": \"Hyattsville\", \"20782\": \"Hyattsville\",\r\n};\r\n// rough bounding boxes [latMin, latMax, lonMin, lonMax]; checked in order\r\nconst AREA_BOXES: [number, number, number, number, Area][] = [\r\n [38.955, 38.985, -77.045, -77.005, \"Brightwood\"],\r\n [38.945, 38.955, -77.045, -77.028, \"Park View / 16th St Hts\"],\r\n [38.925, 38.943, -77.030, -77.012, \"Park View / 16th St Hts\"],\r\n [38.930, 38.955, -77.035, -77.005, \"Petworth\"],\r\n [38.820, 38.848, -77.105, -77.070, \"Fairlington / Shirlington\"],\r\n [38.845, 38.875, -77.125, -77.075, \"Columbia Pike\"],\r\n [38.815, 38.848, -77.070, -77.040, \"Del Ray\"],\r\n [38.935, 38.980, -76.980, -76.920, \"Hyattsville\"],\r\n];\r\nexport function inferArea(text: string, lat?: number | null, lon?: number | null, fallback?: Area): Area | null {\r\n // precedence: zip > coordinates > neighborhood keywords > caller fallback\r\n const zip = (text.match(/\\b(2001[012]|2220[46]|2230[15]|2078[12])\\b/) || [])[1];\r\n if (zip && AREA_ZIPS[zip]) return AREA_ZIPS[zip];\r\n if (lat != null && lon != null) {\r\n for (const [a1, a2, o1, o2, a] of AREA_BOXES) if (lat >= a1 && lat <= a2 && lon >= o1 && lon <= o2) return a;\r\n }\r\n for (const [re, a] of AREA_KEYWORDS) if (re.test(text)) return a;\r\n return fallback ?? null;\r\n}\r\n\r\n// ---------- free-text attribute inference (shared by CL, PoPville, manual) ----------\r\nexport function inferPark(text: string): Listing[\"park\"] {\r\n const t = text.toLowerCase();\r\n if (/\\bgarage\\b/.test(t) && !/\\bno garage\\b|garage sale/.test(t)) return \"garage\";\r\n if (/off[- ]?street|driveway|parking pad|carport|assigned parking|reserved parking|parking (space|spot) included|secured parking|surface lot|parking lot|parking included/.test(t)) return \"offstreet\";\r\n if (/street parking|no parking|permit parking/.test(t)) return \"street\";\r\n return \"unknown\";\r\n}\r\nexport function inferType(text: string): Listing[\"type\"] {\r\n const t = text.toLowerCase();\r\n if (/english basement|basement (unit|apartment|apt)|lower[- ]level (unit|apartment)|in-law|garden[- ]level/.test(t)) return \"basement\";\r\n if (/row ?house|row ?home|townhouse|townhome|duplex|triplex/.test(t)) return \"rowhouse\";\r\n if (/\\bcondo/.test(t)) return \"condo\";\r\n if (/single[- ]family|\\bhouse\\b|\\bsfh\\b|bungalow|cape cod|colonial/.test(t)) return \"house\";\r\n if (/apartment|\\bapt\\b|\\bunit\\b|luxury|community|leasing/.test(t)) return \"apartment\";\r\n return \"unknown\";\r\n}\r\nexport function inferLL(text: string, srcDefault: Listing[\"ll\"]): Listing[\"ll\"] {\r\n const t = text.toLowerCase();\r\n if (/property management|management company|leasing office|leasing center|leasing consultant|apply online|schedule a tour online|equal housing opportunity|professionally managed|realty|\\brealtor\\b|brokerage|\\bllc\\b/.test(t)) return \"pm\";\r\n if (/\\b(i am|i'm|we are|we're) (the )?(owner|landlord)|owner[- ]managed|private owner|by owner|my (house|home|unit|basement)|our (house|home|basement)|@gmail\\.com|@yahoo\\.com|@hotmail\\.com|@outlook\\.com/.test(t)) return \"individual\";\r\n return srcDefault;\r\n}\r\nexport function inferDog(text: string): boolean | null {\r\n const t = text.toLowerCase();\r\n if (/no dogs|no pets|pets? not allowed|cats only|sorry,? no pets|not pet friendly|pet[- ]free/.test(t)) return false;\r\n if (/dogs? (are )?(ok|okay|welcome|allowed|friendly|negotiable|considered)|pet[- ]friendly|pets? (ok|okay|welcome|allowed|negotiable|considered)|dog[- ]friendly|large dogs/.test(t)) return true;\r\n return null;\r\n}\r\nexport function inferBeds(text: string): number | null {\r\n const t = text.toLowerCase();\r\n if (/\\bstudio\\b|\\befficiency\\b/.test(t) && !/\\b[1-9]\\s*(br|bd|bed)/.test(t)) return 0;\r\n const m = t.match(/\\b([1-6])\\s*(\\+\\s*den\\s*)?(br|bd|bdr|bed|beds|bedroom|bedrooms)\\b/) || t.match(/\\b(one|two|three)[- ](br|bd|bed|bedroom)/);\r\n if (!m) return null;\r\n let n = ({ one: 1, two: 2, three: 3 } as Record)[m[1]] ?? parseInt(m[1], 10);\r\n if (n === 1 && /\\bden\\b|\\bbonus room\\b|\\boffice\\b|\\bplus den\\b|1\\s*\\+\\s*den/.test(t)) n = 1.5;\r\n return n;\r\n}\r\n// price from free text: \"$2,250/mo\", \"$2250\", \"2,250/month\". Ignores zips and sqft by requiring $ or /mo context and a sane range.\r\nexport function inferPrice(text: string): number | null {\r\n const t = text.replace(/\\u00a0/g, \" \");\r\n const cands: number[] = [];\r\n for (const m of t.matchAll(/\\$\\s?(\\d{1,2},?\\d{3})(?!\\d)/g)) cands.push(Number(m[1].replace(/,/g, \"\")));\r\n for (const m of t.matchAll(/(? n >= 800 && n <= 6000);\r\n return ok.length ? ok[0] : null;\r\n}\r\nexport function clampBeds(n: number | null): number {\r\n if (n == null) return 1;\r\n if (n === 1.5) return 1.5;\r\n if (n >= 3) return 3;\r\n if (n >= 2) return 2;\r\n return 1; // callers filter studios (0) before this\r\n}\r\nexport function parsePrice(s: string | number | null | undefined): number | null {\r\n if (s == null || s === \"\") return null;\r\n if (typeof s === \"number\") return Number.isFinite(s) ? Math.round(s) : null;\r\n const m = String(s).replace(/,/g, \"\").match(/\\$?\\s*(\\d{3,5})(?!\\d)/);\r\n return m ? parseInt(m[1], 10) : null;\r\n}\r\n\r\n// ---------- dedupe / upsert ----------\r\nexport interface UpsertInput {\r\n addr: string | null;\r\n area: Area;\r\n price: number | null;\r\n beds: number;\r\n source: string;\r\n externalId?: string | null;\r\n url: string;\r\n park: Listing[\"park\"];\r\n type: Listing[\"type\"];\r\n ll: Listing[\"ll\"];\r\n dog: boolean | null;\r\n notes?: string;\r\n lat?: number | null;\r\n lon?: number | null;\r\n raw?: string;\r\n unit?: string | null;\r\n postedAt?: string | number | null; // source's first-posted date (yyyy-mm-dd, ms epoch, or Date-parsable)\r\n}\r\nexport interface UpsertResult { action: \"inserted\" | \"updated\"; rowid: number; id: string; score: number; pushed: boolean; }\r\n\r\n// Street-only key for target matching: address_norm keeps unit numbers (\"820 KENNEDY ST NW 2\") so different\r\n// units dedupe separately, but a landlord target is the whole building. Truncate after the street suffix (+ quadrant).\r\nconst STREET_KEY_RE = /^(\\d+[A-Z]?\\s+(?:[NSEW]\\s+)?(?:\\d+(?:ST|ND|RD|TH)|[A-Z][A-Z'-]*)(?:\\s+[A-Z][A-Z'-]*)*?\\s+(?:ST|AVE|RD|PL|DR|CT|LN|BLVD|TER|CIR|WAY|PKWY|HWY|PIKE|SQ|ROW)\\b(?:\\s+(?:NW|NE|SW|SE|N|S|E|W)\\b)?)/;\r\nexport function streetKey(addrNorm: string): string {\r\n const m = (addrNorm || \"\").match(STREET_KEY_RE);\r\n return m ? m[1] : (addrNorm || \"\");\r\n}\r\n\r\n// Phase 3 rule 3.5: garage-rowhouse landlord target bonus by confidence tier (targets table, keyed by streetKey)\r\nexport async function targetBonus(addrNorm: string): Promise<{ bonus: number; tier: string | null }> {\r\n if (!addrNorm) return { bonus: 0, tier: null };\r\n const r = await sqlite.execute({ sql: `select confidence from targets where address_norm=? limit 1`, args: [streetKey(addrNorm)] });\r\n if (!r.rows.length) return { bonus: 0, tier: null };\r\n const tier = String((r.rows[0] as any).confidence || \"C\");\r\n return { bonus: tier === \"A\" ? 3 : tier === \"B\" ? 2 : 0, tier };\r\n}\r\n\r\n// ---------- age / staleness (Fix 2) ----------\r\nexport const STALE_DAYS = 45;\r\nexport function ageDays(postedAt: string | null | undefined, firstSeen: string | null | undefined, ref = today()): number {\r\n const base = postedAt || firstSeen;\r\n if (!base) return 0;\r\n return Math.max(0, Math.round((Date.parse(ref) - Date.parse(String(base).slice(0, 10))) / 86400000));\r\n}\r\nexport function isStale(postedAt: string | null | undefined, firstSeen: string | null | undefined, ref = today()): boolean {\r\n return ageDays(postedAt, firstSeen, ref) > STALE_DAYS;\r\n}\r\nexport function toIsoDate(v: unknown): string | null {\r\n if (v == null || v === \"\") return null;\r\n const t = typeof v === \"number\" ? v : Date.parse(String(v));\r\n if (!Number.isFinite(t)) return null;\r\n const d = new Date(t).toISOString().slice(0, 10);\r\n return d < \"2015-01-01\" || d > today() ? null : d;\r\n}\r\nconst earliest = (a: string | null | undefined, b: string | null | undefined) => (a && b ? (a < b ? a : b) : a || b || null);\r\nexport type NoteFlags = { stale?: number | null; license?: string | null; anomaly?: boolean; lastDrop?: number; motivated?: boolean };\r\n// Rebuild the flag prefix (STALE | NO BBL | PRICE ANOMALY | DROP $X | MOTIVATED) and the TARGET suffix on every upsert/enrich.\r\nexport function decorateNotes(notes: string, flags: NoteFlags | number | null, tier: string | null): string {\r\n const f: NoteFlags = typeof flags === \"number\" ? { stale: flags } : (flags || {});\r\n let n = stripPrefixes(notes || \"\");\r\n if (tier && !/\\bTARGET [ABC]\\b/.test(n)) n = [n, `TARGET ${tier}${tier === \"B\" ? \" | VERIFY GARAGE (satellite)\" : \"\"}`].filter(Boolean).join(\" | \");\r\n return (buildPrefix(f) + n).replace(/ \\| $/, \"\"); // prefix-only notes keep the tokens without a dangling separator\r\n}\r\n// enrichment flags computed at upsert time (all local sqlite lookups; no external calls inside the pollers)\r\nasync function flagsFor(rowid: number | null, addrNorm: string, area: Area, addr: string | null, price: number | null, beds: number, age: number, source: string) {\r\n const enrichable = !/^signal-|^cl-parking$/.test(source);\r\n const lic = enrichable ? await licenseFor(addrNorm, area, addr) : { license: null as string | null, detail: null as string | null };\r\n const p = enrichable && price != null ? await p25For(area, beds) : { p25: null, basis: \"\" };\r\n const anomaly = enrichable && isAnomaly(price, p.p25);\r\n const trail = rowid != null ? await recordPrice(rowid, price) : [];\r\n const ts = trailStats(trail);\r\n const motivated = enrichable && motivatedFlag(ts.drops, age);\r\n return { license: lic.license, licenseDetail: lic.detail, anomaly, p25: p.p25, trail, drops: ts.drops, lastDrop: ts.lastDrop, motivated };\r\n}\r\n\r\nexport async function upsertListing(inp: UpsertInput, opts: { push?: boolean; pushMin?: number } = {}): Promise {\r\n const now = today();\r\n const threshold = opts.pushMin ?? PUSH_THRESHOLD;\r\n const addrNorm = inp.addr ? normalizeAddress(inp.addr) : \"\";\r\n if (!addrNorm) inp = { ...inp, addr: null }; // placeholder addresses (\".\" / \"#\") count as no address\r\n const id = addrNorm || `${inp.source.toUpperCase()} ${inp.externalId || crypto.randomUUID().slice(0, 8)}`;\r\n const { bonus, tier } = await targetBonus(addrNorm);\r\n const sc = score({ park: inp.park, type: inp.type, ll: inp.ll, beds: inp.beds, price: inp.price, dog: inp.dog, area: inp.area }) + bonus;\r\n const postedIn = toIsoDate(inp.postedAt);\r\n const staleEligible = !/^signal-|^cl-parking$/.test(inp.source); // signals/parking carry an event date, not a listing date - never STALE-tagged\r\n\r\n // 1) same source + external id (a re-fetched post)\r\n let existing: any = null;\r\n if (inp.externalId) {\r\n const r = await sqlite.execute({ sql: `select * from listings where source=? and external_id=? limit 1`, args: [inp.source, inp.externalId] });\r\n existing = r.rows[0] || null;\r\n }\r\n // 2) contract rule: exact id, or same id with equal beds and price within $100\r\n if (!existing) {\r\n const r = await sqlite.execute({ sql: `select * from listings where id=? order by last_seen desc`, args: [id] });\r\n for (const row of r.rows as any[]) {\r\n const sameBeds = Number(row.beds) === Number(inp.beds);\r\n const p1 = row.price == null ? null : Number(row.price);\r\n const closePrice = p1 == null || inp.price == null || Math.abs(p1 - inp.price) <= 100;\r\n if (addrNorm && sameBeds && closePrice) { existing = row; break; }\r\n if (!addrNorm) { existing = row; break; } // synthetic ids are exact-match only\r\n }\r\n }\r\n\r\n if (existing) {\r\n // keep the better-informed attributes, refresh last_seen, reset missed; posted_at keeps the EARLIEST date seen\r\n const merged = {\r\n price: inp.price ?? existing.price,\r\n park: existing.parking_type !== \"unknown\" && inp.park === \"unknown\" ? existing.parking_type : inp.park,\r\n type: existing.htype !== \"unknown\" && inp.type === \"unknown\" ? existing.htype : inp.type,\r\n ll: existing.landlord_type !== \"unknown\" && inp.ll === \"unknown\" ? existing.landlord_type : inp.ll,\r\n dog: inp.dog ?? (existing.pet_ok == null ? null : !!existing.pet_ok),\r\n };\r\n const newScore = score({ ...merged, beds: inp.beds, area: inp.area } as any) + bonus;\r\n const postedAt = earliest(postedIn, existing.posted_at);\r\n const age = ageDays(postedAt, existing.first_seen, now);\r\n const stale = staleEligible && age > STALE_DAYS;\r\n const rowid = Number(existing.rowid_pk);\r\n const fl = await flagsFor(rowid, addrNorm, inp.area, inp.addr, merged.price == null ? null : Number(merged.price), inp.beds, age, inp.source);\r\n const note = inp.notes || \"\";\r\n let notes = String(existing.notes || \"\");\r\n if (note && !notes.includes(note)) notes = notes ? `${notes}\\n${note}` : note;\r\n notes = decorateNotes(notes, { stale: stale ? age : null, license: fl.license, anomaly: fl.anomaly, lastDrop: fl.lastDrop, motivated: fl.motivated }, tier);\r\n await sqlite.execute({\r\n sql: `update listings set price=?, parking_type=?, htype=?, landlord_type=?, pet_ok=?, score=?, last_seen=?, missed=0, posted_at=?,\r\n url=case when ?<>'' then ? else url end, notes=?, license=?, license_detail=?, anomaly=?, drops=?, motivated=?,\r\n lat=coalesce(lat, ?), lon=coalesce(lon, ?)\r\n where rowid_pk=?`,\r\n args: [merged.price, merged.park, merged.type, merged.ll, merged.dog == null ? null : (merged.dog ? 1 : 0), newScore, now, postedAt,\r\n inp.url || \"\", inp.url || \"\", notes, fl.license, fl.licenseDetail, fl.anomaly ? 1 : 0, fl.drops, fl.motivated ? 1 : 0, inp.lat ?? null, inp.lon ?? null, rowid],\r\n });\r\n let pushed = false;\r\n if (opts.push && !existing.pushed && newScore >= threshold && merged.dog !== false && !stale && existing.status !== \"dead\" && !scamGateBlocks(fl.license, fl.anomaly)) {\r\n const lat = inp.lat ?? existing.lat, lon = inp.lon ?? existing.lon;\r\n const vb = await sqlite.execute({ sql: `select line from vibe where rowid_pk=?`, args: [rowid] });\r\n const vibe = vb.rows.length ? String((vb.rows[0] as any).line) : (await vibeForRow(rowid, lat, lon))?.line ?? null;\r\n pushed = await sendOrQueue({ ...inp, ...merged, id, rowid, score: newScore, addr: inp.addr || id, tier, ageDays: age, license: fl.license, licenseDetail: fl.licenseDetail, anomaly: fl.anomaly, trail: fl.trail, motivated: fl.motivated, lat, lon, notes, vibe });\r\n if (pushed) await sqlite.execute({ sql: `update listings set pushed=1 where rowid_pk=?`, args: [rowid] });\r\n }\r\n return { action: \"updated\", rowid, id, score: newScore, pushed };\r\n }\r\n\r\n const age = ageDays(postedIn, now, now);\r\n const stale = staleEligible && age > STALE_DAYS;\r\n const r = await sqlite.execute({\r\n sql: `insert into listings (id, address_norm, addr, unit, area, price, beds, source, external_id, url, parking_type, htype, pet_ok, landlord_type, score, first_seen, last_seen, status, missed, pushed, notes, lat, lon, raw, posted_at)\r\n values (?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,'new',0,0,?,?,?,?,?)`,\r\n args: [id, addrNorm, inp.addr || id, inp.unit || null, inp.area, inp.price, inp.beds, inp.source, inp.externalId || null, inp.url,\r\n inp.park, inp.type, inp.dog == null ? null : (inp.dog ? 1 : 0), inp.ll, sc, now, now, inp.notes || \"\", inp.lat ?? null, inp.lon ?? null, inp.raw ? inp.raw.slice(0, 20000) : null, postedIn],\r\n });\r\n const rowid = Number(r.lastInsertRowid);\r\n const fl = await flagsFor(rowid, addrNorm, inp.area, inp.addr, inp.price, inp.beds, age, inp.source);\r\n const notes = decorateNotes(inp.notes || \"\", { stale: stale ? age : null, license: fl.license, anomaly: fl.anomaly, lastDrop: fl.lastDrop, motivated: fl.motivated }, tier);\r\n await sqlite.execute({ sql: `update listings set notes=?, license=?, license_detail=?, anomaly=?, drops=?, motivated=? where rowid_pk=?`, args: [notes, fl.license, fl.licenseDetail, fl.anomaly ? 1 : 0, fl.drops, fl.motivated ? 1 : 0, rowid] });\r\n const vibe = (await vibeForRow(rowid, inp.lat, inp.lon))?.line ?? null; // sources with coordinates (Craigslist, add endpoint) get the vibe line immediately\r\n let pushed = false;\r\n if (opts.push && sc >= threshold && inp.dog !== false && !stale && !scamGateBlocks(fl.license, fl.anomaly)) { // never alert on a no-pets unit, a stale listing, or NO BBL + price anomaly\r\n pushed = await sendOrQueue({ ...inp, id, rowid, score: sc, addr: inp.addr || id, tier, ageDays: age, license: fl.license, licenseDetail: fl.licenseDetail, anomaly: fl.anomaly, trail: fl.trail, motivated: fl.motivated, notes, vibe });\r\n if (pushed) await sqlite.execute({ sql: `update listings set pushed=1 where rowid_pk=?`, args: [rowid] });\r\n }\r\n return { action: \"inserted\", rowid, id, score: sc, pushed };\r\n}\r\n\r\n// Part 3: quiet hours - pushes between 23:00 and 07:00 ET are queued and released by cron/enrich.ts after 07:00\r\nexport async function sendOrQueue(l: PushInput): Promise {\r\n if (isQuietHour()) { await queuePush(l.rowid ?? null, l); return true; } // counts as pushed so the row is not re-pushed at release\r\n return await pushDiscord(l);\r\n}\r\n\r\n// ---------- feed mapping ----------\r\nexport function rowToListing(row: any): Listing {\r\n return {\r\n id: row.id,\r\n addr: row.addr,\r\n area: row.area,\r\n price: row.price == null ? null : Number(row.price),\r\n beds: Number(row.beds),\r\n park: row.parking_type,\r\n type: row.htype,\r\n ll: row.landlord_type,\r\n dog: row.pet_ok == null ? null : !!row.pet_ok,\r\n url: row.url,\r\n src: row.source,\r\n note: [row.notes, row.score != null ? `score ${row.score}` : \"\"].filter(Boolean).join(\" | \"),\r\n fs: row.first_seen,\r\n lv: row.last_seen,\r\n status: row.status,\r\n missed: Number(row.missed || 0),\r\n };\r\n}\r\n\r\nexport async function activeListings(days = 45, kinds: \"listings\" | \"all\" = \"listings\", v = 1): Promise {\r\n const cutoff = new Date(Date.now() - days * 86400000).toISOString().slice(0, 10);\r\n const extra = kinds === \"all\" ? \"\" : ` and source not like 'signal-%' and source <> 'cl-parking'`;\r\n const r = await sqlite.execute({ sql: `select * from listings where last_seen >= ?${extra} order by score desc, last_seen desc`, args: [cutoff] });\r\n // v=2 adds age_days (today - coalesce(posted_at, first_seen)), posted_at, license, anomaly, price_trail, motivated, vibe;\r\n // v=1 keeps the tracker's exact 16-field contract\r\n if (v < 2) return (r.rows as any[]).map(rowToListing);\r\n const ids = (r.rows as any[]).map((row) => Number(row.rowid_pk));\r\n const trails = new Map();\r\n const vibes = new Map();\r\n if (ids.length) {\r\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 });\r\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)); }\r\n try {\r\n const vb = await sqlite.execute({ sql: `select * from vibe where rowid_pk in (${ids.map(() => \"?\").join(\",\")})`, args: ids });\r\n for (const x of vb.rows as any[]) vibes.set(Number(x.rowid_pk), x);\r\n } catch { /* vibe table not created yet */ }\r\n }\r\n return (r.rows as any[]).map((row) => {\r\n const k = Number(row.rowid_pk); const vb = vibes.get(k);\r\n return {\r\n ...rowToListing(row), age_days: ageDays(row.posted_at, row.first_seen), posted_at: row.posted_at ?? null,\r\n license: row.license ?? null, license_detail: row.license_detail ?? null, anomaly: !!row.anomaly,\r\n price_trail: trails.get(k) || (row.price != null ? [Number(row.price)] : []), motivated: !!row.motivated, drops: Number(row.drops || 0),\r\n lat: row.lat ?? null, lon: row.lon ?? null, gone_at: row.gone_at ?? null,\r\n vibe: vb ? { score: vb.vibe_score, strip: vb.strip, strip_mi: vb.strip_mi, strip_min: vb.strip_min, bars: vb.bars, eats: vb.eats, bar_names: vb.bar_names, metro: vb.metro, metro_mi: vb.metro_mi, dog_park: vb.dog_park, dog_mi: vb.dog_mi, grocery_mi: vb.grocery_mi, shirlington_min: vb.shirlington_min, line: vb.line } : null,\r\n } as any;\r\n });\r\n}\r\n\r\n// ---------- notify ----------\r\nexport type PushInput = {\r\n id: string; addr: string; area: string; price: number | null; beds: number; park: string; type: string; ll: string; dog: boolean | null;\r\n url: string; source: string; score: number; notes?: string; tier?: string | null; ageDays?: number; rowid?: number | null;\r\n license?: string | null; licenseDetail?: string | null; anomaly?: boolean; trail?: (number | null)[]; motivated?: boolean;\r\n lat?: number | null; lon?: number | null; vibe?: string | null;\r\n};\r\nexport const TRACKER_URL = \"https://logan1--c6cdcf92aef811f19dd21607ee4eb77e.web.val.run\";\r\nexport function actionLinks(l: { addr: string; lat?: number | null; lon?: number | null; id: string }): string {\r\n const q = encodeURIComponent(l.addr);\r\n const hasLL = l.lat != null && l.lon != null;\r\n const sat = hasLL ? `https://www.google.com/maps/@?api=1&map_action=map¢er=${l.lat},${l.lon}&zoom=20&basemap=satellite` : `https://www.google.com/maps/search/?api=1&query=${q}&basemap=satellite`;\r\n const pano = hasLL ? `https://www.google.com/maps/@?api=1&map_action=pano&viewpoint=${l.lat},${l.lon}` : `https://www.google.com/maps/search/?api=1&query=${q}`;\r\n const dlcp = `https://boss.dc.gov/homepage/business-license-search`; // DLCP BOSS Global Search (Salesforce SPA, no query param) - pick search type Address, paste the street address\r\n const photos = `https://www.google.com/search?q=${encodeURIComponent(`\"${l.addr}\"`)}`;\r\n const tok = Deno.env.get(\"HOUSING_TOKEN\") || \"\";\r\n const tracker = `${TRACKER_URL}/?token=${tok}#${encodeURIComponent(l.id)}`;\r\n return `[Satellite](${sat}) - [Street View](${pano}) - [DLCP licence](${dlcp}) - [Same photos elsewhere?](${photos}) - [Tracker](${tracker})`;\r\n}\r\nexport async function pushDiscord(l: PushInput, opts: { hookOverride?: string } = {}): Promise {\r\n const hook = opts.hookOverride || Deno.env.get(\"DISCORD_WEBHOOK_URL\");\r\n if (!hook) { console.warn(\"DISCORD_WEBHOOK_URL not set; skipping push for\", l.id); return false; }\r\n const bedsTxt = l.beds === 1.5 ? \"1BR+den\" : `${l.beds}BR`;\r\n const licTxt = l.license === \"no\" ? \":red_circle: NO\" : l.license === \"yes\" ? `yes${l.licenseDetail ? ` (${l.licenseDetail})` : \"\"}` : l.license === \"n/a\" ? \"n/a\" : \"unknown\";\r\n const trail = (l.trail || []).filter((p) => p != null);\r\n const priceTxt = l.price != null ? `$${l.price}` : \"unknown\";\r\n const fields: { name: string; value: string; inline?: boolean }[] = [\r\n { name: \"Price\", value: trail.length > 1 ? `${priceTxt}\\n${fmtTrail(trail)}` : priceTxt, inline: true },\r\n { name: \"Beds\", value: bedsTxt, inline: true },\r\n { name: \"Parking\", value: l.park, inline: true },\r\n { name: \"Type\", value: l.type, inline: true },\r\n { name: \"Landlord\", value: l.ll, inline: true },\r\n { name: \"Dog\", value: l.dog === true ? \"yes\" : l.dog === false ? \"NO\" : \"unknown\", inline: true },\r\n { name: \"Source\", value: l.source, inline: true },\r\n { name: \"Garage target\", value: l.tier ? `Tier ${l.tier}${l.tier === \"B\" ? \" - verify on satellite\" : \"\"}` : \"no\", inline: true },\r\n { name: \"Age\", value: `${l.ageDays != null ? `${l.ageDays}d` : \"?\"}${l.motivated ? \" - MOTIVATED\" : \"\"}`, inline: true },\r\n { name: \"License\", value: `${licTxt}${l.anomaly ? \" - PRICE ANOMALY\" : \"\"}`, inline: true },\r\n ];\r\n if (l.vibe) fields.push({ name: \"Vibe\", value: l.vibe, inline: false });\r\n fields.push({ name: \"Check\", value: actionLinks(l), inline: false });\r\n const body = {\r\n username: \"DC Housing\",\r\n content: `**Score ${l.score}** - ${l.addr} - ${l.price != null ? \"$\" + l.price : \"price?\"} - ${bedsTxt}`,\r\n embeds: [{\r\n title: `${l.addr} (${l.area})`,\r\n url: l.url,\r\n color: l.license === \"no\" ? 0xe74c3c : l.score >= 11 ? 0x2ecc71 : 0xf1c40f,\r\n fields,\r\n footer: { text: (l.notes || \"\").slice(0, 200) || \"Verify dog policy in writing. Scam gate before contact.\" },\r\n }],\r\n };\r\n try {\r\n const res = await fetch(hook, { method: \"POST\", headers: { \"content-type\": \"application/json\" }, body: JSON.stringify(body) });\r\n if (!res.ok) { console.error(\"discord push failed\", res.status, await res.text()); return false; }\r\n return true;\r\n } catch (e) { console.error(\"discord push error\", e); return false; }\r\n}\r\n// plain text message (quiet-hours batch header)\r\nexport async function discordText(content: string): Promise {\r\n const hook = Deno.env.get(\"DISCORD_WEBHOOK_URL\"); if (!hook) return false;\r\n const res = await fetch(hook, { method: \"POST\", headers: { \"content-type\": \"application/json\" }, body: JSON.stringify({ username: \"DC Housing\", content }) });\r\n return res.ok;\r\n}\r\n\r\n// ---------- misc ----------\r\nexport async function logPoll(job: string, ok: boolean, stats: { fetched?: number; inserted?: number; updated?: number; pushed?: number }, detail = \"\") {\r\n await sqlite.execute({\r\n sql: `insert into poll_log (ts, job, ok, fetched, inserted, updated, pushed, detail) values (?,?,?,?,?,?,?,?)`,\r\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)],\r\n });\r\n}\r\n\r\nexport function checkToken(req: Request): boolean {\r\n const expected = Deno.env.get(\"HOUSING_TOKEN\");\r\n if (!expected) return false;\r\n const url = new URL(req.url);\r\n const got = req.headers.get(\"x-housing-token\") || (req.headers.get(\"authorization\") || \"\").replace(/^Bearer\\s+/i, \"\") || url.searchParams.get(\"token\") || \"\";\r\n return got.length > 0 && got === expected;\r\n}\r\n\r\nexport const CORS = {\r\n \"access-control-allow-origin\": \"*\",\r\n \"access-control-allow-methods\": \"GET, POST, OPTIONS\",\r\n \"access-control-allow-headers\": \"content-type, x-housing-token, authorization\",\r\n};\r\nexport function json(data: unknown, status = 200, extra: Record = {}) {\r\n return new Response(JSON.stringify(data, null, 2), { status, headers: { \"content-type\": \"application/json\", ...CORS, ...extra } });\r\n}\r\nexport function decodeEntities(s: string): string {\r\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)));\r\n}\r\nexport function stripTags(s: string): string {\r\n return decodeEntities(s.replace(/|/gi, \"\").replace(/<[^>]+>/g, \" \")).replace(/\\s+/g, \" \").trim();\r\n}\r\nexport const UA = \"Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/128.0 Safari/537.36\";\r\nexport const sleep = (ms: number) => new Promise((r) => setTimeout(r, ms));\r\n","deleted",false,"label",[47,25],"lib","b7ccec7e-ebe9-4364-ba98-e367c8d8849b",["D",1789248987477],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","DC housing search pipeline","imageUrl","userId","87445237-7d14-45c7-b3a2-72e031f10ec1","pinnedFileId","0544e21c-aef2-11f1-a6f0-1607ee4eb77e","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","01a09786-a61b-74b5-8910-af3116d3de5c","tursoName","b7ccec7eebe94364ba98e367c8d8849b","tursoHostname","b7ccec7eebe94364ba98e367c8d8849b-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789519256886],"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",{"_38":92,"_11":93,"_23":31,"_94":48,"_95":-5,"_96":-5,"_97":-5,"_98":-5,"_99":-5,"_100":12,"_101":10},"isOwned",71,"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":35,"_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"]