[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_562":563,"_564":565},"routes/_app.x.$handle.$name",{"_97":96,"_32":46,"_105":87,"_27":106,"_13":14,"_107":-5,"_11":108,"_109":110,"_111":112,"_113":114,"_115":116,"_20":-5,"_117":-5,"_118":-5,"_119":25,"_120":121,"_122":59,"_123":-5,"_124":-5,"_125":126},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_44":45,"_32":46,"_39":47,"_48":-5,"_49":25,"_50":51,"_52":51,"_53":-5,"_54":-5,"_18":55,"_56":57,"_58":59,"_60":59,"_61":-5,"_62":63,"_64":65,"_66":-5,"_67":-5,"_68":-5,"_69":-5,"_70":71,"_72":71,"_73":74,"_75":74,"_76":74,"_77":71,"_78":71,"_79":80,"_81":82,"_83":84,"_85":25},"version",320,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":33,"_34":35,"_36":38,"_39":40,"_41":14,"_42":43,"_24":25},"previous",{"_30":31,"_32":33,"_34":35,"_36":37},"deleted",false,"deletedHere","path","backend/dedup.ts","latestPath","fileId","7d3c1054-f806-11f0-818c-42dde27851f2","name","dedup.ts","fileType","script","content","/**\n * Deduplication engine for Loki\n * Handles address normalization and matching to prevent duplicate listings\n */\n\nimport { sqlite } from \"https://esm.town/v/std/sqlite\";\nimport type { Listing, ListingSource, ScrapedListing, AddressFingerprint } from \"../shared/types.ts\";\n\nconst TABLE_PREFIX = \"loki_\";\n\n// Street suffix mappings for normalization\nconst STREET_SUFFIXES: Record = {\n \"street\": \"st\",\n \"st.\": \"st\",\n \"avenue\": \"ave\",\n \"ave.\": \"ave\",\n \"boulevard\": \"blvd\",\n \"blvd.\": \"blvd\",\n \"drive\": \"dr\",\n \"dr.\": \"dr\",\n \"lane\": \"ln\",\n \"ln.\": \"ln\",\n \"road\": \"rd\",\n \"rd.\": \"rd\",\n \"court\": \"ct\",\n \"ct.\": \"ct\",\n \"place\": \"pl\",\n \"pl.\": \"pl\",\n \"way\": \"way\",\n \"circle\": \"cir\",\n \"cir.\": \"cir\",\n \"terrace\": \"ter\",\n \"ter.\": \"ter\",\n \"parkway\": \"pkwy\",\n \"pkwy.\": \"pkwy\",\n \"highway\": \"hwy\",\n \"hwy.\": \"hwy\",\n \"square\": \"sq\",\n \"sq.\": \"sq\",\n};\n\n// Unit identifier patterns to standardize\nconst UNIT_PATTERNS = [\n /\\b(?:apt|apartment)\\.?\\s*#?\\s*(\\w+)/i,\n /\\b(?:unit)\\.?\\s*#?\\s*(\\w+)/i,\n /\\b(?:suite|ste)\\.?\\s*#?\\s*(\\w+)/i,\n /\\b(?:floor|fl)\\.?\\s*#?\\s*(\\w+)/i,\n /\\b#\\s*(\\w+)/i,\n /\\bno\\.?\\s*(\\w+)/i,\n];\n\n/**\n * Generate unique ID\n */\nfunction generateId(): string {\n return `${Date.now()}-${Math.random().toString(36).substring(2, 15)}`;\n}\n\n/**\n * Normalize a street suffix\n */\nfunction normalizeStreetSuffix(word: string): string {\n const lower = word.toLowerCase();\n return STREET_SUFFIXES[lower] || lower;\n}\n\n/**\n * Extract and standardize unit number from address\n * Returns the unit identifier or null if none found\n */\nfunction extractUnit(address: string): { unit: string | null; addressWithoutUnit: string } {\n let unit: string | null = null;\n let addressWithoutUnit = address;\n\n for (const pattern of UNIT_PATTERNS) {\n const match = address.match(pattern);\n if (match) {\n unit = match[1].toLowerCase();\n // Remove the unit part from the address\n addressWithoutUnit = address.replace(pattern, \"\").trim();\n break;\n }\n }\n\n // Clean up any leftover punctuation/whitespace\n addressWithoutUnit = addressWithoutUnit.replace(/,\\s*,/g, \",\").replace(/\\s+/g, \" \").trim();\n\n return { unit, addressWithoutUnit };\n}\n\n/**\n * Normalize an address for fingerprint generation\n * - Lowercase\n * - Standardize street suffixes\n * - Extract and standardize unit numbers\n * - Remove extra whitespace and punctuation\n */\nexport function normalizeAddress(address: string): AddressFingerprint {\n // First extract the unit\n const { unit, addressWithoutUnit } = extractUnit(address);\n\n // Normalize the main address\n let normalized = addressWithoutUnit\n .toLowerCase()\n .replace(/[^\\w\\s]/g, \" \") // Remove punctuation except spaces\n .replace(/\\s+/g, \" \") // Normalize whitespace\n .trim();\n\n // Normalize street suffixes\n const words = normalized.split(\" \");\n const normalizedWords = words.map(normalizeStreetSuffix);\n const street = normalizedWords.join(\" \");\n\n // Generate fingerprint: street address + unit (if any)\n const fingerprint = unit ? `${street}|unit ${unit}` : street;\n\n return {\n street,\n unit,\n fingerprint,\n };\n}\n\n/**\n * Calculate distance between two lat/lng points in meters\n * Using Haversine formula\n */\nfunction calculateDistance(lat1: number, lng1: number, lat2: number, lng2: number): number {\n const R = 6371000; // Earth's radius in meters\n const dLat = (lat2 - lat1) * Math.PI / 180;\n const dLng = (lng2 - lng1) * Math.PI / 180;\n const a = Math.sin(dLat / 2) * Math.sin(dLat / 2) +\n Math.cos(lat1 * Math.PI / 180) * Math.cos(lat2 * Math.PI / 180) *\n Math.sin(dLng / 2) * Math.sin(dLng / 2);\n const c = 2 * Math.atan2(Math.sqrt(a), Math.sqrt(1 - a));\n return R * c;\n}\n\n/**\n * Find existing listing by fingerprint match\n */\nasync function findByFingerprint(fingerprint: string): Promise {\n const result = await sqlite.execute({\n sql: `SELECT * FROM ${TABLE_PREFIX}listings WHERE address_normalized = ? LIMIT 1`,\n args: [fingerprint],\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 address_original: row.address_original as string,\n address_normalized: row.address_normalized as string,\n unit_number: row.unit_number as string | null,\n lat: row.lat as number | null,\n lng: row.lng as number | null,\n beds: row.beds as number | null,\n baths: row.baths as number | null,\n price: row.price as number | null,\n availability: row.availability as string | null,\n neighborhood: row.neighborhood as string | null,\n first_seen_at: row.first_seen_at as number,\n last_updated_at: row.last_updated_at as number,\n is_active: Boolean(row.is_active),\n };\n}\n\n/**\n * Find existing listing by geo proximity and unit match\n * Used as fallback when fingerprint doesn't match but might be same location\n */\nasync function findByGeoProximity(\n lat: number,\n lng: number,\n unit: string | null,\n beds: number | null,\n price: number | null\n): Promise {\n // Get nearby listings (within approximately 100m bounding box)\n const latDelta = 0.001; // ~111 meters\n const lngDelta = 0.001; // ~85 meters at SF latitude\n\n const result = await sqlite.execute({\n sql: `\n SELECT * FROM ${TABLE_PREFIX}listings \n WHERE lat BETWEEN ? AND ? \n AND lng BETWEEN ? AND ?\n AND is_active = 1\n `,\n args: [lat - latDelta, lat + latDelta, lng - lngDelta, lng + lngDelta],\n });\n\n for (const row of result.rows) {\n const existingLat = row.lat as number;\n const existingLng = row.lng as number;\n const existingUnit = row.unit_number as string | null;\n const existingBeds = row.beds as number | null;\n const existingPrice = row.price as number | null;\n\n // Check distance (< 50 meters)\n const distance = calculateDistance(lat, lng, existingLat, existingLng);\n if (distance > 50) continue;\n\n // Check unit match (both null or same value)\n if (unit !== existingUnit) continue;\n\n // Check beds match (if both have values)\n if (beds !== null && existingBeds !== null && beds !== existingBeds) continue;\n\n // Check price similarity (within 10% or $200)\n if (price !== null && existingPrice !== null) {\n const priceDiff = Math.abs(price - existingPrice);\n const pricePercent = priceDiff / Math.max(price, existingPrice);\n if (priceDiff > 200 && pricePercent > 0.1) continue;\n }\n\n // Found a match\n return {\n id: row.id as string,\n address_original: row.address_original as string,\n address_normalized: row.address_normalized as string,\n unit_number: existingUnit,\n lat: existingLat,\n lng: existingLng,\n beds: existingBeds,\n baths: row.baths as number | null,\n price: existingPrice,\n availability: row.availability as string | null,\n neighborhood: row.neighborhood as string | null,\n first_seen_at: row.first_seen_at as number,\n last_updated_at: row.last_updated_at as number,\n is_active: Boolean(row.is_active),\n };\n }\n\n return null;\n}\n\n/**\n * Check if a source URL already exists\n */\nasync function sourceExists(url: string): Promise {\n const result = await sqlite.execute({\n sql: `SELECT 1 FROM ${TABLE_PREFIX}listing_sources WHERE url = ?`,\n args: [url],\n });\n return result.rows.length > 0;\n}\n\n/**\n * Add a new source to an existing listing\n */\nasync function addSourceToListing(\n listingId: string,\n source: {\n platform: \"zillow\" | \"craigslist\";\n url: string;\n raw_address: string | null;\n }\n): Promise {\n const now = Math.floor(Date.now() / 1000);\n const sourceId = generateId();\n\n await sqlite.execute({\n sql: `\n INSERT INTO ${TABLE_PREFIX}listing_sources \n (id, listing_id, platform, url, raw_address, first_seen_at, last_seen_at)\n VALUES (?, ?, ?, ?, ?, ?, ?)\n `,\n args: [sourceId, listingId, source.platform, source.url, source.raw_address, now, now],\n });\n\n // Update listing's last_updated_at and mark as active\n await sqlite.execute({\n sql: `UPDATE ${TABLE_PREFIX}listings SET last_updated_at = ?, is_active = 1 WHERE id = ?`,\n args: [now, listingId],\n });\n}\n\n/**\n * Update source's last_seen_at timestamp\n */\nasync function updateSourceLastSeen(url: string): Promise {\n const now = Math.floor(Date.now() / 1000);\n await sqlite.execute({\n sql: `UPDATE ${TABLE_PREFIX}listing_sources SET last_seen_at = ? WHERE url = ?`,\n args: [now, url],\n });\n}\n\n/**\n * Create a new canonical listing\n */\nasync function createListing(\n scraped: ScrapedListing,\n fingerprint: AddressFingerprint\n): Promise {\n const now = Math.floor(Date.now() / 1000);\n const listingId = generateId();\n\n await sqlite.execute({\n sql: `\n INSERT INTO ${TABLE_PREFIX}listings \n (id, address_original, address_normalized, unit_number, lat, lng, beds, baths, price, availability, first_seen_at, last_updated_at, is_active)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, 1)\n `,\n args: [\n listingId,\n scraped.address,\n fingerprint.fingerprint,\n fingerprint.unit,\n scraped.lat || null,\n scraped.lng || null,\n scraped.beds || null,\n scraped.baths || null,\n scraped.price || null,\n scraped.availability || null,\n now,\n now,\n ],\n });\n\n // Add the source\n await addSourceToListing(listingId, {\n platform: scraped.platform,\n url: scraped.url,\n raw_address: scraped.address,\n });\n\n return {\n id: listingId,\n address_original: scraped.address,\n address_normalized: fingerprint.fingerprint,\n unit_number: fingerprint.unit,\n lat: scraped.lat || null,\n lng: scraped.lng || null,\n beds: scraped.beds || null,\n baths: scraped.baths || null,\n price: scraped.price || null,\n availability: scraped.availability || null,\n neighborhood: null,\n first_seen_at: now,\n last_updated_at: now,\n is_active: true,\n };\n}\n\n/**\n * Process a scraped listing through deduplication\n * Returns the canonical listing (either existing or newly created)\n */\nexport async function processScrapedListing(scraped: ScrapedListing): Promise<{\n listing: Listing;\n isNew: boolean;\n source: \"fingerprint\" | \"geo\" | \"new\";\n}> {\n // Check if this exact URL already exists\n if (await sourceExists(scraped.url)) {\n // Update last_seen_at for the source\n await updateSourceLastSeen(scraped.url);\n \n // Find the listing for this source\n const sourceResult = await sqlite.execute({\n sql: `SELECT listing_id FROM ${TABLE_PREFIX}listing_sources WHERE url = ?`,\n args: [scraped.url],\n });\n \n if (sourceResult.rows.length > 0) {\n const listingId = sourceResult.rows[0].listing_id as string;\n const listing = await findByFingerprint(\n (await sqlite.execute({\n sql: `SELECT address_normalized FROM ${TABLE_PREFIX}listings WHERE id = ?`,\n args: [listingId],\n })).rows[0].address_normalized as string\n );\n \n if (listing) {\n return { listing, isNew: false, source: \"fingerprint\" };\n }\n }\n }\n\n // Normalize the address\n const fingerprint = normalizeAddress(scraped.address);\n\n // Try to find by fingerprint (exact address match)\n let existingListing = await findByFingerprint(fingerprint.fingerprint);\n if (existingListing) {\n // Add this URL as a new source\n await addSourceToListing(existingListing.id, {\n platform: scraped.platform,\n url: scraped.url,\n raw_address: scraped.address,\n });\n return { listing: existingListing, isNew: false, source: \"fingerprint\" };\n }\n\n // Try to find by geo proximity (if coordinates available)\n if (scraped.lat && scraped.lng) {\n existingListing = await findByGeoProximity(\n scraped.lat,\n scraped.lng,\n fingerprint.unit,\n scraped.beds || null,\n scraped.price || null\n );\n if (existingListing) {\n // Add this URL as a new source\n await addSourceToListing(existingListing.id, {\n platform: scraped.platform,\n url: scraped.url,\n raw_address: scraped.address,\n });\n return { listing: existingListing, isNew: false, source: \"geo\" };\n }\n }\n\n // No match found, create new listing\n const newListing = await createListing(scraped, fingerprint);\n return { listing: newListing, isNew: true, source: \"new\" };\n}\n\n/**\n * Mark listings as inactive if not seen in X days\n */\nexport async function markInactiveListings(daysThreshold: number = 7): Promise {\n const thresholdTimestamp = Math.floor(Date.now() / 1000) - (daysThreshold * 24 * 60 * 60);\n\n // Find listings where all sources haven't been seen recently\n const result = await sqlite.execute({\n sql: `\n UPDATE ${TABLE_PREFIX}listings \n SET is_active = 0 \n WHERE id IN (\n SELECT l.id \n FROM ${TABLE_PREFIX}listings l\n WHERE l.is_active = 1\n AND NOT EXISTS (\n SELECT 1 FROM ${TABLE_PREFIX}listing_sources s \n WHERE s.listing_id = l.id \n AND s.last_seen_at > ?\n )\n )\n `,\n args: [thresholdTimestamp],\n });\n\n return result.rowsAffected || 0;\n}\n\n/**\n * Batch process multiple scraped listings\n */\nexport async function processBatchListings(listings: ScrapedListing[]): Promise<{\n total: number;\n new: number;\n updated: number;\n errors: number;\n}> {\n const results = {\n total: listings.length,\n new: 0,\n updated: 0,\n errors: 0,\n };\n\n for (const listing of listings) {\n try {\n const { isNew } = await processScrapedListing(listing);\n if (isNew) {\n results.new++;\n } else {\n results.updated++;\n }\n } catch (error) {\n console.error(\"Error processing listing:\", listing.url, error);\n results.errors++;\n }\n }\n\n return results;\n}\n\nexport { findByFingerprint, findByGeoProximity, sourceExists };\n","/**\n * Deduplication engine for Loki\n * Handles address normalization and matching to prevent duplicate listings\n */\n\nimport { sqlite } from \"https://esm.town/v/std/sqlite\";\nimport type { Listing, ListingSource, ScrapedListing, AddressFingerprint } from \"../shared/types.ts\";\nimport { rowToObject, rowsToObjects } from \"./db-utils.ts\";\n\nconst TABLE_PREFIX = \"loki_\";\n\n// Street suffix mappings for normalization\nconst STREET_SUFFIXES: Record = {\n \"street\": \"st\",\n \"st.\": \"st\",\n \"avenue\": \"ave\",\n \"ave.\": \"ave\",\n \"boulevard\": \"blvd\",\n \"blvd.\": \"blvd\",\n \"drive\": \"dr\",\n \"dr.\": \"dr\",\n \"lane\": \"ln\",\n \"ln.\": \"ln\",\n \"road\": \"rd\",\n \"rd.\": \"rd\",\n \"court\": \"ct\",\n \"ct.\": \"ct\",\n \"place\": \"pl\",\n \"pl.\": \"pl\",\n \"way\": \"way\",\n \"circle\": \"cir\",\n \"cir.\": \"cir\",\n \"terrace\": \"ter\",\n \"ter.\": \"ter\",\n \"parkway\": \"pkwy\",\n \"pkwy.\": \"pkwy\",\n \"highway\": \"hwy\",\n \"hwy.\": \"hwy\",\n \"square\": \"sq\",\n \"sq.\": \"sq\",\n};\n\n// Unit identifier patterns to standardize\nconst UNIT_PATTERNS = [\n /\\b(?:apt|apartment)\\.?\\s*#?\\s*(\\w+)/i,\n /\\b(?:unit)\\.?\\s*#?\\s*(\\w+)/i,\n /\\b(?:suite|ste)\\.?\\s*#?\\s*(\\w+)/i,\n /\\b(?:floor|fl)\\.?\\s*#?\\s*(\\w+)/i,\n /\\b#\\s*(\\w+)/i,\n /\\bno\\.?\\s*(\\w+)/i,\n];\n\n/**\n * Generate unique ID\n */\nfunction generateId(): string {\n return `${Date.now()}-${Math.random().toString(36).substring(2, 15)}`;\n}\n\n/**\n * Normalize a street suffix\n */\nfunction normalizeStreetSuffix(word: string): string {\n const lower = word.toLowerCase();\n return STREET_SUFFIXES[lower] || lower;\n}\n\n/**\n * Extract and standardize unit number from address\n * Returns the unit identifier or null if none found\n */\nfunction extractUnit(address: string): { unit: string | null; addressWithoutUnit: string } {\n let unit: string | null = null;\n let addressWithoutUnit = address;\n\n for (const pattern of UNIT_PATTERNS) {\n const match = address.match(pattern);\n if (match) {\n unit = match[1].toLowerCase();\n // Remove the unit part from the address\n addressWithoutUnit = address.replace(pattern, \"\").trim();\n break;\n }\n }\n\n // Clean up any leftover punctuation/whitespace\n addressWithoutUnit = addressWithoutUnit.replace(/,\\s*,/g, \",\").replace(/\\s+/g, \" \").trim();\n\n return { unit, addressWithoutUnit };\n}\n\n/**\n * Normalize an address for fingerprint generation\n * - Lowercase\n * - Standardize street suffixes\n * - Extract and standardize unit numbers\n * - Remove extra whitespace and punctuation\n */\nexport function normalizeAddress(address: string): AddressFingerprint {\n // First extract the unit\n const { unit, addressWithoutUnit } = extractUnit(address);\n\n // Normalize the main address\n let normalized = addressWithoutUnit\n .toLowerCase()\n .replace(/[^\\w\\s]/g, \" \") // Remove punctuation except spaces\n .replace(/\\s+/g, \" \") // Normalize whitespace\n .trim();\n\n // Normalize street suffixes\n const words = normalized.split(\" \");\n const normalizedWords = words.map(normalizeStreetSuffix);\n const street = normalizedWords.join(\" \");\n\n // Generate fingerprint: street address + unit (if any)\n const fingerprint = unit ? `${street}|unit ${unit}` : street;\n\n return {\n street,\n unit,\n fingerprint,\n };\n}\n\n/**\n * Calculate distance between two lat/lng points in meters\n * Using Haversine formula\n */\nfunction calculateDistance(lat1: number, lng1: number, lat2: number, lng2: number): number {\n const R = 6371000; // Earth's radius in meters\n const dLat = (lat2 - lat1) * Math.PI / 180;\n const dLng = (lng2 - lng1) * Math.PI / 180;\n const a = Math.sin(dLat / 2) * Math.sin(dLat / 2) +\n Math.cos(lat1 * Math.PI / 180) * Math.cos(lat2 * Math.PI / 180) *\n Math.sin(dLng / 2) * Math.sin(dLng / 2);\n const c = 2 * Math.atan2(Math.sqrt(a), Math.sqrt(1 - a));\n return R * c;\n}\n\n// Type for raw listing row from database\ntype ListingRow = {\n id: string;\n address_original: string;\n address_normalized: string;\n unit_number: string | null;\n lat: number | null;\n lng: number | null;\n beds: number | null;\n baths: number | null;\n price: number | null;\n availability: string | null;\n neighborhood: string | null;\n first_seen_at: number;\n last_updated_at: number;\n is_active: number;\n};\n\n/**\n * Find existing listing by fingerprint match\n */\nasync function findByFingerprint(fingerprint: string): Promise {\n const result = await sqlite.execute({\n sql: `SELECT id, address_original, address_normalized, unit_number, lat, lng, beds, baths, price, availability, neighborhood, first_seen_at, last_updated_at, is_active FROM ${TABLE_PREFIX}listings WHERE address_normalized = ? LIMIT 1`,\n args: [fingerprint],\n });\n\n if (result.rows.length === 0) return null;\n\n const row = rowToObject(result.rows[0] as unknown[] | Record, result.columns);\n return {\n id: row.id,\n address_original: row.address_original,\n address_normalized: row.address_normalized,\n unit_number: row.unit_number,\n lat: row.lat,\n lng: row.lng,\n beds: row.beds,\n baths: row.baths,\n price: row.price,\n availability: row.availability,\n neighborhood: row.neighborhood,\n first_seen_at: row.first_seen_at,\n last_updated_at: row.last_updated_at,\n is_active: Boolean(row.is_active),\n };\n}\n\n/**\n * Find existing listing by geo proximity and unit match\n * Used as fallback when fingerprint doesn't match but might be same location\n */\nasync function findByGeoProximity(\n lat: number,\n lng: number,\n unit: string | null,\n beds: number | null,\n price: number | null\n): Promise {\n // Get nearby listings (within approximately 100m bounding box)\n const latDelta = 0.001; // ~111 meters\n const lngDelta = 0.001; // ~85 meters at SF latitude\n\n const result = await sqlite.execute({\n sql: `\n SELECT id, address_original, address_normalized, unit_number, lat, lng, beds, baths, price, availability, neighborhood, first_seen_at, last_updated_at, is_active FROM ${TABLE_PREFIX}listings \n WHERE lat BETWEEN ? AND ? \n AND lng BETWEEN ? AND ?\n AND is_active = 1\n `,\n args: [lat - latDelta, lat + latDelta, lng - lngDelta, lng + lngDelta],\n });\n\n const rows = rowsToObjects(result.rows as (unknown[] | Record)[], result.columns);\n\n for (const row of rows) {\n const existingLat = row.lat as number;\n const existingLng = row.lng as number;\n const existingUnit = row.unit_number;\n const existingBeds = row.beds;\n const existingPrice = row.price;\n\n // Check distance (< 50 meters)\n const distance = calculateDistance(lat, lng, existingLat, existingLng);\n if (distance > 50) continue;\n\n // Check unit match (both null or same value)\n if (unit !== existingUnit) continue;\n\n // Check beds match (if both have values)\n if (beds !== null && existingBeds !== null && beds !== existingBeds) continue;\n\n // Check price similarity (within 10% or $200)\n if (price !== null && existingPrice !== null) {\n const priceDiff = Math.abs(price - existingPrice);\n const pricePercent = priceDiff / Math.max(price, existingPrice);\n if (priceDiff > 200 && pricePercent > 0.1) continue;\n }\n\n // Found a match\n return {\n id: row.id,\n address_original: row.address_original,\n address_normalized: row.address_normalized,\n unit_number: existingUnit,\n lat: existingLat,\n lng: existingLng,\n beds: existingBeds,\n baths: row.baths,\n price: existingPrice,\n availability: row.availability,\n neighborhood: row.neighborhood,\n first_seen_at: row.first_seen_at,\n last_updated_at: row.last_updated_at,\n is_active: Boolean(row.is_active),\n };\n }\n\n return null;\n}\n\n/**\n * Check if a source URL already exists\n */\nasync function sourceExists(url: string): Promise {\n const result = await sqlite.execute({\n sql: `SELECT 1 FROM ${TABLE_PREFIX}listing_sources WHERE url = ?`,\n args: [url],\n });\n return result.rows.length > 0;\n}\n\n/**\n * Add a new source to an existing listing\n */\nasync function addSourceToListing(\n listingId: string,\n source: {\n platform: \"zillow\" | \"craigslist\";\n url: string;\n raw_address: string | null;\n }\n): Promise {\n const now = Math.floor(Date.now() / 1000);\n const sourceId = generateId();\n\n await sqlite.execute({\n sql: `\n INSERT INTO ${TABLE_PREFIX}listing_sources \n (id, listing_id, platform, url, raw_address, first_seen_at, last_seen_at)\n VALUES (?, ?, ?, ?, ?, ?, ?)\n `,\n args: [sourceId, listingId, source.platform, source.url, source.raw_address, now, now],\n });\n\n // Update listing's last_updated_at and mark as active\n await sqlite.execute({\n sql: `UPDATE ${TABLE_PREFIX}listings SET last_updated_at = ?, is_active = 1 WHERE id = ?`,\n args: [now, listingId],\n });\n}\n\n/**\n * Update source's last_seen_at timestamp\n */\nasync function updateSourceLastSeen(url: string): Promise {\n const now = Math.floor(Date.now() / 1000);\n await sqlite.execute({\n sql: `UPDATE ${TABLE_PREFIX}listing_sources SET last_seen_at = ? WHERE url = ?`,\n args: [now, url],\n });\n}\n\n/**\n * Create a new canonical listing\n */\nasync function createListing(\n scraped: ScrapedListing,\n fingerprint: AddressFingerprint\n): Promise {\n const now = Math.floor(Date.now() / 1000);\n const listingId = generateId();\n\n await sqlite.execute({\n sql: `\n INSERT INTO ${TABLE_PREFIX}listings \n (id, address_original, address_normalized, unit_number, lat, lng, beds, baths, price, availability, first_seen_at, last_updated_at, is_active)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, 1)\n `,\n args: [\n listingId,\n scraped.address,\n fingerprint.fingerprint,\n fingerprint.unit,\n scraped.lat || null,\n scraped.lng || null,\n scraped.beds || null,\n scraped.baths || null,\n scraped.price || null,\n scraped.availability || null,\n now,\n now,\n ],\n });\n\n // Add the source\n await addSourceToListing(listingId, {\n platform: scraped.platform,\n url: scraped.url,\n raw_address: scraped.address,\n });\n\n return {\n id: listingId,\n address_original: scraped.address,\n address_normalized: fingerprint.fingerprint,\n unit_number: fingerprint.unit,\n lat: scraped.lat || null,\n lng: scraped.lng || null,\n beds: scraped.beds || null,\n baths: scraped.baths || null,\n price: scraped.price || null,\n availability: scraped.availability || null,\n neighborhood: null,\n first_seen_at: now,\n last_updated_at: now,\n is_active: true,\n };\n}\n\n/**\n * Process a scraped listing through deduplication\n * Returns the canonical listing (either existing or newly created)\n */\nexport async function processScrapedListing(scraped: ScrapedListing): Promise<{\n listing: Listing;\n isNew: boolean;\n source: \"fingerprint\" | \"geo\" | \"new\";\n}> {\n // Check if this exact URL already exists\n if (await sourceExists(scraped.url)) {\n // Update last_seen_at for the source\n await updateSourceLastSeen(scraped.url);\n \n // Find the listing for this source\n const sourceResult = await sqlite.execute({\n sql: `SELECT listing_id FROM ${TABLE_PREFIX}listing_sources WHERE url = ?`,\n args: [scraped.url],\n });\n \n if (sourceResult.rows.length > 0) {\n const listingId = sourceResult.rows[0].listing_id as string;\n const listing = await findByFingerprint(\n (await sqlite.execute({\n sql: `SELECT address_normalized FROM ${TABLE_PREFIX}listings WHERE id = ?`,\n args: [listingId],\n })).rows[0].address_normalized as string\n );\n \n if (listing) {\n return { listing, isNew: false, source: \"fingerprint\" };\n }\n }\n }\n\n // Normalize the address\n const fingerprint = normalizeAddress(scraped.address);\n\n // Try to find by fingerprint (exact address match)\n let existingListing = await findByFingerprint(fingerprint.fingerprint);\n if (existingListing) {\n // Add this URL as a new source\n await addSourceToListing(existingListing.id, {\n platform: scraped.platform,\n url: scraped.url,\n raw_address: scraped.address,\n });\n return { listing: existingListing, isNew: false, source: \"fingerprint\" };\n }\n\n // Try to find by geo proximity (if coordinates available)\n if (scraped.lat && scraped.lng) {\n existingListing = await findByGeoProximity(\n scraped.lat,\n scraped.lng,\n fingerprint.unit,\n scraped.beds || null,\n scraped.price || null\n );\n if (existingListing) {\n // Add this URL as a new source\n await addSourceToListing(existingListing.id, {\n platform: scraped.platform,\n url: scraped.url,\n raw_address: scraped.address,\n });\n return { listing: existingListing, isNew: false, source: \"geo\" };\n }\n }\n\n // No match found, create new listing\n const newListing = await createListing(scraped, fingerprint);\n return { listing: newListing, isNew: true, source: \"new\" };\n}\n\n/**\n * Mark listings as inactive if not seen in X days\n */\nexport async function markInactiveListings(daysThreshold: number = 7): Promise {\n const thresholdTimestamp = Math.floor(Date.now() / 1000) - (daysThreshold * 24 * 60 * 60);\n\n // Find listings where all sources haven't been seen recently\n const result = await sqlite.execute({\n sql: `\n UPDATE ${TABLE_PREFIX}listings \n SET is_active = 0 \n WHERE id IN (\n SELECT l.id \n FROM ${TABLE_PREFIX}listings l\n WHERE l.is_active = 1\n AND NOT EXISTS (\n SELECT 1 FROM ${TABLE_PREFIX}listing_sources s \n WHERE s.listing_id = l.id \n AND s.last_seen_at > ?\n )\n )\n `,\n args: [thresholdTimestamp],\n });\n\n return result.rowsAffected || 0;\n}\n\n/**\n * Batch process multiple scraped listings\n */\nexport async function processBatchListings(listings: ScrapedListing[]): Promise<{\n total: number;\n new: number;\n updated: number;\n errors: number;\n}> {\n const results = {\n total: listings.length,\n new: 0,\n updated: 0,\n errors: 0,\n };\n\n for (const listing of listings) {\n try {\n const { isNew } = await processScrapedListing(listing);\n if (isNew) {\n results.new++;\n } else {\n results.updated++;\n }\n } catch (error) {\n console.error(\"Error processing listing:\", listing.url, error);\n results.errors++;\n }\n }\n\n return results;\n}\n\nexport { findByFingerprint, findByGeoProximity, sourceExists };\n","createdAt",["D",1769139155818],"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",{"_97":96,"_104":100},"org",{"_97":96,"_98":-5,"_99":100,"_18":55,"_101":102,"_103":25},"branch",{"_13":86,"_32":87,"_44":43,"_88":45,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":46,"_95":96},"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",{"_44":45,"_32":46,"_39":558,"_48":-5,"_49":25,"_50":51,"_52":51,"_53":-5,"_54":-5,"_18":55,"_56":57,"_58":59,"_60":59,"_61":-5,"_62":63,"_64":65,"_66":-5,"_67":-5,"_68":-5,"_69":-5,"_70":71,"_72":71,"_73":74,"_75":74,"_76":74,"_77":71,"_78":71,"_79":559,"_81":560,"_83":561,"_85":25},"tree",[312,322,329,333,335,336,337,338,339,340,341,342,343,344,345,346,347,348,349,350],"files",[312,313,314,315,316,317,318,319,320,321,322,323,324,325,326,327,328,329,330,331,332,333,334,335,336,337,338,339,340,341,342,343,344,345,346,347,348,349,350],"counts",{"_300":63,"_301":302,"_303":63,"_304":305,"_306":307},"contents",[129,130,131,132,133,134,135,136,137,138,139,140,141,142,143,144,145,146,147,148],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{"_127":128},"7db1ceb6-f806-11f0-810f-42dde27851f2","loki.shapedlines.com",{"_44":294,"_32":295,"_30":296,"_152":-5,"_42":43,"_41":297,"_154":59,"_39":298,"_13":63,"_34":280,"_36":-5,"_24":25,"_159":-5,"_27":299},{"_44":288,"_32":289,"_30":290,"_152":-5,"_42":43,"_41":291,"_154":59,"_39":292,"_13":63,"_34":280,"_36":-5,"_24":25,"_159":-5,"_27":293},{"_44":282,"_32":283,"_30":284,"_152":-5,"_42":43,"_41":285,"_154":59,"_39":286,"_13":63,"_34":280,"_36":-5,"_24":25,"_159":-5,"_27":287},{"_44":275,"_32":276,"_30":277,"_152":-5,"_42":43,"_41":278,"_154":59,"_39":279,"_13":63,"_34":280,"_36":-5,"_24":25,"_159":-5,"_27":281},{"_44":268,"_32":269,"_30":270,"_152":-5,"_42":43,"_41":271,"_154":59,"_39":272,"_13":63,"_34":20,"_36":273,"_24":25,"_159":-5,"_27":274},{"_44":261,"_32":262,"_30":263,"_152":-5,"_42":43,"_41":264,"_154":59,"_39":265,"_13":63,"_34":20,"_36":266,"_24":25,"_159":-5,"_27":267},{"_44":254,"_32":255,"_30":256,"_152":-5,"_42":43,"_41":257,"_154":59,"_39":258,"_13":63,"_34":20,"_36":259,"_24":25,"_159":-5,"_27":260},{"_44":245,"_32":246,"_30":247,"_152":-5,"_42":43,"_41":248,"_154":59,"_39":249,"_13":250,"_34":251,"_36":252,"_24":25,"_159":-5,"_27":253},{"_44":239,"_32":240,"_30":57,"_152":-5,"_42":43,"_41":241,"_154":59,"_39":242,"_13":174,"_34":175,"_36":243,"_24":25,"_159":-5,"_27":244},{"_44":231,"_32":232,"_30":233,"_152":-5,"_42":43,"_41":234,"_154":59,"_39":235,"_13":236,"_34":157,"_36":237,"_24":25,"_159":-5,"_27":238},{"_44":224,"_32":225,"_30":226,"_152":-5,"_42":43,"_41":227,"_154":59,"_39":228,"_13":63,"_34":20,"_36":229,"_24":25,"_159":-5,"_27":230},{"_44":216,"_32":217,"_30":218,"_152":-5,"_42":43,"_41":219,"_154":59,"_39":220,"_13":221,"_34":175,"_36":222,"_24":25,"_159":-5,"_27":223},{"_44":209,"_32":210,"_30":211,"_152":-5,"_42":43,"_41":212,"_154":59,"_39":213,"_13":183,"_34":175,"_36":214,"_24":25,"_159":-5,"_27":215},{"_44":201,"_32":202,"_30":203,"_152":-5,"_42":43,"_41":204,"_154":25,"_39":205,"_13":206,"_34":175,"_36":207,"_24":25,"_159":-5,"_27":208},{"_44":194,"_32":195,"_30":196,"_152":-5,"_42":43,"_41":197,"_154":25,"_39":198,"_13":183,"_34":175,"_36":199,"_24":25,"_159":-5,"_27":200},{"_44":186,"_32":187,"_30":188,"_152":-5,"_42":43,"_41":189,"_154":25,"_39":190,"_13":191,"_34":35,"_36":192,"_24":25,"_159":-5,"_27":193},{"_44":178,"_32":179,"_30":180,"_152":-5,"_42":43,"_41":181,"_154":59,"_39":182,"_13":183,"_34":175,"_36":184,"_24":25,"_159":-5,"_27":185},{"_44":169,"_32":170,"_30":171,"_152":-5,"_42":43,"_41":172,"_154":59,"_39":173,"_13":174,"_34":175,"_36":176,"_24":25,"_159":-5,"_27":177},{"_44":161,"_32":162,"_30":163,"_152":-5,"_42":43,"_41":164,"_154":59,"_39":165,"_13":166,"_34":35,"_36":167,"_24":25,"_159":-5,"_27":168},{"_44":149,"_32":150,"_30":151,"_152":-5,"_42":43,"_41":153,"_154":25,"_39":155,"_13":156,"_34":157,"_36":158,"_24":25,"_159":-5,"_27":160},"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",[150],"7fc0d4ae-6774-11f0-8b01-0224a6c84d84","zillowParseURL.tsx","f3734ae0-65ac-11f0-8f64-0224a6c84d84",279,["D",1753241050560],15,"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);",[162],"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}",[170],"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;",[179],"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// );",[187],"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}",[195],"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}",[202],"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}",[210],"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}",[217],"7d307d0c-f806-11f0-8f00-42dde27851f2","deno.json","7d307dfc-f806-11f0-8f00-42dde27851f2",299,["D",1769136720207],"{\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}",[225],"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}",[232],"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}",[240],"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}",[246],"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```",[255],"7db87a40-f806-11f0-8c38-42dde27851f2","AGENTS.md","7db87ae0-f806-11f0-8c38-42dde27851f2",313,["D",1769136721106],"You are an advanced assistant specialized in generating Val Town code.\n\n## Core Guidelines\n\n- Ask clarifying questions when requirements are ambiguous\n- Provide complete, functional solutions rather than skeleton implementations\n- Test your logic against edge cases before presenting the final solution\n- Ensure all code follows Val Town's specific platform requirements\n- If a section of code that you're working on is getting too complex, consider refactoring it into subcomponents\n\n## Code Standards\n\n- Generate code in TypeScript or TSX\n- Add appropriate TypeScript types and interfaces for all data structures\n- Prefer official SDKs or libraries than writing API calls directly\n- Ask the user to supply API or library documentation if you are at all unsure about it\n- **Never bake in secrets into the code** - always use environment variables\n- Include comments explaining complex logic (avoid commenting obvious operations)\n- Follow modern ES6+ conventions and functional programming practices if possible\n\n## Types of triggers\n\n### 1. HTTP Trigger\n\n- Create web APIs and endpoints\n- Handle HTTP requests and responses\n- Example structure:\n\n```ts\nexport default async function (req: Request) {\n return new Response(\"Hello World\");\n}\n```\n\nFiles that are HTTP triggers have http in their name like `foobar.http.tsx`\n\n### 2. Cron Triggers\n\n- Run on a schedule\n- Use cron expressions for timing\n- Example structure:\n\n```ts\nexport default async function () {\n // Scheduled task code\n}\n```\n\nFiles that are Cron triggers have cron in their name like `foobar.cron.tsx`\n\n### 3. Email Triggers\n\n- Process incoming emails\n- Handle email-based workflows\n- Example structure:\n\n```ts\nexport default async function (email: Email) {\n // Process email\n}\n```\n\nFiles that are Email triggers have email in their name like `foobar.email.tsx`\n\n\n## Val Town Standard Libraries\n\nVal Town provides several hosted services and utility functions.\n\n### Blob Storage\n\n```ts\nimport { blob } from \"https://esm.town/v/std/blob\";\nawait blob.setJSON(\"myKey\", { hello: \"world\" });\nlet blobDemo = await blob.getJSON(\"myKey\");\nlet appKeys = await blob.list(\"app_\");\nawait blob.delete(\"myKey\");\n```\n\n### SQLite\n\n```ts\nimport { sqlite } from \"https://esm.town/v/stevekrouse/sqlite\";\nconst TABLE_NAME = 'todo_app_users_2';\n// Create table - do this before usage and change table name when modifying schema\nawait sqlite.execute(`CREATE TABLE IF NOT EXISTS ${TABLE_NAME} (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n name TEXT NOT NULL\n)`);\n// Query data\nconst result = await sqlite.execute(`SELECT * FROM ${TABLE_NAME} WHERE id = ?`, [1]);\n```\n\nNote: When changing a SQLite table's schema, change the table's name (e.g., add _2 or _3) to create a fresh table.\n\n### OpenAI\n\n```ts\nimport { OpenAI } from \"https://esm.town/v/std/openai\";\nconst openai = new OpenAI();\nconst completion = await openai.chat.completions.create({\n messages: [\n { role: \"user\", content: \"Say hello in a creative way\" },\n ],\n model: \"gpt-4o-mini\",\n max_tokens: 30,\n});\n```\n\n### Email\n\n```ts\nimport { email } from \"https://esm.town/v/std/email\";\n// By default emails the owner of the val\nawait email({ \n subject: \"Hi\", \n text: \"Hi\", \n html: \"

Hi

\"\n});\n```\n\n## Val Town Utility Functions\n\nVal Town provides several utility functions to help with common project tasks.\n\n### Importing Utilities\n\nAlways import utilities with version pins to avoid breaking changes:\n\n```ts\nimport { parseProject, readFile, serveFile } from \"https://esm.town/v/std/utils@85-main/index.ts\";\n```\n\n### Available Utilities\n\n\n#### **serveFile** - Serve project files with proper content types\n\nFor example, in Hono:\n\n```ts\n// serve all files in frontend/ and shared/\napp.get(\"/frontend/*\", c => serveFile(c.req.path, import.meta.url));\napp.get(\"/shared/*\", c => serveFile(c.req.path, import.meta.url));\n```\n\n#### **readFile** - Read files from within the project:\n\n```ts\n// Read a file from the project\nconst fileContent = await readFile(\"/frontend/index.html\", import.meta.url);\n```\n\n#### **listFiles** - List all files in the project\n\n```ts\nconst files = await listFiles(import.meta.url);\n```\n\n#### **parseProject** - Extract information about the current project from import.meta.url\n\nThis is useful for including info for linking back to a val, ie in \"view source\" urls:\n\n```ts\nconst projectVal = parseProject(import.meta.url);\nconsole.log(projectVal.username); // Owner of the project\nconsole.log(projectVal.name); // Project name\nconsole.log(projectVal.version); // Version number\nconsole.log(projectVal.branch); // Branch name\nconsole.log(projectVal.links.self.project); // URL to the project page\n```\n\nHowever, it's *extremely importing* to note that `parseProject` and other Standard Library utilities ONLY RUN ON THE SERVER.\nIf you need access to this data on the client, run it in the server and pass it to the client by splicing it into the HTML page\nor by making an API request for it.\n\n## Val Town Platform Specifics\n\n- **Redirects:** Use `return new Response(null, { status: 302, headers: { Location: \"/place/to/redirect\" }})` instead of `Response.redirect` which is broken\n- **Images:** Avoid external images or base64 images. Use emojis, unicode symbols, or icon fonts/libraries instead\n- **AI Image:** To inline generate an AI image use: `

`\n- **Storage:** DO NOT use the Deno KV module for storage\n- **Browser APIs:** DO NOT use the `alert()`, `prompt()`, or `confirm()` methods\n- **Weather Data:** Use open-meteo for weather data (doesn't require API keys) unless otherwise specified\n- **View Source:** Add a view source link by importing & using `import.meta.url.replace(\"ems.sh\", \"val.town)\"` (or passing this data to the client) and include `target=\"_top\"` attribute\n- **Error Debugging:** Add `` to HTML to capture client-side errors\n- **Error Handling:** Only use try...catch when there's a clear local resolution; Avoid catches that merely log or return 500s. Let errors bubble up with full context\n- **Environment Variables:** Use `Deno.env.get('keyname')` when you need to, but generally prefer APIs that don't require keys\n- **Imports:** Use `https://esm.sh` for npm and Deno dependencies to ensure compatibility on server and browser\n- **Storage Strategy:** Only use backend storage if explicitly required; prefer simple static client-side sites\n- **React Configuration:** When using React libraries, pin versions with `?deps=react@18.2.0,react-dom@18.2.0` and start the file with `/** @jsxImportSource https://esm.sh/react@18.2.0 */`\n- Ensure all React dependencies and sub-dependencies are pinned to the same version\n- **Styling:** Default to using TailwindCSS via `` unless otherwise specified\n\n## Project Structure and Design Patterns\n\n### Recommended Directory Structure\n```\n├── backend/\n│ ├── database/\n│ │ ├── migrations.ts # Schema definitions\n│ │ ├── queries.ts # DB query functions\n│ │ └── README.md\n│ └── routes/ # Route modules\n│ ├── [route].ts\n│ └── static.ts # Static file serving\n│ ├── index.ts # Main entry point\n│ └── README.md\n├── frontend/\n│ ├── components/\n│ │ ├── App.tsx\n│ │ └── [Component].tsx\n│ ├── favicon.svg\n│ ├── index.html # Main HTML template\n│ ├── index.tsx # Frontend JS entry point\n│ ├── README.md\n│ └── style.css\n├── README.md\n└── shared/\n ├── README.md\n └── utils.ts # Shared types and functions\n```\n\n### Backend (Hono) Best Practices\n\n- Hono is the recommended API framework\n- Main entry point should be `backend/index.ts`\n- **Static asset serving:** Use the utility functions to read and serve project files:\n ```ts\n import { readFile, serveFile } from \"https://esm.town/v/std/utils@85-main/index.ts\";\n \n // serve all files in frontend/ and shared/\n app.get(\"/frontend/*\", c => serveFile(c.req.path, import.meta.url));\n app.get(\"/shared/*\", c => serveFile(c.req.path, import.meta.url));\n \n // For index.html, often you'll want to bootstrap with initial data\n app.get(\"/\", async c => {\n let html = await readFile(\"/frontend/index.html\", import.meta.url);\n \n // Inject data to avoid extra round-trips\n const initialData = await fetchInitialData();\n const dataScript = ``;\n \n html = html.replace(\"\", `${dataScript}`);\n return c.html(html);\n });\n ```\n- Create RESTful API routes for CRUD operations\n- Always include this snippet at the top-level Hono app to re-throwing errors to see full stack traces:\n ```ts\n // Unwrap Hono errors to see original error details\n app.onError((err, c) => {\n throw err;\n });\n ```\n\n### Database Patterns\n- Run migrations on startup or comment out for performance\n- Change table names when modifying schemas rather than altering\n- Export clear query functions with proper TypeScript typing\n\n## Common Gotchas and Solutions\n\n1. **Environment Limitations:** \n - Val Town runs on Deno in a serverless context, not Node.js\n - Code in `shared/` must work in both frontend and backend environments\n - Cannot use `Deno` keyword in shared code\n - Use `https://esm.sh` for imports that work in both environments\n\n2. **SQLite Peculiarities:**\n - Limited support for ALTER TABLE operations\n - Create new tables with updated schemas and copy data when needed\n - Always run table creation before querying\n\n3. **React Configuration:**\n - All React dependencies must be pinned to 18.2.0\n - Always include `@jsxImportSource https://esm.sh/react@18.2.0` at the top of React files\n - Rendering issues often come from mismatched React versions\n\n4. **File Handling:**\n - Val Town only supports text files, not binary\n - Use the provided utilities to read files across branches and forks\n - For files in the project, use `readFile` helpers\n\n5. **API Design:**\n - `fetch` handler is the entry point for HTTP vals\n - Run the Hono app with `export default app.fetch // This is the entry point for HTTP vals`\n\n",[262],"7db68c4e-f806-11f0-8922-42dde27851f2",".vtignore","7db68cda-f806-11f0-8922-42dde27851f2",312,["D",1769136721104],".git\n.vscode\n.cursorrules\n.DS_Store\nnode_modules\nvendor",[269],"7c93ddbc-f806-11f0-be4c-42dde27851f2","shared","7c93de8e-f806-11f0-be4c-42dde27851f2",291,["D",1769136719198],"directory",[276],"7cb32172-f806-11f0-a6eb-42dde27851f2","scrapers","7cb32212-f806-11f0-a6eb-42dde27851f2",292,["D",1769136719402],[283],"7c5ad03a-f806-11f0-a87d-42dde27851f2","frontend","7c5ad102-f806-11f0-a87d-42dde27851f2",289,["D",1769136718806],[289],"7c7592c6-f806-11f0-be4c-42dde27851f2","backend","7c759398-f806-11f0-be4c-42dde27851f2",290,["D",1769136718999],[295],"pulls","branches",2,"forks","envVars",{"_308":310,"_311":63},"connections",{"_308":63,"_309":63},"count","unfilledCount",6,"emptyCount",{"_44":294,"_32":295,"_30":296,"_152":-5,"_42":43,"_41":297,"_154":59,"_39":555,"_13":63,"_34":280,"_36":-5,"_24":25,"_159":-5,"_352":556,"_27":557},{"_44":547,"_32":548,"_30":549,"_152":296,"_42":43,"_41":550,"_154":25,"_39":551,"_13":500,"_34":35,"_36":552,"_24":25,"_159":-5,"_352":553,"_27":554},{"_44":539,"_32":540,"_30":541,"_152":296,"_42":43,"_41":542,"_154":59,"_39":543,"_13":63,"_34":35,"_36":544,"_24":25,"_159":-5,"_352":545,"_27":546},{"_44":535,"_32":33,"_30":31,"_152":296,"_42":43,"_41":14,"_154":25,"_39":536,"_13":500,"_34":35,"_36":38,"_24":25,"_159":-5,"_352":537,"_27":538},{"_44":527,"_32":528,"_30":529,"_152":296,"_42":43,"_41":530,"_154":25,"_39":531,"_13":500,"_34":35,"_36":532,"_24":25,"_159":-5,"_352":533,"_27":534},{"_44":520,"_32":521,"_30":127,"_152":296,"_42":43,"_41":522,"_154":59,"_39":523,"_13":302,"_34":175,"_36":524,"_24":25,"_159":-5,"_352":525,"_27":526},{"_44":512,"_32":513,"_30":514,"_152":296,"_42":43,"_41":515,"_154":25,"_39":516,"_13":63,"_34":35,"_36":517,"_24":25,"_159":-5,"_352":518,"_27":519},{"_44":504,"_32":505,"_30":506,"_152":296,"_42":43,"_41":507,"_154":59,"_39":508,"_13":63,"_34":35,"_36":509,"_24":25,"_159":-5,"_352":510,"_27":511},{"_44":495,"_32":496,"_30":497,"_152":296,"_42":43,"_41":498,"_154":59,"_39":499,"_13":500,"_34":35,"_36":501,"_24":25,"_159":-5,"_352":502,"_27":503},{"_44":487,"_32":488,"_30":489,"_152":296,"_42":43,"_41":490,"_154":25,"_39":491,"_13":63,"_34":35,"_36":492,"_24":25,"_159":-5,"_352":493,"_27":494},{"_44":288,"_32":289,"_30":290,"_152":-5,"_42":43,"_41":291,"_154":59,"_39":484,"_13":63,"_34":280,"_36":-5,"_24":25,"_159":-5,"_352":485,"_27":486},{"_44":479,"_32":478,"_30":472,"_152":290,"_42":43,"_41":480,"_154":59,"_39":481,"_13":63,"_34":280,"_36":-5,"_24":25,"_159":-5,"_352":482,"_27":483},{"_44":469,"_32":470,"_30":471,"_152":472,"_42":43,"_41":473,"_154":59,"_39":474,"_13":63,"_34":35,"_36":475,"_24":25,"_159":-5,"_352":476,"_27":477},{"_44":464,"_32":463,"_30":457,"_152":290,"_42":43,"_41":465,"_154":59,"_39":466,"_13":63,"_34":280,"_36":-5,"_24":25,"_159":-5,"_352":467,"_27":468},{"_44":454,"_32":455,"_30":456,"_152":457,"_42":43,"_41":458,"_154":59,"_39":459,"_13":63,"_34":35,"_36":460,"_24":25,"_159":-5,"_352":461,"_27":462},{"_44":446,"_32":447,"_30":448,"_152":290,"_42":43,"_41":449,"_154":25,"_39":450,"_13":63,"_34":35,"_36":451,"_24":25,"_159":-5,"_352":452,"_27":453},{"_44":438,"_32":439,"_30":440,"_152":290,"_42":43,"_41":441,"_154":59,"_39":442,"_13":63,"_34":20,"_36":443,"_24":25,"_159":-5,"_352":444,"_27":445},{"_44":282,"_32":283,"_30":284,"_152":-5,"_42":43,"_41":285,"_154":59,"_39":435,"_13":63,"_34":280,"_36":-5,"_24":25,"_159":-5,"_352":436,"_27":437},{"_44":427,"_32":428,"_30":429,"_152":284,"_42":43,"_41":430,"_154":59,"_39":431,"_13":63,"_34":157,"_36":432,"_24":25,"_159":-5,"_352":433,"_27":434},{"_44":419,"_32":420,"_30":421,"_152":284,"_42":43,"_41":422,"_154":59,"_39":423,"_13":63,"_34":157,"_36":424,"_24":25,"_159":-5,"_352":425,"_27":426},{"_44":411,"_32":412,"_30":413,"_152":284,"_42":43,"_41":414,"_154":59,"_39":415,"_13":63,"_34":157,"_36":416,"_24":25,"_159":-5,"_352":417,"_27":418},{"_44":275,"_32":276,"_30":277,"_152":-5,"_42":43,"_41":278,"_154":59,"_39":408,"_13":63,"_34":280,"_36":-5,"_24":25,"_159":-5,"_352":409,"_27":410},{"_44":400,"_32":401,"_30":402,"_152":277,"_42":43,"_41":403,"_154":59,"_39":404,"_13":63,"_34":35,"_36":405,"_24":25,"_159":-5,"_352":406,"_27":407},{"_44":268,"_32":269,"_30":270,"_152":-5,"_42":43,"_41":271,"_154":59,"_39":397,"_13":63,"_34":20,"_36":273,"_24":25,"_159":-5,"_352":398,"_27":399},{"_44":261,"_32":262,"_30":263,"_152":-5,"_42":43,"_41":264,"_154":59,"_39":394,"_13":63,"_34":20,"_36":266,"_24":25,"_159":-5,"_352":395,"_27":396},{"_44":254,"_32":255,"_30":256,"_152":-5,"_42":43,"_41":257,"_154":59,"_39":391,"_13":63,"_34":20,"_36":259,"_24":25,"_159":-5,"_352":392,"_27":393},{"_44":245,"_32":246,"_30":247,"_152":-5,"_42":43,"_41":248,"_154":59,"_39":388,"_13":250,"_34":251,"_36":252,"_24":25,"_159":-5,"_352":389,"_27":390},{"_44":239,"_32":240,"_30":57,"_152":-5,"_42":43,"_41":241,"_154":59,"_39":385,"_13":174,"_34":175,"_36":243,"_24":25,"_159":-5,"_352":386,"_27":387},{"_44":231,"_32":232,"_30":233,"_152":-5,"_42":43,"_41":234,"_154":59,"_39":382,"_13":236,"_34":157,"_36":237,"_24":25,"_159":-5,"_352":383,"_27":384},{"_44":224,"_32":225,"_30":226,"_152":-5,"_42":43,"_41":227,"_154":59,"_39":379,"_13":63,"_34":20,"_36":229,"_24":25,"_159":-5,"_352":380,"_27":381},{"_44":216,"_32":217,"_30":218,"_152":-5,"_42":43,"_41":219,"_154":59,"_39":376,"_13":221,"_34":175,"_36":222,"_24":25,"_159":-5,"_352":377,"_27":378},{"_44":209,"_32":210,"_30":211,"_152":-5,"_42":43,"_41":212,"_154":59,"_39":373,"_13":183,"_34":175,"_36":214,"_24":25,"_159":-5,"_352":374,"_27":375},{"_44":201,"_32":202,"_30":203,"_152":-5,"_42":43,"_41":204,"_154":25,"_39":370,"_13":206,"_34":175,"_36":207,"_24":25,"_159":-5,"_352":371,"_27":372},{"_44":194,"_32":195,"_30":196,"_152":-5,"_42":43,"_41":197,"_154":25,"_39":367,"_13":183,"_34":175,"_36":199,"_24":25,"_159":-5,"_352":368,"_27":369},{"_44":186,"_32":187,"_30":188,"_152":-5,"_42":43,"_41":189,"_154":25,"_39":364,"_13":191,"_34":35,"_36":192,"_24":25,"_159":-5,"_352":365,"_27":366},{"_44":178,"_32":179,"_30":180,"_152":-5,"_42":43,"_41":181,"_154":59,"_39":361,"_13":183,"_34":175,"_36":184,"_24":25,"_159":-5,"_352":362,"_27":363},{"_44":169,"_32":170,"_30":171,"_152":-5,"_42":43,"_41":172,"_154":59,"_39":358,"_13":174,"_34":175,"_36":176,"_24":25,"_159":-5,"_352":359,"_27":360},{"_44":161,"_32":162,"_30":163,"_152":-5,"_42":43,"_41":164,"_154":59,"_39":355,"_13":166,"_34":35,"_36":167,"_24":25,"_159":-5,"_352":356,"_27":357},{"_44":149,"_32":150,"_30":151,"_152":-5,"_42":43,"_41":153,"_154":25,"_39":351,"_13":156,"_34":157,"_36":158,"_24":25,"_159":-5,"_352":353,"_27":354},["D",1753241163437],"children",[],[150],["D",1753241050560],[],[162],["D",1751662988511],[],[170],["D",1750373211745],[],[179],["D",1753241636242],[],[187],["D",1751662575537],[],[195],["D",1753241087758],[],[202],["D",1750372113364],[],[210],["D",1750373092242],[],[217],["D",1769136720207],[],[225],["D",1751693610646],[],[232],["D",1750372552890],[],[240],["D",1759081605407],[],[246],["D",1751662682583],[],[255],["D",1769136721106],[],[262],["D",1769136721104],[],[269],"7d9ab0e6-f806-11f0-8922-42dde27851f2","types.ts","7d9ab19a-f806-11f0-8922-42dde27851f2",307,["D",1769136720919],"/**\n * Shared TypeScript types for Loki rental search platform\n */\n\n// User types\nexport interface User {\n id: string;\n email: string;\n name: string | null;\n avatar_url: string | null;\n created_at: number;\n}\n\nexport interface Session {\n token: string;\n user_id: string;\n expires_at: number;\n}\n\n// Group types\nexport interface Group {\n id: string;\n name: string;\n created_by: string;\n invite_code: string;\n created_at: number;\n}\n\nexport interface GroupMember {\n group_id: string;\n user_id: string;\n role: \"owner\" | \"member\";\n joined_at: number;\n}\n\nexport interface GroupWithMembers extends Group {\n members: (GroupMember & { user: User })[];\n}\n\n// Listing types\nexport interface Listing {\n id: string;\n address_original: string;\n address_normalized: string;\n unit_number: string | null;\n lat: number | null;\n lng: number | null;\n beds: number | null;\n baths: number | null;\n price: number | null;\n availability: string | null;\n neighborhood: string | null;\n first_seen_at: number;\n last_updated_at: number;\n is_active: boolean;\n}\n\nexport interface ListingSource {\n id: string;\n listing_id: string;\n platform: \"zillow\" | \"craigslist\";\n url: string;\n raw_address: string | null;\n first_seen_at: number;\n last_seen_at: number;\n}\n\nexport type ListingStatus =\n | \"new\"\n | \"interested\"\n | \"contacted\"\n | \"toured\"\n | \"applied\"\n | \"rejected\";\n\nexport interface ListingInteraction {\n listing_id: string;\n group_id: string;\n status: ListingStatus;\n is_liked: boolean;\n notes: string | null;\n custom_links: string[] | null;\n updated_by: string | null;\n updated_at: number;\n}\n\nexport interface ListingTransit {\n listing_id: string;\n preference_id: string;\n duration_minutes: number | null;\n calculated_at: number;\n}\n\n// Combined listing with all related data\nexport interface ListingWithDetails extends Listing {\n sources: ListingSource[];\n interaction?: ListingInteraction;\n transit?: ListingTransitResult[];\n // Calculated fields\n rent_per_bedroom?: number | null;\n bed_bath_ratio?: number | null;\n}\n\nexport interface ListingTransitResult {\n preference_id: string;\n preference_name: string;\n duration_minutes: number | null;\n travel_mode: TravelMode;\n}\n\n// Transit preferences\nexport type TravelMode = \"driving\" | \"transit\" | \"walking\" | \"bicycling\";\nexport type TransitPreferenceType = \"gym\" | \"grocery\" | \"baywheels\" | \"custom\";\n\nexport interface TransitPreference {\n id: string;\n group_id: string;\n name: string;\n type: TransitPreferenceType;\n address: string | null;\n lat: number | null;\n lng: number | null;\n travel_mode: TravelMode;\n is_active: boolean;\n created_at: number;\n}\n\n// Notification preferences\nexport interface NotificationPrefs {\n user_id: string;\n notify_new_listing: boolean;\n notify_comment_request: boolean;\n notify_apply_reminder: boolean;\n}\n\n// Reminders\nexport interface Reminder {\n id: string;\n listing_id: string;\n group_id: string;\n created_by: string;\n remind_at: number;\n message: string | null;\n is_sent: boolean;\n created_at: number;\n}\n\n// API request/response types\nexport interface CreateGroupRequest {\n name: string;\n}\n\nexport interface UpdateInteractionRequest {\n status?: ListingStatus;\n is_liked?: boolean;\n notes?: string;\n custom_links?: string[];\n}\n\nexport interface CreateTransitPreferenceRequest {\n name: string;\n type: TransitPreferenceType;\n address?: string;\n lat?: number;\n lng?: number;\n travel_mode?: TravelMode;\n}\n\nexport interface UpdateTransitPreferenceRequest {\n name?: string;\n address?: string;\n lat?: number;\n lng?: number;\n travel_mode?: TravelMode;\n is_active?: boolean;\n}\n\nexport interface UpdateNotificationPrefsRequest {\n notify_new_listing?: boolean;\n notify_comment_request?: boolean;\n notify_apply_reminder?: boolean;\n}\n\nexport interface ListingsFilterParams {\n status?: ListingStatus;\n is_liked?: boolean;\n min_price?: number;\n max_price?: number;\n min_beds?: number;\n max_beds?: number;\n neighborhood?: string;\n is_active?: boolean;\n page?: number;\n limit?: number;\n sort_by?: \"price\" | \"beds\" | \"first_seen_at\" | \"last_updated_at\";\n sort_order?: \"asc\" | \"desc\";\n}\n\nexport interface PaginatedResponse {\n data: T[];\n total: number;\n page: number;\n limit: number;\n total_pages: number;\n}\n\n// Scraper input types\nexport interface ScrapedListing {\n address: string;\n url: string;\n platform: \"zillow\" | \"craigslist\";\n lat?: number;\n lng?: number;\n beds?: number;\n baths?: number;\n price?: number;\n availability?: string;\n}\n\n// Deduplication types\nexport interface AddressFingerprint {\n street: string;\n unit: string | null;\n fingerprint: string;\n}\n\n// API error response\nexport interface ApiError {\n error: string;\n message: string;\n status: number;\n}\n",[],[276,401],["D",1769136719198],[334],[276],"7da68d62-f806-11f0-9cf9-42dde27851f2","zillow.cron.ts","7da68e5c-f806-11f0-9cf9-42dde27851f2",309,["D",1769136720999],"/**\n * Zillow scraper cron job\n * Scrapes Zillow rental listings and processes through deduplication\n */\n\nimport { zillowParseURL } from \"../zillowParseURL.tsx\";\nimport { processBatchListings, markInactiveListings } from \"../backend/dedup.ts\";\nimport { runMigrations } from \"../backend/migrations.ts\";\nimport { sendNewListingsNotification } from \"../backend/notifications.ts\";\nimport { sqlite } from \"https://esm.town/v/std/sqlite\";\nimport type { ScrapedListing, Listing } from \"../shared/types.ts\";\n\n// Browserless endpoint for scraping\nconst BROWSERLESS_ENDPOINT = \"https://shapedlines--31933b5e642311f09be00224a6c84d84.web.val.run\";\n\n// Default Zillow search URL for SF rentals\nconst DEFAULT_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\ninterface ZillowListResult {\n zpid: string;\n detailUrl: string;\n address: string;\n addressStreet?: string;\n addressCity?: string;\n addressState?: string;\n addressZipcode?: string;\n price?: string;\n unformattedPrice?: number;\n beds?: number;\n baths?: number;\n latLong?: {\n latitude: number;\n longitude: number;\n };\n availabilityDate?: string;\n}\n\n/**\n * Request Zillow data for a specific page\n */\nasync function requestZillowData(zillowURL: string, pageNumber: number): Promise {\n const modifiedZillowURL = await zillowParseURL(zillowURL, pageNumber);\n if (!modifiedZillowURL) {\n throw new Error(\"Failed to generate modified Zillow URL\");\n }\n\n const url = new URL(BROWSERLESS_ENDPOINT);\n url.searchParams.set(\"zillowURL\", modifiedZillowURL);\n\n const response = await fetch(url.toString(), {\n method: \"GET\",\n headers: { \"Content-Type\": \"application/json\" },\n });\n\n if (!response.ok) {\n throw new Error(`HTTP error! status: ${response.status}`);\n }\n\n const data = await response.json();\n const zillowData = JSON.parse(data.data.evaluate.value);\n return zillowData.searchResults.listResults || [];\n}\n\n/**\n * Get total pages from Zillow search\n */\nasync function getTotalPages(zillowURL: string): Promise {\n const modifiedZillowURL = await zillowParseURL(zillowURL, 1);\n if (!modifiedZillowURL) {\n throw new Error(\"Failed to generate modified Zillow URL\");\n }\n\n const url = new URL(BROWSERLESS_ENDPOINT);\n url.searchParams.set(\"zillowURL\", modifiedZillowURL);\n\n const response = await fetch(url.toString(), {\n method: \"GET\",\n headers: { \"Content-Type\": \"application/json\" },\n });\n\n if (!response.ok) {\n throw new Error(`HTTP error! status: ${response.status}`);\n }\n\n const data = await response.json();\n const zillowData = JSON.parse(data.data.evaluate.value);\n return zillowData.searchList?.totalPages || 1;\n}\n\n/**\n * Transform Zillow result to ScrapedListing format\n */\nfunction transformZillowResult(result: ZillowListResult): ScrapedListing | null {\n if (!result.detailUrl || !result.address) {\n return null;\n }\n\n // Build full URL\n const url = result.detailUrl.startsWith(\"http\")\n ? result.detailUrl\n : `https://www.zillow.com${result.detailUrl}`;\n\n // Build full address\n let fullAddress = result.address;\n if (result.addressStreet && result.addressCity && result.addressState) {\n fullAddress = `${result.addressStreet}, ${result.addressCity}, ${result.addressState}`;\n if (result.addressZipcode) {\n fullAddress += ` ${result.addressZipcode}`;\n }\n }\n\n return {\n address: fullAddress,\n url,\n platform: \"zillow\",\n lat: result.latLong?.latitude,\n lng: result.latLong?.longitude,\n beds: result.beds,\n baths: result.baths,\n price: result.unformattedPrice,\n availability: result.availabilityDate,\n };\n}\n\n/**\n * Main cron job handler\n */\nexport default async function zillowCron(interval: Interval) {\n console.log(\"Starting Zillow scraper cron job...\");\n\n try {\n // Ensure database is set up\n await runMigrations();\n\n const zillowUrl = DEFAULT_ZILLOW_URL;\n const allResults: ZillowListResult[] = [];\n\n // Get total pages\n console.log(\"Fetching total pages...\");\n const totalPages = await getTotalPages(zillowUrl);\n console.log(`Total pages to scrape: ${totalPages}`);\n\n // Scrape all pages\n for (let page = 1; page <= totalPages; page++) {\n console.log(`Scraping page ${page} of ${totalPages}...`);\n try {\n const pageResults = await requestZillowData(zillowUrl, page);\n allResults.push(...pageResults);\n console.log(`Page ${page}: Found ${pageResults.length} listings`);\n\n // Add a small delay between pages to be respectful\n if (page < totalPages) {\n await new Promise(resolve => setTimeout(resolve, 1000));\n }\n } catch (error) {\n console.error(`Error scraping page ${page}:`, error);\n }\n }\n\n console.log(`Total raw results: ${allResults.length}`);\n\n // Transform to ScrapedListing format\n const scrapedListings: ScrapedListing[] = allResults\n .map(transformZillowResult)\n .filter((listing): listing is ScrapedListing => listing !== null);\n\n console.log(`Valid listings to process: ${scrapedListings.length}`);\n\n // Process through deduplication engine and track new listings\n const newListingIds: string[] = [];\n let newCount = 0;\n let updatedCount = 0;\n let errorCount = 0;\n\n for (const listing of scrapedListings) {\n try {\n const { listing: processedListing, isNew } = await (await import(\"../backend/dedup.ts\")).processScrapedListing(listing);\n if (isNew) {\n newListingIds.push(processedListing.id);\n newCount++;\n } else {\n updatedCount++;\n }\n } catch (error) {\n console.error(\"Error processing listing:\", listing.url, error);\n errorCount++;\n }\n }\n\n console.log(\"Deduplication results:\", { total: scrapedListings.length, new: newCount, updated: updatedCount, errors: errorCount });\n\n // Mark old listings as inactive\n const inactiveCount = await markInactiveListings(7);\n console.log(`Marked ${inactiveCount} listings as inactive`);\n\n // Send notifications for new listings\n let notificationsSent = 0;\n if (newListingIds.length > 0) {\n // Get all groups and send notifications\n const groupsResult = await sqlite.execute(`SELECT DISTINCT id FROM loki_groups`);\n \n // Get the new listings details\n const placeholders = newListingIds.map(() => \"?\").join(\",\");\n const listingsResult = await sqlite.execute({\n sql: `SELECT * FROM loki_listings WHERE id IN (${placeholders})`,\n args: newListingIds,\n });\n\n const newListings: Listing[] = listingsResult.rows.map(row => ({\n id: row.id as string,\n address_original: row.address_original as string,\n address_normalized: row.address_normalized as string,\n unit_number: row.unit_number as string | null,\n lat: row.lat as number | null,\n lng: row.lng as number | null,\n beds: row.beds as number | null,\n baths: row.baths as number | null,\n price: row.price as number | null,\n availability: row.availability as string | null,\n neighborhood: row.neighborhood as string | null,\n first_seen_at: row.first_seen_at as number,\n last_updated_at: row.last_updated_at as number,\n is_active: Boolean(row.is_active),\n }));\n\n // Send to each group\n for (const groupRow of groupsResult.rows) {\n const groupId = groupRow.id as string;\n const result = await sendNewListingsNotification(groupId, newListings);\n notificationsSent += result.sent;\n }\n \n console.log(`Sent ${notificationsSent} notification emails for ${newListings.length} new listings`);\n }\n\n return {\n success: true,\n total_scraped: allResults.length,\n processed: scrapedListings.length,\n new_listings: newCount,\n updated_listings: updatedCount,\n errors: errorCount,\n marked_inactive: inactiveCount,\n notifications_sent: notificationsSent,\n };\n } catch (error) {\n console.error(\"Zillow scraper cron job failed:\", error);\n throw error;\n }\n}\n",[],[283,412],"7da980e4-f806-11f0-818c-42dde27851f2","reminders.cron.ts","7da98198-f806-11f0-818c-42dde27851f2",310,["D",1769136721004],"/**\n * Reminders cron job\n * Processes due reminders and sends email notifications\n */\n\nimport { processDueReminders } from \"../backend/notifications.ts\";\nimport { runMigrations } from \"../backend/migrations.ts\";\n\n/**\n * Main cron job handler - runs daily to process due reminders\n */\nexport default async function remindersCron(interval: Interval) {\n console.log(\"Starting reminders cron job...\");\n\n try {\n // Ensure database is set up\n await runMigrations();\n\n // Process due reminders\n const result = await processDueReminders();\n\n console.log(\"Reminders cron job completed:\", result);\n\n return {\n success: true,\n ...result,\n };\n } catch (error) {\n console.error(\"Reminders cron job failed:\", error);\n throw error;\n }\n}\n",[],[283,420],"7da039c6-f806-11f0-818c-42dde27851f2","craigslist.cron.ts","7da03a70-f806-11f0-818c-42dde27851f2",308,["D",1769136720920],"/**\n * Craigslist scraper cron job\n * Scrapes Craigslist rental listings and processes through deduplication\n */\n\nimport * as cheerio from \"https://esm.sh/cheerio@1.0.0-rc.12\";\nimport { processBatchListings, markInactiveListings, processScrapedListing } from \"../backend/dedup.ts\";\nimport { runMigrations } from \"../backend/migrations.ts\";\nimport { sendNewListingsNotification } from \"../backend/notifications.ts\";\nimport { sqlite } from \"https://esm.town/v/std/sqlite\";\nimport type { ScrapedListing, Listing } from \"../shared/types.ts\";\n\n// Endpoint that returns Craigslist listing URLs\nconst CRAIGSLIST_LISTINGS_ENDPOINT = \"https://shapedlines--b6721782590611f094e1f69ea79377d9.web.val.run\";\n\n// Craigslist detail scraper endpoint\nconst CRAIGSLIST_DETAIL_ENDPOINT = \"https://shapedlines-scrapecraigslistapi.web.val.run\";\n\ninterface CraigslistDetail {\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 lat?: number;\n lng?: number;\n}\n\n/**\n * Fetch list of Craigslist listing URLs\n */\nasync function fetchListingUrls(): Promise {\n const response = await fetch(CRAIGSLIST_LISTINGS_ENDPOINT);\n if (!response.ok) {\n throw new Error(`HTTP error! status: ${response.status}`);\n }\n\n const data = await response.json();\n return data.links || [];\n}\n\n/**\n * Fetch details for a single Craigslist listing\n */\nasync function fetchListingDetail(url: string): Promise {\n try {\n const detailUrl = new URL(CRAIGSLIST_DETAIL_ENDPOINT);\n detailUrl.searchParams.set(\"url\", url);\n\n const response = await fetch(detailUrl.toString());\n if (!response.ok) {\n console.error(`Failed to fetch detail for ${url}: ${response.status}`);\n return null;\n }\n\n const data = await response.json();\n\n // Extract lat/lng from Google Maps link if available\n let lat: number | undefined;\n let lng: number | undefined;\n if (data.googleMapsLink && data.googleMapsLink !== \"N/A\") {\n const match = data.googleMapsLink.match(/q=([-\\d.]+),([-\\d.]+)/);\n if (match) {\n lat = parseFloat(match[1]);\n lng = parseFloat(match[2]);\n }\n }\n\n return {\n ...data,\n lat,\n lng,\n };\n } catch (error) {\n console.error(`Error fetching detail for ${url}:`, error);\n return null;\n }\n}\n\n/**\n * Transform Craigslist detail to ScrapedListing format\n */\nfunction transformCraigslistDetail(detail: CraigslistDetail): ScrapedListing | null {\n if (!detail.listingUrl || detail.address === \"N/A\" || !detail.address) {\n return null;\n }\n\n return {\n address: detail.address,\n url: detail.listingUrl,\n platform: \"craigslist\",\n lat: detail.lat,\n lng: detail.lng,\n beds: detail.beds || undefined,\n baths: detail.baths || undefined,\n price: detail.price || undefined,\n availability: detail.availability !== \"N/A\" ? detail.availability : undefined,\n };\n}\n\n/**\n * Main cron job handler\n */\nexport default async function craigslistCron(interval: Interval) {\n console.log(\"Starting Craigslist scraper cron job...\");\n\n try {\n // Ensure database is set up\n await runMigrations();\n\n // Fetch listing URLs\n console.log(\"Fetching Craigslist listing URLs...\");\n const listingUrls = await fetchListingUrls();\n console.log(`Found ${listingUrls.length} listing URLs`);\n\n // Fetch details for each listing (with rate limiting)\n const scrapedListings: ScrapedListing[] = [];\n const batchSize = 5; // Process 5 at a time\n const delayMs = 500; // 500ms between batches\n\n for (let i = 0; i < listingUrls.length; i += batchSize) {\n const batch = listingUrls.slice(i, i + batchSize);\n console.log(`Processing batch ${Math.floor(i / batchSize) + 1} (${batch.length} listings)...`);\n\n // Fetch batch in parallel\n const batchResults = await Promise.all(\n batch.map(url => fetchListingDetail(url))\n );\n\n // Transform and add to results\n for (const detail of batchResults) {\n if (detail) {\n const scraped = transformCraigslistDetail(detail);\n if (scraped) {\n scrapedListings.push(scraped);\n }\n }\n }\n\n // Rate limiting delay\n if (i + batchSize < listingUrls.length) {\n await new Promise(resolve => setTimeout(resolve, delayMs));\n }\n }\n\n console.log(`Valid listings to process: ${scrapedListings.length}`);\n\n // Process through deduplication engine and track new listings\n const newListingIds: string[] = [];\n let newCount = 0;\n let updatedCount = 0;\n let errorCount = 0;\n\n for (const listing of scrapedListings) {\n try {\n const { listing: processedListing, isNew } = await processScrapedListing(listing);\n if (isNew) {\n newListingIds.push(processedListing.id);\n newCount++;\n } else {\n updatedCount++;\n }\n } catch (error) {\n console.error(\"Error processing listing:\", listing.url, error);\n errorCount++;\n }\n }\n\n console.log(\"Deduplication results:\", { total: scrapedListings.length, new: newCount, updated: updatedCount, errors: errorCount });\n\n // Mark old listings as inactive\n const inactiveCount = await markInactiveListings(7);\n console.log(`Marked ${inactiveCount} listings as inactive`);\n\n // Send notifications for new listings\n let notificationsSent = 0;\n if (newListingIds.length > 0) {\n // Get all groups and send notifications\n const groupsResult = await sqlite.execute(`SELECT DISTINCT id FROM loki_groups`);\n \n // Get the new listings details\n const placeholders = newListingIds.map(() => \"?\").join(\",\");\n const listingsResult = await sqlite.execute({\n sql: `SELECT * FROM loki_listings WHERE id IN (${placeholders})`,\n args: newListingIds,\n });\n\n const newListings: Listing[] = listingsResult.rows.map(row => ({\n id: row.id as string,\n address_original: row.address_original as string,\n address_normalized: row.address_normalized as string,\n unit_number: row.unit_number as string | null,\n lat: row.lat as number | null,\n lng: row.lng as number | null,\n beds: row.beds as number | null,\n baths: row.baths as number | null,\n price: row.price as number | null,\n availability: row.availability as string | null,\n neighborhood: row.neighborhood as string | null,\n first_seen_at: row.first_seen_at as number,\n last_updated_at: row.last_updated_at as number,\n is_active: Boolean(row.is_active),\n }));\n\n // Send to each group\n for (const groupRow of groupsResult.rows) {\n const groupId = groupRow.id as string;\n const result = await sendNewListingsNotification(groupId, newListings);\n notificationsSent += result.sent;\n }\n \n console.log(`Sent ${notificationsSent} notification emails for ${newListings.length} new listings`);\n }\n\n return {\n success: true,\n total_urls: listingUrls.length,\n processed: scrapedListings.length,\n new_listings: newCount,\n updated_listings: updatedCount,\n errors: errorCount,\n marked_inactive: inactiveCount,\n notifications_sent: notificationsSent,\n };\n } catch (error) {\n console.error(\"Craigslist scraper cron job failed:\", error);\n throw error;\n }\n}\n",[],[283,428],["D",1769136719402],[330,331,332],[283],"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",[],[289,439],"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",[],[289,447],"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",[],[289,463,455],"views","7cf069a6-f806-11f0-810f-42dde27851f2",294,["D",1769136719805],[326],[289,463],"7d48e270-f806-11f0-94a6-42dde27851f2","ListingDetail.tsx","7d48e338-f806-11f0-94a6-42dde27851f2","7cd0eeb4-f806-11f0-be4c-42dde27851f2",303,["D",1769136720201],"/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport React, { useState, useEffect } from \"https://esm.sh/react@18.2.0\";\nimport type { ListingWithDetails, ListingStatus, UpdateInteractionRequest } from \"../../shared/types.ts\";\n\ninterface ListingDetailProps {\n listing: ListingWithDetails;\n groupId: string;\n onClose: () => void;\n onUpdate: () => void;\n}\n\nexport function ListingDetail({ listing, groupId, onClose, onUpdate }: ListingDetailProps) {\n const [isUpdating, setIsUpdating] = useState(false);\n const [notes, setNotes] = useState(listing.interaction?.notes || \"\");\n const [customLinks, setCustomLinks] = useState(listing.interaction?.custom_links || []);\n const [newLink, setNewLink] = useState(\"\");\n const [error, setError] = useState(\"\");\n\n const status = listing.interaction?.status || \"new\";\n const isLiked = listing.interaction?.is_liked || false;\n\n const updateInteraction = async (updates: UpdateInteractionRequest) => {\n setIsUpdating(true);\n setError(\"\");\n\n try {\n const response = await fetch(`/api/listings/${listing.id}/interaction`, {\n method: \"PATCH\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ group_id: groupId, ...updates }),\n });\n\n if (!response.ok) {\n const data = await response.json();\n throw new Error(data.message || \"Failed to update listing\");\n }\n\n onUpdate();\n } catch (err) {\n setError(String(err));\n } finally {\n setIsUpdating(false);\n }\n };\n\n const saveNotes = () => {\n updateInteraction({ notes });\n };\n\n const addLink = () => {\n if (!newLink.trim()) return;\n \n try {\n new URL(newLink); // Validate URL\n const updatedLinks = [...customLinks, newLink.trim()];\n setCustomLinks(updatedLinks);\n setNewLink(\"\");\n updateInteraction({ custom_links: updatedLinks });\n } catch {\n setError(\"Please enter a valid URL\");\n }\n };\n\n const removeLink = (index: number) => {\n const updatedLinks = customLinks.filter((_, i) => i !== index);\n setCustomLinks(updatedLinks);\n updateInteraction({ custom_links: updatedLinks });\n };\n\n return (\n

\n {/* Header */}\n

{listing.address_original}

\n {listing.neighborhood && (\n

{listing.neighborhood}

\n )}\n

\n \n ×\n \n

\n\n

\n {/* Price and Details */}\n

\n {listing.price && (\n

\n \n ${listing.price.toLocaleString()}\n \n /month\n

\n )}\n \n

\n {listing.beds !== null && (\n

{listing.beds}

Beds

\n )}\n {listing.baths !== null && (\n

{listing.baths}

Baths

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

${listing.rent_per_bedroom.toLocaleString()}

$/Bed

\n )}\n

\n\n {/* Status and Like */}\n

\n updateInteraction({ status: e.target.value as ListingStatus })}\n disabled={isUpdating}\n className=\"px-4 py-2 border rounded-lg\"\n >\n \n \n \n \n \n \n \n\n updateInteraction({ is_liked: !isLiked })}\n disabled={isUpdating}\n className={`px-4 py-2 border rounded-lg flex items-center gap-2 ${\n isLiked ? \"bg-red-50 border-red-200 text-red-600\" : \"hover:bg-gray-50\"\n }`}\n >\n ♥\n {isLiked ? \"Liked\" : \"Like\"}\n \n\n {listing.availability && (\n \n Available: {listing.availability}\n \n )}\n

\n\n {/* Source Links */}\n

Source Links

\n {listing.sources.map(source => (\n \n View on {source.platform.charAt(0).toUpperCase() + source.platform.slice(1)}\n \n ))}\n \n {/* Google Maps link */}\n {listing.lat && listing.lng && (\n \n View on Google Maps\n \n )}\n

\n\n {/* Transit Times */}\n {listing.transit && listing.transit.length > 0 && (\n

Transit Times

\n {listing.transit.map(t => (\n

\n {t.preference_name}\n \n {t.duration_minutes !== null ? `${t.duration_minutes} min` : \"-\"}\n \n

\n ))}\n

\n )}\n\n {/* Map Preview */}\n {listing.lat && listing.lng && (\n

Location

\n \n

\n )}\n\n {/* Notes */}\n

Notes

\n setNotes(e.target.value)}\n placeholder=\"Add notes about this listing...\"\n className=\"w-full px-3 py-2 border rounded-lg h-32 resize-none\"\n />\n

\n \n Save Notes\n \n

\n\n {/* Custom Links */}\n

Custom Links

\n \n

\n {customLinks.map((link, index) => (\n

\n \n {link}\n \n removeLink(index)}\n className=\"text-red-500 hover:text-red-700 text-sm\"\n >\n Remove\n \n

\n ))}\n

\n\n

\n setNewLink(e.target.value)}\n placeholder=\"Add a link (e.g., application form)\"\n className=\"flex-1 px-3 py-2 border rounded-lg text-sm\"\n />\n \n Add\n \n

\n\n {/* Error message */}\n {error && (\n

\n {error}\n

\n )}\n\n {/* Metadata */}\n

First seen: {new Date(listing.first_seen_at * 1000).toLocaleDateString()}

Last updated: {new Date(listing.last_updated_at * 1000).toLocaleDateString()}

\n {listing.unit_number &&

Unit: {listing.unit_number}

}\n

\n );\n}\n\nexport default ListingDetail;\n",[],[289,478,470],"components","7cd0ed4c-f806-11f0-be4c-42dde27851f2",293,["D",1769136719599],[324],[289,478],["D",1769136718806],[323,325,327,328],[289],"7d7ca970-f806-11f0-a6eb-42dde27851f2","preferences.ts","7d7caa38-f806-11f0-a6eb-42dde27851f2",305,["D",1769136720405],"/**\n * Preferences API for Loki\n * Handles transit destination preferences and notification settings\n */\n\nimport { Hono } from \"https://esm.sh/hono@4.0.0\";\nimport { sqlite } from \"https://esm.town/v/std/sqlite\";\nimport type { AuthContext } from \"./auth.ts\";\nimport { requireAuth } from \"./auth.ts\";\nimport { isGroupMember } from \"./groups.ts\";\nimport type {\n User,\n TransitPreference,\n NotificationPrefs,\n CreateTransitPreferenceRequest,\n UpdateTransitPreferenceRequest,\n UpdateNotificationPrefsRequest,\n TravelMode,\n TransitPreferenceType,\n} from \"../shared/types.ts\";\n\nconst TABLE_PREFIX = \"loki_\";\n\nexport const preferencesRouter = new Hono();\n\n// Apply auth middleware to all preference routes\npreferencesRouter.use(\"/*\", requireAuth);\n\n/**\n * Generate unique ID\n */\nfunction generateId(): string {\n return `${Date.now()}-${Math.random().toString(36).substring(2, 15)}`;\n}\n\n/**\n * Parse transit preference row from database\n */\nfunction parseTransitPreferenceRow(row: any): TransitPreference {\n return {\n id: row.id as string,\n group_id: row.group_id as string,\n name: row.name as string,\n type: row.type as TransitPreferenceType,\n address: row.address as string | null,\n lat: row.lat as number | null,\n lng: row.lng as number | null,\n travel_mode: row.travel_mode as TravelMode,\n is_active: Boolean(row.is_active),\n created_at: row.created_at as number,\n };\n}\n\n// ==================== Transit Preferences ====================\n\n/**\n * GET /preferences/transit - Get group's transit preferences\n */\npreferencesRouter.get(\"/transit\", async (c) => {\n const user = c.get(\"user\") as User;\n const groupId = c.req.query(\"group_id\");\n\n if (!groupId) {\n return c.json({ error: \"Validation error\", message: \"group_id is required\" }, 400);\n }\n\n // Check membership\n if (!await isGroupMember(groupId, user.id)) {\n return c.json({ error: \"Forbidden\", message: \"You are not a member of this group\" }, 403);\n }\n\n const includeInactive = c.req.query(\"include_inactive\") === \"true\";\n\n let query = `SELECT * FROM ${TABLE_PREFIX}transit_preferences WHERE group_id = ?`;\n const args: any[] = [groupId];\n\n if (!includeInactive) {\n query += ` AND is_active = 1`;\n }\n\n query += ` ORDER BY created_at ASC`;\n\n const result = await sqlite.execute({ sql: query, args });\n const preferences = result.rows.map(parseTransitPreferenceRow);\n\n return c.json({ preferences });\n});\n\n/**\n * GET /preferences/transit/:id - Get single transit preference\n */\npreferencesRouter.get(\"/transit/:id\", async (c) => {\n const user = c.get(\"user\") as User;\n const preferenceId = c.req.param(\"id\");\n\n const result = await sqlite.execute({\n sql: `SELECT * FROM ${TABLE_PREFIX}transit_preferences WHERE id = ?`,\n args: [preferenceId],\n });\n\n if (result.rows.length === 0) {\n return c.json({ error: \"Not found\", message: \"Transit preference not found\" }, 404);\n }\n\n const preference = parseTransitPreferenceRow(result.rows[0]);\n\n // Check membership\n if (!await isGroupMember(preference.group_id, user.id)) {\n return c.json({ error: \"Forbidden\", message: \"You are not a member of this group\" }, 403);\n }\n\n return c.json({ preference });\n});\n\n/**\n * POST /preferences/transit - Create new transit preference\n */\npreferencesRouter.post(\"/transit\", async (c) => {\n const user = c.get(\"user\") as User;\n\n let body: CreateTransitPreferenceRequest & { group_id: string };\n try {\n body = await c.req.json();\n } catch {\n return c.json({ error: \"Invalid request\", message: \"Invalid JSON body\" }, 400);\n }\n\n const { group_id: groupId, name, type, address, lat, lng, travel_mode } = body;\n\n if (!groupId) {\n return c.json({ error: \"Validation error\", message: \"group_id is required\" }, 400);\n }\n\n if (!name || name.trim().length === 0) {\n return c.json({ error: \"Validation error\", message: \"name is required\" }, 400);\n }\n\n if (!type) {\n return c.json({ error: \"Validation error\", message: \"type is required\" }, 400);\n }\n\n // Validate type\n const validTypes: TransitPreferenceType[] = [\"gym\", \"grocery\", \"baywheels\", \"custom\"];\n if (!validTypes.includes(type)) {\n return c.json({ error: \"Validation error\", message: \"Invalid type value\" }, 400);\n }\n\n // Validate travel mode\n const validModes: TravelMode[] = [\"driving\", \"transit\", \"walking\", \"bicycling\"];\n if (travel_mode && !validModes.includes(travel_mode)) {\n return c.json({ error: \"Validation error\", message: \"Invalid travel_mode value\" }, 400);\n }\n\n // Check membership\n if (!await isGroupMember(groupId, user.id)) {\n return c.json({ error: \"Forbidden\", message: \"You are not a member of this group\" }, 403);\n }\n\n const preferenceId = generateId();\n const now = Math.floor(Date.now() / 1000);\n\n await sqlite.execute({\n sql: `\n INSERT INTO ${TABLE_PREFIX}transit_preferences \n (id, group_id, name, type, address, lat, lng, travel_mode, is_active, created_at)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?, 1, ?)\n `,\n args: [\n preferenceId,\n groupId,\n name.trim(),\n type,\n address || null,\n lat || null,\n lng || null,\n travel_mode || \"transit\",\n now,\n ],\n });\n\n const result = await sqlite.execute({\n sql: `SELECT * FROM ${TABLE_PREFIX}transit_preferences WHERE id = ?`,\n args: [preferenceId],\n });\n\n const preference = parseTransitPreferenceRow(result.rows[0]);\n return c.json({ preference }, 201);\n});\n\n/**\n * PUT /preferences/transit/:id - Update transit preference\n */\npreferencesRouter.put(\"/transit/:id\", async (c) => {\n const user = c.get(\"user\") as User;\n const preferenceId = c.req.param(\"id\");\n\n // Get existing preference\n const existingResult = await sqlite.execute({\n sql: `SELECT * FROM ${TABLE_PREFIX}transit_preferences WHERE id = ?`,\n args: [preferenceId],\n });\n\n if (existingResult.rows.length === 0) {\n return c.json({ error: \"Not found\", message: \"Transit preference not found\" }, 404);\n }\n\n const existing = parseTransitPreferenceRow(existingResult.rows[0]);\n\n // Check membership\n if (!await isGroupMember(existing.group_id, user.id)) {\n return c.json({ error: \"Forbidden\", message: \"You are not a member of this group\" }, 403);\n }\n\n let body: UpdateTransitPreferenceRequest;\n try {\n body = await c.req.json();\n } catch {\n return c.json({ error: \"Invalid request\", message: \"Invalid JSON body\" }, 400);\n }\n\n // Validate travel mode if provided\n const validModes: TravelMode[] = [\"driving\", \"transit\", \"walking\", \"bicycling\"];\n if (body.travel_mode && !validModes.includes(body.travel_mode)) {\n return c.json({ error: \"Validation error\", message: \"Invalid travel_mode value\" }, 400);\n }\n\n // Build update query\n const setClauses: string[] = [];\n const args: any[] = [];\n\n if (body.name !== undefined) {\n setClauses.push(\"name = ?\");\n args.push(body.name.trim());\n }\n\n if (body.address !== undefined) {\n setClauses.push(\"address = ?\");\n args.push(body.address);\n }\n\n if (body.lat !== undefined) {\n setClauses.push(\"lat = ?\");\n args.push(body.lat);\n }\n\n if (body.lng !== undefined) {\n setClauses.push(\"lng = ?\");\n args.push(body.lng);\n }\n\n if (body.travel_mode !== undefined) {\n setClauses.push(\"travel_mode = ?\");\n args.push(body.travel_mode);\n }\n\n if (body.is_active !== undefined) {\n setClauses.push(\"is_active = ?\");\n args.push(body.is_active ? 1 : 0);\n }\n\n if (setClauses.length > 0) {\n args.push(preferenceId);\n await sqlite.execute({\n sql: `UPDATE ${TABLE_PREFIX}transit_preferences SET ${setClauses.join(\", \")} WHERE id = ?`,\n args,\n });\n }\n\n // Return updated preference\n const result = await sqlite.execute({\n sql: `SELECT * FROM ${TABLE_PREFIX}transit_preferences WHERE id = ?`,\n args: [preferenceId],\n });\n\n const preference = parseTransitPreferenceRow(result.rows[0]);\n return c.json({ preference });\n});\n\n/**\n * DELETE /preferences/transit/:id - Delete transit preference\n */\npreferencesRouter.delete(\"/transit/:id\", async (c) => {\n const user = c.get(\"user\") as User;\n const preferenceId = c.req.param(\"id\");\n\n // Get existing preference\n const existingResult = await sqlite.execute({\n sql: `SELECT * FROM ${TABLE_PREFIX}transit_preferences WHERE id = ?`,\n args: [preferenceId],\n });\n\n if (existingResult.rows.length === 0) {\n return c.json({ error: \"Not found\", message: \"Transit preference not found\" }, 404);\n }\n\n const existing = parseTransitPreferenceRow(existingResult.rows[0]);\n\n // Check membership\n if (!await isGroupMember(existing.group_id, user.id)) {\n return c.json({ error: \"Forbidden\", message: \"You are not a member of this group\" }, 403);\n }\n\n // Delete preference (cascades to transit calculations)\n await sqlite.execute({\n sql: `DELETE FROM ${TABLE_PREFIX}transit_preferences WHERE id = ?`,\n args: [preferenceId],\n });\n\n return c.json({ success: true, message: \"Transit preference deleted\" });\n});\n\n// ==================== Notification Preferences ====================\n\n/**\n * GET /preferences/notifications - Get user's notification preferences\n */\npreferencesRouter.get(\"/notifications\", async (c) => {\n const user = c.get(\"user\") as User;\n\n const result = await sqlite.execute({\n sql: `SELECT * FROM ${TABLE_PREFIX}notification_prefs WHERE user_id = ?`,\n args: [user.id],\n });\n\n if (result.rows.length === 0) {\n // Return defaults if not set\n const defaults: NotificationPrefs = {\n user_id: user.id,\n notify_new_listing: true,\n notify_comment_request: true,\n notify_apply_reminder: true,\n };\n return c.json({ preferences: defaults });\n }\n\n const row = result.rows[0];\n const preferences: NotificationPrefs = {\n user_id: row.user_id as string,\n notify_new_listing: Boolean(row.notify_new_listing),\n notify_comment_request: Boolean(row.notify_comment_request),\n notify_apply_reminder: Boolean(row.notify_apply_reminder),\n };\n\n return c.json({ preferences });\n});\n\n/**\n * PUT /preferences/notifications - Update notification preferences\n */\npreferencesRouter.put(\"/notifications\", async (c) => {\n const user = c.get(\"user\") as User;\n\n let body: UpdateNotificationPrefsRequest;\n try {\n body = await c.req.json();\n } catch {\n return c.json({ error: \"Invalid request\", message: \"Invalid JSON body\" }, 400);\n }\n\n // Check if preferences exist\n const existingResult = await sqlite.execute({\n sql: `SELECT 1 FROM ${TABLE_PREFIX}notification_prefs WHERE user_id = ?`,\n args: [user.id],\n });\n\n if (existingResult.rows.length === 0) {\n // Create new preferences\n await sqlite.execute({\n sql: `\n INSERT INTO ${TABLE_PREFIX}notification_prefs \n (user_id, notify_new_listing, notify_comment_request, notify_apply_reminder)\n VALUES (?, ?, ?, ?)\n `,\n args: [\n user.id,\n body.notify_new_listing !== undefined ? (body.notify_new_listing ? 1 : 0) : 1,\n body.notify_comment_request !== undefined ? (body.notify_comment_request ? 1 : 0) : 1,\n body.notify_apply_reminder !== undefined ? (body.notify_apply_reminder ? 1 : 0) : 1,\n ],\n });\n } else {\n // Update existing preferences\n const setClauses: string[] = [];\n const args: any[] = [];\n\n if (body.notify_new_listing !== undefined) {\n setClauses.push(\"notify_new_listing = ?\");\n args.push(body.notify_new_listing ? 1 : 0);\n }\n\n if (body.notify_comment_request !== undefined) {\n setClauses.push(\"notify_comment_request = ?\");\n args.push(body.notify_comment_request ? 1 : 0);\n }\n\n if (body.notify_apply_reminder !== undefined) {\n setClauses.push(\"notify_apply_reminder = ?\");\n args.push(body.notify_apply_reminder ? 1 : 0);\n }\n\n if (setClauses.length > 0) {\n args.push(user.id);\n await sqlite.execute({\n sql: `UPDATE ${TABLE_PREFIX}notification_prefs SET ${setClauses.join(\", \")} WHERE user_id = ?`,\n args,\n });\n }\n }\n\n // Return updated preferences\n const result = await sqlite.execute({\n sql: `SELECT * FROM ${TABLE_PREFIX}notification_prefs WHERE user_id = ?`,\n args: [user.id],\n });\n\n const row = result.rows[0];\n const preferences: NotificationPrefs = {\n user_id: row.user_id as string,\n notify_new_listing: Boolean(row.notify_new_listing),\n notify_comment_request: Boolean(row.notify_comment_request),\n notify_apply_reminder: Boolean(row.notify_apply_reminder),\n };\n\n return c.json({ preferences });\n});\n\n// ==================== Transit Calculation ====================\n\n/**\n * POST /preferences/transit/:id/calculate - Calculate transit time for a listing\n */\npreferencesRouter.post(\"/transit/:id/calculate\", async (c) => {\n const user = c.get(\"user\") as User;\n const preferenceId = c.req.param(\"id\");\n\n let body: { listing_id: string };\n try {\n body = await c.req.json();\n } catch {\n return c.json({ error: \"Invalid request\", message: \"Invalid JSON body\" }, 400);\n }\n\n const { listing_id: listingId } = body;\n\n if (!listingId) {\n return c.json({ error: \"Validation error\", message: \"listing_id is required\" }, 400);\n }\n\n // Get preference\n const prefResult = await sqlite.execute({\n sql: `SELECT * FROM ${TABLE_PREFIX}transit_preferences WHERE id = ?`,\n args: [preferenceId],\n });\n\n if (prefResult.rows.length === 0) {\n return c.json({ error: \"Not found\", message: \"Transit preference not found\" }, 404);\n }\n\n const preference = parseTransitPreferenceRow(prefResult.rows[0]);\n\n // Check membership\n if (!await isGroupMember(preference.group_id, user.id)) {\n return c.json({ error: \"Forbidden\", message: \"You are not a member of this group\" }, 403);\n }\n\n // Get listing\n const listingResult = await sqlite.execute({\n sql: `SELECT lat, lng, address_original FROM ${TABLE_PREFIX}listings WHERE id = ?`,\n args: [listingId],\n });\n\n if (listingResult.rows.length === 0) {\n return c.json({ error: \"Not found\", message: \"Listing not found\" }, 404);\n }\n\n const listing = listingResult.rows[0];\n\n // Need both listing and preference to have location data\n if (!preference.address && (!preference.lat || !preference.lng)) {\n return c.json({ error: \"Configuration error\", message: \"Transit preference has no destination set\" }, 400);\n }\n\n // Calculate transit time using Google Maps API\n const apiKey = Deno.env.get(\"GOOGLE_MAPS_API_KEY\");\n if (!apiKey) {\n return c.json({ error: \"Configuration error\", message: \"Google Maps API key not configured\" }, 500);\n }\n\n // Build origin (listing address or lat/lng)\n let origin: string;\n if (listing.lat && listing.lng) {\n origin = `${listing.lat},${listing.lng}`;\n } else {\n origin = listing.address_original as string;\n }\n\n // Build destination\n let destination: string;\n if (preference.lat && preference.lng) {\n destination = `${preference.lat},${preference.lng}`;\n } else {\n destination = preference.address!;\n }\n\n try {\n const directionsUrl = new URL(\"https://maps.googleapis.com/maps/api/directions/json\");\n directionsUrl.searchParams.set(\"origin\", origin);\n directionsUrl.searchParams.set(\"destination\", destination);\n directionsUrl.searchParams.set(\"mode\", preference.travel_mode);\n directionsUrl.searchParams.set(\"key\", apiKey);\n\n const response = await fetch(directionsUrl.toString());\n const data = await response.json();\n\n if (data.status !== \"OK\") {\n return c.json({ error: \"API error\", message: `Google Maps API error: ${data.status}` }, 500);\n }\n\n const durationSeconds = data.routes[0]?.legs[0]?.duration?.value;\n const durationMinutes = durationSeconds ? Math.round(durationSeconds / 60) : null;\n\n const now = Math.floor(Date.now() / 1000);\n\n // Upsert transit calculation\n await sqlite.execute({\n sql: `\n INSERT INTO ${TABLE_PREFIX}listing_transit (listing_id, preference_id, duration_minutes, calculated_at)\n VALUES (?, ?, ?, ?)\n ON CONFLICT (listing_id, preference_id) DO UPDATE SET\n duration_minutes = excluded.duration_minutes,\n calculated_at = excluded.calculated_at\n `,\n args: [listingId, preferenceId, durationMinutes, now],\n });\n\n return c.json({\n listing_id: listingId,\n preference_id: preferenceId,\n duration_minutes: durationMinutes,\n calculated_at: now,\n });\n } catch (error) {\n console.error(\"Error calculating transit:\", error);\n return c.json({ error: \"API error\", message: \"Failed to calculate transit time\" }, 500);\n }\n});\n\n/**\n * POST /preferences/transit/calculate-all - Calculate all transit times for a listing\n */\npreferencesRouter.post(\"/transit/calculate-all\", async (c) => {\n const user = c.get(\"user\") as User;\n\n let body: { listing_id: string; group_id: string };\n try {\n body = await c.req.json();\n } catch {\n return c.json({ error: \"Invalid request\", message: \"Invalid JSON body\" }, 400);\n }\n\n const { listing_id: listingId, group_id: groupId } = body;\n\n if (!listingId || !groupId) {\n return c.json({ error: \"Validation error\", message: \"listing_id and group_id are required\" }, 400);\n }\n\n // Check membership\n if (!await isGroupMember(groupId, user.id)) {\n return c.json({ error: \"Forbidden\", message: \"You are not a member of this group\" }, 403);\n }\n\n // Get all active transit preferences for group\n const prefsResult = await sqlite.execute({\n sql: `SELECT id FROM ${TABLE_PREFIX}transit_preferences WHERE group_id = ? AND is_active = 1`,\n args: [groupId],\n });\n\n const results: { preference_id: string; success: boolean; duration_minutes?: number; error?: string }[] = [];\n\n // Calculate each preference\n for (const row of prefsResult.rows) {\n const preferenceId = row.id as string;\n try {\n // Make internal request to calculate endpoint\n const calcResponse = await fetch(new URL(`/preferences/transit/${preferenceId}/calculate`, c.req.url), {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\",\n \"Cookie\": c.req.header(\"Cookie\") || \"\",\n },\n body: JSON.stringify({ listing_id: listingId }),\n });\n\n if (calcResponse.ok) {\n const data = await calcResponse.json();\n results.push({ preference_id: preferenceId, success: true, duration_minutes: data.duration_minutes });\n } else {\n const error = await calcResponse.json();\n results.push({ preference_id: preferenceId, success: false, error: error.message });\n }\n } catch (error) {\n results.push({ preference_id: preferenceId, success: false, error: String(error) });\n }\n }\n\n return c.json({\n listing_id: listingId,\n results,\n total: results.length,\n successful: results.filter(r => r.success).length,\n });\n});\n",[],[295,488],"28eb7a70-f80c-11f0-891d-42dde27851f2","notifications.ts","7d2c9c82-f806-11f0-810f-42dde27851f2",319,["D",1769139155803],1,"/**\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\";\nimport { rowToObject, rowsToObjects } from \"./db-utils.ts\";\n\nconst TABLE_PREFIX = \"loki_\";\n\n// Email templates\ninterface EmailTemplate {\n subject: string;\n text: string;\n html: string;\n}\n\n// Types for database rows\ntype RecipientRow = { id: string; email: string; name: string | null };\ntype GroupRow = { id: string; name: string; created_by: string; invite_code: string; created_at: number };\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 const rows = rowsToObjects(result.rows as (unknown[] | Record)[], result.columns);\n return rows.map(row => ({\n userId: row.id,\n email: row.email,\n name: row.name,\n }));\n}\n\n/**\n * Get group details\n */\nasync function getGroup(groupId: string): Promise {\n const result = await sqlite.execute({\n sql: `SELECT id, name, created_by, invite_code, created_at FROM ${TABLE_PREFIX}groups WHERE id = ?`,\n args: [groupId],\n });\n\n if (result.rows.length === 0) return null;\n\n const row = rowToObject(result.rows[0] as unknown[] | Record, result.columns);\n return {\n id: row.id,\n name: row.name,\n created_by: row.created_by,\n invite_code: row.invite_code,\n created_at: row.created_at,\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// Type for reminder row with joins\ntype ReminderJoinRow = {\n id: string;\n listing_id: string;\n group_id: string;\n created_by: string;\n message: string | null;\n remind_at: number;\n is_sent: number;\n created_at: number;\n address_original: string;\n price: number | null;\n beds: number | null;\n baths: number | null;\n group_name: string;\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.id, r.listing_id, r.group_id, r.created_by, r.message, r.remind_at, r.is_sent, r.created_at, 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 const reminderRows = rowsToObjects(remindersResult.rows as (unknown[] | Record)[], remindersResult.columns);\n\n let processed = 0;\n let sent = 0;\n let errors = 0;\n\n for (const row of reminderRows) {\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 type EmailRow = { email: string };\n const userRow = rowToObject(userResult.rows[0] as unknown[] | Record, userResult.columns);\n\n const listing: Listing = {\n id: row.listing_id,\n address_original: row.address_original,\n address_normalized: \"\",\n unit_number: null,\n lat: null,\n lng: null,\n beds: row.beds,\n baths: row.baths,\n price: row.price,\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,\n listing,\n row.message,\n \"https://your-app.val.run\"\n );\n\n try {\n await email({\n to: [userRow.email],\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",[],[295,496],"7d36656e-f806-11f0-810f-42dde27851f2","migrations.ts","7d366640-f806-11f0-810f-42dde27851f2",300,["D",1769136720263],"/**\n * Database migrations for Loki rental search platform\n * Run this on startup to ensure all tables exist\n */\n\nimport { sqlite } from \"https://esm.town/v/std/sqlite\";\n\nconst TABLE_PREFIX = \"loki_\";\n\n/**\n * Run all migrations to create/update database schema\n */\nexport async function runMigrations(): Promise {\n console.log(\"Running Loki database migrations...\");\n\n // Users table (Google OAuth)\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS ${TABLE_PREFIX}users (\n id TEXT PRIMARY KEY,\n email TEXT UNIQUE NOT NULL,\n name TEXT,\n avatar_url TEXT,\n created_at INTEGER NOT NULL DEFAULT (unixepoch())\n )\n `);\n\n // Groups table (house search teams)\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS ${TABLE_PREFIX}groups (\n id TEXT PRIMARY KEY,\n name TEXT NOT NULL,\n created_by TEXT NOT NULL REFERENCES ${TABLE_PREFIX}users(id),\n invite_code TEXT UNIQUE NOT NULL,\n created_at INTEGER NOT NULL DEFAULT (unixepoch())\n )\n `);\n\n // Group memberships\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS ${TABLE_PREFIX}group_members (\n group_id TEXT NOT NULL REFERENCES ${TABLE_PREFIX}groups(id) ON DELETE CASCADE,\n user_id TEXT NOT NULL REFERENCES ${TABLE_PREFIX}users(id) ON DELETE CASCADE,\n role TEXT NOT NULL DEFAULT 'member',\n joined_at INTEGER NOT NULL DEFAULT (unixepoch()),\n PRIMARY KEY (group_id, user_id)\n )\n `);\n\n // Canonical listings (deduplicated)\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS ${TABLE_PREFIX}listings (\n id TEXT PRIMARY KEY,\n address_original TEXT NOT NULL,\n address_normalized TEXT NOT NULL,\n unit_number TEXT,\n lat REAL,\n lng REAL,\n beds INTEGER,\n baths REAL,\n price INTEGER,\n availability TEXT,\n neighborhood TEXT,\n first_seen_at INTEGER NOT NULL DEFAULT (unixepoch()),\n last_updated_at INTEGER NOT NULL DEFAULT (unixepoch()),\n is_active INTEGER NOT NULL DEFAULT 1\n )\n `);\n\n // Source links (multiple per listing)\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS ${TABLE_PREFIX}listing_sources (\n id TEXT PRIMARY KEY,\n listing_id TEXT NOT NULL REFERENCES ${TABLE_PREFIX}listings(id) ON DELETE CASCADE,\n platform TEXT NOT NULL,\n url TEXT UNIQUE NOT NULL,\n raw_address TEXT,\n first_seen_at INTEGER NOT NULL DEFAULT (unixepoch()),\n last_seen_at INTEGER NOT NULL DEFAULT (unixepoch())\n )\n `);\n\n // User/group interactions with listings\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS ${TABLE_PREFIX}listing_interactions (\n listing_id TEXT NOT NULL REFERENCES ${TABLE_PREFIX}listings(id) ON DELETE CASCADE,\n group_id TEXT NOT NULL REFERENCES ${TABLE_PREFIX}groups(id) ON DELETE CASCADE,\n status TEXT NOT NULL DEFAULT 'new',\n is_liked INTEGER NOT NULL DEFAULT 0,\n notes TEXT,\n custom_links TEXT,\n updated_by TEXT REFERENCES ${TABLE_PREFIX}users(id),\n updated_at INTEGER NOT NULL DEFAULT (unixepoch()),\n PRIMARY KEY (listing_id, group_id)\n )\n `);\n\n // Transit calculation results (cached)\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS ${TABLE_PREFIX}listing_transit (\n listing_id TEXT NOT NULL REFERENCES ${TABLE_PREFIX}listings(id) ON DELETE CASCADE,\n preference_id TEXT NOT NULL REFERENCES ${TABLE_PREFIX}transit_preferences(id) ON DELETE CASCADE,\n duration_minutes INTEGER,\n calculated_at INTEGER NOT NULL DEFAULT (unixepoch()),\n PRIMARY KEY (listing_id, preference_id)\n )\n `);\n\n // User-defined transit preferences\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS ${TABLE_PREFIX}transit_preferences (\n id TEXT PRIMARY KEY,\n group_id TEXT NOT NULL REFERENCES ${TABLE_PREFIX}groups(id) ON DELETE CASCADE,\n name TEXT NOT NULL,\n type TEXT NOT NULL,\n address TEXT,\n lat REAL,\n lng REAL,\n travel_mode TEXT NOT NULL DEFAULT 'transit',\n is_active INTEGER NOT NULL DEFAULT 1,\n created_at INTEGER NOT NULL DEFAULT (unixepoch())\n )\n `);\n\n // Notification preferences\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS ${TABLE_PREFIX}notification_prefs (\n user_id TEXT PRIMARY KEY REFERENCES ${TABLE_PREFIX}users(id) ON DELETE CASCADE,\n notify_new_listing INTEGER NOT NULL DEFAULT 1,\n notify_comment_request INTEGER NOT NULL DEFAULT 1,\n notify_apply_reminder INTEGER NOT NULL DEFAULT 1\n )\n `);\n\n // Reminders for listings\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS ${TABLE_PREFIX}reminders (\n id TEXT PRIMARY KEY,\n listing_id TEXT NOT NULL REFERENCES ${TABLE_PREFIX}listings(id) ON DELETE CASCADE,\n group_id TEXT NOT NULL REFERENCES ${TABLE_PREFIX}groups(id) ON DELETE CASCADE,\n created_by TEXT NOT NULL REFERENCES ${TABLE_PREFIX}users(id),\n remind_at INTEGER NOT NULL,\n message TEXT,\n is_sent INTEGER NOT NULL DEFAULT 0,\n created_at INTEGER NOT NULL DEFAULT (unixepoch())\n )\n `);\n\n // Create indexes for better query performance\n await createIndexes();\n\n console.log(\"Loki database migrations completed successfully.\");\n}\n\n/**\n * Create indexes for frequently queried columns\n */\nasync function createIndexes(): Promise {\n // Listings indexes\n await sqlite.execute(`\n CREATE INDEX IF NOT EXISTS idx_${TABLE_PREFIX}listings_normalized \n ON ${TABLE_PREFIX}listings(address_normalized)\n `);\n await sqlite.execute(`\n CREATE INDEX IF NOT EXISTS idx_${TABLE_PREFIX}listings_active \n ON ${TABLE_PREFIX}listings(is_active)\n `);\n await sqlite.execute(`\n CREATE INDEX IF NOT EXISTS idx_${TABLE_PREFIX}listings_neighborhood \n ON ${TABLE_PREFIX}listings(neighborhood)\n `);\n await sqlite.execute(`\n CREATE INDEX IF NOT EXISTS idx_${TABLE_PREFIX}listings_price \n ON ${TABLE_PREFIX}listings(price)\n `);\n await sqlite.execute(`\n CREATE INDEX IF NOT EXISTS idx_${TABLE_PREFIX}listings_beds \n ON ${TABLE_PREFIX}listings(beds)\n `);\n\n // Listing sources indexes\n await sqlite.execute(`\n CREATE INDEX IF NOT EXISTS idx_${TABLE_PREFIX}listing_sources_listing \n ON ${TABLE_PREFIX}listing_sources(listing_id)\n `);\n await sqlite.execute(`\n CREATE INDEX IF NOT EXISTS idx_${TABLE_PREFIX}listing_sources_platform \n ON ${TABLE_PREFIX}listing_sources(platform)\n `);\n\n // Group members indexes\n await sqlite.execute(`\n CREATE INDEX IF NOT EXISTS idx_${TABLE_PREFIX}group_members_user \n ON ${TABLE_PREFIX}group_members(user_id)\n `);\n\n // Interactions indexes\n await sqlite.execute(`\n CREATE INDEX IF NOT EXISTS idx_${TABLE_PREFIX}interactions_group \n ON ${TABLE_PREFIX}listing_interactions(group_id)\n `);\n await sqlite.execute(`\n CREATE INDEX IF NOT EXISTS idx_${TABLE_PREFIX}interactions_status \n ON ${TABLE_PREFIX}listing_interactions(status)\n `);\n\n // Transit preferences indexes\n await sqlite.execute(`\n CREATE INDEX IF NOT EXISTS idx_${TABLE_PREFIX}transit_prefs_group \n ON ${TABLE_PREFIX}transit_preferences(group_id)\n `);\n\n // Reminders indexes\n await sqlite.execute(`\n CREATE INDEX IF NOT EXISTS idx_${TABLE_PREFIX}reminders_remind_at \n ON ${TABLE_PREFIX}reminders(remind_at)\n `);\n await sqlite.execute(`\n CREATE INDEX IF NOT EXISTS idx_${TABLE_PREFIX}reminders_unsent \n ON ${TABLE_PREFIX}reminders(is_sent, remind_at)\n `);\n}\n\n/**\n * Check if migrations have been run by checking if tables exist\n */\nexport async function checkMigrationsStatus(): Promise {\n try {\n const result = await sqlite.execute(`\n SELECT name FROM sqlite_master \n WHERE type='table' AND name='${TABLE_PREFIX}users'\n `);\n return result.rows.length > 0;\n } catch {\n return false;\n }\n}\n",[],[295,505],"7d750346-f806-11f0-9cf9-42dde27851f2","listings.ts","7d7503fa-f806-11f0-9cf9-42dde27851f2",304,["D",1769136720502],"/**\n * Listings API for Loki\n * Handles listing retrieval, filtering, and user interactions\n */\n\nimport { Hono } from \"https://esm.sh/hono@4.0.0\";\nimport { sqlite } from \"https://esm.town/v/std/sqlite\";\nimport type { AuthContext } from \"./auth.ts\";\nimport { requireAuth } from \"./auth.ts\";\nimport { isGroupMember } from \"./groups.ts\";\nimport type {\n User,\n Listing,\n ListingSource,\n ListingInteraction,\n ListingWithDetails,\n ListingTransitResult,\n ListingsFilterParams,\n UpdateInteractionRequest,\n PaginatedResponse,\n ListingStatus,\n} from \"../shared/types.ts\";\n\nconst TABLE_PREFIX = \"loki_\";\n\nexport const listingsRouter = new Hono();\n\n// Apply auth middleware to all listing routes\nlistingsRouter.use(\"/*\", requireAuth);\n\n/**\n * Generate unique ID\n */\nfunction generateId(): string {\n return `${Date.now()}-${Math.random().toString(36).substring(2, 15)}`;\n}\n\n/**\n * Get listing sources for a listing\n */\nasync function getListingSources(listingId: string): Promise {\n const result = await sqlite.execute({\n sql: `SELECT * FROM ${TABLE_PREFIX}listing_sources WHERE listing_id = ? ORDER BY first_seen_at ASC`,\n args: [listingId],\n });\n\n return result.rows.map(row => ({\n id: row.id as string,\n listing_id: row.listing_id as string,\n platform: row.platform as \"zillow\" | \"craigslist\",\n url: row.url as string,\n raw_address: row.raw_address as string | null,\n first_seen_at: row.first_seen_at as number,\n last_seen_at: row.last_seen_at as number,\n }));\n}\n\n/**\n * Get listing interaction for a group\n */\nasync function getListingInteraction(listingId: string, groupId: string): Promise {\n const result = await sqlite.execute({\n sql: `SELECT * FROM ${TABLE_PREFIX}listing_interactions WHERE listing_id = ? AND group_id = ?`,\n args: [listingId, groupId],\n });\n\n if (result.rows.length === 0) return null;\n\n const row = result.rows[0];\n let customLinks: string[] | null = null;\n if (row.custom_links) {\n try {\n customLinks = JSON.parse(row.custom_links as string);\n } catch {\n customLinks = null;\n }\n }\n\n return {\n listing_id: row.listing_id as string,\n group_id: row.group_id as string,\n status: row.status as ListingStatus,\n is_liked: Boolean(row.is_liked),\n notes: row.notes as string | null,\n custom_links: customLinks,\n updated_by: row.updated_by as string | null,\n updated_at: row.updated_at as number,\n };\n}\n\n/**\n * Get transit results for a listing\n */\nasync function getListingTransit(listingId: string, groupId: string): Promise {\n const result = await sqlite.execute({\n sql: `\n SELECT lt.*, tp.name as preference_name, tp.travel_mode\n FROM ${TABLE_PREFIX}listing_transit lt\n JOIN ${TABLE_PREFIX}transit_preferences tp ON lt.preference_id = tp.id\n WHERE lt.listing_id = ? AND tp.group_id = ? AND tp.is_active = 1\n `,\n args: [listingId, groupId],\n });\n\n return result.rows.map(row => ({\n preference_id: row.preference_id as string,\n preference_name: row.preference_name as string,\n duration_minutes: row.duration_minutes as number | null,\n travel_mode: row.travel_mode as \"driving\" | \"transit\" | \"walking\" | \"bicycling\",\n }));\n}\n\n/**\n * Calculate computed fields for a listing\n */\nfunction calculateFields(listing: Listing): { rent_per_bedroom: number | null; bed_bath_ratio: number | null } {\n const rent_per_bedroom = listing.price && listing.beds && listing.beds > 0\n ? Math.round(listing.price / listing.beds)\n : null;\n\n const bed_bath_ratio = listing.beds !== null && listing.baths !== null && listing.baths > 0\n ? Math.round((listing.beds / listing.baths) * 100) / 100\n : null;\n\n return { rent_per_bedroom, bed_bath_ratio };\n}\n\n/**\n * Build listing with full details\n */\nasync function buildListingWithDetails(\n listing: Listing,\n groupId: string\n): Promise {\n const [sources, interaction, transit] = await Promise.all([\n getListingSources(listing.id),\n getListingInteraction(listing.id, groupId),\n getListingTransit(listing.id, groupId),\n ]);\n\n const calculated = calculateFields(listing);\n\n return {\n ...listing,\n sources,\n interaction: interaction || undefined,\n transit,\n ...calculated,\n };\n}\n\n/**\n * Parse listing row from database\n */\nfunction parseListingRow(row: any): Listing {\n return {\n id: row.id as string,\n address_original: row.address_original as string,\n address_normalized: row.address_normalized as string,\n unit_number: row.unit_number as string | null,\n lat: row.lat as number | null,\n lng: row.lng as number | null,\n beds: row.beds as number | null,\n baths: row.baths as number | null,\n price: row.price as number | null,\n availability: row.availability as string | null,\n neighborhood: row.neighborhood as string | null,\n first_seen_at: row.first_seen_at as number,\n last_updated_at: row.last_updated_at as number,\n is_active: Boolean(row.is_active),\n };\n}\n\n/**\n * GET /listings - List listings for a group with filtering\n */\nlistingsRouter.get(\"/\", async (c) => {\n const user = c.get(\"user\") as User;\n const groupId = c.req.query(\"group_id\");\n\n if (!groupId) {\n return c.json({ error: \"Validation error\", message: \"group_id is required\" }, 400);\n }\n\n // Check membership\n if (!await isGroupMember(groupId, user.id)) {\n return c.json({ error: \"Forbidden\", message: \"You are not a member of this group\" }, 403);\n }\n\n // Parse filter params\n const params: ListingsFilterParams = {\n status: c.req.query(\"status\") as ListingStatus | undefined,\n is_liked: c.req.query(\"is_liked\") === \"true\" ? true : c.req.query(\"is_liked\") === \"false\" ? false : undefined,\n min_price: c.req.query(\"min_price\") ? parseInt(c.req.query(\"min_price\")!) : undefined,\n max_price: c.req.query(\"max_price\") ? parseInt(c.req.query(\"max_price\")!) : undefined,\n min_beds: c.req.query(\"min_beds\") ? parseInt(c.req.query(\"min_beds\")!) : undefined,\n max_beds: c.req.query(\"max_beds\") ? parseInt(c.req.query(\"max_beds\")!) : undefined,\n neighborhood: c.req.query(\"neighborhood\") || undefined,\n is_active: c.req.query(\"is_active\") === \"false\" ? false : true, // Default to active only\n page: c.req.query(\"page\") ? parseInt(c.req.query(\"page\")!) : 1,\n limit: c.req.query(\"limit\") ? Math.min(parseInt(c.req.query(\"limit\")!), 100) : 50,\n sort_by: (c.req.query(\"sort_by\") as ListingsFilterParams[\"sort_by\"]) || \"last_updated_at\",\n sort_order: (c.req.query(\"sort_order\") as \"asc\" | \"desc\") || \"desc\",\n };\n\n // Build query\n let query = `\n SELECT DISTINCT l.* \n FROM ${TABLE_PREFIX}listings l\n LEFT JOIN ${TABLE_PREFIX}listing_interactions i ON l.id = i.listing_id AND i.group_id = ?\n WHERE 1=1\n `;\n const args: any[] = [groupId];\n\n if (params.is_active !== undefined) {\n query += ` AND l.is_active = ?`;\n args.push(params.is_active ? 1 : 0);\n }\n\n if (params.min_price !== undefined) {\n query += ` AND l.price >= ?`;\n args.push(params.min_price);\n }\n\n if (params.max_price !== undefined) {\n query += ` AND l.price <= ?`;\n args.push(params.max_price);\n }\n\n if (params.min_beds !== undefined) {\n query += ` AND l.beds >= ?`;\n args.push(params.min_beds);\n }\n\n if (params.max_beds !== undefined) {\n query += ` AND l.beds <= ?`;\n args.push(params.max_beds);\n }\n\n if (params.neighborhood) {\n query += ` AND l.neighborhood = ?`;\n args.push(params.neighborhood);\n }\n\n if (params.status) {\n query += ` AND i.status = ?`;\n args.push(params.status);\n }\n\n if (params.is_liked !== undefined) {\n query += ` AND i.is_liked = ?`;\n args.push(params.is_liked ? 1 : 0);\n }\n\n // Get total count\n const countQuery = query.replace(\"SELECT DISTINCT l.*\", \"SELECT COUNT(DISTINCT l.id) as count\");\n const countResult = await sqlite.execute({ sql: countQuery, args });\n const total = countResult.rows[0].count as number;\n\n // Add sorting and pagination\n const validSortColumns = [\"price\", \"beds\", \"first_seen_at\", \"last_updated_at\"];\n const sortBy = validSortColumns.includes(params.sort_by!) ? params.sort_by : \"last_updated_at\";\n const sortOrder = params.sort_order === \"asc\" ? \"ASC\" : \"DESC\";\n\n query += ` ORDER BY l.${sortBy} ${sortOrder}`;\n query += ` LIMIT ? OFFSET ?`;\n args.push(params.limit!, (params.page! - 1) * params.limit!);\n\n // Execute query\n const result = await sqlite.execute({ sql: query, args });\n\n // Build full listing details\n const listings: ListingWithDetails[] = [];\n for (const row of result.rows) {\n const listing = parseListingRow(row);\n const listingWithDetails = await buildListingWithDetails(listing, groupId);\n listings.push(listingWithDetails);\n }\n\n const response: PaginatedResponse = {\n data: listings,\n total,\n page: params.page!,\n limit: params.limit!,\n total_pages: Math.ceil(total / params.limit!),\n };\n\n return c.json(response);\n});\n\n/**\n * GET /listings/:id - Get single listing with full details\n */\nlistingsRouter.get(\"/:id\", async (c) => {\n const user = c.get(\"user\") as User;\n const listingId = c.req.param(\"id\");\n const groupId = c.req.query(\"group_id\");\n\n if (!groupId) {\n return c.json({ error: \"Validation error\", message: \"group_id is required\" }, 400);\n }\n\n // Check membership\n if (!await isGroupMember(groupId, user.id)) {\n return c.json({ error: \"Forbidden\", message: \"You are not a member of this group\" }, 403);\n }\n\n // Get listing\n const result = await sqlite.execute({\n sql: `SELECT * FROM ${TABLE_PREFIX}listings WHERE id = ?`,\n args: [listingId],\n });\n\n if (result.rows.length === 0) {\n return c.json({ error: \"Not found\", message: \"Listing not found\" }, 404);\n }\n\n const listing = parseListingRow(result.rows[0]);\n const listingWithDetails = await buildListingWithDetails(listing, groupId);\n\n return c.json({ listing: listingWithDetails });\n});\n\n/**\n * PATCH /listings/:id/interaction - Update listing interaction for group\n */\nlistingsRouter.patch(\"/:id/interaction\", async (c) => {\n const user = c.get(\"user\") as User;\n const listingId = c.req.param(\"id\");\n\n let body: UpdateInteractionRequest & { group_id: string };\n try {\n body = await c.req.json();\n } catch {\n return c.json({ error: \"Invalid request\", message: \"Invalid JSON body\" }, 400);\n }\n\n const { group_id: groupId, ...updates } = body;\n\n if (!groupId) {\n return c.json({ error: \"Validation error\", message: \"group_id is required\" }, 400);\n }\n\n // Check membership\n if (!await isGroupMember(groupId, user.id)) {\n return c.json({ error: \"Forbidden\", message: \"You are not a member of this group\" }, 403);\n }\n\n // Check listing exists\n const listingResult = await sqlite.execute({\n sql: `SELECT id FROM ${TABLE_PREFIX}listings WHERE id = ?`,\n args: [listingId],\n });\n\n if (listingResult.rows.length === 0) {\n return c.json({ error: \"Not found\", message: \"Listing not found\" }, 404);\n }\n\n // Validate status if provided\n const validStatuses: ListingStatus[] = [\"new\", \"interested\", \"contacted\", \"toured\", \"applied\", \"rejected\"];\n if (updates.status && !validStatuses.includes(updates.status)) {\n return c.json({ error: \"Validation error\", message: \"Invalid status value\" }, 400);\n }\n\n const now = Math.floor(Date.now() / 1000);\n\n // Check if interaction exists\n const existingInteraction = await getListingInteraction(listingId, groupId);\n\n if (existingInteraction) {\n // Update existing interaction\n const setClauses: string[] = [];\n const args: any[] = [];\n\n if (updates.status !== undefined) {\n setClauses.push(\"status = ?\");\n args.push(updates.status);\n }\n\n if (updates.is_liked !== undefined) {\n setClauses.push(\"is_liked = ?\");\n args.push(updates.is_liked ? 1 : 0);\n }\n\n if (updates.notes !== undefined) {\n setClauses.push(\"notes = ?\");\n args.push(updates.notes);\n }\n\n if (updates.custom_links !== undefined) {\n setClauses.push(\"custom_links = ?\");\n args.push(JSON.stringify(updates.custom_links));\n }\n\n if (setClauses.length > 0) {\n setClauses.push(\"updated_by = ?\", \"updated_at = ?\");\n args.push(user.id, now, listingId, groupId);\n\n await sqlite.execute({\n sql: `UPDATE ${TABLE_PREFIX}listing_interactions SET ${setClauses.join(\", \")} WHERE listing_id = ? AND group_id = ?`,\n args,\n });\n }\n } else {\n // Create new interaction\n await sqlite.execute({\n sql: `\n INSERT INTO ${TABLE_PREFIX}listing_interactions \n (listing_id, group_id, status, is_liked, notes, custom_links, updated_by, updated_at)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?)\n `,\n args: [\n listingId,\n groupId,\n updates.status || \"new\",\n updates.is_liked ? 1 : 0,\n updates.notes || null,\n updates.custom_links ? JSON.stringify(updates.custom_links) : null,\n user.id,\n now,\n ],\n });\n }\n\n // Return updated interaction\n const interaction = await getListingInteraction(listingId, groupId);\n return c.json({ interaction });\n});\n\n/**\n * GET /listings/neighborhoods - Get list of unique neighborhoods\n */\nlistingsRouter.get(\"/meta/neighborhoods\", async (c) => {\n const result = await sqlite.execute(`\n SELECT DISTINCT neighborhood \n FROM ${TABLE_PREFIX}listings \n WHERE neighborhood IS NOT NULL AND is_active = 1\n ORDER BY neighborhood\n `);\n\n const neighborhoods = result.rows.map(row => row.neighborhood as string);\n return c.json({ neighborhoods });\n});\n\n/**\n * GET /listings/stats - Get listing statistics for a group\n */\nlistingsRouter.get(\"/meta/stats\", async (c) => {\n const user = c.get(\"user\") as User;\n const groupId = c.req.query(\"group_id\");\n\n if (!groupId) {\n return c.json({ error: \"Validation error\", message: \"group_id is required\" }, 400);\n }\n\n // Check membership\n if (!await isGroupMember(groupId, user.id)) {\n return c.json({ error: \"Forbidden\", message: \"You are not a member of this group\" }, 403);\n }\n\n // Get total active listings\n const totalResult = await sqlite.execute(\n `SELECT COUNT(*) as count FROM ${TABLE_PREFIX}listings WHERE is_active = 1`\n );\n\n // Get listings by status for this group\n const statusResult = await sqlite.execute({\n sql: `\n SELECT \n COALESCE(i.status, 'new') as status, \n COUNT(*) as count\n FROM ${TABLE_PREFIX}listings l\n LEFT JOIN ${TABLE_PREFIX}listing_interactions i ON l.id = i.listing_id AND i.group_id = ?\n WHERE l.is_active = 1\n GROUP BY COALESCE(i.status, 'new')\n `,\n args: [groupId],\n });\n\n // Get liked count\n const likedResult = await sqlite.execute({\n sql: `\n SELECT COUNT(*) as count\n FROM ${TABLE_PREFIX}listing_interactions\n WHERE group_id = ? AND is_liked = 1\n `,\n args: [groupId],\n });\n\n // Get price range\n const priceResult = await sqlite.execute(`\n SELECT MIN(price) as min_price, MAX(price) as max_price, AVG(price) as avg_price\n FROM ${TABLE_PREFIX}listings\n WHERE is_active = 1 AND price IS NOT NULL\n `);\n\n const stats = {\n total_active: totalResult.rows[0].count as number,\n by_status: Object.fromEntries(statusResult.rows.map(row => [row.status, row.count])),\n liked_count: likedResult.rows[0].count as number,\n price_range: {\n min: priceResult.rows[0].min_price as number | null,\n max: priceResult.rows[0].max_price as number | null,\n avg: priceResult.rows[0].avg_price ? Math.round(priceResult.rows[0].avg_price as number) : null,\n },\n };\n\n return c.json({ stats });\n});\n\nexport { getListingSources, getListingInteraction, buildListingWithDetails };\n",[],[295,513],"83c28a44-f80a-11f0-a0ff-42dde27851f2","index.ts",315,["D",1769138449230],"/**\n * Main backend entry point for Loki\n * Combines all API routes and serves the application\n */\n\nimport { Hono } from \"https://esm.sh/hono@4.0.0\";\nimport { cors } from \"https://esm.sh/hono@4.0.0/cors\";\nimport { serveFile, readFile } from \"https://esm.town/v/std/utils@85-main/index.ts\";\nimport { runMigrations } from \"./migrations.ts\";\nimport { authRouter, authMiddleware } from \"./auth.ts\";\nimport { groupsRouter } from \"./groups.ts\";\nimport { listingsRouter } from \"./listings.ts\";\nimport { preferencesRouter } from \"./preferences.ts\";\n\n// Run migrations on module load (cold start)\nlet migrationsRun = false;\n\nconst app = new Hono();\n\n// Ensure migrations run before any request\napp.use(\"/*\", async (c, next) => {\n if (!migrationsRun) {\n await runMigrations();\n migrationsRun = true;\n }\n await next();\n});\n\n// Unwrap Hono errors to see original error details\napp.onError((err, c) => {\n console.error(\"Unhandled error:\", err);\n throw err;\n});\n\n// Enable CORS\napp.use(\"/*\", cors({\n origin: \"*\",\n allowMethods: [\"GET\", \"POST\", \"PUT\", \"PATCH\", \"DELETE\", \"OPTIONS\"],\n allowHeaders: [\"Content-Type\", \"Authorization\"],\n credentials: true,\n}));\n\n// Apply auth middleware globally (sets user context)\napp.use(\"/*\", authMiddleware);\n\n// Health check endpoint\napp.get(\"/health\", (c) => {\n return c.json({ status: \"ok\", message: \"Loki API is running\" });\n});\n\n// API routes\napp.route(\"/auth\", authRouter);\napp.route(\"/api/groups\", groupsRouter);\napp.route(\"/api/listings\", listingsRouter);\napp.route(\"/api/preferences\", preferencesRouter);\n\n// Serve frontend static files\napp.get(\"/frontend/*\", c => serveFile(c.req.path, import.meta.url));\napp.get(\"/shared/*\", c => serveFile(c.req.path, import.meta.url));\n\n// Serve index.html for all other routes (SPA routing)\napp.get(\"/*\", async (c) => {\n try {\n let html = await readFile(\"/frontend/index.html\", import.meta.url);\n \n // Inject user data if logged in\n const user = c.get(\"user\");\n if (user) {\n const userScript = ``;\n html = html.replace(\"\", `${userScript}`);\n }\n \n return c.html(html);\n } catch (error) {\n console.error(\"Error serving index:\", error);\n return c.text(\"Error loading application\", 500);\n }\n});\n\n// Export for Val Town\nexport default app.fetch;\n",[],[295,521],"83c69a9e-f80a-11f0-bd71-42dde27851f2","groups.ts","7d41f302-f806-11f0-a6eb-42dde27851f2",316,["D",1769138449253],"/**\n * Group management API for Loki\n * Handles creating, joining, and managing house search groups\n */\n\nimport { Hono } from \"https://esm.sh/hono@4.0.0\";\nimport { sqlite } from \"https://esm.town/v/std/sqlite\";\nimport type { AuthContext } from \"./auth.ts\";\nimport { requireAuth } from \"./auth.ts\";\nimport type { Group, GroupMember, GroupWithMembers, User, CreateGroupRequest } from \"../shared/types.ts\";\n\nconst TABLE_PREFIX = \"loki_\";\n\nexport const groupsRouter = new Hono();\n\n// Apply auth middleware to all group routes\ngroupsRouter.use(\"/*\", requireAuth);\n\n/**\n * Generate a unique ID\n */\nfunction generateId(): string {\n return `${Date.now()}-${Math.random().toString(36).substring(2, 15)}`;\n}\n\n/**\n * Generate a random invite code (6 alphanumeric characters)\n */\nfunction generateInviteCode(): string {\n const chars = \"ABCDEFGHJKLMNPQRSTUVWXYZ23456789\"; // Excluded confusing chars like 0, O, 1, I\n let code = \"\";\n for (let i = 0; i < 6; i++) {\n code += chars.charAt(Math.floor(Math.random() * chars.length));\n }\n return code;\n}\n\n/**\n * Get group by ID with members\n */\nasync function getGroupWithMembers(groupId: string): Promise {\n const groupResult = await sqlite.execute({\n sql: `SELECT * FROM ${TABLE_PREFIX}groups WHERE id = ?`,\n args: [groupId],\n });\n\n if (groupResult.rows.length === 0) return null;\n\n const groupRow = groupResult.rows[0];\n const group: Group = {\n id: groupRow.id as string,\n name: groupRow.name as string,\n created_by: groupRow.created_by as string,\n invite_code: groupRow.invite_code as string,\n created_at: groupRow.created_at as number,\n };\n\n // Get members with user details\n const membersResult = await sqlite.execute({\n sql: `\n SELECT gm.*, u.email, u.name as user_name, u.avatar_url\n FROM ${TABLE_PREFIX}group_members gm\n JOIN ${TABLE_PREFIX}users u ON gm.user_id = u.id\n WHERE gm.group_id = ?\n `,\n args: [groupId],\n });\n\n const members = membersResult.rows.map(row => ({\n group_id: row.group_id as string,\n user_id: row.user_id as string,\n role: row.role as \"owner\" | \"member\",\n joined_at: row.joined_at as number,\n user: {\n id: row.user_id as string,\n email: row.email as string,\n name: row.user_name as string | null,\n avatar_url: row.avatar_url as string | null,\n created_at: 0, // Not needed here\n },\n }));\n\n return { ...group, members };\n}\n\n/**\n * Check if user is member of group\n */\nasync function isGroupMember(groupId: string, userId: string): Promise {\n const result = await sqlite.execute({\n sql: `SELECT 1 FROM ${TABLE_PREFIX}group_members WHERE group_id = ? AND user_id = ?`,\n args: [groupId, userId],\n });\n return result.rows.length > 0;\n}\n\n/**\n * Check if user is owner of group\n */\nasync function isGroupOwner(groupId: string, userId: string): Promise {\n const result = await sqlite.execute({\n sql: `SELECT 1 FROM ${TABLE_PREFIX}group_members WHERE group_id = ? AND user_id = ? AND role = 'owner'`,\n args: [groupId, userId],\n });\n return result.rows.length > 0;\n}\n\n/**\n * POST /groups - Create a new group\n */\ngroupsRouter.post(\"/\", async (c) => {\n const user = c.get(\"user\") as User;\n \n // Validate user object has required fields\n if (!user || !user.id) {\n console.error(\"Invalid user object in create group:\", JSON.stringify(user));\n return c.json({ error: \"Authentication error\", message: \"Invalid user session\" }, 401);\n }\n \n let body: CreateGroupRequest;\n try {\n body = await c.req.json();\n } catch {\n return c.json({ error: \"Invalid request\", message: \"Invalid JSON body\" }, 400);\n }\n\n if (!body.name || body.name.trim().length === 0) {\n return c.json({ error: \"Validation error\", message: \"Group name is required\" }, 400);\n }\n\n const groupId = generateId();\n const inviteCode = generateInviteCode();\n const now = Math.floor(Date.now() / 1000);\n\n // Create group\n await sqlite.execute({\n sql: `INSERT INTO ${TABLE_PREFIX}groups (id, name, created_by, invite_code, created_at) VALUES (?, ?, ?, ?, ?)`,\n args: [groupId, body.name.trim(), user.id, inviteCode, now],\n });\n\n // Add creator as owner\n await sqlite.execute({\n sql: `INSERT INTO ${TABLE_PREFIX}group_members (group_id, user_id, role, joined_at) VALUES (?, ?, 'owner', ?)`,\n args: [groupId, user.id, now],\n });\n\n const group = await getGroupWithMembers(groupId);\n return c.json({ group }, 201);\n});\n\n/**\n * GET /groups - List user's groups\n */\ngroupsRouter.get(\"/\", async (c) => {\n const user = c.get(\"user\") as User;\n\n const result = await sqlite.execute({\n sql: `\n SELECT g.*, gm.role\n FROM ${TABLE_PREFIX}groups g\n JOIN ${TABLE_PREFIX}group_members gm ON g.id = gm.group_id\n WHERE gm.user_id = ?\n ORDER BY g.created_at DESC\n `,\n args: [user.id],\n });\n\n const groups = result.rows.map(row => ({\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 role: row.role as string,\n }));\n\n return c.json({ groups });\n});\n\n/**\n * GET /groups/:id - Get group details with members\n */\ngroupsRouter.get(\"/:id\", async (c) => {\n const user = c.get(\"user\") as User;\n const groupId = c.req.param(\"id\");\n\n // Check membership\n if (!await isGroupMember(groupId, user.id)) {\n return c.json({ error: \"Forbidden\", message: \"You are not a member of this group\" }, 403);\n }\n\n const group = await getGroupWithMembers(groupId);\n if (!group) {\n return c.json({ error: \"Not found\", message: \"Group not found\" }, 404);\n }\n\n return c.json({ group });\n});\n\n/**\n * PUT /groups/:id - Update group name\n */\ngroupsRouter.put(\"/:id\", async (c) => {\n const user = c.get(\"user\") as User;\n const groupId = c.req.param(\"id\");\n\n // Check ownership\n if (!await isGroupOwner(groupId, user.id)) {\n return c.json({ error: \"Forbidden\", message: \"Only group owners can update the group\" }, 403);\n }\n\n let body: { name?: string };\n try {\n body = await c.req.json();\n } catch {\n return c.json({ error: \"Invalid request\", message: \"Invalid JSON body\" }, 400);\n }\n\n if (!body.name || body.name.trim().length === 0) {\n return c.json({ error: \"Validation error\", message: \"Group name is required\" }, 400);\n }\n\n await sqlite.execute({\n sql: `UPDATE ${TABLE_PREFIX}groups SET name = ? WHERE id = ?`,\n args: [body.name.trim(), groupId],\n });\n\n const group = await getGroupWithMembers(groupId);\n return c.json({ group });\n});\n\n/**\n * POST /groups/:id/regenerate-invite - Generate a new invite code\n */\ngroupsRouter.post(\"/:id/regenerate-invite\", async (c) => {\n const user = c.get(\"user\") as User;\n const groupId = c.req.param(\"id\");\n\n // Check ownership\n if (!await isGroupOwner(groupId, user.id)) {\n return c.json({ error: \"Forbidden\", message: \"Only group owners can regenerate invite codes\" }, 403);\n }\n\n const newInviteCode = generateInviteCode();\n await sqlite.execute({\n sql: `UPDATE ${TABLE_PREFIX}groups SET invite_code = ? WHERE id = ?`,\n args: [newInviteCode, groupId],\n });\n\n return c.json({ invite_code: newInviteCode });\n});\n\n/**\n * POST /groups/join/:code - Join a group via invite code\n */\ngroupsRouter.post(\"/join/:code\", async (c) => {\n const user = c.get(\"user\") as User;\n const inviteCode = c.req.param(\"code\").toUpperCase();\n\n // Find group by invite code\n const groupResult = await sqlite.execute({\n sql: `SELECT * FROM ${TABLE_PREFIX}groups WHERE invite_code = ?`,\n args: [inviteCode],\n });\n\n if (groupResult.rows.length === 0) {\n return c.json({ error: \"Not found\", message: \"Invalid invite code\" }, 404);\n }\n\n const groupId = groupResult.rows[0].id as string;\n\n // Check if already a member\n if (await isGroupMember(groupId, user.id)) {\n return c.json({ error: \"Already joined\", message: \"You are already a member of this group\" }, 400);\n }\n\n // Add as member\n const now = Math.floor(Date.now() / 1000);\n await sqlite.execute({\n sql: `INSERT INTO ${TABLE_PREFIX}group_members (group_id, user_id, role, joined_at) VALUES (?, ?, 'member', ?)`,\n args: [groupId, user.id, now],\n });\n\n const group = await getGroupWithMembers(groupId);\n return c.json({ group, message: \"Successfully joined the group\" });\n});\n\n/**\n * DELETE /groups/:id/members/:userId - Remove a member from group\n */\ngroupsRouter.delete(\"/:id/members/:userId\", async (c) => {\n const user = c.get(\"user\") as User;\n const groupId = c.req.param(\"id\");\n const targetUserId = c.req.param(\"userId\");\n\n // Users can remove themselves, or owners can remove others\n const isSelf = targetUserId === user.id;\n const isOwner = await isGroupOwner(groupId, user.id);\n\n if (!isSelf && !isOwner) {\n return c.json({ error: \"Forbidden\", message: \"You can only remove yourself or be a group owner to remove others\" }, 403);\n }\n\n // Check if target is a member\n if (!await isGroupMember(groupId, targetUserId)) {\n return c.json({ error: \"Not found\", message: \"User is not a member of this group\" }, 404);\n }\n\n // Check if trying to remove the only owner\n if (await isGroupOwner(groupId, targetUserId)) {\n const ownersResult = await sqlite.execute({\n sql: `SELECT COUNT(*) as count FROM ${TABLE_PREFIX}group_members WHERE group_id = ? AND role = 'owner'`,\n args: [groupId],\n });\n const ownerCount = ownersResult.rows[0].count as number;\n \n if (ownerCount <= 1) {\n return c.json({ error: \"Cannot remove\", message: \"Cannot remove the only owner. Transfer ownership first or delete the group.\" }, 400);\n }\n }\n\n // Remove member\n await sqlite.execute({\n sql: `DELETE FROM ${TABLE_PREFIX}group_members WHERE group_id = ? AND user_id = ?`,\n args: [groupId, targetUserId],\n });\n\n return c.json({ success: true, message: \"Member removed from group\" });\n});\n\n/**\n * POST /groups/:id/members/:userId/promote - Promote member to owner\n */\ngroupsRouter.post(\"/:id/members/:userId/promote\", async (c) => {\n const user = c.get(\"user\") as User;\n const groupId = c.req.param(\"id\");\n const targetUserId = c.req.param(\"userId\");\n\n // Only owners can promote\n if (!await isGroupOwner(groupId, user.id)) {\n return c.json({ error: \"Forbidden\", message: \"Only group owners can promote members\" }, 403);\n }\n\n // Check if target is a member\n if (!await isGroupMember(groupId, targetUserId)) {\n return c.json({ error: \"Not found\", message: \"User is not a member of this group\" }, 404);\n }\n\n // Promote to owner\n await sqlite.execute({\n sql: `UPDATE ${TABLE_PREFIX}group_members SET role = 'owner' WHERE group_id = ? AND user_id = ?`,\n args: [groupId, targetUserId],\n });\n\n return c.json({ success: true, message: \"Member promoted to owner\" });\n});\n\n/**\n * DELETE /groups/:id - Delete a group (owner only)\n */\ngroupsRouter.delete(\"/:id\", async (c) => {\n const user = c.get(\"user\") as User;\n const groupId = c.req.param(\"id\");\n\n // Only owners can delete\n if (!await isGroupOwner(groupId, user.id)) {\n return c.json({ error: \"Forbidden\", message: \"Only group owners can delete the group\" }, 403);\n }\n\n // Delete group (cascades to members, interactions, etc.)\n await sqlite.execute({\n sql: `DELETE FROM ${TABLE_PREFIX}groups WHERE id = ?`,\n args: [groupId],\n });\n\n return c.json({ success: true, message: \"Group deleted\" });\n});\n\nexport { getGroupWithMembers, isGroupMember, isGroupOwner };\n",[],[295,528],"28f05edc-f80c-11f0-a0bc-42dde27851f2",["D",1769139155818],[],[295,33],"28e4b514-f80c-11f0-8a2e-42dde27851f2","db-utils.ts","28e4b5b4-f80c-11f0-8a2e-42dde27851f2",318,["D",1769139155768],"/**\n * Database utilities for handling Val Town SQLite results\n * Val Town SQLite may return rows as arrays, so we need to convert them to objects\n */\n\n/**\n * Convert a SQLite result row to an object using column names\n * Handles both array-style (Val Town) and object-style rows\n */\nexport function rowToObject>(\n row: unknown[] | Record,\n columns: string[]\n): T {\n if (!Array.isArray(row)) {\n // Row is already an object\n return row as T;\n }\n \n // Convert array row to object using column names\n const obj: Record = {};\n for (let i = 0; i < columns.length; i++) {\n obj[columns[i]] = row[i];\n }\n return obj as T;\n}\n\n/**\n * Convert all rows in a result to objects\n */\nexport function rowsToObjects>(\n rows: (unknown[] | Record)[],\n columns: string[]\n): T[] {\n return rows.map(row => rowToObject(row, columns));\n}\n",[],[295,540],"83d06b1e-f80a-11f0-aa0c-42dde27851f2","auth.ts","7d8fb204-f806-11f0-818c-42dde27851f2",317,["D",1769138449312],"/**\n * Google OAuth authentication for Loki\n * Handles login, callback, session management, and logout\n */\n\nimport { Hono } from \"https://esm.sh/hono@4.0.0\";\nimport { getCookie, setCookie, deleteCookie } from \"https://esm.sh/hono@4.0.0/cookie\";\nimport { sqlite } from \"https://esm.town/v/std/sqlite\";\nimport { blob } from \"https://esm.town/v/std/blob\";\nimport type { User, Session } from \"../shared/types.ts\";\n\nconst TABLE_PREFIX = \"loki_\";\nconst SESSION_EXPIRY_MS = 7 * 24 * 60 * 60 * 1000; // 7 days\n\n// Type for Hono context with user\nexport type AuthContext = {\n Variables: {\n user: User | null;\n session: Session | null;\n };\n};\n\nexport const authRouter = new Hono();\n\n/**\n * Generate a random session token\n */\nfunction generateSessionToken(): string {\n const chars = \"ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789\";\n let token = \"\";\n for (let i = 0; i < 64; i++) {\n token += chars.charAt(Math.floor(Math.random() * chars.length));\n }\n return token;\n}\n\n/**\n * Generate a unique ID\n */\nfunction generateId(): string {\n return `${Date.now()}-${Math.random().toString(36).substring(2, 15)}`;\n}\n\n/**\n * Store session in blob storage\n */\nasync function createSession(userId: string): Promise {\n const token = generateSessionToken();\n const session: Session = {\n token,\n user_id: userId,\n expires_at: Date.now() + SESSION_EXPIRY_MS,\n };\n await blob.setJSON(`loki_session_${token}`, session);\n return session;\n}\n\n/**\n * Get session from blob storage\n */\nasync function getSession(token: string): Promise {\n try {\n const session = await blob.getJSON(`loki_session_${token}`) as Session;\n if (session && session.expires_at > Date.now()) {\n return session;\n }\n // Session expired, delete it\n if (session) {\n await blob.delete(`loki_session_${token}`);\n }\n return null;\n } catch {\n return null;\n }\n}\n\n/**\n * Delete session from blob storage\n */\nasync function deleteSession(token: string): Promise {\n try {\n await blob.delete(`loki_session_${token}`);\n } catch {\n // Ignore errors\n }\n}\n\n/**\n * Get user by ID from database\n */\nasync function getUserById(userId: string): Promise {\n const result = await sqlite.execute({\n sql: `SELECT * FROM ${TABLE_PREFIX}users WHERE id = ?`,\n args: [userId],\n });\n if (result.rows.length === 0) return null;\n const row = result.rows[0];\n return {\n id: row.id as string,\n email: row.email as string,\n name: row.name as string | null,\n avatar_url: row.avatar_url as string | null,\n created_at: row.created_at as number,\n };\n}\n\n/**\n * Get or create user from Google profile\n */\nasync function getOrCreateUser(googleProfile: {\n sub: string;\n email: string;\n name?: string;\n picture?: string;\n}): Promise {\n // Check if user exists\n const existingResult = await sqlite.execute({\n sql: `SELECT * FROM ${TABLE_PREFIX}users WHERE id = ?`,\n args: [googleProfile.sub],\n });\n\n if (existingResult.rows.length > 0) {\n // Update user info\n await sqlite.execute({\n sql: `UPDATE ${TABLE_PREFIX}users SET name = ?, avatar_url = ? WHERE id = ?`,\n args: [googleProfile.name || null, googleProfile.picture || null, googleProfile.sub],\n });\n return {\n id: googleProfile.sub,\n email: existingResult.rows[0].email as string,\n name: googleProfile.name || null,\n avatar_url: googleProfile.picture || null,\n created_at: existingResult.rows[0].created_at as number,\n };\n }\n\n // Create new user\n const now = Math.floor(Date.now() / 1000);\n await sqlite.execute({\n sql: `INSERT INTO ${TABLE_PREFIX}users (id, email, name, avatar_url, created_at) VALUES (?, ?, ?, ?, ?)`,\n args: [googleProfile.sub, googleProfile.email, googleProfile.name || null, googleProfile.picture || null, now],\n });\n\n // Create default notification preferences\n await sqlite.execute({\n sql: `INSERT INTO ${TABLE_PREFIX}notification_prefs (user_id) VALUES (?)`,\n args: [googleProfile.sub],\n });\n\n return {\n id: googleProfile.sub,\n email: googleProfile.email,\n name: googleProfile.name || null,\n avatar_url: googleProfile.picture || null,\n created_at: now,\n };\n}\n\n/**\n * Middleware to authenticate requests\n */\nexport async function authMiddleware(c: any, next: () => Promise) {\n const sessionToken = getCookie(c, \"loki_session\");\n \n if (sessionToken) {\n const session = await getSession(sessionToken);\n if (session) {\n if (!session.user_id) {\n console.error(\"Session has no user_id:\", JSON.stringify(session));\n c.set(\"user\", null);\n c.set(\"session\", null);\n } else {\n const user = await getUserById(session.user_id);\n if (user && !user.id) {\n console.error(\"User object has no id:\", JSON.stringify(user));\n c.set(\"user\", null);\n c.set(\"session\", null);\n } else {\n c.set(\"user\", user);\n c.set(\"session\", session);\n }\n }\n }\n }\n \n if (!c.get(\"user\")) {\n c.set(\"user\", null);\n c.set(\"session\", null);\n }\n \n await next();\n}\n\n/**\n * Middleware to require authentication\n */\nexport async function requireAuth(c: any, next: () => Promise) {\n const user = c.get(\"user\");\n if (!user || !user.id) {\n return c.json({ error: \"Unauthorized\", message: \"Authentication required\" }, 401);\n }\n await next();\n}\n\n/**\n * GET /auth/google - Redirect to Google OAuth\n */\nauthRouter.get(\"/google\", async (c) => {\n const clientId = Deno.env.get(\"GOOGLE_CLIENT_ID\");\n if (!clientId) {\n return c.json({ error: \"Configuration error\", message: \"Google OAuth not configured\" }, 500);\n }\n\n // Get the callback URL from the request\n const requestUrl = new URL(c.req.url);\n const redirectUri = `${requestUrl.protocol}//${requestUrl.host}/auth/callback`;\n \n // Store redirect URI in blob for callback to use\n const state = generateSessionToken();\n await blob.setJSON(`loki_oauth_state_${state}`, {\n redirect_uri: redirectUri,\n expires_at: Date.now() + 10 * 60 * 1000, // 10 minutes\n });\n\n const authUrl = new URL(\"https://accounts.google.com/o/oauth2/v2/auth\");\n authUrl.searchParams.set(\"client_id\", clientId);\n authUrl.searchParams.set(\"redirect_uri\", redirectUri);\n authUrl.searchParams.set(\"response_type\", \"code\");\n authUrl.searchParams.set(\"scope\", \"openid email profile\");\n authUrl.searchParams.set(\"state\", state);\n authUrl.searchParams.set(\"access_type\", \"offline\");\n authUrl.searchParams.set(\"prompt\", \"consent\");\n\n return c.redirect(authUrl.toString());\n});\n\n/**\n * GET /auth/callback - Handle Google OAuth callback\n */\nauthRouter.get(\"/callback\", async (c) => {\n const code = c.req.query(\"code\");\n const state = c.req.query(\"state\");\n const error = c.req.query(\"error\");\n\n if (error) {\n return c.json({ error: \"OAuth error\", message: error }, 400);\n }\n\n if (!code || !state) {\n return c.json({ error: \"Invalid request\", message: \"Missing code or state\" }, 400);\n }\n\n // Verify state\n let stateData: { redirect_uri: string; expires_at: number } | null = null;\n try {\n stateData = await blob.getJSON(`loki_oauth_state_${state}`);\n await blob.delete(`loki_oauth_state_${state}`);\n } catch {\n // State not found\n }\n\n if (!stateData || stateData.expires_at < Date.now()) {\n return c.json({ error: \"Invalid state\", message: \"OAuth state expired or invalid\" }, 400);\n }\n\n const clientId = Deno.env.get(\"GOOGLE_CLIENT_ID\");\n const clientSecret = Deno.env.get(\"GOOGLE_CLIENT_SECRET\");\n\n if (!clientId || !clientSecret) {\n return c.json({ error: \"Configuration error\", message: \"Google OAuth not configured\" }, 500);\n }\n\n try {\n // Exchange code for tokens\n const tokenResponse = await fetch(\"https://oauth2.googleapis.com/token\", {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/x-www-form-urlencoded\" },\n body: new URLSearchParams({\n code,\n client_id: clientId,\n client_secret: clientSecret,\n redirect_uri: stateData.redirect_uri,\n grant_type: \"authorization_code\",\n }),\n });\n\n if (!tokenResponse.ok) {\n const errorData = await tokenResponse.text();\n console.error(\"Token exchange failed:\", errorData);\n return c.json({ error: \"OAuth error\", message: \"Failed to exchange code for tokens\" }, 400);\n }\n\n const tokens = await tokenResponse.json();\n\n // Get user info\n const userInfoResponse = await fetch(\"https://www.googleapis.com/oauth2/v3/userinfo\", {\n headers: { Authorization: `Bearer ${tokens.access_token}` },\n });\n\n if (!userInfoResponse.ok) {\n return c.json({ error: \"OAuth error\", message: \"Failed to get user info\" }, 400);\n }\n\n const googleProfile = await userInfoResponse.json();\n\n // Get or create user\n const user = await getOrCreateUser(googleProfile);\n\n // Create session\n const session = await createSession(user.id);\n\n // Set session cookie\n setCookie(c, \"loki_session\", session.token, {\n httpOnly: true,\n secure: true,\n sameSite: \"Lax\",\n maxAge: SESSION_EXPIRY_MS / 1000,\n path: \"/\",\n });\n\n // Redirect to app home\n return c.redirect(\"/\");\n } catch (err) {\n console.error(\"OAuth callback error:\", err);\n return c.json({ error: \"OAuth error\", message: \"Authentication failed\" }, 500);\n }\n});\n\n/**\n * GET /auth/me - Get current user\n */\nauthRouter.get(\"/me\", async (c) => {\n const user = c.get(\"user\");\n if (!user || !user.id) {\n return c.json({ user: null, groups: [] });\n }\n\n // Get user's groups\n const groupsResult = await sqlite.execute({\n sql: `\n SELECT g.*, gm.role \n FROM ${TABLE_PREFIX}groups g\n JOIN ${TABLE_PREFIX}group_members gm ON g.id = gm.group_id\n WHERE gm.user_id = ?\n `,\n args: [user.id],\n });\n\n const groups = groupsResult.rows.map(row => ({\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 role: row.role as string,\n }));\n\n return c.json({ user, groups });\n});\n\n/**\n * POST /auth/logout - Log out current user\n */\nauthRouter.post(\"/logout\", async (c) => {\n const sessionToken = getCookie(c, \"loki_session\");\n \n if (sessionToken) {\n await deleteSession(sessionToken);\n }\n \n deleteCookie(c, \"loki_session\", { path: \"/\" });\n \n return c.json({ success: true });\n});\n\nexport { getUserById, getSession };\n",[],[295,548],["D",1769136718999],[313,314,315,316,317,318,319,320,321],[295],["D",1750371724044],{"_97":96,"_104":100},{"_97":96,"_98":-5,"_99":100,"_18":55,"_101":102,"_103":25},{"_13":86,"_32":87,"_44":43,"_88":45,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":46,"_95":96},"ctx",{"_79":-5,"_124":595,"_596":597,"_598":599,"_600":25,"_601":25,"_602":25,"_603":59,"_604":-5,"_605":-7,"_606":-7,"_607":63,"_608":25,"_609":25,"_610":-5,"_611":25,"_612":25,"_613":25,"_614":-5},"ENV",{"_566":567,"_568":569,"_570":87,"_571":572,"_573":574,"_575":576,"_577":578,"_579":580,"_581":582,"_583":584,"_585":586,"_587":588,"_589":590,"_591":592,"_593":594},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Diff · v320