Merging pull request #18882

* 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.5",
+  version: "0.0.6",
   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.5",
+  version: "0.0.6",
   annotations: {
     destructiveHint: false,
     openWorldHint: true,

components/microsoft_dynamics_365_sales/microsoft_dynamics_365_sales.app.mjs

@@ -54,6 +54,20 @@ export default {
         };
       },
     },
+    accountId: {
+      type: "string",
+      label: "Account ID",
+      description: "Identifier of an account",
+      async options() {
+        const { value } = await this.listAccounts();
+        return value?.map(({
+          accountid: value, name: label,
+        }) => ({
+          value,
+          label,
+        })) || [];
+      },
+    },
   },
   methods: {
     _baseUrl() {
@@ -119,6 +133,12 @@ export default {
         ...opts,
       });
     },
+    listAccounts(opts = {}) {
+      return this._makeRequest({
+        path: "/accounts",
+        ...opts,
+      });
+    },
     getEntity({
       entityId, ...opts
     }) {

components/microsoft_dynamics_365_sales/package.json

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

components/microsoft_dynamics_365_sales/sources/account-ownership-changed/account-ownership-changed.mjs

@@ -0,0 +1,55 @@
+import common from "../common/common.mjs";
+
+export default {
+  ...common,
+  key: "microsoft_dynamics_365_sales-account-ownership-changed",
+  name: "Account Ownership Changed",
+  description: "Emit new event when the ownership of an account changes.",
+  version: "0.0.1",
+  type: "source",
+  dedupe: "unique",
+  methods: {
+    ...common.methods,
+    _getOwnershipIds() {
+      return this.db.get("ownershipIds") || {};
+    },
+    _setOwnershipIds(ownershipIds) {
+      this.db.set("ownershipIds", ownershipIds);
+    },
+    getResourceFn() {
+      return this.microsoftDynamics365Sales.listAccounts;
+    },
+    getArgs() {
+      return {
+        params: {
+          "$orderby": "modifiedon desc",
+        },
+      };
+    },
+    getTsField() {
+      return "modifiedon";
+    },
+    getRelevantResults(results) {
+      const ownershipIds = this._getOwnershipIds();
+      const relevantResults = [];
+      for (const result of results) {
+        if (ownershipIds[result.accountid] !== result._ownerid_value) {
+          if (ownershipIds[result.accountid]) {
+            relevantResults.push(result);
+          }
+          ownershipIds[result.accountid] = result._ownerid_value;
+        }
+      }
+      this._setOwnershipIds(ownershipIds);
+      return relevantResults;
+    },
+    generateMeta(account) {
+      const ts = Date.parse(account.modifiedon);
+      return {
+        id: `${account.accountid}${ts}`,
+        summary: `Account Ownership Changed: ${account.name}`,
+        ts,
+      };
+    },
+  },
+};

components/microsoft_dynamics_365_sales/sources/account-status-changed/account-status-changed.mjs

@@ -0,0 +1,55 @@
+import common from "../common/common.mjs";
+
+export default {
+  ...common,
+  key: "microsoft_dynamics_365_sales-account-status-changed",
+  name: "Account Status Changed",
+  description: "Emit new event when an account is activated or deactivated.",
+  version: "0.0.1",
+  type: "source",
+  dedupe: "unique",
+  methods: {
+    ...common.methods,
+    _getStatuses() {
+      return this.db.get("statuses") || {};
+    },
+    _setStatuses(statuses) {
+      this.db.set("statuses", statuses);
+    },
+    getResourceFn() {
+      return this.microsoftDynamics365Sales.listAccounts;
+    },
+    getArgs() {
+      return {
+        params: {
+          "$orderby": "modifiedon desc",
+        },
+      };
+    },
+    getTsField() {
+      return "modifiedon";
+    },
+    getRelevantResults(results) {
+      const statuses = this._getStatuses();
+      const relevantResults = [];
+      for (const result of results) {
+        if (statuses[result.accountid] !== result.statuscode) {
+          if (statuses[result.accountid]) {
+            relevantResults.push(result);
+          }
+          statuses[result.accountid] = result.statuscode;
+        }
+      }
+      this._setStatuses(statuses);
+      return relevantResults;
+    },
+    generateMeta(account) {
+      const ts = Date.parse(account.modifiedon);
+      return {
+        id: `${account.accountid}${ts}`,
+        summary: `Account Status Changed: ${account.name}`,
+        ts,
+      };
+    },
+  },
+};

components/microsoft_dynamics_365_sales/sources/contact-added-to-account/contact-added-to-account.mjs

@@ -0,0 +1,56 @@
+import common from "../common/common.mjs";
+
+export default {
+  ...common,
+  key: "microsoft_dynamics_365_sales-contact-added-to-account",
+  name: "Contact Added to Account",
+  description: "Emit new event when a contact is added to an account.",
+  version: "0.0.1",
+  type: "source",
+  dedupe: "unique",
+  props: {
+    ...common.props,
+    accountId: {
+      propDefinition: [
+        common.props.microsoftDynamics365Sales,
+        "accountId",
+      ],
+    },
+  },
+  methods: {
+    ...common.methods,
+    getResourceFn() {
+      return this.microsoftDynamics365Sales.listAccounts;
+    },
+    getArgs() {
+      return {
+        params: {
+          "$filter": `accountid eq ${this.accountId}`,
+          "$expand": "contact_customer_accounts",
+        },
+      };
+    },
+    getTsField() {
+      return "modifiedon";
+    },
+    getRelevantResults(results) {
+      const relevantResults = [];
+      const account = results[0];
+      account.contact_customer_accounts.forEach((contact) => {
+        relevantResults.push({
+          ...contact,
+          addedToAccountOn: account.modifiedon,
+        });
+      });
+      return relevantResults;
+    },
+    generateMeta(contact) {
+      const ts = Date.parse(contact.addedToAccountOn);
+      return {
+        id: `${contact.contactid}${ts}`,
+        summary: `Contact Added to Account: ${contact.fullname}`,
+        ts,
+      };
+    },
+  },
+};

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

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

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

@@ -0,0 +1,34 @@
+import common from "../common/common.mjs";
+
+export default {
+  ...common,
+  key: "microsoft_dynamics_365_sales-new-account-created",
+  name: "New Account Created",
+  description: "Emit new event when a new account is created.",
+  version: "0.0.1",
+  type: "source",
+  dedupe: "unique",
+  methods: {
+    ...common.methods,
+    getResourceFn() {
+      return this.microsoftDynamics365Sales.listAccounts;
+    },
+    getArgs() {
+      return {
+        params: {
+          "$orderby": "createdon desc",
+        },
+      };
+    },
+    getTsField() {
+      return "createdon";
+    },
+    generateMeta(account) {
+      return {
+        id: account.accountid,
+        summary: `New Account: ${account.name}`,
+        ts: Date.parse(account.createdon),
+      };
+    },
+  },
+};

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

@@ -5,7 +5,7 @@ export default {
   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",
+  version: "0.0.2",
   type: "source",
   dedupe: "unique",
   props: {