driver-api.ts

const DEFAULT_SESSION_URL =
  process.env.DRIVER_SESSION_URL?.trim() ||
  "https://api.browser.cash/v1/browser/session";

export interface DriverSessionConfig {
  country?: string;
  type?: string;
  captchaSolver?: boolean;
}

export interface DriverSession {
  sessionId: string;
  cdpUrl: string;
  servedBy?: string;
  status?: string;
}

async function requestWithTimeout(
  input: string,
  init: RequestInit,
  timeoutMs: number,
): Promise<Response> {
  const controller = new AbortController();
  const timer = setTimeout(() => controller.abort(), timeoutMs);
  try {
    return await fetch(input, { ...init, signal: controller.signal });
  } finally {
    clearTimeout(timer);
  }
}

export async function createDriverSession(
  apiKey: string,
  config: DriverSessionConfig,
): Promise<DriverSession> {
  const response = await requestWithTimeout(
    DEFAULT_SESSION_URL,
    {
      method: "POST",
      headers: {
        Authorization: `Bearer ${apiKey}`,
        "Content-Type": "application/json",
      },
      body: JSON.stringify(config),
    },
    120_000,
  );
  if (!response.ok) {
    throw new Error(
      `Driver session create failed: ${response.status} ${await response.text()}`,
    );
  }
  const data = (await response.json()) as DriverSession;
  if (!data.sessionId || !data.cdpUrl) {
    throw new Error("Driver session create response missing sessionId or cdpUrl");
  }
  return data;
}

export async function stopDriverSession(apiKey: string, sessionId: string): Promise<void> {
  const url = new URL(DEFAULT_SESSION_URL);
  url.searchParams.set("sessionId", sessionId);
  const response = await requestWithTimeout(
    url.toString(),
    {
      method: "DELETE",
      headers: {
        Authorization: `Bearer ${apiKey}`,
      },
    },
    30_000,
  );
  if (!response.ok) {
    throw new Error(
      `Driver session stop failed: ${response.status} ${await response.text()}`,
    );
  }
}