From c11ecfb40021d108ee1d035637fac08976948095 Mon Sep 17 00:00:00 2001
From: Mohammad Amoush <mohammad_amoush@brown.edu>
Date: Tue, 15 Oct 2019 18:08:57 -0400
Subject: Room notifications added

---
 src/server/Message.ts | 1 +
 src/server/index.ts   | 8 ++++++++
 2 files changed, 9 insertions(+)

(limited to 'src')

diff --git a/src/server/Message.ts b/src/server/Message.ts
index aaee143e8..7b72b693e 100644
--- a/src/server/Message.ts
+++ b/src/server/Message.ts
@@ -58,4 +58,5 @@ export namespace MessageStore {
     export const YoutubeApiQuery = new Message<YoutubeQueryInput>("Youtube Api Query");
     export const DeleteField = new Message<string>("Delete field");
     export const DeleteFields = new Message<string[]>("Delete fields");
+    export const NotifyRoommates = new Message<string>("Notify Roommates");
 }
diff --git a/src/server/index.ts b/src/server/index.ts
index 690836fff..6b884d099 100644
--- a/src/server/index.ts
+++ b/src/server/index.ts
@@ -776,6 +776,9 @@ server.on("connection", function (socket: Socket) {
     Utils.AddServerHandler(socket, MessageStore.DeleteFields, ids => DeleteFields(socket, ids));
     Utils.AddServerHandlerCallback(socket, MessageStore.GetRefField, GetRefField);
     Utils.AddServerHandlerCallback(socket, MessageStore.GetRefFields, GetRefFields);
+    Utils.AddServerHandler(socket, MessageStore.NotifyRoommates, message => HandleRoommateNotification(socket, message));
+
+
 });
 
 async function deleteFields() {
@@ -837,6 +840,11 @@ function HandleYoutubeQuery([query, callback]: [YoutubeQueryInput, (result?: any
     }
 }
 
+function HandleRoommateNotification(socket: Socket, message: String) {
+    socket.broadcast.emit('message', message);
+
+}
+
 const credentialsPath = path.join(__dirname, "./credentials/google_docs_credentials.json");
 
 const EndpointHandlerMap = new Map<GoogleApiServerUtils.Action, GoogleApiServerUtils.ApiRouter>([
-- 
cgit v1.2.3-70-g09d2