Newer
Older
smart-home-server / webclient-vue / src / api / http.js
@Eugene Sukhodolskiy Eugene Sukhodolskiy 7 hours ago 2 KB Scaffold Vue web client
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);
  }
}