mirror of
https://github.com/cypherstack/stack_wallet.git
synced 2024-12-25 12:59:24 +00:00
53 lines
1.9 KiB
Dart
53 lines
1.9 KiB
Dart
import 'dart:convert';
|
|
import 'dart:io';
|
|
import 'package:cbor/simple.dart';
|
|
import 'package:on_chain/ada/src/provider/blockfrost/core/core.dart';
|
|
import 'package:on_chain/ada/src/provider/service/service.dart';
|
|
|
|
import '../../../utilities/logger.dart';
|
|
|
|
class BlockfrostHttpProvider implements BlockfrostServiceProvider {
|
|
BlockfrostHttpProvider({
|
|
required this.url,
|
|
this.version = "v0",
|
|
this.projectId,
|
|
HttpClient? client,
|
|
this.defaultRequestTimeout = const Duration(seconds: 30),
|
|
}) : client = client ?? HttpClient();
|
|
@override
|
|
final String url;
|
|
final String version;
|
|
final String? projectId;
|
|
final HttpClient client;
|
|
final Duration defaultRequestTimeout;
|
|
|
|
@override
|
|
Future<dynamic> get(BlockforestRequestDetails params,
|
|
[Duration? timeout,]) async {
|
|
final response = await client.getUrl(Uri.parse(params.url(url, "api/$version"))).timeout(timeout ?? defaultRequestTimeout);
|
|
response.headers.add("Content-Type", "application/json");
|
|
response.headers.add("Accept", "application/json");
|
|
if (projectId != null) {
|
|
response.headers.add("project_id", projectId!);
|
|
}
|
|
final responseStream = await response.close();
|
|
final data = json.decode(await responseStream.transform(utf8.decoder).join());
|
|
return data;
|
|
}
|
|
|
|
@override
|
|
Future<dynamic> post(BlockforestRequestDetails params,
|
|
[Duration? timeout,]) async {
|
|
final request = await client.postUrl(Uri.parse(params.url(url, "api/$version"))).timeout(timeout ?? defaultRequestTimeout);
|
|
// Need to change this for other operations than submitting transactions
|
|
request.headers.add("Content-Type", "application/cbor");
|
|
request.headers.add("Accept", "application/json");
|
|
if (projectId != null) {
|
|
request.headers.add("project_id", projectId!);
|
|
}
|
|
request.add(params.body as List<int>);
|
|
final response = await request.close();
|
|
final data = json.decode(await response.transform(utf8.decoder).join());
|
|
return data;
|
|
}
|
|
}
|