Skip to content

Commit

Permalink
2.5.27
Browse files Browse the repository at this point in the history 
[ci skip]
  • Loading branch information
Travis CI committed Jan 4, 2023
1 parent 4e75dc7 commit abfc243
Show file tree
Hide file tree
Showing 18 changed files with 517 additions and 68 deletions.
6 changes: 3 additions & 3 deletions README.md
View file
Expand Up @@ -208,13 +208,13 @@ console.log (ccxt.exchanges) // print all available exchanges

All-in-one browser bundle (dependencies included), served from a CDN of your choice:

* jsDelivr: https://cdn.jsdelivr.net/npm/ccxt@2.5.26/dist/ccxt.browser.js
* unpkg: https://unpkg.com/ccxt@2.5.26/dist/ccxt.browser.js
* jsDelivr: https://cdn.jsdelivr.net/npm/ccxt@2.5.27/dist/ccxt.browser.js
* unpkg: https://unpkg.com/ccxt@2.5.27/dist/ccxt.browser.js

CDNs are not updated in real-time and may have delays. Defaulting to the most recent version without specifying the version number is not recommended. Please, keep in mind that we are not responsible for the correct operation of those CDN servers.

```HTML
<script type="text/javascript" src="https://cdn.jsdelivr.net/npm/ccxt@2.5.26/dist/ccxt.browser.js"></script>
<script type="text/javascript" src="https://cdn.jsdelivr.net/npm/ccxt@2.5.27/dist/ccxt.browser.js"></script>
```

Creates a global `ccxt` object:
Expand Down
2 changes: 1 addition & 1 deletion ccxt.js
View file
Expand Up @@ -37,7 +37,7 @@ const Exchange = require ('./js/base/Exchange')
//-----------------------------------------------------------------------------
// this is updated by vss.js when building

const version = '2.5.26'
const version = '2.5.27'

Exchange.ccxtVersion = version

Expand Down
179 changes: 167 additions & 12 deletions dist/ccxt.browser.js
View file
Expand Up @@ -47,7 +47,7 @@ const Exchange = require ('./js/base/Exchange')
//-----------------------------------------------------------------------------
// this is updated by vss.js when building

const version = '2.5.25'
const version = '2.5.26'

Exchange.ccxtVersion = version

Expand Down Expand Up @@ -176697,7 +176697,7 @@ module.exports = class bequant extends hitbtc {

const binanceRest = require ('../binance.js');
const Precise = require ('../base/Precise');
const { ExchangeError } = require ('../base/errors');
const { ExchangeError, ArgumentsRequired } = require ('../base/errors');
const { ArrayCache, ArrayCacheByTimestamp, ArrayCacheBySymbolById } = require ('./base/Cache');

// -----------------------------------------------------------------------------
Expand All @@ -176713,7 +176713,7 @@ module.exports = class binance extends binanceRest {
'watchOrderBook': true,
'watchOrders': true,
'watchTicker': true,
'watchTickers': false, // for now
'watchTickers': true,
'watchTrades': true,
},
'urls': {
Expand Down Expand Up @@ -176757,6 +176757,9 @@ module.exports = class binance extends binanceRest {
'watchTicker': {
'name': 'ticker', // ticker = 1000ms L1+OHLCV, bookTicker = real-time L1
},
'watchTickers': {
'name': 'ticker', // ticker or miniTicker or bookTicker
},
'watchBalance': {
'fetchBalanceSnapshot': false, // or true
'awaitBalanceSnapshot': true, // whether to wait for the balance snapshot before providing updates
Expand Down Expand Up @@ -177438,12 +177441,76 @@ module.exports = class binance extends binanceRest {
return await this.watch (url, messageHash, this.extend (request, params), messageHash, subscribe);
}

handleTicker (client, message) {
//
// 24hr rolling window ticker statistics for a single symbol
// These are NOT the statistics of the UTC day, but a 24hr rolling window for the previous 24hrs
// Update Speed 1000ms
async watchTickers (symbols = undefined, params = {}) {
/**
* @method
* @name binance#watchTickers
* @description watches a price ticker, a statistical calculation with the information calculated over the past 24 hours for all markets of a specific list
* @param {Array} symbols unified symbol of the market to fetch the ticker for
* @param {object} params extra parameters specific to the binance api endpoint
* @returns {object} a [ticker structure]{@link https://docs.ccxt.com/en/latest/manual.html#ticker-structure}
*/
await this.loadMarkets ();
symbols = this.marketSymbols (symbols);
const marketIds = this.marketIds (symbols);
let market = undefined;
if (marketIds !== undefined) {
market = this.safeMarket (marketIds[0]);
}
let type = undefined;
[ type, params ] = this.handleMarketTypeAndParams ('watchTickers', market, params);
const options = this.safeValue (this.options, 'watchTickers', {});
let name = this.safeString (options, 'name', 'ticker');
name = this.safeString (params, 'name', name);
const oriParams = params;
params = this.omit (params, 'name');
let wsParams = [];
const messageHash = '!' + name + '@arr';
if (name === 'bookTicker') {
if (marketIds === undefined) {
throw new ArgumentsRequired (this.id + ' watchTickers() requires symbols for bookTicker');
}
// simulate watchTickers with subscribe multiple individual bookTicker topic
for (let i = 0; i < marketIds.length; i++) {
wsParams.push (marketIds[i].toLowerCase () + '@bookTicker');
}
} else {
wsParams = [
messageHash,
];
}
const url = this.urls['api']['ws'][type] + '/' + this.stream (type, messageHash);
const requestId = this.requestId (url);
const request = {
'method': 'SUBSCRIBE',
'params': wsParams,
'id': requestId,
};
const subscribe = {
'id': requestId,
};
const tickers = await this.watch (url, messageHash, this.extend (request, params), messageHash, subscribe);
const result = {};
for (let i = 0; i < tickers.length; i++) {
const ticker = tickers[i];
const tickerSymbol = ticker['symbol'];
if (symbols !== undefined && this.inArray (tickerSymbol, symbols)) {
result[tickerSymbol] = ticker;
}
}
const resultKeys = Object.keys (result);
if (resultKeys.length > 0) {
if (this.newUpdates) {
return result;
}
return this.filterByArray (this.tickers, 'symbol', symbols);
}
return await this.watchTickers (symbols, oriParams);
}

parseWsTicker (message) {
//
// ticker
// {
// e: '24hrTicker', // event type
// E: 1579485598569, // event time
Expand All @@ -177470,12 +177537,23 @@ module.exports = class binance extends binanceRest {
// n: 163222, // total number of trades
// }
//
// miniTicker
// {
// e: '24hrMiniTicker',
// E: 1671617114585,
// s: 'MOBBUSD',
// c: '0.95900000',
// o: '0.91200000',
// h: '1.04000000',
// l: '0.89400000',
// v: '2109995.32000000',
// q: '2019254.05788000'
// }
//
let event = this.safeString (message, 'e', 'bookTicker');
if (event === '24hrTicker') {
event = 'ticker';
}
const wsMarketId = this.safeStringLower (message, 's');
const messageHash = wsMarketId + '@' + event;
let timestamp = undefined;
const now = this.milliseconds ();
if (event === 'bookTicker') {
Expand All @@ -177488,7 +177566,7 @@ module.exports = class binance extends binanceRest {
const marketId = this.safeString (message, 's');
const symbol = this.safeSymbol (marketId);
const last = this.safeFloat (message, 'c');
const result = {
const ticker = {
'symbol': symbol,
'timestamp': timestamp,
'datetime': this.iso8601 (timestamp),
Expand All @@ -177510,8 +177588,78 @@ module.exports = class binance extends binanceRest {
'quoteVolume': this.safeFloat (message, 'q'),
'info': message,
};
return ticker;
}

handleTicker (client, message) {
//
// 24hr rolling window ticker statistics for a single symbol
// These are NOT the statistics of the UTC day, but a 24hr rolling window for the previous 24hrs
// Update Speed 1000ms
//
// {
// e: '24hrTicker', // event type
// E: 1579485598569, // event time
// s: 'ETHBTC', // symbol
// p: '-0.00004000', // price change
// P: '-0.209', // price change percent
// w: '0.01920495', // weighted average price
// x: '0.01916500', // the price of the first trade before the 24hr rolling window
// c: '0.01912500', // last (closing) price
// Q: '0.10400000', // last quantity
// b: '0.01912200', // best bid
// B: '4.10400000', // best bid quantity
// a: '0.01912500', // best ask
// A: '0.00100000', // best ask quantity
// o: '0.01916500', // open price
// h: '0.01956500', // high price
// l: '0.01887700', // low price
// v: '173518.11900000', // base volume
// q: '3332.40703994', // quote volume
// O: 1579399197842, // open time
// C: 1579485597842, // close time
// F: 158251292, // first trade id
// L: 158414513, // last trade id
// n: 163222, // total number of trades
// }
//
let event = this.safeString (message, 'e', 'bookTicker');
if (event === '24hrTicker') {
event = 'ticker';
} else if (event === '24hrMiniTicker') {
event = 'miniTicker';
}
const wsMarketId = this.safeStringLower (message, 's');
const messageHash = wsMarketId + '@' + event;
const result = this.parseWsTicker (message);
const symbol = result['symbol'];
this.tickers[symbol] = result;
client.resolve (result, messageHash);
if (event === 'bookTicker') {
// watch bookTickers
client.resolve ([ result ], '!' + 'bookTicker@arr');
}
}

handleTickers (client, message) {
let event = undefined;
for (let i = 0; i < message.length; i++) {
const ticker = message[i];
event = this.safeString (ticker, 'e');
if (event === '24hrTicker') {
event = 'ticker';
} else if (event === '24hrMiniTicker') {
event = 'miniTicker';
}
const wsMarketId = this.safeStringLower (ticker, 's');
const messageHash = wsMarketId + '@' + event;
const result = this.parseWsTicker (ticker);
const symbol = result['symbol'];
this.tickers[symbol] = result;
client.resolve (result, messageHash);
}
const values = Object.values (this.tickers);
client.resolve (values, '!' + event + '@arr');
}

async authenticate (params = {}) {
Expand Down Expand Up @@ -178171,15 +178319,22 @@ module.exports = class binance extends binanceRest {
'trade': this.handleTrade,
'aggTrade': this.handleTrade,
'kline': this.handleOHLCV,
'24hrTicker@arr': this.handleTickers,
'24hrMiniTicker@arr': this.handleTickers,
'24hrTicker': this.handleTicker,
'24hrMiniTicker': this.handleTicker,
'bookTicker': this.handleTicker,
'outboundAccountPosition': this.handleBalance,
'balanceUpdate': this.handleBalance,
'ACCOUNT_UPDATE': this.handleBalance,
'executionReport': this.handleOrderUpdate,
'ORDER_TRADE_UPDATE': this.handleOrderUpdate,
};
const event = this.safeString (message, 'e');
let event = this.safeString (message, 'e');
if (Array.isArray (message)) {
const data = message[0];
event = this.safeString (data, 'e') + '@arr';
}
const method = this.safeValue (methods, event);
if (method === undefined) {
const requestId = this.safeString (message, 'id');
Expand Down
4 changes: 2 additions & 2 deletions package-lock.json
View file

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

16 changes: 8 additions & 8 deletions package.json
View file
@@ -1,6 +1,6 @@
{
"name": "ccxt",
"version": "2.5.26",
"version": "2.5.27",
"description": "A JavaScript / Python / PHP cryptocurrency trading library with support for 130+ exchanges",
"main": "./ccxt.js",
"unpkg": "dist/ccxt.browser.js",
Expand Down Expand Up @@ -244,7 +244,7 @@
"ccex",
"C-CEX",
"cex",
"cex.io",
"CEX.IO",
"CHBTC",
"ChileBit",
"chilebit.net",
Expand Down Expand Up @@ -414,7 +414,7 @@
"fybse.se",
"fybsg.com",
"gatecoin.com",
"Gate.io",
"gate.io",
"gdax.com",
"gemini.com",
"getbtc.org",
Expand Down Expand Up @@ -531,8 +531,8 @@
"dsxglobal.com",
"bitvavo.com",
"Bitvavo",
"Currency.com",
"Waves.Exchange",
"currency.com",
"waves.exchange",
"phemex.com",
"Phemex",
"huobi.co.jp",
Expand Down Expand Up @@ -581,7 +581,7 @@
"Binance USDⓈ-M",
"eqonex.com",
"EQONEX",
"FMFW.io",
"fmfw.io",
"mexc.com",
"MEXC Global",
"bitrue.com",
Expand All @@ -595,8 +595,8 @@
"Zonda",
"futures.kucoin.com",
"KuCoin Futures",
"Blockchain.com",
"Crypto.com",
"blockchain.com",
"crypto.com",
"wazirx.com",
"WazirX",
"woo.org",
Expand Down
4 changes: 2 additions & 2 deletions php/Exchange.php
View file

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

4 changes: 2 additions & 2 deletions php/async/Exchange.php
View file
Expand Up @@ -34,11 +34,11 @@

include 'Throttle.php';

$version = '2.5.26';
$version = '2.5.27';

class Exchange extends \ccxt\Exchange {

const VERSION = '2.5.26';
const VERSION = '2.5.27';

public $browser;
public $marketsLoading = null;
Expand Down

0 comments on commit abfc243

Please sign in to comment.