import 'dart:convert'; import 'dart:io'; import 'package:socks5_proxy/socks_client.dart'; import 'package:stackwallet/networking/tor_service.dart'; import 'package:stackwallet/utilities/logger.dart'; // WIP wrapper layer abstract class HTTP { static Future get({ required Uri url, Map? headers, required bool routeOverTor, }) async { final httpClient = HttpClient(); try { if (routeOverTor) { SocksTCPClient.assignToHttpClient(httpClient, [ ProxySettings( InternetAddress.loopbackIPv4, TorService.sharedInstance.port, ), ]); } 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 post({ required Uri url, Map? headers, Object? body, Encoding? encoding, required bool routeOverTor, }) async { final httpClient = HttpClient(); try { if (routeOverTor) { SocksTCPClient.assignToHttpClient(httpClient, [ ProxySettings( InternetAddress.loopbackIPv4, TorService.sharedInstance.port, ), ]); } 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); } } }