Update document

example/live-order-book.php

@@ -7,13 +7,15 @@
 use Farzai\Bitkub\WebSocket\Message;
 use Farzai\Bitkub\WebSocketClient;
 
-$client = ClientBuilder::create()
-    ->setCredentials('YOUR_API_KEY', 'YOUR_SECRET')
-    ->build();
+$websocket = new LiveOrderBookEndpoint(
+    new WebSocketClient(
+        ClientBuilder::create()
+            ->setCredentials('YOUR_API_KEY', 'YOUR_SECRET')
+            ->build()
+    )
+);
 
-$websocket = new LiveOrderBookEndpoint(new WebSocketClient($client));
-
-$websocket->listen('thb_btc', function (Message $message) {
+$websocket->listen('THB_ADA', function (Message $message) {
     echo $message->json('event').PHP_EOL;
 });
 

example/stream-trade.php

@@ -2,18 +2,15 @@
 
 require_once __DIR__.'/../vendor/autoload.php';
 
-use Farzai\Bitkub\ClientBuilder;
-use Farzai\Bitkub\WebSocket\Endpoints\MarketEndpoint;
-use Farzai\Bitkub\WebSocket\Message;
-use Farzai\Bitkub\WebSocketClient;
+$websocket = new \Farzai\Bitkub\WebSocket\Endpoints\MarketEndpoint(
+    new \Farzai\Bitkub\WebSocketClient(
+        \Farzai\Bitkub\ClientBuilder::create()
+            ->setCredentials('YOUR_API_KEY', 'YOUR_SECRET')
+            ->build()
+    )
+);
 
-$client = ClientBuilder::create()
-    ->setCredentials('YOUR_API_KEY', 'YOUR_SECRET')
-    ->build();
-
-$websocket = new MarketEndpoint(new WebSocketClient($client));
-
-$websocket->listen('trade.thb_ada', function (Message $message) {
+$websocket->listen('trade.thb_ada', function (Farzai\Bitkub\WebSocket\Message $message) {
     echo $message->json('sym').PHP_EOL;
 });
 

src/Endpoints/UserEndpoint.php

@@ -63,7 +63,7 @@ public function tradingCredits(): ResponseInterface
      *      }
      * }
      */
-    public function userLimits(): ResponseInterface
+    public function limits(): ResponseInterface
     {
         $config = $this->client->getConfig();
 

src/WebSocket/Endpoints/AbstractEndpoint.php

@@ -20,4 +20,9 @@ public function run()
     {
         $this->websocket->run();
     }
+
+    protected function getLogger()
+    {
+        return $this->websocket->getLogger();
+    }
 }

src/WebSocket/Endpoints/LiveOrderBookEndpoint.php

@@ -2,6 +2,8 @@
 
 namespace Farzai\Bitkub\WebSocket\Endpoints;
 
+use Farzai\Bitkub\Endpoints as RestApiEndpoints;
+
 class LiveOrderBookEndpoint extends AbstractEndpoint
 {
     /**
@@ -11,10 +13,35 @@ class LiveOrderBookEndpoint extends AbstractEndpoint
      *    echo $message->json('sym').PHP_EOL;
      * });
      *
+     * @param  string|int  $symbol Symbol name or id.
      * @param  callable|array<callable>  $listeners
      */
-    public function listen(string $symbol, $listeners)
+    public function listen($symbol, $listeners)
     {
+        // Check if symbol is numeric.
+        if (! is_numeric($symbol)) {
+
+            $this->getLogger()->debug('Find symbol id by name: '.$symbol);
+
+            // Find symbol id by name.
+            $market = new RestApiEndpoints\MarketEndpoint($this->websocket->getClient());
+
+            foreach ($market->symbols()->throw()->json('result') as $item) {
+                if ($item['symbol'] === strtoupper(trim($symbol))) {
+                    $symbol = $item['id'];
+
+                    $this->getLogger()->debug('Found symbol id: '.$symbol);
+                    break;
+                }
+            }
+
+            if (! is_numeric($symbol)) {
+                $this->getLogger()->debug('Invalid symbol name. Given: '.$symbol);
+
+                throw new \InvalidArgumentException('Invalid symbol name. Given: '.$symbol);
+            }
+        }
+
         $this->websocket->addListener('orderbook/'.$symbol, $listeners);
 
         return $this;

src/WebSocket/Endpoints/MarketEndpoint.php

@@ -22,6 +22,8 @@ public function listen($streamName, $listeners)
             $streamNames = $streamName;
         }
 
+        $this->getLogger()->debug('Add event listener for stream: '.implode(', ', $streamNames));
+
         foreach ($streamNames as $name) {
             $this->websocket->addListener($this->getStreamName($name), $listeners);
         }

src/WebSocket/Engine.php

@@ -21,6 +21,10 @@ public function handle(array $listeners): void
     {
         $events = array_unique(array_keys($listeners));
 
+        $this->logger->info('[WebSocket] - '.Carbon::now()->format('Y-m-d H:i:s').' - Connecting to WebSocket server...');
+
+        $this->logger->debug('[WebSocket] - '.Carbon::now()->format('Y-m-d H:i:s').' - Events: '.implode(', ', $events));
+
         $client = new WebSocketClient('wss://api.bitkub.com/websocket-api/'.implode(',', $events));
 
         $client
@@ -56,6 +60,10 @@ public function handle(array $listeners): void
             }
         });
 
+        $client->onClose(function () {
+            $this->logger->info('[WebSocket] - '.Carbon::now()->format('Y-m-d H:i:s').' - Connection closed.');
+        });
+
         $client->start();
     }
 }

src/WebSocketClient.php

@@ -32,6 +32,11 @@ public function getLogger(): LoggerInterface
         return $this->client->getLogger();
     }
 
+    public function getClient(): ClientInterface
+    {
+        return $this->client;
+    }
+
     /**
      * Add event listener.
      *

tests/UriFactoryTest.php

@@ -0,0 +1,11 @@
+<?php
+
+use Farzai\Bitkub\UriFactory;
+
+it('can create uri', function () {
+    $uri = UriFactory::createFromUri('https://api.bitkub.com');
+
+    expect($uri->getScheme())->toBe('https');
+    expect($uri->getHost())->toBe('api.bitkub.com');
+    expect($uri->getPath())->toBe('');
+});

tests/UserEndpointTest.php

@@ -73,7 +73,7 @@
         ->setHttpClient($psrClient)
         ->build();
 
-    $response = $client->user()->userLimits()->throw();
+    $response = $client->user()->limits()->throw();
 
     expect($response->json('result'))->toBe([
         'limits' => [