update joins and where for notifications

likeandscribe · Nov 5, 2024 · 91706ac · 91706ac
1 parent 48cfc4b
commit 91706ac
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/packages/frontpage/lib/data/db/notification.ts b/packages/frontpage/lib/data/db/notification.ts
@@ -33,17 +33,18 @@ export const getNotifications = cache(
       .from(schema.Notification)
       .where(
         and(
+          eq(schema.Comment.status, "live"),
           eq(schema.Notification.did, user.did),
           cursor
             ? lt(schema.Notification.createdAt, cursorToDate(cursor))
             : undefined,
         ),
       )
-      .leftJoin(
+      .innerJoin(
         schema.Comment,
         eq(schema.Comment.id, schema.Notification.commentId),
       )
-      .leftJoin(schema.Post, eq(schema.Post.id, schema.Comment.postId))
+      .innerJoin(schema.Post, eq(schema.Post.id, schema.Comment.postId))
       .groupBy(schema.Notification.id)
       .orderBy(desc(schema.Notification.id))
       .limit(limit);