const DEFAULT_TIMEOUT_MS = Number(import.meta.env.VITE_API_TIMEOUT_MS || 10000);
function buildQuery(params) {
const query = new URLSearchParams();
for (const [key, value] of Object.entries(params || {})) {
if (value === undefined || value === null) {
continue;
}
query.append(key, String(value));
}
const serialized = query.toString();
return serialized ? `?${serialized}` : "";
}
function joinUrl(baseUrl, path) {
const base = String(baseUrl || "").replace(/\/+$/, "");
const nextPath = String(path || "").replace(/^\/+/, "");
if (!base) {
return `/${nextPath}`;
}
return `${base}/${nextPath}`;
}
function wrapProxyPath(path, query) {
const proxyPath = import.meta.env.VITE_API_PROXY_PATH || "";
if (!proxyPath) {
return `${path}${buildQuery(query)}`;
}
return `${proxyPath}${buildQuery({ path, ...(query || {}) })}`;
}
export async function requestHttp(method, path, body, options = {}) {
const timeoutMs = Number(options.timeoutMs || DEFAULT_TIMEOUT_MS);
const controller = new AbortController();
const timeout = setTimeout(() => controller.abort(), timeoutMs);
const baseUrl = import.meta.env.VITE_API_BASE_URL || "";
const url = joinUrl(baseUrl, wrapProxyPath(path, options.query));
const headers = {
Accept: "application/json",
...(options.headers || {}),
};
const init = {
method,
headers,
signal: controller.signal,
};
if (options.signal) {
options.signal.addEventListener("abort", () => controller.abort(), { once: true });
}
if (body !== undefined && body !== null) {
headers["Content-Type"] = "application/json";
init.body = JSON.stringify(body);
}
try {
const response = await fetch(url, init);
const text = await response.text();
let data = text;
if (text) {
try {
data = JSON.parse(text);
} catch (_) {
data = text;
}
}
return {
response,
data,
meta: {
url,
method,
statusCode: response.status,
headers: response.headers,
},
};
} finally {
clearTimeout(timeout);
}
}