import axios, { AxiosRequestConfig, AxiosResponse } from 'axios';
import { Message } from '@arco-design/web-vue';
import { clearToken, getRefreshToken, getToken } from '@/utils/auth';
import { apiHost } from '@/utils/env';
import { ServiceResponse } from '@/types/global';

axios.defaults.baseURL = apiHost;
axios.defaults.timeout = 30000;

const isRefreshing = false;

axios.interceptors.request.use(
  (config: AxiosRequestConfig) => {
    if (!config.url?.startsWith('/provider')) {
      config.baseURL = `${config.baseURL}/manage`;
    }

    config.headers = {
      Authorization: `Bearer ${isRefreshing ? getRefreshToken() : getToken()}`,
      Accept: 'application/json',
      Route: sessionStorage.getItem('route') || 'dashboard',
      ...config.headers,
    };

    if (config.params) {
      Object.keys(config.params).forEach((key) => {
        if (config.params[key] === undefined || config.params[key] === '') {
          delete config.params[key];
        }
      });
    }

    return config;
  },
  (error) => {
    return Promise.reject(error);
  }
);

axios.interceptors.response.use(
  async (response: AxiosResponse<ServiceResponse>) => {
    if (response.data instanceof Blob) {
      return Promise.resolve(response);
    }

    return Promise.resolve(response.data);
  },
  async (error: any): Promise<any> => {
    if (error.response?.status === 401) {
      clearToken();
      window.location.reload();
      Message.warning({ content: '登陆信息已失效，请重新登陆...' });
    }

    if (error.response?.status === 403) {
      window.location.href = '/exception/403';
    }

    Message.error({
      id: 'service_error',
      content: error.response.data.msg || error.msg || 'Request Error',
      duration: 5 * 1000,
    });

    return Promise.reject(error);
  }
);