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/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;
                 }
                 return false;
@@ -90,7 +90,7 @@ 
 
         $condition = with\predicate($condition);
 
-        return function (...$arguments) use ($listener, $condition) {
+        return function(...$arguments) use ($listener, $condition) {
             if ($condition(...$arguments)) {
                 return $listener(...$arguments);
             }
@@ -101,8 +101,8 @@ 
 
     private function getOnceCallable(callable $listener, $event) : callable
     {
-        return $onceListener = function (...$arguments) use (&$onceListener, $event, $listener) {
-            if(($result = $listener(...$arguments)) !== INF) {
+        return $onceListener = function(...$arguments) use (&$onceListener, $event, $listener) {
+            if (($result = $listener(...$arguments)) !== INF) {
                 $this->removeListener($event, $onceListener);
                 return $result;
             }

Stanza/Error.php

Spacing +4 added lines, -4 removed lines

@@ -66,7 +66,7 @@ 
      */
     public function setType(string $type)
     {
-        if(!in_array($type, ['auth', 'cancel', 'continue', 'modify', 'wait'])) {
+        if (!in_array($type, ['auth', 'cancel', 'continue', 'modify', 'wait'])) {
             throw new InvalidArgumentException(
                 format("Error type must be 'auth', 'cancel', 'continue', 'modify' or 'wait', '{type}' given.", [
                     'type' => $type
@@ -112,7 +112,7 @@ 
      */
     public function setText(string $text)
     {
-        if(!$this->text) {
+        if (!$this->text) {
             $this->append(new XmlElement('text', self::XMLNS));
         }
 
@@ -134,7 +134,7 @@ 
             !$condition instanceof XmlElement ? $this->_definedCondition($condition) : $condition
         ];
 
-        if($description !== null) {
+        if ($description !== null) {
             $content[] = new XmlElement('text', self::XMLNS, ['content' => $description]);
         }
 
@@ -145,7 +145,7 @@ 
 
     private function _definedCondition(string $condition) : XmlElement
     {
-        if(!in_array($condition, [
+        if (!in_array($condition, [
             'bad-request', 'conflict', 'feature-not-implemented', 'forbidden',
             'gone', 'internal-server-error', 'item-not-found', 'jid-malformed',
             'not-acceptable', 'not-allowed', 'not-authorized', 'policy-violation',

Stream/Features.php

Spacing +2 added lines, -2 removed lines

@@ -38,7 +38,7 @@ 
      */
     public function __construct(array $features = [])
     {
-        parent::__construct('stream:features', XmlStream::NAMESPACE_URI, [ 'content' => $features ]);
+        parent::__construct('stream:features', XmlStream::NAMESPACE_URI, ['content' => $features]);
     }
 
     /**
@@ -51,7 +51,7 @@ 
 
     public function getMechanisms()
     {
-        return array_map(function (XmlElement $element) {
+        return array_map(function(XmlElement $element) {
             return $element->innerXml;
         }, $this->get(\Kadet\Xmpp\Utils\filter\tag('mechanisms'))->children ?? []);
     }