From 333bbce9bfbf7dee25eefb586353dd7c84382288 Mon Sep 17 00:00:00 2001 From: Jacopo De Simoi Date: Thu, 27 Oct 2022 15:20:16 -0400 Subject: [PATCH] Add end_time parameter to get_candles --- src/cryptocom/exchange/market.py | 16 +++++++++++----- 1 file changed, 11 insertions(+), 5 deletions(-) diff --git a/src/cryptocom/exchange/market.py b/src/cryptocom/exchange/market.py index 7da1f34..7c70cc5 100644 --- a/src/cryptocom/exchange/market.py +++ b/src/cryptocom/exchange/market.py @@ -87,11 +87,17 @@ class Exchange: ] return OrderBook(buys, sells, pair) - async def get_candles(self, pair: Pair, period: Period) -> List[Candle]: - data = await self.api.get( - "public/get-candlestick", - {"instrument_name": pair.name, "timeframe": period.value}, - ) + async def get_candles(self, pair: Pair, period: Period, endTime:int = None) -> List[Candle]: + + data = [] + if endTime: + data = await self.api.get( + "public/get-candlestick", + {"instrument_name": pair.name, "timeframe": period.value, "end_time": endTime*1000}) + else: + data = await self.api.get( + "public/get-candlestick", + {"instrument_name": pair.name, "timeframe": period.value}) return [Candle.from_api(pair, candle) for candle in data] async def listen_candles(