kadet1090 / nucleus

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

Module/Binding.php

Spacing +4 added lines, -4 removed lines

@@ -30,18 +30,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(\Kadet\Xmpp\Utils\filter\element('bind', self::XMLNS))) {
+        if ($features->has(\Kadet\Xmpp\Utils\filter\element('bind', self::XMLNS))) {
             $stanza = new Stanza('iq', ['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, $this->_client->jid->resource));
             }
 
@@ -58,7 +58,7 @@ 
 
     public function handleResult(Stanza $stanza)
     {
-        if($stanza->type === 'result') {
+        if ($stanza->type === 'result') {
             $this->_client->bind($stanza->element('bind', self::XMLNS)->element('jid')->innerXml);
         }
     }

Utils/Filter.php

Spacing +8 added lines, -8 removed lines

@@ -25,8 +25,8 @@ 
 
     function xmlns($uri)
     {
-        return function ($element) use ($uri) {
-            if(!$element instanceof XmlElement) {
+        return function($element) use ($uri) {
+            if (!$element instanceof XmlElement) {
                 return false;
             }
 
@@ -36,8 +36,8 @@ 
 
     function tag($name)
     {
-        return function ($element) use ($name) {
-            if(!$element instanceof XmlElement) {
+        return function($element) use ($name) {
+            if (!$element instanceof XmlElement) {
                 return false;
             }
 
@@ -47,14 +47,14 @@ 
 
     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;
@@ -67,7 +67,7 @@ 
 
     function any(callable ...$functions)
     {
-        return function (...$args) use ($functions) {
+        return function(...$args) use ($functions) {
             foreach ($functions as $function) {
                 if ($function(...$args)) {
                     return true;
@@ -91,7 +91,7 @@ 
 
     function argument($name, $value) {
         return function($element) use ($name, $value) {
-            if(!$element instanceof XmlElement) {
+            if (!$element instanceof XmlElement) {
                 return false;
             }
 

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

XmppClient.php

Spacing +4 added lines, -4 removed lines

@@ -109,11 +109,11 @@ 
             $this->register($module);
         }
 
-        $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);
@@ -159,7 +159,7 @@ 
     {
         $this->_jid = new Jid($jid);
 
-        $this->emit('bind', [ $jid ]);
+        $this->emit('bind', [$jid]);
     }
 
     private function handleConnect($stream)
@@ -189,7 +189,7 @@ 
             ));
         }
 
-        $this->_connector->on('connect', function ($stream) {
+        $this->_connector->on('connect', function($stream) {
             $this->handleConnect($stream);
         });
     }

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