Bit-Wasp / stratum-php

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

src/Exception/ApiError.php

Spacing +1 added lines, -1 removed lines

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

src/Request/RequestFactory.php

Spacing +9 added lines, -9 removed lines

@@ -9,7 +9,7 @@ 
     /**
      * @var array
      */
-    private $nonces = [];
+    private $nonces = [ ];
 
     /**
      * @param string $method
@@ -35,14 +35,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'])) {
-                return 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' ])) {
+                return 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');