SfCod\QueueBundle\Service\MongoDriver

Complexity

Total Complexity

6

Size/Duplication

Total Lines	83
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	0

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	setCredentials()	0	8	1
A	getClient()	0	12	2
A	setClient()	0	4	1
A	setDbname()	0	4	1
A	getDatabase()	0	4	1

<?php

namespace SfCod\QueueBundle\Service;

use MongoDB\Client;
use MongoDB\Database;

/**
 * Class MongoDriver
 *
 * @author Alexey Orlov <aaorlov88@gmail.com>
 * @author Virchenko Maksim <muslim1992@gmail.com>
 *
 * @package SfCod\QueueBundle\Service
 */
class MongoDriver implements MongoDriverInterface
{
    /**
     * @var string
     */
    protected $dbname;

    /**
     * @var array
     */
    protected $credentials;

    /**
     * @var Client
     */
    protected $client;

    /**
     * Mongodb credentials
     *
     * @param string $uri MongoDB connection string
     * @param array $uriOptions Additional connection string options
     * @param array $driverOptions Driver-specific options
     */
    public function setCredentials(string $uri, array $uriOptions = [], array $driverOptions = [])
    {
        $this->credentials = [
            'uri' => $uri,
            'uriOptions' => $uriOptions,
            'driverOptions' => $driverOptions,
        ];
    }

    /**
     * Get mongodb client
     *
     * @return Client
     */
    public function getClient(): Client
    {
        if (null === $this->client) {
            $this->client = new Client(
                $this->credentials['uri'],
                $this->credentials['uriOptions'],
                $this->credentials['driverOptions']
            );
        }

        return $this->client;
    }

    /**
     * Set client
     *
     * @param MongoDB\Client $client
     */
    public function setClient(Client $client)
    {
        $this->client = $client;
    }

    /**
     * Set mongo dbname
     *
     * @param string $dbname
     */
    public function setDbname(string $dbname = 'db')
    {
        $this->dbname = $dbname;
    }

    /**
     * Get mongo database
     *
     * @param null|string $name
     *
     * @return Database
     */
    public function getDatabase(?string $name = null): Database
    {
        return $this->getClient()->selectDatabase($name ?? $this->dbname);
    }
}