chore: bump dependencies, update server to use simplified express-like api (#8)

eddyv · web-flow · commit 34dfb8f33d73 · 2025-01-31T15:47:34.000-05:00
* bump dependencies, update server to use simplified express-like api

* remove unused dep
diff --git a/package-lock.json b/package-lock.json
diff --git a/package.json b/package.json
@@ -16,28 +16,27 @@
     "@eslint/js": "^9.16.0",
     "@types/content-type": "^1.1.8",
     "@types/eslint__js": "^8.42.3",
-    "@types/node": "^22.10.1",
-    "@types/ws": "^8.5.13",
+    "@types/node": "^22.12.0",
+    "@types/ws": "^8.5.14",
     "@typescript-eslint/eslint-plugin": "^8.18.0",
     "@typescript-eslint/parser": "^8.18.0",
     "concurrently": "^9.1.2",
-    "eslint": "^9.16.0",
+    "eslint": "^9.19.0",
     "eslint-config-prettier": "^9.1.0",
-    "eslint-plugin-prettier": "^5.2.1",
-    "globals": "^15.13.0",
+    "eslint-plugin-prettier": "^5.2.3",
+    "globals": "^15.14.0",
     "husky": "^9.1.7",
-    "openapi-typescript": "^7.5.2",
+    "openapi-typescript": "^7.6.0",
     "prettier": "3.4.2",
     "tsc-alias": "^1.8.10",
-    "typescript": "^5.7.2",
-    "typescript-eslint": "^8.18.0"
+    "typescript": "^5.7.3",
+    "typescript-eslint": "^8.22.0"
   },
   "dependencies": {
-    "@confluentinc/kafka-javascript": "^1.0.0",
-    "@modelcontextprotocol/sdk": "^1.0.4",
+    "@confluentinc/kafka-javascript": "^1.2.0",
+    "@modelcontextprotocol/sdk": "^1.4.1",
     "openapi-fetch": "^0.13.4",
-    "zod": "^3.24.0",
-    "zod-to-json-schema": "^3.24.1"
+    "zod": "^3.24.1"
   },
   "files": [
     "dist"
diff --git a/src/confluent/schema.ts b/src/confluent/schema.ts
@@ -8,5 +8,3 @@ export type CallToolResult = z.infer<typeof CallToolResultSchema>;
 
 // eslint-disable-next-line @typescript-eslint/no-unused-vars
 const ToolInputSchema = ToolSchema.shape.inputSchema;
-
-export type ToolInput = z.infer<typeof ToolInputSchema>;
diff --git a/src/confluent/tools/base-tools.ts b/src/confluent/tools/base-tools.ts
@@ -1,6 +1,7 @@
 import { ClientManager } from "@src/confluent/client-manager.js";
-import { CallToolResult, ToolInput } from "@src/confluent/schema.js";
+import { CallToolResult } from "@src/confluent/schema.js";
 import { ToolName } from "@src/confluent/tools/tool-name.js";
+import { ZodRawShape } from "zod";
 export interface ToolHandler {
   handle(
     clientManager: ClientManager,
@@ -13,7 +14,7 @@ export interface ToolHandler {
 export interface ToolConfig {
   name: ToolName;
   description: string;
-  inputSchema: ToolInput;
+  inputSchema: ZodRawShape;
 }
 
 export abstract class BaseToolHandler implements ToolHandler {
diff --git a/src/confluent/tools/handlers/connect/create-connector-handler.ts b/src/confluent/tools/handlers/connect/create-connector-handler.ts
@@ -1,14 +1,13 @@
 import { ClientManager } from "@src/confluent/client-manager.js";
 import { getEnsuredParam } from "@src/confluent/helpers.js";
-import { CallToolResult, ToolInput } from "@src/confluent/schema.js";
+import { CallToolResult } from "@src/confluent/schema.js";
 import {
   BaseToolHandler,
   ToolConfig,
 } from "@src/confluent/tools/base-tools.js";
 import { ToolName } from "@src/confluent/tools/tool-name.js";
 import { wrapAsPathBasedClient } from "openapi-fetch";
 import { z } from "zod";
-import { zodToJsonSchema } from "zod-to-json-schema";
 
 const createConnectorArguments = z.object({
   environmentId: z
@@ -127,7 +126,7 @@ export class CreateConnectorHandler extends BaseToolHandler {
       name: ToolName.CREATE_CONNECTOR,
       description:
         "Create a new connector. Returns the new connector information if successful.",
-      inputSchema: zodToJsonSchema(createConnectorArguments) as ToolInput,
+      inputSchema: createConnectorArguments.shape,
     };
   }
 }
diff --git a/src/confluent/tools/handlers/connect/list-connectors-handler.ts b/src/confluent/tools/handlers/connect/list-connectors-handler.ts
@@ -1,6 +1,6 @@
 import { ClientManager } from "@src/confluent/client-manager.js";
 import { getEnsuredParam } from "@src/confluent/helpers.js";
-import { CallToolResult, ToolInput } from "@src/confluent/schema.js";
+import { CallToolResult } from "@src/confluent/schema.js";
 import {
   BaseToolHandler,
   ToolConfig,
@@ -9,7 +9,6 @@ import { ToolName } from "@src/confluent/tools/tool-name.js";
 import env from "@src/env.js";
 import { wrapAsPathBasedClient } from "openapi-fetch";
 import { z } from "zod";
-import { zodToJsonSchema } from "zod-to-json-schema";
 
 const listConnectorArguments = z.object({
   baseUrl: z
@@ -83,7 +82,7 @@ export class ListConnectorsHandler extends BaseToolHandler {
       name: ToolName.LIST_CONNECTORS,
       description:
         'Retrieve a list of "names" of the active connectors. You can then make a read request for a specific connector by name.',
-      inputSchema: zodToJsonSchema(listConnectorArguments) as ToolInput,
+      inputSchema: listConnectorArguments.shape,
     };
   }
 }
diff --git a/src/confluent/tools/handlers/connect/read-connectors-handler.ts b/src/confluent/tools/handlers/connect/read-connectors-handler.ts
@@ -1,6 +1,6 @@
 import { ClientManager } from "@src/confluent/client-manager.js";
 import { getEnsuredParam } from "@src/confluent/helpers.js";
-import { CallToolResult, ToolInput } from "@src/confluent/schema.js";
+import { CallToolResult } from "@src/confluent/schema.js";
 import {
   BaseToolHandler,
   ToolConfig,
@@ -9,7 +9,6 @@ import { ToolName } from "@src/confluent/tools/tool-name.js";
 import env from "@src/env.js";
 import { wrapAsPathBasedClient } from "openapi-fetch";
 import { z } from "zod";
-import { zodToJsonSchema } from "zod-to-json-schema";
 
 const readConnectorArguments = z.object({
   baseUrl: z
@@ -86,7 +85,7 @@ export class ReadConnectorHandler extends BaseToolHandler {
     return {
       name: ToolName.READ_CONNECTOR,
       description: "Get information about the connector.",
-      inputSchema: zodToJsonSchema(readConnectorArguments) as ToolInput,
+      inputSchema: readConnectorArguments.shape,
     };
   }
 }
diff --git a/src/confluent/tools/handlers/flink/create-flink-statement-handler.ts b/src/confluent/tools/handlers/flink/create-flink-statement-handler.ts
@@ -1,6 +1,6 @@
 import { ClientManager } from "@src/confluent/client-manager.js";
 import { getEnsuredParam } from "@src/confluent/helpers.js";
-import { CallToolResult, ToolInput } from "@src/confluent/schema.js";
+import { CallToolResult } from "@src/confluent/schema.js";
 import {
   BaseToolHandler,
   ToolConfig,
@@ -9,7 +9,6 @@ import { ToolName } from "@src/confluent/tools/tool-name.js";
 import env from "@src/env.js";
 import { wrapAsPathBasedClient } from "openapi-fetch";
 import { z } from "zod";
-import { zodToJsonSchema } from "zod-to-json-schema";
 
 const createFlinkStatementArguments = z.object({
   baseUrl: z
@@ -64,7 +63,7 @@ const createFlinkStatementArguments = z.object({
     .string()
     .trim()
     .nonempty()
-    .default(env["KAFKA_CLUSTER_ID"] ?? "")
+    .default(env["FLINK_DATABASE_NAME"] ?? "")
     .describe(
       "The database name to be used for the statement. Typically the Kafka cluster name.",
     ),
@@ -145,7 +144,7 @@ export class CreateFlinkStatementHandler extends BaseToolHandler {
     return {
       name: ToolName.CREATE_FLINK_STATEMENT,
       description: "Make a request to create a statement.",
-      inputSchema: zodToJsonSchema(createFlinkStatementArguments) as ToolInput,
+      inputSchema: createFlinkStatementArguments.shape,
     };
   }
 }
diff --git a/src/confluent/tools/handlers/flink/delete-flink-statement-handler.ts b/src/confluent/tools/handlers/flink/delete-flink-statement-handler.ts
@@ -1,6 +1,6 @@
 import { ClientManager } from "@src/confluent/client-manager.js";
 import { getEnsuredParam } from "@src/confluent/helpers.js";
-import { CallToolResult, ToolInput } from "@src/confluent/schema.js";
+import { CallToolResult } from "@src/confluent/schema.js";
 import {
   BaseToolHandler,
   ToolConfig,
@@ -9,7 +9,6 @@ import { ToolName } from "@src/confluent/tools/tool-name.js";
 import env from "@src/env.js";
 import { wrapAsPathBasedClient } from "openapi-fetch";
 import { z } from "zod";
-import { zodToJsonSchema } from "zod-to-json-schema";
 
 const deleteFlinkStatementArguments = z.object({
   baseUrl: z
@@ -91,7 +90,7 @@ export class DeleteFlinkStatementHandler extends BaseToolHandler {
     return {
       name: ToolName.DELETE_FLINK_STATEMENTS,
       description: "Make a request to delete a statement.",
-      inputSchema: zodToJsonSchema(deleteFlinkStatementArguments) as ToolInput,
+      inputSchema: deleteFlinkStatementArguments.shape,
     };
   }
 }
diff --git a/src/confluent/tools/handlers/flink/list-flink-statements-handler.ts b/src/confluent/tools/handlers/flink/list-flink-statements-handler.ts
@@ -1,6 +1,6 @@
 import { ClientManager } from "@src/confluent/client-manager.js";
 import { getEnsuredParam } from "@src/confluent/helpers.js";
-import { CallToolResult, ToolInput } from "@src/confluent/schema.js";
+import { CallToolResult } from "@src/confluent/schema.js";
 import {
   BaseToolHandler,
   ToolConfig,
@@ -9,7 +9,6 @@ import { ToolName } from "@src/confluent/tools/tool-name.js";
 import env from "@src/env.js";
 import { wrapAsPathBasedClient } from "openapi-fetch";
 import { z } from "zod";
-import { zodToJsonSchema } from "zod-to-json-schema";
 
 const listFlinkStatementsArguments = z.object({
   baseUrl: z
@@ -109,7 +108,7 @@ export class ListFlinkStatementsHandler extends BaseToolHandler {
       name: ToolName.LIST_FLINK_STATEMENTS,
       description:
         "Retrieve a sorted, filtered, paginated list of all statements.",
-      inputSchema: zodToJsonSchema(listFlinkStatementsArguments) as ToolInput,
+      inputSchema: listFlinkStatementsArguments.shape,
     };
   }
 }
diff --git a/src/confluent/tools/handlers/flink/read-flink-statement-handler.ts b/src/confluent/tools/handlers/flink/read-flink-statement-handler.ts
@@ -1,6 +1,6 @@
 import { ClientManager } from "@src/confluent/client-manager.js";
 import { getEnsuredParam } from "@src/confluent/helpers.js";
-import { CallToolResult, ToolInput } from "@src/confluent/schema.js";
+import { CallToolResult } from "@src/confluent/schema.js";
 import {
   BaseToolHandler,
   ToolConfig,
@@ -9,7 +9,6 @@ import { ToolName } from "@src/confluent/tools/tool-name.js";
 import env from "@src/env.js";
 import { wrapAsPathBasedClient } from "openapi-fetch";
 import { z } from "zod";
-import { zodToJsonSchema } from "zod-to-json-schema";
 
 const readFlinkStatementArguments = z.object({
   baseUrl: z
@@ -123,7 +122,7 @@ export class ReadFlinkStatementHandler extends BaseToolHandler {
     return {
       name: ToolName.READ_FLINK_STATEMENT,
       description: "Make a request to read a statement and its results",
-      inputSchema: zodToJsonSchema(readFlinkStatementArguments) as ToolInput,
+      inputSchema: readFlinkStatementArguments.shape,
     };
   }
 }
diff --git a/src/confluent/tools/handlers/kafka/create-topics-handler.ts b/src/confluent/tools/handlers/kafka/create-topics-handler.ts
@@ -1,12 +1,11 @@
 import { ClientManager } from "@src/confluent/client-manager.js";
-import { CallToolResult, ToolInput } from "@src/confluent/schema.js";
+import { CallToolResult } from "@src/confluent/schema.js";
 import {
   BaseToolHandler,
   ToolConfig,
 } from "@src/confluent/tools/base-tools.js";
 import { ToolName } from "@src/confluent/tools/tool-name.js";
 import { z } from "zod";
-import { zodToJsonSchema } from "zod-to-json-schema";
 
 const createTopicArgs = z.object({
   topicNames: z
@@ -37,7 +36,7 @@ export class CreateTopicsHandler extends BaseToolHandler {
     return {
       name: ToolName.CREATE_TOPICS,
       description: "Create new topic(s) in the Kafka cluster.",
-      inputSchema: zodToJsonSchema(createTopicArgs) as ToolInput,
+      inputSchema: createTopicArgs.shape,
     };
   }
 }
diff --git a/src/confluent/tools/handlers/kafka/delete-topics-handler.ts b/src/confluent/tools/handlers/kafka/delete-topics-handler.ts
@@ -1,12 +1,11 @@
 import { ClientManager } from "@src/confluent/client-manager.js";
-import { CallToolResult, ToolInput } from "@src/confluent/schema.js";
+import { CallToolResult } from "@src/confluent/schema.js";
 import {
   BaseToolHandler,
   ToolConfig,
 } from "@src/confluent/tools/base-tools.js";
 import { ToolName } from "@src/confluent/tools/tool-name.js";
 import { z } from "zod";
-import { zodToJsonSchema } from "zod-to-json-schema";
 
 const deleteKafkaTopicsArguments = z.object({
   topicNames: z
@@ -29,7 +28,7 @@ export class DeleteTopicsHandler extends BaseToolHandler {
     return {
       name: ToolName.DELETE_TOPICS,
       description: "Delete the topic with the given names.",
-      inputSchema: zodToJsonSchema(deleteKafkaTopicsArguments) as ToolInput,
+      inputSchema: deleteKafkaTopicsArguments.shape,
     };
   }
 }
diff --git a/src/confluent/tools/handlers/kafka/list-topics-handler.ts b/src/confluent/tools/handlers/kafka/list-topics-handler.ts
@@ -1,12 +1,11 @@
 import { ClientManager } from "@src/confluent/client-manager.js";
-import { CallToolResult, ToolInput } from "@src/confluent/schema.js";
+import { CallToolResult } from "@src/confluent/schema.js";
 import {
   BaseToolHandler,
   ToolConfig,
 } from "@src/confluent/tools/base-tools.js";
 import { ToolName } from "@src/confluent/tools/tool-name.js";
 import { z } from "zod";
-import { zodToJsonSchema } from "zod-to-json-schema";
 
 const listTopicArgs = z.object({
   // No arguments
@@ -26,7 +25,7 @@ export class ListTopicsHandler extends BaseToolHandler {
     return {
       name: ToolName.LIST_TOPICS,
       description: "List all topics in the Kafka cluster.",
-      inputSchema: zodToJsonSchema(listTopicArgs) as ToolInput,
+      inputSchema: listTopicArgs.shape,
     };
   }
 }
diff --git a/src/confluent/tools/handlers/kafka/produce-kafka-message-handler.ts b/src/confluent/tools/handlers/kafka/produce-kafka-message-handler.ts
@@ -1,13 +1,12 @@
 import { RecordMetadata } from "@confluentinc/kafka-javascript/types/kafkajs.js";
 import { ClientManager } from "@src/confluent/client-manager.js";
-import { CallToolResult, ToolInput } from "@src/confluent/schema.js";
+import { CallToolResult } from "@src/confluent/schema.js";
 import {
   BaseToolHandler,
   ToolConfig,
 } from "@src/confluent/tools/base-tools.js";
 import { ToolName } from "@src/confluent/tools/tool-name.js";
 import { z } from "zod";
-import { zodToJsonSchema } from "zod-to-json-schema";
 
 const produceKafkaMessageArguments = z.object({
   topicName: z
@@ -45,7 +44,7 @@ export class ProduceKafkaMessageHandler extends BaseToolHandler {
     return {
       name: ToolName.PRODUCE_MESSAGE,
       description: `Produce records to a Kafka topic. For saving user messages/history they should be saved to a kafka topic named claude-conversations unless otherwise specified. If the topic does not exist, it will be created via the ${ToolName.CREATE_TOPICS} tool.`,
-      inputSchema: zodToJsonSchema(produceKafkaMessageArguments) as ToolInput,
+      inputSchema: produceKafkaMessageArguments.shape,
     };
   }
 }
diff --git a/src/index.ts b/src/index.ts
