[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_473":474,"_475":476},"routes/_app.x.$handle.$name",{"_95":94,"_31":44,"_103":85,"_26":104,"_13":14,"_105":-5,"_11":106,"_107":108,"_109":110,"_111":112,"_113":114,"_20":-5,"_115":-5,"_116":-5,"_117":24,"_118":119,"_120":57,"_121":-5,"_122":-5,"_123":124},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_42":43,"_31":44,"_37":45,"_46":-5,"_47":24,"_48":49,"_50":49,"_51":-5,"_52":-5,"_18":53,"_54":55,"_56":57,"_58":57,"_59":-5,"_60":61,"_62":63,"_64":-5,"_65":-5,"_66":-5,"_67":-5,"_68":69,"_70":69,"_71":72,"_73":72,"_74":72,"_75":69,"_76":69,"_77":78,"_79":80,"_81":82,"_83":24},"version",305,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":-7,"_23":24,"_25":24,"_26":27,"_28":27},"file",{"_29":30,"_31":32,"_33":34,"_35":36,"_37":38,"_39":14,"_40":41,"_23":24},"previous","deleted",false,"deletedHere","path","backend/preferences.ts","latestPath","fileId","7d7caa38-f806-11f0-a6eb-42dde27851f2","name","preferences.ts","fileType","script","content","/**\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","createdAt",["D",1769136720405],"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",{"_95":94,"_102":98},"org",{"_95":94,"_96":-5,"_97":98,"_18":53,"_99":100,"_101":24},"branch",{"_13":84,"_31":85,"_42":41,"_86":43,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":44,"_93":94},"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",{"_42":43,"_31":44,"_37":469,"_46":-5,"_47":24,"_48":49,"_50":49,"_51":-5,"_52":-5,"_18":53,"_54":55,"_56":57,"_58":57,"_59":-5,"_60":61,"_62":63,"_64":-5,"_65":-5,"_66":-5,"_67":-5,"_68":69,"_70":69,"_71":72,"_73":72,"_74":72,"_75":69,"_76":69,"_77":470,"_79":471,"_81":472,"_83":24},"tree",[294,301,308,309,310,311,312,313,314,315,316,317,318,319,320,321,322,323],"files",[294,295,296,297,298,299,300,301,302,303,304,305,306,307,308,309,310,311,312,313,314,315,316,317,318,319,320,321,322,323],"counts",{"_282":61,"_283":284,"_285":61,"_286":287,"_288":289},"contents",[127,128,129,130,131,132,133,134,135,136,137,138,139,140,141,142,143,144],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{"_125":126},"7db1ceb6-f806-11f0-810f-42dde27851f2","loki.shapedlines.com",{"_42":276,"_31":277,"_29":278,"_148":-5,"_40":41,"_39":279,"_150":57,"_37":280,"_13":61,"_33":262,"_35":-5,"_23":24,"_155":-5,"_26":281},{"_42":270,"_31":271,"_29":272,"_148":-5,"_40":41,"_39":273,"_150":57,"_37":274,"_13":61,"_33":262,"_35":-5,"_23":24,"_155":-5,"_26":275},{"_42":264,"_31":265,"_29":266,"_148":-5,"_40":41,"_39":267,"_150":57,"_37":268,"_13":61,"_33":262,"_35":-5,"_23":24,"_155":-5,"_26":269},{"_42":257,"_31":258,"_29":259,"_148":-5,"_40":41,"_39":260,"_150":57,"_37":261,"_13":61,"_33":262,"_35":-5,"_23":24,"_155":-5,"_26":263},{"_42":250,"_31":251,"_29":252,"_148":-5,"_40":41,"_39":253,"_150":57,"_37":254,"_13":61,"_33":20,"_35":255,"_23":24,"_155":-5,"_26":256},{"_42":241,"_31":242,"_29":243,"_148":-5,"_40":41,"_39":244,"_150":57,"_37":245,"_13":246,"_33":247,"_35":248,"_23":24,"_155":-5,"_26":249},{"_42":235,"_31":236,"_29":55,"_148":-5,"_40":41,"_39":237,"_150":57,"_37":238,"_13":170,"_33":171,"_35":239,"_23":24,"_155":-5,"_26":240},{"_42":227,"_31":228,"_29":229,"_148":-5,"_40":41,"_39":230,"_150":57,"_37":231,"_13":232,"_33":153,"_35":233,"_23":24,"_155":-5,"_26":234},{"_42":220,"_31":221,"_29":222,"_148":-5,"_40":41,"_39":223,"_150":57,"_37":224,"_13":61,"_33":20,"_35":225,"_23":24,"_155":-5,"_26":226},{"_42":212,"_31":213,"_29":214,"_148":-5,"_40":41,"_39":215,"_150":57,"_37":216,"_13":217,"_33":171,"_35":218,"_23":24,"_155":-5,"_26":219},{"_42":205,"_31":206,"_29":207,"_148":-5,"_40":41,"_39":208,"_150":57,"_37":209,"_13":179,"_33":171,"_35":210,"_23":24,"_155":-5,"_26":211},{"_42":197,"_31":198,"_29":199,"_148":-5,"_40":41,"_39":200,"_150":24,"_37":201,"_13":202,"_33":171,"_35":203,"_23":24,"_155":-5,"_26":204},{"_42":190,"_31":191,"_29":192,"_148":-5,"_40":41,"_39":193,"_150":24,"_37":194,"_13":179,"_33":171,"_35":195,"_23":24,"_155":-5,"_26":196},{"_42":182,"_31":183,"_29":184,"_148":-5,"_40":41,"_39":185,"_150":24,"_37":186,"_13":187,"_33":34,"_35":188,"_23":24,"_155":-5,"_26":189},{"_42":174,"_31":175,"_29":176,"_148":-5,"_40":41,"_39":177,"_150":57,"_37":178,"_13":179,"_33":171,"_35":180,"_23":24,"_155":-5,"_26":181},{"_42":165,"_31":166,"_29":167,"_148":-5,"_40":41,"_39":168,"_150":57,"_37":169,"_13":170,"_33":171,"_35":172,"_23":24,"_155":-5,"_26":173},{"_42":157,"_31":158,"_29":159,"_148":-5,"_40":41,"_39":160,"_150":57,"_37":161,"_13":162,"_33":34,"_35":163,"_23":24,"_155":-5,"_26":164},{"_42":145,"_31":146,"_29":147,"_148":-5,"_40":41,"_39":149,"_150":24,"_37":151,"_13":152,"_33":153,"_35":154,"_23":24,"_155":-5,"_26":156},"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",[146],"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);",[158],"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}",[166],"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;",[175],"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// );",[183],"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}",[191],"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}",[198],"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}",[206],"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}",[213],"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}",[221],"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}",[228],"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}",[236],"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}",[242],"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```",[251],"7c93ddbc-f806-11f0-be4c-42dde27851f2","shared","7c93de8e-f806-11f0-be4c-42dde27851f2",291,["D",1769136719198],"directory",[258],"7cb32172-f806-11f0-a6eb-42dde27851f2","scrapers","7cb32212-f806-11f0-a6eb-42dde27851f2",292,["D",1769136719402],[265],"7c5ad03a-f806-11f0-a87d-42dde27851f2","frontend","7c5ad102-f806-11f0-a87d-42dde27851f2",289,["D",1769136718806],[271],"7c7592c6-f806-11f0-be4c-42dde27851f2","backend","7c759398-f806-11f0-be4c-42dde27851f2",290,["D",1769136718999],[277],"pulls","branches",2,"forks","envVars",{"_290":292,"_293":61},"connections",{"_290":61,"_291":61},"count","unfilledCount",6,"emptyCount",{"_42":276,"_31":277,"_29":278,"_148":-5,"_40":41,"_39":279,"_150":57,"_37":466,"_13":61,"_33":262,"_35":-5,"_23":24,"_155":-5,"_325":467,"_26":468},{"_42":458,"_31":459,"_29":460,"_148":278,"_40":41,"_39":461,"_150":24,"_37":462,"_13":61,"_33":34,"_35":463,"_23":24,"_155":-5,"_325":464,"_26":465},{"_42":450,"_31":451,"_29":452,"_148":278,"_40":41,"_39":453,"_150":24,"_37":454,"_13":61,"_33":34,"_35":455,"_23":24,"_155":-5,"_325":456,"_26":457},{"_42":442,"_31":443,"_29":444,"_148":278,"_40":41,"_39":445,"_150":24,"_37":446,"_13":61,"_33":34,"_35":447,"_23":24,"_155":-5,"_325":448,"_26":449},{"_42":434,"_31":435,"_29":436,"_148":278,"_40":41,"_39":437,"_150":57,"_37":438,"_13":61,"_33":34,"_35":439,"_23":24,"_155":-5,"_325":440,"_26":441},{"_42":426,"_31":427,"_29":428,"_148":278,"_40":41,"_39":429,"_150":24,"_37":430,"_13":61,"_33":34,"_35":431,"_23":24,"_155":-5,"_325":432,"_26":433},{"_42":422,"_31":32,"_29":30,"_148":278,"_40":41,"_39":14,"_150":24,"_37":423,"_13":61,"_33":34,"_35":36,"_23":24,"_155":-5,"_325":424,"_26":425},{"_42":270,"_31":271,"_29":272,"_148":-5,"_40":41,"_39":273,"_150":57,"_37":419,"_13":61,"_33":262,"_35":-5,"_23":24,"_155":-5,"_325":420,"_26":421},{"_42":414,"_31":413,"_29":407,"_148":272,"_40":41,"_39":415,"_150":57,"_37":416,"_13":61,"_33":262,"_35":-5,"_23":24,"_155":-5,"_325":417,"_26":418},{"_42":404,"_31":405,"_29":406,"_148":407,"_40":41,"_39":408,"_150":57,"_37":409,"_13":61,"_33":34,"_35":410,"_23":24,"_155":-5,"_325":411,"_26":412},{"_42":399,"_31":398,"_29":392,"_148":272,"_40":41,"_39":400,"_150":57,"_37":401,"_13":61,"_33":262,"_35":-5,"_23":24,"_155":-5,"_325":402,"_26":403},{"_42":389,"_31":390,"_29":391,"_148":392,"_40":41,"_39":393,"_150":57,"_37":394,"_13":61,"_33":34,"_35":395,"_23":24,"_155":-5,"_325":396,"_26":397},{"_42":381,"_31":382,"_29":383,"_148":272,"_40":41,"_39":384,"_150":24,"_37":385,"_13":61,"_33":34,"_35":386,"_23":24,"_155":-5,"_325":387,"_26":388},{"_42":373,"_31":374,"_29":375,"_148":272,"_40":41,"_39":376,"_150":57,"_37":377,"_13":61,"_33":20,"_35":378,"_23":24,"_155":-5,"_325":379,"_26":380},{"_42":264,"_31":265,"_29":266,"_148":-5,"_40":41,"_39":267,"_150":57,"_37":370,"_13":61,"_33":262,"_35":-5,"_23":24,"_155":-5,"_325":371,"_26":372},{"_42":257,"_31":258,"_29":259,"_148":-5,"_40":41,"_39":260,"_150":57,"_37":367,"_13":61,"_33":262,"_35":-5,"_23":24,"_155":-5,"_325":368,"_26":369},{"_42":250,"_31":251,"_29":252,"_148":-5,"_40":41,"_39":253,"_150":57,"_37":364,"_13":61,"_33":20,"_35":255,"_23":24,"_155":-5,"_325":365,"_26":366},{"_42":241,"_31":242,"_29":243,"_148":-5,"_40":41,"_39":244,"_150":57,"_37":361,"_13":246,"_33":247,"_35":248,"_23":24,"_155":-5,"_325":362,"_26":363},{"_42":235,"_31":236,"_29":55,"_148":-5,"_40":41,"_39":237,"_150":57,"_37":358,"_13":170,"_33":171,"_35":239,"_23":24,"_155":-5,"_325":359,"_26":360},{"_42":227,"_31":228,"_29":229,"_148":-5,"_40":41,"_39":230,"_150":57,"_37":355,"_13":232,"_33":153,"_35":233,"_23":24,"_155":-5,"_325":356,"_26":357},{"_42":220,"_31":221,"_29":222,"_148":-5,"_40":41,"_39":223,"_150":57,"_37":352,"_13":61,"_33":20,"_35":225,"_23":24,"_155":-5,"_325":353,"_26":354},{"_42":212,"_31":213,"_29":214,"_148":-5,"_40":41,"_39":215,"_150":57,"_37":349,"_13":217,"_33":171,"_35":218,"_23":24,"_155":-5,"_325":350,"_26":351},{"_42":205,"_31":206,"_29":207,"_148":-5,"_40":41,"_39":208,"_150":57,"_37":346,"_13":179,"_33":171,"_35":210,"_23":24,"_155":-5,"_325":347,"_26":348},{"_42":197,"_31":198,"_29":199,"_148":-5,"_40":41,"_39":200,"_150":24,"_37":343,"_13":202,"_33":171,"_35":203,"_23":24,"_155":-5,"_325":344,"_26":345},{"_42":190,"_31":191,"_29":192,"_148":-5,"_40":41,"_39":193,"_150":24,"_37":340,"_13":179,"_33":171,"_35":195,"_23":24,"_155":-5,"_325":341,"_26":342},{"_42":182,"_31":183,"_29":184,"_148":-5,"_40":41,"_39":185,"_150":24,"_37":337,"_13":187,"_33":34,"_35":188,"_23":24,"_155":-5,"_325":338,"_26":339},{"_42":174,"_31":175,"_29":176,"_148":-5,"_40":41,"_39":177,"_150":57,"_37":334,"_13":179,"_33":171,"_35":180,"_23":24,"_155":-5,"_325":335,"_26":336},{"_42":165,"_31":166,"_29":167,"_148":-5,"_40":41,"_39":168,"_150":57,"_37":331,"_13":170,"_33":171,"_35":172,"_23":24,"_155":-5,"_325":332,"_26":333},{"_42":157,"_31":158,"_29":159,"_148":-5,"_40":41,"_39":160,"_150":57,"_37":328,"_13":162,"_33":34,"_35":163,"_23":24,"_155":-5,"_325":329,"_26":330},{"_42":145,"_31":146,"_29":147,"_148":-5,"_40":41,"_39":149,"_150":24,"_37":324,"_13":152,"_33":153,"_35":154,"_23":24,"_155":-5,"_325":326,"_26":327},["D",1753241163437],"children",[],[146],["D",1753241050560],[],[158],["D",1751662988511],[],[166],["D",1750373211745],[],[175],["D",1753241636242],[],[183],["D",1751662575537],[],[191],["D",1753241087758],[],[198],["D",1750372113364],[],[206],["D",1750373092242],[],[213],["D",1769136720207],[],[221],["D",1751693610646],[],[228],["D",1750372552890],[],[236],["D",1759081605407],[],[242],["D",1751662682583],[],[251],["D",1769136719198],[],[258],["D",1769136719402],[],[265],"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",[],[271,374],"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",[],[271,382],"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",[],[271,398,390],"views","7cf069a6-f806-11f0-810f-42dde27851f2",294,["D",1769136719805],[305],[271,398],"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",[],[271,413,405],"components","7cd0ed4c-f806-11f0-be4c-42dde27851f2",293,["D",1769136719599],[303],[271,413],["D",1769136718806],[302,304,306,307],[271],"7d7ca970-f806-11f0-a6eb-42dde27851f2",["D",1769136720405],[],[277,32],"7d2c9b92-f806-11f0-810f-42dde27851f2","notifications.ts","7d2c9c82-f806-11f0-810f-42dde27851f2",298,["D",1769136720200],"/**\n * Notifications module for Loki\n * Handles email notifications for listings, reminders, and group interactions\n */\n\nimport { email } from \"https://esm.town/v/std/email?v=13\";\nimport { sqlite } from \"https://esm.town/v/std/sqlite\";\nimport type { User, Listing, Group, Reminder } from \"../shared/types.ts\";\n\nconst TABLE_PREFIX = \"loki_\";\n\n// Email templates\ninterface EmailTemplate {\n subject: string;\n text: string;\n html: string;\n}\n\n/**\n * Get users who want a specific notification type for a group\n */\nasync function getNotificationRecipients(\n groupId: string,\n notificationType: \"notify_new_listing\" | \"notify_comment_request\" | \"notify_apply_reminder\"\n): Promise<{ userId: string; email: string; name: string | null }[]> {\n const result = await sqlite.execute({\n sql: `\n SELECT u.id, u.email, u.name\n FROM ${TABLE_PREFIX}users u\n JOIN ${TABLE_PREFIX}group_members gm ON u.id = gm.user_id\n LEFT JOIN ${TABLE_PREFIX}notification_prefs np ON u.id = np.user_id\n WHERE gm.group_id = ?\n AND (np.${notificationType} = 1 OR np.${notificationType} IS NULL)\n `,\n args: [groupId],\n });\n\n return result.rows.map(row => ({\n userId: row.id as string,\n email: row.email as string,\n name: row.name as string | null,\n }));\n}\n\n/**\n * Get group details\n */\nasync function getGroup(groupId: string): Promise {\n const result = await sqlite.execute({\n sql: `SELECT * FROM ${TABLE_PREFIX}groups WHERE id = ?`,\n args: [groupId],\n });\n\n if (result.rows.length === 0) return null;\n\n const row = result.rows[0];\n return {\n id: row.id as string,\n name: row.name as string,\n created_by: row.created_by as string,\n invite_code: row.invite_code as string,\n created_at: row.created_at as number,\n };\n}\n\n/**\n * Generate new listings digest email\n */\nfunction generateNewListingsDigest(\n groupName: string,\n listings: Listing[],\n baseUrl: string\n): EmailTemplate {\n const listingRows = listings.map(l => `\n \n \n \n ${l.address_original}\n \n ${l.unit_number ? ` Unit ${l.unit_number}` : \"\"}\n \n \n ${l.price ? `$${l.price.toLocaleString()}` : \"N/A\"}\n \n \n ${l.beds ?? \"-\"} bed / ${l.baths ?? \"-\"} bath\n \n \n `).join(\"\");\n\n const textListings = listings.map(l => \n `- ${l.address_original}: ${l.price ? `$${l.price}` : \"N/A\"} - ${l.beds ?? \"?\"} bed / ${l.baths ?? \"?\"} bath`\n ).join(\"\\n\");\n\n return {\n subject: `[Loki] ${listings.length} new listing${listings.length > 1 ? \"s\" : \"\"} for ${groupName}`,\n text: `\nNew listings found for ${groupName}!\n\n${textListings}\n\nView all listings: ${baseUrl}\n `.trim(),\n html: `\n\n\n\n \n \n\n\n

Loki

\n \n

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

For ${groupName}

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

Address	Price	Details

\n \n

\n \n View All Listings\n \n

\n \n

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

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

Loki

\n \n

Feedback Requested

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

\n \n

${listing.address_original}

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

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

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

Reminder

\n \n

Time to Apply!

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

\n \n

${listing.address_original}

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

\n ${message ? `

\"${message}\"

` : \"\"}\n

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

\n\n\n `.trim(),\n };\n}\n\n/**\n * Send new listings notification to a group\n */\nexport async function sendNewListingsNotification(\n groupId: string,\n listings: Listing[],\n baseUrl: string = \"https://your-app.val.run\"\n): Promise<{ sent: number; errors: number }> {\n if (listings.length === 0) {\n return { sent: 0, errors: 0 };\n }\n\n const group = await getGroup(groupId);\n if (!group) {\n console.error(\"Group not found:\", groupId);\n return { sent: 0, errors: 1 };\n }\n\n const recipients = await getNotificationRecipients(groupId, \"notify_new_listing\");\n if (recipients.length === 0) {\n console.log(\"No recipients for new listings notification\");\n return { sent: 0, errors: 0 };\n }\n\n const template = generateNewListingsDigest(group.name, listings, baseUrl);\n let sent = 0;\n let errors = 0;\n\n for (const recipient of recipients) {\n try {\n await email({\n to: [recipient.email],\n subject: template.subject,\n text: template.text,\n html: template.html,\n });\n sent++;\n } catch (err) {\n console.error(\"Failed to send email to\", recipient.email, err);\n errors++;\n }\n }\n\n return { sent, errors };\n}\n\n/**\n * Send comment request notification\n */\nexport async function sendCommentRequestNotification(\n groupId: string,\n listing: Listing,\n requestingUserId: string,\n baseUrl: string = \"https://your-app.val.run\"\n): Promise<{ sent: number; errors: number }> {\n const group = await getGroup(groupId);\n if (!group) {\n return { sent: 0, errors: 1 };\n }\n\n // Get requesting user's name\n const userResult = await sqlite.execute({\n sql: `SELECT name, email FROM ${TABLE_PREFIX}users WHERE id = ?`,\n args: [requestingUserId],\n });\n const requestingUser = userResult.rows[0]?.name || userResult.rows[0]?.email || \"A group member\";\n\n // Get recipients (excluding the requesting user)\n const recipients = (await getNotificationRecipients(groupId, \"notify_comment_request\"))\n .filter(r => r.userId !== requestingUserId);\n\n if (recipients.length === 0) {\n return { sent: 0, errors: 0 };\n }\n\n const template = generateCommentRequest(group.name, listing, requestingUser as string, baseUrl);\n let sent = 0;\n let errors = 0;\n\n for (const recipient of recipients) {\n try {\n await email({\n to: [recipient.email],\n subject: template.subject,\n text: template.text,\n html: template.html,\n });\n sent++;\n } catch (err) {\n console.error(\"Failed to send email to\", recipient.email, err);\n errors++;\n }\n }\n\n return { sent, errors };\n}\n\n/**\n * Process and send due reminders\n */\nexport async function processDueReminders(): Promise<{ processed: number; sent: number; errors: number }> {\n const now = Math.floor(Date.now() / 1000);\n\n // Get due reminders\n const remindersResult = await sqlite.execute({\n sql: `\n SELECT r.*, l.address_original, l.price, l.beds, l.baths, g.name as group_name\n FROM ${TABLE_PREFIX}reminders r\n JOIN ${TABLE_PREFIX}listings l ON r.listing_id = l.id\n JOIN ${TABLE_PREFIX}groups g ON r.group_id = g.id\n WHERE r.is_sent = 0 AND r.remind_at <= ?\n `,\n args: [now],\n });\n\n let processed = 0;\n let sent = 0;\n let errors = 0;\n\n for (const row of remindersResult.rows) {\n processed++;\n\n // Get user email\n const userResult = await sqlite.execute({\n sql: `SELECT email FROM ${TABLE_PREFIX}users WHERE id = ?`,\n args: [row.created_by],\n });\n\n if (userResult.rows.length === 0) continue;\n\n const listing: Listing = {\n id: row.listing_id as string,\n address_original: row.address_original as string,\n address_normalized: \"\",\n unit_number: null,\n lat: null,\n lng: null,\n beds: row.beds as number | null,\n baths: row.baths as number | null,\n price: row.price as number | null,\n availability: null,\n neighborhood: null,\n first_seen_at: 0,\n last_updated_at: 0,\n is_active: true,\n };\n\n const template = generateApplyReminder(\n row.group_name as string,\n listing,\n row.message as string | null,\n \"https://your-app.val.run\"\n );\n\n try {\n await email({\n to: [userResult.rows[0].email as string],\n subject: template.subject,\n text: template.text,\n html: template.html,\n });\n\n // Mark as sent\n await sqlite.execute({\n sql: `UPDATE ${TABLE_PREFIX}reminders SET is_sent = 1 WHERE id = ?`,\n args: [row.id],\n });\n\n sent++;\n } catch (err) {\n console.error(\"Failed to send reminder:\", err);\n errors++;\n }\n }\n\n return { processed, sent, errors };\n}\n\n/**\n * Create a reminder for a listing\n */\nexport async function createReminder(\n listingId: string,\n groupId: string,\n userId: string,\n remindAt: number,\n message?: string\n): Promise {\n const id = `${Date.now()}-${Math.random().toString(36).substring(2, 15)}`;\n const now = Math.floor(Date.now() / 1000);\n\n await sqlite.execute({\n sql: `\n INSERT INTO ${TABLE_PREFIX}reminders \n (id, listing_id, group_id, created_by, remind_at, message, is_sent, created_at)\n VALUES (?, ?, ?, ?, ?, ?, 0, ?)\n `,\n args: [id, listingId, groupId, userId, remindAt, message || null, now],\n });\n\n return id;\n}\n\nexport { getNotificationRecipients, getGroup };\n",[],[277,427],"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",[],[277,435],"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",[],[277,443],"7d41f244-f806-11f0-a6eb-42dde27851f2","groups.ts","7d41f302-f806-11f0-a6eb-42dde27851f2",302,["D",1769136720340],"/**\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 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",[],[277,451],"7d3c0fc8-f806-11f0-818c-42dde27851f2","dedup.ts","7d3c1054-f806-11f0-818c-42dde27851f2",301,["D",1769136720298],"/**\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",[],[277,459],["D",1769136718999],[295,296,297,298,299,300],[277],["D",1750371724044],{"_95":94,"_102":98},{"_95":94,"_96":-5,"_97":98,"_18":53,"_99":100,"_101":24},{"_13":84,"_31":85,"_42":41,"_86":43,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":44,"_93":94},"ctx",{"_77":-5,"_122":506,"_507":508,"_509":510,"_511":24,"_512":24,"_513":24,"_514":57,"_515":-5,"_516":-7,"_517":-7,"_518":61,"_519":24,"_520":24,"_521":-5,"_522":24,"_523":24,"_524":24,"_525":-5},"ENV",{"_477":478,"_479":480,"_481":85,"_482":483,"_484":485,"_486":487,"_488":489,"_490":491,"_492":493,"_494":495,"_496":497,"_498":499,"_500":501,"_502":503,"_504":505},"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 · v305