Остановите трубу посередине
В моем угловом приложении у меня есть перехватчик обновления токена, который перехватывает ошибки 401-Unauthorized, пытается обновить токен доступа и снова выполнять исходный http-запрос.
В некоторых случаях конечная точка обновления токена также может дать сбой и вернуть известную ошибку (в моем случае это ошибка 400 invalid_grant).
Часть перехватчика, которая обновляет токен:
return this.httpClient
.request('POST', "token", { observe: 'response' })
.pipe(
map(response => {
// some logic when the token was refreshed successfully
}),
catchError(err => {
this.routingService.navigateToLoginNoQuery();
return throwError(err); // a 400 - invalid_grant error
})
);
Когда это происходит, он переходит к оператору catchError, который выполняет 2 действия: выходит из системы (с перенаправлением на страницу входа в систему) и возвращает throwError (ошибка). Эта ошибка, которую он выдает, является ошибкой 400-Invalid_grant.
Это приводит к тому, что новая ошибка поступает к некоторым операторам catchError в функциях, которые первоначально активировали токен обновления.
Просто для контекста: Я регистрирую ошибки в блоках catch и хочу избежать регистрации таких ошибок, потому что обычно они означают только то, что срок действия токена пользователя истек.
Что я хотел бы сделать, так это как-то остановить эту цепочку операторов и просто перенаправить на страницу входа.
Можно ли остановить канал посередине и избежать как внешнего catchError, так и следующего оператора в канале?
Ответы 2
Вы можете вернуть пустой Observable, чтобы события или ошибки не достигли компонента, который будет уничтожен:
return this.httpClient
.request('POST', "token", { observe: 'response' })
.pipe(
map(response => {
// some logic when the token was refreshed successfully
}),
catchError(err => {
this.routingService.navigateToLoginNoQuery();
return EMPTY;
})
);
Кое-что об этом я писал здесь: stackoverflow.com/questions/59653696/… Короче говоря, риск действительно есть, поэтому нужно убедиться, что вы отписались в нужный момент.
Если я правильно понял вопрос, то, возможно, вам поможет оператор takeUntil. Пример будет выглядеть примерно так:
export class MyHttpInterceptor implements HttpInterceptor {
anyError = new Subject();
intercept(req: HttpRequest, next: HttpHandler): Observable<HttpEvent<any>> {
return next.handle(req)
.pipe(
takeUntil(this.anyError),
catchError(err => {
this.anyError.next();
...
}
)
}
}
Спасибо, не пробовал (потому что у меня сработало возвращение EMPTY), но не уверен, что это поможет в моей ситуации.
Но я не уверен, что произойдет, если наблюдаемый объект будет находиться внутри службы с корневым внедрением, которая не будет уничтожена. Я имею в виду, ПУСТО приведет к тому, что наблюдаемое никогда не завершится? Может ли это вызвать утечку памяти?