Bankiru\Api\Rpc\DependencyInjection\BankiruRpcServerExtension

Complexity

Total Complexity

6

Size/Duplication

Total Lines	93
Duplicated Lines	0 %

Coupling/Cohesion

Components	0
Dependencies	7

Test Coverage

Coverage

100%

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
B	load()	0	32	3
A	getAlias()	0	4	1
B	configureRouter()	0	46	2

<?php

namespace Bankiru\Api\Rpc\DependencyInjection;

use Bankiru\Api\Rpc\Cache\RouterCacheWarmer;
use Bankiru\Api\Rpc\Listener\ExceptionListener;
use Bankiru\Api\Rpc\Listener\RouterListener;
use Bankiru\Api\Rpc\Routing\ResourceMethodCollectionLoader;
use Bankiru\Api\Rpc\Routing\Router;
use Bankiru\Api\Rpc\RpcEvents;
use Sensio\Bundle\FrameworkExtraBundle\SensioFrameworkExtraBundle;
use Symfony\Bundle\SecurityBundle\SecurityBundle;
use Symfony\Component\Config\FileLocator;
use Symfony\Component\DependencyInjection\ContainerBuilder;
use Symfony\Component\DependencyInjection\Definition;
use Symfony\Component\DependencyInjection\Extension\Extension;
use Symfony\Component\DependencyInjection\Loader\YamlFileLoader;
use Symfony\Component\DependencyInjection\Reference;

final class BankiruRpcServerExtension extends Extension
{

    /** {@inheritdoc} */
    public function load(array $configs, ContainerBuilder $container)
    {
        $loader = new YamlFileLoader($container, new FileLocator(__DIR__ . '/../Resources/config'));

        $bundles = $container->getParameter('kernel.bundles');

        $configuration = new Configuration();
        $config        = $this->processConfiguration($configuration, $configs);

        $loader->load('rpc.yml');

        if (in_array(SensioFrameworkExtraBundle::class, $bundles, true)) {
            $loader->load('sensio.yml');

            if (in_array(SecurityBundle::class, $bundles, true)) {
                $loader->load('security.yml');
            }
        }

        $container
            ->register('rpc_server.exception_listener', ExceptionListener::class)
            ->setArguments([$config['debug'], new Reference('logger')])
            ->addTag(
                'kernel.event_listener',
                [
                    'event'  => RpcEvents::EXCEPTION,
                    'method' => 'onException',
                ]
            );

        $this->configureRouter($config['router'], $container);
    }

    public function getAlias()
    {
        return 'rpc_server';
    }

    /**
     * @param array            $router
     * @param ContainerBuilder $container
     */
    private function configureRouter(array $router, ContainerBuilder $container)
    {
        $endpoints        = $router['endpoints'];
        $endpointLoader   = $container->getDefinition('rpc_server.router.loader');
        $routerCollection = $container->getDefinition('rpc_server.router.collection');

        foreach ($endpoints as $name => $config) {
            $routerId = sprintf('rpc_server.endpoint_router.%s', $name);

            $container->register($routerId, Router::class)
                      ->setArguments(
                          [
                              new Definition(
                                  ResourceMethodCollectionLoader::class,
                                  [
                                      new Reference('rpc_server.router.resolver'),
                                      $config['resources'],
                                      $config['context'],
                                  ]
                              ),
                              $name,
                              [
                                  'cache_dir' => '%kernel.cache_dir%',
                              ],
                          ]
                      )
                      ->setPublic(false)
                      ->addTag('rpc_router');

            $container->register(sprintf('rpc_server.router_warmer.%s', $name), RouterCacheWarmer::class)
                      ->setPublic(false)
                      ->setArguments(
                          [
                              new Reference($routerId),
                          ]
                      )
                      ->addTag('kernel.cache_warmer');

            $container->register('rpc_server.router_listener.' . $name, RouterListener::class)
                      ->setArguments([$name, new Reference($routerId)])
                      ->addTag('kernel.event_listener', ['event' => 'rpc.request', 'method' => 'onRequest']);

            $endpointLoader->addMethodCall('addEndpoint', [$name, $config]);
            $routerCollection->addMethodCall('addRouter', [$name, new Reference($routerId)]);
        }
    }
}