Telegram Bot - New Message Updates (Instant) - Add optional Chat ID prop

components/telegram_bot_api/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@pipedream/telegram_bot_api",
-  "version": "0.3.11",
+  "version": "0.3.12",
   "description": "Pipedream Telegram_bot_api Components",
   "main": "telegram_bot_api.app.mjs",
   "keywords": [
@@ -10,7 +10,7 @@
   "homepage": "https://pipedream.com/apps/telegram_bot_api",
   "author": "Pipedream <[email protected]> (https://pipedream.com/)",
   "dependencies": {
-    "@pipedream/platform": "^0.9.0",
+    "@pipedream/platform": "^3.0.3",
     "node-telegram-bot-api": "^0.54.0",
     "uuid": "^8.3.2"
   },

components/telegram_bot_api/sources/message-updates/message-updates.mjs

@@ -6,11 +6,37 @@ export default {
   key: "telegram_bot_api-message-updates",
   name: "New Message Updates (Instant)",
   description: "Emit new event each time a Telegram message is created or updated.",
-  version: "0.1.5",
+  version: "0.1.6",
   type: "source",
   dedupe: "unique",
+  props: {
+    ...base.props,
+    chatId: {
+      propDefinition: [
+        base.props.telegramBotApi,
+        "chatId",
+      ],
+      optional: true,
+    },
+  },
+  hooks: {
+    ...base.hooks,
+    async deploy() {
+      if (this.chatId) {
+        const { id } = await this.telegramBotApi.sdk().getChat(this.chatId);
+        this._setChatId(id);
+      }
+      await base.hooks.deploy.call(this);
+    },
+  },
   methods: {
     ...base.methods,
+    _getChatId() {
+      return this.db.get("chatId");
+    },
+    _setChatId(chatId) {
+      this.db.set("chatId", chatId);
+    },
     getMeta(event, message) {
       return {
         id: event.update_id,
@@ -26,6 +52,12 @@ export default {
     },
     processEvent(event) {
       const message = event.edited_message ?? event.message;
+      if (this.chatId) {
+        const chatId = this._getChatId();
+        if (chatId && chatId != message?.chat?.id) {
+          return;
+        }
+      }
       this.$emit(event, this.getMeta(event, message));
     },
   },