Function convertOpenAIError

packages/kosong/src/providers/openai-common.ts:92–130

(error: unknown)

 * Convert an OpenAI SDK error (or raw Error) to a kosong `ChatProviderError`.
 */
export function convertOpenAIError(error: unknown): ChatProviderError {
  if (error instanceof ChatProviderError) {
    return error;
  }
  // v6: APIConnectionTimeoutError extends APIConnectionError, check timeout first
  if (error instanceof OpenAITimeoutError) {
    return new APITimeoutError(error.message);
  }
  if (error instanceof OpenAIConnectionError) {
    return new APIConnectionError(error.message);
  }
  // APIError with a status code => status error
  if (error instanceof OpenAIAPIError && typeof error.status === 'number') {
    const reqId = error.requestID ?? null;
    return normalizeAPIStatusError(error.status, error.message, reqId);
  }
  // Base APIError with no status and no body => transport-layer failure.
  // When the error has a body (e.g. SSE error events from the server),
  // skip the heuristic to avoid misclassifying server-side errors.
  if (
    error instanceof OpenAIAPIError &&
    error.constructor === OpenAIAPIError &&
    error.error === undefined
  ) {
    return classifyBaseApiError(error.message);
  }
  if (error instanceof OpenAIError) {
    return new ChatProviderError(`Error: ${error.message}`);
  }
  // Raw, non-SDK errors (e.g. undici's `TypeError: terminated` raised when a
  // streaming response body is dropped mid-flight) never get wrapped by the
  // OpenAI SDK during stream iteration. Route them through the same
  // transport-layer heuristic so genuine connection failures become
  // retryable instead of fatal generic errors.
  if (error instanceof Error) {
    return classifyBaseApiError(error.message);
  }
  return new ChatProviderError(`Error: ${String(error)}`);
}
/** Shape of a function-type tool call (subset used by the guard). */
export interface FunctionToolCallShape {
  type: 'function';