Spaces:
Sleeping
Sleeping
File size: 7,281 Bytes
da2e594 | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 178 179 180 181 182 183 184 185 186 187 188 189 190 191 192 193 194 195 196 197 | /**
* Instance Context for flexible configuration support
*
* Allows the n8n-mcp engine to accept instance-specific configuration
* at runtime, enabling flexible deployment scenarios while maintaining
* backward compatibility with environment-based configuration.
*/
export interface InstanceContext {
/**
* Instance-specific n8n API configuration
* When provided, these override environment variables
*/
n8nApiUrl?: string;
n8nApiKey?: string;
n8nApiTimeout?: number;
n8nApiMaxRetries?: number;
/**
* Instance identification
* Used for session management and logging
*/
instanceId?: string;
sessionId?: string;
/**
* Extensible metadata for future use
* Allows passing additional configuration without interface changes
*/
metadata?: Record<string, any>;
}
/**
* Validate URL format with enhanced checks
*/
function isValidUrl(url: string): boolean {
try {
const parsed = new URL(url);
// Allow only http and https protocols
if (parsed.protocol !== 'http:' && parsed.protocol !== 'https:') {
return false;
}
// Check for reasonable hostname (not empty or invalid)
if (!parsed.hostname || parsed.hostname.length === 0) {
return false;
}
// Validate port if present
if (parsed.port && (isNaN(Number(parsed.port)) || Number(parsed.port) < 1 || Number(parsed.port) > 65535)) {
return false;
}
// Allow localhost, IP addresses, and domain names
const hostname = parsed.hostname.toLowerCase();
// Allow localhost for development
if (hostname === 'localhost' || hostname === '127.0.0.1' || hostname === '::1') {
return true;
}
// Basic IPv4 address validation
const ipv4Pattern = /^(\d{1,3}\.){3}\d{1,3}$/;
if (ipv4Pattern.test(hostname)) {
const parts = hostname.split('.');
return parts.every(part => {
const num = parseInt(part, 10);
return num >= 0 && num <= 255;
});
}
// Basic IPv6 pattern check (simplified)
if (hostname.includes(':') || hostname.startsWith('[') && hostname.endsWith(']')) {
// Basic IPv6 validation - just checking it's not obviously wrong
return true;
}
// Domain name validation - allow subdomains and TLDs
const domainPattern = /^([a-zA-Z0-9]([a-zA-Z0-9-]*[a-zA-Z0-9])?\.)*[a-zA-Z]([a-zA-Z0-9-]*[a-zA-Z0-9])?$/;
return domainPattern.test(hostname);
} catch {
return false;
}
}
/**
* Validate API key format (basic check for non-empty string)
*/
function isValidApiKey(key: string): boolean {
// API key should be non-empty and not contain obvious placeholder values
return key.length > 0 &&
!key.toLowerCase().includes('your_api_key') &&
!key.toLowerCase().includes('placeholder') &&
!key.toLowerCase().includes('example');
}
/**
* Type guard to check if an object is an InstanceContext
*/
export function isInstanceContext(obj: any): obj is InstanceContext {
if (!obj || typeof obj !== 'object') return false;
// Check for known properties with validation
const hasValidUrl = obj.n8nApiUrl === undefined ||
(typeof obj.n8nApiUrl === 'string' && isValidUrl(obj.n8nApiUrl));
const hasValidKey = obj.n8nApiKey === undefined ||
(typeof obj.n8nApiKey === 'string' && isValidApiKey(obj.n8nApiKey));
const hasValidTimeout = obj.n8nApiTimeout === undefined ||
(typeof obj.n8nApiTimeout === 'number' && obj.n8nApiTimeout > 0);
const hasValidRetries = obj.n8nApiMaxRetries === undefined ||
(typeof obj.n8nApiMaxRetries === 'number' && obj.n8nApiMaxRetries >= 0);
const hasValidInstanceId = obj.instanceId === undefined || typeof obj.instanceId === 'string';
const hasValidSessionId = obj.sessionId === undefined || typeof obj.sessionId === 'string';
const hasValidMetadata = obj.metadata === undefined ||
(typeof obj.metadata === 'object' && obj.metadata !== null);
return hasValidUrl && hasValidKey && hasValidTimeout && hasValidRetries &&
hasValidInstanceId && hasValidSessionId && hasValidMetadata;
}
/**
* Validate and sanitize InstanceContext
* Provides field-specific error messages for better debugging
*/
export function validateInstanceContext(context: InstanceContext): {
valid: boolean;
errors?: string[]
} {
const errors: string[] = [];
// Validate URL if provided (even empty string should be validated)
if (context.n8nApiUrl !== undefined) {
if (context.n8nApiUrl === '') {
errors.push(`Invalid n8nApiUrl: empty string - URL is required when field is provided`);
} else if (!isValidUrl(context.n8nApiUrl)) {
// Provide specific reason for URL invalidity
try {
const parsed = new URL(context.n8nApiUrl);
if (parsed.protocol !== 'http:' && parsed.protocol !== 'https:') {
errors.push(`Invalid n8nApiUrl: URL must use HTTP or HTTPS protocol, got ${parsed.protocol}`);
}
} catch {
errors.push(`Invalid n8nApiUrl: URL format is malformed or incomplete`);
}
}
}
// Validate API key if provided
if (context.n8nApiKey !== undefined) {
if (context.n8nApiKey === '') {
errors.push(`Invalid n8nApiKey: empty string - API key is required when field is provided`);
} else if (!isValidApiKey(context.n8nApiKey)) {
// Provide specific reason for API key invalidity
if (context.n8nApiKey.toLowerCase().includes('your_api_key')) {
errors.push(`Invalid n8nApiKey: contains placeholder 'your_api_key' - Please provide actual API key`);
} else if (context.n8nApiKey.toLowerCase().includes('placeholder')) {
errors.push(`Invalid n8nApiKey: contains placeholder text - Please provide actual API key`);
} else if (context.n8nApiKey.toLowerCase().includes('example')) {
errors.push(`Invalid n8nApiKey: contains example text - Please provide actual API key`);
} else {
errors.push(`Invalid n8nApiKey: format validation failed - Ensure key is valid`);
}
}
}
// Validate timeout
if (context.n8nApiTimeout !== undefined) {
if (typeof context.n8nApiTimeout !== 'number') {
errors.push(`Invalid n8nApiTimeout: ${context.n8nApiTimeout} - Must be a number, got ${typeof context.n8nApiTimeout}`);
} else if (context.n8nApiTimeout <= 0) {
errors.push(`Invalid n8nApiTimeout: ${context.n8nApiTimeout} - Must be positive (greater than 0)`);
} else if (!isFinite(context.n8nApiTimeout)) {
errors.push(`Invalid n8nApiTimeout: ${context.n8nApiTimeout} - Must be a finite number (not Infinity or NaN)`);
}
}
// Validate retries
if (context.n8nApiMaxRetries !== undefined) {
if (typeof context.n8nApiMaxRetries !== 'number') {
errors.push(`Invalid n8nApiMaxRetries: ${context.n8nApiMaxRetries} - Must be a number, got ${typeof context.n8nApiMaxRetries}`);
} else if (context.n8nApiMaxRetries < 0) {
errors.push(`Invalid n8nApiMaxRetries: ${context.n8nApiMaxRetries} - Must be non-negative (0 or greater)`);
} else if (!isFinite(context.n8nApiMaxRetries)) {
errors.push(`Invalid n8nApiMaxRetries: ${context.n8nApiMaxRetries} - Must be a finite number (not Infinity or NaN)`);
}
}
return {
valid: errors.length === 0,
errors: errors.length > 0 ? errors : undefined
};
} |