/**
* MCP Server Configuration
*
* Handles environment variables and configuration for the standalone MCP server
*/
import dotenv from "dotenv";
import { InfluxProductType } from "./helpers/enums/influx-product-types.enum.js";
dotenv.config();
export interface InfluxConfig {
url?: string;
token?: string;
management_token?: string;
type: string;
account_id?: string;
cluster_id?: string;
}
export interface McpServerConfig {
influx: InfluxConfig;
server: {
name: string;
version: string;
};
}
/**
* Load configuration from environment variables
*/
export function loadConfig(): McpServerConfig {
return {
influx: {
url: process.env.INFLUX_DB_INSTANCE_URL,
token:
process.env.INFLUX_DB_TOKEN ||
process.env.INFLUX_DB_DATABASE_TOKEN ||
undefined,
management_token: process.env.INFLUX_DB_MANAGEMENT_TOKEN || undefined,
type:
(process.env.INFLUX_DB_PRODUCT_TYPE as InfluxProductType) || "unknown",
account_id: process.env.INFLUX_DB_ACCOUNT_ID,
cluster_id: process.env.INFLUX_DB_CLUSTER_ID,
},
server: {
name: "influxdb-mcp-server",
version: "1.0.0",
},
};
}
/**
* Validate that required configuration is present
*/
export function validateConfig(config: McpServerConfig): void {
const errors: string[] = [];
if (
!config.influx.type ||
![
InfluxProductType.Enterprise,
InfluxProductType.Core,
InfluxProductType.CloudDedicated,
].includes(config.influx.type as InfluxProductType)
) {
errors.push(
`INFLUX_DB_PRODUCT_TYPE is required and must be one of: ${InfluxProductType.Enterprise}, ${InfluxProductType.Core}, ${InfluxProductType.CloudDedicated}`,
);
}
if (config.influx.type === InfluxProductType.CloudDedicated) {
if (!config.influx.cluster_id) {
errors.push("INFLUX_DB_CLUSTER_ID is required for cloud-dedicated");
}
const hasQueryWrite = config.influx.cluster_id && config.influx.token;
const hasManagement =
config.influx.cluster_id &&
config.influx.account_id &&
config.influx.management_token;
if (!hasQueryWrite && !hasManagement) {
errors.push(
"For cloud-dedicated, provide at least either: (CLUSTER_ID + DB TOKEN) for query/write, or (CLUSTER_ID + ACCOUNT_ID + MANAGEMENT TOKEN) for management API.",
);
}
} else if (
[InfluxProductType.Enterprise, InfluxProductType.Core].includes(
config.influx.type as InfluxProductType,
)
) {
if (!config.influx.url) {
errors.push("INFLUX_DB_INSTANCE_URL is required for core/enterprise");
}
if (!config.influx.token) {
errors.push("INFLUX_DB_TOKEN is required for core/enterprise");
}
}
if (errors.length > 0) {
throw new Error(`Configuration validation failed:\n${errors.join("\n")}`);
}
}
