kadet1090 / nucleus

Utils/BetterEmitter.php

Spacing +3 added lines, -3 removed lines

@@ -83,7 +83,7 @@ 
 
         $condition = with\predicate($condition);
 
-        return function (...$arguments) use ($listener, $condition) {
+        return function(...$arguments) use ($listener, $condition) {
             if ($condition(...$arguments)) {
                 return (bool)$listener(...$arguments);
             }
@@ -94,8 +94,8 @@ 
 
     private function getOnceCallable(callable $listener, $event) : callable
     {
-        return $onceListener = function (...$arguments) use (&$onceListener, $event, $listener) {
-            if(($result = $listener(...$arguments)) !== null) {
+        return $onceListener = function(...$arguments) use (&$onceListener, $event, $listener) {
+            if (($result = $listener(...$arguments)) !== null) {
                 $this->removeListener($event, $onceListener);
                 return $result;
             }

Xml/XmlStream.php

Spacing +11 added lines, -11 removed lines

@@ -76,32 +76,32 @@ 
 
         $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) {
             try {
                 $this->emit('element', $arguments);
-            } catch(\Throwable $error) {
-                if($this->emit('exception', [ $error ])) {
+            } catch (\Throwable $error) {
+                if ($this->emit('exception', [$error])) {
                     throw $error;
                 }
             }
 
         });
-        $this->on('close', function () { $this->_isOpened = false; });
+        $this->on('close', function() { $this->_isOpened = false; });
     }
 
     /**
@@ -113,7 +113,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);
     }
@@ -178,7 +178,7 @@ 
 
     private function handleError(Error $element)
     {
-        if ($this->emit('stream.error', [ $element ])) {
+        if ($this->emit('stream.error', [$element])) {
             throw new StreamErrorException($element);
         }
 

Stanza/Stanza.php

Spacing +4 added lines, -4 removed lines

@@ -54,7 +54,7 @@ 
 
     public function getFrom()
     {
-        if($this->_from === false) {
+        if ($this->_from === false) {
             $this->_from = $this->hasAttribute('from') ? new Jid($this->_from) : null;
         }
 
@@ -63,7 +63,7 @@ 
 
     public function getTo()
     {
-        if($this->_to === false) {
+        if ($this->_to === false) {
             $this->_to = $this->hasAttribute('to') ? new Jid($this->_to) : null;
         }
 
@@ -82,7 +82,7 @@ 
 
     public function setFrom($from)
     {
-        if($from instanceof Jid) {
+        if ($from instanceof Jid) {
             $this->_from = $from instanceof Jid ? $from : new Jid($from);
         }
 
@@ -91,7 +91,7 @@ 
 
     public function setTo($to)
     {
-        if($to instanceof Jid) {
+        if ($to instanceof Jid) {
             $this->_to = $to instanceof Jid ? $to : new Jid($to);
         }
 

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

Xml/XmlElement.php

Spacing +13 added lines, -13 removed lines

@@ -105,7 +105,7 @@ 
     {
         $this->init($name, $uri);
         $this->append($content);
-        foreach($attributes as $name => $value) {
+        foreach ($attributes as $name => $value) {
             $this->setAttribute($name, $value);
         }
     }
@@ -134,7 +134,7 @@ 
      */
     public function getInnerXml()
     {
-        return implode('', array_map(function ($element) {
+        return implode('', array_map(function($element) {
             if (is_string($element)) {
                 return htmlspecialchars($element);
             } elseif ($element instanceof XmlElement) {
@@ -161,7 +161,7 @@ 
         $attributes = $this->attributes();
 
         $result = "<{$this->name}";
-        $result .= ' ' . implode(' ', array_map(function ($key, $value) {
+        $result .= ' ' . implode(' ', array_map(function($key, $value) {
             return $key . '="' . htmlspecialchars($value, ENT_QUOTES) . '"';
         }, array_keys($attributes), array_values($attributes)));
 
@@ -182,7 +182,7 @@ 
      */
     public function lookupPrefix(string $uri = null)
     {
-        return $this->getNamespaces()[ $uri ] ?? false;
+        return $this->getNamespaces()[$uri] ?? false;
     }
 
     /**
@@ -226,12 +226,12 @@ 
     {
         $attribute = $this->_prefix($attribute, $uri);
         if ($value === null) {
-            unset($this->_attributes[ $attribute ]);
+            unset($this->_attributes[$attribute]);
 
             return;
         }
 
-        $this->_attributes[ $attribute ] = $value;
+        $this->_attributes[$attribute] = $value;
     }
 
     /**
@@ -243,7 +243,7 @@ 
      */
     public function getAttribute(string $attribute, string $uri = null)
     {
-        return $this->_attributes[ $this->_prefix($attribute, $uri) ] ?? false;
+        return $this->_attributes[$this->_prefix($attribute, $uri)] ?? false;
     }
 
     /**
@@ -256,7 +256,7 @@ 
      */
     public function hasAttribute(string $attribute, string $uri = null)
     {
-        return isset($this->_attributes[ $this->_prefix($attribute, $uri) ]);
+        return isset($this->_attributes[$this->_prefix($attribute, $uri)]);
     }
 
     /**
@@ -275,7 +275,7 @@ 
     protected function setParent(XmlElement $parent)
     {
         if (!$this->_prefix && ($prefix = $parent->lookupPrefix($this->namespace)) !== false) {
-            $this->_namespaces[ $this->namespace ] = $prefix;
+            $this->_namespaces[$this->namespace] = $prefix;
             $this->_prefix                         = $prefix;
         }
 
@@ -298,7 +298,7 @@ 
             return false;
         }
 
-        if(is_array($element)) {
+        if (is_array($element)) {
             array_walk($element, [$this, 'append']);
             return $element;
         }
@@ -342,7 +342,7 @@ 
             $prefix = $this->_prefix;
         }
 
-        $this->_namespaces[ $uri ] = $prefix;
+        $this->_namespaces[$uri] = $prefix;
     }
 
     public function getName()
@@ -381,7 +381,7 @@ 
      */
     public function element(string $name, string $uri = null, int $index = 0)
     {
-        return array_values($this->elements($name, $uri))[ $index ] ?? false;
+        return array_values($this->elements($name, $uri))[$index] ?? false;
     }
 
     /**
@@ -455,7 +455,7 @@ 
     private function attributes(): array
     {
         $namespaces = $this->getNamespaces(false);
-        $namespaces = array_map(function ($prefix, $uri) {
+        $namespaces = array_map(function($prefix, $uri) {
             return [$prefix ? "xmlns:{$prefix}" : 'xmlns', $uri];
         }, array_values($namespaces), array_keys($namespaces));
 

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

Xml/XmlParser.php

Spacing +10 added lines, -10 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 ]);
+        $element = $this->factory->create($uri, $tag, [$name, $uri]);
 
         foreach ($namespaces as $prefix => $uri) {
             $element->setNamespace($uri, $prefix);
@@ -145,7 +145,7 @@ 
         if (count($this->_stack) > 1) {
             end($this->_stack)->append($element);
         }
-        $this->emit('parse.begin', [ $element ]);
+        $this->emit('parse.begin', [$element]);
 
         $this->_stack[] = $element;
     }
@@ -158,10 +158,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)

XmppClient.php

Spacing +4 added lines, -4 removed lines

@@ -110,11 +110,11 @@ 
 
         $this->applyOptions($options);
 
-        $this->_connector->on('connect', function (...$arguments) {
+        $this->_connector->on('connect', function(...$arguments) {
             return $this->emit('connect', $arguments);
         });
 
-        $this->on('element', function (Features $element) {
+        $this->on('element', function(Features $element) {
             $this->_features = $element;
             $this->emit('features', [$element]);
         }, Features::class);
@@ -133,7 +133,7 @@ 
             'password'  => -1
         ]);
 
-        if($options['default-modules']) {
+        if ($options['default-modules']) {
             $options['modules'] = array_merge([
                 TlsEnabler::class    => new TlsEnabler(),
                 Binding::class       => new Binding(),
@@ -218,7 +218,7 @@ 
             ));
         }
 
-        $this->_connector->on('connect', function ($stream) {
+        $this->_connector->on('connect', function($stream) {
             $this->handleConnect($stream);
         });
     }