PeekAndPoke\Component\Slumber\Data\MongoDb\MongoDbStorageDriverFactory

Complexity

Total Complexity

5

Size/Duplication

Total Lines	67
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	1

Test Coverage

Coverage

0%

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	getDns2client()	0	4	1
A	create()	0	7	1
A	getOrCreateClient()	0	16	2

<?php
/**
 * Created by IntelliJ IDEA.
 * User: gerk
 * Date: 12.04.17
 * Time: 06:26
 */

namespace PeekAndPoke\Component\Slumber\Data\MongoDb;

use MongoDB\Client;
use PeekAndPoke\Component\Slumber\Data\EntityPool;
use PeekAndPoke\Component\Slumber\Data\StorageDriver;
use PeekAndPoke\Component\Slumber\Data\StorageDriverFactory;


/**
 * @author Karsten J. Gerber <kontakt@karsten-gerber.de>
 */
class MongoDbStorageDriverFactory implements StorageDriverFactory
{
    /** @var EntityPool */
    private $entityPool;
    /** @var MongoDbCodecSet */
    private $codecSet;

    /** @var Client[] Key is the dns, value is the Client */
    private $dns2client = [];

    /**
     * MongoDbStorageDriverFactory constructor.
     *
     * @param EntityPool      $entityPool
     * @param MongoDbCodecSet $codecSet
     */
    public function __construct(EntityPool $entityPool, MongoDbCodecSet $codecSet)
    {
        $this->entityPool = $entityPool;
        $this->codecSet   = $codecSet;
    }

    /**
     * @return Client[]
     */
    public function getDns2client()
    {
        return $this->dns2client;
    }

    /**
     * @param array            $config
     * @param string           $tableName
     * @param \ReflectionClass $baseClass
     *
     * @return StorageDriver|MongoDbStorageDriver
     */
    public function create($config, $tableName, \ReflectionClass $baseClass)
    {
        $client = $this->getOrCreateClient($config['dns']);
        $table  = $client->selectCollection($config['database'], $tableName);

        return new MongoDbStorageDriver($this->entityPool, $this->codecSet, $table, $baseClass);
    }

    /**
     * @param string $dns
     *
     * @return Client
     */
    private function getOrCreateClient($dns)
    {
        if (isset($this->dns2client[$dns])) {
            return $this->dns2client[$dns];
        }

        return $this->dns2client[$dns] = new Client(
            $dns,
            [
                // do not connect right away
                'connect' => false,
                // force return of associative array
                'typeMap' => ['root' => 'array', 'document' => 'array', 'array' => 'array'],
            ]
        );
    }
}