n8n-MCP

"use strict"; Object.defineProperty(exports, "__esModule", { value: true }); exports.NodeParser = void 0; const property_extractor_1 = require("./property-extractor"); const node_types_1 = require("../types/node-types"); class NodeParser { constructor() { this.propertyExtractor = new property_extractor_1.PropertyExtractor(); this.currentNodeClass = null; } parse(nodeClass, packageName) { this.currentNodeClass = nodeClass; const description = this.getNodeDescription(nodeClass); const outputInfo = this.extractOutputs(description); return { style: this.detectStyle(nodeClass), nodeType: this.extractNodeType(description, packageName), displayName: description.displayName || description.name, description: description.description, category: this.extractCategory(description), properties: this.propertyExtractor.extractProperties(nodeClass), credentials: this.propertyExtractor.extractCredentials(nodeClass), isAITool: this.propertyExtractor.detectAIToolCapability(nodeClass), isTrigger: this.detectTrigger(description), isWebhook: this.detectWebhook(description), operations: this.propertyExtractor.extractOperations(nodeClass), version: this.extractVersion(nodeClass), isVersioned: this.detectVersioned(nodeClass), packageName: packageName, outputs: outputInfo.outputs, outputNames: outputInfo.outputNames }; } getNodeDescription(nodeClass) { let description; if ((0, node_types_1.isVersionedNodeClass)(nodeClass)) { try { const instance = new nodeClass(); const inst = instance; description = inst.description || (inst.nodeVersions ? inst.baseDescription : undefined); } catch (e) { } } else if (typeof nodeClass === 'function') { try { const instance = new nodeClass(); description = instance.description; if (!description || !description.name) { const inst = instance; if (inst.baseDescription?.name) { description = inst.baseDescription; } } } catch (e) { description = nodeClass.description; } } else { description = nodeClass.description; if (!description || !description.name) { const inst = nodeClass; if (inst.baseDescription?.name) { description = inst.baseDescription; } } } return description || {}; } detectStyle(nodeClass) { const desc = this.getNodeDescription(nodeClass); return desc.routing ? 'declarative' : 'programmatic'; } extractNodeType(description, packageName) { const name = description.name; if (!name) { throw new Error('Node is missing name property'); } if (name.includes('.')) { return name; } const packagePrefix = packageName.replace('@n8n/', '').replace('n8n-', ''); return `${packagePrefix}.${name}`; } extractCategory(description) { return description.group?.[0] || description.categories?.[0] || description.category || 'misc'; } detectTrigger(description) { const desc = description; if (description.group && Array.isArray(description.group)) { if (description.group.includes('trigger')) { return true; } } return desc.polling === true || desc.trigger === true || desc.eventTrigger === true || description.name?.toLowerCase().includes('trigger'); } detectWebhook(description) { const desc = description; return (desc.webhooks?.length > 0) || desc.webhook === true || description.name?.toLowerCase().includes('webhook'); } extractVersion(nodeClass) { try { const instance = typeof nodeClass === 'function' ? new nodeClass() : nodeClass; const inst = instance; if (inst?.currentVersion !== undefined) { return inst.currentVersion.toString(); } if (inst?.description?.defaultVersion) { return inst.description.defaultVersion.toString(); } if (inst?.nodeVersions) { const versions = Object.keys(inst.nodeVersions).map(Number); if (versions.length > 0) { const maxVersion = Math.max(...versions); if (!isNaN(maxVersion)) { return maxVersion.toString(); } } } if (inst?.description?.version) { const version = inst.description.version; if (Array.isArray(version)) { const numericVersions = version.map((v) => parseFloat(v.toString())); if (numericVersions.length > 0) { const maxVersion = Math.max(...numericVersions); if (!isNaN(maxVersion)) { return maxVersion.toString(); } } } else if (typeof version === 'number' || typeof version === 'string') { return version.toString(); } } } catch (e) { } const nodeClassAny = nodeClass; if (nodeClassAny.description?.defaultVersion) { return nodeClassAny.description.defaultVersion.toString(); } if (nodeClassAny.nodeVersions) { const versions = Object.keys(nodeClassAny.nodeVersions).map(Number); if (versions.length > 0) { const maxVersion = Math.max(...versions); if (!isNaN(maxVersion)) { return maxVersion.toString(); } } } const description = this.getNodeDescription(nodeClass); const desc = description; if (desc?.version) { if (Array.isArray(desc.version)) { const numericVersions = desc.version.map((v) => parseFloat(v.toString())); if (numericVersions.length > 0) { const maxVersion = Math.max(...numericVersions); if (!isNaN(maxVersion)) { return maxVersion.toString(); } } } else if (typeof desc.version === 'number' || typeof desc.version === 'string') { return desc.version.toString(); } } return '1'; } detectVersioned(nodeClass) { try { const instance = typeof nodeClass === 'function' ? new nodeClass() : nodeClass; const inst = instance; if (inst?.baseDescription?.defaultVersion) { return true; } if (inst?.nodeVersions) { return true; } if (inst?.description?.version && Array.isArray(inst.description.version)) { return true; } } catch (e) { } const nodeClassAny = nodeClass; if (nodeClassAny.nodeVersions || nodeClassAny.baseDescription?.defaultVersion) { return true; } const description = this.getNodeDescription(nodeClass); const desc = description; if (desc?.version && Array.isArray(desc.version)) { return true; } return false; } extractOutputs(description) { const result = {}; const desc = description; if (desc.outputs) { result.outputs = Array.isArray(desc.outputs) ? desc.outputs : [desc.outputs]; } if (desc.outputNames) { result.outputNames = Array.isArray(desc.outputNames) ? desc.outputNames : [desc.outputNames]; } if (!result.outputs && !result.outputNames) { const nodeClass = this.currentNodeClass; if (nodeClass) { try { const instance = typeof nodeClass === 'function' ? new nodeClass() : nodeClass; const inst = instance; if (inst.nodeVersions) { const versions = Object.keys(inst.nodeVersions).map(Number); if (versions.length > 0) { const latestVersion = Math.max(...versions); if (!isNaN(latestVersion)) { const versionedDescription = inst.nodeVersions[latestVersion]?.description; if (versionedDescription) { if (versionedDescription.outputs) { result.outputs = Array.isArray(versionedDescription.outputs) ? versionedDescription.outputs : [versionedDescription.outputs]; } if (versionedDescription.outputNames) { result.outputNames = Array.isArray(versionedDescription.outputNames) ? versionedDescription.outputNames : [versionedDescription.outputNames]; } } } } } } catch (e) { } } } return result; } } exports.NodeParser = NodeParser; //# sourceMappingURL=node-parser.js.map