Merge branch 'master' into configure-filesync-for-zohocrm

Author: js07

components/akeneo/actions/create-a-new-product-media-file/create-a-new-product-media-file.mjs

@@ -7,7 +7,7 @@ import FormData from "form-data";
 export default {
   type: "action",
   key: "akeneo-create-a-new-product-media-file",
-  version: "0.1.0",
+  version: "0.1.1",
   name: "Create A New Product Media File",
   description: "Allows you to create a new media file and associate it to an attribute value of a given product or product model. [See the docs](https://api.akeneo.com/api-reference.html#post_media_files)",
   props: {

components/akeneo/akeneo.app.mjs

@@ -51,7 +51,7 @@ export default {
           params: {
             limit: PAGE_SIZE,
             page,
-            search: {
+            search: JSON.stringify({
               type: [
                 {
                   operator: "IN",
@@ -60,7 +60,7 @@ export default {
                   ],
                 },
               ],
-            },
+            }),
           },
         });
         return resp?._embedded?.items?.map((attribute) => attribute.code) || [];

components/akeneo/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@pipedream/akeneo",
-  "version": "0.1.0",
+  "version": "0.1.1",
   "description": "Pipedream Akeneo Components",
   "main": "akeneo.app.mjs",
   "keywords": [

components/avosms/avosms.app.mjs

@@ -8,4 +8,4 @@ export default {
       console.log(Object.keys(this.$auth));
     },
   },
-};
+};

components/tettra/app/tettra.app.ts renamed to components/chattermill/chattermill.app.mjs

@@ -1,13 +1,11 @@
-import { defineApp } from "@pipedream/types";
-
-export default defineApp({
+export default {
   type: "app",
-  app: "tettra",
+  app: "chattermill",
   propDefinitions: {},
   methods: {
     // this.$auth contains connected account data
     authKeys() {
       console.log(Object.keys(this.$auth));
     },
   },
-});
+};

components/chattermill/package.json

@@ -0,0 +1,15 @@
+{
+  "name": "@pipedream/chattermill",
+  "version": "0.0.1",
+  "description": "Pipedream Chattermill Components",
+  "main": "chattermill.app.mjs",
+  "keywords": [
+    "pipedream",
+    "chattermill"
+  ],
+  "homepage": "https://pipedream.com/apps/chattermill",
+  "author": "Pipedream <[email protected]> (https://pipedream.com/)",
+  "publishConfig": {
+    "access": "public"
+  }
+}

components/deepsource/deepsource.app.mjs

@@ -8,4 +8,4 @@ export default {
       console.log(Object.keys(this.$auth));
     },
   },
-};
+};

components/discord_bot/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@pipedream/discord_bot",
-  "version": "0.6.1",
+  "version": "0.6.2",
   "description": "Pipedream Discord_bot Components",
   "main": "discord_bot.app.mjs",
   "keywords": [

components/discord_bot/sources/common.mjs renamed to components/discord_bot/sources/common/common.mjs

@@ -1,5 +1,5 @@
-import common from "../common.mjs";
-import constants from "../common/constants.mjs";
+import common from "../../common.mjs";
+import constants from "../../common/constants.mjs";
 
 export default {
   ...common,
@@ -17,5 +17,16 @@ export default {
     _setLastMemberID(memberID) {
       this.db.set(constants.LAST_MEMBER_ID, memberID);
     },
+    _getBotId() {
+      return this.db.get("botId");
+    },
+    _setBotId(botId) {
+      this.db.set("botId", botId);
+    },
+    getBotProfile() {
+      return this.discord._makeRequest({
+        path: "/users/@me",
+      });
+    },
   },
 };

components/discord_bot/sources/new-forum-thread-message/new-forum-thread-message.mjs

@@ -1,7 +1,7 @@
 import { DEFAULT_POLLING_SOURCE_TIMER_INTERVAL } from "@pipedream/platform";
 import maxBy from "lodash.maxby";
 import constants from "../../common/constants.mjs";
-import common from "../common.mjs";
+import common from "../common/common.mjs";
 import sampleEmit from "./test-event.mjs";
 
 export default {
@@ -10,7 +10,7 @@ export default {
   name: "New Forum Thread Message",
   description: "Emit new event for each forum thread message posted. Note that your bot must have the `MESSAGE_CONTENT` privilege intent to see the message content. [See the documentation](https://discord.com/developers/docs/topics/gateway#message-content-intent).",
   type: "source",
-  version: "0.0.4",
+  version: "0.0.5",
   dedupe: "unique", // Dedupe events based on the Discord message ID
   props: {
     ...common.props,
@@ -35,6 +35,20 @@ export default {
       label: "Forum Id",
       description: "Select the forum you want to watch.",
     },
+    ignoreBotMessages: {
+      type: "boolean",
+      label: "Ignore Bot Messages",
+      description: "Set to `true` to only emit messages NOT from the configured Discord bot",
+      optional: true,
+    },
+  },
+  hooks: {
+    async deploy() {
+      if (this.ignoreBotMessages) {
+        const { id } = await this.getBotProfile();
+        this._setBotId(id);
+      }
+    },
   },
   methods: {
     ...common.methods,
@@ -47,6 +61,9 @@ export default {
   async run({ $ }) {
     // We store a cursor to the last message ID
     let lastMessageIDs = this._getLastMessageIDs();
+    const botId = this.ignoreBotMessages
+      ? this._getBotId()
+      : null;
 
     const { threads } = await this.discord.listThreads({
       $,
@@ -113,6 +130,10 @@ export default {
         continue;
       }
 
+      if (botId) {
+        messages = messages.filter((message) => message.author.id !== botId);
+      }
+
       console.log(`${messages.length} new messages in thread ${channelId}`);
 
       messages = await Promise.all(messages.map(async (message) => ({