How to send BigCommerce orders to ProfitMetrics using a Cloudflare Worker (free Zapier alternative)

npm install -g wrangler

wrangler login

mkdir bigcommerce-profitmetrics
cd bigcommerce-profitmetrics

name = "bigcommerce-profitmetrics"
main = "worker.js"
compatibility_date = "2024-01-01"

/**
 * BigCommerce → ProfitMetrics Server-Side Hybrid Universal Integration
 * Cloudflare Worker
 *
 * Environment variables (set via `wrangler secret put`):
 *   BC_STORE_HASH      - Your BigCommerce store hash
 *   BC_ACCESS_TOKEN     - BigCommerce API access token
 *   PM_PUBLIC_ID        - ProfitMetrics website Public ID
 */

export default {
  async fetch(request, env) {
    if (request.method !== "POST") {
      return new Response("Method not allowed", { status: 405 });
    }

    try {
      const payload = await request.json();

      const orderId = payload?.data?.id;
      if (!orderId) {
        return new Response("No order ID in payload", { status: 400 });
      }

      console.log(`Received webhook for order ${orderId}`);

      // Fetch full order from BigCommerce V2 Orders API
      const bcBase = `https://api.bigcommerce.com/stores/${env.BC_STORE_HASH}`;
      const bcHeaders = {
        "X-Auth-Token": env.BC_ACCESS_TOKEN,
        "Accept": "application/json",
        "Content-Type": "application/json",
      };

      const orderRes = await fetch(`${bcBase}/v2/orders/${orderId}`, {
        headers: bcHeaders,
      });

      if (!orderRes.ok) {
        console.error(`Order fetch failed: ${orderRes.status}`);
        return new Response("Failed to fetch order", { status: 502 });
      }

      const order = await orderRes.json();

      // Fetch order products
      const productsRes = await fetch(
        `${bcBase}/v2/orders/${orderId}/products`,
        { headers: bcHeaders }
      );

      if (!productsRes.ok) {
        console.error(`Products fetch failed: ${productsRes.status}`);
        return new Response("Failed to fetch order products", { status: 502 });
      }

      const products = await productsRes.json();

      // Build ProfitMetrics orderspec
      const orderspec = buildOrderspec(order, products);

      // Send to ProfitMetrics
      const pmUrl = buildProfitMetricsUrl(env.PM_PUBLIC_ID, orderspec);
      const pmRes = await fetch(pmUrl);

      if (!pmRes.ok) {
        console.error(`ProfitMetrics request failed: ${pmRes.status}`);
        return new Response("ProfitMetrics request failed", { status: 502 });
      }

      console.log(`Order ${orderId} sent to ProfitMetrics successfully`);
      return new Response("OK", { status: 200 });

    } catch (err) {
      console.error("Worker error:", err);
      return new Response("Internal error", { status: 500 });
    }
  },
};


function buildOrderspec(order, products) {
  const email = order.billing_address?.email || "";
  const rawPhone = order.billing_address?.phone || "";
  const phone = rawPhone.replace(/[^0-9]/g, "") || null;

  const totalInclVat = parseFloat(order.total_inc_tax) || 0;
  const totalExVat = parseFloat(order.total_ex_tax) || 0;
  const shippingExVat = parseFloat(order.shipping_cost_ex_tax) || 0;

  const shippingCountry = order.shipping_addresses?.length
    ? order.shipping_addresses[0].country_iso2
    : order.billing_address?.country_iso2 || null;

  const shippingZipcode = order.shipping_addresses?.length
    ? order.shipping_addresses[0].zip
    : order.billing_address?.zip || null;

  const shippingState = order.shipping_addresses?.length
    ? order.shipping_addresses[0].state
    : order.billing_address?.state || null;

  // IMPORTANT: The "sku" field must match the product ID used in your
  // ProfitMetrics product feed. Adjust if your feed uses product_id
  // or variant_id instead of the actual SKU.
  const pmProducts = products.map((product) => ({
    sku: product.sku || String(product.product_id),
    qty: product.quantity,
    priceExVat: parseFloat(product.price_ex_tax) || 0,
  }));

  const orderspec = {
    id: String(order.id),
    ts: Math.floor(new Date(order.date_created).getTime() / 1000),
    orderEmail: email,
    shippingMethod: order.shipping_method || "Standard",
    paymentMethod: order.payment_method || "Unknown",
    currency: order.currency_code || "GBP",
    priceShippingExVat: shippingExVat,
    priceTotalExVat: totalExVat,
    priceTotalInclVat: totalInclVat,
    products: pmProducts,
  };

  if (phone) orderspec.customerPhone = phone;
  if (shippingCountry) orderspec.shippingCountry = shippingCountry;
  if (shippingZipcode) orderspec.shippingZipcode = shippingZipcode;
  if (shippingState) orderspec.shippingState = shippingState;

  const firstName = order.billing_address?.first_name || null;
  const lastName = order.billing_address?.last_name || null;
  if (firstName) orderspec.customerFirstname = firstName;
  if (lastName) orderspec.customerLastname = lastName;

  return orderspec;
}


function buildProfitMetricsUrl(publicId, orderspec) {
  const params = new URLSearchParams({
    v: "3uh",
    pid: publicId,
    o: JSON.stringify(orderspec),
  });

  return `https://my.profitmetrics.io/l.php?${params.toString()}`;
}

wrangler secret put BC_STORE_HASH
wrangler secret put BC_ACCESS_TOKEN
wrangler secret put PM_PUBLIC_ID

wrangler deploy

https://bigcommerce-profitmetrics.<your-subdomain>.workers.dev

curl -X POST \
  https://api.bigcommerce.com/stores/{STORE_HASH}/v3/hooks \
  -H "X-Auth-Token: {ACCESS_TOKEN}" \
  -H "Content-Type: application/json" \
  -d '{
    "scope": "store/order/created",
    "destination": "{WORKER_URL}",
    "is_active": true,
    "headers": {}
  }'