add pubsub

 import { prisma, isAuthenticated } from "../../../utils";
 import { prisma, isAuthenticated } from "../../../utils";
+import { NEW_MESSAGE } from "../../../topics";
 
 
 export default {
 export default {
   Mutation: {
   Mutation: {
-    createMessage: async (_, args, { request }) => {
+    createMessage: async (_, args, { request, pubsub }) => {
       isAuthenticated(request);
       isAuthenticated(request);
       const { user } = request;
       const { user } = request;
       const { message, roomId } = args;
       const { message, roomId } = args;
@@ -46,6 +47,11 @@ export default {
       } else {
       } else {
         throw new Error("There is no room");
         throw new Error("There is no room");
       }
       }
+
+      if (messageObj !== undefined) {
+        pubsub.publish(NEW_MESSAGE, { subMessage: messageObj });
+      }
+
       return messageObj;
       return messageObj;
     },
     },
   },
   },