src/Controller/WebhookController.php line 42

Open in your IDE?
  1. <?php
  3. namespace App\Controller;
  5. use App\Service\Api\Subscription\SubscriptionService;
  6. use App\Service\Api\UsersProfile\Webshop\PaymentService;
  7. use Doctrine\DBAL\Exception\DeadlockException;
  8. use Psr\Log\LoggerInterface;
  9. use Stripe\Exception\SignatureVerificationException;
  10. use Stripe\Webhook;
  11. use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
  12. use Symfony\Component\HttpFoundation\Request;
  13. use Symfony\Component\HttpFoundation\Response;
  14. use Symfony\Component\Routing\Annotation\Route;
  16. class WebhookController extends AbstractController
  17. {
  18.     private $subscriptionService;
  19.     /**
  20.      * @var LoggerInterface
  21.      */
  22.     private $logger;
  23.     /**
  24.      * @var PaymentService
  25.      */
  26.     private $paymentService;
  28.     public function __construct(
  29.         SubscriptionService $subscriptionService,
  30.         LoggerInterface $logger,
  31.         PaymentService $paymentService
  32.     )
  33.     {
  34.         $this->subscriptionService = $subscriptionService;
  35.         $this->logger = $logger;
  36.         $this->paymentService = $paymentService;
  37.     }
  39.     /**
  40.      * @Route("/webhook/stripe", name="stripe_webhook", methods={"POST"})
  41.      */
  42.     public function handleStripeWebhook(Request $request): Response
  43.     {
  44.         $payload = $request->getContent();
  45.         $sigHeader = $request->headers->get('Stripe-Signature');
  46.         $endpointSecret = $_ENV['STRIPE_WEBHOOK_SECRET'];
  48.         try {
  49.             $event = Webhook::constructEvent($payload, $sigHeader, $endpointSecret);
  50.         } catch (SignatureVerificationException $e) {
  51.             $this->logger->error('Webhook signature verification failed.', ['error' => $e->getMessage()]);
  52.             return new Response('', 400);
  53.         }
  55.         try {
  56.             $this->processWebhookWithRetry(function() use ($event) {
  57.                 switch ($event->type) {
  58.                     case 'customer.subscription.updated':
  59.                         $this->subscriptionService->handleSubscriptionUpdated($event->data->object);
  60.                         break;
  61.                     case 'invoice.paid':
  62.                         $this->subscriptionService->handleInvoicePaid($event->data->object);
  63.                         break;
  64.                     case 'invoice.payment_failed':
  65.                         $this->subscriptionService->handleInvoicePaymentFailed($event->data->object);
  66.                         break;
  67.                     case 'customer.subscription.deleted':
  68.                         $this->subscriptionService->handleSubscriptionCanceled($event->data->object);
  69.                         break;
  70.                     case 'payment_intent.succeeded':
  71.                         $this->paymentService->distributedPayment(
  72.                             $event->data->object->id,
  73.                             $event->data->object->latest_charge,
  74.                         );
  75.                         break;
  76.                     default:
  77.                         $this->logger->info('Unhandled event type: ' . $event->type);
  78.                         return new Response('Unhandled event type: ' . $event->type, 200);
  79.                 }
  80.             });
  81.         } catch (\Exception $e) {
  82.             $this->logger->error('Error processing webhook', [
  83.                 'event' => $event->type,
  84.                 'error' => $e->getMessage(),
  85.                 'trace' => $e->getTraceAsString(),
  86.             ]);
  87.             return new Response('Webhook processing failed: ' . $e->getMessage(), 500);
  88.         }
  90.         return new Response('Webhook processed successfully', 200);
  91.     }
  93.     /**
  94.      * @throws DeadlockException
  95.      */
  96.     private function processWebhookWithRetry(callable $process, $maxRetries = 3, $delay = 100000): void // 100000 microseconds = 0.1 seconds
  97.     {
  98.         $attempts = 0;
  99.         while ($attempts < $maxRetries) {
  100.             try {
  101.                 $process();
  102.                 return;
  103.             } catch (DeadlockException $e) {
  104.                 $attempts++;
  105.                 if ($attempts >= $maxRetries) {
  106.                     throw $e;
  107.                 }
  108.                 usleep($delay * $attempts); // Exponential backoff
  109.             }
  110.         }
  111.     }
  112. }