stream

RocketChat · Oct 3, 2023 · 68037ee · 68037ee
1 parent 43922e4
commit 68037ee
Show file tree

Hide file tree

Showing 4 changed files with 11 additions and 2 deletions.
diff --git a/apps/meteor/server/modules/listeners/listeners.module.ts b/apps/meteor/server/modules/listeners/listeners.module.ts
@@ -471,5 +471,13 @@ export class ListenersModule {
 			notifications.streamApps.emitWithoutBroadcast('actions/changed');
 			notifications.streamApps.emitWithoutBroadcast('apps', ['actions/changed', []]);
 		});
+
+		service.onEvent('mac.limitReached', () => {
+			notifications.notifyLoggedInThisInstance('mac.limit', { limitReached: true });
+		});
+
+		service.onEvent('mac.limitRestored', () => {
+			notifications.notifyLoggedInThisInstance('mac.limit', { limitReached: false });
+		});
 	}
 }
diff --git a/apps/meteor/server/services/omnichannel/mac.ts b/apps/meteor/server/services/omnichannel/mac.ts
diff --git a/apps/meteor/server/services/omnichannel/service.ts b/apps/meteor/server/services/omnichannel/service.ts
@@ -32,12 +32,12 @@ export class OmnichannelService extends ServiceClassInternal implements IOmnicha
 		});
 
 		License.onLimitReached('monthlyActiveContacts', async (): Promise<void> => {
-			void this.api?.broadcast('mac.LimitReached', {});
+			void this.api?.broadcast('mac.limitReached');
 			await this.queueWorker.stop();
 		});
 
 		License.onValidateLicense(async (): Promise<void> => {
-			void this.api?.broadcast('mac.limitRestored', {});
+			void this.api?.broadcast('mac.limitRestored');
 			await this.queueWorker.shouldStart();
 		});
 	}

diff --git a/ee/packages/ddp-client/src/types/streams.ts b/ee/packages/ddp-client/src/types/streams.ts
@@ -235,6 +235,7 @@ export interface StreamerEvents {
 		},
 
 		{ key: 'voip.statuschanged'; args: [boolean] },
+		{ key: 'mac.limit'; args: [{ limitReached: boolean }] },
 		{ key: 'omnichannel.priority-changed'; args: [{ id: string; clientAction: ClientAction; name?: string }] },
 	];
-Original file line number
+Diff line change
@@ Expand Up / @@ -235,6 +235,7 @@ export interface StreamerEvents { @@
     		},
     		{ key: 'voip.statuschanged'; args: [boolean] },
+    		{ key: 'mac.limit'; args: [{ limitReached: boolean }] },
     		{ key: 'omnichannel.priority-changed'; args: [{ id: string; clientAction: ClientAction; name?: string }] },
     	];
@@ Expand Down @@