status_change.mjs

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 changed match to your setting.",
  version: "0.0.1",
  key: "fraudlabspro_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
      });

      await fetch(`${baseUrl}?${params.toString()}`, {
        method: "GET",
      });

      // 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;

    // 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 || Date.now(), 
      ts: Date.now(),
    });

    // Acknowledge the receipt to FraudLabs Pro
    this.http.respond({
      status: 200,
      body: { message: "Success" },
    });
  },
};