updates

Author: michelle0927

components/frontapp/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@pipedream/frontapp",
-  "version": "0.8.1",
+  "version": "0.8.2",
   "description": "Pipedream Frontapp Components",
   "main": "frontapp.app.mjs",
   "keywords": [

components/frontapp/sources/common/base.mjs

@@ -45,13 +45,17 @@ export default {
         if (filterFn) {
           responseArray.sort((a, b) => b.created_at - a.created_at);
         }
-        this._setLastTs(this._getEmit(responseArray[0]).ts);
+        this._setLastTs(this._getEmit(responseArray[0])?.ts ?? 0);
       }
 
       for (const item of responseArray.reverse()) {
+        const emit = this._getEmit(item);
+        if (!emit) {
+          continue;
+        }
         this.$emit(
           item,
-          this._getEmit(item),
+          emit,
         );
       }
     },

components/frontapp/sources/new-conversation-tag/new-conversation-tag.mjs

@@ -6,7 +6,7 @@ export default {
   key: "frontapp-new-conversation-tag",
   name: "New Conversation Tag",
   description: "Emit new event when a conversation is tagged with a specific tag or any tag. [See the documentation](https://dev.frontapp.com/reference/events)",
-  version: "0.0.5",
+  version: "0.0.6",
   type: "source",
   dedupe: "unique",
   props: {
@@ -24,9 +24,8 @@ export default {
     _getFunction() {
       return this.frontapp.listEvents;
     },
-    _getParams(lastTs) {
+    _getParams() {
       return {
-        "q[after]": lastTs,
         "q[types]": [
           "tag",
         ],
@@ -39,11 +38,19 @@ export default {
       if (item.type === "tag" && tagIdsArray.includes(item.target?.data?.id)) {
         return {
           id: item.id,
-          summary: `New conversation with id: "${item.id}" was tagged as '${item.target?.data?.name}'!`,
-          ts: Date.parse(item.created_at),
+          summary: `Conversation with ID: "${item.id}" was tagged as '${item.target?.data?.name}'!`,
+          ts: (Math.floor(item.emitted_at / 1000)) * 1000,
         };
       }
     },
   },
+  hooks: {
+    async deploy() {
+      await this.startEvent(10, (item, lastTs) => item.emitted_at > lastTs);
+    },
+  },
+  async run() {
+    await this.startEvent(0, (item, lastTs) => item.emitted_at > lastTs);
+  },
   sampleEmit,
 };