Merge branch 'master' into master

Author: luancazarine

components/attio/attio.app.mjs

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

components/attio/package.json

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

components/bitbadges/bitbadges.app.mjs

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

components/bitbadges/package.json

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

components/burstyai/actions/run-workflow/run-workflow.mjs

@@ -0,0 +1,57 @@
+import burstyai from "../../burstyai.app.mjs";
+
+export default {
+  key: "burstyai-run-workflow",
+  name: "Run Workflow",
+  description: "Triggers an AI workflow on BurstyAI. [See the documentation](https://burstyai.readme.io/reference)",
+  version: "0.0.1",
+  type: "action",
+  props: {
+    burstyai,
+    workflow: {
+      type: "string",
+      label: "Workflow ID",
+      description: "The ID of the specific workflow to run. When viewing the workflow in BurstyAI, the ID is the last part of the URL. Example: `65e1cd00141fdc000195cb88`",
+    },
+    params: {
+      type: "object",
+      label: "Parameters",
+      description: "Optional parameters for the workflow",
+      optional: true,
+    },
+    waitForCompletion: {
+      type: "boolean",
+      label: "Wait For Completion",
+      description: "Set to `true` to poll the API in 3-second intervals until the workflow is completed",
+      optional: true,
+    },
+  },
+  async run({ $ }) {
+    let response = await this.burstyai.triggerWorkflow({
+      $,
+      workflow: this.workflow,
+      data: {
+        params: this.params || {},
+      },
+    });
+
+    const jobId = response;
+
+    if (this.waitForCompletion) {
+      const timer = (ms) => new Promise((res) => setTimeout(res, ms));
+      while (response?.jobStatus !== "END" && response?.jobStatus !== "ERROR") {
+        response = await this.burstyai.getWorkflowExecutionResult({
+          $,
+          jobId,
+        });
+        await timer(3000);
+      }
+    }
+
+    if (response?.status === "END") {
+      $.export("$summary", `Successfully triggered workflow ${this.workflow}`);
+    }
+
+    return response;
+  },
+};

components/burstyai/burstyai.app.mjs

@@ -0,0 +1,42 @@
+import { axios } from "@pipedream/platform";
+
+export default {
+  type: "app",
+  app: "burstyai",
+  methods: {
+    _baseUrl() {
+      return "https://app.burstyai.com/burstyai";
+    },
+    _makeRequest(opts = {}) {
+      const {
+        $ = this,
+        path,
+        ...otherOpts
+      } = opts;
+      return axios($, {
+        ...otherOpts,
+        url: `${this._baseUrl()}${path}`,
+        headers: {
+          Authorization: `Bearer ${this.$auth.api_key}`,
+        },
+      });
+    },
+    triggerWorkflow({
+      workflow, ...args
+    }) {
+      return this._makeRequest({
+        method: "POST",
+        path: `/aiflows/${workflow}/async_run`,
+        ...args,
+      });
+    },
+    getWorkflowExecutionResult({
+      jobId, ...args
+    }) {
+      return this._makeRequest({
+        path: `/aiflowjobs/${jobId}/result`,
+        ...args,
+      });
+    },
+  },
+};

components/burstyai/package.json

@@ -0,0 +1,18 @@
+{
+  "name": "@pipedream/burstyai",
+  "version": "0.1.0",
+  "description": "Pipedream BurstyAI Components",
+  "main": "burstyai.app.mjs",
+  "keywords": [
+    "pipedream",
+    "burstyai"
+  ],
+  "homepage": "https://pipedream.com/apps/burstyai",
+  "author": "Pipedream <[email protected]> (https://pipedream.com/)",
+  "publishConfig": {
+    "access": "public"
+  },
+  "dependencies": {
+    "@pipedream/platform": "^3.0.3"
+  }
+}

components/cliento/actions/get-ref-data/get-ref-data.mjs

@@ -0,0 +1,19 @@
+import cliento from "../../cliento.app.mjs";
+
+export default {
+  key: "cliento-get-ref-data",
+  name: "Get Reference Data",
+  description: "Fetch services, resources and mappings for the booking widget. [See the documentation](https://developers.cliento.com/docs/rest-api#fetch-ref-data)",
+  version: "0.0.1",
+  type: "action",
+  props: {
+    cliento,
+  },
+  async run({ $ }) {
+    const response = await this.cliento.fetchRefData({
+      $,
+    });
+    $.export("$summary", "Successfully fetched reference data");
+    return response;
+  },
+};

components/cliento/actions/get-settings/get-settings.mjs

@@ -0,0 +1,19 @@
+import cliento from "../../cliento.app.mjs";
+
+export default {
+  key: "cliento-get-settings",
+  name: "Fetch Settings",
+  description: "Fetch settings and features for the booking widget. [See the documentation](https://developers.cliento.com/docs/rest-api#fetch-settings)",
+  version: "0.0.1",
+  type: "action",
+  props: {
+    cliento,
+  },
+  async run({ $ }) {
+    const response = await this.cliento.fetchSettings({
+      $,
+    });
+    $.export("$summary", "Successfully fetched settings");
+    return response;
+  },
+};

components/cliento/actions/get-slots/get-slots.mjs

@@ -0,0 +1,53 @@
+import cliento from "../../cliento.app.mjs";
+
+export default {
+  key: "cliento-get-slots",
+  name: "Get Slots",
+  description: "Fetch available slots for the given service, resource and dates. [See the documentation](https://developers.cliento.com/docs/rest-api#fetch-slots)",
+  version: "0.0.1",
+  type: "action",
+  props: {
+    cliento,
+    fromDate: {
+      propDefinition: [
+        cliento,
+        "fromDate",
+      ],
+    },
+    toDate: {
+      propDefinition: [
+        cliento,
+        "toDate",
+      ],
+    },
+    resourceIds: {
+      propDefinition: [
+        cliento,
+        "resourceIds",
+      ],
+    },
+    serviceIds: {
+      propDefinition: [
+        cliento,
+        "serviceIds",
+      ],
+    },
+  },
+  async run({ $ }) {
+    const response = await this.cliento.fetchSlots({
+      $,
+      params: {
+        fromDate: this.fromDate,
+        toDate: this.toDate,
+        resIds: this.resourceIds.join(),
+        srvIds: this.serviceIds.join(),
+      },
+    });
+    if (response?.length) {
+      $.export("$summary", `Successfully fetched ${response.length} slot${response.length === 1
+        ? ""
+        : "s"}`);
+    }
+    return response;
+  },
+};