[{"_1":2,"_178":-5,"_179":-5},"loaderData",{"_3":4,"_93":94},"root",{"_5":6,"_36":37,"_66":67},"ctx",{"_7":8,"_23":-5,"_24":25,"_26":27,"_28":20,"_29":20,"_30":20,"_31":-5,"_32":33,"_34":20,"_35":20},"auth",{"_9":-5,"_10":-5,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":20,"_21":22},"sessionClaims","sessionId","sessionStatus","userId","actor","orgId","orgRole","orgSlug","orgPermissions","factorVerificationAge","isAuthenticated",false,"tokenType","session_token","user","preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesChatPanelState","notificationCount",0,"flagDenols","isTeamOrgMember","ENV",{"_38":39,"_40":41,"_42":43,"_44":45,"_46":47,"_48":49,"_50":51,"_52":53,"_54":55,"_56":57,"_58":59,"_60":61,"_62":63,"_64":65},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","VAL_RUNTIME_NAME","prod","RENDER_GIT_COMMIT","33df83e696f6114f722b841240a715c7c887bf2c","RENDER_GIT_BRANCH","main","CLERK_PUBLISHABLE_KEY","pk_live_Y2xlcmsudmFsLnRvd24k","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","API_URL","https://api.val.town","clerkState",{"_68":69},"__internal_clerk_state",{"_70":71,"_72":47,"_73":74,"_75":74,"_76":20,"_77":74,"_78":74,"_79":74,"_80":74,"_81":82,"_91":20,"_92":20},"__clerk_ssr_state",{"_21":22,"_9":-5,"_10":-5,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":20},"__publishableKey","__proxyUrl","","__domain","__isSatellite","__signInUrl","__signUpUrl","__afterSignInUrl","__afterSignUpUrl","__clerk_debug",{"_83":20,"_19":20,"_84":74,"_85":86,"_87":74,"_88":47,"_89":20,"_90":74},"isSignedIn","proxyUrl","reason","session-token-and-uat-missing","message","publishableKey","isSatellite","domain","__telemetryDisabled","__telemetryDebug","routes/embed.x.$handle.$name.$",{"_95":96,"_97":98,"_99":100,"_101":102,"_157":158,"_175":176,"_177":-5},"handle","stevekrouse","name","lex","path","main.tsx","project",{"_103":104,"_97":98,"_105":106,"_107":-5,"_108":20,"_109":110,"_111":-5,"_112":-5,"_12":113,"_114":-5,"_115":20,"_116":-5,"_117":-5,"_118":33,"_14":119,"_120":-5,"_121":-5,"_122":123,"_124":123,"_125":126,"_127":126,"_128":126,"_129":123,"_130":123,"_23":131,"_134":135,"_139":140,"_156":20},"id","0562e704-028f-11f1-806e-42dde27851f2","createdAt",["D",1770294871881],"deletedAt","legacyEnvVars","privacy","public","description","imageUrl","a0bf3b31-15a5-4d5c-880e-4b1e22c9bc18","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount","e81e7335-6d4c-4764-a902-d0962bbfa9f7","tursoName","tursoHostname","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm",{"_95":96,"_132":133},"profileImageUrl","https://images.clerk.dev/uploaded/img_2PqHa2Gsy93xQrjh2w78Xu0cChW.jpeg","org",{"_95":96,"_136":133,"_12":113,"_137":138},"avatar","tier","pro","branch",{"_141":142,"_97":45,"_103":143,"_144":104,"_145":146,"_147":148,"_149":110,"_150":151,"_152":153,"_154":98,"_155":96},"version",1,"0566766c-028f-11f1-806e-42dde27851f2","projectId","forkedBranchId","070195a2-01da-11f1-9121-42dde27851f2","forkedBranchVersion",91,"forkedProjectPrivacy","forkedProjectId","07013a12-01da-11f1-9121-42dde27851f2","forkedProjectOrgId","019c0245-aaf5-73a9-b140-326d4c3ee25e","projectName","userHandle","isOwned","file",{"_103":159,"_97":100,"_160":161,"_162":-5,"_163":143,"_164":142,"_165":166,"_105":167,"_141":33,"_168":169,"_170":171,"_172":20,"_173":-5,"_99":174},"056d778c-028f-11f1-806e-42dde27851f2","fileId","019c2dcc-0788-73ef-aa41-a4388e0c00d5","parentId","branchId","branchVersion","latest",true,["D",1770294871881],"fileType","http","content","// Lexicon Resolver - generates TypeScript using @atproto/lex\n//\n// Routes:\n// /{nsid}.ts - Generated TypeScript for single lexicon\n// /{authority}.*.ts - Bundle all lexicons from authority\n// /{nsid}.json - Raw lexicon JSON\n//\n// Resolution:\n// - Published lexicons resolve via DNS (_lexicon.{authority})\n// - Unpublished lexicons use query params: ?authority=did:xxx\n// - Use ?v=N to bust cache when lexicons update\n\nimport { Project, IndentationText } from \"npm:ts-morph@27\";\nimport { LexDefBuilder } from \"npm:@gaearon/lex-builder@0.0.14\";\nimport { ensureValidNsid, ensureValidDid } from \"npm:@atproto/syntax@0.3.0\";\n\ninterface LexiconDoc {\n lexicon: number;\n id: string;\n defs: Record;\n}\n\ntype UnpublishedMap = Map; // authority -> DID\n\n// === Parsing ===\n\nfunction parseUnpublishedParams(url: URL): UnpublishedMap {\n const map = new Map();\n\n for (const [key, value] of url.searchParams) {\n // Any param that looks like authority=did:xxx is an unpublished mapping\n if (value.startsWith(\"did:\")) {\n map.set(key, value);\n }\n }\n\n return map;\n}\n\nfunction getAuthority(nsid: string): string {\n // app.bsky.feed.post -> app.bsky.feed\n const parts = nsid.split(\".\");\n return parts.slice(0, -1).join(\".\");\n}\n\n// === DID/PDS Resolution ===\n\nasync function resolvePds(did: string): Promise {\n if (did.startsWith(\"did:plc:\")) {\n const res = await fetch(\n `https://plc.directory/${encodeURIComponent(did)}`,\n { redirect: \"error\" }\n );\n if (!res.ok) throw new Error(`Failed to resolve ${did}`);\n const doc = await res.json();\n const pds = doc.service?.find(\n (s: any) =>\n s.id === \"#atproto_pds\" || s.type === \"AtprotoPersonalDataServer\"\n );\n if (!pds) throw new Error(`No PDS found for ${did}`);\n return pds.serviceEndpoint;\n } else if (did.startsWith(\"did:web:\")) {\n const domain = did.slice(\"did:web:\".length).replace(/%3A/g, \":\");\n const res = await fetch(`https://${domain}/.well-known/did.json`, {\n redirect: \"error\",\n });\n if (!res.ok) throw new Error(`Failed to resolve ${did}`);\n const doc = await res.json();\n const pds = doc.service?.find(\n (s: any) =>\n s.id === \"#atproto_pds\" || s.type === \"AtprotoPersonalDataServer\"\n );\n if (!pds) throw new Error(`No PDS found for ${did}`);\n return pds.serviceEndpoint;\n }\n throw new Error(`Unsupported DID method: ${did}`);\n}\n\nasync function fetchLexiconFromDid(\n nsid: string,\n did: string\n): Promise {\n ensureValidNsid(nsid);\n ensureValidDid(did);\n const pds = await resolvePds(did);\n const res = await fetch(\n `${pds}/xrpc/com.atproto.repo.getRecord?repo=${encodeURIComponent(did)}&collection=com.atproto.lexicon.schema&rkey=${encodeURIComponent(nsid)}`,\n { redirect: \"error\" }\n );\n if (!res.ok) throw new Error(`Lexicon not found: ${nsid} in ${did}`);\n const { value } = await res.json();\n return value as LexiconDoc;\n}\n\nasync function listLexiconsFromDid(\n did: string,\n prefix: string\n): Promise {\n ensureValidDid(did);\n const pds = await resolvePds(did);\n const docs: LexiconDoc[] = [];\n let cursor: string | undefined;\n let iterations = 0;\n const MAX_ITERATIONS = 10; // Max 1000 lexicons\n\n while (iterations++ < MAX_ITERATIONS) {\n const params = new URLSearchParams({\n repo: did,\n collection: \"com.atproto.lexicon.schema\",\n limit: \"100\",\n });\n if (cursor) params.set(\"cursor\", cursor);\n\n const res = await fetch(\n `${pds}/xrpc/com.atproto.repo.listRecords?${params}`,\n { redirect: \"error\" }\n );\n if (!res.ok) throw new Error(`Failed to list lexicons from ${did}`);\n const data = await res.json();\n\n for (const record of data.records || []) {\n const doc = record.value as LexiconDoc;\n if (doc.id.startsWith(prefix + \".\")) {\n docs.push(doc);\n }\n }\n\n if (!data.cursor) break;\n cursor = data.cursor;\n }\n\n return docs;\n}\n\nasync function resolveAuthorityViaDns(\n authority: string,\n existingUnpublished: UnpublishedMap\n): Promise {\n // app.bsky.feed -> _lexicon.feed.bsky.app\n const parts = authority.split(\".\");\n const authorityDomain = [...parts].reverse().join(\".\");\n const txtRecord = `_lexicon.${authorityDomain}`;\n\n // Use DNS-over-HTTPS to resolve TXT record\n const res = await fetch(\n `https://dns.google/resolve?name=${encodeURIComponent(txtRecord)}&type=TXT`,\n { redirect: \"error\" }\n );\n if (!res.ok) throw new Error(`DNS resolution failed for ${txtRecord}`);\n const data = await res.json();\n\n if (!data.Answer || data.Answer.length === 0) {\n // Build helpful hint\n const existingParams = Array.from(existingUnpublished.entries())\n .map(([a, d]) => `${a}=${d}`)\n .join(\"&\");\n const hint = authority\n ? existingParams\n ? `?${existingParams}&${authority}=`\n : `?${authority}=`\n : \"a valid authority=did mapping\";\n\n throw new Error(\n `Authority \"${authority || \"(empty)\"}\" is not published (no DNS TXT record at ${txtRecord}). ` +\n `For unpublished lexicons, use ${hint}`\n );\n }\n\n // Parse did=xxx from TXT record\n for (const answer of data.Answer) {\n const txt = answer.data?.replace(/\"/g, \"\") || \"\";\n if (txt.startsWith(\"did=\")) {\n return txt.slice(4);\n }\n }\n\n throw new Error(`No did= found in TXT record for ${txtRecord}`);\n}\n\n// === Lexicon Resolution ===\n\nasync function resolveLexicon(\n nsid: string,\n unpublished: UnpublishedMap\n): Promise<{ doc: LexiconDoc; did: string }> {\n const authority = getAuthority(nsid);\n\n // Check unpublished map first\n for (const [auth, did] of unpublished) {\n if (authority === auth || authority.startsWith(auth + \".\")) {\n const doc = await fetchLexiconFromDid(nsid, did);\n return { doc, did };\n }\n }\n\n // Fall back to DNS resolution\n const did = await resolveAuthorityViaDns(getAuthority(nsid), unpublished);\n const doc = await fetchLexiconFromDid(nsid, did);\n return { doc, did };\n}\n\n// === On-demand Lexicon Indexer ===\n\nclass OnDemandIndexer {\n private cache = new Map();\n\n constructor(\n private initialDoc: LexiconDoc,\n private unpublished: UnpublishedMap\n ) {\n this.cache.set(initialDoc.id, initialDoc);\n }\n\n async get(nsid: string): Promise {\n const cached = this.cache.get(nsid);\n if (cached) return cached;\n\n const { doc } = await resolveLexicon(nsid, this.unpublished);\n this.cache.set(nsid, doc);\n return doc;\n }\n\n async *[Symbol.asyncIterator]() {\n yield this.initialDoc;\n }\n}\n\n// === TypeScript Generation ===\n\nasync function generateTs(\n doc: LexiconDoc,\n baseUrl: string,\n unpublished: UnpublishedMap,\n v: string | null\n): Promise {\n const project = new Project({\n useInMemoryFileSystem: true,\n manipulationSettings: { indentationText: IndentationText.TwoSpaces },\n });\n\n // Create file at a path (doesn't matter much, we just need the content)\n const file = project.createSourceFile(`/${doc.id}.ts`);\n\n // Build query params to pass through\n const parts: string[] = [];\n for (const [auth, did] of unpublished) {\n parts.push(`${auth}=${did}`);\n }\n if (v) parts.push(`v=${v}`);\n const queryString = parts.length > 0 ? \"?\" + parts.join(\"&\") : \"\";\n\n const indexer = new OnDemandIndexer(doc, unpublished);\n const builder = new LexDefBuilder(\n {\n lib: \"npm:@atproto/lex\",\n moduleSpecifier: (nsid: string) => `${baseUrl}/${nsid}.ts${queryString}`,\n },\n file,\n doc as any,\n indexer as any\n );\n await builder.build();\n\n // Sort imports for deterministic output\n const imports = file.getImportDeclarations();\n const importData = imports.map((imp) => ({\n module: imp.getModuleSpecifierValue(),\n text: imp.getText(),\n }));\n importData.sort((a, b) => a.module.localeCompare(b.module));\n\n // Remove all imports and re-add sorted\n imports.forEach((imp) => imp.remove());\n const sortedText = importData.map((d) => d.text).join(\"\\n\") + \"\\n\";\n file.insertText(0, sortedText);\n\n let output = file.getFullText();\n\n // Post-process: add callable default export for JSX compatibility\n // Only for PascalCase procedures (components)\n const name = doc.id.split(\".\").pop()!;\n const isPascalCase = name[0] === name[0].toUpperCase();\n const hasProcedure = doc.defs?.main?.type === \"procedure\";\n if (hasProcedure && isPascalCase) {\n output += `\n// JSX-compatible default export\nconst _self = { $nsid, main } as const;\nexport default _self as typeof _self & ((props: InputBody) => any);\n`;\n }\n\n return output;\n}\n\n// === Bundle Generation ===\n\nfunction generateBundle(\n docs: LexiconDoc[],\n baseUrl: string,\n unpublished: UnpublishedMap,\n v: string | null\n): string {\n // Build query params to pass through\n const parts: string[] = [];\n for (const [auth, did] of unpublished) {\n parts.push(`${auth}=${did}`);\n }\n if (v) parts.push(`v=${v}`);\n const queryString = parts.length > 0 ? \"?\" + parts.join(\"&\") : \"\";\n\n // Generate re-exports for each lexicon\n // PascalCase procedures get `export { default as X }` (callable for JSX)\n // Everything else gets `export * as X` (namespace)\n const lines: string[] = [];\n for (const doc of docs) {\n const name = doc.id.split(\".\").pop()!; // org.atsui.Text -> Text\n const isPascalCase = name[0] === name[0].toUpperCase();\n const hasProcedure = (doc.defs as any)?.main?.type === \"procedure\";\n if (isPascalCase && hasProcedure) {\n lines.push(\n `export { default as ${name} } from \"${baseUrl}/${doc.id}.ts${queryString}\";`\n );\n } else {\n lines.push(\n `export * as ${name} from \"${baseUrl}/${doc.id}.ts${queryString}\";`\n );\n }\n }\n\n return lines.join(\"\\n\") + \"\\n\";\n}\n\n// === HTTP Handler ===\n\nexport default async function handler(req: Request): Promise {\n const url = new URL(req.url);\n const unpublished = parseUnpublishedParams(url);\n const v = url.searchParams.get(\"v\");\n const baseUrl = url.origin;\n\n // /{nsid}.json - Raw lexicon JSON\n const jsonMatch = url.pathname.match(/^\\/(.+)\\.json$/);\n if (jsonMatch) {\n const nsid = jsonMatch[1];\n try {\n ensureValidNsid(nsid);\n const { doc } = await resolveLexicon(nsid, unpublished);\n return new Response(JSON.stringify(doc, null, 2), {\n headers: { \"Content-Type\": \"application/json; charset=utf-8\" },\n });\n } catch (e) {\n return Response.json({ error: String(e), nsid }, { status: 404 });\n }\n }\n\n // /{authority}.*.ts - Bundle all lexicons from authority\n const bundleMatch = url.pathname.match(/^\\/(.+)\\.\\*\\.ts$/);\n if (bundleMatch) {\n const authority = bundleMatch[1];\n\n try {\n // Resolve DID for this authority - check unpublished map first, then DNS\n let did: string | undefined;\n for (const [auth, d] of unpublished) {\n if (authority === auth || authority.startsWith(auth + \".\")) {\n did = d;\n break;\n }\n }\n if (!did) {\n // Try DNS resolution\n did = await resolveAuthorityViaDns(authority, unpublished);\n }\n\n const docs = await listLexiconsFromDid(did, authority);\n if (docs.length === 0) {\n throw new Error(`No lexicons found matching ${authority}.* in ${did}`);\n }\n\n const ts = generateBundle(docs, baseUrl, unpublished, v);\n return new Response(ts, {\n headers: { \"Content-Type\": \"text/typescript; charset=utf-8\" },\n });\n } catch (e) {\n return Response.json({ error: String(e), authority }, { status: 404 });\n }\n }\n\n // /{nsid}.ts - Generated TypeScript\n const tsMatch = url.pathname.match(/^\\/(.+)\\.ts$/);\n if (tsMatch) {\n const nsid = tsMatch[1];\n\n try {\n ensureValidNsid(nsid);\n const { doc } = await resolveLexicon(nsid, unpublished);\n const ts = await generateTs(doc, baseUrl, unpublished, v);\n return new Response(ts, {\n headers: { \"Content-Type\": \"text/typescript; charset=utf-8\" },\n });\n } catch (e) {\n return Response.json({ error: String(e), nsid }, { status: 404 });\n }\n }\n\n return Response.json({\n usage: {\n single: \"/{nsid}.ts - Generated TypeScript for one lexicon\",\n bundle: \"/{authority}.*.ts - Bundle all lexicons from an authority\",\n json: \"/{nsid}.json - Raw lexicon JSON\",\n },\n params: {\n \"authority=did:xxx\": \"Map an authority to a DID for unpublished lexicons\",\n \"v=N\": \"Cache buster - bump when lexicons update\",\n },\n examples: {\n single: \"/app.bsky.feed.post.ts?v=1\",\n bundle: \"/app.bsky.feed.*.ts?v=1\",\n unpublished: \"/com.example.fooBar.ts?v=1&com.example=did:plc:abc123\",\n multipleDeps:\n \"/com.example.*.ts?v=1&com.example=did:plc:abc123&org.other=did:plc:xyz789\",\n },\n tip: \"Put ?v=1 first, then authority mappings. Bump v when you update lexicons.\",\n });\n}\n","deleted","label",[100],"permalink","https://www.val.town/x/stevekrouse/lex/code/main.tsx","extension","actionData","errors"]