\" sponsored posts in\r\n// the main stream. We poll both: the WP REST search (structured, full content) and\r\n// the category RSS (fallback). Only listings inside our seven areas are kept.\r\nimport {\r\n ensureSchema, upsertListing, logPoll, inferArea, inferPark, inferType, inferLL, inferDog, inferBeds, clampBeds,\r\n parsePrice, inferPrice, decodeEntities, stripTags, UA, PRICE_MIN, PRICE_MAX,\r\n} from \"../lib/core.ts\";\r\n\r\nconst REST = `https://www.popville.com/wp-json/wp/v2/posts?search=${encodeURIComponent('\"rental of the day\"')}&per_page=15&orderby=date&_fields=id,date,link,title,content`;\r\nconst RSS = \"https://www.popville.com/category/dc-rentals/feed/\";\r\n\r\ninterface Post { id: string; link: string; title: string; text: string; date: string }\r\n\r\nasync function fromRest(): Promise {\r\n const res = await fetch(REST, { headers: { \"user-agent\": UA, accept: \"application/json\" } });\r\n if (!res.ok) throw new Error(`rest http ${res.status}`);\r\n const arr = await res.json();\r\n return (arr as any[]).map((p) => ({\r\n id: String(p.id), link: p.link, title: decodeEntities(stripTags(p.title?.rendered || \"\")), text: stripTags(p.content?.rendered || \"\"), date: p.date,\r\n }));\r\n}\r\nasync function fromRss(): Promise {\r\n const res = await fetch(RSS, { headers: { \"user-agent\": UA } });\r\n if (!res.ok) throw new Error(`rss http ${res.status}`);\r\n const xml = await res.text();\r\n const items = [...xml.matchAll(/([\\s\\S]*?)<\\/item>/g)].map((m) => m[1]);\r\n const cd = (s: string) => s.replace(/^$/g, \"\");\r\n return items.map((it) => {\r\n const g = (tag: string) => cd(((it.match(new RegExp(`<${tag}[^>]*>([\\\\s\\\\S]*?)<\\\\/${tag}>`)) || [, \"\"])[1]).trim());\r\n const link = g(\"link\"); const guid = g(\"guid\");\r\n return { id: (guid.match(/p=(\\d+)/) || [, link])[1], link, title: decodeEntities(stripTags(g(\"title\"))), text: stripTags(g(\"content:encoded\") || g(\"description\")), date: g(\"pubDate\") };\r\n });\r\n}\r\n\r\n// \"Address: 1401 Columbia Rd NW Unit 319, Washington, DC, 20009 Neighborhood: Columbia Heights Type: 1 BR, 1 BA, condo ... Listed: $2,150\"\r\nexport function parsePost(p: Post) {\r\n const t = p.text;\r\n const addr = (t.match(/Address:\\s*(.+?)\\s+(?:Neighborhood|Type|Listed|Rent|Price|Noteworthy):/i) || [])[1]\r\n || (p.title.match(/Rental of the Day:\\s*(.+?)(?:,\\s*Washington)?$/i) || [])[1] || null;\r\n const hood = (t.match(/Neighborhood:\\s*(.+?)\\s+(?:Type|Listed|Rent|Price|Noteworthy):/i) || [])[1] || \"\";\r\n const typeLine = (t.match(/Type:\\s*(.+?)\\s+(?:Listed|Rent|Price|Noteworthy):/i) || [])[1] || \"\";\r\n const price = parsePrice((t.match(/(?:Listed|Rent|Price|Asking):\\s*\\$?\\s*([\\d,]{4,6})/i) || [])[1]) ?? inferPrice(t);\r\n return { addr: addr ? addr.replace(/,\\s*Washington,?\\s*DC,?\\s*(\\d{5})?$/i, \"\").trim() : null, hood, typeLine, price };\r\n}\r\n\r\nexport default async function () {\r\n await ensureSchema();\r\n const stats = { fetched: 0, inserted: 0, updated: 0, pushed: 0 };\r\n const notes: string[] = [];\r\n const posts = new Map();\r\n for (const src of [fromRest, fromRss]) {\r\n try { for (const p of await src()) if (!posts.has(p.id)) posts.set(p.id, p); }\r\n catch (e) { notes.push(`${src.name}: ${String(e).slice(0, 80)}`); }\r\n }\r\n stats.fetched = posts.size;\r\n\r\n const cutoff = Date.now() - 30 * 86400000;\r\n for (const p of posts.values()) {\r\n if (!/rental of the day|for rent|rental/i.test(p.title)) continue;\r\n const ts = Date.parse(p.date); if (Number.isFinite(ts) && ts < cutoff) continue; // dormant category feed still serves 2025 posts\r\n const parsed = parsePost(p);\r\n const all = [p.title, parsed.addr, parsed.hood, parsed.typeLine, p.text].filter(Boolean).join(\" \\n \");\r\n const area = inferArea(all);\r\n if (!area) continue; // outside our seven areas\r\n if (parsed.price != null && (parsed.price < PRICE_MIN - 100 || parsed.price > PRICE_MAX + 100)) continue;\r\n const bedsRaw = inferBeds(parsed.typeLine) ?? inferBeds(all);\r\n if (bedsRaw === 0) continue;\r\n const beds = clampBeds(bedsRaw);\r\n const type = (() => { const a = inferType(parsed.typeLine); return a !== \"unknown\" ? a : inferType(p.text); })();\r\n const r = await upsertListing({\r\n addr: parsed.addr, area, price: parsed.price, beds, source: \"popville\", externalId: p.id, url: p.link,\r\n park: inferPark(p.text), type, ll: inferLL(p.text, \"pm\"), dog: inferDog(p.text),\r\n notes: `PoPville: ${p.title}`.slice(0, 140) + (parsed.hood ? ` | ${parsed.hood}` : \"\"), raw: p.text.slice(0, 4000), postedAt: p.date || null,\r\n }, { push: true });\r\n if (r.action === \"inserted\") stats.inserted++; else stats.updated++;\r\n if (r.pushed) stats.pushed++;\r\n }\r\n const summary = `${posts.size} posts scanned. ${notes.join(\"; \")}`;\r\n await logPoll(\"popville\", true, stats, summary);\r\n console.log(\"popville\", stats, summary);\r\n return { ...stats, summary };\r\n}\r\n",[19,64],"0c95371c-41e6-4ef1-8f55-8ed66b49d47a","enrich.ts","e89d35e8-af77-11f1-8a84-1607ee4eb77e",68,["D",1789308595421],1,"// Enrichment cron (every 30 min). Steps, each logged to poll_log as enrich::\r\n// queue release quiet-hours pushes after 07:00 ET (\"Overnight: N listings\" + the individual embeds)\r\n// bbl weekly (Sunday) full-city BBL refresh, resumable 6 pages per run (bbl_offset in enrich_state)\r\n// license licence check for rows that still have license = null (new rows are flagged at upsert; this catches\r\n// rows inserted before the table existed and rows inserted while the table was mid-refresh)\r\n// price re-derive DROP/MOTIVATED flags for active rows (age-driven MOTIVATED changes without any new poll)\r\n// geocode Census batch geocoder (cap 200/run) + DC address-points fallback (Part 5)\r\n// vibe strip / bars / Metro / dog park / grocery distances + vibe_score for rows with coordinates (Part 5)\r\n// calibration Sunday 18:00 ET weekly report email (cron/calibration.ts)\r\n// Admin: ?job=enrich[&force=1][&step=queue|bbl|license|price|geocode|vibe]\r\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\r\nimport { ensureSchema, logPoll, pushDiscord, discordText, ageDays, today, decorateNotes, sleep } from \"../lib/core.ts\";\r\nimport { refreshBbl, getState, setState, licenseFor, p25For, isAnomaly, pendingQueue, markReleased, isQuietHour, etHour, priceTrail, trailStats, motivatedFlag } from \"../lib/enrich.ts\";\r\nimport { geocodeStep, vibeStep } from \"../lib/vibe.ts\";\r\nimport { sendCalibration } from \"../cron/calibration.ts\";\r\n\r\nconst TIME_BUDGET_MS = 40_000;\r\n\r\nexport async function releaseQueue(): Promise<{ released: number }> {\r\n if (isQuietHour()) return { released: 0 };\r\n const q = await pendingQueue();\r\n if (!q.length) return { released: 0 };\r\n await discordText(`**Overnight: ${q.length} listing${q.length === 1 ? \"\" : \"s\"}** queued between 23:00 and 07:00 ET`);\r\n const done: number[] = [];\r\n for (const item of q) {\r\n const ok = await pushDiscord(item.payload);\r\n if (ok) done.push(item.id);\r\n await sleep(400);\r\n }\r\n await markReleased(done);\r\n return { released: done.length };\r\n}\r\n\r\nasync function licenseStep(started: number): Promise<{ checked: number; yes: number; no: number }> {\r\n const out = { checked: 0, yes: 0, no: 0 };\r\n const rows = await sqlite.execute(`select rowid_pk, address_norm, area, addr, notes, posted_at, first_seen, anomaly, drops, motivated from listings\r\n where license is null and source not like 'signal-%' and source <> 'cl-parking' and status <> 'dead' order by score desc limit 300`);\r\n for (const r of rows.rows as any[]) {\r\n if (Date.now() - started > TIME_BUDGET_MS) break;\r\n const lic = await licenseFor(String(r.address_norm), String(r.area), r.addr);\r\n if (lic.license === \"unknown\" && !(await getState(\"bbl_refreshed\"))) continue; // table not loaded yet - leave null so we retry\r\n const age = ageDays(r.posted_at, r.first_seen);\r\n const notes = decorateNotes(String(r.notes || \"\"), { stale: age > 45 ? age : null, license: lic.license, anomaly: !!r.anomaly, motivated: !!r.motivated }, null);\r\n await sqlite.execute({ sql: `update listings set license=?, license_detail=?, notes=? where rowid_pk=?`, args: [lic.license, lic.detail, notes, r.rowid_pk] });\r\n out.checked++; if (lic.license === \"yes\") out.yes++; if (lic.license === \"no\") out.no++;\r\n }\r\n return out;\r\n}\r\n\r\n// re-derive age-driven flags (MOTIVATED at 25 d with a drop / 40 d) and the anomaly flag for active rows\r\nasync function priceStep(started: number): Promise<{ rows: number; motivated: number; anomaly: number }> {\r\n const out = { rows: 0, motivated: 0, anomaly: 0 };\r\n const rows = await sqlite.execute(`select rowid_pk, area, beds, price, notes, posted_at, first_seen, license, drops, motivated, anomaly, address_norm from listings\r\n where status <> 'dead' and last_seen >= date('now','-14 day') and source not like 'signal-%' and source <> 'cl-parking' and score >= 4`);\r\n const p25Cache = new Map();\r\n for (const r of rows.rows as any[]) {\r\n if (Date.now() - started > TIME_BUDGET_MS) break;\r\n const age = ageDays(r.posted_at, r.first_seen);\r\n const trail = await priceTrail(Number(r.rowid_pk));\r\n if (!trail.length && r.price != null) { await sqlite.execute({ sql: `insert into price_history (rowid_pk, price, seen) values (?,?,?)`, args: [r.rowid_pk, r.price, r.first_seen] }); trail.push(Number(r.price)); }\r\n const ts = trailStats(trail);\r\n const motivated = motivatedFlag(ts.drops, age);\r\n const key = `${r.area}|${r.beds}`;\r\n if (!p25Cache.has(key)) p25Cache.set(key, (await p25For(String(r.area), Number(r.beds))).p25);\r\n const anomaly = isAnomaly(r.price == null ? null : Number(r.price), p25Cache.get(key) ?? null);\r\n const tierM = String(r.notes || \"\").match(/\\bTARGET ([ABC])\\b/);\r\n const notes = decorateNotes(String(r.notes || \"\"), { stale: age > 45 ? age : null, license: r.license, anomaly, lastDrop: ts.lastDrop, motivated }, tierM ? tierM[1] : null);\r\n if (notes !== r.notes || motivated !== !!r.motivated || anomaly !== !!r.anomaly || ts.drops !== Number(r.drops)) {\r\n await sqlite.execute({ sql: `update listings set notes=?, drops=?, motivated=?, anomaly=? where rowid_pk=?`, args: [notes, ts.drops, motivated ? 1 : 0, anomaly ? 1 : 0, r.rowid_pk] });\r\n }\r\n out.rows++; if (motivated) out.motivated++; if (anomaly) out.anomaly++;\r\n }\r\n return out;\r\n}\r\n\r\nexport default async function run(opts: { force?: boolean; step?: string } = {}) {\r\n const started = Date.now();\r\n await ensureSchema();\r\n const results: Record = {};\r\n const want = (s: string) => !opts.step || opts.step === s;\r\n const step = async (name: string, fn: () => Promise) => {\r\n if (!want(name)) return;\r\n try { const r = await fn(); results[name] = r; await logPoll(`enrich:${name}`, true, {}, JSON.stringify(r).slice(0, 500)); }\r\n catch (e) { results[name] = { error: String(e).slice(0, 200) }; await logPoll(`enrich:${name}`, false, {}, String(e).slice(0, 500)); }\r\n };\r\n await step(\"queue\", releaseQueue);\r\n await step(\"bbl\", async () => {\r\n const refreshed = await getState(\"bbl_refreshed\"); const inProgress = await getState(\"bbl_offset\");\r\n const isSunday = new Intl.DateTimeFormat(\"en-US\", { timeZone: \"America/New_York\", weekday: \"short\" }).format(new Date()) === \"Sun\";\r\n const due = opts.force || !refreshed || inProgress || (isSunday && refreshed < today() && etHour(new Date()) < 8);\r\n if (!due) return { skipped: `refreshed ${refreshed}` };\r\n return await refreshBbl(6);\r\n });\r\n if (Date.now() - started < TIME_BUDGET_MS) await step(\"license\", () => licenseStep(started));\r\n if (Date.now() - started < TIME_BUDGET_MS) await step(\"price\", () => priceStep(started));\r\n if (Date.now() - started < TIME_BUDGET_MS) await step(\"geocode\", () => geocodeStep(started, TIME_BUDGET_MS));\r\n if (Date.now() - started < TIME_BUDGET_MS) await step(\"vibe\", () => vibeStep(started, TIME_BUDGET_MS));\r\n // weekly calibration email: Sunday 18:00-18:29 ET (this cron runs every 30 min), once per week (enrich_state.calibration_sent)\r\n await step(\"calibration\", async () => {\r\n const now = new Date();\r\n const et = new Intl.DateTimeFormat(\"en-US\", { timeZone: \"America/New_York\", weekday: \"short\", hour: \"numeric\", minute: \"numeric\", hour12: false }).formatToParts(now);\r\n const part = (t: string) => et.find((p) => p.type === t)?.value || \"\";\r\n const due = opts.force || (part(\"weekday\") === \"Sun\" && Number(part(\"hour\")) === 18 && Number(part(\"minute\")) < 30);\r\n const last = await getState(\"calibration_sent\");\r\n if (!due || last === today()) return { skipped: last === today() ? `sent ${last}` : \"not Sunday 18:00 ET\" };\r\n const r = await sendCalibration(); await setState(\"calibration_sent\", today()); return r;\r\n });\r\n const summary = { seconds: Math.round((Date.now() - started) / 1000), results };\r\n console.log(\"enrich\", JSON.stringify(summary).slice(0, 1500));\r\n return summary;\r\n}\r\n",[19,72],"6705c675-c235-4ab7-94be-78970ad157a2","digest.ts","0825d9a0-aef2-11f1-895b-1607ee4eb77e",65,["D",1789308410810],4,"// Daily digest email (cron). Schedule as `0 12,13 * * *` (UTC) - the handler only\r\n// sends when it is 8 AM in America/New_York, so EDT/EST both land at 8:00 ET.\r\n// Pass force=true (admin endpoint) to send regardless of the hour.\r\nimport { email } from \"https://esm.town/v/std/email\";\r\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\r\nimport { ensureSchema, logPoll, rowToListing } from \"../lib/core.ts\";\r\n\r\nfunction etHour(d = new Date()): number {\r\n return Number(new Intl.DateTimeFormat(\"en-US\", { timeZone: \"America/New_York\", hour: \"numeric\", hour12: false }).format(d));\r\n}\r\nconst vibeLines = new Map(); // rowid -> vibe line (Part 5), filled per digest run\r\nconst fmt = (l: any) => {\r\n const beds = l.beds === 1.5 ? \"1BR+den\" : `${l.beds}BR`;\r\n const vibe = l.rowid_pk != null && vibeLines.has(Number(l.rowid_pk)) ? `\\n ${vibeLines.get(Number(l.rowid_pk))}` : \"\";\r\n const flags = [l.park !== \"unknown\" ? l.park : \"\", l.type !== \"unknown\" ? l.type : \"\", l.ll !== \"unknown\" ? l.ll : \"\", l.dog === true ? \"dog OK\" : l.dog === false ? \"NO DOG\" : \"\"].filter(Boolean).join(\", \");\r\n return `[${String(l.score).padStart(2)}] ${l.price != null ? \"$\" + l.price : \"$????\"} ${beds} ${l.addr} (${l.area}) ${flags}${vibe}\\n ${l.url}`;\r\n};\r\n\r\nexport async function sendDigest(force = false) {\r\n await ensureSchema();\r\n if (!force && etHour() !== 8) { console.log(\"digest: not 8 AM ET, skipping\"); return { skipped: true }; }\r\n const since = new Date(Date.now() - 24 * 3600 * 1000).toISOString().slice(0, 10);\r\n const NOT_SIGNAL = `source not like 'signal-%' and source <> 'cl-parking'`;\r\n const newRows = await sqlite.execute({ sql: `select *, score from listings where first_seen >= ? and ${NOT_SIGNAL} order by score desc, price asc`, args: [since] });\r\n const week = new Date(Date.now() - 7 * 86400000).toISOString().slice(0, 10);\r\n const parking = await sqlite.execute({ sql: `select * from listings where source='cl-parking' and first_seen >= ? order by price asc limit 12`, args: [week] });\r\n const signals = await sqlite.execute({ sql: `select * from listings where source like 'signal-%' and first_seen >= ? order by first_seen desc limit 20`, args: [week] });\r\n await sqlite.execute(`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)`);\r\n const health = await sqlite.execute(`select source, fail_count, last_ok, last_run from source_state order by fail_count desc, source`);\r\n const staleRows = await sqlite.execute(`select rowid_pk, addr, price, url, score, posted_at, first_seen, motivated, drops, cast(julianday('now') - julianday(coalesce(posted_at, first_seen)) as integer) age_days from listings where score >= 6 and status not in ('dead') and last_seen >= date('now','-14 day') and ${NOT_SIGNAL} and (motivated = 1 or drops > 0 or julianday('now') - julianday(coalesce(posted_at, first_seen)) >= 25) order by motivated desc, drops desc, age_days desc limit 15`);\r\n const trailFor = async (rowid: number) => { const t = await sqlite.execute({ sql: `select price from price_history where rowid_pk=? order by id`, args: [rowid] }); return (t.rows as any[]).map((x) => x.price == null ? \"$?\" : \"$\" + Number(x.price).toLocaleString(\"en-US\")).join(\" -> \"); };\r\n const scamRows = await sqlite.execute(`select addr, price, url, score, license, anomaly, notes from listings where status not in ('dead') and last_seen >= date('now','-14 day') and ${NOT_SIGNAL} and (license = 'no' or anomaly = 1) order by (license='no' and anomaly=1) desc, score desc limit 20`);\r\n const hot = await sqlite.execute({ sql: `select *, score from listings where score >= 8 and status not in ('dead') and last_seen >= date('now','-14 day') and ${NOT_SIGNAL} order by score desc, first_seen desc limit 15` });\r\n const gone = await sqlite.execute({ sql: `select * from listings where missed >= 3 and status not in ('dead','new') order by missed desc limit 10` });\r\n const counts = await sqlite.execute(`select count(*) total, sum(first_seen >= date('now','-1 day')) new24, sum(score>=8) hot, sum(status='dead') dead from listings`);\r\n const polls = await sqlite.execute(`select job, count(*) n, sum(ok) ok, sum(inserted) ins, max(ts) last from poll_log where ts >= datetime('now','-1 day') group by job`);\r\n\r\n try { const vl = await sqlite.execute(`select rowid_pk, line from vibe`); vibeLines.clear(); for (const r of vl.rows as any[]) vibeLines.set(Number(r.rowid_pk), String(r.line)); } catch { /* vibe table not yet created */ }\r\n const c: any = counts.rows[0] || {};\r\n const lines: string[] = [];\r\n lines.push(`DC HOUSING DIGEST - ${new Date().toLocaleDateString(\"en-US\", { timeZone: \"America/New_York\", weekday: \"short\", month: \"short\", day: \"numeric\" })}`);\r\n const hs = health.rows as any[];\r\n const failing = hs.filter((r) => Number(r.fail_count) >= 1);\r\n const stale = hs.filter((r) => Number(r.fail_count) >= 3);\r\n lines.push(`Tracked ${c.total ?? 0} | new 24h ${c.new24 ?? 0} | score>=8 ${c.hot ?? 0} | dead ${c.dead ?? 0}`);\r\n lines.push(`Sources: ${hs.length - failing.length} ok / ${failing.length} failing${stale.length ? ` - 3+ consecutive failures: ${stale.map((r) => r.source).join(\", \")}` : \"\"}`);\r\n lines.push(\"\");\r\n lines.push(`NEW IN LAST 24H (${newRows.rows.length})`);\r\n lines.push(newRows.rows.length ? (newRows.rows as any[]).map((r) => fmt({ ...rowToListing(r), score: r.score, rowid_pk: r.rowid_pk })).join(\"\\n\") : \" none\");\r\n lines.push(\"\");\r\n lines.push(`ACTIVE SCORE >= 8 (${hot.rows.length})`);\r\n lines.push(hot.rows.length ? (hot.rows as any[]).map((r) => fmt({ ...rowToListing(r), score: r.score, rowid_pk: r.rowid_pk })).join(\"\\n\") : \" none\");\r\n if (gone.rows.length) {\r\n lines.push(\"\"); lines.push(\"IN-PROGRESS LISTINGS NO LONGER APPEARING (follow up: 'if it falls through')\");\r\n lines.push((gone.rows as any[]).map((r) => ` ${r.addr} - ${r.status}, missed ${r.missed} polls - ${r.url}`).join(\"\\n\"));\r\n }\r\n if (staleRows.rows.length) {\r\n lines.push(\"\"); lines.push(`NEGOTIATION TARGETS - MOTIVATED first, then price drops, then 25+ days (offer asking minus $100-150 or ask for parking)`);\r\n const out: string[] = [];\r\n for (const r of staleRows.rows as any[]) {\r\n const trail = Number(r.drops) > 0 ? await trailFor(Number(r.rowid_pk)) : \"\";\r\n out.push(` [${String(r.score).padStart(2)}] ${r.price != null ? \"$\" + r.price : \"$????\"} ${r.age_days}d${r.posted_at ? \"\" : \" (since first seen)\"}${r.motivated ? \" MOTIVATED\" : \"\"}${trail ? \" \" + trail : \"\"} ${r.addr}\\n ${r.url}`);\r\n }\r\n lines.push(out.join(\"\\n\"));\r\n }\r\n if (scamRows.rows.length) {\r\n lines.push(\"\"); lines.push(`SCAM-GATE FLAGS (NO BBL = no active DC rental licence at that street number; PRICE ANOMALY = under 80% of the area P25; both = not pushed)`);\r\n lines.push((scamRows.rows as any[]).map((r) => ` [${String(r.score).padStart(2)}] ${r.price != null ? \"$\" + r.price : \"$????\"} ${[r.license === \"no\" ? \"NO BBL\" : \"\", r.anomaly ? \"PRICE ANOMALY\" : \"\"].filter(Boolean).join(\" + \")} ${r.addr}\\n ${r.url}`).join(\"\\n\"));\r\n }\r\n if (parking.rows.length) {\r\n lines.push(\"\"); lines.push(`GARAGE-ONLY RENTALS (Craigslist parking, last 7 days) - decouple the garage from the lease`);\r\n lines.push((parking.rows as any[]).map((r) => ` ${r.price != null ? \"$\" + r.price + \"/mo\" : \"$?\"} ${r.notes.replace(/^garage-only: /, \"\")}\\n ${r.url}`).join(\"\\n\"));\r\n }\r\n if (signals.rows.length) {\r\n lines.push(\"\"); lines.push(`COMING SOON SIGNALS (new licenses / CofO / permits, last 7 days) - landlords about to list`);\r\n lines.push((signals.rows as any[]).map((r) => ` ${r.addr} (${r.area}) - ${r.notes.replace(/^SIGNAL /, \"\")}`).join(\"\\n\"));\r\n }\r\n lines.push(\"\"); lines.push(\"PIPELINE (24h)\");\r\n lines.push(polls.rows.length ? (polls.rows as any[]).map((p) => ` ${p.job}: ${p.ok}/${p.n} ok, ${p.ins} inserted, last ${String(p.last).slice(0, 16)}Z`).join(\"\\n\") : \" no polls logged - check cron schedules\");\r\n lines.push(\"\"); lines.push(\"Rules: written dog OK before any fee. Scam gate (DLCP license, reverse image, no wire/Zelle) before contact.\");\r\n\r\n const text = lines.join(\"\\n\");\r\n const subject = `Housing digest: ${newRows.rows.length} new, ${hot.rows.length} hot`;\r\n await email({ subject, text });\r\n await logPoll(\"digest\", true, { fetched: newRows.rows.length }, subject);\r\n console.log(\"digest sent:\", subject);\r\n return { sent: true, subject, text };\r\n}\r\n\r\nexport default async function () {\r\n return await sendDigest(false);\r\n}\r\n",[19,80],"225fc9c3-90e6-4912-96d9-200130fda262","craigslist.ts","07013416-aef2-11f1-8bc7-1607ee4eb77e",39,["D",1789302859020],"// Craigslist poller (cron, every 25 min). Public search URLs, no login.\r\n// Parses the static

markup, fetches detail\r\n// pages only for posts not already in the DB, inserts + dedupes + scores, pushes\r\n// on score >= 8, and maintains the `missed` counter for CL listings.\r\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\r\nimport {\r\n ensureSchema, upsertListing, logPoll, inferArea, inferPark, inferType, inferLL, inferDog, inferBeds, clampBeds,\r\n parsePrice, decodeEntities, stripTags, today, UA, sleep, PRICE_MIN, PRICE_MAX, type Area,\r\n} from \"../lib/core.ts\";\r\n\r\nconst QUERIES: { q: string; area: Area }[] = [\r\n { q: \"petworth\", area: \"Petworth\" },\r\n { q: \"brightwood\", area: \"Brightwood\" },\r\n { q: \"16th street heights\", area: \"Park View / 16th St Hts\" },\r\n { q: \"park view\", area: \"Park View / 16th St Hts\" },\r\n { q: \"shirlington\", area: \"Fairlington / Shirlington\" },\r\n { q: \"fairlington\", area: \"Fairlington / Shirlington\" },\r\n { q: \"columbia pike\", area: \"Columbia Pike\" },\r\n { q: \"del ray\", area: \"Del Ray\" },\r\n { q: \"arlandria\", area: \"Del Ray\" },\r\n { q: \"hyattsville\", area: \"Hyattsville\" },\r\n];\r\nconst SEARCH_BASE = \"https://washingtondc.craigslist.org/search/apa\";\r\nconst TIME_BUDGET_MS = 45_000;\r\nconst MAX_DETAILS_PER_RUN = 25;\r\nconst SEARCH_DELAY_MS = 400;\r\nconst DETAIL_DELAY_MS = 700;\r\n\r\ninterface SearchHit { extId: string; url: string; title: string; price: number | null; location: string; area: Area }\r\n\r\nasync function fetchText(url: string): Promise<{ status: number; text: string }> {\r\n const res = await fetch(url, { headers: { \"user-agent\": UA, \"accept\": \"text/html,application/xhtml+xml\", \"accept-language\": \"en-US,en;q=0.9\" } });\r\n return { status: res.status, text: res.ok ? await res.text() : \"\" };\r\n}\r\n\r\nexport function parseSearch(html: string, area: Area): SearchHit[] {\r\n const out: SearchHit[] = [];\r\n const re = /

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

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

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

([\\s\\S]*?)<\\/div>/) || [, \"\"])[1]).replace(/\\s+/g, \" \").trim();\r\n out.push({ extId, url: href, title, price, location, area });\r\n }\r\n return out;\r\n}\r\n\r\nexport function parseDetail(html: string) {\r\n const g = (re: RegExp) => (html.match(re) || [])[1];\r\n const title = decodeEntities(g(/([\\s\\S]*?)<\\/span>/) || \"\").trim();\r\n const price = parsePrice(g(/([\\s\\S]*?)<\\/span>/));\r\n // the mapaddress div holds the street address as text; posts without one carry only a \"google map\" link\r\n const rawAddr = stripTags(g(/class=\"mapaddress\">([\\s\\S]*?)<\\/div>/) || \"\").replace(/\\bgoogle map\\b/i, \"\").replace(/\\s+/g, \" \").trim();\r\n const mapaddress = /\\d/.test(rawAddr) && /[a-z]/i.test(rawAddr) ? rawAddr : null; // need a house number and a street\r\n const lat = g(/data-latitude=\"([^\"]+)\"/); const lon = g(/data-longitude=\"([^\"]+)\"/);\r\n const attrs = [...html.matchAll(/\\s*(?:]*>)?([\\s\\S]*?)(?:<\\/a>)?\\s*<\\/span>/g)].map((x) => stripTags(x[1]).toLowerCase());\r\n const bedsAttr = g(/\\s*([\\s\\S]*?)\\s*<\\/span>/);\r\n const body = stripTags((g(/

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

\\s*<\\/div>/, \"\"));\r\n const posted = g(/();\r\n\r\n // 1) search pages\r\n for (const { q, area } of QUERIES) {\r\n const url = `${SEARCH_BASE}?query=${encodeURIComponent(q)}&min_price=${PRICE_MIN}&max_price=${PRICE_MAX}`;\r\n try {\r\n const { status, text } = await fetchText(url);\r\n if (status !== 200 || !text.includes(\"cl-static-search-result\")) {\r\n failedQueries++; notes.push(`search \"${q}\" http ${status} (${text.length}b)`);\r\n } else {\r\n const hits = parseSearch(text, area);\r\n stats.fetched += hits.length;\r\n for (const h of hits) if (!seen.has(h.extId)) seen.set(h.extId, h);\r\n }\r\n } catch (e) { failedQueries++; notes.push(`search \"${q}\" error ${String(e).slice(0, 80)}`); }\r\n await sleep(SEARCH_DELAY_MS);\r\n }\r\n\r\n // 2) which hits are already known?\r\n const ids = [...seen.keys()];\r\n const known = new Set();\r\n const skipped = new Set(); // studios / out-of-band posts we already looked at\r\n const skip = (id: string, reason: string) => sqlite.execute({ sql: `insert or replace into skips (source, external_id, reason, ts) values ('craigslist', ?, ?, ?)`, args: [id, reason, new Date().toISOString()] });\r\n for (let i = 0; i < ids.length; i += 50) {\r\n const chunk = ids.slice(i, i + 50);\r\n const ph = chunk.map(() => \"?\").join(\",\");\r\n const r = await sqlite.execute({ sql: `select external_id from listings where source='craigslist' and external_id in (${ph})`, args: chunk });\r\n for (const row of r.rows as any[]) known.add(String(row.external_id));\r\n const sk = await sqlite.execute({ sql: `select external_id from skips where source='craigslist' and external_id in (${ph})`, args: chunk });\r\n for (const row of sk.rows as any[]) skipped.add(String(row.external_id));\r\n }\r\n // refresh known ones (seen again -> last_seen today, missed 0, price tracks)\r\n const now = today();\r\n for (const id of known) {\r\n const h = seen.get(id)!;\r\n await sqlite.execute({ sql: `update listings set last_seen=?, missed=0, price=coalesce(?, price) where source='craigslist' and external_id=?`, args: [now, h.price, id] });\r\n }\r\n\r\n // 3) detail-fetch the new ones (polite, capped, time-budgeted)\r\n let details = 0;\r\n for (const id of ids) {\r\n if (known.has(id) || skipped.has(id)) continue;\r\n if (details >= MAX_DETAILS_PER_RUN || Date.now() - started > TIME_BUDGET_MS) { notes.push(\"detail cap/time budget hit; remainder next poll\"); break; }\r\n const h = seen.get(id)!;\r\n details++;\r\n try {\r\n const { status, text } = await fetchText(h.url);\r\n if (status !== 200 || !text.includes(\"postingbody\")) { notes.push(`detail ${id} http ${status}`); await sleep(DETAIL_DELAY_MS); continue; }\r\n const d = parseDetail(text);\r\n const allText = [d.title, h.location, d.mapaddress, d.attrs.join(\" | \"), d.body].filter(Boolean).join(\" \\n \");\r\n const bedsRaw = inferBeds(d.bedsAttr || \"\") ?? inferBeds(allText);\r\n if (bedsRaw === 0) { await skip(id, \"studio\"); notes.push(`skip studio ${id}`); await sleep(DETAIL_DELAY_MS); continue; }\r\n let beds = clampBeds(bedsRaw);\r\n if (beds === 1 && /\\bden\\b|bonus room|\\boffice\\b/i.test(d.body)) beds = 1.5;\r\n const price = d.price ?? h.price;\r\n if (price != null && (price < PRICE_MIN - 100 || price > PRICE_MAX + 100)) { await skip(id, `price ${price}`); await sleep(DETAIL_DELAY_MS); continue; }\r\n\r\n // CL structured attrs take precedence over free-text inference\r\n let park = inferPark(d.attrs.join(\" \")); if (park === \"unknown\") park = inferPark(d.body);\r\n let type = inferType(d.attrs.join(\" \"));\r\n if (type === \"unknown\" || type === \"apartment\" || type === \"house\") { const t2 = inferType(d.body); if (t2 === \"basement\" || t2 === \"rowhouse\") type = t2; else if (type === \"unknown\") type = t2; }\r\n const dogAttr = d.attrs.some((a) => /dogs are ok/.test(a)) ? true : null;\r\n const dog = dogAttr ?? inferDog(d.body);\r\n const ll = inferLL(allText, \"individual\"); // Craigslist source counts as an individual-landlord signal\r\n const area = inferArea(allText, d.lat, d.lon, h.area)!;\r\n const noteBits = [`CL: ${d.title}`.slice(0, 120), h.location && !d.mapaddress ? `loc: ${h.location}` : \"\", d.posted ? `posted ${d.posted.slice(0, 10)}` : \"\"].filter(Boolean);\r\n\r\n const r = await upsertListing({\r\n addr: d.mapaddress, area, price, beds, source: \"craigslist\", externalId: id, url: h.url,\r\n park, type, ll, dog, notes: noteBits.join(\" | \"), lat: d.lat, lon: d.lon, raw: d.body.slice(0, 4000), postedAt: d.posted || null,\r\n }, { push: true });\r\n if (r.action === \"inserted\") stats.inserted++; else stats.updated++;\r\n if (r.pushed) stats.pushed++;\r\n } catch (e) { notes.push(`detail ${id} error ${String(e).slice(0, 80)}`); }\r\n await sleep(DETAIL_DELAY_MS);\r\n }\r\n\r\n // 4) missed counter: only when every search succeeded, so a CL block doesn't look like delistings\r\n if (failedQueries === 0 && ids.length > 0) {\r\n const cutoff = new Date(Date.now() - 45 * 86400000).toISOString().slice(0, 10);\r\n const r = await sqlite.execute({ sql: `select rowid_pk, external_id from listings where source='craigslist' and status<>'dead' and last_seen>=?`, args: [cutoff] });\r\n const missedIds = (r.rows as any[]).filter((row) => !seen.has(String(row.external_id))).map((row) => row.rowid_pk);\r\n await sqlite.execute({ sql: `delete from skips where source='craigslist' and ts < ?`, args: [new Date(Date.now() - 60 * 86400000).toISOString()] }); // let old skips age out\r\n for (let i = 0; i < missedIds.length; i += 50) {\r\n const chunk = missedIds.slice(i, i + 50);\r\n await sqlite.execute({ sql: `update listings set missed=missed+1 where rowid_pk in (${chunk.map(() => \"?\").join(\",\")})`, args: chunk });\r\n }\r\n }\r\n\r\n const summary = `${ids.length} unique hits, ${known.size} known, ${skipped.size} skipped, ${details} detail fetches, ${failedQueries} failed queries, ${Math.round((Date.now() - started) / 1000)}s. ${notes.join(\"; \")}`;\r\n await logPoll(\"craigslist\", failedQueries < QUERIES.length, stats, summary);\r\n console.log(\"craigslist\", stats, summary);\r\n return { ...stats, summary };\r\n}\r\n",[19,88],"017f86ea-b754-4874-bc78-ae51d294917e","calibration.ts","c7f3415c-af7c-11f1-98c5-1607ee4eb77e",67,["D",1789308589025],0,"script","// Weekly calibration report (Part 6). Markdown over the last 7/90 days: price medians by area x beds x parking,\n// days-on-market, source yield funnel, pushes per day, scam-gate counts, vibe distribution, and a push-threshold\n// recommendation. Admin: ?job=calibration[&email=1]; cron/enrich.ts emails it Sundays 18:00 ET. The weekly-review\n// scheduled task saves the markdown to phase3/calibration/YYYY-MM-DD.md.\nimport { email } from \"https://esm.town/v/std/email\";\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { ensureSchema, logPoll, PUSH_THRESHOLD, today } from \"../lib/core.ts\";\nimport { p25 } from \"../lib/enrich.ts\";\n\nconst NOT_SIGNAL = `source not like 'signal-%' and source <> 'cl-parking'`;\nconst median = (v: number[]) => { const s = [...v].sort((a, b) => a - b); return s.length ? (s.length % 2 ? s[(s.length - 1) / 2] : (s[s.length / 2 - 1] + s[s.length / 2]) / 2) : null; };\nconst q = async (sql: string, args: any[] = []) => (await sqlite.execute({ sql, args })).rows as any[];\nconst money = (n: number | null) => n == null ? \"-\" : `$${Math.round(n).toLocaleString(\"en-US\")}`;\nconst table = (head: string[], rows: (string | number | null)[][]) => [`| ${head.join(\" | \")} |`, `|${head.map(() => \"---\").join(\"|\")}|`, ...rows.map((r) => `| ${r.map((x) => x == null ? \"-\" : String(x)).join(\" | \")} |`)].join(\"\\n\");\n\nexport async function calibrationReport(): Promise<{ markdown: string; pushesPerDay: number; recommendation: string }> {\n await ensureSchema();\n const since90 = new Date(Date.now() - 90 * 86400000).toISOString().slice(0, 10);\n const since7 = new Date(Date.now() - 7 * 86400000).toISOString().slice(0, 10);\n const L: string[] = [`# Housing calibration - ${today()}`, \"\", `Window: prices/DOM last 90 days (since ${since90}), activity last 7 days (since ${since7}). Fit score rules unchanged (max 13, push at ${PUSH_THRESHOLD}).`, \"\"];\n\n // 1. price by area x beds x parking bucket\n const px = await q(`select area, beds, case when parking_type in ('garage','offstreet') then 'off-street' else 'street/unknown' end park, price from listings where price is not null and first_seen >= ? and ${NOT_SIGNAL}`, [since90]);\n const groups = new Map();\n for (const r of px) { const k = `${r.area}|${r.beds}|${r.park}`; (groups.get(k) || groups.set(k, []).get(k)!).push(Number(r.price)); }\n const prow = [...groups.entries()].sort().map(([k, v]) => { const [area, beds, park] = k.split(\"|\"); return [area, beds === \"1.5\" ? \"1+den\" : beds, park, v.length, money(median(v)), money(p25(v))]; });\n L.push(\"## Price by area x beds x parking (asking, listings seen in window)\", \"\", table([\"Area\", \"Beds\", \"Parking\", \"n\", \"Median\", \"P25\"], prow), \"\");\n\n // 2. days on market by area (gone/dead rows: posted_at|first_seen -> gone_at|last_seen; active rows: age so far)\n const dom = await q(`select area, status, gone_at, posted_at, first_seen, last_seen from listings where ${NOT_SIGNAL} and first_seen >= ?`, [since90]);\n const domBy = new Map();\n for (const r of dom) {\n const start = Date.parse(String(r.posted_at || r.first_seen)); const g = domBy.get(r.area) || domBy.set(r.area, { gone: [], active: [] }).get(r.area)!;\n if (r.status === \"dead\" || r.gone_at) g.gone.push(Math.round((Date.parse(String(r.gone_at || r.last_seen)) - start) / 86400000));\n else g.active.push(Math.round((Date.now() - start) / 86400000));\n }\n L.push(\"## Days on market by area\", \"\", table([\"Area\", \"Gone (n)\", \"Gone median d\", \"Gone P25 d\", \"Active (n)\", \"Active median age d\"],\n [...domBy.entries()].sort().map(([a, g]) => [a, g.gone.length, median(g.gone) ?? \"-\", p25(g.gone) ?? \"-\", g.active.length, median(g.active) ?? \"-\"])), \"\");\n\n // 3. source yield funnel\n const funnel = await q(`select source, count(*) inserted, sum(score >= ${PUSH_THRESHOLD}) hot, sum(pushed) pushed, sum(status in ('contacted','touring','applied')) acted, sum(status='dead') dead, sum(license='no') nobbl from listings where ${NOT_SIGNAL} group by source order by inserted desc`);\n L.push(\"## Source yield funnel (all time)\", \"\", table([\"Source\", \"Inserted\", `Score >= ${PUSH_THRESHOLD}`, \"Pushed\", \"Status changed by Logan\", \"Dead\", \"NO BBL\"],\n funnel.map((r) => [r.source, r.inserted, r.hot, r.pushed, r.acted, r.dead, r.nobbl])), \"\");\n\n // 4. pushes per day (poll_log pushed counts + quiet-hours queue)\n const ppd = await q(`select substr(ts,1,10) day, sum(pushed) pushed from poll_log where ts >= ? group by day order by day`, [since7]);\n const totalPushed = ppd.reduce((a, r) => a + Number(r.pushed || 0), 0);\n const days = Math.max(1, ppd.length);\n const pushesPerDay = Math.round((totalPushed / 7) * 100) / 100;\n L.push(\"## Pushes per day (last 7 days)\", \"\", table([\"Day\", \"Pushed\"], ppd.map((r) => [r.day, r.pushed])), \"\", `Total ${totalPushed} over 7 days = **${pushesPerDay}/day** (${days} days with polls logged).`, \"\");\n\n // 5. scam-gate flags\n const scam = await q(`select coalesce(license,'null') license, count(*) n, sum(anomaly) anomaly, sum(license='no' and anomaly=1) both_flags from listings where ${NOT_SIGNAL} and status <> 'dead' group by license`);\n L.push(\"## Scam-gate flags (active rows)\", \"\", table([\"License\", \"n\", \"Price anomaly\", \"NO BBL + anomaly (suppressed)\"], scam.map((r) => [r.license, r.n, r.anomaly, r.both_flags])), \"\");\n\n // 6. vibe distribution of score >= 8 rows\n const vibe = await q(`select coalesce(v.vibe_score, -1) vs, count(*) n from listings l left join vibe v on v.rowid_pk=l.rowid_pk where l.score >= ${PUSH_THRESHOLD} and l.status <> 'dead' and ${NOT_SIGNAL.replace(/source/g, \"l.source\")} group by vs order by vs`);\n L.push(`## Vibe score of score >= ${PUSH_THRESHOLD} rows`, \"\", table([\"Vibe\", \"n\"], vibe.map((r) => [Number(r.vs) < 0 ? \"no coordinates\" : `${r.vs}/5`, r.n])), \"\");\n\n // 7. recommendation\n let recommendation = `Push threshold ${PUSH_THRESHOLD} is fine (${pushesPerDay}/day is inside 0.3-2).`;\n if (pushesPerDay > 2) recommendation = `${pushesPerDay} pushes/day > 2: raise PUSH_THRESHOLD to ${PUSH_THRESHOLD + 1} or require dog=true for pushes.`;\n else if (pushesPerDay < 0.3) recommendation = `${pushesPerDay} pushes/day < 0.3: lower PUSH_THRESHOLD to ${PUSH_THRESHOLD - 1} for one week, or widen price/beds gates; check the source health line first.`;\n L.push(\"## Recommendation\", \"\", recommendation, \"\");\n return { markdown: L.join(\"\\n\"), pushesPerDay, recommendation };\n}\n\nexport async function sendCalibration(): Promise<{ sent: boolean; subject: string }> {\n const r = await calibrationReport();\n const subject = `Housing calibration ${today()}: ${r.pushesPerDay} pushes/day`;\n await email({ subject, text: r.markdown });\n await logPoll(\"calibration\", true, {}, r.recommendation);\n return { sent: true, subject };\n}\n",[19,95],"a6e88f36-5bc0-4bcb-92fb-69a5d6485a73",["D",1789248989948],"directory",[19],{"_39":195,"_13":196,"_42":197,"_44":-5,"_46":47,"_48":68,"_50":51,"_52":198,"_17":99,"_55":105,"_57":-5,"_59":60,"_61":-5,"_115":199,"_18":200},{"_39":103,"_13":19,"_42":45,"_44":-5,"_46":47,"_48":54,"_50":51,"_52":168,"_17":99,"_55":105,"_57":-5,"_59":60,"_61":-5,"_115":169,"_18":170},{"_39":153,"_13":154,"_42":155,"_44":-5,"_46":47,"_48":156,"_50":51,"_52":157,"_17":99,"_55":105,"_57":-5,"_59":60,"_61":-5,"_115":158,"_18":159},{"_39":111,"_13":112,"_42":113,"_44":-5,"_46":47,"_48":76,"_50":51,"_52":114,"_17":99,"_55":105,"_57":-5,"_59":60,"_61":-5,"_115":116,"_18":117},"3019fed4-fb55-4304-982a-27563c4bac65","lib","03892172-aef2-11f1-9a6d-1607ee4eb77e",["D",1789248988970],"children",[118,119,120,121],[112],{"_39":144,"_13":145,"_42":146,"_44":113,"_46":47,"_48":147,"_50":51,"_52":148,"_17":149,"_55":24,"_57":150,"_59":60,"_61":-5,"_115":151,"_18":152},{"_39":137,"_13":72,"_42":138,"_44":113,"_46":47,"_48":139,"_50":51,"_52":140,"_17":68,"_55":100,"_57":141,"_59":60,"_61":-5,"_115":142,"_18":143},{"_39":130,"_13":41,"_42":131,"_44":113,"_46":47,"_48":132,"_50":51,"_52":133,"_17":84,"_55":100,"_57":134,"_59":60,"_61":-5,"_115":135,"_18":136},{"_39":122,"_13":123,"_42":124,"_44":113,"_46":47,"_48":125,"_50":51,"_52":126,"_17":76,"_55":100,"_57":127,"_59":60,"_61":-5,"_115":128,"_18":129},"a733d1b9-01d9-4909-bca8-894bbf6883d2","vibe.ts","e570c70e-af77-11f1-95c6-1607ee4eb77e",63,["D",1789308398032],"// Neighborhood vibe layer (Part 5). Geocoding (Census batch + DC address points fallback), OSM POIs\r\n// (loaded by phase3/pois.ts -> POST {pois:[...]}), per-listing vibe metrics and a 0-5 vibe_score.\r\n// The vibe_score is a SEPARATE number - it never feeds score() (fit) and never gates a push.\r\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\r\nimport { streetKey, today, sleep, UA } from \"./core.ts\";\r\n\r\n// Nightlife strips (coordinates checked on Google Maps satellite/road view 2026-09-13 - each sits on the strip itself)\r\nexport const STRIPS: { name: string; lat: number; lon: number; area: string }[] = [\r\n { name: \"Upshur St NW @ 9th\", lat: 38.9424, lon: -77.0238, area: \"Petworth\" },\r\n { name: \"Georgia Ave @ Petworth Metro\", lat: 38.9367, lon: -77.0242, area: \"Petworth\" },\r\n { name: \"Kennedy St NW @ 5th\", lat: 38.9564, lon: -77.0195, area: \"Brightwood\" },\r\n { name: \"11th St NW Columbia Heights\", lat: 38.9290, lon: -77.0275, area: \"Park View / 16th St Hts\" },\r\n { name: \"Mt Vernon Ave Del Ray\", lat: 38.8285, lon: -77.0585, area: \"Del Ray\" },\r\n { name: \"Shirlington Village\", lat: 38.8405, lon: -77.0890, area: \"Fairlington / Shirlington\" },\r\n { name: \"Columbia Pike @ Walter Reed Dr\", lat: 38.8622, lon: -77.0906, area: \"Columbia Pike\" },\r\n { name: \"Route 1 Hyattsville Arts District\", lat: 38.9556, lon: -76.9410, area: \"Hyattsville\" },\r\n];\r\nexport const SHIRLINGTON = { lat: 38.8404, lon: -77.0872 }; // friend anchor\r\n// venues still tagged in OSM but closed (checked 2026-09-13): dropped from counts and names\r\nconst CLOSED = new Set([\"Slash Run\", \"Cinder Neighborhood Barbeque\", \"Cinder BBQ\"]);\r\n\r\n// Two-sentence blurbs. Venues verified 2026-09-13 (WebSearch / OSM): Timber Pizza 809 Upshur, Looking Glass Lounge 3634 Georgia,\r\n// Reliable Tavern 3655 Georgia, Brightwood Pizza & Bottle by ANXO 711 Kennedy, Wonderland Ballroom 11th & Kenyon, Cheesetique +\r\n// Pork Barrel BBQ on Mt Vernon Ave, Busboys and Poets + Samuel Beckett's in Shirlington, Lost Dog Cafe on the Pike, Franklins +\r\n// Busboys and Poets on Route 1. Slash Run (closed 2024) and Cinder (closed since the Jan 2026 fire) are deliberately not named.\r\nexport const AREA_BLURBS: Record = {\r\n \"Petworth\": \"Two short strips - Upshur St at 9th (Timber Pizza and a handful of taverns) and Georgia Ave around the Metro (Looking Glass Lounge, Reliable Tavern) - with quiet rowhouse blocks in every direction. The housing stock is exactly the search target (rowhouses with alley garages and English basements), so the trade-off is only that the nightlife is small-scale and closes early on weeknights.\",\r\n \"Park View / 16th St Hts\": \"Park View leans on Georgia Ave and, a 10-minute walk south, the 11th St corridor in Columbia Heights (Wonderland Ballroom, Red Rocks) - the densest bar strip in the search. Rowhouses and basement units are plentiful on the Park View side while 16th St Heights is larger detached and semi-detached houses with driveways; the trade-off is that the best-vibe blocks near 11th St price above budget and garages get rarer as you go south.\",\r\n \"Brightwood\": \"Kennedy St NW is the strip - Brightwood Pizza & Bottle by ANXO is the anchor and the rest is carry-outs and a slow trickle of new spots. Brightwood and Brightwood Park are the deepest pool of alley-garage rowhouses at the lowest DC prices in the search, at the cost of the thinnest nightlife and a longer ride to Shirlington.\",\r\n \"Fairlington / Shirlington\": \"Shirlington Village (Busboys and Poets, Samuel Beckett's, Palette 22) is a real restaurant row and it is the friend anchor - vibe here is walking distance to dinner, not late-night bars. Fairlington is 1940s brick condo townhouses: dog-friendly, green, garage-free (some carports/assigned spaces), so a Fairlington match trades the garage bonus for the strip and the friends.\",\r\n \"Columbia Pike\": \"The Pike around Walter Reed Dr (Lost Dog Cafe, Rebellion on the Pike, Penrose Square) is a bus-corridor main street: plenty of restaurants, a few bars, no Metro. Housing is garden apartments and some townhouses with surface parking; garages are rare, but prices and dog policies are friendlier than DC and Shirlington is a short drive.\",\r\n \"Del Ray\": \"Mt Vernon Ave is a classic small-town main street (Cheesetique, Pork Barrel BBQ, Taqueria Poblano) - family-hour busy, quiet by 10. Detached and semi-detached houses on small lots, many with detached garages off driveways, and Potomac Yard Metro at the south end; the trade-off is that whole-house rentals in budget are scarce and basement units rarer than in DC.\",\r\n \"Hyattsville\": \"The Route 1 Arts District (Franklins, Busboys and Poets, Pizzeria Paradiso, Vigilante Coffee) is a compact strip with two Metro stations within a mile. Housing is 1920s-40s bungalows and Cape Cods with driveways and detached garages at the lowest prices in the search; the trade-off is a longer commute to everything in Virginia and a strip that is one street, not a neighborhood of them.\",\r\n};\r\n\r\nconst R_MI = 3958.8;\r\nexport function haversineMi(lat1: number, lon1: number, lat2: number, lon2: number): number {\r\n const toR = (d: number) => d * Math.PI / 180;\r\n const dLat = toR(lat2 - lat1), dLon = toR(lon2 - lon1);\r\n const a = Math.sin(dLat / 2) ** 2 + Math.cos(toR(lat1)) * Math.cos(toR(lat2)) * Math.sin(dLon / 2) ** 2;\r\n return 2 * R_MI * Math.asin(Math.sqrt(a));\r\n}\r\nexport type Poi = { id: string; kind: string; name: string; lat: number; lon: number; area: string };\r\nexport type Vibe = {\r\n strip: string; strip_mi: number; strip_min: number; bars: number; eats: number; bar_names: string;\r\n metro: string | null; metro_mi: number | null; dog_park: string | null; dog_mi: number | null; grocery_mi: number | null;\r\n shirlington_min: number; vibe_score: number; line: string;\r\n};\r\nconst r1 = (x: number) => Math.round(x * 10) / 10;\r\n// pure: metrics + 0-5 score from a coordinate and the POI set\r\nexport function computeVibe(lat: number, lon: number, pois: Poi[]): Vibe {\r\n const d = (p: { lat: number; lon: number }) => haversineMi(lat, lon, p.lat, p.lon);\r\n const strip = STRIPS.map((s) => ({ s, mi: d(s) })).sort((a, b) => a.mi - b.mi)[0];\r\n const live = pois.filter((p) => !CLOSED.has(p.name));\r\n const bars = live.filter((p) => p.kind === \"bar\").map((p) => ({ p, mi: d(p) })).filter((x) => x.mi <= 0.5).sort((a, b) => a.mi - b.mi);\r\n const eats = live.filter((p) => p.kind === \"eat\" && d(p) <= 0.5).length;\r\n const nearest = (kind: string, maxMi: number) => { const c = live.filter((p) => p.kind === kind).map((p) => ({ p, mi: d(p) })).sort((a, b) => a.mi - b.mi)[0]; return c && c.mi <= maxMi ? c : null; };\r\n const metro = nearest(\"metro\", 3), dog = nearest(\"dog\", 1.5), groc = nearest(\"grocery\", 2);\r\n const shirl = Math.round(haversineMi(lat, lon, SHIRLINGTON.lat, SHIRLINGTON.lon) * 2.8);\r\n let score = 0;\r\n if (strip.mi <= 0.5) score += 2; else if (strip.mi <= 0.8) score += 1;\r\n if (bars.length >= 5) score += 1;\r\n if (metro && metro.mi <= 0.6) score += 1;\r\n if (dog && dog.mi <= 0.5) score += 1;\r\n const stripMin = Math.round(strip.mi * 20);\r\n const line = `Vibe ${score}/5 - ${strip.s.name} ${r1(strip.mi)} mi (${stripMin} min) - ${bars.length} bar${bars.length === 1 ? \"\" : \"s\"} - ${metro ? `${metro.p.name} ${r1(metro.mi)} mi` : \"no Metro <3 mi\"} - ~${shirl} min to Shirlington`;\r\n return {\r\n strip: strip.s.name, strip_mi: r1(strip.mi), strip_min: stripMin, bars: bars.length, eats,\r\n bar_names: bars.slice(0, 3).map((x) => x.p.name).filter(Boolean).join(\", \"),\r\n metro: metro ? metro.p.name : null, metro_mi: metro ? r1(metro.mi) : null,\r\n dog_park: dog ? dog.p.name : null, dog_mi: dog ? r1(dog.mi) : null, grocery_mi: groc ? r1(groc.mi) : null,\r\n shirlington_min: shirl, vibe_score: score, line,\r\n };\r\n}\r\n\r\n// ---------- schema ----------\r\nexport async function ensureVibeSchema() {\r\n await sqlite.batch([\r\n `create table if not exists pois (id text primary key, kind text not null, name text not null default '', lat real not null, lon real not null, area text)`,\r\n `create table if not exists vibe (rowid_pk integer primary key, strip text, strip_mi real, strip_min integer, bars integer, eats integer, bar_names text,\r\n metro text, metro_mi real, dog_park text, dog_mi real, grocery_mi real, shirlington_min integer, vibe_score integer, line text, computed text)`,\r\n ]);\r\n}\r\nlet poiCache: { at: number; pois: Poi[] } | null = null;\r\nexport async function loadPois(): Promise {\r\n if (poiCache && Date.now() - poiCache.at < 10 * 60_000) return poiCache.pois;\r\n const r = await sqlite.execute(`select id, kind, name, lat, lon, area from pois`);\r\n poiCache = { at: Date.now(), pois: (r.rows as any[]).map((x) => ({ id: String(x.id), kind: String(x.kind), name: String(x.name || \"\"), lat: Number(x.lat), lon: Number(x.lon), area: String(x.area || \"\") })) };\r\n return poiCache.pois;\r\n}\r\nexport async function upsertVibe(rowid: number, v: Vibe) {\r\n await sqlite.execute({\r\n sql: `insert or replace into vibe (rowid_pk, strip, strip_mi, strip_min, bars, eats, bar_names, metro, metro_mi, dog_park, dog_mi, grocery_mi, shirlington_min, vibe_score, line, computed) values (?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)`,\r\n args: [rowid, v.strip, v.strip_mi, v.strip_min, v.bars, v.eats, v.bar_names, v.metro, v.metro_mi, v.dog_park, v.dog_mi, v.grocery_mi, v.shirlington_min, v.vibe_score, v.line, today()],\r\n });\r\n await sqlite.execute({ sql: `update listings set vibe_score=? where rowid_pk=?`, args: [v.vibe_score, rowid] });\r\n}\r\n// vibe for a freshly upserted row that already has coordinates (Craigslist, add endpoint); no-op without POIs\r\nexport async function vibeForRow(rowid: number, lat: number | null | undefined, lon: number | null | undefined): Promise {\r\n if (lat == null || lon == null) return null;\r\n const pois = await loadPois(); if (!pois.length) return null;\r\n const v = computeVibe(Number(lat), Number(lon), pois);\r\n await upsertVibe(rowid, v);\r\n return v;\r\n}\r\n\r\n// ---------- geocoding ----------\r\nconst SYNTHETIC_RE = /^[A-Z0-9-]+ [A-Za-z0-9]+$/; // \"NESTFULLY-20782 428581813\", \"CRAIGSLIST kdRP...\" - ids with no address\r\nconst CITY: Record = {\r\n \"Petworth\": [\"Washington\", \"DC\"], \"Park View / 16th St Hts\": [\"Washington\", \"DC\"], \"Brightwood\": [\"Washington\", \"DC\"],\r\n \"Fairlington / Shirlington\": [\"Arlington\", \"VA\"], \"Columbia Pike\": [\"Arlington\", \"VA\"], \"Del Ray\": [\"Alexandria\", \"VA\"], \"Hyattsville\": [\"Hyattsville\", \"MD\"],\r\n};\r\nexport function geocodable(id: string, addrNorm: string): boolean {\r\n return !!addrNorm && !SYNTHETIC_RE.test(id) && /^\\d+[A-Z]?\\s+\\S/.test(addrNorm) && !/\\bNEAR\\b/.test(addrNorm);\r\n}\r\nfunction csvCell(s: string) { return `\"${String(s).replace(/\"/g, \"'\")}\"`; }\r\nexport async function censusBatch(rows: { rowid: number; street: string; city: string; state: string; zip: string }[]): Promise> {\r\n const out = new Map();\r\n if (!rows.length) return out;\r\n const csv = rows.map((r) => [r.rowid, csvCell(r.street), csvCell(r.city), r.state, r.zip].join(\",\")).join(\"\\n\");\r\n const fd = new FormData();\r\n fd.append(\"addressFile\", new Blob([csv], { type: \"text/csv\" }), \"addresses.csv\");\r\n fd.append(\"benchmark\", \"Public_AR_Current\");\r\n const res = await fetch(\"https://geocoding.geo.census.gov/geocoder/locations/addressbatch\", { method: \"POST\", body: fd, headers: { \"user-agent\": UA } });\r\n if (!res.ok) throw new Error(`census http ${res.status}`);\r\n const text = await res.text();\r\n for (const line of text.split(\"\\n\")) {\r\n // \"id\",\"input\",\"Match\",\"Exact\",\"matched address\",\"lon,lat\",\"tigerline\",\"side\"\r\n const m = line.match(/^\"(\\d+)\",\".*?\",\"Match\",\"[^\"]*\",\"[^\"]*\",\"(-?[\\d.]+),(-?[\\d.]+)\"/);\r\n if (m) out.set(Number(m[1]), { lon: Number(m[2]), lat: Number(m[3]) });\r\n }\r\n return out;\r\n}\r\nconst EXPAND: Record = { ST: \"STREET\", AVE: \"AVENUE\", RD: \"ROAD\", PL: \"PLACE\", DR: \"DRIVE\", CT: \"COURT\", LN: \"LANE\", BLVD: \"BOULEVARD\", TER: \"TERRACE\", CIR: \"CIRCLE\" };\r\nexport async function dcAddressPoint(addrNorm: string): Promise<{ lat: number; lon: number } | null> {\r\n const k = streetKey(addrNorm);\r\n const m = k.match(/^(\\d+)[A-Z]?\\s+(.+?)\\s+(ST|AVE|RD|PL|DR|CT|LN|BLVD|TER|CIR)\\s+(NW|NE|SW|SE)$/);\r\n if (!m) return null;\r\n const where = `ADDRESS_NUMBER=${Number(m[1])} AND STREET_NAME='${m[2].replace(/'/g, \"''\")}' AND STREET_TYPE='${EXPAND[m[3]] || m[3]}' AND QUADRANT='${m[4]}'`;\r\n const u = `https://maps2.dcgis.dc.gov/dcgis/rest/services/DCGIS_DATA/Location_WebMercator/MapServer/0/query?where=${encodeURIComponent(where)}&outFields=ADDRESS&returnGeometry=true&outSR=4326&f=json`;\r\n const res = await fetch(u, { headers: { \"user-agent\": UA } });\r\n if (!res.ok) return null;\r\n const j = await res.json(); const g = j.features?.[0]?.geometry;\r\n return g ? { lat: Number(g.y), lon: Number(g.x) } : null;\r\n}\r\nexport async function geocodeStep(started: number, budget: number, cap = 200): Promise {\r\n await ensureVibeSchema();\r\n const rows = await sqlite.execute(`select rowid_pk, id, address_norm, addr, area from listings where lat is null and geocode_src is null\r\n and source not like 'signal-%' and source <> 'cl-parking' and status <> 'dead' order by score desc limit ${cap}`);\r\n const cand: any[] = [];\r\n let skipped = 0;\r\n for (const r of rows.rows as any[]) {\r\n if (!geocodable(String(r.id), String(r.address_norm))) { skipped++; await sqlite.execute({ sql: `update listings set geocode_src='skip' where rowid_pk=?`, args: [r.rowid_pk] }); continue; }\r\n const [city, state] = CITY[String(r.area)] || [\"Washington\", \"DC\"];\r\n const zip = (String(r.addr).match(/\\b(2\\d{4})\\b/) || [])[1] || \"\";\r\n const street = String(r.addr).split(\",\")[0].replace(/\\b(unit|apt|ste|#)\\s*\\S+$/i, \"\").replace(/\\s+[A-Z]$/i, \"\").trim();\r\n cand.push({ rowid: Number(r.rowid_pk), street, city, state, zip, addrNorm: String(r.address_norm) });\r\n }\r\n let census = 0, dc = 0, miss = 0;\r\n if (cand.length) {\r\n const hits = await censusBatch(cand);\r\n for (const c of cand) {\r\n if (Date.now() - started > budget) break;\r\n let pt = hits.get(c.rowid); let src = \"census\";\r\n if (!pt && c.state === \"DC\") { try { pt = (await dcAddressPoint(c.addrNorm)) || undefined; src = \"dc-mar\"; } catch { /* ignore */ } await sleep(150); }\r\n if (pt) { await sqlite.execute({ sql: `update listings set lat=?, lon=?, geocode_src=? where rowid_pk=?`, args: [pt.lat, pt.lon, src, c.rowid] }); if (src === \"census\") census++; else dc++; }\r\n else { await sqlite.execute({ sql: `update listings set geocode_src='miss' where rowid_pk=?`, args: [c.rowid] }); miss++; }\r\n }\r\n }\r\n return { candidates: cand.length, census, dc_mar: dc, miss, skipped };\r\n}\r\n\r\n// ---------- vibe step ----------\r\nexport async function vibeStep(started: number, budget: number, cap = 300): Promise {\r\n await ensureVibeSchema();\r\n const pois = await loadPois();\r\n if (!pois.length) return { skipped: \"no pois loaded (POST {pois:[...]} from phase3/pois-load-*.json)\" };\r\n const rows = await sqlite.execute(`select l.rowid_pk, l.lat, l.lon from listings l left join vibe v on v.rowid_pk=l.rowid_pk\r\n where l.lat is not null and l.lon is not null and v.rowid_pk is null and l.source not like 'signal-%' and l.source <> 'cl-parking' order by l.score desc limit ${cap}`);\r\n let n = 0;\r\n for (const r of rows.rows as any[]) {\r\n if (Date.now() - started > budget) break;\r\n await upsertVibe(Number(r.rowid_pk), computeVibe(Number(r.lat), Number(r.lon), pois));\r\n n++;\r\n }\r\n return { computed: n, pois: pois.length };\r\n}\r\n",[],[112,123],"0bccf9a5-ef34-4edd-a6be-f86fa0f157d3","18a74ccc-af66-11f1-9858-1607ee4eb77e",61,["D",1789307288593],"// Multi-source registry + one parser per platform. Pure functions (text -> hits) so they are\r\n// unit-testable against scripts/fixtures/*. The cron (cron/sources.ts) does the fetching,\r\n// rotation, dedupe and upsert. Adding a source = one REGISTRY entry (+ a parser if new platform).\r\n// Per-source gotchas are documented in valtown/SOURCES.md.\r\nimport {\r\n decodeEntities, stripTags, inferArea, inferBeds, inferPrice, parsePrice, type Area, type Listing,\r\n} from \"./core.ts\";\r\nimport { parseSearch as clParseSearch } from \"../cron/craigslist.ts\";\r\n\r\nexport type Kind = \"listing\" | \"parking\" | \"signal\";\r\nexport interface Hit {\r\n extId: string; // stable per-source id (dedupe key)\r\n url: string;\r\n addr: string | null; // street address if known\r\n price: number | null;\r\n beds: number | null; // null = unknown (caller clamps), 0 = studio\r\n text: string; // everything we know, for the infer* helpers\r\n zip?: string | null;\r\n lat?: number | null; lon?: number | null;\r\n park?: Listing[\"park\"]; type?: Listing[\"type\"]; ll?: Listing[\"ll\"]; dog?: boolean | null; // structured overrides\r\n note?: string;\r\n posted?: string | number | null; // source's first-posted date when it exposes one (listing date, pubDate, issue date)\r\n detailUrl?: string; // fetch this for structured fields (Nestfully)\r\n}\r\nexport interface ParseResult { hits: Hit[]; more?: boolean; }\r\nexport type Parser = (text: string, ctx: { url: string; zip?: string; area?: Area }) => ParseResult;\r\n\r\nexport interface Source {\r\n key: string; // becomes listings.source and poll_log job 'sources:'\r\n parser: keyof typeof PARSERS;\r\n urls: string[]; // fetched in order; parser may request more pages via ParseResult.more + pageUrl()\r\n every: number; // minutes between runs\r\n ll: Listing[\"ll\"]; // default landlord type for this source\r\n kind?: Kind; // default 'listing'\r\n push?: boolean; // default true for listings; parking/signals never push\r\n pushMin?: number; // override PUSH_THRESHOLD for this source (RSS = 6)\r\n enabled?: boolean; // false = skipped without redeploying parsers\r\n zip?: string; // zip context for parsers that don't carry one (CL sub/prk)\r\n headers?: Record;\r\n accept?: \"html\" | \"json\" | \"xml\";\r\n pageUrl?: (base: string, n: number) => string; // n >= 2\r\n maxPages?: number;\r\n detailCap?: number; // detail fetches per run (Nestfully)\r\n spacingMs?: number; // delay between fetches to the same source\r\n group?: string; // at most one source per group runs per invocation (Cloudflare bursts: Nestfully)\r\n}\r\n\r\nexport const TARGET_ZIPS = [\"20010\", \"20011\", \"20012\", \"22206\", \"22204\", \"22301\", \"22305\", \"20781\", \"20782\"];\r\nexport const ZIP_RE = /\\b(2001[012]|2220[46]|2230[15]|2078[12])\\b/;\r\nconst NAV_HEADERS = {\r\n \"accept\": \"text/html,application/xhtml+xml,application/xml;q=0.9,*/*;q=0.8\",\r\n \"accept-language\": \"en-US,en;q=0.9\",\r\n \"upgrade-insecure-requests\": \"1\",\r\n \"sec-fetch-mode\": \"navigate\", \"sec-fetch-dest\": \"document\", \"sec-fetch-site\": \"none\",\r\n};\r\n\r\n// ---------- helpers ----------\r\nconst clean = (s: string) => decodeEntities(s).replace(/\\s+/g, \" \").trim();\r\nfunction pipeText(html: string): string {\r\n // tags -> \" | \" separators so label/value pairs survive\r\n const t = html.replace(//g, \"\").replace(/|/gi, \"\").replace(/<[^>]+>/g, \" | \");\r\n return decodeEntities(t).replace(/\\s+/g, \" \").replace(/(\\s*\\|\\s*)+/g, \" | \").trim();\r\n}\r\nfunction labelValue(pt: string, label: string): string | null {\r\n const m = pt.match(new RegExp(label.replace(/[.*+?^${}()|[\\]\\\\]/g, \"\\\\$&\") + \"\\\\s*:?\\\\s*\\\\|\\\\s*([^|]+)\"));\r\n return m ? m[1].trim() : null;\r\n}\r\nexport function inferZip(s: string): string | null { return (s.match(ZIP_RE) || [])[1] || null; }\r\nfunction bedsFrom(s: string): number | null { return inferBeds(s); }\r\n\r\n// ---------- 1a. Nestfully (Bright MLS consumer portal) ----------\r\nexport const nestfully: Parser = (html, ctx) => {\r\n const hits: Hit[] = [];\r\n const descByUrl = new Map();\r\n const postedByUrl = new Map();\r\n for (const m of html.matchAll(/\n\n`;\n\nexport default async function (req: Request): Promise {\n if (req.method !== \"GET\") return json({ error: \"GET only\" }, 405);\n if (!checkToken(req)) return new Response(\"unauthorized: open the tracker link that includes ?token=\", { status: 401 });\n return new Response(HTML, { headers: { \"content-type\": \"text/html; charset=utf-8\", \"cache-control\": \"no-store\", \"x-robots-tag\": \"noindex\" } });\n}\n",[],[196,206],"9d7d683c-4161-4851-a574-edb97359a76c","feed.ts","05d34138-aef2-11f1-8674-1607ee4eb77e",43,["D",1789302877522],"// housing-feed: JSON feed of active listings (GET). The Listing Tracker artifact\r\n// pulls this on open. Token via X-Housing-Token header or ?token= query.\r\n// Returns a bare JSON array of { id, addr, area, price, beds, park, type, ll, dog,\r\n// url, src, note, fs, lv, status, missed }.\r\n//\r\n// ?days=N window on last_seen (default 45)\r\n// ?kinds=all include signal-* and cl-parking rows (excluded by default)\r\n// ?v=2 add age_days + posted_at to each row (default contract unchanged for the tracker)\r\n// ?stats=1 returns a stats object instead of the array (for validation/debug)\r\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\r\nimport { ensureSchema, activeListings, checkToken, json, CORS } from \"../lib/core.ts\";\r\n\r\nexport default async function (req: Request): Promise {\r\n if (req.method === \"OPTIONS\") return new Response(null, { status: 204, headers: CORS });\r\n if (req.method !== \"GET\") return json({ error: \"GET only\" }, 405);\r\n if (!checkToken(req)) return json({ error: \"unauthorized\" }, 401);\r\n await ensureSchema();\r\n const url = new URL(req.url);\r\n\r\n if (url.searchParams.get(\"stats\")) {\r\n const bySrc = await sqlite.execute(`select source, count(*) n, max(last_seen) last from listings group by source`);\r\n const byArea = await sqlite.execute(`select area, count(*) n, round(avg(price)) avg_price from listings group by area`);\r\n const recent = await sqlite.execute(`select ts, job, ok, fetched, inserted, updated, pushed, detail from poll_log order by id desc limit 15`);\r\n const total = await sqlite.execute(`select count(*) n, sum(score>=8) hot, sum(pushed) pushed from listings`);\r\n return json({ total: total.rows[0], bySource: bySrc.rows, byArea: byArea.rows, recentPolls: recent.rows });\r\n }\r\n\r\n const days = Math.min(365, Math.max(1, Number(url.searchParams.get(\"days\") || 45)));\r\n const list = await activeListings(days, url.searchParams.get(\"kinds\") === \"all\" ? \"all\" : \"listings\", Number(url.searchParams.get(\"v\") || 1)); // ?kinds=all includes signal-*/cl-parking rows; ?v=2 adds age_days/posted_at\r\n return json(list, 200, { \"cache-control\": \"no-store\" });\r\n}\r\n",[],[196,215],"e9cee830-9665-4d39-825b-5703d3abf333","admin.ts","066872bc-aef2-11f1-8bc7-1607ee4eb77e",69,["D",1789308601983],13,"// housing-admin: token-checked maintenance endpoint for validation and manual runs.\r\n// GET ?job=craigslist | popville | digest | sources run a job now (digest sends immediately)\r\n// ?job=sources&only= ?job=sources&force=1 one source / ignore the `every` interval\r\n// GET ?sql=select ... read-only query (SELECT only)\r\n// POST { id, status } set a listing's status (new|contacted|touring|applied|dead)\r\n// POST { targets: [...] } load Phase 3 landlord targets ({addr, area, confidence A|B|C, verified_at?, ...}; bonus A +3, B +2, C 0)\r\n// POST { pois: [...] } load vibe-layer POIs (phase3/pois-load-*.json)\r\n// POST { verify_target: { address_norm, result: garage|none|probable } } satellite verdict -> A / demote to C / keep B, stamps verified_at\r\n// GET ?job=calibration[&email=1] weekly calibration report as Markdown (email=1 sends it via std/email)\r\n// GET ?job=enrich[&force=1][&step=queue|bbl|license|price|geocode|vibe] enrichment cron steps now (force = BBL refresh regardless of day)\r\n// GET ?job=backfill_posted[&cap=40] re-fetch Craigslist / Nestfully pages to fill posted_at for score>=6 rows\r\n// GET ?testpush=1 send a test Discord push\r\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\r\nimport { ensureSchema, checkToken, json, CORS, STATUS, pushDiscord, actionLinks, PUSH_THRESHOLD, normalizeAddress, streetKey, toIsoDate, UA, sleep } from \"../lib/core.ts\";\r\nimport { parseDetail as clParseDetail } from \"../cron/craigslist.ts\";\r\nimport { PARSERS, REGISTRY } from \"../lib/sources.ts\";\r\nimport craigslist from \"../cron/craigslist.ts\";\r\nimport popville from \"../cron/popville.ts\";\r\nimport { sendDigest } from \"../cron/digest.ts\";\r\nimport sources from \"../cron/sources.ts\";\r\nimport enrich from \"../cron/enrich.ts\";\r\nimport { calibrationReport, sendCalibration } from \"../cron/calibration.ts\";\r\n\r\nexport default async function (req: Request): Promise {\r\n if (req.method === \"OPTIONS\") return new Response(null, { status: 204, headers: CORS });\r\n if (!checkToken(req)) return json({ error: \"unauthorized\" }, 401);\r\n await ensureSchema();\r\n const url = new URL(req.url);\r\n\r\n if (req.method === \"POST\") {\r\n const b = await req.json().catch(() => ({}));\r\n // POST { delete: { id? | source? | url_like? | before? } } - remove rows matching ALL given filters (at least one)\r\n if (b.delete && typeof b.delete === \"object\") {\r\n const w: string[] = []; const a: any[] = [];\r\n if (b.delete.id != null) { w.push(\"id=?\"); a.push(b.delete.id); }\r\n if (b.delete.rowid != null) { w.push(\"rowid_pk=?\"); a.push(Number(b.delete.rowid)); }\r\n if (b.delete.source) { w.push(\"source=?\"); a.push(b.delete.source); }\r\n if (b.delete.url_like) { w.push(\"url like ?\"); a.push(b.delete.url_like); }\r\n if (b.delete.before) { w.push(\"first_seen t.addr && t.area).map((t: any) => ({\r\n sql: `insert or replace into targets (address_norm, addr, area, owner, mailing, garage_evidence, units, beds, bbl, rank, added, confidence, verified_at) values (?,?,?,?,?,?,?,?,?,?,date('now'),?,?)`,\r\n args: [streetKey(normalizeAddress(String(t.addr).split(\",\")[0])), String(t.addr).split(\",\")[0].trim(), t.area, t.owner || \"\", t.mailing || \"\", t.garage_evidence || \"\", t.units ?? null, t.beds ?? null, t.bbl ? 1 : 0, t.rank ?? null,\r\n /^[ABC]$/.test(String(t.confidence || \"\")) ? t.confidence : \"C\", t.verified_at || null],\r\n }));\r\n if (stmts.length) await sqlite.batch(stmts);\r\n const n = await sqlite.execute(`select count(*) n, sum(confidence='A') a, sum(confidence='B') b, sum(confidence='C') c from targets`);\r\n return json({ ok: true, upserted: stmts.length, totals: n.rows[0] });\r\n }\r\n // POST { pois: [{id, kind, name, lat, lon, area}] } - vibe layer POIs from phase3/pois.ts (<= 400 per call)\r\n if (Array.isArray(b.pois)) {\r\n const rows = b.pois.slice(0, 400).filter((p: any) => p.id && p.kind && p.lat != null && p.lon != null);\r\n if (rows.length) await sqlite.batch(rows.map((p: any) => ({ sql: `insert or replace into pois (id, kind, name, lat, lon, area) values (?,?,?,?,?,?)`, args: [String(p.id), String(p.kind), String(p.name || \"\"), Number(p.lat), Number(p.lon), p.area || null] })));\r\n const n = await sqlite.execute(`select kind, count(*) n from pois group by kind`);\r\n return json({ ok: true, upserted: rows.length, totals: n.rows });\r\n }\r\n // POST { verify_target: { address_norm, result } } - the Chrome sweep's satellite verdict for a \"VERIFY GARAGE\" push\r\n if (b.verify_target && typeof b.verify_target === \"object\") {\r\n const key = streetKey(normalizeAddress(String(b.verify_target.address_norm || b.verify_target.addr || \"\").split(\",\")[0]));\r\n const result = String(b.verify_target.result || \"\");\r\n if (!key || ![\"garage\", \"none\", \"probable\"].includes(result)) return json({ error: \"need address_norm and result in garage|none|probable\" }, 400);\r\n const conf = result === \"garage\" ? \"A\" : result === \"none\" ? \"C\" : \"B\";\r\n const r = await sqlite.execute({ sql: `update targets set confidence=?, verified_at=date('now') where address_norm=?`, args: [conf, key] });\r\n return json({ ok: true, address_norm: key, confidence: conf, rowsAffected: r.rowsAffected });\r\n }\r\n if (!b.id || !STATUS.includes(b.status)) return json({ error: `need id and status in ${STATUS.join(\"|\")}` }, 400);\r\n const r = await sqlite.execute({ sql: `update listings set status=? where id=?`, args: [b.status, b.id] });\r\n return json({ ok: true, rowsAffected: r.rowsAffected });\r\n }\r\n\r\n const job = url.searchParams.get(\"job\");\r\n if (job === \"craigslist\") return json(await craigslist());\r\n if (job === \"popville\") return json(await popville());\r\n if (job === \"digest\") return json(await sendDigest(true));\r\n if (job === \"sources\") return json(await sources({ only: url.searchParams.get(\"only\") || undefined, force: !!url.searchParams.get(\"force\") }));\r\n if (job === \"calibration\") {\r\n if (url.searchParams.get(\"email\")) return json(await sendCalibration());\r\n const r = await calibrationReport();\r\n return new Response(r.markdown, { headers: { \"content-type\": \"text/markdown; charset=utf-8\", ...CORS } });\r\n }\r\n if (job === \"enrich\") return json(await enrich({ force: !!url.searchParams.get(\"force\"), step: url.searchParams.get(\"step\") || undefined }));\r\n if (job === \"backfill_posted\") return json(await backfillPosted(Number(url.searchParams.get(\"cap\") || 40)));\r\n\r\n // push every active score>=8 row that never got a Discord alert (webhook was down / not yet configured)\r\n if (url.searchParams.get(\"pushpending\")) {\r\n const r = await sqlite.execute(`select * from listings where score >= ${PUSH_THRESHOLD} and pushed = 0 and status <> 'dead' and last_seen >= date('now','-14 day') order by score desc`);\r\n const out: any[] = [];\r\n for (const row of r.rows as any[]) {\r\n const ok = await pushDiscord({ id: row.id, addr: row.addr, area: row.area, price: row.price, beds: Number(row.beds), park: row.parking_type, type: row.htype, ll: row.landlord_type, dog: row.pet_ok == null ? null : !!row.pet_ok, url: row.url, source: row.source, score: row.score, notes: row.notes });\r\n if (ok) await sqlite.execute({ sql: `update listings set pushed=1 where rowid_pk=?`, args: [row.rowid_pk] });\r\n out.push({ id: row.id, score: row.score, pushed: ok });\r\n }\r\n return json({ pending: out.length, results: out });\r\n }\r\n\r\n if (url.searchParams.get(\"testpush\")) {\r\n const l = { id: \"719 QUEBEC PL NW\", rowid: null, addr: \"Test push - 719 Quebec Pl NW\", area: \"Park View / 16th St Hts\", price: 2400, beds: 2, park: \"garage\", type: \"basement\", ll: \"individual\", dog: true, url: \"https://example.com\", source: \"test\", score: 12, notes: \"Pipeline test; ignore.\", tier: \"B\", ageDays: 31, license: \"yes\", licenseDetail: \"500620000246 exp 2028-08-31\", anomaly: false, trail: [2500, 2450, 2400], motivated: true, lat: 38.9365, lon: -77.0223, vibe: \"Vibe 4/5 - Georgia Ave @ Petworth Metro 0.3 mi (6 min) - 6 bars - Petworth Metro 0.4 mi - ~14 min to Shirlington\" };\r\n const ok = await pushDiscord(l);\r\n return json({ pushed: ok, links: actionLinks(l) });\r\n }\r\n\r\n const sql = url.searchParams.get(\"sql\");\r\n if (sql) {\r\n if (!/^\\s*select\\b/i.test(sql)) return json({ error: \"SELECT only\" }, 400);\r\n const r = await sqlite.execute(sql);\r\n return json({ columns: r.columns, rows: r.rows });\r\n }\r\n return json({ usage: \"?job=craigslist|popville|digest|sources[&only=key][&force=1] ?sql=select... ?testpush=1 POST {id,status}\" });\r\n}\r\n\r\n// Fix 2 backfill: posted_at for Craigslist rows (detail page ) and Nestfully rows (list page datePosted),\r\n// score >= 6 only, capped, polite. Everything else stays null (first_seen is the age fallback).\r\nasync function backfillPosted(cap: number) {\r\n const headers = { \"user-agent\": UA, \"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\" };\r\n const out: any[] = []; let fetches = 0;\r\n // step 0 (no fetch): Nestfully / add-endpoint notes already carry \"posted YYYY-MM-DD\" from the list page\r\n const fromNotes = await sqlite.execute(`select rowid_pk, notes from listings where posted_at is null and notes like '%posted 20__-__-__%'`);\r\n let notesFilled = 0;\r\n for (const row of fromNotes.rows as any[]) {\r\n const m = String(row.notes).match(/posted (\\d{4}-\\d{2}-\\d{2})/); const d = m ? toIsoDate(m[1]) : null;\r\n if (d) { await sqlite.execute({ sql: `update listings set posted_at=? where rowid_pk=? and posted_at is null`, args: [d, row.rowid_pk] }); notesFilled++; }\r\n }\r\n out.push({ step: \"posted_at from notes\", filled: notesFilled });\r\n const cl = await sqlite.execute(`select rowid_pk, url, addr from listings where source='craigslist' and posted_at is null and score >= 6 order by score desc`);\r\n for (const row of cl.rows as any[]) {\r\n if (fetches >= cap) break;\r\n fetches++;\r\n try {\r\n const res = await fetch(String(row.url), { headers }); const text = res.ok ? await res.text() : \"\";\r\n const posted = text ? toIsoDate(clParseDetail(text).posted) : null;\r\n if (posted) await sqlite.execute({ sql: `update listings set posted_at=? where rowid_pk=?`, args: [posted, row.rowid_pk] });\r\n out.push({ addr: row.addr, http: res.status, posted });\r\n } catch (e) { out.push({ addr: row.addr, error: String(e).slice(0, 80) }); }\r\n await sleep(1500);\r\n }\r\n const nf = await sqlite.execute(`select source, count(*) n from listings where source like 'nestfully-%' and posted_at is null and score >= 6 group by source`);\r\n for (const g of nf.rows as any[]) {\r\n if (fetches >= cap) break;\r\n const zip = String(g.source).replace(\"nestfully-\", \"\");\r\n const reg = REGISTRY.find((s) => s.key === g.source); if (!reg) continue;\r\n const byId = new Map();\r\n await sleep(6000); // Cloudflare 403s Nestfully bursts - one zip at a time, spaced\r\n for (let page = 1; page <= 3 && fetches < cap; page++) {\r\n fetches++;\r\n const u = page > 1 && reg.pageUrl ? reg.pageUrl(reg.urls[0], page) : reg.urls[0];\r\n try {\r\n let res = await fetch(u, { headers: { \"user-agent\": UA, ...(reg.headers || headers) } });\r\n if (res.status === 403 || res.status === 429) { await sleep(8000); res = await fetch(u, { headers: { \"user-agent\": UA, ...(reg.headers || headers) } }); }\r\n if (!res.ok) { out.push({ source: g.source, page, http: res.status }); break; }\r\n const r = PARSERS.nestfully(await res.text(), { url: u, zip });\r\n for (const h of r.hits) if (h.posted) byId.set(h.extId, String(h.posted).slice(0, 10));\r\n if (!r.more) break;\r\n } catch (e) { out.push({ source: g.source, page, error: String(e).slice(0, 80) }); break; }\r\n await sleep(5000);\r\n }\r\n let updated = 0;\r\n for (const [extId, posted] of byId) {\r\n const r = await sqlite.execute({ sql: `update listings set posted_at=? where source=? and external_id=? and posted_at is null`, args: [posted, g.source, extId] });\r\n updated += Number(r.rowsAffected || 0);\r\n }\r\n out.push({ source: g.source, listPagesParsed: byId.size, updated });\r\n }\r\n // re-derive STALE prefixes for rows that now have a posted_at\r\n const stale = await sqlite.execute(`select rowid_pk, notes, posted_at, first_seen from listings where posted_at is not null and score >= 6`);\r\n let restamped = 0;\r\n for (const row of stale.rows as any[]) {\r\n const age = Math.round((Date.now() - Date.parse(String(row.posted_at || row.first_seen))) / 86400000);\r\n const base = String(row.notes || \"\").replace(/^STALE \\d+d \\| /, \"\");\r\n const notes = age > 45 ? `STALE ${age}d | ${base}` : base;\r\n if (notes !== row.notes) { await sqlite.execute({ sql: `update listings set notes=? where rowid_pk=?`, args: [notes, row.rowid_pk] }); restamped++; }\r\n }\r\n return { fetches, restamped, out };\r\n}\r\n",[],[196,223],"1fba8fc3-f36b-4b1c-90e3-1d45a5867818","add.ts","0544e21c-aef2-11f1-a6f0-1607ee4eb77e",42,["D",1789302872872],"// housing-add: manual ingestion endpoint (POST). Claude in Chrome and Logan post\r\n// FB / sign / portal finds here. Shared-secret header X-Housing-Token.\r\n//\r\n// Body (JSON, single object or array):\r\n// { addr, area?, price?, beds?, park?, type?, ll?, dog?, url, src, note?, text?, posted? (yyyy-mm-dd first-posted date) }\r\n// `text` is optional free text (the listing body) used to infer any field left blank.\r\nimport {\r\n AREAS, PARK, HTYPE, LL, ensureSchema, upsertListing, inferArea, inferPark, inferType, inferLL, inferDog,\r\n inferBeds, clampBeds, parsePrice, inferPrice, checkToken, json, CORS, type Area,\r\n} from \"../lib/core.ts\";\r\n\r\nexport default async function (req: Request): Promise {\r\n if (req.method === \"OPTIONS\") return new Response(null, { status: 204, headers: CORS });\r\n if (req.method !== \"POST\") return json({ error: \"POST only\" }, 405);\r\n if (!checkToken(req)) return json({ error: \"unauthorized\" }, 401);\r\n\r\n let body: any;\r\n try { body = await req.json(); } catch { return json({ error: \"invalid JSON\" }, 400); }\r\n const items: any[] = Array.isArray(body) ? body : [body];\r\n if (items.length === 0 || items.length > 50) return json({ error: \"1-50 listings per request\" }, 400);\r\n\r\n await ensureSchema();\r\n const results: any[] = [];\r\n for (const it of items) {\r\n const text = [it.addr, it.title, it.note, it.text].filter(Boolean).join(\" \\n \");\r\n const url = String(it.url || \"\").trim();\r\n const src = String(it.src || it.source || \"manual\").toLowerCase().trim();\r\n if (!url && !it.addr) { results.push({ error: \"need url or addr\", input: it }); continue; }\r\n\r\n let area: Area | null = AREAS.includes(it.area) ? it.area : inferArea(text);\r\n if (!area) { results.push({ error: `area required; one of ${AREAS.join(\" | \")}`, input: it }); continue; }\r\n\r\n let beds = it.beds != null && it.beds !== \"\" ? Number(it.beds) : inferBeds(text);\r\n if (beds === 0) { results.push({ skipped: \"studio\", input: it }); continue; }\r\n beds = clampBeds(beds);\r\n\r\n const park = PARK.includes(it.park) ? it.park : inferPark(text);\r\n const type = HTYPE.includes(it.type) ? it.type : inferType(text);\r\n // FB/CL/sign posts default to individual-landlord signal; portals default to pm\r\n const llDefault = [\"fb\", \"fbm\", \"facebook\", \"craigslist\", \"sign\", \"popville\", \"manual\"].includes(src) ? \"individual\" : \"pm\";\r\n const ll = LL.includes(it.ll) ? it.ll : inferLL(text, llDefault);\r\n const dog = typeof it.dog === \"boolean\" ? it.dog : inferDog(text);\r\n const price = it.price != null && it.price !== \"\" ? parsePrice(it.price) : inferPrice(text);\r\n\r\n const r = await upsertListing({\r\n addr: it.addr ? String(it.addr).trim() : null,\r\n area, price, beds, source: src, externalId: it.externalId || it.external_id || null, url: url || \"\",\r\n park, type, ll, dog, notes: String(it.note || \"\").trim(), raw: it.text ? String(it.text) : undefined, unit: it.unit || null,\r\n postedAt: it.posted || it.posted_at || null,\r\n }, { push: true });\r\n results.push(r);\r\n }\r\n return json({ ok: true, results });\r\n}\r\n",[],[196,232],"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","pinPreview","pinMigrated","screenshotVersion","likeCount","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",{"_11":12,"_297":293},"org",{"_11":12,"_290":291,"_292":293,"_249":250,"_294":295,"_296":60},"branch",{"_17":281,"_13":16,"_39":47,"_282":239,"_283":-5,"_284":-5,"_285":-5,"_286":-5,"_287":-5,"_288":14,"_289":12},"isOwned",71,"projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","Logan","avatar","https://lh3.googleusercontent.com/a/ACg8ocIFxddfJftSiTFZN49YShT3nY7q8GOQ7dXYM2vJ6XkajnQMGA=s96-c","tier","free","canRestrictVals","profileImageUrl","adoptOrgId",{"_39":239,"_13":14,"_52":396,"_241":-5,"_242":60,"_243":244,"_245":244,"_246":247,"_248":-5,"_249":250,"_251":233,"_252":51,"_253":-5,"_254":-5,"_255":99,"_256":257,"_258":259,"_260":261,"_262":397,"_264":-5,"_265":266,"_267":266,"_268":269,"_270":269,"_271":269,"_272":266,"_273":266,"_274":398,"_276":399,"_278":400,"_280":60},[339,344,351,353],"files",[339,340,341,342,343,344,345,346,347,348,349,350,351,352,353,354,355,356,357],"counts",{"_330":99,"_331":76,"_332":99,"_32":333,"_334":335},[318,319,320,321,322,323],{"_39":103,"_13":19,"_42":45,"_44":-5,"_46":47,"_48":54,"_50":51,"_52":104,"_17":99,"_55":105,"_57":-5,"_59":60,"_61":-5,"_18":317},"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},[19],{"_39":94,"_13":95,"_42":96,"_44":45,"_46":47,"_48":97,"_50":51,"_52":98,"_17":99,"_55":100,"_57":101,"_59":60,"_61":-5,"_18":329},{"_39":87,"_13":88,"_42":89,"_44":45,"_46":47,"_48":90,"_50":51,"_52":91,"_17":54,"_55":56,"_57":92,"_59":60,"_61":-5,"_18":328},{"_39":79,"_13":80,"_42":81,"_44":45,"_46":47,"_48":82,"_50":51,"_52":83,"_17":84,"_55":56,"_57":85,"_59":60,"_61":-5,"_18":327},{"_39":71,"_13":72,"_42":73,"_44":45,"_46":47,"_48":74,"_50":51,"_52":75,"_17":76,"_55":56,"_57":77,"_59":60,"_61":-5,"_18":326},{"_39":63,"_13":64,"_42":65,"_44":45,"_46":47,"_48":66,"_50":51,"_52":67,"_17":68,"_55":56,"_57":69,"_59":60,"_61":-5,"_18":325},{"_39":40,"_13":41,"_42":43,"_44":45,"_46":47,"_48":49,"_50":51,"_52":53,"_17":54,"_55":56,"_57":58,"_59":60,"_61":-5,"_18":324},[19,41],[19,64],[19,72],[19,80],[19,88],[19,95],"pulls","branches","forks",{"_336":68,"_338":99},"connections",{"_336":99,"_337":99},"count","unfilledCount","emptyCount",{"_39":195,"_13":196,"_42":197,"_44":-5,"_46":47,"_48":68,"_50":51,"_52":198,"_17":99,"_55":105,"_57":-5,"_59":60,"_61":-5,"_115":394,"_18":395},{"_39":231,"_13":232,"_42":233,"_44":197,"_46":47,"_48":234,"_50":51,"_52":235,"_17":68,"_55":210,"_57":236,"_59":60,"_61":-5,"_115":392,"_18":393},{"_39":222,"_13":223,"_42":224,"_44":197,"_46":47,"_48":225,"_50":51,"_52":226,"_17":227,"_55":210,"_57":228,"_59":60,"_61":-5,"_115":390,"_18":391},{"_39":214,"_13":215,"_42":216,"_44":197,"_46":47,"_48":217,"_50":51,"_52":218,"_17":68,"_55":210,"_57":219,"_59":60,"_61":-5,"_115":388,"_18":389},{"_39":205,"_13":206,"_42":207,"_44":197,"_46":47,"_48":208,"_50":51,"_52":209,"_17":54,"_55":210,"_57":211,"_59":60,"_61":-5,"_115":386,"_18":387},{"_39":103,"_13":19,"_42":45,"_44":-5,"_46":47,"_48":54,"_50":51,"_52":168,"_17":99,"_55":105,"_57":-5,"_59":60,"_61":-5,"_115":384,"_18":385},{"_39":94,"_13":95,"_42":96,"_44":45,"_46":47,"_48":97,"_50":51,"_52":192,"_17":99,"_55":100,"_57":101,"_59":60,"_61":-5,"_115":382,"_18":383},{"_39":87,"_13":88,"_42":89,"_44":45,"_46":47,"_48":90,"_50":51,"_52":189,"_17":54,"_55":56,"_57":92,"_59":60,"_61":-5,"_115":380,"_18":381},{"_39":79,"_13":80,"_42":81,"_44":45,"_46":47,"_48":82,"_50":51,"_52":186,"_17":84,"_55":56,"_57":85,"_59":60,"_61":-5,"_115":378,"_18":379},{"_39":71,"_13":72,"_42":73,"_44":45,"_46":47,"_48":74,"_50":51,"_52":183,"_17":76,"_55":56,"_57":77,"_59":60,"_61":-5,"_115":376,"_18":377},{"_39":63,"_13":64,"_42":65,"_44":45,"_46":47,"_48":66,"_50":51,"_52":180,"_17":68,"_55":56,"_57":69,"_59":60,"_61":-5,"_115":374,"_18":375},{"_39":40,"_13":41,"_42":43,"_44":45,"_46":47,"_48":49,"_50":51,"_52":177,"_17":54,"_55":56,"_57":58,"_59":60,"_61":-5,"_115":372,"_18":373},{"_39":153,"_13":154,"_42":155,"_44":-5,"_46":47,"_48":156,"_50":51,"_52":157,"_17":99,"_55":105,"_57":-5,"_59":60,"_61":-5,"_115":370,"_18":371},{"_39":161,"_13":162,"_42":163,"_44":155,"_46":47,"_48":156,"_50":51,"_52":164,"_17":99,"_55":154,"_57":165,"_59":60,"_61":-5,"_115":368,"_18":369},{"_39":111,"_13":112,"_42":113,"_44":-5,"_46":47,"_48":76,"_50":51,"_52":114,"_17":99,"_55":105,"_57":-5,"_59":60,"_61":-5,"_115":366,"_18":367},{"_39":144,"_13":145,"_42":146,"_44":113,"_46":47,"_48":147,"_50":51,"_52":148,"_17":149,"_55":24,"_57":150,"_59":60,"_61":-5,"_115":364,"_18":365},{"_39":137,"_13":72,"_42":138,"_44":113,"_46":47,"_48":139,"_50":51,"_52":140,"_17":68,"_55":100,"_57":141,"_59":60,"_61":-5,"_115":362,"_18":363},{"_39":130,"_13":41,"_42":131,"_44":113,"_46":47,"_48":132,"_50":51,"_52":133,"_17":84,"_55":100,"_57":134,"_59":60,"_61":-5,"_115":360,"_18":361},{"_39":122,"_13":123,"_42":124,"_44":113,"_46":47,"_48":125,"_50":51,"_52":126,"_17":76,"_55":100,"_57":127,"_59":60,"_61":-5,"_115":358,"_18":359},[],[112,123],[],[112,41],[],[112,72],[],[112,145],[354,355,356,357],[112],[],[154,162],[352],[154],[],[19,41],[],[19,64],[],[19,72],[],[19,80],[],[19,88],[],[19,95],[345,346,347,348,349,350],[19],[],[196,206],[],[196,215],[],[196,223],[],[196,232],[340,341,342,343],[196],["D",1789248987477],["D",1789519256886],{"_11":12,"_297":293},{"_11":12,"_290":291,"_292":293,"_249":250,"_294":295,"_296":60},{"_17":281,"_13":16,"_39":47,"_282":239,"_283":-5,"_284":-5,"_285":-5,"_286":-5,"_287":-5,"_288":14,"_289":12},"ctx",{"_274":-5,"_314":434,"_435":436,"_437":438,"_439":60,"_440":60,"_441":60,"_442":51,"_443":-5,"_444":-7,"_445":-7,"_446":99,"_447":60,"_448":60,"_449":-5,"_450":60,"_451":60,"_452":60,"_453":-5},"ENV",{"_405":406,"_407":408,"_409":16,"_410":411,"_412":413,"_414":415,"_416":417,"_418":419,"_420":421,"_422":423,"_424":425,"_426":427,"_428":429,"_430":431,"_432":433},"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"]