new tool to get all schemas

src/confluent/tools/handlers/schema/list-schemas-handler.ts

@@ -0,0 +1,62 @@
+import { ClientManager } from "@src/confluent/client-manager.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 env from "@src/env.js";
+import { wrapAsPathBasedClient } from "openapi-fetch";
+import { z } from "zod";
+
+const listSchemasArguments = z.object({
+  baseUrl: z
+    .string()
+    .describe("The base URL of the Schema Registry REST API.")
+    .url()
+    .default(env.SCHEMA_REGISTRY_ENDPOINT ?? "")
+    .optional(),
+});
+
+export class ListSchemasHandler extends BaseToolHandler {
+  async handle(
+    clientManager: ClientManager,
+    toolArguments: Record<string, unknown>,
+  ): Promise<CallToolResult> {
+    const { baseUrl } = listSchemasArguments.parse(toolArguments);
+
+    if (baseUrl !== undefined && baseUrl !== "") {
+      clientManager.setConfluentCloudSchemaRegistryEndpoint(baseUrl);
+    }
+
+    const pathBasedClient = wrapAsPathBasedClient(
+      clientManager.getConfluentCloudSchemaRegistryRestClient(),
+    );
+
+    // First get all subjects
+    const { data: response, error: error } = await pathBasedClient[
+      "/schemas"
+    ].GET({
+      query: {
+        latestOnly: "true",
+      },
+    });
+
+    if (error) {
+      return this.createResponse(
+        `Failed to list subjects: ${JSON.stringify(error)}`,
+        true,
+      );
+    }
+
+    return this.createResponse(`${JSON.stringify(response)}`);
+  }
+
+  getToolConfig(): ToolConfig {
+    return {
+      name: ToolName.LIST_SCHEMAS,
+      description: "List all schemas in the Schema Registry.",
+      inputSchema: listSchemasArguments.shape,
+    };
+  }
+}

src/confluent/tools/tool-factory.ts

@@ -23,6 +23,7 @@ import { ToolName } from "@src/confluent/tools/tool-name.js";
 import { DeleteConnectorHandler } from "@src/confluent/tools/handlers/connect/delete-connector-handler.js";
 import { SearchTopicsByNameHandler } from "@src/confluent/tools/handlers/search/search-topics-by-name-handler.js";
 import { ListClustersHandler } from "@src/confluent/tools/handlers/clusters/list-clusters-handler.js";
+import { ListSchemasHandler } from "@src/confluent/tools/handlers/schema/list-schemas-handler.js";
 
 export class ToolFactory {
   private static handlers: Map<ToolName, ToolHandler> = new Map([
@@ -49,6 +50,7 @@ export class ToolFactory {
     [ToolName.LIST_CLUSTERS, new ListClustersHandler()],
     [ToolName.LIST_ENVIRONMENTS, new ListEnvironmentsHandler()],
     [ToolName.READ_ENVIRONMENT, new ReadEnvironmentHandler()],
+    [ToolName.LIST_SCHEMAS, new ListSchemasHandler()],
   ]);
 
   static createToolHandler(toolName: ToolName): ToolHandler {

src/confluent/tools/tool-name.ts

@@ -22,4 +22,5 @@ export enum ToolName {
   LIST_CLUSTERS = "list-clusters",
   LIST_ENVIRONMENTS = "list-environments",
   READ_ENVIRONMENT = "read-environment",
+  LIST_SCHEMAS = "list-schemas",
 }