Se soluciono authenticacion
This commit is contained in:
@@ -25,7 +25,10 @@ const refreshToken = async () => {
|
||||
throw new Error('No refresh token available');
|
||||
}
|
||||
|
||||
const response = await fetch(`${API_URL}/auth/token/refresh/`, {
|
||||
// Intentar primero con el endpoint completo
|
||||
let refreshEndpoint = `${API_URL}/token/refresh/`;
|
||||
|
||||
let response = await fetch(refreshEndpoint, {
|
||||
method: 'POST',
|
||||
headers: {
|
||||
'Content-Type': 'application/json',
|
||||
@@ -35,8 +38,23 @@ const refreshToken = async () => {
|
||||
}),
|
||||
});
|
||||
|
||||
// Si falla con 404, intentar con el endpoint alternativo
|
||||
if (response.status === 404) {
|
||||
refreshEndpoint = `${API_URL}/token/refresh/`;
|
||||
response = await fetch(refreshEndpoint, {
|
||||
method: 'POST',
|
||||
headers: {
|
||||
'Content-Type': 'application/json',
|
||||
},
|
||||
body: JSON.stringify({
|
||||
refresh: refresh
|
||||
}),
|
||||
});
|
||||
}
|
||||
|
||||
if (!response.ok) {
|
||||
throw new Error('Failed to refresh token');
|
||||
const errorText = await response.text();
|
||||
throw new Error(`Failed to refresh token: ${response.status} - ${errorText}`);
|
||||
}
|
||||
|
||||
const data = await response.json();
|
||||
@@ -62,7 +80,7 @@ const refreshToken = async () => {
|
||||
window.location.href = '/login';
|
||||
}, 1000);
|
||||
|
||||
throw error;
|
||||
throw new Error('SESSION_EXPIRED');
|
||||
}
|
||||
};
|
||||
|
||||
@@ -90,42 +108,75 @@ export const fetchWithAuth = async (url, options = {}) => {
|
||||
// Hacer la petición inicial
|
||||
let response = await fetch(url, finalOptions);
|
||||
|
||||
// Si la respuesta es 401 (Unauthorized), intentar renovar el token
|
||||
if (response.status === 401 && !isRefreshing) {
|
||||
isRefreshing = true;
|
||||
// Si la respuesta es 401 (Unauthorized), manejar renovación de token
|
||||
if (response.status === 401) {
|
||||
if (!isRefreshing) {
|
||||
isRefreshing = true;
|
||||
|
||||
try {
|
||||
// Renovar el token
|
||||
const newToken = await refreshToken();
|
||||
|
||||
// Procesar la cola de peticiones pendientes
|
||||
processQueue(null, newToken);
|
||||
|
||||
// Actualizar el header de autorización y reintentar la petición original
|
||||
finalOptions.headers['Authorization'] = `Bearer ${newToken}`;
|
||||
response = await fetch(url, finalOptions);
|
||||
|
||||
} catch (refreshError) {
|
||||
// Si falla la renovación, procesar la cola con error
|
||||
processQueue(refreshError, null);
|
||||
throw refreshError;
|
||||
} finally {
|
||||
isRefreshing = false;
|
||||
try {
|
||||
// Renovar el token
|
||||
const newToken = await refreshToken();
|
||||
|
||||
// Procesar la cola de peticiones pendientes
|
||||
processQueue(null, newToken);
|
||||
|
||||
// Actualizar el header de autorización y reintentar la petición original
|
||||
finalOptions.headers['Authorization'] = `Bearer ${newToken}`;
|
||||
response = await fetch(url, finalOptions);
|
||||
|
||||
} catch (refreshError) {
|
||||
// Si falla la renovación, procesar la cola con error
|
||||
processQueue(refreshError, null);
|
||||
throw refreshError;
|
||||
} finally {
|
||||
isRefreshing = false;
|
||||
}
|
||||
} else {
|
||||
// Ya hay un refresh en proceso, agregar esta petición a la cola
|
||||
return new Promise((resolve, reject) => {
|
||||
failedQueue.push({
|
||||
resolve: (token) => {
|
||||
finalOptions.headers['Authorization'] = `Bearer ${token}`;
|
||||
fetch(url, finalOptions)
|
||||
.then(resolve)
|
||||
.catch(reject);
|
||||
},
|
||||
reject
|
||||
});
|
||||
});
|
||||
}
|
||||
}
|
||||
|
||||
// Si todavía hay un 401 después del intento de renovación, redirigir al login
|
||||
// Si todavía hay un 401 después del intento de renovación, verificar si realmente es un problema de auth
|
||||
if (response.status === 401) {
|
||||
localStorage.removeItem('access');
|
||||
localStorage.removeItem('refresh');
|
||||
localStorage.removeItem('user_id');
|
||||
localStorage.removeItem('user_is_importador');
|
||||
// Verificar si tenemos un token válido en localStorage
|
||||
const currentToken = localStorage.getItem('access');
|
||||
|
||||
setTimeout(() => {
|
||||
window.location.href = '/login';
|
||||
}, 1000);
|
||||
// Intentar obtener más información del error
|
||||
let errorDetails = '';
|
||||
try {
|
||||
const errorText = await response.text();
|
||||
errorDetails = errorText;
|
||||
} catch (e) {
|
||||
// Error al leer respuesta
|
||||
}
|
||||
|
||||
throw new Error('Session expired');
|
||||
// Si no hay token o el error indica problema de autenticación, limpiar sesión
|
||||
if (!currentToken || errorDetails.includes('token') || errorDetails.includes('auth')) {
|
||||
localStorage.removeItem('access');
|
||||
localStorage.removeItem('refresh');
|
||||
localStorage.removeItem('user_id');
|
||||
localStorage.removeItem('user_is_importador');
|
||||
|
||||
setTimeout(() => {
|
||||
window.location.href = '/login';
|
||||
}, 1000);
|
||||
|
||||
throw new Error('SESSION_EXPIRED');
|
||||
} else {
|
||||
// Si hay token pero sigue fallando, podría ser un problema del servidor
|
||||
// No limpiar la sesión, dejar que el error se propague
|
||||
}
|
||||
}
|
||||
|
||||
return response;
|
||||
@@ -185,21 +236,36 @@ export const postFormDataWithAuth = async (url, formData) => {
|
||||
try {
|
||||
let response = await fetch(url, options);
|
||||
|
||||
if (response.status === 401 && !isRefreshing) {
|
||||
isRefreshing = true;
|
||||
if (response.status === 401) {
|
||||
if (!isRefreshing) {
|
||||
isRefreshing = true;
|
||||
|
||||
try {
|
||||
const newToken = await refreshToken();
|
||||
processQueue(null, newToken);
|
||||
|
||||
options.headers['Authorization'] = `Bearer ${newToken}`;
|
||||
response = await fetch(url, options);
|
||||
|
||||
} catch (refreshError) {
|
||||
processQueue(refreshError, null);
|
||||
throw refreshError;
|
||||
} finally {
|
||||
isRefreshing = false;
|
||||
try {
|
||||
const newToken = await refreshToken();
|
||||
processQueue(null, newToken);
|
||||
|
||||
options.headers['Authorization'] = `Bearer ${newToken}`;
|
||||
response = await fetch(url, options);
|
||||
|
||||
} catch (refreshError) {
|
||||
processQueue(refreshError, null);
|
||||
throw refreshError;
|
||||
} finally {
|
||||
isRefreshing = false;
|
||||
}
|
||||
} else {
|
||||
// Ya hay un refresh en proceso, agregar esta petición a la cola
|
||||
return new Promise((resolve, reject) => {
|
||||
failedQueue.push({
|
||||
resolve: (token) => {
|
||||
options.headers['Authorization'] = `Bearer ${token}`;
|
||||
fetch(url, options)
|
||||
.then(resolve)
|
||||
.catch(reject);
|
||||
},
|
||||
reject
|
||||
});
|
||||
});
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
Reference in New Issue
Block a user