Release 1.42.0

package.json

@@ -1,6 +1,6 @@
 {
     "name": "@rocket.chat/apps-engine",
-    "version": "1.41.1",
+    "version": "1.42.0-alpha",
     "description": "The engine code for the Rocket.Chat Apps which manages, runs, translates, coordinates and all of that.",
     "main": "index",
     "typings": "index",

src/definition/accessors/ILivechatRead.ts

@@ -17,6 +17,8 @@ export interface ILivechatRead {
     isOnlineAsync(departmentId?: string): Promise<boolean>;
     getDepartmentsEnabledWithAgents(): Promise<Array<IDepartment>>;
     getLivechatRooms(visitor: IVisitor, departmentId?: string): Promise<Array<ILivechatRoom>>;
+    getLivechatOpenRoomsByAgentId(agentId: string): Promise<Array<ILivechatRoom>>;
+    getLivechatTotalOpenRoomsByAgentId(agentId: string): Promise<number>;
     /**
      * @deprecated This method does not adhere to the conversion practices applied
      * elsewhere in the Apps-Engine and will be removed in the next major version.

src/server/accessors/LivechatRead.ts

@@ -30,6 +30,14 @@ export class LivechatRead implements ILivechatRead {
         return this.livechatBridge.doFindRooms(visitor, departmentId, this.appId);
     }
 
+    public getLivechatTotalOpenRoomsByAgentId(agentId: string): Promise<number> {
+        return this.livechatBridge.doCountOpenRoomsByAgentId(agentId, this.appId);
+    }
+
+    public getLivechatOpenRoomsByAgentId(agentId: string): Promise<Array<ILivechatRoom>> {
+        return this.livechatBridge.doFindOpenRoomsByAgentId(agentId, this.appId);
+    }
+
     /**
      * @deprecated This method does not adhere to the conversion practices applied
      * elsewhere in the Apps-Engine and will be removed in the next major version.

src/server/bridges/LivechatBridge.ts

@@ -104,6 +104,18 @@ export abstract class LivechatBridge extends BaseBridge {
         }
     }
 
+    public async doCountOpenRoomsByAgentId(agentId: string, appId: string): Promise<number> {
+        if (this.hasReadPermission(appId, 'livechat-room')) {
+            return this.countOpenRoomsByAgentId(agentId, appId);
+        }
+    }
+
+    public async doFindOpenRoomsByAgentId(agentId: string, appId: string): Promise<Array<ILivechatRoom>> {
+        if (this.hasReadPermission(appId, 'livechat-room')) {
+            return this.findOpenRoomsByAgentId(agentId, appId);
+        }
+    }
+
     public async doFindRooms(visitor: IVisitor, departmentId: string | null, appId: string): Promise<Array<ILivechatRoom>> {
         if (this.hasReadPermission(appId, 'livechat-room')) {
             return this.findRooms(visitor, departmentId, appId);
@@ -171,6 +183,10 @@ export abstract class LivechatBridge extends BaseBridge {
 
     protected abstract closeRoom(room: ILivechatRoom, comment: string, closer: IUser | undefined, appId: string): Promise<boolean>;
 
+    protected abstract countOpenRoomsByAgentId(agentId: string, appId: string): Promise<number>;
+
+    protected abstract findOpenRoomsByAgentId(agentId: string, appId: string): Promise<Array<ILivechatRoom>>;
+
     protected abstract findRooms(visitor: IVisitor, departmentId: string | null, appId: string): Promise<Array<ILivechatRoom>>;
 
     protected abstract findDepartmentByIdOrName(value: string, appId: string): Promise<IDepartment | undefined>;

tests/test-data/bridges/livechatBridge.ts

@@ -70,6 +70,14 @@ export class TestLivechatBridge extends LivechatBridge {
         throw new Error('Method not implemented');
     }
 
+    public findOpenRoomsByAgentId(agentId: string, appId: string): Promise<ILivechatRoom[]> {
+        throw new Error('Method not implemented');
+    }
+
+    public countOpenRoomsByAgentId(agentId: string, appId: string): Promise<number> {
+        throw new Error('Method not implemented');
+    }
+
     public findDepartmentByIdOrName(value: string, appId: string): Promise<IDepartment | undefined> {
         throw new Error('Method not implemented');
     }