feat(api): regenerate for LMNT API 1.1

Baseline regeneration for the 1.1 spec; further refinements will
follow as smaller deltas on top.

Author: zachoverflow

_carbonsteel.json

@@ -1,7 +1,7 @@
 {
-  "version": "1.0.0",
-  "generated_at": "2026-04-27T23:27:14Z",
-  "spec_sha": "04a10d47ed2270bd:510635fad1875bc4",
+  "version": "1.1",
+  "generated_at": "2026-05-07T23:13:22Z",
+  "spec_sha": "dd2556942628d8b4:63d381c5e2045349",
   "files": [
     "api.md",
     "src/_shims/MultipartBody.ts",
@@ -32,6 +32,7 @@
     "src/_shims/web-types.d.ts",
     "src/_shims/web-types.js",
     "src/_shims/web-types.mjs",
+    "src/_websocketRuntime.ts",
     "src/core.ts",
     "src/error.ts",
     "src/index.ts",
@@ -45,6 +46,7 @@
     "src/uploads.ts",
     "src/version.ts",
     "tests/api-resources/accounts.test.ts",
+    "tests/api-resources/sessions.test.ts",
     "tests/api-resources/speech.test.ts",
     "tests/api-resources/voices.test.ts",
     "tests/form.test.ts",

src/_websocketRuntime.ts

@@ -0,0 +1,58 @@
+// Vendored by carbonsteel. DO NOT EDIT here in the SDK; edit
+// tool/carbonsteel/src/lmnt/tool/carbonsteel/codegen/node/vendor/src/_websocketRuntime.ts
+// in the monorepo and re-run carbonsteel.
+//
+// Spec-agnostic WebSocket session helpers shared by the generated SpeechSession.
+// MessageQueue: simple async resolver/buffer pair so the generated session can
+// expose an `AsyncIterator` while the underlying WebSocket pushes via callbacks.
+// processAudioData: normalises Blob/Buffer payloads to a uniform binary type.
+
+import { Buffer } from 'buffer';
+import { LmntError } from './error';
+
+export const WEBSOCKET_OPEN_STATE = 1;
+export const WEBSOCKET_NORMAL_CLOSE = 1000;
+
+export class MessageQueue {
+  private messages: any[] = [];
+  private resolvers: ((value: any) => void)[] = [];
+  private done = false;
+
+  finish() {
+    this.done = true;
+    while (this.resolvers.length) {
+      const resolve = this.resolvers.shift();
+      resolve?.(null);
+    }
+  }
+
+  push(message: any) {
+    if (this.done) return;
+    if (this.resolvers.length) {
+      const resolve = this.resolvers.shift();
+      resolve?.(message);
+    } else {
+      this.messages.push(message);
+    }
+  }
+
+  async next() {
+    if (this.messages.length) {
+      return this.messages.shift();
+    }
+    if (this.done) {
+      return null;
+    }
+    return new Promise((resolve) => this.resolvers.push(resolve));
+  }
+}
+
+export async function processAudioData(audioData: Blob | Buffer): Promise<ArrayBuffer | Buffer> {
+  if (audioData instanceof Blob) {
+    return await audioData.arrayBuffer();
+  } else if (audioData instanceof Buffer) {
+    return audioData;
+  } else {
+    throw new LmntError(`Unexpected message type received from server: ${audioData}`);
+  }
+}

src/core.ts

@@ -74,7 +74,7 @@ async function defaultParseResponse<T>(props: APIResponseProps): Promise<T> {
 
     debug('response', response.status, response.url, response.headers, json);
 
-    return json as T;
+    return addRequestID(json as T, response);
   }
 
   const text = await response.text();
@@ -84,6 +84,27 @@ async function defaultParseResponse<T>(props: APIResponseProps): Promise<T> {
   return text as unknown as T;
 }
 
+/**
+ * Attaches `_request_id` (read from the `request-id` response header) as a non-enumerable
+ * property on object responses. Skipped for arrays and non-objects (callers can read the
+ * `request-id` header from the underlying `Response` directly via `.withResponse()`).
+ */
+export function addRequestID<T>(value: T, response: Response): T {
+  if (!value || typeof value !== 'object' || Array.isArray(value)) {
+    return value;
+  }
+  return Object.defineProperty(value, '_request_id', {
+    value: response.headers.get('request-id'),
+    enumerable: false,
+  }) as T;
+}
+
+/** Optional `_request_id` field added to plain-object responses by `addRequestID`. */
+export type WithRequestID<T> =
+  T extends Array<any> | Response ? T
+  : T extends Record<string, any> ? T & { _request_id?: string | null }
+  : T;
+
 /**
  * A subclass of `Promise` providing additional helper methods
  * for interacting with the SDK.

src/error.ts

@@ -16,11 +16,25 @@ export class APIError<
   /** JSON body of the response that caused the error */
   readonly error: TError;
 
-  constructor(status: TStatus, error: TError, message: string | undefined, headers: THeaders) {
+  /** The unique identifier of the request that caused this error, matching the `request-id` response header. */
+  readonly requestID: string | null | undefined;
+
+  /** The `error.type` from the API response body, e.g. `"rate_limit_error"`. */
+  readonly type: string | null;
+
+  constructor(
+    status: TStatus,
+    error: TError,
+    message: string | undefined,
+    headers: THeaders,
+    type?: string | null,
+  ) {
     super(`${APIError.makeMessage(status, error, message)}`);
     this.status = status;
     this.headers = headers;
+    this.requestID = headers?.['request-id'] ?? undefined;
     this.error = error;
+    this.type = type ?? null;
   }
 
   private static makeMessage(status: number | undefined, error: any, message: string | undefined) {
@@ -55,40 +69,41 @@ export class APIError<
     }
 
     const error = errorResponse as Record<string, any>;
+    const type = (error?.['error']?.['type'] as string | undefined) ?? null;
 
     if (status === 400) {
-      return new BadRequestError(status, error, message, headers);
+      return new BadRequestError(status, error, message, headers, type);
     }
 
     if (status === 401) {
-      return new AuthenticationError(status, error, message, headers);
+      return new AuthenticationError(status, error, message, headers, type);
     }
 
     if (status === 403) {
-      return new PermissionDeniedError(status, error, message, headers);
+      return new PermissionDeniedError(status, error, message, headers, type);
     }
 
     if (status === 404) {
-      return new NotFoundError(status, error, message, headers);
+      return new NotFoundError(status, error, message, headers, type);
     }
 
     if (status === 409) {
-      return new ConflictError(status, error, message, headers);
+      return new ConflictError(status, error, message, headers, type);
     }
 
     if (status === 422) {
-      return new UnprocessableEntityError(status, error, message, headers);
+      return new UnprocessableEntityError(status, error, message, headers, type);
     }
 
     if (status === 429) {
-      return new RateLimitError(status, error, message, headers);
+      return new RateLimitError(status, error, message, headers, type);
     }
 
     if (status >= 500) {
-      return new InternalServerError(status, error, message, headers);
+      return new InternalServerError(status, error, message, headers, type);
     }
 
-    return new APIError(status, error, message, headers);
+    return new APIError(status, error, message, headers, type);
   }
 }
 

src/index.ts

@@ -4,6 +4,7 @@ import { type Agent } from './_shims/index';
 import * as Core from './core';
 import * as Errors from './error';
 import * as Uploads from './uploads';
+import { LMNT_API_VERSION } from './version';
 import * as API from './resources/index';
 import {
   Speech,
@@ -158,6 +159,7 @@ export class Lmnt extends Core.APIClient {
   protected override defaultHeaders(opts: Core.FinalRequestOptions): Core.Headers {
     return {
       ...super.defaultHeaders(opts),
+      'lmnt-version': LMNT_API_VERSION,
       ...this._options.defaultHeaders,
     };
   }