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/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',

Exception/Protocol/BindingException.php

Spacing +2 added lines, -2 removed lines

@@ -42,13 +42,13 @@
 
     private static function _conditionDescription(Error $error)
     {
-        if(!empty($error->text)) {
+        if (!empty($error->text)) {
             return $error->text;
         }
 
         return [
             'bad-request' => 'Bad Request: "{resource}" is not valid XMPP resource identifier.',
             'conflict'    => 'Conflict: {bare}/{resource} is already in use.'
-        ][$error->condition] ?? 'Unknown reason: '.$error->condition;
+        ][$error->condition] ?? 'Unknown reason: ' . $error->condition;
     }
 }

Xml/XmlStream.php

Spacing +13 added lines, -13 removed lines

@@ -91,35 +91,35 @@ 
         parent::__construct($transport);
         $this->setParser($parser);
 
-        $this->on('close', function () { $this->_isOpened = false; });
-        $this->on('element', function (Error $element) {
+        $this->on('close', function() { $this->_isOpened = false; });
+        $this->on('element', function(Error $element) {
             $this->handleError($element);
         }, with\instance(Error::class));
     }
 
     public function setParser(XmlParser $parser)
     {
-        if($this->_parser) {
-            $this->removeListener('data', [ $this->_parser, 'parse' ]);
+        if ($this->_parser) {
+            $this->removeListener('data', [$this->_parser, 'parse']);
         }
 
         $this->_parser = $parser;
 
-        $this->_parser->on('parse.begin', function (XmlElement $stream) {
+        $this->_parser->on('parse.begin', function(XmlElement $stream) {
             $this->_inbound = $stream;
-            $this->emit('stream.open', [ $stream ]);
+            $this->emit('stream.open', [$stream]);
         }, with\argument(1, with\equals(0)));
 
-        $this->_parser->on('parse.end', function (XmlElement $stream) {
-            $this->emit('stream.close', [ $stream ]);
+        $this->_parser->on('parse.end', function(XmlElement $stream) {
+            $this->emit('stream.close', [$stream]);
             $this->_inbound = null;
         }, with\argument(1, with\equals(0)));
 
-        $this->_parser->on('element', function (...$arguments) {
+        $this->_parser->on('element', function(...$arguments) {
             $this->emit('element', $arguments);
         });
 
-        $this->on('data', [ $this->_parser, 'parse' ]);
+        $this->on('data', [$this->_parser, 'parse']);
     }
 
     /**
@@ -130,11 +130,11 @@ 
      */
     public function write($data)
     {
-        if($data instanceof XmlElement) {
+        if ($data instanceof XmlElement) {
             $this->_outbound->append($data);
         }
 
-        $this->emit('send.'.($data instanceof XmlElement ? 'element' : 'text'), [ $data ]);
+        $this->emit('send.' . ($data instanceof XmlElement ? 'element' : 'text'), [$data]);
 
         return parent::write($data);
     }
@@ -195,7 +195,7 @@ 
 
     private function handleError(Error $element)
     {
-        if ($this->emit('stream.error', [ $element ])) {
+        if ($this->emit('stream.error', [$element])) {
             throw new StreamErrorException($element);
         }
 

Xml/XmlElementFactory.php

Spacing +2 added lines, -2 removed lines

@@ -33,7 +33,7 @@ 
         }
 
         foreach ($lookup['<predicate>'] as list($class, $predicate)) {
-            if($predicate($tag, $namespace)) {
+            if ($predicate($tag, $namespace)) {
                 return $class;
             }
         }
@@ -64,7 +64,7 @@ 
     {
         $result = ['<predicate>' => []];
         foreach ($dictionary as $element) {
-            if($element['name'] instanceof \Closure || $element['uri'] instanceof \Closure) {
+            if ($element['name'] instanceof \Closure || $element['uri'] instanceof \Closure) {
                 $result['<predicate>'][] = [$element[0], \Kadet\Xmpp\Utils\filter\consecutive(
                     \Kadet\Xmpp\Utils\filter\predicate($element['name']),
                     \Kadet\Xmpp\Utils\filter\predicate($element['uri'])