feat: implement pinned posts

bluesky-social · May 2, 2024 · 13c271d · 13c271d
1 parent d544758
commit 13c271d
Show file tree

Hide file tree

Showing 4 changed files with 36 additions and 9 deletions.
diff --git a/packages/bsky/src/api/app/bsky/feed/getAuthorFeed.ts b/packages/bsky/src/api/app/bsky/feed/getAuthorFeed.ts
@@ -79,6 +79,20 @@ export const skeleton = async (inputs: {
   if (clearlyBadCursor(params.cursor)) {
     return { actor, filter: params.filter, items: [] }
   }
+
+  if (params.filter === 'pinned_posts') {
+    return {
+      actor,
+      filter: params.filter,
+      items:
+        actor.profile?.pinnedPosts?.map((uri) => ({
+          post: { uri: uri, cid: undefined },
+          repost: undefined,
+        })) || [],
+      cursor: undefined,
+    }
+  }
+
   const res = await ctx.dataplane.getAuthorFeed({
     actorDid: did,
     limit: params.limit,

diff --git a/packages/bsky/src/hydration/feed.ts b/packages/bsky/src/hydration/feed.ts
@@ -20,6 +20,7 @@ export type Posts = HydrationMap<Post>
 export type PostViewerState = {
   like?: string
   repost?: string
+  pinned?: boolean
 }
 
 export type PostViewerStates = HydrationMap<PostViewerState>
@@ -86,23 +87,24 @@ export class FeedHydrator {
 
   async getPostViewerStates(
     refs: ItemRef[],
-    viewer: string,
+    { did, pinnedPosts }: { did: string; pinnedPosts?: string[] },
   ): Promise<PostViewerStates> {
     if (!refs.length) return new HydrationMap<PostViewerState>()
     const [likes, reposts] = await Promise.all([
       this.dataplane.getLikesByActorAndSubjects({
-        actorDid: viewer,
+        actorDid: did,
         refs,
       }),
       this.dataplane.getRepostsByActorAndSubjects({
-        actorDid: viewer,
+        actorDid: did,
         refs,
       }),
     ])
     return refs.reduce((acc, { uri }, i) => {
       return acc.set(uri, {
         like: parseString(likes.uris[i]),
         repost: parseString(reposts.uris[i]),
+        pinned: pinnedPosts?.includes(uri) || undefined,
       })
     }, new HydrationMap<PostViewerState>())
   }

diff --git a/packages/bsky/src/hydration/hydrator.ts b/packages/bsky/src/hydration/hydrator.ts
@@ -13,6 +13,7 @@ import {
   Actors,
   ProfileViewerStates,
   ProfileViewerState,
+  Actor,
 } from './actor'
 import {
   Follows,
@@ -269,11 +270,14 @@ export class Hydrator {
     state: HydrationState = {},
   ): Promise<HydrationState> {
     const uris = refs.map((ref) => ref.uri)
-    const postsLayer0 = await this.feed.getPosts(
-      uris,
-      ctx.includeTakedowns,
-      state.posts,
-    )
+    const [postsLayer0, viewer] = await Promise.all([
+      this.feed.getPosts(uris, ctx.includeTakedowns, state.posts),
+      ctx.viewer
+        ? this.actor
+            .getActors([ctx.viewer])
+            .then((v) => v.get(ctx.viewer as string))
+        : undefined,
+    ])
     // first level embeds plus thread roots we haven't fetched yet
     const urisLayer1 = nestedRecordUrisFromPosts(postsLayer0)
     const additionalRootUris = rootUrisFromPosts(postsLayer0) // supports computing threadgates
@@ -329,7 +333,12 @@ export class Hydrator {
         ...postUrisLayer1.map(uriToRef), // supports aggregates on embed #viewRecords
         ...postUrisLayer2.map(uriToRef),
       ]),
-      ctx.viewer ? this.feed.getPostViewerStates(refs, ctx.viewer) : undefined,
+      ctx.viewer
+        ? this.feed.getPostViewerStates(refs, {
+            did: ctx.viewer,
+            pinnedPosts: viewer?.profile?.pinnedPosts,
+          })
+        : undefined,
       this.label.getLabelsForSubjects(allPostUris, ctx.labelers),
       this.hydratePostBlocks(posts),
       this.hydrateProfiles(allPostUris.map(didFromUri), ctx),

diff --git a/packages/bsky/src/views/index.ts b/packages/bsky/src/views/index.ts
@@ -109,6 +109,7 @@ export class Views {
         lists: profileAggs?.lists,
         feedgens: profileAggs?.feeds,
         labeler: actor?.isLabeler,
+        pinnedPosts: actor.profile?.pinnedPosts?.length,
       },
     }
   }
@@ -443,6 +444,7 @@ export class Views {
         ? {
             repost: viewer.repost,
             like: viewer.like,
+            pinned: viewer.pinned,
             replyDisabled: this.userReplyDisabled(uri, state),
           }
         : undefined,