Intercom - new-conversation-rating-added source

components/intercom/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@pipedream/intercom",
-  "version": "0.3.9",
+  "version": "0.4.0",
   "description": "Pipedream Intercom Components",
   "main": "intercom.app.mjs",
   "keywords": [
@@ -14,7 +14,7 @@
     "access": "public"
   },
   "dependencies": {
-    "@pipedream/platform": "^1.2.0",
+    "@pipedream/platform": "^3.0.3",
     "crypto": "^1.0.1"
   }
 }

components/intercom/sources/common.mjs → components/intercom/sources/common/common.mjs

@@ -1,4 +1,4 @@
-import intercom from "../intercom.app.mjs";
+import intercom from "../../intercom.app.mjs";
 import { DEFAULT_POLLING_SOURCE_TIMER_INTERVAL } from "@pipedream/platform";
 
 export default {

components/intercom/sources/conversation-closed/conversation-closed.mjs

@@ -1,11 +1,11 @@
-import common from "../common.mjs";
+import common from "../common/common.mjs";
 
 export default {
   ...common,
   key: "intercom-conversation-closed",
   name: "New Closed Conversation",
   description: "Emit new event each time a conversation is closed.",
-  version: "0.0.4",
+  version: "0.0.5",
   type: "source",
   dedupe: "unique",
   methods: {

components/intercom/sources/lead-added-email/lead-added-email.mjs

@@ -1,11 +1,11 @@
-import common from "../common.mjs";
+import common from "../common/common.mjs";
 
 export default {
   ...common,
   key: "intercom-lead-added-email",
   name: "Lead Added Email",
   description: "Emit new event each time a lead adds their email address.",
-  version: "0.0.4",
+  version: "0.0.5",
   type: "source",
   dedupe: "unique",
   methods: {

components/intercom/sources/new-admin-reply/new-admin-reply.mjs

@@ -1,11 +1,11 @@
-import common from "../common.mjs";
+import common from "../common/common.mjs";
 
 export default {
   ...common,
   key: "intercom-new-admin-reply",
   name: "New Reply From Admin",
   description: "Emit new event each time an admin replies to a conversation.",
-  version: "0.0.4",
+  version: "0.0.5",
   type: "source",
   dedupe: "unique",
   methods: {

components/intercom/sources/new-company/new-company.mjs

@@ -1,11 +1,11 @@
-import common from "../common.mjs";
+import common from "../common/common.mjs";
 
 export default {
   ...common,
   key: "intercom-new-company",
   name: "New Companies",
   description: "Emit new event each time a new company is added.",
-  version: "0.0.4",
+  version: "0.0.5",
   type: "source",
   dedupe: "unique",
   methods: {

components/intercom/sources/new-conversation-rating-added/new-conversation-rating-added.mjs

@@ -0,0 +1,43 @@
+import common from "../common/common.mjs";
+
+export default {
+  ...common,
+  key: "intercom-new-conversation-rating-added",
+  name: "New Conversation Rating Added",
+  description: "Emit new event each time a new rating is added to a conversation.",
+  version: "0.0.1",
+  type: "source",
+  dedupe: "unique",
+  methods: {
+    ...common.methods,
+    generateMeta(conversation) {
+      const ts = conversation.conversation_rating.created_at;
+      return {
+        id: `${conversation.id}-${ts}`,
+        summary: `New rating added to conversation with ID: ${conversation.id}`,
+        ts,
+      };
+    },
+  },
+  async run() {
+    let lastRatingCreatedAt = this._getLastUpdate();
+    const data = {
+      query: {
+        field: "conversation_rating.requested_at",
+        operator: ">",
+        value: lastRatingCreatedAt,
+      },
+    };
+
+    const results = await this.intercom.searchConversations(data);
+    for (const conversation of results) {
+      const createdAt = conversation.conversation_rating.created_at;
+      if (createdAt > lastRatingCreatedAt)
+        lastRatingCreatedAt = createdAt;
+      const meta = this.generateMeta(conversation);
+      this.$emit(conversation, meta);
+    }
+
+    this._setLastUpdate(lastRatingCreatedAt);
+  },
+};

components/intercom/sources/new-conversation/new-conversation.mjs

@@ -1,11 +1,11 @@
-import common from "../common.mjs";
+import common from "../common/common.mjs";
 
 export default {
   ...common,
   key: "intercom-new-conversation",
   name: "New Conversations",
   description: "Emit new event each time a new conversation is added.",
-  version: "0.0.4",
+  version: "0.0.5",
   type: "source",
   dedupe: "unique",
   methods: {

components/intercom/sources/new-event/new-event.mjs

@@ -1,11 +1,11 @@
-import common from "../common.mjs";
+import common from "../common/common.mjs";
 
 export default {
   ...common,
   key: "intercom-new-event",
   name: "New Event",
   description: "Emit new event for each new Intercom event for a user.",
-  version: "0.0.4",
+  version: "0.0.5",
   type: "source",
   dedupe: "unique",
   props: {

components/intercom/sources/new-lead/new-lead.mjs

@@ -1,11 +1,11 @@
-import common from "../common.mjs";
+import common from "../common/common.mjs";
 
 export default {
   ...common,
   key: "intercom-new-lead",
   name: "New Leads",
   description: "Emit new event each time a new lead is added.",
-  version: "0.0.4",
+  version: "0.0.5",
   type: "source",
   dedupe: "unique",
   methods: {

components/intercom/sources/new-unsubscription/new-unsubscription.mjs

@@ -1,11 +1,11 @@
-import common from "../common.mjs";
+import common from "../common/common.mjs";
 
 export default {
   ...common,
   key: "intercom-new-unsubscription",
   name: "New Unsubscriptions",
   description: "Emit new event each time a user unsubscribes from receiving emails.",
-  version: "0.0.4",
+  version: "0.0.5",
   type: "source",
   dedupe: "unique",
   methods: {

components/intercom/sources/new-user-reply/new-user-reply.mjs

@@ -1,11 +1,11 @@
-import common from "../common.mjs";
+import common from "../common/common.mjs";
 
 export default {
   ...common,
   key: "intercom-new-user-reply",
   name: "New Reply From User",
   description: "Emit new event each time a user replies to a conversation.",
-  version: "0.0.4",
+  version: "0.0.5",
   type: "source",
   dedupe: "unique",
   methods: {

components/intercom/sources/new-user/new-user.mjs

@@ -1,11 +1,11 @@
-import common from "../common.mjs";
+import common from "../common/common.mjs";
 
 export default {
   ...common,
   key: "intercom-new-user",
   name: "New Users",
   description: "Emit new event each time a new user is added.",
-  version: "0.0.4",
+  version: "0.0.5",
   type: "source",
   dedupe: "unique",
   methods: {

components/intercom/sources/tag-added-to-conversation/tag-added-to-conversation.mjs

@@ -1,11 +1,11 @@
-import common from "../common.mjs";
+import common from "../common/common.mjs";
 
 export default {
   ...common,
   key: "intercom-tag-added-to-conversation",
   name: "Tag Added To Conversation",
   description: "Emit new event each time a new tag is added to a conversation.",
-  version: "0.0.4",
+  version: "0.0.5",
   type: "source",
   dedupe: "unique",
   methods: {

components/intercom/sources/tag-added-to-lead/tag-added-to-lead.mjs

@@ -1,11 +1,11 @@
-import common from "../common.mjs";
+import common from "../common/common.mjs";
 
 export default {
   ...common,
   key: "intercom-tag-added-to-lead",
   name: "Tag Added To Lead",
   description: "Emit new event each time a new tag is added to a lead.",
-  version: "0.0.4",
+  version: "0.0.5",
   type: "source",
   dedupe: "unique",
   methods: {

components/intercom/sources/tag-added-to-user/tag-added-to-user.mjs

@@ -1,11 +1,11 @@
-import common from "../common.mjs";
+import common from "../common/common.mjs";
 
 export default {
   ...common,
   key: "intercom-tag-added-to-user",
   name: "Tag Added To User",
   description: "Emit new event each time a new tag is added to a user.",
-  version: "0.0.4",
+  version: "0.0.5",
   type: "source",
   dedupe: "unique",
   methods: {