Function createClient

packages/openapi-python/src/createClient.ts:26–210

({
  config,
  dependencies,
  jobIndex,
  logger,
  watches: _watches,
}: {
  config: Config;
  dependencies: Record<string, string>;
  jobIndex: number;
  logger: Logger;
  /**
   * Always undefined on the first run, defined on subsequent runs.
   */
  watches?: ReadonlyArray<WatchValues>;
})

import { PythonRenderer } from './py-dsl';

export async function createClient({
  config,
  dependencies,
  jobIndex,
  logger,
  watches: _watches,
}: {
  config: Config;
  dependencies: Record<string, string>;
  jobIndex: number;
  logger: Logger;
  /**
   * Always undefined on the first run, defined on subsequent runs.
   */
  watches?: ReadonlyArray<WatchValues>;
}): Promise<Context | undefined> {
  const watches: ReadonlyArray<WatchValues> =
    _watches ||
    Array.from({ length: config.input.length }, () => ({
      headers: new Headers(),
    }));

  const jobStart = Date.now();
  const inputPaths = config.input.map((input) => compileInputPath(input));

  // on first run, print the message as soon as possible
  if (!_watches) {
    logInputPaths(inputPaths, jobIndex, config.logs.level);
  }

  const getSpecData = async (input: Input, index: number) => {
    const eventSpec = logger.timeEvent('spec');
    const { arrayBuffer, error, resolvedInput, response } = await getSpec({
      fetchOptions: input.fetch,
      inputPath: inputPaths[index]!.path,
      timeout: input.watch.timeout,
      watch: watches[index]!,
    });
    eventSpec.timeEnd();

    // throw on first run if there's an error to preserve user experience
    // if in watch mode, subsequent errors won't throw to gracefully handle
    // cases where server might be reloading
    if (error && !_watches) {
      const text = await response.text().catch((): string => '');
      const message = `Request failed with status ${response.status}: ${text || response.statusText}`;
      // Handle 4xx client errors as input errors (bad URL, bad API key, etc.)
      if (response.status >= 400 && response.status < 500) {
        const statusText = response.statusText || 'Unknown';
        const originalError = new Error(message) as Error & { source?: string };
        originalError.source = String(inputPaths[index]!.path);
        throw new InputError(
          `Input request failed: ${response.status} ${statusText}`,
          originalError,
        );
      }
      // For 5xx server errors, keep the generic error (could be a bug)
      throw new Error(message);