src/ApplicationBundle/TimeService/TenantDbConfigResolver.php line 50

Open in your IDE?
  1. <?php
  3. namespace ApplicationBundle\TimeService;
  5. use CompanyGroupBundle\Entity\CompanyGroup;
  6. use Doctrine\ORM\EntityManagerInterface;
  7. use Symfony\Contracts\Cache\CacheInterface;
  8. use Symfony\Contracts\Cache\ItemInterface;
  10. class TenantDbConfigResolver
  11. {
  12.     private $cache;
  13.     private $companyGroupEntityManager;
  15.     public function __construct(CacheInterface $cache, EntityManagerInterface $companyGroupEntityManager)
  16.     {
  17.         $this->cache = $cache;
  18.         $this->companyGroupEntityManager = $companyGroupEntityManager;
  19.     }
  21.     public function resolveByAppId($appID): array
  22.     {
  23.         $appID = (int) $appID;
  24.         if ($appID <= 0) {
  25.             throw new \RuntimeException('Missing appID for tenant DB resolution.');
  26.         }
  28.         $cacheKey = $this->getCacheKey($appID);
  30.         return $this->cache->get($cacheKey, function (ItemInterface $item) use ($appID) {
  31.             $item->expiresAfter(900);
  33.             /** @var CompanyGroup|null $companyGroup */
  34.             $companyGroup = $this->companyGroupEntityManager
  35.                 ->getRepository(CompanyGroup::class)
  36.                 ->findOneBy([
  37.                     'appId' => $appID,
  38.                 ]);
  40.             if (!$companyGroup) {
  41.                 throw new \RuntimeException('CompanyGroup not found for appID.');
  42.             }
  44.             return [
  45.                 'dbName' => $companyGroup->getDbName(),
  46.                 'dbUser' => $companyGroup->getDbUser(),
  47.                 'dbPassword' => $companyGroup->getDbPass(),
  48.                 'dbHost' => $companyGroup->getDbHost(),
  49.             ];
  50.         });
  51.     }
  53.     public function invalidateByAppId($appID): void
  54.     {
  55.         $this->cache->delete($this->getCacheKey($appID));
  56.     }
  58.     private function getCacheKey($appID): string
  59.     {
  60.         return 'tenant_db_config_app_' . preg_replace('/[^a-zA-Z0-9_:-]/', '_', (string) $appID);
  61.     }
  62. }