MySQLReplication\Event\Event::consume()

Complexity

Conditions	14
Paths	25

Size

Total Lines	55
Code Lines	35

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	35
CRAP Score	14.9079

Importance

Changes

0

<?php
    public function consume()
    {
        $binaryDataReader = new BinaryDataReader($this->binLogSocketConnect->getResponse());

        // check EOF_Packet -> https://dev.mysql.com/doc/internals/en/packet-EOF_Packet.html
        if (self::EOF_HEADER_VALUE === $binaryDataReader->readUInt8()) {
            return;
        }

        // decode all events data
        $eventInfo = $this->createEventInfo($binaryDataReader);

        $eventDTO = null;

        // always parse table map event but propagate when needed (we need this for creating table cache)
        if (ConstEventType::TABLE_MAP_EVENT === $eventInfo->getType()) {

The condition MySQLReplication\Definitions\ConstEventType::TABLE_MAP_EVENT === $eventInfo->getType() is always false.

            $eventDTO = $this->rowEventFactory->makeRowEvent($binaryDataReader, $eventInfo)->makeTableMapDTO();
        }

        if (!Config::checkEvent($eventInfo->getType())) {

$eventInfo->getType() of type string is incompatible with the type integer expected by parameter $type of MySQLReplication\Config\Config::checkEvent().

            return;
        }

        if (in_array(
            $eventInfo->getType(), [ConstEventType::UPDATE_ROWS_EVENT_V1, ConstEventType::UPDATE_ROWS_EVENT_V2], true
        )) {
            $eventDTO = $this->rowEventFactory->makeRowEvent($binaryDataReader, $eventInfo)->makeUpdateRowsDTO();
        } else if (in_array(
            $eventInfo->getType(), [ConstEventType::WRITE_ROWS_EVENT_V1, ConstEventType::WRITE_ROWS_EVENT_V2], true
        )) {
            $eventDTO = $this->rowEventFactory->makeRowEvent($binaryDataReader, $eventInfo)->makeWriteRowsDTO();
        } else if (in_array(
            $eventInfo->getType(), [ConstEventType::DELETE_ROWS_EVENT_V1, ConstEventType::DELETE_ROWS_EVENT_V2], true
        )) {
            $eventDTO = $this->rowEventFactory->makeRowEvent($binaryDataReader, $eventInfo)->makeDeleteRowsDTO();
        } else if (ConstEventType::XID_EVENT === $eventInfo->getType()) {

The condition MySQLReplication\Definitions\ConstEventType::XID_EVENT === $eventInfo->getType() is always false.

            $eventDTO = (new XidEvent($eventInfo, $binaryDataReader))->makeXidDTO();
        } else if (ConstEventType::ROTATE_EVENT === $eventInfo->getType()) {

The condition MySQLReplication\Definitions\ConstEventType::ROTATE_EVENT === $eventInfo->getType() is always false.

            $this->cache->clear();
            $eventDTO = (new RotateEvent($eventInfo, $binaryDataReader))->makeRotateEventDTO();
        } else if (ConstEventType::GTID_LOG_EVENT === $eventInfo->getType()) {

The condition MySQLReplication\Definitions\ConstEventType::GTID_LOG_EVENT === $eventInfo->getType() is always false.

            $eventDTO = (new GtidEvent($eventInfo, $binaryDataReader))->makeGTIDLogDTO();
        } else if (ConstEventType::QUERY_EVENT === $eventInfo->getType()) {

The condition MySQLReplication\Definitions\ConstEventType::QUERY_EVENT === $eventInfo->getType() is always false.

            $eventDTO = $this->filterDummyMariaDbEvents(
                (new QueryEvent($eventInfo, $binaryDataReader))->makeQueryDTO()
            );
        } else if (ConstEventType::MARIA_GTID_EVENT === $eventInfo->getType()) {

The condition MySQLReplication\Definitions\ConstEventType::MARIA_GTID_EVENT === $eventInfo->getType() is always false.

            $eventDTO = (new MariaDbGtidEvent($eventInfo, $binaryDataReader))->makeMariaDbGTIDLogDTO();
        } else if (ConstEventType::FORMAT_DESCRIPTION_EVENT === $eventInfo->getType()) {

The condition MySQLReplication\Definitions\ConstEventType::FORMAT_DESCRIPTION_EVENT === $eventInfo->getType() is always false.

            $eventDTO = new FormatDescriptionEventDTO($eventInfo);
        } else if (ConstEventType::HEARTBEAT_LOG_EVENT === $eventInfo->getType()) {

The condition MySQLReplication\Definitions\ConstEventType::HEARTBEAT_LOG_EVENT === $eventInfo->getType() is always false.

            $eventDTO = new HeartbeatDTO($eventInfo);
        }

        $this->dispatch($eventDTO);
    }