trustpilot fixes

Author: Afstkla

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

@@ -14,6 +14,18 @@ export default {
         "businessUnitId",
       ],
     },
+    sku: {
+      propDefinition: [
+        trustpilot,
+        "sku",
+      ],
+    },
+    productUrl: {
+      propDefinition: [
+        trustpilot,
+        "productUrl",
+      ],
+    },
     stars: {
       propDefinition: [
         trustpilot,
@@ -62,6 +74,8 @@ export default {
   async run({ $ }) {
     const {
       businessUnitId,
+      sku,
+      productUrl,
       stars,
       sortBy,
       limit,
@@ -74,6 +88,8 @@ export default {
     try {
       const result = await this.trustpilot.getProductReviews({
         businessUnitId,
+        sku,
+        productUrl,
         stars,
         sortBy,
         limit,

components/trustpilot/common/constants.mjs

@@ -11,7 +11,7 @@ export const WEBHOOK_EVENTS = {
 
 export const ENDPOINTS = {
   // Business Units
-  BUSINESS_UNITS: "/business-units",
+  BUSINESS_UNITS: "/business-units/search",
   BUSINESS_UNIT_BY_ID: "/business-units/{businessUnitId}",
 
   // Public Reviews

components/trustpilot/trustpilot.app.mjs

@@ -31,11 +31,11 @@ export default defineApp({
       type: "string",
       label: "Business Unit ID",
       description: "The unique identifier for your business unit on Trustpilot",
-      async options() {
+      async options(page, prevContext, query) {
         try {
           const businessUnits = await this.searchBusinessUnits({
-            query: "",
-            limit: 20,
+            query,
+            page,
           });
           return businessUnits.map(({
             id, displayName, name: { identifying },
@@ -54,6 +54,18 @@ export default defineApp({
       label: "Review ID",
       description: "The unique identifier for a review",
     },
+    sku: {
+      type: "string",
+      label: "SKU",
+      description: "Filter by SKU",
+      optional: true,
+    },
+    productUrl: {
+      type: "string",
+      label: "Product URL",
+      description: "Filter by product URL",
+      optional: true,
+    },
     stars: {
       type: "integer",
       label: "Star Rating",
@@ -106,25 +118,50 @@ export default defineApp({
   },
   methods: {
     // Authentication and base request methods
-    _getAuthHeaders() {
+    _isPrivateURL(url) {
+      return url.includes("private");
+    },
+
+    _getAuthHeadersForPrivateURL() {
+      if (!this.$auth?.oauth_access_token) {
+        throw new Error("Authentication required: OAuth token is required for private requests");
+      } else {
+        return {
+          "Authorization": `Bearer ${this.$auth.oauth_access_token}`,
+        };
+      }
+    },
+
+    _getAuthHeadersForPublicURL() {
+      if (!this.$auth?.api_key) {
+        throw new Error("Authentication required: API key is required for public requests");
+      } else {
+        return {
+          "apikey": this.$auth.api_key,
+        };
+      }
+    },
+
+    _getAuthHeaders(url) {
       const headers = {
         "Content-Type": "application/json",
         "User-Agent": "Pipedream/1.0",
       };
 
-      if (!this.$auth?.api_key && !this.$auth?.oauth_access_token) {
-        throw new Error("Authentication required: Configure either API key or OAuth token");
-      }
-
-      if (this.$auth?.api_key) {
-        headers["apikey"] = this.$auth.api_key;
-      }
+      const isPrivate = this._isPrivateURL(url);
+      console.log("isPrivate", isPrivate);
 
-      if (this.$auth?.oauth_access_token) {
-        headers["Authorization"] = `Bearer ${this.$auth.oauth_access_token}`;
+      if (isPrivate) {
+        return {
+          ...headers,
+          ...this._getAuthHeadersForPrivateURL(),
+        };
+      } else {
+        return {
+          ...headers,
+          ...this._getAuthHeadersForPublicURL(),
+        };
       }
-
-      return headers;
     },
 
     async _makeRequest({
@@ -182,14 +219,13 @@ export default defineApp({
     },
 
     async searchBusinessUnits({
-      query = "", limit = DEFAULT_LIMIT, offset = 0,
+      query = "", page = 1,
     } = {}) {
       const response = await this._makeRequest({
         endpoint: ENDPOINTS.BUSINESS_UNITS,
         params: {
           query,
-          limit,
-          offset,
+          page,
         },
       });
 
@@ -265,6 +301,8 @@ export default defineApp({
     async _getReviews({
       endpoint,
       businessUnitId,
+      sku = null,
+      productUrl = null,
       stars = null,
       sortBy = SORT_OPTIONS.CREATED_AT_DESC,
       limit = DEFAULT_LIMIT,
@@ -277,7 +315,13 @@ export default defineApp({
         throw new Error("Invalid business unit ID");
       }
 
+      if (sku === null && productUrl === null) {
+        throw new Error("Either SKU or product URL is required");
+      }
+
       const params = {
+        sku,
+        productUrl,
         stars,
         orderBy: sortBy,
         perPage: limit,