Bit-Wasp / stratum-php

src/Client.php

Spacing +2 added lines, -2 removed lines

@@ -36,9 +36,9 @@
      */
     public function connect($host, $port)
     {
-        return $this->connector->create($host, $port)->then(function (Stream $stream) {
+        return $this->connector->create($host, $port)->then(function(Stream $stream) {
             return new Connection($stream, $this->requestFactory);
-        }, function (\Exception $e) {
+        }, function(\Exception $e) {
             throw $e;
         });
     }

src/Connection.php

Spacing +18 added lines, -18 removed lines

@@ -31,7 +31,7 @@ 
     /**
      * @var Deferred[]
      */
-    private $deferred = [];
+    private $deferred = [ ];
 
     /**
      * @var string
@@ -47,7 +47,7 @@ 
     {
         $this->factory = $requestFactory;
         $this->stream = $stream;
-        $this->stream->on('data', [$this, 'onData']);
+        $this->stream->on('data', [ $this, 'onData' ]);
     }
 
     public function close()
@@ -80,7 +80,7 @@ 
     public function sendRequest(Request $request)
     {
         $result = new Deferred();
-        $this->deferred[$request->getId()] = $result;
+        $this->deferred[ $request->getId() ] = $result;
         $this->sendData($request->write());
         return $result->promise();
     }
@@ -90,7 +90,7 @@ 
      * @param array $params
      * @return \React\Promise\Promise|\React\Promise\PromiseInterface
      */
-    public function request($method, array $params = [])
+    public function request($method, array $params = [ ])
     {
         $request = $this->factory->create($method, $params);
         return $this->sendRequest($request);
@@ -101,7 +101,7 @@ 
      */
     public function onData($data)
     {
-        $buffer = $this->streamBuffer . $data;
+        $buffer = $this->streamBuffer.$data;
 
         while (($nextPos = strpos($buffer, "\n"))) {
             $msg = substr($buffer, 0, $nextPos);
@@ -127,54 +127,54 @@ 
     public function onMessage($data)
     {
         $response = $this->factory->response($data);
-        if (isset($this->deferred[$response->getId()])) {
-            $this->deferred[$response->getId()]->resolve($response);
+        if (isset($this->deferred[ $response->getId() ])) {
+            $this->deferred[ $response->getId() ]->resolve($response);
         } else {
-            $this->emit('message', [$response]);
+            $this->emit('message', [ $response ]);
 
             if ($response instanceof Request) {
                 $params = $response->getParams();
 
                 switch ($response->getMethod()) {
                     case ElectrumClient::HEADERS_SUBSCRIBE:
-                        if (!isset($params[0])) {
+                        if (!isset($params[ 0 ])) {
                             throw new \RuntimeException('Headers notification missing body');
                         }
                         
-                        $header = $params[0];
+                        $header = $params[ 0 ];
                         if (count($header) !== 8) {
                             throw new \RuntimeException('Headers notification missing parameter');
                         }
 
-                        $this->emit(ElectrumClient::HEADERS_SUBSCRIBE, [new HeadersNotification($header[0], $header[1], $header[2], $header[3], $header[4], $header[5], $header[6], $header[7])]);
+                        $this->emit(ElectrumClient::HEADERS_SUBSCRIBE, [ new HeadersNotification($header[ 0 ], $header[ 1 ], $header[ 2 ], $header[ 3 ], $header[ 4 ], $header[ 5 ], $header[ 6 ], $header[ 7 ]) ]);
                         break;
                     case ElectrumClient::ADDRESS_SUBSCRIBE:
-                        if (!isset($params[0]) || !isset($params[1])) {
+                        if (!isset($params[ 0 ]) || !isset($params[ 1 ])) {
                             throw new \RuntimeException('Address notification missing address/txid');
                         }
 
-                        $this->emit(ElectrumClient::ADDRESS_SUBSCRIBE, [new AddressNotification($params[0], $params[1])]);
+                        $this->emit(ElectrumClient::ADDRESS_SUBSCRIBE, [ new AddressNotification($params[ 0 ], $params[ 1 ]) ]);
                         break;
                     case ElectrumClient::NUMBLOCKS_SUBSCRIBE:
-                        if (!isset($params[0])) {
+                        if (!isset($params[ 0 ])) {
                             throw new \RuntimeException('Missing notification parameter: height');
                         }
 
-                        $this->emit(ElectrumClient::NUMBLOCKS_SUBSCRIBE, [new NumBlocksNotification($params[0])]);
+                        $this->emit(ElectrumClient::NUMBLOCKS_SUBSCRIBE, [ new NumBlocksNotification($params[ 0 ]) ]);
                         break;
                     case MiningClient::SET_DIFFICULTY:
-                        if (!isset($params[0])) {
+                        if (!isset($params[ 0 ])) {
                             throw new \RuntimeException('Missing mining difficulty notification parameter');
                         }
 
-                        $this->emit(MiningClient::SET_DIFFICULTY, [new SetDifficultyNotification($params[0])]);
+                        $this->emit(MiningClient::SET_DIFFICULTY, [ new SetDifficultyNotification($params[ 0 ]) ]);
                         break;
                     case MiningClient::NOTIFY:
                         if (count($params) !== 9) {
                             throw new \RuntimeException('Missing mining notification parameter');
                         }
 
-                        $this->emit(MiningClient::NOTIFY, [new MiningNotification($params[0], $params[1], $params[2], $params[3], $params[4], $params[5], $params[6], $params[7], $params[8])]);
+                        $this->emit(MiningClient::NOTIFY, [ new MiningNotification($params[ 0 ], $params[ 1 ], $params[ 2 ], $params[ 3 ], $params[ 4 ], $params[ 5 ], $params[ 6 ], $params[ 7 ], $params[ 8 ]) ]);
                         break;
                 }
             }