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

Indentation +3 added lines, -3 removed lines

@@ -352,9 +352,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);

src/MySQLReplication/MySQLReplicationFactory.php

Indentation +1 added lines, -1 removed lines

@@ -75,7 +75,7 @@
             'host' => $config->getIp(),
             'port' => $config->getPort(),
             'driver' => 'pdo_mysql',
-			'charset' => $config->getCharset()
+            'charset' => $config->getCharset()
         ]);
         $this->binLogAuth = new BinLogAuth();
         $this->MySQLRepository = new MySQLRepository($this->connection);