retry interceptor added

Author: actionanand

src/app/services/retry.interceptor.ts

@@ -0,0 +1,26 @@
+import { HttpErrorResponse, HttpHandlerFn, HttpInterceptorFn, HttpRequest } from '@angular/common/http';
+import { retry, timer } from 'rxjs';
+
+const maxRetries = 3;
+const delayMs = 2000;
+
+export const RetryInterceptor: HttpInterceptorFn = (req: HttpRequest<unknown>, next: HttpHandlerFn) => {
+  return next(req).pipe(
+    retry({
+      count: maxRetries,
+      delay: (error: HttpErrorResponse, retryCount) => {
+        if (error.status == 401) {
+          console.log(req.url, ' : 401 retrying...', retryCount);
+          return timer(delayMs);
+        } else if (error.status >= 500) {
+          console.log(req.url, ' : 500 retrying...', retryCount);
+          return timer(delayMs);
+        } else {
+          console.log(`${req.url} : ${error.status} retrying... ${retryCount}`);
+          return timer(delayMs);
+        }
+        throw error;
+      },
+    }),
+  );
+};

src/main.ts

@@ -2,18 +2,13 @@ import { bootstrapApplication } from '@angular/platform-browser';
 import { HttpHandlerFn, HttpRequest, provideHttpClient, withInterceptors } from '@angular/common/http';
 
 import { AppComponent } from './app/app.component';
+import { RetryInterceptor } from './app/services/retry.interceptor';
 
 function loggingInterceptor(req: HttpRequest<unknown>, next: HttpHandlerFn) {
-  /*
-  const newReq = req.clone({
-    headers: req.headers.set('new-Header', 'headerValue')
-  });
-  */
-
   console.log('Interceptor: ', req);
   return next(req);
 }
 
 bootstrapApplication(AppComponent, {
-  providers: [provideHttpClient(withInterceptors([loggingInterceptor]))],
+  providers: [provideHttpClient(withInterceptors([loggingInterceptor, RetryInterceptor]))],
 }).catch(err => console.error(err));