Refactor article fetching

* Apply different limits to profile and feed
* Ensure the limit is the returned amount
* Pre-sort articles

handlers/user-atom-feed.ts

@@ -2,7 +2,6 @@ import { Context } from "@oak/oak";
 import { lookupPubkeyByUsername } from "../directory.ts";
 import { fetchArticlesByAuthor, fetchProfileEvent } from "../nostr.ts";
 import { profileAtomFeed } from "../feeds.ts";
-import Article from "../models/article.ts";
 import Profile from "../models/profile.ts";
 import { notFoundHandler } from "../handlers/errors.ts";
 
@@ -21,8 +20,7 @@ const userAtomFeedHandler = async function (ctx: Context) {
     const profile = new Profile(profileEvent, username);
 
     if (profile.nip05) {
-      const articleEvents = await fetchArticlesByAuthor(pubkey);
-      const articles = articleEvents.map((a) => new Article(a));
+      const articles = await fetchArticlesByAuthor(pubkey, 10);
       const atom = await profileAtomFeed(profile, articles);
 
       ctx.response.headers.set("Content-Type", "application/atom+xml");

handlers/user-profile.ts

@@ -1,7 +1,6 @@
 import { Context } from "@oak/oak";
 import { lookupPubkeyByUsername } from "../directory.ts";
 import { fetchArticlesByAuthor, fetchProfileEvent } from "../nostr.ts";
-import Article from "../models/article.ts";
 import Profile from "../models/profile.ts";
 import { profilePageHtml } from "../html.ts";
 import { notFoundHandler } from "../handlers/errors.ts";
@@ -20,8 +19,7 @@ const userProfileHandler = async function (ctx: Context) {
 
   if (profileEvent) {
     const profile = new Profile(profileEvent, username);
-    const articleEvents = await fetchArticlesByAuthor(pubkey);
-    const articles = articleEvents.map((a) => new Article(a));
+    const articles = await fetchArticlesByAuthor(pubkey, 210);
     const html = await profilePageHtml(profile, articles);
     generateOgProfileImage(profile);
 

html.ts

@@ -92,10 +92,9 @@ function articleListItemHtml(article: Article): string {
 
 export function articleListHtml(articles: Article[]): string {
   if (articles.length === 0) return "";
-  const sortedArticles = articles.sort((a, b) => b.publishedAt - a.publishedAt);
   let html = "";
 
-  for (const article of sortedArticles) {
+  for (const article of articles) {
     html += articleListItemHtml(article);
   }
 

nostr.ts

@@ -2,6 +2,7 @@ import { NostrEvent, NostrFilter, NPool, NRelay1 } from "@nostrify/nostrify";
 import { nip19 } from "@nostr/tools";
 import { lookupUsernameByPubkey } from "./directory.ts";
 import config from "./config.ts";
+import Article from "./models/article.ts";
 
 const relayPool = new NPool({
   open: (url) => new NRelay1(url),
@@ -49,14 +50,20 @@ export async function fetchReplaceableEvent(
   }
 }
 
-export async function fetchArticlesByAuthor(pubkey: string) {
+export async function fetchArticlesByAuthor(
+  pubkey: string,
+  limit: number = 10,
+) {
   const events = await fetchWithTimeout([{
     authors: [pubkey],
     kinds: [30023],
-    limit: 210,
+    limit: limit,
   }]) as NostrEvent[];
 
-  return events;
+  const articles = events.map((a) => new Article(a));
+  const sortedArticles = articles.sort((a, b) => b.publishedAt - a.publishedAt);
+  // The limit seems to apply per relay, not per pool query
+  return sortedArticles.slice(0, limit);
 }
 
 export async function fetchProfileEvent(pubkey: string) {