fix: processWebhookMessage & chat.postMessage types

apps/meteor/app/lib/server/functions/processWebhookMessage.js → apps/meteor/app/lib/server/functions/processWebhookMessage.ts

@@ -1,3 +1,4 @@
+import type { IMessage, IUser, RequiredField, MessageAttachment } from '@rocket.chat/core-typings';
 import { Meteor } from 'meteor/meteor';
 import _ from 'underscore';
 
@@ -7,9 +8,46 @@ import { validateRoomMessagePermissionsAsync } from '../../../authorization/serv
 import { getRoomByNameOrIdWithOptionToJoin } from './getRoomByNameOrIdWithOptionToJoin';
 import { sendMessage } from './sendMessage';
 
-export const processWebhookMessage = async function (messageObj, user, defaultValues = { channel: '', alias: '', avatar: '', emoji: '' }) {
+type Payload = {
+	channel?: string | string[];
+	roomId?: string | string[];
+	text?: IMessage['msg'];
+	msg?: IMessage['msg']; // overridden if text is present
+	username?: IMessage['alias'];
+	alias?: IMessage['alias']; // overridden if username is present
+	icon_emoji?: IMessage['emoji'];
+	emoji?: IMessage['emoji']; // overridden if icon_emoji is present
+	icon_url?: IMessage['avatar'];
+	avatar?: IMessage['avatar']; // overridden if icon_url is present
+	attachments?: IMessage['attachments'];
+	parseUrls?: boolean;
+	bot?: IMessage['bot'];
+	groupable?: IMessage['groupable'];
+	tmid?: IMessage['tmid'];
+};
+
+type DefaultValues = {
+	channel: string | string[];
+	alias: string;
+	avatar: string;
+	emoji: string;
+};
+
+const toArray = (value: string | Array<string>): Array<string> => {
+	if (typeof value === 'string') {
+		return [value];
+	}
+	return value;
+};
+
+export const processWebhookMessage = async function (
+	messageObj: Payload,
+	user: IUser & { username: RequiredField<IUser, 'username'> },
+	defaultValues: DefaultValues = { channel: '', alias: '', avatar: '', emoji: '' },
+) {
 	const sentData = [];
-	const channels = [].concat(messageObj.channel || messageObj.roomId || defaultValues.channel);
+
+	const channels: Array<string> = [...new Set(toArray(messageObj.channel || messageObj.roomId || defaultValues.channel))];
 
 	for await (const channel of channels) {
 		const channelType = channel[0];
@@ -69,7 +107,7 @@ export const processWebhookMessage = async function (messageObj, user, defaultVa
 			messageObj.attachments = undefined;
 		}
 
-		const message = {
+		const message: Partial<IMessage> & { parseUrls?: boolean } = {
 			alias: messageObj.username || messageObj.alias || defaultValues.alias,
 			msg: trim(messageObj.text || messageObj.msg || ''),
 			attachments: messageObj.attachments || [],
@@ -91,7 +129,7 @@ export const processWebhookMessage = async function (messageObj, user, defaultVa
 
 		if (Array.isArray(message.attachments)) {
 			for (let i = 0; i < message.attachments.length; i++) {
-				const attachment = message.attachments[i];
+				const attachment = message.attachments[i] as MessageAttachment & { msg?: string };
 				if (attachment.msg) {
 					attachment.text = trim(attachment.msg);
 					delete attachment.msg;

apps/meteor/client/views/room/modals/ForwardMessageModal/ForwardMessageModal.tsx

@@ -37,17 +37,12 @@ const ForwardMessageModal = ({ onClose, permalink, message }: ForwardMessageProp
 		mutationFn: async () => {
 			const optionalMessage = '';
 			const curMsg = await prependReplies(optionalMessage, [message]);
+			const sendPayload = {
+				roomId: rooms,
+				text: curMsg,
+			};
 
-			return Promise.all(
-				rooms.map(async (roomId) => {
-					const sendPayload = {
-						roomId,
-						text: curMsg,
-					};
-
-					await sendMessage(sendPayload);
-				}),
-			);
+			return sendMessage(sendPayload);
 		},
 		onSuccess: () => {
 			dispatchToastMessage({ type: 'success', message: t('Message_has_been_forwarded') });

packages/rest-typings/src/v1/chat.ts

@@ -697,16 +697,24 @@ const ChatGetDeletedMessagesSchema = {
 export const isChatGetDeletedMessagesProps = ajv.compile<ChatGetDeletedMessages>(ChatGetDeletedMessagesSchema);
 
 type ChatPostMessage =
-	| { roomId: string; text?: string; alias?: string; emoji?: string; avatar?: string; attachments?: MessageAttachment[] }
-	| { channel: string; text?: string; alias?: string; emoji?: string; avatar?: string; attachments?: MessageAttachment[] };
+	| { roomId: string | string[]; text?: string; alias?: string; emoji?: string; avatar?: string; attachments?: MessageAttachment[] }
+	| { channel: string | string[]; text?: string; alias?: string; emoji?: string; avatar?: string; attachments?: MessageAttachment[] };
 
 const ChatPostMessageSchema = {
 	oneOf: [
 		{
 			type: 'object',
 			properties: {
 				roomId: {
-					type: 'string',
+					oneOf: [
+						{ type: 'string' },
+						{
+							type: 'array',
+							items: {
+								type: 'string',
+							},
+						},
+					],
 				},
 				text: {
 					type: 'string',
@@ -739,7 +747,15 @@ const ChatPostMessageSchema = {
 			type: 'object',
 			properties: {
 				channel: {
-					type: 'string',
+					oneOf: [
+						{ type: 'string' },
+						{
+							type: 'array',
+							items: {
+								type: 'string',
+							},
+						},
+					],
 				},
 				text: {
 					type: 'string',