[{"_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/preferences.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},"28fe27ce-f80c-11f0-a19d-42dde27851f2","preferences.ts","fileId","7d7caa38-f806-11f0-a6eb-42dde27851f2","parentId","7c759398-f806-11f0-be4c-42dde27851f2","branchId","branchVersion",322,"latest",["D",1769139155905],1,"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\";\nimport { rowToObject, rowsToObjects } from \"./db-utils.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// Type for raw transit preference row from database\ntype TransitPreferenceRow = {\n id: string;\n group_id: string;\n name: string;\n type: string;\n address: string | null;\n lat: number | null;\n lng: number | null;\n travel_mode: string;\n is_active: number;\n created_at: number;\n};\n\n/**\n * Parse transit preference row from database\n */\nfunction parseTransitPreferenceRow(row: TransitPreferenceRow): TransitPreference {\n return {\n id: row.id,\n group_id: row.group_id,\n name: row.name,\n type: row.type as TransitPreferenceType,\n address: row.address,\n lat: row.lat,\n lng: row.lng,\n travel_mode: row.travel_mode as TravelMode,\n is_active: Boolean(row.is_active),\n created_at: row.created_at,\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 id, group_id, name, type, address, lat, lng, travel_mode, is_active, created_at 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 rows = rowsToObjects(result.rows as (unknown[] | Record)[], result.columns);\n const preferences = 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 id, group_id, name, type, address, lat, lng, travel_mode, is_active, created_at 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 row = rowToObject(result.rows[0] as unknown[] | Record, result.columns);\n const preference = parseTransitPreferenceRow(row);\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 id, group_id, name, type, address, lat, lng, travel_mode, is_active, created_at FROM ${TABLE_PREFIX}transit_preferences WHERE id = ?`,\n args: [preferenceId],\n });\n\n const row = rowToObject(result.rows[0] as unknown[] | Record, result.columns);\n const preference = parseTransitPreferenceRow(row);\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 id, group_id, name, type, address, lat, lng, travel_mode, is_active, created_at 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 existingRow = rowToObject(existingResult.rows[0] as unknown[] | Record, existingResult.columns);\n const existing = parseTransitPreferenceRow(existingRow);\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 id, group_id, name, type, address, lat, lng, travel_mode, is_active, created_at FROM ${TABLE_PREFIX}transit_preferences WHERE id = ?`,\n args: [preferenceId],\n });\n\n const row = rowToObject(result.rows[0] as unknown[] | Record, result.columns);\n const preference = parseTransitPreferenceRow(row);\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 id, group_id, name, type, address, lat, lng, travel_mode, is_active, created_at 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 existingRow = rowToObject(existingResult.rows[0] as unknown[] | Record, existingResult.columns);\n const existing = parseTransitPreferenceRow(existingRow);\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// Type for notification preferences row\ntype NotificationPrefsRow = {\n user_id: string;\n notify_new_listing: number;\n notify_comment_request: number;\n notify_apply_reminder: number;\n};\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 user_id, notify_new_listing, notify_comment_request, notify_apply_reminder 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 = rowToObject(result.rows[0] as unknown[] | Record, result.columns);\n const preferences: NotificationPrefs = {\n user_id: row.user_id,\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 user_id, notify_new_listing, notify_comment_request, notify_apply_reminder FROM ${TABLE_PREFIX}notification_prefs WHERE user_id = ?`,\n args: [user.id],\n });\n\n const row = rowToObject(result.rows[0] as unknown[] | Record, result.columns);\n const preferences: NotificationPrefs = {\n user_id: row.user_id,\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 id, group_id, name, type, address, lat, lng, travel_mode, is_active, created_at 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 prefRow = rowToObject(prefResult.rows[0] as unknown[] | Record, prefResult.columns);\n const preference = parseTransitPreferenceRow(prefRow);\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 type ListingLocationRow = { lat: number | null; lng: number | null; address_original: string };\n const listing = rowToObject(listingResult.rows[0] as unknown[] | Record, listingResult.columns);\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 type PrefIdRow = { id: string };\n const prefRows = rowsToObjects(prefsResult.rows as (unknown[] | Record)[], prefsResult.columns);\n\n const results: { preference_id: string; success: boolean; duration_minutes?: number; error?: string }[] = [];\n\n // Calculate each preference\n for (const row of prefRows) {\n const preferenceId = row.id;\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","deleted","label",[176,158],"backend","permalink","https://www.val.town/x/shapedlines/loki/code/backend/preferences.ts","extension","actionData","errors"]