Implement comprehensive Trustpilot webhooks and review management

components/trustpilot/.gitignore

@@ -1,3 +1,2 @@
 *.js
-*.mjs
 dist

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

@@ -0,0 +1,39 @@
+import trustpilot from "../../app/trustpilot.app.ts";
+
+export default {
+  key: "trustpilot-fetch-product-review-by-id",
+  name: "Fetch Product Review by ID",
+  description: "Fetch a specific product review by its ID. [See the documentation](https://developers.trustpilot.com/product-reviews-api#get-private-product-review)",
+  version: "0.0.1",
+  type: "action",
+  props: {
+    trustpilot,
+    reviewId: {
+      propDefinition: [
+        trustpilot,
+        "reviewId",
+      ],
+    },
+  },
+  async run({ $ }) {
+    const { reviewId } = this;
+
+    try {
+      const review = await this.trustpilot.getProductReviewById({
+        reviewId,
+      });
+
+      $.export("$summary", `Successfully fetched product review ${reviewId}`);
+
+      return {
+        review,
+        metadata: {
+          reviewId,
+          requestTime: new Date().toISOString(),
+        },
+      };
+    } catch (error) {
+      throw new Error(`Failed to fetch product review: ${error.message}`);
+    }
+  },
+};

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

@@ -0,0 +1,109 @@
+import trustpilot from "../../app/trustpilot.app.ts";
+
+export default {
+  key: "trustpilot-fetch-product-reviews",
+  name: "Fetch Product Reviews",
+  description: "Fetch product reviews for a business unit. [See the documentation](https://developers.trustpilot.com/product-reviews-api#get-private-product-reviews)",
+  version: "0.0.1",
+  type: "action",
+  props: {
+    trustpilot,
+    businessUnitId: {
+      propDefinition: [
+        trustpilot,
+        "businessUnitId",
+      ],
+    },
+    stars: {
+      propDefinition: [
+        trustpilot,
+        "stars",
+      ],
+    },
+    sortBy: {
+      propDefinition: [
+        trustpilot,
+        "sortBy",
+      ],
+    },
+    limit: {
+      propDefinition: [
+        trustpilot,
+        "limit",
+      ],
+    },
+    includeReportedReviews: {
+      propDefinition: [
+        trustpilot,
+        "includeReportedReviews",
+      ],
+    },
+    tags: {
+      propDefinition: [
+        trustpilot,
+        "tags",
+      ],
+    },
+    language: {
+      propDefinition: [
+        trustpilot,
+        "language",
+      ],
+    },
+    offset: {
+      type: "integer",
+      label: "Offset",
+      description: "Number of results to skip (for pagination)",
+      min: 0,
+      default: 0,
+      optional: true,
+    },
+  },
+  async run({ $ }) {
+    const {
+      businessUnitId,
+      stars,
+      sortBy,
+      limit,
+      includeReportedReviews,
+      tags,
+      language,
+      offset,
+    } = this;
+
+    try {
+      const result = await this.trustpilot.getProductReviews({
+        businessUnitId,
+        stars,
+        sortBy,
+        limit,
+        includeReportedReviews,
+        tags,
+        language,
+        offset,
+      });
+
+      const { reviews, pagination } = result;
+
+      $.export("$summary", `Successfully fetched ${reviews.length} product review(s) for business unit ${businessUnitId}`);
+
+      return {
+        reviews,
+        pagination,
+        metadata: {
+          businessUnitId,
+          filters: {
+            stars,
+            sortBy,
+            includeReportedReviews,
+            tags,
+            language,
+          },
+          requestTime: new Date().toISOString(),
+        },
+      };
+    } catch (error) {
+      throw new Error(`Failed to fetch product reviews: ${error.message}`);
+    }
+  },
+};

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

@@ -0,0 +1,50 @@
+import trustpilot from "../../app/trustpilot.app.ts";
+
+export default {
+  key: "trustpilot-fetch-service-review-by-id",
+  name: "Fetch Service Review by ID",
+  description: "Fetch a specific service review by its ID. [See the documentation](https://developers.trustpilot.com/business-units-api#get-business-unit-review)",
+  version: "0.0.1",
+  type: "action",
+  props: {
+    trustpilot,
+    businessUnitId: {
+      propDefinition: [
+        trustpilot,
+        "businessUnitId",
+      ],
+    },
+    reviewId: {
+      propDefinition: [
+        trustpilot,
+        "reviewId",
+      ],
+    },
+  },
+  async run({ $ }) {
+    const {
+      businessUnitId,
+      reviewId,
+    } = this;
+
+    try {
+      const review = await this.trustpilot.getServiceReviewById({
+        businessUnitId,
+        reviewId,
+      });
+
+      $.export("$summary", `Successfully fetched service review ${reviewId} for business unit ${businessUnitId}`);
+
+      return {
+        review,
+        metadata: {
+          businessUnitId,
+          reviewId,
+          requestTime: new Date().toISOString(),
+        },
+      };
+    } catch (error) {
+      throw new Error(`Failed to fetch service review: ${error.message}`);
+    }
+  },
+};

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

@@ -0,0 +1,109 @@
+import trustpilot from "../../app/trustpilot.app.ts";
+
+export default {
+  key: "trustpilot-fetch-service-reviews",
+  name: "Fetch Service Reviews",
+  description: "Fetch service reviews for a business unit. [See the documentation](https://developers.trustpilot.com/business-units-api#get-business-unit-reviews)",
+  version: "0.0.1",
+  type: "action",
+  props: {
+    trustpilot,
+    businessUnitId: {
+      propDefinition: [
+        trustpilot,
+        "businessUnitId",
+      ],
+    },
+    stars: {
+      propDefinition: [
+        trustpilot,
+        "stars",
+      ],
+    },
+    sortBy: {
+      propDefinition: [
+        trustpilot,
+        "sortBy",
+      ],
+    },
+    limit: {
+      propDefinition: [
+        trustpilot,
+        "limit",
+      ],
+    },
+    includeReportedReviews: {
+      propDefinition: [
+        trustpilot,
+        "includeReportedReviews",
+      ],
+    },
+    tags: {
+      propDefinition: [
+        trustpilot,
+        "tags",
+      ],
+    },
+    language: {
+      propDefinition: [
+        trustpilot,
+        "language",
+      ],
+    },
+    offset: {
+      type: "integer",
+      label: "Offset",
+      description: "Number of results to skip (for pagination)",
+      min: 0,
+      default: 0,
+      optional: true,
+    },
+  },
+  async run({ $ }) {
+    const {
+      businessUnitId,
+      stars,
+      sortBy,
+      limit,
+      includeReportedReviews,
+      tags,
+      language,
+      offset,
+    } = this;
+
+    try {
+      const result = await this.trustpilot.getServiceReviews({
+        businessUnitId,
+        stars,
+        sortBy,
+        limit,
+        includeReportedReviews,
+        tags,
+        language,
+        offset,
+      });
+
+      const { reviews, pagination } = result;
+
+      $.export("$summary", `Successfully fetched ${reviews.length} service review(s) for business unit ${businessUnitId}`);
+
+      return {
+        reviews,
+        pagination,
+        metadata: {
+          businessUnitId,
+          filters: {
+            stars,
+            sortBy,
+            includeReportedReviews,
+            tags,
+            language,
+          },
+          requestTime: new Date().toISOString(),
+        },
+      };
+    } catch (error) {
+      throw new Error(`Failed to fetch service reviews: ${error.message}`);
+    }
+  },
+};

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

@@ -0,0 +1,54 @@
+import trustpilot from "../../app/trustpilot.app.ts";
+
+export default {
+  key: "trustpilot-reply-to-product-review",
+  name: "Reply to Product Review",
+  description: "Reply to a product review on behalf of your business. [See the documentation](https://developers.trustpilot.com/product-reviews-api#reply-to-product-review)",
+  version: "0.0.1",
+  type: "action",
+  props: {
+    trustpilot,
+    reviewId: {
+      propDefinition: [
+        trustpilot,
+        "reviewId",
+      ],
+    },
+    message: {
+      type: "string",
+      label: "Reply Message",
+      description: "The message to reply to the review with",
+    },
+  },
+  async run({ $ }) {
+    const {
+      reviewId,
+      message,
+    } = this;
+
+    if (!message || message.trim().length === 0) {
+      throw new Error("Reply message cannot be empty");
+    }
+
+    try {
+      const result = await this.trustpilot.replyToProductReview({
+        reviewId,
+        message: message.trim(),
+      });
+
+      $.export("$summary", `Successfully replied to product review ${reviewId}`);
+
+      return {
+        success: true,
+        reply: result,
+        metadata: {
+          reviewId,
+          messageLength: message.trim().length,
+          requestTime: new Date().toISOString(),
+        },
+      };
+    } catch (error) {
+      throw new Error(`Failed to reply to product review: ${error.message}`);
+    }
+  },
+};