feat: add remove real time

aienginedev · May 1, 2023 · 230ac72 · 230ac72
1 parent e3b104c
commit 230ac72
Show file tree

Hide file tree

Showing 3 changed files with 29 additions and 3 deletions.
diff --git a/app/actions/getConversations.ts b/app/actions/getConversations.ts
@@ -1,8 +1,7 @@
 import prisma from "@/app/libs/prismadb";
 import getCurrentUser from "./getCurrentUser";
-import { cache } from "react";
 
-const getConversations = cache(async () => {
+const getConversations = async () => {
   const currentUser = await getCurrentUser();
 
   if (!currentUser?.id) {
@@ -34,6 +33,6 @@ const getConversations = cache(async () => {
   } catch (error: any) {
     return [];
   }
-});
+};
 
 export default getConversations;
diff --git a/app/api/conversations/[conversationId]/route.ts b/app/api/conversations/[conversationId]/route.ts
@@ -2,6 +2,7 @@ import getCurrentUser from "@/app/actions/getCurrentUser";
 import { NextResponse } from "next/server";
 
 import prisma from "@/app/libs/prismadb";
+import { pusherServer } from "@/app/libs/pusher";
 
 interface IParams {
   conversationId?: string;
@@ -19,6 +20,19 @@ export async function DELETE(
       return NextResponse.json(null);
     }
 
+    const existingConversation = await prisma.conversation.findUnique({
+      where: {
+        id: conversationId
+      },
+      include: {
+        users: true
+      }
+    });
+
+    if (!existingConversation) {
+      return new NextResponse('Invalid ID', { status: 400 });
+    }
+
     const deletedConversation = await prisma.conversation.deleteMany({
       where: {
         id: conversationId,
@@ -28,6 +42,12 @@ export async function DELETE(
       },
     });
 
+    existingConversation.users.forEach((user) => {
+      if (user.email) {
+        pusherServer.trigger(user.email, 'conversation:remove', existingConversation);
+      }
+    });
+
     return NextResponse.json(deletedConversation)
   } catch (error) {
     return NextResponse.json(null);

diff --git a/app/conversations/components/ConversationList.tsx b/app/conversations/components/ConversationList.tsx
@@ -66,8 +66,15 @@ const ConversationList: React.FC<ConversationListProps> = ({
       });
     }
 
+    const removeHandler = (conversation: FullConversationType) => {
+      setItems((current) => {
+        return [...current.filter((convo) => convo.id !== conversation.id)]
+      });
+    }
+
     pusherClient.bind('conversation:update', updateHandler)
     pusherClient.bind('conversation:new', newHandler)
+    pusherClient.bind('conversation:remove', removeHandler)
   }, [pusherKey, router]);
 
   return (