Здравствуйте!
Описание: находимся в AuthInterceptor, angular 6. Он перехватывает ошибку, пробует обновить токен, если получается, то добавляет header и пробует повторить запрос, иначе ДОЛЖЕН logout-ить юзера.
Статья, где описан код, почти один в один)
Когда срабатывает ошибка при первом запросе, то она ловится и удачно обрабатывается, т.е. пара токенов обновляется.
Но когда я в localStorage изменил refresh_token на рандомный текст, то соответственно refresh_token стал не валидным, сервер возвращает 505 ERROR, программа должна попасть в this.authS.refreshTokens().pipe( catchError ...) и logout-ить пользователя. Но ошибка происходит и в блок catchError программа не попадает.
Интересно, что код идет по второму кругу. Вот мой дебаг на коленках:
zone.js:2969 GET
http://localhost:4200/api/user 500 (Internal Server Error)
We're in catch block
Refresh tokens
POST
http://localhost:4200/api/token 500 (Internal Server Error)
We're in catch block
in progress
intercept(req: HttpRequest<any>, next: HttpHandler): Observable<HttpEvent<any>> {
return next.handle(req).pipe(
catchError(error => {
console.log("We're in catch block");
if (this.refreshTokenInProgress) {
console.log("in progress");
return this.refreshTokenSubject.pipe(
filter(value => value != null),
take(1),
switchMap(val => {
console.log("We finally got msg that token was updated");
return next.handle(this.authToken(req));
})
)
} else {
console.log("Refresh tokens");
this.refreshTokenInProgress = true;
this.refreshTokenSubject.next(null);
return this.authS.refreshTokens().pipe(
switchMap(tokens => {
console.log("We got a response!");
this.refreshTokenInProgress = false;
this.refreshTokenSubject.next(tokens);
// save tokens in localStorage
this.authS.saveTokens(tokens.access_token, tokens.refresh_token);
return next.handle(this.authToken(req));
}),
catchError(err => {
this.refreshTokenInProgress = false;
console.log("Refreshing tokens fails");
this.authS.logout();
return throwError(err);
})
)
}
})
);
}
authToken(request) {
const accessToken = this.authS.getAccessToken();
if (!accessToken) {
return request;
}
return request.clone({
setHeaders: {
Authorization: this.authS.getAccessToken()
}
})
}