Add thread support to slash commands

package.json

@@ -56,6 +56,7 @@
   },
   "homepage": "https://github.com/RocketChat/Rocket.Chat.Apps-engine#readme",
   "devDependencies": {
+    "@types/node": "^12.7.12",
     "@types/adm-zip": "^0.4.31",
     "@types/lodash.clonedeep": "^4.5.3",
     "@types/nedb": "^1.8.5",

src/definition/accessors/IMessageBuilder.ts

@@ -19,6 +19,19 @@ export interface IMessageBuilder {
      */
     setData(message: IMessage): IMessageBuilder;
 
+    /**
+     * Sets the thread to which this message belongs, if any.
+     *
+     * @param threadId The id of the thread
+     */
+    setThreadId(threadId: string): IMessageBuilder;
+
+    /**
+     * Retrieves the thread to which this message belongs,
+     * if any.
+     */
+    getThreadId(): string;
+
     /**
      * Sets the room where this message should be sent to.
      *

src/definition/messages/IMessage.ts

@@ -6,6 +6,7 @@ import { IMessageReactions } from './IMessageReaction';
 
 export interface IMessage {
     id?: string;
+    threadId?: string;
     room: IRoom;
     sender: IUser;
     text?: string;

src/definition/slashcommands/SlashCommandContext.ts

@@ -6,7 +6,12 @@ import { IUser } from '../users';
  * executes a slash command.
  */
 export class SlashCommandContext {
-    constructor(private sender: IUser, private room: IRoom, private params: Array<string>) { }
+    constructor(
+        private sender: IUser,
+        private room: IRoom,
+        private params: Array<string>,
+        private threadId?: string,
+    ) { }
 
     /** The user who sent the command. */
     public getSender(): IUser {
@@ -22,4 +27,8 @@ export class SlashCommandContext {
     public getArguments(): Array<string> {
         return this.params;
     }
+
+    public getThreadId(): string | undefined {
+        return this.threadId;
+    }
 }

src/server/accessors/MessageBuilder.ts

@@ -20,6 +20,16 @@ export class MessageBuilder implements IMessageBuilder {
         return this;
     }
 
+    public setThreadId(threadId: string): IMessageBuilder {
+        this.msg.threadId = threadId;
+
+        return this;
+    }
+
+    public getThreadId(): string {
+        return this.msg.threadId;
+    }
+
     public setRoom(room: IRoom): IMessageBuilder {
         this.msg.room = room;
         return this;

src/server/managers/AppSlashCommandManager.ts

@@ -385,7 +385,7 @@ export class AppSlashCommandManager {
             room = new Room(context.getRoom(), this.manager);
         }
 
-        return new SlashCommandContext(context.getSender(), room, context.getArguments());
+        return new SlashCommandContext(context.getSender(), room, context.getArguments(), context.getThreadId());
     }
 
     /**

tests/server/accessors/MessageBuilder.spec.ts

@@ -21,6 +21,11 @@ export class MessageBuilderAccessorTestFixture {
 
         const msg: IMessage = {} as IMessage;
         const mb = new MessageBuilder(msg);
+
+        Expect(mb.setThreadId('a random thread id')).toBe(mb);
+        Expect(msg.threadId).toBe('a random thread id');
+        Expect(mb.getThreadId()).toBe('a random thread id');
+
         Expect(mb.setRoom(TestData.getRoom())).toBe(mb);
         Expect(msg.room).toEqual(TestData.getRoom());
         Expect(mb.getRoom()).toEqual(TestData.getRoom());