fix(cex-market-data): coingecko ohlc parsing

packages/komodo_cex_market_data/lib/src/binance/data/binance_provider.dart

@@ -42,10 +42,13 @@ class BinanceProvider implements IBinanceProvider {
 
     final response = await http.get(uri);
     if (response.statusCode == 200) {
-      return CoinOhlc.fromJson(jsonDecode(response.body) as List<dynamic>);
+      return CoinOhlc.fromJson(
+        jsonDecode(response.body) as List<dynamic>,
+        source: OhlcSource.binance,
+      );
     } else {
       throw Exception(
-        'Failed to load klines for \'$symbol\': '
+        "Failed to load klines for '$symbol': "
         '${response.statusCode} ${response.body}',
       );
     }
@@ -113,7 +116,7 @@ class BinanceProvider implements IBinanceProvider {
       );
     } else {
       throw Exception(
-        'Failed to load 24hr ticker for \'$symbol\': '
+        "Failed to load 24hr ticker for '$symbol': "
         '${response.statusCode} ${response.body}',
       );
     }

packages/komodo_cex_market_data/lib/src/binance/data/binance_repository.dart

@@ -161,7 +161,7 @@ class BinanceRepository implements CexRepository {
       endAt: endAt,
       limit: 1,
     );
-    return Decimal.parse(ohlcData.ohlc.first.close.toString());
+    return ohlcData.ohlc.first.closeDecimal;
   }
 
   @override
@@ -206,10 +206,12 @@ class BinanceRepository implements CexRepository {
         map,
         ohlc,
       ) {
-        final date = DateTime.fromMillisecondsSinceEpoch(ohlc.closeTime);
-        map[DateTime(date.year, date.month, date.day)] = Decimal.parse(
-          ohlc.close.toString(),
+        final dateUtc = DateTime.fromMillisecondsSinceEpoch(
+          ohlc.closeTimeMs,
+          isUtc: true,
         );
+        map[DateTime.utc(dateUtc.year, dateUtc.month, dateUtc.day)] =
+            ohlc.closeDecimal;
         return map;
       });
 

packages/komodo_cex_market_data/lib/src/coingecko/data/coingecko_cex_provider.dart

@@ -504,7 +504,7 @@ class CoinGeckoCexProvider implements ICoinGeckoProvider {
     return http.get(uri).then((http.Response response) {
       if (response.statusCode == 200) {
         final data = jsonDecode(response.body) as List<dynamic>;
-        return CoinOhlc.fromJson(data);
+        return CoinOhlc.fromJson(data, source: OhlcSource.coingecko);
       } else {
         throw Exception(
           'Failed to load coin ohlc data: ${response.statusCode} ${response.body}',

packages/komodo_cex_market_data/lib/src/coingecko/data/coingecko_repository.dart

@@ -228,10 +228,12 @@ class CoinGeckoRepository implements CexRepository {
         map,
         ohlc,
       ) {
-        final date = DateTime.fromMillisecondsSinceEpoch(ohlc.closeTime);
-        map[DateTime(date.year, date.month, date.day)] = Decimal.parse(
-          ohlc.close.toString(),
+        final dateUtc = DateTime.fromMillisecondsSinceEpoch(
+          ohlc.closeTimeMs,
+          isUtc: true,
         );
+        map[DateTime.utc(dateUtc.year, dateUtc.month, dateUtc.day)] =
+            ohlc.closeDecimal;
         return map;
       });