[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_293":294,"_295":296},"routes/_app.x.$handle.$name",{"_104":103,"_32":49,"_113":94,"_27":114,"_13":14,"_115":-5,"_11":116,"_117":118,"_119":120,"_121":122,"_123":124,"_21":-5,"_125":-5,"_126":-5,"_127":25,"_128":129,"_130":63,"_131":-5,"_132":-5,"_133":134},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_47":48,"_32":49,"_36":50,"_51":-5,"_52":25,"_53":54,"_55":54,"_56":57,"_58":-5,"_18":59,"_60":61,"_62":63,"_64":-5,"_65":-5,"_66":67,"_68":69,"_70":71,"_72":73,"_74":75,"_76":-5,"_77":78,"_79":78,"_80":81,"_82":81,"_83":81,"_84":78,"_85":78,"_86":87,"_88":89,"_90":91,"_92":25},"version",32,"changes",[19,20],"aiChatInfo","userId",{"_21":41,"_23":-7,"_24":25,"_26":25,"_27":42,"_29":42},{"_21":22,"_23":-7,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":34,"_35":-5,"_36":37,"_38":14,"_39":40,"_24":25},"previous","deleted",false,"deletedHere","path","email","latestPath","fileId","c5747c18-ef02-4239-beb4-bae26fa9425f","name","fileType","directory","content","createdAt",["D",1789299968238],"branchVersion","branchId","a4c5838e-3adb-4640-ab71-e9f3d2b72f0a",{"_30":43,"_32":44,"_33":28,"_35":45,"_36":46,"_38":14,"_39":40,"_24":25},"email/listserv.ts","b58e8080-af68-11f1-92e5-1607ee4eb77e","listserv.ts","// housing/email/listserv.ts - inbound email handler. Subscribe this val's address to the members-only\n// neighborhood listservs (petworth@groups.io, BrightwoodDC, shepherdpark, HOPE, DelRayCitizensAssociation,\n// penrosegroup, bsclchat) or forward Gmail to it. Each message is keyword-filtered like the RSS sources\n// (rent/lease/basement/BR + a target-area match), then upserted with source='listserv-' at the\n// RSS push threshold (6). Non-matching mail is logged to poll_log and dropped. Nothing is ever replied to.\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { ensureSchema, upsertListing, logPoll, inferArea, inferPark, inferType, inferLL, inferDog, inferBeds, inferPrice, clampBeds, stripTags } from \"../lib/core.ts\";\nimport { RSS_KEEP, RSS_DROP } from \"../lib/sources.ts\";\n\nexport default async function (e: Email) {\n await ensureSchema();\n const from = String(e.from || \"\");\n const subject = String(e.subject || \"\");\n const body = stripTags(String(e.html || e.text || \"\")).slice(0, 8000);\n const text = `${subject} \\n ${body}`;\n const list = (from.match(/([a-z0-9._-]+)@groups\\.io/i) || from.match(/\\[([^\\]]+)\\]/) || subject.match(/^\\[([^\\]]+)\\]/) || [, \"unknown\"])[1].toLowerCase().replace(/[^a-z0-9]+/g, \"-\");\n const msgId = String(e.headers?.get?.(\"message-id\") || e.messageId || `${from}|${subject}|${Date.now()}`).replace(/[<>]/g, \"\");\n\n if (!RSS_KEEP.test(text) || RSS_DROP.test(subject)) { await logPoll(`listserv:${list}`, true, { fetched: 1 }, `dropped (no rental keywords): ${subject.slice(0, 120)}`); return; }\n const area = inferArea(text, null, null, list.includes(\"petworth\") ? \"Petworth\" : list.includes(\"brightwood\") || list.includes(\"shepherd\") ? \"Brightwood\" : list.includes(\"hope\") || list.includes(\"rptown\") ? \"Hyattsville\" : list.includes(\"delray\") ? \"Del Ray\" : list.includes(\"penrose\") || list.includes(\"bscl\") ? \"Columbia Pike\" : undefined);\n if (!area) { await logPoll(`listserv:${list}`, true, { fetched: 1 }, `dropped (no area): ${subject.slice(0, 120)}`); return; }\n const bedsRaw = inferBeds(text);\n if (bedsRaw === 0) { await logPoll(`listserv:${list}`, true, { fetched: 1 }, `dropped (studio): ${subject.slice(0, 120)}`); return; }\n const price = inferPrice(text);\n if (price != null && (price < 1500 || price > 3000)) { await logPoll(`listserv:${list}`, true, { fetched: 1 }, `dropped (price ${price}): ${subject.slice(0, 120)}`); return; }\n const addrM = body.match(/\\b\\d{2,5}\\s+[A-Z][A-Za-z]+(?:\\s[A-Z][A-Za-z]+)?\\s(?:St|Street|Ave|Avenue|Rd|Road|Pl|Place|Dr|Drive|Ct|Ln|Way|Ter)\\b\\.?(?:\\s?(?:NW|NE|SW|SE|S|N))?/);\n let beds = clampBeds(bedsRaw); if (beds === 1 && /\\bden\\b|\\boffice\\b/i.test(text)) beds = 1.5;\n const r = await upsertListing({\n addr: addrM ? addrM[0] : null, area, price, beds, source: `listserv-${list}`, externalId: msgId, url: `mailto:${from}`,\n park: inferPark(text), type: inferType(text), ll: inferLL(text, \"individual\"), dog: inferDog(text),\n notes: `listserv ${list}: ${subject.slice(0, 100)} | from ${from.slice(0, 60)}`, raw: body.slice(0, 4000),\n }, { push: true, pushMin: 6 });\n await logPoll(`listserv:${list}`, true, { fetched: 1, inserted: r.action === \"inserted\" ? 1 : 0, updated: r.action === \"updated\" ? 1 : 0, pushed: r.pushed ? 1 : 0 }, `${r.action} ${r.id} score ${r.score}: ${subject.slice(0, 100)}`);\n}\n",["D",1789299968238],"id","b7ccec7e-ebe9-4364-ba98-e367c8d8849b","housing",["D",1789248987477],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","DC housing search pipeline","imageUrl","87445237-7d14-45c7-b3a2-72e031f10ec1","pinnedFileId","0544e21c-aef2-11f1-a6f0-1607ee4eb77e","pinPreview",true,"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",{"_104":103,"_112":108},"org",{"_104":103,"_105":106,"_107":108,"_18":59,"_109":110,"_111":25},"branch",{"_13":93,"_32":94,"_47":40,"_95":48,"_96":-5,"_97":-5,"_98":-5,"_99":-5,"_100":-5,"_101":49,"_102":103},"isOwned",71,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","logan1","handle","displayName","Logan","avatar","https://lh3.googleusercontent.com/a/ACg8ocIFxddfJftSiTFZN49YShT3nY7q8GOQ7dXYM2vJ6XkajnQMGA=s96-c","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_47":48,"_32":49,"_36":288,"_51":-5,"_52":25,"_53":54,"_55":54,"_56":57,"_58":-5,"_18":59,"_60":61,"_62":63,"_64":-5,"_65":-5,"_66":67,"_68":69,"_70":71,"_72":73,"_74":289,"_76":-5,"_77":78,"_79":78,"_80":81,"_82":81,"_83":81,"_84":78,"_85":78,"_86":290,"_88":291,"_90":292,"_92":25},"tree",[173,178,183,185],"files",[173,174,175,176,177,178,179,180,181,182,183,184,185,186,187],"counts",{"_163":67,"_164":143,"_165":67,"_166":167,"_168":169},"contents",[135,136,137,138],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_47":157,"_32":158,"_30":159,"_142":-5,"_39":40,"_38":160,"_144":63,"_36":161,"_13":67,"_33":34,"_35":-5,"_24":25,"_146":-5,"_27":162},{"_47":151,"_32":152,"_30":153,"_142":-5,"_39":40,"_38":154,"_144":63,"_36":155,"_13":67,"_33":34,"_35":-5,"_24":25,"_146":-5,"_27":156},{"_47":148,"_32":28,"_30":31,"_142":-5,"_39":40,"_38":14,"_144":63,"_36":149,"_13":67,"_33":34,"_35":-5,"_24":25,"_146":-5,"_27":150},{"_47":139,"_32":140,"_30":141,"_142":-5,"_39":40,"_38":143,"_144":63,"_36":145,"_13":67,"_33":34,"_35":-5,"_24":25,"_146":-5,"_27":147},"3019fed4-fb55-4304-982a-27563c4bac65","lib","03892172-aef2-11f1-9a6d-1607ee4eb77e","parentId",1,"latest",["D",1789248988970],"label",[140],"27f1b4ee-4369-441d-ac9b-84788125d19c",["D",1789299968238],[28],"a6e88f36-5bc0-4bcb-92fb-69a5d6485a73","cron","041eaecc-aef2-11f1-9a8e-1607ee4eb77e",3,["D",1789248989948],[152],"5c11403c-d645-4b4e-b1c8-b1cc89a025ad","api","03d27d86-aef2-11f1-ba0a-1607ee4eb77e",2,["D",1789248989432],[158],"pulls","branches","forks","envVars",{"_170":160,"_172":67},"connections",{"_170":67,"_171":67},"count","unfilledCount","emptyCount",{"_47":157,"_32":158,"_30":159,"_142":-5,"_39":40,"_38":160,"_144":63,"_36":285,"_13":67,"_33":34,"_35":-5,"_24":25,"_146":-5,"_195":286,"_27":287},{"_47":278,"_32":279,"_30":61,"_142":159,"_39":40,"_38":280,"_144":25,"_36":281,"_13":143,"_33":257,"_35":282,"_24":25,"_146":-5,"_195":283,"_27":284},{"_47":269,"_32":270,"_30":271,"_142":159,"_39":40,"_38":272,"_144":25,"_36":273,"_13":274,"_33":257,"_35":275,"_24":25,"_146":-5,"_195":276,"_27":277},{"_47":261,"_32":262,"_30":263,"_142":159,"_39":40,"_38":264,"_144":25,"_36":265,"_13":143,"_33":257,"_35":266,"_24":25,"_146":-5,"_195":267,"_27":268},{"_47":252,"_32":253,"_30":254,"_142":159,"_39":40,"_38":255,"_144":25,"_36":256,"_13":143,"_33":257,"_35":258,"_24":25,"_146":-5,"_195":259,"_27":260},{"_47":151,"_32":152,"_30":153,"_142":-5,"_39":40,"_38":154,"_144":63,"_36":249,"_13":67,"_33":34,"_35":-5,"_24":25,"_146":-5,"_195":250,"_27":251},{"_47":241,"_32":242,"_30":243,"_142":153,"_39":40,"_38":244,"_144":25,"_36":245,"_13":160,"_33":221,"_35":246,"_24":25,"_146":-5,"_195":247,"_27":248},{"_47":233,"_32":234,"_30":235,"_142":153,"_39":40,"_38":236,"_144":25,"_36":237,"_13":143,"_33":221,"_35":238,"_24":25,"_146":-5,"_195":239,"_27":240},{"_47":225,"_32":226,"_30":227,"_142":153,"_39":40,"_38":228,"_144":25,"_36":229,"_13":143,"_33":221,"_35":230,"_24":25,"_146":-5,"_195":231,"_27":232},{"_47":217,"_32":189,"_30":218,"_142":153,"_39":40,"_38":219,"_144":25,"_36":220,"_13":143,"_33":221,"_35":222,"_24":25,"_146":-5,"_195":223,"_27":224},{"_47":148,"_32":28,"_30":31,"_142":-5,"_39":40,"_38":14,"_144":63,"_36":214,"_13":67,"_33":34,"_35":-5,"_24":25,"_146":-5,"_195":215,"_27":216},{"_47":210,"_32":44,"_30":43,"_142":31,"_39":40,"_38":14,"_144":63,"_36":211,"_13":67,"_33":28,"_35":45,"_24":25,"_146":-5,"_195":212,"_27":213},{"_47":139,"_32":140,"_30":141,"_142":-5,"_39":40,"_38":143,"_144":63,"_36":207,"_13":67,"_33":34,"_35":-5,"_24":25,"_146":-5,"_195":208,"_27":209},{"_47":198,"_32":199,"_30":200,"_142":141,"_39":40,"_38":201,"_144":25,"_36":202,"_13":203,"_33":21,"_35":204,"_24":25,"_146":-5,"_195":205,"_27":206},{"_47":188,"_32":189,"_30":190,"_142":141,"_39":40,"_38":191,"_144":25,"_36":192,"_13":143,"_33":193,"_35":194,"_24":25,"_146":-5,"_195":196,"_27":197},"7c66571e-dc77-4e2e-bdfb-729e8669fa04","sources.ts","18a74ccc-af66-11f1-9858-1607ee4eb77e",30,["D",1789299277591],"script","// 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 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)) {\n return new Response(\n \"unauthorized: open the tracker link that includes ?token=\",\n { status: 401 },\n );\n }\n return new Response(HTML, {\n headers: {\n \"content-type\": \"text/html; charset=utf-8\",\n \"cache-control\": \"no-store\",\n \"x-robots-tag\": \"noindex\",\n },\n });\n}",[],[158,253],"f5accce4-9ada-458f-a8e8-3d4eb79e01c2","feed.ts","05d34138-aef2-11f1-8674-1607ee4eb77e",28,["D",1789298928499],"// 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// ?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\"); // ?kinds=all includes signal-*/cl-parking rows\r\n return json(list, 200, { \"cache-control\": \"no-store\" });\r\n}\r\n",[],[158,262],"44fa40e0-8133-4b29-b60a-c39ca57840f0","admin.ts","066872bc-aef2-11f1-8bc7-1607ee4eb77e",29,["D",1789298941172],4,"// 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// 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, PUSH_THRESHOLD } from \"../lib/core.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\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=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 ok = await pushDiscord({ id: \"TEST\", addr: \"Test push - 123 Example St NW\", area: \"Petworth\", price: 2350, beds: 2, park: \"garage\", type: \"rowhouse\", ll: \"individual\", dog: true, url: \"https://example.com\", source: \"test\", score: 12, notes: \"Pipeline test; ignore.\" });\r\n return json({ pushed: ok });\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",[],[158,270],"628c5726-9291-4ed6-91cc-49658499dcde","add.ts",12,["D",1789249256010],"// housing-add: manual ingestion endpoint (POST). Claude in Chrome and Logan post\n// FB / sign / portal finds here. Shared-secret header X-Housing-Token.\n//\n// Body (JSON, single object or array):\n// { addr, area?, price?, beds?, park?, type?, ll?, dog?, url, src, note?, text? }\n// `text` is optional free text (the listing body) used to infer any field left blank.\nimport {\n AREAS, PARK, HTYPE, LL, ensureSchema, upsertListing, inferArea, inferPark, inferType, inferLL, inferDog,\n inferBeds, clampBeds, parsePrice, inferPrice, checkToken, json, CORS, type Area,\n} from \"../lib/core.ts\";\n\nexport default async function (req: Request): Promise {\n if (req.method === \"OPTIONS\") return new Response(null, { status: 204, headers: CORS });\n if (req.method !== \"POST\") return json({ error: \"POST only\" }, 405);\n if (!checkToken(req)) return json({ error: \"unauthorized\" }, 401);\n\n let body: any;\n try { body = await req.json(); } catch { return json({ error: \"invalid JSON\" }, 400); }\n const items: any[] = Array.isArray(body) ? body : [body];\n if (items.length === 0 || items.length > 50) return json({ error: \"1-50 listings per request\" }, 400);\n\n await ensureSchema();\n const results: any[] = [];\n for (const it of items) {\n const text = [it.addr, it.title, it.note, it.text].filter(Boolean).join(\" \\n \");\n const url = String(it.url || \"\").trim();\n const src = String(it.src || it.source || \"manual\").toLowerCase().trim();\n if (!url && !it.addr) { results.push({ error: \"need url or addr\", input: it }); continue; }\n\n let area: Area | null = AREAS.includes(it.area) ? it.area : inferArea(text);\n if (!area) { results.push({ error: `area required; one of ${AREAS.join(\" | \")}`, input: it }); continue; }\n\n let beds = it.beds != null && it.beds !== \"\" ? Number(it.beds) : inferBeds(text);\n if (beds === 0) { results.push({ skipped: \"studio\", input: it }); continue; }\n beds = clampBeds(beds);\n\n const park = PARK.includes(it.park) ? it.park : inferPark(text);\n const type = HTYPE.includes(it.type) ? it.type : inferType(text);\n // FB/CL/sign posts default to individual-landlord signal; portals default to pm\n const llDefault = [\"fb\", \"fbm\", \"facebook\", \"craigslist\", \"sign\", \"popville\", \"manual\"].includes(src) ? \"individual\" : \"pm\";\n const ll = LL.includes(it.ll) ? it.ll : inferLL(text, llDefault);\n const dog = typeof it.dog === \"boolean\" ? it.dog : inferDog(text);\n const price = it.price != null && it.price !== \"\" ? parsePrice(it.price) : inferPrice(text);\n\n const r = await upsertListing({\n addr: it.addr ? String(it.addr).trim() : null,\n area, price, beds, source: src, externalId: it.externalId || it.external_id || null, url: url || \"\",\n park, type, ll, dog, notes: String(it.note || \"\").trim(), raw: it.text ? String(it.text) : undefined, unit: it.unit || null,\n }, { push: true });\n results.push(r);\n }\n return json({ ok: true, results });\n}\n",[],[158,279],["D",1789248989432],[174,175,176,177],[158],["D",1789248987477],["D",1789519256886],{"_104":103,"_112":108},{"_104":103,"_105":106,"_107":108,"_18":59,"_109":110,"_111":25},{"_13":93,"_32":94,"_47":40,"_95":48,"_96":-5,"_97":-5,"_98":-5,"_99":-5,"_100":-5,"_101":49,"_102":103},"ctx",{"_86":-5,"_132":326,"_327":328,"_329":330,"_331":25,"_332":25,"_333":25,"_334":63,"_335":-5,"_336":-7,"_337":-7,"_338":67,"_339":25,"_340":25,"_341":-5,"_342":25,"_343":25,"_344":25,"_345":-5},"ENV",{"_297":298,"_299":300,"_301":94,"_302":303,"_304":305,"_306":307,"_308":309,"_310":311,"_312":313,"_314":315,"_316":317,"_318":319,"_320":321,"_322":323,"_324":325},"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"]

Diff · v32