async log

Author: hhxsv5

README.md

@@ -38,6 +38,18 @@ composer require "kucoin/kucoin-php-sdk:~1.1.0"
 KuCoinApi::setBaseUri('https://openapi-sandbox.kucoin.com');
 ```
 
+### Debug mode & logging
+
+```php
+// Debug mode will record the logs of API and WebSocket to files in the directory "KuCoinApi::getDefaultLogPath()" according to the minimum log level "KuCoinApi::getLogLevel()".
+KuCoinApi::setDebugMode(true);
+
+// Logging in your code
+// KuCoinApi::setLogPath('/tmp');
+// KuCoinApi::setLogLevel(Monolog\Logger::DEBUG);
+KuCoinApi::getLogger()->debug('I\'am a debug message');
+```
+
 ### Examples
 > See the [test case](tests) for more examples.
 
@@ -251,6 +263,12 @@ go(function () {
 > Modify your API key in `phpunit.xml` first.
 
 ```shell
+# Add your API configuration items into the environmental variable first
+export API_BASE_URI=https://openapi-v2.kucoin.com
+export API_KEY=key
+export API_SECRET=secret
+export API_PASSPHRASE=passphrase
+
 composer test
 ```
 

src/Api.php

@@ -28,6 +28,21 @@ abstract class Api
      */
     protected static $debugMode = false;
 
+    /**
+     * @var string
+     */
+    protected static $logPath = '/tmp';
+
+    /**
+     * @var LoggerInterface $logger
+     */
+    protected static $logger;
+
+    /**
+     * @var int
+     */
+    protected static $logLevel = Logger::DEBUG;
+
     /**
      * @var IAuth $auth
      */
@@ -38,11 +53,6 @@ abstract class Api
      */
     protected $http;
 
-    /**
-     * @var LoggerInterface $logger
-     */
-    protected $logger;
-
     public function __construct(IAuth $auth = null, IHttp $http = null)
     {
         if ($http === null) {
@@ -103,25 +113,57 @@ public static function setDebugMode($debugMode)
     /**
      * @param LoggerInterface $logger
      */
-    public function setLogger(LoggerInterface $logger)
+    public static function setLogger(LoggerInterface $logger)
     {
-        $this->logger = $logger;
+        self::$logger = $logger;
     }
 
     /**
      * @return Logger|LoggerInterface
      * @throws \Exception
      */
-    public function getLogger()
+    public static function getLogger()
     {
-        if ($this->logger === null) {
-            $this->logger = new Logger('kucoin-sdk');
-            $handler = new RotatingFileHandler('/tmp/kucoin-sdk.log', 0, Logger::DEBUG);
+        if (self::$logger === null) {
+            self::$logger = new Logger('kucoin-sdk');
+            $handler = new RotatingFileHandler(static::getLogPath() . '/kucoin-sdk.log', 0, static::$logLevel);
             $formatter = new LineFormatter(null, null, false, true);
             $handler->setFormatter($formatter);
-            $this->logger->pushHandler($handler);
+            self::$logger->pushHandler($handler);
         }
-        return $this->logger;
+        return self::$logger;
+    }
+
+    /**
+     * @return string
+     */
+    public static function getLogPath()
+    {
+        return self::$logPath;
+    }
+
+    /**
+     * @param string $logPath
+     */
+    public static function setLogPath($logPath)
+    {
+        self::$logPath = $logPath;
+    }
+
+    /**
+     * @return int
+     */
+    public static function getLogLevel()
+    {
+        return self::$logLevel;
+    }
+
+    /**
+     * @param int $logLevel
+     */
+    public static function setLogLevel($logLevel)
+    {
+        self::$logLevel = $logLevel;
     }
 
     /**
@@ -155,11 +197,11 @@ public function call($method, $uri, array $params = [], array $headers = [], $ti
         $requestId = uniqid();
 
         if (self::isDebugMode()) {
-            $this->getLogger()->debug(sprintf('Sent a HTTP request#%s: %s', $requestId, $request));
+            static::getLogger()->debug(sprintf('Sent a HTTP request#%s: %s', $requestId, $request));
         }
         $response = $this->http->request($request, $timeout);
         if (self::isDebugMode()) {
-            $this->getLogger()->debug(sprintf('Received a HTTP response#%s: %s', $requestId, $response));
+            static::getLogger()->debug(sprintf('Received a HTTP response#%s: %s', $requestId, $response));
         }
 
         return $response;

src/Http/SwooleHttp.php

@@ -7,11 +7,18 @@
 use Swlib\Http\ContentType;
 use Swlib\Http\Exception\RequestException;
 use Swlib\Saber;
+use Swoole\Runtime;
 
 class SwooleHttp extends BaseHttp
 {
     protected static $clients = [];
 
+    public function __construct(array $config = [])
+    {
+        parent::__construct($config);
+        Runtime::enableCoroutine();
+    }
+
     /**
      * @param array $config
      * @return Saber

src/PrivateApi/WebSocketFeed.php

@@ -117,7 +117,7 @@ public function subscribeChannels(array $server, array $channels, callable $onMe
                     $ping = $this->createPingMessage();
                     $pingStr = json_encode($ping);
                     if (self::isDebugMode()) {
-                        $this->getLogger()->debug(sprintf('Sent a WebSocket message: %s', $pingStr));
+                        static::getLogger()->debug(sprintf('Sent a WebSocket message: %s', $pingStr));
                     }
                     // fputs(STDIN, print_r($ping, true));
                     $ws->send($pingStr);
@@ -128,7 +128,7 @@ public function subscribeChannels(array $server, array $channels, callable $onMe
             $ws->on('message', function (MessageInterface $msg) use ($server, $ws, $channels, $onMessage, $loop, $pingTimer) {
                 $msgStr = $msg->__toString();
                 if (self::isDebugMode()) {
-                    $this->getLogger()->debug(sprintf('Received a WebSocket message: %s', $msgStr));
+                    static::getLogger()->debug(sprintf('Received a WebSocket message: %s', $msgStr));
                 }
                 $msgArray = json_decode($msgStr, true);
                 if (!isset($msgArray['type'])) {