[{"_1":2,"_176":-5,"_177":-5},"loaderData",{"_3":4,"_91":92},"root",{"_5":6,"_34":35,"_64":65},"ctx",{"_7":8,"_23":-5,"_24":25,"_26":27,"_28":20,"_29":20,"_30":20,"_31":32,"_33":20},"auth",{"_9":-5,"_10":-5,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":20,"_21":22},"sessionClaims","sessionId","sessionStatus","userId","actor","orgId","orgRole","orgSlug","orgPermissions","factorVerificationAge","isAuthenticated",false,"tokenType","session_token","user","preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","notificationCount",0,"flagDenols","ENV",{"_36":37,"_38":39,"_40":41,"_42":43,"_44":45,"_46":47,"_48":49,"_50":51,"_52":53,"_54":55,"_56":57,"_58":59,"_60":61,"_62":63},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","VAL_RUNTIME_NAME","prod","RENDER_GIT_COMMIT","4ff166458996ccfe3bfa8627489090938620785a","RENDER_GIT_BRANCH","main","CLERK_PUBLISHABLE_KEY","pk_live_Y2xlcmsudmFsLnRvd24k","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","API_URL","https://api.val.town","clerkState",{"_66":67},"__internal_clerk_state",{"_68":69,"_70":45,"_71":72,"_73":72,"_74":20,"_75":72,"_76":72,"_77":72,"_78":72,"_79":80,"_89":20,"_90":20},"__clerk_ssr_state",{"_21":22,"_9":-5,"_10":-5,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":20},"__publishableKey","__proxyUrl","","__domain","__isSatellite","__signInUrl","__signUpUrl","__afterSignInUrl","__afterSignUpUrl","__clerk_debug",{"_81":20,"_19":20,"_82":72,"_83":84,"_85":72,"_86":45,"_87":20,"_88":72},"isSignedIn","proxyUrl","reason","session-token-and-uat-missing","message","publishableKey","isSatellite","domain","__telemetryDisabled","__telemetryDebug","routes/embed.x.$handle.$name.$",{"_93":94,"_95":96,"_97":98,"_99":100,"_150":151,"_173":174,"_175":-5},"handle","tijs","name","atproto-to-fediverse","path","backend/services/atproto-password-client.ts","project",{"_101":102,"_95":96,"_103":104,"_105":-5,"_106":20,"_107":108,"_109":110,"_111":-5,"_12":112,"_113":114,"_115":116,"_117":-5,"_118":119,"_14":120,"_121":122,"_123":122,"_124":125,"_126":125,"_127":125,"_128":122,"_129":122,"_23":130,"_133":134,"_136":137,"_149":20},"id","c4d11e94-63b1-11f0-866e-0224a6c84d84","createdAt",["D",1752827561082],"deletedAt","legacyEnvVars","privacy","public","description","Syncing Bluesky posts to Mastodon - Prod","imageUrl","14049850-28c1-11f0-89c9-c7d0e2d9e1ea","pinnedFileId","2e2e3aac-63bc-11f0-8513-0224a6c84d84","pinPreview",true,"screenshotVersion","likeCount",1,"c04d51b2-a7dc-46ca-ad6f-52f47c2906a8","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm",{"_93":94,"_131":132},"profileImageUrl","https://img.clerk.com/eyJ0eXBlIjoicHJveHkiLCJzcmMiOiJodHRwczovL2ltYWdlcy5jbGVyay5kZXYvb2F1dGhfZ2l0aHViL2ltZ18yd2Nod2N0bE1MWFdEUlRYd083ZE5pbXJ1bDAifQ","org",{"_93":94,"_135":132},"avatar","branch",{"_138":139,"_95":43,"_101":140,"_141":102,"_142":-5,"_143":-5,"_144":-5,"_145":-5,"_146":-5,"_147":96,"_148":94},"version",420,"c4d19400-63b1-11f0-866e-0224a6c84d84","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","isOwned","file",{"_101":152,"_95":153,"_154":155,"_156":157,"_158":140,"_159":160,"_161":116,"_103":162,"_138":163,"_164":165,"_166":167,"_168":20,"_169":-5,"_97":170},"5acf271c-64a5-11f0-8367-0224a6c84d84","atproto-password-client.ts","fileId","ec23bcb2-6498-11f0-b940-0224a6c84d84","parentId","2db6fbea-63bc-11f0-ab6c-0224a6c84d84","branchId","branchVersion",314,"latest",["D",1752932180430],16,"fileType","script","content","import { BskyAgent } from \"https://esm.sh/@atproto/api@0.15.23\";\nimport { ATProtoPost } from \"../../shared/types.ts\";\n\n/**\n * ATProto client using App Password authentication\n * Simple implementation using BskyAgent with bsky.social\n */\nexport class ATProtoPasswordClient {\n private agent: BskyAgent;\n private did: string;\n private handle: string;\n private appPassword: string;\n\n constructor(\n _pdsUrl: string, // Not needed for BskyAgent\n handle: string,\n appPassword: string,\n did: string,\n ) {\n // Use BskyAgent with bsky.social (the standard approach)\n this.agent = new BskyAgent({\n service: \"https://bsky.social\",\n });\n this.did = did;\n this.handle = handle;\n this.appPassword = appPassword;\n }\n\n /**\n * Login using App Password\n */\n async login(): Promise {\n await this.agent.login({\n identifier: this.handle,\n password: this.appPassword,\n });\n }\n\n /**\n * Get the current session info\n */\n getSession() {\n return this.agent.session;\n }\n\n /**\n * Fetch recent posts from the user's timeline\n */\n async fetchRecentPosts(\n limit: number = 50,\n cursor?: string,\n ): Promise<{ posts: ATProtoPost[]; cursor?: string }> {\n const response = await this.agent.getAuthorFeed({\n actor: this.handle,\n limit,\n cursor,\n });\n\n if (!response.success) {\n throw new Error(\"Failed to fetch author feed\");\n }\n\n return this.transformResponse(response);\n }\n\n private transformResponse(response: any) {\n // Transform the feed items to our ATProtoPost format\n const posts: ATProtoPost[] = response.data.feed.map((item) => ({\n uri: item.post.uri,\n cid: item.post.cid,\n author: {\n did: item.post.author.did,\n handle: item.post.author.handle,\n displayName: item.post.author.displayName || undefined,\n avatar: item.post.author.avatar || undefined,\n },\n record: {\n text: (item.post.record as any).text || \"\",\n createdAt: (item.post.record as any).createdAt,\n embed: (item.post.record as any).embed,\n facets: (item.post.record as any).facets,\n reply: (item.post.record as any).reply,\n },\n indexedAt: item.post.indexedAt,\n }));\n\n return {\n posts,\n cursor: response.data.cursor,\n };\n }\n\n /**\n * Fetch posts since a specific timestamp\n */\n fetchPostsSince(\n sinceTime: string,\n limit: number = 50,\n ): Promise<{ posts: ATProtoPost[]; cursor?: string }> {\n return this.fetchPostsWithCursor(undefined, sinceTime, limit);\n }\n\n /**\n * Fetch posts starting from a cursor with optional time filtering\n */\n async fetchPostsWithCursor(\n startCursor?: string,\n sinceTime?: string,\n limit: number = 50,\n ): Promise<{ posts: ATProtoPost[]; cursor?: string }> {\n let allPosts: ATProtoPost[] = [];\n let cursor: string | undefined = startCursor;\n let hasMore = true;\n let finalCursor: string | undefined;\n\n while (hasMore && allPosts.length < limit) {\n const { posts, cursor: nextCursor } = await this.fetchRecentPosts(\n Math.min(50, limit - allPosts.length),\n cursor,\n );\n\n if (posts.length === 0) {\n hasMore = false;\n break;\n }\n\n let postsToAdd = posts;\n\n // Apply time filter if provided\n if (sinceTime) {\n postsToAdd = posts.filter((post) => post.record.createdAt > sinceTime);\n\n // If we got filtered posts and some were too old, we can stop\n if (postsToAdd.length < posts.length) {\n allPosts = allPosts.concat(postsToAdd);\n finalCursor = nextCursor;\n hasMore = false;\n break;\n }\n }\n\n allPosts = allPosts.concat(postsToAdd);\n finalCursor = nextCursor;\n cursor = nextCursor;\n\n // Stop if we got fewer posts than requested (reached end)\n if (posts.length < 50) {\n hasMore = false;\n }\n\n // Stop if no cursor (reached end)\n if (!nextCursor) {\n hasMore = false;\n }\n }\n\n return {\n posts: allPosts.slice(0, limit),\n cursor: finalCursor,\n };\n }\n\n /**\n * Get a specific post by URI\n */\n async getPost(uri: string): Promise {\n const response = await this.agent.getPostThread({\n uri,\n depth: 0,\n });\n\n if (!response.success) {\n return null;\n }\n\n const thread = response.data.thread;\n if (!thread || thread.$type !== \"app.bsky.feed.defs#threadViewPost\") {\n return null;\n }\n const post = (thread as any).post;\n\n return {\n uri: post.uri,\n cid: post.cid,\n author: {\n did: post.author.did,\n handle: post.author.handle,\n displayName: post.author.displayName || undefined,\n avatar: post.author.avatar || undefined,\n },\n record: {\n text: (post.record as any).text || \"\",\n createdAt: (post.record as any).createdAt,\n embed: (post.record as any).embed,\n facets: (post.record as any).facets,\n reply: (post.record as any).reply,\n },\n indexedAt: post.indexedAt,\n };\n }\n\n /**\n * Resolve a blob reference to a URL using bsky.social\n */\n resolveBlobUrl(blobRef: string): string {\n // Use bsky.social for blob URLs (standard approach)\n return `https://bsky.social/xrpc/com.atproto.sync.getBlob?did=${this.did}&cid=${blobRef}`;\n }\n\n /**\n * Get blob data as ArrayBuffer\n */\n async getBlobData(blobRef: string): Promise {\n const url = this.resolveBlobUrl(blobRef);\n const response = await fetch(url);\n\n if (!response.ok) {\n throw new Error(\"Failed to fetch blob\");\n }\n\n return await response.arrayBuffer();\n }\n\n /**\n * Get blob as Blob object for media uploads\n */\n async getBlob(blobRef: string): Promise {\n const data = await this.getBlobData(blobRef);\n return new Blob([data]);\n }\n\n /**\n * Get user profile information\n */\n async getProfile(): Promise {\n const response = await this.agent.getProfile({\n actor: this.did,\n });\n\n if (!response.success) {\n throw new Error(\"Failed to get profile\");\n }\n\n return response.data;\n }\n\n /**\n * Verify credentials and test connection\n */\n async verifyCredentials(): Promise {\n try {\n // Try to get the current session\n const response = await this.agent.api.com.atproto.server.getSession();\n return response.success;\n } catch (error) {\n console.error(\"Credential verification error:\", error);\n return false;\n }\n }\n}\n","deleted","label",[171,172,153],"backend","services","permalink","https://www.val.town/x/tijs/atproto-to-fediverse/code/backend/services/atproto-password-client.ts","extension","actionData","errors"]