New Components - chatfly

components/chatfly/actions/send-message/send-message.mjs

@@ -0,0 +1,45 @@
+import chatfly from "../../chatfly.app.mjs";
+
+export default {
+  key: "chatfly-send-message",
+  name: "Send Message",
+  description: "Dispatches a text message to a specified group or individual in Chatfly.",
+  version: "0.0.1",
+  type: "action",
+  props: {
+    chatfly,
+    botId: {
+      propDefinition: [
+        chatfly,
+        "botId",
+      ],
+    },
+    sessionId: {
+      propDefinition: [
+        chatfly,
+        "sessionId",
+        ({ botId }) => ({
+          botId,
+        }),
+      ],
+    },
+    message: {
+      propDefinition: [
+        chatfly,
+        "message",
+      ],
+    },
+  },
+  async run({ $ }) {
+    const response = await this.chatfly.dispatchMessage({
+      $,
+      data: {
+        bot_id: this.botId,
+        message: this.message,
+        session_id: this.sessionId,
+      },
+    });
+    $.export("$summary", "Message dispatched successfully");
+    return response;
+  },
+};

components/chatfly/chatfly.app.mjs

@@ -1,11 +1,86 @@
+import { axios } from "@pipedream/platform";
+import { prepareSessionLabel } from "./common/utils.mjs";
+
 export default {
   type: "app",
   app: "chatfly",
-  propDefinitions: {},
+  propDefinitions: {
+    botId: {
+      type: "string",
+      label: "Bot ID",
+      description: "The ID of the bot to send the message to.",
+      async options() {
+        const data = await this.listBots();
+
+        return data.map(({
+          id: value, bot_name: label,
+        }) => ({
+          label,
+          value,
+        }));
+      },
+    },
+    message: {
+      type: "string",
+      label: "Message",
+      description: "The message to send.",
+    },
+    sessionId: {
+      type: "string",
+      label: "Session ID",
+      description: "The session ID for the message. To initiate a new session, use a unique string in a Custom Expression, for example: `8g12h`",
+      async options({ botId }) {
+        const data = await this.listSessions({
+          params: {
+            bot_id: botId,
+          },
+        });
+
+        return data.map(({
+          session_id: value, chat_history_response,
+        }) => ({
+          label: prepareSessionLabel(chat_history_response),
+          value,
+        }));
+      },
+    },
+  },
   methods: {
-    // this.$auth contains connected account data
-    authKeys() {
-      console.log(Object.keys(this.$auth));
+    _baseUrl() {
+      return "https://backend.chatfly.co/api";
+    },
+    _headers() {
+      return {
+        "CHATFLY-API-KEY": `${this.$auth.api_key}`,
+      };
+    },
+    _makeRequest({
+      $ = this, path = "/", ...opts
+    }) {
+      return axios($, {
+        url: this._baseUrl() + path,
+        headers: this._headers(),
+        ...opts,
+      });
+    },
+    dispatchMessage(opts = {}) {
+      return this._makeRequest({
+        method: "POST",
+        path: "/chat/get-streaming-response",
+        ...opts,
+      });
+    },
+    listBots(opts = {}) {
+      return this._makeRequest({
+        path: "/bot",
+        ...opts,
+      });
+    },
+    listSessions(opts = {}) {
+      return this._makeRequest({
+        path: "/chat/history",
+        ...opts,
+      });
     },
   },
-};
+};

components/chatfly/common/utils.mjs

@@ -0,0 +1,5 @@
+export const prepareSessionLabel = (messages) => {
+  return `${messages[messages.length - 1].content.substring(0, 60)} ${(messages[messages.length - 1].content.length > 60)
+    ? "..."
+    : ""}`;
+};

components/chatfly/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@pipedream/chatfly",
-  "version": "0.0.1",
+  "version": "0.1.0",
   "description": "Pipedream ChatFly Components",
   "main": "chatfly.app.mjs",
   "keywords": [
@@ -11,5 +11,8 @@
   "author": "Pipedream <support@pipedream.com> (https://pipedream.com/)",
   "publishConfig": {
     "access": "public"
+  },
+  "dependencies": {
+    "@pipedream/platform": "^1.6.5"
   }
-}
+}