vendor/bestit/commercetools-odm/src/RepositoryFactory.php line 66

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace BestIt\CommercetoolsODM;
  7. use BestIt\CTAsyncPool\PoolAwareTrait;
  8. use BestIt\CTAsyncPool\PoolInterface;
  9. use BestIt\CommercetoolsODM\Filter\FilterManagerInterface;
  10. use BestIt\CommercetoolsODM\Helper\FilterManagerAwareTrait;
  11. use BestIt\CommercetoolsODM\Mapping\ClassMetadataInterface;
  12. use BestIt\CommercetoolsODM\Model\DefaultRepository;
  13. use Doctrine\Common\Persistence\ObjectRepository;
  14. use Psr\Log\LoggerAwareInterface;
  15. use Psr\Log\LoggerAwareTrait;
  16. use Psr\Log\NullLogger;
  18. /**
  19. * Factory to provide the system with repositories.
  20. *
  21. * @author lange <lange@bestit-online.de>
  22. * @package BestIt\CommercetoolsODM
  23. */
  24. class RepositoryFactory implements LoggerAwareInterface, RepositoryFactoryInterface
  25. {
  26. use FilterManagerAwareTrait;
  27. use LoggerAwareTrait;
  28. use PoolAwareTrait;
  30. /**
  31. * @var string The default repository for this factory.
  32. */
  33. public const DEFAULT_REPOSITORY = DefaultRepository::class;
  35. /**
  36. * @var ObjectRepository[] Loaded repos.
  37. */
  38. private $cachedRepos = [];
  40. /**
  41. * RepositoryFactory constructor.
  42. *
  43. * @param FilterManagerInterface $filterManager
  44. * @param PoolInterface|null $pool
  45. */
  46. public function __construct(FilterManagerInterface $filterManager, PoolInterface $pool = null)
  47. {
  48. $this->logger = new NullLogger();
  50. $this->setFilterManager($filterManager);
  52. if ($pool) {
  53. $this->setPool($pool);
  54. }
  55. }
  57. /**
  58. * Gets the repository for a class.
  59. *
  60. * @param DocumentManagerInterface $documentManager
  61. * @param string $className
  62. *
  63. * @return ObjectRepository
  64. */
  65. #[\Override]
  66. public function getRepository(DocumentManagerInterface $documentManager, string $className): ObjectRepository
  67. {
  68. if (!@$this->cachedRepos[$className]) {
  69. $metadata = $documentManager->getClassMetadata($className);
  70. $repository = static::DEFAULT_REPOSITORY;
  72. if (($metadata instanceof ClassMetadataInterface) && ($tmp = $metadata->getRepository())) {
  73. $repository = $tmp;
  74. }
  76. $this->cachedRepos[$className] = $repository = new $repository(
  77. $metadata,
  78. $documentManager,
  79. $documentManager->getQueryHelper(),
  80. $this->getFilterManager(),
  81. $this->getPool()
  82. );
  84. if ($repository instanceof LoggerAwareInterface) {
  85. $repository->setLogger($this->logger);
  86. }
  87. }
  89. return $this->cachedRepos[$className];
  90. }
  91. }