Paiements Stripe : connecte, sync et gère tes produits

1
# mode test - ne jamais pousser en prod
2
STRIPE_PUBLISHABLE_KEY=pk_test_xxx
3
STRIPE_SECRET_KEY=sk_test_xxx

1
npm add stripe

1
import Stripe from "stripe";
2

3
export const stripe = new Stripe(process.env.STRIPE_SECRET_KEY!, {
4
  apiVersion: "2023-10-16",
5
});

1
import { prisma } from "~/server/db.server";
2
import { stripe } from "./stripe.server";
3

4
export async function syncProductWithStripe(productId: string) {
5
  const product = await prisma.product.findUnique({
6
    where: { id: productId },
7
    include: { images: { take: 1 } },
8
  });
9
  if (!product) throw new Error("Product not found");
10

11
  /* 1 - Produit Stripe */
12
  const stripeProduct =
13
    product.stripeProductId
14
      ? await stripe.products.retrieve(product.stripeProductId)
15
      : await stripe.products.create({
16
          name: product.name,
17
          description: product.description ?? "",
18
          images: product.images.map((i) => i.url),
19
          active: product.isActive,
20
        });
21

22
  /* 2 - Prix Stripe */
23
  await syncStripePrice({ product, stripeProductId: stripeProduct.id });
24

25
  /* 3 - Sauvegarde en DB */
26
  await prisma.product.update({
27
    where: { id: product.id },
28
    data: { stripeProductId: stripeProduct.id },
29
  });
30
}
31

32
async function syncStripePrice({
33
  product,
34
  stripeProductId,
35
}: {
36
  product: { priceCents: number; stripePriceId?: string };
37
  stripeProductId: string;
38
}) {
39
  const amount = product.priceCents;
40

41
  /* Stripe interdit la modif direct d'un prix */
42
  if (product.stripePriceId) {
43
    await stripe.prices.update(product.stripePriceId, { active: false });
44
  }
45

46
  const price = await stripe.prices.create({
47
    product: stripeProductId,
48
    unit_amount: amount,
49
    currency: "eur",
50
  });
51

52
  await prisma.product.update({
53
    where: { stripeProductId },
54
    data: { stripePriceId: price.id },
55
  });
56
}

1
import { syncProductWithStripe } from "~/server/stripe-products.server";
2

3
export const action = async ({ params }: Route.ActionArgs) => {
4
  await syncProductWithStripe(params.productSlug);
5
  return redirect(`/admin/products/${params.productSlug}`);
6
};

1
<fetcher.Form method="POST">
2
  <Button
3
    name="intent"
4
    value="sync-stripe"
5
    isLoading={fetcher.state === "submitting"}
6
  >
7
    Synchroniser Stripe
8
  </Button>
9
</fetcher.Form>

1
export async function action() {
2
  const ids = await prisma.product.findMany({ select: { id: true } });
3
  for (const { id } of ids) await syncProductWithStripe(id);
4
  return redirect("/admin/products");
5
}

1
<fetcher.Form method="POST">
2
  <Button isLoading={fetcher.state==="submitting"}>Sync catalogue</Button>
3
</fetcher.Form>

1
export async function deleteStripeProduct(stripeProductId?: string) {
2
  if (!stripeProductId) return;
3

4
  const prices = await stripe.prices.list({ product: stripeProductId });
5
  for (const p of prices.data) await stripe.prices.update(p.id, { active: false });
6

7
  await stripe.products.update(stripeProductId, { active: false });
8
}

1
await deleteStripeProduct(product.stripeProductId);
2
await prisma.product.delete({ where: { id: product.id } });