diff --git a/src/store/modules/ftbot/index.ts b/src/store/modules/ftbot/index.ts index 7957fb38..2204b11a 100644 --- a/src/store/modules/ftbot/index.ts +++ b/src/store/modules/ftbot/index.ts @@ -21,6 +21,7 @@ import { LockResponse, Lock, RunModes, + TradeResponse, } from '@/types'; import { @@ -101,9 +102,9 @@ export default { updateRefreshRequired(state: FtbotStateType, refreshRequired: boolean) { state.refreshRequired = refreshRequired; }, - updateTrades(state: FtbotStateType, trades) { - state.trades = trades.trades; - state.tradeCount = trades.trades_count; + updateTrades(state: FtbotStateType, { trades, tradesCount }) { + state.trades = trades; + state.tradeCount = tradesCount; }, updateOpenTrades(state: FtbotStateType, trades) { state.openTrades = trades; @@ -194,11 +195,33 @@ export default { setSelectedPair({ commit }, pair: string) { commit('setSelectedPair', pair); }, - getTrades({ commit }) { - return api - .get('/trades') - .then((result) => commit('updateTrades', result.data)) - .catch(console.error); + async getTrades({ commit }) { + try { + let totalTrades = 0; + const fetchTrades = async (limit: number, offset: number) => { + return api.get('/trades', { params: { limit, offset } }); + }; + const res = await fetchTrades(500, 0); + const result: TradeResponse = res.data; + let { trades } = result; + if (trades.length !== result.total_trades) { + // Pagination necessary + do { + // eslint-disable-next-line no-await-in-loop + const res = await fetchTrades(500, trades.length); + + const result: TradeResponse = res.data; + trades = trades.concat(result.trades); + totalTrades = res.data.total_trades; + } while (trades.length !== totalTrades); + } + const tradesCount = trades.length; + commit('updateTrades', { trades, tradesCount }); + return Promise.resolve(); + } catch (error) { + console.error(error.response); + return Promise.reject(error); + } }, getLocks({ commit }) { return api diff --git a/src/types/trades.ts b/src/types/trades.ts index a1d9f969..9fa97b76 100644 --- a/src/types/trades.ts +++ b/src/types/trades.ts @@ -65,3 +65,11 @@ export interface ClosedTrade extends Trade { min_rate: number; max_rate: number; } + +export interface TradeResponse { + trades: ClosedTrade[]; + /** Trades count for this response */ + trades_count: number; + /** Total trade count */ + total_trades: number; +}