Step 9.3: Add Subscription.chatAdded

Urigo · May 20, 2020 · d361ec1 · d361ec1
1 parent 5008bbf
commit d361ec1
Show file tree

Hide file tree

Showing 2 changed files with 17 additions and 1 deletion.
diff --git a/schema/resolvers.ts b/schema/resolvers.ts
@@ -131,7 +131,7 @@ const resolvers: Resolvers = {
       return message;
     },
 
-    addChat(root, { recipientId }, { currentUser }) {
+    addChat(root, { recipientId }, { currentUser, pubsub }) {
       if (!currentUser) return null;
       if (!users.some(u => u.id === recipientId)) return null;
 
@@ -153,6 +153,10 @@ const resolvers: Resolvers = {
 
       chats.push(chat);
 
+      pubsub.publish('chatAdded', {
+        chatAdded: chat,
+      });
+
       return chat;
     },
   },
@@ -170,6 +174,17 @@ const resolvers: Resolvers = {
         }
       ),
     },
+
+    chatAdded: {
+      subscribe: withFilter(
+        (root, args, { pubsub }) => pubsub.asyncIterator('chatAdded'),
+        ({ chatAdded }: { chatAdded: Chat }, args, { currentUser }) => {
+          if (!currentUser) return false;
+
+          return chatAdded.participants.some(p => p === currentUser.id);
+        }
+      ),
+    },
   },
 };
 

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