Add addToChannel prop to message-based triggers

and remove historical messages for new-keyword-mention source since the
search:read scope is no longer requested.

Author: js07

components/slack_v2_test/slack_v2_test.app.mjs

@@ -465,6 +465,13 @@ export default {
       default: 1,
       optional: true,
     },
+    addToChannel: {
+      type: "boolean",
+      label: "Add app to channel automatically?",
+      description: "If `true`, the app will be added to the specified channel(s) automatically. If `false`, you must add the app to the channel manually. Defaults to `true`.",
+      default: true,
+      optional: false,
+    },
   },
   methods: {
     getChannelLabel(resource) {

components/slack_v2_test/sources/common/base.mjs

@@ -160,6 +160,28 @@ export default {
         },
       );
     },
+    async getBotInfo() {
+      return await this.slack.authTest({
+        as_bot: true,
+      });
+    },
+    async addAppToChannels(channelIds = []) {
+      const { user_id: botUserId } = await this.getBotInfo();
+      // XXX: Don't try to add the app to DM or group DM channels,
+      // it will result in an error: method_not_supported_for_channel_type
+      for (const channel of channelIds) {
+        try {
+          await this.slack.inviteToConversation({
+            channel,
+            users: botUserId,
+          });
+        } catch (error) {
+          if (!error.includes("already_in_channel")) {
+            throw error;
+          }
+        }
+      }
+    },
     processEvent(event) {
       return event;
     },

components/slack_v2_test/sources/new-keyword-mention/new-keyword-mention.mjs

@@ -38,6 +38,12 @@ export default {
         "keyword",
       ],
     },
+    addToChannel: {
+      propDefinition: [
+        common.props.slack,
+        "addToChannel",
+      ],
+    },
     ignoreBot: {
       propDefinition: [
         common.props.slack,
@@ -47,43 +53,15 @@ export default {
   },
   hooks: {
     ...common.hooks,
-    async deploy() {
-      // emit historical events
-      const messages = await this.getMatches({
-        query: this.keyword,
-        sort: "timestamp",
-      });
-      const filteredMessages = this.conversations?.length > 0
-        ? messages.filter((message) => this.conversations.includes(message.channel.id))
-        : messages;
-      await this.emitHistoricalEvents(filteredMessages.slice(-25).reverse());
+    async activate() {
+      if (this.addToChannel && this.conversations?.length) {
+        if (this.conversations[0] === "message") return;
+        await this.addAppToChannels(this.conversations);
+      }
     },
   },
   methods: {
     ...common.methods,
-    async getMatches(params) {
-      return (await this.slack.searchMessages(params)).messages.matches || [];
-    },
-    async emitHistoricalEvents(messages) {
-      for (const message of messages) {
-        const event = await this.processEvent({
-          ...message,
-          subtype: message.subtype || constants.SUBTYPE.PD_HISTORY_MESSAGE,
-        });
-        if (event) {
-          if (!event.client_msg_id) {
-            event.pipedream_msg_id = `pd_${Date.now()}_${Math.random().toString(36)
-              .substr(2, 10)}`;
-          }
-
-          this.$emit(event, {
-            id: event.client_msg_id || event.pipedream_msg_id,
-            summary: this.getSummary(event),
-            ts: event.event_ts || Date.now(),
-          });
-        }
-      }
-    },
     getSummary() {
       return "New keyword mention received";
     },

components/slack_v2_test/sources/new-message-in-channels/new-message-in-channels.mjs

@@ -32,6 +32,12 @@ export default {
         ];
       },
     },
+    addToChannel: {
+      propDefinition: [
+        common.props.slack,
+        "addToChannel",
+      ],
+    },
     resolveNames: {
       propDefinition: [
         common.props.slack,
@@ -51,6 +57,14 @@ export default {
       optional: true,
     },
   },
+  hooks: {
+    async activate() {
+      if (this.addToChannel && this.conversations?.length) {
+        if (this.conversations[0] === "message") return;
+        await this.addAppToChannels(this.conversations);
+      }
+    },
+  },
   methods: {
     ...common.methods,
     getSummary() {

components/slack_v2_test/sources/new-user-mention/new-user-mention.mjs

@@ -52,6 +52,14 @@ export default {
       ],
     },
   },
+  hooks: {
+    async activate() {
+      if (this.addToChannel && this.conversations?.length) {
+        if (this.conversations[0] === "message") return;
+        await this.addAppToChannels(this.conversations);
+      }
+    },
+  },
   methods: {
     ...common.methods,
     getSummary() {