feed for comments and top posts

feed-generator/src/algos/heb-ppl-posts-comments.ts

···
+import { QueryParams } from "@my/lexicon/server/types/app/bsky/feed/getFeedSkeleton";
+import { AppContext } from "@/config";
+
+// max 15 chars
+export const shortname = "heb-ppl-pst-cmt";
+
+export const handler = async (ctx: AppContext, params: QueryParams) => {
+  let builder = ctx.db
+    .selectFrom("post")
+    .selectAll()
+    .orderBy("indexedAt", "desc")
+    .orderBy("cid", "desc")
+    // .where("parent_cid", "is not", null) // this is what makes it only posts and not replies
+    .limit(params.limit);
+
+  if (params.cursor) {
+    const timeStr = new Date(parseInt(params.cursor, 10)).toISOString();
+    builder = builder.where("post.indexedAt", "<", timeStr);
+  }
+  const res = await builder.execute();
+
+  const feed = res.map((row) => ({
+    post: row.uri,
+  }));
+
+  let cursor: string | undefined;
+  const last = res.at(-1);
+  if (last) {
+    cursor = new Date(last.indexedAt).getTime().toString(10);
+  }
+
+  return {
+    cursor,
+    feed,
+  };
+};

feed-generator/src/algos/heb-ppl-posts.ts

···
     .selectAll()
     .orderBy("indexedAt", "desc")
     .orderBy("cid", "desc")
+    .where("parent_cid", "is not", null) // this is what makes it only posts and not replies
     .limit(params.limit);
 
   if (params.cursor) {

feed-generator/src/db/migrations.ts

···
       .addColumn("uri", "varchar", (col) => col.primaryKey())
       .addColumn("cid", "varchar", (col) => col.notNull())
       .addColumn("author_did", "varchar", (col) => col.notNull())
+      .addColumn("parent_cid", "varchar")
       .addColumn("indexedAt", "varchar", (col) => col.notNull())
       .addColumn("analysis", "text") // json
       .execute();

feed-generator/src/db/schema.ts

···
   uri: string;
   cid: string;
   author_did: string;
+  parent_cid?: string | null;
   indexedAt: string;
   analysis: string;
 };

feed-generator/src/heb-ppl/subscriber.ts

···
       uri: post.uri,
       cid: post.cid,
       author_did: post.author,
+      parent_cid: post.record.reply?.parent.cid,
       indexedAt: timestamp,
       analysis: JSON.stringify({ counts }),
     };