import type { OpenVikingClient } from "./client.js";

export function withTimeout<T>(promise: Promise<T>, timeoutMs: number, timeoutMessage: string): Promise<T> {
  return new Promise((resolve, reject) => {
    const timer = setTimeout(() => reject(new Error(timeoutMessage)), timeoutMs);
    promise.then(
      (value) => {
        clearTimeout(timer);
        resolve(value);
      },
      (err) => {
        clearTimeout(timer);
        reject(err);
      },
    );
  });
}

export async function quickHealthCheck(
  client: OpenVikingClient,
  agentId: string | undefined,
  timeoutMs: number,
): Promise<boolean> {
  try {
    await client.healthCheck(timeoutMs, agentId);
    return true;
  } catch {
    return false;
  }
}

export async function quickRecallPrecheck(
  client: OpenVikingClient,
  agentId?: string,
): Promise<{ ok: true } | { ok: false; reason: string }> {
  const healthOk = await quickHealthCheck(client, agentId, 500);
  if (healthOk) {
    return { ok: true };
  }
  return { ok: false, reason: "health check failed" };
}