updates

michelle0927 · michelle0927 · commit 9d5b80dfc03f · 2025-08-20T13:45:23.000-04:00
diff --git a/components/dataforseo/actions/get-app-intersection/get-app-intersection.mjs b/components/dataforseo/actions/get-app-intersection/get-app-intersection.mjs
@@ -1,5 +1,6 @@
 import dataforseo from "../../dataforseo.app.mjs";
 import { ConfigurationError } from "@pipedream/platform";
+import { parseArray } from "../../common/utils.mjs";
 
 export default {
   key: "dataforseo-get-app-intersection",
@@ -35,8 +36,10 @@ export default {
   },
   async run({ $ }) {
     const appIds = {};
-    for (let i = 0; i < this.appIds.length; i++) {
-      appIds[`${i + 1}`] = this.appIds[i];
+    const parsedAppIds = parseArray(this.appIds);
+
+    for (let i = 0; i < parsedAppIds.length; i++) {
+      appIds[`${i + 1}`] = parsedAppIds[i];
     }
 
     const response = await this.dataforseo.getAppIntersection({
diff --git a/components/dataforseo/actions/get-app-reviews-summary/get-app-reviews-summary.mjs b/components/dataforseo/actions/get-app-reviews-summary/get-app-reviews-summary.mjs
@@ -4,15 +4,15 @@ import { ConfigurationError } from "@pipedream/platform";
 export default {
   key: "dataforseo-get-app-reviews-summary",
   name: "Get App Reviews Summary",
-  description: "Get app reviews and ratings summary for mobile app reputation analysis. [See the documentation](https://docs.dataforseo.com/v3/app_data/apple/app_reviews/live/?bash)",
+  description: "Get app reviews and ratings summary for mobile app reputation analysis. [See the documentation](https://docs.dataforseo.com/v3/app_data/apple/app_reviews/task_post/?bash)",
   version: "0.0.1",
   type: "action",
   props: {
     dataforseo,
     appId: {
       type: "string",
       label: "App ID",
-      description: "App ID or package name for the mobile app",
+      description: "The ID of the mobile application on App Store. Yyou can find the ID in the URL of every app listed on App Store. Example: in the URL https://apps.apple.com/us/app/id835599320, the id is `835599320`",
     },
     locationCode: {
       propDefinition: [
diff --git a/components/dataforseo/actions/get-app-store-search/get-app-store-search.mjs b/components/dataforseo/actions/get-app-store-search/get-app-store-search.mjs
@@ -4,7 +4,7 @@ import { ConfigurationError } from "@pipedream/platform";
 export default {
   key: "dataforseo-get-app-store-search",
   name: "Get App Store Search",
-  description: "Search iOS App Store apps by keywords for app store optimization (ASO) analysis. [See the documentation](https://docs.dataforseo.com/v3/app_data/apple/app_searches/live/?bash)",
+  description: "Search iOS App Store apps by keywords for app store optimization (ASO) analysis. [See the documentation](https://docs.dataforseo.com/v3/app_data/apple/app_searches/task_post/?bash)",
   version: "0.0.1",
   type: "action",
   props: {
@@ -26,25 +26,57 @@ export default {
         "languageCode",
       ],
     },
+    waitForResults: {
+      type: "boolean",
+      label: "Wait for Results",
+      description: "Wait for the results to be available. Not for use with Pipedream Connect.",
+      default: true,
+      optional: true,
+    },
+    postbackUrl: {
+      type: "string",
+      label: "Postback URL",
+      description: "The URL to receive the search results. Only applicable when \"Wait for Results\" = `FALSE`",
+      optional: true,
+    },
   },
   async run({ $ }) {
-    const response = await this.dataforseo.getAppStoreSearch({
-      $,
-      data: [
-        {
-          keyword: this.keyword,
-          location_code: this.locationCode,
-          language_code: this.languageCode,
-        },
-      ],
-    });
+    let response;
+    const context = $.context;
+    const run = context
+      ? context.run
+      : {
+        runs: 1,
+      };
+
+    if (run.runs === 1) {
+      let postbackUrl  = this.postbackUrl;
+      if (context && this.waitForResults) {
+        ({ resume_url: postbackUrl } = $.flow.rerun(600000, null, 1));
+      }
+      response = await this.dataforseo.getAppStoreSearch({
+        $,
+        data: [
+          {
+            keyword: this.keyword,
+            location_code: this.locationCode,
+            language_code: this.languageCode,
+            postback_url: postbackUrl,
+          },
+        ],
+      });
+
+      if (response.status_code !== 20000) {
+        throw new ConfigurationError(`Error: ${response.status_message}`);
+      }
 
-    if (response.status_code !== 20000) {
-      throw new ConfigurationError(`Error: ${response.status_message}`);
+      if (response.tasks[0].status_code !== 20000 && response.tasks[0].status_code !== 20100) {
+        throw new ConfigurationError(`Error: ${response.tasks[0].status_message}`);
+      }
     }
 
-    if (response.tasks[0].status_code !== 20000 && response.tasks[0].status_code !== 20100) {
-      throw new ConfigurationError(`Error: ${response.tasks[0].status_message}`);
+    if (run.runs > 1) {
+      response = run.callback_request.body;
     }
 
     $.export("$summary", `Successfully searched App Store for "${this.keyword}".`);
diff --git a/components/dataforseo/actions/get-bing-organic-results/get-bing-organic-results.mjs b/components/dataforseo/actions/get-bing-organic-results/get-bing-organic-results.mjs
@@ -4,7 +4,7 @@ import { ConfigurationError } from "@pipedream/platform";
 export default {
   key: "dataforseo-get-bing-organic-results",
   name: "Get Bing Organic Results",
-  description: "Retrieve Bing organic search results for specified keywords. [See the documentation](https://docs.dataforseo.com/v3/serp/bing/organic/live/?bash)",
+  description: "Retrieve Bing organic search results for specified keywords. [See the documentation](https://docs.dataforseo.com/v3/serp/bing/organic/live/regular/?bash)",
   version: "0.0.1",
   type: "action",
   props: {
diff --git a/components/dataforseo/actions/get-google-images-results/get-google-images-results.mjs b/components/dataforseo/actions/get-google-images-results/get-google-images-results.mjs
@@ -4,7 +4,7 @@ import { ConfigurationError } from "@pipedream/platform";
 export default {
   key: "dataforseo-get-google-images-results",
   name: "Get Google Images Results",
-  description: "Retrieve Google Images search results for specified keywords. [See the documentation](https://docs.dataforseo.com/v3/serp/google/images/live/?bash)",
+  description: "Retrieve Google Images search results for specified keywords. [See the documentation](https://docs.dataforseo.com/v3/serp/google/images/live/advanced/?bash)",
   version: "0.0.1",
   type: "action",
   props: {
diff --git a/components/dataforseo/actions/get-google-my-business-info/get-google-my-business-info.mjs b/components/dataforseo/actions/get-google-my-business-info/get-google-my-business-info.mjs
@@ -4,7 +4,7 @@ import { ConfigurationError } from "@pipedream/platform";
 export default {
   key: "dataforseo-get-google-my-business-info",
   name: "Get Google My Business Info",
-  description: "Get detailed Google My Business listing information for local SEO analysis. [See the documentation](https://docs.dataforseo.com/v3/business_data/google/my_business/info/live/?bash)",
+  description: "Get detailed Google My Business listing information for local SEO analysis. [See the documentation](https://docs.dataforseo.com/v3/business_data/google/my_business_info/live/?bash)",
   version: "0.0.1",
   type: "action",
   props: {
diff --git a/components/dataforseo/actions/get-google-news-results/get-google-news-results.mjs b/components/dataforseo/actions/get-google-news-results/get-google-news-results.mjs
@@ -4,7 +4,7 @@ import { ConfigurationError } from "@pipedream/platform";
 export default {
   key: "dataforseo-get-google-news-results",
   name: "Get Google News Results",
-  description: "Retrieve Google News search results for specified keywords. [See the documentation](https://docs.dataforseo.com/v3/serp/google/news/live/?bash)",
+  description: "Retrieve Google News search results for specified keywords. [See the documentation](https://docs.dataforseo.com/v3/serp/google/news/live/advanced/?bash)",
   version: "0.0.1",
   type: "action",
   props: {
diff --git a/components/dataforseo/actions/get-google-organic-results/get-google-organic-results.mjs b/components/dataforseo/actions/get-google-organic-results/get-google-organic-results.mjs
@@ -4,7 +4,7 @@ import { ConfigurationError } from "@pipedream/platform";
 export default {
   key: "dataforseo-get-google-organic-results",
   name: "Get Google Organic Results",
-  description: "Retrieve Google organic search results for specified keywords. [See the documentation](https://docs.dataforseo.com/v3/serp/google/organic/live/?bash)",
+  description: "Retrieve Google organic search results for specified keywords. [See the documentation](https://docs.dataforseo.com/v3/serp/google/organic/live/regular/?bash)",
   version: "0.0.1",
   type: "action",
   props: {
diff --git a/components/dataforseo/actions/get-google-play-search/get-google-play-search.mjs b/components/dataforseo/actions/get-google-play-search/get-google-play-search.mjs
@@ -4,7 +4,7 @@ import { ConfigurationError } from "@pipedream/platform";
 export default {
   key: "dataforseo-get-google-play-search",
   name: "Get Google Play Search",
-  description: "Search Google Play Store apps by keywords for app store optimization (ASO) analysis. [See the documentation](https://docs.dataforseo.com/v3/app_data/google/app_searches/live/?bash)",
+  description: "Search Google Play Store apps by keywords for app store optimization (ASO) analysis. [See the documentation](https://docs.dataforseo.com/v3/app_data/google/app_searches/task_post/?bash)",
   version: "0.0.1",
   type: "action",
   props: {
@@ -43,7 +43,7 @@ export default {
       throw new ConfigurationError(`Error: ${response.status_message}`);
     }
 
-    if (response.tasks[0].status_code !== 20000) {
+    if (response.tasks[0].status_code !== 20000 && response.tasks[0].status_code !== 20100) {
       throw new ConfigurationError(`Error: ${response.tasks[0].status_message}`);
     }
 
diff --git a/components/dataforseo/actions/get-google-reviews/get-google-reviews.mjs b/components/dataforseo/actions/get-google-reviews/get-google-reviews.mjs
@@ -4,7 +4,7 @@ import { ConfigurationError } from "@pipedream/platform";
 export default {
   key: "dataforseo-get-google-reviews",
   name: "Get Google Reviews",
-  description: "Get Google business reviews and ratings for local SEO and reputation management. [See the documentation](https://docs.dataforseo.com/v3/business_data/google/reviews/live/?bash)",
+  description: "Get Google business reviews and ratings for local SEO and reputation management. [See the documentation](https://docs.dataforseo.com/v3/business_data/google/reviews/task_post/?bash)",
   version: "0.0.1",
   type: "action",
   props: {
@@ -43,7 +43,7 @@ export default {
       throw new ConfigurationError(`Error: ${response.status_message}`);
     }
 
-    if (response.tasks[0].status_code !== 20000) {
+    if (response.tasks[0].status_code !== 20000 && response.tasks[0].status_code !== 20100) {
       throw new ConfigurationError(`Error: ${response.tasks[0].status_message}`);
     }
 
diff --git a/components/dataforseo/actions/get-keyword-data-errors/get-keyword-data-errors.mjs b/components/dataforseo/actions/get-keyword-data-errors/get-keyword-data-errors.mjs
@@ -26,7 +26,32 @@ export default {
       ],
     },
   },
+  methods: {
+    validateDateRange(dateTimeFrom, dateTimeTo) {
+      const from = new Date(dateTimeFrom);
+      const to = new Date(dateTimeTo);
+      const now = new Date();
+
+      if (isNaN(from) || isNaN(to)) {
+        throw new ConfigurationError("Invalid date format. Use yyyy-mm-dd hh:mm:ss +00:00");
+      }
+
+      if (from >= to) {
+        throw new ConfigurationError("DateTimeFrom must be before DateTimeTo");
+      }
+
+      const sevenDaysAgo = new Date(now.getTime() - 7 * 24 * 60 * 60 * 1000);
+      if (from < sevenDaysAgo || from > now) {
+        throw new ConfigurationError("DateTimeFrom must be within the last 7 days");
+      }
+      if (to < sevenDaysAgo || to > now) {
+        throw new ConfigurationError("DateTimeTo must be within the last 7 days");
+      }
+    },
+  },
   async run({ $ }) {
+    this.validateDateRange(this.dateTimeFrom, this.dateTimeTo);
+
     const response = await this.dataforseo.getKeywordDataErrors({
       $,
       data: [
diff --git a/components/dataforseo/actions/get-keyword-data-id-list/get-keyword-data-id-list.mjs b/components/dataforseo/actions/get-keyword-data-id-list/get-keyword-data-id-list.mjs
@@ -12,7 +12,7 @@ export default {
     dateTimeFrom: {
       type: "string",
       label: "Date Time From",
-      description: "The start time for filtering results in the format \"yyyy-mm-dd hh-mm-ss +00:00\". Example: `2023-01-15 12:57:46 +00:00`. If include_metadata is set to true, maximum value: a month from current datetime. If include_metadata is set to false, maximum value: six months from current datetime",
+      description: "The start time for filtering results in the format \"yyyy-mm-dd hh-mm-ss +00:00\". Example: `2023-01-15 12:57:46 +00:00`. If include_metadata is set to true, minimum value: a month before the current datetime. If include_metadata is set to false, minimum value: six months before the current datetime",
     },
     dateTimeTo: {
       type: "string",
@@ -42,7 +42,33 @@ export default {
       ],
     },
   },
+  methods: {
+    validateDateRange(dateTimeFrom, dateTimeTo, includeMetadata) {
+      const from = new Date(dateTimeFrom);
+      const to = new Date(dateTimeTo);
+
+      if (isNaN(from) || isNaN(to)) {
+        throw new ConfigurationError("Invalid date format. Use yyyy-mm-dd hh:mm:ss +00:00");
+      }
+
+      if (from >= to) {
+        throw new ConfigurationError("DateTimeFrom must be before DateTimeTo");
+      }
+
+      const monthsBack = includeMetadata
+        ? 1
+        : 6;
+      const minDate = new Date();
+      minDate.setMonth(minDate.getMonth() - monthsBack);
+
+      if (from < minDate) {
+        throw new ConfigurationError(`DateTimeFrom must not be earlier than ${monthsBack} month(s) ago`);
+      }
+    },
+  },
   async run({ $ }) {
+    this.validateDateRange(this.dateTimeFrom, this.dateTimeTo, this.includeMetadata);
+
     const response = await this.dataforseo.getKeywordDataIdList({
       $,
       data: [
diff --git a/components/dataforseo/actions/get-sentiment-analysis/get-sentiment-analysis.mjs b/components/dataforseo/actions/get-sentiment-analysis/get-sentiment-analysis.mjs
@@ -4,7 +4,7 @@ import { ConfigurationError } from "@pipedream/platform";
 export default {
   key: "dataforseo-get-sentiment-analysis",
   name: "Get Sentiment Analysis",
-  description: "Analyze sentiment of brand mentions and content for reputation management. [See the documentation](https://docs.dataforseo.com/v3/content_analysis/sentiment/live/?bash)",
+  description: "Analyze sentiment of brand mentions and content for reputation management. [See the documentation](https://docs.dataforseo.com/v3/content_analysis/sentiment_analysis/live/?bash)",
   version: "0.0.1",
   type: "action",
   props: {
diff --git a/components/dataforseo/actions/get-tripadvisor-reviews/get-tripadvisor-reviews.mjs b/components/dataforseo/actions/get-tripadvisor-reviews/get-tripadvisor-reviews.mjs
@@ -4,7 +4,7 @@ import { ConfigurationError } from "@pipedream/platform";
 export default {
   key: "dataforseo-get-tripadvisor-reviews",
   name: "Get TripAdvisor Reviews",
-  description: "Get TripAdvisor business reviews and ratings, especially useful for hospitality businesses. [See the documentation](https://docs.dataforseo.com/v3/business_data/tripadvisor/reviews/live/?bash)",
+  description: "Get TripAdvisor business reviews and ratings, especially useful for hospitality businesses. [See the documentation](https://docs.dataforseo.com/v3/business_data/tripadvisor/reviews/task_post/?bash)",
   version: "0.0.1",
   type: "action",
   props: {
@@ -54,7 +54,7 @@ export default {
       throw new ConfigurationError(`Error: ${response.status_message}`);
     }
 
-    if (response.tasks[0].status_code !== 20000) {
+    if (response.tasks[0].status_code !== 20000 && response.tasks[0].status_code !== 20100) {
       throw new ConfigurationError(`Error: ${response.tasks[0].status_message}`);
     }
 
diff --git a/components/dataforseo/actions/get-trustpilot-reviews/get-trustpilot-reviews.mjs b/components/dataforseo/actions/get-trustpilot-reviews/get-trustpilot-reviews.mjs
@@ -4,7 +4,7 @@ import { ConfigurationError } from "@pipedream/platform";
 export default {
   key: "dataforseo-get-trustpilot-reviews",
   name: "Get Trustpilot Reviews",
-  description: "Get Trustpilot business reviews and ratings for reputation management. [See the documentation](https://docs.dataforseo.com/v3/business_data/trustpilot/reviews/live/?bash)",
+  description: "Get Trustpilot business reviews and ratings for reputation management. [See the documentation](https://docs.dataforseo.com/v3/business_data/trustpilot/reviews/task_post/?bash)",
   version: "0.0.1",
   type: "action",
   props: {
@@ -40,7 +40,7 @@ export default {
       throw new ConfigurationError(`Error: ${response.status_message}`);
     }
 
-    if (response.tasks[0].status_code !== 20000) {
+    if (response.tasks[0].status_code !== 20000 && response.tasks[0].status_code !== 20100) {
       throw new ConfigurationError(`Error: ${response.tasks[0].status_message}`);
     }
 
diff --git a/components/dataforseo/actions/get-yahoo-organic-results/get-yahoo-organic-results.mjs b/components/dataforseo/actions/get-yahoo-organic-results/get-yahoo-organic-results.mjs
@@ -4,7 +4,7 @@ import { ConfigurationError } from "@pipedream/platform";
 export default {
   key: "dataforseo-get-yahoo-organic-results",
   name: "Get Yahoo Organic Results",
-  description: "Retrieve Yahoo organic search results for specified keywords. [See the documentation](https://docs.dataforseo.com/v3/serp/yahoo/organic/live/?bash)",
+  description: "Retrieve Yahoo organic search results for specified keywords. [See the documentation](https://docs.dataforseo.com/v3/serp/yahoo/organic/live/regular/?bash)",
   version: "0.0.1",
   type: "action",
   props: {
diff --git a/components/dataforseo/common/utils.mjs b/components/dataforseo/common/utils.mjs
@@ -20,3 +20,11 @@ export function parseObjectEntries(value = {}) {
     ]),
   );
 }
+
+export function parseArray(value) {
+  if (!value) return [];
+  if (typeof value === "string") {
+    return JSON.parse(value);
+  }
+  return value;
+}
diff --git a/components/dataforseo/dataforseo.app.mjs b/components/dataforseo/dataforseo.app.mjs
@@ -6,7 +6,7 @@ export default {
   app: "dataforseo",
   propDefinitions: {
     locationCode: {
-      type: "string",
+      type: "integer",
       label: "Location Code",
       description: "The code of the target location",
       async options() {
@@ -419,7 +419,7 @@ export default {
     },
     getGoogleMyBusinessInfo(args = {}) {
       return this._makeRequest({
-        path: "/business_data/google/my_business/info/live",
+        path: "/business_data/google/my_business_info/live",
         method: "post",
         ...args,
       });
@@ -458,6 +458,14 @@ export default {
         ...args,
       });
     },
+    getAppStoreSearchResults({
+      id, ...args
+    }) {
+      return this._makeRequest({
+        path: `/app_data/apple/app_searches/task_get/advanced/${id}`,
+        ...args,
+      });
+    },
     getGooglePlaySearch(args = {}) {
       return this._makeRequest({
         path: "/app_data/google/app_searches/task_post",
