feat: enhance reaction and comment handling with unique IDs

- Added optional `id` field to the Reaction interface for better tracking.
- Updated comment creation to generate a unique comment ID, improving notification consistency.
- Introduced unique reaction IDs during reaction creation to enhance notification handling.
- Refactored notification persistence to ensure reliable insertion and real-time publishing without duplicates.

Author: kingRayhan

src/backend/models/domain-models.ts

@@ -196,6 +196,7 @@ export enum DIRECTORY_NAME {
 }
 
 export interface Reaction {
+  id?: string;
   resource_id: string;
   resource_type: "ARTICLE" | "COMMENT" | "GIST";
   reaction_type: REACTION_TYPE;

src/backend/services/comment.action.ts

@@ -47,9 +47,11 @@ export const createMyComment = async (
 
   await assertCommentResourceExists(resource_id, resource_type);
 
+  const commentId = input.comment_id ?? crypto.randomUUID();
+
   const created = await persistenceRepository.comment.insert([
     {
-      id: input.comment_id ?? crypto.randomUUID(),
+      id: commentId,
       body,
       resource_id,
       resource_type,
@@ -59,6 +61,7 @@ export const createMyComment = async (
 
   inngest
     .send({
+      id: `notif:comment:${commentId}`,
       name: "app/notification.requested",
       data: {
         actor_id: sessionId,

src/backend/services/reaction.actions.ts

@@ -69,9 +69,12 @@ export async function toogleReaction(
       };
     }
 
+    const reactionId = crypto.randomUUID();
+
     // If reaction does not exist, create it
     await persistenceRepository.reaction.insert([
       {
+        id: reactionId,
         resource_id: input.resource_id,
         resource_type: input.resource_type,
         reaction_type: input.reaction_type,
@@ -83,6 +86,7 @@ export async function toogleReaction(
     // Send notification event for insert path only (log errors, don't fail mutation)
     inngest
       .send({
+        id: `notif:reaction:${reactionId}`,
         name: "app/notification.requested",
         data: {
           actor_id: sessionUserId,

src/lib/inngest.ts

@@ -122,13 +122,13 @@ export const persistNotificationFn = inngest.createFunction(
     id: "persist-notification",
     triggers: [{ event: "app/notification.requested" }],
   },
-  async ({ event }: { event: { data: NotificationEventData } }) => {
+  async ({ event, step }) => {
     const parsed = notificationEventSchema.safeParse(event.data);
     if (!parsed.success) {
       return { skipped: true, reason: "invalid-notification-payload" };
     }
 
-    let data = parsed.data;
+    let data: NotificationEventData = parsed.data;
 
     if (data.reaction_request && data.actor_id) {
       const built = await buildPersistableNotification({
@@ -182,23 +182,26 @@ export const persistNotificationFn = inngest.createFunction(
       return { skipped: true, reason: "self-notification" };
     }
 
-    await persistenceRepository.notification.insert([
-      {
-        recipient_id: data.recipient_id,
-        actor_id: data.actor_id ?? null,
-        type: data.type as NotificationType,
-        payload: (data.payload ?? null) as NotificationPayload | null,
-        created_at: new Date(),
-      },
-    ]);
+    const row = {
+      recipient_id: data.recipient_id,
+      actor_id: data.actor_id ?? null,
+      type: data.type as NotificationType,
+      payload: (data.payload ?? null) as NotificationPayload | null,
+      created_at: new Date(),
+    };
 
-    // Broadcast a lightweight signal so the recipient's browser can invalidate
-    // its TanStack Query caches without polling.
-    await publishMessage(
-      `private-user.${data.recipient_id}`,
-      REALTIME_PUSHER_EVENTS.NOTIFICATION_NEW,
-      { scope: "notifications" },
-    );
+    // Durable step: retries must not insert duplicate rows when a later line fails.
+    await step.run("insert-notification-row", async () => {
+      await persistenceRepository.notification.insert([row]);
+    });
+
+    await step.run("publish-notification-realtime", async () => {
+      await publishMessage(
+        `private-user.${data.recipient_id}`,
+        REALTIME_PUSHER_EVENTS.NOTIFICATION_NEW,
+        { scope: "notifications" },
+      );
+    });
 
     return { success: true };
   },

src/lib/pusher/pusher.server.ts

@@ -37,16 +37,10 @@ export async function publishMessage(
   event: RealtimePusherEvent,
   data: Record<string, unknown> = {},
 ): Promise<void> {
-  console.log(`
-    [pusher] Publishing message to channel ${channel} with event ${event} and data ${JSON.stringify(data)}
-  `);
-
-  pusherServer
-    ?.trigger(channel, event, data)
-    .then((data) => {
-      console.log("[pusher] Published message successfully");
-    })
-    .catch((err) => {
-      console.error("[pusher] Failed to publish message:", JSON.stringify(err));
-    });
+  if (!pusherServer) return;
+  try {
+    await pusherServer.trigger(channel, event, data);
+  } catch (err) {
+    console.error("[pusher] Failed to publish message:", JSON.stringify(err));
+  }
 }