clean up

Author: krowinski

example/dump_events.php

@@ -1,52 +1,52 @@
-<?php
-
-namespace example;
-
-error_reporting(E_ALL);
-ini_set('display_errors', 1);
-date_default_timezone_set('UTC');
-include __DIR__ . '/../vendor/autoload.php';
-
-use MySQLReplication\Config\ConfigService;
-use MySQLReplication\Event\DTO\EventDTO;
-use MySQLReplication\Event\EventSubscribers;
-use MySQLReplication\MySQLReplicationFactory;
-
-$binLogStream = new MySQLReplicationFactory(
-    (new ConfigService())->makeConfigFromArray([
-        'user' => 'root',
-        'ip' => '127.0.0.1',
-        'password' => 'root',
-        //'mariaDbGtid' => '1-1-3,0-1-88',
-        //'gtid' => '9b1c8d18-2a76-11e5-a26b-000c2976f3f3:1-177592',
-    ])
-);
-
-/**
- * Class BenchmarkEventSubscribers
- * @package example
- */
-class MyEventSubscribers extends EventSubscribers
-{
-    /**
-     * @param EventDTO $event (your own handler more in EventSubscribers class )
-     */
-    public function allEvents(EventDTO $event)
-    {
-        // all events got __toString() implementation
-        echo $event;
-
-        // all events got JsonSerializable implementation
-        //echo json_encode($result, JSON_PRETTY_PRINT);
-
-        echo 'Memory usage ' . round(memory_get_usage() / 1048576, 2) . ' MB' . PHP_EOL;
-    }
-}
-
-// register your events handler here
-$binLogStream->registerSubscriber(new MyEventSubscribers());
-
-// start consuming events
-while (1) {
-    $binLogStream->binLogEvent();
+<?php
+
+namespace example;
+
+error_reporting(E_ALL);
+ini_set('display_errors', 1);
+date_default_timezone_set('UTC');
+include __DIR__ . '/../vendor/autoload.php';
+
+use MySQLReplication\Config\ConfigService;
+use MySQLReplication\Event\DTO\EventDTO;
+use MySQLReplication\Event\EventSubscribers;
+use MySQLReplication\MySQLReplicationFactory;
+
+$binLogStream = new MySQLReplicationFactory(
+    (new ConfigService())->makeConfigFromArray([
+        'user' => 'root',
+        'ip' => '127.0.0.1',
+        'password' => 'root',
+        //'mariaDbGtid' => '1-1-3,0-1-88',
+        //'gtid' => '9b1c8d18-2a76-11e5-a26b-000c2976f3f3:1-177592',
+    ])
+);
+
+/**
+ * Class BenchmarkEventSubscribers
+ * @package example
+ */
+class MyEventSubscribers extends EventSubscribers
+{
+    /**
+     * @param EventDTO $event (your own handler more in EventSubscribers class )
+     */
+    public function allEvents(EventDTO $event)
+    {
+        // all events got __toString() implementation
+        echo $event;
+
+        // all events got JsonSerializable implementation
+        //echo json_encode($result, JSON_PRETTY_PRINT);
+
+        echo 'Memory usage ' . round(memory_get_usage() / 1048576, 2) . ' MB' . PHP_EOL;
+    }
+}
+
+// register your events handler here
+$binLogStream->registerSubscriber(new MyEventSubscribers());
+
+// start consuming events
+while (1) {
+    $binLogStream->binLogEvent();
 }

src/MySQLReplication/Gtid/GtidService.php

@@ -19,6 +19,7 @@ public function __construct()
     /**
      * @param string $gtids
      * @return GtidCollection
+     * @throws GtidException
      */
     public function makeCollectionFromString($gtids)
     {

src/MySQLReplication/MySQLReplicationFactory.php

@@ -1,4 +1,5 @@
 <?php
+
 namespace MySQLReplication;
 
 use Doctrine\DBAL\Connection;
@@ -14,7 +15,6 @@
 use MySQLReplication\Event\EventSubscribers;
 use MySQLReplication\Event\RowEvent\RowEventService;
 use MySQLReplication\Exception\MySQLReplicationException;
-use MySQLReplication\Gtid\GtidCollection;
 use MySQLReplication\Gtid\GtidService;
 use MySQLReplication\Repository\MySQLRepository;
 use Symfony\Component\EventDispatcher\EventDispatcher;

src/MySQLReplication/Repository/MySQLRepository.php

@@ -13,16 +13,16 @@ class MySQLRepository
     /**
      * @var Connection
      */
-    private $conn;
+    private $connection;
 
     public function __construct(Connection $connection)
     {
-        $this->conn = $connection;
+        $this->connection = $connection;
     }
 
     public function __destruct()
     {
-        $this->conn->close();
+        $this->connection->close();
     }
 
     /**
@@ -56,12 +56,12 @@ public function getFields($schema, $table)
      */
     public function getConnection()
     {
-        if (false === $this->conn->ping()) {
-            $this->conn->close();
-            $this->conn->connect();
+        if (false === $this->connection->ping()) {
+            $this->connection->close();
+            $this->connection->connect();
         }
 
-        return $this->conn;
+        return $this->connection;
     }
 
     /**