Merge branch 'master' into issue-12998

Author: lcaresia

.github/workflows/publish-platform-package.yaml

@@ -0,0 +1,32 @@
+on:
+  push:
+    branches:
+      - platform-1.x
+      - platform-2.x
+
+jobs:
+  # See https://pnpm.io/continuous-integration#github-actions
+  publish:
+    name: pnpm publish
+    runs-on: ubuntu-latest
+    concurrency:
+      group: ${{ github.workflow }}-${{ github.ref }}
+    steps:
+      - uses: actions/checkout@v4.1.7
+      - uses: pnpm/action-setup@v4.0.0
+        with:
+          version: 7.33.6
+      - uses: actions/setup-node@v4.0.3
+        with:
+          node-version: 18
+          registry-url: https://registry.npmjs.org/
+          cache: 'pnpm'
+      - name: pnpm install
+        run: pnpm install -r --no-frozen-lockfile
+      - name: Compile TypeScript
+        run: npm run build
+      # See https://pnpm.io/using-changesets
+      - name: Setup npmrc for pnpm publish
+        run: echo "//registry.npmjs.org/:_authToken=${{ secrets.NPM_TOKEN }}" > .npmrc
+      - name: pnpm publish (platform)
+        run: pnpm publish platform --no-git-checks

components/_8x8_connect/_8x8_connect.app.mjs

@@ -1,11 +1,76 @@
+import { axios } from "@pipedream/platform";
+
 export default {
   type: "app",
   app: "_8x8_connect",
-  propDefinitions: {},
+  propDefinitions: {
+    destination: {
+      type: "string",
+      label: "Destination",
+      description: "Destination of the SMS, i.e. `+12124567890`",
+    },
+    text: {
+      type: "string",
+      label: "Text",
+      description: "The text of the message",
+    },
+    from: {
+      type: "string",
+      label: "From",
+      description: "The initial date of the log, i.e. `2024-08-14T00:00:00`",
+    },
+    to: {
+      type: "string",
+      label: "To",
+      description: "The initial date of the log, i.e. `2024-08-15T10:00:00`",
+    },
+    jobId: {
+      type: "string",
+      label: "Log ID",
+      description: "The ID of the log",
+    },
+  },
   methods: {
-    // this.$auth contains connected account data
-    authKeys() {
-      console.log(Object.keys(this.$auth));
+    _baseUrl() {
+      return `${this.$auth.base_url}/api/v1`;
+    },
+    async _makeRequest(opts = {}) {
+      const {
+        $ = this,
+        path,
+        headers,
+        ...otherOpts
+      } = opts;
+      return axios($, {
+        ...otherOpts,
+        url: this._baseUrl() + path,
+        headers: {
+          ...headers,
+          Authorization: `Bearer ${this.$auth.api_key}`,
+        },
+      });
+    },
+    async sendSms(args = {}) {
+      return this._makeRequest({
+        method: "post",
+        path: `/subaccounts/${this.$auth.subaccount_id}/messages`,
+        ...args,
+      });
+    },
+    async requestLog(args = {}) {
+      return this._makeRequest({
+        method: "post",
+        path: `/subaccounts/${this.$auth.subaccount_id}/messages/exports`,
+        ...args,
+      });
+    },
+    async getLog({
+      jobId, ...args
+    }) {
+      return this._makeRequest({
+        path: `/subaccounts/${this.$auth.subaccount_id}/messages/exports/${jobId}`,
+        ...args,
+      });
     },
   },
 };

components/_8x8_connect/actions/get-log-result/get-log-result.mjs

@@ -0,0 +1,28 @@
+import app from "../../_8x8_connect.app.mjs";
+
+export default {
+  key: "_8x8_connect-get-log-result",
+  name: "Get Log Result",
+  description: "Check the status of an SMS Logs export job and to get a download link if its generation has succeeded. [See the documentation](https://developer.8x8.com/connect/reference/get-log-export-job-result)",
+  version: "0.0.1",
+  type: "action",
+  props: {
+    app,
+    jobId: {
+      propDefinition: [
+        app,
+        "jobId",
+      ],
+    },
+  },
+  async run({ $ }) {
+    const response = await this.app.getLog({
+      $,
+      jobId: this.jobId,
+    });
+
+    $.export("$summary", `Successfully retrieved the log status: '${response.status}'`);
+
+    return response;
+  },
+};

components/_8x8_connect/actions/request-log/request-log.mjs

@@ -0,0 +1,45 @@
+import app from "../../_8x8_connect.app.mjs";
+
+export default {
+  key: "_8x8_connect-request-log",
+  name: "Request Log",
+  description: "Request an SMS log file. [See the documentation](https://developer.8x8.com/connect/reference/start-log-export-job)",
+  version: "0.0.4",
+  type: "action",
+  props: {
+    app,
+    destination: {
+      propDefinition: [
+        app,
+        "destination",
+      ],
+      optional: true,
+    },
+    from: {
+      propDefinition: [
+        app,
+        "from",
+      ],
+    },
+    to: {
+      propDefinition: [
+        app,
+        "to",
+      ],
+    },
+  },
+  async run({ $ }) {
+    const response = await this.app.requestLog({
+      $,
+      data: {
+        phoneNumber: this.destination,
+        from: this.from,
+        to: this.to,
+      },
+    });
+
+    $.export("$summary", `Successfully requested SMS log.  You will need the following ID get the request result: '${response.jobId}'`);
+
+    return response;
+  },
+};

components/_8x8_connect/actions/send-sms/send-sms.mjs

@@ -0,0 +1,38 @@
+import app from "../../_8x8_connect.app.mjs";
+
+export default {
+  key: "_8x8_connect-send-sms",
+  name: "Send SMS",
+  description: "Send a SMS to the specified destination. [See the documentation](https://developer.8x8.com/connect/reference/send-sms-single)",
+  version: "0.0.2",
+  type: "action",
+  props: {
+    app,
+    destination: {
+      propDefinition: [
+        app,
+        "destination",
+      ],
+    },
+    text: {
+      propDefinition: [
+        app,
+        "text",
+      ],
+    },
+
+  },
+  async run({ $ }) {
+    const response = await this.app.sendSms({
+      $,
+      data: {
+        destination: this.destination,
+        text: this.text,
+      },
+    });
+
+    $.export("$summary", `Successfully queued SMS for processing. ID: '${response.umid}'`);
+
+    return response;
+  },
+};

components/_8x8_connect/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@pipedream/_8x8_connect",
-  "version": "0.0.1",
+  "version": "0.1.0",
   "description": "Pipedream 8x8 Connect Components",
   "main": "_8x8_connect.app.mjs",
   "keywords": [
@@ -11,5 +11,8 @@
   "author": "Pipedream <support@pipedream.com> (https://pipedream.com/)",
   "publishConfig": {
     "access": "public"
+  },
+  "dependencies": {
+    "@pipedream/platform": "^3.0.0"
   }
-}
+}

components/activecalculator/activecalculator.app.mjs

@@ -1,11 +1,67 @@
+import { axios } from "@pipedream/platform";
+import { LIMIT } from "./common/constants.mjs";
+
 export default {
   type: "app",
   app: "activecalculator",
-  propDefinitions: {},
+  propDefinitions: {
+    calculatorIds: {
+      type: "string[]",
+      label: "Calculator Ids",
+      description: "A list of calculator's Ids.",
+      async options({ page }) {
+        const { data } = await this.listCalculators({
+          params: {
+            limit: LIMIT,
+            offset: LIMIT * page,
+          },
+        });
+
+        return data.map(({
+          id: value, name: label,
+        }) => ({
+          label,
+          value,
+        }));
+      },
+    },
+  },
   methods: {
-    // this.$auth contains connected account data
-    authKeys() {
-      console.log(Object.keys(this.$auth));
+    _baseUrl() {
+      return "https://app.activecalculator.com/api/v1";
+    },
+    _headers() {
+      return {
+        "x-ac-api-key": `${this.$auth.api_key}`,
+      };
+    },
+    _makeRequest({
+      $ = this, path, ...opts
+    }) {
+      return axios($, {
+        url: this._baseUrl() + path,
+        headers: this._headers(),
+        ...opts,
+      });
+    },
+    listCalculators(opts = {}) {
+      return this._makeRequest({
+        path: "/calculators",
+        ...opts,
+      });
+    },
+    createWebhook(opts = {}) {
+      return this._makeRequest({
+        method: "POST",
+        path: "/webhooks",
+        ...opts,
+      });
+    },
+    deleteWebhook(webhookId) {
+      return this._makeRequest({
+        method: "DELETE",
+        path: `/webhooks/${webhookId}`,
+      });
     },
   },
 };

components/activecalculator/common/constants.mjs

@@ -0,0 +1 @@
+export const LIMIT = 100;

components/activecalculator/common/utils.mjs

@@ -0,0 +1,24 @@
+export const parseObject = (obj) => {
+  if (!obj) return undefined;
+
+  if (Array.isArray(obj)) {
+    return obj.map((item) => {
+      if (typeof item === "string") {
+        try {
+          return JSON.parse(item);
+        } catch (e) {
+          return item;
+        }
+      }
+      return item;
+    });
+  }
+  if (typeof obj === "string") {
+    try {
+      return JSON.parse(obj);
+    } catch (e) {
+      return obj;
+    }
+  }
+  return obj;
+};

components/activecalculator/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@pipedream/activecalculator",
-  "version": "0.0.1",
+  "version": "0.1.0",
   "description": "Pipedream ActiveCalculator Components",
   "main": "activecalculator.app.mjs",
   "keywords": [
@@ -11,5 +11,9 @@
   "author": "Pipedream <support@pipedream.com> (https://pipedream.com/)",
   "publishConfig": {
     "access": "public"
+  },
+  "dependencies": {
+    "@pipedream/platform": "^3.0.0"
   }
-}
+}
+