dazzle-php / mysql

src/MySQL/Transaction.php

Spacing +6 added lines, -6 removed lines

@@ -63,10 +63,10 @@ 
         $query   = new Query($sql, $sqlParams);
         $command = new QueryCommand($this->database, $query);
 
-        $this->on('error', function ($trans, $err) use ($promise) {
+        $this->on('error', function($trans, $err) use ($promise) {
             return $promise->reject($err);
         });
-        $this->on('success', function ($trans) use ($promise, $command) {
+        $this->on('success', function($trans) use ($promise, $command) {
             return $promise->resolve($command);
         });
 
@@ -97,15 +97,15 @@ 
 
         $promise = new Promise();
 
-        $this->on('error', function ($trans, $err) use ($promise) {
+        $this->on('error', function($trans, $err) use ($promise) {
             return $promise->reject($err);
         });
-        $this->on('success', function ($trans) use ($promise) {
+        $this->on('success', function($trans) use ($promise) {
             return $promise->resolve();
         });
 
         $this->open = false;
-        $this->emit('commit', [ $this, $this->queue ]);
+        $this->emit('commit', [$this, $this->queue]);
         $this->queue = [];
 
         return $promise;
@@ -123,7 +123,7 @@ 
         }
 
         $this->open = false;
-        $this->emit('rollback', [ $this ]);
+        $this->emit('rollback', [$this]);
         $this->queue = [];
 
         return Promise::doResolve();

src/MySQL/Database.php

Spacing +24 added lines, -24 removed lines

@@ -33,42 +33,42 @@ 
     /**
      * @var int
      */
-    const STATE_INIT                 = 0;
+    const STATE_INIT = 0;
 
     /**
      * @var int
      */
-    const STATE_CONNECT_PENDING      = 4;
+    const STATE_CONNECT_PENDING = 4;
 
     /**
      * @var int
      */
-    const STATE_CONNECT_FAILED       = 2;
+    const STATE_CONNECT_FAILED = 2;
 
     /**
      * @var int
      */
-    const STATE_CONNECT_SUCCEEDED    = 6;
+    const STATE_CONNECT_SUCCEEDED = 6;
 
     /**
      * @var int
      */
-    const STATE_AUTH_PENDING         = 5;
+    const STATE_AUTH_PENDING = 5;
 
     /**
      * @var int
      */
-    const STATE_AUTH_FAILED          = 3;
+    const STATE_AUTH_FAILED = 3;
 
     /**
      * @var int
      */
-    const STATE_AUTH_SUCCEEDED       = 7;
+    const STATE_AUTH_SUCCEEDED = 7;
 
     /**
      * @var int
      */
-    const STATE_DISCONNECT_PENDING   = 8;
+    const STATE_DISCONNECT_PENDING = 8;
 
     /**
      * @var int
@@ -179,12 +179,12 @@ 
         $this->state = self::STATE_CONNECT_PENDING;
         $config = $this->config;
 
-        $errorHandler = function ($command, $reason) use ($promise) {
+        $errorHandler = function($command, $reason) use ($promise) {
             $this->state = self::STATE_AUTH_FAILED;
             return $promise->reject($reason);
         };
 
-        $connectedHandler = function ($command, $info) use ($promise) {
+        $connectedHandler = function($command, $info) use ($promise) {
             $this->state = self::STATE_AUTH_SUCCEEDED;
             $this->serverInfo = $info;
             return $promise->resolve($info);
@@ -195,8 +195,8 @@ 
             ->then(function($stream) use ($config, $errorHandler, $connectedHandler) {
                 $this->stream = $stream;
 
-                $stream->on('error', [ $this, 'handleSocketError' ]);
-                $stream->on('close', [ $this, 'handleSocketClose' ]);
+                $stream->on('error', [$this, 'handleSocketError']);
+                $stream->on('close', [$this, 'handleSocketClose']);
 
                 $this->state  = self::STATE_AUTH_PENDING;
                 $this->parser = new ProtocolParser($stream, $this->queue, $config);
@@ -207,7 +207,7 @@ 
 
                 $this->parser->start();
             })
-            ->done(null, [ $this, 'handleError' ]);
+            ->done(null, [$this, 'handleError']);
 
         return $promise;
     }
@@ -227,7 +227,7 @@ 
                 ->doCommand(new QuitCommand($this))
                 ->on('success', function() use($resolve) {
                     $this->state = self::STATE_DISCONNECT_SUCCEEDED;
-                    $this->emit('stop', [ $this ]);
+                    $this->emit('stop', [$this]);
                     $resolve($this);
                 });
             $this->state = self::STATE_DISCONNECT_PENDING;
@@ -282,10 +282,10 @@ 
 
         $this->doCommand($command);
 
-        $command->on('error', function ($command, $err) use ($promise) {
+        $command->on('error', function($command, $err) use ($promise) {
             return $promise->reject($err);
         });
-        $command->on('success', function ($command) use ($promise) {
+        $command->on('success', function($command) use ($promise) {
             return $promise->resolve($command);
         });
 
@@ -312,10 +312,10 @@ 
         $promise = new Promise();
 
         $command = $this->doCommand(new PingCommand($this));
-        $command->on('error', function ($command, $reason) use ($promise) {
+        $command->on('error', function($command, $reason) use ($promise) {
             return $promise->reject($reason);
         });
-        $command->on('success', function () use ($promise) {
+        $command->on('success', function() use ($promise) {
             return $promise->resolve();
         });
 
@@ -333,10 +333,10 @@ 
         $trans->on('commit', function(TransactionInterface $trans, array $queue) {
             $this->commitTransaction($queue)->then(
                 function() use($trans) {
-                    return $trans->emit('success', [ $trans ]);
+                    return $trans->emit('success', [$trans]);
                 },
                 function($ex) use($trans) {
-                    return $trans->emit('error', [ $trans, $ex ]);
+                    return $trans->emit('error', [$trans, $ex]);
                 }
             );
             $this->transBox->remove($trans);
@@ -374,7 +374,7 @@ 
         $size = 0;
         $sizeCap = count($queue);
 
-        for ($i=0; $i<$sizeCap; $i++)
+        for ($i = 0; $i < $sizeCap; $i++)
         {
             $command = $this->doCommand($queue[$i]);
             $command->on('error', function($command, $err) use(&$ex, $promise) {
@@ -416,7 +416,7 @@ 
      */
     public function handleError($err)
     {
-        $this->emit('error', [ $this, $err ]);
+        $this->emit('error', [$this, $err]);
     }
 
     /**
@@ -424,7 +424,7 @@ 
      */
     public function handleSocketError($socket, $err)
     {
-        $this->emit('error', [ $this, $err ]);
+        $this->emit('error', [$this, $err]);
     }
 
     /**
@@ -435,7 +435,7 @@ 
         if ($this->state < self::STATE_DISCONNECT_PENDING)
         {
             $this->state = self::STATE_DISCONNECT_SUCCEEDED;
-            $this->emit('error', [ $this, new RuntimeException('MySQL server has gone away!') ]);
+            $this->emit('error', [$this, new RuntimeException('MySQL server has gone away!')]);
         }
     }