HttpInterceptor wiederholen in Angular 4.3

Question

Ich versuche, meinen ersten Code 401 Fehler mit HttpInterceptor zu fangen. Was ich tun möchte, hängt von einer Bedingung ab, die ein neues Authentifizierungs-Token erstellt und dann erneut versucht. Aber derzeit macht mein Code die Wiederholung, aber es tut es, bevor das neue Authentifizierungs-Token erstellt wurde. Hier ist mein Code:

intercept(request: HttpRequest<any>, next: HttpHandler): Observable<any> { 

    return next.handle(request).catch(error => { 

     if (error.status === 401) { 

      console.log('401 error'); 

      //check for valid refresh token 
      let refreshToken = localStorage.getItem('refresh_token'); 

      this._refreshTokenService.getRefreshToken(refreshToken).subscribe(
       refreshToken => { 
        if (refreshToken != null) { 

         console.log('valid refresh token') 

         //if valid refresh token, relogin and create new auth token 
         console.log(localStorage.getItem('auth_token')); 

         this._userService.logout(); 

         let email = localStorage.getItem('profile_email'); 

         this._userService.autoLogin(email) 
          .subscribe(
          result => { 
           if (result) { 
            console.log('new auth token created'); 

            let auth_token = localStorage.getItem('auth_token'); 

            //retry 
            request = request.clone({ headers: request.headers.set('Authorization', `Bearer ${auth_token}`) }); 
           } 
          }); 


        } 
        else { 
         console.log('invalid refresh token'); 
        } 
       }); 
      return next.handle(request); 
     } 
     else { 
      console.log(error.status); 
     } 
    }); 
} 

Ich bin immer noch vertraut mit Typoskript Syntax immer, ich glaube, ich brauche die Wiederholung nur zu machen, auftritt, nachdem die neuen Token erstellt wurden, aber ich bin mir nicht sicher über die genaue Syntax in diesem Fall. Jede Hilfe würde sehr geschätzt werden!

Answer 1

Sorry ich kann nicht in den Kommentaren antworten. Ich denke, hier geht es darum, Observable zu verketten.

Grundsätzlich alles, was Sie anrufen, bevor Ihre letzte return next.handle(request); verarbeitet wird, bevor eckig machen Sie Ihren http-Aufruf. Nur dass alles innerhalb this._refreshTokenService.getRefreshToken(refreshToken).subsribe() asynchron verarbeitet wird.

sollten Sie ketten Ihre beobachtbare wie folgt aus:

intercept(request: HttpRequest<any>, next: HttpHandler): Observable<any> { 
    return next.handle(request).catch(error => { 
     return this._refreshTokenService.getRefreshToken(refreshToken).subscribe(
      refreshToken => { 
       return next.handle(request); 
      } 
     ); 
    }); 
}