Merging pull request #18875

* new sources

* versions

Author: michelle0927

components/microsoft_dynamics_365_sales/actions/create-custom-entity/create-custom-entity.mjs

@@ -6,7 +6,7 @@ export default {
   key: "microsoft_dynamics_365_sales-create-custom-entity",
   name: "Create Custom Entity",
   description: "Create a custom entity. [See the documentation](https://learn.microsoft.com/en-us/power-apps/developer/data-platform/webapi/create-update-entity-definitions-using-web-api)",
-  version: "0.0.4",
+  version: "0.0.5",
   annotations: {
     destructiveHint: true,
     openWorldHint: true,

components/microsoft_dynamics_365_sales/actions/find-contact/find-contact.mjs

@@ -4,7 +4,7 @@ export default {
   key: "microsoft_dynamics_365_sales-find-contact",
   name: "Find Contact",
   description: "Search for a contact by id, name, or using a custom filter. [See the documentation](https://learn.microsoft.com/en-us/power-apps/developer/data-platform/webapi/query/overview)",
-  version: "0.0.4",
+  version: "0.0.5",
   annotations: {
     destructiveHint: false,
     openWorldHint: true,

components/microsoft_dynamics_365_sales/microsoft_dynamics_365_sales.app.mjs

@@ -33,6 +33,27 @@ export default {
         })) || [];
       },
     },
+    opportunityId: {
+      type: "string",
+      label: "Opportunity ID",
+      description: "Identifier of an opportunity",
+      async options({ prevContext }) {
+        const response = await this.listOpportunities({
+          url: prevContext?.url,
+        });
+        return {
+          options: response.value?.map(({
+            opportunityid: value, name: label,
+          }) => ({
+            value,
+            label,
+          })) || [],
+          context: {
+            url: response["@odata.nextLink"],
+          },
+        };
+      },
+    },
   },
   methods: {
     _baseUrl() {
@@ -92,6 +113,12 @@ export default {
         ...opts,
       });
     },
+    listActivityPointers(opts = {}) {
+      return this._makeRequest({
+        path: "/activitypointers",
+        ...opts,
+      });
+    },
     getEntity({
       entityId, ...opts
     }) {

components/microsoft_dynamics_365_sales/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@pipedream/microsoft_dynamics_365_sales",
-  "version": "0.2.0",
+  "version": "0.3.0",
   "description": "Pipedream Microsoft Dynamics 365 Sales Components",
   "main": "microsoft_dynamics_365_sales.app.mjs",
   "keywords": [

components/microsoft_dynamics_365_sales/sources/new-opportunity-activity/new-opportunity-activity.mjs

@@ -0,0 +1,45 @@
+import common from "../common/common.mjs";
+
+export default {
+  ...common,
+  key: "microsoft_dynamics_365_sales-new-opportunity-activity",
+  name: "New Opportunity Activity",
+  description: "Emit new event when a new task or activity is created for an opportunity.",
+  version: "0.0.1",
+  type: "source",
+  dedupe: "unique",
+  props: {
+    ...common.props,
+    opportunityId: {
+      propDefinition: [
+        common.props.microsoftDynamics365Sales,
+        "opportunityId",
+      ],
+    },
+  },
+  methods: {
+    ...common.methods,
+    getResourceFn() {
+      return this.microsoftDynamics365Sales.listActivityPointers;
+    },
+    getArgs() {
+      return {
+        params: {
+          "$orderby": "createdon desc",
+          "$filter": `_regardingobjectid_value eq ${this.opportunityId}`,
+        },
+      };
+    },
+    getTsField() {
+      return "createdon";
+    },
+    generateMeta(activity) {
+      const ts = Date.parse(activity.createdon);
+      return {
+        id: `${activity.opportunityid}${ts}`,
+        summary: `New Opportunity Activity: ${activity.subject}`,
+        ts,
+      };
+    },
+  },
+};

components/microsoft_dynamics_365_sales/sources/new-opportunity-created/new-opportunity-created.mjs

@@ -5,7 +5,7 @@ export default {
   key: "microsoft_dynamics_365_sales-new-opportunity-created",
   name: "New Opportunity Created",
   description: "Emit new event when a new opportunity is created.",
-  version: "0.0.1",
+  version: "0.0.2",
   type: "source",
   dedupe: "unique",
   hooks: {

components/microsoft_dynamics_365_sales/sources/opportunity-close-date-updated/opportunity-close-date-updated.mjs

@@ -5,7 +5,7 @@ export default {
   key: "microsoft_dynamics_365_sales-opportunity-close-date-updated",
   name: "Opportunity Close Date Updated",
   description: "Emit new event when the estimated close date of an opportunity is updated.",
-  version: "0.0.1",
+  version: "0.0.2",
   type: "source",
   dedupe: "unique",
   methods: {

components/microsoft_dynamics_365_sales/sources/opportunity-close-probability-updated/opportunity-close-probability-updated.mjs

@@ -5,7 +5,7 @@ export default {
   key: "microsoft_dynamics_365_sales-opportunity-close-probability-updated",
   name: "Opportunity Close Probability Updated",
   description: "Emit new event when the close probability of an opportunity is updated.",
-  version: "0.0.1",
+  version: "0.0.2",
   type: "source",
   dedupe: "unique",
   methods: {

components/microsoft_dynamics_365_sales/sources/opportunity-contact-changed/opportunity-contact-changed.mjs

@@ -0,0 +1,55 @@
+import common from "../common/common.mjs";
+
+export default {
+  ...common,
+  key: "microsoft_dynamics_365_sales-opportunity-contact-changed",
+  name: "Opportunity Contact Changed",
+  description: "Emit new event when an opportunity's contact is changed.",
+  version: "0.0.{{ts}}",
+  type: "source",
+  dedupe: "unique",
+  methods: {
+    ...common.methods,
+    _getContactIds() {
+      return this.db.get("contactIds") || {};
+    },
+    _setContactIds(contactIds) {
+      this.db.set("contactIds", contactIds);
+    },
+    getResourceFn() {
+      return this.microsoftDynamics365Sales.listOpportunities;
+    },
+    getArgs() {
+      return {
+        params: {
+          "$orderby": "modifiedon desc",
+        },
+      };
+    },
+    getTsField() {
+      return "modifiedon";
+    },
+    getRelevantResults(results) {
+      const contactIds = this._getContactIds();
+      const relevantResults = [];
+      for (const result of results) {
+        if (contactIds[result.opportunityid] !== result._parentcontactid_value) {
+          if (contactIds[result.opportunityid]) {
+            relevantResults.push(result);
+          }
+          contactIds[result.opportunityid] = result._parentcontactid_value;
+        }
+      }
+      this._setContactIds(contactIds);
+      return relevantResults;
+    },
+    generateMeta(opportunity) {
+      const ts = Date.parse(opportunity.modifiedon);
+      return {
+        id: `${opportunity.opportunityid}${ts}`,
+        summary: `Opportunity Contact Changed: ${opportunity.name}`,
+        ts,
+      };
+    },
+  },
+};

components/microsoft_dynamics_365_sales/sources/opportunity-estimated-value-updated/opportunity-estimated-value-updated.mjs

@@ -5,7 +5,7 @@ export default {
   key: "microsoft_dynamics_365_sales-opportunity-estimated-value-updated",
   name: "Opportunity Estimated Value Updated",
   description: "Emit new event when the estimated value of an opportunity is updated.",
-  version: "0.0.1",
+  version: "0.0.2",
   type: "source",
   dedupe: "unique",
   methods: {