Initial migration - 'list sites' action

Author: GTFalcao

components/webflow/actions/list-sites/list-sites.mjs renamed to components/webflow_v2/actions/list-sites/list-sites.mjs

@@ -1,16 +1,16 @@
-import webflow from "../../webflow.app.mjs";
+import app from "../../webflow_v2.app.mjs";
 
 export default {
-  key: "webflow-list-sites",
+  key: "webflow_v2-list-sites",
   name: "List Sites",
   description: "List sites. [See the docs here](https://developers.webflow.com/#list-sites)",
-  version: "0.0.4",
+  version: "0.1.{{ts}}",
   type: "action",
   props: {
-    webflow,
+    app,
   },
   async run({ $ }) {
-    const response = await this.webflow.getSites();
+    const response = await this.app.getSites();
 
     $.export("$summary", "Successfully retrieved sites");
 

components/webflow_v2/common/constants.mjs

@@ -0,0 +1,4 @@
+export default {
+  LIMIT: 100,
+  DEPLOY_OFFSET: 25,
+};

components/webflow_v2/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@pipedream/webflow_v2",
-  "version": "0.0.1",
+  "version": "0.1.0",
   "description": "Pipedream Webflow (v2) Components",
   "main": "webflow_v2.app.mjs",
   "keywords": [
@@ -9,7 +9,11 @@
   ],
   "homepage": "https://pipedream.com/apps/webflow_v2",
   "author": "Pipedream <[email protected]> (https://pipedream.com/)",
+  "dependencies": {
+    "@pipedream/platform": "^3.0.3",
+    "webflow-api": "2.4.2"
+  },
   "publishConfig": {
     "access": "public"
   }
-}
+}

components/webflow_v2/webflow_v2.app.mjs

@@ -1,11 +1,246 @@
+import { WebflowClient } from "webflow-api";
+import constants from "./common/constants.mjs";
+
 export default {
   type: "app",
   app: "webflow_v2",
-  propDefinitions: {},
+  propDefinitions: {
+    domains: {
+      label: "Domain",
+      description: "The list of domains.",
+      type: "string[]",
+      async options({ siteId }) {
+        const domains = await this.getDomains(siteId);
+
+        return domains.map((domain) => domain.name);
+      },
+    },
+    sites: {
+      label: "Site",
+      description: "The list of sites",
+      type: "string",
+      async options() {
+        const sites = await this.getSites();
+
+        return sites.map((site) => ({
+          label: site.name,
+          value: site._id,
+        }));
+      },
+    },
+    collections: {
+      label: "Collection",
+      description: "The list of collection of a site",
+      type: "string",
+      async options({ siteId }) {
+        const collections = await this.getCollections(siteId);
+
+        return collections.map((collection) => ({
+          label: collection.name,
+          value: collection._id,
+        }));
+      },
+    },
+    items: {
+      label: "Item",
+      description: "The list of items of a collection",
+      type: "string",
+      async options({
+        collectionId, page,
+      }) {
+        const items = await this.getItems(page, collectionId);
+
+        return items.map((item) => ({
+          label: item.name,
+          value: item._id,
+        }));
+      },
+    },
+    orders: {
+      label: "Order",
+      description: "The list of orders of a site",
+      type: "string",
+      async options({
+        siteId, page,
+      }) {
+        const items = await this.getOrders({
+          page,
+          siteId,
+        });
+
+        return items.map((item) => item.orderId);
+      },
+    },
+  },
   methods: {
-    // this.$auth contains connected account data
-    authKeys() {
-      console.log(Object.keys(this.$auth));
+    /**
+     * Get the auth access token;
+     *
+     * @returns {string} The base auth access token.
+     */
+    _authToken() {
+      return this.$auth.oauth_access_token;
+    },
+    _createApiClient() {
+      return new WebflowClient({
+        accessToken: this._authToken(),
+      });
+    },
+    /**
+     * Create a Webflow webhook;
+     *
+     * @param {siteId} ID of the site to be monitored.
+     * @param {url} URL to webhook return.
+     * @param {triggerType} Type of event that will be triggered.
+     * @param {filter} Filters to be applied in webhook.
+     *
+     * @returns {params} The Webflow webhook.
+     */
+    async createWebhook(siteId, url, triggerType, filter = {}) {
+      const apiClient = this._createApiClient();
+
+      return apiClient.createWebhook({
+        siteId,
+        triggerType,
+        url,
+        filter,
+      });
+    },
+    /**
+     * Remove a Webflow webhook;
+     *
+     * @param {siteId} ID of the site.
+     * @param {webhookId} ID of the webhook.
+     */
+    async removeWebhook(siteId, webhookId) {
+      const apiClient = this._createApiClient();
+      return apiClient.removeWebhook({
+        siteId,
+        webhookId,
+      });
+    },
+    /**
+     * Get an order;
+     *
+     * @param {options} Options to filter the order.
+     *
+     * @returns {params} An order.
+     */
+    async getOrder({
+      siteId, orderId,
+    }) {
+      const apiClient = this._createApiClient();
+
+      return apiClient.get(`/sites/${siteId}/order/${orderId}`);
+    },
+    /**
+     * Get a list of orders;
+     *
+     * @param {options} Options to filter the orders.
+     *
+     * @returns {params} A list of orders.
+     */
+    async getOrders({
+      page, siteId, status,
+    }) {
+      const apiClient = this._createApiClient();
+
+      return apiClient.get(`/sites/${siteId}/orders`, {
+        status: status,
+        offset: page ?? 0,
+        limit: constants.LIMIT,
+      });
+    },
+    /**
+     * Get a list of domains;
+     *
+     * @param {options} Options to filter the domains.
+     *
+     * @returns {params} A list of domains.
+     */
+    async getDomains(siteId) {
+      const webflow = this._createApiClient();
+
+      return await webflow.domains({
+        siteId,
+      });
+    },
+    /**
+     * Get a site;
+     *
+     * @param {options} Options to filter the site.
+     *
+     * @returns {params} A site.
+     */
+    async getSite(siteId) {
+      const webflow = this._createApiClient();
+
+      return await webflow.site({
+        siteId,
+      });
+    },
+    /**
+     * Get a list of sites;
+     *
+     * @param {options} Options to filter the sites.
+     *
+     * @returns {params} A list of sites.
+     */
+    async getSites() {
+      const webflow = this._createApiClient();
+
+      return await webflow.sites.list();
+    },
+    /**
+     * Get a collection;
+     *
+     * @param {options} Options to filter the collection.
+     *
+     * @returns {params} A collection.
+     */
+    async getCollection(collectionId) {
+      const webflow = this._createApiClient();
+
+      return await webflow.collection({
+        collectionId,
+      });
+    },
+    /**
+     * Get a list of collections;
+     *
+     * @param {options} Options to filter the collections.
+     *
+     * @returns {params} A list of collections.
+     */
+    async getCollections(siteId) {
+      const webflow = this._createApiClient();
+
+      if (!siteId) return [];
+
+      return await webflow.collections.list({
+        siteId: siteId,
+      });
+    },
+    /**
+     * Get a list of items;
+     *
+     * @param {options} Options to filter the items.
+     *
+     * @returns {params} A list of items.
+     */
+    async getItems(page = 0, collectionId) {
+      const webflow = this._createApiClient();
+
+      if (!collectionId) return [];
+
+      const response = await webflow.items({
+        collectionId,
+      }, {
+        limit: constants.LIMIT,
+        offset: page,
+      });
+
+      return response;
     },
   },
-};
+};