axios instance setup for logout and new access token

Author: Srihari62

apps/user-ui/src/utils/axiosInstance.ts

@@ -0,0 +1,73 @@
+import axios from "axios";
+
+const axiosInstance = axios.create({
+  baseURL: process.env.NEXT_PUBLIC_SERVER_URI,
+  withCredentials: true,
+});
+
+let isRefreshing = false;
+let refreshSubscribers: (() => void)[] = [];
+
+//Handle logout and prevent infinite loops
+
+const handleLogout = () => {
+  if (window.location.pathname !== "/login") {
+    window.location.href = "/login";
+  }
+};
+
+//handle adding a new access token to queued requests
+
+const subscribeTokenRefresh = (callback: () => void) => {
+  refreshSubscribers.push(callback);
+};
+
+//execute queued request after refresh
+const onRefreshSuccess = () => {
+  refreshSubscribers.forEach((callback) => callback());
+  refreshSubscribers = [];
+};
+
+//Handle Api requests
+axiosInstance.interceptors.request.use(
+  (config) => config,
+  (error) => Promise.reject(error)
+);
+
+// Handle expired Tokens and refresah logic
+axiosInstance.interceptors.response.use(
+  (response) => response,
+  async (error) => {
+    const originalRequest = error.config;
+
+    //prevent infinite loop
+    if (error.response?.status === 401 && !originalRequest._retry) {
+      if (isRefreshing) {
+        return new Promise((resolve) => {
+          subscribeTokenRefresh(() => resolve(axiosInstance(originalRequest)));
+        });
+      }
+
+      originalRequest._retry = true;
+      isRefreshing = true;
+      try {
+        await axios.post(
+          `${process.env.NEXT_PUBLIC_SERVER_URI}/auth/api/refresh-token-user`,
+          {},
+          { withCredentials: true }
+        );
+
+        isRefreshing = false;
+        onRefreshSuccess();
+
+        return axiosInstance(originalRequest);
+      } catch (error) {
+        isRefreshing = false;
+        refreshSubscribers = [];
+        handleLogout();
+        return Promise.reject(error);
+      }
+    }
+    return Promise.reject(error);
+  }
+);