Merge branch 'master' into jay/dj-3523-migrate-sdk

Author: jverce

components/brandfetch/brandfetch.app.mjs

@@ -0,0 +1,11 @@
+export default {
+  type: "app",
+  app: "brandfetch",
+  propDefinitions: {},
+  methods: {
+    // this.$auth contains connected account data
+    authKeys() {
+      console.log(Object.keys(this.$auth));
+    },
+  },
+};

components/brandfetch/package.json

@@ -0,0 +1,15 @@
+{
+  "name": "@pipedream/brandfetch",
+  "version": "0.0.1",
+  "description": "Pipedream Brandfetch Components",
+  "main": "brandfetch.app.mjs",
+  "keywords": [
+    "pipedream",
+    "brandfetch"
+  ],
+  "homepage": "https://pipedream.com/apps/brandfetch",
+  "author": "Pipedream <[email protected]> (https://pipedream.com/)",
+  "publishConfig": {
+    "access": "public"
+  }
+}

components/codescene/actions/get-project-analysis/get-project-analysis.mjs

@@ -4,7 +4,7 @@ export default {
   key: "codescene-get-project-analysis",
   name: "Get Project Analysis",
   description: "Returns a single project analysis. [See the documentation](https://codescene.io/docs/integrations/public-api.html#single-analysis-details)",
-  version: "0.0.NaN",
+  version: "0.1.0",
   annotations: {
     destructiveHint: false,
     openWorldHint: true,

components/connectwise_psa/actions/create-company/create-company.mjs

@@ -4,7 +4,7 @@ export default {
   key: "connectwise_psa-create-company",
   name: "Create Company",
   description: "Creates a new company in Connectwise. [See the documentation](https://developer.connectwise.com/Products/ConnectWise_PSA/REST#/Companies/postCompanyCompanies)",
-  version: "0.0.2",
+  version: "0.0.3",
   annotations: {
     destructiveHint: false,
     openWorldHint: true,

components/connectwise_psa/actions/create-contact/create-contact.mjs

@@ -5,7 +5,7 @@ export default {
   key: "connectwise_psa-create-contact",
   name: "Create Contact",
   description: "Creates a new contact in Connectwise. [See the documentation](https://developer.connectwise.com/Products/ConnectWise_PSA/REST#/Contacts/postCompanyContacts)",
-  version: "0.1.1",
+  version: "0.1.2",
   annotations: {
     destructiveHint: false,
     openWorldHint: true,

components/connectwise_psa/actions/create-ticket/create-ticket.mjs

@@ -4,7 +4,7 @@ export default {
   key: "connectwise_psa-create-ticket",
   name: "Create Ticket",
   description: "Creates a new ticket in Connectwise. [See the documentation](https://developer.connectwise.com/Products/ConnectWise_PSA/REST#/Tickets/postServiceTickets)",
-  version: "0.1.1",
+  version: "0.1.2",
   annotations: {
     destructiveHint: false,
     openWorldHint: true,

components/connectwise_psa/connectwise_psa.app.mjs

@@ -339,6 +339,7 @@ export default {
       resourceFn,
       params,
       max,
+      lastId,
     }) {
       params = {
         ...params,
@@ -350,12 +351,19 @@ export default {
           params,
         });
         for (const item of items) {
-          yield item;
-          count++;
           if (max && count >= max) {
             return;
           }
+
+          // orderby id desc
+          if (item.id <= lastId) {
+            return;
+          }
+
+          yield item;
+          count++;
         }
+
         hasMore = items.length;
         params.page++;
       } while (hasMore);

components/connectwise_psa/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@pipedream/connectwise_psa",
-  "version": "0.2.1",
+  "version": "0.2.2",
   "description": "Pipedream Connectwise PSA Components",
   "main": "connectwise_psa.app.mjs",
   "keywords": [

components/connectwise_psa/sources/common/base.mjs

@@ -25,7 +25,10 @@ export default {
       this.db.set("lastId", lastId);
     },
     getParams() {
-      return {};
+      return {
+        pageSize: 500,
+        orderBy: "id desc",
+      };
     },
     generateMeta(item) {
       return {
@@ -38,25 +41,30 @@ export default {
       const lastId = this._getLastId();
       const resourceFn = this.getResourceFn();
       const params = this.getParams();
-      const results = this.connectwise.paginate({
+      const iterator = this.connectwise.paginate({
         resourceFn,
         params,
         max,
+        lastId,
       });
-      let items = [];
-      for await (const item of results) {
-        if (item.id > lastId) {
-          items.push(item);
+
+      const items = [];
+      let firstNewId;
+
+      for await (const item of iterator) {
+        if (!firstNewId) {
+          firstNewId = item.id;
         }
+        items.push(item);
       }
-      if (!items.length) {
-        return;
-      }
-      if (max) {
-        items = items.slice(-1 * max);
+
+      if (firstNewId) {
+        this._setLastId(firstNewId);
       }
-      this._setLastId(items[items.length - 1].id);
-      items.forEach((item) => this.$emit(item, this.generateMeta(item)));
+
+      items
+        .reverse()
+        .forEach((item) => this.$emit(item, this.generateMeta(item)));
     },
     getResourceFn() {
       throw new Error("getResourceFn is not implemented");

components/connectwise_psa/sources/new-contact-created/new-contact-created.mjs

@@ -6,7 +6,7 @@ export default {
   key: "connectwise_psa-new-contact-created",
   name: "New Contact Created",
   description: "Emit new event when a new contact is created in Connectwise.",
-  version: "0.0.2",
+  version: "0.0.3",
   type: "source",
   dedupe: "unique",
   methods: {