[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_315":316,"_317":318},"routes/_app.x.$handle.$name",{"_92":91,"_31":42,"_101":82,"_26":102,"_13":14,"_103":-5,"_11":104,"_105":106,"_107":108,"_109":110,"_111":112,"_20":-5,"_113":-5,"_114":-5,"_115":24,"_116":117,"_118":119,"_120":-5,"_121":-5,"_122":123},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_40":41,"_31":42,"_35":43,"_44":-5,"_45":24,"_46":47,"_48":47,"_49":50,"_51":-5,"_18":52,"_53":-5,"_54":24,"_55":-5,"_56":-5,"_57":58,"_59":60,"_61":-5,"_62":-5,"_63":-5,"_64":-5,"_65":66,"_67":66,"_68":69,"_70":69,"_71":69,"_72":66,"_73":66,"_74":75,"_76":77,"_78":79,"_80":24},"version",18,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":-7,"_23":24,"_25":24,"_26":27,"_28":27},"file",{"_29":30,"_31":27,"_32":20,"_33":34,"_35":36,"_37":14,"_38":39,"_23":24},"previous","deleted",false,"deletedHere","path","README.md","latestPath","fileId","1efd9b5a-0a91-11f1-9f65-42dde27851f2","name","fileType","content","# OpenPDS\n\nDirectory of AT Protocol PDS servers with open registration.\n\nPulls data from\n[mary-ext/atproto-scraping](https://github.com/mary-ext/atproto-scraping),\nenriches it with server metadata (version, user count, geo-location, contact\ninfo), and presents a browsable directory.\n\n## How it works\n\nA daily cron job:\n\n1. Fetches `state.json` listing ~2900 known PDSes with signup status\n2. Syncs open/closed status to a SQLite database\n3. Enriches a batch of 20 servers per run (health, describeServer, listRepos,\n geo-IP)\n4. Checks for the latest PDS version from the `bluesky-social/pds` GitHub repo\n\nThe web interface shows open servers with sortable columns, version badges, and\ntrust signals.\n\n## Endpoints\n\n- `/` — HTML directory page\n- `/api/servers` — JSON API with all open servers and metadata\n\n## Development\n\n```bash\ndeno task check # type check\ndeno task quality # fmt + lint + check\ndeno task deploy # quality + vt push\n```\n\n## Data sources\n\n- [atproto-scraping state.json](https://github.com/mary-ext/atproto-scraping) —\n PDS list and signup status\n- [dns.google](https://dns.google) — hostname to IP resolution\n- [ip-api.com](http://ip-api.com) — IP to country geo-lookup\n- [GitHub API](https://api.github.com) — latest PDS version tag\n","createdAt",["D",1771175383120],"branchVersion","branchId","1d3b78dc-0a91-11f1-9151-42dde27851f2","id","1d3a5aa6-0a91-11f1-9151-42dde27851f2","openpds",["D",1771175379615],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","AT Protocol PDS servers with open registration.","imageUrl","14049850-28c1-11f0-89c9-c7d0e2d9e1ea","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","c04d51b2-a7dc-46ca-ad6f-52f47c2906a8","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_92":91,"_100":96},"org",{"_92":91,"_93":94,"_95":96,"_18":52,"_97":98,"_99":24},"branch",{"_13":81,"_31":82,"_40":39,"_83":41,"_84":-5,"_85":-5,"_86":-5,"_87":-5,"_88":-5,"_89":42,"_90":91},"isOwned",102,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","tijs","handle","displayName","Tijs","avatar","https://img.clerk.com/eyJ0eXBlIjoicHJveHkiLCJzcmMiOiJodHRwczovL2ltYWdlcy5jbGVyay5kZXYvb2F1dGhfZ2l0aHViL2ltZ18yd2Nod2N0bE1MWFdEUlRYd083ZE5pbXJ1bDAifQ","tier","pro","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_40":41,"_31":42,"_35":311,"_44":-5,"_45":24,"_46":47,"_48":47,"_49":50,"_51":-5,"_18":52,"_53":-5,"_54":24,"_55":-5,"_56":-5,"_57":58,"_59":60,"_61":-5,"_62":-5,"_63":-5,"_64":-5,"_65":66,"_67":66,"_68":69,"_70":69,"_71":69,"_72":66,"_73":66,"_74":312,"_76":313,"_78":314,"_80":24},"tree",[180,193,194,195,196,197],"files",[180,181,182,183,184,185,186,187,188,189,190,191,192,193,194,195,196,197],"counts",{"_170":58,"_171":167,"_172":58,"_173":174,"_175":176},"contents",[126,127,128,129,130,131],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles",true,"grants","orgs","customDomains",{"_124":125},"1ed9a0b0-0a91-11f1-9740-42dde27851f2","openpds.tijs.org",{"_40":164,"_31":165,"_29":166,"_135":-5,"_38":39,"_37":167,"_137":119,"_35":168,"_13":58,"_32":150,"_33":-5,"_23":24,"_140":-5,"_26":169},{"_40":158,"_31":159,"_29":160,"_135":-5,"_38":39,"_37":161,"_137":119,"_35":162,"_13":58,"_32":150,"_33":-5,"_23":24,"_140":-5,"_26":163},{"_40":152,"_31":153,"_29":154,"_135":-5,"_38":39,"_37":155,"_137":24,"_35":156,"_13":58,"_32":150,"_33":-5,"_23":24,"_140":-5,"_26":157},{"_40":145,"_31":146,"_29":147,"_135":-5,"_38":39,"_37":148,"_137":119,"_35":149,"_13":58,"_32":150,"_33":-5,"_23":24,"_140":-5,"_26":151},{"_40":142,"_31":27,"_29":30,"_135":-5,"_38":39,"_37":14,"_137":119,"_35":143,"_13":58,"_32":20,"_33":34,"_23":24,"_140":-5,"_26":144},{"_40":132,"_31":133,"_29":134,"_135":-5,"_38":39,"_37":136,"_137":24,"_35":138,"_13":58,"_32":20,"_33":139,"_23":24,"_140":-5,"_26":141},"1eafafb2-0a91-11f1-afb2-42dde27851f2","deno.json","1eafb070-0a91-11f1-afb2-42dde27851f2","parentId",8,"latest",["D",1771175382646],"{\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\": [\"https://www.val.town/types/valtown.d.ts\"],\n \"lib\": [\n \"dom\",\n \"dom.iterable\",\n \"dom.asynciterable\",\n \"deno.ns\",\n \"deno.unstable\"\n ]\n },\n \"lint\": {\n \"include\": [\"**/*.ts\"],\n \"rules\": { \"exclude\": [\"no-explicit-any\", \"no-import-prefix\"] }\n },\n \"node_modules_dir\": false,\n \"tasks\": {\n \"check\": \"deno check --allow-import backend/index.http.ts cron/refresh.cron.ts\",\n \"quality\": \"deno fmt && deno lint && deno task check\",\n \"deploy\": \"deno task quality && vt push\"\n }\n}\n","label",[133],"1efd9ab0-0a91-11f1-9f65-42dde27851f2",["D",1771175383120],[27],"1df465fe-0a91-11f1-ac04-42dde27851f2","shared","1df466e4-0a91-11f1-ac04-42dde27851f2",2,["D",1771175381422],"directory",[146],"1e17be1e-0a91-11f1-9455-42dde27851f2","openen","1e17bedc-0a91-11f1-9455-42dde27851f2",3,["D",1771175381651],[153],"1e3f9592-0a91-11f1-a289-42dde27851f2","cron","1e3f9650-0a91-11f1-a289-42dde27851f2",4,["D",1771175381915],[159],"1dd5afa6-0a91-11f1-a289-42dde27851f2","backend","1dd5b05a-0a91-11f1-a289-42dde27851f2",1,["D",1771175381220],[165],"pulls","branches","forks","envVars",{"_177":58,"_179":58},"connections",{"_177":58,"_178":58},"count","unfilledCount","emptyCount",{"_40":164,"_31":165,"_29":166,"_135":-5,"_38":39,"_37":167,"_137":119,"_35":308,"_13":58,"_32":150,"_33":-5,"_23":24,"_140":-5,"_199":309,"_26":310},{"_40":303,"_31":294,"_29":288,"_135":166,"_38":39,"_37":304,"_137":119,"_35":305,"_13":58,"_32":150,"_33":-5,"_23":24,"_140":-5,"_199":306,"_26":307},{"_40":295,"_31":296,"_29":297,"_135":288,"_38":39,"_37":298,"_137":24,"_35":299,"_13":58,"_32":228,"_33":300,"_23":24,"_140":-5,"_199":301,"_26":302},{"_40":285,"_31":286,"_29":287,"_135":288,"_38":39,"_37":289,"_137":24,"_35":290,"_13":58,"_32":228,"_33":291,"_23":24,"_140":-5,"_199":292,"_26":293},{"_40":280,"_31":271,"_29":265,"_135":166,"_38":39,"_37":281,"_137":119,"_35":282,"_13":58,"_32":150,"_33":-5,"_23":24,"_140":-5,"_199":283,"_26":284},{"_40":272,"_31":273,"_29":274,"_135":265,"_38":39,"_37":275,"_137":24,"_35":276,"_13":58,"_32":228,"_33":277,"_23":24,"_140":-5,"_199":278,"_26":279},{"_40":262,"_31":263,"_29":264,"_135":265,"_38":39,"_37":266,"_137":24,"_35":267,"_13":58,"_32":228,"_33":268,"_23":24,"_140":-5,"_199":269,"_26":270},{"_40":257,"_31":232,"_29":225,"_135":166,"_38":39,"_37":258,"_137":119,"_35":259,"_13":58,"_32":150,"_33":-5,"_23":24,"_140":-5,"_199":260,"_26":261},{"_40":249,"_31":250,"_29":251,"_135":225,"_38":39,"_37":252,"_137":119,"_35":253,"_13":58,"_32":228,"_33":254,"_23":24,"_140":-5,"_199":255,"_26":256},{"_40":241,"_31":242,"_29":243,"_135":225,"_38":39,"_37":244,"_137":24,"_35":245,"_13":58,"_32":228,"_33":246,"_23":24,"_140":-5,"_199":247,"_26":248},{"_40":233,"_31":234,"_29":235,"_135":225,"_38":39,"_37":236,"_137":24,"_35":237,"_13":58,"_32":228,"_33":238,"_23":24,"_140":-5,"_199":239,"_26":240},{"_40":222,"_31":223,"_29":224,"_135":225,"_38":39,"_37":226,"_137":24,"_35":227,"_13":58,"_32":228,"_33":229,"_23":24,"_140":-5,"_199":230,"_26":231},{"_40":214,"_31":215,"_29":124,"_135":166,"_38":39,"_37":216,"_137":24,"_35":217,"_13":58,"_32":218,"_33":219,"_23":24,"_140":42,"_199":220,"_26":221},{"_40":158,"_31":159,"_29":160,"_135":-5,"_38":39,"_37":161,"_137":119,"_35":211,"_13":58,"_32":150,"_33":-5,"_23":24,"_140":-5,"_199":212,"_26":213},{"_40":152,"_31":153,"_29":154,"_135":-5,"_38":39,"_37":155,"_137":24,"_35":208,"_13":58,"_32":150,"_33":-5,"_23":24,"_140":-5,"_199":209,"_26":210},{"_40":145,"_31":146,"_29":147,"_135":-5,"_38":39,"_37":148,"_137":119,"_35":205,"_13":58,"_32":150,"_33":-5,"_23":24,"_140":-5,"_199":206,"_26":207},{"_40":142,"_31":27,"_29":30,"_135":-5,"_38":39,"_37":14,"_137":119,"_35":202,"_13":58,"_32":20,"_33":34,"_23":24,"_140":-5,"_199":203,"_26":204},{"_40":132,"_31":133,"_29":134,"_135":-5,"_38":39,"_37":136,"_137":24,"_35":198,"_13":58,"_32":20,"_33":139,"_23":24,"_140":-5,"_199":200,"_26":201},["D",1771175382646],"children",[],[133],["D",1771175383120],[],[27],["D",1771175381422],[],[146],["D",1771175381651],[],[153],["D",1771175381915],[],[159],"1ed99eb2-0a91-11f1-9740-42dde27851f2","index.http.ts",14,["D",1771175382903],"http","import { Hono } from \"https://esm.sh/hono@4.4.0\";\nimport { runMigrations } from \"./database/migrations.ts\";\nimport { pages } from \"./routes/pages.ts\";\nimport { api } from \"./routes/api.ts\";\n\nconst app = new Hono();\n\napp.onError((err, _c) => {\n throw err;\n});\n\nlet migrationsRan = false;\napp.use(\"*\", async (_c, next) => {\n if (!migrationsRan) {\n await runMigrations();\n migrationsRan = true;\n }\n await next();\n});\n\napp.route(\"/api\", api);\napp.route(\"/\", pages);\n\nexport default app.fetch;\n",[],[165,215],"1ede6cbc-0a91-11f1-b423-42dde27851f2","version-checker.ts","1ede6d98-0a91-11f1-b423-42dde27851f2","1e950220-0a91-11f1-987b-42dde27851f2",15,["D",1771175382923],"script","import { PDS_REPO_NAME, PDS_REPO_OWNER } from \"../../shared/constants.ts\";\n\n/** Fetch the latest PDS release version from GitHub */\nexport async function fetchLatestPdsVersion(): Promise {\n const url =\n `https://api.github.com/repos/${PDS_REPO_OWNER}/${PDS_REPO_NAME}/tags?per_page=5`;\n\n const resp = await fetch(url, {\n headers: { \"Accept\": \"application/vnd.github.v3+json\" },\n });\n\n if (!resp.ok) {\n console.error(`GitHub API error: ${resp.status}`);\n return null;\n }\n\n const tags: Array<{ name: string }> = await resp.json();\n if (tags.length === 0) return null;\n\n // Tags are like \"v0.4.74\" — return the first (most recent)\n return tags[0].name;\n}\n",[],[165,232,223],"services","1ef5c61e-0a91-11f1-a315-42dde27851f2","pds-fetcher.ts","1ef5c6d2-0a91-11f1-a315-42dde27851f2",17,["D",1771175383107],"import { STATE_JSON_URL } from \"../../shared/constants.ts\";\nimport type { StateJson } from \"../../shared/types.ts\";\n\nexport type FilteredPds = {\n url: string;\n inviteCodeRequired: boolean;\n version: string;\n errorAt: number | null;\n isOpen: boolean;\n};\n\n/** Fetch state.json and return all PDSes with their open status */\nexport async function fetchPdsList(): Promise {\n const resp = await fetch(STATE_JSON_URL);\n if (!resp.ok) {\n throw new Error(`Failed to fetch state.json: ${resp.status}`);\n }\n\n const data: StateJson = await resp.json();\n const results: FilteredPds[] = [];\n\n for (const [url, entry] of Object.entries(data.pdses)) {\n const isOpen = !entry.inviteCodeRequired && !entry.errorAt;\n results.push({\n url,\n inviteCodeRequired: entry.inviteCodeRequired,\n version: entry.version,\n errorAt: entry.errorAt ?? null,\n isOpen,\n });\n }\n\n return results;\n}\n",[],[165,232,234],"1eedceaa-0a91-11f1-82a1-42dde27851f2","pds-enricher.ts","1eedcf72-0a91-11f1-82a1-42dde27851f2",16,["D",1771175383056],"import { PDS_REQUEST_TIMEOUT_MS } from \"../../shared/constants.ts\";\nimport type {\n DescribeServerResponse,\n HealthResponse,\n} from \"../../shared/types.ts\";\nimport { batchGeoLookup, resolveIp } from \"./geo-resolver.ts\";\n\nexport type EnrichmentResult = {\n url: string;\n version: string | null;\n did: string | null;\n phoneVerification: boolean;\n userDomains: string[];\n contactEmail: string | null;\n privacyPolicy: string | null;\n termsOfService: string | null;\n userCount: number | null;\n ipAddress: string | null;\n countryCode: string | null;\n countryName: string | null;\n};\n\n/** Enrich a batch of PDS URLs with metadata */\nexport async function enrichBatch(urls: string[]): Promise {\n // Step 1: Fetch PDS endpoints concurrently\n const pdsResults = await Promise.allSettled(\n urls.map((url) => enrichSinglePds(url)),\n );\n\n const results: EnrichmentResult[] = [];\n const ipMap = new Map();\n\n for (let i = 0; i < urls.length; i++) {\n const r = pdsResults[i];\n if (r.status === \"fulfilled\") {\n results.push(r.value);\n if (r.value.ipAddress) {\n ipMap.set(r.value.url, r.value.ipAddress);\n }\n } else {\n console.error(`Enrichment failed for ${urls[i]}:`, r.reason);\n // Return a minimal result so we still update last_enriched\n results.push(emptyResult(urls[i]));\n }\n }\n\n // Step 2: Batch geo-IP lookup\n const geoData = await batchGeoLookup(ipMap);\n for (const result of results) {\n const geo = geoData.get(result.url);\n if (geo) {\n result.countryCode = geo.countryCode;\n result.countryName = geo.countryName;\n }\n }\n\n return results;\n}\n\nasync function enrichSinglePds(url: string): Promise {\n const result = emptyResult(url);\n const signal = AbortSignal.timeout(PDS_REQUEST_TIMEOUT_MS);\n\n // Resolve IP from hostname\n const hostname = new URL(url).hostname;\n result.ipAddress = await resolveIp(hostname);\n\n // Fetch health, describeServer, and listRepos concurrently\n const [health, describe, userCount] = await Promise.allSettled([\n fetchHealth(url, signal),\n fetchDescribeServer(url, signal),\n fetchUserCount(url, signal),\n ]);\n\n if (health.status === \"fulfilled\" && health.value) {\n result.version = health.value.version ?? null;\n }\n\n if (describe.status === \"fulfilled\" && describe.value) {\n const d = describe.value;\n result.did = d.did;\n result.userDomains = d.availableUserDomains ?? [];\n result.phoneVerification = d.phoneVerificationRequired ?? false;\n result.contactEmail = d.contact?.email ?? null;\n result.privacyPolicy = d.links?.privacyPolicy ?? null;\n result.termsOfService = d.links?.termsOfService ?? null;\n }\n\n if (userCount.status === \"fulfilled\") {\n result.userCount = userCount.value;\n }\n\n return result;\n}\n\nasync function fetchHealth(\n url: string,\n signal: AbortSignal,\n): Promise {\n try {\n const resp = await fetch(`${url}/xrpc/_health`, { signal });\n if (!resp.ok) return null;\n return await resp.json();\n } catch {\n return null;\n }\n}\n\nasync function fetchDescribeServer(\n url: string,\n signal: AbortSignal,\n): Promise {\n try {\n const resp = await fetch(\n `${url}/xrpc/com.atproto.server.describeServer`,\n { signal },\n );\n if (!resp.ok) return null;\n return await resp.json();\n } catch {\n return null;\n }\n}\n\nasync function fetchUserCount(\n url: string,\n signal: AbortSignal,\n): Promise {\n try {\n const resp = await fetch(\n `${url}/xrpc/com.atproto.sync.listRepos?limit=1000`,\n { signal },\n );\n if (!resp.ok) return null;\n const data = await resp.json();\n const repos: unknown[] = data.repos ?? [];\n // If there's a cursor, there are more than 1000\n return data.cursor ? 1000 : repos.length;\n } catch {\n return null;\n }\n}\n\nfunction emptyResult(url: string): EnrichmentResult {\n return {\n url,\n version: null,\n did: null,\n phoneVerification: false,\n userDomains: [],\n contactEmail: null,\n privacyPolicy: null,\n termsOfService: null,\n userCount: null,\n ipAddress: null,\n countryCode: null,\n countryName: null,\n };\n}\n",[],[165,232,242],"1ed2b034-0a91-11f1-a09a-42dde27851f2","geo-resolver.ts","1ed2b0e8-0a91-11f1-a09a-42dde27851f2",13,["D",1771175382877],"import type { DnsResponse, GeoIpResult } from \"../../shared/types.ts\";\n\n/** Resolve hostname to IP address via DNS-over-HTTPS */\nexport async function resolveIp(hostname: string): Promise {\n try {\n const resp = await fetch(\n `https://dns.google/resolve?name=${encodeURIComponent(hostname)}&type=A`,\n { signal: AbortSignal.timeout(5000) },\n );\n if (!resp.ok) return null;\n\n const data: DnsResponse = await resp.json();\n if (!data.Answer || data.Answer.length === 0) return null;\n\n // Return the last A record (usually the actual IP after CNAMEs)\n return data.Answer[data.Answer.length - 1].data;\n } catch {\n return null;\n }\n}\n\n/** Batch geo-IP lookup for up to 100 IPs */\nexport async function batchGeoLookup(\n ipMap: Map,\n): Promise> {\n const results = new Map<\n string,\n { countryCode: string; countryName: string }\n >();\n if (ipMap.size === 0) return results;\n\n // ip-api.com batch endpoint: POST array of IPs\n const ips = [...new Set(ipMap.values())].filter(Boolean);\n if (ips.length === 0) return results;\n\n try {\n const resp = await fetch(\n \"http://ip-api.com/batch?fields=status,query,country,countryCode\",\n {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify(ips),\n signal: AbortSignal.timeout(10000),\n },\n );\n\n if (!resp.ok) {\n console.error(`ip-api.com batch error: ${resp.status}`);\n return results;\n }\n\n const geoResults: GeoIpResult[] = await resp.json();\n\n // Build IP → geo map\n const ipToGeo = new Map<\n string,\n { countryCode: string; countryName: string }\n >();\n for (const r of geoResults) {\n if (r.status === \"success\") {\n ipToGeo.set(r.query, {\n countryCode: r.countryCode,\n countryName: r.country,\n });\n }\n }\n\n // Map hostnames back to geo data via their IPs\n for (const [hostname, ip] of ipMap) {\n const geo = ipToGeo.get(ip);\n if (geo) results.set(hostname, geo);\n }\n } catch (err) {\n console.error(\"Geo lookup failed:\", err);\n }\n\n return results;\n}\n",[],[165,232,250],"1e95013a-0a91-11f1-987b-42dde27851f2",7,["D",1771175382473],[188,189,190,191],[165,232],"1eb91ac0-0a91-11f1-aa7d-42dde27851f2","pages.ts","1eb91b88-0a91-11f1-aa7d-42dde27851f2","1e7af3e4-0a91-11f1-a09a-42dde27851f2",10,["D",1771175382678],"import { Hono } from \"https://esm.sh/hono@4.4.0\";\nimport {\n getMetadata,\n getOpenServers,\n getServerCount,\n} from \"../database/queries.ts\";\nimport { countryFlag } from \"../../shared/constants.ts\";\nimport type {\n PdsServer,\n SortDirection,\n SortField,\n} from \"../../shared/types.ts\";\n\nconst pages = new Hono();\n\npages.get(\"/\", async (c) => {\n const sort = (c.req.query(\"sort\") || \"users\") as SortField;\n const dir = (c.req.query(\"dir\") || \"desc\") as SortDirection;\n const showOutdated = c.req.query(\"show_outdated\") === \"true\";\n\n const [latestVersion, counts] = await Promise.all([\n getMetadata(\"latest_pds_version\"),\n getServerCount(),\n ]);\n\n const servers = await getOpenServers(sort, dir, showOutdated, latestVersion);\n\n return c.html(renderPage(servers, {\n sort,\n dir,\n showOutdated,\n latestVersion,\n openCount: counts.open,\n totalCount: counts.total,\n }));\n});\n\ntype PageOpts = {\n sort: SortField;\n dir: SortDirection;\n showOutdated: boolean;\n latestVersion: string | null;\n openCount: number;\n totalCount: number;\n};\n\nfunction renderPage(servers: PdsServer[], opts: PageOpts): string {\n const { sort, dir, showOutdated, latestVersion, openCount, totalCount } =\n opts;\n\n function sortUrl(field: SortField): string {\n const newDir = sort === field && dir === \"desc\" ? \"asc\" : \"desc\";\n const params = new URLSearchParams();\n params.set(\"sort\", field);\n params.set(\"dir\", newDir);\n if (showOutdated) params.set(\"show_outdated\", \"true\");\n return `/?${params}`;\n }\n\n function sortIndicator(field: SortField): string {\n if (sort !== field) return \"\";\n return dir === \"asc\" ? \" ▲\" : \" ▼\";\n }\n\n const toggleUrl = (() => {\n const params = new URLSearchParams();\n params.set(\"sort\", sort);\n params.set(\"dir\", dir);\n if (!showOutdated) params.set(\"show_outdated\", \"true\");\n return `/?${params}`;\n })();\n\n const rows = servers.map((s) => renderRow(s, latestVersion)).join(\"\\n\");\n\n return `\n\n\n \n \n OpenPDS - AT Protocol PDS Directory\n \n\n\n

OpenPDS

\n AT Protocol PDS servers with open registration.\n Data from atproto-scraping,\n enriched daily.\n

\n ${servers.length} servers listed\n ${openCount} open of ${totalCount} known\n ${latestVersion ? `Latest PDS: ${esc(latestVersion)}` : \"\"}\n

\n ${\n showOutdated ? \"Hide outdated versions\" : \"Show outdated versions\"\n }\n

\n ${\n servers.length > 0\n ? `\n \n \n \n \n \n \n \n \n \n \n \n \n ${rows}\n \n

Hostname	Country${\n sortIndicator(\"country\")\n }	Version${\n sortIndicator(\"version\")\n }	Users${\n sortIndicator(\"users\")\n }	First seen${sortIndicator(\"first_seen\")}	Trust

`\n : `

No servers found. Data may still be loading — check back after the first cron run.

`\n }\n \n\n`;\n}\n\nfunction renderRow(s: PdsServer, latestVersion: string | null): string {\n const hostname = new URL(s.url).hostname;\n const flag = s.country_code ? countryFlag(s.country_code) + \" \" : \"\";\n const country = s.country_name || \"\";\n\n let versionClass = \"version-unknown\";\n let versionText = \"unknown\";\n if (s.version) {\n versionText = s.version;\n versionClass = s.version === latestVersion\n ? \"version-current\"\n : \"version-outdated\";\n }\n\n const users = s.user_count != null\n ? (s.user_count >= 1000 ? \"1000+\" : String(s.user_count))\n : \"-\";\n\n const firstSeen = s.first_seen\n ? new Date(s.first_seen).toLocaleDateString(\"en-US\", {\n month: \"short\",\n day: \"numeric\",\n year: \"numeric\",\n })\n : \"-\";\n\n const hasEmail = s.contact_email;\n const hasTos = s.terms_of_service;\n const hasPrivacy = s.privacy_policy;\n\n return `\n ${esc(hostname)}\n ${flag}${esc(country)}\n ${\n esc(versionText)\n }\n ${esc(users)}\n ${esc(firstSeen)}\n \n \n ${\n hasEmail\n ? `@`\n : `@`\n }\n ${\n hasTos\n ? `T`\n : `T`\n }\n ${\n hasPrivacy\n ? `P`\n : `P`\n }\n \n \n `;\n}\n\nfunction esc(str: string): string {\n return str\n .replace(/&/g, \"&\")\n .replace(//g, \">\")\n .replace(/\"/g, \""\");\n}\n\nexport { pages };\n",[],[165,271,263],"routes","1eccee1a-0a91-11f1-a315-42dde27851f2","api.ts","1eccef46-0a91-11f1-a315-42dde27851f2",12,["D",1771175382678],"import { Hono } from \"https://esm.sh/hono@4.4.0\";\nimport {\n getAllServers,\n getMetadata,\n getServerCount,\n} from \"../database/queries.ts\";\n\nconst api = new Hono();\n\napi.get(\"/servers\", async (c) => {\n const [servers, latestVersion, counts] = await Promise.all([\n getAllServers(),\n getMetadata(\"latest_pds_version\"),\n getServerCount(),\n ]);\n\n return c.json({\n meta: {\n latest_pds_version: latestVersion,\n total_known: counts.total,\n total_open: counts.open,\n updated_at: new Date().toISOString(),\n },\n servers,\n });\n});\n\nexport { api };\n",[],[165,271,273],"1e7af2d6-0a91-11f1-a09a-42dde27851f2",6,["D",1771175382290],[185,186],[165,271],"1eb4281c-0a91-11f1-a169-42dde27851f2","queries.ts","1eb42916-0a91-11f1-a169-42dde27851f2","1e5c8756-0a91-11f1-8d35-42dde27851f2",9,["D",1771175382658],"import { sqlite } from \"https://esm.town/v/stevekrouse/sqlite?v=13\";\nimport { METADATA_TABLE, SERVERS_TABLE } from \"../../shared/constants.ts\";\nimport type {\n PdsServer,\n SortDirection,\n SortField,\n} from \"../../shared/types.ts\";\n\n// --- Server operations ---\n\nexport async function upsertServer(\n url: string,\n opts: {\n inviteCodeRequired: boolean;\n version: string | null;\n errorAt: number | null;\n isOpen: boolean;\n },\n): Promise {\n const now = new Date().toISOString();\n await sqlite.execute({\n sql: `\n INSERT INTO ${SERVERS_TABLE} (url, first_seen, last_seen, invite_code_required, version, error_at, is_open)\n VALUES (?, ?, ?, ?, ?, ?, ?)\n ON CONFLICT(url) DO UPDATE SET\n last_seen = ?,\n invite_code_required = ?,\n version = COALESCE(?, version),\n error_at = ?,\n is_open = ?\n `,\n args: [\n url,\n now,\n now,\n opts.inviteCodeRequired ? 1 : 0,\n opts.version,\n opts.errorAt,\n opts.isOpen ? 1 : 0,\n now,\n opts.inviteCodeRequired ? 1 : 0,\n opts.version,\n opts.errorAt,\n opts.isOpen ? 1 : 0,\n ],\n });\n}\n\nexport async function updateEnrichment(\n url: string,\n data: {\n version?: string | null;\n did?: string | null;\n phoneVerification?: boolean;\n userDomains?: string[];\n contactEmail?: string | null;\n privacyPolicy?: string | null;\n termsOfService?: string | null;\n userCount?: number | null;\n countryCode?: string | null;\n countryName?: string | null;\n ipAddress?: string | null;\n },\n): Promise {\n const now = new Date().toISOString();\n await sqlite.execute({\n sql: `\n UPDATE ${SERVERS_TABLE} SET\n last_enriched = ?,\n version = COALESCE(?, version),\n did = COALESCE(?, did),\n phone_verification = ?,\n user_domains = ?,\n contact_email = ?,\n privacy_policy = ?,\n terms_of_service = ?,\n user_count = COALESCE(?, user_count),\n country_code = COALESCE(?, country_code),\n country_name = COALESCE(?, country_name),\n ip_address = COALESCE(?, ip_address)\n WHERE url = ?\n `,\n args: [\n now,\n data.version ?? null,\n data.did ?? null,\n data.phoneVerification ? 1 : 0,\n data.userDomains ? JSON.stringify(data.userDomains) : null,\n data.contactEmail ?? null,\n data.privacyPolicy ?? null,\n data.termsOfService ?? null,\n data.userCount ?? null,\n data.countryCode ?? null,\n data.countryName ?? null,\n data.ipAddress ?? null,\n url,\n ],\n });\n}\n\nexport async function getServersToEnrich(limit: number): Promise {\n const result = await sqlite.execute({\n sql: `\n SELECT url FROM ${SERVERS_TABLE}\n WHERE is_open = 1\n ORDER BY last_enriched ASC NULLS FIRST\n LIMIT ?\n `,\n args: [limit],\n });\n return result.rows.map((r) => r.url as string);\n}\n\nexport async function getOpenServers(\n sort: SortField = \"users\",\n dir: SortDirection = \"desc\",\n showOutdated: boolean = false,\n latestVersion: string | null = null,\n): Promise {\n let orderClause: string;\n switch (sort) {\n case \"users\":\n orderClause = `user_count ${dir} NULLS LAST`;\n break;\n case \"country\":\n orderClause = `country_name ${dir} NULLS LAST`;\n break;\n case \"first_seen\":\n orderClause = `first_seen ${dir}`;\n break;\n case \"version\":\n orderClause = `version ${dir} NULLS LAST`;\n break;\n default:\n orderClause = \"user_count DESC NULLS LAST\";\n }\n\n let whereClause = \"is_open = 1\";\n const args: (string | number)[] = [];\n\n if (!showOutdated && latestVersion) {\n whereClause += \" AND (version = ? OR version IS NULL)\";\n args.push(latestVersion);\n }\n\n const result = await sqlite.execute({\n sql:\n `SELECT * FROM ${SERVERS_TABLE} WHERE ${whereClause} ORDER BY ${orderClause}`,\n args,\n });\n\n return result.rows.map(rowToServer);\n}\n\nexport async function getAllServers(): Promise {\n const result = await sqlite.execute(\n `SELECT * FROM ${SERVERS_TABLE} WHERE is_open = 1 ORDER BY user_count DESC NULLS LAST`,\n );\n return result.rows.map(rowToServer);\n}\n\nexport async function getServerCount(): Promise<\n { open: number; total: number }\n> {\n const result = await sqlite.execute(\n `SELECT COUNT(*) as total, SUM(CASE WHEN is_open = 1 THEN 1 ELSE 0 END) as open FROM ${SERVERS_TABLE}`,\n );\n const row = result.rows[0];\n return {\n total: (row.total as number) || 0,\n open: (row.open as number) || 0,\n };\n}\n\n// --- Metadata operations ---\n\nexport async function getMetadata(key: string): Promise {\n const result = await sqlite.execute({\n sql: `SELECT value FROM ${METADATA_TABLE} WHERE key = ?`,\n args: [key],\n });\n return result.rows.length > 0 ? (result.rows[0].value as string) : null;\n}\n\nexport async function setMetadata(key: string, value: string): Promise {\n await sqlite.execute({\n sql: `\n INSERT INTO ${METADATA_TABLE} (key, value) VALUES (?, ?)\n ON CONFLICT(key) DO UPDATE SET value = ?\n `,\n args: [key, value, value],\n });\n}\n\n// --- Helpers ---\n\nfunction rowToServer(row: Record): PdsServer {\n return {\n url: row.url as string,\n first_seen: row.first_seen as string,\n last_seen: row.last_seen as string,\n last_enriched: (row.last_enriched as string) || null,\n version: (row.version as string) || null,\n did: (row.did as string) || null,\n invite_code_required: Boolean(row.invite_code_required),\n phone_verification: Boolean(row.phone_verification),\n user_domains: row.user_domains\n ? JSON.parse(row.user_domains as string)\n : [],\n contact_email: (row.contact_email as string) || null,\n privacy_policy: (row.privacy_policy as string) || null,\n terms_of_service: (row.terms_of_service as string) || null,\n user_count: row.user_count != null ? Number(row.user_count) : null,\n country_code: (row.country_code as string) || null,\n country_name: (row.country_name as string) || null,\n ip_address: (row.ip_address as string) || null,\n is_open: Boolean(row.is_open),\n error_at: row.error_at != null ? Number(row.error_at) : null,\n };\n}\n",[],[165,294,286],"database","1ebd22e6-0a91-11f1-9740-42dde27851f2","migrations.ts","1ebd23c2-0a91-11f1-9740-42dde27851f2",11,["D",1771175382658],"import { sqlite } from \"https://esm.town/v/stevekrouse/sqlite?v=13\";\nimport { METADATA_TABLE, SERVERS_TABLE } from \"../../shared/constants.ts\";\n\nexport async function runMigrations(): Promise {\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS ${SERVERS_TABLE} (\n url TEXT PRIMARY KEY,\n first_seen TEXT NOT NULL,\n last_seen TEXT NOT NULL,\n last_enriched TEXT,\n version TEXT,\n did TEXT,\n invite_code_required INTEGER NOT NULL DEFAULT 0,\n phone_verification INTEGER NOT NULL DEFAULT 0,\n user_domains TEXT,\n contact_email TEXT,\n privacy_policy TEXT,\n terms_of_service TEXT,\n user_count INTEGER,\n country_code TEXT,\n country_name TEXT,\n ip_address TEXT,\n is_open INTEGER NOT NULL DEFAULT 0,\n error_at INTEGER\n )\n `);\n\n await sqlite.execute(`\n CREATE INDEX IF NOT EXISTS idx_${SERVERS_TABLE}_is_open\n ON ${SERVERS_TABLE} (is_open)\n `);\n\n await sqlite.execute(`\n CREATE INDEX IF NOT EXISTS idx_${SERVERS_TABLE}_last_enriched\n ON ${SERVERS_TABLE} (last_enriched)\n `);\n\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS ${METADATA_TABLE} (\n key TEXT PRIMARY KEY,\n value TEXT NOT NULL\n )\n `);\n}\n",[],[165,294,296],"1e5c86ac-0a91-11f1-8d35-42dde27851f2",5,["D",1771175382101],[182,183],[165,294],["D",1771175381220],[181,184,187,192],[165],["D",1771175379615],{"_92":91,"_100":96},{"_92":91,"_93":94,"_95":96,"_18":52,"_97":98,"_99":24},{"_13":81,"_31":82,"_40":39,"_83":41,"_84":-5,"_85":-5,"_86":-5,"_87":-5,"_88":-5,"_89":42,"_90":91},"ctx",{"_74":-5,"_121":348,"_349":350,"_351":352,"_353":24,"_354":24,"_355":24,"_356":119,"_357":-5,"_358":-7,"_359":-7,"_360":58,"_361":24,"_362":24,"_363":-5,"_364":24,"_365":24,"_366":24,"_367":-5},"ENV",{"_319":320,"_321":322,"_323":82,"_324":325,"_326":327,"_328":329,"_330":331,"_332":333,"_334":335,"_336":337,"_338":339,"_340":341,"_342":343,"_344":345,"_346":347},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Diff · v18