Send the paywall event

// SERVER ONLY. Call this after your app receives its response.
export async function sendHyzlPaywallEvent(user, paywallVisit) {
  const token = process.env.HYZL_INGEST_TOKEN;
  if (!token) return { ok: false, retryable: false };

  try {
    const response = await fetch(
      "https://yvklwfalxxeslusmnpwi.supabase.co/functions/v1/paywall-event",
      {
        method: "POST",
        signal: AbortSignal.timeout(10_000),
        headers: {
          Authorization: `Bearer ${token}`,
          "Content-Type": "application/json",
        },
        body: JSON.stringify({
          userId: user.id,
          stripeCustomerId: user.stripeCustomerId,
          phoneNumber: user.phoneE164,
          firstName: user.firstName,
          email: user.email,
          consent: {
            attested: user.contactConsent === true,
            text: user.contactConsentText,
            at: user.contactConsentAt,
          },
          eventId: paywallVisit.id,
          occurredAt: paywallVisit.occurredAt,
          stage: "saw_price",
          recoveryUrl: paywallVisit.recoveryUrl,
        }),
      },
    );

    const ok = response.status === 200 || response.status === 202;
    if (!ok) {
      const body = await response.json().catch(() => ({}));
      console.warn("Hyzl", { status: response.status, error: body.error });
    }
    return { ok, retryable: response.status >= 500 };
  } catch {
    return { ok: false, retryable: true };
  }
}

// SWIFT SERVER ONLY. Never put this request or token in an iOS app.
import Foundation

guard let token = ProcessInfo.processInfo.environment["HYZL_INGEST_TOKEN"] else {
  return
}

var request = URLRequest(
  url: URL(string: "https://yvklwfalxxeslusmnpwi.supabase.co/functions/v1/paywall-event")!
)
request.httpMethod = "POST"
request.timeoutInterval = 10
request.setValue("Bearer \(token)", forHTTPHeaderField: "Authorization")
request.setValue("application/json", forHTTPHeaderField: "Content-Type")
request.httpBody = try JSONSerialization.data(withJSONObject: [
  "userId": user.id,
  "stripeCustomerId": user.stripeCustomerId,
  "phoneNumber": user.phoneE164,
  "firstName": user.firstName,
  "email": user.email,
  "consent": [
    "attested": user.contactConsent,
    "text": user.contactConsentText,
    "at": user.contactConsentAt,
  ],
  "eventId": paywallVisit.id,
  "occurredAt": paywallVisit.occurredAt,
  "stage": "saw_price",
  "recoveryUrl": paywallVisit.recoveryUrl,
])

let (_, response) = try await URLSession.shared.data(for: request)
let status = (response as? HTTPURLResponse)?.statusCode
// 200 and 202 mean success. Retry only network errors and 5xx responses.