kadet1090 / nucleus

Utils/BetterEmitter.php

Doc Comments +3 added lines

@@ -48,6 +48,9 @@
         return true;
     }
 
+    /**
+     * @param string $event
+     */
     public function emit($event, array $arguments = [])
     {
         foreach ($this->listeners($event) as $listener) {

Spacing +4 added lines, -4 removed lines

@@ -40,7 +40,7 @@ 
 
     public function removeListener($event, callable $listener)
     {
-        if(!isset($this->listeners[$event])) {
+        if (!isset($this->listeners[$event])) {
             return false;
         }
 
@@ -66,7 +66,7 @@ 
 
     private function addListener($event, callable $listener, int $priority = 0)
     {
-        if(!isset($this->listeners[$event])) {
+        if (!isset($this->listeners[$event])) {
             $this->listeners[$event] = new PriorityCollection();
         }
 
@@ -80,7 +80,7 @@ 
         }
 
         $condition = $this->emitterResolveCondition($condition);
-        return function (...$arguments) use ($listener, $condition) {
+        return function(...$arguments) use ($listener, $condition) {
             if ($condition(...$arguments)) {
                 $listener(...$arguments);
             }
@@ -89,7 +89,7 @@ 
 
     private function getOnceCallable(callable $listener, $event) : callable
     {
-        return $onceListener = function (...$arguments) use (&$onceListener, $event, $listener) {
+        return $onceListener = function(...$arguments) use (&$onceListener, $event, $listener) {
             $this->removeListener($event, $onceListener);
 
             $listener(...$arguments);

Xml/XmlElement.php

Doc Comments +2 added lines, -1 removed lines

@@ -20,7 +20,8 @@
  */
 class XmlElement extends \DOMElement
 {
-    /** @return static */
+    /** @param string $uri
+/** @return static */
     public static function create($name = 'element', $content = null, $uri = null)
     {
         return self::_document()->importNode(new static($name, $content, $uri));

Xml/XmlParser.php

Doc Comments +3 added lines

@@ -126,6 +126,9 @@
         return [$name, $namespace];
     }
 
+    /**
+     * @param string|null $prefix
+     */
     private function _lookup($prefix, $namespaces)
     {
         if ($prefix === 'xmlns') {

Spacing +6 added lines, -6 removed lines

@@ -78,13 +78,13 @@ 
         xml_parser_set_option($this->parser, XML_OPTION_SKIP_WHITE, 1);
         xml_parser_set_option($this->parser, XML_OPTION_CASE_FOLDING, 0);
 
-        xml_set_element_handler($this->parser, function ($parser, $name, $attrs) {
+        xml_set_element_handler($this->parser, function($parser, $name, $attrs) {
             $this->handleElementStart($name, $attrs);
-        }, function ($parser, $name) {
+        }, function($parser, $name) {
             $this->handleElementEnd();
         });
 
-        xml_set_character_data_handler($this->parser, function ($parser, $data) {
+        xml_set_character_data_handler($this->parser, function($parser, $data) {
             $this->handleTextData($data);
         });
 
@@ -159,7 +159,7 @@ 
         if (count($this->stack) > 1) {
             end($this->stack)->appendChild($element);
         }
-        $this->emit('parse.begin', [ $element ]);
+        $this->emit('parse.begin', [$element]);
 
         $this->stack[] = $element;
     }
@@ -172,10 +172,10 @@ 
 
         $element = array_pop($this->stack);
         if (count($this->stack) == 1) {
-            $this->emit('element', [ $element ]);
+            $this->emit('element', [$element]);
         }
 
-        $this->emit('parse.end', [ $element ]);
+        $this->emit('parse.end', [$element]);
     }
 
     private function handleTextData($data)

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);
     }
 }

Xml/XmlStream.php

Spacing +10 added lines, -10 removed lines

@@ -75,25 +75,25 @@ 
 
         $this->parser = $parser;
 
-        $this->on('element', function (Error $element) {
+        $this->on('element', function(Error $element) {
             $this->handleError($element);
         }, with\ofType(Error::class));
 
-        $this->parser->on('parse.begin', function (XmlElement $stream) {
+        $this->parser->on('parse.begin', function(XmlElement $stream) {
             $this->stream = $stream;
-            $this->emit('stream.open', [ $stream ]);
+            $this->emit('stream.open', [$stream]);
         }, with\all(with\tag('stream'), with\xmlns(self::NAMESPACE_URI)));
 
-        $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->stream = null;
         }, with\all(with\tag('stream'), with\xmlns(self::NAMESPACE_URI)));
 
         $this->on('data', [$this->parser, 'parse']);
-        $this->parser->on('element', function (...$arguments) {
+        $this->parser->on('element', function(...$arguments) {
             $this->emit('element', $arguments);
         });
-        $this->on('close', function () { $this->isOpened = false; });
+        $this->on('close', function() { $this->isOpened = false; });
     }
 
     /**
@@ -105,7 +105,7 @@ 
      */
     public function write($data)
     {
-        $this->emit('send.'.($data instanceof XmlElement ? 'element' : 'text'), [ $data ]);
+        $this->emit('send.' . ($data instanceof XmlElement ? 'element' : 'text'), [$data]);
 
         return parent::write($data);
     }
@@ -135,7 +135,7 @@ 
      */
     public function close()
     {
-        if($this->isOpened()) {
+        if ($this->isOpened()) {
             $this->write('</stream:stream>');
             $this->isOpened = false;
         }
@@ -170,7 +170,7 @@ 
 
     private function handleError(Error $element)
     {
-        if($this->emit('stream.error', [ $element ])) {
+        if ($this->emit('stream.error', [$element])) {
             throw new StreamErrorException($element);
         }
 

Utils/Helper.php

Spacing +5 added lines, -5 removed lines

@@ -23,10 +23,10 @@ 
  */
 function typeof($value) : string
 {
-    if(is_object($value)) {
-        return "object of type ".get_class($value);
-    } elseif(is_resource($value)) {
-        return get_resource_type($value).' resource';
+    if (is_object($value)) {
+        return "object of type " . get_class($value);
+    } elseif (is_resource($value)) {
+        return get_resource_type($value) . ' resource';
     } else {
         return gettype($value);
     }
@@ -37,7 +37,7 @@ 
     return function(...$arguments) use ($callable, $argument, $position) {
         $arguments = array_merge(
             array_slice($arguments, 0, $position),
-            [ $argument ],
+            [$argument],
             array_slice($arguments, $position)
         );
 

Utils/Filter.php

Spacing +5 added lines, -5 removed lines

@@ -19,28 +19,28 @@ 
 
 function xmlns($uri)
 {
-    return function (XmlElement $element) use ($uri) {
+    return function(XmlElement $element) use ($uri) {
         return $element->namespaceURI === $uri;
     };
 }
 
 function tag($name)
 {
-    return function (XmlElement $element) use ($name) {
+    return function(XmlElement $element) use ($name) {
         return $element->localName === $name;
     };
 }
 
 function ofType($class)
 {
-    return function ($object) use ($class) {
+    return function($object) use ($class) {
         return $object instanceof $class;
     };
 }
 
 function all(callable ...$functions)
 {
-    return function (...$args) use ($functions) {
+    return function(...$args) use ($functions) {
         foreach ($functions as $function) {
             if (!$function(...$args)) {
                 return false;
@@ -53,7 +53,7 @@ 
 
 function any(callable ...$functions)
 {
-    return function (...$args) use ($functions) {
+    return function(...$args) use ($functions) {
         foreach ($functions as $function) {
             if ($function(...$args)) {
                 return true;

Stream/Error.php

Spacing +1 added lines, -1 removed lines

@@ -39,7 +39,7 @@
 
     public function getText()
     {
-        if($text = $this->query(".//xmpp:text")->with('xmpp', 'urn:ietf:params:xml:ns:xmpp-streams')->query()->item(0)) {
+        if ($text = $this->query(".//xmpp:text")->with('xmpp', 'urn:ietf:params:xml:ns:xmpp-streams')->query()->item(0)) {
             return $text;
         }
 

XmppStream.php

Spacing +3 added lines, -3 removed lines

@@ -37,15 +37,15 @@
         parent::__construct($parser, $transport);
 
         $this->parser->factory->register(Features::class, self::NAMESPACE_URI, 'features');
-        $this->parser->factory->register(Error::class,    self::NAMESPACE_URI, 'error');
+        $this->parser->factory->register(Error::class, self::NAMESPACE_URI, 'error');
 
         $this->_lang = $lang;
 
-        $this->on('element', function (Features $element) {
+        $this->on('element', function(Features $element) {
             $this->handleFeatures($element);
         }, Features::class);
 
-        $this->on('element', function (XmlElement $element) {
+        $this->on('element', function(XmlElement $element) {
             $this->handleTls($element);
         }, with\xmlns(self::TLS_NAMESPACE));
     }