kadet1090 / nucleus

Xml/XmlParser.php

Spacing +11 added lines, -11 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 () {
+        }, function() {
             $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);
         });
 
@@ -111,8 +111,8 @@ 
             return 'http://www.w3.org/2000/xmlns/';
         }
 
-        if (isset($namespaces[ $prefix ])) {
-            return $namespaces[ $prefix ];
+        if (isset($namespaces[$prefix])) {
+            return $namespaces[$prefix];
         }
 
         return !empty($this->_stack) ? end($this->_stack)->lookupUri($prefix) : null;
@@ -123,10 +123,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 ], $this->_getCollocations());
+        $element = $this->factory->create($uri, $tag, [$name, $uri], $this->_getCollocations());
 
         foreach ($namespaces as $prefix => $uri) {
             $element->setNamespace($uri, $prefix);
@@ -140,7 +140,7 @@ 
 
     private function _getCollocations()
     {
-        if(empty($this->_stack)) {
+        if (empty($this->_stack)) {
             return [];
         }
 
@@ -159,7 +159,7 @@ 
         if (count($this->_stack) > 0) {
             end($this->_stack)->append($element);
         }
-        $this->emit('parse.begin', [ $element, count($this->_stack) ]);
+        $this->emit('parse.begin', [$element, count($this->_stack)]);
 
         $this->_stack[] = $element;
     }
@@ -172,10 +172,10 @@ 
 
         $element = array_pop($this->_stack);
         if (count($this->_stack) == 1) {
-            $this->emit('element', [ $element, count($this->_stack) ]);
+            $this->emit('element', [$element, count($this->_stack)]);
         }
 
-        $this->emit('parse.end', [ $element, count($this->_stack) ]);
+        $this->emit('parse.end', [$element, count($this->_stack)]);
     }
 
     private function handleTextData($data)

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'])

Utils/BetterEmitter.php

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

Component/Binding.php

Spacing +4 added lines, -4 removed lines

@@ -31,18 +31,18 @@ 
     {
         parent::setClient($client);
 
-        $client->on('features', function (Features $features) {
+        $client->on('features', function(Features $features) {
             return !$this->bind($features);
         });
     }
 
     public function bind(Features $features)
     {
-        if($features->has(with\element('bind', self::XMLNS))) {
+        if ($features->has(with\element('bind', self::XMLNS))) {
             $stanza = new Stanza('iq', ['attributes' => ['type' => 'set']]);
             $bind = $stanza->append(new XmlElement('bind', self::XMLNS));
 
-            if(!$this->_client->jid->isBare()) {
+            if (!$this->_client->jid->isBare()) {
                 $bind->append(new XmlElement('resource', null, ['content' => $this->_client->jid->resource]));
             }
 
@@ -59,7 +59,7 @@ 
 
     public function handleResult(Stanza $stanza)
     {
-        if($stanza->type === 'error') {
+        if ($stanza->type === 'error') {
             throw BindingException::fromError($this->_client->jid, $stanza->error);
         }
 

Component/TlsEnabler.php

Spacing +2 added lines, -2 removed lines

@@ -29,11 +29,11 @@
     {
         parent::setClient($client);
 
-        $client->on('features', function (Features $features) {
+        $client->on('features', function(Features $features) {
             return $this->handleFeatures($features);
         }, null, 10);
 
-        $client->on('element', function (XmlElement $element) {
+        $client->on('element', function(XmlElement $element) {
             $this->handleTls($element);
         }, with\xmlns(Features\StartTls::XMLNS));
     }

Component/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]);

Stanza/Iq.php

Spacing +2 added lines, -2 removed lines

@@ -48,7 +48,7 @@ 
 
     protected function appendChild($element)
     {
-        if(count($this->children) > 0) {
+        if (count($this->children) > 0) {
             throw new \RuntimeException('Iq stanzas cannot have more than one child.');
         }
 
@@ -77,7 +77,7 @@ 
     public static function getXmlCollocations() : array
     {
         return array_merge(
-            [[ Query::class, 'name' => pass(), 'uri' => pass() ]],
+            [[Query::class, 'name' => pass(), 'uri' => pass()]],
             parent::getXmlCollocations()
         );
     }

Component/Roster.php

Spacing +4 added lines, -4 removed lines

@@ -62,7 +62,7 @@ 
     private function handleSet(Iq\Query\Roster $query)
     {
         foreach ($query->items as $item) {
-            if($item->subscription == 'remove') {
+            if ($item->subscription == 'remove') {
                 $this->removeItem($item->jid);
             } else {
                 $this->setItem($item);
@@ -151,7 +151,7 @@ 
 
         $iq = new Iq('remove', ['query' => new Iq\Query\Roster()]);
         /** @var Iq\Query\Roster\Item $item */
-        foreach($remove as $item) {
+        foreach ($remove as $item) {
             $iq->query->append(new Iq\Query\Roster\Item($item->jid, ['subscription' => 'remove']));
         }
 
@@ -228,7 +228,7 @@ 
 
     private function setItem(Iq\Query\Roster\Item $item)
     {
-        $this->emit('item', [ $item ]);
+        $this->emit('item', [$item]);
         $this->_items[(string)$item->jid] = $item;
     }
 
@@ -241,7 +241,7 @@ 
             return;
         }
 
-        $this->emit('remove', [ $this->_items[(string)$jid] ]);
+        $this->emit('remove', [$this->_items[(string)$jid]]);
         unset($this->_items[(string)$jid]);
     }
 }