interface PlatformCustomer {
  user_id: string;
  user_email: string;
  full_name: string;
  mobile_number?: string;
  subscription_plan: "free" | "pro" | "enterprise";
  lifetime_value: number;
}

import { TajoConnector } from "@tajo/connector-sdk";

const connector = new TajoConnector({
  name: "my-platform-brevo",
  brevoApiKey: process.env.BREVO_API_KEY,
});

connector.defineMapping("customer", (platformCustomer: PlatformCustomer) => ({
  email: platformCustomer.user_email,
  attributes: {
    FIRSTNAME: platformCustomer.full_name.split(" ")[0],
    LASTNAME: platformCustomer.full_name.split(" ").slice(1).join(" "),
    SMS: platformCustomer.mobile_number,
    SUBSCRIPTION_PLAN: platformCustomer.subscription_plan,
    LIFETIME_VALUE: platformCustomer.lifetime_value,
  },
}));

app.post("/webhooks/platform", async (req, res) => {
  const event = req.body;

  switch (event.type) {
    case "user.created":
      await connector.syncCustomer(event.data);
      break;
    case "purchase.completed":
      await connector.trackEvent({
        email: event.data.user_email,
        event: "purchase",
        properties: { amount: event.data.amount },
      });
      break;
  }

  res.json({ received: true });
});