feat: pinned posts

parakeet/src/db.rs

···
         .load(conn)
         .await
 }
+
+pub async fn get_pinned_post_uri(
+    conn: &mut AsyncPgConnection,
+    did: &str,
+) -> QueryResult<Option<String>> {
+    schema::profiles::table
+        .select(schema::profiles::pinned_uri.assume_not_null())
+        .filter(
+            schema::profiles::did
+                .eq(did)
+                .and(schema::profiles::pinned_uri.is_not_null()),
+        )
+        .get_result(conn)
+        .await
+        .optional()
+}

parakeet/src/xrpc/app_bsky/feed/posts.rs

···
 
     let hyd = StatefulHydrator::new(&state.dataloaders, &state.cdn, &labelers, maybe_auth);
 
+    let pin = match query.include_pins && query.cursor.is_none() {
+        false => None,
+        true => match crate::db::get_pinned_post_uri(&mut conn, &did).await? {
+            Some(post) => hyd.hydrate_post(post).await,
+            None => None,
+        },
+    };
+
     let limit = query.limit.unwrap_or(50).clamp(1, 100);
 
     let mut posts_query = schema::posts::table
···
 
     let mut posts = hyd.hydrate_feed_posts(at_uris).await;
 
-    let feed = results
+    let mut feed: Vec<_> = results
         .into_iter()
         .filter_map(|(_, uri)| posts.remove(&uri))
         .collect();
+
+    if let Some(post) = pin {
+        feed.insert(
+            0,
+            FeedViewPost {
+                post,
+                reply: None,
+                reason: Some(FeedViewPostReason::Pin),
+                feed_context: None,
+            },
+        );
+    }
 
     Ok(Json(FeedRes { cursor, feed }))
 }