MySQLReplication\MySQLReplicationFactory

Complexity

Total Complexity

5

Size/Duplication

Total Lines	93
Duplicated Lines	0 %

Test Coverage

Coverage

91.43%

Importance

Changes	4
Bugs	2	Features	0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	unregisterSubscriber()	0	3	1
B	__construct()	0	30	1
A	registerSubscriber()	0	3	1
A	getDbConnection()	0	3	1
A	consume()	0	3	1

<?php

namespace MySQLReplication;

use Doctrine\DBAL\Connection;
use Doctrine\DBAL\DBALException;
use Doctrine\DBAL\DriverManager;
use MySQLReplication\BinaryDataReader\BinaryDataReaderException;
use MySQLReplication\BinaryDataReader\BinaryDataReaderFactory;
use MySQLReplication\BinLog\BinLogException;
use MySQLReplication\BinLog\BinLogSocketConnect;
use MySQLReplication\Cache\ArrayCache;
use MySQLReplication\Config\Config;
use MySQLReplication\Config\ConfigException;
use MySQLReplication\Event\Event;
use MySQLReplication\Event\EventException;
use MySQLReplication\Event\EventSubscribers;
use MySQLReplication\Event\RowEvent\RowEventFactory;
use MySQLReplication\Exception\MySQLReplicationException;
use MySQLReplication\JsonBinaryDecoder\JsonBinaryDecoderException;
use MySQLReplication\JsonBinaryDecoder\JsonBinaryDecoderFactory;
use MySQLReplication\Repository\MySQLRepository;
use MySQLReplication\Socket\Socket;
use MySQLReplication\Socket\SocketException;
use Psr\SimpleCache\InvalidArgumentException;
use Symfony\Component\EventDispatcher\EventDispatcher;

/**
 * Class MySQLReplicationFactory
 * @package MySQLReplication
 */
class MySQLReplicationFactory
{
    /**
     * @var Connection
     */
    private $connection;
    /**
     * @var EventDispatcher
     */
    private $eventDispatcher;
    /**
     * @var Event
     */
    private $event;

    /**
     * @throws MySQLReplicationException
     * @throws DBALException
     * @throws ConfigException
     * @throws BinLogException
     * @throws \MySQLReplication\Gtid\GtidException
     * @throws \MySQLReplication\Socket\SocketException
     */
    public function __construct()
    {
        Config::validate();

        $this->connection = DriverManager::getConnection(
            [
                'user' => Config::getUser(),
                'password' => Config::getPassword(),
                'host' => Config::getHost(),
                'port' => Config::getPort(),
                'driver' => 'pdo_mysql',
                'charset' => Config::getCharset()
            ]
        );
        $repository = new MySQLRepository($this->connection);
        $cache = new ArrayCache();

        $rowEventService = new RowEventFactory(
            $repository,
            new JsonBinaryDecoderFactory(),
            $cache
        );
        $this->eventDispatcher = new EventDispatcher();

        $this->event = new Event(
            new BinLogSocketConnect($repository, new Socket()),
            new BinaryDataReaderFactory(),
            $rowEventService,
            $this->eventDispatcher,
            $cache
        );
    }

    /**
     * @param EventSubscribers $eventSubscribers
     */
    public function registerSubscriber(EventSubscribers $eventSubscribers)
    {
        $this->eventDispatcher->addSubscriber($eventSubscribers);
    }

    /**
     * @param EventSubscribers $eventSubscribers
     */
    public function unregisterSubscriber(EventSubscribers $eventSubscribers)
    {
        $this->eventDispatcher->removeSubscriber($eventSubscribers);
    }

    /**
     * @return Connection
     */
    public function getDbConnection()
    {
        return $this->connection;
    }

    /**
     * @throws MySQLReplicationException
     * @throws InvalidArgumentException
     * @throws BinLogException
     * @throws BinaryDataReaderException
     * @throws ConfigException
     * @throws EventException
     * @throws JsonBinaryDecoderException
     * @throws SocketException
     */
    public function consume()
    {
        $this->event->consume();
    }
}