*/ private array $managedRepositories = []; /** @param ContainerInterface $container A service locator containing the repositories */ public function __construct( private readonly ContainerInterface $container, ) { } /** * @param class-string $entityName * * @return ObjectRepository * @phpstan-return ($strictTypeCheck is true ? EntityRepository : ObjectRepository) * * @template T of object */ private function doGetRepository(EntityManagerInterface $entityManager, string $entityName, bool $strictTypeCheck): ObjectRepository { $metadata = $entityManager->getClassMetadata($entityName); $repositoryServiceId = $metadata->customRepositoryClassName; $customRepositoryName = $metadata->customRepositoryClassName; if ($customRepositoryName !== null) { // fetch from the container if ($this->container->has($customRepositoryName)) { $repository = $this->container->get($customRepositoryName); if (! $repository instanceof EntityRepository && $strictTypeCheck) { throw new RuntimeException(sprintf('The service "%s" must extend EntityRepository (e.g. by extending ServiceEntityRepository), "%s" given.', $repositoryServiceId, get_debug_type($repository))); } if (! $repository instanceof ObjectRepository) { throw new RuntimeException(sprintf('The service "%s" must implement ObjectRepository (or extend a base class, like ServiceEntityRepository), "%s" given.', $repositoryServiceId, get_debug_type($repository))); } if (! $repository instanceof EntityRepository) { Deprecation::trigger( 'doctrine/doctrine-bundle', 'https://github.com/doctrine/DoctrineBundle/pull/1722', 'The service "%s" of type "%s" should extend "%s", not doing so is deprecated.', $repositoryServiceId, get_debug_type($repository), EntityRepository::class, ); } /** @phpstan-var ObjectRepository */ return $repository; } // if not in the container but the class/id implements the interface, throw an error if (is_a($customRepositoryName, ServiceEntityRepositoryInterface::class, true)) { throw new RuntimeException(sprintf('The "%s" entity repository implements "%s", but its service could not be found. Make sure the service exists and is tagged with "%s".', $customRepositoryName, ServiceEntityRepositoryInterface::class, ServiceRepositoryCompilerPass::REPOSITORY_SERVICE_TAG)); } if (! class_exists($customRepositoryName)) { throw new RuntimeException(sprintf('The "%s" entity has a repositoryClass set to "%s", but this is not a valid class. Check your class naming. If this is meant to be a service id, make sure this service exists and is tagged with "%s".', $metadata->name, $customRepositoryName, ServiceRepositoryCompilerPass::REPOSITORY_SERVICE_TAG)); } // allow the repository to be created below } return $this->getOrCreateRepository($entityManager, $metadata); } /** * @param ClassMetadata $metadata * * @return ObjectRepository * * @template TEntity of object */ private function getOrCreateRepository( EntityManagerInterface $entityManager, ClassMetadata $metadata, ): ObjectRepository { $repositoryHash = $metadata->getName() . spl_object_hash($entityManager); if (isset($this->managedRepositories[$repositoryHash])) { /** @phpstan-var ObjectRepository */ return $this->managedRepositories[$repositoryHash]; } $repositoryClassName = $metadata->customRepositoryClassName ?: $entityManager->getConfiguration()->getDefaultRepositoryClassName(); /** @phpstan-var ObjectRepository */ return $this->managedRepositories[$repositoryHash] = new $repositoryClassName($entityManager, $metadata); } }