This course is still being released! Check back later for more chapters.

Get Notified About this Course!

We will send you messages regarding this course only
and nothing else, we promise.
You can unsubscribe anytime by emailing us at:
privacy@symfonycasts.com
> Symfony 7 > Procesador de Pagos con Lemon Squeezy
Login to bookmark this video
Buy Access to Course
12.

Implementar el consumidor de webhooks

|

Share this awesome video!

|

Keep on Learning!

Start your All-Access Pass

With a Subscription, click any sentence in the script to jump to that part of the video!

Login Subscribe

En el último capítulo, configuramos con éxito el analizador de peticiones de webhook. Este analizador está diseñado para recibir un webhook de LemonSqueezy, verificar su firma, analizar la carga útil y pasar los datos analizados a un consumidor de webhook. Ahora que nuestro analizador está listo, podemos abordar la siguiente parte: manejar los datos del webhook en el consumidor.

Empieza abriendo el archivo LemonSqueezyWebhookConsumer.php del directoriosrc/RemoveEvent/, y busca el método consume(). Podemos deshacernos de este TODO. Nuestra tarea aquí es encontrar el usuario correspondiente al customer_idque obtenemos de los datos del webhook, y conectarlos.

Una cosa a tener en cuenta es que el consumidor es activado por una petición totalmente independiente: el webhook de LemonSqueezy. No sólo eso, sino que los consumidores son gestionados por Symfony Messenger. Es posible que sean procesados por un trabajador en segundo plano. La cuestión es que no tenemos acceso al objeto usuario original como en el controlador de pago.

Entonces... ¿cómo obtenemos el usuario en el consumidor? Por suerte para nosotros, la documentación de la API "Crear una compra" de LemonSqueezy explica cómo añadir datos personalizados al crear la URL de la compra. Esto es perfecto para pasar nuestro ID de usuario, ¡así que empecemos! Dirígete a LemonSqueezyApi ensrc/Store/ y busca el método createCheckoutUrl().

Aquí, tenemos que hacer que el usuario no sea opcional. Esto es crucial porque es la información que necesitamos para enlazar con el cliente LemonSqueezy correspondiente. Elimina el ? de la sugerencia de tipo User y la declaración if ($user) que ahora es innecesaria. Ahora, añade$attributes['checkout_data']['custom']['user_id'] = $user->getId(). Este campocustom nos permite pasar cualquier dato personalizado que necesitemos a LemonSqueezy y estará a nuestra disposición en la carga útil del webhook.

97 lines | src/Store/LemonSqueezyApi.php
// ... lines 1 - 11
final readonly class LemonSqueezyApi
{
// ... lines 14 - 23
public function createCheckoutUrl(User $user): string
{
// ... lines 26 - 32
$attributes = [];
$attributes['checkout_data']['email'] = $user->getEmail();
$attributes['checkout_data']['name'] = $user->getFirstName();
$attributes['checkout_data']['custom']['user_id'] = $user->getId();
// ... lines 37 - 86
}
// ... lines 88 - 95
}

El objetivo es compartir el ID de usuario con LemonSqueezy cuando un cliente realiza un pedido. Para ello, es necesario que el usuario haya iniciado sesión. Volviendo aOrderController::checkout(), todo lo que hace falta para que esta ruta requiera autenticación es eliminar el ? de la sugerencia de tipo User. Muy bonito, ¿verdad?

92 lines | src/Controller/OrderController.php
// ... lines 1 - 17
class OrderController extends AbstractController
{
// ... lines 20 - 60
public function checkout(
// ... line 62
#[CurrentUser] User $user,
): Response {
// ... lines 65 - 67
}
// ... lines 69 - 90
}

Para confirmar que todo funciona según lo esperado, en nuestro sitio, cierra la sesión... añade un producto al carrito e intenta pasar por caja. Como somos un usuario no autenticado, deberíamos ser redirigidos a la página de inicio de sesión, y... ¡perfecto!

Manejo del consumidor Webhook

De vuelta en el método LemonSqueezyWebhookConsumer::consume(), establece$payload = $event->getPayload().

Para acceder al user_id que establecimos en createCheckoutUrl(), escribe$userId = $payload['meta']['custom_data']['user_id'] ?? null. Añadiré un comentario rápido para explicar que no podemos obtener el usuario por "medios tradicionales".

Ahora, escribe una comprobación de cordura con if (!$userId). Si esta comprobación falla, haremos throw new InvalidArgumentException() consprintf('User ID not found in LemonSqueezy webhook: %s', $event->getId()).

27 lines | src/RemoteEvent/LemonSqueezyWebhookConsumer.php
// ... lines 1 - 9
final class LemonSqueezyWebhookConsumer implements ConsumerInterface
{
// ... lines 12 - 15
public function consume(RemoteEvent $event): void
{
$payload = $event->getPayload();
// $this->getUser() will not work in webhooks as no authenticated user in that process
$userId = $payload['meta']['custom_data']['user_id'] ?? null;
if (!$userId) {
throw new \InvalidArgumentException(sprintf('User ID not found in LemonSqueezy webhook "%s"!', $event->getId()));
}
}
}

Ahora tenemos el $userId, pero ¿cómo obtenemos el objeto usuario? En nuestro constructor, inyecta private EntityManagerInterface $entityManager.

29 lines | src/RemoteEvent/LemonSqueezyWebhookConsumer.php
// ... lines 1 - 4
use Doctrine\ORM\EntityManagerInterface;
// ... lines 6 - 10
final class LemonSqueezyWebhookConsumer implements ConsumerInterface
{
public function __construct(
private EntityManagerInterface $entityManager,
){
}
// ... lines 17 - 27
}

De vuelta al método consume(), recupera el usuario con$user = $this->entityManager->getRepository(User::class)->find($userId).

A continuación, si $user no existe, escribiremos throw new EntityNotFoundException()(elige el de Doctrine\ORM). Para el mensaje escribesprintf('User "%s" not found for LemonSqueezy webhook "%s"!', $userId, $event->getId()).

37 lines | src/RemoteEvent/LemonSqueezyWebhookConsumer.php
// ... lines 1 - 19
public function consume(RemoteEvent $event): void
{
// ... lines 22 - 29
$user = $this->entityManager->getRepository(User::class)
->find($userId);
if (!$user) {
throw new EntityNotFoundException(sprintf('User "%s" not found for LemonSqueezy webhook "%s"!', $userId, $event->getId()));
}
}
// ... lines 36 - 37

A continuación, añade match ($event->getName()), y para order_created, llama a$this->handleOrderCreatedEvent(). Este método aún no existe, pero lo crearemos más adelante. Pasa también $event y $user como argumentos. Llegados a este punto, sólo deberíamos tener eventos admitidos, pero por si acaso nos falta algo, añade un default que throw new LogicException(), consprintf('Unsupported LemonSqueezy event: %s', $event->getId()). Muy bien.

46 lines | src/RemoteEvent/LemonSqueezyWebhookConsumer.php
// ... lines 1 - 19
public function consume(RemoteEvent $event): void
{
// ... lines 22 - 35
match ($event->getName()) {
'order_created' => $this->handleOrderCreatedEvent($event, $user),
default => throw new \LogicException(sprintf('Unsupported LemonSqueezy event: %s', $event->getName())),
};
}
// ... lines 41 - 46

Crear el evento ManejarOrden

Ahora, crea el método handleOrderCreatedEvent() con PhpStorm como una función privada. Parece que PhpStorm añadió un argumento - RemoteEvent $event - pero olvidó el segundo, así que añadeUser $user manualmente y devuelve el tipo: void.

46 lines | src/RemoteEvent/LemonSqueezyWebhookConsumer.php
// ... lines 1 - 41
private function handleOrderCreatedEvent(RemoteEvent $event, User $user): void
{
}
// ... lines 45 - 46

Dentro, obtén la carga útil con $payload = $event->getPayload(). Debajo, busca el ID del cliente con$customerId = $payload['data']['attributes']['customer_id']. Si te preguntas de dónde ha salido esto, puedes encontrarlo en el inspector de Ngrok.

48 lines | src/RemoteEvent/LemonSqueezyWebhookConsumer.php
// ... lines 1 - 41
private function handleOrderCreatedEvent(RemoteEvent $event, User $user): void
{
$payload = $event->getPayload();
$customerId = $payload['data']['attributes']['customer_id'];
}
// ... lines 47 - 48

Vale, ya tenemos el customer_id, pero aún necesitamos una nueva propiedad en elUser para guardarlo. En tu terminal, crea una nueva pestaña y ejecuta:

bin/console make:entity

Para la clase, escribe User para coger la entidad existente. Para el nombre de la propiedad, llámalalsCustomerId. Haz que sea una cadena con una longitud de 255, y anulable. Pulsa Enter una vez más y... ¡listo!

De vuelta a nuestro código, abre src/Entity/User.php... si nos desplazamos hacia abajo... ¡aquí está nuestra nueva columna! Establécela en unique: true. Tiene muy buena pinta, y si nos desplazamos hacia abajo, veremos que también ha creado un getter y un setter para el campo. ¡Genial!

157 lines | src/Entity/User.php
// ... lines 1 - 14
class User implements UserInterface, PasswordAuthenticatedUserInterface
{
// ... lines 17 - 44
#[ORM\Column(length: 255, unique: true, nullable: true)]
private ?string $lsCustomerId = null;
// ... lines 47 - 146
public function getLsCustomerId(): ?string
{
return $this->lsCustomerId;
}
public function setLsCustomerId(?string $lsCustomerId): void
{
$this->lsCustomerId = $lsCustomerId;
}
}

Ahora tenemos que crear una migración. Hazlo con:

bin/console make:migration

Si vamos a comprobarlo... ¡tiene buena pinta! Sólo añadiremos una descripción rápida -Add customer ID property to User entity.

45 lines | migrations/Version20250219215150.php
// ... lines 1 - 12
final class Version20250219215150 extends AbstractMigration
{
public function getDescription(): string
{
return 'Add customer ID property to User entity';
}
// ... lines 19 - 43
}

Y de vuelta a nuestro terminal, migra con:

bin/console doctrine:migration:migrate

Una vez terminado, vuelve a handleOrderCreatedEvent() y llama a nuestro nuevo configurador: $user->setLsCustomerId() con $customerId. Para guardarlo, llama a$this->entityManager->flush().

51 lines | src/RemoteEvent/LemonSqueezyWebhookConsumer.php
// ... lines 1 - 12
final class LemonSqueezyWebhookConsumer implements ConsumerInterface
{
// ... lines 15 - 41
private function handleOrderCreatedEvent(RemoteEvent $event, User $user): void
{
// ... lines 44 - 45
$user->setLsCustomerId($customerId);
$this->entityManager->flush();
}
}

Probar el webhook

¡Es hora de volver a probar el webhook! En el inspector Ngrok, vuelve a reproducir. Hmm... un error. Es un poco difícil de ver, pero aquí está:

ID de usuario no encontrado en el webhook LemonSqueezy

Esto tiene sentido: cuando este webhook se ejecutó originalmente, no tenía configurado el user_id. Con Ngrok, podemos modificar el contenido del webhook original y reproducirlo con modificaciones, pero... para estar más seguros de que se tienen en cuenta nuestros cambios, volveremos a pasar por el proceso de compra para que LemonSqueezy pueda configurar el user_id correctamente.

Vuelve a iniciar sesión, añade un producto al carrito e intenta pasar por caja. Uy, otro error: un 422. Salta a LemonSqueezyApi y descomenta este dd() para ver qué está pasando aquí.

97 lines | src/Store/LemonSqueezyApi.php
// ... lines 1 - 11
final readonly class LemonSqueezyApi
{
// ... lines 14 - 23
public function createCheckoutUrl(User $user): string
{
// ... lines 26 - 82
//dd($response->getContent(false));
// ... lines 84 - 86
}
// ... lines 88 - 95
}

Si actualizamos nuestro sitio... ¡ah!

...el campo debe ser una cadena...

y está apuntando al user_id personalizado que añadimos... Resulta que LemonSqueezy es bastante estricto con los tipos. Vuelve a nuestro código, comenta de nuevo ese dd()... y, aquí arriba... convierte este $user->getId() en una cadena. Volvemos a nuestra aplicación... refrescamos... ¡y éxito! ¡Estamos en la página de pago!

97 lines | src/Store/LemonSqueezyApi.php
// ... lines 1 - 23
public function createCheckoutUrl(User $user): string
{
// ... lines 26 - 35
$attributes['checkout_data']['custom']['user_id'] = (string) $user->getId();
// ... lines 37 - 86
}
// ... lines 88 - 97

Rellenemos los datos de la tarjeta... la dirección... realicemos el pago, y esperemos al webhook. ¡Sí! Nuestra transacción ha sido aceptada y, aquí, tenemos un código de estado 202.

Si miramos la petición, podemos ver que nuestra custom_data -> user_ides igual a 1. También podemos comprobar la base de datos con un práctico comando SQL. En tu terminal, ejecuta:

bin/console doctrine:query:sql "SELECT * FROM user WHERE id = 1"

Este lsCustomerId es el ID único de LemonSqueezy. ¡Genial!

Antes de continuar, escribamos algunas pruebas para nuestra configuración de webhook. ¡Eso a continuación!