src/EventListener/Strava/WebhookActivitySubscriber.php line 41

Open in your IDE?
  1. <?php
  3. namespace App\EventListener\Strava;
  5. use App\Entity\Activity;
  6. use App\Entity\SocialToken;
  7. use App\Entity\User;
  8. use App\Message\Event\CompileActivityEvent;
  9. use App\Repository\ActivityRepository;
  10. use App\Repository\SocialTokenRepository;
  11. use Doctrine\ORM\EntityManagerInterface;
  12. use NuBox\Strava\Api\DataObject\Activity as StravaActivity;
  13. use NuBox\Strava\Api\Event\StravaApiEvents;
  14. use NuBox\Strava\Api\Event\Webhook\ActivityDeletedEvent;
  15. use NuBox\Strava\Api\Event\Webhook\WebhookEventInterface;
  16. use NuBox\Strava\Api\Service\StravaApi;
  17. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  18. use Symfony\Component\Messenger\MessageBusInterface;
  20. final class WebhookActivitySubscriber implements EventSubscriberInterface
  21. {
  22.     public function __construct(
  23.         private readonly EntityManagerInterface $entityManager,
  24.         private readonly ActivityRepository $activityRepository,
  25.         private readonly SocialTokenRepository $socialTokenRepository,
  26.         private readonly MessageBusInterface $messageBus,
  27.         private readonly StravaApi $stravaApi,
  28.         private readonly string $debugEmail
  29.     ) {
  30.     }
  32.     public static function getSubscribedEvents(): array
  33.     {
  34.         return [
  35.             StravaApiEvents::WEBHOOK_ACTIVITY_CREATED => 'onActivityModified',
  36.             StravaApiEvents::WEBHOOK_ACTIVITY_UPDATED => 'onActivityModified',
  37.             StravaApiEvents::WEBHOOK_ACTIVITY_DELETED => 'onActivityDeleted',
  38.         ];
  39.     }
  41.     public function onActivityModified(WebhookEventInterface $event): void
  42.     {
  43.         $activityEntry = $this->getActivity($event);
  44.         $activity = $this->stravaApi->getActivity($this->getSocialToken($event), $event->getWebhook()->getObjectId());
  46.         if ($activityEntry === null) {
  47.             $activityEntry = new Activity();
  48.             $activityEntry->setUser($this->getUser($event));
  50.             // initial payload setting
  51.             $socialPayload = $activityEntry->getSocialPayload();
  52.             $socialPayload['master'] = StravaApi::TYPE;
  53.             $activityEntry->setSocialPayload($socialPayload);
  55.             $this->entityManager->persist($activityEntry);
  56.         }
  58.         $socialPayload = $activityEntry->getSocialPayload();
  59.         $socialPayload = $this->setStravaPayload($socialPayload, $activity);
  60.         $activityEntry->setSocialPayload($socialPayload);
  62.         mail(
  63.             $this->debugEmail,
  64.             '[Wearable-Cloud] Activity Sync',
  65.             'A activity for user [' . $this->getUser($event)->getUserIdentifier() . '] was synced with payload:' . PHP_EOL .
  66.                     var_export($activityEntry->getSocialPayload()[StravaApi::TYPE], true)
  67.         );
  69.         $this->entityManager->flush();
  71.         $this->messageBus->dispatch(new CompileActivityEvent($activityEntry));
  72.     }
  74.     public function onActivityDeleted(ActivityDeletedEvent $event): void
  75.     {
  76.         $activity = $this->getActivity($event);
  78.         mail(
  79.             $this->debugEmail,
  80.             '[Wearable-Cloud] Delete Activity',
  81.             'A activity for user [' . $this->getUser($event)->getUserIdentifier() . '] was deleted:' . PHP_EOL .
  82.             var_export($activity, true)
  83.         );
  85.         $this->entityManager->remove($activity);
  86.         $this->entityManager->flush();
  87.     }
  89.     private function getActivity(WebhookEventInterface $event): ?Activity
  90.     {
  91.         $activities = $this->activityRepository->findBy([
  92.             'user' => $this->getUser($event),
  93.         ]);
  95.         if (count($activities) > 0) {
  96.             foreach ($activities as $activity) {
  97.                 $payload = $activity->getSocialPayload();
  99.                 $stravaActivity = $this->getStravaPayload($payload);
  101.                 if ($stravaActivity instanceof StravaActivity) {
  102.                     if ($stravaActivity->getId() === $event->getWebhook()->getObjectId()) {
  103.                         return $activity;
  104.                     }
  105.                 }
  106.             }
  107.         }
  109.         return null;
  110.     }
  112.     private function setStravaPayload(array $payload, StravaActivity $activity): array
  113.     {
  114.         $payload[StravaApi::TYPE] = serialize($activity);
  116.         return $payload;
  117.     }
  119.     private function getStravaPayload(array $payload): ?StravaActivity
  120.     {
  121.         if (array_key_exists(StravaApi::TYPE, $payload)) {
  122.             return unserialize($payload[StravaApi::TYPE]);
  123.         }
  125.         return null;
  126.     }
  128.     private function getUser(WebhookEventInterface $event): User
  129.     {
  130.         return $this->getSocialToken($event)->getUser();
  131.     }
  133.     private function getSocialToken(WebhookEventInterface $event): SocialToken
  134.     {
  135.         $socialUserId = $event->getWebhook()->getOwnerId();
  137.         $socialToken = $this->socialTokenRepository->findOneBy([
  138.             'type' => StravaApi::TYPE,
  139.             'socialUserId' => $socialUserId,
  140.         ]);
  142.         assert($socialToken instanceof SocialToken);
  144.         return $socialToken;
  145.     }
  146. }