Updating sources to timestamp-based

Author: GTFalcao

components/frontapp/sources/common/base.mjs

@@ -19,7 +19,7 @@ export default {
     _setLastTs(lastTs) {
       this.db.set("lastTs", lastTs);
     },
-    async startEvent(maxResults = 0) {
+    async startEvent(maxResults = 0, filterFn = null) {
       const lastTs = this._getLastTs();
       const items = this.frontapp.paginate({
         fn: this._getFunction(),
@@ -30,10 +30,18 @@ export default {
       let responseArray = [];
 
       for await (const item of items) {
-        responseArray.push(item);
+        // If filterFn is provided, use it to filter items, otherwise add all items
+        if (!filterFn || filterFn(item, lastTs)) {
+          responseArray.push(item);
+        }
       }
 
-      if (responseArray.length) this._setLastTs(responseArray[0].emitted_at);
+      if (responseArray.length) {
+        if (filterFn) {
+          responseArray.sort((a, b) => b.created_at - a.created_at);
+        }
+        this._setLastTs(responseArray[0].emitted_at);
+      }
 
       for (const item of responseArray.reverse()) {
         this.$emit(

components/frontapp/sources/common/polling-ids.mjs

@@ -1,4 +1,4 @@
-import common from "../common/polling-ids.mjs";
+import common from "../common/base.mjs";
 import sampleEmit from "./test-event.mjs";
 
 export default {
@@ -11,26 +11,22 @@ export default {
   dedupe: "unique",
   methods: {
     ...common.methods,
-    generateMeta(conversation) {
+    _getFunction() {
+      return this.frontapp.listConversations;
+    },
+    _getParams() {
+      return {
+        sort_by: "date",
+        sort_order: "desc",
+      };
+    },
+    _getEmit(conversation) {
       return {
         id: conversation.id,
         summary: `New conversation created: ${conversation.subject}`,
         ts: conversation.created_at * 1000,
       };
     },
-    getItemId(conversation) {
-      return conversation.id;
-    },
-    async getItems() {
-      const response = await this.frontapp.listConversations({
-        params: {
-          sort_by: "date",
-          sort_order: "desc",
-        },
-      });
-
-      return response._results || [];
-    },
   },
   sampleEmit,
 };

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

@@ -1,4 +1,4 @@
-import common from "../common/polling-ids.mjs";
+import common from "../common/base.mjs";
 import sampleEmit from "./test-event.mjs";
 
 export default {
@@ -11,26 +11,22 @@ export default {
   dedupe: "unique",
   methods: {
     ...common.methods,
-    generateMeta(template) {
+    _getFunction() {
+      return this.frontapp.listMessageTemplates;
+    },
+    _getParams() {
+      return {
+        sort_by: "created_at",
+        sort_order: "desc",
+      };
+    },
+    _getEmit(template) {
       return {
         id: template.id,
         summary: `New message template created: ${template.name}`,
         ts: template.created_at * 1000,
       };
     },
-    getItemId(template) {
-      return template.id;
-    },
-    async getItems() {
-      const response = await this.frontapp.listMessageTemplates({
-        params: {
-          sort_by: "created_at",
-          sort_order: "desc",
-        },
-      });
-
-      return response._results || [];
-    },
   },
   sampleEmit,
 };