Yiisoft\Yii\Cycle\Factory\RepositoryProvider

Complexity

Total Complexity

8

Size/Duplication

Total Lines	55
Duplicated Lines	0 %

Test Coverage

Coverage

0%

Importance

Changes	2
Bugs	0	Features	0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	getRepositoryFactories()	0	17	5
A	getDefinitions()	0	3	1
A	makeRepositoryFactory()	0	3	1
A	getExtensions()	0	13	1

<?php

declare(strict_types=1);

namespace Yiisoft\Yii\Cycle\Factory;

use Closure;
use Cycle\ORM\ORMInterface;
use Cycle\ORM\RepositoryInterface;
use Cycle\ORM\SchemaInterface;
use Psr\Container\ContainerInterface;
use Yiisoft\Di\Container;

The type Yiisoft\Di\Container was not found. Maybe you did not declare it correctly or list all dependencies?

use Yiisoft\Di\CompositeContainer;

The type Yiisoft\Di\CompositeContainer was not found. Maybe you did not declare it correctly or list all dependencies?

use Yiisoft\Di\Contracts\ServiceProviderInterface;

The type Yiisoft\Di\Contracts\ServiceProviderInterface was not found. Maybe you did not declare it correctly or list all dependencies?

use function is_string;

/**
 * This provider provides factories to the container for creating Cycle entity repositories.
 * Repository list is compiled based on data from the database schema.
 */
final class RepositoryProvider implements ServiceProviderInterface
{
    public function getDefinitions(): array
    {
        return [];
    }

    /**
     * @return array<Closure>
     */
    public function getExtensions(): array
    {
        return [
            ContainerInterface::class => function (ContainerInterface $container, ContainerInterface $extended) {
                /** @var ORMInterface */
                $orm = $extended->get(ORMInterface::class);
                /** @psalm-suppress InaccessibleMethod */
                $repositoryContainer = new Container($this->getRepositoryFactories($orm));
                $compositeContainer = new CompositeContainer();
                $compositeContainer->attach($repositoryContainer);
                $compositeContainer->attach($extended);

                return $compositeContainer;
            }
        ];
    }

    /**
     * @return array<string, Closure> Repository name as key and factory as value
     */
    private function getRepositoryFactories(ORMInterface $orm): array
    {
        $schema = $orm->getSchema();
        $result = [];
        $roles = [];
        foreach ($schema->getRoles() as $role) {
            $repository = $schema->define($role, SchemaInterface::REPOSITORY);
            if (is_string($repository)) {
                $roles[$repository][] = $role;
            }
        }
        foreach ($roles as $repo => $role) {
            if (count($role) === 1) {
                $result[$repo] = $this->makeRepositoryFactory($orm, current($role));
            }
        }
        return $result;
    }

    /**
     * @psalm-pure
     */
    private function makeRepositoryFactory(ORMInterface $orm, string $role): Closure
    {
        return static fn(): RepositoryInterface => $orm->getRepository($role);
    }
}