Angular2 http " retry-Logik

Hatte ich etwas ähnliches in meinem letzten Projekt shafihuzaib/cdp-ng-boilerplate und landete auf diese Frage für meine Antwort. Ich konnte nicht gehen, für die oben vorgeschlagene Lösung, wie es fühlte sich kompliziert und etwas, was nicht wünschenswert ist. So kam ich zurück zu lassen, meine Lösung, nachdem ich implementiert ein. Allerdings mit dem Unterschied, dass in meinem Fall, ich hatte zwei dieser tokens.

So, wird jede Anforderung, die Bedürfnisse zu haben-Token' Gültigkeit überprüft, ist aufgerufen, in dieser Funktion.

tokenValidatedRequest(func): Observable<any>{
    let returnObservable = new Observable();

    /**
     * 1. check for auth token expiry - refresh it, if necessary
     */
    if( parseInt(localStorage.getItem('AUTH_TOKEN_EXPIRY')) < (new Date()).valueOf() ){
        //auth expired
        this.refresh().subscribe(res => {
            //refreshed
            //this.postAuthSuccess(res);

             returnObservable = func();

        })
    }
    else{
        //auth not expired

       returnObservable = func();

    }

    return returnObservable;
}

Das wichtigste hier ist, dass func() zurückgeben sollte eine Observable, so dass es verbraucht werden kann, entsprechend.

makeSomeHttpCall(){
   this.tokenValidatedRequest(()=>{
       return this.http.post(...);
   }). subscribe();
}

Es scheinen mag ein wenig kompliziert für jemand neues, aber ich bin sicher, es ist ein wenig effizienter.

In den folgenden links, bitte ignorieren Sie die details, die irrelevant für diese Frage und konzentrieren sich auf die Nutzung der vorgeschlagenen Lösung.

Die tatsächliche Implementierung von tokenValidatedRequest() in meinem Projekt.

 tokenValidatedRequest(func , tqlCheck = false): Observable<any>{
    /**
     * Delegate the actual task. However return an Observable, so as to execute 
     * the callback function only when subscribed to..
     */
    //return Observable.create(obs => obs = (this.__tokenValidatedRequest(func, tqlCheck)));

    return this.__tokenValidatedRequest(func, tqlCheck);
}
private __tokenValidatedRequest(func, tqlCheck = false): Observable<any>{
    let returnObservable = new Observable();

    /**
     * 1. check for auth token expiry - refresh it, if necessary
     * 2. after step 1 - check for TQL token expiry (if tqlCheck is true) - refresh it, if necessary
     * 3. 
     */
    if( parseInt(localStorage.getItem('AUTH_TOKEN_EXPIRY')) < (new Date()).valueOf() ){
        //auth expired
        this.refresh().subscribe(res => {
            //refreshed
            this.postAuthSuccess(res);

            if(tqlCheck &&  localStorage.getItem("TQL_TOKEN_EXPIRY") &&
                    parseInt(localStorage.getItem("TQL_TOKEN_EXPIRY")) < (new Date()).valueOf()
               ){

                this.activateUser().subscribe(res => {
                    //TQL token subscribed 
                    returnObservable = func();
                })
            }
            else{
                //Probably not a TQL request
                returnObservable = func();
            }
        })
    }
    else{
        //auth not expired

        //check if tql token has expired
        if(tqlCheck &&  localStorage.getItem("TQL_TOKEN_EXPIRY") &&
                    parseInt(localStorage.getItem("TQL_TOKEN_EXPIRY")) < (new Date()).valueOf()
               ){

                this.activateUser().subscribe(res => {
                    //TQL token subscribed 
                    returnObservable = func();
                })
            }
            else{
                //Probably not a TQL request or none of the tokens expired
                returnObservable = func();
            }
    }

    return returnObservable;
}

Wie ist es in anderen Dienstleistungen!

getAllParkingSpaces() : Observable<any> {
    let query = {
        Query: {
            ....
        }
    };

    return this.authService.tokenValidatedRequest(()=>{
        return this.api.post( CONFIG.api.engineUrl + 'devices/parking', query);
    }, true);
}

Wie ich endlich zu abonnieren!

    this.realTimeParkingService.getAllParkingSpaces().subscribe( r => {
  this.parkingSpaces = r;
});