Unify ephemeral message events (#19464)

app/apps/server/bridges/messages.js

@@ -51,7 +51,7 @@ export class AppMessageBridge {
 			return;
 		}
 
-		api.broadcast('stream.ephemeralMessage', user.id, msg.rid, {
+		api.broadcast('notify.ephemeralMessage', user.id, msg.rid, {
 			...msg,
 		});
 	}
@@ -72,7 +72,7 @@ export class AppMessageBridge {
 		Users.findByIds(users, { fields: { _id: 1 } })
 			.fetch()
 			.forEach(({ _id }) =>
-				api.broadcast('stream.ephemeralMessage', _id, room.id, {
+				api.broadcast('notify.ephemeralMessage', _id, room.id, {
 					...msg,
 				}),
 			);

ee/server/services/ddp-streamer/DDPStreamer.ts

@@ -114,16 +114,6 @@ export class DDPStreamer extends ServiceClass {
 		this.onEvent('meteor.autoUpdateClientVersionChanged', ({ record }): void => {
 			events.emit('meteor.autoUpdateClientVersionChanged', record);
 		});
-
-		this.onEvent('stream.ephemeralMessage', (uid, rid, message): void => {
-			notifications.notifyUser(uid, 'message', {
-				groupable: false,
-				...message,
-				_id: String(Date.now()),
-				rid,
-				ts: new Date(),
-			});
-		});
 	}
 
 	async created(): Promise<void> {

server/sdk/lib/Events.ts

@@ -28,7 +28,6 @@ export type EventSignatures = {
 	'room.avatarUpdate'(room: Partial<IRoom>): void;
 	'setting'(data: { action: string; setting: Partial<ISetting> }): void;
 	'stream'([streamer, eventName, payload]: [string, string, string]): void;
-	'stream.ephemeralMessage'(uid: string, rid: string, message: Partial<IMessage>): void;
 	'subscription'(data: { action: string; subscription: Partial<ISubscription> }): void;
 	'user.avatarUpdate'(user: Partial<IUser>): void;
 	'user.deleted'(user: Partial<IUser>): void;