import { URL } from 'node:url';
import HttpError from '../../errors/http.js';
import axios from '../axios-with-proxy.js';

const removeBaseUrlForAbsoluteUrls = (requestConfig) => {
  try {
    const url = new URL(requestConfig.url);
    requestConfig.baseURL = url.origin;
    requestConfig.url = url.pathname + url.search;

    return requestConfig;
  } catch {
    return requestConfig;
  }
};

export default function createHttpClient({ $, baseURL, beforeRequest = [] }) {
  const instance = axios.create({
    baseURL,
  });

  instance.interceptors.request.use((requestConfig) => {
    const newRequestConfig = removeBaseUrlForAbsoluteUrls(requestConfig);

    const result = beforeRequest.reduce((newConfig, beforeRequestFunc) => {
      return beforeRequestFunc($, newConfig);
    }, newRequestConfig);

    /**
     * axios seems to want InternalAxiosRequestConfig returned not AxioRequestConfig
     * anymore even though requests do require AxiosRequestConfig.
     *
     * Since both interfaces are very similar (InternalAxiosRequestConfig
     * extends AxiosRequestConfig), we can utilize an assertion below
     **/
    return result;
  });

  instance.interceptors.response.use(
    (response) => response,
    async (error) => {
      const { config, response } = error;
      // Do not destructure `status` from `error.response` because it might not exist
      const status = response?.status;

      if (
        // TODO: provide a `shouldRefreshToken` function in the app
        (status === 401 || status === 403) &&
        $.app.auth &&
        $.app.auth.refreshToken &&
        !$.app.auth.isRefreshTokenRequested
      ) {
        $.app.auth.isRefreshTokenRequested = true;
        await $.app.auth.refreshToken($);

        // retry the previous request before the expired token error
        const newResponse = await instance.request(config);
        $.app.auth.isRefreshTokenRequested = false;

        return newResponse;
      }

      throw new HttpError(error);
    }
  );

  return instance;
}