kadet1090 / nucleus

Xml/XmlElement.php

Doc Comments +4 added lines, -1 removed lines

@@ -220,7 +220,7 @@ 
      * Retrieves array of matching elements
      *
      * @param string $name  Requested element tag name
-     * @param null   $uri   Requested element namespace
+     * @param null|string   $uri   Requested element namespace
      *
      * @return XmlElement[] Found Elements
      */
@@ -248,6 +248,9 @@ 
         return $this->elements($name, $uri)[$index] ?? false;
     }
 
+    /**
+     * @param \Closure $predicate
+     */
     public function all($predicate) {
         $predicate = filter\predicate($predicate);
         return array_filter($this->_children, $predicate);

Spacing +20 added lines, -20 removed lines

@@ -68,27 +68,27 @@ 
 
     public function xml($clean = true): string
     {
-        if($this->namespace && $this->_prefix === null) {
+        if ($this->namespace && $this->_prefix === null) {
             $this->_prefix = $this->lookupPrefix($this->namespace);
         }
 
         $attributes = $this->attributes();
 
         $result = "<{$this->name}";
-        $result .= ' '.implode(' ', array_map(function($key, $value) {
-            return $key.'="'.htmlspecialchars($value, ENT_QUOTES).'"';
+        $result .= ' ' . implode(' ', array_map(function($key, $value) {
+            return $key . '="' . htmlspecialchars($value, ENT_QUOTES) . '"';
         }, array_keys($attributes), array_values($attributes)));
 
-        if(!empty($this->_children)) {
-            $result .= ">".implode('', array_map(function($element) {
-                if(is_string($element)) {
+        if (!empty($this->_children)) {
+            $result .= ">" . implode('', array_map(function($element) {
+                if (is_string($element)) {
                     return htmlspecialchars($element);
                 } elseif ($element instanceof XmlElement) {
                     return $element->xml(false);
                 }
 
                 return (string)$element;
-            }, $this->_children))."</{$this->name}>";
+            }, $this->_children)) . "</{$this->name}>";
         } else {
             $result .= "/>";
         }
@@ -98,12 +98,12 @@ 
 
     public function setAttribute(string $attribute, $value, string $uri = null)
     {
-        if($uri === 'http://www.w3.org/2000/xmlns/') {
+        if ($uri === 'http://www.w3.org/2000/xmlns/') {
             $this->_namespaces[(string)$value] = $attribute;
             return;
         }
 
-        if($uri !== null) {
+        if ($uri !== null) {
             $attribute = $this->_prefix($attribute, $uri);
         }
 
@@ -112,7 +112,7 @@ 
 
     public function getAttribute(string $attribute, string $uri = null)
     {
-        if($uri !== null) {
+        if ($uri !== null) {
             $attribute = $this->_prefix($attribute, $uri);
         }
 
@@ -124,11 +124,11 @@ 
      */
     public function getNamespaces($parent = true): array
     {
-        if(!$this->_parent) {
+        if (!$this->_parent) {
             return $this->_namespaces;
         }
 
-        if($parent) {
+        if ($parent) {
             return array_merge($this->_namespaces, $this->_parent->getNamespaces());
         } else {
             return array_diff_assoc($this->_namespaces, $this->_parent->getNamespaces());
@@ -139,7 +139,7 @@ 
     {
         $namespaces = $this->getNamespaces(false);
         $namespaces = array_map(function($prefix, $uri) {
-            return [ $prefix ? "xmlns:{$prefix}" : 'xmlns', $uri ];
+            return [$prefix ? "xmlns:{$prefix}" : 'xmlns', $uri];
         }, array_values($namespaces), array_keys($namespaces));
 
         return array_merge(
@@ -160,7 +160,7 @@ 
 
     public function setNamespace(string $uri, $prefix = false)
     {
-        if($prefix === false) {
+        if ($prefix === false) {
             $prefix = $this->_prefix;
         }
 
@@ -179,15 +179,15 @@ 
 
     public function append($element)
     {
-        if(!is_string($element) && !$element instanceof XmlElement) {
+        if (!is_string($element) && !$element instanceof XmlElement) {
             throw new InvalidArgumentException(helper\format('$element should be either string or object of {class} class, {type} given', [
                 'class' => XmlElement::class,
                 'type'  => helper\typeof($element)
             ]));
         }
 
-        if($element instanceof XmlElement) {
-            $element->parent  = $this;
+        if ($element instanceof XmlElement) {
+            $element->parent = $this;
         }
 
         $this->_children[] = $element;
@@ -195,7 +195,7 @@ 
 
     public function getName()
     {
-        return ($this->_prefix ? $this->prefix.':' : null).$this->localName;
+        return ($this->_prefix ? $this->prefix . ':' : null) . $this->localName;
     }
 
     public function getPrefix()
@@ -211,7 +211,7 @@ 
     protected function setParent(XmlElement $parent)
     {
         $this->_parent = $parent;
-        if($this->namespace === false) {
+        if ($this->namespace === false) {
             $this->namespace = $parent->namespace;
         }
     }
@@ -227,7 +227,7 @@ 
     public function elements($name, $uri = null) : array
     {
         $predicate = filter\tag($name);
-        if($uri !== null) {
+        if ($uri !== null) {
             $predicate = filter\all($predicate, filter\xmlns($uri));
         }
 

Xml/XPathQuery.php

Spacing +3 added lines, -3 removed lines

@@ -33,7 +33,7 @@ 
     public function query(string $query = null)
     {
         /** @var \DOMNode $element */
-        foreach($this->_xpath->query($query ?: $this->_query) as $element) {
+        foreach ($this->_xpath->query($query ?: $this->_query) as $element) {
             yield $this->getElementFromPath($element->getNodePath());
         }
     }
@@ -70,14 +70,14 @@ 
         array_shift($path);
 
         $current = $this->_context;
-        foreach($path as $chunk) {
+        foreach ($path as $chunk) {
             // Chunk is in format node-name[index], parse it with regex
             preg_match('/([\w\*]+)(?:\[([0-9]+)\])?/', $chunk, $matches);
 
             $name  = $matches[1];
             $index = isset($matches[2]) ? $matches[2] - 1 : 0;
 
-            if($name == '*') {
+            if ($name == '*') {
                 // Path returns * if namespace occurs so we need to obtain index-th child
                 $current = $current->children[$index];
             } else {

Xml/XmlStream.php

Spacing +10 added lines, -10 removed lines

@@ -76,25 +76,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; });
     }
 
     /**
@@ -106,7 +106,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);
     }
@@ -136,7 +136,7 @@ 
      */
     public function close()
     {
-        if($this->isOpened()) {
+        if ($this->isOpened()) {
             $this->write('</stream:stream>');
             $this->_isOpened = false;
         }
@@ -171,7 +171,7 @@ 
 
     private function handleError(Error $element)
     {
-        if($this->emit('stream.error', [ $element ])) {
+        if ($this->emit('stream.error', [$element])) {
             throw new StreamErrorException($element);
         }
 

Xml/XmlParser.php

Spacing +8 added lines, -8 removed lines

@@ -71,13 +71,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);
         });
 
@@ -119,10 +119,10 @@ 
         list($attributes, $namespaces) = $this->_attributes($attrs);
         list($tag, $prefix)            = XmlElement::resolve($name);
 
-        $uri   = $this->_lookup($prefix, $namespaces);
+        $uri = $this->_lookup($prefix, $namespaces);
 
         /** @var XmlElement $element */
-        $element = $this->factory->create($uri, $tag, [ $name, $uri ]);
+        $element = $this->factory->create($uri, $tag, [$name, $uri]);
         foreach ($attributes as $name => $value) {
             $element->setAttribute($name, $value);
         }
@@ -137,7 +137,7 @@ 
         if (count($this->_stack) > 1) {
             end($this->_stack)->append($element);
         }
-        $this->emit('parse.begin', [ $element ]);
+        $this->emit('parse.begin', [$element]);
 
         $this->_stack[] = $element;
     }
@@ -150,10 +150,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)

Network/Connector/TcpXmppConnector.php

Spacing +3 added lines, -3 removed lines

@@ -41,14 +41,14 @@
                 'port' => $port
             ]);
 
-            if($stream = @stream_socket_client("tcp://$ip:$port")) {
+            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)

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

Utils/StreamDecorator.php

Spacing +6 added lines, -6 removed lines

@@ -1,4 +1,4 @@ 
-<?php declare(strict_types=1);
+<?php declare(strict_types = 1);
 /**
  * XMPP Library
  *
@@ -36,7 +36,7 @@ 
      */
     public function __construct(DuplexStreamInterface $decorated = null)
     {
-        if($decorated !== null) {
+        if ($decorated !== null) {
             $this->exchangeStream($decorated);
         }
     }
@@ -85,7 +85,7 @@ 
     {
         static $events = ['data', 'end', 'drain', 'error', 'close', 'pipe'];
 
-        if($this->_decorated !== null) {
+        if ($this->_decorated !== null) {
             $this->unsubscribe($this->_decorated, $events);
         }
 
@@ -96,7 +96,7 @@ 
     private function unsubscribe(DuplexStreamInterface $stream, array $events)
     {
         foreach ($events as $event) {
-            if(!isset($this->_redirectors[$event])) {
+            if (!isset($this->_redirectors[$event])) {
                 continue;
             }
 
@@ -107,8 +107,8 @@ 
     private function subscribe(DuplexStreamInterface $stream, array $events)
     {
         foreach ($events as $event) {
-            if(!isset($this->_redirectors[$event])) {
-                $this->_redirectors[$event] = function (...$arguments) use ($event) {
+            if (!isset($this->_redirectors[$event])) {
+                $this->_redirectors[$event] = function(...$arguments) use ($event) {
                     $this->emit($event, $arguments);
                 };
             }

Utils/Dumper.php

Spacing +7 added lines, -7 removed lines

@@ -37,16 +37,16 @@ 
 
     private function getDumper($value)
     {
-        if(is_object($value)) {
+        if (is_object($value)) {
             $class = get_class($value);
             foreach (array_merge([$class], class_parents($class), class_implements($class)) as $class) {
-                if(isset($this->_dumpers[$class])) {
+                if (isset($this->_dumpers[$class])) {
                     return $this->_dumpers[$class];
                 }
             }
         }
 
-        if(isset($this->_dumpers[gettype($value)])) {
+        if (isset($this->_dumpers[gettype($value)])) {
             return $this->_dumpers[gettype($value)];
         }
 
@@ -72,9 +72,9 @@ 
     {
         $console = Console::get();
 
-        $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 = $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;
         }
 
         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/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));
         }