ElasticsearchModule\Service\TransportFactory

Complexity

Total Complexity

6

Size/Duplication

Total Lines	32
Duplicated Lines	21.88 %

Coupling/Cohesion

Components	0
Dependencies	4

Test Coverage

Coverage

100%

Importance

Changes

0

2 Methods

Rating	Name	Duplication	Size	Complexity
B	create()	7	17	5
A	getServiceType()	0	4	1

<?php

namespace ElasticsearchModule\Service;

use Elasticsearch\ConnectionPool\AbstractConnectionPool;
use Elasticsearch\Transport;
use Zend\ServiceManager\Exception\ServiceNotCreatedException;
use Zend\ServiceManager\ServiceLocatorInterface;

/**
 * @author Pedro Alves <pedro.m.develop@gmail.com>
 */
class TransportFactory extends AbstractFactory
{
 
    /**
     * {@inheritDoc}
     */
    protected function create(ServiceLocatorInterface $serviceLocator, $config)
    {
        $retries = isset($config['retries']) ? $config['retries'] : 2;
        $sniffOnStart = isset($config['sniff_on_start']) ? $config['sniff_on_start'] : false;
        $connectionPool = $serviceLocator->get($config['connection_pool']);
        
        if (!$connectionPool instanceof AbstractConnectionPool) {

This code seems to be duplicated across your project.

            throw new ServiceNotCreatedException(sprintf(
                "The connection pool must be an instance of %s, %s given",
                AbstractConnectionPool::class,
                is_object($connectionPool) ? get_class($connectionPool) : gettype($connectionPool)
            ));
        }
        $loggers = $serviceLocator->get($config['loggers']);
        
        return new Transport($retries, $sniffOnStart, $connectionPool, $loggers['logger']);
    }

    /**
     * {@inheritDoc}
     */
    public function getServiceType()
    {
        return 'transport';
    }
}