EchoZenith/PiliPlus
1
0
Fork 0
mirror of https://github.com/bggRGjQaUbCoE/PiliPlus.git synced 2026-07-12 04:10:12 +08:00
Code Issues Packages Projects Releases Wiki Activity

opt: post redirect (#788)

Browse Source 
* opt: cookie

* opt: post redirect
This commit is contained in:
My-Responsitories
2025-05-01 10:08:48 +08:00
committed by GitHub
parent a46bde68f5
commit c090cae1a1
5 changed files with 68 additions and 67 deletions
Download Patch File Download Diff File Expand all files Collapse all files

68
lib/http/retry_interceptor.dart
View File

@@ -10,26 +10,56 @@ class RetryInterceptor extends Interceptor {
@override
void onError(DioException err, ErrorInterceptorHandler handler) {
if (err.response != null) return handler.next(err);
switch (err.type) {
case DioExceptionType.connectionError:
case DioExceptionType.connectionTimeout:
case DioExceptionType.sendTimeout:
case DioExceptionType.unknown:
if ((err.requestOptions.extra['_rt'] ??= 0) < _count) {
Future.delayed(
Duration(
milliseconds: ++err.requestOptions.extra['_rt'] * _delay),
() => Request.dio
.fetch(err.requestOptions)
.then(handler.resolve)
.onError<DioException>((error, _) => handler.reject(error)));
} else {
handler.next(err);
if (err.response != null) {
final options = err.requestOptions;
if (options.followRedirects && options.maxRedirects > 0) {
final status = err.response!.statusCode;
if (status != null && 300 <= status && status < 400) {
var redirectUrl = err.response!.headers.value('location');
if (redirectUrl != null) {
var uri = Uri.parse(redirectUrl);
if (!uri.hasScheme) {
uri = options.uri.resolveUri(uri);
redirectUrl = uri.toString();
}
(options..path = redirectUrl).maxRedirects--;
if (status == 303) {
options.data = null;
options.method = 'GET';
}
Request.dio
.fetch(options)
.then((i) => handler.resolve(i
..redirects.add(RedirectRecord(status, options.method, uri))
..isRedirect = true))
.onError<DioException>((error, _) => handler.next(error));
return;
}
}
return;
default:
return handler.next(err);
}
return handler.next(err);
} else {
switch (err.type) {
case DioExceptionType.connectionError:
case DioExceptionType.connectionTimeout:
case DioExceptionType.sendTimeout:
case DioExceptionType.unknown:
if ((err.requestOptions.extra['_rt'] ??= 0) < _count) {
Future.delayed(
Duration(
milliseconds: ++err.requestOptions.extra['_rt'] * _delay),
() => Request.dio
.fetch(err.requestOptions)
.then(handler.resolve)
.onError<DioException>(
(error, _) => handler.reject(error)));
} else {
handler.next(err);
}
return;
default:
return handler.next(err);
}
}
}
}