mirror of
https://github.com/chillpadclub/bedolaga-cabinet.git
synced 2026-07-28 09:33:46 +00:00
Update auth.ts
This commit is contained in:
@@ -36,8 +36,12 @@ interface AuthState {
|
|||||||
}
|
}
|
||||||
|
|
||||||
// Блокировка для предотвращения race condition при инициализации
|
// Блокировка для предотвращения race condition при инициализации
|
||||||
let initializePromise: Promise<void> | null = null
|
// Используем объект для атомарности операций
|
||||||
let isInitializing = false
|
const initState = {
|
||||||
|
promise: null as Promise<void> | null,
|
||||||
|
isInitializing: false,
|
||||||
|
isInitialized: false,
|
||||||
|
}
|
||||||
|
|
||||||
export const useAuthStore = create<AuthState>()(
|
export const useAuthStore = create<AuthState>()(
|
||||||
persist(
|
persist(
|
||||||
@@ -69,8 +73,8 @@ export const useAuthStore = create<AuthState>()(
|
|||||||
logout: () => {
|
logout: () => {
|
||||||
const { refreshToken } = get()
|
const { refreshToken } = get()
|
||||||
if (refreshToken) {
|
if (refreshToken) {
|
||||||
authApi.logout(refreshToken).catch((error) => {
|
authApi.logout(refreshToken).catch(() => {
|
||||||
console.error('[Auth] Logout API call failed:', error)
|
// Logout API call failed - ignore silently
|
||||||
})
|
})
|
||||||
}
|
}
|
||||||
tokenStorage.clearTokens()
|
tokenStorage.clearTokens()
|
||||||
@@ -93,8 +97,7 @@ export const useAuthStore = create<AuthState>()(
|
|||||||
// Используем apiClient для единообразной обработки ошибок
|
// Используем apiClient для единообразной обработки ошибок
|
||||||
const response = await apiClient.get<{ is_admin: boolean }>('/cabinet/auth/me/is-admin')
|
const response = await apiClient.get<{ is_admin: boolean }>('/cabinet/auth/me/is-admin')
|
||||||
set({ isAdmin: response.data.is_admin })
|
set({ isAdmin: response.data.is_admin })
|
||||||
} catch (error) {
|
} catch {
|
||||||
console.error('[Auth] Failed to check admin status:', error)
|
|
||||||
set({ isAdmin: false })
|
set({ isAdmin: false })
|
||||||
}
|
}
|
||||||
},
|
},
|
||||||
@@ -103,19 +106,24 @@ export const useAuthStore = create<AuthState>()(
|
|||||||
try {
|
try {
|
||||||
const user = await authApi.getMe()
|
const user = await authApi.getMe()
|
||||||
set({ user })
|
set({ user })
|
||||||
} catch (error) {
|
} catch {
|
||||||
console.error('[Auth] Failed to refresh user:', error)
|
// Failed to refresh user - ignore silently
|
||||||
}
|
}
|
||||||
},
|
},
|
||||||
|
|
||||||
initialize: async () => {
|
initialize: async () => {
|
||||||
// Защита от race condition - если уже идёт инициализация, ждём её завершения
|
// Защита от race condition - если уже инициализировано, выходим
|
||||||
if (isInitializing && initializePromise) {
|
if (initState.isInitialized) {
|
||||||
return initializePromise
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
isInitializing = true
|
// Если уже идёт инициализация, ждём её завершения
|
||||||
initializePromise = (async () => {
|
if (initState.isInitializing && initState.promise) {
|
||||||
|
return initState.promise
|
||||||
|
}
|
||||||
|
|
||||||
|
initState.isInitializing = true
|
||||||
|
initState.promise = (async () => {
|
||||||
try {
|
try {
|
||||||
set({ isLoading: true })
|
set({ isLoading: true })
|
||||||
|
|
||||||
@@ -167,8 +175,7 @@ export const useAuthStore = create<AuthState>()(
|
|||||||
isLoading: false,
|
isLoading: false,
|
||||||
})
|
})
|
||||||
get().checkAdminStatus()
|
get().checkAdminStatus()
|
||||||
} catch (error) {
|
} catch {
|
||||||
console.error('[Auth] getMe failed, trying refresh:', error)
|
|
||||||
// Token might be invalid on server, try to refresh
|
// Token might be invalid on server, try to refresh
|
||||||
const newToken = await tokenRefreshManager.refreshAccessToken()
|
const newToken = await tokenRefreshManager.refreshAccessToken()
|
||||||
if (newToken) {
|
if (newToken) {
|
||||||
@@ -182,8 +189,7 @@ export const useAuthStore = create<AuthState>()(
|
|||||||
isLoading: false,
|
isLoading: false,
|
||||||
})
|
})
|
||||||
get().checkAdminStatus()
|
get().checkAdminStatus()
|
||||||
} catch (userError) {
|
} catch {
|
||||||
console.error('[Auth] getMe failed after refresh:', userError)
|
|
||||||
tokenStorage.clearTokens()
|
tokenStorage.clearTokens()
|
||||||
set({
|
set({
|
||||||
accessToken: null,
|
accessToken: null,
|
||||||
@@ -206,12 +212,13 @@ export const useAuthStore = create<AuthState>()(
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
} finally {
|
} finally {
|
||||||
isInitializing = false
|
initState.isInitializing = false
|
||||||
initializePromise = null
|
initState.isInitialized = true
|
||||||
|
initState.promise = null
|
||||||
}
|
}
|
||||||
})()
|
})()
|
||||||
|
|
||||||
return initializePromise
|
return initState.promise
|
||||||
},
|
},
|
||||||
|
|
||||||
loginWithTelegram: async (initData) => {
|
loginWithTelegram: async (initData) => {
|
||||||
|
|||||||
Reference in New Issue
Block a user