refactor: update publishMessage calls for consistency and error handling

- Changed `void publishMessage` to `await publishMessage` in comment actions to ensure proper asynchronous handling.
- Updated the `publishMessage` function in pusher.server.ts to return a value, improving error handling and consistency in message publishing.
- Adjusted notification function in inngest.ts to return the result of `publishMessage`, enhancing clarity in notification flow.

Author: kingRayhan

src/backend/services/comment.action.ts

@@ -75,7 +75,7 @@ export const createMyComment = async (
       console.error("[inngest] Failed to send notification event:", err);
     });
 
-  void publishMessage(
+  await publishMessage(
     `resource.${resource_type}.${resource_id}`,
     REALTIME_PUSHER_EVENTS.COMMENT_CREATED,
     { scope: "comments" },
@@ -110,7 +110,7 @@ export const updateMyComment = async (
       data: { body: input.body, updated_at: new Date() },
     });
 
-    void publishMessage(
+    await publishMessage(
       `resource.${existing.resource_type}.${existing.resource_id}`,
       REALTIME_PUSHER_EVENTS.COMMENT_UPDATED,
       { scope: "comments" },
@@ -168,7 +168,7 @@ export const deleteMyComment = async (
       where: inArray("id", ids),
     });
 
-    void publishMessage(
+    await publishMessage(
       `resource.${root.resource_type}.${root.resource_id}`,
       REALTIME_PUSHER_EVENTS.COMMENT_DELETED,
       { scope: "comments" },

src/lib/inngest.ts

@@ -196,7 +196,7 @@ export const persistNotificationFn = inngest.createFunction(
     });
 
     await step.run("publish-notification-realtime", async () => {
-      await publishMessage(
+      return await publishMessage(
         `private-user.${data.recipient_id}`,
         REALTIME_PUSHER_EVENTS.NOTIFICATION_NEW,
         { scope: "notifications" },

src/lib/pusher/pusher.server.ts

@@ -36,11 +36,12 @@ export async function publishMessage(
   channel: string,
   event: RealtimePusherEvent,
   data: Record<string, unknown> = {},
-): Promise<void> {
+) {
   if (!pusherServer) return;
   try {
-    await pusherServer.trigger(channel, event, data);
+    return await pusherServer.trigger(channel, event, data);
   } catch (err) {
     console.error("[pusher] Failed to publish message:", JSON.stringify(err));
+    return null;
   }
 }