[{"_1":2,"_174":-5,"_175":-5},"loaderData",{"_3":4,"_91":92},"root",{"_5":6,"_34":35,"_64":65},"ctx",{"_7":8,"_23":-5,"_24":25,"_26":27,"_28":20,"_29":20,"_30":20,"_31":32,"_33":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","notificationCount",0,"flagDenols","ENV",{"_36":37,"_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},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","VAL_RUNTIME_NAME","prod","RENDER_GIT_COMMIT","ff0419d68e57d8cc3e37e5d3da688157c5dd37c6","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",{"_66":67},"__internal_clerk_state",{"_68":69,"_70":45,"_71":72,"_73":72,"_74":20,"_75":72,"_76":72,"_77":72,"_78":72,"_79":80,"_89":20,"_90":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",{"_81":20,"_19":20,"_82":72,"_83":84,"_85":72,"_86":45,"_87":20,"_88":72},"isSignedIn","proxyUrl","reason","session-token-and-uat-missing","message","publishableKey","isSatellite","domain","__telemetryDisabled","__telemetryDebug","routes/embed.x.$handle.$name.$",{"_93":94,"_95":96,"_97":98,"_99":100,"_148":149,"_171":172,"_173":-5},"handle","tijs","name","location-feed-generator","path","backend/api/anchor-api.ts","project",{"_101":102,"_95":96,"_103":104,"_105":-5,"_106":20,"_107":108,"_109":110,"_111":-5,"_12":112,"_113":-5,"_114":20,"_115":-5,"_116":117,"_14":118,"_119":120,"_121":120,"_122":123,"_124":123,"_125":123,"_126":120,"_127":120,"_23":128,"_131":132,"_134":135,"_147":20},"id","db7bc7d6-58ab-11f0-bdec-f69ea79377d9","createdAt",["D",1751615559344],"deletedAt","legacyEnvVars","privacy","public","description","This is the Anchor AppView - location based feed generator","imageUrl","14049850-28c1-11f0-89c9-c7d0e2d9e1ea","pinnedFileId","pinPreview","screenshotVersion","likeCount",1,"c04d51b2-a7dc-46ca-ad6f-52f47c2906a8","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm",{"_93":94,"_129":130},"profileImageUrl","https://img.clerk.com/eyJ0eXBlIjoicHJveHkiLCJzcmMiOiJodHRwczovL2ltYWdlcy5jbGVyay5kZXYvb2F1dGhfZ2l0aHViL2ltZ18yd2Nod2N0bE1MWFdEUlRYd083ZE5pbXJ1bDAifQ","org",{"_93":94,"_133":130},"avatar","branch",{"_136":137,"_95":43,"_101":138,"_139":102,"_140":-5,"_141":-5,"_142":-5,"_143":-5,"_144":-5,"_145":96,"_146":94},"version",1064,"db7c07aa-58ab-11f0-bdec-f69ea79377d9","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","isOwned","file",{"_101":150,"_95":151,"_152":153,"_154":155,"_156":138,"_157":137,"_158":159,"_103":160,"_136":161,"_162":163,"_164":165,"_166":20,"_167":-5,"_97":168},"10ae55f8-9147-11f0-8e02-0224a6c84d84","anchor-api.ts","fileId","d974912a-7467-11f0-81d0-0224a6c84d84","parentId","d93537e6-7467-11f0-a68b-0224a6c84d84","branchId","branchVersion","latest",true,["D",1757839485692],27,"fileType","script","content","// @val-town anchorAPI\n// Main HTTP API handler for Anchor AppView\nimport { db, initializeTables } from \"../database/db.ts\";\nimport {\n checkinsTable,\n processingLogTable,\n userFollowsTable,\n} from \"../database/schema.ts\";\nimport { and, desc, eq, inArray, lt, sql } from \"https://esm.sh/drizzle-orm\";\nimport { ATProtocolProfileResolver } from \"../utils/profile-resolver.ts\";\nimport {\n DrizzleStorageProvider,\n ProfileData,\n} from \"../utils/storage-provider.ts\";\nimport { OverpassService } from \"../services/overpass-service.ts\";\nimport { CategoryService } from \"../services/category-service.ts\";\nimport { NominatimService } from \"../services/nominatim-service.ts\";\nimport { PlacesNearbyResponse } from \"../models/place-models.ts\";\nimport { createCheckin } from \"./checkins.ts\";\nimport { getCheckinCounts, getRecentActivity } from \"../database/queries.ts\";\n\n// Types for better TypeScript support\ninterface CorsHeaders {\n \"Access-Control-Allow-Origin\": string;\n \"Access-Control-Allow-Methods\": string;\n \"Access-Control-Allow-Headers\": string;\n \"Content-Type\": string;\n [key: string]: string;\n}\n\ninterface CheckinRecord {\n id: string;\n uri: string;\n author: {\n did: string;\n handle: string;\n displayName?: string;\n avatar?: string;\n };\n text: string;\n createdAt: string;\n coordinates?: {\n latitude: number;\n longitude: number;\n };\n address?: {\n name?: string;\n street?: string;\n locality?: string;\n region?: string;\n country?: string;\n postalCode?: string;\n };\n distance?: number;\n}\n\nexport default async function (req: Request): Promise {\n const url = new URL(req.url);\n const corsHeaders: CorsHeaders = {\n \"Access-Control-Allow-Origin\": \"*\",\n \"Access-Control-Allow-Methods\": \"GET, POST, OPTIONS\",\n \"Access-Control-Allow-Headers\": \"Content-Type, Cookie\",\n \"Content-Type\": \"application/json\",\n };\n\n // Handle CORS preflight\n if (req.method === \"OPTIONS\") {\n return new Response(null, { headers: corsHeaders });\n }\n\n // Initialize database tables - let errors bubble up\n await initializeTables();\n\n // Route to appropriate handler - let errors bubble up\n switch (url.pathname) {\n case \"/api/global\":\n return await getGlobalFeed(url, corsHeaders);\n case \"/api/nearby\":\n return await getNearbyCheckins(url, corsHeaders);\n case \"/api/user\":\n return await getUserCheckins(url, corsHeaders);\n case \"/api/following\":\n return await getFollowingFeed(url, corsHeaders);\n case \"/api/places/nearby\":\n return await getNearbyPlaces(url, corsHeaders);\n case \"/api/places/search\":\n return await searchPlaces(url, corsHeaders);\n case \"/api/places/categories\":\n return getPlaceCategories(corsHeaders);\n case \"/api/stats\":\n return await getStats(corsHeaders);\n case \"/api/checkins\":\n return await handleCreateCheckin(req, corsHeaders);\n default:\n // Check for dynamic routes like /api/checkin/:id\n if (url.pathname.startsWith(\"/api/checkin/\")) {\n const checkinId = url.pathname.split(\"/api/checkin/\")[1];\n return await getCheckinById(checkinId, corsHeaders);\n }\n return new Response(JSON.stringify({ error: \"Not Found\" }), {\n status: 404,\n headers: corsHeaders,\n });\n }\n}\n\nasync function getGlobalFeed(\n url: URL,\n corsHeaders: CorsHeaders,\n): Promise {\n const limit = Math.min(parseInt(url.searchParams.get(\"limit\") || \"50\"), 100);\n const cursor = url.searchParams.get(\"cursor\");\n\n // Type-safe Drizzle query - no more field name confusion!\n const baseQuery = db.select({\n id: checkinsTable.id,\n uri: checkinsTable.uri,\n did: checkinsTable.did,\n handle: checkinsTable.handle,\n text: checkinsTable.text,\n createdAt: checkinsTable.createdAt,\n latitude: checkinsTable.latitude,\n longitude: checkinsTable.longitude,\n venueName: checkinsTable.venueName, // UNIFIED venue name field\n addressStreet: checkinsTable.addressStreet,\n addressLocality: checkinsTable.addressLocality,\n addressRegion: checkinsTable.addressRegion,\n addressCountry: checkinsTable.addressCountry,\n addressPostalCode: checkinsTable.addressPostalCode,\n }).from(checkinsTable);\n\n const rows = cursor\n ? await baseQuery\n .where(sql`${checkinsTable.createdAt} < ${cursor}`)\n .orderBy(desc(checkinsTable.createdAt))\n .limit(limit)\n : await baseQuery\n .orderBy(desc(checkinsTable.createdAt))\n .limit(limit);\n\n // Resolve profiles for all authors\n const dids = [...new Set(rows.map((row) => row.did))];\n const storage = new DrizzleStorageProvider(db); // Use Drizzle db for type safety\n const profileResolver = new ATProtocolProfileResolver(storage);\n const profiles = await profileResolver.batchResolveProfiles(dids);\n\n const checkins = await Promise.all(\n rows.map((row) => formatCheckinWithPlaces(row, profiles)),\n );\n\n return new Response(\n JSON.stringify({\n checkins,\n cursor: checkins.length > 0\n ? checkins[checkins.length - 1].createdAt\n : null,\n }),\n { headers: corsHeaders },\n );\n}\n\nasync function getNearbyCheckins(\n url: URL,\n corsHeaders: CorsHeaders,\n): Promise {\n const lat = parseFloat(url.searchParams.get(\"lat\") || \"0\");\n const lng = parseFloat(url.searchParams.get(\"lng\") || \"0\");\n const radius = Math.min(\n parseFloat(url.searchParams.get(\"radius\") || \"5\"),\n 50,\n ); // max 50km\n const limit = Math.min(parseInt(url.searchParams.get(\"limit\") || \"50\"), 100);\n\n if (!lat || !lng) {\n return new Response(\n JSON.stringify({ error: \"lat and lng parameters required\" }),\n {\n status: 400,\n headers: corsHeaders,\n },\n );\n }\n\n // Get all checkins with coordinates using type-safe Drizzle query\n const rows = await db.select({\n id: checkinsTable.id,\n uri: checkinsTable.uri,\n did: checkinsTable.did,\n handle: checkinsTable.handle,\n text: checkinsTable.text,\n createdAt: checkinsTable.createdAt,\n latitude: checkinsTable.latitude,\n longitude: checkinsTable.longitude,\n venueName: checkinsTable.venueName, // UNIFIED venue name field\n addressStreet: checkinsTable.addressStreet,\n addressLocality: checkinsTable.addressLocality,\n addressRegion: checkinsTable.addressRegion,\n addressCountry: checkinsTable.addressCountry,\n addressPostalCode: checkinsTable.addressPostalCode,\n }).from(checkinsTable)\n .where(and(\n sql`${checkinsTable.latitude} IS NOT NULL`,\n sql`${checkinsTable.longitude} IS NOT NULL`,\n ))\n .orderBy(desc(checkinsTable.createdAt))\n .limit(limit * 3); // Get more to filter by distance\n\n // Calculate distances and filter\n const nearbyRows = rows\n .map((row) => {\n const distance = calculateDistance(\n lat,\n lng,\n row.latitude as number,\n row.longitude as number,\n );\n return { ...row, distance };\n })\n .filter((row) => row.distance <= radius)\n .sort((a, b) => a.distance - b.distance)\n .slice(0, limit);\n\n // Resolve profiles for filtered results\n const dids = [\n ...new Set(nearbyRows.map((row: any) => row.did as string)),\n ];\n const storage = new DrizzleStorageProvider(db);\n const profileResolver = new ATProtocolProfileResolver(storage);\n const profiles = await profileResolver.batchResolveProfiles(dids);\n\n const nearbyCheckins = await Promise.all(\n nearbyRows.map((row) => formatCheckinWithPlaces(row, profiles)),\n );\n\n return new Response(\n JSON.stringify({\n checkins: nearbyCheckins,\n center: { latitude: lat, longitude: lng },\n radius,\n }),\n { headers: corsHeaders },\n );\n}\n\nasync function getUserCheckins(\n url: URL,\n corsHeaders: CorsHeaders,\n): Promise {\n const did = url.searchParams.get(\"did\");\n const limit = Math.min(parseInt(url.searchParams.get(\"limit\") || \"50\"), 100);\n\n if (!did) {\n return new Response(JSON.stringify({ error: \"did parameter required\" }), {\n status: 400,\n headers: corsHeaders,\n });\n }\n\n const rows = await db.select({\n id: checkinsTable.id,\n uri: checkinsTable.uri,\n did: checkinsTable.did,\n handle: checkinsTable.handle,\n text: checkinsTable.text,\n createdAt: checkinsTable.createdAt,\n latitude: checkinsTable.latitude,\n longitude: checkinsTable.longitude,\n venueName: checkinsTable.venueName, // UNIFIED venue name field\n addressStreet: checkinsTable.addressStreet,\n addressLocality: checkinsTable.addressLocality,\n addressRegion: checkinsTable.addressRegion,\n addressCountry: checkinsTable.addressCountry,\n addressPostalCode: checkinsTable.addressPostalCode,\n }).from(checkinsTable)\n .where(eq(checkinsTable.did, did))\n .orderBy(desc(checkinsTable.createdAt))\n .limit(limit);\n\n // Resolve profiles\n const dids = [...new Set(rows.map((row) => row.did))];\n const storage = new DrizzleStorageProvider(db);\n const profileResolver = new ATProtocolProfileResolver(storage);\n const profiles = await profileResolver.batchResolveProfiles(dids);\n\n const checkins = await Promise.all(\n rows.map((row) => formatCheckinWithPlaces(row, profiles)),\n );\n\n // Get user info from first checkin (they should all be from the same user)\n const userInfo = rows.length > 0\n ? {\n did: rows[0].did,\n handle: rows[0].handle,\n }\n : { did };\n\n return new Response(\n JSON.stringify({\n checkins,\n user: userInfo,\n }),\n { headers: corsHeaders },\n );\n}\n\nasync function getFollowingFeed(\n url: URL,\n corsHeaders: CorsHeaders,\n): Promise {\n const userDid = url.searchParams.get(\"user\");\n const limit = Math.min(parseInt(url.searchParams.get(\"limit\") || \"50\"), 100);\n const cursor = url.searchParams.get(\"cursor\");\n\n if (!userDid) {\n return new Response(JSON.stringify({ error: \"user parameter required\" }), {\n status: 400,\n headers: corsHeaders,\n });\n }\n\n // Get users this person follows using type-safe Drizzle query\n const follows = await db.select({\n followingDid: userFollowsTable.followingDid,\n }).from(userFollowsTable)\n .where(eq(userFollowsTable.followerDid, userDid));\n\n if (follows.length === 0) {\n return new Response(\n JSON.stringify({\n checkins: [],\n message: \"No follows found for user\",\n }),\n { headers: corsHeaders },\n );\n }\n\n const followingDids = follows.map((row) => row.followingDid);\n\n // Get checkins from followed users using type-safe Drizzle query\n const baseFollowingQuery = db.select({\n id: checkinsTable.id,\n uri: checkinsTable.uri,\n did: checkinsTable.did,\n handle: checkinsTable.handle,\n text: checkinsTable.text,\n createdAt: checkinsTable.createdAt,\n latitude: checkinsTable.latitude,\n longitude: checkinsTable.longitude,\n venueName: checkinsTable.venueName, // UNIFIED venue name field\n addressStreet: checkinsTable.addressStreet,\n addressLocality: checkinsTable.addressLocality,\n addressRegion: checkinsTable.addressRegion,\n addressCountry: checkinsTable.addressCountry,\n addressPostalCode: checkinsTable.addressPostalCode,\n }).from(checkinsTable);\n\n const rows = cursor\n ? await baseFollowingQuery\n .where(and(\n inArray(checkinsTable.did, followingDids),\n lt(checkinsTable.createdAt, cursor),\n ))\n .orderBy(desc(checkinsTable.createdAt))\n .limit(limit)\n : await baseFollowingQuery\n .where(inArray(checkinsTable.did, followingDids))\n .orderBy(desc(checkinsTable.createdAt))\n .limit(limit);\n\n // Resolve profiles\n const dids = [...new Set(rows.map((row) => row.did))];\n const storage = new DrizzleStorageProvider(db);\n const profileResolver = new ATProtocolProfileResolver(storage);\n const profiles = await profileResolver.batchResolveProfiles(dids);\n\n const checkins = await Promise.all(\n rows.map((row) => formatCheckinWithPlaces(row, profiles)),\n );\n\n return new Response(\n JSON.stringify({\n checkins,\n cursor: checkins.length > 0\n ? checkins[checkins.length - 1].createdAt\n : null,\n followingCount: followingDids.length,\n }),\n { headers: corsHeaders },\n );\n}\n\nasync function getStats(corsHeaders: CorsHeaders): Promise {\n // Use shared query functions to eliminate duplication\n const [counts, recentActivity, processingStats] = await Promise.all([\n getCheckinCounts(),\n getRecentActivity(),\n db.select().from(processingLogTable)\n .orderBy(desc(processingLogTable.runAt))\n .limit(1),\n ]);\n\n const stats = {\n totalCheckins: counts.totalCheckins,\n totalUsers: counts.uniqueUsers,\n recentActivity,\n lastProcessingRun: processingStats[0] || null,\n timestamp: new Date().toISOString(),\n };\n\n return new Response(JSON.stringify(stats), { headers: corsHeaders });\n}\n\nasync function getNearbyPlaces(\n url: URL,\n corsHeaders: CorsHeaders,\n): Promise {\n const lat = parseFloat(url.searchParams.get(\"lat\") || \"0\");\n const lng = parseFloat(url.searchParams.get(\"lng\") || \"0\");\n const radius = Math.min(\n parseFloat(url.searchParams.get(\"radius\") || \"300\"),\n 2000, // max 2km for places search\n );\n const categoriesParam = url.searchParams.get(\"categories\");\n const categories = categoriesParam ? categoriesParam.split(\",\") : [];\n\n // Validate coordinates\n if (!lat || !lng || Math.abs(lat) > 90 || Math.abs(lng) > 180) {\n return new Response(\n JSON.stringify({\n error:\n \"Valid lat and lng parameters required (lat: -90 to 90, lng: -180 to 180)\",\n }),\n {\n status: 400,\n headers: corsHeaders,\n },\n );\n }\n\n try {\n // Initialize Overpass service\n const overpassService = new OverpassService();\n\n // Search for nearby places\n const placesWithDistance = await overpassService\n .findNearbyPlacesWithDistance(\n { latitude: lat, longitude: lng },\n radius,\n categories,\n );\n\n // Map backend PlaceWithDistance to API format (distanceMeters -> distance)\n const apiPlaces = placesWithDistance.map((place) => ({\n ...place,\n distance: place.distanceMeters, // Map distanceMeters to distance for mobile client\n // Remove distanceMeters to avoid confusion\n distanceMeters: undefined,\n }));\n\n // Format response\n const response: PlacesNearbyResponse = {\n places: apiPlaces,\n radius: radius, // Changed from searchRadius to radius for mobile client\n center: {\n latitude: lat,\n longitude: lng,\n },\n };\n\n return new Response(JSON.stringify(response), { headers: corsHeaders });\n } catch (error) {\n console.error(\"Places search error:\", error);\n\n return new Response(\n JSON.stringify({\n error: \"Failed to search for nearby places\",\n details: error instanceof Error ? error.message : \"Unknown error\",\n }),\n {\n status: 500,\n headers: corsHeaders,\n },\n );\n }\n}\n\nfunction getPlaceCategories(corsHeaders: CorsHeaders): Response {\n try {\n // Get all category data for mobile app consumption\n const categories = CategoryService.getAllCategoryObjects();\n const defaultSearchCategories = CategoryService\n .getDefaultSearchCategories();\n const sociallyRelevantCategories = CategoryService\n .getSociallyRelevantCategories();\n\n const response = {\n categories,\n defaultSearch: defaultSearchCategories,\n sociallyRelevant: sociallyRelevantCategories,\n metadata: {\n totalCategories: categories.length,\n defaultSearchCount: defaultSearchCategories.length,\n sociallyRelevantCount: sociallyRelevantCategories.length,\n },\n };\n\n return new Response(JSON.stringify(response), {\n status: 200,\n headers: corsHeaders,\n });\n } catch (error) {\n console.error(\"Error fetching place categories:\", error);\n return new Response(\n JSON.stringify({\n error: \"Failed to fetch place categories\",\n details: error instanceof Error ? error.message : \"Unknown error\",\n }),\n {\n status: 500,\n headers: corsHeaders,\n },\n );\n }\n}\n\n// Create service instances to reuse\nconst overpassService = new OverpassService();\nconst nominatimService = new NominatimService();\n\nasync function searchPlaces(\n url: URL,\n corsHeaders: CorsHeaders,\n): Promise {\n // Parse and validate parameters\n const query = url.searchParams.get(\"q\");\n const lat = parseFloat(url.searchParams.get(\"lat\") || \"0\");\n const lng = parseFloat(url.searchParams.get(\"lng\") || \"0\");\n const country = url.searchParams.get(\"country\");\n const limit = Math.min(\n parseInt(url.searchParams.get(\"limit\") || \"10\"),\n 25, // max 25 results\n );\n\n // Validate required parameters\n if (!query || query.trim() === \"\") {\n return new Response(\n JSON.stringify({ error: \"Query parameter 'q' is required\" }),\n {\n status: 400,\n headers: corsHeaders,\n },\n );\n }\n\n if (!lat || !lng || lat === 0 || lng === 0) {\n return new Response(\n JSON.stringify({\n error: \"Valid latitude and longitude parameters are required\",\n }),\n {\n status: 400,\n headers: corsHeaders,\n },\n );\n }\n\n // Validate coordinate ranges\n if (lat < -90 || lat > 90 || lng < -180 || lng > 180) {\n return new Response(\n JSON.stringify({ error: \"Invalid latitude or longitude values\" }),\n {\n status: 400,\n headers: corsHeaders,\n },\n );\n }\n\n try {\n console.log(\n `Searching places: \"${query}\" near ${lat}, ${lng} (country: ${\n country || \"any\"\n })`,\n );\n\n // Search for places using Nominatim\n const places = await nominatimService.searchPlaces(\n query.trim(),\n { latitude: lat, longitude: lng },\n {\n country,\n limit,\n radiusKm: 2, // 2km search radius for 4x4km box as requested\n },\n );\n\n console.log(`Found ${places.length} places for query: \"${query}\"`);\n\n // Format response to match the existing places API structure\n const response = {\n places,\n query,\n center: {\n latitude: lat,\n longitude: lng,\n },\n radius: 2000, // 2km in meters\n count: places.length,\n };\n\n return new Response(JSON.stringify(response), { headers: corsHeaders });\n } catch (error) {\n console.error(\"Places search error:\", error);\n const errorResponse = {\n error: \"Failed to search for places\",\n details: error instanceof Error ? error.message : \"Unknown error\",\n };\n\n // Return appropriate status code based on error type\n const status =\n error instanceof Error && error.message.includes(\"Rate limit\")\n ? 429\n : 500;\n\n return new Response(JSON.stringify(errorResponse), {\n status,\n headers: corsHeaders,\n });\n }\n}\n\nasync function formatCheckinWithPlaces(\n row: any,\n profiles: Map,\n): Promise {\n const profile = profiles.get(row.did as string);\n\n const checkin: any = {\n id: row.id,\n uri: row.uri,\n author: {\n did: row.did,\n handle: profile?.handle || row.handle || row.did,\n displayName: profile?.displayName,\n avatar: profile?.avatar,\n },\n text: row.text,\n createdAt: row.createdAt, // Fixed field name - Drizzle returns createdAt not created_at\n };\n\n // Add coordinates if available\n if (row.latitude && row.longitude) {\n checkin.coordinates = {\n latitude: row.latitude,\n longitude: row.longitude,\n };\n }\n\n // Add address if available - using unified venueName field (no more confusion!)\n if (\n row.venueName || row.addressStreet || row.addressLocality ||\n row.addressRegion || row.addressCountry || row.addressPostalCode\n ) {\n checkin.address = {\n name: row.venueName, // UNIFIED venue name field - always consistent\n street: row.addressStreet,\n locality: row.addressLocality,\n region: row.addressRegion,\n country: row.addressCountry,\n postalCode: row.addressPostalCode,\n };\n } else if (row.latitude && row.longitude) {\n // If no cached address data, try to find the nearest place via Overpass\n try {\n const nearbyPlaces = await overpassService.findNearbyPlaces(\n { latitude: row.latitude, longitude: row.longitude },\n 100, // 100 meter radius\n [], // All categories\n );\n\n if (nearbyPlaces.length > 0) {\n // Use the first (closest) place found\n const nearestPlace = nearbyPlaces[0];\n checkin.address = {\n name: nearestPlace.name, // Use the actual venue name from OSM\n street: nearestPlace.address?.street,\n locality: nearestPlace.address?.locality,\n region: nearestPlace.address?.region,\n country: nearestPlace.address?.country,\n postalCode: nearestPlace.address?.postalCode,\n };\n }\n } catch (error) {\n console.warn(\"Failed to lookup nearby place:\", error);\n // Continue without address data - this is non-critical\n }\n }\n\n // Add distance if calculated\n if (row.distance !== undefined) {\n checkin.distance = Math.round(row.distance * 100) / 100; // 2 decimal places\n }\n\n return checkin;\n}\n\nfunction calculateDistance(\n lat1: number,\n lng1: number,\n lat2: number,\n lng2: number,\n): number {\n const R = 6371; // Earth's radius in km\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\nasync function getCheckinById(\n checkinId: string,\n corsHeaders: CorsHeaders,\n): Promise {\n try {\n // Query for the specific checkin by id (rkey)\n const rows = await db.select({\n id: checkinsTable.id,\n uri: checkinsTable.uri,\n rkey: checkinsTable.rkey,\n did: checkinsTable.did,\n handle: checkinsTable.handle,\n displayName: checkinsTable.displayName,\n avatar: checkinsTable.avatar,\n text: checkinsTable.text,\n createdAt: checkinsTable.createdAt,\n latitude: checkinsTable.latitude,\n longitude: checkinsTable.longitude,\n venueName: checkinsTable.venueName,\n category: checkinsTable.category,\n categoryGroup: checkinsTable.categoryGroup,\n categoryIcon: checkinsTable.categoryIcon,\n addressStreet: checkinsTable.addressStreet,\n addressLocality: checkinsTable.addressLocality,\n addressRegion: checkinsTable.addressRegion,\n addressCountry: checkinsTable.addressCountry,\n addressPostalCode: checkinsTable.addressPostalCode,\n })\n .from(checkinsTable)\n .where(eq(checkinsTable.id, checkinId))\n .limit(1);\n\n if (rows.length === 0) {\n return new Response(JSON.stringify({ error: \"Checkin not found\" }), {\n status: 404,\n headers: corsHeaders,\n });\n }\n\n const row = rows[0];\n\n // Get profile data for the author\n const storage = new DrizzleStorageProvider(db);\n const profileResolver = new ATProtocolProfileResolver(storage);\n const profiles = await profileResolver.batchResolveProfiles([row.did]);\n\n // Convert to CheckinRecord format\n const checkin = await formatCheckinWithPlaces(row, profiles);\n\n return new Response(JSON.stringify(checkin), {\n status: 200,\n headers: corsHeaders,\n });\n } catch (error) {\n console.error(\"Get checkin error:\", error);\n return new Response(JSON.stringify({ error: \"Internal server error\" }), {\n status: 500,\n headers: corsHeaders,\n });\n }\n}\n\nasync function handleCreateCheckin(\n req: Request,\n corsHeaders: CorsHeaders,\n): Promise {\n // Only handle POST requests for checkin creation\n if (req.method !== \"POST\") {\n return new Response(JSON.stringify({ error: \"Method not allowed\" }), {\n status: 405,\n headers: corsHeaders,\n });\n }\n\n // Create a mock Hono Context for the createCheckin function\n const context = {\n req: {\n header: (name: string) => req.headers.get(name),\n json: () => req.json(),\n },\n json: (data: any, status?: number) =>\n new Response(JSON.stringify(data), {\n status: status || 200,\n headers: corsHeaders,\n }),\n };\n\n return await createCheckin(context as any);\n}\n","deleted","label",[169,170,151],"backend","api","permalink","https://www.val.town/x/tijs/location-feed-generator/code/backend/api/anchor-api.ts","extension","actionData","errors"]