wehub-resource-sync
87 lines
2.3 KiB
Dart
87 lines
2.3 KiB
Dart
import 'package:common/isolate.dart';
|
|
import 'package:common/model/stored_security_context.dart';
|
|
import 'package:rhttp/rhttp.dart';
|
|
|
|
class RhttpWrapper implements CustomHttpClient {
|
|
final RhttpClient _client;
|
|
|
|
RhttpWrapper._(this._client);
|
|
|
|
factory RhttpWrapper.create(Duration timeout, StoredSecurityContext securityContext) {
|
|
final client = createRhttpClient(timeout, securityContext);
|
|
return RhttpWrapper._(client);
|
|
}
|
|
|
|
@override
|
|
Future<String> get({
|
|
required String uri,
|
|
required Map<String, String> query,
|
|
}) async {
|
|
final response = await _client.get(
|
|
uri,
|
|
query: query,
|
|
);
|
|
return response.body;
|
|
}
|
|
|
|
@override
|
|
Future<String> post({
|
|
required String uri,
|
|
Map<String, String> query = const {},
|
|
required Map<String, dynamic> json,
|
|
}) async {
|
|
final response = await _client.post(
|
|
uri,
|
|
query: query,
|
|
body: HttpBody.json(json),
|
|
);
|
|
return response.body;
|
|
}
|
|
|
|
@override
|
|
Future<void> postStream({
|
|
required String uri,
|
|
required Map<String, String> query,
|
|
required Map<String, String> headers,
|
|
required Stream<List<int>> stream,
|
|
required void Function(double progress) onSendProgress,
|
|
required CustomCancelToken cancelToken,
|
|
}) async {
|
|
final token = CancelToken();
|
|
cancelToken.setCancel(token.cancel);
|
|
await _client.request(
|
|
method: HttpMethod.post,
|
|
expectBody: HttpExpectBody.bytes,
|
|
url: uri,
|
|
query: query,
|
|
headers: HttpHeaders.rawMap(headers),
|
|
body: HttpBody.stream(
|
|
stream,
|
|
length: int.parse(headers['Content-Length']!),
|
|
),
|
|
onSendProgress: (curr, total) {
|
|
onSendProgress(curr / total);
|
|
},
|
|
cancelToken: token,
|
|
);
|
|
}
|
|
}
|
|
|
|
RhttpClient createRhttpClient(Duration timeout, StoredSecurityContext securityContext, {Interceptor? interceptor}) {
|
|
return RhttpClient.createSync(
|
|
settings: ClientSettings(
|
|
timeoutSettings: TimeoutSettings(
|
|
timeout: timeout,
|
|
),
|
|
tlsSettings: TlsSettings(
|
|
verifyCertificates: false,
|
|
clientCertificate: ClientCertificate(
|
|
certificate: securityContext.certificate,
|
|
privateKey: securityContext.privateKey,
|
|
),
|
|
),
|
|
),
|
|
interceptors: interceptor != null ? [interceptor] : [],
|
|
);
|
|
}
|