|
| 1 | +// src/apis/instance.ts |
1 | 2 | import axios, { |
2 | 3 | AxiosError, |
3 | 4 | AxiosHeaders, |
4 | 5 | InternalAxiosRequestConfig, |
5 | 6 | AxiosRequestHeaders, |
6 | | - AxiosRequestConfig, |
7 | 7 | } from "axios"; |
8 | 8 | import useTokenStore from "@/stores/useTokenStore"; |
9 | | -import { GlobalResponse } from "@/types/common/apiResponse.type"; |
10 | 9 |
|
11 | | -// ===== 타입 정의 ===== |
12 | | -interface RetryConfig extends InternalAxiosRequestConfig { |
13 | | - _retry?: boolean; |
| 10 | +type ReqConfig = InternalAxiosRequestConfig & { |
14 | 11 | _skipAuth?: boolean; |
15 | | -} |
16 | | - |
17 | | -interface RefreshRequestConfig extends AxiosRequestConfig { |
18 | | - _skipAuth?: boolean; |
19 | | -} |
20 | | - |
21 | | -interface RefreshResponse { |
22 | | - accessToken: string; |
23 | | - refreshToken: string; |
24 | | -} |
| 12 | +}; |
25 | 13 |
|
26 | | -// ===== API 인스턴스 ===== |
27 | 14 | const api = axios.create({ |
28 | 15 | baseURL: import.meta.env.VITE_API_URL, |
29 | 16 | }); |
30 | 17 |
|
31 | | -// 리프레시 전용 클라이언트(인터셉터 X) |
32 | | -const refreshClient = axios.create({ |
33 | | - baseURL: import.meta.env.VITE_API_URL, |
34 | | -}); |
35 | | - |
36 | | -/** 요청 인터셉터: 최신 accessToken 자동 부착 */ |
37 | | -api.interceptors.request.use((config: RetryConfig) => { |
38 | | - // 스킵 옵션이면 바로 리턴 |
| 18 | +/** 요청 인터셉터: accessToken 부착 (옵션으로 스킵 가능) */ |
| 19 | +api.interceptors.request.use((config: ReqConfig) => { |
39 | 20 | if (config._skipAuth) return config; |
40 | 21 |
|
41 | 22 | const { accessToken } = useTokenStore.getState(); |
42 | 23 | const headers = (config.headers ??= |
43 | 24 | new AxiosHeaders()) as AxiosRequestHeaders; |
44 | 25 |
|
45 | | - if (accessToken) { |
46 | | - headers.Authorization = `Bearer ${accessToken}`; |
47 | | - } else { |
48 | | - delete headers.Authorization; |
49 | | - } |
| 26 | + if (accessToken) headers.Authorization = `Bearer ${accessToken}`; |
| 27 | + else delete headers.Authorization; |
| 28 | + |
50 | 29 | return config; |
51 | 30 | }); |
52 | 31 |
|
53 | | -// ===== 토큰 갱신 동시성 제어 ===== |
54 | | -let isRefreshing = false; |
55 | | -let queue: Array<(token: string | null) => void> = []; |
56 | | -const flushQueue = (token: string | null) => { |
57 | | - queue.forEach(resolve => resolve(token)); |
58 | | - queue = []; |
59 | | -}; |
60 | | - |
61 | | -const isRefreshUrl = (url?: string) => url?.includes("/api/v1/auth/refresh"); |
62 | | - |
63 | | -/** 응답 인터셉터: 401 → refresh → 재시도 */ |
| 32 | +/** 응답 인터셉터: 403 → /onboarding 이동, 401 → 토큰 클리어 */ |
64 | 33 | api.interceptors.response.use( |
65 | 34 | res => res, |
66 | 35 | async (error: AxiosError) => { |
67 | 36 | const status = error.response?.status; |
68 | | - const original = error.config as RetryConfig | undefined; |
69 | | - |
70 | | - // config 없는 경우 or 401 아님 → 바로 reject |
71 | | - if (!original || status !== 401) { |
72 | | - return Promise.reject(error); |
73 | | - } |
74 | 37 |
|
75 | | - // 리프레시 요청 자체가 401이면 → 바로 종료 |
76 | | - if (isRefreshUrl(original.url)) { |
77 | | - flushQueue(null); |
78 | | - useTokenStore.getState().clearTokens(); |
| 38 | + if (status === 403) { |
| 39 | + // 권한 없음 → 온보딩으로 보냄 |
| 40 | + window.location.assign("/onboarding"); |
| 41 | + // 이동 직후에도 호출부는 에러 흐름 유지 |
79 | 42 | return Promise.reject(error); |
80 | 43 | } |
81 | 44 |
|
82 | | - // 무한루프 방지 |
83 | | - if (original._retry) { |
| 45 | + if (status === 401) { |
| 46 | + // 인증 만료/무효 → 토큰 정리 (필요시 로그인 페이지로 이동하도록 조정 가능) |
| 47 | + const store = useTokenStore.getState(); |
| 48 | + store.clearTokens?.(); |
| 49 | + // 예: window.location.assign("/login"); |
84 | 50 | return Promise.reject(error); |
85 | 51 | } |
86 | | - original._retry = true; |
87 | | - |
88 | | - const store = useTokenStore.getState(); |
89 | | - const refreshToken = store.refreshToken; |
90 | | - |
91 | | - // 리프레시 토큰 없으면 → 로그아웃 |
92 | | - if (!refreshToken) { |
93 | | - store.clearTokens(); |
94 | | - return Promise.reject(error); |
95 | | - } |
96 | | - |
97 | | - // 이미 리프레시 중이면 완료까지 대기 |
98 | | - if (isRefreshing) { |
99 | | - const newToken = await new Promise<string | null>(resolve => { |
100 | | - queue.push(resolve); |
101 | | - }); |
102 | | - if (!newToken) { |
103 | | - store.clearTokens(); |
104 | | - return Promise.reject(error); |
105 | | - } |
106 | | - const headers = (original.headers ??= |
107 | | - new AxiosHeaders()) as AxiosRequestHeaders; |
108 | | - headers.Authorization = `Bearer ${newToken}`; |
109 | | - return api(original); |
110 | | - } |
111 | 52 |
|
112 | | - // 실제 리프레시 요청 수행 |
113 | | - try { |
114 | | - isRefreshing = true; |
115 | | - |
116 | | - const resp = await refreshClient.post<GlobalResponse<RefreshResponse>>( |
117 | | - "/api/v1/auth/refresh", |
118 | | - { refreshToken }, |
119 | | - { headers: new AxiosHeaders(), _skipAuth: true } as RefreshRequestConfig |
120 | | - ); |
121 | | - |
122 | | - const { accessToken: newAccessToken, refreshToken: newRefreshToken } = |
123 | | - resp.data.result; |
124 | | - |
125 | | - if (!newAccessToken) { |
126 | | - throw new Error("No accessToken in refresh response"); |
127 | | - } |
128 | | - |
129 | | - // 스토어 갱신 |
130 | | - store.setAccessToken(newAccessToken); |
131 | | - if (newRefreshToken) { |
132 | | - store.setRefreshToken(newRefreshToken); |
133 | | - } |
134 | | - |
135 | | - // 대기 중인 요청 처리 |
136 | | - flushQueue(newAccessToken); |
137 | | - |
138 | | - // 원 요청 재시도 |
139 | | - const headers = (original.headers ??= |
140 | | - new AxiosHeaders()) as AxiosRequestHeaders; |
141 | | - headers.Authorization = `Bearer ${newAccessToken}`; |
142 | | - return api(original); |
143 | | - } catch (e) { |
144 | | - flushQueue(null); |
145 | | - useTokenStore.getState().clearTokens(); |
146 | | - return Promise.reject(e); |
147 | | - } finally { |
148 | | - isRefreshing = false; |
149 | | - } |
| 53 | + return Promise.reject(error); |
150 | 54 | } |
151 | 55 | ); |
152 | 56 |
|
|
0 commit comments