src/EventSubscriber/StdWebUsersSubscriber.php line 58

Open in your IDE?
  1. <?php
  2. namespace App\EventSubscriber;
  4. use App\Admin\Entity\StdWebUsers;
  5. use App\Event\StdWebUsersNewAddressEvent;
  6. use App\Event\StdWebUsersUpdateAddressEvent;
  7. use App\Event\StdWebUsersActivatedEvent;
  8. use App\API\SavannahBusClient;
  9. use App\Event\StdDeleteUserDataEvent;
  10. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  11. use Doctrine\ORM\EntityManagerInterface;
  13. class StdWebUsersSubscriber implements EventSubscriberInterface
  14. {
  15.     private $entityManager;
  16.     private $savannahclient;
  17.     public function __construct(EntityManagerInterface $entityManager,SavannahBusClient $client)
  18.     {
  19.         $this->entityManager=$entityManager;
  20.         $this->savannahclient=$client;
  21.     }
  23.     public static function getSubscribedEvents(): array
  24.     {
  25.         return [
  26.             StdWebUsersActivatedEvent::NAME => 'onActivatedWebuser',
  27.             StdWebUsersNewAddressEvent::NAME => 'onNewAddress',
  28.             StdWebUsersUpdateAddressEvent::NAME => 'onUpdateAddress',
  29.             StdDeleteUserDataEvent::NAME => 'onDeleteUserData',
  31.         ];
  32.     }
  34.     public function onNewAddress(StdWebUsersNewAddressEvent $event)
  35.     {
  36.         $address=$event->getWebUserAddress();
  37.         if(getenv("SAVANNAH_BUS_URL")!=""){
  38.             $response=$this->savannahclient->newUserAddress($address);
  39.         }
  40.     }
  41.     public function onUpdateAddress(StdWebUsersUpdateAddressEvent $event)
  42.     {
  43.         $address=$event->getWebUserAddress();
  44.         if(getenv("SAVANNAH_BUS_URL")!=""){
  45.             $response=$this->savannahclient->updateUserAddress($address);
  46.         }
  47.     }
  48.     public function onActivatedWebuser(StdWebUsersActivatedEvent $event)
  49.     {
  50.         $webuser=$event->getWebuser();
  51.         if(getenv("SAVANNAH_BUS_URL")!=""){
  52.             $response=$this->savannahclient->newUser($webuser);
  53.             if($response->success){
  54.                 $webuser->setErpCode($response->code);
  55.             }
  56.         }
  57.     }
  58.     public function onDeleteUserData(StdDeleteUserDataEvent $event)
  59.     {
  60.         $address=$event->getAddress();
  61.         // find user to anonimize
  62.         $usersToDeleteData=$this->entityManager->getRepository(StdWebUsers::class)->findByEmail($address);
  63.         foreach($usersToDeleteData as $user){
  64.             $user->setName("xxxxx");
  65.             $user->setPhone("");
  66.             $user->setMobile("");
  67.             $user->setUsername("xxxxx");
  68.             $user->setEmail('xxxxx@xxxx.xx');
  69.             // anonimize addresses
  70.             foreach ($user->getAddresses() as $address) {
  71.                 $address->setName("xxxxx");
  72.                 $address->setPhone("");
  73.                 $address->setMobile("");
  74.                 $user->addAddress($address);
  75.             }
  76.             $this->entityManager->persist($user);
  77.         }
  78.         $this->entityManager->flush();
  79.     }
  80. }
  81. ?>