Search code examples
angularrxjses6-promiseangular-httpclientangular-httpclient-interceptors

Use a promise in Angular HttpClient Interceptor


Can I use promise within HttpInterceptor? For example:

export class AuthInterceptor implements HttpInterceptor{
this.someService.someFunction()
    .then((data)=>{
       //do something with data and then
       return next.handle(req);
    });
}

why I need this? because I need to get a token to add to request header before making the request to the server.

My interceptor:

@Injectable()
export class AuthInterceptor implements HttpInterceptor{

    constructor(private authService: AuthService){}

    intercept(req: HttpRequest<any>, next: HttpHandler) : Observable<HttpEvent<any>>{
        console.log('Intercepted!');
        // return next.handle(req);
        this.authService.getToken()
            .then((token)=>{
                console.log(token);
                const reqClone = req.clone({
                    headers: req.headers
                            .set('Authorization', 'Bearer ' + token)
                            .append('Content-Type', 'application/json')
                });
                console.log(reqClone);
                return next.handle(reqClone);
            })
            .catch((err)=>{
                console.log('error in interceptor' + err);
                return null;
            });
    }
}

Request:

this.http.post(this.baseURL + 'hero', data)
                    .subscribe(
                            (res: any) => {
                                console.log('Saved Successfully.');
                                console.log(res);
                            },
                            (err: any) => {
                                console.log('Save Error.' + err);
                            }
                        );

Problems I am facing:

->I get this error before the promise is resolved.

You provided 'undefined' where a stream was expected. You can provide an Observable, Promise, Array, or Iterable.

Promise resloves and I get my token but after the error.


Solution

  • UPDATE: using [email protected]

    import { from, Observable } from 'rxjs';
    import { switchMap } from 'rxjs/operators';
    
    @Injectable()
    export class AuthInterceptor implements HttpInterceptor {
    
        constructor(private authService: AuthService){}
    
        intercept(request: HttpRequest<any>, next: HttpHandler) : Observable<HttpEvent<any>>{
            return from(this.authService.getToken())
                  .pipe(
                    switchMap(token => {
                       const headers = request.headers
                                .set('Authorization', 'Bearer ' + token)
                                .append('Content-Type', 'application/json');
                       const requestClone = request.clone({
                         headers 
                        });
                      return next.handle(requestClone);
                    })
                   );
        }
    }
    

    ORIGINAL ANSWER

    Yes, you could inject the required service into the constructor method of the interceptor, and in the implementation of intercept retrieve the value, create a new updated http request and handle it.

    I'm not good with promises, so you could try the following:

    import { fromPromise } from 'rxjs/observable/fromPromise';
    
    @Injectable()
    export class AuthInterceptor implements HttpInterceptor{
    
        constructor(private authService: AuthService){}
    
        intercept(req: HttpRequest<any>, next: HttpHandler) : Observable<HttpEvent<any>>{
            return fromPromise(this.authService.getToken())
                  .switchMap(token => {
                       const headers = req.headers
                                .set('Authorization', 'Bearer ' + token)
                                .append('Content-Type', 'application/json');
                       const reqClone = req.clone({
                         headers 
                        });
                      return next.handle(reqClone);
                 });
        }
    }