omni

src/agent.ts

@@ -140,6 +140,10 @@ export default (): void => {
 
 	b.on('getRoutingConfig', async () => {
 		const agent = rand(agents);
+
+		if (!agent) {
+			return;
+		}
 		await agent.getRoutingConfig();
 		const { departments } = (await agent.getAgentDepartments()) || {
 			departments: [],
@@ -151,11 +155,17 @@ export default (): void => {
 
 	b.on('getQueuedInquiries', async () => {
 		const agent = rand(agents);
+		if (!agent) {
+			return;
+		}
 		await agent.getQueuedInquiries();
 	});
 
 	b.on('takeInquiry', async () => {
 		const agent = rand(agents);
+		if (!agent) {
+			return;
+		}
 		const response = await agent.getQueuedInquiries();
 		if (!response?.inquiries) {
 			return;
@@ -170,6 +180,10 @@ export default (): void => {
 		}
 
 		const processedInquiry = rand(inquiries);
+
+		if (!processedInquiry) {
+			return;
+		}
 		try {
 			// Re-fetch inquiry
 			await agent.getInquiry(processedInquiry._id);
@@ -186,6 +200,9 @@ export default (): void => {
 
 	b.on('message', async () => {
 		const agent = rand(agents);
+		if (!agent) {
+			return;
+		}
 		const sub = agent.getRandomLivechatSubscription();
 
 		if (!sub) {

src/client/Omnichannel.ts

@@ -9,7 +9,12 @@ export class OmnichannelClient extends Client {
 		const subscriptions = this.subscriptions.filter(
 			(sub) => config.IGNORE_ROOMS.indexOf(sub.rid) === -1 && config.IGNORE_ROOMS.indexOf(sub.name) === -1 && sub.t === 'l',
 		);
-		return rand(subscriptions);
+		const subscription = rand(subscriptions);
+
+		if (!subscription) {
+			throw new Error('no subscriptions');
+		}
+		return subscription;
 	}
 
 	async getRoutingConfig(): Promise<{ [k: string]: string } | undefined> {

src/profile.ts

@@ -26,6 +26,10 @@ export default (): void => {
 	async function getLoggedInClient() {
 		const client = rand(clients);
 
+		if (!client) {
+			throw new Error('No logged in client found');
+		}
+
 		if (client.status === 'logging') {
 			throw new AlreadyLoggingError();
 		}