Change static properties to non-static.

Author: Moln

README.md

@@ -1,28 +1,35 @@
 php-mysql-replication
 =========
-[![Build Status](https://travis-ci.org/krowinski/php-mysql-replication.svg?branch=master)](https://travis-ci.org/krowinski/php-mysql-replication)
-[![Latest Stable Version](https://poser.pugx.org/krowinski/php-mysql-replication/v/stable)](https://packagist.org/packages/krowinski/php-mysql-replication) [![Total Downloads](https://poser.pugx.org/krowinski/php-mysql-replication/downloads)](https://packagist.org/packages/krowinski/php-mysql-replication) [![Latest Unstable Version](https://poser.pugx.org/krowinski/php-mysql-replication/v/unstable)](https://packagist.org/packages/krowinski/php-mysql-replication) 
-[![SensioLabsInsight](https://insight.sensiolabs.com/projects/4a0e49d4-3802-41d3-bb32-0a8194d0fd4d/mini.png)](https://insight.sensiolabs.com/projects/4a0e49d4-3802-41d3-bb32-0a8194d0fd4d) [![License](https://poser.pugx.org/krowinski/php-mysql-replication/license)](https://packagist.org/packages/krowinski/php-mysql-replication)
-[![Scrutinizer Code Quality](https://scrutinizer-ci.com/g/krowinski/php-mysql-replication/badges/quality-score.png?b=master)](https://scrutinizer-ci.com/g/krowinski/php-mysql-replication/?branch=master)
-[![Code Coverage](https://scrutinizer-ci.com/g/krowinski/php-mysql-replication/badges/coverage.png?b=master)](https://scrutinizer-ci.com/g/krowinski/php-mysql-replication/?branch=master)
+[![Build Status](https://travis-ci.org/moln/php-mysql-replication.svg?branch=master)](https://travis-ci.org/moln/php-mysql-replication)
+[![Latest Stable Version](https://poser.pugx.org/moln/php-mysql-replication/v/stable)](https://packagist.org/packages/moln/php-mysql-replication) [![Total Downloads](https://poser.pugx.org/moln/php-mysql-replication/downloads)](https://packagist.org/packages/moln/php-mysql-replication) [![Latest Unstable Version](https://poser.pugx.org/moln/php-mysql-replication/v/unstable)](https://packagist.org/packages/moln/php-mysql-replication) 
+[![SensioLabsInsight](https://insight.sensiolabs.com/projects/4a0e49d4-3802-41d3-bb32-0a8194d0fd4d/mini.png)](https://insight.sensiolabs.com/projects/4a0e49d4-3802-41d3-bb32-0a8194d0fd4d) [![License](https://poser.pugx.org/moln/php-mysql-replication/license)](https://packagist.org/packages/moln/php-mysql-replication)
+[![Scrutinizer Code Quality](https://scrutinizer-ci.com/g/moln/php-mysql-replication/badges/quality-score.png?b=master)](https://scrutinizer-ci.com/g/moln/php-mysql-replication/?branch=master)
+[![Code Coverage](https://scrutinizer-ci.com/g/moln/php-mysql-replication/badges/coverage.png?b=master)](https://scrutinizer-ci.com/g/moln/php-mysql-replication/?branch=master)
 
 Pure PHP Implementation of MySQL replication protocol. This allow you to receive event like insert, update, delete with their data and raw SQL queries.
 
 Based on a great work of creators：https://github.com/noplay/python-mysql-replication and https://github.com/fengxiangyun/mysql-replication
 
+--------------------------------------------------
+
+**Note:** Resolve [krowinski/php-mysql-replication#94](https://github.com/krowinski/php-mysql-replication/issues/94),  change static config properties to non-static.
+
+--------------------------------------------------
+
+
 Installation
 =========
 
 In you project
 
 ```sh
-composer require krowinski/php-mysql-replication
+composer require moln/php-mysql-replication
 ```
 
 or standalone 
 
 ```sh
-git clone https://github.com/krowinski/php-mysql-replication.git
+git clone https://github.com/moln/php-mysql-replication.git
 
 composer install -o
 ```
@@ -89,9 +96,9 @@ Available options:
 
 'binLogPosition' - bin log position to start from 
 
-'eventsOnly' - array  to listen on events (full list in [ConstEventType.php](https://github.com/krowinski/php-mysql-replication/blob/master/src/MySQLReplication/Definitions/ConstEventType.php) file)
+'eventsOnly' - array  to listen on events (full list in [ConstEventType.php](https://github.com/moln/php-mysql-replication/blob/master/src/MySQLReplication/Definitions/ConstEventType.php) file)
 
-'eventsIgnore' - array to ignore events (full list in [ConstEventType.php](https://github.com/krowinski/php-mysql-replication/blob/master/src/MySQLReplication/Definitions/ConstEventType.php) file) 
+'eventsIgnore' - array to ignore events (full list in [ConstEventType.php](https://github.com/moln/php-mysql-replication/blob/master/src/MySQLReplication/Definitions/ConstEventType.php) file) 
 
 'tablesOnly' - array to only listen on given tables (default all tables) 
 
@@ -118,7 +125,7 @@ Python: https://github.com/noplay/python-mysql-replication
 Examples
 =========
 
-All examples are available in the [examples directory](https://github.com/krowinski/php-mysql-replication/tree/master/example)
+All examples are available in the [examples directory](https://github.com/moln/php-mysql-replication/tree/master/example)
 
 This example will dump all replication events to the console:
 
@@ -397,14 +404,14 @@ FAQ
  Well first of all mysql don't give you async calls. You usually need to program this in your application (by event dispaching and adding to some queue system and if your db have many point of entry like web, backend other microservices its not always cheap to add processing to all of them. But using mysql replication protocol you can lisen on write events and process then asynchronously (best combo it's to add item to some queue system like rabbitmq, redis or kafka). Also in invalidate cache,  search engine replication, real time analytics and audits.
 
 2. ### It's awsome ! but what is the catch ?
- Well first of all you need to know that a lot of events may come through, like if you update 1 000 000  records in table   "bar" and you need this one insert from your table "foo" Then all must be processed by script and you need to wait for your data. This is normal and this how it's work. You can speed up using [config options](https://github.com/krowinski/php-mysql-replication#configuration).
+ Well first of all you need to know that a lot of events may come through, like if you update 1 000 000  records in table   "bar" and you need this one insert from your table "foo" Then all must be processed by script and you need to wait for your data. This is normal and this how it's work. You can speed up using [config options](https://github.com/moln/php-mysql-replication#configuration).
 Also if script crashes you need to save from time to time position form binlog (or gtid) to start from this position when  you run this script again to avoid duplicates.
 
 3. ### I need to process 1 000 000 records and its taking forever!!
  Like I mention in 1 point use queue system like rabbitmq, redis or kafka, they will give you ability to process data in multiple scripts.
 
 4. ### I have a problem ? you script is missing something ! I have found a bug !
- Create an [issue](https://github.com/krowinski/php-mysql-replication/issues) I will try to work on it in my free time :)
+ Create an [issue](https://github.com/moln/php-mysql-replication/issues) I will try to work on it in my free time :)
 
 5. ### How much its give overhead to mysql server ?
  It work like any other mysql in slave mode and its giving same overhead.

src/MySQLReplication/BinLog/BinLogServerInfo.php

@@ -8,35 +8,38 @@ class BinLogServerInfo
     private const MYSQL_VERSION_MARIADB = 'MariaDB';
     private const MYSQL_VERSION_PERCONA = 'Percona';
     private const MYSQL_VERSION_GENERIC = 'MySQL';
-    private static $serverInfo = [];
+    /**
+     * @var array
+     */
+    private $serverInfo;
 
-    public static function parsePackage(string $data, string $version): void
+    public static function parsePackage(string $data, string $version): BinLogServerInfo
     {
         $i = 0;
         $length = strlen($data);
-        self::$serverInfo['protocol_version'] = ord($data[$i]);
+        $serverInfo['protocol_version'] = ord($data[$i]);
         ++$i;
 
         //version
-        self::$serverInfo['server_version'] = '';
+        $serverInfo['server_version'] = '';
         $start = $i;
         for ($i = $start; $i < $length; ++$i) {
             if ($data[$i] === chr(0)) {
                 ++$i;
                 break;
             }
-            self::$serverInfo['server_version'] .= $data[$i];
+            $serverInfo['server_version'] .= $data[$i];
         }
 
         //connection_id 4 bytes
-        self::$serverInfo['connection_id'] = unpack('I', $data[$i] . $data[++$i] . $data[++$i] . $data[++$i])[1];
+        $serverInfo['connection_id'] = unpack('I', $data[$i] . $data[++$i] . $data[++$i] . $data[++$i])[1];
         ++$i;
 
         //auth_plugin_data_part_1
         //[len=8] first 8 bytes of the auth-plugin data
-        self::$serverInfo['salt'] = '';
+        $serverInfo['salt'] = '';
         for ($j = $i; $j < $i + 8; ++$j) {
-            self::$serverInfo['salt'] .= $data[$j];
+            $serverInfo['salt'] .= $data[$j];
         }
         $i += 8;
 
@@ -47,7 +50,7 @@ public static function parsePackage(string $data, string $version): void
         $i += 2;
 
         //character_set (1) -- default server character-set, only the lower 8-bits Protocol::CharacterSet (optional)
-        self::$serverInfo['character_set'] = $data[$i];
+        $serverInfo['character_set'] = $data[$i];
         ++$i;
 
         //status_flags (2) -- Protocol::StatusFlags (optional)
@@ -67,23 +70,30 @@ public static function parsePackage(string $data, string $version): void
         //next salt
         if ($length >= $i + $salt_len) {
             for ($j = $i; $j < $i + $salt_len; ++$j) {
-                self::$serverInfo['salt'] .= $data[$j];
+                $serverInfo['salt'] .= $data[$j];
             }
 
         }
-        self::$serverInfo['auth_plugin_name'] = '';
+        $serverInfo['auth_plugin_name'] = '';
         $i += $salt_len + 1;
         for ($j = $i; $j < $length - 1; ++$j) {
-            self::$serverInfo['auth_plugin_name'] .= $data[$j];
+            $serverInfo['auth_plugin_name'] .= $data[$j];
         }
 
-        self::$serverInfo['version_name'] = self::parseVersion($version);
-        self::$serverInfo['version_revision'] = self::parseRevision($version);
+        $serverInfo['version_name'] = self::parseVersion($version);
+        $serverInfo['version_revision'] = self::parseRevision($version);
+
+        return new self($serverInfo);
+    }
+
+    public function __construct(array $serverInfo)
+    {
+        $this->serverInfo = $serverInfo;
     }
 
-    public static function getSalt(): string
+    public function getSalt(): string
     {
-        return self::$serverInfo['salt'];
+        return $this->serverInfo['salt'];
     }
 
     /**
@@ -103,29 +113,29 @@ private static function parseVersion(string $version): string
         return self::MYSQL_VERSION_GENERIC;
     }
 
-    public static function getRevision(): float
+    public function getRevision(): float
     {
-        return self::$serverInfo['version_revision'];
+        return $this->serverInfo['version_revision'];
     }
 
-    public static function getVersion(): string
+    public function getVersion(): string
     {
-        return self::$serverInfo['version_name'];
+        return $this->serverInfo['version_name'];
     }
 
-    public static function isMariaDb(): bool
+    public function isMariaDb(): bool
     {
-        return self::MYSQL_VERSION_MARIADB === self::getVersion();
+        return self::MYSQL_VERSION_MARIADB === $this->getVersion();
     }
 
-    public static function isPercona(): bool
+    public function isPercona(): bool
     {
-        return self::MYSQL_VERSION_PERCONA === self::getVersion();
+        return self::MYSQL_VERSION_PERCONA === $this->getVersion();
     }
 
-    public static function isGeneric(): bool
+    public function isGeneric(): bool
     {
-        return self::MYSQL_VERSION_GENERIC === self::getVersion();
+        return self::MYSQL_VERSION_GENERIC === $this->getVersion();
     }
 
     private static function parseRevision(string $version): float

src/MySQLReplication/BinLog/BinLogSocketConnect.php

@@ -28,25 +28,44 @@ class BinLogSocketConnect
     private $socket;
     private $binLogCurrent;
 
+    /**
+     * @var Config
+     */
+    private $config;
+    /**
+     * @var BinLogServerInfo
+     */
+    private $binLogServerInfo;
+
     /**
      * @throws BinLogException
      * @throws GtidException
      * @throws SocketException
      */
     public function __construct(
+        Config $config,
         RepositoryInterface $repository,
         SocketInterface $socket
     ) {
+        $this->config = $config;
         $this->repository = $repository;
         $this->socket = $socket;
         $this->binLogCurrent = new BinLogCurrent();
 
-        $this->socket->connectToStream(Config::getHost(), Config::getPort());
-        BinLogServerInfo::parsePackage($this->getResponse(false), $this->repository->getVersion());
+        $this->socket->connectToStream($config->getHost(), $config->getPort());
+        $this->binLogServerInfo = BinLogServerInfo::parsePackage(
+            $this->getResponse(false),
+            $this->repository->getVersion()
+        );
         $this->authenticate();
         $this->getBinlogStream();
     }
 
+    public function getBinLogServerInfo(): BinLogServerInfo
+    {
+        return $this->binLogServerInfo;
+    }
+
     /**
      * @throws BinLogException
      * @throws SocketException
@@ -111,11 +130,11 @@ private function authenticate(): void
         for ($i = 0; $i < 23; ++$i) {
             $data .= chr(0);
         }
-        $result = sha1(Config::getPassword(), true) ^ sha1(
-                BinLogServerInfo::getSalt() . sha1(sha1(Config::getPassword(), true), true), true
+        $result = sha1($this->config->getPassword(), true) ^ sha1(
+                $this->binLogServerInfo->getSalt() . sha1(sha1($this->config->getPassword(), true), true), true
             );
 
-        $data = $data . Config::getUser() . chr(0) . chr(strlen($result)) . $result;
+        $data = $data . $this->config->getUser() . chr(0) . chr(strlen($result)) . $result;
         $str = pack('L', strlen($data));
         $s = $str[0] . $str[1] . $str[2];
         $data = $s . chr(1) . $data;
@@ -152,17 +171,17 @@ private function getBinlogStream(): void
             $this->execute('SET @master_binlog_checksum = @@global.binlog_checksum');
         }
 
-        if (0 !== Config::getHeartbeatPeriod()) {
+        if (0 !== $this->config->getHeartbeatPeriod()) {
             // master_heartbeat_period is in nanoseconds
-            $this->execute('SET @master_heartbeat_period = ' . Config::getHeartbeatPeriod() * 1000000000);
+            $this->execute('SET @master_heartbeat_period = ' . $this->config->getHeartbeatPeriod() * 1000000000);
         }
 
         $this->registerSlave();
 
-        if ('' !== Config::getMariaDbGtid()) {
+        if ('' !== $this->config->getMariaDbGtid()) {
             $this->setBinLogDumpMariaGtid();
         }
-        if ('' !== Config::getGtid()) {
+        if ('' !== $this->config->getGtid()) {
             $this->setBinLogDumpGtid();
         } else {
             $this->setBinLogDump();
@@ -188,19 +207,19 @@ private function registerSlave(): void
     {
         $host = gethostname();
         $hostLength = strlen($host);
-        $userLength = strlen(Config::getUser());
-        $passLength = strlen(Config::getPassword());
+        $userLength = strlen($this->config->getUser());
+        $passLength = strlen($this->config->getPassword());
 
         $data = pack('l', 18 + $hostLength + $userLength + $passLength);
         $data .= chr(self::COM_REGISTER_SLAVE);
-        $data .= pack('V', Config::getSlaveId());
+        $data .= pack('V', $this->config->getSlaveId());
         $data .= pack('C', $hostLength);
         $data .= $host;
         $data .= pack('C', $userLength);
-        $data .= Config::getUser();
+        $data .= $this->config->getUser();
         $data .= pack('C', $passLength);
-        $data .= Config::getPassword();
-        $data .= pack('v', Config::getPort());
+        $data .= $this->config->getPassword();
+        $data .= pack('v', $this->config->getPort());
         $data .= pack('V', 0);
         $data .= pack('V', 0);
 
@@ -215,11 +234,11 @@ private function registerSlave(): void
     private function setBinLogDumpMariaGtid(): void
     {
         $this->execute('SET @mariadb_slave_capability = 4');
-        $this->execute('SET @slave_connect_state = \'' . Config::getMariaDbGtid() . '\'');
+        $this->execute('SET @slave_connect_state = \'' . $this->config->getMariaDbGtid() . '\'');
         $this->execute('SET @slave_gtid_strict_mode = 0');
         $this->execute('SET @slave_gtid_ignore_duplicates = 0');
 
-        $this->binLogCurrent->setMariaDbGtid(Config::getMariaDbGtid());
+        $this->binLogCurrent->setMariaDbGtid($this->config->getMariaDbGtid());
     }
 
     /**
@@ -230,11 +249,11 @@ private function setBinLogDumpMariaGtid(): void
      */
     private function setBinLogDumpGtid(): void
     {
-        $collection = GtidCollection::makeCollectionFromString(Config::getGtid());
+        $collection = GtidCollection::makeCollectionFromString($this->config->getGtid());
 
         $data = pack('l', 26 + $collection->getEncodedLength()) . chr(self::COM_BINLOG_DUMP_GTID);
         $data .= pack('S', 0);
-        $data .= pack('I', Config::getSlaveId());
+        $data .= pack('I', $this->config->getSlaveId());
         $data .= pack('I', 3);
         $data .= chr(0);
         $data .= chr(0);
@@ -246,7 +265,7 @@ private function setBinLogDumpGtid(): void
         $this->socket->writeToSocket($data);
         $this->getResponse();
 
-        $this->binLogCurrent->setGtid(Config::getGtid());
+        $this->binLogCurrent->setGtid($this->config->getGtid());
     }
 
     /**
@@ -256,8 +275,8 @@ private function setBinLogDumpGtid(): void
      */
     private function setBinLogDump(): void
     {
-        $binFilePos = Config::getBinLogPosition();
-        $binFileName = Config::getBinLogFileName();
+        $binFilePos = $this->config->getBinLogPosition();
+        $binFileName = $this->config->getBinLogFileName();
         if (0 === $binFilePos && '' === $binFileName) {
             $masterStatusDTO = $this->repository->getMasterStatus();
             $binFilePos = $masterStatusDTO->getPosition();
@@ -267,7 +286,7 @@ private function setBinLogDump(): void
         $data = pack('i', strlen($binFileName) + 11) . chr(self::COM_BINLOG_DUMP);
         $data .= pack('I', $binFilePos);
         $data .= pack('v', 0);
-        $data .= pack('I', Config::getSlaveId());
+        $data .= pack('I', $this->config->getSlaveId());
         $data .= $binFileName;
 
         $this->socket->writeToSocket($data);