Intercom - new-conversation-rating-added source (#14456)

michelle0927 · web-flow · commit 7fa4e07d3c98 · 2024-10-30T10:39:31.000-04:00
* new-conversation-rating-added

* pnpm-lock.yaml
diff --git a/components/intercom/package.json b/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"
   }
 }
diff --git a/components/intercom/sources/common/common.mjs b/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 {
diff --git a/components/intercom/sources/conversation-closed/conversation-closed.mjs b/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: {
diff --git a/components/intercom/sources/lead-added-email/lead-added-email.mjs b/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: {
diff --git a/components/intercom/sources/new-admin-reply/new-admin-reply.mjs b/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: {
diff --git a/components/intercom/sources/new-company/new-company.mjs b/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: {
diff --git a/components/intercom/sources/new-conversation-rating-added/new-conversation-rating-added.mjs b/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);
+  },
+};
diff --git a/components/intercom/sources/new-conversation/new-conversation.mjs b/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: {
diff --git a/components/intercom/sources/new-event/new-event.mjs b/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: {
diff --git a/components/intercom/sources/new-lead/new-lead.mjs b/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: {
diff --git a/components/intercom/sources/new-unsubscription/new-unsubscription.mjs b/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: {
diff --git a/components/intercom/sources/new-user-reply/new-user-reply.mjs b/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: {
diff --git a/components/intercom/sources/new-user/new-user.mjs b/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: {
diff --git a/components/intercom/sources/tag-added-to-conversation/tag-added-to-conversation.mjs b/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: {
diff --git a/components/intercom/sources/tag-added-to-lead/tag-added-to-lead.mjs b/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: {
diff --git a/components/intercom/sources/tag-added-to-user/tag-added-to-user.mjs b/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: {
diff --git a/pnpm-lock.yaml b/pnpm-lock.yaml

Original file line number	Diff line number	Diff line change
`@@ -1,6 +1,6 @@`
`1`	`1`	`{`
`2`	`2`	`"name": "@pipedream/intercom",`
`3`		`- "version": "0.3.9",`
	`3`	`+ "version": "0.4.0",`
`4`	`4`	`"description": "Pipedream Intercom Components",`
`5`	`5`	`"main": "intercom.app.mjs",`
`6`	`6`	`"keywords": [`
`@@ -14,7 +14,7 @@`
`14`	`14`	`"access": "public"`
`15`	`15`	`},`
`16`	`16`	`"dependencies": {`
`17`		`- "@pipedream/platform": "^1.2.0",`
	`17`	`+ "@pipedream/platform": "^3.0.3",`
`18`	`18`	`"crypto": "^1.0.1"`
`19`	`19`	`}`
`20`	`20`	`}`
Original file line number	Diff line number	Diff line change
`@@ -1,4 +1,4 @@`
`1`		`-import intercom from "../intercom.app.mjs";`
	`1`	`+import intercom from "../../intercom.app.mjs";`
`2`	`2`	`import { DEFAULT_POLLING_SOURCE_TIMER_INTERVAL } from "@pipedream/platform";`
`3`	`3`
`4`	`4`	`export default {`