Node.js Integration

type GroupedServers = {
  game_id: string;
  servers: string[];
};

const GQ_API_BASE_URL = process.env.GQ_API_BASE_URL ?? 'https://api.gamequery.dev';
const GQ_API_VERSION = process.env.GQ_API_VERSION ?? 'v1';

function getHeaders() {
  return {
    'Content-Type': 'application/json',
    'X-API-Token': process.env.GQ_API_TOKEN ?? '',
    'X-API-Token-Type': process.env.GQ_API_TOKEN_TYPE ?? 'FREE',
    'X-API-Token-Email': process.env.GQ_API_TOKEN_EMAIL ?? '',
  };
}

async function gqRequest<T>(path: string, init: RequestInit = {}): Promise<T> {
  const res = await fetch(`${GQ_API_BASE_URL}/${GQ_API_VERSION}${path}`, {
    ...init,
    headers: {
      ...getHeaders(),
      ...(init.headers ?? {}),
    },
  });

  if (!res.ok) {
    const body = await res.text();
    throw new Error(`GameQuery request failed (${res.status}): ${body}`);
  }

  return res.json() as Promise<T>;
}

export async function getGamesCatalog() {
  const res = await fetch(`${GQ_API_BASE_URL}/${GQ_API_VERSION}/get/games`);

  if (!res.ok) {
    const body = await res.text();
    throw new Error(`GameQuery request failed (${res.status}): ${body}`);
  }

  return res.json() as Promise<Array<{ id: string; name: string }>>;
}

export function fetchServers(servers: GroupedServers[]) {
  return gqRequest('/post/fetch', {
    method: 'POST',
    body: JSON.stringify({ servers }),
  });
}