release for sse heartbeat

infiniteregrets · infiniteregrets · commit 99c49fddf9d3 · 2025-03-07T13:23:16.000-05:00
diff --git a/.speakeasy/gen.lock b/.speakeasy/gen.lock
@@ -1,12 +1,12 @@
 lockVersion: 2.0.0
 id: 2d20490e-9921-47d5-9711-d3c4b91c8cfa
 management:
-  docChecksum: 07391cade7c3cb454a12cd9adee46b89
+  docChecksum: deebedbb7334d4fd56b50a655b7543d6
   docVersion: 1.0.0
-  speakeasyVersion: 1.505.0
-  generationVersion: 2.531.0
-  releaseVersion: 0.5.2
-  configChecksum: a7c3f56f1e1d8a289e621dabc673c527
+  speakeasyVersion: 1.513.2
+  generationVersion: 2.545.2
+  releaseVersion: 0.7.0
+  configChecksum: dda0a94310d35cfb7716c7b21a29741c
   repoURL: https://github.com/s2-streamstore/s2-sdk-typescript.git
   installationURL: https://github.com/s2-streamstore/s2-sdk-typescript
   published: true
@@ -23,7 +23,7 @@ features:
     globalSecurityCallbacks: 0.1.0
     globalSecurityFlattening: 0.1.0
     globalServerURLs: 2.82.4
-    mcpServer: 0.3.0
+    mcpServer: 0.6.0
     methodServerURLs: 2.82.1
     nullables: 0.1.1
     pagination: 2.83.0
@@ -56,15 +56,19 @@ generatedFiles:
   - docs/models/components/createbasinrequest.md
   - docs/models/components/createstreamrequest.md
   - docs/models/components/errort.md
+  - docs/models/components/event.md
   - docs/models/components/firstseqnum.md
   - docs/models/components/formatoption.md
   - docs/models/components/header.md
   - docs/models/components/listbasinsresponse.md
   - docs/models/components/liststreamsresponse.md
+  - docs/models/components/message.md
   - docs/models/components/nextseqnum.md
   - docs/models/components/output.md
+  - docs/models/components/ping.md
   - docs/models/components/readresponse.md
-  - docs/models/components/readresponseoutput.md
+  - docs/models/components/readresponse3event.md
+  - docs/models/components/readresponseevent.md
   - docs/models/components/retentionpolicy.md
   - docs/models/components/scope.md
   - docs/models/components/security.md
@@ -142,6 +146,7 @@ generatedFiles:
   - src/mcp-server/cli/start/command.ts
   - src/mcp-server/cli/start/impl.ts
   - src/mcp-server/console-logger.ts
+  - src/mcp-server/extensions.ts
   - src/mcp-server/mcp-server.ts
   - src/mcp-server/resources.ts
   - src/mcp-server/scopes.ts
diff --git a/.speakeasy/gen.yaml b/.speakeasy/gen.yaml
@@ -18,7 +18,7 @@ generation:
     oAuth2ClientCredentialsEnabled: true
     oAuth2PasswordEnabled: true
 typescript:
-  version: 0.5.2
+  version: 0.7.0
   additionalDependencies:
     dependencies:
       uuid: ^9.0.1
diff --git a/.speakeasy/workflow.lock b/.speakeasy/workflow.lock
@@ -1,20 +1,20 @@
-speakeasyVersion: 1.505.0
+speakeasyVersion: 1.513.2
 sources:
     S2 API:
         sourceNamespace: s-2-api
-        sourceRevisionDigest: sha256:b665d4a0efce3c6f1e42efd0e591706fd056910195690483b3c941cc5c3681a6
-        sourceBlobDigest: sha256:85a629f07b9d45e43ce9ee38cf75894c2e007828b338ccbcda990d2f9dfaa7ec
+        sourceRevisionDigest: sha256:fe70df1ff95a1323aa4a63d06955f23fa882d54d9b9a3665cac7b0da656319be
+        sourceBlobDigest: sha256:160fe652db09e8ae1c112f0027282678157362a74c0b1230abd2ee671ed8f77b
         tags:
             - latest
             - 1.0.0
 targets:
     streamstore:
         source: S2 API
         sourceNamespace: s-2-api
-        sourceRevisionDigest: sha256:b665d4a0efce3c6f1e42efd0e591706fd056910195690483b3c941cc5c3681a6
-        sourceBlobDigest: sha256:85a629f07b9d45e43ce9ee38cf75894c2e007828b338ccbcda990d2f9dfaa7ec
+        sourceRevisionDigest: sha256:fe70df1ff95a1323aa4a63d06955f23fa882d54d9b9a3665cac7b0da656319be
+        sourceBlobDigest: sha256:160fe652db09e8ae1c112f0027282678157362a74c0b1230abd2ee671ed8f77b
         codeSamplesNamespace: s-2-api-typescript-code-samples
-        codeSamplesRevisionDigest: sha256:dacefd8aa47a8f7dfd39542849d9731f381bd635d3f0dde7e498c43ef1171a2a
+        codeSamplesRevisionDigest: sha256:f6981ca95c8fa8bd83f53256040b95dd2329e3f44de76a4888d5d2f41ac304dd
 workflow:
     workflowVersion: 1.0.0
     speakeasyVersion: latest
diff --git a/docs/models/components/errort.md b/docs/models/components/errort.md
@@ -7,13 +7,13 @@ import { ErrorT } from "@s2-dev/streamstore/models/components";
 
 let value: ErrorT = {
   data: "<value>",
-  event: "<value>",
+  event: "error",
 };
 ```
 
 ## Fields
 
-| Field              | Type               | Required           | Description        |
-| ------------------ | ------------------ | ------------------ | ------------------ |
-| `data`             | *string*           | :heavy_check_mark: | N/A                |
-| `event`            | *string*           | :heavy_check_mark: | N/A                |
+| Field                                                                        | Type                                                                         | Required                                                                     | Description                                                                  |
+| ---------------------------------------------------------------------------- | ---------------------------------------------------------------------------- | ---------------------------------------------------------------------------- | ---------------------------------------------------------------------------- |
+| `data`                                                                       | *string*                                                                     | :heavy_check_mark:                                                           | N/A                                                                          |
+| `event`                                                                      | [components.ReadResponseEvent](../../models/components/readresponseevent.md) | :heavy_check_mark:                                                           | N/A                                                                          |
diff --git a/docs/models/components/event.md b/docs/models/components/event.md
@@ -0,0 +1,15 @@
+# Event
+
+## Example Usage
+
+```typescript
+import { Event } from "@s2-dev/streamstore/models/components";
+
+let value: Event = "message";
+```
+
+## Values
+
+```typescript
+"message"
+```
diff --git a/docs/models/components/message.md b/docs/models/components/message.md
@@ -1,11 +1,11 @@
-# ReadResponseOutput
+# Message
 
 ## Example Usage
 
 ```typescript
-import { ReadResponseOutput } from "@s2-dev/streamstore/models/components";
+import { Message } from "@s2-dev/streamstore/models/components";
 
-let value: ReadResponseOutput = {
+let value: Message = {
   data: {
     batch: {
       records: [
@@ -22,7 +22,7 @@ let value: ReadResponseOutput = {
       ],
     },
   },
-  event: "<value>",
+  event: "message",
 };
 ```
 
@@ -31,4 +31,4 @@ let value: ReadResponseOutput = {
 | Field                                                                                              | Type                                                                                               | Required                                                                                           | Description                                                                                        |
 | -------------------------------------------------------------------------------------------------- | -------------------------------------------------------------------------------------------------- | -------------------------------------------------------------------------------------------------- | -------------------------------------------------------------------------------------------------- |
 | `data`                                                                                             | *components.Output*                                                                                | :heavy_check_mark:                                                                                 | Reply which can be a batch of records, or a sequence number if the request could not be satisfied. |
-| `event`                                                                                            | *string*                                                                                           | :heavy_check_mark:                                                                                 | N/A                                                                                                |
+| `event`                                                                                            | [components.Event](../../models/components/event.md)                                               | :heavy_check_mark:                                                                                 | N/A                                                                                                |
diff --git a/docs/models/components/ping.md b/docs/models/components/ping.md
@@ -0,0 +1,17 @@
+# Ping
+
+## Example Usage
+
+```typescript
+import { Ping } from "@s2-dev/streamstore/models/components";
+
+let value: Ping = {
+  event: "ping",
+};
+```
+
+## Fields
+
+| Field                                                                          | Type                                                                           | Required                                                                       | Description                                                                    |
+| ------------------------------------------------------------------------------ | ------------------------------------------------------------------------------ | ------------------------------------------------------------------------------ | ------------------------------------------------------------------------------ |
+| `event`                                                                        | [components.ReadResponse3Event](../../models/components/readresponse3event.md) | :heavy_check_mark:                                                             | N/A                                                                            |
diff --git a/docs/models/components/readresponse.md b/docs/models/components/readresponse.md
@@ -3,10 +3,10 @@
 
 ## Supported Types
 
-### `components.ReadResponseOutput`
+### `components.Message`
 
 ```typescript
-const value: components.ReadResponseOutput = {
+const value: components.Message = {
   data: {
     batch: {
       records: [
@@ -23,7 +23,7 @@ const value: components.ReadResponseOutput = {
       ],
     },
   },
-  event: "<value>",
+  event: "message",
 };
 ```
 
@@ -32,7 +32,15 @@ const value: components.ReadResponseOutput = {
 ```typescript
 const value: components.ErrorT = {
   data: "<value>",
-  event: "<value>",
+  event: "error",
+};
+```
+
+### `components.Ping`
+
+```typescript
+const value: components.Ping = {
+  event: "ping",
 };
 ```
 
diff --git a/docs/models/components/readresponse3event.md b/docs/models/components/readresponse3event.md
@@ -0,0 +1,15 @@
+# ReadResponse3Event
+
+## Example Usage
+
+```typescript
+import { ReadResponse3Event } from "@s2-dev/streamstore/models/components";
+
+let value: ReadResponse3Event = "ping";
+```
+
+## Values
+
+```typescript
+"ping"
+```
diff --git a/docs/models/components/readresponseevent.md b/docs/models/components/readresponseevent.md
@@ -0,0 +1,15 @@
+# ReadResponseEvent
+
+## Example Usage
+
+```typescript
+import { ReadResponseEvent } from "@s2-dev/streamstore/models/components";
+
+let value: ReadResponseEvent = "error";
+```
+
+## Values
+
+```typescript
+"error"
+```
diff --git a/jsr.json b/jsr.json
@@ -2,7 +2,7 @@
 
 {
   "name": "@s2-dev/streamstore",
-  "version": "0.5.2",
+  "version": "0.7.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.5.2",
+  "version": "0.7.0",
   "author": "Speakeasy",
   "type": "module",
   "bin": {
diff --git a/src/index.extras.ts b/src/index.extras.ts
@@ -6,9 +6,9 @@ import {
     CheckTailResponse,
     CreateBasinRequest,
     CreateStreamRequest,
+    Message,
     Output,
     ReadResponse,
-    ReadResponseOutput,
     SequencedRecord,
     SequencedRecordBatch,
     StreamConfig,
@@ -438,7 +438,7 @@ class Stream {
                     yield event;
 
                     if (event.event === 'message') {
-                        const output = event as ReadResponseOutput;
+                        const output = event as Message;
                         if ('batch' in output.data) {
                             const batch = output.data.batch;
                             if (batch.records && batch.records.length > 0) {
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.5.2",
-  genVersion: "2.531.0",
-  userAgent: "speakeasy-sdk/typescript 0.5.2 2.531.0 1.0.0 @s2-dev/streamstore",
+  sdkVersion: "0.7.0",
+  genVersion: "2.545.2",
+  userAgent: "speakeasy-sdk/typescript 0.7.0 2.545.2 1.0.0 @s2-dev/streamstore",
 } as const;
diff --git a/src/mcp-server/cli/start/command.ts b/src/mcp-server/cli/start/command.ts
@@ -28,6 +28,15 @@ export const startCommand = buildCommand({
         parse: (val: string) =>
           z.coerce.number().int().gte(0).lt(65536).parse(val),
       },
+      tool: {
+        kind: "parsed",
+        brief: "Specify tools to mount on the server",
+        optional: true,
+        variadic: true,
+        parse: (value) => {
+          return z.string().parse(value);
+        },
+      },
       ...(mcpScopes.length
         ? {
           scope: {
diff --git a/src/mcp-server/cli/start/impl.ts b/src/mcp-server/cli/start/impl.ts
@@ -17,6 +17,7 @@ import { createMCPServer } from "../../server.js";
 interface StartCommandFlags {
   readonly transport: "stdio" | "sse";
   readonly port: number;
+  readonly tool?: string[];
   readonly scope?: MCPScope[];
   readonly "bearer-auth"?: string | undefined;
   readonly "server-url"?: string;
@@ -47,6 +48,7 @@ async function startStdio(flags: StartCommandFlags) {
   const transport = new StdioServerTransport();
   const server = createMCPServer({
     logger,
+    allowedTools: flags.tool,
     scopes: flags.scope,
     ...{ bearerAuth: flags["bearer-auth"] },
     serverURL: flags["server-url"],
@@ -67,6 +69,7 @@ async function startSSE(flags: StartCommandFlags) {
   const app = express();
   const mcpServer = createMCPServer({
     logger,
+    allowedTools: flags.tool,
     scopes: flags.scope,
     ...{ bearerAuth: flags["bearer-auth"] },
     serverURL: flags["server-url"],
diff --git a/src/mcp-server/extensions.ts b/src/mcp-server/extensions.ts
@@ -0,0 +1,13 @@
+/*
+ * Code generated by Speakeasy (https://speakeasy.com). DO NOT EDIT.
+ */
+
+import { ZodRawShape } from "zod";
+import { ResourceDefinition, ResourceTemplateDefinition } from "./resources.js";
+import { ToolDefinition } from "./tools.js";
+
+export type Register = {
+  tool: <A extends ZodRawShape | undefined>(def: ToolDefinition<A>) => void;
+  resource: (def: ResourceDefinition) => void;
+  resourceTemplate: (def: ResourceTemplateDefinition) => void;
+};
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.5.2",
+    currentVersion: "0.7.0",
   },
 });
 
diff --git a/src/mcp-server/resources.ts b/src/mcp-server/resources.ts
diff --git a/src/mcp-server/server.ts b/src/mcp-server/server.ts
diff --git a/src/mcp-server/tools.ts b/src/mcp-server/tools.ts
diff --git a/src/models/components/readresponse.ts b/src/models/components/readresponse.ts
