Timestamp fix for event emission

Author: GTFalcao

components/frontapp/sources/common/base.mjs

@@ -19,6 +19,9 @@ export default {
     _setLastTs(lastTs) {
       this.db.set("lastTs", lastTs);
     },
+    _getItemTs(item) {
+      return item.created_at * 1000;
+    },
     async startEvent(maxResults = 0, filterFn = null) {
       const lastTs = this._getLastTs();
       const items = this.frontapp.paginate({

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

@@ -23,18 +23,18 @@ export default {
     _getEmit(conversation) {
       return {
         id: conversation.id,
-        summary: `New conversation created: ${conversation.subject}`,
+        summary: `New conversation: ${conversation.subject}`,
         ts: conversation.created_at * 1000,
       };
     },
   },
   hooks: {
     async deploy() {
-      await this.startEvent(25, (item, lastTs) => item.created_at > lastTs);
+      await this.startEvent(25, (item, lastTs) => this._getItemTs(item) > lastTs);
     },
   },
   async run() {
-    await this.startEvent(0, (item, lastTs) => item.created_at > lastTs);
+    await this.startEvent(0, (item, lastTs) => this._getItemTs(item) > lastTs);
   },
   sampleEmit,
 };

components/frontapp/sources/new-message-template-created/new-message-template-created.mjs

@@ -23,18 +23,18 @@ export default {
     _getEmit(template) {
       return {
         id: template.id,
-        summary: `New message template created: ${template.name}`,
+        summary: `New template: ${template.name}`,
         ts: template.created_at * 1000,
       };
     },
   },
   hooks: {
     async deploy() {
-      await this.startEvent(25, (item, lastTs) => item.created_at > lastTs);
+      await this.startEvent(25, (item, lastTs) => this._getItemTs(item) > lastTs);
     },
   },
   async run() {
-    await this.startEvent(0, (item, lastTs) => item.created_at > lastTs);
+    await this.startEvent(0, (item, lastTs) => this._getItemTs(item) > lastTs);
   },
   sampleEmit,
 };