Update client.ts

src/api/client.ts

@@ -1,8 +1,11 @@
 import axios, { AxiosError, InternalAxiosRequestConfig } from 'axios'
-import { tokenStorage, isTokenExpired } from '../utils/token'
+import { tokenStorage, isTokenExpired, tokenRefreshManager } from '../utils/token'
 
 const API_BASE_URL = import.meta.env.VITE_API_URL || '/api'
 
+// Настраиваем endpoint для refresh
+tokenRefreshManager.setRefreshEndpoint(`${API_BASE_URL}/cabinet/auth/refresh`)
+
 const getTelegramInitData = (): string | null => {
   if (typeof window === 'undefined') return null
 
@@ -22,62 +25,22 @@ export const apiClient = axios.create({
   },
 })
 
-// Флаг для предотвращения множественных refresh запросов
-let isRefreshing = false
-let refreshSubscribers: ((token: string) => void)[] = []
-
-const subscribeTokenRefresh = (cb: (token: string) => void) => {
-  refreshSubscribers.push(cb)
-}
-
-const onTokenRefreshed = (token: string) => {
-  refreshSubscribers.forEach((cb) => cb(token))
-  refreshSubscribers = []
-}
-
-const refreshAccessToken = async (): Promise<string | null> => {
-  const refreshToken = tokenStorage.getRefreshToken()
-  if (!refreshToken) return null
-
-  try {
-    const response = await axios.post(`${API_BASE_URL}/cabinet/auth/refresh`, {
-      refresh_token: refreshToken,
-    })
-
-    const { access_token } = response.data
-    tokenStorage.setAccessToken(access_token)
-    return access_token
-  } catch {
-    tokenStorage.clearTokens()
-    window.location.href = '/login'
-    return null
-  }
-}
-
 // Request interceptor - add auth token with expiration check
 apiClient.interceptors.request.use(async (config: InternalAxiosRequestConfig) => {
   let token = tokenStorage.getAccessToken()
 
   // Проверяем срок действия токена перед запросом
   if (token && isTokenExpired(token)) {
-    // Токен истёк или скоро истечёт - обновляем
+    // Используем централизованный менеджер для refresh
-    if (!isRefreshing) {
+    const newToken = await tokenRefreshManager.refreshAccessToken()
-      isRefreshing = true
-      const newToken = await refreshAccessToken()
-      isRefreshing = false
-
     if (newToken) {
       token = newToken
-        onTokenRefreshed(newToken)
     } else {
+      // Refresh не удался - редирект на логин
+      tokenStorage.clearTokens()
+      window.location.href = '/login'
       return config
     }
-    } else {
-      // Другой запрос уже обновляет токен - ждём
-      token = await new Promise<string>((resolve) => {
-        subscribeTokenRefresh(resolve)
-      })
-    }
   }
 
   if (token && config.headers) {
@@ -101,27 +64,16 @@ apiClient.interceptors.response.use(
     if (error.response?.status === 401 && !originalRequest._retry) {
       originalRequest._retry = true
 
-      if (!isRefreshing) {
+      const newToken = await tokenRefreshManager.refreshAccessToken()
-        isRefreshing = true
-        const newToken = await refreshAccessToken()
-        isRefreshing = false
-
       if (newToken) {
-          onTokenRefreshed(newToken)
         if (originalRequest.headers) {
           originalRequest.headers.Authorization = `Bearer ${newToken}`
         }
         return apiClient(originalRequest)
-        }
       } else {
-        // Ждём завершения refresh от другого запроса
+        // Refresh не удался
-        const token = await new Promise<string>((resolve) => {
+        tokenStorage.clearTokens()
-          subscribeTokenRefresh(resolve)
+        window.location.href = '/login'
-        })
-        if (originalRequest.headers) {
-          originalRequest.headers.Authorization = `Bearer ${token}`
-        }
-        return apiClient(originalRequest)
       }
     }