Basis\Provider\PoolProvider

Complexity

Total Complexity

2

Size/Duplication

Total Lines	42
Duplicated Lines	0 %

Coupling/Cohesion

Components	0
Dependencies	7

Test Coverage

Coverage

0%

Importance

Changes	1
Bugs	0	Features	0

1 Method

Rating	Name	Duplication	Size	Complexity
B	register()	0	35	2

<?php

namespace Basis\Provider;

use Basis\Service;
use League\Container\ServiceProvider\AbstractServiceProvider;
use Tarantool\Client\Connection\StreamConnection;
use Tarantool\Client\Packer\PurePacker;
use Tarantool\Client\Request\DeleteRequest;
use Tarantool\Client\Request\InsertRequest;
use Tarantool\Client\Request\ReplaceRequest;
use Tarantool\Client\Request\UpdateRequest;
use Tarantool\Mapper\Client;
use Tarantool\Mapper\Mapper;
use Tarantool\Mapper\Plugin;
use Tarantool\Mapper\Plugin\Sequence;
use Tarantool\Mapper\Plugin\Spy;
use Tarantool\Mapper\Plugin\Temporal;
use Tarantool\Mapper\Pool;
use Tarantool\Mapper\Schema;

class PoolProvider extends AbstractServiceProvider
{
    protected $provides = [
        Pool::class,
    ];

    public function register()
    {
        $this->getContainer()->share(Pool::class, function () {
            $container = $this->getContainer();

            $mapper = $container->get(Mapper::class);

            $service = $container->get(Service::class);
            $mapper->serviceName = $service->getName();

            $pool = new Pool();
            $pool->register('default', $mapper);
            $pool->register($mapper->serviceName, $mapper);

            $pool->registerResolver(function ($name) use ($service) {
                if (in_array($name, $service->listServices())) {
                    $connection = new StreamConnection('tcp://'.$name.'-db:3301');
                    $packer = new PurePacker();
                    $client = new Client($connection, $packer);
                    $client->disableRequest(DeleteRequest::class);
                    $client->disableRequest(InsertRequest::class);
                    $client->disableRequest(ReplaceRequest::class);
                    $client->disableRequest(UpdateRequest::class);
                    $mapper = new Mapper($client);
                    $mapper->getPlugin(Sequence::class);
                    $mapper->getPlugin(Spy::class);
                    $mapper->getPlugin(Temporal::class);
                    $mapper->serviceName = $name;

The property serviceName does not seem to exist in Tarantool\Mapper\Mapper.

                    return $mapper;
                }
            });

            return $pool;
        });
    }
}