chore: regenerate

infiniteregrets · infiniteregrets · commit 75429a336947 · 2025-03-11T13:31:05.000-04:00
diff --git a/.speakeasy/gen.lock b/.speakeasy/gen.lock
@@ -1,20 +1,20 @@
 lockVersion: 2.0.0
 id: 2d20490e-9921-47d5-9711-d3c4b91c8cfa
 management:
-  docChecksum: 7c839b3c9b2925069b31d7192dfc6c2e
+  docChecksum: 23f42b58e87a7663f5f4b25666a46888
   docVersion: 1.0.0
-  speakeasyVersion: 1.514.0
-  generationVersion: 2.546.0
-  releaseVersion: 0.7.6
-  configChecksum: ab20053dd820fb0ae70e2c23192fa57a
+  speakeasyVersion: 1.515.0
+  generationVersion: 2.547.2
+  releaseVersion: 0.8.0
+  configChecksum: 572e6900829fb68746dab10a09b39214
   repoURL: https://github.com/s2-streamstore/s2-sdk-typescript.git
   installationURL: https://github.com/s2-streamstore/s2-sdk-typescript
   published: true
 features:
   typescript:
     acceptHeaders: 2.81.2
     additionalDependencies: 0.1.0
-    core: 3.21.3
+    core: 3.21.4
     defaultEnabledRetries: 0.1.0
     devContainers: 2.90.0
     enumUnions: 0.1.0
@@ -23,7 +23,7 @@ features:
     globalSecurityCallbacks: 0.1.0
     globalSecurityFlattening: 0.1.0
     globalServerURLs: 2.82.4
-    mcpServer: 0.6.0
+    mcpServer: 0.7.0
     methodServerURLs: 2.82.1
     nullables: 0.1.1
     pagination: 2.83.0
diff --git a/.speakeasy/gen.yaml b/.speakeasy/gen.yaml
@@ -18,7 +18,7 @@ generation:
     oAuth2ClientCredentialsEnabled: true
     oAuth2PasswordEnabled: true
 typescript:
-  version: 0.7.6
+  version: 0.8.0
   additionalDependencies:
     dependencies:
       uuid: ^9.0.1
diff --git a/.speakeasy/workflow.lock b/.speakeasy/workflow.lock
@@ -1,20 +1,20 @@
-speakeasyVersion: 1.514.0
+speakeasyVersion: 1.515.0
 sources:
     S2 API:
         sourceNamespace: s-2-api
-        sourceRevisionDigest: sha256:bef42cc20bb77e53e7577a999da223794d048ad98ce438e6df04b9fefbc2dafd
-        sourceBlobDigest: sha256:cc4df25935d2e51786a891356ba89a60ef6b781e6f4ec209937763357ff98bb8
+        sourceRevisionDigest: sha256:05effe964d65865f8cf78165cfb5c869ebd548fcb4d1388eaea80715d040873f
+        sourceBlobDigest: sha256:0e4e392546802337dc61a34779aa909e94a055dd9f98907472e2f75ebf087a3c
         tags:
             - latest
             - 1.0.0
 targets:
     streamstore:
         source: S2 API
         sourceNamespace: s-2-api
-        sourceRevisionDigest: sha256:bef42cc20bb77e53e7577a999da223794d048ad98ce438e6df04b9fefbc2dafd
-        sourceBlobDigest: sha256:cc4df25935d2e51786a891356ba89a60ef6b781e6f4ec209937763357ff98bb8
+        sourceRevisionDigest: sha256:05effe964d65865f8cf78165cfb5c869ebd548fcb4d1388eaea80715d040873f
+        sourceBlobDigest: sha256:0e4e392546802337dc61a34779aa909e94a055dd9f98907472e2f75ebf087a3c
         codeSamplesNamespace: s-2-api-typescript-code-samples
-        codeSamplesRevisionDigest: sha256:9d88cb06336f142996ca335355a3cf4c7580fb0b44964529d00947e867855541
+        codeSamplesRevisionDigest: sha256:205adf52b387c2adfd064d155ab7fd0d09a7ef4734b2e8e7919c595b4d46f92d
 workflow:
     workflowVersion: 1.0.0
     speakeasyVersion: latest
diff --git a/docs/models/components/basinconfig.md b/docs/models/components/basinconfig.md
@@ -7,11 +7,14 @@ Basin configuration.
 ```typescript
 import { BasinConfig } from "@s2-dev/streamstore/models/components";
 
-let value: BasinConfig = {};
+let value: BasinConfig = {
+  createStreamOnAppend: false,
+};
 ```
 
 ## Fields
 
-| Field                                                              | Type                                                               | Required                                                           | Description                                                        |
-| ------------------------------------------------------------------ | ------------------------------------------------------------------ | ------------------------------------------------------------------ | ------------------------------------------------------------------ |
-| `defaultStreamConfig`                                              | [components.StreamConfig](../../models/components/streamconfig.md) | :heavy_minus_sign:                                                 | N/A                                                                |
+| Field                                                                                | Type                                                                                 | Required                                                                             | Description                                                                          |
+| ------------------------------------------------------------------------------------ | ------------------------------------------------------------------------------------ | ------------------------------------------------------------------------------------ | ------------------------------------------------------------------------------------ |
+| `createStreamOnAppend`                                                               | *boolean*                                                                            | :heavy_check_mark:                                                                   | Create stream on append if it doesn't exist,<br/>using the default stream configuration. |
+| `defaultStreamConfig`                                                                | [components.StreamConfig](../../models/components/streamconfig.md)                   | :heavy_minus_sign:                                                                   | N/A                                                                                  |
diff --git a/docs/models/operations/reconfigurebasinrequest.md b/docs/models/operations/reconfigurebasinrequest.md
@@ -7,7 +7,9 @@ import { ReconfigureBasinRequest } from "@s2-dev/streamstore/models/operations";
 
 let value: ReconfigureBasinRequest = {
   basin: "<value>",
-  basinConfig: {},
+  basinConfig: {
+    createStreamOnAppend: false,
+  },
 };
 ```
 
diff --git a/docs/sdks/account/README.md b/docs/sdks/account/README.md
@@ -346,7 +346,9 @@ const s2 = new S2({
 async function run() {
   const result = await s2.account.reconfigureBasin({
     basin: "<value>",
-    basinConfig: {},
+    basinConfig: {
+      createStreamOnAppend: false,
+    },
   });
 
   // Handle the result
@@ -373,7 +375,9 @@ const s2 = new S2Core({
 async function run() {
   const res = await accountReconfigureBasin(s2, {
     basin: "<value>",
-    basinConfig: {},
+    basinConfig: {
+      createStreamOnAppend: false,
+    },
   });
 
   if (!res.ok) {
diff --git a/jsr.json b/jsr.json
@@ -2,7 +2,7 @@
 
 {
   "name": "@s2-dev/streamstore",
-  "version": "0.7.6",
+  "version": "0.8.0",
   "exports": {
     ".": "./src/index.ts",    
     "./models/errors": "./src/models/errors/index.ts",    
diff --git a/package-lock.json b/package-lock.json
diff --git a/package.json b/package.json
@@ -1,6 +1,6 @@
 {
   "name": "@s2-dev/streamstore",
-  "version": "0.7.6",
+  "version": "0.8.0",
   "author": "Speakeasy",
   "type": "module",
   "bin": {
diff --git a/src/lib/config.ts b/src/lib/config.ts
@@ -54,7 +54,7 @@ export function serverURLFromOptions(options: SDKOptions): URL | null {
 export const SDK_METADATA = {
   language: "typescript",
   openapiDocVersion: "1.0.0",
-  sdkVersion: "0.7.6",
-  genVersion: "2.546.0",
-  userAgent: "speakeasy-sdk/typescript 0.7.6 2.546.0 1.0.0 @s2-dev/streamstore",
+  sdkVersion: "0.8.0",
+  genVersion: "2.547.2",
+  userAgent: "speakeasy-sdk/typescript 0.8.0 2.547.2 1.0.0 @s2-dev/streamstore",
 } as const;
diff --git a/src/lib/sdks.ts b/src/lib/sdks.ts
@@ -195,14 +195,9 @@ export class ClientSDK {
 
     if (conf.body instanceof ReadableStream) {
       if (!fetchOptions) {
-        fetchOptions = {
-          // @ts-expect-error see https://github.com/node-fetch/node-fetch/issues/1769
-          duplex: "half",
-        };
-      } else {
-        // @ts-expect-error see https://github.com/node-fetch/node-fetch/issues/1769
-        fetchOptions.duplex = "half";
+        fetchOptions = {};
       }
+      Object.assign(fetchOptions, { duplex: "half" });
     }
 
     let input;
diff --git a/src/mcp-server/mcp-server.ts b/src/mcp-server/mcp-server.ts
@@ -19,7 +19,7 @@ const routes = buildRouteMap({
 export const app = buildApplication(routes, {
   name: "mcp",
   versionInfo: {
-    currentVersion: "0.7.6",
+    currentVersion: "0.8.0",
   },
 });
 
diff --git a/src/mcp-server/server.ts b/src/mcp-server/server.ts
@@ -36,7 +36,7 @@ export function createMCPServer(deps: {
 }) {
   const server = new McpServer({
     name: "S2",
-    version: "0.7.6",
+    version: "0.8.0",
   });
 
   const client = new S2Core({
diff --git a/src/mcp-server/tools.ts b/src/mcp-server/tools.ts
@@ -102,6 +102,10 @@ export function createRegisterTool(
     }
 
     const toolScopes = tool.scopes ?? [];
+    if (allowedScopes.size > 0 && toolScopes.length === 0) {
+      return;
+    }
+
     if (!toolScopes.every((s) => allowedScopes.has(s))) {
       return;
     }
diff --git a/src/mcp-server/tools/accountCreateBasin.ts b/src/mcp-server/tools/accountCreateBasin.ts
@@ -11,7 +11,7 @@ const args = {
 };
 
 export const tool$accountCreateBasin: ToolDefinition<typeof args> = {
-  name: "account_create-basin",
+  name: "account-create-basin",
   description: `Create a new basin.`,
   scopes: ["write"],
   args,
diff --git a/src/mcp-server/tools/accountDeleteBasin.ts b/src/mcp-server/tools/accountDeleteBasin.ts
@@ -11,7 +11,7 @@ const args = {
 };
 
 export const tool$accountDeleteBasin: ToolDefinition<typeof args> = {
-  name: "account_delete-basin",
+  name: "account-delete-basin",
   description: `Delete a basin.`,
   scopes: ["write"],
   args,
diff --git a/src/mcp-server/tools/accountGetBasinConfig.ts b/src/mcp-server/tools/accountGetBasinConfig.ts
@@ -11,7 +11,7 @@ const args = {
 };
 
 export const tool$accountGetBasinConfig: ToolDefinition<typeof args> = {
-  name: "account_get-basin-config",
+  name: "account-get-basin-config",
   description: `Get basin configuration.`,
   scopes: ["read"],
   args,
diff --git a/src/mcp-server/tools/accountListBasins.ts b/src/mcp-server/tools/accountListBasins.ts
@@ -11,7 +11,7 @@ const args = {
 };
 
 export const tool$accountListBasins: ToolDefinition<typeof args> = {
-  name: "account_list-basins",
+  name: "account-list-basins",
   description: `List basins.`,
   scopes: ["read"],
   args,
diff --git a/src/mcp-server/tools/accountReconfigureBasin.ts b/src/mcp-server/tools/accountReconfigureBasin.ts
@@ -11,7 +11,7 @@ const args = {
 };
 
 export const tool$accountReconfigureBasin: ToolDefinition<typeof args> = {
-  name: "account_reconfigure-basin",
+  name: "account-reconfigure-basin",
   description: `Update basin configuration.`,
   scopes: ["write"],
   args,
diff --git a/src/mcp-server/tools/basinCreateStream.ts b/src/mcp-server/tools/basinCreateStream.ts
@@ -11,7 +11,7 @@ const args = {
 };
 
 export const tool$basinCreateStream: ToolDefinition<typeof args> = {
-  name: "basin_create-stream",
+  name: "basin-create-stream",
   description: `Create a stream.`,
   scopes: ["write"],
   args,
diff --git a/src/mcp-server/tools/basinDeleteStream.ts b/src/mcp-server/tools/basinDeleteStream.ts
@@ -11,7 +11,7 @@ const args = {
 };
 
 export const tool$basinDeleteStream: ToolDefinition<typeof args> = {
-  name: "basin_delete-stream",
+  name: "basin-delete-stream",
   description: `Delete a stream.`,
   scopes: ["write"],
   args,
diff --git a/src/mcp-server/tools/basinGetStreamConfig.ts b/src/mcp-server/tools/basinGetStreamConfig.ts
@@ -11,7 +11,7 @@ const args = {
 };
 
 export const tool$basinGetStreamConfig: ToolDefinition<typeof args> = {
-  name: "basin_get-stream-config",
+  name: "basin-get-stream-config",
   description: `Get stream configuration.`,
   scopes: ["read"],
   args,
diff --git a/src/mcp-server/tools/basinListStreams.ts b/src/mcp-server/tools/basinListStreams.ts
@@ -11,7 +11,7 @@ const args = {
 };
 
 export const tool$basinListStreams: ToolDefinition<typeof args> = {
-  name: "basin_list-streams",
+  name: "basin-list-streams",
   description: `List Streams.`,
   scopes: ["read"],
   args,
diff --git a/src/mcp-server/tools/basinReconfigureStream.ts b/src/mcp-server/tools/basinReconfigureStream.ts
@@ -11,7 +11,7 @@ const args = {
 };
 
 export const tool$basinReconfigureStream: ToolDefinition<typeof args> = {
-  name: "basin_reconfigure-stream",
+  name: "basin-reconfigure-stream",
   description: `Update stream configuration.`,
   scopes: ["write"],
   args,
diff --git a/src/mcp-server/tools/streamAppend.ts b/src/mcp-server/tools/streamAppend.ts
@@ -11,7 +11,7 @@ const args = {
 };
 
 export const tool$streamAppend: ToolDefinition<typeof args> = {
-  name: "stream_append",
+  name: "stream-append",
   description: `Append records.
 
 Append a batch of records to a stream.`,
diff --git a/src/mcp-server/tools/streamCheckTail.ts b/src/mcp-server/tools/streamCheckTail.ts
@@ -11,7 +11,7 @@ const args = {
 };
 
 export const tool$streamCheckTail: ToolDefinition<typeof args> = {
-  name: "stream_check-tail",
+  name: "stream-check-tail",
   description: `Check the tail.
 
 Check the sequence number that will be assigned to the next record on a stream.`,
diff --git a/src/mcp-server/tools/streamRead.ts b/src/mcp-server/tools/streamRead.ts
@@ -11,7 +11,7 @@ const args = {
 };
 
 export const tool$streamRead: ToolDefinition<typeof args> = {
-  name: "stream_read",
+  name: "stream-read",
   description: `Retrieve records.
 
 Retrieve a batch of records, or set \`Accept: text/event-stream\` to stream using server-sent events.`,
diff --git a/src/models/components/basinconfig.ts b/src/models/components/basinconfig.ts
@@ -18,6 +18,13 @@ import {
  * Basin configuration.
  */
 export type BasinConfig = {
+  /**
+   * Create stream on append if it doesn't exist,
+   *
+   * @remarks
+   * using the default stream configuration.
+   */
+  createStreamOnAppend: boolean;
   defaultStreamConfig?: StreamConfig | null | undefined;
 };
 
@@ -27,15 +34,18 @@ export const BasinConfig$inboundSchema: z.ZodType<
   z.ZodTypeDef,
   unknown
 > = z.object({
+  create_stream_on_append: z.boolean(),
   default_stream_config: z.nullable(StreamConfig$inboundSchema).optional(),
 }).transform((v) => {
   return remap$(v, {
+    "create_stream_on_append": "createStreamOnAppend",
     "default_stream_config": "defaultStreamConfig",
   });
 });
 
 /** @internal */
 export type BasinConfig$Outbound = {
+  create_stream_on_append: boolean;
   default_stream_config?: StreamConfig$Outbound | null | undefined;
 };
 
@@ -45,9 +55,11 @@ export const BasinConfig$outboundSchema: z.ZodType<
   z.ZodTypeDef,
   BasinConfig
 > = z.object({
+  createStreamOnAppend: z.boolean(),
   defaultStreamConfig: z.nullable(StreamConfig$outboundSchema).optional(),
 }).transform((v) => {
   return remap$(v, {
+    createStreamOnAppend: "create_stream_on_append",
     defaultStreamConfig: "default_stream_config",
   });
 });

Original file line number	Diff line number	Diff line change
`@@ -2,7 +2,7 @@`
`2`	`2`
`3`	`3`	`{`
`4`	`4`	`"name": "@s2-dev/streamstore",`
`5`		`- "version": "0.7.6",`
	`5`	`+ "version": "0.8.0",`
`6`	`6`	`"exports": {`
`7`	`7`	`".": "./src/index.ts",`
`8`	`8`	`"./models/errors": "./src/models/errors/index.ts",`
Original file line number	Diff line number	Diff line change
`@@ -1,6 +1,6 @@`
`1`	`1`	`{`
`2`	`2`	`"name": "@s2-dev/streamstore",`
`3`		`- "version": "0.7.6",`
	`3`	`+ "version": "0.8.0",`
`4`	`4`	`"author": "Speakeasy",`
`5`	`5`	`"type": "module",`
`6`	`6`	`"bin": {`