[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_418":419,"_420":421},"routes/_app.x.$handle.$name",{"_93":92,"_31":42,"_101":83,"_26":102,"_13":14,"_103":-5,"_11":104,"_105":106,"_107":108,"_109":110,"_111":112,"_20":-5,"_113":-5,"_114":-5,"_115":24,"_116":117,"_118":55,"_119":-5,"_120":-5,"_121":122},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_40":41,"_31":42,"_35":43,"_44":-5,"_45":24,"_46":47,"_48":47,"_49":-5,"_50":-5,"_18":51,"_52":53,"_54":55,"_56":55,"_57":-5,"_58":59,"_60":61,"_62":-5,"_63":-5,"_64":-5,"_65":-5,"_66":67,"_68":67,"_69":70,"_71":70,"_72":70,"_73":67,"_74":67,"_75":76,"_77":78,"_79":80,"_81":24},"version",299,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":-7,"_23":24,"_25":24,"_26":27,"_28":27},"file",{"_29":30,"_31":27,"_32":20,"_33":34,"_35":36,"_37":14,"_38":39,"_23":24},"previous","deleted",false,"deletedHere","path","deno.json","latestPath","fileId","7d307dfc-f806-11f0-8f00-42dde27851f2","name","fileType","content","{\n \"$schema\": \"https://raw.githubusercontent.com/denoland/deno/98f62cee78e85bfc47c62ed703777c6bc8794f1c/cli/schemas/config-file.v1.json\",\n \"lock\": false,\n \"compilerOptions\": {\n \"noImplicitAny\": false,\n \"strict\": true,\n \"types\": [\"https://www.val.town/types/valtown.d.ts\"],\n \"lib\": [\n \"dom\",\n \"dom.iterable\",\n \"dom.asynciterable\",\n \"deno.ns\",\n \"deno.unstable\"\n ]\n },\n \"lint\": {\n \"include\": [\"deno:/https/esm.town/**/*\"],\n \"rules\": {\n \"exclude\": [\"no-explicit-any\"]\n }\n },\n \"node_modules_dir\": false,\n \"experimental\": {\n \"unstable-node-globals\": true,\n \"unstable-temporal\": true,\n \"unstable-worker-options\": true,\n \"unstable-sloppy-imports\": true\n }\n}","createdAt",["D",1769136720207],"branchVersion","branchId","d3df7564-4d5b-11f0-b336-76b3cceeab13","id","d3df2ae6-4d5b-11f0-b336-76b3cceeab13","loki",["D",1750371724044],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","imageUrl","7ed186b0-c78a-4757-a5b0-12c00ac89afa","pinnedFileId","9cf06f84-4d5d-11f0-a672-76b3cceeab13","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","e9195859-3c6b-4b40-bb3e-c11844477fdf","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_93":92,"_100":96},"org",{"_93":92,"_94":-5,"_95":96,"_18":51,"_97":98,"_99":24},"branch",{"_13":82,"_31":83,"_40":39,"_84":41,"_85":-5,"_86":-5,"_87":-5,"_88":-5,"_89":-5,"_90":42,"_91":92},"isOwned",336,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","shapedlines","handle","displayName","avatar","https://img.clerk.com/eyJ0eXBlIjoicHJveHkiLCJzcmMiOiJodHRwczovL2ltYWdlcy5jbGVyay5kZXYvb2F1dGhfZ2l0aHViL2ltZ18yYlc2Q1A2eUFyNEdDeXBud0E0bFJyWlJVUzQifQ","tier","pro","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_40":41,"_31":42,"_35":414,"_44":-5,"_45":24,"_46":47,"_48":47,"_49":-5,"_50":-5,"_18":51,"_52":53,"_54":55,"_56":55,"_57":-5,"_58":59,"_60":61,"_62":-5,"_63":-5,"_64":-5,"_65":-5,"_66":67,"_68":67,"_69":70,"_71":70,"_72":70,"_73":67,"_74":67,"_75":415,"_77":416,"_79":417,"_81":24},"tree",[289,291,297,298,299,300,301,302,303,304,305,306,307,308,309,310,311,312],"files",[289,290,291,292,293,294,295,296,297,298,299,300,301,302,303,304,305,306,307,308,309,310,311,312],"counts",{"_277":59,"_278":279,"_280":59,"_281":282,"_283":284},"contents",[125,126,127,128,129,130,131,132,133,134,135,136,137,138,139,140,141,142],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{"_123":124},"7db1ceb6-f806-11f0-810f-42dde27851f2","loki.shapedlines.com",{"_40":271,"_31":272,"_29":273,"_146":-5,"_38":39,"_37":274,"_148":55,"_35":275,"_13":59,"_32":257,"_33":-5,"_23":24,"_153":-5,"_26":276},{"_40":265,"_31":266,"_29":267,"_146":-5,"_38":39,"_37":268,"_148":55,"_35":269,"_13":59,"_32":257,"_33":-5,"_23":24,"_153":-5,"_26":270},{"_40":259,"_31":260,"_29":261,"_146":-5,"_38":39,"_37":262,"_148":55,"_35":263,"_13":59,"_32":257,"_33":-5,"_23":24,"_153":-5,"_26":264},{"_40":252,"_31":253,"_29":254,"_146":-5,"_38":39,"_37":255,"_148":55,"_35":256,"_13":59,"_32":257,"_33":-5,"_23":24,"_153":-5,"_26":258},{"_40":245,"_31":246,"_29":247,"_146":-5,"_38":39,"_37":248,"_148":55,"_35":249,"_13":59,"_32":20,"_33":250,"_23":24,"_153":-5,"_26":251},{"_40":236,"_31":237,"_29":238,"_146":-5,"_38":39,"_37":239,"_148":55,"_35":240,"_13":241,"_32":242,"_33":243,"_23":24,"_153":-5,"_26":244},{"_40":230,"_31":231,"_29":53,"_146":-5,"_38":39,"_37":232,"_148":55,"_35":233,"_13":169,"_32":170,"_33":234,"_23":24,"_153":-5,"_26":235},{"_40":222,"_31":223,"_29":224,"_146":-5,"_38":39,"_37":225,"_148":55,"_35":226,"_13":227,"_32":151,"_33":228,"_23":24,"_153":-5,"_26":229},{"_40":219,"_31":27,"_29":30,"_146":-5,"_38":39,"_37":14,"_148":55,"_35":220,"_13":59,"_32":20,"_33":34,"_23":24,"_153":-5,"_26":221},{"_40":211,"_31":212,"_29":213,"_146":-5,"_38":39,"_37":214,"_148":55,"_35":215,"_13":216,"_32":170,"_33":217,"_23":24,"_153":-5,"_26":218},{"_40":204,"_31":205,"_29":206,"_146":-5,"_38":39,"_37":207,"_148":55,"_35":208,"_13":178,"_32":170,"_33":209,"_23":24,"_153":-5,"_26":210},{"_40":196,"_31":197,"_29":198,"_146":-5,"_38":39,"_37":199,"_148":24,"_35":200,"_13":201,"_32":170,"_33":202,"_23":24,"_153":-5,"_26":203},{"_40":189,"_31":190,"_29":191,"_146":-5,"_38":39,"_37":192,"_148":24,"_35":193,"_13":178,"_32":170,"_33":194,"_23":24,"_153":-5,"_26":195},{"_40":181,"_31":182,"_29":183,"_146":-5,"_38":39,"_37":184,"_148":24,"_35":185,"_13":186,"_32":161,"_33":187,"_23":24,"_153":-5,"_26":188},{"_40":173,"_31":174,"_29":175,"_146":-5,"_38":39,"_37":176,"_148":55,"_35":177,"_13":178,"_32":170,"_33":179,"_23":24,"_153":-5,"_26":180},{"_40":164,"_31":165,"_29":166,"_146":-5,"_38":39,"_37":167,"_148":55,"_35":168,"_13":169,"_32":170,"_33":171,"_23":24,"_153":-5,"_26":172},{"_40":155,"_31":156,"_29":157,"_146":-5,"_38":39,"_37":158,"_148":55,"_35":159,"_13":160,"_32":161,"_33":162,"_23":24,"_153":-5,"_26":163},{"_40":143,"_31":144,"_29":145,"_146":-5,"_38":39,"_37":147,"_148":24,"_35":149,"_13":150,"_32":151,"_33":152,"_23":24,"_153":-5,"_26":154},"c308d5cc-6774-11f0-bf6c-0224a6c84d84","zillowResults.tsx","46fb0eca-6772-11f0-be61-0224a6c84d84","parentId",283,"latest",["D",1753241163437],14,"interval","import { scrapeZillowOrchestrator } from \"https://esm.town/v/shapedlines/houseSearchSF/scrapeZillowOrchestrator.tsx\";\n\nexport default async function(interval: Interval) {\n // call zillow function, return results\n const zillow_url =\n \"https://www.zillow.com/san-francisco-ca/rentals/?searchQueryState=%7B%22pagination%22%3A%7B%22currentPage%22%3A1%7D%2C%22isMapVisible%22%3Atrue%2C%22mapBounds%22%3A%7B%22west%22%3A-122.57855502490234%2C%22east%22%3A-122.28810397509766%2C%22south%22%3A37.65402648064302%2C%22north%22%3A37.896358847455964%7D%2C%22regionSelection%22%3A%5B%7B%22regionId%22%3A20330%2C%22regionType%22%3A6%7D%5D%2C%22filterState%22%3A%7B%22sort%22%3A%7B%22value%22%3A%22days%22%7D%2C%22fr%22%3A%7B%22value%22%3Atrue%7D%2C%22fsba%22%3A%7B%22value%22%3Afalse%7D%2C%22fsbo%22%3A%7B%22value%22%3Afalse%7D%2C%22nc%22%3A%7B%22value%22%3Afalse%7D%2C%22cmsn%22%3A%7B%22value%22%3Afalse%7D%2C%22auc%22%3A%7B%22value%22%3Afalse%7D%2C%22fore%22%3A%7B%22value%22%3Afalse%7D%2C%22mf%22%3A%7B%22value%22%3Afalse%7D%2C%22land%22%3A%7B%22value%22%3Afalse%7D%2C%22manu%22%3A%7B%22value%22%3Afalse%7D%7D%2C%22isListVisible%22%3Atrue%2C%22mapZoom%22%3A12%2C%22usersSearchTerm%22%3A%22San%20Francisco%20CA%22%7D\";\n\n const zillow_results = await scrapeZillowOrchestrator(zillow_url);\n console.log(zillow_results);\n\n // store results in database (TODO: dedup / remove listings that are no longer there)\n}","label",[144],"7fc0d4ae-6774-11f0-8b01-0224a6c84d84","zillowParseURL.tsx","f3734ae0-65ac-11f0-8f64-0224a6c84d84",279,["D",1753241050560],15,"script","export const zillowParseURL = async (zillow_url, page_number) => {\n // console.log(\"Input URL:\", zillow_url);\n // console.log(\"Target page:\", page_number);\n\n try {\n // Parse the URL to extract query parameters\n const url = new URL(zillow_url);\n const searchQueryState = url.searchParams.get(\"searchQueryState\");\n // console.log(searchQueryState);\n if (!searchQueryState) {\n throw new Error(\"No searchQueryState parameter found in URL\");\n }\n\n // Decode the URL-encoded JSON\n const decodedString = decodeURIComponent(searchQueryState);\n // console.log(\"Decoded JSON string:\", decodedString);\n\n // Parse the JSON\n const searchState = JSON.parse(decodedString);\n // console.log(\"Parsed search state:\", searchState);\n\n // Modify the pagination for the new page number\n searchState.pagination = {\n currentPage: page_number,\n };\n\n // Re-encode the JSON back to a URL-encoded string\n const newEncodedState = encodeURIComponent(JSON.stringify(searchState));\n\n // Build the new URL\n let newPath = url.pathname;\n\n // Handle page suffix in the URL path\n if (page_number > 1) {\n // Remove any existing page suffix and add the new one\n newPath = newPath.replace(/\\/\\d+_p\\/$/, \"/\"); // Remove existing page suffix\n if (!newPath.endsWith(\"/\")) newPath += \"/\";\n newPath += `${page_number}_p/`;\n } else {\n // For page 1, remove any page suffix\n newPath = newPath.replace(/\\/\\d+_p\\/$/, \"/\");\n }\n\n // Construct the final URL\n const newUrl = `${url.protocol}//${url.host}${newPath}?searchQueryState=${newEncodedState}`;\n\n // console.log(\"New URL:\", newUrl);\n return newUrl;\n } catch (error) {\n console.error(\"Error parsing URL:\", error);\n return null;\n }\n};\n\n// // Test with your working URL\n// const testUrl =\n// \"https://www.zillow.com/san-francisco-ca/rentals/?searchQueryState=%7B%22pagination%22%3A%7B%7D%2C%22isMapVisible%22%3Atrue%2C%22mapBounds%22%3A%7B%22west%22%3A-122.57855502490234%2C%22east%22%3A-122.28810397509766%2C%22south%22%3A37.65402648064302%2C%22north%22%3A37.896358847455964%7D%2C%22regionSelection%22%3A%5B%7B%22regionId%22%3A20330%2C%22regionType%22%3A6%7D%5D%2C%22filterState%22%3A%7B%22sort%22%3A%7B%22value%22%3A%22days%22%7D%2C%22fr%22%3A%7B%22value%22%3Atrue%7D%2C%22fsba%22%3A%7B%22value%22%3Afalse%7D%2C%22fsbo%22%3A%7B%22value%22%3Afalse%7D%2C%22nc%22%3A%7B%22value%22%3Afalse%7D%2C%22cmsn%22%3A%7B%22value%22%3Afalse%7D%2C%22auc%22%3A%7B%22value%22%3Afalse%7D%2C%22fore%22%3A%7B%22value%22%3Afalse%7D%2C%22mf%22%3A%7B%22value%22%3Afalse%7D%2C%22land%22%3A%7B%22value%22%3Afalse%7D%2C%22manu%22%3A%7B%22value%22%3Afalse%7D%7D%2C%22isListVisible%22%3Atrue%2C%22mapZoom%22%3A12%2C%22usersSearchTerm%22%3A%22San%20Francisco%20CA%22%7D\";\n\n// console.log(\"=== TESTING ===\");\n// console.log(\"Page 1:\");\n// zillowParseURL(testUrl, 1);\n\n// console.log(\"\\nPage 2:\");\n// zillowParseURL(testUrl, 2);\n\n// console.log(\"\\nPage 3:\");\n// zillowParseURL(testUrl, 3);\n\n// // Test with invalid input\n// console.log(\"\\nInvalid URL test:\");\n// zillowParseURL(\"hello\", 2);",[156],"497b71d2-591a-11f0-88f0-f69ea79377d9","scraper-api.ts","8059d6b8-5919-11f0-93d0-f69ea79377d9",57,["D",1751662988511],5,"http","/**\n * HTTP API endpoint for the listing URL scraper\n */\n\n// Inline the scraper functions since Val Town doesn't support local imports\ninterface ListingData {\n url: string;\n address: string;\n}\n\nasync function scrapeListingUrls(url: string): Promise {\n try {\n const response = await fetch(url, {\n headers: {\n 'User-Agent': 'Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_7) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/120.0.0.0 Safari/537.36',\n 'Accept': 'text/html,application/xhtml+xml,application/xml;q=0.9,image/webp,*/*;q=0.8',\n 'Accept-Language': 'en-US,en;q=0.5',\n 'Accept-Encoding': 'gzip, deflate, br',\n 'DNT': '1',\n 'Connection': 'keep-alive',\n 'Upgrade-Insecure-Requests': '1',\n 'Sec-Fetch-Dest': 'document',\n 'Sec-Fetch-Mode': 'navigate',\n 'Sec-Fetch-Site': 'none',\n 'Cache-Control': 'max-age=0'\n }\n });\n\n if (!response.ok) {\n throw new Error(`HTTP error! status: ${response.status} - ${response.statusText}. This might be due to anti-bot protection.`);\n }\n\n const html = await response.text();\n return parseListingUrls(html);\n } catch (error) {\n console.error('Error scraping webpage:', error);\n throw error;\n }\n}\n\nfunction parseListingUrls(html: string): ListingData[] {\n const listings: ListingData[] = [];\n \n const listingRegex = /]*href=\"([^\"]*)\"[^>]*data-test=\"property-card-link\"[^>]*>[\\s\\S]*?]*>([^<]*)<\\/address>[\\s\\S]*?<\\/a>/gi;\n \n let match;\n while ((match = listingRegex.exec(html)) !== null) {\n const url = match[1];\n const address = match[2].trim();\n \n if (url && address) {\n listings.push({\n url: url.startsWith('http') ? url : `https://www.zillow.com${url}`,\n address: address\n });\n }\n }\n\n if (listings.length === 0) {\n const alternativeRegex = /]*data-test=\"property-card-link\"[^>]*href=\"([^\"]*)\"[^>]*>[\\s\\S]*?]*>([^<]*)<\\/address>[\\s\\S]*?<\\/a>/gi;\n \n while ((match = alternativeRegex.exec(html)) !== null) {\n const url = match[1];\n const address = match[2].trim();\n \n if (url && address) {\n listings.push({\n url: url.startsWith('http') ? url : `https://www.zillow.com${url}`,\n address: address\n });\n }\n }\n }\n\n return listings;\n}\n\nexport default async function(req: Request): Promise {\n // Handle CORS\n const corsHeaders = {\n 'Access-Control-Allow-Origin': '*',\n 'Access-Control-Allow-Methods': 'GET, POST, OPTIONS',\n 'Access-Control-Allow-Headers': 'Content-Type',\n };\n\n if (req.method === 'OPTIONS') {\n return new Response(null, { headers: corsHeaders });\n }\n\n try {\n const url = new URL(req.url);\n \n if (req.method === 'GET') {\n const testParam = url.searchParams.get('test');\n \n if (testParam === 'real') {\n // Test with a simple HTML page that has similar structure\n const testHtml = `\n

\n \n

\n `;\n \n const listings = parseListingUrls(testHtml);\n \n return new Response(JSON.stringify({\n success: true,\n message: \"Real parsing test with sample HTML\",\n count: listings.length,\n listings: listings\n }, null, 2), {\n headers: { \n 'Content-Type': 'application/json',\n ...corsHeaders\n }\n });\n }\n \n // Default test endpoint - returns sample parsing results\n const sampleHtml = `\n

\n \n

1020 Pierce St #A, San Francisco, CA 94115

\n \n \n

456 Oak St, San Francisco, CA 94102

\n \n

\n `;\n \n const listings = parseListingUrls(sampleHtml);\n \n return new Response(JSON.stringify({\n success: true,\n message: \"Sample HTML parsing test\",\n count: listings.length,\n listings: listings,\n note: \"Add ?test=real to test with different HTML structure\"\n }, null, 2), {\n headers: { \n 'Content-Type': 'application/json',\n ...corsHeaders\n }\n });\n }\n \n if (req.method === 'POST') {\n const body = await req.json();\n const targetUrl = body.url;\n \n if (!targetUrl) {\n return new Response(JSON.stringify({\n success: false,\n error: \"URL is required in request body\"\n }), {\n status: 400,\n headers: { \n 'Content-Type': 'application/json',\n ...corsHeaders\n }\n });\n }\n \n // Scrape the provided URL\n const listings = await scrapeListingUrls(targetUrl);\n \n return new Response(JSON.stringify({\n success: true,\n url: targetUrl,\n count: listings.length,\n listings: listings,\n urls: listings.map(l => l.url)\n }, null, 2), {\n headers: { \n 'Content-Type': 'application/json',\n ...corsHeaders\n }\n });\n }\n \n return new Response(JSON.stringify({\n success: false,\n error: \"Method not allowed. Use GET for test or POST with URL in body.\"\n }), {\n status: 405,\n headers: { \n 'Content-Type': 'application/json',\n ...corsHeaders\n }\n });\n \n } catch (error) {\n console.error('Scraper API error:', error);\n \n return new Response(JSON.stringify({\n success: false,\n error: error.message || \"Internal server error\"\n }), {\n status: 500,\n headers: { \n 'Content-Type': 'application/json',\n ...corsHeaders\n }\n });\n }\n}",[165],"4a9d5eca-4d5f-11f0-80e4-76b3cceeab13","scrapedHouses.tsx","d3e16446-4d5b-11f0-b336-76b3cceeab13",21,["D",1750373211745],3,"// This val creates a form to input a Zillow or Craigslist link, determines the link type,\n// calls the appropriate scraping API, and renders the results in a table.\n// It uses React for the UI, fetch for API calls, and basic string manipulation for link validation.\n\n/** @jsxImportSource https://esm.sh/react */\nimport React, { useState } from \"https://esm.sh/react\";\nimport { createRoot } from \"https://esm.sh/react-dom/client\";\n\nfunction App() {\n const [link, setLink] = useState(\"\");\n const [results, setResults] = useState(null);\n const [isLoading, setIsLoading] = useState(false);\n const [error, setError] = useState(\"\");\n\n const handleSubmit = async (e) => {\n e.preventDefault();\n setError(\"\");\n setResults(null);\n setIsLoading(true);\n\n try {\n const response = await fetch(\"/scrape\", {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ link }),\n });\n\n if (!response.ok) {\n throw new Error(\"Failed to fetch data\");\n }\n\n const data = await response.json();\n setResults(data);\n } catch (err) {\n setError(\"An error occurred while fetching the data.\");\n } finally {\n setIsLoading(false);\n }\n };\n\n return (\n

Property Scraper

\n setLink(e.target.value)}\n placeholder=\"Enter Zillow or Craigslist link\"\n required\n />\n \n \n {isLoading &&

}\n {error &&

{error}

}\n {results && (\n \n \n \n {Object.keys(results).map((key) => )}\n \n \n \n \n {Object.values(results).map((value, index) => )}\n \n \n

{key}
{value}

\n )}\n

\n \n View source: val.town\n \n

\n );\n}\n\nfunction client() {\n createRoot(document.getElementById(\"root\")).render();\n}\n\nif (typeof document !== \"undefined\") {\n client();\n}\n\nasync function server(request: Request): Promise {\n if (request.method === \"POST\" && new URL(request.url).pathname === \"/scrape\") {\n const { link } = await request.json();\n let scrapingEndpoint;\n\n if (link.includes(\"zillow.com\")) {\n scrapingEndpoint = \"https://shapedlines-scrapezillowapi.web.val.run?url=\";\n } else if (link.includes(\"craigslist.org\")) {\n scrapingEndpoint = \"https://shapedlines-scrapecraigslistapi.web.val.run?url=\";\n } else {\n return new Response(JSON.stringify({ error: \"Invalid link. Please provide a Zillow or Craigslist link.\" }), {\n status: 400,\n headers: { \"Content-Type\": \"application/json\" },\n });\n }\n\n try {\n const scrapeResponse = await fetch(`${scrapingEndpoint}${encodeURIComponent(link)}`);\n if (!scrapeResponse.ok) {\n throw new Error(\"Failed to scrape data\");\n }\n const scrapeResult = await scrapeResponse.json();\n\n // Calculate transit time\n const transitResponse = await fetch(\n `https://shapedlines-calculatetransitapi.web.val.run?address=${encodeURIComponent(scrapeResult.address)}`,\n );\n if (!transitResponse.ok) {\n throw new Error(\"Failed to calculate transit time\");\n }\n const transitResult = await transitResponse.json();\n\n return new Response(JSON.stringify({ ...scrapeResult, ...transitResult }), {\n headers: { \"Content-Type\": \"application/json\" },\n });\n } catch (error) {\n return new Response(JSON.stringify({ error: \"Failed to scrape data\" }), {\n status: 500,\n headers: { \"Content-Type\": \"application/json\" },\n });\n }\n }\n\n return new Response(\n `\n \n \n Property Scraper\n \n \n \n

\n \n \n \n `,\n {\n headers: {\n \"content-type\": \"text/html\",\n },\n },\n );\n}\n\nconst css = `\nbody {\n font-family: Arial, sans-serif;\n max-width: 800px;\n margin: 0 auto;\n padding: 20px;\n}\n\ninput[type=\"text\"] {\n width: 70%;\n padding: 10px;\n margin-right: 10px;\n}\n\nbutton {\n padding: 10px 20px;\n}\n\ntable {\n width: 100%;\n border-collapse: collapse;\n margin-top: 20px;\n}\n\nth, td {\n border: 1px solid #ddd;\n padding: 8px;\n text-align: left;\n}\n\nth {\n background-color: #f2f2f2;\n}\n\n.loader {\n border: 4px solid #f3f3f3;\n border-top: 4px solid #3498db;\n border-radius: 50%;\n width: 40px;\n height: 40px;\n animation: spin 1s linear infinite;\n margin: 20px auto;\n}\n\n@keyframes spin {\n 0% { transform: rotate(0deg); }\n 100% { transform: rotate(360deg); }\n}\n`;\n\nexport default server;",[174],"dcd90020-6775-11f0-9af0-0224a6c84d84","scrapeZillowOrchestrator.tsx","3eed0c20-65af-11f0-986f-0224a6c84d84",286,["D",1753241636242],65,"import { zillowParseURL } from \"https://esm.town/v/shapedlines/houseSearchSF/zillowParseURL.tsx\";\n\nexport const scrapeZillowOrchestrator = async (zillow_filters_url) => {\n // list of results\n let zillow_results = [];\n\n // call to navigate to the first page and scrape it, returning the first page results and the number of pages\n const baseEndpoint = \"https://shapedlines--31933b5e642311f09be00224a6c84d84.web.val.run\";\n let current_zillow_filters_url = zillow_filters_url;\n let total_zillow_pages = 1;\n\n // first run\n try {\n const response = await requestZillowData(baseEndpoint, current_zillow_filters_url, 1);\n const zillow_data_first = JSON.parse(response.data.evaluate.value);\n // console.log(\"Success:\", zillow_json);\n // console.log(zillow_data_first);\n\n zillow_results.push(...zillow_data_first.searchResults.listResults); // add page 1 results to the results list\n console.log(zillow_results);\n total_zillow_pages = zillow_data_first.searchList.totalPages; // set the number of pages to scrape\n // console.log(\"total_zillow_pages\", total_zillow_pages);\n // console.log(1, zillow_data_first.searchResults.listResults[0]);\n } catch (error) {\n console.error(\"First Run Request failed:\", error);\n }\n\n // X subsequent runs: for each page, scrape and return the results\n let current_zillow_page = 1;\n while (current_zillow_page <= total_zillow_pages) {\n current_zillow_page += 1;\n\n try {\n const response = await requestZillowData(baseEndpoint, current_zillow_filters_url, current_zillow_page);\n const zillow_data_x = JSON.parse(response.data.evaluate.value);\n // console.log(\"Success:\", zillow_json);\n // console.log(typeof zillow_data_x);\n\n const zillow_page_results = zillow_data_x.searchResults.listResults;\n\n zillow_results.push(...zillow_page_results); // add page Z results to the results list\n // console.log(current_zillow_page, zillow_page_results[0]);\n } catch (error) {\n console.error(\"Request failed:\", error);\n }\n }\n\n return zillow_results;\n};\n\nasync function requestZillowData(baseEndpoint, zillowURL, page_number = 1) {\n try {\n // Modify the Zillow URL to include the correct page number\n const modifiedZillowURL = await zillowParseURL(zillowURL, page_number);\n if (!modifiedZillowURL) {\n throw new Error(\"Failed to generate modified Zillow URL\");\n }\n\n // Construct the API request URL\n const url = new URL(baseEndpoint);\n url.searchParams.set(\"zillowURL\", modifiedZillowURL);\n\n // console.log(\"Making request to:\", url.toString());\n\n // Make the request\n const response = await fetch(url.toString(), {\n method: \"GET\",\n headers: {\n \"Content-Type\": \"application/json\",\n },\n });\n\n if (!response.ok) {\n throw new Error(`HTTP error! status: ${response.status}`);\n }\n\n const data = await response.json();\n return data;\n } catch (error) {\n console.error(\"Error making request:\", error);\n throw error;\n }\n}\n\n// scrapeZillowOrchestrator(\n// \"https://www.zillow.com/san-francisco-ca/rentals/?searchQueryState=%7B%22pagination%22%3A%7B%22currentPage%22%3A1%7D%2C%22isMapVisible%22%3Atrue%2C%22mapBounds%22%3A%7B%22west%22%3A-122.57855502490234%2C%22east%22%3A-122.28810397509766%2C%22south%22%3A37.65402648064302%2C%22north%22%3A37.896358847455964%7D%2C%22regionSelection%22%3A%5B%7B%22regionId%22%3A20330%2C%22regionType%22%3A6%7D%5D%2C%22filterState%22%3A%7B%22sort%22%3A%7B%22value%22%3A%22days%22%7D%2C%22fr%22%3A%7B%22value%22%3Atrue%7D%2C%22fsba%22%3A%7B%22value%22%3Afalse%7D%2C%22fsbo%22%3A%7B%22value%22%3Afalse%7D%2C%22nc%22%3A%7B%22value%22%3Afalse%7D%2C%22cmsn%22%3A%7B%22value%22%3Afalse%7D%2C%22auc%22%3A%7B%22value%22%3Afalse%7D%2C%22fore%22%3A%7B%22value%22%3Afalse%7D%2C%22mf%22%3A%7B%22value%22%3Afalse%7D%2C%22land%22%3A%7B%22value%22%3Afalse%7D%2C%22manu%22%3A%7B%22value%22%3Afalse%7D%7D%2C%22isListVisible%22%3Atrue%2C%22mapZoom%22%3A12%2C%22usersSearchTerm%22%3A%22San%20Francisco%20CA%22%7D\",\n// );",[182],"5352e4ca-5919-11f0-a6b8-f69ea79377d9","scrapeZillowForRentSF.tsx","460ae6aa-5919-11f0-abdb-f69ea79377d9",45,["D",1751662575537],"export default async function (req: Request): Promise {\n return Response.json({ ok: true })\n}",[190],"95ecd7e6-6774-11f0-9af0-0224a6c84d84","scrapeZillowBrowserless.tsx","31933b5e-6423-11f0-9be0-0224a6c84d84",281,["D",1753241087758],90,"import { fetchJSON } from \"https://esm.town/v/stevekrouse/fetchJSON?v=41\";\n\nexport default async function scrapeZillowBrowserless(req: Request): Promise {\n const endpoint = \"https://production-sfo.browserless.io/chrome/bql\";\n const token = \"2ShlvGXL3n6SwXc50be914c708af153f435866d869e2d32b2\";\n\n // Extract zillowURL from URL parameters\n const requestUrl = new URL(req.url);\n const zillow_url = requestUrl.searchParams.get(\"zillowURL\");\n\n if (!zillow_url) {\n return new Response(JSON.stringify({ error: \"zillowURL parameter is required\" }), {\n status: 400,\n headers: {\n \"Content-Type\": \"application/json\",\n },\n });\n }\n const optionsString = \"&humanlike=true&blockConsentModals=true\";\n\n const options = {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({\n \"query\": `\n mutation zillowBrowserless($url: String!) {\n goto(url: $url, waitUntil: domContentLoaded) {\n status\n }\n evaluate(content: \"\"\"\n (() => {\n const el = document.getElementById('__NEXT_DATA__');\n if (!el) return null;\n try {\n const json = JSON.parse(el.textContent);\n \t const cat1 = json.props.pageProps.searchPageState.cat1;\n return JSON.stringify(cat1);\n } catch (e) {\n return null;\n }\n })()\n \"\"\") {\n value\n }\n }\n \n \n `,\n \"operationName\": \"zillowBrowserless\",\n \"variables\": {\n \"url\": zillow_url,\n },\n }),\n };\n\n const url = `${endpoint}?token=${token}${optionsString}`;\n const response = await fetch(url, options);\n const data = await response.json();\n const zillow_data = JSON.parse(data.data.evaluate.value);\n // console.log(zillow_data);\n // console.log(typeof zillow_data);\n const encoded_url = zillow_data.url;\n const page_listings = zillow_data.searchResults.listResults;\n const next_page_url = \"https://www.zillow.com\" + zillow_data.searchList.pagination.nextUrl;\n\n // console.log(encoded_url);\n // console.log(next_page_url);\n\n return new Response(JSON.stringify(data), {\n headers: {\n \"Content-Type\": \"application/json\",\n },\n });\n}",[197],"bbed969c-4d5c-11f0-a043-76b3cceeab13","scrapeZillowAPI.tsx","2a5cff4c-4d5c-11f0-a672-76b3cceeab13",7,["D",1750372113364],"// This HTTP val scrapes a Zillow listing page and returns key information in JSON format.\n// It uses the cheerio library to parse the HTML content and extract the required data.\n\nimport cheerio from \"https://esm.sh/cheerio@1.0.0-rc.12\";\n\nexport default async function server(request: Request): Promise {\n const url = new URL(request.url);\n const zillowUrl = url.searchParams.get(\"url\");\n\n if (!zillowUrl) {\n return new Response(JSON.stringify({ error: \"No Zillow URL provided\" }), {\n status: 400,\n headers: { \"Content-Type\": \"application/json\" },\n });\n }\n\n try {\n const response = await fetch(zillowUrl);\n const html = await response.text();\n const $ = cheerio.load(html);\n\n const bedBathText = $(\"[data-testid=\\\"bed-bath-sqft-facts\\\"]\").text().trim();\n const bedBathMatch = bedBathText.match(/(\\d+(?:\\.\\d+)?)\\s*bed.*?(\\d+(?:\\.\\d+)?)\\s*bath/i);\n const beds = bedBathMatch ? parseFloat(bedBathMatch[1]) : null;\n const baths = bedBathMatch ? parseFloat(bedBathMatch[2]) : null;\n const rentText = $(\"[data-testid=\\\"price\\\"] span\").text().trim();\n const rentMatch = rentText.match(/\\$?([\\d,]+)/);\n const rent = rentMatch ? parseInt(rentMatch[1].replace(/,/g, \"\"), 10) : null;\n const address = $(\"[class*=\\\"address\\\" i] h1\").text().trim();\n const availabilityText = $(\"body\").text();\n const availabilityMatch = availabilityText.match(/available\\s+(.*?2024)/i);\n let availability = \"Not specified\";\n\n interface ListingData {\n address: string;\n listingUrl: string;\n price: number | null;\n beds: number | null;\n baths: number | null;\n availability: string;\n googleMapsLink: string;\n }\n\n if (availabilityText.toLowerCase().includes(\"available now\")) {\n availability = \"now\";\n } else if (availabilityMatch) {\n availability = availabilityMatch[1].trim();\n }\n\n const googleMapsLink = `https://www.google.com/maps?q=${encodeURIComponent(address).replace(/%20/g, \"+\")}`;\n\n const data: ListingData = {\n address,\n listingUrl: zillowUrl,\n price: rent,\n beds,\n baths,\n availability,\n googleMapsLink,\n };\n\n return new Response(JSON.stringify(data, null, 2), {\n headers: { \"Content-Type\": \"application/json\" },\n });\n } catch (error) {\n console.error(\"Error scraping Zillow:\", error);\n return new Response(JSON.stringify({ error: \"Error scraping Zillow listing\" }), {\n status: 500,\n headers: { \"Content-Type\": \"application/json\" },\n });\n }\n}",[205],"0362f222-4d5f-11f0-a95b-76b3cceeab13","scrapeCraigslistAPI.tsx","bfb90ab8-4d5c-11f0-8261-76b3cceeab13",18,["D",1750373092242],4,"import * as cheerio from \"https://esm.sh/cheerio@1.0.0-rc.12\";\n\nexport default async function server(request: Request): Promise {\n const url = new URL(request.url).searchParams.get(\"url\");\n\n if (!url) {\n return new Response(\"No URL provided\", { status: 400 });\n }\n\n try {\n const response = await fetch(url);\n const html = await response.text();\n\n const $ = cheerio.load(html);\n\n let beds: number | null = null;\n let baths: number | null = null;\n\n // Look for bedroom and bathroom information\n $(\"body\").contents().each((_, element) => {\n const text = $(element).text().trim();\n\n // Check for \"BR / BA\" format\n const brBaMatch = text.match(/(\\d+)\\s*BR\\s*\\/\\s*(\\d+)\\s*BA/i);\n if (brBaMatch) {\n beds = parseInt(brBaMatch[1], 10);\n baths = parseInt(brBaMatch[2], 10);\n return false; // Break the loop if found\n }\n\n // Check for \"bed\" and \"bath\" separately\n const bedMatch = text.match(/(\\d+)\\s*bed/i);\n const bathMatch = text.match(/(\\d+)\\s*bath/i);\n if (bedMatch) beds = parseInt(bedMatch[1], 10);\n if (bathMatch) baths = parseInt(bathMatch[1], 10);\n\n // Break the loop if both are found\n if (beds !== null && baths !== null) return false;\n });\n\n let address = \"N/A\";\n // Try to find the address using the correct class\n const addressElement = $(\".street-address\");\n if (addressElement.length > 0) {\n address = addressElement.text().trim();\n }\n\n // If still not found, try searching through all text nodes\n if (address === \"N/A\") {\n $(\"body\").contents().each((_, element) => {\n const text = $(element).text().trim();\n if (\n text.match(\n /^(\\d+\\s+[\\w\\s]+(?:street|st|avenue|ave|road|rd|boulevard|blvd|lane|ln|drive|dr|way|place|pl|court|ct)\\.?)/i,\n )\n ) {\n address = text;\n return false; // break the loop\n }\n });\n }\n\n let price: number | null = null;\n const priceText = $(\".price\").text().trim();\n if (priceText) {\n const priceMatch = priceText.match(/\\$?([\\d,]+)/);\n if (priceMatch)\n price = parseInt(priceMatch[1].replace(/,/g, \"\"), 10);\n }\n\n let availability = \"N/A\";\n $(\".attrgroup span.attr\").each((_, element) => {\n const text = $(element).text().trim();\n if (text.toLowerCase().startsWith(\"available\")) {\n availability = text;\n }\n });\n\n const mapUrl = $(\"#map\").attr(\"data-latitude\") && $(\"#map\").attr(\"data-longitude\")\n ? `${$(\"#map\").attr(\"data-latitude\")},${$(\"#map\").attr(\"data-longitude\")}`\n : null;\n const googleMapsLink = mapUrl ? `https://www.google.com/maps?q=${mapUrl}` : \"N/A\";\n\n const result = {\n address,\n listingUrl: url,\n price,\n beds,\n baths,\n availability,\n googleMapsLink,\n };\n\n return new Response(JSON.stringify(result), {\n headers: { \"Content-Type\": \"application/json\" },\n });\n } catch (error) {\n return new Response(`Error: ${error.message}`, { status: 500 });\n }\n}",[212],"7d307d0c-f806-11f0-8f00-42dde27851f2",["D",1769136720207],[27],"95b0cd6c-5961-11f0-8a32-f69ea79377d9","craigslistResults","8b6340d2-5912-11f0-b744-f69ea79377d9",98,["D",1751693610646],37,"// import { scrape_craigslist_results } from \"https://esm.town/v/shapedlines/scrapeCraigslistRentListings\";\nimport { sqlite } from \"https://esm.town/v/std/sqlite\";\n\nexport default async function(interval: Interval) {\n const sf_craigslist_rent_results_url = \"https://shapedlines--b6721782590611f094e1f69ea79377d9.web.val.run\";\n\n try {\n console.log(\"Fetching Craigslist results from:\", sf_craigslist_rent_results_url);\n\n const response = await fetch(sf_craigslist_rent_results_url);\n\n if (!response.ok) {\n throw new Error(`HTTP error! status: ${response.status}`);\n }\n\n const data = await response.json(); // or response.json() if it returns JSON\n console.log(\"Response received successfully:\");\n console.log(\"Status:\", response.status);\n // console.log(\"Headers:\", Object.fromEntries(response.headers.entries()));\n // console.log(\"Data:\", data);\n\n const listingLinks: string[] = data.links;\n console.log(listingLinks);\n\n // TODOs:\n // for each link, write to the table if the link `is not already present in the table in the primary_key row\n // get all primary keys from the table titled craigslist_rent_SF\n // for each item in listingLinks, write the item to craigslist_rent_SF as the primary key and all other rows blank if the item is not present in the primary keys.\n // Initialize database connection\n // Get all existing primary keys (listing URLs) from the table\n\n const existingLinksResult = await sqlite.execute(\"SELECT id FROM craigslist_rent_SF\");\n const existingUrls = new Set(existingLinksResult.rows.map(row => row.id));\n\n console.log(`Found ${existingUrls.size} existing URLs in database`);\n\n // Filter out links that already exist in the database\n const newLinks = listingLinks.filter(link => !existingUrls.has(link));\n\n console.log(`${newLinks.length} new links to add to database`);\n\n // Insert new links into the database\n let insertedCount = 0;\n for (const link of newLinks) {\n try {\n console.log(`Inserting link: ${link}`);\n await sqlite.execute({\n sql: `INSERT INTO craigslist_rent_SF (id) VALUES (:listing_url)`,\n args: { listing_url: link },\n });\n insertedCount++;\n } catch (error) {\n console.error(`Error inserting link ${link}:`, error);\n }\n }\n\n console.log(`Successfully inserted ${insertedCount} new listings`);\n\n // Return summary information\n return {\n ...data,\n database_summary: {\n total_links_fetched: listingLinks.length,\n existing_links: existingUrls.size,\n new_links_added: insertedCount,\n database_table: \"craigslist_rent_SF\",\n },\n };\n } catch (error) {\n console.error(\"Error fetching Craigslist results:\", error);\n throw error;\n }\n}",[223],"c1e7f5be-4d5d-11f0-8a86-76b3cceeab13","calculateTransitAPI.tsx",17,["D",1750372552890],"function parseTimeToMinutes(timeString: string): number {\n const parts = timeString.split(\" \");\n let minutes = 0;\n for (let i = 0; i < parts.length; i += 2) {\n if (parts[i + 1].startsWith(\"hour\")) minutes += parseInt(parts[i]) * 60;\n if (parts[i + 1].startsWith(\"min\")) minutes += parseInt(parts[i]);\n }\n return minutes;\n}\n\nexport default async function server(request: Request): Promise {\n const url = new URL(request.url);\n\n const origin = url.searchParams.get(\"address\");\n\n if (!origin) {\n return new Response(JSON.stringify({ error: \"Address is required\" }), {\n status: 400,\n headers: { \"Content-Type\": \"application/json\" },\n });\n }\n\n const apiKey = Deno.env.get(\"GOOGLE_MAPS_API_KEY\");\n if (!apiKey) {\n return new Response(JSON.stringify({ error: \"API key is not configured\" }), {\n status: 500,\n headers: { \"Content-Type\": \"application/json\" },\n });\n }\n\n try {\n const { blob } = await import(\"https://esm.town/v/std/blob\");\n\n const groceries = await blob.getJSON(\"SF_Grocery\");\n const gyms = await blob.getJSON(\"SF_Gyms\");\n\n const nearestGrocery = await findNearest(origin, groceries, apiKey);\n const nearestGym = await findNearest(origin, gyms, apiKey);\n\n const fidiDestination = \"548 Market St, San Francisco, CA 94104\";\n const fidiDrivingTime = await getDrivingTime(origin, fidiDestination, apiKey);\n\n const robloxDestination = \"910 Park Pl Ste 300, San Mateo, CA 94403\";\n const robloxDrivingTime = await getDrivingTime(origin, robloxDestination, apiKey, \"09:00:00\", \"Tuesday\");\n\n const samsaraDestination = \"1 De Haro St, San Francisco, CA 94103\";\n const samsaraTransitTime = await getTransitTime(origin, samsaraDestination, apiKey);\n\n const zipCode = await getZipCode(origin, apiKey);\n const neighborhoodZipMap = await blob.getJSON(\"SF_Neighborhood_ZIP\");\n const neighborhood = neighborhoodZipMap[zipCode] || \"Unknown\";\n\n const result = {\n neighborhood,\n nearestGroceryStore: parseTimeToMinutes(nearestGrocery.drivingTime),\n nearestGym: parseTimeToMinutes(nearestGym.drivingTime),\n fidiTransit: parseTimeToMinutes(fidiDrivingTime),\n robloxTransit: parseTimeToMinutes(robloxDrivingTime),\n samsaraTransit: parseTimeToMinutes(samsaraTransitTime),\n };\n\n console.log(\"Calculated result:\", result);\n return new Response(JSON.stringify(result), {\n headers: { \"Content-Type\": \"application/json\" },\n });\n } catch (error) {\n return new Response(\n JSON.stringify({ error: \"An error occurred while calculating travel times\", details: error.message }),\n {\n status: 500,\n headers: { \"Content-Type\": \"application/json\" },\n },\n );\n }\n}\n\nasync function findNearest(origin: string, locations: any[], apiKey: string): Promise {\n const batchSize = 25;\n let nearestLocation = null;\n let shortestTime = Infinity;\n\n for (let i = 0; i < locations.length; i += batchSize) {\n const batch = locations.slice(i, i + batchSize);\n const destinations = batch.map(location => `${location.gps.lat},${location.gps.lng}`).join(\"|\");\n const distanceMatrixUrl = `https://maps.googleapis.com/maps/api/distancematrix/json?origins=${\n encodeURIComponent(origin)\n }&destinations=${encodeURIComponent(destinations)}&mode=driving&key=${apiKey}`;\n\n const response = await fetch(distanceMatrixUrl);\n const data = await response.json();\n\n if (data.status !== \"OK\") {\n throw new Error(`Distance Matrix API failed. Status: ${data.status}`);\n }\n\n data.rows[0].elements.forEach((element, index) => {\n if (element.status === \"OK\" && element.duration.value < shortestTime) {\n shortestTime = element.duration.value;\n nearestLocation = {\n name: batch[index].name,\n address: batch[index].address,\n drivingTime: element.duration.text, // Keep this as text, we'll parse it later\n };\n }\n });\n }\n\n if (!nearestLocation) {\n throw new Error(\"No valid locations found\");\n }\n\n return nearestLocation;\n}\n\nasync function getDrivingTime(\n origin: string,\n destination: string,\n apiKey: string,\n arrivalTime?: string,\n arrivalDay?: string,\n): Promise {\n let directionsUrl = `https://maps.googleapis.com/maps/api/directions/json?origin=${\n encodeURIComponent(origin)\n }&destination=${encodeURIComponent(destination)}&mode=driving&key=${apiKey}`;\n\n if (arrivalTime && arrivalDay) {\n const nextTuesday = getNextDayOfWeek(new Date(), arrivalDay);\n nextTuesday.setHours(parseInt(arrivalTime.split(\":\")[0]), parseInt(arrivalTime.split(\":\")[1]), 0, 0);\n directionsUrl += `&arrival_time=${Math.floor(nextTuesday.getTime() / 1000)}`;\n }\n\n const directionsResponse = await fetch(directionsUrl);\n const directionsData = await directionsResponse.json();\n\n if (directionsData.status === \"OK\") {\n const route = directionsData.routes[0];\n const leg = route.legs[0];\n return leg.duration.text; // Keep this as text, we'll parse it later\n } else {\n throw new Error(`Unable to calculate driving time. Status: ${directionsData.status}`);\n }\n}\n\nasync function getTransitTime(origin: string, destination: string, apiKey: string): Promise {\n const directionsUrl = `https://maps.googleapis.com/maps/api/directions/json?origin=${\n encodeURIComponent(origin)\n }&destination=${encodeURIComponent(destination)}&mode=transit&key=${apiKey}`;\n\n const directionsResponse = await fetch(directionsUrl);\n const directionsData = await directionsResponse.json();\n\n if (directionsData.status === \"OK\") {\n const route = directionsData.routes[0];\n const leg = route.legs[0];\n return leg.duration.text; // Keep this as text, we'll parse it later\n } else {\n throw new Error(`Unable to calculate transit time. Status: ${directionsData.status}`);\n }\n}\n\nasync function getZipCode(address: string, apiKey: string): Promise {\n const geocodeUrl = `https://maps.googleapis.com/maps/api/geocode/json?address=${\n encodeURIComponent(address)\n }&key=${apiKey}`;\n const response = await fetch(geocodeUrl);\n const data = await response.json();\n\n if (data.status === \"OK\") {\n const zipCode = data.results[0].address_components.find(\n (component) => component.types.includes(\"postal_code\"),\n )?.long_name;\n return zipCode || \"Unknown\";\n } else {\n throw new Error(`Unable to get ZIP code. Status: ${data.status}`);\n }\n}\n\nfunction getNextDayOfWeek(date: Date, dayOfWeek: string): Date {\n const days = [\"sunday\", \"monday\", \"tuesday\", \"wednesday\", \"thursday\", \"friday\", \"saturday\"];\n const targetDay = days.indexOf(dayOfWeek.toLowerCase());\n const currentDay = date.getDay();\n const daysToAdd = (targetDay + 7 - currentDay) % 7;\n date.setDate(date.getDate() + daysToAdd);\n return date;\n}",[231],"19b9e868-9c93-11f0-a40a-0224a6c84d84","ZillowEmail.ts","5c73dbd0-591f-11f0-ad5c-f69ea79377d9",288,["D",1759081605407],16,"email","import { encode } from \"https://deno.land/std@0.203.0/encoding/base64.ts\";\nimport { extractValInfo } from \"https://esm.town/v/pomdtr/extractValInfo?v=29\";\nimport { AttachmentData, email } from \"https://esm.town/v/std/email?v=13\";\n\nconst { author, name } = extractValInfo(import.meta.url);\n\nexport default async function (e: Email) {\n console.log(\"Received email HTML:\", e.html);\n\n let attachments: AttachmentData[] = [];\n for (const f of e.attachments) {\n attachments.push({\n filename: f.name,\n content: encode(await f.arrayBuffer()),\n type: f.type,\n disposition: \"attachment\",\n });\n }\n console.log(\"Forwarding email:\", e);\n return email({\n to: [\"shapedlines@gmail.com\"],\n html: e.html,\n text: e.text,\n subject: \"Fwd:\" + e.subject,\n attachments,\n replyTo: e.from,\n });\n}",[237],"931fbb6e-5919-11f0-8e09-f69ea79377d9","README.md","931fbc2c-5919-11f0-8e09-f69ea79377d9",50,["D",1751662682583],"# Listing URL Scraper\n\nA TypeScript scraper designed to extract property listing URLs from webpages, specifically optimized for Zillow-style property listings.\n\n## Files\n\n- `scraper.ts` - Main scraper functions and utilities\n- `scraper-api.ts` - HTTP API endpoint for the scraper\n- `test-scraper.ts` - Test file with sample usage\n- `README.md` - This documentation\n\n## Features\n\n- Extracts listing URLs and addresses from HTML content\n- Handles both absolute and relative URLs\n- Includes proper error handling and validation\n- Provides both programmatic API and HTTP endpoint\n- User-Agent spoofing to avoid bot detection\n\n## Usage\n\n### Programmatic Usage\n\n```typescript\nimport { scrapeListingUrls, getListingUrls } from \"./scraper.ts\";\n\n// Get full listing data (URL + address)\nconst listings = await scrapeListingUrls(\"https://www.zillow.com/san-francisco-ca/\");\nconsole.log(listings);\n// Output: [{ url: \"https://...\", address: \"123 Main St...\" }, ...]\n\n// Get just the URLs\nconst urls = await getListingUrls(\"https://www.zillow.com/san-francisco-ca/\");\nconsole.log(urls);\n// Output: [\"https://www.zillow.com/homedetails/...\", ...]\n```\n\n### HTTP API Usage\n\nThe scraper is also available as an HTTP endpoint:\n\n**GET Request** (Test with sample data):\n```bash\ncurl https://your-val-town-url.web.val.run\n```\n\n**POST Request** (Scrape a real URL):\n```bash\ncurl -X POST https://your-val-town-url.web.val.run \\\n -H \"Content-Type: application/json\" \\\n -d '{\"url\": \"https://www.zillow.com/san-francisco-ca/\"}'\n```\n\n## HTML Pattern Matching\n\nThe scraper looks for HTML elements matching this pattern:\n\n```html\n\n

[ADDRESS]

\n\n```\n\nIt uses flexible regex patterns to handle variations in:\n- Attribute order\n- CSS classes\n- Whitespace\n- Relative vs absolute URLs\n\n## Functions\n\n### `scrapeListingUrls(url: string): Promise`\nMain function that fetches a webpage and extracts all listing URLs and addresses.\n\n### `parseListingUrls(html: string): ListingData[]`\nParses HTML content to extract listing data without making HTTP requests.\n\n### `getListingUrls(url: string): Promise`\nConvenience function that returns just the URLs as an array of strings.\n\n### `validateUrls(urls: string[]): string[]`\nUtility function to filter out invalid URLs.\n\n## Error Handling\n\nThe scraper includes comprehensive error handling for:\n- Network failures\n- Invalid HTML\n- Missing elements\n- Malformed URLs\n\n## Rate Limiting & Ethics\n\nWhen scraping websites:\n- Be respectful of rate limits\n- Check robots.txt\n- Consider the website's terms of service\n- Add delays between requests for large-scale scraping\n- Use appropriate User-Agent headers\n\n## Example Output\n\n```json\n{\n \"success\": true,\n \"count\": 2,\n \"listings\": [\n {\n \"url\": \"https://www.zillow.com/homedetails/1020-Pierce-St-A-San-Francisco-CA-94115/2113064552_zpid/\",\n \"address\": \"1020 Pierce St #A, San Francisco, CA 94115\"\n },\n {\n \"url\": \"https://www.zillow.com/homedetails/456-Oak-St-San-Francisco-CA-94102/123456789_zpid/\",\n \"address\": \"456 Oak St, San Francisco, CA 94102\"\n }\n ]\n}\n```",[246],"7c93ddbc-f806-11f0-be4c-42dde27851f2","shared","7c93de8e-f806-11f0-be4c-42dde27851f2",291,["D",1769136719198],"directory",[253],"7cb32172-f806-11f0-a6eb-42dde27851f2","scrapers","7cb32212-f806-11f0-a6eb-42dde27851f2",292,["D",1769136719402],[260],"7c5ad03a-f806-11f0-a87d-42dde27851f2","frontend","7c5ad102-f806-11f0-a87d-42dde27851f2",289,["D",1769136718806],[266],"7c7592c6-f806-11f0-be4c-42dde27851f2","backend","7c759398-f806-11f0-be4c-42dde27851f2",290,["D",1769136718999],[272],"pulls","branches",2,"forks","envVars",{"_285":287,"_288":59},"connections",{"_285":59,"_286":59},"count","unfilledCount",6,"emptyCount",{"_40":271,"_31":272,"_29":273,"_146":-5,"_38":39,"_37":274,"_148":55,"_35":411,"_13":59,"_32":257,"_33":-5,"_23":24,"_153":-5,"_314":412,"_26":413},{"_40":403,"_31":404,"_29":405,"_146":273,"_38":39,"_37":406,"_148":24,"_35":407,"_13":59,"_32":161,"_33":408,"_23":24,"_153":-5,"_314":409,"_26":410},{"_40":265,"_31":266,"_29":267,"_146":-5,"_38":39,"_37":268,"_148":55,"_35":400,"_13":59,"_32":257,"_33":-5,"_23":24,"_153":-5,"_314":401,"_26":402},{"_40":393,"_31":394,"_29":395,"_146":267,"_38":39,"_37":396,"_148":55,"_35":397,"_13":59,"_32":257,"_33":-5,"_23":24,"_153":-5,"_314":398,"_26":399},{"_40":388,"_31":387,"_29":381,"_146":267,"_38":39,"_37":389,"_148":55,"_35":390,"_13":59,"_32":257,"_33":-5,"_23":24,"_153":-5,"_314":391,"_26":392},{"_40":378,"_31":379,"_29":380,"_146":381,"_38":39,"_37":382,"_148":55,"_35":383,"_13":59,"_32":161,"_33":384,"_23":24,"_153":-5,"_314":385,"_26":386},{"_40":370,"_31":371,"_29":372,"_146":267,"_38":39,"_37":373,"_148":24,"_35":374,"_13":59,"_32":161,"_33":375,"_23":24,"_153":-5,"_314":376,"_26":377},{"_40":362,"_31":363,"_29":364,"_146":267,"_38":39,"_37":365,"_148":55,"_35":366,"_13":59,"_32":20,"_33":367,"_23":24,"_153":-5,"_314":368,"_26":369},{"_40":259,"_31":260,"_29":261,"_146":-5,"_38":39,"_37":262,"_148":55,"_35":359,"_13":59,"_32":257,"_33":-5,"_23":24,"_153":-5,"_314":360,"_26":361},{"_40":252,"_31":253,"_29":254,"_146":-5,"_38":39,"_37":255,"_148":55,"_35":356,"_13":59,"_32":257,"_33":-5,"_23":24,"_153":-5,"_314":357,"_26":358},{"_40":245,"_31":246,"_29":247,"_146":-5,"_38":39,"_37":248,"_148":55,"_35":353,"_13":59,"_32":20,"_33":250,"_23":24,"_153":-5,"_314":354,"_26":355},{"_40":236,"_31":237,"_29":238,"_146":-5,"_38":39,"_37":239,"_148":55,"_35":350,"_13":241,"_32":242,"_33":243,"_23":24,"_153":-5,"_314":351,"_26":352},{"_40":230,"_31":231,"_29":53,"_146":-5,"_38":39,"_37":232,"_148":55,"_35":347,"_13":169,"_32":170,"_33":234,"_23":24,"_153":-5,"_314":348,"_26":349},{"_40":222,"_31":223,"_29":224,"_146":-5,"_38":39,"_37":225,"_148":55,"_35":344,"_13":227,"_32":151,"_33":228,"_23":24,"_153":-5,"_314":345,"_26":346},{"_40":219,"_31":27,"_29":30,"_146":-5,"_38":39,"_37":14,"_148":55,"_35":341,"_13":59,"_32":20,"_33":34,"_23":24,"_153":-5,"_314":342,"_26":343},{"_40":211,"_31":212,"_29":213,"_146":-5,"_38":39,"_37":214,"_148":55,"_35":338,"_13":216,"_32":170,"_33":217,"_23":24,"_153":-5,"_314":339,"_26":340},{"_40":204,"_31":205,"_29":206,"_146":-5,"_38":39,"_37":207,"_148":55,"_35":335,"_13":178,"_32":170,"_33":209,"_23":24,"_153":-5,"_314":336,"_26":337},{"_40":196,"_31":197,"_29":198,"_146":-5,"_38":39,"_37":199,"_148":24,"_35":332,"_13":201,"_32":170,"_33":202,"_23":24,"_153":-5,"_314":333,"_26":334},{"_40":189,"_31":190,"_29":191,"_146":-5,"_38":39,"_37":192,"_148":24,"_35":329,"_13":178,"_32":170,"_33":194,"_23":24,"_153":-5,"_314":330,"_26":331},{"_40":181,"_31":182,"_29":183,"_146":-5,"_38":39,"_37":184,"_148":24,"_35":326,"_13":186,"_32":161,"_33":187,"_23":24,"_153":-5,"_314":327,"_26":328},{"_40":173,"_31":174,"_29":175,"_146":-5,"_38":39,"_37":176,"_148":55,"_35":323,"_13":178,"_32":170,"_33":179,"_23":24,"_153":-5,"_314":324,"_26":325},{"_40":164,"_31":165,"_29":166,"_146":-5,"_38":39,"_37":167,"_148":55,"_35":320,"_13":169,"_32":170,"_33":171,"_23":24,"_153":-5,"_314":321,"_26":322},{"_40":155,"_31":156,"_29":157,"_146":-5,"_38":39,"_37":158,"_148":55,"_35":317,"_13":160,"_32":161,"_33":162,"_23":24,"_153":-5,"_314":318,"_26":319},{"_40":143,"_31":144,"_29":145,"_146":-5,"_38":39,"_37":147,"_148":24,"_35":313,"_13":150,"_32":151,"_33":152,"_23":24,"_153":-5,"_314":315,"_26":316},["D",1753241163437],"children",[],[144],["D",1753241050560],[],[156],["D",1751662988511],[],[165],["D",1750373211745],[],[174],["D",1753241636242],[],[182],["D",1751662575537],[],[190],["D",1753241087758],[],[197],["D",1750372113364],[],[205],["D",1750373092242],[],[212],["D",1769136720207],[],[27],["D",1751693610646],[],[223],["D",1750372552890],[],[231],["D",1759081605407],[],[237],["D",1751662682583],[],[246],["D",1769136719198],[],[253],["D",1769136719402],[],[260],"7d1f4dc0-f806-11f0-94a6-42dde27851f2","index.html","7d1f4e6a-f806-11f0-94a6-42dde27851f2",296,["D",1769136720111],"\n\n\n \n \n Loki - Rental Search\n \n \n \n \n \n \n \n \n \n \n \n \n\n\n

\n \n\n\n",[],[266,363],"7d136258-f806-11f0-810f-42dde27851f2","App.tsx","7d136334-f806-11f0-810f-42dde27851f2",295,["D",1769136720034],"/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport React, { useState, useEffect, createContext, useContext, useCallback } from \"https://esm.sh/react@18.2.0\";\nimport { createRoot } from \"https://esm.sh/react-dom@18.2.0/client\";\nimport type { User, Group, ListingWithDetails, ListingsFilterParams, ListingStatus, TransitPreference, NotificationPrefs } from \"../shared/types.ts\";\nimport { ListingDetail } from \"./components/ListingDetail.tsx\";\nimport { PreferencesView } from \"./views/PreferencesView.tsx\";\n\n// ==================== Context ====================\n\ninterface AuthContextType {\n user: User | null;\n groups: (Group & { role: string })[];\n currentGroup: (Group & { role: string }) | null;\n setCurrentGroup: (group: Group & { role: string }) => void;\n isLoading: boolean;\n login: () => void;\n logout: () => Promise;\n refreshUser: () => Promise;\n}\n\nconst AuthContext = createContext(null);\n\nexport function useAuth() {\n const context = useContext(AuthContext);\n if (!context) throw new Error(\"useAuth must be used within AuthProvider\");\n return context;\n}\n\nfunction AuthProvider({ children }: { children: React.ReactNode }) {\n const [user, setUser] = useState((window as any).__LOKI_USER__ || null);\n const [groups, setGroups] = useState<(Group & { role: string })[]>([]);\n const [currentGroup, setCurrentGroup] = useState<(Group & { role: string }) | null>(null);\n const [isLoading, setIsLoading] = useState(true);\n\n const refreshUser = useCallback(async () => {\n try {\n const response = await fetch(\"/auth/me\");\n const data = await response.json();\n setUser(data.user);\n setGroups(data.groups || []);\n \n // Set current group to first one if not set\n if (!currentGroup && data.groups?.length > 0) {\n setCurrentGroup(data.groups[0]);\n }\n } catch (error) {\n console.error(\"Error fetching user:\", error);\n } finally {\n setIsLoading(false);\n }\n }, [currentGroup]);\n\n useEffect(() => {\n refreshUser();\n }, []);\n\n const login = () => {\n window.location.href = \"/auth/google\";\n };\n\n const logout = async () => {\n await fetch(\"/auth/logout\", { method: \"POST\" });\n setUser(null);\n setGroups([]);\n setCurrentGroup(null);\n window.location.href = \"/\";\n };\n\n return (\n \n {children}\n \n );\n}\n\n// ==================== API Hooks ====================\n\nfunction useListings(groupId: string | undefined, filters: ListingsFilterParams = {}) {\n const [listings, setListings] = useState([]);\n const [total, setTotal] = useState(0);\n const [totalPages, setTotalPages] = useState(0);\n const [isLoading, setIsLoading] = useState(false);\n const [error, setError] = useState(null);\n\n const fetchListings = useCallback(async () => {\n if (!groupId) return;\n \n setIsLoading(true);\n setError(null);\n \n try {\n const params = new URLSearchParams({ group_id: groupId });\n Object.entries(filters).forEach(([key, value]) => {\n if (value !== undefined) params.set(key, String(value));\n });\n \n const response = await fetch(`/api/listings?${params}`);\n if (!response.ok) throw new Error(\"Failed to fetch listings\");\n \n const data = await response.json();\n setListings(data.data);\n setTotal(data.total);\n setTotalPages(data.total_pages);\n } catch (err) {\n setError(String(err));\n } finally {\n setIsLoading(false);\n }\n }, [groupId, JSON.stringify(filters)]);\n\n useEffect(() => {\n fetchListings();\n }, [fetchListings]);\n\n return { listings, total, totalPages, isLoading, error, refresh: fetchListings };\n}\n\n// ==================== Components ====================\n\nfunction Header({ onOpenSettings }: { onOpenSettings?: () => void }) {\n const { user, groups, currentGroup, setCurrentGroup, login, logout } = useAuth();\n\n return (\n

Loki

\n \n {user && groups.length > 0 && (\n {\n const group = groups.find(g => g.id === e.target.value);\n if (group) setCurrentGroup(group);\n }}\n className=\"px-3 py-1.5 border rounded-lg text-sm\"\n >\n {groups.map(g => (\n \n ))}\n \n )}\n

\n \n

\n {user ? (\n <>\n {currentGroup && onOpenSettings && (\n \n ⚙ Settings\n \n )}\n

\n {user.avatar_url && (\n $\"\"$ \n )}\n {user.name || user.email}\n

\n \n Log out\n \n \n ) : (\n \n Sign in with Google\n \n )}\n

\n );\n}\n\nfunction ViewSwitcher({ view, setView }: { view: string; setView: (v: string) => void }) {\n const views = [\n { id: \"table\", label: \"Table\", icon: \"≡\" },\n { id: \"kanban\", label: \"Kanban\", icon: \"▤\" },\n { id: \"map\", label: \"Map\", icon: \"◎\" },\n ];\n\n return (\n

\n {views.map(v => (\n setView(v.id)}\n className={`px-4 py-2 rounded-md text-sm font-medium transition-colors ${\n view === v.id\n ? \"bg-white text-gray-900 shadow-sm\"\n : \"text-gray-600 hover:text-gray-900\"\n }`}\n >\n {v.icon}\n {v.label}\n \n ))}\n

\n );\n}\n\nfunction Filters({ filters, setFilters }: { \n filters: ListingsFilterParams; \n setFilters: (f: ListingsFilterParams) => void;\n}) {\n return (\n

\n Min Price\n setFilters({ ...filters, min_price: e.target.value ? parseInt(e.target.value) : undefined, page: 1 })}\n placeholder=\"$0\"\n className=\"px-3 py-2 border rounded-lg w-28 text-sm\"\n />\n

\n \n

\n Max Price\n setFilters({ ...filters, max_price: e.target.value ? parseInt(e.target.value) : undefined, page: 1 })}\n placeholder=\"$10000\"\n className=\"px-3 py-2 border rounded-lg w-28 text-sm\"\n />\n

\n \n

\n Beds\n setFilters({ ...filters, min_beds: e.target.value ? parseInt(e.target.value) : undefined, page: 1 })}\n className=\"px-3 py-2 border rounded-lg text-sm\"\n >\n \n \n \n \n \n \n

\n \n

\n Status\n setFilters({ ...filters, status: e.target.value as ListingStatus || undefined, page: 1 })}\n className=\"px-3 py-2 border rounded-lg text-sm\"\n >\n \n \n \n \n \n \n \n \n

\n \n

\n Sort By\n setFilters({ ...filters, sort_by: e.target.value as ListingsFilterParams[\"sort_by\"] })}\n className=\"px-3 py-2 border rounded-lg text-sm\"\n >\n \n \n \n \n \n

\n \n

\n \n setFilters({ ...filters, is_liked: e.target.checked ? true : undefined, page: 1 })}\n className=\"rounded\"\n />\n Liked only\n \n

\n );\n}\n\nfunction Pagination({ \n page, \n totalPages, \n onPageChange \n}: { \n page: number; \n totalPages: number; \n onPageChange: (page: number) => void;\n}) {\n if (totalPages <= 1) return null;\n\n return (\n

\n onPageChange(page - 1)}\n disabled={page <= 1}\n className=\"px-3 py-2 border rounded-lg text-sm disabled:opacity-50 disabled:cursor-not-allowed hover:bg-gray-50\"\n >\n Previous\n \n \n \n Page {page} of {totalPages}\n \n \n onPageChange(page + 1)}\n disabled={page >= totalPages}\n className=\"px-3 py-2 border rounded-lg text-sm disabled:opacity-50 disabled:cursor-not-allowed hover:bg-gray-50\"\n >\n Next\n \n

\n );\n}\n\n// Loading skeleton component\nfunction ListingCardSkeleton() {\n return (\n

\n );\n}\n\nfunction TableRowSkeleton() {\n return (\n \n

\n \n );\n}\n\nfunction ListingCard({ listing, onUpdate }: { listing: ListingWithDetails; onUpdate: () => void }) {\n const { currentGroup } = useAuth();\n const [isUpdating, setIsUpdating] = useState(false);\n const [optimisticStatus, setOptimisticStatus] = useState(null);\n const [optimisticLiked, setOptimisticLiked] = useState(null);\n\n const updateInteraction = async (updates: { status?: ListingStatus; is_liked?: boolean }) => {\n if (!currentGroup) return;\n \n // Optimistic update\n if (updates.status !== undefined) setOptimisticStatus(updates.status);\n if (updates.is_liked !== undefined) setOptimisticLiked(updates.is_liked);\n \n setIsUpdating(true);\n try {\n await fetch(`/api/listings/${listing.id}/interaction`, {\n method: \"PATCH\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ group_id: currentGroup.id, ...updates }),\n });\n onUpdate();\n } catch (error) {\n console.error(\"Error updating interaction:\", error);\n // Revert optimistic update on error\n setOptimisticStatus(null);\n setOptimisticLiked(null);\n } finally {\n setIsUpdating(false);\n setOptimisticStatus(null);\n setOptimisticLiked(null);\n }\n };\n\n const status = optimisticStatus ?? listing.interaction?.status ?? \"new\";\n const isLiked = optimisticLiked ?? listing.interaction?.is_liked ?? false;\n\n return (\n

\n {listing.address_original}\n

\n {\n e.stopPropagation();\n updateInteraction({ is_liked: !isLiked });\n }}\n disabled={isUpdating}\n className={`text-xl transition-colors ${isLiked ? \"text-red-500\" : \"text-gray-300\"} hover:text-red-500`}\n >\n ♥\n \n

\n \n

\n {listing.price && (\n ${listing.price.toLocaleString()}/mo\n )}\n {listing.beds !== null && {listing.beds} bed}\n {listing.baths !== null && {listing.baths} bath}\n

\n \n {listing.rent_per_bedroom && (\n

\n ${listing.rent_per_bedroom.toLocaleString()}/bedroom\n

\n )}\n \n

\n {listing.sources.map(source => (\n e.stopPropagation()}\n className={`text-xs px-2 py-1 rounded transition-colors ${\n source.platform === \"zillow\" \n ? \"bg-blue-100 text-blue-700 hover:bg-blue-200\" \n : \"bg-purple-100 text-purple-700 hover:bg-purple-200\"\n }`}\n >\n {source.platform}\n \n ))}\n

\n \n {\n e.stopPropagation();\n updateInteraction({ status: e.target.value as ListingStatus });\n }}\n onClick={(e) => e.stopPropagation()}\n disabled={isUpdating}\n className=\"w-full px-3 py-2 border rounded text-sm focus:ring-2 focus:ring-blue-500\"\n >\n \n \n \n \n \n \n \n

\n );\n}\n\n// Placeholder views - will be expanded in Phase 4.2-4.3\nfunction TableView({ listings, onUpdate }: { listings: ListingWithDetails[]; onUpdate: () => void }) {\n const { currentGroup } = useAuth();\n const [selectedListing, setSelectedListing] = useState(null);\n\n const updateInteraction = async (listingId: string, updates: { status?: ListingStatus; is_liked?: boolean }) => {\n if (!currentGroup) return;\n \n try {\n await fetch(`/api/listings/${listingId}/interaction`, {\n method: \"PATCH\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ group_id: currentGroup.id, ...updates }),\n });\n onUpdate();\n } catch (error) {\n console.error(\"Error updating interaction:\", error);\n }\n };\n\n return (\n <>\n

\n \n \n \n \n \n \n \n \n \n \n \n \n \n \n {listings.map(listing => {\n const status = listing.interaction?.status || \"new\";\n const isLiked = listing.interaction?.is_liked || false;\n \n return (\n setSelectedListing(listing)}\n >\n \n \n \n \n \n \n \n \n \n );\n })}\n \n

Like	Address	Price	Beds	Baths	$/Bed	Status	Sources
e.stopPropagation()}>\n updateInteraction(listing.id, { is_liked: !isLiked })}\n className={`text-xl ${isLiked ? \"text-red-500\" : \"text-gray-300\"} hover:text-red-500`}\n >\n ♥\n \n	{listing.address_original}	\n {listing.price ? `$${listing.price.toLocaleString()}` : \"-\"}\n	{listing.beds ?? \"-\"}	{listing.baths ?? \"-\"}	\n {listing.rent_per_bedroom ? `$${listing.rent_per_bedroom.toLocaleString()}` : \"-\"}\n	e.stopPropagation()}>\n updateInteraction(listing.id, { status: e.target.value as ListingStatus })}\n className=\"px-2 py-1 border rounded text-sm\"\n >\n \n \n \n \n \n \n \n	e.stopPropagation()}>\n \n {listing.sources.map(source => (\n \n {source.platform}\n \n ))}\n \n

\n \n {listings.length === 0 && (\n

\n No listings found matching your filters.\n

\n )}\n

\n {columns.map(({ status, listings: columnListings }) => (\n

\n {status.charAt(0).toUpperCase() + status.slice(1)} ({columnListings.length})\n

\n {columnListings.map(listing => (\n

setSelectedListing(listing)} className=\"cursor-pointer\">\n \n

\n ))}\n

\n\n {selectedListing && currentGroup && (\n setSelectedListing(null)}\n onUpdate={() => {\n onUpdate();\n setSelectedListing(null);\n }}\n />\n )}\n \n );\n}\n\nfunction MapView({ listings, onUpdate }: { listings: ListingWithDetails[]; onUpdate: () => void }) {\n const { currentGroup } = useAuth();\n const mapRef = React.useRef(null);\n const mapInstance = React.useRef(null);\n const markersRef = React.useRef>(new Map());\n const [selectedListing, setSelectedListing] = useState(null);\n\n useEffect(() => {\n if (!mapRef.current || mapInstance.current) return;\n\n // Initialize map centered on San Francisco\n const L = (window as any).L;\n const map = L.map(mapRef.current).setView([37.7749, -122.4194], 12);\n\n L.tileLayer(\"https://{s}.tile.openstreetmap.org/{z}/{x}/{y}.png\", {\n attribution: '© OpenStreetMap contributors',\n }).addTo(map);\n\n mapInstance.current = map;\n\n return () => {\n map.remove();\n mapInstance.current = null;\n };\n }, []);\n\n useEffect(() => {\n if (!mapInstance.current) return;\n\n const L = (window as any).L;\n const map = mapInstance.current;\n\n // Clear existing markers\n markersRef.current.forEach(marker => map.removeLayer(marker));\n markersRef.current.clear();\n\n // Status color mapping\n const statusColors: Record = {\n new: \"#9ca3af\",\n interested: \"#3b82f6\",\n contacted: \"#f59e0b\",\n toured: \"#10b981\",\n applied: \"#8b5cf6\",\n rejected: \"#ef4444\",\n };\n\n // Add markers for listings with coordinates\n listings.forEach(listing => {\n if (listing.lat && listing.lng) {\n const status = listing.interaction?.status || \"new\";\n const isLiked = listing.interaction?.is_liked || false;\n const color = statusColors[status] || statusColors.new;\n \n // Create custom icon\n const icon = L.divIcon({\n className: \"custom-marker\",\n html: `

${isLiked ? \"♥\" : \"\"}

`,\n iconSize: [24, 24],\n iconAnchor: [12, 12],\n });\n \n const marker = L.marker([listing.lat, listing.lng], { icon }).addTo(map);\n markersRef.current.set(listing.id, marker);\n \n // Click to open detail panel\n marker.on(\"click\", () => {\n setSelectedListing(listing);\n });\n \n marker.bindPopup(`\n

${listing.address_original}

\n ${listing.price ? `$${listing.price.toLocaleString()}/mo` : \"\"} \n ${listing.beds ? `• ${listing.beds} bed` : \"\"} \n ${listing.baths ? `• ${listing.baths} bath` : \"\"}\n

\n ${status}\n

Click marker for full details

\n `);\n }\n });\n\n // Fit bounds if there are listings with coordinates\n const validListings = listings.filter(l => l.lat && l.lng);\n if (validListings.length > 0) {\n const bounds = L.latLngBounds(validListings.map(l => [l.lat, l.lng]));\n map.fitBounds(bounds, { padding: [50, 50] });\n }\n }, [listings]);\n\n return (\n <>\n

\n \n {selectedListing && currentGroup && (\n setSelectedListing(null)}\n onUpdate={() => {\n onUpdate();\n setSelectedListing(null);\n }}\n />\n )}\n \n );\n}\n\nfunction CreateGroupModal({ onClose, onCreated }: { onClose: () => void; onCreated: () => void }) {\n const [name, setName] = useState(\"\");\n const [isLoading, setIsLoading] = useState(false);\n const [error, setError] = useState(\"\");\n\n const handleSubmit = async (e: React.FormEvent) => {\n e.preventDefault();\n if (!name.trim()) return;\n\n setIsLoading(true);\n setError(\"\");\n\n try {\n const response = await fetch(\"/api/groups\", {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ name: name.trim() }),\n });\n\n if (!response.ok) {\n const data = await response.json();\n throw new Error(data.message || \"Failed to create group\");\n }\n\n onCreated();\n onClose();\n } catch (err) {\n setError(String(err));\n } finally {\n setIsLoading(false);\n }\n };\n\n return (\n

Create New Group

\n \n

\n );\n}\n\nfunction JoinGroupModal({ onClose, onJoined }: { onClose: () => void; onJoined: () => void }) {\n const [code, setCode] = useState(\"\");\n const [isLoading, setIsLoading] = useState(false);\n const [error, setError] = useState(\"\");\n\n const handleSubmit = async (e: React.FormEvent) => {\n e.preventDefault();\n if (!code.trim()) return;\n\n setIsLoading(true);\n setError(\"\");\n\n try {\n const response = await fetch(`/api/groups/join/${code.trim().toUpperCase()}`, {\n method: \"POST\",\n });\n\n if (!response.ok) {\n const data = await response.json();\n throw new Error(data.message || \"Failed to join group\");\n }\n\n onJoined();\n onClose();\n } catch (err) {\n setError(String(err));\n } finally {\n setIsLoading(false);\n }\n };\n\n return (\n

Join Group

\n \n

\n );\n}\n\nfunction NoGroupView() {\n const { refreshUser } = useAuth();\n const [showCreateModal, setShowCreateModal] = useState(false);\n const [showJoinModal, setShowJoinModal] = useState(false);\n\n return (\n

Welcome to Loki

\n Create a new group to start tracking rental listings, or join an existing group with an invite code.\n

\n \n

\n setShowCreateModal(true)}\n className=\"w-full px-6 py-3 bg-blue-600 text-white rounded-lg hover:bg-blue-700\"\n >\n Create New Group\n \n \n setShowJoinModal(true)}\n className=\"w-full px-6 py-3 border border-gray-300 text-gray-700 rounded-lg hover:bg-gray-50\"\n >\n Join with Invite Code\n \n

\n \n {showCreateModal && (\n setShowCreateModal(false)} onCreated={refreshUser} />\n )}\n \n {showJoinModal && (\n setShowJoinModal(false)} onJoined={refreshUser} />\n )}\n

\n );\n}\n\nfunction LoginView() {\n const { login } = useAuth();\n\n return (\n

Loki

Rental Search Made Easy

\n Track listings from Zillow and Craigslist, coordinate with roommates, and find your perfect home.\n

\n \n \n \n Sign in with Google\n \n

\n );\n}\n\nfunction MainContent({ onOpenSettings }: { onOpenSettings: () => void }) {\n const { user, currentGroup, isLoading: authLoading } = useAuth();\n const [view, setView] = useState(\"table\");\n const [filters, setFilters] = useState({ page: 1, limit: 50 });\n \n const { listings, total, totalPages, isLoading, error, refresh } = useListings(currentGroup?.id, filters);\n\n if (authLoading) {\n return (\n

\n );\n }\n\n if (!user) {\n return ;\n }\n\n if (!currentGroup) {\n return ;\n }\n\n return (\n

{currentGroup.name}

\n {total} listing{total !== 1 ? \"s\" : \"\"} found\n {filters.page && totalPages > 1 && ` (page ${filters.page} of ${totalPages})`}\n

\n \n

\n \n {isLoading ? (\n

\n ) : error ? (\n

\n Error loading listings: {error}\n

\n ) : (\n <>\n {view === \"table\" && }\n {view === \"kanban\" && }\n {view === \"map\" && }\n \n {view === \"table\" && (\n setFilters({ ...filters, page })}\n />\n )}\n \n )}\n

\n );\n}\n\nfunction AppContent() {\n const { currentGroup } = useAuth();\n const [showSettings, setShowSettings] = useState(false);\n\n return (\n

setShowSettings(true)} />\n setShowSettings(true)} />\n \n {showSettings && currentGroup && (\n setShowSettings(false)}\n />\n )}\n

\n );\n}\n\nfunction App() {\n return (\n \n \n \n );\n}\n\n// Mount the app\nconst root = createRoot(document.getElementById(\"root\")!);\nroot.render();\n\nexport default App;\n",[],[266,371],"7d22c57c-f806-11f0-a6eb-42dde27851f2","PreferencesView.tsx","7d22c644-f806-11f0-a6eb-42dde27851f2","7cf06a64-f806-11f0-810f-42dde27851f2",297,["D",1769136720124],"/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport React, { useState, useEffect, useCallback } from \"https://esm.sh/react@18.2.0\";\nimport type { TransitPreference, NotificationPrefs, TravelMode, TransitPreferenceType } from \"../../shared/types.ts\";\n\ninterface PreferencesViewProps {\n groupId: string;\n onClose: () => void;\n}\n\nexport function PreferencesView({ groupId, onClose }: PreferencesViewProps) {\n const [activeTab, setActiveTab] = useState<\"transit\" | \"notifications\" | \"group\">(\"transit\");\n \n return (\n

\n {/* Header */}\n

Settings

\n \n ×\n \n

\n\n {/* Tabs */}\n

\n setActiveTab(\"transit\")}\n className={`py-3 border-b-2 text-sm font-medium ${\n activeTab === \"transit\"\n ? \"border-blue-500 text-blue-600\"\n : \"border-transparent text-gray-500 hover:text-gray-700\"\n }`}\n >\n Transit Destinations\n \n setActiveTab(\"notifications\")}\n className={`py-3 border-b-2 text-sm font-medium ${\n activeTab === \"notifications\"\n ? \"border-blue-500 text-blue-600\"\n : \"border-transparent text-gray-500 hover:text-gray-700\"\n }`}\n >\n Notifications\n \n setActiveTab(\"group\")}\n className={`py-3 border-b-2 text-sm font-medium ${\n activeTab === \"group\"\n ? \"border-blue-500 text-blue-600\"\n : \"border-transparent text-gray-500 hover:text-gray-700\"\n }`}\n >\n Group\n \n

\n\n {/* Content */}\n

\n {activeTab === \"transit\" && }\n {activeTab === \"notifications\" && }\n {activeTab === \"group\" && }\n

\n );\n}\n\n// ==================== Transit Preferences Tab ====================\n\nfunction TransitPreferencesTab({ groupId }: { groupId: string }) {\n const [preferences, setPreferences] = useState([]);\n const [isLoading, setIsLoading] = useState(true);\n const [showAddForm, setShowAddForm] = useState(false);\n const [error, setError] = useState(\"\");\n\n const fetchPreferences = useCallback(async () => {\n try {\n const response = await fetch(`/api/preferences/transit?group_id=${groupId}&include_inactive=true`);\n const data = await response.json();\n setPreferences(data.preferences || []);\n } catch (err) {\n setError(String(err));\n } finally {\n setIsLoading(false);\n }\n }, [groupId]);\n\n useEffect(() => {\n fetchPreferences();\n }, [fetchPreferences]);\n\n const deletePreference = async (id: string) => {\n if (!confirm(\"Are you sure you want to delete this destination?\")) return;\n \n try {\n await fetch(`/api/preferences/transit/${id}`, { method: \"DELETE\" });\n fetchPreferences();\n } catch (err) {\n setError(String(err));\n }\n };\n\n const toggleActive = async (id: string, isActive: boolean) => {\n try {\n await fetch(`/api/preferences/transit/${id}`, {\n method: \"PUT\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ is_active: !isActive }),\n });\n fetchPreferences();\n } catch (err) {\n setError(String(err));\n }\n };\n\n if (isLoading) {\n return

;\n }\n\n return (\n

Transit Destinations

Calculate commute times from listings to these locations.

\n setShowAddForm(true)}\n className=\"px-4 py-2 bg-blue-600 text-white rounded-lg hover:bg-blue-700 text-sm\"\n >\n Add Destination\n \n

\n\n {error && (\n

{error}

\n )}\n\n

\n {preferences.map(pref => (\n \n

\n {pref.name}\n \n {pref.type}\n \n \n via {pref.travel_mode}\n \n

\n {pref.address && (\n

{pref.address}

\n )}\n

\n \n

\n toggleActive(pref.id, pref.is_active)}\n className={`text-xs px-3 py-1 rounded ${\n pref.is_active\n ? \"bg-green-100 text-green-700\"\n : \"bg-gray-100 text-gray-500\"\n }`}\n >\n {pref.is_active ? \"Active\" : \"Inactive\"}\n \n deletePreference(pref.id)}\n className=\"text-red-500 hover:text-red-700 text-sm\"\n >\n Delete\n \n

\n ))}\n \n {preferences.length === 0 && (\n

\n No transit destinations configured. Add one to start calculating commute times.\n

\n )}\n

\n\n {showAddForm && (\n setShowAddForm(false)}\n onCreated={() => {\n setShowAddForm(false);\n fetchPreferences();\n }}\n />\n )}\n

\n );\n}\n\nfunction AddTransitPreferenceForm({ \n groupId, \n onClose, \n onCreated \n}: { \n groupId: string; \n onClose: () => void; \n onCreated: () => void;\n}) {\n const [name, setName] = useState(\"\");\n const [type, setType] = useState(\"custom\");\n const [address, setAddress] = useState(\"\");\n const [travelMode, setTravelMode] = useState(\"transit\");\n const [isLoading, setIsLoading] = useState(false);\n const [error, setError] = useState(\"\");\n\n const handleSubmit = async (e: React.FormEvent) => {\n e.preventDefault();\n if (!name.trim()) return;\n\n setIsLoading(true);\n setError(\"\");\n\n try {\n const response = await fetch(\"/api/preferences/transit\", {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({\n group_id: groupId,\n name: name.trim(),\n type,\n address: address.trim() || undefined,\n travel_mode: travelMode,\n }),\n });\n\n if (!response.ok) {\n const data = await response.json();\n throw new Error(data.message || \"Failed to create preference\");\n }\n\n onCreated();\n } catch (err) {\n setError(String(err));\n } finally {\n setIsLoading(false);\n }\n };\n\n return (\n

Add Transit Destination

\n \n

\n Name\n setName(e.target.value)}\n placeholder=\"e.g., Work, Gym, Grocery Store\"\n className=\"w-full px-3 py-2 border rounded-lg\"\n required\n />\n

\n\n

\n Type\n setType(e.target.value as TransitPreferenceType)}\n className=\"w-full px-3 py-2 border rounded-lg\"\n >\n \n \n \n \n \n

\n\n

\n Address\n setAddress(e.target.value)}\n placeholder=\"e.g., 123 Main St, San Francisco, CA\"\n className=\"w-full px-3 py-2 border rounded-lg\"\n />\n

\n\n

\n Travel Mode\n setTravelMode(e.target.value as TravelMode)}\n className=\"w-full px-3 py-2 border rounded-lg\"\n >\n \n \n \n \n \n

\n\n {error &&

{error}

}\n\n

\n \n Cancel\n \n \n {isLoading ? \"Creating...\" : \"Add\"}\n \n

\n );\n}\n\n// ==================== Notifications Tab ====================\n\nfunction NotificationsTab() {\n const [prefs, setPrefs] = useState(null);\n const [isLoading, setIsLoading] = useState(true);\n const [isSaving, setIsSaving] = useState(false);\n const [error, setError] = useState(\"\");\n\n useEffect(() => {\n fetchPrefs();\n }, []);\n\n const fetchPrefs = async () => {\n try {\n const response = await fetch(\"/api/preferences/notifications\");\n const data = await response.json();\n setPrefs(data.preferences);\n } catch (err) {\n setError(String(err));\n } finally {\n setIsLoading(false);\n }\n };\n\n const updatePref = async (key: keyof NotificationPrefs, value: boolean) => {\n if (!prefs) return;\n \n setIsSaving(true);\n setError(\"\");\n\n try {\n const response = await fetch(\"/api/preferences/notifications\", {\n method: \"PUT\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ [key]: value }),\n });\n\n if (!response.ok) throw new Error(\"Failed to update preferences\");\n\n const data = await response.json();\n setPrefs(data.preferences);\n } catch (err) {\n setError(String(err));\n } finally {\n setIsSaving(false);\n }\n };\n\n if (isLoading) {\n return

;\n }\n\n return (\n

Email Notifications

Choose which notifications you'd like to receive via email.

\n\n {error && (\n

{error}

\n )}\n\n

\n \n

New Listings

Get notified when new listings match your criteria

\n updatePref(\"notify_new_listing\", e.target.checked)}\n disabled={isSaving}\n className=\"w-5 h-5 rounded\"\n />\n \n\n \n

Comment Requests

Get notified when a group member requests your feedback

\n updatePref(\"notify_comment_request\", e.target.checked)}\n disabled={isSaving}\n className=\"w-5 h-5 rounded\"\n />\n \n\n \n

Apply Reminders

Get reminded to submit applications for listings you're interested in

\n updatePref(\"notify_apply_reminder\", e.target.checked)}\n disabled={isSaving}\n className=\"w-5 h-5 rounded\"\n />\n \n

\n );\n}\n\n// ==================== Group Tab ====================\n\nfunction GroupTab({ groupId }: { groupId: string }) {\n const [group, setGroup] = useState(null);\n const [isLoading, setIsLoading] = useState(true);\n const [showInviteCode, setShowInviteCode] = useState(false);\n const [error, setError] = useState(\"\");\n\n useEffect(() => {\n fetchGroup();\n }, [groupId]);\n\n const fetchGroup = async () => {\n try {\n const response = await fetch(`/api/groups/${groupId}`);\n const data = await response.json();\n setGroup(data.group);\n } catch (err) {\n setError(String(err));\n } finally {\n setIsLoading(false);\n }\n };\n\n const regenerateInviteCode = async () => {\n if (!confirm(\"Are you sure you want to generate a new invite code? The old code will no longer work.\")) return;\n \n try {\n const response = await fetch(`/api/groups/${groupId}/regenerate-invite`, { method: \"POST\" });\n const data = await response.json();\n setGroup({ ...group, invite_code: data.invite_code });\n } catch (err) {\n setError(String(err));\n }\n };\n\n const copyInviteCode = () => {\n navigator.clipboard.writeText(group.invite_code);\n alert(\"Invite code copied to clipboard!\");\n };\n\n if (isLoading) {\n return

;\n }\n\n if (!group) {\n return

Failed to load group details.

;\n }\n\n return (\n

\n {/* Group Info */}\n

Group Details

{group.name}

\n\n {error && (\n

{error}

\n )}\n\n {/* Invite Code */}\n

Invite Code

\n setShowInviteCode(!showInviteCode)}\n className=\"text-sm text-blue-600 hover:text-blue-800\"\n >\n {showInviteCode ? \"Hide\" : \"Show\"}\n \n

\n \n {showInviteCode && (\n

\n \n {group.invite_code}\n \n \n Copy\n \n \n Regenerate\n \n

\n )}\n \n

\n Share this code with others to invite them to your group.\n

\n\n {/* Members */}\n

Members ({group.members?.length || 0})

\n {group.members?.map((member: any) => (\n

\n {member.user.avatar_url ? (\n $\"\"$ \n ) : (\n

\n {(member.user.name || member.user.email).charAt(0).toUpperCase()}\n

\n )}\n

\n {member.user.name || member.user.email}\n

\n {member.user.name && (\n

{member.user.email}

\n )}\n

\n \n \n {member.role}\n \n

\n ))}\n

\n );\n}\n\nexport default PreferencesView;\n",[],[266,387,379],"views","7cf069a6-f806-11f0-810f-42dde27851f2",294,["D",1769136719805],[294],[266,387],"7cd0ed4c-f806-11f0-be4c-42dde27851f2","components","7cd0eeb4-f806-11f0-be4c-42dde27851f2",293,["D",1769136719599],[],[266,394],["D",1769136718806],[292,293,295,296],[266],"7d2c9b92-f806-11f0-810f-42dde27851f2","notifications.ts","7d2c9c82-f806-11f0-810f-42dde27851f2",298,["D",1769136720200],"/**\n * Notifications module for Loki\n * Handles email notifications for listings, reminders, and group interactions\n */\n\nimport { email } from \"https://esm.town/v/std/email?v=13\";\nimport { sqlite } from \"https://esm.town/v/std/sqlite\";\nimport type { User, Listing, Group, Reminder } from \"../shared/types.ts\";\n\nconst TABLE_PREFIX = \"loki_\";\n\n// Email templates\ninterface EmailTemplate {\n subject: string;\n text: string;\n html: string;\n}\n\n/**\n * Get users who want a specific notification type for a group\n */\nasync function getNotificationRecipients(\n groupId: string,\n notificationType: \"notify_new_listing\" | \"notify_comment_request\" | \"notify_apply_reminder\"\n): Promise<{ userId: string; email: string; name: string | null }[]> {\n const result = await sqlite.execute({\n sql: `\n SELECT u.id, u.email, u.name\n FROM ${TABLE_PREFIX}users u\n JOIN ${TABLE_PREFIX}group_members gm ON u.id = gm.user_id\n LEFT JOIN ${TABLE_PREFIX}notification_prefs np ON u.id = np.user_id\n WHERE gm.group_id = ?\n AND (np.${notificationType} = 1 OR np.${notificationType} IS NULL)\n `,\n args: [groupId],\n });\n\n return result.rows.map(row => ({\n userId: row.id as string,\n email: row.email as string,\n name: row.name as string | null,\n }));\n}\n\n/**\n * Get group details\n */\nasync function getGroup(groupId: string): Promise {\n const result = await sqlite.execute({\n sql: `SELECT * FROM ${TABLE_PREFIX}groups WHERE id = ?`,\n args: [groupId],\n });\n\n if (result.rows.length === 0) return null;\n\n const row = result.rows[0];\n return {\n id: row.id as string,\n name: row.name as string,\n created_by: row.created_by as string,\n invite_code: row.invite_code as string,\n created_at: row.created_at as number,\n };\n}\n\n/**\n * Generate new listings digest email\n */\nfunction generateNewListingsDigest(\n groupName: string,\n listings: Listing[],\n baseUrl: string\n): EmailTemplate {\n const listingRows = listings.map(l => `\n \n \n \n ${l.address_original}\n \n ${l.unit_number ? ` Unit ${l.unit_number}` : \"\"}\n \n \n ${l.price ? `$${l.price.toLocaleString()}` : \"N/A\"}\n \n \n ${l.beds ?? \"-\"} bed / ${l.baths ?? \"-\"} bath\n \n \n `).join(\"\");\n\n const textListings = listings.map(l => \n `- ${l.address_original}: ${l.price ? `$${l.price}` : \"N/A\"} - ${l.beds ?? \"?\"} bed / ${l.baths ?? \"?\"} bath`\n ).join(\"\\n\");\n\n return {\n subject: `[Loki] ${listings.length} new listing${listings.length > 1 ? \"s\" : \"\"} for ${groupName}`,\n text: `\nNew listings found for ${groupName}!\n\n${textListings}\n\nView all listings: ${baseUrl}\n `.trim(),\n html: `\n\n\n\n \n \n\n\n

Loki

\n \n

${listings.length} New Listing${listings.length > 1 ? \"s\" : \"\"}

For ${groupName}

\n \n \n \n \n \n \n \n \n \n \n ${listingRows}\n \n

Address	Price	Details

\n \n

\n \n View All Listings\n \n

\n \n

\n You're receiving this because you're a member of ${groupName} on Loki.\n Manage notification preferences\n

\n\n\n `.trim(),\n };\n}\n\n/**\n * Generate comment request email\n */\nfunction generateCommentRequest(\n groupName: string,\n listing: Listing,\n requestingUser: string,\n baseUrl: string\n): EmailTemplate {\n return {\n subject: `[Loki] ${requestingUser} wants your feedback on a listing`,\n text: `\n${requestingUser} from ${groupName} is requesting your feedback on:\n\n${listing.address_original}\n${listing.price ? `Price: $${listing.price}` : \"\"}\n${listing.beds ? `Beds: ${listing.beds}` : \"\"} / ${listing.baths ? `Baths: ${listing.baths}` : \"\"}\n\nView listing: ${baseUrl}\n `.trim(),\n html: `\n\n\n\n \n\n\n

Loki

\n \n

Feedback Requested

\n ${requestingUser} from ${groupName} wants your feedback on this listing:\n

\n \n

${listing.address_original}

\n ${listing.price ? `$${listing.price.toLocaleString()}/mo • ` : \"\"}\n ${listing.beds ?? \"?\"} bed • ${listing.baths ?? \"?\"} bath\n

\n \n \n View & Comment\n \n

\n\n\n `.trim(),\n };\n}\n\n/**\n * Generate apply reminder email\n */\nfunction generateApplyReminder(\n groupName: string,\n listing: Listing,\n message: string | null,\n baseUrl: string\n): EmailTemplate {\n return {\n subject: `[Loki] Reminder: Apply for listing at ${listing.address_original}`,\n text: `\nDon't forget to apply!\n\n${listing.address_original}\n${listing.price ? `Price: $${listing.price}` : \"\"}\n${message ? `\\nNote: ${message}` : \"\"}\n\nView listing: ${baseUrl}\n `.trim(),\n html: `\n\n\n\n \n\n\n

Reminder

\n \n

Time to Apply!

\n You set a reminder to apply for this listing:\n

\n \n

${listing.address_original}

\n ${listing.price ? `$${listing.price.toLocaleString()}/mo` : \"\"}\n

\n ${message ? `

\"${message}\"

` : \"\"}\n

\n \n \n View Listing\n \n

\n\n\n `.trim(),\n };\n}\n\n/**\n * Send new listings notification to a group\n */\nexport async function sendNewListingsNotification(\n groupId: string,\n listings: Listing[],\n baseUrl: string = \"https://your-app.val.run\"\n): Promise<{ sent: number; errors: number }> {\n if (listings.length === 0) {\n return { sent: 0, errors: 0 };\n }\n\n const group = await getGroup(groupId);\n if (!group) {\n console.error(\"Group not found:\", groupId);\n return { sent: 0, errors: 1 };\n }\n\n const recipients = await getNotificationRecipients(groupId, \"notify_new_listing\");\n if (recipients.length === 0) {\n console.log(\"No recipients for new listings notification\");\n return { sent: 0, errors: 0 };\n }\n\n const template = generateNewListingsDigest(group.name, listings, baseUrl);\n let sent = 0;\n let errors = 0;\n\n for (const recipient of recipients) {\n try {\n await email({\n to: [recipient.email],\n subject: template.subject,\n text: template.text,\n html: template.html,\n });\n sent++;\n } catch (err) {\n console.error(\"Failed to send email to\", recipient.email, err);\n errors++;\n }\n }\n\n return { sent, errors };\n}\n\n/**\n * Send comment request notification\n */\nexport async function sendCommentRequestNotification(\n groupId: string,\n listing: Listing,\n requestingUserId: string,\n baseUrl: string = \"https://your-app.val.run\"\n): Promise<{ sent: number; errors: number }> {\n const group = await getGroup(groupId);\n if (!group) {\n return { sent: 0, errors: 1 };\n }\n\n // Get requesting user's name\n const userResult = await sqlite.execute({\n sql: `SELECT name, email FROM ${TABLE_PREFIX}users WHERE id = ?`,\n args: [requestingUserId],\n });\n const requestingUser = userResult.rows[0]?.name || userResult.rows[0]?.email || \"A group member\";\n\n // Get recipients (excluding the requesting user)\n const recipients = (await getNotificationRecipients(groupId, \"notify_comment_request\"))\n .filter(r => r.userId !== requestingUserId);\n\n if (recipients.length === 0) {\n return { sent: 0, errors: 0 };\n }\n\n const template = generateCommentRequest(group.name, listing, requestingUser as string, baseUrl);\n let sent = 0;\n let errors = 0;\n\n for (const recipient of recipients) {\n try {\n await email({\n to: [recipient.email],\n subject: template.subject,\n text: template.text,\n html: template.html,\n });\n sent++;\n } catch (err) {\n console.error(\"Failed to send email to\", recipient.email, err);\n errors++;\n }\n }\n\n return { sent, errors };\n}\n\n/**\n * Process and send due reminders\n */\nexport async function processDueReminders(): Promise<{ processed: number; sent: number; errors: number }> {\n const now = Math.floor(Date.now() / 1000);\n\n // Get due reminders\n const remindersResult = await sqlite.execute({\n sql: `\n SELECT r.*, l.address_original, l.price, l.beds, l.baths, g.name as group_name\n FROM ${TABLE_PREFIX}reminders r\n JOIN ${TABLE_PREFIX}listings l ON r.listing_id = l.id\n JOIN ${TABLE_PREFIX}groups g ON r.group_id = g.id\n WHERE r.is_sent = 0 AND r.remind_at <= ?\n `,\n args: [now],\n });\n\n let processed = 0;\n let sent = 0;\n let errors = 0;\n\n for (const row of remindersResult.rows) {\n processed++;\n\n // Get user email\n const userResult = await sqlite.execute({\n sql: `SELECT email FROM ${TABLE_PREFIX}users WHERE id = ?`,\n args: [row.created_by],\n });\n\n if (userResult.rows.length === 0) continue;\n\n const listing: Listing = {\n id: row.listing_id as string,\n address_original: row.address_original as string,\n address_normalized: \"\",\n unit_number: null,\n lat: null,\n lng: null,\n beds: row.beds as number | null,\n baths: row.baths as number | null,\n price: row.price as number | null,\n availability: null,\n neighborhood: null,\n first_seen_at: 0,\n last_updated_at: 0,\n is_active: true,\n };\n\n const template = generateApplyReminder(\n row.group_name as string,\n listing,\n row.message as string | null,\n \"https://your-app.val.run\"\n );\n\n try {\n await email({\n to: [userResult.rows[0].email as string],\n subject: template.subject,\n text: template.text,\n html: template.html,\n });\n\n // Mark as sent\n await sqlite.execute({\n sql: `UPDATE ${TABLE_PREFIX}reminders SET is_sent = 1 WHERE id = ?`,\n args: [row.id],\n });\n\n sent++;\n } catch (err) {\n console.error(\"Failed to send reminder:\", err);\n errors++;\n }\n }\n\n return { processed, sent, errors };\n}\n\n/**\n * Create a reminder for a listing\n */\nexport async function createReminder(\n listingId: string,\n groupId: string,\n userId: string,\n remindAt: number,\n message?: string\n): Promise {\n const id = `${Date.now()}-${Math.random().toString(36).substring(2, 15)}`;\n const now = Math.floor(Date.now() / 1000);\n\n await sqlite.execute({\n sql: `\n INSERT INTO ${TABLE_PREFIX}reminders \n (id, listing_id, group_id, created_by, remind_at, message, is_sent, created_at)\n VALUES (?, ?, ?, ?, ?, ?, 0, ?)\n `,\n args: [id, listingId, groupId, userId, remindAt, message || null, now],\n });\n\n return id;\n}\n\nexport { getNotificationRecipients, getGroup };\n",[],[272,404],["D",1769136718999],[290],[272],["D",1750371724044],{"_93":92,"_100":96},{"_93":92,"_94":-5,"_95":96,"_18":51,"_97":98,"_99":24},{"_13":82,"_31":83,"_40":39,"_84":41,"_85":-5,"_86":-5,"_87":-5,"_88":-5,"_89":-5,"_90":42,"_91":92},"ctx",{"_75":-5,"_120":451,"_452":453,"_454":455,"_456":24,"_457":24,"_458":24,"_459":55,"_460":-5,"_461":-7,"_462":-7,"_463":59,"_464":24,"_465":24,"_466":-5,"_467":24,"_468":24,"_469":24,"_470":-5},"ENV",{"_422":423,"_424":425,"_426":83,"_427":428,"_429":430,"_431":432,"_433":434,"_435":436,"_437":438,"_439":440,"_441":442,"_443":444,"_445":446,"_447":448,"_449":450},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","fdb67791413f4386b4dbf18f354029a617f6160f","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 · v299