src/EventSubscriber/EasyAdminSubscriber.php line 92

  1. <?php
  3. namespace App\EventSubscriber;
  5. use App\Entity\Company;
  6. use App\Entity\Offer;
  7. use App\Entity\Subscription;
  8. use App\Entity\User;
  9. use App\Service\StripeService;
  10. use App\Service\SubscriptionService;
  11. use App\Service\WidgetService;
  12. use Doctrine\ORM\EntityManagerInterface;
  13. use EasyCorp\Bundle\EasyAdminBundle\Event\AfterEntityPersistedEvent;
  14. use EasyCorp\Bundle\EasyAdminBundle\Event\AfterEntityUpdatedEvent;
  15. use EasyCorp\Bundle\EasyAdminBundle\Event\BeforeEntityDeletedEvent;
  16. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  18. class EasyAdminSubscriber implements EventSubscriberInterface
  19. {
  20.     public function __construct(
  21.         private readonly EntityManagerInterface $em,
  22.         private readonly StripeService $stripe,
  23.         private readonly WidgetService $widgetService,
  24.         private readonly SubscriptionService $subscriptionService
  25.     ) {
  26.     }
  28.     public static function getSubscribedEvents(): array
  29.     {
  30.         return [
  31.             AfterEntityPersistedEvent::class => ['postPersist'],
  32.             AfterEntityUpdatedEvent::class => ['postUpdate'],
  33.             BeforeEntityDeletedEvent::class => ['preDelete']
  34.         ];
  35.     }
  37.     /**
  38.      * After persist event
  39.      */
  40.     public function postPersist(AfterEntityPersistedEvent $event): void
  41.     {
  42.         $entity = $event->getEntityInstance();
  44.         // After persist a new offer, create it on Stripe
  45.         if ($entity instanceof Offer) {
  46.             $this->stripe->planCreate(
  47.                 $entity->getStripeId(),
  48.                 $entity->getName(),
  49.                 $entity->getAmount(),
  50.                 $entity->getIntervalType(),
  51.                 $entity->getTrialPeriodDays(),
  52.                 'SOCIALVAULT PRO'
  53.             );
  54.         }
  56.         // After persist a new subscription, create it on Stripe. Then, set returned Stripe data on subscription
  57.         if ($entity instanceof Subscription) {
  58.             // Create Stripe subscription
  59.             $this->stripe->subscriptionCreate(null, $entity->getOffer()->getStripeId(), $entity->getIsCancelAtPeriodEnd());
  61.             // Update subscription w/ Stripe data
  62.             $entity->setStripeId($this->stripe->getSubscription()->id);
  63.             $entity->setLatestStripeInvoiceId($this->stripe->getSubscription()->latest_invoice);
  64.         }
  66.         $this->em->flush();
  67.     }
  69.     /**
  70.      * After update event
  71.      */
  72.     public function postUpdate(AfterEntityUpdatedEvent $event): void
  73.     {
  74.         $entity = $event->getEntityInstance();
  76.         // After updated a subscription, update it on Stripe. Then, set returned Stripe data on subscription
  77.         if ($entity instanceof Subscription) {
  78.             $this->stripe->subscriptionUpdate(
  79.                 $entity->getStripeId(),
  80.                 $entity->getIsCancelAtPeriodEnd(),
  81.                 $entity->getOffer()->getStripeId()
  82.             );
  83.             $this->subscriptionService->{($entity->getIsActive() ? 'enable' : 'cancel') . 'Subscription'}($entity);
  84.         }
  86.         $this->em->flush();
  87.     }
  89.     /**
  90.      * Before delete event
  91.      */
  92.     public function preDelete(BeforeEntityDeletedEvent $event): void
  93.     {
  94.         $entity = $event->getEntityInstance();
  96.         // Before deleting company, remove all employees
  97.         if ($entity instanceof Company) {
  98.             foreach ($entity->getEmployees() as $employee) {
  99.                 $this->preDeleteUser($employee);
  100.             }
  101.         }
  103.         // Before deleting user, check for data
  104.         if ($entity instanceof User) {
  105.             $this->preDeleteUser($entity);
  106.         }
  108.         // Before deleting offer, remove subscriptions and remove it from Stripe
  109.         if ($entity instanceof Offer) {
  110.             // Remove Stripe offer subscription's
  111.             foreach ($entity->getSubscribers() as $subscription) {
  112.                 $this->preDeleteSubscription($subscription);
  113.             }
  115.             // Remove Stripe offer
  116.             $this->stripe->productDelete($entity->getStripeId());
  117.         }
  119.         if ($entity instanceof Subscription) {
  120.             $this->preDeleteSubscription($entity);
  121.         }
  123.         $this->em->flush();
  124.     }
  126.     /**
  127.      * Before deleting user, check for data:
  128.      * - if there is another company admin, give him widget data and update his upload count
  129.      * - if not, delete the widget and uploads from DB & disk
  130.      * Also, clear user subscription's
  131.      */
  132.     private function preDeleteUser(User $user): void
  133.     {
  134.         // Get another company admin
  135.         /** @var User $companyAdmin */
  136.         $companyAdmin = $this->em->getRepository(User::class)->findAnAdmin($user);
  138.         foreach ($user->getWidgets() as $widget) {
  139.             // If there is another company admin, give him user widget and upload count
  140.             if ($companyAdmin) {
  141.                 $widget->setAuthor($companyAdmin);
  142.                 $widget->getAuthor()->setUploadCount($companyAdmin->getUploadCount() + $widget->getUploadCount());
  143.             } else {
  144.                 // Before deleting widget, remove widget snippet and uploads from disk
  145.                 $this->widgetService->deleteWidget($widget);
  146.             }
  147.         }
  149.         // Remove user subscription's
  150.         /** @var Subscription $subscription */
  151.         foreach ($user->getSubscriptions() as $subscription) {
  152.             $this->preDeleteSubscription($subscription->getId());
  153.         }
  154.     }
  156.     /**
  157.      * Before deleting subscription, remove it from Stripe
  158.      */
  159.     private function preDeleteSubscription(Subscription $subscription): void
  160.     {
  161.         $this->stripe->subscriptionCancel($subscription->getStripeId());
  162.     }
  163. }