hash-wallet/lib/new-ui/model/charts/price_api_client.dart

import "dart:convert";

import "package:hash_wallet/.secrets.g.dart" as secrets;
import "package:hash_wallet/utils/feature_flag.dart";
import "package:hash_wallet/new-ui/model/charts/datetime_extension.dart";
import "package:hash_wallet/new-ui/model/charts/price_data.dart";
import "package:cw_core/amount/money.dart";
import "package:cw_core/currency.dart";
import "package:cw_core/utils/print_verbose.dart";
import "package:cw_core/utils/proxy_wrapper.dart";

const priceApiHost = "prices.cakewallet.com";
const priceApiHostOnion = "46wisoe2uwipcj2j4og6smiq7hbmj34fkkrquwlzbbsqtgat7bf3erid.onion";

class LatestPriceRequest {
  LatestPriceRequest({required this.from, required this.to});

  final Currency from;
  final Currency to;

  Uri get uri => Uri.https(priceApiHost, "/v3/rates", {
        "base": from.apiString,
        "quote": to.apiString,
      });

  Uri get onionUri => Uri.http(priceApiHostOnion, uri.path, uri.queryParameters);
}

class PriceRequest {
  const PriceRequest({
    required this.interval,
    required this.from,
    required this.to,
    this.beginTime,
    this.count,
  });

  final DateTime? beginTime;
  final Duration interval;
  final int? count;
  final Currency from;
  final Currency to;

  Uri get uri => Uri.https(priceApiHost, "/v3/rates", {
        "start": (beginTime?.secondsSinceEpoch ?? 0).toString(),
        "end": DateTime.now().secondsSinceEpoch.toString(),
        "interval": "${interval.inSeconds}",
        if (count != null) "count": count.toString(),
        "quote": from.apiString,
        "base": to.apiString,
      });

  Uri get onionUri => Uri.http(priceApiHostOnion, uri.path, uri.queryParameters);
}

class PriceApiClient {
  static Future<Map<String, dynamic>?> _getJson(Uri uri) async {
    if (!FeatureFlag.isChartsEnabled) return null;
    final resp =
        await ProxyWrapper().get(headers: {"x-api-key": secrets.fiatApiKey}, clearnetUri: uri);
    if (!(resp.statusCode >= 200 && resp.statusCode < 300)) {
      printV("server returned code: ${resp.statusCode}\nuri: ${uri}\nresp body: ${resp.body}");
      return null;
    }
    try {
      return jsonDecode(resp.body) as Map<String, dynamic>?;
    } catch (e) {
      printV("failed to decode response for ${uri.host}/${uri.path}: $e");
      return null;
    }
  }

  static Future<List<PriceData>> getPrices(PriceRequest request, {bool torOnly = false}) async {
    final List<PriceData> ret = [];
    printV(request.uri);
    final data = await _getJson(torOnly ? request.onionUri : request.uri);
    if (data == null) {
      return [];
    }
    final results = data["results"] as Map<String, dynamic>?;
    if (results == null) {
      printV(data.toString());
      return [];
    }
    printV(data.toString());
    for (final time in results.keys) {
      ret.add(
        PriceData(
          time: DateTimeX.fromSecondsSinceEpoch(int.parse(time)),
          base: request.from,
          quote: Money.parse((results[time] as num).toStringAsFixed(20), request.to, strictParsing: false),
        ),
      );
    }
    return ret;
  }

  static Future<PriceData?> getLatestPrice(
    LatestPriceRequest request, {
    bool torOnly = false,
  }) async {
    final data = await _getJson(torOnly ? request.onionUri : request.uri);
    if (data == null) {
      return null;
    }
    final results = data["results"] as Map<String, dynamic>?;
    if (results == null) {
      return null;
    }
    final result = results[results.keys.first];
    return PriceData(
      time: DateTime.now(),
      base: request.from,
      quote: Money.parse((result as num).toString(), request.to, strictParsing: false),
    );
  }
}