feat: add server side atproto blog apis

jonathanyeong · Kai-ros · jonathanyeong · commit 8d06923e8450 · 2026-02-03T16:08:09.000-05:00
This pulls apart the feature work done on this PR #257. In this commit, we're adding the atproto server side blog apis that will fetch bluesky comments and author profiles. This will be used in a later PR that will implement the frontend blog functionality. Co-authored-by: Brandon Hurrington <brandon.o.hurrington@gmail.com>
diff --git a/server/api/atproto/author-profiles.get.ts b/server/api/atproto/author-profiles.get.ts
@@ -0,0 +1,102 @@
+import * as v from 'valibot'
+import { CACHE_MAX_AGE_ONE_DAY, BLUESKY_API } from '#shared/utils/constants'
+import { AuthorSchema } from '#shared/schemas/blog'
+import type { Author, ResolvedAuthor } from '#shared/schemas/blog'
+
+type ProfilesResponse = {
+  profiles: Array<{
+    did: string
+    handle: string
+    displayName?: string
+    avatar?: string
+  }>
+}
+
+export default defineCachedEventHandler(
+  async event => {
+    const query = getQuery(event)
+    const authorsParam = query.authors
+
+    if (!authorsParam || typeof authorsParam !== 'string') {
+      throw createError({
+        statusCode: 400,
+        statusMessage: 'authors query parameter is required (JSON array)',
+      })
+    }
+
+    let authors: Author[]
+    try {
+      const parsed = JSON.parse(authorsParam)
+      authors = v.parse(v.array(AuthorSchema), parsed)
+    } catch (error) {
+      if (error instanceof v.ValiError) {
+        throw createError({
+          statusCode: 400,
+          statusMessage: `Invalid authors format: ${error.message}`,
+        })
+      }
+      throw createError({
+        statusCode: 400,
+        statusMessage: 'authors must be valid JSON',
+      })
+    }
+
+    if (!Array.isArray(authors) || authors.length === 0) {
+      return { authors: [] }
+    }
+
+    const handles = authors.filter(a => a.blueskyHandle).map(a => a.blueskyHandle as string)
+
+    if (handles.length === 0) {
+      return {
+        authors: authors.map(author => ({
+          ...author,
+          avatar: null,
+          profileUrl: null,
+        })),
+      }
+    }
+
+    try {
+      const response = await $fetch<ProfilesResponse>(`${BLUESKY_API}app.bsky.actor.getProfiles`, {
+        query: { actors: handles },
+      })
+
+      const avatarMap = new Map<string, string>()
+      for (const profile of response.profiles) {
+        if (profile.avatar) {
+          avatarMap.set(profile.handle, profile.avatar)
+        }
+      }
+
+      const resolvedAuthors: ResolvedAuthor[] = authors.map(author => ({
+        ...author,
+        avatar: author.blueskyHandle ? avatarMap.get(author.blueskyHandle) || null : null,
+        profileUrl: author.blueskyHandle
+          ? `https://bsky.app/profile/${author.blueskyHandle}`
+          : null,
+      }))
+
+      return { authors: resolvedAuthors }
+    } catch (error) {
+      console.error('[Author Profiles] Failed to fetch profiles:', error)
+      return {
+        authors: authors.map(author => ({
+          ...author,
+          avatar: null,
+          profileUrl: author.blueskyHandle
+            ? `https://bsky.app/profile/${author.blueskyHandle}`
+            : null,
+        })),
+      }
+    }
+  },
+  {
+    name: 'author-profiles',
+    maxAge: CACHE_MAX_AGE_ONE_DAY,
+    getKey: event => {
+      const { authors } = getQuery(event)
+      return `author-profiles:${authors}`
+    },
+  },
+)
diff --git a/server/api/atproto/bluesky-comments.get.ts b/server/api/atproto/bluesky-comments.get.ts
@@ -0,0 +1,177 @@
+import { safeParse, flatten } from 'valibot'
+import type { Comment, CommentEmbed } from '#shared/types/blog-post'
+import {
+  AppBskyFeedDefs,
+  AppBskyFeedPost,
+  AppBskyEmbedImages,
+  AppBskyEmbedExternal,
+} from '@atproto/api'
+import { BlueSkyUriSchema } from '#shared/schemas/atproto'
+import { CACHE_MAX_AGE_ONE_MINUTE, BLUESKY_API, AT_URI_REGEX } from '#shared/utils/constants'
+
+import { jsonToLex } from '@atproto/api'
+
+type ThreadResponse = { thread: AppBskyFeedDefs.ThreadViewPost }
+
+type LikesResponse = {
+  likes: Array<{
+    actor: {
+      did: string
+      handle: string
+      displayName?: string
+      avatar?: string
+    }
+  }>
+}
+
+type PostsResponse = { posts: Array<{ likeCount?: number }> }
+
+/**
+ * Provides both build and runtime comments refreshes
+ * During build, cache aggressively to avoid rate limits
+ * During runtime, refresh cache once every minute
+ */
+export default defineCachedEventHandler(
+  async event => {
+    const query = getQuery(event)
+    const parsed = safeParse(BlueSkyUriSchema, query)
+
+    if (!parsed.success) {
+      throw createError({
+        statusCode: 400,
+        statusMessage: `Invalid URI format: ${flatten(parsed.issues).root?.[0] || 'Must be a valid at:// URI'}`,
+      })
+    }
+
+    const { uri } = parsed.output
+
+    try {
+      // Fetch thread, likes, and post metadata in parallel
+      const [threadResponse, likesResponse, postsResponse] = await Promise.all([
+        $fetch<ThreadResponse>(`${BLUESKY_API}app.bsky.feed.getPostThread`, {
+          query: { uri, depth: 10 },
+        }).catch((err: Error) => {
+          console.warn(`[Bluesky] Thread fetch failed for ${uri}:`, err.message)
+          return null
+        }),
+
+        $fetch<LikesResponse>(`${BLUESKY_API}app.bsky.feed.getLikes`, {
+          query: { uri, limit: 50 },
+        }).catch(() => ({ likes: [] })),
+
+        $fetch<PostsResponse>(`${BLUESKY_API}app.bsky.feed.getPosts`, {
+          query: { uris: [uri] },
+        }).catch(() => ({ posts: [] })),
+      ])
+
+      // Early return if thread fetch fails w/o 404
+      if (!threadResponse) {
+        return {
+          thread: null,
+          likes: [],
+          totalLikes: 0,
+          postUrl: atUriToWebUrl(uri),
+          _empty: true,
+        }
+      }
+
+      const thread = parseThread(threadResponse.thread)
+
+      return {
+        thread,
+        likes: likesResponse.likes || [],
+        totalLikes: postsResponse.posts?.[0]?.likeCount || thread?.likeCount || 0,
+        postUrl: atUriToWebUrl(uri),
+      }
+    } catch (error) {
+      // Fail open during build to prevent build breakage
+      console.error('[Bluesky] Unexpected error:', error)
+      return {
+        thread: null,
+        likes: [],
+        totalLikes: 0,
+        postUrl: atUriToWebUrl(uri),
+        _error: true,
+      }
+    }
+  },
+  {
+    name: 'bluesky-comments',
+    maxAge: CACHE_MAX_AGE_ONE_MINUTE,
+    getKey: event => {
+      const { uri } = getQuery(event)
+      return `bluesky:${uri}`
+    },
+  },
+)
+
+// Helper to convert AT URI to web URL
+function atUriToWebUrl(uri: string): string | null {
+  const match = uri.match(AT_URI_REGEX)
+  if (!match) return null
+  const [, did, rkey] = match
+  return `https://bsky.app/profile/${did}/post/${rkey}`
+}
+
+function parseEmbed(embed: AppBskyFeedDefs.PostView['embed']): CommentEmbed | undefined {
+  if (!embed) return undefined
+
+  if (AppBskyEmbedImages.isView(embed)) {
+    return {
+      type: 'images',
+      images: embed.images,
+    }
+  }
+
+  if (AppBskyEmbedExternal.isView(embed)) {
+    return {
+      type: 'external',
+      external: embed.external,
+    }
+  }
+
+  return undefined
+}
+
+function parseThread(thread: AppBskyFeedDefs.ThreadViewPost): Comment | null {
+  if (!AppBskyFeedDefs.isThreadViewPost(thread)) return null
+
+  const { post } = thread
+
+  // This casts our external.thumb as a blobRef which is needed to validateRecord
+  const lexPostRecord = jsonToLex(post.record)
+  const recordValidation = AppBskyFeedPost.validateRecord(lexPostRecord)
+
+  if (!recordValidation.success) return null
+  const record = recordValidation.value
+
+  const replies: Comment[] = []
+  if (thread.replies) {
+    for (const reply of thread.replies) {
+      if (AppBskyFeedDefs.isThreadViewPost(reply)) {
+        const parsed = parseThread(reply)
+        if (parsed) replies.push(parsed)
+      }
+    }
+    replies.sort((a, b) => new Date(a.createdAt).getTime() - new Date(b.createdAt).getTime())
+  }
+
+  return {
+    uri: post.uri,
+    cid: post.cid,
+    author: {
+      did: post.author.did,
+      handle: post.author.handle,
+      displayName: post.author.displayName,
+      avatar: post.author.avatar,
+    },
+    text: record.text,
+    facets: record.facets,
+    embed: parseEmbed(post.embed),
+    createdAt: record.createdAt,
+    likeCount: post.likeCount ?? 0,
+    replyCount: post.replyCount ?? 0,
+    repostCount: post.repostCount ?? 0,
+    replies,
+  }
+}
diff --git a/shared/schemas/atproto.ts b/shared/schemas/atproto.ts
@@ -0,0 +1,14 @@
+import { object, string, startsWith, minLength, regex, pipe } from 'valibot'
+import type { InferOutput } from 'valibot'
+import { AT_URI_REGEX } from '#shared/utils/constants'
+
+export const BlueSkyUriSchema = object({
+  uri: pipe(
+    string(),
+    startsWith('at://'),
+    minLength(10),
+    regex(AT_URI_REGEX, 'Must be a valid at:// URI'),
+  ),
+})
+
+export type BlueSkyUri = InferOutput<typeof BlueSkyUriSchema>
diff --git a/shared/schemas/blog.ts b/shared/schemas/blog.ts
@@ -0,0 +1,32 @@
+import { object, string, optional, array, boolean, pipe, isoDate } from 'valibot'
+import type { InferOutput } from 'valibot'
+
+export const AuthorSchema = object({
+  name: string(),
+  blueskyHandle: optional(string()),
+})
+
+export const BlogPostSchema = object({
+  authors: array(AuthorSchema),
+  title: string(),
+  date: pipe(string(), isoDate()),
+  description: string(),
+  path: string(),
+  slug: string(),
+  excerpt: optional(string()),
+  tags: optional(array(string())),
+  draft: optional(boolean()),
+})
+
+export type Author = InferOutput<typeof AuthorSchema>
+
+export interface ResolvedAuthor extends Author {
+  avatar: string | null
+  profileUrl: string | null
+}
+
+/**
+ * Inferred type for blog post frontmatter
+ */
+/** @public */
+export type BlogPostFrontmatter = InferOutput<typeof BlogPostSchema>
diff --git a/shared/types/blog-post.ts b/shared/types/blog-post.ts
@@ -0,0 +1,25 @@
+import type {
+  AppBskyActorDefs,
+  AppBskyRichtextFacet,
+  AppBskyEmbedImages,
+  AppBskyEmbedExternal,
+} from '@atproto/api'
+export interface CommentEmbed {
+  type: 'images' | 'external'
+  images?: AppBskyEmbedImages.ViewImage[]
+  external?: AppBskyEmbedExternal.ViewExternal
+}
+
+export interface Comment {
+  uri: string
+  cid: string
+  author: Pick<AppBskyActorDefs.ProfileViewBasic, 'did' | 'handle' | 'displayName' | 'avatar'>
+  text: string
+  facets?: AppBskyRichtextFacet.Main[]
+  embed?: CommentEmbed
+  createdAt: string
+  likeCount: number
+  replyCount: number
+  repostCount: number
+  replies: Comment[]
+}
diff --git a/shared/utils/constants.ts b/shared/utils/constants.ts
@@ -8,6 +8,9 @@ export const CACHE_MAX_AGE_ONE_DAY = 60 * 60 * 24
 export const CACHE_MAX_AGE_ONE_YEAR = 60 * 60 * 24 * 365
 
 // API Strings
+export const NPMX_SITE = 'https://npmx.dev'
+export const BLUESKY_API = 'https://public.api.bsky.app/xrpc/'
+export const BLUESKY_COMMENTS_REQUEST = '/api/atproto/bluesky-comments'
 export const NPM_REGISTRY = 'https://registry.npmjs.org'
 export const ERROR_PACKAGE_ANALYSIS_FAILED = 'Failed to analyze package.'
 export const ERROR_PACKAGE_VERSION_AND_FILE_FAILED = 'Version and file path are required.'
@@ -57,3 +60,6 @@ export const BACKGROUND_THEMES = {
   slate: 'oklch(0.555 0.046 257.407)',
   black: 'oklch(0.4 0 0)',
 } as const
+
+// Regex
+export const AT_URI_REGEX = /^at:\/\/(did:plc:[a-z0-9]+)\/app\.bsky\.feed\.post\/([a-z0-9]+)$/
diff --git a/shared/utils/parse-basic-frontmatter.ts b/shared/utils/parse-basic-frontmatter.ts
