|
|
|
|
@ -77,11 +77,7 @@ class ApiClient {
|
|
|
|
|
print("Url:$url");
|
|
|
|
|
print("body:${jsonEncode(jsonObject)}");
|
|
|
|
|
}
|
|
|
|
|
var response = await postJsonForResponse(url, jsonObject, token: token,
|
|
|
|
|
queryParameters: queryParameters,
|
|
|
|
|
headers: _headers,
|
|
|
|
|
retryTimes: retryTimes,
|
|
|
|
|
isPutRequest: isPutRequest);
|
|
|
|
|
var response = await postJsonForResponse(url, jsonObject, token: token, queryParameters: queryParameters, headers: _headers, retryTimes: retryTimes, isPutRequest: isPutRequest);
|
|
|
|
|
try {
|
|
|
|
|
var jsonData = jsonDecode(response.body);
|
|
|
|
|
return factoryConstructor(jsonData);
|
|
|
|
|
@ -102,11 +98,7 @@ class ApiClient {
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
return await _postForResponse(url, requestBody, token: token,
|
|
|
|
|
queryParameters: queryParameters,
|
|
|
|
|
headers: headers,
|
|
|
|
|
retryTimes: retryTimes,
|
|
|
|
|
isPutRequest: isPutRequest);
|
|
|
|
|
return await _postForResponse(url, requestBody, token: token, queryParameters: queryParameters, headers: headers, retryTimes: retryTimes, isPutRequest: isPutRequest);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
Future<Response> _postForResponse(String url, requestBody, {String token, Map<String, dynamic> queryParameters, Map<String, String> headers, int retryTimes = 0, bool isPutRequest = false}) async {
|
|
|
|
|
@ -135,11 +127,7 @@ class ApiClient {
|
|
|
|
|
if (retryTimes > 0) {
|
|
|
|
|
print('will retry after 3 seconds...');
|
|
|
|
|
await Future.delayed(Duration(seconds: 3));
|
|
|
|
|
return await _postForResponse(url, requestBody, token: token,
|
|
|
|
|
queryParameters: queryParameters,
|
|
|
|
|
headers: headers,
|
|
|
|
|
retryTimes: retryTimes - 1,
|
|
|
|
|
isPutRequest: isPutRequest);
|
|
|
|
|
return await _postForResponse(url, requestBody, token: token, queryParameters: queryParameters, headers: headers, retryTimes: retryTimes - 1, isPutRequest: isPutRequest);
|
|
|
|
|
} else {
|
|
|
|
|
throw APIException(APIException.OTHER, arguments: e);
|
|
|
|
|
}
|
|
|
|
|
@ -147,11 +135,7 @@ class ApiClient {
|
|
|
|
|
if (retryTimes > 0) {
|
|
|
|
|
print('will retry after 3 seconds...');
|
|
|
|
|
await Future.delayed(Duration(seconds: 3));
|
|
|
|
|
return await _postForResponse(url, requestBody, token: token,
|
|
|
|
|
queryParameters: queryParameters,
|
|
|
|
|
headers: headers,
|
|
|
|
|
retryTimes: retryTimes - 1,
|
|
|
|
|
isPutRequest: isPutRequest);
|
|
|
|
|
return await _postForResponse(url, requestBody, token: token, queryParameters: queryParameters, headers: headers, retryTimes: retryTimes - 1, isPutRequest: isPutRequest);
|
|
|
|
|
} else {
|
|
|
|
|
throw APIException(APIException.OTHER, arguments: e);
|
|
|
|
|
}
|
|
|
|
|
@ -161,11 +145,7 @@ class ApiClient {
|
|
|
|
|
if (retryTimes > 0) {
|
|
|
|
|
print('will retry after 3 seconds...');
|
|
|
|
|
await Future.delayed(Duration(seconds: 3));
|
|
|
|
|
return await _postForResponse(url, requestBody, token: token,
|
|
|
|
|
queryParameters: queryParameters,
|
|
|
|
|
headers: headers,
|
|
|
|
|
retryTimes: retryTimes - 1,
|
|
|
|
|
isPutRequest: isPutRequest);
|
|
|
|
|
return await _postForResponse(url, requestBody, token: token, queryParameters: queryParameters, headers: headers, retryTimes: retryTimes - 1, isPutRequest: isPutRequest);
|
|
|
|
|
} else {
|
|
|
|
|
throw APIException(APIException.OTHER, arguments: e);
|
|
|
|
|
}
|
|
|
|
|
@ -175,8 +155,7 @@ class ApiClient {
|
|
|
|
|
bool _certificateCheck(X509Certificate cert, String host, int port) => true;
|
|
|
|
|
|
|
|
|
|
Future<T> _withClient<T>(Future<T> Function(Client) fn) async {
|
|
|
|
|
var httpClient = HttpClient()
|
|
|
|
|
..badCertificateCallback = _certificateCheck;
|
|
|
|
|
var httpClient = HttpClient()..badCertificateCallback = _certificateCheck;
|
|
|
|
|
var client = IOClient(httpClient);
|
|
|
|
|
try {
|
|
|
|
|
return await fn(client);
|
|
|
|
|
@ -185,12 +164,92 @@ class ApiClient {
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
Future<Response> _post(url, {Map<String, String> headers, body, Encoding encoding, bool isPutRequest = false}) =>
|
|
|
|
|
_withClient((client) {
|
|
|
|
|
Future<Response> _post(url, {Map<String, String> headers, body, Encoding encoding, bool isPutRequest = false}) => _withClient((client) {
|
|
|
|
|
if (isPutRequest) {
|
|
|
|
|
return client.put(url, headers: headers, body: body, encoding: encoding);
|
|
|
|
|
} else {
|
|
|
|
|
return client.post(url, headers: headers, body: body, encoding: encoding);
|
|
|
|
|
}
|
|
|
|
|
});
|
|
|
|
|
|
|
|
|
|
Future<U> getJsonForObject<T, U>(FactoryConstructor<U> factoryConstructor, String url, {String token, Map<String, dynamic> queryParameters, Map<String, String> headers, int retryTimes = 0}) async {
|
|
|
|
|
var _headers = {'Accept': 'application/json'};
|
|
|
|
|
if (headers != null && headers.isNotEmpty) {
|
|
|
|
|
_headers.addAll(headers);
|
|
|
|
|
}
|
|
|
|
|
if (!kReleaseMode) {
|
|
|
|
|
print("Url:$url");
|
|
|
|
|
}
|
|
|
|
|
var response = await getJsonForResponse(url, token: token, queryParameters: queryParameters, headers: _headers, retryTimes: retryTimes);
|
|
|
|
|
try {
|
|
|
|
|
var jsonData = jsonDecode(response.body);
|
|
|
|
|
return factoryConstructor(jsonData);
|
|
|
|
|
} catch (ex) {
|
|
|
|
|
throw APIException(APIException.BAD_RESPONSE_FORMAT, arguments: ex);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
Future<Response> getJsonForResponse<T>(String url, {String token, Map<String, dynamic> queryParameters, Map<String, String> headers, int retryTimes = 0}) async {
|
|
|
|
|
headers = {'Content-Type': 'application/json'};
|
|
|
|
|
|
|
|
|
|
return await _getForResponse(url, token: token, queryParameters: queryParameters, headers: headers, retryTimes: retryTimes);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
Future<Response> _getForResponse(String url, {String token, Map<String, dynamic> queryParameters, Map<String, String> headers, int retryTimes = 0}) async {
|
|
|
|
|
try {
|
|
|
|
|
var _headers = <String, String>{};
|
|
|
|
|
if (token != null) {
|
|
|
|
|
_headers['Authorization'] = 'Bearer $token';
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
if (headers != null && headers.isNotEmpty) {
|
|
|
|
|
_headers.addAll(headers);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
if (queryParameters != null) {
|
|
|
|
|
var queryString = new Uri(queryParameters: queryParameters).query;
|
|
|
|
|
url = url + '?' + queryString;
|
|
|
|
|
}
|
|
|
|
|
var response = await _get(
|
|
|
|
|
Uri.parse(url),
|
|
|
|
|
headers: _headers,
|
|
|
|
|
).timeout(Duration(minutes: 2));
|
|
|
|
|
|
|
|
|
|
if (response.statusCode >= 200 && response.statusCode < 300) {
|
|
|
|
|
return response;
|
|
|
|
|
} else {
|
|
|
|
|
throw _throwAPIException(response);
|
|
|
|
|
}
|
|
|
|
|
} on SocketException catch (e) {
|
|
|
|
|
if (retryTimes > 0) {
|
|
|
|
|
print('will retry after 3 seconds...');
|
|
|
|
|
await Future.delayed(Duration(seconds: 3));
|
|
|
|
|
return await _getForResponse(url, token: token, queryParameters: queryParameters, headers: headers, retryTimes: retryTimes - 1);
|
|
|
|
|
} else {
|
|
|
|
|
throw APIException(APIException.OTHER, arguments: e);
|
|
|
|
|
}
|
|
|
|
|
} on HttpException catch (e) {
|
|
|
|
|
if (retryTimes > 0) {
|
|
|
|
|
print('will retry after 3 seconds...');
|
|
|
|
|
await Future.delayed(Duration(seconds: 3));
|
|
|
|
|
return await _getForResponse(url, token: token, queryParameters: queryParameters, headers: headers, retryTimes: retryTimes - 1);
|
|
|
|
|
} else {
|
|
|
|
|
throw APIException(APIException.OTHER, arguments: e);
|
|
|
|
|
}
|
|
|
|
|
} on TimeoutException catch (e) {
|
|
|
|
|
throw APIException(APIException.TIMEOUT, arguments: e);
|
|
|
|
|
} on ClientException catch (e) {
|
|
|
|
|
if (retryTimes > 0) {
|
|
|
|
|
print('will retry after 3 seconds...');
|
|
|
|
|
await Future.delayed(Duration(seconds: 3));
|
|
|
|
|
return await _getForResponse(url, token: token, queryParameters: queryParameters, headers: headers, retryTimes: retryTimes - 1);
|
|
|
|
|
} else {
|
|
|
|
|
throw APIException(APIException.OTHER, arguments: e);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
Future<Response> _get(url, {Map<String, String> headers}) => _withClient((client) {
|
|
|
|
|
return client.get(url, headers: headers);
|
|
|
|
|
});
|
|
|
|
|
}
|
|
|
|
|
|