krowinski / php-mysql-replication

src/MySQLReplication/Event/Event.php

Indentation +16 added lines, -16 removed lines

@@ -86,10 +86,10 @@ 
         );
 
         if (ConstEventType::TABLE_MAP_EVENT === $eventInfo->getType()) {
-			$event = $this->rowEventService->makeRowEvent($binaryDataReader, $eventInfo)->makeTableMapDTO();
-			if ($event !== null) {
-				$this->eventDispatcher->dispatch(ConstEventsNames::TABLE_MAP, $event);
-			}
+            $event = $this->rowEventService->makeRowEvent($binaryDataReader, $eventInfo)->makeTableMapDTO();
+            if ($event !== null) {
+                $this->eventDispatcher->dispatch(ConstEventsNames::TABLE_MAP, $event);
+            }
         } else {
             if ([] !== $this->config->getEventsOnly() && !in_array($eventInfo->getType(), $this->config->getEventsOnly(), true)) {
                 return;
@@ -100,20 +100,20 @@ 
             }
 
             if (in_array($eventInfo->getType(), [ConstEventType::UPDATE_ROWS_EVENT_V1, ConstEventType::UPDATE_ROWS_EVENT_V2], true)) {
-				$event = $this->rowEventService->makeRowEvent($binaryDataReader, $eventInfo)->makeUpdateRowsDTO();
-				if ($event !== null) {
-					$this->eventDispatcher->dispatch(ConstEventsNames::UPDATE, $event);
-				}
+                $event = $this->rowEventService->makeRowEvent($binaryDataReader, $eventInfo)->makeUpdateRowsDTO();
+                if ($event !== null) {
+                    $this->eventDispatcher->dispatch(ConstEventsNames::UPDATE, $event);
+                }
             } elseif (in_array($eventInfo->getType(), [ConstEventType::WRITE_ROWS_EVENT_V1, ConstEventType::WRITE_ROWS_EVENT_V2], true)) {
-				$event = $this->rowEventService->makeRowEvent($binaryDataReader, $eventInfo)->makeWriteRowsDTO();
-				if ($event !== null) {
-					$this->eventDispatcher->dispatch(ConstEventsNames::WRITE, $event);
-				}
+                $event = $this->rowEventService->makeRowEvent($binaryDataReader, $eventInfo)->makeWriteRowsDTO();
+                if ($event !== null) {
+                    $this->eventDispatcher->dispatch(ConstEventsNames::WRITE, $event);
+                }
             } elseif (in_array($eventInfo->getType(), [ConstEventType::DELETE_ROWS_EVENT_V1, ConstEventType::DELETE_ROWS_EVENT_V2], true)) {
-            	$event = $this->rowEventService->makeRowEvent($binaryDataReader, $eventInfo)->makeDeleteRowsDTO();
-            	if ($event !== null) {
-					$this->eventDispatcher->dispatch(ConstEventsNames::DELETE, $event);
-				}
+                $event = $this->rowEventService->makeRowEvent($binaryDataReader, $eventInfo)->makeDeleteRowsDTO();
+                if ($event !== null) {
+                    $this->eventDispatcher->dispatch(ConstEventsNames::DELETE, $event);
+                }
             } elseif (ConstEventType::XID_EVENT === $eventInfo->getType()) {
                 $this->eventDispatcher->dispatch(ConstEventsNames::XID, (new XidEvent($eventInfo, $binaryDataReader))->makeXidDTO());
             } elseif (ConstEventType::ROTATE_EVENT === $eventInfo->getType()) {

src/MySQLReplication/Event/RowEvent/RowEvent.php

Unused Use Statements +16 added lines, -16 removed lines

@@ -2,22 +2,22 @@
 

 namespace MySQLReplication\Event\RowEvent;

 

-use MySQLReplication\BinaryDataReader\BinaryDataReader;

-use MySQLReplication\BinaryDataReader\Exception\BinaryDataReaderException;

-use MySQLReplication\Config\Config;

-use MySQLReplication\Config\Exception\ConfigException;

-use MySQLReplication\Definitions\ConstEventType;

-use MySQLReplication\Definitions\ConstFieldType;

-use MySQLReplication\Event\DTO\DeleteRowsDTO;

-use MySQLReplication\Event\DTO\TableMapDTO;

-use MySQLReplication\Event\DTO\UpdateRowsDTO;

-use MySQLReplication\Event\DTO\WriteRowsDTO;

-use MySQLReplication\Event\EventCommon;

-use MySQLReplication\Event\EventInfo;

-use MySQLReplication\Event\Exception\EventException;

-use MySQLReplication\Exception\MySQLReplicationException;

-use MySQLReplication\JsonBinaryDecoder\JsonBinaryDecoderException;

-use MySQLReplication\JsonBinaryDecoder\JsonBinaryDecoderFactory;

+use MySQLReplication\BinaryDataReader\BinaryDataReader;
+use MySQLReplication\BinaryDataReader\Exception\BinaryDataReaderException;
+use MySQLReplication\Config\Config;
+use MySQLReplication\Config\Exception\ConfigException;
+use MySQLReplication\Definitions\ConstEventType;
+use MySQLReplication\Definitions\ConstFieldType;
+use MySQLReplication\Event\DTO\DeleteRowsDTO;
+use MySQLReplication\Event\DTO\TableMapDTO;
+use MySQLReplication\Event\DTO\UpdateRowsDTO;
+use MySQLReplication\Event\DTO\WriteRowsDTO;
+use MySQLReplication\Event\EventCommon;
+use MySQLReplication\Event\EventInfo;
+use MySQLReplication\Event\Exception\EventException;
+use MySQLReplication\Exception\MySQLReplicationException;
+use MySQLReplication\JsonBinaryDecoder\JsonBinaryDecoderException;
+use MySQLReplication\JsonBinaryDecoder\JsonBinaryDecoderFactory;
 use MySQLReplication\Repository\MySQLRepository;

 

 /**

Indentation +3 added lines, -3 removed lines

@@ -401,9 +401,9 @@
                 $values[$name] = $this->getDatetime2($column);

             }

             elseif ($column['type'] === ConstFieldType::TIMESTAMP)

-			{

-				$values[$name] = date('c', $this->binaryDataReader->readUInt32());

-			}

+            {

+                $values[$name] = date('c', $this->binaryDataReader->readUInt32());

+            }

             elseif ($column['type'] === ConstFieldType::TIME2)

             {

                 $values[$name] = $this->getTime2($column);