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

HotFix message in back

Browse source
This commit is contained in:
Gregoire Parant 2021-03-11 01:25:36 +01:00
parent a28fcbb9e6
commit 46cb9333e6
6 changed files with 53 additions and 49 deletions
Download patch file Download diff file Expand all files Collapse all files

2
back/src/RoomManager.ts
View file

@ -204,7 +204,7 @@ const roomManager: IRoomManagerServer = {
}, },
ban(call: ServerUnaryCall<BanMessage>, callback: sendUnaryData<EmptyMessage>): void { ban(call: ServerUnaryCall<BanMessage>, callback: sendUnaryData<EmptyMessage>): void {
// FIXME Work in progress // FIXME Work in progress
socketManager.banUser(call.request.getRoomid(), call.request.getRecipientuuid(), 'foo bar TODO change this'); socketManager.banUser(call.request.getRoomid(), call.request.getRecipientuuid(), call.request.getMessage());
callback(null, new EmptyMessage()); callback(null, new EmptyMessage());
}, },

19
back/src/Services/SocketManager.ts
View file

@ -809,10 +809,10 @@ export class SocketManager {
sendUserMessage.setMessage(message); sendUserMessage.setMessage(message);
sendUserMessage.setType('ban'); sendUserMessage.setType('ban');
const subToPusherMessage = new SubToPusherMessage(); const serverToClientMessage = new ServerToClientMessage();
subToPusherMessage.setSendusermessage(sendUserMessage); serverToClientMessage.setSendusermessage(sendUserMessage);
recipient.socket.write(subToPusherMessage); recipient.socket.write(serverToClientMessage);
} }
public banUser(roomId: string, recipientUuid: string, message: string): void { public banUser(roomId: string, recipientUuid: string, message: string): void {
@ -831,16 +831,15 @@ export class SocketManager {
// Let's leave the room now. // Let's leave the room now.
room.leave(recipient); room.leave(recipient);
const sendUserMessage = new SendUserMessage(); const banUserMessage = new BanUserMessage();
sendUserMessage.setMessage(message); banUserMessage.setMessage(message);
sendUserMessage.setType('banned'); banUserMessage.setType('banned');
const subToPusherMessage = new SubToPusherMessage(); const serverToClientMessage = new ServerToClientMessage();
subToPusherMessage.setSendusermessage(sendUserMessage); serverToClientMessage.setBanusermessage(banUserMessage);
recipient.socket.write(subToPusherMessage);
// Let's close the connection when the user is banned. // Let's close the connection when the user is banned.
recipient.socket.write(serverToClientMessage);
recipient.socket.end(); recipient.socket.end();
} }
} }

2
front/src/Connexion/RoomConnection.ts
View file

@ -186,6 +186,8 @@ export class RoomConnection implements RoomConnection {
this.dispatch(EventMessage.START_JITSI_ROOM, message.getSendjitsijwtmessage()); this.dispatch(EventMessage.START_JITSI_ROOM, message.getSendjitsijwtmessage());
} else if (message.hasSendusermessage()) { } else if (message.hasSendusermessage()) {
this.dispatch(EventMessage.USER_MESSAGE, message.getSendusermessage()); this.dispatch(EventMessage.USER_MESSAGE, message.getSendusermessage());
} else if (message.hasBanusermessage()) {
this.dispatch(EventMessage.USER_MESSAGE, message.getBanusermessage());
} else { } else {
throw new Error('Unknown message received'); throw new Error('Unknown message received');
} }

3
messages/protos/messages.proto
View file

@ -349,6 +349,7 @@ message AdminMessage {
string message = 1; string message = 1;
string recipientUuid = 2; string recipientUuid = 2;
string roomId = 3; string roomId = 3;
string type = 4;
} }
// A message sent by an administrator to absolutely everybody // A message sent by an administrator to absolutely everybody
@ -359,6 +360,8 @@ message AdminGlobalMessage {
message BanMessage { message BanMessage {
string recipientUuid = 1; string recipientUuid = 1;
string roomId = 2; string roomId = 2;
string type = 3;
string message = 4;
} }
message EmptyMessage { message EmptyMessage {

4
pusher/src/Controller/IoSocketController.ts
View file

@ -92,10 +92,10 @@ export class IoSocketController {
if(message.event === 'user-message') { if(message.event === 'user-message') {
const messageToEmit = (message.message as { message: string, type: string, userUuid: string }); const messageToEmit = (message.message as { message: string, type: string, userUuid: string });
if(messageToEmit.type === 'banned'){ if(messageToEmit.type === 'banned'){
socketManager.emitBan(messageToEmit.userUuid, messageToEmit.message, messageToEmit.type); socketManager.emitBan(messageToEmit.userUuid, messageToEmit.message, messageToEmit.type, ws.roomId as string);
} }
if(messageToEmit.type === 'ban') { if(messageToEmit.type === 'ban') {
socketManager.emitSendUserMessage(messageToEmit.userUuid, messageToEmit.message, messageToEmit.type); socketManager.emitSendUserMessage(messageToEmit.userUuid, messageToEmit.message, messageToEmit.type, ws.roomId as string);
} }
} }
}catch (err) { }catch (err) {

50
pusher/src/Services/SocketManager.ts
View file

@ -23,7 +23,7 @@ import {
AdminPusherToBackMessage, AdminPusherToBackMessage,
ServerToAdminClientMessage, ServerToAdminClientMessage,
SendUserMessage, SendUserMessage,
BanUserMessage, UserJoinedRoomMessage, UserLeftRoomMessage BanUserMessage, UserJoinedRoomMessage, UserLeftRoomMessage, AdminMessage, BanMessage
} from "../Messages/generated/messages_pb"; } from "../Messages/generated/messages_pb";
import {PointInterface} from "../Model/Websocket/PointInterface"; import {PointInterface} from "../Model/Websocket/PointInterface";
import {ProtobufUtils} from "../Model/Websocket/ProtobufUtils"; import {ProtobufUtils} from "../Model/Websocket/ProtobufUtils";
@ -549,54 +549,54 @@ export class SocketManager implements ZoneEventListener {
} }
} }
public emitSendUserMessage(userUuid: string, message: string, type: string): void { public async emitSendUserMessage(userUuid: string, message: string, type: string, roomId: string) {
const client = this.searchClientByUuid(userUuid); const client = this.searchClientByUuid(userUuid);
if(!client){ if(client) {
throw Error('client not found');
}
const adminMessage = new SendUserMessage(); const adminMessage = new SendUserMessage();
adminMessage.setMessage(message); adminMessage.setMessage(message);
adminMessage.setType(type); adminMessage.setType(type);
const pusherToBackMessage = new PusherToBackMessage(); const pusherToBackMessage = new PusherToBackMessage();
pusherToBackMessage.setSendusermessage(adminMessage); pusherToBackMessage.setSendusermessage(adminMessage);
client.backConnection.write(pusherToBackMessage); client.backConnection.write(pusherToBackMessage);
return;
}
/*const backConnection = await apiClientRepository.getClient(client.roomId); const backConnection = await apiClientRepository.getClient(roomId);
const adminMessage = new AdminMessage(); const backAdminMessage = new AdminMessage();
adminMessage.setMessage(message); backAdminMessage.setMessage(message);
adminMessage.setRoomid(client.roomId); backAdminMessage.setRoomid(roomId);
adminMessage.setRecipientuuid(client.userUuid); backAdminMessage.setRecipientuuid(userUuid);
backConnection.sendAdminMessage(adminMessage, (error) => { backAdminMessage.setType(type);
backConnection.sendAdminMessage(backAdminMessage, (error) => {
if (error !== null) { if (error !== null) {
console.error('Error while sending admin message', error); console.error('Error while sending admin message', error);
} }
});*/ });
} }
public emitBan(userUuid: string, message: string, type: string): void { public async emitBan(userUuid: string, message: string, type: string, roomId: string) {
const client = this.searchClientByUuid(userUuid); const client = this.searchClientByUuid(userUuid);
if(!client){ if(client) {
throw Error('client not found');
}
const banUserMessage = new BanUserMessage(); const banUserMessage = new BanUserMessage();
banUserMessage.setMessage(message); banUserMessage.setMessage(message);
banUserMessage.setType(type); banUserMessage.setType(type);
const pusherToBackMessage = new PusherToBackMessage(); const pusherToBackMessage = new PusherToBackMessage();
pusherToBackMessage.setBanusermessage(banUserMessage); pusherToBackMessage.setBanusermessage(banUserMessage);
client.backConnection.write(pusherToBackMessage); client.backConnection.write(pusherToBackMessage);
return;
}
/*const backConnection = await apiClientRepository.getClient(client.roomId); const backConnection = await apiClientRepository.getClient(roomId);
const adminMessage = new AdminMessage(); const banMessage = new BanMessage();
adminMessage.setMessage(message); banMessage.setMessage(message);
adminMessage.setRoomid(client.roomId); banMessage.setRoomid(roomId);
adminMessage.setRecipientuuid(client.userUuid); banMessage.setRecipientuuid(userUuid);
backConnection.sendAdminMessage(adminMessage, (error) => { banMessage.setType(type);
backConnection.ban(banMessage, (error) => {
if (error !== null) { if (error !== null) {
console.error('Error while sending admin message', error); console.error('Error while sending admin message', error);
} }
});*/ });
} }
/** /**