tardis-dev - npm Package Compare versions

Comparing version 13.30.0 to 13.31.0

dist/consts.d.ts

@@ -1,2 +0,2 @@
-export declare const EXCHANGES: readonly ["bitmex", "deribit", "binance-futures", "binance-delivery", "binance-options", "binance-european-options", "binance", "ftx", "okex-futures", "okex-options", "okex-swap", "okex", "okex-spreads", "huobi-dm", "huobi-dm-swap", "huobi-dm-linear-swap", "huobi", "bitfinex-derivatives", "bitfinex", "coinbase", "cryptofacilities", "kraken", "bitstamp", "gemini", "poloniex", "bybit", "bybit-spot", "bybit-options", "phemex", "delta", "ftx-us", "binance-us", "gate-io-futures", "gate-io", "okcoin", "bitflyer", "hitbtc", "coinflex", "binance-jersey", "binance-dex", "upbit", "ascendex", "dydx", "dydx-v4", "serum", "mango", "huobi-dm-options", "star-atlas", "crypto-com", "crypto-com-derivatives", "kucoin", "kucoin-futures", "bitnomial", "woo-x", "blockchain-com"];
+export declare const EXCHANGES: readonly ["bitmex", "deribit", "binance-futures", "binance-delivery", "binance-options", "binance-european-options", "binance", "ftx", "okex-futures", "okex-options", "okex-swap", "okex", "okex-spreads", "huobi-dm", "huobi-dm-swap", "huobi-dm-linear-swap", "huobi", "bitfinex-derivatives", "bitfinex", "coinbase", "cryptofacilities", "kraken", "bitstamp", "gemini", "poloniex", "bybit", "bybit-spot", "bybit-options", "phemex", "delta", "ftx-us", "binance-us", "gate-io-futures", "gate-io", "okcoin", "bitflyer", "hitbtc", "coinflex", "binance-jersey", "binance-dex", "upbit", "ascendex", "dydx", "dydx-v4", "serum", "mango", "huobi-dm-options", "star-atlas", "crypto-com", "crypto-com-derivatives", "kucoin", "kucoin-futures", "bitnomial", "woo-x", "blockchain-com", "bitget", "bitget-futures"];
 export declare const EXCHANGE_CHANNELS_INFO: {
@@ -58,3 +58,5 @@ bitmex: readonly ["trade", "orderBookL2", "liquidation", "connected", "announcement", "chat", "publicNotifications", "instrument", "settlement", "funding", "insurance", "orderBookL2_25", "orderBook10", "quote", "quoteBin1m", "quoteBin5m", "quoteBin1h", "quoteBin1d", "tradeBin1m", "tradeBin5m", "tradeBin1h", "tradeBin1d"];
     'kucoin-futures': string[];
+    bitget: string[];
+    'bitget-futures': string[];
 };
 //# sourceMappingURL=consts.d.ts.map

dist/consts.js

@@ -59,3 +59,5 @@ "use strict";
     'woo-x',
-    'blockchain-com'
+    'blockchain-com',
+    'bitget',
+    'bitget-futures'
 ];
@@ -432,2 +434,4 @@ const BINANCE_CHANNELS = ['trade', 'aggTrade', 'ticker', 'depth', 'depthSnapshot', 'bookTicker', 'recentTrades', 'borrowInterest'];
 ];
+const BITGET_CHANNELS = ['trade', 'books1', 'books'];
+const BITGET_FUTURES_CHANNELS = ['trade', 'books1', 'books', 'ticker'];
 exports.EXCHANGE_CHANNELS_INFO = {
@@ -488,4 +492,6 @@ bitmex: BITMEX_CHANNELS,
     'okex-spreads': OKEX_SPREADS_CHANNELS,
-    'kucoin-futures': KUCOIN_FUTURES_CHANNELS
+    'kucoin-futures': KUCOIN_FUTURES_CHANNELS,
+    bitget: BITGET_CHANNELS,
+    'bitget-futures': BITGET_FUTURES_CHANNELS
 };
 //# sourceMappingURL=consts.js.map

dist/handy.d.ts

@@ -28,2 +28,3 @@ /// <reference types="node" />
 export declare function batch(symbols: string[], batchSize: number): Generator<string[], void, unknown>;
+export declare function batchObjects<T>(payload: T[], batchSize: number): Generator<T[], void, unknown>;
 export declare function parseμs(dateString: string): number;
@@ -30,0 +31,0 @@ export declare function optimizeFilters(filters: Filter<any>[]): Filter<any>[];

dist/handy.js

@@ -29,3 +29,3 @@ "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-exports.fromMicroSecondsToDate = exports.httpClient = exports.lowerCaseSymbols = exports.upperCaseSymbols = exports.asNumberIfValid = exports.decimalPlaces = exports.CappedSet = exports.CircularBuffer = exports.cleanTempFiles = exports.download = exports.httpsProxyAgent = exports.optimizeFilters = exports.parseμs = exports.batch = exports.getFilters = exports.normalizeMessages = exports.take = exports.HttpError = exports.ONE_SEC_IN_MS = exports.sequence = exports.addDays = exports.addMinutes = exports.sha256 = exports.doubleDigit = exports.formatDateToPath = exports.getRandomString = exports.wait = exports.parseAsUTCDate = void 0;
+exports.fromMicroSecondsToDate = exports.httpClient = exports.lowerCaseSymbols = exports.upperCaseSymbols = exports.asNumberIfValid = exports.decimalPlaces = exports.CappedSet = exports.CircularBuffer = exports.cleanTempFiles = exports.download = exports.httpsProxyAgent = exports.optimizeFilters = exports.parseμs = exports.batchObjects = exports.batch = exports.getFilters = exports.normalizeMessages = exports.take = exports.HttpError = exports.ONE_SEC_IN_MS = exports.sequence = exports.addDays = exports.addMinutes = exports.sha256 = exports.doubleDigit = exports.formatDateToPath = exports.getRandomString = exports.wait = exports.parseAsUTCDate = void 0;
 const crypto_1 = __importStar(require("crypto"));
@@ -191,2 +191,8 @@ const fs_extra_1 = require("fs-extra");
 exports.batch = batch;
+function* batchObjects(payload, batchSize) {
+    for (let i = 0; i < payload.length; i += batchSize) {
+        yield payload.slice(i, i + batchSize);
+    }
+}
+exports.batchObjects = batchObjects;
 function parseμs(dateString) {
@@ -193,0 +199,0 @@ // check if we have ISO 8601 format date string, e.g: 2019-06-01T00:03:03.1238784Z or 2020-07-22T00:09:16.836773Z

dist/mappers/bybit.d.ts

@@ -25,3 +25,3 @@ import { BookChange, BookTicker, DerivativeTicker, Exchange, Liquidation, OptionSummary, Trade } from '../types';
         readonly symbol: string;
-        readonly exchange: "bitmex" | "deribit" | "binance-futures" | "binance-delivery" | "binance-options" | "binance-european-options" | "binance" | "ftx" | "okex-futures" | "okex-options" | "okex-swap" | "okex" | "okex-spreads" | "huobi-dm" | "huobi-dm-swap" | "huobi-dm-linear-swap" | "huobi" | "bitfinex-derivatives" | "bitfinex" | "coinbase" | "cryptofacilities" | "kraken" | "bitstamp" | "gemini" | "poloniex" | "bybit" | "bybit-spot" | "bybit-options" | "phemex" | "delta" | "ftx-us" | "binance-us" | "gate-io-futures" | "gate-io" | "okcoin" | "bitflyer" | "hitbtc" | "coinflex" | "binance-jersey" | "binance-dex" | "upbit" | "ascendex" | "dydx" | "dydx-v4" | "serum" | "mango" | "huobi-dm-options" | "star-atlas" | "crypto-com" | "crypto-com-derivatives" | "kucoin" | "kucoin-futures" | "bitnomial" | "woo-x" | "blockchain-com";
+        readonly exchange: "bitmex" | "deribit" | "binance-futures" | "binance-delivery" | "binance-options" | "binance-european-options" | "binance" | "ftx" | "okex-futures" | "okex-options" | "okex-swap" | "okex" | "okex-spreads" | "huobi-dm" | "huobi-dm-swap" | "huobi-dm-linear-swap" | "huobi" | "bitfinex-derivatives" | "bitfinex" | "coinbase" | "cryptofacilities" | "kraken" | "bitstamp" | "gemini" | "poloniex" | "bybit" | "bybit-spot" | "bybit-options" | "phemex" | "delta" | "ftx-us" | "binance-us" | "gate-io-futures" | "gate-io" | "okcoin" | "bitflyer" | "hitbtc" | "coinflex" | "binance-jersey" | "binance-dex" | "upbit" | "ascendex" | "dydx" | "dydx-v4" | "serum" | "mango" | "huobi-dm-options" | "star-atlas" | "crypto-com" | "crypto-com-derivatives" | "kucoin" | "kucoin-futures" | "bitnomial" | "woo-x" | "blockchain-com" | "bitget" | "bitget-futures";
         readonly isSnapshot: boolean;
@@ -104,3 +104,3 @@ readonly bids: {
         readonly symbol: string;
-        readonly exchange: "bitmex" | "deribit" | "binance-futures" | "binance-delivery" | "binance-options" | "binance-european-options" | "binance" | "ftx" | "okex-futures" | "okex-options" | "okex-swap" | "okex" | "okex-spreads" | "huobi-dm" | "huobi-dm-swap" | "huobi-dm-linear-swap" | "huobi" | "bitfinex-derivatives" | "bitfinex" | "coinbase" | "cryptofacilities" | "kraken" | "bitstamp" | "gemini" | "poloniex" | "bybit" | "bybit-spot" | "bybit-options" | "phemex" | "delta" | "ftx-us" | "binance-us" | "gate-io-futures" | "gate-io" | "okcoin" | "bitflyer" | "hitbtc" | "coinflex" | "binance-jersey" | "binance-dex" | "upbit" | "ascendex" | "dydx" | "dydx-v4" | "serum" | "mango" | "huobi-dm-options" | "star-atlas" | "crypto-com" | "crypto-com-derivatives" | "kucoin" | "kucoin-futures" | "bitnomial" | "woo-x" | "blockchain-com";
+        readonly exchange: "bitmex" | "deribit" | "binance-futures" | "binance-delivery" | "binance-options" | "binance-european-options" | "binance" | "ftx" | "okex-futures" | "okex-options" | "okex-swap" | "okex" | "okex-spreads" | "huobi-dm" | "huobi-dm-swap" | "huobi-dm-linear-swap" | "huobi" | "bitfinex-derivatives" | "bitfinex" | "coinbase" | "cryptofacilities" | "kraken" | "bitstamp" | "gemini" | "poloniex" | "bybit" | "bybit-spot" | "bybit-options" | "phemex" | "delta" | "ftx-us" | "binance-us" | "gate-io-futures" | "gate-io" | "okcoin" | "bitflyer" | "hitbtc" | "coinflex" | "binance-jersey" | "binance-dex" | "upbit" | "ascendex" | "dydx" | "dydx-v4" | "serum" | "mango" | "huobi-dm-options" | "star-atlas" | "crypto-com" | "crypto-com-derivatives" | "kucoin" | "kucoin-futures" | "bitnomial" | "woo-x" | "blockchain-com" | "bitget" | "bitget-futures";
         readonly isSnapshot: boolean;
@@ -107,0 +107,0 @@ readonly bids: {

dist/mappers/bybitspot.d.ts

@@ -24,3 +24,3 @@ import { BookChange, Exchange, BookTicker, Trade } from '../types';
         readonly symbol: "RENUSDT";
-        readonly exchange: "bitmex" | "deribit" | "binance-futures" | "binance-delivery" | "binance-options" | "binance-european-options" | "binance" | "ftx" | "okex-futures" | "okex-options" | "okex-swap" | "okex" | "okex-spreads" | "huobi-dm" | "huobi-dm-swap" | "huobi-dm-linear-swap" | "huobi" | "bitfinex-derivatives" | "bitfinex" | "coinbase" | "cryptofacilities" | "kraken" | "bitstamp" | "gemini" | "poloniex" | "bybit" | "bybit-spot" | "bybit-options" | "phemex" | "delta" | "ftx-us" | "binance-us" | "gate-io-futures" | "gate-io" | "okcoin" | "bitflyer" | "hitbtc" | "coinflex" | "binance-jersey" | "binance-dex" | "upbit" | "ascendex" | "dydx" | "dydx-v4" | "serum" | "mango" | "huobi-dm-options" | "star-atlas" | "crypto-com" | "crypto-com-derivatives" | "kucoin" | "kucoin-futures" | "bitnomial" | "woo-x" | "blockchain-com";
+        readonly exchange: "bitmex" | "deribit" | "binance-futures" | "binance-delivery" | "binance-options" | "binance-european-options" | "binance" | "ftx" | "okex-futures" | "okex-options" | "okex-swap" | "okex" | "okex-spreads" | "huobi-dm" | "huobi-dm-swap" | "huobi-dm-linear-swap" | "huobi" | "bitfinex-derivatives" | "bitfinex" | "coinbase" | "cryptofacilities" | "kraken" | "bitstamp" | "gemini" | "poloniex" | "bybit" | "bybit-spot" | "bybit-options" | "phemex" | "delta" | "ftx-us" | "binance-us" | "gate-io-futures" | "gate-io" | "okcoin" | "bitflyer" | "hitbtc" | "coinflex" | "binance-jersey" | "binance-dex" | "upbit" | "ascendex" | "dydx" | "dydx-v4" | "serum" | "mango" | "huobi-dm-options" | "star-atlas" | "crypto-com" | "crypto-com-derivatives" | "kucoin" | "kucoin-futures" | "bitnomial" | "woo-x" | "blockchain-com" | "bitget" | "bitget-futures";
         readonly isSnapshot: true;
@@ -27,0 +27,0 @@ readonly bids: {

dist/mappers/cryptocom.d.ts

@@ -24,3 +24,3 @@ import { BookChange, Exchange, BookTicker, Trade, DerivativeTicker } from '../types';
         readonly symbol: "ETH_CRO" | "BTCUSD-PERP" | "DOT_USDT";
-        readonly exchange: "bitmex" | "deribit" | "binance-futures" | "binance-delivery" | "binance-options" | "binance-european-options" | "binance" | "ftx" | "okex-futures" | "okex-options" | "okex-swap" | "okex" | "okex-spreads" | "huobi-dm" | "huobi-dm-swap" | "huobi-dm-linear-swap" | "huobi" | "bitfinex-derivatives" | "bitfinex" | "coinbase" | "cryptofacilities" | "kraken" | "bitstamp" | "gemini" | "poloniex" | "bybit" | "bybit-spot" | "bybit-options" | "phemex" | "delta" | "ftx-us" | "binance-us" | "gate-io-futures" | "gate-io" | "okcoin" | "bitflyer" | "hitbtc" | "coinflex" | "binance-jersey" | "binance-dex" | "upbit" | "ascendex" | "dydx" | "dydx-v4" | "serum" | "mango" | "huobi-dm-options" | "star-atlas" | "crypto-com" | "crypto-com-derivatives" | "kucoin" | "kucoin-futures" | "bitnomial" | "woo-x" | "blockchain-com";
+        readonly exchange: "bitmex" | "deribit" | "binance-futures" | "binance-delivery" | "binance-options" | "binance-european-options" | "binance" | "ftx" | "okex-futures" | "okex-options" | "okex-swap" | "okex" | "okex-spreads" | "huobi-dm" | "huobi-dm-swap" | "huobi-dm-linear-swap" | "huobi" | "bitfinex-derivatives" | "bitfinex" | "coinbase" | "cryptofacilities" | "kraken" | "bitstamp" | "gemini" | "poloniex" | "bybit" | "bybit-spot" | "bybit-options" | "phemex" | "delta" | "ftx-us" | "binance-us" | "gate-io-futures" | "gate-io" | "okcoin" | "bitflyer" | "hitbtc" | "coinflex" | "binance-jersey" | "binance-dex" | "upbit" | "ascendex" | "dydx" | "dydx-v4" | "serum" | "mango" | "huobi-dm-options" | "star-atlas" | "crypto-com" | "crypto-com-derivatives" | "kucoin" | "kucoin-futures" | "bitnomial" | "woo-x" | "blockchain-com" | "bitget" | "bitget-futures";
         readonly isSnapshot: boolean;
@@ -27,0 +27,0 @@ readonly bids: {

dist/mappers/huobi.d.ts

@@ -25,3 +25,3 @@ import { CircularBuffer } from '../handy';
         readonly symbol: string;
-        readonly exchange: "bitmex" | "deribit" | "binance-futures" | "binance-delivery" | "binance-options" | "binance-european-options" | "binance" | "ftx" | "okex-futures" | "okex-options" | "okex-swap" | "okex" | "okex-spreads" | "huobi-dm" | "huobi-dm-swap" | "huobi-dm-linear-swap" | "huobi" | "bitfinex-derivatives" | "bitfinex" | "coinbase" | "cryptofacilities" | "kraken" | "bitstamp" | "gemini" | "poloniex" | "bybit" | "bybit-spot" | "bybit-options" | "phemex" | "delta" | "ftx-us" | "binance-us" | "gate-io-futures" | "gate-io" | "okcoin" | "bitflyer" | "hitbtc" | "coinflex" | "binance-jersey" | "binance-dex" | "upbit" | "ascendex" | "dydx" | "dydx-v4" | "serum" | "mango" | "huobi-dm-options" | "star-atlas" | "crypto-com" | "crypto-com-derivatives" | "kucoin" | "kucoin-futures" | "bitnomial" | "woo-x" | "blockchain-com";
+        readonly exchange: "bitmex" | "deribit" | "binance-futures" | "binance-delivery" | "binance-options" | "binance-european-options" | "binance" | "ftx" | "okex-futures" | "okex-options" | "okex-swap" | "okex" | "okex-spreads" | "huobi-dm" | "huobi-dm-swap" | "huobi-dm-linear-swap" | "huobi" | "bitfinex-derivatives" | "bitfinex" | "coinbase" | "cryptofacilities" | "kraken" | "bitstamp" | "gemini" | "poloniex" | "bybit" | "bybit-spot" | "bybit-options" | "phemex" | "delta" | "ftx-us" | "binance-us" | "gate-io-futures" | "gate-io" | "okcoin" | "bitflyer" | "hitbtc" | "coinflex" | "binance-jersey" | "binance-dex" | "upbit" | "ascendex" | "dydx" | "dydx-v4" | "serum" | "mango" | "huobi-dm-options" | "star-atlas" | "crypto-com" | "crypto-com-derivatives" | "kucoin" | "kucoin-futures" | "bitnomial" | "woo-x" | "blockchain-com" | "bitget" | "bitget-futures";
         readonly isSnapshot: boolean;
@@ -55,3 +55,3 @@ readonly bids: {
         readonly symbol: string;
-        readonly exchange: "bitmex" | "deribit" | "binance-futures" | "binance-delivery" | "binance-options" | "binance-european-options" | "binance" | "ftx" | "okex-futures" | "okex-options" | "okex-swap" | "okex" | "okex-spreads" | "huobi-dm" | "huobi-dm-swap" | "huobi-dm-linear-swap" | "huobi" | "bitfinex-derivatives" | "bitfinex" | "coinbase" | "cryptofacilities" | "kraken" | "bitstamp" | "gemini" | "poloniex" | "bybit" | "bybit-spot" | "bybit-options" | "phemex" | "delta" | "ftx-us" | "binance-us" | "gate-io-futures" | "gate-io" | "okcoin" | "bitflyer" | "hitbtc" | "coinflex" | "binance-jersey" | "binance-dex" | "upbit" | "ascendex" | "dydx" | "dydx-v4" | "serum" | "mango" | "huobi-dm-options" | "star-atlas" | "crypto-com" | "crypto-com-derivatives" | "kucoin" | "kucoin-futures" | "bitnomial" | "woo-x" | "blockchain-com";
+        readonly exchange: "bitmex" | "deribit" | "binance-futures" | "binance-delivery" | "binance-options" | "binance-european-options" | "binance" | "ftx" | "okex-futures" | "okex-options" | "okex-swap" | "okex" | "okex-spreads" | "huobi-dm" | "huobi-dm-swap" | "huobi-dm-linear-swap" | "huobi" | "bitfinex-derivatives" | "bitfinex" | "coinbase" | "cryptofacilities" | "kraken" | "bitstamp" | "gemini" | "poloniex" | "bybit" | "bybit-spot" | "bybit-options" | "phemex" | "delta" | "ftx-us" | "binance-us" | "gate-io-futures" | "gate-io" | "okcoin" | "bitflyer" | "hitbtc" | "coinflex" | "binance-jersey" | "binance-dex" | "upbit" | "ascendex" | "dydx" | "dydx-v4" | "serum" | "mango" | "huobi-dm-options" | "star-atlas" | "crypto-com" | "crypto-com-derivatives" | "kucoin" | "kucoin-futures" | "bitnomial" | "woo-x" | "blockchain-com" | "bitget" | "bitget-futures";
         readonly isSnapshot: false;
@@ -71,3 +71,3 @@ readonly bids: {
         readonly symbol: string;
-        readonly exchange: "bitmex" | "deribit" | "binance-futures" | "binance-delivery" | "binance-options" | "binance-european-options" | "binance" | "ftx" | "okex-futures" | "okex-options" | "okex-swap" | "okex" | "okex-spreads" | "huobi-dm" | "huobi-dm-swap" | "huobi-dm-linear-swap" | "huobi" | "bitfinex-derivatives" | "bitfinex" | "coinbase" | "cryptofacilities" | "kraken" | "bitstamp" | "gemini" | "poloniex" | "bybit" | "bybit-spot" | "bybit-options" | "phemex" | "delta" | "ftx-us" | "binance-us" | "gate-io-futures" | "gate-io" | "okcoin" | "bitflyer" | "hitbtc" | "coinflex" | "binance-jersey" | "binance-dex" | "upbit" | "ascendex" | "dydx" | "dydx-v4" | "serum" | "mango" | "huobi-dm-options" | "star-atlas" | "crypto-com" | "crypto-com-derivatives" | "kucoin" | "kucoin-futures" | "bitnomial" | "woo-x" | "blockchain-com";
+        readonly exchange: "bitmex" | "deribit" | "binance-futures" | "binance-delivery" | "binance-options" | "binance-european-options" | "binance" | "ftx" | "okex-futures" | "okex-options" | "okex-swap" | "okex" | "okex-spreads" | "huobi-dm" | "huobi-dm-swap" | "huobi-dm-linear-swap" | "huobi" | "bitfinex-derivatives" | "bitfinex" | "coinbase" | "cryptofacilities" | "kraken" | "bitstamp" | "gemini" | "poloniex" | "bybit" | "bybit-spot" | "bybit-options" | "phemex" | "delta" | "ftx-us" | "binance-us" | "gate-io-futures" | "gate-io" | "okcoin" | "bitflyer" | "hitbtc" | "coinflex" | "binance-jersey" | "binance-dex" | "upbit" | "ascendex" | "dydx" | "dydx-v4" | "serum" | "mango" | "huobi-dm-options" | "star-atlas" | "crypto-com" | "crypto-com-derivatives" | "kucoin" | "kucoin-futures" | "bitnomial" | "woo-x" | "blockchain-com" | "bitget" | "bitget-futures";
         readonly isSnapshot: true;
@@ -74,0 +74,0 @@ readonly bids: {

dist/mappers/index.d.ts

 import { BookChange, DerivativeTicker, Liquidation, OptionSummary, BookTicker, Trade } from '../types';
 import { Mapper } from './mapper';
 export * from './mapper';
-export declare const normalizeTrades: <T extends "bitmex" | "deribit" | "binance-futures" | "binance-delivery" | "binance-options" | "binance-european-options" | "binance" | "ftx" | "okex-futures" | "okex-options" | "okex-swap" | "okex" | "okex-spreads" | "huobi-dm" | "huobi-dm-swap" | "huobi-dm-linear-swap" | "huobi" | "bitfinex-derivatives" | "bitfinex" | "coinbase" | "cryptofacilities" | "kraken" | "bitstamp" | "gemini" | "poloniex" | "bybit" | "bybit-spot" | "bybit-options" | "phemex" | "delta" | "ftx-us" | "binance-us" | "gate-io-futures" | "gate-io" | "okcoin" | "bitflyer" | "hitbtc" | "coinflex" | "binance-jersey" | "binance-dex" | "upbit" | "ascendex" | "dydx" | "dydx-v4" | "serum" | "mango" | "huobi-dm-options" | "star-atlas" | "crypto-com" | "crypto-com-derivatives" | "kucoin" | "kucoin-futures" | "bitnomial" | "woo-x" | "blockchain-com">(exchange: T, localTimestamp: Date) => Mapper<T, Trade>;
-export declare const normalizeBookChanges: <T extends "bitmex" | "deribit" | "binance-futures" | "binance-delivery" | "binance-options" | "binance-european-options" | "binance" | "ftx" | "okex-futures" | "okex-options" | "okex-swap" | "okex" | "okex-spreads" | "huobi-dm" | "huobi-dm-swap" | "huobi-dm-linear-swap" | "huobi" | "bitfinex-derivatives" | "bitfinex" | "coinbase" | "cryptofacilities" | "kraken" | "bitstamp" | "gemini" | "poloniex" | "bybit" | "bybit-spot" | "bybit-options" | "phemex" | "delta" | "ftx-us" | "binance-us" | "gate-io-futures" | "gate-io" | "okcoin" | "bitflyer" | "hitbtc" | "coinflex" | "binance-jersey" | "binance-dex" | "upbit" | "ascendex" | "dydx" | "dydx-v4" | "serum" | "mango" | "huobi-dm-options" | "star-atlas" | "crypto-com" | "crypto-com-derivatives" | "kucoin" | "kucoin-futures" | "bitnomial" | "woo-x" | "blockchain-com">(exchange: T, localTimestamp: Date) => Mapper<T, BookChange>;
-export declare const normalizeDerivativeTickers: <T extends "bitmex" | "deribit" | "binance-futures" | "binance-delivery" | "ftx" | "okex-futures" | "okex-swap" | "huobi-dm" | "huobi-dm-swap" | "huobi-dm-linear-swap" | "bitfinex-derivatives" | "cryptofacilities" | "bybit" | "phemex" | "delta" | "gate-io-futures" | "coinflex" | "ascendex" | "dydx" | "dydx-v4" | "crypto-com" | "crypto-com-derivatives" | "kucoin-futures" | "woo-x">(exchange: T, localTimestamp: Date) => Mapper<T, DerivativeTicker>;
+export declare const normalizeTrades: <T extends "bitmex" | "deribit" | "binance-futures" | "binance-delivery" | "binance-options" | "binance-european-options" | "binance" | "ftx" | "okex-futures" | "okex-options" | "okex-swap" | "okex" | "okex-spreads" | "huobi-dm" | "huobi-dm-swap" | "huobi-dm-linear-swap" | "huobi" | "bitfinex-derivatives" | "bitfinex" | "coinbase" | "cryptofacilities" | "kraken" | "bitstamp" | "gemini" | "poloniex" | "bybit" | "bybit-spot" | "bybit-options" | "phemex" | "delta" | "ftx-us" | "binance-us" | "gate-io-futures" | "gate-io" | "okcoin" | "bitflyer" | "hitbtc" | "coinflex" | "binance-jersey" | "binance-dex" | "upbit" | "ascendex" | "dydx" | "dydx-v4" | "serum" | "mango" | "huobi-dm-options" | "star-atlas" | "crypto-com" | "crypto-com-derivatives" | "kucoin" | "kucoin-futures" | "bitnomial" | "woo-x" | "blockchain-com" | "bitget" | "bitget-futures">(exchange: T, localTimestamp: Date) => Mapper<T, Trade>;
+export declare const normalizeBookChanges: <T extends "bitmex" | "deribit" | "binance-futures" | "binance-delivery" | "binance-options" | "binance-european-options" | "binance" | "ftx" | "okex-futures" | "okex-options" | "okex-swap" | "okex" | "okex-spreads" | "huobi-dm" | "huobi-dm-swap" | "huobi-dm-linear-swap" | "huobi" | "bitfinex-derivatives" | "bitfinex" | "coinbase" | "cryptofacilities" | "kraken" | "bitstamp" | "gemini" | "poloniex" | "bybit" | "bybit-spot" | "bybit-options" | "phemex" | "delta" | "ftx-us" | "binance-us" | "gate-io-futures" | "gate-io" | "okcoin" | "bitflyer" | "hitbtc" | "coinflex" | "binance-jersey" | "binance-dex" | "upbit" | "ascendex" | "dydx" | "dydx-v4" | "serum" | "mango" | "huobi-dm-options" | "star-atlas" | "crypto-com" | "crypto-com-derivatives" | "kucoin" | "kucoin-futures" | "bitnomial" | "woo-x" | "blockchain-com" | "bitget" | "bitget-futures">(exchange: T, localTimestamp: Date) => Mapper<T, BookChange>;
+export declare const normalizeDerivativeTickers: <T extends "bitmex" | "deribit" | "binance-futures" | "binance-delivery" | "ftx" | "okex-futures" | "okex-swap" | "huobi-dm" | "huobi-dm-swap" | "huobi-dm-linear-swap" | "bitfinex-derivatives" | "cryptofacilities" | "bybit" | "phemex" | "delta" | "gate-io-futures" | "coinflex" | "ascendex" | "dydx" | "dydx-v4" | "crypto-com" | "crypto-com-derivatives" | "kucoin-futures" | "woo-x" | "bitget-futures">(exchange: T, localTimestamp: Date) => Mapper<T, DerivativeTicker>;
 export declare const normalizeOptionsSummary: <T extends "deribit" | "binance-options" | "binance-european-options" | "okex-options" | "bybit-options" | "huobi-dm-options">(exchange: T, localTimestamp: Date) => Mapper<T, OptionSummary>;
 export declare const normalizeLiquidations: <T extends "bitmex" | "deribit" | "binance-futures" | "binance-delivery" | "ftx" | "okex-futures" | "okex-swap" | "huobi-dm" | "huobi-dm-swap" | "huobi-dm-linear-swap" | "bitfinex-derivatives" | "cryptofacilities" | "bybit" | "dydx-v4">(exchange: T, localTimestamp: Date) => Mapper<T, Liquidation>;
-export declare const normalizeBookTickers: <T extends "bitmex" | "deribit" | "binance-futures" | "binance-delivery" | "binance" | "ftx" | "okex-futures" | "okex-options" | "okex-swap" | "okex" | "okex-spreads" | "huobi-dm" | "huobi-dm-swap" | "huobi-dm-linear-swap" | "huobi" | "bitfinex-derivatives" | "bitfinex" | "coinbase" | "cryptofacilities" | "kraken" | "bybit" | "bybit-spot" | "delta" | "ftx-us" | "binance-us" | "gate-io-futures" | "gate-io" | "okcoin" | "bitflyer" | "binance-dex" | "ascendex" | "serum" | "mango" | "star-atlas" | "crypto-com" | "crypto-com-derivatives" | "kucoin" | "kucoin-futures" | "woo-x">(exchange: T, localTimestamp: Date) => Mapper<T, BookTicker>;
+export declare const normalizeBookTickers: <T extends "bitmex" | "deribit" | "binance-futures" | "binance-delivery" | "binance" | "ftx" | "okex-futures" | "okex-options" | "okex-swap" | "okex" | "okex-spreads" | "huobi-dm" | "huobi-dm-swap" | "huobi-dm-linear-swap" | "huobi" | "bitfinex-derivatives" | "bitfinex" | "coinbase" | "cryptofacilities" | "kraken" | "bybit" | "bybit-spot" | "delta" | "ftx-us" | "binance-us" | "gate-io-futures" | "gate-io" | "okcoin" | "bitflyer" | "binance-dex" | "ascendex" | "serum" | "mango" | "star-atlas" | "crypto-com" | "crypto-com-derivatives" | "kucoin" | "kucoin-futures" | "woo-x" | "bitget" | "bitget-futures">(exchange: T, localTimestamp: Date) => Mapper<T, BookTicker>;
 //# sourceMappingURL=index.d.ts.map

dist/mappers/index.js

@@ -26,2 +26,3 @@ "use strict";
 const bitflyer_1 = require("./bitflyer");
+const bitget_1 = require("./bitget");
 const bitmex_1 = require("./bitmex");
@@ -172,3 +173,5 @@ const bitnomial_1 = require("./bitnomial");
     'binance-european-options': () => new binanceeuropeanoptions_1.BinanceEuropeanOptionsTradesMapper(),
-    'okex-spreads': () => new okexspreads_1.OkexSpreadsTradesMapper()
+    'okex-spreads': () => new okexspreads_1.OkexSpreadsTradesMapper(),
+    bitget: () => new bitget_1.BitgetTradesMapper('bitget'),
+    'bitget-futures': () => new bitget_1.BitgetTradesMapper('bitget-futures')
 };
@@ -244,3 +247,5 @@ const bookChangeMappers = {
     'binance-european-options': () => new binanceeuropeanoptions_1.BinanceEuropeanOptionsBookChangeMapper(),
-    'okex-spreads': () => new okexspreads_1.OkexSpreadsBookChangeMapper()
+    'okex-spreads': () => new okexspreads_1.OkexSpreadsBookChangeMapper(),
+    bitget: () => new bitget_1.BitgetBookChangeMapper('bitget'),
+    'bitget-futures': () => new bitget_1.BitgetBookChangeMapper('bitget-futures')
 };
@@ -273,3 +278,4 @@ const derivativeTickersMappers = {
     'woo-x': () => new woox_1.WooxDerivativeTickerMapper(),
-    'kucoin-futures': () => new kucoinfutures_1.KucoinFuturesDerivativeTickerMapper()
+    'kucoin-futures': () => new kucoinfutures_1.KucoinFuturesDerivativeTickerMapper(),
+    'bitget-futures': () => new bitget_1.BitgetDerivativeTickerMapper()
 };
@@ -349,3 +355,5 @@ const optionsSummaryMappers = {
     'okex-spreads': () => new okexspreads_1.OkexSpreadsBookTickerMapper(),
-    'kucoin-futures': () => new kucoinfutures_1.KucoinFuturesBookTickerMapper()
+    'kucoin-futures': () => new kucoinfutures_1.KucoinFuturesBookTickerMapper(),
+    bitget: () => new bitget_1.BitgetBookTickerMapper('bitget'),
+    'bitget-futures': () => new bitget_1.BitgetBookTickerMapper('bitget-futures')
 };
@@ -352,0 +360,0 @@ const normalizeTrades = (exchange, localTimestamp) => {

dist/realtimefeeds/index.js

@@ -56,2 +56,3 @@ "use strict";
 const dydx_v4_1 = require("./dydx_v4");
+const bitget_1 = require("./bitget");
 __exportStar(require("./realtimefeed"), exports);
@@ -113,3 +114,5 @@ const realTimeFeedsMap = {
     'kucoin-futures': kucoinfutures_1.KucoinFuturesRealTimeFeed,
-    'dydx-v4': dydx_v4_1.DydxV4RealTimeFeed
+    'dydx-v4': dydx_v4_1.DydxV4RealTimeFeed,
+    bitget: bitget_1.BitgetRealTimeFeed,
+    'bitget-futures': bitget_1.BitgetFuturesRealTimeFeed
 };
@@ -116,0 +119,0 @@ function getRealTimeFeedFactory(exchange) {

package.json

 {
   "name": "tardis-dev",
-  "version": "13.30.0",
+  "version": "13.31.0",
   "engines": {
@@ -5,0 +5,0 @@ "node": ">=12"

src/consts.ts

@@ -56,3 +56,5 @@ export const EXCHANGES = [
   'woo-x',
-  'blockchain-com'
+  'blockchain-com',
+  'bitget',
+  'bitget-futures'
 ] as const
@@ -476,2 +478,5 @@
 
+const BITGET_CHANNELS = ['trade', 'books1', 'books']
+const BITGET_FUTURES_CHANNELS = ['trade', 'books1', 'books', 'ticker']
+
 export const EXCHANGE_CHANNELS_INFO = {
@@ -532,3 +537,5 @@ bitmex: BITMEX_CHANNELS,
   'okex-spreads': OKEX_SPREADS_CHANNELS,
-  'kucoin-futures': KUCOIN_FUTURES_CHANNELS
+  'kucoin-futures': KUCOIN_FUTURES_CHANNELS,
+  bitget: BITGET_CHANNELS,
+  'bitget-futures': BITGET_FUTURES_CHANNELS
 }

src/handy.ts

@@ -180,2 +180,7 @@ import crypto, { createHash } from 'crypto'
 }
+export function* batchObjects<T>(payload: T[], batchSize: number) {
+  for (let i = 0; i < payload.length; i += batchSize) {
+    yield payload.slice(i, i + batchSize)
+  }
+}
 
@@ -182,0 +187,0 @@ export function parseμs(dateString: string): number {

src/mappers/index.ts

@@ -27,2 +27,3 @@ import { ONE_SEC_IN_MS } from '../handy'
 import { BitflyerBookChangeMapper, bitflyerBookTickerMapper, bitflyerTradesMapper } from './bitflyer'
+import { BitgetBookChangeMapper, BitgetBookTickerMapper, BitgetDerivativeTickerMapper, BitgetTradesMapper } from './bitget'
 import {
@@ -275,3 +276,5 @@ BitmexBookChangeMapper,
   'binance-european-options': () => new BinanceEuropeanOptionsTradesMapper(),
-  'okex-spreads': () => new OkexSpreadsTradesMapper()
+  'okex-spreads': () => new OkexSpreadsTradesMapper(),
+  bitget: () => new BitgetTradesMapper('bitget'),
+  'bitget-futures': () => new BitgetTradesMapper('bitget-futures')
 }
@@ -364,3 +367,5 @@
   'binance-european-options': () => new BinanceEuropeanOptionsBookChangeMapper(),
-  'okex-spreads': () => new OkexSpreadsBookChangeMapper()
+  'okex-spreads': () => new OkexSpreadsBookChangeMapper(),
+  bitget: () => new BitgetBookChangeMapper('bitget'),
+  'bitget-futures': () => new BitgetBookChangeMapper('bitget-futures')
 }
@@ -399,3 +404,4 @@
   'woo-x': () => new WooxDerivativeTickerMapper(),
-  'kucoin-futures': () => new KucoinFuturesDerivativeTickerMapper()
+  'kucoin-futures': () => new KucoinFuturesDerivativeTickerMapper(),
+  'bitget-futures': () => new BitgetDerivativeTickerMapper()
 }
@@ -492,3 +498,5 @@
   'okex-spreads': () => new OkexSpreadsBookTickerMapper(),
-  'kucoin-futures': () => new KucoinFuturesBookTickerMapper()
+  'kucoin-futures': () => new KucoinFuturesBookTickerMapper(),
+  bitget: () => new BitgetBookTickerMapper('bitget'),
+  'bitget-futures': () => new BitgetBookTickerMapper('bitget-futures')
 }
@@ -495,0 +503,0 @@

src/realtimefeeds/index.ts

@@ -53,2 +53,3 @@ import { Exchange, Filter } from '../types'
 import { DydxV4RealTimeFeed } from './dydx_v4'
+import { BitgetFuturesRealTimeFeed, BitgetRealTimeFeed } from './bitget'
 
@@ -114,3 +115,5 @@ export * from './realtimefeed'
   'kucoin-futures': KucoinFuturesRealTimeFeed,
-  'dydx-v4': DydxV4RealTimeFeed
+  'dydx-v4': DydxV4RealTimeFeed,
+  bitget: BitgetRealTimeFeed,
+  'bitget-futures': BitgetFuturesRealTimeFeed
 }
@@ -117,0 +120,0 @@

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

2007867

increased by1.69%

Number of package files

519

increased by1.96%

Lines of code

37205

increased by1.78%

No dependency changes