1import { requireUser } from "../auth";
2import { StripeClient } from "../billing/stripe";
3import { Inventory } from "../catalog/inventory";
4import { Orders } from "../db/orders";
5 
6export async function createCheckout(req: Request) {
7  const user = await requireUser(req);
8  const cart = await Inventory.loadCart(user.id);
9  return chargeCart(user, cart);
10}
11 
12async function chargeCart(user: User, cart: Cart) {
13  const session = await StripeClient.sessions.create({
14    customer: user.stripeId,
15    line_items: cart.lines,
16    success_url: "/orders",
17  });
18  await Orders.insert({ userId: user.id, sessionId: session.id });
19  return Response.json({ url: session.url });
20}
21 
22export async function handleWebhook(event: Stripe.Event) {
23  if (event.type !== "checkout.session.completed") return;
24  const order = await Orders.bySession(event.data.object.id);
25  await Inventory.commit(order.cartId);
26  await Orders.markPaid(order.id);
27}