@ex-master/huobi - npm Package Compare versions

Comparing version 0.3.62 to 0.3.63

bld/library/spot/huobi-spot-client.d.ts

@@ -35,3 +35,3 @@ /// <reference types="node" />
     getMarkets(noCache?: boolean): Promise<HuobiSpotMarketData[]>;
-    getKLine(market: Market, startTime: number, endTime?: number, interval?: number): Promise<KLineEntry[]>;
+    getKLine(market: Market, startTime: number, endTime?: number, interval?: number, limit?: number): Promise<KLineEntry[]>;
     getMarketQuotations(): Promise<MarketQuotation[]>;
@@ -38,0 +38,0 @@ getDepth(market: Market, size?: number): Promise<DepthData>;

bld/library/spot/huobi-spot-client.js

@@ -219,3 +219,3 @@ "use strict";
     }
-    getKLine(market, startTime, endTime, interval = ONE_MINUTE_MILLISECONDS) {
+    getKLine(market, startTime, endTime, interval = ONE_MINUTE_MILLISECONDS, limit) {
         return tslib_1.__awaiter(this, void 0, void 0, function* () {
@@ -290,2 +290,5 @@ let now = startOfMinute_1.default(Date.now()).getTime();
                     }
+                    if (limit && limit > 0 && entryMap.size >= limit) {
+                        break;
+                    }
                     let last = klineEntries[klineEntries.length - 1];
@@ -307,3 +310,9 @@ let lastTime = startOfMinute_1.default(last.id * 1000).getTime();
             }
-            return Array.from(entryMap.values());
+            const result = Array.from(entryMap.values());
+            if (limit && limit > 0) {
+                return result.slice(0, limit);
+            }
+            else {
+                return result;
+            }
         });
@@ -310,0 +319,0 @@ }

package.json

 {
   "name": "@ex-master/huobi",
-  "version": "0.3.62",
+  "version": "0.3.63",
   "main": "bld/library/index.js",
@@ -30,3 +30,3 @@ "types": "bld/library/index.d.ts",
   },
-  "gitHead": "571c95ebe11912c480ef19b46a1aa590b9cd6647"
+  "gitHead": "18d0ab10916e32ebb3396526528226fc23543519"
 }

src/library/spot/huobi-spot-client.ts

@@ -181,2 +181,3 @@ import {Agent} from 'http';
     interval: number = ONE_MINUTE_MILLISECONDS,
+    limit?: number,
   ): Promise<KLineEntry[]> {
@@ -264,2 +265,6 @@ let now = startOfMinute(Date.now()).getTime();
 
+        if (limit && limit > 0 && entryMap.size >= limit) {
+          break;
+        }
+
         let last = klineEntries[klineEntries.length - 1];
@@ -286,3 +291,9 @@ let lastTime = startOfMinute(last.id * 1000).getTime();
 
-    return Array.from(entryMap.values());
+    const result = Array.from(entryMap.values());
+
+    if (limit && limit > 0) {
+      return result.slice(0, limit);
+    } else {
+      return result;
+    }
   }
@@ -289,0 +300,0 @@

No alert changes

Improved metrics

Total package byte prevSize

272688

increased by0.29%

Lines of code

5383

increased by0.34%

No dependency changes