Moln / php-mysql-replication

src/MySQLReplication/MySQLReplicationFactory.php

Spacing +1 added lines, -1 removed lines

@@ -152,7 +152,7 @@
     {
         $retryNum = $this->config->getRetry();
         while (1) {
-            if (! $this->socket->isConnected()) {
+            if (!$this->socket->isConnected()) {
                 try {
                     if ($retryNum) {
                         $retryNum--;

src/MySQLReplication/Config/Config.php

Spacing +8 added lines, -8 removed lines

@@ -71,22 +71,22 @@ 
      */
     public function validate(): void
     {
-        if (! empty($this->host)) {
+        if (!empty($this->host)) {
             $ip = gethostbyname($this->host);
             if (false === filter_var($ip, FILTER_VALIDATE_IP)) {
                 throw new ConfigException(ConfigException::IP_ERROR_MESSAGE, ConfigException::IP_ERROR_CODE);
             }
         }
-        if (! empty($this->port) && false === filter_var(
+        if (!empty($this->port) && false === filter_var(
             $this->port,
             FILTER_VALIDATE_INT,
             ['options' => ['min_range' => 0]]
         )) {
             throw new ConfigException(ConfigException::PORT_ERROR_MESSAGE, ConfigException::PORT_ERROR_CODE);
         }
-        if (! empty($this->gtid)) {
+        if (!empty($this->gtid)) {
             foreach (explode(',', $this->gtid) as $gtid) {
-                if (! (bool)preg_match(
+                if (!(bool)preg_match(
                     '/^([0-9a-fA-F]{8}(?:-[0-9a-fA-F]{4}){3}-[0-9a-fA-F]{12})((?::[0-9-]+)+)$/',
                     $gtid,
                     $matches
@@ -95,7 +95,7 @@ 
                 }
             }
         }
-        if (! empty($this->slaveId) && false === filter_var(
+        if (!empty($this->slaveId) && false === filter_var(
             $this->slaveId,
             FILTER_VALIDATE_INT,
             ['options' => ['min_range' => 0]]
@@ -186,7 +186,7 @@ 
 
     public function checkDataBasesOnly(string $database): bool
     {
-        return [] !== $this->getDatabasesOnly() && ! self::matchNames($database, $this->getDatabasesOnly());
+        return [] !== $this->getDatabasesOnly() && !self::matchNames($database, $this->getDatabasesOnly());
     }
 
     public function getDatabasesOnly(): array
@@ -196,7 +196,7 @@ 
 
     public function checkTablesOnly(string $table): bool
     {
-        return [] !== $this->getTablesOnly() && ! self::matchNames($table, $this->getTablesOnly());
+        return [] !== $this->getTablesOnly() && !self::matchNames($table, $this->getTablesOnly());
     }
 
     private static function matchNames(string $subject, array $names): bool
@@ -217,7 +217,7 @@ 
 
     public function checkEvent(int $type): bool
     {
-        if ([] !== $this->getEventsOnly() && ! in_array($type, $this->getEventsOnly(), true)) {
+        if ([] !== $this->getEventsOnly() && !in_array($type, $this->getEventsOnly(), true)) {
             return false;
         }
 

src/MySQLReplication/BinLog/BinLogSocketConnect.php

Spacing +1 added lines, -1 removed lines

@@ -113,7 +113,7 @@
     private function isWriteSuccessful(string $data): void
     {
         $head = ord($data[0]);
-        if (! in_array($head, $this->packageOkHeader, true)) {
+        if (!in_array($head, $this->packageOkHeader, true)) {
             $errorCode = unpack('v', $data[1] . $data[2])[1];
             $errorMessage = '';
             $packetLength = strlen($data);

src/MySQLReplication/BinaryDataReader/BinaryDataReader.php

Spacing +1 added lines, -1 removed lines

@@ -289,7 +289,7 @@
 
     public function isComplete(int $size): bool
     {
-        return ! ($this->readBytes - 20 < $size);
+        return !($this->readBytes - 20 < $size);
     }
 
     public function getBinaryDataLength(): int

src/MySQLReplication/Socket/Socket.php

Spacing +3 added lines, -3 removed lines

@@ -29,7 +29,7 @@ 
     public function connectToStream(string $host, int $port): void
     {
         $this->socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
-        if (! $this->socket) {
+        if (!$this->socket) {
             throw new SocketException(
                 SocketException::SOCKET_UNABLE_TO_CREATE_MESSAGE . $this->getSocketErrorMessage(),
                 SocketException::SOCKET_UNABLE_TO_CREATE_CODE
@@ -38,7 +38,7 @@ 
         socket_set_block($this->socket);
         socket_set_option($this->socket, SOL_SOCKET, SO_KEEPALIVE, 1);
 
-        if (! socket_connect($this->socket, $host, $port)) {
+        if (!socket_connect($this->socket, $host, $port)) {
             throw new SocketException($this->getSocketErrorMessage(), $this->getSocketErrorCode());
         }
     }
@@ -73,7 +73,7 @@ 
 
     public function writeToSocket(string $data): void
     {
-        if (! socket_write($this->socket, $data, strlen($data))) {
+        if (!socket_write($this->socket, $data, strlen($data))) {
             throw new SocketException(
                 SocketException::SOCKET_UNABLE_TO_WRITE_MESSAGE . $this->getSocketErrorMessage(),
                 SocketException::SOCKET_UNABLE_TO_WRITE_CODE

src/MySQLReplication/Event/RowEvent/RowEvent.php

Spacing +6 added lines, -6 removed lines

@@ -351,7 +351,7 @@ 
         $fieldDTOCollection = $this->repository->getFields($data['schema_name'], $data['table_name']);
         $columnDTOCollection = new ColumnDTOCollection();
         // if you drop tables and parse of logs you will get empty scheme
-        if (! $fieldDTOCollection->isEmpty()) {
+        if (!$fieldDTOCollection->isEmpty()) {
             $columnLength = strlen($data['column_types']);
             for ($offset = 0; $offset < $columnLength; ++$offset) {
                 // this a dirty hack to prevent row events containing columns which have been dropped
@@ -391,7 +391,7 @@ 
      */
     public function makeWriteRowsDTO(): ?WriteRowsDTO
     {
-        if (! $this->rowInit()) {
+        if (!$this->rowInit()) {
             return null;
         }
 
@@ -455,7 +455,7 @@ 
         );
 
         $values = [];
-        while (! $this->binaryDataReader->isComplete($this->eventInfo->getSizeNoHeader())) {
+        while (!$this->binaryDataReader->isComplete($this->eventInfo->getSizeNoHeader())) {
             $values[] = $this->getColumnData($binaryData);
         }
 
@@ -894,7 +894,7 @@ 
      */
     public function makeDeleteRowsDTO(): ?DeleteRowsDTO
     {
-        if (! $this->rowInit()) {
+        if (!$this->rowInit()) {
             return null;
         }
 
@@ -916,7 +916,7 @@ 
      */
     public function makeUpdateRowsDTO(): ?UpdateRowsDTO
     {
-        if (! $this->rowInit()) {
+        if (!$this->rowInit()) {
             return null;
         }
 
@@ -925,7 +925,7 @@ 
         $afterBinaryData = $this->binaryDataReader->read($columnsBinarySize);
 
         $values = [];
-        while (! $this->binaryDataReader->isComplete($this->eventInfo->getSizeNoHeader())) {
+        while (!$this->binaryDataReader->isComplete($this->eventInfo->getSizeNoHeader())) {
             $values[] = [
                 'before' => $this->getColumnData($beforeBinaryData),
                 'after' => $this->getColumnData($afterBinaryData)

src/MySQLReplication/Event/RowEvent/ColumnDTO.php

Spacing +1 added lines, -1 removed lines

@@ -186,7 +186,7 @@
 
     public function isUnsigned(): bool
     {
-        return ! (stripos($this->fieldDTO->getColumnType(), 'unsigned') === false);
+        return !(stripos($this->fieldDTO->getColumnType(), 'unsigned') === false);
     }
 
     public function isPrimary(): bool

src/MySQLReplication/Event/Event.php

Spacing +1 added lines, -1 removed lines

@@ -93,7 +93,7 @@
         }
 
         // check for ignore and permitted events
-        if (! $this->config->checkEvent($eventInfo->getType())) {
+        if (!$this->config->checkEvent($eventInfo->getType())) {
             return;
         }