import axios, { AxiosRequestConfig } from 'axios';

interface PendingTask {
    config: AxiosRequestConfig;
    resolve: Function;
}

let refreshing = false; // 狀態(tài)鎖：標(biāo)志是否正在刷新 Token
let queue: PendingTask[] = []; // 請求隊(duì)列：暫存 Token 刷新期間的請求

const axiosInstance = axios.create({
    baseURL: '/api'
});

// 1. 請求攔截器：自動(dòng)注入 Token
axiosInstance.interceptors.request.use((config) => {
    const accessToken = localStorage.getItem('access_token');
    if (accessToken && config.headers) {
        config.headers.authorization = `Bearer ${accessToken}`;
    }
    return config;
});

// 2. 響應(yīng)攔截器：處理 Token 過期
axiosInstance.interceptors.response.use(
    (response) => response,
    async (error) => {
        const { data, config } = error.response;

        // 情況 A：正在刷新 Token 中，將后續(xù)請求存入隊(duì)列
        if (refreshing) {
            return new Promise((resolve) => {
                queue.push({ config, resolve });
            });
        }

        // 情況 B：access_token 過期 (狀態(tài)碼 401 且非刷新接口本身)
        if (data.statusCode === 401 && !config.url.includes('/refresh')) {
            refreshing = true;
            
            try {
                const res = await refreshToken();
                refreshing = false;

                if (res.status === 200) {
                    // 核心邏輯：Token 刷新成功，回放隊(duì)列中的所有請求
                    queue.forEach(({ config, resolve }) => {
                        resolve(axiosInstance(config));
                    });
                    queue = []; // 清空隊(duì)列
                    
                    // 執(zhí)行當(dāng)前觸發(fā)刷新的那個(gè)請求
                    return axiosInstance(config);
                }
            } catch (err) {
                refreshing = false;
                queue = [];
                // 情況 C：refresh_token 也過期了，徹底清除登錄態(tài)
                localStorage.clear();
                window.location.href = '/login';
                return Promise.reject(err);
            }
        }

        return Promise.reject(error);
    }
);

/**
 * 刷新 Token 的異步方法
 */
async function refreshToken() {
    const res = await axios.get('/api/refresh', {
        params: {
            token: localStorage.getItem('refresh_token')
        }
    });
    // 更新本地存儲(chǔ)
    localStorage.setItem('access_token', res.data.accessToken);
    localStorage.setItem('refresh_token', res.data.refreshToken);
    return res;
}