fix: Apify: actor -> Actor, add @apify/consts, tracking headers

components/adtraction/adtraction.app.mjs

@@ -8,4 +8,4 @@ export default {
       console.log(Object.keys(this.$auth));
     },
   },
-};
+};

components/apify/README.md

@@ -6,7 +6,7 @@ The Apify API unleashes the power to automate web scraping, process data, and or
 
 **E-commerce Price Monitoring**
 
-- Set up a Pipedream workflow that triggers an Apify actor to scrape product prices from multiple e-commerce sites daily. Store this data in Pipedream's built-in data store and use the Pipedream Email API to send a daily digest of the best deals to subscribers.
+- Set up a Pipedream workflow that triggers an Apify Actor to scrape product prices from multiple e-commerce sites daily. Store this data in Pipedream's built-in data store and use the Pipedream Email API to send a daily digest of the best deals to subscribers.
 
 **Social Media Sentiment Analysis**
 

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.2",
+  version: "0.0.3",
   type: "action",
   props: {
     apify,

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

@@ -6,8 +6,8 @@ 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.3",
+  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.4",
   type: "action",
   props: {
     apify,
@@ -30,7 +30,7 @@ export default {
     runAsynchronously: {
       type: "boolean",
       label: "Run Asynchronously",
-      description: "Set to `true` to run the actor asynchronously",
+      description: "Set to `true` to run the Actor asynchronously",
       reloadProps: true,
     },
     timeout: {
@@ -162,7 +162,7 @@ export default {
         props.properties = {
           type: "object",
           label: "Properties",
-          description: "Properties to set for this actor",
+          description: "Properties to set for this Actor",
         };
       }
       if (this.runAsynchronously) {
@@ -241,8 +241,8 @@ export default {
       },
     });
     const summary = this.runAsynchronously
-      ? `Successfully started actor run with ID: ${response.data.id}`
-      : `Successfully ran actor with ID: ${this.actorId}`;
+      ? `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.2",
+  version: "0.0.3",
   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.3",
+  version: "0.0.4",
   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.3",
+  version: "0.0.4",
   type: "action",
   props: {
     apify,

components/apify/apify.app.mjs

@@ -1,4 +1,5 @@
 import { axios } from "@pipedream/platform";
+import { ApifyClient } from "apify-client";
 import { LIMIT } from "./common/constants.mjs";
 
 export default {
@@ -49,7 +50,7 @@ export default {
     userActorId: {
       type: "string",
       label: "Actor ID",
-      description: "The ID of the actor to monitor.",
+      description: "The ID of the Actor to monitor.",
       async options({ page }) {
         const { data: { items } } = await this.listUserActors({
           params: {
@@ -162,6 +163,7 @@ export default {
       return {
         "Content-Type": "application/json",
         "Authorization": `Bearer ${this.$auth.api_token}`,
+        "x-apify-integration-platform": "pipedream",
       };
     },
     _makeRequest({

components/apify/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@pipedream/apify",
-  "version": "0.2.1",
+  "version": "0.2.2",
   "description": "Pipedream Apify Components",
   "main": "apify.app.mjs",
   "keywords": [
@@ -13,6 +13,7 @@
     "access": "public"
   },
   "dependencies": {
+    "@apify/consts": "^2.41.0",
     "@pipedream/platform": "^3.0.3"
   }
 }

components/apify/sources/common/base.mjs

@@ -1,3 +1,4 @@
+import { WEBHOOK_EVENT_TYPES } from '@apify/consts';
 import apify from "../../apify.app.mjs";
 
 export default {
@@ -15,10 +16,10 @@ export default {
         data: {
           requestUrl: this.http.endpoint,
           eventTypes: [
-            "ACTOR.RUN.SUCCEEDED",
-            "ACTOR.RUN.FAILED",
-            "ACTOR.RUN.TIMED_OUT",
-            "ACTOR.RUN.ABORTED",
+            WEBHOOK_EVENT_TYPES.ACTOR_RUN_SUCCEEDED,
+            WEBHOOK_EVENT_TYPES.ACTOR_RUN_FAILED,
+            WEBHOOK_EVENT_TYPES.ACTOR_RUN_TIMED_OUT,
+            WEBHOOK_EVENT_TYPES.ACTOR_RUN_ABORTED,
           ],
           condition: this.getCondition(),
         },
@@ -36,7 +37,7 @@ export default {
     });
 
     this.$emit(body, {
-      summary: body.eventType === "TEST"
+      summary: body.eventType === WEBHOOK_EVENT_TYPES.TEST
         ? "Webhook test has successfully triggered!"
         : this.getSummary(body),
       id: body.eventData.actorRunId || `${body.userId}-${body.createAt}`,

components/apify/sources/new-finished-actor-run-instant/new-finished-actor-run-instant.mjs

@@ -5,8 +5,8 @@ export default {
   ...common,
   key: "apify-new-finished-actor-run-instant",
   name: "New Finished Actor Run (Instant)",
-  description: "Emit new event when a selected actor is run and finishes.",
-  version: "0.0.3",
+  description: "Emit new event when a selected Actor is run and finishes.",
+  version: "0.0.4",
   type: "source",
   dedupe: "unique",
   props: {
@@ -27,7 +27,7 @@ export default {
       };
     },
     getSummary(body) {
-      return `A new actor run ${body.eventData.actorRunId} has finished`;
+      return `A new Actor run ${body.eventData.actorRunId} has finished`;
     },
   },
   sampleEmit,

components/apify/sources/new-finished-task-run-instant/new-finished-task-run-instant.mjs

@@ -6,7 +6,7 @@ export default {
   key: "apify-new-finished-task-run-instant",
   name: "New Finished Task Run (Instant)",
   description: "Emit new event when a selected task is run and finishes.",
-  version: "0.0.3",
+  version: "0.0.4",
   type: "source",
   dedupe: "unique",
   props: {

components/asters/asters.app.mjs

@@ -8,4 +8,4 @@ export default {
       console.log(Object.keys(this.$auth));
     },
   },
-};
+};

components/bitget/bitget.app.mjs

@@ -8,4 +8,4 @@ export default {
       console.log(Object.keys(this.$auth));
     },
   },
-};
+};

components/explorium/explorium.app.mjs

@@ -8,4 +8,4 @@ export default {
       console.log(Object.keys(this.$auth));
     },
   },
-};
+};

components/joggai/joggai.app.mjs

@@ -8,4 +8,4 @@ export default {
       console.log(Object.keys(this.$auth));
     },
   },
-};
+};

components/mumble/mumble.app.mjs

@@ -8,4 +8,4 @@ export default {
       console.log(Object.keys(this.$auth));
     },
   },
-};
+};

components/neetoform/neetoform.app.mjs

@@ -8,4 +8,4 @@ export default {
       console.log(Object.keys(this.$auth));
     },
   },
-};
+};

components/order_sender/order_sender.app.mjs

@@ -8,4 +8,4 @@ export default {
       console.log(Object.keys(this.$auth));
     },
   },
-};
+};

components/pinghome/pinghome.app.mjs

@@ -8,4 +8,4 @@ export default {
       console.log(Object.keys(this.$auth));
     },
   },
-};
+};

components/prepr_graphql/prepr_graphql.app.mjs

@@ -8,4 +8,4 @@ export default {
       console.log(Object.keys(this.$auth));
     },
   },
-};
+};

components/prodatakey/prodatakey.app.mjs

@@ -8,4 +8,4 @@ export default {
       console.log(Object.keys(this.$auth));
     },
   },
-};
+};

components/salesforge/salesforge.app.mjs

@@ -8,4 +8,4 @@ export default {
       console.log(Object.keys(this.$auth));
     },
   },
-};
+};

components/sign_plus/sign_plus.app.mjs

@@ -8,4 +8,4 @@ export default {
       console.log(Object.keys(this.$auth));
     },
   },
-};
+};

components/themarketer/themarketer.app.mjs

@@ -8,4 +8,4 @@ export default {
       console.log(Object.keys(this.$auth));
     },
   },
-};
+};

components/vincario/vincario.app.mjs

@@ -8,4 +8,4 @@ export default {
       console.log(Object.keys(this.$auth));
     },
   },
-};
+};

components/zenedu/zenedu.app.mjs

@@ -8,4 +8,4 @@ export default {
       console.log(Object.keys(this.$auth));
     },
   },
-};
+};