new send-message actions

Author: michelle0927

components/slack/actions/common/send-message.mjs

@@ -170,6 +170,9 @@ export default {
         },
       };
     },
+    getChannelId() {
+      return this.conversation ?? this.reply_channel;
+    },
   },
   async run({ $ }) {
     let blocks = this.blocks;
@@ -207,7 +210,7 @@ export default {
 
     const obj = {
       text: this.text,
-      channel: this.conversation ?? this.reply_channel,
+      channel: await this.getChannelId(),
       attachments: this.attachments,
       unfurl_links: this.unfurl_links,
       unfurl_media: this.unfurl_media,

components/slack/actions/send-message-to-channel/send-message-to-channel.mjs

@@ -0,0 +1,40 @@
+import common from "../common/send-message.mjs";
+import constants from "../../common/constants.mjs";
+
+export default {
+  ...common,
+  key: "slack-send-message-to-channel",
+  name: "Send Message to Channel",
+  description: "Send a message to a public or private channel. [See the documentation](https://api.slack.com/methods/chat.postMessage)",
+  version: "0.0.1",
+  type: "action",
+  props: {
+    slack: common.props.slack,
+    conversation: {
+      propDefinition: [
+        common.props.slack,
+        "conversation",
+        () => ({
+          types: [
+            constants.CHANNEL_TYPE.PUBLIC,
+            constants.CHANNEL_TYPE.PRIVATE,
+          ],
+        }),
+      ],
+      description: "Select a public or private channel",
+    },
+    text: {
+      propDefinition: [
+        common.props.slack,
+        "text",
+      ],
+    },
+    mrkdwn: {
+      propDefinition: [
+        common.props.slack,
+        "mrkdwn",
+      ],
+    },
+    ...common.props,
+  },
+};

components/slack/actions/send-message-to-user-or-group/send-message-to-user-or-group.mjs

@@ -0,0 +1,73 @@
+import common from "../common/send-message.mjs";
+import constants from "../../common/constants.mjs";
+import { ConfigurationError } from "@pipedream/platform";
+
+export default {
+  ...common,
+  key: "slack-send-message-to-user-or-group",
+  name: "Send Message to User or Group",
+  description: "Send a message to a user or group. [See the documentation](https://api.slack.com/methods/chat.postMessage)",
+  version: "0.0.1",
+  type: "action",
+  props: {
+    slack: common.props.slack,
+    users: {
+      propDefinition: [
+        common.props.slack,
+        "user",
+      ],
+      type: "string[]",
+      label: "Users",
+      description: "Select the user(s) to message",
+      optional: true,
+    },
+    conversation: {
+      propDefinition: [
+        common.props.slack,
+        "conversation",
+        () => ({
+          types: [
+            constants.CHANNEL_TYPE.MPIM,
+          ],
+        }),
+      ],
+      description: "Select the group to message",
+      optional: true,
+    },
+    text: {
+      propDefinition: [
+        common.props.slack,
+        "text",
+      ],
+    },
+    mrkdwn: {
+      propDefinition: [
+        common.props.slack,
+        "mrkdwn",
+      ],
+    },
+    ...common.props,
+  },
+  methods: {
+    ...common.methods,
+    openConversation(args = {}) {
+      return this.slack.makeRequest({
+        method: "conversations.open",
+        ...args,
+      });
+    },
+    async getChannelId() {
+      if (!this.conversation && !this.users?.length) {
+        throw new ConfigurationError("Must select a group or user(s) to message");
+      }
+
+      if (this.conversation) {
+        return this.conversation;
+      }
+      const { channel: { id } } = await this.openConversation({
+        users: this.users.join(),
+      });
+      return id;
+    },
+  },
+};

components/slack/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@pipedream/slack",
-  "version": "0.7.0",
+  "version": "0.7.1",
   "description": "Pipedream Slack Components",
   "main": "slack.app.mjs",
   "keywords": [

components/slack/slack.app.mjs

@@ -119,7 +119,7 @@ export default {
           }
         }
         const [
-          userNames,
+          userNames = await this.userNames(),
           conversationsResp,
         ] = await Promise.all([
           userNamesOrPromise,