AtlassianConnectBundle\Storage\DoctrineTenantStorage

Complexity

Total Complexity

4

Size/Duplication

Total Lines	59
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	findById()	0	8	1
A	persist()	0	4	1
A	findByClientKey()	0	8	1
A	__construct()	0	4	1

<?php declare(strict_types = 1);

namespace AtlassianConnectBundle\Storage;

use AtlassianConnectBundle\Entity\TenantInterface;
use Doctrine\ORM\EntityManagerInterface;

/**
 * Class DoctrineTenantStorage
 */
class DoctrineTenantStorage implements TenantStorageInterface
{
    /**
     * @var EntityManagerInterface
     */
    private $entityManager;

    /**
     * @var string
     */
    private $tenantEntityClass;

    /**
     * DoctrineTenantStorage constructor.
     *
     * @param EntityManagerInterface $entityManager
     * @param string                 $tenantEntityClass
     */
    public function __construct(EntityManagerInterface $entityManager, string $tenantEntityClass)
    {
        $this->entityManager = $entityManager;
        $this->tenantEntityClass = $tenantEntityClass;
    }

    /**
     * @param string $clientKey
     * @return TenantInterface|null
     */
    public function findByClientKey(string $clientKey): ?TenantInterface
    {
        /** @var TenantInterface|null $tenant */
        $tenant = $this->entityManager
            ->getRepository($this->tenantEntityClass)
            ->findOneBy(['clientKey' => $clientKey]);

        return $tenant;
    }

    /**
     * @param int $tenantId
     * @return TenantInterface|null
     */
    public function findById(int $tenantId): ?TenantInterface
    {
        /** @var TenantInterface|null $tenant */
        $tenant = $this->entityManager
            ->getRepository($this->tenantEntityClass)
            ->find($tenantId);

        return $tenant;
    }

    /**
     * @param TenantInterface $tenant
     */
    public function persist(TenantInterface $tenant): void
    {
        $this->entityManager->persist($tenant);
        $this->entityManager->flush();
    }
}