|
1 | 1 | import axios from 'axios'; |
2 | 2 |
|
3 | | -// 기존 authState를 가져오는 함수 정의 |
4 | | -const getAuthState = () => { |
5 | | - const authState = localStorage.getItem('authState'); |
6 | | - return authState ? JSON.parse(authState) : null; |
7 | | -}; |
8 | | - |
9 | 3 | const baseUrl = process.env.REACT_APP_API_URL; |
10 | 4 |
|
11 | 5 | export const apiClient = axios.create({ |
12 | 6 | baseURL: baseUrl, |
13 | | - headers: { |
14 | | - Authorization: `Bearer ${getAuthState()?.accessToken}`, |
15 | | - }, |
| 7 | + withCredentials: true, |
16 | 8 | }); |
17 | 9 |
|
18 | | -apiClient.interceptors.request.use( |
19 | | - config => { |
20 | | - const authState = getAuthState(); // authState 객체를 가져옵니다. |
21 | | - const accessToken = authState?.accessToken; |
22 | | - if (accessToken) { |
23 | | - config.headers.Authorization = `Bearer ${accessToken}`; |
24 | | - } else { |
25 | | - delete config.headers.Authorization; |
26 | | - } |
27 | | - return config; |
28 | | - }, |
29 | | - error => { |
30 | | - return Promise.reject(error); |
31 | | - }, |
32 | | -); |
| 10 | +// 동시에 여러 요청이 401 터질 때 refresh 중복 호출 방지 |
| 11 | +let isRefreshing = false; |
| 12 | +let refreshQueue = []; |
| 13 | + |
| 14 | +const runQueue = error => { |
| 15 | + refreshQueue.forEach(({ resolve, reject }) => { |
| 16 | + if (error) reject(error); |
| 17 | + else resolve(); |
| 18 | + }); |
| 19 | + refreshQueue = []; |
| 20 | +}; |
33 | 21 |
|
34 | 22 | apiClient.interceptors.response.use( |
35 | | - response => { |
36 | | - return response; |
37 | | - }, |
| 23 | + response => response, |
38 | 24 | async error => { |
39 | | - if (error.response && error.response.status === 401) { |
40 | | - // 리프레시 토큰 가져오기 |
41 | | - const authState = getAuthState(); // authState 객체를 가져옵니다. |
42 | | - const refreshToken = authState?.refreshToken; |
| 25 | + if (!error?.response) return Promise.reject(error); |
43 | 26 |
|
44 | | - if (!refreshToken) { |
45 | | - // 리프레시 토큰이 없으면 로그아웃 처리 |
46 | | - return Promise.reject(error); |
47 | | - } |
| 27 | + const originalRequest = error.config; |
48 | 28 |
|
49 | | - // 현재 요청이 리프레시 요청인지 확인 |
50 | | - if (error.config.url.includes('/auth/refresh')) { |
51 | | - return Promise.reject(error); |
52 | | - } |
| 29 | + // 401만 처리 |
| 30 | + if (error.response.status !== 401) { |
| 31 | + return Promise.reject(error); |
| 32 | + } |
53 | 33 |
|
54 | | - try { |
55 | | - // 리프레시 토큰으로 액세스 토큰 갱신 |
56 | | - const response = await axios.post(`${baseUrl}/auth/refresh`, { |
57 | | - refreshToken: refreshToken, // 올바른 키 사용 |
58 | | - }); |
59 | | - const accessToken = response.data.data.accessToken; |
| 34 | + // refresh 자체가 401이면 종료 (로그인 만료) |
| 35 | + if (originalRequest?.url?.includes('/auth/refresh')) { |
| 36 | + return Promise.reject(error); |
| 37 | + } |
60 | 38 |
|
61 | | - // authState 업데이트 |
62 | | - const updatedAuthState = { |
63 | | - ...authState, |
64 | | - accessToken: accessToken, |
65 | | - }; |
| 39 | + // 무한 루프 방지 |
| 40 | + if (originalRequest._retry) { |
| 41 | + return Promise.reject(error); |
| 42 | + } |
| 43 | + originalRequest._retry = true; |
66 | 44 |
|
67 | | - localStorage.setItem('authState', JSON.stringify(updatedAuthState)); |
68 | | - // 새로운 토큰으로 원래 요청 재시도 |
69 | | - error.config.headers['Authorization'] = `Bearer ${accessToken}`; |
70 | | - return axios(error.config); // 원래 요청 재시도 |
71 | | - } catch (refreshError) { |
72 | | - // 토큰 갱신 실패 시 로그아웃 처리 |
73 | | - return Promise.reject(error); |
74 | | - } |
| 45 | + // 이미 refresh 중이면 큐에서 대기 후 재시도 |
| 46 | + if (isRefreshing) { |
| 47 | + return new Promise((resolve, reject) => { |
| 48 | + refreshQueue.push({ |
| 49 | + resolve: () => resolve(apiClient(originalRequest)), |
| 50 | + reject, |
| 51 | + }); |
| 52 | + }); |
75 | 53 | } |
76 | 54 |
|
77 | | - return Promise.reject(error); |
| 55 | + isRefreshing = true; |
| 56 | + |
| 57 | + try { |
| 58 | + // efreshToken 쿠키를 서버가 읽는 구조라면 바디 필요 없음 |
| 59 | + await apiClient.post('/auth/refresh'); |
| 60 | + |
| 61 | + runQueue(null); |
| 62 | + return apiClient(originalRequest); |
| 63 | + } catch (refreshError) { |
| 64 | + runQueue(refreshError); |
| 65 | + return Promise.reject(refreshError); |
| 66 | + } finally { |
| 67 | + isRefreshing = false; |
| 68 | + } |
78 | 69 | }, |
79 | 70 | ); |
0 commit comments