// Example: Redirect to billing portal
const handleManageBilling = async () => {
  const portalUrl = await getBillingPortalUrl(organizationId);
  window.open(portalUrl, "_blank");
};

import { getAutumnCustomer } from "@/lib/autumn";

export async function canAddMembers(organizationId: string): Promise<boolean> {
  const customer = await getAutumnCustomer(organizationId);
  return customer?.plan === "pro" && customer?.status === "active";
}

"use client";

import { useOrganization } from "@/lib/hooks/use-organization";

export function AddMemberForm({ organizationId }: { organizationId: string }) {
  const { subscription } = useOrganization(organizationId);

  if (subscription?.plan !== "pro") {
    return (
      <div className="text-center p-8">
        <h3>Upgrade to Pro</h3>
        <p>Add team members by upgrading to the Pro plan.</p>
        <UpgradeButton organizationId={organizationId} />
      </div>
    );
  }

  return (
    // Member invitation form
  );
}

// When organization is created
await autumn.customers.create({
  id: organization.id, // Use org ID as customer ID
  email: owner.email,
  name: organization.name,
});

// When upgrading
await autumn.subscriptions.create({
  customerId: organization.id,
  productId: "pro-plan",
  quantity: 1, // Initial seat for owner
});

// When adding member
await autumn.subscriptions.update({
  customerId: organization.id,
  quantity: memberCount + 1,
});

import { httpRouter } from "convex/server";
import { httpAction } from "./_generated/server";

const http = httpRouter();

http.route({
  path: "/autumn-webhook",
  method: "POST",
  handler: httpAction(async (ctx, request) => {
    const body = await request.json();
    const signature = request.headers.get("x-autumn-signature");

    // Verify webhook signature
    if (!verifySignature(body, signature)) {
      return new Response("Invalid signature", { status: 401 });
    }

    switch (body.event) {
      case "subscription.created":
        await handleSubscriptionCreated(ctx, body.data);
        break;
      case "subscription.canceled":
        await handleSubscriptionCanceled(ctx, body.data);
        break;
      // ... handle other events
    }

    return new Response("OK", { status: 200 });
  }),
});

export default http;