feat: Add Status Change Source

components/fraudlabs_pro/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@pipedream/fraudlabs_pro",
-  "version": "0.4.0",
+  "version": "0.5.0",
   "description": "Pipedream Fraudlabs_pro Components",
   "main": "fraudlabs_pro.app.mjs",
   "keywords": [

components/fraudlabs_pro/sources/status_changed/status_change.mjs

@@ -0,0 +1,104 @@
+import fraudlabsProApp from "../../fraudlabs_pro.app.mjs";
+
+export default {
+  name: "FraudLabs Pro Status Change Trigger",
+  description: "Trigger to receive data from FraudLabs Pro Screen Order API if the status change matches your setting.",
+  version: "0.0.1",
+  key: "fraudlabs_pro-status-change",
+  type: "source",
+  props: {
+    fraudlabsProApp,
+    db: "$.service.db",
+    http: {
+      type: "$.interface.http",
+      customResponse: true,
+    },
+  },
+  hooks: {
+    async activate() {
+      // 1. Check if a webhook already exists in the DB to prevent duplicates
+      const existingHookId = this.db.get("hookId");
+      if (existingHookId) {
+        console.log(`Webhook already active with ID: ${existingHookId}`);
+        return;
+      }
+
+      const urlWithAuth = `https://www.fraudlabspro.com/pipedream-webhook-subscribe?key=${encodeURIComponent(this.$auth.api_key)}`;
+
+      const response = await fetch(urlWithAuth, {
+        method: "POST",
+        headers: {
+			"Content-Type": "application/json"
+		},
+        body: JSON.stringify({
+          url: this.http.endpoint,
+          event: "status_changed",
+          description: "Pipedream Workflow Trigger",
+        }),
+      });
+
+      if (!response.ok) {
+        const errorText = await response.text();
+        throw new Error(`Activation failed (${response.status}): ${errorText}`);
+      }
+
+      const data = await response.json();
+
+      // Store the ID returned by FraudLabs Pro
+      if (data && data.id) {
+        this.db.set("hookId", data.id);
+      }
+    },
+
+    async deactivate() {
+      const hookId = this.db.get("hookId");
+      if (!hookId) return;
+
+      const baseUrl = "https://www.fraudlabspro.com/pipedream-webhook-unsubscribe";
+      const params = new URLSearchParams({
+        key: this.$auth.api_key,
+        id: hookId,
+      });
+
+      const response = await fetch(`${baseUrl}?${params.toString()}`, {
+        method: "GET",
+      });
+      if (!response.ok) {
+        const errorText = await response.text();
+        throw new Error(`Deactivation failed (${response.status}): ${errorText}`);
+      }
+
+      // Clear the DB so it can be re-activated later
+      this.db.set("hookId", null);
+    },
+  },
+  async run(event) {
+    // 2. Capture the incoming POST data from the API
+    const body = event.body;
+    if (!body || typeof body !== "object") {
+      this.http.respond({
+        status: 400,
+        body: {
+			message: "Invalid payload"
+		},
+      });
+      return;
+    }
+
+    // Emit the data so it can be used in workflow steps
+    // We use fields like order_id as the primary ID for deduplication in Pipedream
+    this.$emit(body, {
+      summary: `New Status: ${body.flp_status} for Order #${body.order_id}`,
+      id: `${body.order_id}-${body.flp_status}-${body.updated_at ?? body.timestamp ?? Date.now()}`,
+      ts: Date.now(),
+    });
+
+    // Acknowledge the receipt to FraudLabs Pro
+    this.http.respond({
+      status: 200,
+      body: {
+		  message: "Success"
+	  },
+    });
+  },
+};