kadet1090 / nucleus

Exception/Protocol/StreamErrorException.php

Spacing +1 added lines, -1 removed lines

@@ -40,6 +40,6 @@
 
     private function generateMessage(Error $error) : string
     {
-        return 'Stream error: '.str_replace('-', ' ', $error->kind).($error->text ? " ({$error->text})" : null);
+        return 'Stream error: ' . str_replace('-', ' ', $error->kind) . ($error->text ? " ({$error->text})" : null);
     }
 }

Utils/DnsResolver.php

Spacing +1 added lines, -1 removed lines

@@ -54,7 +54,7 @@
                 continue;
             }
 
-            $this->_results = array_merge($this->_results, array_map(function ($record) {
+            $this->_results = array_merge($this->_results, array_map(function($record) {
                 return [$record['target'], $record['port']];
             }, $result));
         }

Network/Connector/TcpXmppConnector.php

Spacing +2 added lines, -2 removed lines

@@ -42,13 +42,13 @@
 
             if ($stream = @stream_socket_client("tcp://$ip:$port")) {
                 $stream = new TcpStream($stream, $this->_loop);
-                $this->emit('connect', [ $stream ]);
+                $this->emit('connect', [$stream]);
 
                 return $stream;
             }
         }
 
-        throw new \RuntimeException('Cannot connect to '.$this->_host);
+        throw new \RuntimeException('Cannot connect to ' . $this->_host);
     }
 
     public function __construct(string $host, LoopInterface $loop)

Utils/Dumper.php

Spacing +3 added lines, -3 removed lines

@@ -72,9 +72,9 @@ 
     {
         $console = Console::get();
 
-        $result = $console->styled(['color' => 'yellow'], 'array').' with '.$console->styled(['color' => 'magenta'], count($array)).' elements:'.PHP_EOL;
+        $result = $console->styled(['color' => 'yellow'], 'array') . ' with ' . $console->styled(['color' => 'magenta'], count($array)) . ' elements:' . PHP_EOL;
         foreach ($array as $key => $value) {
-            $result .= "\t".str_replace("\n", "\n\t", '['.$this->dump($key).']: '.$this->dump($value)).PHP_EOL;
+            $result .= "\t" . str_replace("\n", "\n\t", '[' . $this->dump($key) . ']: ' . $this->dump($value)) . PHP_EOL;
         }
 
         return $result;
@@ -82,7 +82,7 @@ 
 
     public function init()
     {
-        $this->register('array',  [$this, '_dumpArray']);
+        $this->register('array', [$this, '_dumpArray']);
         $this->register('object', [$this, '_dumpObject']);
     }
 }

Utils/StreamDecorator.php

Spacing +1 added lines, -1 removed lines

@@ -107,7 +107,7 @@
     {
         foreach ($events as $event) {
             if (!isset($this->_redirectors[$event])) {
-                $this->_redirectors[$event] = function (...$arguments) use ($event) {
+                $this->_redirectors[$event] = function(...$arguments) use ($event) {
                     $this->emit($event, $arguments);
                 };
             }

Utils/PriorityCollection.php

Spacing +2 added lines, -2 removed lines

@@ -61,7 +61,7 @@ 
 
     public function remove($value)
     {
-        $this->_collection = array_filter($this->_collection, function ($e) use ($value) {
+        $this->_collection = array_filter($this->_collection, function($e) use ($value) {
             return $e[1] !== $value;
         });
 
@@ -70,7 +70,7 @@ 
 
     private function rebuildCache()
     {
-        usort($this->_collection, function ($a, $b) {
+        usort($this->_collection, function($a, $b) {
             return $b[0] <=> $a[0];
         });
 

Utils/Helper.php

Spacing +6 added lines, -6 removed lines

@@ -26,9 +26,9 @@ 
 function typeof($value) : string
 {
     if (is_object($value)) {
-        return "object of type ".get_class($value);
+        return "object of type " . get_class($value);
     } elseif (is_resource($value)) {
-        return get_resource_type($value).' resource';
+        return get_resource_type($value) . ' resource';
     } else {
         return gettype($value);
     }
@@ -36,10 +36,10 @@ 
 
 function partial(callable $callable, $argument, int $position = 0) : callable
 {
-    return function (...$arguments) use ($callable, $argument, $position) {
+    return function(...$arguments) use ($callable, $argument, $position) {
         $arguments = array_merge(
             array_slice($arguments, 0, $position),
-            [ $argument ],
+            [$argument],
             array_slice($arguments, $position)
         );
 
@@ -49,10 +49,10 @@ 
 
 function dd($value)
 {
-    echo Dumper::get()->dump($value).PHP_EOL.PHP_EOL;
+    echo Dumper::get()->dump($value) . PHP_EOL . PHP_EOL;
 }
 
 function format($string, array $arguments = [])
 {
-    return str_replace(array_map(function ($e) { return "{{$e}}"; }, array_keys($arguments)), $arguments, $string);
+    return str_replace(array_map(function($e) { return "{{$e}}"; }, array_keys($arguments)), $arguments, $string);
 }

Utils/BetterEmitter.php

Doc Comments +4 added lines

@@ -32,6 +32,10 @@
         return $this->addListener($event, $this->getConditionalCallable($listener, $condition), $priority);
     }
 
+    /**
+     * @param string $event
+     * @param \Closure $condition
+     */
     public function once($event, callable $listener, $condition = null, int $priority = 0)
     {
         return $this->on($event, $this->getOnceCallable($this->getConditionalCallable($listener, $condition), $event), null, $priority);

Spacing +4 added lines, -4 removed lines

@@ -56,7 +56,7 @@ 
                     return false;
                 }
             } catch (\Throwable $exception) {
-                if($this->emit('exception', [ $exception, $event ])) {
+                if ($this->emit('exception', [$exception, $event])) {
                     throw $exception;
                 }
             }
@@ -89,7 +89,7 @@ 
 
         $condition = with\predicate($condition);
 
-        return function (...$arguments) use ($listener, $condition) {
+        return function(...$arguments) use ($listener, $condition) {
             if ($condition(...$arguments)) {
                 return (bool)$listener(...$arguments);
             }
@@ -100,8 +100,8 @@ 
 
     private function getOnceCallable(callable $listener, $event) : callable
     {
-        return $onceListener = function (...$arguments) use (&$onceListener, $event, $listener) {
-            if(($result = $listener(...$arguments)) !== null) {
+        return $onceListener = function(...$arguments) use (&$onceListener, $event, $listener) {
+            if (($result = $listener(...$arguments)) !== null) {
                 $this->removeListener($event, $onceListener);
                 return $result;
             }

Module/SaslAuthenticator.php

Spacing +6 added lines, -6 removed lines

@@ -59,7 +59,7 @@ 
     {
         parent::setClient($client);
 
-        $client->on('features', function (Features $features) {
+        $client->on('features', function(Features $features) {
             return !$this->auth($features);
         });
     }
@@ -68,7 +68,7 @@ 
     {
         if (!empty($features->mechanisms)) {
             foreach ($features->mechanisms as $name) {
-                if($this->tryMechanism($name)) {
+                if ($this->tryMechanism($name)) {
                     return true;
                 }
             }
@@ -112,11 +112,11 @@ 
             $response = '=';
         }
 
-        $callback = $this->_client->on('element', function (XmlElement $challenge) use ($mechanism) {
+        $callback = $this->_client->on('element', function(XmlElement $challenge) use ($mechanism) {
             $this->handleChallenge($challenge, $mechanism);
         }, with\all(with\tag('challenge'), with\xmlns(self::XMLNS)));
 
-        $this->_client->once('element', function (XmlElement $result) use ($callback) {
+        $this->_client->once('element', function(XmlElement $result) use ($callback) {
             $this->_client->removeListener('element', $callback);
             $this->handleAuthResult($result);
         }, with\all(with\any(with\tag('success'), with\tag('failure')), with\xmlns(self::XMLNS)));
@@ -126,7 +126,7 @@ 
 
     private function mechanismWithoutChallenge(AuthenticationInterface $mechanism)
     {
-        $this->_client->once('element', function (XmlElement $result) {
+        $this->_client->once('element', function(XmlElement $result) {
             $this->handleAuthResult($result);
         }, with\all(with\any(with\tag('success'), with\tag('failure')), with\xmlns(self::XMLNS)));
 
@@ -144,7 +144,7 @@ 
     private function handleAuthResult(XmlElement $result)
     {
         if ($result->localName === 'failure') {
-            throw new AuthenticationException('Unable to auth. '.trim($result->innerXml));
+            throw new AuthenticationException('Unable to auth. ' . trim($result->innerXml));
         }
 
         $this->_client->getLogger()->info('Successfully authorized as {name}.', ['name' => (string)$this->_client->jid]);