tardis-dev
Advanced tools
Comparing version 13.10.4 to 13.11.0
@@ -1,2 +0,2 @@ | ||
export declare const EXCHANGES: readonly ["bitmex", "deribit", "binance-futures", "binance-delivery", "binance-options", "binance", "ftx", "okex-futures", "okex-options", "okex-swap", "okex", "huobi-dm", "huobi-dm-swap", "huobi-dm-linear-swap", "huobi", "bitfinex-derivatives", "bitfinex", "coinbase", "cryptofacilities", "kraken", "bitstamp", "gemini", "poloniex", "bybit", "bybit-spot", "phemex", "delta", "ftx-us", "binance-us", "gate-io-futures", "gate-io", "okcoin", "bitflyer", "hitbtc", "coinflex", "binance-jersey", "binance-dex", "upbit", "ascendex", "dydx", "serum", "mango", "huobi-dm-options", "star-atlas", "crypto-com", "crypto-com-derivatives", "kucoin"]; | ||
export declare const EXCHANGES: readonly ["bitmex", "deribit", "binance-futures", "binance-delivery", "binance-options", "binance", "ftx", "okex-futures", "okex-options", "okex-swap", "okex", "huobi-dm", "huobi-dm-swap", "huobi-dm-linear-swap", "huobi", "bitfinex-derivatives", "bitfinex", "coinbase", "cryptofacilities", "kraken", "bitstamp", "gemini", "poloniex", "bybit", "bybit-spot", "phemex", "delta", "ftx-us", "binance-us", "gate-io-futures", "gate-io", "okcoin", "bitflyer", "hitbtc", "coinflex", "binance-jersey", "binance-dex", "upbit", "ascendex", "dydx", "serum", "mango", "huobi-dm-options", "star-atlas", "crypto-com", "crypto-com-derivatives", "kucoin", "bitnomial"]; | ||
export declare const EXCHANGE_CHANNELS_INFO: { | ||
@@ -50,3 +50,4 @@ 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: string[]; | ||
bitnomial: string[]; | ||
}; | ||
//# sourceMappingURL=consts.d.ts.map |
@@ -51,3 +51,4 @@ "use strict"; | ||
'crypto-com-derivatives', | ||
'kucoin' | ||
'kucoin', | ||
'bitnomial' | ||
]; | ||
@@ -349,2 +350,3 @@ const BINANCE_CHANNELS = ['trade', 'aggTrade', 'ticker', 'depth', 'depthSnapshot', 'bookTicker', 'recentTrades', 'borrowInterest']; | ||
const KUCOIN_CHANNELS = ['market/ticker', 'market/snapshot', 'market/level2', 'market/match', 'market/level2Snapshot']; | ||
const BITNOMIAL_CHANNELS = ['trade', 'level', 'book', 'block', 'status']; | ||
exports.EXCHANGE_CHANNELS_INFO = { | ||
@@ -397,4 +399,5 @@ bitmex: BITMEX_CHANNELS, | ||
'crypto-com-derivatives': CRYPTO_COM_DERIVATIVES, | ||
kucoin: KUCOIN_CHANNELS | ||
kucoin: KUCOIN_CHANNELS, | ||
bitnomial: BITNOMIAL_CHANNELS | ||
}; | ||
//# sourceMappingURL=consts.js.map |
@@ -192,3 +192,3 @@ "use strict"; | ||
// or 2020-03-01T00:00:24.893456+00:00 | ||
if (dateString.length === 27 || dateString.length === 28 || dateString.length === 32) { | ||
if (dateString.length === 27 || dateString.length === 28 || dateString.length === 32 || dateString.length === 30) { | ||
return Number(dateString.slice(23, 26)); | ||
@@ -195,0 +195,0 @@ } |
@@ -227,3 +227,3 @@ "use strict"; | ||
asks: binanceDepthUpdateData.a.map(this.mapBookLevel), | ||
timestamp: new Date(binanceDepthUpdateData.T), | ||
timestamp: new Date(binanceDepthUpdateData.E), | ||
localTimestamp: localTimestamp | ||
@@ -230,0 +230,0 @@ }; |
@@ -28,3 +28,3 @@ import { BookChange, DerivativeTicker, Exchange, Liquidation, Trade } from '../types'; | ||
readonly symbol: string; | ||
readonly exchange: "bitmex" | "deribit" | "binance-futures" | "binance-delivery" | "binance-options" | "binance" | "ftx" | "okex-futures" | "okex-options" | "okex-swap" | "okex" | "huobi-dm" | "huobi-dm-swap" | "huobi-dm-linear-swap" | "huobi" | "bitfinex-derivatives" | "bitfinex" | "coinbase" | "cryptofacilities" | "kraken" | "bitstamp" | "gemini" | "poloniex" | "bybit" | "bybit-spot" | "phemex" | "delta" | "ftx-us" | "binance-us" | "gate-io-futures" | "gate-io" | "okcoin" | "bitflyer" | "hitbtc" | "coinflex" | "binance-jersey" | "binance-dex" | "upbit" | "ascendex" | "dydx" | "serum" | "mango" | "huobi-dm-options" | "star-atlas" | "crypto-com" | "crypto-com-derivatives" | "kucoin"; | ||
readonly exchange: "bitmex" | "deribit" | "binance-futures" | "binance-delivery" | "binance-options" | "binance" | "ftx" | "okex-futures" | "okex-options" | "okex-swap" | "okex" | "huobi-dm" | "huobi-dm-swap" | "huobi-dm-linear-swap" | "huobi" | "bitfinex-derivatives" | "bitfinex" | "coinbase" | "cryptofacilities" | "kraken" | "bitstamp" | "gemini" | "poloniex" | "bybit" | "bybit-spot" | "phemex" | "delta" | "ftx-us" | "binance-us" | "gate-io-futures" | "gate-io" | "okcoin" | "bitflyer" | "hitbtc" | "coinflex" | "binance-jersey" | "binance-dex" | "upbit" | "ascendex" | "dydx" | "serum" | "mango" | "huobi-dm-options" | "star-atlas" | "crypto-com" | "crypto-com-derivatives" | "kucoin" | "bitnomial"; | ||
readonly isSnapshot: boolean; | ||
@@ -31,0 +31,0 @@ readonly bids: { |
@@ -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" | "ftx" | "okex-futures" | "okex-options" | "okex-swap" | "okex" | "huobi-dm" | "huobi-dm-swap" | "huobi-dm-linear-swap" | "huobi" | "bitfinex-derivatives" | "bitfinex" | "coinbase" | "cryptofacilities" | "kraken" | "bitstamp" | "gemini" | "poloniex" | "bybit" | "bybit-spot" | "phemex" | "delta" | "ftx-us" | "binance-us" | "gate-io-futures" | "gate-io" | "okcoin" | "bitflyer" | "hitbtc" | "coinflex" | "binance-jersey" | "binance-dex" | "upbit" | "ascendex" | "dydx" | "serum" | "mango" | "huobi-dm-options" | "star-atlas" | "crypto-com" | "crypto-com-derivatives" | "kucoin"; | ||
readonly exchange: "bitmex" | "deribit" | "binance-futures" | "binance-delivery" | "binance-options" | "binance" | "ftx" | "okex-futures" | "okex-options" | "okex-swap" | "okex" | "huobi-dm" | "huobi-dm-swap" | "huobi-dm-linear-swap" | "huobi" | "bitfinex-derivatives" | "bitfinex" | "coinbase" | "cryptofacilities" | "kraken" | "bitstamp" | "gemini" | "poloniex" | "bybit" | "bybit-spot" | "phemex" | "delta" | "ftx-us" | "binance-us" | "gate-io-futures" | "gate-io" | "okcoin" | "bitflyer" | "hitbtc" | "coinflex" | "binance-jersey" | "binance-dex" | "upbit" | "ascendex" | "dydx" | "serum" | "mango" | "huobi-dm-options" | "star-atlas" | "crypto-com" | "crypto-com-derivatives" | "kucoin" | "bitnomial"; | ||
readonly isSnapshot: true; | ||
@@ -27,0 +27,0 @@ readonly bids: { |
@@ -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" | "ftx" | "okex-futures" | "okex-options" | "okex-swap" | "okex" | "huobi-dm" | "huobi-dm-swap" | "huobi-dm-linear-swap" | "huobi" | "bitfinex-derivatives" | "bitfinex" | "coinbase" | "cryptofacilities" | "kraken" | "bitstamp" | "gemini" | "poloniex" | "bybit" | "bybit-spot" | "phemex" | "delta" | "ftx-us" | "binance-us" | "gate-io-futures" | "gate-io" | "okcoin" | "bitflyer" | "hitbtc" | "coinflex" | "binance-jersey" | "binance-dex" | "upbit" | "ascendex" | "dydx" | "serum" | "mango" | "huobi-dm-options" | "star-atlas" | "crypto-com" | "crypto-com-derivatives" | "kucoin"; | ||
readonly exchange: "bitmex" | "deribit" | "binance-futures" | "binance-delivery" | "binance-options" | "binance" | "ftx" | "okex-futures" | "okex-options" | "okex-swap" | "okex" | "huobi-dm" | "huobi-dm-swap" | "huobi-dm-linear-swap" | "huobi" | "bitfinex-derivatives" | "bitfinex" | "coinbase" | "cryptofacilities" | "kraken" | "bitstamp" | "gemini" | "poloniex" | "bybit" | "bybit-spot" | "phemex" | "delta" | "ftx-us" | "binance-us" | "gate-io-futures" | "gate-io" | "okcoin" | "bitflyer" | "hitbtc" | "coinflex" | "binance-jersey" | "binance-dex" | "upbit" | "ascendex" | "dydx" | "serum" | "mango" | "huobi-dm-options" | "star-atlas" | "crypto-com" | "crypto-com-derivatives" | "kucoin" | "bitnomial"; | ||
readonly isSnapshot: boolean; | ||
@@ -27,0 +27,0 @@ readonly bids: { |
@@ -25,3 +25,3 @@ import { CircularBuffer } from '../handy'; | ||
readonly symbol: string; | ||
readonly exchange: "bitmex" | "deribit" | "binance-futures" | "binance-delivery" | "binance-options" | "binance" | "ftx" | "okex-futures" | "okex-options" | "okex-swap" | "okex" | "huobi-dm" | "huobi-dm-swap" | "huobi-dm-linear-swap" | "huobi" | "bitfinex-derivatives" | "bitfinex" | "coinbase" | "cryptofacilities" | "kraken" | "bitstamp" | "gemini" | "poloniex" | "bybit" | "bybit-spot" | "phemex" | "delta" | "ftx-us" | "binance-us" | "gate-io-futures" | "gate-io" | "okcoin" | "bitflyer" | "hitbtc" | "coinflex" | "binance-jersey" | "binance-dex" | "upbit" | "ascendex" | "dydx" | "serum" | "mango" | "huobi-dm-options" | "star-atlas" | "crypto-com" | "crypto-com-derivatives" | "kucoin"; | ||
readonly exchange: "bitmex" | "deribit" | "binance-futures" | "binance-delivery" | "binance-options" | "binance" | "ftx" | "okex-futures" | "okex-options" | "okex-swap" | "okex" | "huobi-dm" | "huobi-dm-swap" | "huobi-dm-linear-swap" | "huobi" | "bitfinex-derivatives" | "bitfinex" | "coinbase" | "cryptofacilities" | "kraken" | "bitstamp" | "gemini" | "poloniex" | "bybit" | "bybit-spot" | "phemex" | "delta" | "ftx-us" | "binance-us" | "gate-io-futures" | "gate-io" | "okcoin" | "bitflyer" | "hitbtc" | "coinflex" | "binance-jersey" | "binance-dex" | "upbit" | "ascendex" | "dydx" | "serum" | "mango" | "huobi-dm-options" | "star-atlas" | "crypto-com" | "crypto-com-derivatives" | "kucoin" | "bitnomial"; | ||
readonly isSnapshot: boolean; | ||
@@ -55,3 +55,3 @@ readonly bids: { | ||
readonly symbol: string; | ||
readonly exchange: "bitmex" | "deribit" | "binance-futures" | "binance-delivery" | "binance-options" | "binance" | "ftx" | "okex-futures" | "okex-options" | "okex-swap" | "okex" | "huobi-dm" | "huobi-dm-swap" | "huobi-dm-linear-swap" | "huobi" | "bitfinex-derivatives" | "bitfinex" | "coinbase" | "cryptofacilities" | "kraken" | "bitstamp" | "gemini" | "poloniex" | "bybit" | "bybit-spot" | "phemex" | "delta" | "ftx-us" | "binance-us" | "gate-io-futures" | "gate-io" | "okcoin" | "bitflyer" | "hitbtc" | "coinflex" | "binance-jersey" | "binance-dex" | "upbit" | "ascendex" | "dydx" | "serum" | "mango" | "huobi-dm-options" | "star-atlas" | "crypto-com" | "crypto-com-derivatives" | "kucoin"; | ||
readonly exchange: "bitmex" | "deribit" | "binance-futures" | "binance-delivery" | "binance-options" | "binance" | "ftx" | "okex-futures" | "okex-options" | "okex-swap" | "okex" | "huobi-dm" | "huobi-dm-swap" | "huobi-dm-linear-swap" | "huobi" | "bitfinex-derivatives" | "bitfinex" | "coinbase" | "cryptofacilities" | "kraken" | "bitstamp" | "gemini" | "poloniex" | "bybit" | "bybit-spot" | "phemex" | "delta" | "ftx-us" | "binance-us" | "gate-io-futures" | "gate-io" | "okcoin" | "bitflyer" | "hitbtc" | "coinflex" | "binance-jersey" | "binance-dex" | "upbit" | "ascendex" | "dydx" | "serum" | "mango" | "huobi-dm-options" | "star-atlas" | "crypto-com" | "crypto-com-derivatives" | "kucoin" | "bitnomial"; | ||
readonly isSnapshot: false; | ||
@@ -71,3 +71,3 @@ readonly bids: { | ||
readonly symbol: string; | ||
readonly exchange: "bitmex" | "deribit" | "binance-futures" | "binance-delivery" | "binance-options" | "binance" | "ftx" | "okex-futures" | "okex-options" | "okex-swap" | "okex" | "huobi-dm" | "huobi-dm-swap" | "huobi-dm-linear-swap" | "huobi" | "bitfinex-derivatives" | "bitfinex" | "coinbase" | "cryptofacilities" | "kraken" | "bitstamp" | "gemini" | "poloniex" | "bybit" | "bybit-spot" | "phemex" | "delta" | "ftx-us" | "binance-us" | "gate-io-futures" | "gate-io" | "okcoin" | "bitflyer" | "hitbtc" | "coinflex" | "binance-jersey" | "binance-dex" | "upbit" | "ascendex" | "dydx" | "serum" | "mango" | "huobi-dm-options" | "star-atlas" | "crypto-com" | "crypto-com-derivatives" | "kucoin"; | ||
readonly exchange: "bitmex" | "deribit" | "binance-futures" | "binance-delivery" | "binance-options" | "binance" | "ftx" | "okex-futures" | "okex-options" | "okex-swap" | "okex" | "huobi-dm" | "huobi-dm-swap" | "huobi-dm-linear-swap" | "huobi" | "bitfinex-derivatives" | "bitfinex" | "coinbase" | "cryptofacilities" | "kraken" | "bitstamp" | "gemini" | "poloniex" | "bybit" | "bybit-spot" | "phemex" | "delta" | "ftx-us" | "binance-us" | "gate-io-futures" | "gate-io" | "okcoin" | "bitflyer" | "hitbtc" | "coinflex" | "binance-jersey" | "binance-dex" | "upbit" | "ascendex" | "dydx" | "serum" | "mango" | "huobi-dm-options" | "star-atlas" | "crypto-com" | "crypto-com-derivatives" | "kucoin" | "bitnomial"; | ||
readonly isSnapshot: true; | ||
@@ -74,0 +74,0 @@ readonly bids: { |
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" | "ftx" | "okex-futures" | "okex-options" | "okex-swap" | "okex" | "huobi-dm" | "huobi-dm-swap" | "huobi-dm-linear-swap" | "huobi" | "bitfinex-derivatives" | "bitfinex" | "coinbase" | "cryptofacilities" | "kraken" | "bitstamp" | "gemini" | "poloniex" | "bybit" | "bybit-spot" | "phemex" | "delta" | "ftx-us" | "binance-us" | "gate-io-futures" | "gate-io" | "okcoin" | "bitflyer" | "hitbtc" | "coinflex" | "binance-jersey" | "binance-dex" | "upbit" | "ascendex" | "dydx" | "serum" | "mango" | "huobi-dm-options" | "star-atlas" | "crypto-com" | "crypto-com-derivatives" | "kucoin">(exchange: T, localTimestamp: Date) => Mapper<T, Trade>; | ||
export declare const normalizeBookChanges: <T extends "bitmex" | "deribit" | "binance-futures" | "binance-delivery" | "binance-options" | "binance" | "ftx" | "okex-futures" | "okex-options" | "okex-swap" | "okex" | "huobi-dm" | "huobi-dm-swap" | "huobi-dm-linear-swap" | "huobi" | "bitfinex-derivatives" | "bitfinex" | "coinbase" | "cryptofacilities" | "kraken" | "bitstamp" | "gemini" | "poloniex" | "bybit" | "bybit-spot" | "phemex" | "delta" | "ftx-us" | "binance-us" | "gate-io-futures" | "gate-io" | "okcoin" | "bitflyer" | "hitbtc" | "coinflex" | "binance-jersey" | "binance-dex" | "upbit" | "ascendex" | "dydx" | "serum" | "mango" | "huobi-dm-options" | "star-atlas" | "crypto-com" | "crypto-com-derivatives" | "kucoin">(exchange: T, localTimestamp: Date) => Mapper<T, BookChange>; | ||
export declare const normalizeTrades: <T extends "bitmex" | "deribit" | "binance-futures" | "binance-delivery" | "binance-options" | "binance" | "ftx" | "okex-futures" | "okex-options" | "okex-swap" | "okex" | "huobi-dm" | "huobi-dm-swap" | "huobi-dm-linear-swap" | "huobi" | "bitfinex-derivatives" | "bitfinex" | "coinbase" | "cryptofacilities" | "kraken" | "bitstamp" | "gemini" | "poloniex" | "bybit" | "bybit-spot" | "phemex" | "delta" | "ftx-us" | "binance-us" | "gate-io-futures" | "gate-io" | "okcoin" | "bitflyer" | "hitbtc" | "coinflex" | "binance-jersey" | "binance-dex" | "upbit" | "ascendex" | "dydx" | "serum" | "mango" | "huobi-dm-options" | "star-atlas" | "crypto-com" | "crypto-com-derivatives" | "kucoin" | "bitnomial">(exchange: T, localTimestamp: Date) => Mapper<T, Trade>; | ||
export declare const normalizeBookChanges: <T extends "bitmex" | "deribit" | "binance-futures" | "binance-delivery" | "binance-options" | "binance" | "ftx" | "okex-futures" | "okex-options" | "okex-swap" | "okex" | "huobi-dm" | "huobi-dm-swap" | "huobi-dm-linear-swap" | "huobi" | "bitfinex-derivatives" | "bitfinex" | "coinbase" | "cryptofacilities" | "kraken" | "bitstamp" | "gemini" | "poloniex" | "bybit" | "bybit-spot" | "phemex" | "delta" | "ftx-us" | "binance-us" | "gate-io-futures" | "gate-io" | "okcoin" | "bitflyer" | "hitbtc" | "coinflex" | "binance-jersey" | "binance-dex" | "upbit" | "ascendex" | "dydx" | "serum" | "mango" | "huobi-dm-options" | "star-atlas" | "crypto-com" | "crypto-com-derivatives" | "kucoin" | "bitnomial">(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" | "crypto-com" | "crypto-com-derivatives">(exchange: T, localTimestamp: Date) => Mapper<T, DerivativeTicker>; | ||
@@ -7,0 +7,0 @@ export declare const normalizeOptionsSummary: <T extends "deribit" | "binance-options" | "okex-options" | "huobi-dm-options">(exchange: T, localTimestamp: Date) => Mapper<T, OptionSummary>; |
@@ -26,2 +26,3 @@ "use strict"; | ||
const bitmex_1 = require("./bitmex"); | ||
const bitnomial_1 = require("./bitnomial"); | ||
const bitstamp_1 = require("./bitstamp"); | ||
@@ -123,3 +124,4 @@ const bybit_1 = require("./bybit"); | ||
'crypto-com-derivatives': () => new cryptocom_1.CryptoComTradesMapper('crypto-com-derivatives'), | ||
kucoin: () => new kucoin_1.KucoinTradesMapper('kucoin') | ||
kucoin: () => new kucoin_1.KucoinTradesMapper('kucoin'), | ||
bitnomial: () => bitnomial_1.bitnomialTradesMapper | ||
}; | ||
@@ -183,3 +185,4 @@ const bookChangeMappers = { | ||
'crypto-com-derivatives': () => new cryptocom_1.CryptoComBookChangeMapper('crypto-com-derivatives'), | ||
kucoin: (localTimestamp) => new kucoin_1.KucoinBookChangeMapper('kucoin', isRealTime(localTimestamp) === false) | ||
kucoin: (localTimestamp) => new kucoin_1.KucoinBookChangeMapper('kucoin', isRealTime(localTimestamp) === false), | ||
bitnomial: () => new bitnomial_1.BitnomialBookChangMapper() | ||
}; | ||
@@ -186,0 +189,0 @@ const derivativeTickersMappers = { |
@@ -50,2 +50,3 @@ "use strict"; | ||
const kucoin_1 = require("./kucoin"); | ||
const bitnomial_1 = require("./bitnomial"); | ||
__exportStar(require("./realtimefeed"), exports); | ||
@@ -99,3 +100,4 @@ const realTimeFeedsMap = { | ||
'crypto-com-derivatives': cryptocom_1.CryptoComRealTimeFeed, | ||
kucoin: kucoin_1.KucoinRealTimeFeed | ||
kucoin: kucoin_1.KucoinRealTimeFeed, | ||
bitnomial: bitnomial_1.BitnomialRealTimeFeed | ||
}; | ||
@@ -102,0 +104,0 @@ function getRealTimeFeedFactory(exchange) { |
import { EXCHANGES, EXCHANGE_CHANNELS_INFO } from './consts'; | ||
export type Exchange = typeof EXCHANGES[number]; | ||
export type Exchange = (typeof EXCHANGES)[number]; | ||
export type FilterForExchange = { | ||
[key in Exchange]: Filter<typeof EXCHANGE_CHANNELS_INFO[key][number]>; | ||
[key in Exchange]: Filter<(typeof EXCHANGE_CHANNELS_INFO)[key][number]>; | ||
}; | ||
@@ -6,0 +6,0 @@ export type Filter<T> = { |
{ | ||
"name": "tardis-dev", | ||
"version": "13.10.4", | ||
"version": "13.11.0", | ||
"engines": { | ||
@@ -5,0 +5,0 @@ "node": ">=12" |
@@ -48,3 +48,4 @@ export const EXCHANGES = [ | ||
'crypto-com-derivatives', | ||
'kucoin' | ||
'kucoin', | ||
'bitnomial' | ||
] as const | ||
@@ -387,2 +388,4 @@ | ||
const BITNOMIAL_CHANNELS = ['trade', 'level', 'book', 'block', 'status'] | ||
export const EXCHANGE_CHANNELS_INFO = { | ||
@@ -435,3 +438,4 @@ bitmex: BITMEX_CHANNELS, | ||
'crypto-com-derivatives': CRYPTO_COM_DERIVATIVES, | ||
kucoin: KUCOIN_CHANNELS | ||
kucoin: KUCOIN_CHANNELS, | ||
bitnomial: BITNOMIAL_CHANNELS | ||
} |
@@ -182,3 +182,3 @@ import crypto, { createHash } from 'crypto' | ||
// or 2020-03-01T00:00:24.893456+00:00 | ||
if (dateString.length === 27 || dateString.length === 28 || dateString.length === 32) { | ||
if (dateString.length === 27 || dateString.length === 28 || dateString.length === 32 || dateString.length === 30) { | ||
return Number(dateString.slice(23, 26)) | ||
@@ -185,0 +185,0 @@ } |
@@ -262,3 +262,3 @@ import { debug } from '../debug' | ||
asks: binanceDepthUpdateData.a.map(this.mapBookLevel), | ||
timestamp: new Date(binanceDepthUpdateData.T), | ||
timestamp: new Date(binanceDepthUpdateData.E), | ||
localTimestamp: localTimestamp | ||
@@ -265,0 +265,0 @@ } |
@@ -29,2 +29,3 @@ import { ONE_SEC_IN_MS } from '../handy' | ||
} from './bitmex' | ||
import { BitnomialBookChangMapper, bitnomialTradesMapper } from './bitnomial' | ||
import { BitstampBookChangeMapper, bitstampTradesMapper } from './bitstamp' | ||
@@ -185,3 +186,4 @@ import { BybitBookChangeMapper, BybitDerivativeTickerMapper, BybitLiquidationsMapper, BybitTradesMapper } from './bybit' | ||
'crypto-com-derivatives': () => new CryptoComTradesMapper('crypto-com-derivatives'), | ||
kucoin: () => new KucoinTradesMapper('kucoin') | ||
kucoin: () => new KucoinTradesMapper('kucoin'), | ||
bitnomial: () => bitnomialTradesMapper | ||
} | ||
@@ -259,3 +261,4 @@ | ||
'crypto-com-derivatives': () => new CryptoComBookChangeMapper('crypto-com-derivatives'), | ||
kucoin: (localTimestamp: Date) => new KucoinBookChangeMapper('kucoin', isRealTime(localTimestamp) === false) | ||
kucoin: (localTimestamp: Date) => new KucoinBookChangeMapper('kucoin', isRealTime(localTimestamp) === false), | ||
bitnomial: () => new BitnomialBookChangMapper() | ||
} | ||
@@ -262,0 +265,0 @@ |
@@ -47,2 +47,3 @@ import { Exchange, Filter } from '../types' | ||
import { KucoinRealTimeFeed } from './kucoin' | ||
import { BitnomialRealTimeFeed } from './bitnomial' | ||
@@ -100,3 +101,4 @@ export * from './realtimefeed' | ||
'crypto-com-derivatives': CryptoComRealTimeFeed, | ||
kucoin: KucoinRealTimeFeed | ||
kucoin: KucoinRealTimeFeed, | ||
bitnomial: BitnomialRealTimeFeed | ||
} | ||
@@ -103,0 +105,0 @@ |
import { EXCHANGES, EXCHANGE_CHANNELS_INFO } from './consts' | ||
export type Exchange = typeof EXCHANGES[number] | ||
export type Exchange = (typeof EXCHANGES)[number] | ||
export type FilterForExchange = { [key in Exchange]: Filter<typeof EXCHANGE_CHANNELS_INFO[key][number]> } | ||
export type FilterForExchange = { [key in Exchange]: Filter<(typeof EXCHANGE_CHANNELS_INFO)[key][number]> } | ||
@@ -7,0 +7,0 @@ export type Filter<T> = { |
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
1609878
454
29670