Fix breakage (part 1)

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(

src/cryptocom/exchange/structs.py

@@ -141,11 +141,11 @@ class Candle:
     def from_api(cls, pair: Pair, data: Dict):
         return cls(
             time=int(data["t"] / 1000),
-            open=pair.round_price(data["o"]),
-            high=pair.round_price(data["h"]),
-            low=pair.round_price(data["l"]),
-            close=pair.round_price(data["c"]),
-            volume=pair.round_quantity(data["v"]),
+            open=pair.round_price(float(data["o"])),
+            high=pair.round_price(float(data["h"])),
+            low=pair.round_price(float(data["l"])),
+            close=pair.round_price(float(data["c"])),
+            volume=pair.round_quantity(float(data["v"])),
             pair=pair,
         )