Merge branch 'master' into issue-16400

Author: luancazarine

components/xendit/app/xendit.app.ts renamed to components/airpinpoint/airpinpoint.app.mjs

@@ -1,13 +1,11 @@
-import { defineApp } from "@pipedream/types";
-
-export default defineApp({
+export default {
   type: "app",
-  app: "xendit",
+  app: "airpinpoint",
   propDefinitions: {},
   methods: {
     // this.$auth contains connected account data
     authKeys() {
       console.log(Object.keys(this.$auth));
     },
   },
-});
+};

components/airpinpoint/package.json

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

components/airtable_oauth/actions/list-bases/list-bases.mjs

@@ -0,0 +1,23 @@
+import airtable from "../../airtable_oauth.app.mjs";
+
+export default {
+  key: "airtable_oauth-list-bases",
+  name: "List Bases",
+  description:
+    "Get the list of bases that can be accessed. [See the documentation](https://airtable.com/developers/web/api/list-bases)",
+  type: "action",
+  version: "0.0.1",
+  props: {
+    airtable,
+  },
+  async run({ $ }) {
+    const { bases } = await this.airtable.listBases({
+      $,
+    });
+    $.export(
+      "$summary",
+      `Successfully retrieved ${bases.length} bases`,
+    );
+    return bases;
+  },
+};

components/airtable_oauth/actions/list-tables/list-tables.mjs

@@ -0,0 +1,30 @@
+import airtable from "../../airtable_oauth.app.mjs";
+
+export default {
+  key: "airtable_oauth-list-tables",
+  name: "List Tables",
+  description:
+    "Get a list of tables in the selected base. [See the documentation](https://airtable.com/developers/web/api/get-base-schema)",
+  type: "action",
+  version: "0.0.1",
+  props: {
+    airtable,
+    baseId: {
+      propDefinition: [
+        airtable,
+        "baseId",
+      ],
+    },
+  },
+  async run({ $ }) {
+    const { tables } = await this.airtable.listTables({
+      $,
+      baseId: this.baseId,
+    });
+    $.export(
+      "$summary",
+      `Successfully retrieved ${tables.length} tables`,
+    );
+    return tables;
+  },
+};

components/airtable_oauth/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@pipedream/airtable_oauth",
-  "version": "0.4.4",
+  "version": "0.5.0",
   "description": "Pipedream Airtable (OAuth) Components",
   "main": "airtable_oauth.app.mjs",
   "keywords": [

components/apify/actions/get-dataset-items/get-dataset-items.mjs

@@ -5,7 +5,7 @@ export default {
   key: "apify-get-dataset-items",
   name: "Get Dataset Items",
   description: "Returns data stored in a dataset. [See the documentation](https://docs.apify.com/api/v2/dataset-items-get)",
-  version: "0.0.1",
+  version: "0.0.2",
   type: "action",
   props: {
     apify,

components/apify/actions/run-actor/run-actor.mjs

@@ -1,11 +1,13 @@
 /* eslint-disable no-unused-vars */
 import apify from "../../apify.app.mjs";
+import { parseObject } from "../../common/utils.mjs";
+import { EVENT_TYPES } from "../../common/constants.mjs";
 
 export default {
   key: "apify-run-actor",
   name: "Run Actor",
   description: "Performs an execution of a selected actor in Apify. [See the documentation](https://docs.apify.com/api/v2#/reference/actors/run-collection/run-actor)",
-  version: "0.0.2",
+  version: "0.0.3",
   type: "action",
   props: {
     apify,
@@ -14,6 +16,52 @@ export default {
         apify,
         "actorId",
       ],
+    },
+    buildId: {
+      propDefinition: [
+        apify,
+        "buildId",
+        (c) => ({
+          actorId: c.actorId,
+        }),
+      ],
+      reloadProps: true,
+    },
+    runAsynchronously: {
+      type: "boolean",
+      label: "Run Asynchronously",
+      description: "Set to `true` to run the actor asynchronously",
+      reloadProps: true,
+    },
+    timeout: {
+      type: "string",
+      label: "Timeout",
+      description: "Optional timeout for the run, in seconds. By default, the run uses a timeout specified in the default run configuration for the Actor.",
+      optional: true,
+    },
+    memory: {
+      type: "string",
+      label: "Memory",
+      description: "Memory limit for the run, in megabytes. The amount of memory can be set to a power of 2 with a minimum of 128. By default, the run uses a memory limit specified in the default run configuration for the Actor.",
+      optional: true,
+    },
+    maxItems: {
+      type: "string",
+      label: "Max Items",
+      description: "The maximum number of items that the Actor run should return. This is useful for pay-per-result Actors, as it allows you to limit the number of results that will be charged to your subscription. You can access the maximum number of items in your Actor by using the ACTOR_MAX_PAID_DATASET_ITEMS environment variable.",
+      optional: true,
+    },
+    maxTotalChargeUsd: {
+      type: "string",
+      label: "Max Total Charge USD",
+      description: "Specifies the maximum cost of the Actor run. This parameter is useful for pay-per-event Actors, as it allows you to limit the amount charged to your subscription. You can access the maximum cost in your Actor by using the ACTOR_MAX_TOTAL_CHARGE_USD environment variable.",
+      optional: true,
+    },
+    webhook: {
+      type: "string",
+      label: "Webhook",
+      description: "Specifies optional webhook associated with the Actor run, which can be used to receive a notification e.g. when the Actor finished or failed.",
+      optional: true,
       reloadProps: true,
     },
   },
@@ -28,16 +76,14 @@ export default {
         ? type
         : "string[]";
     },
-    async getSchema() {
-      const { data: { items: builds } } = await this.apify.listBuilds(this.actorId);
-      const buildId = builds.at(-1).id;
+    async getSchema(buildId) {
       const { data: { inputSchema } } = await this.apify.getBuild(buildId);
       return JSON.parse(inputSchema);
     },
     async prepareData(data) {
       const newData = {};
 
-      const { properties } = await this.getSchema();
+      const { properties } = await this.getSchema(this.buildId);
       for (const [
         key,
         value,
@@ -85,27 +131,64 @@ export default {
   },
   async additionalProps() {
     const props = {};
-    if (this.actorId) {
-      const {
-        properties, required: requiredProps = [],
-      } = await this.getSchema();
+    if (this.buildId) {
+      try {
+        const {
+          properties, required: requiredProps = [],
+        } = await this.getSchema(this.buildId);
 
-      for (const [
-        key,
-        value,
-      ] of Object.entries(properties)) {
-        if (value.editor === "hidden") continue;
+        for (const [
+          key,
+          value,
+        ] of Object.entries(properties)) {
+          if (value.editor === "hidden") continue;
 
-        props[key] = {
-          type: this.getType(value.type),
-          label: value.title,
-          description: value.description,
-          optional: !requiredProps.includes(key),
+          props[key] = {
+            type: this.getType(value.type),
+            label: value.title,
+            description: value.description,
+            optional: !requiredProps.includes(key),
+          };
+          const options = this.prepareOptions(value);
+          if (options) props[key].options = options;
+          if (value.default) {
+            props[key].description += ` Default: \`${JSON.stringify(value.default)}\``;
+            if (props[key].type !== "object") { // default values don't work properly for object props
+              props[key].default = value.default;
+            }
+          }
+        }
+      } catch {
+        props.properties = {
+          type: "object",
+          label: "Properties",
+          description: "Properties to set for this actor",
+        };
+      }
+      if (this.runAsynchronously) {
+        props.outputRecordKey = {
+          type: "string",
+          label: "Output Record Key",
+          description: "Key of the record from run's default key-value store to be returned in the response. By default, it is OUTPUT.",
+          optional: true,
+        };
+      } else {
+        props.waitForFinish = {
+          type: "string",
+          label: "Wait For Finish",
+          description: "The maximum number of seconds the server waits for the run to finish. By default, it is 0, the maximum value is 60. If the build finishes in time then the returned run object will have a terminal status (e.g. SUCCEEDED), otherwise it will have a transitional status (e.g. RUNNING).",
+          optional: true,
         };
-        const options = this.prepareOptions(value);
-        if (options) props[key].options = options;
       }
     }
+    if (this.webhook) {
+      props.eventTypes = {
+        type: "string[]",
+        label: "Event Types",
+        description: "The types of events to send to the webhook",
+        options: EVENT_TYPES,
+      };
+    }
     return props;
   },
   async run({ $ }) {
@@ -117,14 +200,50 @@ export default {
       prepareData,
       apify,
       actorId,
+      buildId,
+      properties,
+      runAsynchronously,
+      outputRecordKey,
+      timeout,
+      memory,
+      maxItems,
+      maxTotalChargeUsd,
+      waitForFinish,
+      webhook,
+      eventTypes,
       ...data
     } = this;
 
-    const response = await apify.runActor({
+    const fn = runAsynchronously
+      ? apify.runActorAsynchronously
+      : apify.runActor;
+
+    const response = await fn({
       actorId,
-      data: await prepareData(data),
+      data: properties
+        ? parseObject(properties)
+        : await prepareData(data),
+      params: {
+        outputRecordKey,
+        timeout,
+        memory,
+        maxItems,
+        maxTotalChargeUsd,
+        waitForFinish,
+        webhooks: webhook
+          ? btoa(JSON.stringify([
+            {
+              eventTypes,
+              requestUrl: webhook,
+            },
+          ]))
+          : undefined,
+      },
     });
-    $.export("$summary", `Successfully started actor run with ID: ${response.data.id}`);
+    const summary = this.runAsynchronously
+      ? `Successfully started actor run with ID: ${response.data.id}`
+      : `Successfully ran actor with ID: ${this.actorId}`;
+    $.export("$summary", `${summary}`);
     return response;
   },
 };

components/apify/actions/run-task-synchronously/run-task-synchronously.mjs

@@ -4,7 +4,7 @@ export default {
   key: "apify-run-task-synchronously",
   name: "Run Task Synchronously",
   description: "Run a specific task and return its dataset items. [See the documentation](https://docs.apify.com/api/v2/actor-task-run-sync-get-dataset-items-get)",
-  version: "0.0.1",
+  version: "0.0.2",
   type: "action",
   props: {
     apify,

components/apify/actions/scrape-single-url/scrape-single-url.mjs

@@ -5,7 +5,7 @@ export default {
   key: "apify-scrape-single-url",
   name: "Scrape Single URL",
   description: "Executes a scraper on a specific website and returns its content as text. This action is perfect for extracting content from a single page.",
-  version: "0.0.2",
+  version: "0.0.3",
   type: "action",
   props: {
     apify,

components/apify/actions/set-key-value-store-record/set-key-value-store-record.mjs

@@ -5,7 +5,7 @@ export default {
   key: "apify-set-key-value-store-record",
   name: "Set Key-Value Store Record",
   description: "Create or update a record in the key-value store of Apify. [See the documentation](https://docs.apify.com/api/v2#/reference/key-value-stores/record-collection/put-record)",
-  version: "0.0.2",
+  version: "0.0.3",
   type: "action",
   props: {
     apify,