mcp-confluent

import { logLevels } from "@src/logger.js"; import { z } from "zod"; // Environment variables that are required for tools to be enabled/disabled const envSchema = z.object({ HTTP_PORT: z.coerce .number() .int() .positive() .describe("Port to use for HTTP transport") .default(8080), HTTP_HOST: z .string() .describe("Host to bind for HTTP transport. 0.0.0.0 means all interfaces.") .default("0.0.0.0"), HTTP_MCP_ENDPOINT_PATH: z .string() .describe("HTTP endpoint path for MCP transport (e.g., '/mcp')") .default("/mcp"), SSE_MCP_ENDPOINT_PATH: z .string() .describe( "SSE endpoint path for establishing SSE connections (e.g., '/sse', '/events')", ) .default("/sse"), SSE_MCP_MESSAGE_ENDPOINT_PATH: z .string() .describe( "SSE message endpoint path for receiving messages (e.g., '/messages', '/events/messages')", ) .default("/messages"), LOG_LEVEL: z .preprocess( (val) => (typeof val === "string" ? val.toLowerCase() : val), z.enum( Object.keys(logLevels) as [ keyof typeof logLevels, ...Array<keyof typeof logLevels>, ], ), ) .describe( "Log level for application logging (trace, debug, info, warn, error, fatal)", ) .default("info"), BOOTSTRAP_SERVERS: z .string() .describe( "List of Kafka broker addresses in the format host1:port1,host2:port2 used to establish initial connection to the Kafka cluster", ) .trim() .optional(), KAFKA_API_KEY: z .string() .describe( "Authentication credential (username) required to establish secure connection with the Kafka cluster", ) .trim() .min(1) .optional(), KAFKA_API_SECRET: z .string() .describe( "Authentication credential (password) paired with KAFKA_API_KEY for secure Kafka cluster access", ) .trim() .min(1) .optional(), FLINK_API_KEY: z .string() .describe( "Authentication key for accessing Confluent Cloud's Flink services, including compute pools and SQL statement management", ) .trim() .min(1) .optional(), FLINK_API_SECRET: z .string() .describe( "Secret token paired with FLINK_API_KEY for authenticated access to Confluent Cloud's Flink services", ) .trim() .min(1) .optional(), CONFLUENT_CLOUD_API_KEY: z .string() .describe( "Master API key for Confluent Cloud platform administration, enabling management of resources across your organization", ) .trim() .min(1) .optional(), CONFLUENT_CLOUD_API_SECRET: z .string() .describe( "Master API secret paired with CONFLUENT_CLOUD_API_KEY for comprehensive Confluent Cloud platform administration", ) .trim() .min(1) .optional(), SCHEMA_REGISTRY_API_KEY: z .string() .describe( "Authentication key for accessing Schema Registry services to manage and validate data schemas", ) .trim() .min(1) .optional(), SCHEMA_REGISTRY_API_SECRET: z .string() .describe( "Authentication secret paired with SCHEMA_REGISTRY_API_KEY for secure Schema Registry access", ) .trim() .min(1) .optional(), TABLEFLOW_API_KEY: z .string() .describe( "Authentication key for accessing Confluent Cloud's Tableflow services", ) .trim() .min(1) .optional(), TABLEFLOW_API_SECRET: z .string() .describe( "Authentication secret paired with TABLEFLOW_API_KEY for secure Tableflow access", ) .trim() .min(1) .optional(), }); // Environment variables that are optional for tools / could be provided at runtime const configSchema = z .object({ FLINK_ENV_ID: z .string() .describe( "Unique identifier for the Flink environment, must start with 'env-' prefix", ) .trim() .startsWith("env-"), FLINK_ORG_ID: z .string() .describe( "Organization identifier within Confluent Cloud for Flink resource management", ) .trim() .min(1), FLINK_REST_ENDPOINT: z .string() .describe( "Base URL for Confluent Cloud's Flink REST API endpoints used for SQL statement and compute pool management", ) .trim() .url(), FLINK_COMPUTE_POOL_ID: z .string() .describe( "Unique identifier for the Flink compute pool, must start with 'lfcp-' prefix", ) .trim() .startsWith("lfcp-"), FLINK_ENV_NAME: z .string() .describe( "Human-readable name for the Flink environment used for identification and display purposes", ) .trim() .min(1), FLINK_DATABASE_NAME: z .string() .describe( "Name of the associated Kafka cluster used as a database reference in Flink SQL operations", ) .trim() .min(1), KAFKA_CLUSTER_ID: z .string() .describe( "Unique identifier for the Kafka cluster within Confluent Cloud ecosystem", ) .trim() .min(1), KAFKA_ENV_ID: z .string() .describe( "Environment identifier for Kafka cluster, must start with 'env-' prefix", ) .trim() .startsWith("env-"), CONFLUENT_CLOUD_REST_ENDPOINT: z .string() .describe("Base URL for Confluent Cloud's REST API services") .trim() .url() .default("https://api.confluent.cloud"), SCHEMA_REGISTRY_ENDPOINT: z .string() .describe( "URL endpoint for accessing Schema Registry services to manage data schemas", ) .trim() .url(), KAFKA_REST_ENDPOINT: z .string() .describe( "REST API endpoint for Kafka cluster management and administration", ) .trim() .url(), }) .partial(); export const combinedSchema = envSchema.merge(configSchema); // Export type for environment variable names export type EnvVar = keyof z.infer<typeof combinedSchema>;