Kraut.World/server
3
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Redirect user on wait scene

Browse source 
- Create wait scene
- Load wait scne with status close message
This commit is contained in:
Gregoire Parant 2020-10-22 01:33:36 +02:00
parent 7ac4a2b849
commit f9bb749c56
5 changed files with 121 additions and 21 deletions
Download patch file Download diff file Expand all files Collapse all files

31
back/src/Controller/IoSocketController.ts
View file

@ -165,10 +165,10 @@ export class IoSocketController {
const room = await socketManager.getOrCreateRoom(roomId);
//TODO http return status
/*if (room.isFull()) {
res.writeStatus("503").end('Too many users');
return;
/*if (room.isFull) {
throw new Error('Room is full');
}*/
try {
const userData = await adminApi.fetchMemberDataByUuid(userUuid);
//console.log('USERDATA', userData)
@ -239,14 +239,13 @@ export class IoSocketController {
(async () => {
// Let's join the room
const client = this.initClient(ws); //todo: into the upgrade instead?
socketManager.handleJoinRoom(client);
resetPing(client);
//if room is full, emit redirect room message
const room = await socketManager.getOrCreateRoom(client.roomId);
if (room.isFull) {
socketManager.emitCloseMessage(client.userUuid, 302);
return;
const room = socketManager.getRoomById(client.roomId);
if (room && room.isFull) {
socketManager.emitCloseMessage(client, 302);
}else {
socketManager.handleJoinRoom(client);
resetPing(client);
}
//get data information and shwo messages
@ -263,13 +262,20 @@ export class IoSocketController {
message: messageToSend.message
})
});
}catch(err) {
} catch (err) {
console.error('fetchMemberDataByUuid => err', err);
};
}
})();
},
message: (ws, arrayBuffer, isBinary): void => {
const client = ws as ExSocketInterface;
const room = socketManager.getRoomById(client.roomId);
if (room && room.isFull) {
return;
}
const message = ClientToServerMessage.deserializeBinary(new Uint8Array(arrayBuffer));
if (message.hasViewportmessage()) {
@ -293,7 +299,6 @@ export class IoSocketController {
} else if (message.hasQueryjitsijwtmessage()){
socketManager.handleQueryJitsiJwtMessage(client, message.getQueryjitsijwtmessage() as QueryJitsiJwtMessage);
}
/* Ok is false if backpressure was built up, wait for drain */
//let ok = ws.send(message, isBinary);
},