interceptor and polling has added

Author: rxzx

src/app/Providers/httpservice.ts

@@ -11,4 +11,22 @@ export class HTTPService {
   getData() {
     return this.http.get(`${this.baseUrl}assets/data/election.json`);
   }
+
+  startPolling() {
+    setTimeout(() => {
+      this.polling();
+    }, 1500);
+  }
+
+  polling() {
+    setTimeout(() => {
+      this.http.get(`${this.baseUrl}assets/data/election.json`)
+        .subscribe((response: any) => {
+          console.log("polling");
+          this.startPolling();
+        });
+    }, 2500);
+  }
+
+
 }

src/app/Providers/my-http-interceptor.ts

@@ -0,0 +1,31 @@
+import { Injectable } from "@angular/core";
+import { HttpRequest, HttpHandler, HttpEvent } from "@angular/common/http";
+import { Observable } from "rxjs/Rx";
+
+
+@Injectable()
+export class MyHttpInterceptor {
+    constructor(
+    ) { }
+
+    intercept(req: HttpRequest<any>, next: HttpHandler): Observable<HttpEvent<any>> {
+
+        console.log("intercepted request ... ");
+
+        // Clone the request to add the new header.
+        const authReq = req.clone({ headers: req.headers.set("headerName", "headerValue") });
+
+        console.log("Sending request with new header now ...");
+
+        //send the newly created request
+        return next.handle(authReq)
+            .catch((error, caught) => {
+                //intercept the respons error and displace it to the console
+                console.log("Error Occurred");
+                console.log(error);
+                //return the error to the method that called it
+                return Observable.throw(error);
+            }) as any;
+    }
+
+}

src/app/app.module.ts

@@ -1,5 +1,5 @@
 import { ToastrModule } from 'ngx-toastr';
-import { HttpClientModule, HttpClient } from '@angular/common/http';
+import { HttpClientModule, HttpClient, HTTP_INTERCEPTORS } from '@angular/common/http';
 import { BrowserModule } from '@angular/platform-browser';
 import { BrowserAnimationsModule } from '@angular/platform-browser/animations';
 import { NgModule, CUSTOM_ELEMENTS_SCHEMA } from '@angular/core';
@@ -11,6 +11,7 @@ import { PrivateModule } from './private/private.module';
 import { AlwaysAuthGuard, OnlyLoggedInUsersGuard } from './AlwaysAuthGuard ';
 import { LocationStrategy, HashLocationStrategy } from '@angular/common';
 import { StorageService } from './Providers/storageservice';
+import { MyHttpInterceptor } from './Providers/my-http-interceptor';
 @NgModule({
   declarations: [
     AppComponent
@@ -34,7 +35,8 @@ import { StorageService } from './Providers/storageservice';
     StorageService,
     AlwaysAuthGuard,
     OnlyLoggedInUsersGuard,
-    { provide: LocationStrategy, useClass: HashLocationStrategy }
+    { provide: LocationStrategy, useClass: HashLocationStrategy },
+    { provide: HTTP_INTERCEPTORS, useClass: MyHttpInterceptor,  multi: true }
   ],
   bootstrap: [AppComponent],
   schemas: [

src/app/private/private.component.ts

@@ -1,3 +1,4 @@
+import { HTTPService } from './../Providers/httpservice';
 import { Component, OnInit } from '@angular/core';
 
 @Component({
@@ -7,9 +8,12 @@ import { Component, OnInit } from '@angular/core';
 })
 export class PrivateComponent implements OnInit {
 
-  constructor() { }
+  constructor(
+    private http: HTTPService
+  ) { }
 
   ngOnInit() {
+    // this.http.startPolling();
   }
 
 }