kadet1090 / nucleus

Component/Roster.php

Doc Comments -1 removed lines

@@ -184,7 +184,6 @@
     }
 
     /**
-     * @param callable(Item $item) $mapper
      * @return array
      */
     public function map(callable $mapper)

Spacing +6 added lines, -6 removed lines

@@ -47,7 +47,7 @@ 
 
     public function setClient(XmppClient $client)
     {
-        if($this->_client !== null) {
+        if ($this->_client !== null) {
             throw new BadMethodCallException("You cannot change rosters XmppClient instance.");
         }
 
@@ -72,7 +72,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);
@@ -169,7 +169,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']));
         }
 
@@ -186,7 +186,7 @@ 
     public function update(Iq\Query\Roster\Item $item)
     {
         $iq = new Iq('set', ['query' => new Iq\Query\Roster([
-            'items' => [ $item ]
+            'items' => [$item]
         ])]);
 
         return $this->_client->send($iq);
@@ -274,7 +274,7 @@ 
 
     private function setItem(Iq\Query\Roster\Item $item)
     {
-        $this->emit('item', [ $item ]);
+        $this->emit('item', [$item]);
         $this->_items[(string)$item->jid] = $item;
     }
 
@@ -287,7 +287,7 @@ 
             return;
         }
 
-        $this->emit('remove', [ $this->_items[(string)$jid] ]);
+        $this->emit('remove', [$this->_items[(string)$jid]]);
         unset($this->_items[(string)$jid]);
     }
 }

Stanza/Iq/Query/Roster.php

Spacing +2 added lines, -2 removed lines

@@ -86,7 +86,7 @@ 
 
     protected function appendChild($element)
     {
-        if(!$element instanceof Item) {
+        if (!$element instanceof Item) {
             throw new InvalidArgumentException(format('Only instances of roster item ({expected}) can be added into roster, tried to add {actual}', [
                 'expected' => Item::class,
                 'actual'   => get_class($element)
@@ -99,7 +99,7 @@ 
     public static function getXmlCollocations() : array
     {
         return [
-            [ Item::class, 'name' => 'item', 'uri' => 'jabber:iq:roster' ]
+            [Item::class, 'name' => 'item', 'uri' => 'jabber:iq:roster']
         ];
     }
 }

XmppClient.php

Spacing +11 added lines, -11 removed lines

@@ -148,17 +148,17 @@ 
 
         $this->applyOptions($options);
 
-        $this->on('element', function (Features $element) {
+        $this->on('element', function(Features $element) {
             $this->_features = $element;
             $this->emit('features', [$element]);
         }, Features::class);
 
-        $this->on('element', function (Stanza $stanza) {
-            $this->emit('stanza', [ $stanza ]);
-            $this->emit($stanza->localName, [ $stanza ]);
+        $this->on('element', function(Stanza $stanza) {
+            $this->emit('stanza', [$stanza]);
+            $this->emit($stanza->localName, [$stanza]);
         }, Stanza::class);
 
-        $this->on('close', function () {
+        $this->on('close', function() {
             $this->state = 'disconnected';
         });
     }
@@ -211,7 +211,7 @@ 
         $this->state = 'bound';
 
         $queue = new \SplQueue();
-        $this->emit('init', [ $queue ]);
+        $this->emit('init', [$queue]);
 
         \React\Promise\all(iterator_to_array($queue))->then(function() {
             $this->state = 'ready';
@@ -235,10 +235,10 @@ 
 
         if ($alias === true) {
             $this->_addToContainer($module, array_merge(class_implements($module), array_slice(class_parents($module), 1)));
-        } elseif(is_array($alias)) {
+        } elseif (is_array($alias)) {
             $this->_addToContainer($module, $alias);
         } else {
-            $this->_addToContainer($module, [ $alias === false ? get_class($module) : $alias ]);
+            $this->_addToContainer($module, [$alias === false ? get_class($module) : $alias]);
         }
     }
 
@@ -261,7 +261,7 @@ 
         $deferred = new Deferred();
 
         $this->once('element', function(Stanza $stanza) use ($deferred) {
-            if($stanza->type === "error") {
+            if ($stanza->type === "error") {
                 $deferred->reject($stanza);
             } else {
                 $deferred->resolve($stanza);
@@ -297,7 +297,7 @@ 
     //region Parser
     public function setParser(XmlParser $parser)
     {
-        if($this->state !== "disconnected") {
+        if ($this->state !== "disconnected") {
             throw new \BadMethodCallException('Parser can be changed only when client is disconnected.');
         }
 
@@ -325,7 +325,7 @@ 
             ));
         }
 
-        $this->_connector->on('connect', function ($stream) {
+        $this->_connector->on('connect', function($stream) {
             return $this->handleConnect($stream);
         });
     }

Indentation +1 added lines, -1 removed lines

@@ -267,7 +267,7 @@
             } else {
                 $deferred->resolve($stanza);
             }
-         }, with\stanza\id($stanza->id));
+            }, with\stanza\id($stanza->id));
         $this->write($stanza);
 
         return $deferred->promise();

Sasl/DigestMD5.php

Spacing +1 added lines, -1 removed lines

@@ -28,7 +28,7 @@
      */
     public function createResponse($challenge = null)
     {
-        if(strpos($challenge, 'rspauth=') !== false) {
+        if (strpos($challenge, 'rspauth=') !== false) {
             return '';
         }
 

Utils/DnsResolver.php

Spacing +1 added lines, -1 removed lines

@@ -56,7 +56,7 @@
                 continue;
             }
 
-            $this->_results = array_merge($this->_results, array_map(function ($record) use($type) {
+            $this->_results = array_merge($this->_results, array_map(function($record) use($type) {
                 return $type === DNS_SRV
                     ? [$record['target'], $record['port']]
                     : [$record['ip'], $this->_port];

Component/Subscription/SubscriptionManager.php

Doc Comments +4 added lines, -1 removed lines

@@ -55,7 +55,7 @@ 
     /**
      * Sends subscription removal request presence to server.
      *
-     * @param Jid|string $jid
+     * @param Jid $jid
      * @return \React\Promise\ExtendedPromiseInterface
      */
     public function unsubscribe(Jid $jid)
@@ -74,6 +74,9 @@ 
         return $this->_client->send($this->presence('unsubscribed', $jid));
     }
 
+    /**
+     * @param string $type
+     */
     private function presence($type, $jid)
     {
         $jid = $jid instanceof Jid ? $jid : new Jid($jid);

Spacing +1 added lines, -1 removed lines

@@ -38,7 +38,7 @@
 
     private function handleSubscriptionRequest(Presence $presence)
     {
-        $this->emit('request', [ $presence ]);
+        $this->emit('request', [$presence]);
     }
 
     /**

Component/TlsEnabler.php

Unused Use Statements -1 removed lines

@@ -20,7 +20,6 @@
 use Kadet\Xmpp\Stream\Features;
 use Kadet\Xmpp\Utils\filter as with;
 use Kadet\Xmpp\Xml\XmlElement;
-use Kadet\Xmpp\XmppClient;
 
 class TlsEnabler extends Component
 {

Spacing +2 added lines, -2 removed lines

@@ -26,11 +26,11 @@
 {
     public function init()
     {
-        $this->_client->on('features', function (Features $features) {
+        $this->_client->on('features', function(Features $features) {
             return !$this->startTls($features);
         }, null, 10);
 
-        $this->_client->on('element', function (XmlElement $element) {
+        $this->_client->on('element', function(XmlElement $element) {
             return $this->handleTls($element);
         }, with\element\xmlns(Features\StartTls::XMLNS));
     }

Network/Connector/TcpXmppConnector.php

Spacing +2 added lines, -2 removed lines

@@ -44,13 +44,13 @@
                 stream_context_set_option($stream, 'ssl', 'peer_name', $this->_host);
 
                 $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)

Stanza/Stanza.php

Spacing +5 added lines, -5 removed lines

@@ -55,7 +55,7 @@ 
 
     public function getFrom()
     {
-        if((string)$this->_from !== $this->hasAttribute('from')) {
+        if ((string)$this->_from !== $this->hasAttribute('from')) {
             $this->_from = $this->hasAttribute('from') ? new Jid($this->getAttribute('from')) : null;
         }
 
@@ -64,7 +64,7 @@ 
 
     public function getTo()
     {
-        if((string)$this->_to !== $this->hasAttribute('to')) {
+        if ((string)$this->_to !== $this->hasAttribute('to')) {
             $this->_to = $this->hasAttribute('to') ? new Jid($this->getAttribute('to')) : null;
         }
 
@@ -88,7 +88,7 @@ 
 
     public function setFrom($from)
     {
-        if($from instanceof Jid) {
+        if ($from instanceof Jid) {
             $this->_from = $from instanceof Jid ? $from : new Jid($from);
         }
 
@@ -97,7 +97,7 @@ 
 
     public function setTo($to)
     {
-        if($to instanceof Jid) {
+        if ($to instanceof Jid) {
             $this->_to = $to instanceof Jid ? $to : new Jid($to);
         }
 
@@ -133,7 +133,7 @@ 
     public static function getXmlCollocations() : array
     {
         return [
-            [ Error::class, 'name' => 'error', 'uri' => 'jabber:client' ],
+            [Error::class, 'name' => 'error', 'uri' => 'jabber:client'],
         ];
     }
 }