carno-php / database

src/Connectors/MySQL.php

Spacing +9 added lines, -9 removed lines

@@ -114,7 +114,7 @@ 
         $this->named = $named;
         $this->timeout = $timeout ?? new Timeouts;
 
-        ($this->link = new SWMySQL)->on('close', function () {
+        ($this->link = new SWMySQL)->on('close', function() {
             $this->closed()->resolve();
         });
     }
@@ -140,8 +140,8 @@ 
      */
     public function connect() : Promised
     {
-        return new Promise(function (Promised $promise) {
-            $this->link->connect($this->options(), static function (SWMySQL $db, bool $success) use ($promise) {
+        return new Promise(function(Promised $promise) {
+            $this->link->connect($this->options(), static function(SWMySQL $db, bool $success) use ($promise) {
                 $success
                     ? $promise->resolve()
                     : $promise->throw(new ConnectingException($db->connect_error, $db->connect_errno))
@@ -155,8 +155,8 @@ 
      */
     public function heartbeat() : Promised
     {
-        return new Promise(function (Promised $promised) {
-            $this->link->query('SELECT 1', function (SWMySQL $db, $result) use ($promised) {
+        return new Promise(function(Promised $promised) {
+            $this->link->query('SELECT 1', function(SWMySQL $db, $result) use ($promised) {
                 (is_array($result) && count($result) === 1)
                     ? $promised->resolve()
                     : $promised->reject()
@@ -194,13 +194,13 @@ 
             $sql = $this->binding($sql, $bind);
         }
 
-        $executor = function ($fn) use ($sql) {
+        $executor = function($fn) use ($sql) {
             if (false === $this->link->query($sql, $fn)) {
                 throw new UplinkException('Unknown failure');
             }
         };
 
-        $receiver = function (SWMySQL $db, $result) use ($sql) {
+        $receiver = function(SWMySQL $db, $result) use ($sql) {
             if (is_bool($result)) {
                 if ($result) {
                     if ($db->insert_id) {
@@ -276,13 +276,13 @@ 
             EXT::REMOTE_ENDPOINT => new Endpoint($this->named),
         ]);
 
-        $executor = function ($fn) use ($func) {
+        $executor = function($fn) use ($func) {
             if (false === $this->link->$func($fn)) {
                 throw new UplinkException('Unknown failure');
             }
         };
 
-        $receiver = static function (SWMySQL $db, bool $result) {
+        $receiver = static function(SWMySQL $db, bool $result) {
             if ($result) {
                 return;
             } else {

src/Chips/ParamsBind.php

Spacing +1 added lines, -1 removed lines

@@ -23,7 +23,7 @@
     protected function binding(string $sql, array $params) : string
     {
         // sort by key length (make correct of ":test,:test2")
-        uksort($params, static function ($a, $b) {
+        uksort($params, static function($a, $b) {
             return strlen($b) - strlen($a);
         });
 

src/Chips/TransactionGuard.php

Spacing +2 added lines, -2 removed lines

@@ -40,12 +40,12 @@
         $rollback = Promise::deferred();
 
         // automatic release after commit
-        $commit->then(static function () use ($link) {
+        $commit->then(static function() use ($link) {
             $link->release();
         });
 
         // automatic release after rollback
-        $rollback->then(static function () use ($link) {
+        $rollback->then(static function() use ($link) {
             $link->release();
         });
 

src/Clusters/MySQL.php

Spacing +1 added lines, -1 removed lines

@@ -78,7 +78,7 @@
             $dsn->option('execute', $this->timeout)
         );
 
-        return new Pool($this->options($endpoint), static function () use ($timeouts, $dsn, $vid) {
+        return new Pool($this->options($endpoint), static function() use ($timeouts, $dsn, $vid) {
             return new Connector(
                 $dsn->host(),
                 $dsn->port() ?: 3306,