Function probeOpenAI

packages/runtime/src/test-connection.ts:332–380

(
  connection: Pick<ConnectionEffectConnection, 'providerType'>,
  baseUrl: string,
  apiKey: string,
  model: string,
  t0: number,
  fetchFn: ConnectionEffectFetch | undefined,
  timeoutMs = CONNECTION_TEST_TIMEOUT_MS,
)

}

async function probeOpenAI(
  connection: Pick<ConnectionEffectConnection, 'providerType'>,
  baseUrl: string,
  apiKey: string,
  model: string,
  t0: number,
  fetchFn: ConnectionEffectFetch | undefined,
  timeoutMs = CONNECTION_TEST_TIMEOUT_MS,
): Promise<ConnectionTestResult> {
  if (connection.providerType === 'openai-codex') {
    // Codex Subscription credentials are ChatGPT account-scoped OAuth
    // tokens. A live `/responses` probe is not a stable readiness test:
    // the backend can hold or reject small synthetic requests even when
    // the stored login is valid and the real send path has enough context.
    // Mirror Claude OAuth and treat a resolved main-process OAuth token as
    // the explicit connection test; actual turn failures still surface in
    // chat with the provider error class.
    return { ok: true, latencyMs: Date.now() - t0, modelTested: model };
  }
  const r = await fetchForConnectionEffect(fetchFn, `${stripTrailing(baseUrl)}/chat/completions`, {
    method: 'POST',
    headers: {
      ...(apiKey ? { authorization: `Bearer ${apiKey}` } : {}),
      'content-type': 'application/json',
    },
    body: JSON.stringify({
      model,
      max_tokens: 16,
      messages: [{ role: 'user', content: 'Hi' }],
    }),
    timeoutMs,
  });
  if (!r.ok) return httpFailure(r, t0);
  if (connection.providerType === 'opencode-free') {
    const body = await r.readJson<unknown>();
    if (!isOpenAIChatCompletion(body)) {
      return {
        ok: false,
        errorMessage: 'OpenCode Free returned no valid chat completion',
        errorClass: 'provider_unavailable',
        latencyMs: Date.now() - t0,
        modelTested: model,
      };
    }
    return { ok: true, latencyMs: Date.now() - t0, modelTested: model };
  }
  await r.cancel();
  return { ok: true, latencyMs: Date.now() - t0, modelTested: model };
}

function isOpenAIChatCompletion(value: unknown): boolean {
  if (!value || typeof value !== 'object') return false;