comments

Author: Afstkla

components/trustpilot/actions/fetch-product-review-by-id/fetch-product-review-by-id.mjs

@@ -40,7 +40,7 @@ export default {
       });
 
       // Make the API request
-      const response = await makeRequest(this.trustpilot, {
+      const response = await makeRequest($, this.trustpilot, {
         endpoint,
       });
 

components/trustpilot/actions/fetch-product-reviews/fetch-product-reviews.mjs

@@ -3,8 +3,8 @@ import trustpilot from "../../trustpilot.app.mjs";
 export default {
   key: "trustpilot-fetch-product-reviews",
   name: "Fetch Product Reviews",
-  description: "Retrieves a list of product reviews for a specific business unit.",
-  version: "0.1.0",
+  description: "Retrieves a list of product reviews for a specific business unit. See documentation [here](https://developers.trustpilot.com/product-reviews-api/#get-private-product-reviews)",
+  version: "1.0.0",
   type: "action",
   props: {
     trustpilot,

components/trustpilot/actions/fetch-service-review-by-id/fetch-service-review-by-id.mjs

@@ -40,7 +40,7 @@ export default {
       });
 
       // Make the API request
-      const response = await makeRequest(this.trustpilot, {
+      const response = await makeRequest($, this.trustpilot, {
         endpoint,
       });
 

components/trustpilot/actions/fetch-service-reviews/fetch-service-reviews.mjs

@@ -23,7 +23,7 @@ export default {
     page: {
       type: "integer",
       label: "Page",
-      description: "The page to retrieve. If the page number requested is higher than the available number of pages an empty array will be returned.",
+      description: "The page to retrieve. If the page number requested is higher than the available number of pages, an empty array will be returned.",
       min: 1,
       default: 1,
       optional: true,
@@ -120,13 +120,13 @@ export default {
     startDateTime: {
       type: "string",
       label: "Start Date Time",
-      description: "Filter reviews by datetime range. If no time is specified than time is implicit 00:00:00. Format: 2013-09-07T13:37:00",
+      description: "Filter reviews by datetime range. If no time is specified, then time is implicitly `00:00:00`. Format: `2013-09-07T13:37:00`",
       optional: true,
     },
     endDateTime: {
       type: "string",
       label: "End Date Time",
-      description: "Filter reviews by datetime range. If no time is specified than time is implicit 00:00:00. Format: 2013-09-07T13:37:00",
+      description: "Filter reviews by datetime range. If no time is specified, then time is implicitly `00:00:00`. Format: `2013-09-07T13:37:00`",
       optional: true,
     },
     source: {

components/trustpilot/actions/get-conversation-from-product-review/get-conversation-from-product-review.mjs

@@ -11,7 +11,7 @@ export default {
   key: "trustpilot-get-conversation-from-product-review",
   name: "Get Conversation from Product Review",
   description: "Get conversation and related comments from a product review. First fetches the review to get the conversationId, then retrieves the full conversation details. [See the documentation](https://developers.trustpilot.com/conversations-api#get-conversation)",
-  version: "0.1.0",
+  version: "0.0.1",
   type: "action",
   props: {
     trustpilot,
@@ -33,62 +33,58 @@ export default {
       throw new ConfigurationError("Invalid review ID format");
     }
 
-    try {
-      // Step 1: Get the product review to get the conversationId
-      $.export("$summary", "Fetching product review details...");
+    // Step 1: Get the product review to get the conversationId
+    $.export("$summary", "Fetching product review details...");
 
-      const getReviewEndpoint = buildUrl(ENDPOINTS.PRIVATE_PRODUCT_REVIEW_BY_ID, {
-        reviewId,
-      });
-
-      const review = await makeRequest(this.trustpilot, {
-        endpoint: getReviewEndpoint,
-      });
-
-      const conversationId = review.conversationId;
-
-      if (!conversationId) {
-        return {
-          success: false,
-          message: "No conversation found for this product review",
-          review: {
-            id: reviewId,
-            hasConversation: false,
-          },
-          metadata: {
-            reviewId,
-            requestTime: new Date().toISOString(),
-          },
-        };
-      }
+    const getReviewEndpoint = buildUrl(ENDPOINTS.PRIVATE_PRODUCT_REVIEW_BY_ID, {
+      reviewId,
+    });
 
-      // Step 2: Get the conversation details
-      $.export("$summary", "Fetching conversation details...");
+    const review = await makeRequest($, this.trustpilot, {
+      endpoint: getReviewEndpoint,
+    });
 
-      const getConversationEndpoint = buildUrl(ENDPOINTS.CONVERSATION_BY_ID, {
-        conversationId,
-      });
-
-      const conversation = await makeRequest(this.trustpilot, {
-        endpoint: getConversationEndpoint,
-      });
-
-      $.export("$summary", `Successfully retrieved conversation ${conversationId} for product review ${reviewId}`);
+    const conversationId = review.conversationId;
 
+    if (!conversationId) {
       return {
-        success: true,
-        conversation,
+        success: false,
+        message: "No conversation found for this product review",
+        review: {
+          id: reviewId,
+          hasConversation: false,
+        },
         metadata: {
           reviewId,
-          conversationId,
-          commentCount: conversation.comments?.length || 0,
-          conversationState: conversation.state,
-          source: conversation.source,
           requestTime: new Date().toISOString(),
         },
       };
-    } catch (error) {
-      throw new ConfigurationError(`Failed to get conversation from product review: ${error.message}`);
     }
+
+    // Step 2: Get the conversation details
+    $.export("$summary", "Fetching conversation details...");
+
+    const getConversationEndpoint = buildUrl(ENDPOINTS.CONVERSATION_BY_ID, {
+      conversationId,
+    });
+
+    const conversation = await makeRequest($, this.trustpilot, {
+      endpoint: getConversationEndpoint,
+    });
+
+    $.export("$summary", `Successfully retrieved conversation ${conversationId} for product review ${reviewId}`);
+
+    return {
+      success: true,
+      conversation,
+      metadata: {
+        reviewId,
+        conversationId,
+        commentCount: conversation.comments?.length || 0,
+        conversationState: conversation.state,
+        source: conversation.source,
+        requestTime: new Date().toISOString(),
+      },
+    };
   },
 };

components/trustpilot/actions/reply-to-product-review/reply-to-product-review.mjs

@@ -70,7 +70,7 @@ export default {
         reviewId,
       });
 
-      const review = await makeRequest(this.trustpilot, {
+      const review = await makeRequest($, this.trustpilot, {
         endpoint: getReviewEndpoint,
       });
 
@@ -84,7 +84,7 @@ export default {
           reviewId,
         });
 
-        const createConversationResponse = await makeRequest(this.trustpilot, {
+        const createConversationResponse = await makeRequest($, this.trustpilot, {
           endpoint: createConversationEndpoint,
           method: "POST",
         });
@@ -113,7 +113,7 @@ export default {
         requestData.integrationId = integrationId;
       }
 
-      const replyResponse = await makeRequest(this.trustpilot, {
+      const replyResponse = await makeRequest($, this.trustpilot, {
         endpoint: replyEndpoint,
         method: "POST",
         data: requestData,

components/trustpilot/actions/reply-to-service-review/reply-to-service-review.mjs

@@ -68,7 +68,7 @@ export default {
       };
 
       // Make the API request
-      await makeRequest(this.trustpilot, {
+      await makeRequest($, this.trustpilot, {
         endpoint,
         method: "POST",
         data: requestData,

components/trustpilot/common/api-client.mjs

@@ -1,10 +1,6 @@
 import { axios } from "@pipedream/platform";
-import {
-  BASE_URL, HTTP_STATUS, RETRY_CONFIG,
-} from "./constants.mjs";
-import {
-  formatQueryParams, sleep,
-} from "./utils.mjs";
+import { BASE_URL } from "./constants.mjs";
+import { formatQueryParams } from "./utils.mjs";
 
 /**
  * Make an authenticated request to the Trustpilot API
@@ -16,18 +12,17 @@ import {
  * @param {object} [options.data] - Request body data
  * @param {object} [options.additionalHeaders={}] - Additional headers to include in the request
  * @param {number} [options.timeout=30000] - Request timeout
- * @param {number} [retries=RETRY_CONFIG.MAX_RETRIES] - Number of retries for rate limiting
  * @returns {Promise<object>} API response data
  */
-export async function makeRequest(trustpilotApp, {
+export async function makeRequest($, trustpilotApp, {
   endpoint,
   method = "GET",
   params = {},
   data = null,
   timeout = 30000,
   additionalHeaders = {},
   ...args
-}, retries = RETRY_CONFIG.MAX_RETRIES) {
+}) {
   const url = `${BASE_URL}${endpoint}`;
   const headers = {
     ...getAuthHeaders(trustpilotApp, url),
@@ -47,28 +42,8 @@ export async function makeRequest(trustpilotApp, {
     config.data = data;
   }
 
-  try {
-    const response = await axios(trustpilotApp, config);
-    return response.data || response;
-  } catch (error) {
-    if (retries > 0 && error.response?.status === HTTP_STATUS.TOO_MANY_REQUESTS) {
-      const delay = Math.min(
-        RETRY_CONFIG.INITIAL_DELAY * (RETRY_CONFIG.MAX_RETRIES - retries + 1),
-        RETRY_CONFIG.MAX_DELAY,
-      );
-      await sleep(delay);
-      return makeRequest(trustpilotApp, {
-        endpoint,
-        method,
-        params,
-        data,
-        timeout,
-        additionalHeaders,
-        ...args,
-      }, retries - 1);
-    }
-    throw error;
-  }
+  const response = await axios($ ?? trustpilotApp, config);
+  return response.data || response;
 }
 
 /**

components/trustpilot/common/constants.mjs

@@ -64,24 +64,6 @@ export const RATING_SCALE = [
 export const DEFAULT_LIMIT = 20;
 export const MAX_LIMIT = 100;
 
-export const HTTP_STATUS = {
-  OK: 200,
-  CREATED: 201,
-  NO_CONTENT: 204,
-  BAD_REQUEST: 400,
-  UNAUTHORIZED: 401,
-  FORBIDDEN: 403,
-  NOT_FOUND: 404,
-  TOO_MANY_REQUESTS: 429,
-  INTERNAL_SERVER_ERROR: 500,
-};
-
-export const RETRY_CONFIG = {
-  MAX_RETRIES: 3,
-  INITIAL_DELAY: 1000,
-  MAX_DELAY: 10000,
-};
-
 export const POLLING_CONFIG = {
   DEFAULT_TIMER_INTERVAL_SECONDS: 15 * 60, // 15 minutes
   MAX_ITEMS_PER_POLL: 100,

components/trustpilot/common/utils.mjs

@@ -281,12 +281,3 @@ export function parseApiError(error) {
     code: "UNKNOWN_ERROR",
   };
 }
-
-/**
- * Sleep function for retry logic
- * @param {number} ms - Milliseconds to sleep
- * @returns {Promise} - Promise that resolves after delay
- */
-export function sleep(ms) {
-  return new Promise((resolve) => setTimeout(resolve, ms));
-}