Merge pull request #138 from jacobrs/chat_filtering

fix #131 and fix #76 added new message filtering
jacobrs · Apr 11, 2017 · f8086f5 · f8086f5
2 parents f6c0173 + 70abdba
commit f8086f5
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 2 deletions.
diff --git a/client/modules/User/UserReducer.js b/client/modules/User/UserReducer.js
@@ -97,12 +97,14 @@ const UserReducer = (state = initialState, action) => {
     }
     case PREPARE_CHAT_MESSAGE: {
       let userIndex = state.chat.users.indexOf(action.message.user);
+
       if (userIndex === -1) {
         state.chat.users.push(action.message.user);
         userIndex = state.chat.users.length - 1;
       }
 
       state.chat.messages.push(<div key={state.chat.messages.length + 1} style={{ color: getColorFromUserIndex(userIndex) }}>{`${action.message.user}: ${action.message.message}`}</div>);
+
       return {
         user: state.user,
         currentStudyGroup: state.currentStudyGroup,

diff --git a/client/modules/User/components/ChatComponent/ChatComponent.js b/client/modules/User/components/ChatComponent/ChatComponent.js
@@ -49,7 +49,9 @@ export class ChatComponent extends Component {
   }
 
   onMessageReceive(data) {
-    this.props.prepareChatMessage(data);
+    if (this.props.users.user.studyGroups[this.props.users.currentStudyGroup].guid == data.studyGroup) {
+      this.props.prepareChatMessage(data);      
+    }
   }
 
   handleChange(event) {

diff --git a/server/socketEvents.js b/server/socketEvents.js
@@ -31,7 +31,7 @@ exports = module.exports = function (io) {
           throw err;
         }
         else {
-          io.sockets.emit('UpdateMessages', { message: data.message, user: socket.nickname });
+          io.sockets.emit('UpdateMessages', { message: data.message, user: socket.nickname, studyGroup: data.studyGroup });
         }
       });
     });