fix: watch mode tweaks

Author: mrlubos

.changeset/gentle-deers-sit.md

@@ -0,0 +1,5 @@
+---
+'@hey-api/openapi-ts': patch
+---
+
+fix: watch mode handles servers not exposing HEAD method for spec

.changeset/happy-eels-kick.md

@@ -0,0 +1,5 @@
+---
+'@hey-api/openapi-ts': patch
+---
+
+fix: add watch.timeout option

docs/openapi-ts/configuration.md

@@ -273,7 +273,7 @@ Setting `output.clean` to `false` may result in broken output. Ensure you typech
 
 ## Config API
 
-You can view the complete list of options in the [UserConfig](https://github.com/hey-api/openapi-ts/blob/main/packages/openapi-ts/src/types/config.ts) interface.
+You can view the complete list of options in the [UserConfig](https://github.com/hey-api/openapi-ts/blob/main/packages/openapi-ts/src/types/config.d.ts) interface.
 
 <!--@include: ../examples.md-->
 <!--@include: ../sponsors.md-->

packages/openapi-ts/package.json

@@ -79,7 +79,7 @@
     "node": "^18.18.0 || ^20.9.0 || >=22.11.0"
   },
   "dependencies": {
-    "@hey-api/json-schema-ref-parser": "1.0.1",
+    "@hey-api/json-schema-ref-parser": "1.0.2",
     "c12": "2.0.1",
     "commander": "13.0.0",
     "handlebars": "4.7.8"

packages/openapi-ts/src/createClient.ts

@@ -0,0 +1,101 @@
+import path from 'node:path';
+
+import { generateLegacyOutput, generateOutput } from './generate/output';
+import { getSpec } from './getSpec';
+import type { IR } from './ir/types';
+import { parseLegacy, parseOpenApiSpec } from './openApi';
+import { processOutput } from './processOutput';
+import type { Client } from './types/client';
+import type { Config } from './types/config';
+import type { WatchValues } from './types/types';
+import { isLegacyClient, legacyNameFromConfig } from './utils/config';
+import type { Templates } from './utils/handlebars';
+import { Performance } from './utils/performance';
+import { postProcessClient } from './utils/postprocess';
+
+export const createClient = async ({
+  config,
+  templates,
+  watch: _watch,
+}: {
+  config: Config;
+  templates: Templates;
+  watch?: WatchValues;
+}) => {
+  const inputPath = config.input.path;
+  const timeout = config.watch.timeout;
+
+  const watch: WatchValues = _watch || { headers: new Headers() };
+
+  Performance.start('spec');
+  const { data, error, response } = await getSpec({
+    inputPath,
+    timeout,
+    watch,
+  });
+  Performance.end('spec');
+
+  // 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 && !_watch) {
+    throw new Error(
+      `Request failed with status ${response.status}: ${response.statusText}`,
+    );
+  }
+
+  let client: Client | undefined;
+  let context: IR.Context | undefined;
+
+  if (data) {
+    if (_watch) {
+      console.clear();
+      console.log(`⏳ Input changed, generating from ${inputPath}`);
+    } else {
+      console.log(`⏳ Generating from ${inputPath}`);
+    }
+
+    Performance.start('parser');
+    if (
+      config.experimentalParser &&
+      !isLegacyClient(config) &&
+      !legacyNameFromConfig(config)
+    ) {
+      context = parseOpenApiSpec({ config, spec: data });
+    }
+
+    // fallback to legacy parser
+    if (!context) {
+      const parsed = parseLegacy({ openApi: data });
+      client = postProcessClient(parsed, config);
+    }
+    Performance.end('parser');
+
+    Performance.start('generator');
+    if (context) {
+      await generateOutput({ context });
+    } else if (client) {
+      await generateLegacyOutput({ client, openApi: data, templates });
+    }
+    Performance.end('generator');
+
+    Performance.start('postprocess');
+    if (!config.dryRun) {
+      processOutput({ config });
+
+      const outputPath = process.env.INIT_CWD
+        ? `./${path.relative(process.env.INIT_CWD, config.output.path)}`
+        : config.output.path;
+      console.log(`🚀 Done! Your output is in ${outputPath}`);
+    }
+    Performance.end('postprocess');
+  }
+
+  if (config.watch.enabled && typeof inputPath === 'string') {
+    setTimeout(() => {
+      createClient({ config, templates, watch });
+    }, config.watch.interval);
+  }
+
+  return context || client;
+};

packages/openapi-ts/src/generate/__tests__/class.test.ts

@@ -60,7 +60,8 @@ describe('generateLegacyClientClass', () => {
       useOptions: true,
       watch: {
         enabled: false,
-        interval: 1000,
+        interval: 1_000,
+        timeout: 60_000,
       },
     });
 

packages/openapi-ts/src/generate/__tests__/core.test.ts

@@ -75,7 +75,8 @@ describe('generateLegacyCore', () => {
       useOptions: true,
       watch: {
         enabled: false,
-        interval: 1000,
+        interval: 1_000,
+        timeout: 60_000,
       },
     });
 
@@ -166,7 +167,8 @@ describe('generateLegacyCore', () => {
       useOptions: true,
       watch: {
         enabled: false,
-        interval: 1000,
+        interval: 1_000,
+        timeout: 60_000,
       },
     });
 
@@ -240,7 +242,8 @@ describe('generateLegacyCore', () => {
       useOptions: true,
       watch: {
         enabled: false,
-        interval: 1000,
+        interval: 1_000,
+        timeout: 60_000,
       },
     });
 

packages/openapi-ts/src/generate/__tests__/index.test.ts

@@ -59,7 +59,8 @@ describe('generateIndexFile', () => {
       useOptions: true,
       watch: {
         enabled: false,
-        interval: 1000,
+        interval: 1_000,
+        timeout: 60_000,
       },
     });
 

packages/openapi-ts/src/generate/__tests__/output.test.ts

@@ -61,7 +61,8 @@ describe('generateLegacyOutput', () => {
       useOptions: false,
       watch: {
         enabled: false,
-        interval: 1000,
+        interval: 1_000,
+        timeout: 60_000,
       },
     });
 

packages/openapi-ts/src/getLogs.ts

@@ -0,0 +1,17 @@
+import type { Config, UserConfig } from './types/config';
+
+export const getLogs = (userConfig: UserConfig): Config['logs'] => {
+  let logs: Config['logs'] = {
+    level: 'info',
+    path: process.cwd(),
+  };
+  if (typeof userConfig.logs === 'string') {
+    logs.path = userConfig.logs;
+  } else {
+    logs = {
+      ...logs,
+      ...userConfig.logs,
+    };
+  }
+  return logs;
+};