canrd-outside / order-erp-front · Files

import type {
  AxiosRequestConfig,
  AxiosInstance,
  AxiosResponse,
  AxiosError,
  InternalAxiosRequestConfig,
} from 'axios';

import type { RequestOptions, Result, UploadFileParams } from '/#/axios';

import type { CreateAxiosOptions } from './axiosTransform';

import axios from 'axios';

import qs from 'qs';

import { AxiosCanceler } from './axiosCancel';
import { isFunction } from '/@/utils/is';

import { cloneDeep } from 'lodash-es';

import { ContentTypeEnum, RequestEnum } from '/@/enums/httpEnum';

import { useMessage } from '/@/hooks/web/useMessage';
import { router } from '/@/router';
import { useUserStoreWithOut } from '/@/store/modules/user';

export * from './axiosTransform';

const { createMessage } = useMessage();

/**

 * @description:  axios module

 */
export class VAxios {
  private axiosInstance: AxiosInstance;

  private readonly options: CreateAxiosOptions;

  constructor(options: CreateAxiosOptions) {
    this.options = options;
    this.axiosInstance = axios.create(options);
    this.setupInterceptors();
  }

  /**

   * @description:  Create axios instance

   */
  private createAxios(config: CreateAxiosOptions): void {
    this.axiosInstance = axios.create(config);
  }

  private getTransform() {
    const { transform } = this.options;
    return transform;
  }

  getAxios(): AxiosInstance {
    return this.axiosInstance;
  }

  /**

   * @description: Reconfigure axios

   */
  configAxios(config: CreateAxiosOptions) {
    if (!this.axiosInstance) {
      return;
    }
    this.createAxios(config);
  }

  /**

   * @description: Set general header

   */
  setHeader(headers: any): void {
    if (!this.axiosInstance) {
      return;
    }
    Object.assign(this.axiosInstance.defaults.headers, headers);
  }

  /**

   * @description: Interceptor configuration 拦截器配置

   */
  private setupInterceptors() {

    // const transform = this.getTransform();
    const {
      axiosInstance,
      options: { transform },
    } = this;

    if (!transform) {
      return;
    }
    const {
      requestInterceptors,
      requestInterceptorsCatch,
      responseInterceptors,
      responseInterceptorsCatch,
    } = transform;

    const axiosCanceler = new AxiosCanceler();

    // Request interceptor configuration processing

    this.axiosInstance.interceptors.request.use((config: InternalAxiosRequestConfig) => {

      // If cancel repeat request is turned on, then cancel repeat request is prohibited

      const { requestOptions } = this.options;
      const ignoreCancelToken = requestOptions?.ignoreCancelToken ?? true;

      !ignoreCancelToken && axiosCanceler.addPending(config);

      if (requestInterceptors && isFunction(requestInterceptors)) {

        config = requestInterceptors(config, this.options);

      }
      return config;
    }, undefined);

    // Request interceptor error capture

    requestInterceptorsCatch &&
      isFunction(requestInterceptorsCatch) &&
      this.axiosInstance.interceptors.request.use(undefined, requestInterceptorsCatch);

    // Response result interceptor processing

    this.axiosInstance.interceptors.response.use((res: AxiosResponse<any>) => {
      res && axiosCanceler.removePending(res.config);
      if (responseInterceptors && isFunction(responseInterceptors)) {
        res = responseInterceptors(res);
      }
      return res;
    }, undefined);

    // Response result interceptor error capture

    responseInterceptorsCatch &&
      isFunction(responseInterceptorsCatch) &&

      this.axiosInstance.interceptors.response.use(undefined, (error) => {

        return responseInterceptorsCatch(axiosInstance, error);

      });

  }

  /**

   * @description:  File Upload

   */
  uploadFile<T = any>(config: AxiosRequestConfig, params: UploadFileParams) {
    const formData = new window.FormData();

    const customFilename = params.name || 'file';

    if (params.filename) {
      formData.append(customFilename, params.file, params.filename);
    } else {
      formData.append(customFilename, params.file);
    }

    if (params.data) {
      Object.keys(params.data).forEach((key) => {

        const value = params.data![key];

        if (Array.isArray(value)) {
          value.forEach((item) => {
            formData.append(`${key}[]`, item);
          });
          return;
        }

        formData.append(key, params.data![key]);

      });
    }

    return this.axiosInstance.request<T>({
      ...config,
      method: 'POST',
      data: formData,
      headers: {
        'Content-type': ContentTypeEnum.FORM_DATA,

        // @ts-ignore

        ignoreCancelToken: true,
      },
    });
  }

  // support form-data
  supportFormData(config: AxiosRequestConfig) {

    const headers = config.headers || this.options.headers;

    const contentType = headers?.['Content-Type'] || headers?.['content-type'];

    if (
      contentType !== ContentTypeEnum.FORM_URLENCODED ||
      !Reflect.has(config, 'data') ||
      config.method?.toUpperCase() === RequestEnum.GET
    ) {
      return config;
    }

    return {
      ...config,

      data: qs.stringify(config.data, { arrayFormat: 'brackets' }),

    };
  }

  get<T = any>(config: AxiosRequestConfig, options?: RequestOptions): Promise<T> {
    return this.request({ ...config, method: 'GET' }, options);
  }

  post<T = any>(config: AxiosRequestConfig, options?: RequestOptions): Promise<T> {
    return this.request({ ...config, method: 'POST' }, options);
  }

  put<T = any>(config: AxiosRequestConfig, options?: RequestOptions): Promise<T> {
    return this.request({ ...config, method: 'PUT' }, options);
  }

  delete<T = any>(config: AxiosRequestConfig, options?: RequestOptions): Promise<T> {
    return this.request({ ...config, method: 'DELETE' }, options);
  }

  request<T = any>(config: AxiosRequestConfig, options?: RequestOptions): Promise<T> {

    let conf: CreateAxiosOptions = cloneDeep(config);

    // cancelToken 如果被深拷贝，会导致最外层无法使用cancel方法来取消请求

    if (config.cancelToken) {
      conf.cancelToken = config.cancelToken;

    }

    const transform = this.getTransform();

    const { requestOptions } = this.options;

    const { message } = options || {};

    const opt: RequestOptions = Object.assign({}, requestOptions, options);

    const { beforeRequestHook, requestCatchHook, transformResponseHook } = transform || {};

    if (beforeRequestHook && isFunction(beforeRequestHook)) {
      conf = beforeRequestHook(conf, opt);
    }

    conf.requestOptions = opt;

    conf = this.supportFormData(conf);

    return new Promise((resolve, reject) => {

      const userStore = useUserStoreWithOut();

      this.axiosInstance
        .request<any, AxiosResponse<Result>>(conf)
        .then((res: AxiosResponse<Result>) => {

          if (res.data.result === 401) {
            userStore.setToken('');
            createMessage.error(res.data.message);
            return router.push('/login');
          }
          if (res.data.result !== 0 && res.data.message) {

            createMessage.error(res.data.message);
            return reject(res.data);

          }

          if (message && res.data.result === 0) {
            createMessage.success(message);
          }

          if (transformResponseHook && isFunction(transformResponseHook)) {

            try {

              const ret = transformResponseHook(res, opt);

              resolve(ret);
            } catch (err) {
              reject(err || new Error('request error!'));
            }

            return;
          }

          resolve(res as unknown as Promise<T>);

        })

        .catch((e: Error | AxiosError) => {

          console.log('%c [ e ]-257', 'font-size:13px; background:pink; color:#bf2c9f;', e);

          if (requestCatchHook && isFunction(requestCatchHook)) {

            reject(requestCatchHook(e, opt));

            return;
          }

          if (axios.isAxiosError(e)) {
            // rewrite error message from axios in here
          }

          reject(e);
        });
    });
  }
}