Step 9.5: Add Subscription.chatRemoved

Urigo · May 20, 2020 · 1b26dec · 1b26dec
1 parent ceaf88f
commit 1b26dec
Show file tree

Hide file tree

Showing 2 changed files with 18 additions and 1 deletion.
diff --git a/schema/resolvers.ts b/schema/resolvers.ts
@@ -160,7 +160,7 @@ const resolvers: Resolvers = {
       return chat;
     },
 
-    removeChat(root, { chatId }, { currentUser }) {
+    removeChat(root, { chatId }, { currentUser, pubsub }) {
       if (!currentUser) return null;
 
       const chatIndex = chats.findIndex(c => c.id === chatId);
@@ -181,6 +181,11 @@ const resolvers: Resolvers = {
 
       chats.splice(chatIndex, 1);
 
+      pubsub.publish('chatRemoved', {
+        chatRemoved: chat.id,
+        targetChat: chat,
+      });
+
       return chatId;
     },
   },
@@ -209,6 +214,17 @@ const resolvers: Resolvers = {
         }
       ),
     },
+
+    chatRemoved: {
+      subscribe: withFilter(
+        (root, args, { pubsub }) => pubsub.asyncIterator('chatRemoved'),
+        ({ targetChat }: { targetChat: Chat }, args, { currentUser }) => {
+          if (!currentUser) return false;
+
+          return targetChat.participants.some(p => p === currentUser.id);
+        }
+      ),
+    },
   },
 };
 

diff --git a/schema/typeDefs.graphql b/schema/typeDefs.graphql
@@ -41,4 +41,5 @@ type Mutation {
 type Subscription {
   messageAdded: Message!
   chatAdded: Chat!
+  chatRemoved: ID!
 }