Ecosystem/stack_wallet
1
0
Fork 0
mirror of https://github.com/cypherstack/stack_wallet.git synced 2025-01-10 20:54:33 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

update network wrapper

Browse source
This commit is contained in:
julian 2023-08-07 09:18:08 -06:00
parent 544df2c882
commit f1cb7278c5
1 changed files with 56 additions and 17 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

73
lib/networking/http.dart
View file

@ -1,40 +1,79 @@
import 'dart:convert';
import 'dart:io';
import 'package:http/http.dart' as http;
import 'package:stackwallet/utilities/logger.dart';
// WIP wrapper layer
abstract class HTTP {
static Future<http.Response> get({
static Future<HttpClientResponse> get({
required Uri url,
Map<String, String>? headers,
required bool routeOverTor,
}) async {
if (routeOverTor) {
// TODO
throw UnimplementedError();
} else {
return http.get(url, headers: headers);
final httpClient = HttpClient();
try {
if (routeOverTor) {
// TODO
throw UnimplementedError();
} else {
final HttpClientRequest request = await httpClient.getUrl(
url,
);
request.headers.clear();
if (headers != null) {
headers.forEach((key, value) => request.headers.add);
}
return request.close();
}
} catch (e, s) {
Logging.instance.log(
"HTTP.get() rethrew: $e\n$s",
level: LogLevel.Info,
);
rethrow;
} finally {
httpClient.close(force: true);
}
}
static Future<http.Response> post({
static Future<HttpClientResponse> post({
required Uri url,
Map<String, String>? headers,
Object? body,
Encoding? encoding,
required bool routeOverTor,
}) async {
if (routeOverTor) {
// TODO
throw UnimplementedError();
} else {
return http.post(
url,
headers: headers,
body: body,
encoding: encoding,
final httpClient = HttpClient();
try {
if (routeOverTor) {
// TODO
throw UnimplementedError();
} else {
final HttpClientRequest request = await httpClient.postUrl(
url,
);
request.headers.clear();
if (headers != null) {
headers.forEach((key, value) => request.headers.add);
}
request.write(body);
return request.close();
}
} catch (e, s) {
Logging.instance.log(
"HTTP.post() rethrew: $e\n$s",
level: LogLevel.Info,
);
rethrow;
} finally {
httpClient.close(force: true);
}
}
}