This repository was archived by the owner on Nov 22, 2021. It is now read-only.
-
Notifications
You must be signed in to change notification settings - Fork 2
Expand file tree
/
Copy pathinterceptor_lock.dart
More file actions
86 lines (82 loc) · 2.75 KB
/
interceptor_lock.dart
File metadata and controls
86 lines (82 loc) · 2.75 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
import 'dart:async';
import 'package:dio_http/dio_http.dart';
void main() async {
var dio = Dio();
// dio instance to request token
var tokenDio = Dio();
String? csrfToken;
dio.options.baseUrl = 'http://www.dtworkroom.com/doris/1/2.0.0/';
tokenDio.options = dio.options;
dio.interceptors.add(InterceptorsWrapper(
onRequest: (options, handler) {
print('send request：path:${options.path}，baseURL:${options.baseUrl}');
if (csrfToken == null) {
print('no token，request token firstly...');
dio.lock();
//print(dio.interceptors.requestLock.locked);
tokenDio.get('/token').then((d) {
options.headers['csrfToken'] = csrfToken = d.data['data']['token'];
print('request token succeed, value: ' + d.data['data']['token']);
print(
'continue to perform request：path:${options.path}，baseURL:${options.path}');
handler.next(options);
}).catchError((error, stackTrace) {
handler.reject(error, true);
}).whenComplete(() => dio.unlock()); // unlock the dio
} else {
options.headers['csrfToken'] = csrfToken;
return handler.next(options);
}
},
onError: (error, handler) {
//print(error);
// Assume 401 stands for token expired
if (error.response?.statusCode == 401) {
var options = error.response!.requestOptions;
// If the token has been updated, repeat directly.
if (csrfToken != options.headers['csrfToken']) {
options.headers['csrfToken'] = csrfToken;
//repeat
dio.fetch(options).then(
(r) => handler.resolve(r),
onError: (e) {
handler.reject(e);
},
);
return;
}
// update token and repeat
// Lock to block the incoming request until the token updated
dio.lock();
dio.interceptors.responseLock.lock();
dio.interceptors.errorLock.lock();
tokenDio.get('/token').then((d) {
//update csrfToken
options.headers['csrfToken'] = csrfToken = d.data['data']['token'];
}).whenComplete(() {
dio.unlock();
dio.interceptors.responseLock.unlock();
dio.interceptors.errorLock.unlock();
}).then((e) {
//repeat
dio.fetch(options).then(
(r) => handler.resolve(r),
onError: (e) {
handler.reject(e);
},
);
});
return;
}
return handler.next(error);
},
));
FutureOr<void> _onResult(d) {
print('request ok!');
}
await Future.wait([
dio.get('/test?tag=1').then(_onResult),
dio.get('/test?tag=2').then(_onResult),
dio.get('/test?tag=3').then(_onResult)
]);
}