feat(slack): add includeBotMessages option for interacting with bot_message

packages/bottender/src/slack/SlackBot.ts

@@ -21,19 +21,22 @@ export default class SlackBot extends Bot<
     verificationToken,
     origin,
     skipLegacyProfile,
+    includeBotMessages,
   }: {
     accessToken: string;
     sessionStore?: SessionStore;
     sync?: boolean;
     verificationToken?: string;
     origin?: string;
-    skipLegacyProfile?: boolean | null;
+    skipLegacyProfile?: boolean;
+    includeBotMessages?: boolean;
   }) {
     const connector = new SlackConnector({
       accessToken,
       verificationToken,
       origin,
       skipLegacyProfile,
+      includeBotMessages,
     });
     super({ connector, sessionStore, sync });
     this._accessToken = accessToken;

packages/bottender/src/slack/SlackConnector.ts

@@ -38,8 +38,9 @@ type EventsAPIBody = {
 export type SlackRequestBody = EventsAPIBody | { payload: string };
 
 type CommonConstructorOptions = {
-  skipLegacyProfile?: boolean | null;
+  skipLegacyProfile?: boolean;
   verificationToken?: string;
+  includeBotMessages?: boolean;
 };
 
 type ConstructorOptionsWithoutClient = {
@@ -63,8 +64,14 @@ export default class SlackConnector
 
   _skipLegacyProfile: boolean;
 
+  _includeBotMessages: boolean;
+
   constructor(options: ConstructorOptions) {
-    const { verificationToken, skipLegacyProfile } = options;
+    const {
+      verificationToken,
+      skipLegacyProfile,
+      includeBotMessages,
+    } = options;
     if ('client' in options) {
       this._client = options.client;
     } else {
@@ -83,15 +90,17 @@ export default class SlackConnector
 
     this._verificationToken = verificationToken || '';
 
-    this._skipLegacyProfile =
-      typeof skipLegacyProfile === 'boolean' ? skipLegacyProfile : true;
-
     if (!this._verificationToken) {
       warning(
         false,
         '`verificationToken` is not set. Will bypass Slack event verification.\nPass in `verificationToken` to perform Slack event verification.'
       );
     }
+
+    this._skipLegacyProfile =
+      typeof skipLegacyProfile === 'boolean' ? skipLegacyProfile : true;
+
+    this._includeBotMessages = includeBotMessages || false;
   }
 
   _getRawEventFromRequest(body: SlackRequestBody): SlackRawEvent {
@@ -304,8 +313,8 @@ export default class SlackConnector
   mapRequestToEvents(body: SlackRequestBody): SlackEvent[] {
     const rawEvent = this._getRawEventFromRequest(body);
 
-    if (this._isBotEventRequest(body)) {
-      return []; // FIXME
+    if (!this._includeBotMessages && this._isBotEventRequest(body)) {
+      return [];
     }
 
     return [new SlackEvent(rawEvent)];

packages/bottender/src/slack/SlackEvent.ts

@@ -278,6 +278,14 @@ export default class SlackEvent implements Event<SlackRawEvent> {
     }
     return null;
   }
+
+  /**
+   * Determine if the event is a bot message event.
+   *
+   */
+  get isBotMessage(): boolean {
+    return (this._rawEvent as any).subtype === 'bot_message';
+  }
 }
 
 // https://api.slack.com/events

packages/bottender/src/slack/__tests__/SlackConnector.spec.ts

@@ -150,6 +150,7 @@ const RtmMessage = {
 function setup({
   verificationToken = 'xxxxxxxxxxxxxxxxxxxxxxxxxxx',
   skipLegacyProfile,
+  includeBotMessages,
 } = {}) {
   const mockSlackOAuthClient = {
     getUserInfo: jest.fn(),
@@ -164,6 +165,7 @@ function setup({
       accessToken,
       verificationToken,
       skipLegacyProfile,
+      includeBotMessages,
     }),
     mockSlackOAuthClient,
   };
@@ -396,6 +398,23 @@ describe('#mapRequestToEvents', () => {
     expect(events).toHaveLength(1);
     expect(events[0]).toBeInstanceOf(SlackEvent);
   });
+
+  it('should not include bot message by default', () => {
+    const { connector } = setup();
+    const events = connector.mapRequestToEvents(botRequest.body);
+
+    expect(events).toHaveLength(0);
+  });
+
+  it('should include bot message when includeBotMessages is true', () => {
+    const { connector } = setup({
+      includeBotMessages: true,
+    });
+    const events = connector.mapRequestToEvents(botRequest.body);
+
+    expect(events).toHaveLength(1);
+    expect(events[0]).toBeInstanceOf(SlackEvent);
+  });
 });
 
 describe('#createContext', () => {

packages/bottender/src/slack/__tests__/SlackEvent.spec.ts

@@ -272,6 +272,16 @@ const message = {
   ts: '1355517523.000005',
 };
 
+const botMessage = {
+  type: 'message',
+  subtype: 'bot_message',
+  ts: '1358877455.000010',
+  text: 'Pushing is the answer',
+  botId: 'BB12033',
+  username: 'github',
+  icons: {},
+};
+
 const channelsMessage = {
   type: 'message',
   channel: 'C2147483705',
@@ -894,3 +904,8 @@ describe('interactive message event', () => {
     expect(new SlackEvent(message).action).toEqual(null);
   });
 });
+
+it('#isBotMessage', () => {
+  expect(new SlackEvent(message).isBotMessage).toEqual(false);
+  expect(new SlackEvent(botMessage).isBotMessage).toEqual(true);
+});