mediahub-fe/service/http-config/http-interceptor-service.ts

import { useRouter } from "next/navigation";
import axiosInterceptorInstance from "./axios-interceptor-instance";
import Cookies from "js-cookie";
import { getCsrfToken } from "../auth";

export async function httpGetInterceptor(pathUrl: any) {
  const pathname = window.location.pathname;
  const response = await axiosInterceptorInstance
    .get(pathUrl)
    .catch((error) => error.response);
  console.log("Response interceptor : ", response);
  if (response?.status == 200 || response?.status == 201) {
    return {
      error: false,
      message: "success",
      data: response?.data,
    };
  } else if (response?.status == 401) {
    Object.keys(Cookies.get()).forEach((cookieName) => {
      Cookies.remove(cookieName);
    });
    if (pathname?.includes("/contributor/") || pathname?.includes("/admin/") || pathname?.includes("/supervisor/")) {
      window.location.href = "/";
    }
  } else {
    return {
      error: true,
      message: response?.data?.message || response?.data || null,
      data: null,
    };
  }
}

export async function httpPostInterceptor(
  pathUrl: any,
  data?: any,
  headers?: any
) {
  const resCsrf = await getCsrfToken();
  const csrfToken = resCsrf?.data?.token;

  const defaultHeaders = {
    "Content-Type": "application/json",
  };
  const mergedHeaders = {
    ...defaultHeaders,
    ...headers,
    ...(csrfToken ? { "X-XSRF-TOKEN": csrfToken } : {}),
  };

  const response = await axiosInterceptorInstance
    .post(pathUrl, data, { headers: mergedHeaders })
    .catch((error) => error.response);
  console.log("Response interceptor : ", response);
  if (response?.status == 200 || response?.status == 201) {
    return {
      error: false,
      message: "success",
      data: response?.data,
    };
  } else if (response?.status == 401) {
    Object.keys(Cookies.get()).forEach((cookieName) => {
      Cookies.remove(cookieName);
    });
    window.location.href = "/";
  } else {
    return {
      error: true,
      message: response?.data?.message || response?.data || null,
      data: null,
    };
  }
}

export async function httpPutInterceptor(
  pathUrl: any,
  data: any,
  headers?: any
) {
  const resCsrf = await getCsrfToken();
  const csrfToken = resCsrf?.data?.token;

  const defaultHeaders = {
    "Content-Type": "application/json",
  };
  const mergedHeaders = {
    ...defaultHeaders,
    ...headers,
    ...(csrfToken ? { "X-XSRF-TOKEN": csrfToken } : {}),
  };

  const response = await axiosInterceptorInstance
    .put(pathUrl, data, { headers: mergedHeaders })
    .catch((error) => error.response);
  console.log("Response interceptor : ", response);
  if (response?.status == 200 || response?.status == 201) {
    return {
      error: false,
      message: "success",
      data: response?.data,
    };
  } else if (response?.status == 401) {
    Object.keys(Cookies.get()).forEach((cookieName) => {
      Cookies.remove(cookieName);
    });
    window.location.href = "/";
  } else {
    return {
      error: true,
      message: response?.data?.message || response?.data || null,
      data: null,
    };
  }
}

export async function httpDeleteInterceptor(pathUrl: any) {
  const resCsrf = await getCsrfToken();
  const csrfToken = resCsrf?.data?.token;

  const defaultHeaders = {
    "Content-Type": "application/json",
  };
  const mergedHeaders = {
    ...defaultHeaders,
    ...(csrfToken ? { "X-XSRF-TOKEN": csrfToken } : {}),
  };

  const response = await axiosInterceptorInstance
    .delete(pathUrl, { headers: mergedHeaders})
    .catch((error) => error.response);
  console.log("Response interceptor : ", response);
  if (response?.status == 200 || response?.status == 201) {
    return {
      error: false,
      message: "success",
      data: response?.data,
    };
  } else if (response?.status == 401) {
    Object.keys(Cookies.get()).forEach((cookieName) => {
      Cookies.remove(cookieName);
    });
    window.location.href = "/";
  } else {
    return {
      error: true,
      message: response?.data?.message || response?.data || null,
      data: null,
    };
  }
}

export async function httpGetInterceptorWithToken(pathUrl: any, headers?: any) {
  const response = await axiosInterceptorInstance
    .get(pathUrl, headers)
    .catch((error) => error.response);
  console.log("Response interceptor : ", response);
  if (response?.status == 200 || response?.status == 201) {
    return {
      error: false,
      message: "success",
      data: response?.data,
    };
  } else {
    return {
      error: true,
      message: response?.data?.message || response?.data || null,
      data: null,
    };
  }
}