RXJS / Angular Заменить наблюдаемый - PullRequest
Новая
       28

RXJS / Angular Заменить наблюдаемый

0 голосов
/ 04 апреля 2020

В перехватчике angular я хочу проверить, существует ли токен авторизации. Если нет, его следует обновить и запрос следует отправить повторно. 

return next.handle(authReq).pipe(map((result: any) => {
  if (result.body && result.body.error) {
    if (result.body.error === 'ERR_TOKEN_EXPIRED' || result.body.error === 'ERR_TOKENS_DO_NOT_MATCH') {
      console.log('Token is expired or invalid, refreshing.', result.body.error);

      return this.userService.refreshLoginToken().subscribe(success => {
        if (success) {
          return this.intercept(req, next);
        }
      });
    }
  }
  return result;
}));

Проблема заключается в том, что я не знаю, как заменить исходный Observable, возвращаемый функцией next.handle (), на новый. Оператор return до this.userService.refreshLoginToken().subscribe() возвращает объект подписки. Если я просто передам результат refreshLoginToken(), он не будет работать, потому что refreshLoginToken отправляет httprequest, который выполняется только при наличии подписки.

Чтобы свести вопрос к одной строке: как заменить возвращаемое наблюдаемое в строке 1 функцией next.handle () с возвращенной this.intercept(req, next)?

Спасибо!

1 Ответ

1 голос
/ 04 апреля 2020

Я думаю, вы должны сделать это немного по-другому.

, пожалуйста, посмотрите пример ниже и самую последнюю версию switchMap: 

import {HttpEvent, HttpHandler, HttpInterceptor, HttpRequest} from '@angular/common/http';
import {Injectable} from '@angular/core';
import {StoreState} from '@core/store';
import {select, Store} from '@ngrx/store';
import {getAuthToken} from '@v2/core/store/auth/auth.reducer';
import {iif, Observable, of} from 'rxjs';
import {switchMap, take} from 'rxjs/operators';

@Injectable()
export class AuthInterceptor implements HttpInterceptor {
    constructor(protected readonly store: Store<StoreState>) {}

    public intercept(request: HttpRequest<void>, next: HttpHandler): Observable<HttpEvent<void>> {
        return this.store.pipe(
            select(getAuthToken),
            take(1),
            switchMap(token =>
                iif(
                    () => !token,
                    of(request),
                    of(
                        request.clone({
                            setHeaders: {
                                Authorization: `Bearer ${token?.accessToken}`,
                            },
                        }),
                    ),
                ),
            ),
            switchMap(clonedRequest => next.handle(clonedRequest)),
        );
    }
}
...