src/Services/SwitchTenantManager.php line 34

Open in your IDE?
  1. <?php
  3. namespace App\Services;
  5. use App\Entity\Main\Tenant;
  6. use Doctrine\Persistence\ManagerRegistry;
  7. use Symfony\Component\HttpFoundation\RequestStack;
  9. class SwitchTenantManager
  10. {
  11.     private $event;
  13.     private $request;
  15.     public function __construct(ManagerRegistry $event, RequestStack $request)
  16.     {
  17.         $this->request = $request;
  18.         $this->event = $event;
  19.         $this->defaultManager = $this->event->getManager();
  20.     }
  22.     public function reconnect()
  23.     {
  24.         $server = $this->request->getCurrentRequest()->server->get('HTTP_HOST');
  25.         $item = explode(".", $server);
  26.         try {
  27.             $subDomain = $item[0];
  28.         } catch (\Exception $e) {
  29.             echo $e->getMessage() . 'The subdomain parameters is required in the URL';
  30.         }
  31.         // Testing tenant
  32.         try {
  33.             $tenantData = $this->defaultManager->getRepository(Tenant::class)->findOneBy([
  34.                 'subDomain' => $subDomain
  35.             ]);
  36.         } catch (\Exception $e) {
  37.             echo $e->getMessage() . 'The tenant for this ID not found';
  38.         }
  40.         $connection = $this->event->getConnection('tenant');
  41.         if (!is_null($tenantData)) {
  42.             $connection->changeParams($tenantData->getDbName(), $tenantData->getDbUser(), $tenantData->getDbPassword());
  43.             $connection->reconnect();
  44.         }
  45.     }
  46. }