updates

Author: michelle0927

components/dataforseo/actions/get-tripadvisor-reviews/get-tripadvisor-reviews.mjs

@@ -14,17 +14,26 @@ export default {
       label: "Keyword",
       description: "The keyword to search for",
     },
+    countryCode: {
+      type: "string",
+      label: "Country Code",
+      description: "The country code of the target location. Ex: `US`",
+    },
     locationCode: {
       propDefinition: [
         dataforseo,
-        "locationCode",
+        "tripAdvisorLocationCode",
+        (c) => ({
+          countryCode: c.countryCode,
+        }),
       ],
     },
     languageCode: {
       propDefinition: [
         dataforseo,
         "languageCode",
       ],
+      optional: true,
     },
     sortBy: {
       type: "string",
@@ -36,26 +45,58 @@ export default {
       ],
       optional: true,
     },
+    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.getTripadvisorReviews({
-      $,
-      data: [
-        {
-          keyword: this.keyword,
-          location_code: this.locationCode,
-          language_code: this.languageCode,
-          sort_by: this.sortBy,
-        },
-      ],
-    });
+    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.getTripadvisorReviews({
+        $,
+        data: [
+          {
+            keyword: this.keyword,
+            location_code: this.locationCode,
+            language_code: this.languageCode,
+            sort_by: this.sortBy,
+            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 retrieved TripAdvisor reviews for "${this.keyword}".`);

components/dataforseo/dataforseo.app.mjs

@@ -20,6 +20,23 @@ export default {
         }));
       },
     },
+    tripAdvisorLocationCode: {
+      type: "integer",
+      label: "Location Code",
+      description: "The code of the target location",
+      async options({ countryCode }) {
+        const response = await this.getTripadvisorLocations({
+          countryCode,
+        });
+        const locationCodes = response.tasks[0].result;
+        return locationCodes?.map(({
+          location_name, location_code,
+        }) => ({
+          value: location_code,
+          label: location_name,
+        })) || [];
+      },
+    },
     locationCoordinate: {
       type: "string",
       label: "Location Coordinate",
@@ -247,6 +264,14 @@ export default {
         ...args,
       });
     },
+    getTripadvisorLocations({
+      countryCode, ...args
+    }) {
+      return this._makeRequest({
+        path: `/business_data/tripadvisor/locations/${countryCode}`,
+        ...args,
+      });
+    },
     getGoogleAdsLanguages(args = {}) {
       return this._makeRequest({
         path: "/keywords_data/google_ads/languages",