FOS\ElasticaBundle\Manager\RepositoryManager

Complexity

Total Complexity

9

Size/Duplication

Total Lines	68
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	0

Test Coverage

Coverage

95.65%

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	addIndex()	0	7	1
A	getRepository()	0	15	3
A	hasRepository()	0	4	1
A	getRepositoryName()	0	8	2
A	createRepository()	0	8	2

<?php

/*
 * This file is part of the FOSElasticaBundle package.
 *
 * (c) FriendsOfSymfony <http://friendsofsymfony.github.com/>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

namespace FOS\ElasticaBundle\Manager;

use FOS\ElasticaBundle\Finder\FinderInterface;
use FOS\ElasticaBundle\Repository;

/**
 * @author Richard Miller <info@limethinking.co.uk>
 *
 * Allows retrieval of basic or custom repository for mapped Doctrine
 * entities/documents
 */
class RepositoryManager implements RepositoryManagerInterface
{
    /**
     * @var array
     */
    private $indexes = [];

    /**
     * @var array
     */
    private $repositories = [];

    public function addIndex(string $indexName, FinderInterface $finder, ?string $repositoryName = null): void
    {
        $this->indexes[$indexName] = [
            'finder' => $finder,
            'repositoryName' => $repositoryName,
        ];
    }

    /**
     * Return repository for entity.
     *
     * Returns custom repository if one specified otherwise
     * returns a basic repository.
     */
    public function getRepository(string $indexName): Repository
    {
        if (isset($this->repositories[$indexName])) {
            return $this->repositories[$indexName];
        }

        if (!$this->hasRepository($indexName)) {
            throw new \RuntimeException(sprintf('No repository configured for %s', $indexName));
        }

        $repository = $this->createRepository($indexName);
        $this->repositories[$indexName] = $repository;

        return $repository;
    }

    public function hasRepository(string $indexName): bool
    {
        return isset($this->indexes[$indexName]);
    }

    protected function getRepositoryName(string $indexName): string
    {
        if (isset($this->indexes[$indexName]['repositoryName'])) {
            return $this->indexes[$indexName]['repositoryName'];
        }

        return 'FOS\ElasticaBundle\Repository';
    }

    /**
     * @return mixed
     */
    private function createRepository(string $indexName)
    {
        if (!class_exists($repositoryName = $this->getRepositoryName($indexName))) {
            throw new \RuntimeException(sprintf('%s repository for %s does not exist', $repositoryName, $indexName));
        }

        return new $repositoryName($this->indexes[$indexName]['finder']);
    }
}