import baseRequest from "./baseRequest";
import { get } from "./storeInfo";
import Toast from "react-native-toast-message";
import { generateSignature } from "./crypto";
// import { useRouter } from "next/navigation";
// import webviewBaseRequest from "@/utils/webviewBaseRequest";

// 创建一个封装 fetch 的函数
export default async function customFetch(
  method,
  url,
  options = {},
  needMid,
  timeoutValue = 0
) {
  const controller = new AbortController();
  const signal = controller.signal;

  // 设置超时

  let timeout = null;
  if (timeoutValue) {
    timeout = setTimeout(() => {
      controller.abort("Request timed out");
    }, timeoutValue);
  }
  // 默认选项
  const defaultOptions = {
    method: method,
    signal,
    headers: {
      "Content-Type": "application/json",
      "X-Req-Source-TF": "wittgenstein",
      ...options?.headers,
      // 可以添加其他默认头部信息
    },
    // 可以添加其他默认选项
  };
  let newBody = { ...options?.body };
  if (needMid) {
    let { mid } = await get("account");
    if (!mid) return;
    newBody.mid = mid;
  }

  const apiUrl = process.env.EXPO_PUBLIC_API_URL;
  const base = await baseRequest();
  const body = JSON.stringify({ ...base, ...newBody });

  // 合并选项
  const mergedOptions = { ...defaultOptions, body };
  // console.log("body", body);
  // 返回 Promise 对象
  const signature = await generateSignature({
    ...base,
  });
  return new Promise((resolve, reject) => {
    try {
      fetch(`${apiUrl + url}?signature=${signature}`, mergedOptions)
        .then((response) => {
          if (timeout) clearTimeout(timeout);

          // // 检查响应状态码
          if (!response.ok) {
            throw new Error(
              "Network response was not ok " + response.statusText
            );
          }
          // console.log("response-----", response);
          // const contentLength = response.headers.get("Content-Length");
          // if (!contentLength) {
          //   throw new Error("Content-Length is null");
          // }

          // const total = parseInt(contentLength, 10);
          // let loaded = 0;
          // alert("Error--" + url + "-----" + response);
          return response;
          // 解析 JSON 响应
          // return response.json();
        })
        .then((data) => {
          // 解析成功，返回数据
          resolve(data.json());
        })
        .catch((error) => {
          // alert("ErrorCatch" + error);
          if (error.name === "AbortError") {
            // console.log("Fetch request timed out.");
            Toast.show({
              type: "error",
              text1: "请求超时，请检查网络后重试。",
              topOffset: 60,
            });
            // 这里可以实现重试逻辑
            // fetchDataWithRetry();
          } else {
            console.error("Fetch error:", error);
          }

          // 请求失败，拒绝 Promise
          reject(error);
        });
    } catch (error) {
      Toast.show({
        type: "error",
        text1: "请求数据出现问题！",
        topOffset: 60,
      });
    }
  });
}