Angular: обновление JWT с эффектом NgRx - PullRequest
Новая
       7

Angular: обновление JWT с эффектом NgRx

0 голосов
/ 02 сентября 2018

Я хотел бы адаптировать этот код для проекта Angular, используя эффект NgRx для обработки обновления JWT. Но я застреваю с наблюдаемыми, так как токен обновляется только один раз, потому что timer завершается в первый раз. Я также пытался с оператором delay, но поскольку он не создает наблюдаемого, я не знаю, как реализовать его в этом потоке. Какие-нибудь мысли? Thanx! 

// auth.effects.ts

@Effect()
renewJWT$: Observable<Action> = this.actions$.pipe(
  ofType(ActionTypes.RenewJWT),
  filter(() => this.authService.isLoggedIn()),
  concatMap(() =>
    this.authService.renewJWT().pipe(
      map(() => new ScheduleJWTRenewalAction())
    )
  )
);

@Effect()
scheduleJWTRenewal$: Observable<Action> = this.actions$.pipe(
  ofType(
    ROOT_EFFECTS_INIT,
    ActionTypes.SigninSuccess,
    ActionTypes.ScheduleJWTRenewal
  ),
  takeUntil(this.actions$.pipe(ofType(ActionTypes.Logout))),
  map(() => Date.parse(this.authService.session.expiresAt) - Date.now()),
  filter((remainingTime: number) => remainingTime > 0),
  concatMap((remainingTime: number) =>
    timer(Math.max(remainingTime, 1)).pipe(
      map(() => new RenewJWTAction())
    )
  )
);

1 Ответ

0 голосов
/ 16 сентября 2018

Таймер

подпись: таймер (initialDelay: число | Дата, период: число, планировщик: Scheduler): наблюдаемый

По истечении заданной длительности генерировать числа в последовательности каждый указанный длительность.

Если period не указан, timer будет излучать один раз и завершать. 

takeUntil(this.actions$.pipe(ofType(ActionTypes.Logout))),

После выхода пользователя из системы scheduleJWTRenewal$ поток завершится. Возможно ли пользователю войти снова? )

Лучше заменить takeUntil на filter.

...