[{"_1":2,"_180":-5,"_181":-5},"loaderData",{"_3":4,"_93":94},"root",{"_5":6,"_36":37,"_66":67},"ctx",{"_7":8,"_23":-5,"_24":25,"_26":27,"_28":20,"_29":20,"_30":20,"_31":-5,"_32":33,"_34":20,"_35":20},"auth",{"_9":-5,"_10":-5,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":20,"_21":22},"sessionClaims","sessionId","sessionStatus","userId","actor","orgId","orgRole","orgSlug","orgPermissions","factorVerificationAge","isAuthenticated",false,"tokenType","session_token","user","preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesChatPanelState","notificationCount",0,"flagDenols","isTeamOrgMember","ENV",{"_38":39,"_40":41,"_42":43,"_44":45,"_46":47,"_48":49,"_50":51,"_52":53,"_54":55,"_56":57,"_58":59,"_60":61,"_62":63,"_64":65},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","VAL_RUNTIME_NAME","prod","RENDER_GIT_COMMIT","1f1a009cadcf7353a37b999b92a7f8af633192ea","RENDER_GIT_BRANCH","main","CLERK_PUBLISHABLE_KEY","pk_live_Y2xlcmsudmFsLnRvd24k","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","API_URL","https://api.val.town","clerkState",{"_68":69},"__internal_clerk_state",{"_70":71,"_72":47,"_73":74,"_75":74,"_76":20,"_77":74,"_78":74,"_79":74,"_80":74,"_81":82,"_91":20,"_92":20},"__clerk_ssr_state",{"_21":22,"_9":-5,"_10":-5,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":20},"__publishableKey","__proxyUrl","","__domain","__isSatellite","__signInUrl","__signUpUrl","__afterSignInUrl","__afterSignUpUrl","__clerk_debug",{"_83":20,"_19":20,"_84":74,"_85":86,"_87":74,"_88":47,"_89":20,"_90":74},"isSignedIn","proxyUrl","reason","session-token-and-uat-missing","message","publishableKey","isSatellite","domain","__telemetryDisabled","__telemetryDebug","routes/embed.x.$handle.$name.$",{"_95":96,"_97":98,"_99":100,"_101":102,"_155":156,"_177":178,"_179":-5},"handle","shapedlines","name","loki","path","backend/listings.ts","project",{"_103":104,"_97":98,"_105":106,"_107":-5,"_108":20,"_109":110,"_111":-5,"_112":-5,"_12":113,"_114":115,"_116":117,"_118":117,"_119":-5,"_120":33,"_14":121,"_122":-5,"_123":-5,"_124":125,"_126":125,"_127":128,"_129":128,"_130":128,"_131":125,"_132":125,"_23":133,"_136":137,"_141":142,"_154":20},"id","d3df2ae6-4d5b-11f0-b336-76b3cceeab13","createdAt",["D",1750371724044],"deletedAt","legacyEnvVars","privacy","public","description","imageUrl","7ed186b0-c78a-4757-a5b0-12c00ac89afa","pinnedFileId","9cf06f84-4d5d-11f0-a672-76b3cceeab13","pinPreview",true,"pinMigrated","screenshotVersion","likeCount","e9195859-3c6b-4b40-bb3e-c11844477fdf","tursoName","tursoHostname","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm",{"_95":96,"_134":135},"profileImageUrl","https://img.clerk.com/eyJ0eXBlIjoicHJveHkiLCJzcmMiOiJodHRwczovL2ltYWdlcy5jbGVyay5kZXYvb2F1dGhfZ2l0aHViL2ltZ18yYlc2Q1A2eUFyNEdDeXBud0E0bFJyWlJVUzQifQ","org",{"_95":96,"_138":135,"_12":113,"_139":140},"avatar","tier","free","branch",{"_143":144,"_97":45,"_103":145,"_146":104,"_147":-5,"_148":-5,"_149":-5,"_150":-5,"_151":-5,"_152":98,"_153":96},"version",336,"d3df7564-4d5b-11f0-b336-76b3cceeab13","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","isOwned","file",{"_103":157,"_97":158,"_159":160,"_161":162,"_163":145,"_164":165,"_166":117,"_105":167,"_143":168,"_169":170,"_171":172,"_173":20,"_174":-5,"_99":175},"2906b8b2-f80c-11f0-a19d-42dde27851f2","listings.ts","fileId","7d7503fa-f806-11f0-9cf9-42dde27851f2","parentId","7c759398-f806-11f0-be4c-42dde27851f2","branchId","branchVersion",323,"latest",["D",1769139155999],1,"fileType","script","content","/**\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\";\nimport { rowToObject, rowsToObjects } from \"./db-utils.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 id, listing_id, platform, url, raw_address, first_seen_at, last_seen_at FROM ${TABLE_PREFIX}listing_sources WHERE listing_id = ? ORDER BY first_seen_at ASC`,\n args: [listingId],\n });\n\n type SourceRow = { id: string; listing_id: string; platform: string; url: string; raw_address: string | null; first_seen_at: number; last_seen_at: number };\n const rows = rowsToObjects(result.rows as (unknown[] | Record)[], result.columns);\n\n return rows.map(row => ({\n id: row.id,\n listing_id: row.listing_id,\n platform: row.platform as \"zillow\" | \"craigslist\",\n url: row.url,\n raw_address: row.raw_address,\n first_seen_at: row.first_seen_at,\n last_seen_at: row.last_seen_at,\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 listing_id, group_id, status, is_liked, notes, custom_links, updated_by, updated_at 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 type InteractionRow = { listing_id: string; group_id: string; status: string; is_liked: number; notes: string | null; custom_links: string | null; updated_by: string | null; updated_at: number };\n const row = rowToObject(result.rows[0] as unknown[] | Record, result.columns);\n\n let customLinks: string[] | null = null;\n if (row.custom_links) {\n try {\n customLinks = JSON.parse(row.custom_links);\n } catch {\n customLinks = null;\n }\n }\n\n return {\n listing_id: row.listing_id,\n group_id: row.group_id,\n status: row.status as ListingStatus,\n is_liked: Boolean(row.is_liked),\n notes: row.notes,\n custom_links: customLinks,\n updated_by: row.updated_by,\n updated_at: row.updated_at,\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.preference_id, lt.duration_minutes, 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 type TransitRow = { preference_id: string; duration_minutes: number | null; preference_name: string; travel_mode: string };\n const rows = rowsToObjects(result.rows as (unknown[] | Record)[], result.columns);\n\n return rows.map(row => ({\n preference_id: row.preference_id,\n preference_name: row.preference_name,\n duration_minutes: row.duration_minutes,\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// Type for raw listing row from database\ntype ListingRow = {\n id: string;\n address_original: string;\n address_normalized: string;\n unit_number: string | null;\n lat: number | null;\n lng: number | null;\n beds: number | null;\n baths: number | null;\n price: number | null;\n availability: string | null;\n neighborhood: string | null;\n first_seen_at: number;\n last_updated_at: number;\n is_active: number;\n};\n\n/**\n * Parse listing row from database\n */\nfunction parseListingRow(row: ListingRow): Listing {\n return {\n id: row.id,\n address_original: row.address_original,\n address_normalized: row.address_normalized,\n unit_number: row.unit_number,\n lat: row.lat,\n lng: row.lng,\n beds: row.beds,\n baths: row.baths,\n price: row.price,\n availability: row.availability,\n neighborhood: row.neighborhood,\n first_seen_at: row.first_seen_at,\n last_updated_at: row.last_updated_at,\n is_active: Boolean(row.is_active),\n };\n}\n\n/**\n * 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 // Convert rows to objects\n const listingRows = rowsToObjects(result.rows as (unknown[] | Record)[], result.columns);\n\n // Build full listing details\n const listings: ListingWithDetails[] = [];\n for (const row of listingRows) {\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 id, address_original, address_normalized, unit_number, lat, lng, beds, baths, price, availability, neighborhood, first_seen_at, last_updated_at, is_active FROM ${TABLE_PREFIX}listings WHERE 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 row = rowToObject(result.rows[0] as unknown[] | Record, result.columns);\n const listing = parseListingRow(row);\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 type NeighborhoodRow = { neighborhood: string };\n const rows = rowsToObjects(result.rows as (unknown[] | Record)[], result.columns);\n const neighborhoods = rows.map(row => row.neighborhood);\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 type CountRow = { count: number };\n const totalRow = rowToObject(totalResult.rows[0] as unknown[] | Record, totalResult.columns);\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 type StatusRow = { status: string; count: number };\n const statusRows = rowsToObjects(statusResult.rows as (unknown[] | Record)[], statusResult.columns);\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 const likedRow = rowToObject(likedResult.rows[0] as unknown[] | Record, likedResult.columns);\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 type PriceRow = { min_price: number | null; max_price: number | null; avg_price: number | null };\n const priceRow = rowToObject(priceResult.rows[0] as unknown[] | Record, priceResult.columns);\n\n const stats = {\n total_active: totalRow.count,\n by_status: Object.fromEntries(statusRows.map(row => [row.status, row.count])),\n liked_count: likedRow.count,\n price_range: {\n min: priceRow.min_price,\n max: priceRow.max_price,\n avg: priceRow.avg_price ? Math.round(priceRow.avg_price) : null,\n },\n };\n\n return c.json({ stats });\n});\n\nexport { getListingSources, getListingInteraction, buildListingWithDetails };\n","deleted","label",[176,158],"backend","permalink","https://www.val.town/x/shapedlines/loki/code/backend/listings.ts","extension","actionData","errors"]