chore: Break big LivechatTyped file into smaller modules (#33656)

apps/meteor/app/apps/server/bridges/livechat.ts

@@ -10,7 +10,9 @@ import { LivechatVisitors, LivechatRooms, LivechatDepartment, Users } from '@roc
 
 import { callbacks } from '../../../../lib/callbacks';
 import { deasyncPromise } from '../../../../server/deasync/deasync';
-import { type ILivechatMessage, Livechat as LivechatTyped } from '../../../livechat/server/lib/LivechatTyped';
+import { Livechat as LivechatTyped } from '../../../livechat/server/lib/LivechatTyped';
+import { getRoomMessages } from '../../../livechat/server/lib/getRoomMessages';
+import type { ILivechatMessage } from '../../../livechat/server/lib/localTypes';
 import { settings } from '../../../settings/server';
 
 declare module '@rocket.chat/apps/dist/converters/IAppMessagesConverter' {
@@ -379,7 +381,7 @@ export class AppLivechatBridge extends LivechatBridge {
  throw new Error('Could not get the message converter to process livechat room messages');
  }
 
- const livechatMessages = await LivechatTyped.getRoomMessages({ rid: roomId });
+ const livechatMessages = await getRoomMessages({ rid: roomId });
  return Promise.all(await livechatMessages.map((message) => messageConverter.convertMessage(message, livechatMessages)).toArray());
  }
 

apps/meteor/app/lib/server/functions/closeLivechatRoom.ts

@@ -3,8 +3,8 @@ import { isOmnichannelRoom } from '@rocket.chat/core-typings';
 import { LivechatRooms, Subscriptions } from '@rocket.chat/models';
 
 import { hasPermissionAsync } from '../../../authorization/server/functions/hasPermission';
-import type { CloseRoomParams } from '../../../livechat/server/lib/LivechatTyped';
 import { Livechat } from '../../../livechat/server/lib/LivechatTyped';
+import type { CloseRoomParams } from '../../../livechat/server/lib/localTypes';
 import { notifyOnSubscriptionChanged } from '../lib/notifyListener';
 
 export const closeLivechatRoom = async (

apps/meteor/app/livechat/imports/server/rest/departments.ts

@@ -15,7 +15,7 @@ import {
  findArchivedDepartments,
 } from '../../../server/api/lib/departments';
 import { DepartmentHelper } from '../../../server/lib/Departments';
-import { Livechat as LivechatTs } from '../../../server/lib/LivechatTyped';
+import { saveDepartment, archiveDepartment, unarchiveDepartment, saveDepartmentAgents } from '../../../server/lib/departmentsLib';
 import { isDepartmentCreationAvailable } from '../../../server/lib/isDepartmentCreationAvailable';
 
 API.v1.addRoute(
@@ -62,7 +62,7 @@ API.v1.addRoute(
 
  const agents = this.bodyParams.agents ? { upsert: this.bodyParams.agents } : {};
  const { departmentUnit } = this.bodyParams;
- const department = await LivechatTs.saveDepartment(
+ const department = await saveDepartment(
  this.userId,
  null,
  this.bodyParams.department as ILivechatDepartment,
@@ -131,7 +131,7 @@ API.v1.addRoute(
  }
 
  const agentParam = permissionToAddAgents && agents ? { upsert: agents } : {};
- await LivechatTs.saveDepartment(this.userId, _id, department, agentParam, departmentUnit || {});
+ await saveDepartment(this.userId, _id, department, agentParam, departmentUnit || {});
 
  return API.v1.success({
  department: await LivechatDepartment.findOneById(_id),
@@ -191,7 +191,7 @@ API.v1.addRoute(
  },
  {
  async post() {
- await LivechatTs.archiveDepartment(this.urlParams._id);
+ await archiveDepartment(this.urlParams._id);
 
  return API.v1.success();
  },
@@ -206,7 +206,7 @@ API.v1.addRoute(
  },
  {
  async post() {
- await LivechatTs.unarchiveDepartment(this.urlParams._id);
+ await unarchiveDepartment(this.urlParams._id);
  return API.v1.success();
  },
  },
@@ -271,7 +271,7 @@ API.v1.addRoute(
  remove: Array,
  }),
  );
- await LivechatTs.saveDepartmentAgents(this.urlParams._id, this.bodyParams);
+ await saveDepartmentAgents(this.urlParams._id, this.bodyParams);
 
  return API.v1.success();
  },

apps/meteor/app/livechat/imports/server/rest/sms.ts

@@ -21,8 +21,8 @@ import { FileUpload } from '../../../../file-upload/server';
 import { checkUrlForSsrf } from '../../../../lib/server/functions/checkUrlForSsrf';
 import { settings } from '../../../../settings/server';
 import { setCustomField } from '../../../server/api/lib/customFields';
-import type { ILivechatMessage } from '../../../server/lib/LivechatTyped';
 import { Livechat as LivechatTyped } from '../../../server/lib/LivechatTyped';
+import type { ILivechatMessage } from '../../../server/lib/localTypes';
 
 const logger = new Logger('SMS');
 

apps/meteor/app/livechat/server/api/v1/room.ts

@@ -23,8 +23,8 @@ import { addUserToRoom } from '../../../../lib/server/functions/addUserToRoom';
 import { closeLivechatRoom } from '../../../../lib/server/functions/closeLivechatRoom';
 import { settings as rcSettings } from '../../../../settings/server';
 import { normalizeTransferredByData } from '../../lib/Helper';
-import type { CloseRoomParams } from '../../lib/LivechatTyped';
 import { Livechat as LivechatTyped } from '../../lib/LivechatTyped';
+import type { CloseRoomParams } from '../../lib/localTypes';
 import { findGuest, findRoom, settings, findAgent, onCheckRoomParams } from '../lib/livechat';
 
 const isAgentWithInfo = (agentObj: ILivechatAgent | { hiddenInfo: boolean }): agentObj is ILivechatAgent => !('hiddenInfo' in agentObj);

apps/meteor/app/livechat/server/hooks/sendEmailTranscriptOnClose.ts

@@ -3,7 +3,7 @@ import { isOmnichannelRoom } from '@rocket.chat/core-typings';
 import { LivechatRooms } from '@rocket.chat/models';
 
 import { callbacks } from '../../../../lib/callbacks';
-import type { CloseRoomParams } from '../lib/LivechatTyped';
+import type { CloseRoomParams } from '../lib/localTypes';
 import { sendTranscript } from '../lib/sendTranscript';
 
 type LivechatCloseCallbackParams = {

apps/meteor/app/livechat/server/lib/Helper.ts

@@ -47,6 +47,7 @@ import { settings } from '../../../settings/server';
 import { Livechat as LivechatTyped } from './LivechatTyped';
 import { queueInquiry, saveQueueInquiry } from './QueueManager';
 import { RoutingManager } from './RoutingManager';
+import { getOnlineAgents } from './getOnlineAgents';
 
 const logger = new Logger('LivechatHelper');
 export const allowAgentSkipQueue = (agent: SelectedAgent) => {
@@ -403,7 +404,7 @@ export const dispatchInquiryQueued = async (inquiry: ILivechatInquiryRecord, age
  await saveQueueInquiry(inquiry);
 
  // Alert only the online agents of the queued request
- const onlineAgents = await LivechatTyped.getOnlineAgents(department, agent);
+ const onlineAgents = await getOnlineAgents(department, agent);
  if (!onlineAgents) {
  logger.debug('Cannot notify agents of queued inquiry. No online agents found');
  return;