src/EventListener/Strava/WebhookAthleteSubscriber.php line 30

Open in your IDE?
  1. <?php
  3. namespace App\EventListener\Strava;
  5. use App\Entity\SocialToken;
  6. use App\Entity\User;
  7. use App\Repository\SocialTokenRepository;
  8. use Doctrine\ORM\EntityManagerInterface;
  9. use NuBox\Strava\Api\Event\StravaApiEvents;
  10. use NuBox\Strava\Api\Event\Webhook\ActivityDeletedEvent;
  11. use NuBox\Strava\Api\Event\Webhook\WebhookEventInterface;
  12. use NuBox\Strava\Api\Service\StravaApi;
  13. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  15. final class WebhookAthleteSubscriber implements EventSubscriberInterface
  16. {
  17.     public function __construct(
  18.         private readonly SocialTokenRepository $socialTokenRepository,
  19.         private readonly EntityManagerInterface $entityManager,
  20.     ) {
  21.     }
  23.     public static function getSubscribedEvents(): array
  24.     {
  25.         return [
  26.             StravaApiEvents::WEBHOOK_ATHLETE_DELETED => 'onAthleteDeleted',
  27.         ];
  28.     }
  30.     public function onAthleteDeleted(ActivityDeletedEvent $event): void
  31.     {
  32.         $socialToken = $this->getSocialToken($event);
  34.         $this->entityManager->remove($socialToken);
  35.         $this->entityManager->flush();
  36.     }
  38.     private function getSocialToken(WebhookEventInterface $event): SocialToken
  39.     {
  40.         $socialUserId = $event->getWebhook()->getOwnerId();
  42.         $socialToken = $this->socialTokenRepository->findOneBy([
  43.             'type' => StravaApi::TYPE,
  44.             'socialUserId' => $socialUserId,
  45.         ]);
  47.         assert($socialToken instanceof SocialToken);
  49.         return $socialToken;
  50.     }
  51. }