import { Injectable } from "@angular/core";

import { HttpInterceptor, HttpRequest, HttpHandler, HttpEvent, HttpHeaders } from "@angular/common/http";

import { Observable, throwError, BehaviorSubject } from "rxjs";

import { catchError, filter, take, switchMap } from "rxjs/operators";

import { AuthService } from "./services/auth.service";

@Injectable()

export class ErrorInterceptor implements HttpInterceptor {

private refreshTokenSubject: BehaviorSubject<any> = new BehaviorSubject<any>(

null

);

constructor(private auth: AuthService) {

}

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

let accToken;

return next.handle(request).pipe(catchError(err => {

if (err["error"]["error"] === "invalid_token") {

this.auth.refreshToken().subscribe(data => {

this.refreshTokenSubject.next(data["access_token"]);

console.log('access_token:'+JSON.stringify(this.refreshTokenSubject['_value']));

})

// add authorization header with jwt token if available

request = request.clone({

setHeaders: {

Authorization: `Bearer ${JSON.stringify(this.refreshTokenSubject['_value'])}`

}

});

return next.handle(request);

}

if (err.status === 401) {

// auto logout if 401 response returned from api

// location.reload(true);

}

const error = err.error.message || err.statusText;

return throwError(error);

}))

}

}