Added support for thread_broadcast subtype

RocketChat · Apr 3, 2020 · 2e34181 · 2e34181
1 parent 7234412
commit 2e34181
Showing 1 changed file with 34 additions and 2 deletions.
diff --git a/app/importer-slack/server/importer.js b/app/importer-slack/server/importer.js
@@ -241,7 +241,7 @@ export class SlackImporter extends Base {
 		});
 	}
 
-	processMessageSubType(message, room, msgDataDefaults, missedTypes) {
+	processMessageSubType(message, room, msgDataDefaults, missedTypes, slackChannel) {
 		const ignoreTypes = { bot_add: true, file_comment: true, file_mention: true };
 
 		let rocketUser = this.getRocketUserFromUserId(message.user);
@@ -349,6 +349,38 @@ export class SlackImporter extends Base {
 					this.uploadFile(details, message.file.url_private_download, rocketUser, room, new Date(parseInt(message.ts.split('.')[0]) * 1000));
 				}
 				break;
+			case 'thread_broadcast':
+				const user = this.getRocketUserFromUserId(message.user);
+				const msgObj = {
+					...msgDataDefaults,
+					msg: this.convertSlackMessageToRocketChat(message.text),
+					rid: room._id,
+					attachments: this.convertMessageAttachments(message.attachments),
+					u: {
+						_id: user._id,
+						username: user.username,
+					},
+				};
+
+				msgObj.tmid = `slack-${ slackChannel.id }-${ message.thread_ts.replace(/\./g, '-') }`;
+
+				if (message.edited) {
+					msgObj.editedAt = new Date(parseInt(message.edited.ts.split('.')[0]) * 1000);
+					const editedBy = this.getRocketUserFromUserId(message.edited.user);
+					if (editedBy) {
+						msgObj.editedBy = {
+							_id: editedBy._id,
+							username: editedBy.username,
+						};
+					}
+				}
+
+				try {
+					insertMessage(this.getRocketUserFromUserId(message.user), msgObj, room, this._anyExistingSlackMessage);
+				} catch (e) {
+					this.logger.warn(`Failed to import the message: ${ msgDataDefaults._id }`);
+				}
+				break;
 			default:
 				if (!missedTypes[message.subtype] && !ignoreTypes[message.subtype]) {
 					missedTypes[message.subtype] = message;
@@ -407,7 +439,7 @@ export class SlackImporter extends Base {
 			}
 
 			if (message.subtype) {
-				this.processMessageSubType(message, room, msgDataDefaults, missedTypes);
+				this.processMessageSubType(message, room, msgDataDefaults, missedTypes, slackChannel);
 			} else {
 				const user = this.getRocketUserFromUserId(message.user);
 				if (user) {