dazzle-php / mysql

src/MySQL/Protocol/ProtocolParser.php

Doc Comments +25 added lines

@@ -84,6 +84,9 @@ 
 
     protected $queue;
 
+    /**
+     * @param \Dazzle\MySQL\Executor $executor
+     */
     public function __construct($stream, $executor)
     {
         $this->stream   = $stream;
@@ -105,6 +108,9 @@ 
         }
     }
 
+    /**
+     * @param string $message
+     */
     public function debug($message)
     {
         if ($this->debug) {
@@ -343,6 +349,9 @@ 
         $this->buffer .= $str;
     }
 
+    /**
+     * @param string $str
+     */
     public function prepend($str)
     {
         $this->buffer = $str . substr($this->buffer, $this->bufferPos);
@@ -363,11 +372,17 @@ 
         return $buffer;
     }
 
+    /**
+     * @param integer $len
+     */
     public function skip($len)
     {
         $this->bufferPos += $len;
     }
 
+    /**
+     * @param double $len
+     */
     public function restBuffer($len)
     {
         if(strlen($this->buffer) === ($this->bufferPos+$len)){
@@ -383,6 +398,9 @@ 
         return strlen($this->buffer) - $this->bufferPos;
     }
 
+    /**
+     * @param string $what
+     */
     public function search($what)
     {
         if (($p = strpos($this->buffer, $what, $this->bufferPos)) !== false) {
@@ -421,6 +439,9 @@ 
         $this->debug('Auth packet sent');
     }
 
+    /**
+     * @param string $scramble
+     */
     public function getAuthToken($scramble, $password = '')
     {
         if ($password === '') {
@@ -434,6 +455,7 @@ 
     /**
      * Builds length-encoded BinarySupport string
      * @param string String
+     * @param string $s
      * @return string Resulting BinarySupport string
      */
     public function buildLenEncodedBinarySupport($s)
@@ -499,6 +521,9 @@ 
         return $this->read($l);
     }
 
+    /**
+     * @param string $packet
+     */
     public function sendPacket($packet)
     {
         return $this->stream->write(BinarySupport::int2bytes(3, strlen($packet), true) . chr($this->seq++) . $packet);

Spacing +6 added lines, -6 removed lines

@@ -94,8 +94,8 @@ 
 
     public function start()
     {
-        $this->stream->on('data', [ $this, 'handleData' ]);
-        $this->stream->on('close', [ $this, 'handleClose' ]);
+        $this->stream->on('data', [$this, 'handleData']);
+        $this->stream->on('close', [$this, 'handleClose']);
     }
 
     public function handleNewCommand()
@@ -230,7 +230,7 @@ 
                     $this->nextRequest();
                     $this->onResultDone();
                 } else {
-                    ++ $this->rsState;
+                    ++$this->rsState;
                 }
 
             } else { //Data packet
@@ -370,10 +370,10 @@ 
 
     public function restBuffer($len)
     {
-        if(strlen($this->buffer) === ($this->bufferPos+$len)){
+        if (strlen($this->buffer) === ($this->bufferPos + $len)) {
             $this->buffer = '';
-        }else{
-            $this->buffer = substr($this->buffer,$this->bufferPos+$len);
+        } else {
+            $this->buffer = substr($this->buffer, $this->bufferPos + $len);
         }
         $this->bufferPos = 0;
     }

Braces +112 added lines, -49 removed lines

@@ -100,14 +100,16 @@ 
 
     public function handleNewCommand()
     {
-        if ($this->queue->count() <= 0) {
+        if ($this->queue->count() <= 0)
+        {
             $this->nextRequest();
         }
     }
 
     public function debug($message)
     {
-        if ($this->debug) {
+        if ($this->debug)
+        {
             $bt = debug_backtrace();
             $caller = array_shift($bt);
             printf("[DEBUG] <%s:%d> %s\n", $caller['class'], $caller['line'], $message);
@@ -116,8 +118,10 @@ 
 
     public function setOptions($options)
     {
-        foreach ($options as $option => $value) {
-            if (property_exists($this, $option)) {
+        foreach ($options as $option => $value)
+        {
+            if (property_exists($this, $option))
+            {
                 $this->$option = $value;
             }
         }
@@ -127,8 +131,10 @@ 
     {
         $this->append($data);
 packet:
-        if ($this->state === self::STATE_STANDBY) {
-            if ($this->length() < 4) {
+        if ($this->state === self::STATE_STANDBY)
+        {
+            if ($this->length() < 4)
+            {
                 return;
             }
 
@@ -139,17 +145,21 @@ 
         }
 
         $len = $this->length();
-        if ($len < $this->pctSize) {
+        if ($len < $this->pctSize)
+        {
             $this->debug('Buffer not enouth, return');
             return;
         }
         $this->state = self::STATE_STANDBY;
         //$this->stream->bufferSize = 4;
-        if ($this->phase === 0) {
+        if ($this->phase === 0)
+        {
             $this->phase = self::PHASE_GOT_INIT;
             $this->protocalVersion = ord($this->read(1));
             $this->debug(sprintf("Protocol Version: %d", $this->protocalVersion));
-            if ($this->protocalVersion === 0xFF) { //error
+            if ($this->protocalVersion === 0xFF)
+            {
+//error
                 $fieldCount = $this->protocalVersion;
                 $this->protocalVersion = 0;
                 printf("Error:\n");
@@ -157,13 +167,15 @@ 
                 $this->rsState = self::RS_STATE_HEADER;
                 $this->resultFields = [];
                 $this->resultRows = [];
-                if ($this->phase === self::PHASE_AUTH_SENT || $this->phase === self::PHASE_GOT_INIT) {
+                if ($this->phase === self::PHASE_AUTH_SENT || $this->phase === self::PHASE_GOT_INIT)
+                {
                     $this->phase = self::PHASE_AUTH_ERR;
                 }
 
                 goto field;
             }
-            if (($p = $this->search("\x00")) === false) {
+            if (($p = $this->search("\x00")) === false)
+            {
                 printf("Finish\n");
                 //finish
                 return;
@@ -181,10 +193,13 @@ 
             $this->scramble          .= $restScramble;
 
             $this->nextRequest(true);
-        } else {
+        }
+        else
+        {
             $fieldCount = ord($this->read(1));
 field:
-            if ($fieldCount === 0xFF) {
+            if ($fieldCount === 0xFF)
+            {
                 //error packet
                 $u             = unpack('v', $this->read(2));
                 $this->errno   = $u[1];
@@ -194,11 +209,15 @@ 
 
                 $this->nextRequest();
                 $this->onError();
-            } elseif ($fieldCount === 0x00) { //OK Packet Empty
+            }
+            elseif ($fieldCount === 0x00)
+            {
+//OK Packet Empty
                 $this->debug('Ok Packet');
 
                 $isAuthenticated = false;
-                if ($this->phase === self::PHASE_AUTH_SENT) {
+                if ($this->phase === self::PHASE_AUTH_SENT)
+                {
                     $this->phase = self::PHASE_HANDSHAKED;
                     $isAuthenticated = true;
                 }
@@ -214,35 +233,50 @@ 
 
                 $this->message      = $this->read($this->pctSize - $len + $this->length());
 
-                if ($isAuthenticated) {
+                if ($isAuthenticated)
+                {
                     $this->onAuthenticated();
-                } else {
+                }
+                else
+                {
                     $this->onSuccess();
                 }
                 $this->debug(sprintf("AffectedRows: %d, InsertId: %d, WarnCount:%d", $this->affectedRows, $this->insertId, $this->warnCount));
                 $this->nextRequest();
 
-            } elseif ($fieldCount === 0xFE) { //EOF Packet
+            }
+            elseif ($fieldCount === 0xFE)
+            {
+//EOF Packet
                 $this->debug('EOF Packet');
-                if ($this->rsState === self::RS_STATE_ROW) {
+                if ($this->rsState === self::RS_STATE_ROW)
+                {
                     $this->debug('result done');
 
                     $this->nextRequest();
                     $this->onResultDone();
-                } else {
+                }
+                else
+                {
                     ++ $this->rsState;
                 }
 
-            } else { //Data packet
+            }
+            else
+            {
+//Data packet
                 $this->debug('Data Packet');
                 $this->prepend(chr($fieldCount));
 
-                if ($this->rsState === self::RS_STATE_HEADER) {
+                if ($this->rsState === self::RS_STATE_HEADER)
+                {
                     $this->debug('Header packet of Data packet');
                     $extra = $this->parseEncodedBinarySupport();
                     //var_dump($extra);
                     $this->rsState = self::RS_STATE_FIELD;
-                } elseif ($this->rsState === self::RS_STATE_FIELD) {
+                }
+                elseif ($this->rsState === self::RS_STATE_FIELD)
+                {
                     $this->debug('Field packet of Data packet');
                     $field = [
                         'catalog'   => $this->parseEncodedString(),
@@ -268,10 +302,13 @@ 
                     //var_dump($field);
                     $this->resultFields[] = $field;
 
-                } elseif ($this->rsState === self::RS_STATE_ROW) {
+                }
+                elseif ($this->rsState === self::RS_STATE_ROW)
+                {
                     $this->debug('Row packet of Data packet');
                     $row = [];
-                    for ($i = 0, $nf = sizeof($this->resultFields); $i < $nf; ++$i) {
+                    for ($i = 0, $nf = sizeof($this->resultFields); $i < $nf; ++$i)
+                    {
                         $row[$this->resultFields[$i]['name']] = $this->parseEncodedString();
                     }
                     $this->resultRows[] = $row;
@@ -310,7 +347,8 @@ 
     protected function onSuccess()
     {
         $command = $this->queue->dequeue();
-        if ($command->equals(Command::QUERY)) {
+        if ($command->equals(Command::QUERY))
+        {
             $command->affectedRows = $this->affectedRows;
             $command->insertId     = $this->insertId;
             $command->warnCount    = $this->warnCount;
@@ -328,9 +366,11 @@ 
     protected function handleClose()
     {
         $this->emit('close');
-        if ($this->queue->count()) {
+        if ($this->queue->count())
+        {
             $command = $this->queue->dequeue();
-            if ($command->equals(Command::QUIT)) {
+            if ($command->equals(Command::QUIT))
+            {
                 $command->emit('success');
             }
         }
@@ -351,12 +391,14 @@ 
 
     public function read($len, $skiplen = 0)
     {
-        if (strlen($this->buffer) - $this->bufferPos - $len - $skiplen < 0) {
+        if (strlen($this->buffer) - $this->bufferPos - $len - $skiplen < 0)
+        {
             throw new \LogicException('Logic Error');
         }
         $buffer = substr($this->buffer, $this->bufferPos, $len);
         $this->bufferPos += $len;
-        if ($skiplen) {
+        if ($skiplen)
+        {
             $this->bufferPos += $skiplen;
         }
 
@@ -370,9 +412,12 @@ 
 
     public function restBuffer($len)
     {
-        if(strlen($this->buffer) === ($this->bufferPos+$len)){
+        if(strlen($this->buffer) === ($this->bufferPos+$len))
+        {
             $this->buffer = '';
-        }else{
+        }
+        else
+        {
             $this->buffer = substr($this->buffer,$this->bufferPos+$len);
         }
         $this->bufferPos = 0;
@@ -385,7 +430,8 @@ 
 
     public function search($what)
     {
-        if (($p = strpos($this->buffer, $what, $this->bufferPos)) !== false) {
+        if (($p = strpos($this->buffer, $what, $this->bufferPos)) !== false)
+        {
             return $p - $this->bufferPos;
         }
 
@@ -395,7 +441,8 @@ 
 
     public function authenticate()
     {
-        if ($this->phase !== self::PHASE_GOT_INIT) {
+        if ($this->phase !== self::PHASE_GOT_INIT)
+        {
             return;
         }
         $this->phase = self::PHASE_AUTH_SENT;
@@ -423,7 +470,8 @@ 
 
     public function getAuthToken($scramble, $password = '')
     {
-        if ($password === '') {
+        if ($password === '')
+        {
             return "\x00";
         }
         $token = sha1($scramble . sha1($hash1 = sha1($password, true), true), true) ^ $hash1;
@@ -438,21 +486,25 @@ 
      */
     public function buildLenEncodedBinarySupport($s)
     {
-        if ($s === null) {
+        if ($s === null)
+        {
             return "\251";
         }
 
         $l = strlen($s);
 
-        if ($l <= 250) {
+        if ($l <= 250)
+        {
             return chr($l) . $s;
         }
 
-        if ($l <= 0xFFFF) {
+        if ($l <= 0xFFFF)
+        {
             return "\252" . BinarySupport::int2bytes(2, true) . $s;
         }
 
-        if ($l <= 0xFFFFFF) {
+        if ($l <= 0xFFFFFF)
+        {
             return "\254" . BinarySupport::int2bytes(3, true) . $s;
         }
 
@@ -466,19 +518,24 @@ 
     public function parseEncodedBinarySupport()
     {
         $f = ord($this->read(1));
-        if ($f <= 250) {
+        if ($f <= 250)
+        {
             return $f;
         }
-        if ($f === 251) {
+        if ($f === 251)
+        {
             return null;
         }
-        if ($f === 255) {
+        if ($f === 255)
+        {
             return false;
         }
-        if ($f === 252) {
+        if ($f === 252)
+        {
             return BinarySupport::bytes2int($this->read(2), true);
         }
-        if ($f === 253) {
+        if ($f === 253)
+        {
             return BinarySupport::bytes2int($this->read(3), true);
         }
 
@@ -492,7 +549,8 @@ 
     public function parseEncodedString()
     {
         $l = $this->parseEncodedBinarySupport();
-        if (($l === null) || ($l === false)) {
+        if (($l === null) || ($l === false))
+        {
             return $l;
         }
 
@@ -506,15 +564,20 @@ 
 
     protected function nextRequest($isHandshake = false)
     {
-        if (!$isHandshake && $this->phase != self::PHASE_HANDSHAKED) {
+        if (!$isHandshake && $this->phase != self::PHASE_HANDSHAKED)
+        {
             return false;
         }
-        if (!$this->executor->isIdle()) {
+        if (!$this->executor->isIdle())
+        {
             $command = $this->executor->dequeue();
             $this->queue->enqueue($command);
-            if ($command->equals(Command::INIT_AUTHENTICATE)) {
+            if ($command->equals(Command::INIT_AUTHENTICATE))
+            {
                 $this->authenticate();
-            } else {
+            }
+            else
+            {
                 $this->seq = 0;
                 $this->sendPacket(chr($command->getID()) . $command->getSql());
             }

src/MySQL/Protocol/Support/BinarySupport.php

Doc Comments +1 added lines

@@ -382,6 +382,7 @@
 
     /**
      * @see BinarySupport::int2bytes
+     * @param integer $bytes
      */
     public static function i2b($bytes, $int = 0, $l = false)
     {

Braces +47 added lines, -21 removed lines

@@ -20,7 +20,8 @@ 
         {
             $r .= chr(strlen($e[$i])) . $e[$i];
         }
-        if (static::binarySubstr($r, -1) !== "\x00") {
+        if (static::binarySubstr($r, -1) !== "\x00")
+        {
             $r .= "\x00";
         }
         return $r;
@@ -40,7 +41,8 @@ 
         {
             $l = ord($data[0]);
 
-            if ($l >= 192) {
+            if ($l >= 192)
+            {
                 $pos  = static::bytes2int(chr($l - 192) . static::binarySubstr($data, 1, 1));
                 $data = static::binarySubstr($data, 2);
                 $ref  = static::binarySubstr($orig, $pos);
@@ -51,7 +53,8 @@ 
             $p = substr($data, 1, $l);
             $str .= $p . (($l !== 0) ? '.' : '');
             $data = substr($data, $l + 1);
-            if ($l === 0) {
+            if ($l === 0)
+            {
                 break;
             }
         }
@@ -68,7 +71,8 @@ 
     public static function LV($str, $len = 1, $lrev = false)
     {
         $l = static::i2b($len, strlen($str));
-        if ($lrev) {
+        if ($lrev)
+        {
             $l = strrev($l);
         }
         return $l . $str;
@@ -216,7 +220,8 @@ 
     {
         $r = static::binarySubstr($p, 0, 2);
         $p = static::binarySubstr($p, 2);
-        if ($l) {
+        if ($l)
+        {
             $r = strrev($r);
         }
         return $r;
@@ -262,7 +267,8 @@ 
     public static function getStrQWord(&$p, $l = false)
     {
         $r = static::binarySubstr($p, 0, 8);
-        if ($l) {
+        if ($l)
+        {
             $r = strrev($r);
         }
         $p = static::binarySubstr($p, 8);
@@ -279,7 +285,8 @@ 
     public static function getString(&$str)
     {
         $p = strpos($str, "\x00");
-        if ($p === false) {
+        if ($p === false)
+        {
             return '';
         }
         $r   = static::binarySubstr($str, 0, $p);
@@ -302,19 +309,26 @@ 
         $s = static::b2i(static::binarySubstr($p, 0, $l), !!$lrev);
         $p = static::binarySubstr($p, $l);
 
-        if ($s == 0) {
+        if ($s == 0)
+        {
             return '';
         }
 
         $r = '';
 
-        if (strlen($p) < $s) {
+        if (strlen($p) < $s)
+        {
             echo("getLV error: buf length (" . strlen($p) . "): " . Debug::exportBytes($p) . ", must be >= string length (" . $s . ")\n");
 
-        } else if ($nul) {
-            if ($p{$s - 1} != "\x00") {
+        }
+        else if ($nul)
+        {
+            if ($p{$s - 1} != "\x00")
+            {
                 echo("getLV error: Wrong end of NUL-string (" . Debug::exportBytes($p{$s - 1}) . "), len " . $s . "\n");
-            } else {
+            }
+            else
+            {
                 $d = $s - 1;
                 if ($d < 0)
                 {
@@ -324,7 +338,9 @@ 
                 $p = static::binarySubstr($p, $s);
             }
 
-        } else {
+        }
+        else
+        {
             $r = static::binarySubstr($p, 0, $s);
             $p = static::binarySubstr($p, $s);
         }
@@ -344,11 +360,15 @@ 
     {
         $hexstr = dechex($int);
 
-        if ($len === null) {
-            if (strlen($hexstr) % 2) {
+        if ($len === null)
+        {
+            if (strlen($hexstr) % 2)
+            {
                 $hexstr = "0" . $hexstr;
             }
-        } else {
+        }
+        else
+        {
             $hexstr = str_repeat('0', $len * 2 - strlen($hexstr)) . $hexstr;
         }
 
@@ -397,7 +417,8 @@ 
      */
     public static function bytes2int($str, $l = false)
     {
-        if ($l) {
+        if ($l)
+        {
             $str = strrev($str);
         }
 
@@ -437,7 +458,8 @@ 
         {
             $r .= chr((int) bindec(static::binarySubstr($bitmap, $i * 8, 8)));
         }
-        if ($checkLen && (strlen($r) != $checkLen)) {
+        if ($checkLen && (strlen($r) != $checkLen))
+        {
             throw new Exception('Warning! Bitmap incorrect.');
         }
 
@@ -465,13 +487,17 @@ 
      */
     protected static function binarySubstr($s, $p, $len = null)
     {
-        if ($len === null) {
+        if ($len === null)
+        {
             $ret = substr($s, $p);
-        } else {
+        }
+        else
+        {
             $ret = substr($s, $p, $len);
         }
 
-        if ($ret === false) {
+        if ($ret === false)
+        {
             $ret = '';
         }
 

src/MySQL/Query.php

Doc Comments -1 removed lines

@@ -44,7 +44,6 @@
     /**
      * Binding params for the query, mutiple arguments support.
      *
-     * @param  mixed              $param
      * @return Query
      */
     public function bindParams()

Spacing +2 added lines, -2 removed lines

@@ -50,7 +50,7 @@ 
     public function bindParams()
     {
         $this->sqlPrepared = null;
-        $this->params   = func_get_args();
+        $this->params = func_get_args();
 
         return $this;
     }
@@ -58,7 +58,7 @@ 
     public function bindParamsFromArray(array $params)
     {
         $this->sqlPrepared = null;
-        $this->params   = $params;
+        $this->params = $params;
 
         return $this;
     }

Braces +2 added lines, -1 removed lines

@@ -89,7 +89,8 @@
                 break;
             case 'array':
                 $nvalue = [];
-                foreach ($value as $v) {
+                foreach ($value as $v)
+                {
                     $nvalue[] = $this->resolveValueForSql($v);
                 }
                 $value = implode(',', $nvalue);

src/MySQL/Command/Concrete/QuitCommand.php

Braces +2 added lines, -1 removed lines

@@ -12,7 +12,8 @@
     }
 
     public function buildPacket()
-    {}
+    {
+}
 
     public function getSql()
     {

src/MySQL/Command/Concrete/AuthCommand.php

Braces +2 added lines, -1 removed lines

@@ -20,5 +20,6 @@
      * @inheritDoc
      */
     public function buildPacket()
-    {}
+    {
+}
 }

src/MySQL/Command/Concrete/PingCommand.php

Braces +2 added lines, -1 removed lines

@@ -20,7 +20,8 @@
      * @inheritDoc
      */
     public function buildPacket()
-    {}
+    {
+}
 
     /**
      * @override

src/MySQL/Command/Concrete/QueryCommand.php

Spacing +1 added lines, -1 removed lines

@@ -24,7 +24,7 @@
 
     public function setQuery($query)
     {
-        if (! $query instanceof Query)
+        if (!$query instanceof Query)
         {
             $query = new Query($query);
         }

Braces +2 added lines, -1 removed lines

@@ -43,5 +43,6 @@
     }
 
     public function buildPacket()
-    {}
+    {
+}
 }

src/MySQL/Database.php

Spacing +15 added lines, -15 removed lines

@@ -108,12 +108,12 @@ 
             throw new Exception('Not Implemented');
         }
 
-        $errorHandler = function ($reason) use ($args) {
+        $errorHandler = function($reason) use ($args) {
             $this->state = self::STATE_AUTH_FAILED;
             $args[0]($reason, $this);
         };
 
-        $connectedHandler = function ($serverOptions) use ($args) {
+        $connectedHandler = function($serverOptions) use ($args) {
             $this->state = self::STATE_AUTH_SUCCEEDED;
             $this->serverOptions = $serverOptions;
             $args[0](null, $this);
@@ -121,11 +121,11 @@ 
 
         $this
             ->connect()
-            ->then(function ($stream) use (&$streamRef, $options, $errorHandler, $connectedHandler) {
+            ->then(function($stream) use (&$streamRef, $options, $errorHandler, $connectedHandler) {
                 $streamRef = $stream;
 
-                $stream->on('error', [ $this, 'handleConnectionError' ]);
-                $stream->on('close', [ $this, 'handleConnectionClosed' ]);
+                $stream->on('error', [$this, 'handleConnectionError']);
+                $stream->on('close', [$this, 'handleConnectionClosed']);
 
                 $parser = $this->parser = new ProtocolParser($stream, $this->executor);
 
@@ -138,7 +138,7 @@ 
                 //$parser->on('close', $closeHandler);
                 $parser->start();
 
-            }, [ $this, 'handleConnectionError' ]);
+            }, [$this, 'handleConnectionError']);
     }
 
     /**
@@ -151,8 +151,8 @@ 
             ->doCommand(new QuitCommand($this))
             ->on('success', function() {
                 $this->state = self::STATE_STOPPED;
-                $this->emit('end', [ $this ]);
-                $this->emit('close', [ $this ]);
+                $this->emit('end', [$this]);
+                $this->emit('close', [$this]);
             });
         $this->state = self::STATE_CLOSEING;
     }
@@ -191,13 +191,13 @@ 
         $query->bindParamsFromArray($args);
         $this->doCommand($command);
 
-        $command->on('results', function ($rows, $command) use ($callback) {
+        $command->on('results', function($rows, $command) use ($callback) {
             $callback($command, $this);
         });
-        $command->on('error', function ($err, $command) use ($callback) {
+        $command->on('error', function($err, $command) use ($callback) {
             $callback($command, $this);
         });
-        $command->on('success', function ($command) use ($callback) {
+        $command->on('success', function($command) use ($callback) {
             $callback($command, $this);
         });
     }
@@ -209,10 +209,10 @@ 
             throw new InvalidArgumentException('Callback is not a valid callable');
         }
         $this->doCommand(new PingCommand($this))
-            ->on('error', function ($reason) use ($callback) {
+            ->on('error', function($reason) use ($callback) {
                 $callback($reason, $this);
             })
-            ->on('success', function () use ($callback) {
+            ->on('success', function() use ($callback) {
                 $callback(null, $this);
             });
     }
@@ -246,7 +246,7 @@ 
 
     public function handleConnectionError($err)
     {
-        $this->emit('error', [ $err, $this ]);
+        $this->emit('error', [$err, $this]);
     }
 
     public function handleConnectionClosed()
@@ -254,7 +254,7 @@ 
         if ($this->state < self::STATE_CLOSEING)
         {
             $this->state = self::STATE_STOPPED;
-            $this->emit('error', [ new RuntimeException('mysql server has gone away'), $this ]);
+            $this->emit('error', [new RuntimeException('mysql server has gone away'), $this]);
         }
     }
 

Braces +2 added lines, -1 removed lines

@@ -104,7 +104,8 @@
         $streamRef = $this->stream;
         $args = func_get_args();
 
-        if (!$args) {
+        if (!$args)
+        {
             throw new Exception('Not Implemented');
         }