Bit-Wasp / stratum-php

src/Request/RequestFactory.php

Doc Comments +2 added lines, -3 removed lines

@@ -12,9 +12,8 @@ 
     private $nonces = [];
 
     /**
-     * @param $method
+     * @param string $method
      * @param array $params
-     * @param bool $id
      * @return Request
      */
     public function create($method, $params = array())
@@ -27,7 +26,7 @@ 
     }
 
     /**
-     * @param $string
+     * @param string $string
      * @return Response|Request
      * @throws \Exception
      */

Spacing +9 added lines, -9 removed lines

@@ -9,7 +9,7 @@ 
     /**
      * @var array
      */
-    private $nonces = [];
+    private $nonces = [ ];
 
     /**
      * @param $method
@@ -36,14 +36,14 @@ 
         $decoded = json_decode(trim($string), true);
 
         if (json_last_error() === JSON_ERROR_NONE) {
-            $id = isset($decoded['id']) ? $decoded['id'] : null;
-
-            if (isset($decoded['error'])) {
-                throw new ApiError($id, $decoded['error']);
-            } elseif (isset($decoded['method']) && isset($decoded['params'])) {
-                return new Request($id, $decoded['method'], $decoded['params']);
-            } elseif (isset($decoded['result'])) {
-                return new Response($id, $decoded['result']);
+            $id = isset($decoded[ 'id' ]) ? $decoded[ 'id' ] : null;
+
+            if (isset($decoded[ 'error' ])) {
+                throw new ApiError($id, $decoded[ 'error' ]);
+            } elseif (isset($decoded[ 'method' ]) && isset($decoded[ 'params' ])) {
+                return new Request($id, $decoded[ 'method' ], $decoded[ 'params' ]);
+            } elseif (isset($decoded[ 'result' ])) {
+                return new Response($id, $decoded[ 'result' ]);
             }
 
             throw new \Exception('Response missing error/params/result');

src/Api/ElectrumClient.php

Spacing +13 added lines, -13 removed lines

@@ -48,7 +48,7 @@ 
      */
     public function getServerVersion($clientVersion, $protocolVersion)
     {
-        return $this->conn->request(self::SERVER_VERSION, [$clientVersion, $protocolVersion]);
+        return $this->conn->request(self::SERVER_VERSION, [ $clientVersion, $protocolVersion ]);
     }
 
     /**
@@ -97,7 +97,7 @@ 
      */
     public function subscribeAddress($address)
     {
-        return $this->conn->request(self::ADDRESS_SUBSCRIBE, [$address]);
+        return $this->conn->request(self::ADDRESS_SUBSCRIBE, [ $address ]);
     }
 
     /**
@@ -106,7 +106,7 @@ 
      */
     public function transactionBroadcast($hex)
     {
-        return $this->conn->request(self::TRANSACTION_BROADCAST, [$hex]);
+        return $this->conn->request(self::TRANSACTION_BROADCAST, [ $hex ]);
     }
 
     /**
@@ -116,7 +116,7 @@ 
      */
     public function transactionGetMerkle($txid, $height)
     {
-        return $this->conn->request(self::TRANSACTION_GET_MERKLE, [$txid, $height]);
+        return $this->conn->request(self::TRANSACTION_GET_MERKLE, [ $txid, $height ]);
     }
 
     /**
@@ -125,7 +125,7 @@ 
      */
     public function transactionGet($txid)
     {
-        return $this->conn->request(self::TRANSACTION_GET, [$txid]);
+        return $this->conn->request(self::TRANSACTION_GET, [ $txid ]);
     }
 
     /**
@@ -134,7 +134,7 @@ 
      */
     public function addressGetHistory($address)
     {
-        return $this->conn->request(self::ADDRESS_GET_HISTORY, [$address]);
+        return $this->conn->request(self::ADDRESS_GET_HISTORY, [ $address ]);
     }
 
     /**
@@ -143,7 +143,7 @@ 
      */
     public function addressGetBalance($address)
     {
-        return $this->conn->request(self::ADDRESS_GET_BALANCE, [$address]);
+        return $this->conn->request(self::ADDRESS_GET_BALANCE, [ $address ]);
     }
 
     /**
@@ -152,7 +152,7 @@ 
      */
     public function addressGetProof($address)
     {
-        return $this->conn->request(self::ADDRESS_GET_PROOF, [$address]);
+        return $this->conn->request(self::ADDRESS_GET_PROOF, [ $address ]);
     }
 
     /**
@@ -161,7 +161,7 @@ 
      */
     public function addressListUnspent($address)
     {
-        return $this->conn->request(self::ADDRESS_LIST_UNSPENT, [$address]);
+        return $this->conn->request(self::ADDRESS_LIST_UNSPENT, [ $address ]);
     }
 
     /**
@@ -170,7 +170,7 @@ 
      */
     public function addressGetMempool($address)
     {
-        return $this->conn->request(self::ADDRESS_GET_MEMPOOL, [$address]);
+        return $this->conn->request(self::ADDRESS_GET_MEMPOOL, [ $address ]);
     }
 
     /**
@@ -180,7 +180,7 @@ 
      */
     public function utxoGetAddress($txid, $nOutput)
     {
-        return $this->conn->request(self::UTXO_GET_ADDRESS, [$txid, $nOutput]);
+        return $this->conn->request(self::UTXO_GET_ADDRESS, [ $txid, $nOutput ]);
     }
 
     /**
@@ -205,7 +205,7 @@ 
      */
     public function blockGetHeader($blockHeight)
     {
-        return $this->conn->request(self::BLOCK_GET_HEADER, [$blockHeight]);
+        return $this->conn->request(self::BLOCK_GET_HEADER, [ $blockHeight ]);
     }
 
     /**
@@ -214,6 +214,6 @@ 
      */
     public function blockGetChunk($blockHeight)
     {
-        return $this->conn->request(self::BLOCK_GET_CHUNK, [$blockHeight]);
+        return $this->conn->request(self::BLOCK_GET_CHUNK, [ $blockHeight ]);
     }
 }

src/Api/MiningClient.php

Spacing +2 added lines, -2 removed lines

@@ -41,7 +41,7 @@ 
      */
     public function authorize($user, $password)
     {
-        return $this->conn->request(self::AUTHORIZE, [$user, $password]);
+        return $this->conn->request(self::AUTHORIZE, [ $user, $password ]);
     }
 
     /**
@@ -54,6 +54,6 @@ 
      */
     public function submit($worker_name, $job_id, $extranonce2, $ntime, $nonce)
     {
-        return $this->conn->request(self::SUBMIT, [$worker_name, $job_id, $extranonce2, $ntime, $nonce]);
+        return $this->conn->request(self::SUBMIT, [ $worker_name, $job_id, $extranonce2, $ntime, $nonce ]);
     }
 }

src/Connection.php

Spacing +17 added lines, -17 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()
@@ -60,7 +60,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->send($request);
@@ -82,7 +82,7 @@ 
     public function send(Request $request)
     {
         $result = new Deferred();
-        $this->deferred[$request->getId()] = $result;
+        $this->deferred[ $request->getId() ] = $result;
         $this->stream->write($request->write());
 
         return $result->promise();
@@ -93,7 +93,7 @@ 
      */
     public function onData($data)
     {
-        $buffer = $this->streamBuffer . $data;
+        $buffer = $this->streamBuffer.$data;
 
         while (($nextPos = strpos($buffer, "\n"))) {
             $msg = substr($buffer, 0, $nextPos);
@@ -119,54 +119,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 (count($params) !== 1) {
                             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;
                 }
             }

src/Request/Response.php

Spacing +1 added lines, -1 removed lines

@@ -48,6 +48,6 @@
         return json_encode([
             'id' => $this->id,
             'result' => $this->result
-        ]) . "\n";
+        ])."\n";
     }
 }

src/Client.php

Spacing +2 added lines, -2 removed lines

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

src/Notification/NumBlocksNotification.php

Spacing +1 added lines, -1 removed lines

@@ -34,6 +34,6 @@
      */
     public function toRequest()
     {
-        return new Request(null, ElectrumClient::NUMBLOCKS_SUBSCRIBE, [$this->height]);
+        return new Request(null, ElectrumClient::NUMBLOCKS_SUBSCRIBE, [ $this->height ]);
     }
 }

src/Notification/HeadersNotification.php

Spacing +2 added lines, -2 removed lines

@@ -139,10 +139,10 @@
      */
     public function toRequest()
     {
-        return new Request(null, ElectrumClient::HEADERS_SUBSCRIBE, [[
+        return new Request(null, ElectrumClient::HEADERS_SUBSCRIBE, [ [
             $this->nonce, $this->prevBlock, $this->timestamp,
             $this->merkleRoot, $this->height, $this->utxoRoot,
             $this->version, $this->bits
-        ]]);
+        ] ]);
     }
 }

src/Notification/AddressNotification.php

Spacing +1 added lines, -1 removed lines

@@ -49,6 +49,6 @@
      */
     public function toRequest()
     {
-        return new Request(null, ElectrumClient::ADDRESS_SUBSCRIBE, [$this->address, $this->txid]);
+        return new Request(null, ElectrumClient::ADDRESS_SUBSCRIBE, [ $this->address, $this->txid ]);
     }
 }