mirror of
https://github.com/czlonkowski/n8n-mcp.git
synced 2026-01-30 06:22:04 +00:00
95 lines
3.4 KiB
JavaScript
95 lines
3.4 KiB
JavaScript
"use strict";
|
|
Object.defineProperty(exports, "__esModule", { value: true });
|
|
exports.SUPPORTED_VERSIONS = exports.N8N_PROTOCOL_VERSION = exports.STANDARD_PROTOCOL_VERSION = void 0;
|
|
exports.isN8nClient = isN8nClient;
|
|
exports.negotiateProtocolVersion = negotiateProtocolVersion;
|
|
exports.isVersionSupported = isVersionSupported;
|
|
exports.getCompatibleVersion = getCompatibleVersion;
|
|
exports.logProtocolNegotiation = logProtocolNegotiation;
|
|
exports.STANDARD_PROTOCOL_VERSION = '2025-03-26';
|
|
exports.N8N_PROTOCOL_VERSION = '2024-11-05';
|
|
exports.SUPPORTED_VERSIONS = [
|
|
exports.STANDARD_PROTOCOL_VERSION,
|
|
exports.N8N_PROTOCOL_VERSION,
|
|
'2024-06-25',
|
|
];
|
|
function isN8nClient(clientInfo, userAgent, headers) {
|
|
if (clientInfo?.name) {
|
|
const clientName = clientInfo.name.toLowerCase();
|
|
if (clientName.includes('n8n') || clientName.includes('langchain')) {
|
|
return true;
|
|
}
|
|
}
|
|
if (userAgent) {
|
|
const ua = userAgent.toLowerCase();
|
|
if (ua.includes('n8n') || ua.includes('langchain')) {
|
|
return true;
|
|
}
|
|
}
|
|
if (headers) {
|
|
const headerValues = Object.values(headers).join(' ').toLowerCase();
|
|
if (headerValues.includes('n8n') || headerValues.includes('langchain')) {
|
|
return true;
|
|
}
|
|
if (headers['x-n8n-version'] || headers['x-langchain-version']) {
|
|
return true;
|
|
}
|
|
}
|
|
if (process.env.N8N_MODE === 'true') {
|
|
return true;
|
|
}
|
|
return false;
|
|
}
|
|
function negotiateProtocolVersion(clientRequestedVersion, clientInfo, userAgent, headers) {
|
|
const isN8n = isN8nClient(clientInfo, userAgent, headers);
|
|
if (isN8n) {
|
|
return {
|
|
version: exports.N8N_PROTOCOL_VERSION,
|
|
isN8nClient: true,
|
|
reasoning: 'n8n client detected, using n8n-compatible protocol version'
|
|
};
|
|
}
|
|
if (clientRequestedVersion && exports.SUPPORTED_VERSIONS.includes(clientRequestedVersion)) {
|
|
return {
|
|
version: clientRequestedVersion,
|
|
isN8nClient: false,
|
|
reasoning: `Using client-requested version: ${clientRequestedVersion}`
|
|
};
|
|
}
|
|
if (clientRequestedVersion) {
|
|
return {
|
|
version: exports.STANDARD_PROTOCOL_VERSION,
|
|
isN8nClient: false,
|
|
reasoning: `Client requested unsupported version ${clientRequestedVersion}, using standard version`
|
|
};
|
|
}
|
|
return {
|
|
version: exports.STANDARD_PROTOCOL_VERSION,
|
|
isN8nClient: false,
|
|
reasoning: 'No specific client detected, using standard protocol version'
|
|
};
|
|
}
|
|
function isVersionSupported(version) {
|
|
return exports.SUPPORTED_VERSIONS.includes(version);
|
|
}
|
|
function getCompatibleVersion(targetVersion) {
|
|
if (!targetVersion) {
|
|
return exports.STANDARD_PROTOCOL_VERSION;
|
|
}
|
|
if (exports.SUPPORTED_VERSIONS.includes(targetVersion)) {
|
|
return targetVersion;
|
|
}
|
|
return exports.STANDARD_PROTOCOL_VERSION;
|
|
}
|
|
function logProtocolNegotiation(result, logger, context) {
|
|
const logContext = context ? `[${context}] ` : '';
|
|
logger.info(`${logContext}Protocol version negotiated`, {
|
|
version: result.version,
|
|
isN8nClient: result.isN8nClient,
|
|
reasoning: result.reasoning
|
|
});
|
|
if (result.isN8nClient) {
|
|
logger.info(`${logContext}Using n8n-compatible protocol version for better integration`);
|
|
}
|
|
}
|
|
//# sourceMappingURL=protocol-version.js.map
|