#66 use async in Interceptor

src/app/app.module.ts

@@ -91,6 +91,6 @@ import {AuthService} from './core/auth-service';
 export class AppModule {
 
     constructor() {
-        localStorage.setItem('token', '11111');
+        // localStorage.setItem('token', '11111');
     }
 }

src/app/core/auth-service.ts

@@ -1,13 +1,25 @@
 import {Injectable} from '@angular/core';
+import {HttpClient} from '@angular/common/http';
 
 @Injectable()
 export class AuthService {
 
+
+    constructor(private http: HttpClient) {
+    }
+
     getToken(): string {
         return localStorage.getItem('token');
     }
 
     removeToken(): void {
         localStorage.removeItem('token');
     }
+
+    logic() {
+        return this.http.get('mock-data/user.json').map((res: any) => {
+            localStorage.setItem('token', res.token);
+            return res;
+        });
+    }
 }

src/app/core/token-interceptor.ts

@@ -1,5 +1,5 @@
 import {Injectable} from '@angular/core';
-import {HttpErrorResponse, HttpEvent, HttpHandler, HttpInterceptor, HttpRequest} from '@angular/common/http';
+import {HttpEvent, HttpHandler, HttpInterceptor, HttpRequest} from '@angular/common/http';
 import {AuthService} from './auth-service';
 import {Observable} from 'rxjs/Observable';
 import 'rxjs/add/operator/do';
@@ -10,25 +10,24 @@ export class TokenInterceptor implements HttpInterceptor {
     }
 
     intercept(request: HttpRequest<any>, next: HttpHandler): Observable<HttpEvent<any>> {
+        if (request.url === 'mock-data/user.json') {
+            return next.handle(request);
+        }
+
         if (this.authService.getToken()) {
             request = request.clone({
                 setHeaders: {
                     Authorization: `Bearer ${this.authService.getToken()}`
                 }
             });
+            return next.handle(request);
         }
-        return next.handle(request).do((event) => {
-                return event;
-            },
-            (err: any) => {
-                if (err instanceof HttpErrorResponse) {
-                    if (err.status === 401) {
-                        // this.authService.removeToken();
-                        // location.reload();
-                    }
+
+        return this.authService.logic().flatMap(() => {
+            return next.handle(request).do((event) => {
+                    return event;
                 }
-                return Observable.throw(err);
-            }
-        );
+            );
+        });
     }
 }

src/app/home/home.component.ts

@@ -78,9 +78,9 @@ export class HomeComponent implements OnInit {
         });
         this.test();
         console.log(this.quickSort([3, 1, 2, 4, 19, 4]));
-        this.getUsers().subscribe(res => {
-            console.log(res);
-        });
+        // this.getUsers().subscribe(res => {
+        //     console.log(res);
+        // });
     }
 
     getUsers() {

src/mock-data/user.json

@@ -0,0 +1,3 @@
+{
+  "token": "xxxxxx"
+}