[{"_1":2,"_477":-5,"_478":-5},"loaderData",{"_3":4,"_91":92,"_386":387},"root",{"_5":6,"_34":35,"_64":65},"ctx",{"_7":8,"_23":-5,"_24":25,"_26":27,"_28":22,"_29":22,"_30":22,"_31":32,"_33":22},"auth",{"_9":10,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":-5,"_20":-5,"_21":22},"tokenType","session_token","sessionClaims","sessionId","sessionStatus","userId","actor","orgId","orgRole","orgSlug","orgPermissions","factorVerificationAge","isAuthenticated",false,"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","e3ca0a77ab07ff2ce3097208ffd6aa0e378d3c47","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":22,"_75":72,"_76":72,"_77":72,"_78":72,"_79":80,"_89":22,"_90":22},"__clerk_ssr_state",{"_9":10,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":-5,"_20":-5,"_21":22},"__publishableKey","__proxyUrl","","__domain","__isSatellite","__signInUrl","__signUpUrl","__afterSignInUrl","__afterSignUpUrl","__clerk_debug",{"_81":22,"_21":22,"_82":72,"_83":84,"_85":72,"_86":45,"_87":22,"_88":72},"isSignedIn","proxyUrl","reason","session-token-and-uat-missing","message","publishableKey","isSatellite","domain","__telemetryDisabled","__telemetryDebug","routes/_app.x.$handle.$name",{"_93":94,"_95":96,"_97":43,"_98":99,"_100":101,"_102":103,"_150":151,"_367":368,"_369":370,"_375":376,"_177":377,"_380":-5,"_381":-5,"_382":22,"_383":22,"_384":385},"handle","tijs","name","location-feed-generator","branchName","path","src/social","version",24,"project",{"_104":105,"_95":96,"_106":107,"_108":-5,"_109":22,"_110":111,"_112":113,"_114":-5,"_14":115,"_116":-5,"_117":22,"_118":-5,"_119":120,"_16":121,"_122":123,"_124":123,"_125":126,"_127":126,"_128":126,"_129":123,"_130":123,"_23":131,"_134":135,"_137":138,"_149":22},"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,"_132":133},"profileImageUrl","https://img.clerk.com/eyJ0eXBlIjoicHJveHkiLCJzcmMiOiJodHRwczovL2ltYWdlcy5jbGVyay5kZXYvb2F1dGhfZ2l0aHViL2ltZ18yd2Nod2N0bE1MWFdEUlRYd083ZE5pbXJ1bDAifQ","org",{"_93":94,"_136":133},"avatar","branch",{"_100":139,"_95":43,"_104":140,"_141":105,"_142":-5,"_143":-5,"_144":-5,"_145":-5,"_146":-5,"_147":96,"_148":94},1067,"db7c07aa-58ab-11f0-bdec-f69ea79377d9","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","isOwned","tree",[152,182,199,215,223,263,350,359],{"_104":153,"_95":154,"_155":156,"_157":-5,"_158":140,"_159":160,"_161":162,"_106":163,"_100":32,"_164":165,"_166":-5,"_167":22,"_168":-5,"_169":170,"_98":181},"56d49838-58b4-11f0-9e45-f69ea79377d9",".claude","fileId","56d499b4-58b4-11f0-9e45-f69ea79377d9","parentId","branchId","branchVersion",4,"latest",true,["D",1751619202254],"fileType","directory","content","deleted","label","children",[171],{"_104":172,"_95":173,"_155":174,"_157":156,"_158":140,"_159":175,"_161":22,"_106":176,"_100":32,"_164":177,"_166":178,"_167":22,"_168":-5,"_169":179,"_98":180},"581a4102-58b4-11f0-acd5-f69ea79377d9","settings.local.json","581a41b6-58b4-11f0-acd5-f69ea79377d9",23,["D",1751619204389],"file","{\n \"permissions\": {\n \"allow\": [\n \"Bash(chmod:*)\",\n \"Bash(mkdir:*)\",\n \"Bash(mv:*)\",\n \"Bash(grep:*)\",\n \"Bash(deno test:*)\",\n \"Bash(/Users/tijs/projects/Anchor/location-feed-generator/scripts/test.sh:*)\",\n \"Bash(./scripts/test.sh:*)\"\n ],\n \"deny\": []\n }\n}",[],[154,173],[154],{"_104":183,"_95":184,"_155":185,"_157":-5,"_158":140,"_159":186,"_161":162,"_106":187,"_100":32,"_164":165,"_166":-5,"_167":22,"_168":-5,"_169":188,"_98":198},"56a78f96-58b4-11f0-9210-f69ea79377d9","database","56a79054-58b4-11f0-9210-f69ea79377d9",2,["D",1751619201960],[189],{"_104":190,"_95":191,"_155":192,"_157":185,"_158":140,"_159":193,"_161":22,"_106":194,"_100":32,"_164":177,"_166":195,"_167":22,"_168":-5,"_169":196,"_98":197},"57f0a28e-58b4-11f0-aaa5-f69ea79377d9","database-schema.sql","57f0a342-58b4-11f0-aaa5-f69ea79377d9",15,["D",1751619204117],"-- Anchor AppView Database Schema for Val Town SQLite\n-- Phase 1: Core Infrastructure\n\n-- Main checkins table\nCREATE TABLE IF NOT EXISTS checkins_v1 (\n id TEXT PRIMARY KEY, -- record rkey\n uri TEXT UNIQUE NOT NULL, -- full AT URI\n author_did TEXT NOT NULL, -- creator DID\n author_handle TEXT, -- cached handle for display\n text TEXT NOT NULL, -- checkin message\n created_at TEXT NOT NULL, -- ISO timestamp\n \n -- Extracted coordinates\n latitude REAL,\n longitude REAL,\n \n -- Address reference (strongref)\n address_ref_uri TEXT, -- URI to address record\n address_ref_cid TEXT, -- content hash for verification\n \n -- Cached resolved address data\n cached_address_name TEXT, -- venue name\n cached_address_street TEXT, -- street address\n cached_address_locality TEXT, -- city\n cached_address_region TEXT, -- state/province\n cached_address_country TEXT, -- country code\n cached_address_postal_code TEXT, -- postal code\n cached_address_full JSON, -- complete resolved address object\n \n -- Metadata\n address_resolved_at TEXT, -- when address was last resolved\n indexed_at TEXT DEFAULT CURRENT_TIMESTAMP\n);\n\n-- Address cache for efficiency\nCREATE TABLE IF NOT EXISTS address_cache_v1 (\n uri TEXT PRIMARY KEY, -- address record URI\n cid TEXT, -- content hash\n name TEXT,\n street TEXT,\n locality TEXT,\n region TEXT,\n country TEXT,\n postal_code TEXT,\n latitude REAL,\n longitude REAL,\n full_data JSON, -- complete address record\n resolved_at TEXT, -- when successfully fetched\n failed_at TEXT -- if resolution failed\n);\n\n-- Social graph for following feeds (v2)\nCREATE TABLE IF NOT EXISTS user_follows_v1 (\n follower_did TEXT NOT NULL,\n following_did TEXT NOT NULL,\n created_at TEXT,\n synced_at TEXT DEFAULT CURRENT_TIMESTAMP,\n PRIMARY KEY (follower_did, following_did)\n);\n\n-- Processing logs for monitoring\nCREATE TABLE IF NOT EXISTS processing_log_v1 (\n id INTEGER PRIMARY KEY,\n run_at TEXT NOT NULL,\n events_processed INTEGER DEFAULT 0,\n errors INTEGER DEFAULT 0,\n duration_ms INTEGER\n);\n\n-- Performance indexes\nCREATE INDEX IF NOT EXISTS idx_checkins_created ON checkins_v1(created_at DESC);\nCREATE INDEX IF NOT EXISTS idx_checkins_author ON checkins_v1(author_did);\nCREATE INDEX IF NOT EXISTS idx_checkins_location ON checkins_v1(latitude, longitude);\nCREATE INDEX IF NOT EXISTS idx_follows_follower ON user_follows_v1(follower_did);",[],[184,191],[184],{"_104":200,"_95":201,"_155":202,"_157":-5,"_158":140,"_159":203,"_161":162,"_106":204,"_100":32,"_164":165,"_166":-5,"_167":22,"_168":-5,"_169":205,"_98":214},"56ec730e-58b4-11f0-8987-f69ea79377d9","docs","56ec73e0-58b4-11f0-8987-f69ea79377d9",5,["D",1751619202409],[206],{"_104":207,"_95":208,"_155":209,"_157":202,"_158":140,"_159":101,"_161":22,"_106":210,"_100":32,"_164":177,"_166":211,"_167":22,"_168":-5,"_169":212,"_98":213},"5821a316-58b4-11f0-a9f0-f69ea79377d9","deployment-guide.md","5821a3d4-58b4-11f0-a9f0-f69ea79377d9",["D",1751619204397],"# Anchor AppView Deployment Guide\n\n## Prerequisites\n\nEnsure you have the Val Town CLI installed:\n\n```bash\nnpm install -g @valtown/cli\n# or\nnpx @valtown/cli --help\n```\n\n## Functions Overview\n\nThis AppView consists of 3 main Val Town functions:\n\n1. **jetstreamPoller** - Cron job (5 minutes)\n2. **anchorAPI** - HTTP function \n3. **socialGraphSync** - Cron job (daily)\n\n## Quick Deployment with Val Town CLI\n\n### 1. Deploy All Functions\n\n```bash\n# Deploy the ingestion cron job\nvt create cron jetstreamPoller --file src/ingestion/jetstream-poller.ts --schedule \"*/5 * * * *\"\n\n# Deploy the HTTP API\nvt create http anchorAPI --file src/api/anchor-api.ts\n\n# Deploy the social sync cron job\nvt create cron socialGraphSync --file src/social/social-graph-sync.ts --schedule \"0 2 * * *\"\n```\n\n### 2. Verify Deployments\n\n```bash\n# List your functions\nvt list\n\n# Check function status\nvt status jetstreamPoller\nvt status anchorAPI\nvt status socialGraphSync\n```\n\n### 3. Test the API\n\n```bash\n# Get your API URL\nAPI_URL=$(vt url anchorAPI)\n\n# Test endpoints\ncurl \"$API_URL/stats\"\ncurl \"$API_URL/global?limit=5\"\n```\n\n## Alternative: Manual Deployment\n\nIf you prefer the web interface:\n\n### 1. No Database Setup Required\nTables are automatically created when functions first run.\n\n### 2. Create Functions via Web Interface\n- Go to [val.town](https://val.town)\n- Create new cron function: `jetstreamPoller`\n- Copy code from `src/ingestion/jetstream-poller.ts`\n- Set schedule: `*/5 * * * *`\n\n### 3. Repeat for Other Functions\n- HTTP function: `anchorAPI` from `src/api/anchor-api.ts`\n- Cron function: `socialGraphSync` from `src/social/social-graph-sync.ts` (schedule: `0 2 * * *`)\n\n## Environment Variables\n\nNo environment variables are required for the basic deployment. All authentication uses public APIs.\n\n## Testing the Deployment\n\n### 1. Test Data Ingestion\nMonitor the `jetstreamPoller` logs to ensure it's receiving and processing check-in events.\n\n### 2. Test API Endpoints\nUse the provided test script or Val Town CLI:\n\n```bash\n# Using the test script (update BASE_URL first)\n./scripts/test-api.sh\n\n# Or using Val Town CLI\nAPI_URL=$(vt url anchorAPI)\ncurl \"$API_URL/global?limit=5\"\ncurl \"$API_URL/stats\"\ncurl \"$API_URL/nearby?lat=52.0705&lng=4.3007&radius=5\"\n```\n\n### 3. Monitor Processing Logs\nCheck the `processing_log_v1` table to monitor ingestion health and performance.\n\n## Scaling Considerations\n\n### Performance Optimization\n- Monitor SQLite performance as data grows\n- Consider implementing pagination for large result sets\n- Add query timeout handling for long-running spatial queries\n\n### Rate Limiting\n- The social graph sync includes built-in rate limiting\n- Jetstream poller has a 45-second collection window\n- API endpoints have built-in limits (max 100 results per query)\n\n### Error Handling\n- All functions include comprehensive error handling\n- Failed address resolutions are cached to avoid retry storms\n- Processing logs track errors for monitoring\n\n## Monitoring and Maintenance\n\n### Health Checks\n- Monitor the `/stats` endpoint for system health\n- Check processing logs for ingestion errors\n- Monitor SQLite database size and performance\n\n### Database Maintenance\n- Periodically clean up old processing logs\n- Monitor address cache hit rates\n- Consider archiving old check-ins if storage becomes an issue\n\n### Updates and Schema Changes\n- When changing database schema, increment table versions (e.g., `checkins_v1` → `checkins_v2`)\n- Test schema migrations carefully in development\n- Consider data migration scripts for breaking changes\n\n## Troubleshooting\n\n### Common Issues\n1. **Jetstream connection failures**: Check network connectivity and Jetstream service status\n2. **Address resolution errors**: Verify AT Protocol network accessibility\n3. **Social graph sync failures**: Check Bluesky API rate limits and status\n4. **SQLite performance**: Monitor query execution times and optimize indexes\n\n### Debugging\n- All functions include detailed logging\n- Use Val Town's built-in debugging tools\n- Monitor function execution times and memory usage\n\n## Security Considerations\n\n- All API endpoints include proper CORS headers\n- No sensitive data is logged or stored\n- Public APIs are used for all external integrations\n- Rate limiting prevents abuse of external services\n\n## Integration with Anchor Client\n\nThe deployed AppView provides these endpoints for the Anchor client:\n\n- **Global Feed**: Recent check-ins from all users\n- **Nearby Feed**: Location-based spatial queries\n- **User Feed**: Personal check-in history\n- **Following Feed**: Social feed based on Bluesky follows\n- **Stats**: System health and metrics\n\nEach endpoint returns properly formatted JSON with consistent response structures for easy client integration.",[],[201,208],[201],{"_104":216,"_95":217,"_155":218,"_157":-5,"_158":140,"_159":219,"_161":22,"_106":220,"_100":32,"_164":165,"_166":-5,"_167":22,"_168":-5,"_169":221,"_98":222},"5703f59c-58b4-11f0-a3e4-f69ea79377d9","scripts","5703f66e-58b4-11f0-a3e4-f69ea79377d9",6,["D",1751619202565],[],[217],{"_104":224,"_95":225,"_155":226,"_157":-5,"_158":140,"_159":227,"_161":22,"_106":228,"_100":32,"_164":165,"_166":-5,"_167":22,"_168":-5,"_169":229,"_98":262},"571dd57a-58b4-11f0-b0d2-f69ea79377d9","src","571dd64c-58b4-11f0-b0d2-f69ea79377d9",7,["D",1751619202735],[230,238,246,254],{"_104":231,"_95":232,"_155":233,"_157":226,"_158":140,"_159":234,"_161":22,"_106":235,"_100":32,"_164":165,"_166":-5,"_167":22,"_168":-5,"_169":236,"_98":237},"57da2ed2-58b4-11f0-9210-f69ea79377d9","api","57da2fa4-58b4-11f0-9210-f69ea79377d9",14,["D",1751619203969],[],[225,232],{"_104":239,"_95":240,"_155":241,"_157":226,"_158":140,"_159":242,"_161":22,"_106":243,"_100":32,"_164":165,"_166":-5,"_167":22,"_168":-5,"_169":244,"_98":245},"578c11de-58b4-11f0-acd5-f69ea79377d9","ingestion","578c127e-58b4-11f0-acd5-f69ea79377d9",11,["D",1751619203457],[],[225,240],{"_104":247,"_95":248,"_155":249,"_157":226,"_158":140,"_159":250,"_161":22,"_106":251,"_100":32,"_164":165,"_166":-5,"_167":22,"_168":-5,"_169":252,"_98":253},"57b95ba8-58b4-11f0-a9f0-f69ea79377d9","social","57b95c70-58b4-11f0-a9f0-f69ea79377d9",13,["D",1751619203754],[],[225,248],{"_104":255,"_95":256,"_155":257,"_157":226,"_158":140,"_159":258,"_161":22,"_106":259,"_100":32,"_164":165,"_166":-5,"_167":22,"_168":-5,"_169":260,"_98":261},"57a2ef6c-58b4-11f0-a9f0-f69ea79377d9","utils","57a2f034-58b4-11f0-a9f0-f69ea79377d9",12,["D",1751619203606],[],[225,256],[225],{"_104":264,"_95":265,"_155":266,"_157":-5,"_158":140,"_159":267,"_161":162,"_106":268,"_100":32,"_164":165,"_166":-5,"_167":22,"_168":-5,"_169":269,"_98":349},"56be52d0-58b4-11f0-9210-f69ea79377d9","tests","56be5424-58b4-11f0-9210-f69ea79377d9",3,["D",1751619202108],[270,288,305],{"_104":271,"_95":272,"_155":273,"_157":266,"_158":140,"_159":274,"_161":162,"_106":275,"_100":32,"_164":165,"_166":-5,"_167":22,"_168":-5,"_169":276,"_98":287},"5769d894-58b4-11f0-a0a5-f69ea79377d9","fixtures","5769d952-58b4-11f0-a0a5-f69ea79377d9",10,["D",1751619203233],[277],{"_104":278,"_95":279,"_155":280,"_157":273,"_158":140,"_159":281,"_161":22,"_106":282,"_100":32,"_164":283,"_166":284,"_167":22,"_168":-5,"_169":285,"_98":286},"58119ee4-58b4-11f0-84ee-f69ea79377d9","test-data.ts","58119f98-58b4-11f0-84ee-f69ea79377d9",21,["D",1751619204292],"script","// Test fixtures for Anchor AppView tests\n\nexport const mockCheckins = [\n {\n id: \"checkin1\",\n uri: \"at://did:plc:user1/app.dropanchor.checkin/checkin1\",\n author_did: \"did:plc:user1\",\n author_handle: \"alice.bsky.social\",\n text: \"Amazing coffee at this local spot! ☕️\",\n created_at: \"2024-07-04T10:30:00Z\",\n latitude: 40.7128,\n longitude: -74.0060,\n address_ref_uri: \"at://did:plc:venues/community.lexicon.location.address/cafe-joe\",\n address_ref_cid: \"bafyreic7...\",\n cached_address_name: \"Joe's Coffee Shop\",\n cached_address_street: \"123 Broadway\",\n cached_address_locality: \"New York\",\n cached_address_region: \"NY\",\n cached_address_country: \"US\",\n cached_address_postal_code: \"10001\"\n },\n {\n id: \"checkin2\", \n uri: \"at://did:plc:user2/app.dropanchor.checkin/checkin2\",\n author_did: \"did:plc:user2\",\n author_handle: \"bob.bsky.social\",\n text: \"Great lunch spot with outdoor seating 🌞\",\n created_at: \"2024-07-04T12:15:00Z\",\n latitude: 40.7589,\n longitude: -73.9851,\n address_ref_uri: \"at://did:plc:venues/community.lexicon.location.address/times-square-cafe\",\n address_ref_cid: \"bafyreie8...\",\n cached_address_name: \"Times Square Cafe\",\n cached_address_street: \"1500 Broadway\",\n cached_address_locality: \"New York\", \n cached_address_region: \"NY\",\n cached_address_country: \"US\",\n cached_address_postal_code: \"10036\"\n },\n {\n id: \"checkin3\",\n uri: \"at://did:plc:user3/app.dropanchor.checkin/checkin3\", \n author_did: \"did:plc:user3\",\n author_handle: \"charlie.bsky.social\",\n text: \"Perfect spot for remote work 💻\",\n created_at: \"2024-07-04T14:45:00Z\",\n latitude: 37.7749,\n longitude: -122.4194,\n address_ref_uri: null,\n address_ref_cid: null,\n cached_address_name: null,\n cached_address_street: null,\n cached_address_locality: \"San Francisco\",\n cached_address_region: \"CA\", \n cached_address_country: \"US\",\n cached_address_postal_code: \"94102\"\n }\n];\n\nexport const mockAddresses = [\n {\n uri: \"at://did:plc:venues/community.lexicon.location.address/cafe-joe\",\n cid: \"bafyreic7...\",\n name: \"Joe's Coffee Shop\",\n street: \"123 Broadway\",\n locality: \"New York\",\n region: \"NY\",\n country: \"US\",\n postal_code: \"10001\",\n latitude: 40.7128,\n longitude: -74.0060,\n full_data: {\n name: \"Joe's Coffee Shop\",\n street: \"123 Broadway\", \n locality: \"New York\",\n region: \"NY\",\n country: \"US\",\n postalCode: \"10001\",\n latitude: 40.7128,\n longitude: -74.0060,\n hours: {\n monday: \"7:00-19:00\",\n tuesday: \"7:00-19:00\"\n },\n amenities: [\"wifi\", \"outdoor_seating\", \"accepts_cards\"]\n },\n resolved_at: \"2024-07-04T09:00:00Z\"\n },\n {\n uri: \"at://did:plc:venues/community.lexicon.location.address/times-square-cafe\",\n cid: \"bafyreie8...\", \n name: \"Times Square Cafe\",\n street: \"1500 Broadway\",\n locality: \"New York\",\n region: \"NY\", \n country: \"US\",\n postal_code: \"10036\",\n latitude: 40.7589,\n longitude: -73.9851,\n full_data: {\n name: \"Times Square Cafe\",\n street: \"1500 Broadway\",\n locality: \"New York\", \n region: \"NY\",\n country: \"US\",\n postalCode: \"10036\",\n latitude: 40.7589,\n longitude: -73.9851,\n hours: {\n monday: \"6:00-22:00\",\n tuesday: \"6:00-22:00\"\n },\n amenities: [\"wifi\", \"outdoor_seating\", \"delivery\"]\n },\n resolved_at: \"2024-07-04T11:30:00Z\"\n }\n];\n\nexport const mockUsers = [\n {\n did: \"did:plc:user1\",\n handle: \"alice.bsky.social\",\n displayName: \"Alice Johnson\", \n avatar: \"https://example.com/avatar1.jpg\"\n },\n {\n did: \"did:plc:user2\", \n handle: \"bob.bsky.social\",\n displayName: \"Bob Smith\",\n avatar: \"https://example.com/avatar2.jpg\"\n },\n {\n did: \"did:plc:user3\",\n handle: \"charlie.bsky.social\", \n displayName: \"Charlie Brown\",\n avatar: \"https://example.com/avatar3.jpg\"\n }\n];\n\nexport const mockFollows = [\n {\n follower_did: \"did:plc:user1\",\n following_did: \"did:plc:user2\", \n created_at: \"2024-06-01T10:00:00Z\",\n synced_at: \"2024-07-04T08:00:00Z\"\n },\n {\n follower_did: \"did:plc:user1\",\n following_did: \"did:plc:user3\",\n created_at: \"2024-06-15T14:30:00Z\", \n synced_at: \"2024-07-04T08:00:00Z\"\n },\n {\n follower_did: \"did:plc:user2\",\n following_did: \"did:plc:user1\",\n created_at: \"2024-06-02T09:15:00Z\",\n synced_at: \"2024-07-04T08:00:00Z\" \n }\n];\n\nexport const mockJetstreamEvents = [\n {\n kind: \"commit\",\n commit: {\n repo: \"did:plc:user1\",\n collection: \"app.dropanchor.checkin\",\n operation: \"create\",\n rkey: \"checkin1\",\n record: {\n text: \"Amazing coffee at this local spot! ☕️\",\n createdAt: \"2024-07-04T10:30:00Z\",\n coordinates: {\n latitude: \"40.7128\",\n longitude: \"-74.0060\"\n },\n addressRef: {\n uri: \"at://did:plc:venues/community.lexicon.location.address/cafe-joe\",\n cid: \"bafyreic7...\"\n }\n }\n }\n },\n {\n kind: \"commit\", \n commit: {\n repo: \"did:plc:user2\",\n collection: \"app.dropanchor.checkin\",\n operation: \"create\", \n rkey: \"checkin2\",\n record: {\n text: \"Great lunch spot with outdoor seating 🌞\",\n createdAt: \"2024-07-04T12:15:00Z\",\n coordinates: {\n latitude: \"40.7589\", \n longitude: \"-73.9851\"\n },\n addressRef: {\n uri: \"at://did:plc:venues/community.lexicon.location.address/times-square-cafe\",\n cid: \"bafyreie8...\"\n }\n }\n }\n }\n];\n\nexport const mockProcessingLogs = [\n {\n id: 1,\n run_at: \"2024-07-04T10:00:00Z\",\n events_processed: 5,\n errors: 0, \n duration_ms: 1250\n },\n {\n id: 2,\n run_at: \"2024-07-04T10:05:00Z\", \n events_processed: 3,\n errors: 1,\n duration_ms: 2100\n },\n {\n id: 3,\n run_at: \"2024-07-04T10:10:00Z\",\n events_processed: 7, \n errors: 0,\n duration_ms: 980\n }\n];\n\n// Coordinate pairs for testing spatial queries\nexport const testCoordinates = {\n newYork: { lat: 40.7128, lng: -74.0060 },\n sanFrancisco: { lat: 37.7749, lng: -122.4194 },\n london: { lat: 51.5074, lng: -0.1278 },\n tokyo: { lat: 35.6762, lng: 139.6503 },\n sydney: { lat: -33.8688, lng: 151.2093 }\n};\n\n// Helper function to create formatted checkin records\nexport function formatTestCheckin(rawCheckin: typeof mockCheckins[0]) {\n return {\n id: rawCheckin.id,\n uri: rawCheckin.uri,\n author: {\n did: rawCheckin.author_did,\n handle: rawCheckin.author_handle\n },\n text: rawCheckin.text,\n createdAt: rawCheckin.created_at,\n coordinates: rawCheckin.latitude && rawCheckin.longitude ? {\n latitude: rawCheckin.latitude,\n longitude: rawCheckin.longitude\n } : undefined,\n address: rawCheckin.cached_address_name ? {\n name: rawCheckin.cached_address_name,\n street: rawCheckin.cached_address_street,\n locality: rawCheckin.cached_address_locality,\n region: rawCheckin.cached_address_region,\n country: rawCheckin.cached_address_country,\n postalCode: rawCheckin.cached_address_postal_code\n } : undefined\n };\n}",[],[265,272,279],[265,272],{"_104":289,"_95":290,"_155":291,"_157":266,"_158":140,"_159":292,"_161":162,"_106":293,"_100":32,"_164":165,"_166":-5,"_167":22,"_168":-5,"_169":294,"_98":304},"5753ebce-58b4-11f0-9040-f69ea79377d9","integration","5753ec82-58b4-11f0-9040-f69ea79377d9",9,["D",1751619203088],[295],{"_104":296,"_95":297,"_155":298,"_157":291,"_158":140,"_159":299,"_161":22,"_106":300,"_100":32,"_164":283,"_166":301,"_167":22,"_168":-5,"_169":302,"_98":303},"580a4c02-58b4-11f0-b945-f69ea79377d9","api.test.ts","580a4cb6-58b4-11f0-b945-f69ea79377d9",20,["D",1751619204283],"import { assertEquals, assertExists } from \"https://deno.land/std@0.208.0/assert/mod.ts\";\nimport { stub, restore } from \"https://deno.land/std@0.208.0/testing/mock.ts\";\n\n// Mock SQLite for testing\nconst mockDatabase = new Map();\n\nconst mockSqlite = {\n async execute(query: string, params: any[] = []) {\n // Simple mock that returns test data based on query patterns\n if (query.includes(\"CREATE TABLE\")) {\n return [];\n }\n \n if (query.includes(\"SELECT COUNT(*) as count FROM checkins_v1\")) {\n return [{ count: 42 }];\n }\n \n if (query.includes(\"SELECT * FROM checkins_v1\")) {\n return [\n {\n id: \"test123\",\n uri: \"at://did:plc:test/app.dropanchor.checkin/test123\",\n author_did: \"did:plc:test\",\n author_handle: \"test.bsky.social\",\n text: \"Great coffee!\",\n created_at: \"2024-01-01T12:00:00Z\",\n latitude: 40.7128,\n longitude: -74.0060,\n cached_address_name: \"Test Cafe\",\n cached_address_street: \"123 Test St\",\n cached_address_locality: \"New York\",\n cached_address_region: \"NY\",\n cached_address_country: \"US\",\n cached_address_postal_code: \"10001\"\n }\n ];\n }\n \n if (query.includes(\"SELECT DISTINCT author_did FROM checkins_v1\")) {\n return [{ author_did: \"did:plc:test\" }];\n }\n \n return [];\n }\n};\n\n// Import the API handler (we'll need to mock the sqlite import)\n// For now, let's test the core functionality by creating a test version\n\nasync function createTestAPIHandler() {\n // Mock CORS headers type\n interface CorsHeaders extends Record {\n 'Access-Control-Allow-Origin': string;\n 'Access-Control-Allow-Methods': string;\n 'Access-Control-Allow-Headers': string;\n 'Content-Type': string;\n }\n\n const corsHeaders: CorsHeaders = {\n 'Access-Control-Allow-Origin': '*',\n 'Access-Control-Allow-Methods': 'GET, OPTIONS',\n 'Access-Control-Allow-Headers': 'Content-Type',\n 'Content-Type': 'application/json'\n };\n\n async function handleRequest(req: Request): Promise {\n const url = new URL(req.url);\n \n if (req.method === 'OPTIONS') {\n return new Response(null, { headers: corsHeaders });\n }\n \n switch (url.pathname) {\n case '/global':\n return new Response(JSON.stringify({\n checkins: await getMockCheckins(),\n cursor: null\n }), { headers: corsHeaders });\n \n case '/stats':\n return new Response(JSON.stringify({\n totalCheckins: 42,\n totalUsers: 10,\n recentActivity: 5,\n timestamp: new Date().toISOString()\n }), { headers: corsHeaders });\n \n case '/nearby':\n const lat = parseFloat(url.searchParams.get('lat') || '0');\n const lng = parseFloat(url.searchParams.get('lng') || '0');\n const radius = parseFloat(url.searchParams.get('radius') || '5');\n \n if (isNaN(lat) || isNaN(lng) || url.searchParams.get('lat') === null || url.searchParams.get('lng') === null) {\n return new Response(JSON.stringify({ error: 'lat and lng parameters required' }), {\n status: 400,\n headers: corsHeaders\n });\n }\n \n return new Response(JSON.stringify({\n checkins: await getMockNearbyCheckins(lat, lng, radius),\n center: { latitude: lat, longitude: lng },\n radius\n }), { headers: corsHeaders });\n \n default:\n return new Response(JSON.stringify({ error: 'Not Found' }), { \n status: 404, \n headers: corsHeaders \n });\n }\n }\n\n async function getMockCheckins() {\n return [\n {\n id: \"test123\",\n uri: \"at://did:plc:test/app.dropanchor.checkin/test123\",\n author: {\n did: \"did:plc:test\",\n handle: \"test.bsky.social\"\n },\n text: \"Great coffee!\",\n createdAt: \"2024-01-01T12:00:00Z\",\n coordinates: {\n latitude: 40.7128,\n longitude: -74.0060\n },\n address: {\n name: \"Test Cafe\",\n street: \"123 Test St\",\n locality: \"New York\",\n region: \"NY\",\n country: \"US\",\n postalCode: \"10001\"\n }\n }\n ];\n }\n\n async function getMockNearbyCheckins(lat: number, lng: number, radius: number) {\n // Simple distance check for test data\n const testLat = 40.7128;\n const testLng = -74.0060;\n const distance = Math.sqrt(Math.pow(lat - testLat, 2) + Math.pow(lng - testLng, 2)) * 111; // Rough km conversion\n \n if (distance <= radius) {\n const checkins = await getMockCheckins();\n return checkins.map(checkin => ({\n ...checkin,\n distance: Math.round(distance * 100) / 100\n }));\n }\n \n return [];\n }\n\n return handleRequest;\n}\n\nDeno.test(\"API Integration - OPTIONS request returns CORS headers\", async () => {\n const handler = await createTestAPIHandler();\n const req = new Request(\"http://localhost/global\", { method: \"OPTIONS\" });\n const response = await handler(req);\n \n assertEquals(response.status, 200);\n assertEquals(response.headers.get(\"Access-Control-Allow-Origin\"), \"*\");\n});\n\nDeno.test(\"API Integration - /global endpoint returns checkin data\", async () => {\n const handler = await createTestAPIHandler();\n const req = new Request(\"http://localhost/global\");\n const response = await handler(req);\n \n assertEquals(response.status, 200);\n \n const data = await response.json();\n assertExists(data.checkins);\n assertEquals(Array.isArray(data.checkins), true);\n assertEquals(data.checkins.length, 1);\n assertEquals(data.checkins[0].id, \"test123\");\n});\n\nDeno.test(\"API Integration - /stats endpoint returns statistics\", async () => {\n const handler = await createTestAPIHandler();\n const req = new Request(\"http://localhost/stats\");\n const response = await handler(req);\n \n assertEquals(response.status, 200);\n \n const data = await response.json();\n assertEquals(data.totalCheckins, 42);\n assertEquals(data.totalUsers, 10);\n assertEquals(data.recentActivity, 5);\n assertExists(data.timestamp);\n});\n\nDeno.test(\"API Integration - /nearby endpoint requires lat/lng parameters\", async () => {\n const handler = await createTestAPIHandler();\n const req = new Request(\"http://localhost/nearby\");\n const response = await handler(req);\n \n assertEquals(response.status, 400);\n \n const data = await response.json();\n assertEquals(data.error, \"lat and lng parameters required\");\n});\n\nDeno.test(\"API Integration - /nearby endpoint returns nearby checkins\", async () => {\n const handler = await createTestAPIHandler();\n const req = new Request(\"http://localhost/nearby?lat=40.7128&lng=-74.0060&radius=5\");\n const response = await handler(req);\n \n assertEquals(response.status, 200);\n \n const data = await response.json();\n assertExists(data.checkins);\n assertExists(data.center);\n assertEquals(data.center.latitude, 40.7128);\n assertEquals(data.center.longitude, -74.0060);\n assertEquals(data.radius, 5);\n \n if (data.checkins.length > 0) {\n assertExists(data.checkins[0].distance);\n }\n});\n\nDeno.test(\"API Integration - /nearby endpoint filters by distance\", async () => {\n const handler = await createTestAPIHandler();\n \n // Test far away coordinates\n const req = new Request(\"http://localhost/nearby?lat=0&lng=0&radius=5\");\n const response = await handler(req);\n \n assertEquals(response.status, 200);\n \n const data = await response.json();\n assertEquals(data.checkins.length, 0); // Should be empty due to distance\n});\n\nDeno.test(\"API Integration - unknown endpoint returns 404\", async () => {\n const handler = await createTestAPIHandler();\n const req = new Request(\"http://localhost/unknown\");\n const response = await handler(req);\n \n assertEquals(response.status, 404);\n \n const data = await response.json();\n assertEquals(data.error, \"Not Found\");\n});",[],[265,290,297],[265,290],{"_104":306,"_95":307,"_155":308,"_157":266,"_158":140,"_159":309,"_161":162,"_106":310,"_100":32,"_164":165,"_166":-5,"_167":22,"_168":-5,"_169":311,"_98":348},"573c83c6-58b4-11f0-a3e4-f69ea79377d9","unit","573c8484-58b4-11f0-a3e4-f69ea79377d9",8,["D",1751619202935],[312,321,330,339],{"_104":313,"_95":314,"_155":315,"_157":308,"_158":140,"_159":316,"_161":22,"_106":317,"_100":32,"_164":283,"_166":318,"_167":22,"_168":-5,"_169":319,"_98":320},"57fd2414-58b4-11f0-9e45-f69ea79377d9","address-cache.test.ts","57fd24e6-58b4-11f0-9e45-f69ea79377d9",17,["D",1751619204121],"import { assertEquals, assertExists } from \"https://deno.land/std@0.208.0/assert/mod.ts\";\nimport { stub, restore } from \"https://deno.land/std@0.208.0/testing/mock.ts\";\n\n// Mock blob storage for testing\nconst mockBlobStorage = new Map();\n\n// Mock the blob import\nconst mockBlob = {\n async getJSON(key: string) {\n return mockBlobStorage.get(key) || null;\n },\n async setJSON(key: string, value: any) {\n mockBlobStorage.set(key, value);\n },\n async delete(key: string) {\n mockBlobStorage.delete(key);\n },\n async list(prefix: string) {\n return Array.from(mockBlobStorage.keys()).filter(key => key.startsWith(prefix));\n }\n};\n\n// Import and test the address cache functions\nimport { \n getCachedAddress, \n setCachedAddress, \n setCachedAddressFailure, \n getCacheStats \n} from \"../../src/utils/address-cache.ts\";\n\n// Mock the blob import in the module\nconst originalImport = (await import(\"../../src/utils/address-cache.ts\"));\n\nDeno.test(\"Address Cache - setCachedAddress stores address data\", async () => {\n const testUri = \"at://did:plc:test/collection/record\";\n const testAddress = {\n name: \"Test Venue\",\n street: \"123 Test St\",\n locality: \"Test City\",\n region: \"TS\",\n country: \"TC\",\n postalCode: \"12345\",\n latitude: 40.7128,\n longitude: -74.0060\n };\n\n // Clear storage\n mockBlobStorage.clear();\n\n // This test demonstrates the expected interface\n // In actual implementation, we'd need to mock the blob import differently\n const cacheKey = `address_cache_${encodeURIComponent(testUri)}`;\n await mockBlob.setJSON(cacheKey, {\n ...testAddress,\n resolvedAt: new Date().toISOString()\n });\n\n const stored = await mockBlob.getJSON(cacheKey);\n assertExists(stored);\n assertEquals(stored.name, \"Test Venue\");\n assertEquals(stored.latitude, 40.7128);\n});\n\nDeno.test(\"Address Cache - cache expiry logic\", async () => {\n const testUri = \"at://did:plc:expired/collection/record\";\n const cacheKey = `address_cache_${encodeURIComponent(testUri)}`;\n \n // Store an expired entry (31 days old)\n const expiredDate = new Date();\n expiredDate.setDate(expiredDate.getDate() - 31);\n \n await mockBlob.setJSON(cacheKey, {\n name: \"Expired Venue\",\n resolvedAt: expiredDate.toISOString()\n });\n\n const stored = await mockBlob.getJSON(cacheKey);\n assertExists(stored);\n \n // Check if entry would be considered expired\n const cacheAge = Date.now() - new Date(stored.resolvedAt).getTime();\n const maxAge = 30 * 24 * 60 * 60 * 1000; // 30 days\n assertEquals(cacheAge > maxAge, true);\n});\n\nDeno.test(\"Address Cache - failure caching\", async () => {\n const testUri = \"at://did:plc:failed/collection/record\";\n const cacheKey = `address_cache_${encodeURIComponent(testUri)}`;\n \n await mockBlob.setJSON(cacheKey, {\n failedAt: new Date().toISOString(),\n resolvedAt: new Date().toISOString()\n });\n\n const stored = await mockBlob.getJSON(cacheKey);\n assertExists(stored);\n assertExists(stored.failedAt);\n});\n\nDeno.test(\"Address Cache - cache statistics\", async () => {\n mockBlobStorage.clear();\n \n // Add some test entries\n await mockBlob.setJSON(\"address_cache_success1\", {\n name: \"Success 1\",\n resolvedAt: new Date().toISOString()\n });\n \n await mockBlob.setJSON(\"address_cache_success2\", {\n name: \"Success 2\", \n resolvedAt: new Date().toISOString()\n });\n \n await mockBlob.setJSON(\"address_cache_failed1\", {\n failedAt: new Date().toISOString(),\n resolvedAt: new Date().toISOString()\n });\n\n const keys = await mockBlob.list(\"address_cache_\");\n assertEquals(keys.length, 3);\n \n // Count failed entries\n let failedCount = 0;\n for (const key of keys) {\n const cached = await mockBlob.getJSON(key);\n if (cached?.failedAt) failedCount++;\n }\n \n assertEquals(failedCount, 1);\n});",[],[265,307,314],{"_104":322,"_95":323,"_155":324,"_157":308,"_158":140,"_159":325,"_161":22,"_106":326,"_100":32,"_164":283,"_166":327,"_167":22,"_168":-5,"_169":328,"_98":329},"57f61b7e-58b4-11f0-9539-f69ea79377d9","database.test.ts","57f61c3c-58b4-11f0-9539-f69ea79377d9",16,["D",1751619204119],"import { assertEquals, assertExists } from \"https://deno.land/std@0.208.0/assert/mod.ts\";\n\n// Mock SQLite implementation for testing\nclass MockSQLite {\n private tables = new Map();\n private tableSchemas = new Map();\n\n async execute(query: string, params: any[] = []): Promise {\n const normalizedQuery = query.trim().toLowerCase();\n \n // Handle CREATE TABLE\n if (normalizedQuery.startsWith('create table')) {\n const tableName = this.extractTableName(query, 'create table');\n if (tableName) {\n this.tables.set(tableName, []);\n this.tableSchemas.set(tableName, query);\n }\n return [];\n }\n \n // Handle CREATE INDEX\n if (normalizedQuery.startsWith('create index')) {\n return [];\n }\n \n // Handle INSERT\n if (normalizedQuery.startsWith('insert')) {\n const tableName = this.extractTableName(query, 'insert');\n if (tableName && this.tables.has(tableName)) {\n const table = this.tables.get(tableName)!;\n // Extract field names from the query\n const fieldsMatch = query.match(/\\(([^)]+)\\)\\s*values/i);\n if (fieldsMatch) {\n const fieldNames = fieldsMatch[1].split(',').map(f => f.trim());\n const record: any = {};\n fieldNames.forEach((field, index) => {\n if (params[index] !== undefined) {\n record[field] = params[index];\n }\n });\n table.push(record);\n } else {\n // Fallback for checkins_v1\n const record: any = {};\n if (tableName === 'checkins_v1') {\n const fields = ['id', 'uri', 'author_did', 'author_handle', 'text', 'created_at', 'latitude', 'longitude', 'address_ref_uri', 'address_ref_cid'];\n fields.forEach((field, index) => {\n if (params[index] !== undefined) {\n record[field] = params[index];\n }\n });\n }\n table.push(record);\n }\n }\n return [];\n }\n \n // Handle SELECT\n if (normalizedQuery.startsWith('select')) {\n const tableName = this.extractTableName(query, 'from');\n if (tableName && this.tables.has(tableName)) {\n let results = [...this.tables.get(tableName)!];\n \n // Simple WHERE clause handling\n if (query.toLowerCase().includes('where') && params.length > 0) {\n if (query.toLowerCase().includes('id = ?')) {\n results = results.filter(row => row.id === params[0]);\n }\n if (query.toLowerCase().includes('author_did = ?')) {\n results = results.filter(row => row.author_did === params[0]);\n }\n }\n \n // Handle COUNT queries\n if (normalizedQuery.includes('count(*)')) {\n return [{ count: results.length }];\n }\n \n return results;\n }\n }\n \n return [];\n }\n\n private extractTableName(query: string, keyword: string): string | null {\n let regex: RegExp;\n \n if (keyword === 'create table') {\n regex = /create\\s+table\\s+(?:if\\s+not\\s+exists\\s+)?(\\w+)/i;\n } else if (keyword === 'insert') {\n regex = /insert\\s+(?:or\\s+ignore\\s+)?into\\s+(\\w+)/i;\n } else if (keyword === 'from') {\n regex = /from\\s+(\\w+)/i;\n } else {\n regex = new RegExp(`${keyword}\\\\s+(?:if\\\\s+not\\\\s+exists\\\\s+)?([\\\\w_]+)`, 'i');\n }\n \n const match = query.match(regex);\n return match ? match[1].toLowerCase() : null;\n }\n\n reset() {\n this.tables.clear();\n this.tableSchemas.clear();\n }\n}\n\nconst mockSqlite = new MockSQLite();\n\n// Test database table creation\nDeno.test(\"Database - table creation\", async () => {\n mockSqlite.reset();\n \n // Test checkins table creation\n await mockSqlite.execute(`\n CREATE TABLE IF NOT EXISTS checkins_v1 (\n id TEXT PRIMARY KEY,\n uri TEXT UNIQUE NOT NULL,\n author_did TEXT NOT NULL,\n author_handle TEXT,\n text TEXT NOT NULL,\n created_at TEXT NOT NULL,\n latitude REAL,\n longitude REAL,\n address_ref_uri TEXT,\n address_ref_cid TEXT,\n cached_address_name TEXT,\n cached_address_street TEXT,\n cached_address_locality TEXT,\n cached_address_region TEXT,\n cached_address_country TEXT,\n cached_address_postal_code TEXT,\n cached_address_full JSON,\n address_resolved_at TEXT,\n indexed_at TEXT DEFAULT CURRENT_TIMESTAMP\n )\n `);\n\n // Verify table was created\n const result = await mockSqlite.execute(\"SELECT * FROM checkins_v1\");\n assertEquals(Array.isArray(result), true);\n assertEquals(result.length, 0);\n});\n\nDeno.test(\"Database - checkin insertion and retrieval\", async () => {\n mockSqlite.reset();\n \n // Create table\n await mockSqlite.execute(`\n CREATE TABLE IF NOT EXISTS checkins_v1 (\n id TEXT PRIMARY KEY,\n uri TEXT UNIQUE NOT NULL,\n author_did TEXT NOT NULL,\n author_handle TEXT,\n text TEXT NOT NULL,\n created_at TEXT NOT NULL,\n latitude REAL,\n longitude REAL,\n address_ref_uri TEXT,\n address_ref_cid TEXT\n )\n `);\n\n // Insert test data\n await mockSqlite.execute(`\n INSERT INTO checkins_v1 \n (id, uri, author_did, author_handle, text, created_at, latitude, longitude, address_ref_uri, address_ref_cid)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?)\n `, [\n \"test123\",\n \"at://did:plc:test/app.dropanchor.checkin/test123\",\n \"did:plc:test\",\n \"test.bsky.social\",\n \"Great coffee!\",\n \"2024-01-01T12:00:00Z\",\n 40.7128,\n -74.0060,\n null,\n null\n ]);\n\n // Retrieve all checkins\n const allCheckins = await mockSqlite.execute(\"SELECT * FROM checkins_v1\");\n assertEquals(allCheckins.length, 1);\n assertEquals(allCheckins[0].id, \"test123\");\n assertEquals(allCheckins[0].text, \"Great coffee!\");\n\n // Test duplicate prevention\n const duplicateCheck = await mockSqlite.execute(\"SELECT id FROM checkins_v1 WHERE id = ?\", [\"test123\"]);\n assertEquals(duplicateCheck.length, 1);\n});\n\nDeno.test(\"Database - schema validation\", async () => {\n mockSqlite.reset();\n \n // Test that we can create all required tables without errors\n const tables = [\n 'checkins_v1',\n 'address_cache_v1', \n 'user_follows_v1',\n 'processing_log_v1'\n ];\n \n // Create checkins table\n await mockSqlite.execute(`\n CREATE TABLE IF NOT EXISTS checkins_v1 (\n id TEXT PRIMARY KEY,\n uri TEXT UNIQUE NOT NULL,\n author_did TEXT NOT NULL,\n text TEXT NOT NULL,\n created_at TEXT NOT NULL\n )\n `);\n \n // Create other tables\n await mockSqlite.execute(`CREATE TABLE IF NOT EXISTS address_cache_v1 (uri TEXT PRIMARY KEY)`);\n await mockSqlite.execute(`CREATE TABLE IF NOT EXISTS user_follows_v1 (follower_did TEXT, following_did TEXT)`);\n await mockSqlite.execute(`CREATE TABLE IF NOT EXISTS processing_log_v1 (id INTEGER PRIMARY KEY)`);\n \n // Verify all tables exist (mock should have them in memory)\n const mockInstance = mockSqlite as any;\n for (const table of tables) {\n assertEquals(mockInstance.tables.has(table), true, `Table ${table} should exist`);\n }\n});\n\nDeno.test(\"Database - count queries\", async () => {\n mockSqlite.reset();\n \n // Create and populate table\n await mockSqlite.execute(`\n CREATE TABLE IF NOT EXISTS checkins_v1 (\n id TEXT PRIMARY KEY,\n uri TEXT UNIQUE NOT NULL,\n author_did TEXT NOT NULL,\n text TEXT NOT NULL,\n created_at TEXT NOT NULL\n )\n `);\n\n // Insert test records\n for (let i = 1; i <= 5; i++) {\n await mockSqlite.execute(`\n INSERT INTO checkins_v1 (id, uri, author_did, text, created_at)\n VALUES (?, ?, ?, ?, ?)\n `, [`id${i}`, `uri${i}`, `did:plc:user${i}`, `text${i}`, \"2024-01-01T12:00:00Z\"]);\n }\n\n // Test count query\n const countResult = await mockSqlite.execute(\"SELECT COUNT(*) as count FROM checkins_v1\");\n assertEquals(countResult.length, 1);\n assertEquals(countResult[0].count, 5);\n});\n\nDeno.test(\"Database - address cache table operations\", async () => {\n mockSqlite.reset();\n\n // Create address cache table\n await mockSqlite.execute(`\n CREATE TABLE IF NOT EXISTS address_cache_v1 (\n uri TEXT PRIMARY KEY,\n cid TEXT,\n name TEXT,\n street TEXT,\n locality TEXT,\n region TEXT,\n country TEXT,\n postal_code TEXT,\n latitude REAL,\n longitude REAL,\n full_data JSON,\n resolved_at TEXT,\n failed_at TEXT\n )\n `);\n\n // Verify table creation\n const result = await mockSqlite.execute(\"SELECT * FROM address_cache_v1\");\n assertEquals(Array.isArray(result), true);\n});\n\nDeno.test(\"Database - processing logs\", async () => {\n mockSqlite.reset();\n\n // Create processing log table\n await mockSqlite.execute(`\n CREATE TABLE IF NOT EXISTS processing_log_v1 (\n id INTEGER PRIMARY KEY,\n run_at TEXT NOT NULL,\n events_processed INTEGER DEFAULT 0,\n errors INTEGER DEFAULT 0,\n duration_ms INTEGER\n )\n `);\n\n // Test table was created successfully\n const result = await mockSqlite.execute(\"SELECT * FROM processing_log_v1\");\n assertEquals(Array.isArray(result), true);\n});",[],[265,307,323],{"_104":331,"_95":332,"_155":333,"_157":308,"_158":140,"_159":334,"_161":22,"_106":335,"_100":32,"_164":283,"_166":336,"_167":22,"_168":-5,"_169":337,"_98":338},"58050dbe-58b4-11f0-9539-f69ea79377d9","handle-resolver.test.ts","58050e72-58b4-11f0-9539-f69ea79377d9",19,["D",1751619204218],"import { assertEquals, assertRejects } from \"https://deno.land/std@0.208.0/assert/mod.ts\";\nimport { stub, restore } from \"https://deno.land/std@0.208.0/testing/mock.ts\";\n\n// Import the functions to test\nimport { resolveHandle, batchResolveHandles } from \"../../src/utils/handle-resolver.ts\";\n\nDeno.test(\"Handle Resolver - resolveHandle success\", async () => {\n // Mock fetch to return a successful response\n const fetchStub = stub(globalThis, \"fetch\", () => {\n return Promise.resolve(new Response(JSON.stringify({\n handle: \"user.bsky.social\"\n }), { status: 200 }));\n });\n\n try {\n const result = await resolveHandle(\"did:plc:test123\");\n assertEquals(result, \"user.bsky.social\");\n } finally {\n restore();\n }\n});\n\nDeno.test(\"Handle Resolver - resolveHandle fallback to reverse lookup\", async () => {\n let callCount = 0;\n const fetchStub = stub(globalThis, \"fetch\", () => {\n callCount++;\n if (callCount === 1) {\n // First call fails\n return Promise.resolve(new Response(\"Not Found\", { status: 404 }));\n } else {\n // Second call (reverse lookup) succeeds\n return Promise.resolve(new Response(JSON.stringify({\n handle: \"fallback.bsky.social\"\n }), { status: 200 }));\n }\n });\n\n try {\n const result = await resolveHandle(\"did:plc:test123\");\n assertEquals(result, \"fallback.bsky.social\");\n assertEquals(callCount, 2); // Should have made 2 calls\n } finally {\n restore();\n }\n});\n\nDeno.test(\"Handle Resolver - resolveHandle returns shortened DID on total failure\", async () => {\n const fetchStub = stub(globalThis, \"fetch\", () => {\n return Promise.resolve(new Response(\"Error\", { status: 500 }));\n });\n\n try {\n const result = await resolveHandle(\"did:plc:abcdef123456\");\n assertEquals(result, \"abcdef12\"); // Should return shortened DID\n } finally {\n restore();\n }\n});\n\nDeno.test(\"Handle Resolver - batchResolveHandles processes multiple DIDs\", async () => {\n const fetchStub = stub(globalThis, \"fetch\", (url: string) => {\n if (url.includes(\"did:plc:user1\")) {\n return Promise.resolve(new Response(JSON.stringify({\n handle: \"user1.bsky.social\"\n }), { status: 200 }));\n } else if (url.includes(\"did:plc:user2\")) {\n return Promise.resolve(new Response(JSON.stringify({\n handle: \"user2.bsky.social\"\n }), { status: 200 }));\n }\n return Promise.resolve(new Response(\"Not Found\", { status: 404 }));\n });\n\n try {\n const dids = [\"did:plc:user1\", \"did:plc:user2\"];\n const result = await batchResolveHandles(dids);\n \n assertEquals(result.size, 2);\n assertEquals(result.get(\"did:plc:user1\"), \"user1.bsky.social\");\n assertEquals(result.get(\"did:plc:user2\"), \"user2.bsky.social\");\n } finally {\n restore();\n }\n});\n\nDeno.test(\"Handle Resolver - batchResolveHandles handles rate limiting\", async () => {\n const startTime = Date.now();\n \n const fetchStub = stub(globalThis, \"fetch\", () => {\n return Promise.resolve(new Response(JSON.stringify({\n handle: \"test.bsky.social\"\n }), { status: 200 }));\n });\n\n try {\n // Test with 6 DIDs (should create 2 batches of 5, with 1s delay)\n const dids = Array.from({ length: 6 }, (_, i) => `did:plc:user${i}`);\n await batchResolveHandles(dids);\n \n const duration = Date.now() - startTime;\n // Should take at least 1 second due to rate limiting between batches\n assertEquals(duration >= 1000, true);\n } finally {\n restore();\n }\n});",[],[265,307,332],{"_104":340,"_95":341,"_155":342,"_157":308,"_158":140,"_159":343,"_161":22,"_106":344,"_100":32,"_164":283,"_166":345,"_167":22,"_168":-5,"_169":346,"_98":347},"580105c0-58b4-11f0-a0a5-f69ea79377d9","spatial.test.ts","5801066a-58b4-11f0-a0a5-f69ea79377d9",18,["D",1751619204223],"import { assertEquals, assertAlmostEquals } from \"https://deno.land/std@0.208.0/assert/mod.ts\";\n\n// Haversine distance calculation (from the API code)\nfunction calculateDistance(lat1: number, lng1: number, lat2: number, lng2: number): 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\nDeno.test(\"Spatial - calculateDistance same point\", () => {\n const distance = calculateDistance(40.7128, -74.0060, 40.7128, -74.0060);\n assertEquals(distance, 0);\n});\n\nDeno.test(\"Spatial - calculateDistance New York to Los Angeles\", () => {\n // NYC: 40.7128° N, 74.0060° W\n // LA: 34.0522° N, 118.2437° W\n const distance = calculateDistance(40.7128, -74.0060, 34.0522, -118.2437);\n \n // Expected distance is approximately 3944 km\n assertAlmostEquals(distance, 3944, 50); // Allow 50km tolerance\n});\n\nDeno.test(\"Spatial - calculateDistance short distance\", () => {\n // Two points in Manhattan, approximately 1km apart\n const lat1 = 40.7589; // Times Square\n const lng1 = -73.9851;\n const lat2 = 40.7505; // Empire State Building \n const lng2 = -73.9934;\n \n const distance = calculateDistance(lat1, lng1, lat2, lng2);\n \n // Should be approximately 1.2 km\n assertAlmostEquals(distance, 1.2, 0.5);\n});\n\nDeno.test(\"Spatial - calculateDistance across equator\", () => {\n // Test crossing the equator\n const distance = calculateDistance(10, 0, -10, 0);\n \n // 20 degrees of latitude ≈ 2222 km\n assertAlmostEquals(distance, 2222, 50);\n});\n\nDeno.test(\"Spatial - calculateDistance across 180th meridian\", () => {\n // Test crossing the international date line\n const distance = calculateDistance(0, 179, 0, -179);\n \n // Should be about 222 km (2 degrees of longitude at equator)\n assertAlmostEquals(distance, 222, 50);\n});\n\nDeno.test(\"Spatial - distance filtering logic\", () => {\n interface TestCheckin {\n id: string;\n latitude: number;\n longitude: number;\n distance?: number;\n }\n\n const centerLat = 40.7128;\n const centerLng = -74.0060;\n const radius = 5; // 5km radius\n\n const checkins: TestCheckin[] = [\n { id: \"nearby1\", latitude: 40.7150, longitude: -74.0080 }, // ~250m away\n { id: \"nearby2\", latitude: 40.7200, longitude: -74.0100 }, // ~1km away\n { id: \"far1\", latitude: 40.8000, longitude: -74.0000 }, // ~10km away\n { id: \"far2\", latitude: 41.0000, longitude: -74.0000 }, // ~32km away\n ];\n\n // Calculate distances and filter\n const nearbyCheckins = checkins\n .map(checkin => ({\n ...checkin,\n distance: calculateDistance(centerLat, centerLng, checkin.latitude, checkin.longitude)\n }))\n .filter(checkin => checkin.distance <= radius)\n .sort((a, b) => a.distance - b.distance);\n\n // Should have 2 nearby checkins\n assertEquals(nearbyCheckins.length, 2);\n assertEquals(nearbyCheckins[0].id, \"nearby1\");\n assertEquals(nearbyCheckins[1].id, \"nearby2\");\n \n // Verify distances are calculated and within radius\n assertEquals(nearbyCheckins[0].distance! < radius, true);\n assertEquals(nearbyCheckins[1].distance! < radius, true);\n \n // Verify sorting by distance\n assertEquals(nearbyCheckins[0].distance! <= nearbyCheckins[1].distance!, true);\n});\n\nDeno.test(\"Spatial - coordinate validation\", () => {\n // Test invalid coordinates\n const invalidLat = calculateDistance(91, 0, 0, 0); // Latitude > 90\n assertEquals(isNaN(invalidLat), false); // Should still calculate, even if unrealistic\n \n const invalidLng = calculateDistance(0, 181, 0, 0); // Longitude > 180\n assertEquals(isNaN(invalidLng), false); // Should still calculate\n});\n\nDeno.test(\"Spatial - precision rounding\", () => {\n const distance = calculateDistance(40.7128, -74.0060, 40.7130, -74.0062);\n const rounded = Math.round(distance * 100) / 100; // 2 decimal places\n \n // Should be a very small distance, properly rounded\n assertEquals(typeof rounded, \"number\");\n assertEquals(rounded >= 0, true);\n assertEquals(rounded < 1, true); // Should be less than 1km\n});\n\nDeno.test(\"Spatial - boundary conditions\", () => {\n // Test at the poles\n const northPole1 = calculateDistance(90, 0, 90, 180);\n assertAlmostEquals(northPole1, 0, 0.001); // All points at north pole are the same (within 1m)\n \n // Test at extreme longitudes\n const extremeLng = calculateDistance(0, -180, 0, 180);\n assertAlmostEquals(extremeLng, 0, 0.001); // -180 and 180 longitude are the same meridian (within 1m)\n});",[],[265,307,341],[265,307],[265],{"_104":351,"_95":352,"_155":353,"_157":-5,"_158":140,"_159":354,"_161":22,"_106":355,"_100":32,"_164":177,"_166":356,"_167":22,"_168":-5,"_169":357,"_98":358},"5815fa7a-58b4-11f0-aaa5-f69ea79377d9","deno.json","5815fb42-58b4-11f0-aaa5-f69ea79377d9",22,["D",1751619204362],"{\n \"$schema\": \"https://raw.githubusercontent.com/denoland/deno/348900b8b79f4a434cab4c74b3bc8d4d2fa8ee74/cli/schemas/config-file.v1.json\",\n \"lock\": false,\n \"compilerOptions\": {\n \"noImplicitAny\": false,\n \"strict\": false,\n \"types\": [\n \"https://www.val.town/types/valtown.d.ts\"\n ],\n \"lib\": [\n \"dom\",\n \"dom.iterable\",\n \"dom.asynciterable\",\n \"deno.ns\",\n \"deno.unstable\"\n ]\n },\n \"lint\": {\n \"files\": {\n \"include\": [\n \"deno:/https/esm.town/**/*\"\n ]\n },\n \"rules\": {\n \"exclude\": [\n \"no-explicit-any\"\n ]\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 \"tasks\": {\n \"test\": \"deno test --allow-all tests/\",\n \"test:unit\": \"deno test --allow-all tests/unit/\",\n \"test:integration\": \"deno test --allow-all tests/integration/\",\n \"test:watch\": \"deno test --allow-all --watch tests/\"\n }\n}",[],[352],{"_104":360,"_95":361,"_155":362,"_157":-5,"_158":140,"_159":120,"_161":22,"_106":363,"_100":32,"_164":283,"_166":72,"_167":22,"_168":364,"_169":365,"_98":366},"db7d9232-58ab-11f0-bdec-f69ea79377d9","main.tsx","db7d92c8-58ab-11f0-bdec-f69ea79377d9",["D",1751615559352],"dropanchor",[],[361],"files",[152,171,182,189,199,206,215,223,230,238,246,254,263,270,277,288,295,305,312,321,330,339,350,359],"counts",{"_371":32,"_372":120,"_373":32,"_374":227},"pulls","branches","forks","envVars","contents",[],{"_104":247,"_95":248,"_155":249,"_157":226,"_158":140,"_159":250,"_161":22,"_106":378,"_100":32,"_164":165,"_166":-5,"_167":22,"_168":-5,"_98":379},["D",1751619203754],[225,248],"upstreamProject","upstreamBranch","emptyEnvVars","isNew","flags",[],"routes/_app.x.$handle.$name.branch.$branch.version.$version.code.$",{"_93":94,"_95":96,"_97":43,"_100":101,"_98":99,"_102":388,"_150":393,"_367":466,"_177":467,"_375":469,"_470":-5,"_471":22,"_472":-5,"_473":-5,"_474":-5,"_475":476},{"_104":105,"_95":96,"_106":389,"_108":-5,"_109":22,"_110":111,"_112":113,"_114":-5,"_14":115,"_116":-5,"_117":22,"_118":-5,"_119":120,"_16":121,"_122":123,"_124":123,"_125":126,"_127":126,"_128":126,"_129":123,"_130":123,"_23":390,"_134":391,"_137":392,"_149":22},["D",1751615559344],{"_93":94,"_132":133},{"_93":94,"_136":133},{"_100":139,"_95":43,"_104":140,"_141":105,"_142":-5,"_143":-5,"_144":-5,"_145":-5,"_146":-5,"_147":96,"_148":94},[394,400,406,412,415,430,460,463],{"_104":153,"_95":154,"_155":156,"_157":-5,"_158":140,"_159":160,"_161":162,"_106":163,"_100":32,"_164":165,"_166":-5,"_167":22,"_168":-5,"_169":395,"_98":399},[396],{"_104":172,"_95":173,"_155":174,"_157":156,"_158":140,"_159":175,"_161":22,"_106":176,"_100":32,"_164":177,"_166":178,"_167":22,"_168":-5,"_169":397,"_98":398},[],[154,173],[154],{"_104":183,"_95":184,"_155":185,"_157":-5,"_158":140,"_159":186,"_161":162,"_106":187,"_100":32,"_164":165,"_166":-5,"_167":22,"_168":-5,"_169":401,"_98":405},[402],{"_104":190,"_95":191,"_155":192,"_157":185,"_158":140,"_159":193,"_161":22,"_106":194,"_100":32,"_164":177,"_166":195,"_167":22,"_168":-5,"_169":403,"_98":404},[],[184,191],[184],{"_104":200,"_95":201,"_155":202,"_157":-5,"_158":140,"_159":203,"_161":162,"_106":204,"_100":32,"_164":165,"_166":-5,"_167":22,"_168":-5,"_169":407,"_98":411},[408],{"_104":207,"_95":208,"_155":209,"_157":202,"_158":140,"_159":101,"_161":22,"_106":210,"_100":32,"_164":177,"_166":211,"_167":22,"_168":-5,"_169":409,"_98":410},[],[201,208],[201],{"_104":216,"_95":217,"_155":218,"_157":-5,"_158":140,"_159":219,"_161":22,"_106":220,"_100":32,"_164":165,"_166":-5,"_167":22,"_168":-5,"_169":413,"_98":414},[],[217],{"_104":224,"_95":225,"_155":226,"_157":-5,"_158":140,"_159":227,"_161":22,"_106":228,"_100":32,"_164":165,"_166":-5,"_167":22,"_168":-5,"_169":416,"_98":429},[417,420,423,426],{"_104":231,"_95":232,"_155":233,"_157":226,"_158":140,"_159":234,"_161":22,"_106":235,"_100":32,"_164":165,"_166":-5,"_167":22,"_168":-5,"_169":418,"_98":419},[],[225,232],{"_104":239,"_95":240,"_155":241,"_157":226,"_158":140,"_159":242,"_161":22,"_106":243,"_100":32,"_164":165,"_166":-5,"_167":22,"_168":-5,"_169":421,"_98":422},[],[225,240],{"_104":247,"_95":248,"_155":249,"_157":226,"_158":140,"_159":250,"_161":22,"_106":251,"_100":32,"_164":165,"_166":-5,"_167":22,"_168":-5,"_169":424,"_98":425},[],[225,248],{"_104":255,"_95":256,"_155":257,"_157":226,"_158":140,"_159":258,"_161":22,"_106":259,"_100":32,"_164":165,"_166":-5,"_167":22,"_168":-5,"_169":427,"_98":428},[],[225,256],[225],{"_104":264,"_95":265,"_155":266,"_157":-5,"_158":140,"_159":267,"_161":162,"_106":268,"_100":32,"_164":165,"_166":-5,"_167":22,"_168":-5,"_169":431,"_98":459},[432,438,444],{"_104":271,"_95":272,"_155":273,"_157":266,"_158":140,"_159":274,"_161":162,"_106":275,"_100":32,"_164":165,"_166":-5,"_167":22,"_168":-5,"_169":433,"_98":437},[434],{"_104":278,"_95":279,"_155":280,"_157":273,"_158":140,"_159":281,"_161":22,"_106":282,"_100":32,"_164":283,"_166":284,"_167":22,"_168":-5,"_169":435,"_98":436},[],[265,272,279],[265,272],{"_104":289,"_95":290,"_155":291,"_157":266,"_158":140,"_159":292,"_161":162,"_106":293,"_100":32,"_164":165,"_166":-5,"_167":22,"_168":-5,"_169":439,"_98":443},[440],{"_104":296,"_95":297,"_155":298,"_157":291,"_158":140,"_159":299,"_161":22,"_106":300,"_100":32,"_164":283,"_166":301,"_167":22,"_168":-5,"_169":441,"_98":442},[],[265,290,297],[265,290],{"_104":306,"_95":307,"_155":308,"_157":266,"_158":140,"_159":309,"_161":162,"_106":310,"_100":32,"_164":165,"_166":-5,"_167":22,"_168":-5,"_169":445,"_98":458},[446,449,452,455],{"_104":313,"_95":314,"_155":315,"_157":308,"_158":140,"_159":316,"_161":22,"_106":317,"_100":32,"_164":283,"_166":318,"_167":22,"_168":-5,"_169":447,"_98":448},[],[265,307,314],{"_104":322,"_95":323,"_155":324,"_157":308,"_158":140,"_159":325,"_161":22,"_106":326,"_100":32,"_164":283,"_166":327,"_167":22,"_168":-5,"_169":450,"_98":451},[],[265,307,323],{"_104":331,"_95":332,"_155":333,"_157":308,"_158":140,"_159":334,"_161":22,"_106":335,"_100":32,"_164":283,"_166":336,"_167":22,"_168":-5,"_169":453,"_98":454},[],[265,307,332],{"_104":340,"_95":341,"_155":342,"_157":308,"_158":140,"_159":343,"_161":22,"_106":344,"_100":32,"_164":283,"_166":345,"_167":22,"_168":-5,"_169":456,"_98":457},[],[265,307,341],[265,307],[265],{"_104":351,"_95":352,"_155":353,"_157":-5,"_158":140,"_159":354,"_161":22,"_106":355,"_100":32,"_164":177,"_166":356,"_167":22,"_168":-5,"_169":461,"_98":462},[],[352],{"_104":360,"_95":361,"_155":362,"_157":-5,"_158":140,"_159":120,"_161":22,"_106":363,"_100":32,"_164":283,"_166":72,"_167":22,"_168":364,"_169":464,"_98":465},[],[361],[394,396,400,402,406,408,412,415,417,420,423,426,430,432,434,438,440,444,446,449,452,455,460,463],{"_104":247,"_95":248,"_155":249,"_157":226,"_158":140,"_159":250,"_161":22,"_106":378,"_100":32,"_164":165,"_166":-5,"_167":22,"_168":-5,"_98":468},[225,248],[],"upstream","showCompareCallout","pull","ahead","behind","templates",[],"actionData","errors"]