fix AF webhook & v3_usage pipe

Author: steven-tey

apps/web/app/(ee)/api/appsflyer/webhook/route.ts

@@ -4,6 +4,7 @@ import { isLocalDev } from "@/lib/api/environment";
 import { DubApiError, handleAndReturnErrorResponse } from "@/lib/api/errors";
 import { getIP } from "@/lib/api/utils/get-ip";
 import { withAxiom } from "@/lib/axiom/server";
+import { appsflyerAmountToDubCents } from "@/lib/integrations/appsflyer/amount-to-dub-cents";
 import { APPSFLYER_IP_RANGES } from "@/lib/integrations/appsflyer/constants";
 import { isIpInRange } from "@/lib/middleware/utils/is-ip-in-range";
 import { trackLeadRequestSchema } from "@/lib/zod/schemas/leads";
@@ -101,10 +102,11 @@ export const GET = withAxiom(async (req) => {
 
     // Track sale event
     if (partnerEventId === "sale") {
+      const amountInCents = appsflyerAmountToDubCents(queryParams.amount);
       const { eventName, customerExternalId, amount, currency, invoiceId } =
         trackSaleRequestSchema.parse({
           ...queryParams,
-          ...(queryParams.amount && { amount: Number(queryParams.amount) }),
+          ...(amountInCents !== undefined && { amount: amountInCents }),
         });
 
       await trackSale({

apps/web/lib/integrations/appsflyer/amount-to-dub-cents.ts

@@ -0,0 +1,25 @@
+/**
+ * Dub's track-sale API expects `amount` in minor units (e.g. cents for USD).
+ * AppsFlyer postbacks usually send revenue in major units with a decimal (e.g. "0.52").
+ * If the param string contains ".", treat as major units and convert to cents.
+ * Otherwise treat as already in minor units (e.g. "2900" cents).
+ */
+export function appsflyerAmountToDubCents(
+  amount: string | undefined,
+): number | undefined {
+  if (amount == null) {
+    return undefined;
+  }
+  const trimmed = amount.trim();
+  if (trimmed === "") {
+    return undefined;
+  }
+  const n = Number(trimmed);
+  if (!Number.isFinite(n)) {
+    return undefined;
+  }
+  if (trimmed.includes(".")) {
+    return Math.round(n * 100);
+  }
+  return Math.round(n);
+}

packages/tinybird/pipes/v3_usage.pipe

@@ -112,8 +112,8 @@ SQL >
                     required=True,
                 )
             }}
-            AND created_at >= {{ DateTime(start, '2025-09-03 00:00:00') }}
-            AND created_at < {{ DateTime(end, '2025-10-03 00:00:00') }}
+            AND toDateTime64(timestamp, 3) >= {{ DateTime(start, '2025-09-03 00:00:00') }}
+            AND toDateTime64(timestamp, 3) < {{ DateTime(end, '2025-10-03 00:00:00') }}
             {% if defined(folderId) %} AND folder_id = {{ folderId }}
             {% end %}
             {% if defined(domain) %} AND domain IN {{ Array(domain, 'String') }} {% end %}