> */ private array $managedRepositories = []; /** @param ContainerInterface $container A service locator containing the repositories */ public function __construct( private readonly ContainerInterface $container, ) { } /** * Gets the repository for an entity class. * * @param class-string $entityName * * @return EntityRepository * * @template T of object */ public function getRepository(EntityManagerInterface $entityManager, string $entityName): EntityRepository { $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) { throw new RuntimeException(sprintf( 'The service "%s" must extend EntityRepository (e.g. by extending ServiceEntityRepository), "%s" given.', $repositoryServiceId, get_debug_type($repository), )); } /** @phpstan-var EntityRepository */ 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 EntityRepository * * @template TEntity of object */ private function getOrCreateRepository( EntityManagerInterface $entityManager, ClassMetadata $metadata, ): EntityRepository { $repositoryHash = $metadata->getName() . spl_object_hash($entityManager); if (isset($this->managedRepositories[$repositoryHash])) { /** @phpstan-var EntityRepository */ return $this->managedRepositories[$repositoryHash]; } $repositoryClassName = $metadata->customRepositoryClassName ?: $entityManager->getConfiguration()->getDefaultRepositoryClassName(); /** @phpstan-var EntityRepository */ return $this->managedRepositories[$repositoryHash] = new $repositoryClassName($entityManager, $metadata); } }