name changer event added

src/Constants/Renames.js

@@ -0,0 +1,7 @@
+const RENAMES = {
+    ROOM: 'room',
+    USER: 'user',
+  }
+
+  export default RENAMES;
+

src/Constants/SocketEvents.js

@@ -17,6 +17,8 @@ const SOCKET_EVENTS = {
   VIDEO_DURATION_CHANGED: 'video-duration-changed',
   SKIP_VIDEO: 'skip-video',
   VIDEO_SKIPPED: 'video-skipped',
+  CHANGE_NAME: 'change-name',
+  NAME_CHANGED: 'name-changed',
 };
 
 export default SOCKET_EVENTS;

src/Constants/index.js

@@ -2,11 +2,13 @@ import SOCKET_EVENTS from './SocketEvents';
 import PLAYLIST_STATUS from './PlaylistStatus';
 import VIDEO_STATUS from './VideoStatus';
 import { USER_TYPES, ACTIONS } from './Room';
+import RENAMES from './Renames';
 
 export {
   SOCKET_EVENTS,
   PLAYLIST_STATUS,
   VIDEO_STATUS,
   USER_TYPES,
   ACTIONS,
+  RENAMES,
 };

src/Events/Room/index.js

@@ -12,9 +12,21 @@ export const joinRoom = async ({ id, userId, username }, { socket, io }) => {
   io.to(id).emit(SOCKET_EVENTS.RECEIVE_MESSAGE, { message });
 };
 
+export const changeName = async ({
+  id, type, name
+}, { socket, io }) => {
+  await RoomService.changeName({id, socketId: socket.id,  type, name});
+
+  io.to(id).emit(SOCKET_EVENTS.NAME_CHANGED, { name, type });
+};
+
 export default [
   {
     event: SOCKET_EVENTS.JOIN_ROOM,
     handler: joinRoom,
   },
+  {
+    event: SOCKET_EVENTS.CHANGE_NAME,
+    handler: changeName,
+  },
 ];

src/Services/Room/index.js

@@ -1,8 +1,7 @@
-import Model from 'metronom';
 import axios from 'axios';
 import MessageService from '../Message';
 import generateId from '../../Utilities/GenerateId';
-import { USER_TYPES, VIDEO_STATUS } from '../../Constants';
+import { USER_TYPES, VIDEO_STATUS, RENAMES } from '../../Constants';
 import { MongoRoomModel, RedisRoomModel, UserModel } from '../../Models';
 import CustomError from '../../Exceptions/CustomError';
 
@@ -305,6 +304,26 @@ const addSocketId = async (id, socketId) => {
   return user;
 };
 
+const changeName = async ({id, socketId,  type, name}) => {
+  let willBeRenamed;
+  switch (type) {
+    case RENAMES.USER:
+      willBeRenamed = await findUserWithSocketId(socketId);
+      willBeRenamed.username = name;
+      break;
+    case RENAMES.ROOM:
+      willBeRenamed = await findMongoRoom(id);
+      willBeRenamed.name = name;
+      break;
+    default:
+      break;
+  }
+
+  willBeRenamed.save();
+
+  return willBeRenamed;
+};
+
 const RoomService = {
   createRoom,
   joinRoom,
@@ -325,6 +344,7 @@ const RoomService = {
   findUserWithId,
   findUserWithSocketId,
   addSocketId,
+  changeName,
 };
 
 export default RoomService;