more fixes

Author: Afstkla

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

@@ -3,7 +3,7 @@ import trustpilot from "../../trustpilot.app.mjs";
 export default {
   key: "trustpilot-fetch-service-reviews",
   name: "Fetch Service Reviews",
-  description: "Get private reviews for a business unit, limited to 100,000 records. Response includes customer email and order ID. [See the documentation](https://developers.trustpilot.com/business-units-api#get-private-reviews-for-business-unit)",
+  description: "Get private reviews for a business unit. Response includes customer email and order ID. [See the documentation](https://developers.trustpilot.com/business-units-api#get-private-reviews-for-business-unit)",
   version: "0.1.0",
   type: "action",
   props: {

components/trustpilot/common/constants.mjs

@@ -1,22 +1,8 @@
 export const BASE_URL = "https://api.trustpilot.com/v1";
 
-export const WEBHOOK_EVENTS = {
-  REVIEW_CREATED: "review.created",
-  REVIEW_REVISED: "review.revised",
-  REVIEW_DELETED: "review.deleted",
-  REPLY_CREATED: "reply.created",
-  INVITATION_SENT: "invitation.sent",
-  INVITATION_FAILED: "invitation.failed",
-};
-
 export const ENDPOINTS = {
   // Business Units
   BUSINESS_UNITS: "/business-units/search",
-  BUSINESS_UNIT_BY_ID: "/business-units/{businessUnitId}",
-
-  // Public Reviews
-  PUBLIC_REVIEWS: "/business-units/{businessUnitId}/reviews",
-  PUBLIC_REVIEW_BY_ID: "/reviews/{reviewId}",
 
   // Service Reviews
   SERVICE_REVIEWS: "/private/business-units/{businessUnitId}/reviews",
@@ -29,51 +15,9 @@ export const ENDPOINTS = {
   CREATE_CONVERSATION_FOR_REVIEW: "/private/product-reviews/{reviewId}/create-conversation",
 
   // Conversations
-  CONVERSATIONS: "/private/conversations",
   CONVERSATION_BY_ID: "/private/conversations/{conversationId}",
   REPLY_TO_CONVERSATION: "/private/conversations/{conversationId}/comments",
 };
 
-export const REVIEW_TYPES = {
-  SERVICE: "service",
-  PRODUCT: "product",
-};
-
-export const INVITATION_TYPES = {
-  REVIEW: "review",
-  PRODUCT_REVIEW: "product-review",
-};
-
-export const SORT_OPTIONS = {
-  CREATED_AT_ASC: "createdat.asc",
-  CREATED_AT_DESC: "createdat.desc",
-  STARS_ASC: "stars.asc",
-  STARS_DESC: "stars.desc",
-  UPDATED_AT_ASC: "updatedat.asc",
-  UPDATED_AT_DESC: "updatedat.desc",
-};
-
-export const RATING_SCALE = [
-  1,
-  2,
-  3,
-  4,
-  5,
-];
-
 export const DEFAULT_LIMIT = 20;
 export const MAX_LIMIT = 100;
-
-export const POLLING_CONFIG = {
-  DEFAULT_TIMER_INTERVAL_SECONDS: 15 * 60, // 15 minutes
-  MAX_ITEMS_PER_POLL: 100,
-  LOOKBACK_HOURS: 24, // How far back to look on first run
-};
-
-export const SOURCE_TYPES = {
-  NEW_REVIEWS: "new_reviews",
-  UPDATED_REVIEWS: "updated_reviews",
-  NEW_REPLIES: "new_replies",
-  NEW_CONVERSATIONS: "new_conversations",
-  UPDATED_CONVERSATIONS: "updated_conversations",
-};

components/trustpilot/sources/new-product-reviews/new-product-reviews.mjs

@@ -1,4 +1,5 @@
 import common from "../common/polling.mjs";
+import { DEFAULT_LIMIT } from "../../common/constants.mjs";
 
 export default {
   ...common,
@@ -23,7 +24,7 @@ export default {
       // so we'll rely on pagination and client-side filtering
       return {
         businessUnitId: this.businessUnitId,
-        perPage: 100,
+        perPage: DEFAULT_LIMIT,
         page: 1,
       };
     },

components/trustpilot/sources/new-service-reviews/new-service-reviews.mjs

@@ -1,4 +1,8 @@
 import common from "../common/polling.mjs";
+import {
+  DEFAULT_LIMIT,
+  MAX_LIMIT,
+} from "../../common/constants.mjs";
 
 export default {
   ...common,
@@ -20,7 +24,7 @@ export default {
     getFetchParams(lastReviewTime) {
       const params = {
         businessUnitId: this.businessUnitId,
-        perPage: 100,
+        perPage: DEFAULT_LIMIT,
         orderBy: "createdat.desc",
       };
 
@@ -36,10 +40,17 @@ export default {
       let result = await this.trustpilot.fetchServiceReviews($, params);
 
       // Handle pagination for service reviews
-      while (result.reviews && result.reviews.length === 100) {
-        params.page = (params.page || 1) + 1;
-        const nextResult = await this.trustpilot.fetchServiceReviews($, params);
-        result.reviews = result.reviews.concat(nextResult.reviews || []);
+      if (result.reviews && result.reviews.length === DEFAULT_LIMIT) {
+        while (true) {
+          params.page = (params.page || 1) + 1;
+          const nextResult = await this.trustpilot.fetchServiceReviews($, params);
+          result.reviews = result.reviews.concat(nextResult.reviews || []);
+
+          if ((nextResult.reviews && nextResult.reviews.length < DEFAULT_LIMIT)
+            || result.reviews.length >= MAX_LIMIT) {
+            break;
+          }
+        }
       }
 
       return result;

components/trustpilot/trustpilot.app.mjs

@@ -122,7 +122,14 @@ export default {
 
     // Shared method for fetching service reviews - used by both actions and sources
     async fetchServiceReviews($, params = {}) {
-      const { businessUnitId } = params;
+      const {
+        businessUnitId,
+        page = 1,
+        perPage = 20,
+        orderBy = "createdat.desc",
+        ignoreTagValueCase = false,
+        ...filters
+      } = params;
 
       // Validate required parameters
       if (!businessUnitId) {
@@ -139,11 +146,11 @@ export default {
 
       // Prepare query parameters
       const queryParams = {
-        ...params,
-        page: 1,
-        perPage: 20,
-        orderBy: "createdat.desc",
-        ignoreTagValueCase: false,
+        ...filters,
+        page,
+        perPage,
+        orderBy,
+        ignoreTagValueCase,
       };
 
       // Make the API request