New: capability of muting or unmuting a user in a room

src/definition/accessors/IRoomUpdater.ts

@@ -0,0 +1,8 @@
+import { IRoom } from '../rooms';
+import { IUser } from '../users';
+
+export interface IRoomUpdater {
+    muteUser(room: IRoom, executorId: IUser, user: IUser): Promise<void>;
+
+    unmuteUser(room: IRoom, executorId: IUser, user: IUser): Promise<void>;
+}

src/server/accessors/RoomUpdater.ts

@@ -0,0 +1,17 @@
+import { IRoomUpdater } from '../../definition/accessors/IRoomUpdater';
+import { IRoom } from '../../definition/rooms';
+import { IUser } from '../../definition/users';
+import { AppBridges } from '../bridges';
+
+export class RoomUpdater implements IRoomUpdater {
+    constructor(private readonly bridges: AppBridges, private readonly appId: string) {
+    }
+
+    public async muteUser(room: IRoom, executor: IUser, user: IUser) {
+        return this.bridges.getRoomBridge().doMuteUser(room.id, executor.id, user.id, this.appId);
+    }
+
+    public async unmuteUser(room: IRoom, executor: IUser, user: IUser) {
+        return this.bridges.getRoomBridge().doUnmuteUser(room.id, executor.id, user.id, this.appId);
+    }
+}

src/server/bridges/RoomBridge.ts

@@ -49,6 +49,19 @@ export abstract class RoomBridge extends BaseBridge {
         }
     }
 
+    // TODO: check if we can use a list of user ids
+    public async doMuteUser(roomId: string, executorId: string, userId: string, appId: string): Promise<void> {
+        if (this.hasWritePermission(appId)) {
+            return this.doUnmuteUser(roomId, executorId, userId, appId);
+        }
+    }
+
+    public async doUnmuteUser(roomId: string, executorId: string, userId: string, appId: string): Promise<void> {
+        if (this.hasWritePermission(appId)) {
+            return this.doMuteUser(roomId, executorId, userId, appId);
+        }
+    }
+
     public async doUpdate(room: IRoom, members: Array<string>, appId: string): Promise<void> {
         if (this.hasWritePermission(appId)) {
             return this.update(room, members, appId);
@@ -92,25 +105,41 @@ export abstract class RoomBridge extends BaseBridge {
     }
 
     protected abstract create(room: IRoom, members: Array<string>, appId: string): Promise<string>;
+
     protected abstract getById(roomId: string, appId: string): Promise<IRoom>;
+
     protected abstract getByName(roomName: string, appId: string): Promise<IRoom>;
+
     protected abstract getCreatorById(roomId: string, appId: string): Promise<IUser | undefined>;
+
     protected abstract getCreatorByName(roomName: string, appId: string): Promise<IUser | undefined>;
+
     protected abstract getDirectByUsernames(usernames: Array<string>, appId: string): Promise<IRoom | undefined>;
+
     protected abstract getMembers(roomId: string, appId: string): Promise<Array<IUser>>;
+
     protected abstract update(room: IRoom, members: Array<string>, appId: string): Promise<void>;
+
     protected abstract createDiscussion(
         room: IRoom,
         parentMessage: IMessage | undefined,
         reply: string | undefined,
         members: Array<string>,
         appId: string,
     ): Promise<string>;
+
     protected abstract delete(room: string, appId: string): Promise<void>;
+
     protected abstract getModerators(roomId: string, appId: string): Promise<Array<IUser>>;
+
     protected abstract getOwners(roomId: string, appId: string): Promise<Array<IUser>>;
+
     protected abstract getLeaders(roomId: string, appId: string): Promise<Array<IUser>>;
 
+    protected abstract muteUser(roomId: string, executorId: string, userId: string, appId: string): Promise<void>;
+
+    protected abstract unmuteUser(roomId: string, executorId: string, userId: string, appId: string): Promise<void>;
+
     private hasWritePermission(appId: string): boolean {
         if (AppPermissionManager.hasPermission(appId, AppPermissions.room.write)) {
             return true;

tests/test-data/bridges/roomBridge.ts

@@ -55,4 +55,12 @@ export class TestsRoomBridge extends RoomBridge {
     public getOwners(roomId: string, appId: string): Promise<Array<IUser>> {
         throw new Error('Method not implemented.');
     }
+
+    public muteUser(roomId: string, executorId: string, userId: string, appId: string): Promise<void> {
+        throw new Error('Method not implemented');
+    }
+
+    public unmuteUser(roomId: string, executorId: string, userId: string, appId: string): Promise<void> {
+        throw new Error('Method not implemented');
+    }
 }