Neo4j Memory Server

/** * Environment Configuration Management * Single source of truth for all environment variables * Note: dotenv.config() is called in main index.ts before any imports */ import { MCPValidationError, MCPErrorCodes } from '../infrastructure/errors'; export interface EnvironmentConfig { neo4j: { uri: string; username: string; password: string; database: string; }; logging: { level: string; }; vector: { modelName: string; dimensions: number | 'auto'; idleTimeout: number; preload: boolean; }; limits: { maxMemoriesPerOperation: number; maxRelationsPerOperation: number; maxTraversalDepth: number; }; } /** * Validates and returns environment configuration * Fails fast if required environment variables are missing */ export function getEnvironmentConfig(): EnvironmentConfig { const requiredVars = [ 'NEO4J_URI', 'NEO4J_USERNAME', 'NEO4J_PASSWORD' // NEO4J_DATABASE is optional - defaults to 'neo4j' if not provided ]; // Validate required environment variables for (const varName of requiredVars) { if (!process.env[varName]) { throw new MCPValidationError( `Required environment variable ${varName} is not set`, MCPErrorCodes.INVALID_ENVIRONMENT_CONFIG ); } } return { neo4j: { uri: process.env.NEO4J_URI!, username: process.env.NEO4J_USERNAME!, password: process.env.NEO4J_PASSWORD!, database: process.env.NEO4J_DATABASE || process.env.DEFAULT_DATABASE || 'neo4j', // Default to neo4j database }, logging: { level: process.env.LOG_LEVEL || 'info', }, vector: { modelName: process.env.VECTOR_MODEL || 'sentence-transformers/paraphrase-multilingual-MiniLM-L12-v2', dimensions: process.env.VECTOR_DIMENSIONS ? (process.env.VECTOR_DIMENSIONS === 'auto' ? 'auto' : parseInt(process.env.VECTOR_DIMENSIONS, 10)) : 'auto', idleTimeout: (() => { const parsed = parseInt(process.env.VECTOR_IDLE_TIMEOUT || '600000', 10); return isNaN(parsed) ? 600000 : parsed; })(), // 10 minutes preload: process.env.VECTOR_PRELOAD !== 'false' // Default true }, limits: { maxMemoriesPerOperation: (() => { const parsed = parseInt(process.env.MAX_MEMORIES_PER_OP || '50', 10); return isNaN(parsed) ? 50 : parsed; })(), maxRelationsPerOperation: (() => { const parsed = parseInt(process.env.MAX_RELATIONS_PER_OP || '200', 10); return isNaN(parsed) ? 200 : parsed; })(), maxTraversalDepth: (() => { const parsed = parseInt(process.env.MAX_TRAVERSAL_DEPTH || '5', 10); return isNaN(parsed) ? 5 : parsed; })(), }, }; } /** * Get Neo4j configuration specifically * Used by database components */ export function getNeo4jConfig() { const config = getEnvironmentConfig(); return config.neo4j; } /** * Get Vector configuration specifically * Used by vector processing components */ export function getVectorConfig() { const config = getEnvironmentConfig(); return config.vector; } /** * Get Operation Limits configuration * Used by unified handlers for validation */ export function getLimitsConfig() { const config = getEnvironmentConfig(); return config.limits; }