Compare commits

...

5 Commits

Author SHA1 Message Date
czlonkowski
f5088918aa fix: memory leak in SSE session reset (#542)
When SSE sessions are recreated every 5 minutes, the old session's MCP
server was not being closed, causing:
- SimpleCache cleanup timer continuing to run indefinitely
- Database connections remaining open
- Cached data (~50-100MB per session) persisting in memory

Added server.close() call before transport.close() in resetSessionSSE(),
mirroring the existing cleanup pattern in removeSession().

Fixes #542

Conceived by Romuald Członkowski - https://www.aiadvisors.pl/en

Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>
2026-01-21 13:04:04 +01:00
Romuald Członkowski
0f15b82f1e chore: update n8n to 2.4.4 (#543)
* chore: update n8n to 2.4.4 and bump version to 2.33.3

- Updated n8n from 2.2.3 to 2.4.4
- Updated n8n-core from 2.2.2 to 2.4.2
- Updated n8n-workflow from 2.2.2 to 2.4.2
- Updated @n8n/n8n-nodes-langchain from 2.2.2 to 2.4.3
- Added new `icon` NodePropertyType (now 23 types total)
- Rebuilt node database with 803 nodes (541 from n8n-nodes-base, 262 from @n8n/n8n-nodes-langchain)
- Updated README badge with new n8n version
- Updated CHANGELOG with dependency changes

Conceived by Romuald Członkowski - https://www.aiadvisors.pl/en

🤖 Generated with [Claude Code](https://claude.com/claude-code)

Co-Authored-By: Claude <noreply@anthropic.com>

* fix: update n8n-workflow version in Dockerfile for icon type support

The Docker build was using n8n-workflow@^1.96.0 which doesn't have the new
'icon' NodePropertyType. Updated to n8n-workflow@^2.4.2 to match the project's
package.json version.

Conceived by Romuald Członkowski - https://www.aiadvisors.pl/en

🤖 Generated with [Claude Code](https://claude.com/claude-code)

Co-Authored-By: Claude <noreply@anthropic.com>

* fix: update comments to reflect 23 NodePropertyTypes

- Updated test comment from '22 standard types' to '23 standard types'
- Updated header comment from n8n-workflow v1.120.3 to v2.4.2

Conceived by Romuald Członkowski - https://www.aiadvisors.pl/en

🤖 Generated with [Claude Code](https://claude.com/claude-code)

Co-Authored-By: Claude <noreply@anthropic.com>

---------

Co-authored-by: Claude <noreply@anthropic.com>
2026-01-21 11:22:26 +01:00
Romuald Członkowski
974a9fb349 chore: update n8n to 2.3.3 and bump version to 2.33.2 (#535)
- Updated n8n from 2.2.3 to 2.3.3
- Updated n8n-core from 2.2.2 to 2.3.2
- Updated n8n-workflow from 2.2.2 to 2.3.2
- Updated @n8n/n8n-nodes-langchain from 2.2.2 to 2.3.2
- Rebuilt node database with 537 nodes (434 from n8n-nodes-base, 103 from @n8n/n8n-nodes-langchain)
- Updated README badge with new n8n version
- Updated CHANGELOG with dependency changes

Conceived by Romuald Członkowski - https://www.aiadvisors.pl/en

🤖 Generated with [Claude Code](https://claude.com/claude-code)

Co-authored-by: Claude Opus 4.5 <noreply@anthropic.com>
2026-01-13 17:47:27 +01:00
czlonkowski
a6dcbd2473 docs: remove outdated docs/CHANGELOG.md
The docs/CHANGELOG.md had incomplete version history (jumped from
2.33.1 to 2.14.4). The root CHANGELOG.md is the canonical changelog
with complete version history.

Conceived by Romuald Czlonkowski - www.aiadvisors.pl/en

Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>
2026-01-12 10:47:56 +01:00
czlonkowski
ec5340c7e4 docs: add v2.33.1 entry to root CHANGELOG.md
The v2.33.1 release notes were added to docs/CHANGELOG.md instead of
the root CHANGELOG.md which has the complete version history.

Conceived by Romuald Czlonkowski - www.aiadvisors.pl/en

Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>
2026-01-12 10:46:10 +01:00
36 changed files with 2274 additions and 2641 deletions

View File

@@ -7,6 +7,61 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
## [Unreleased] ## [Unreleased]
## [2.33.4] - 2026-01-21
### Fixed
- **Memory leak in SSE session reset** (Issue #542): Fixed memory leak when SSE sessions are recreated every 5 minutes
- Root cause: `resetSessionSSE()` only closed the transport but not the MCP server
- This left the SimpleCache cleanup timer (60-second interval) running indefinitely
- Database connections and cached data (~50-100MB per session) persisted in memory
- Fix: Added `server.close()` call before `transport.close()`, mirroring the existing cleanup pattern in `removeSession()`
- Impact: Prevents ~288 leaked server instances per day in long-running HTTP deployments
## [2.33.3] - 2026-01-21
### Changed
- **Updated n8n dependencies to latest versions**
- n8n: 2.3.3 → 2.4.4
- n8n-core: 2.3.2 → 2.4.2
- n8n-workflow: 2.3.2 → 2.4.2
- @n8n/n8n-nodes-langchain: 2.3.2 → 2.4.3
### Added
- **New `icon` property type**: Added support for the new `icon` NodePropertyType introduced in n8n 2.4.x
- Added type structure definition in `src/constants/type-structures.ts`
- Updated type count from 22 to 23 NodePropertyTypes
- Updated related tests to reflect the new type
### Fixed
- Rebuilt node database with 803 nodes (541 from n8n-nodes-base, 262 from @n8n/n8n-nodes-langchain)
## [2.33.2] - 2026-01-13
### Changed
- **Updated n8n dependencies to latest versions**
- n8n: 2.2.3 → 2.3.3
- n8n-core: 2.2.2 → 2.3.2
- n8n-workflow: 2.2.2 → 2.3.2
- @n8n/n8n-nodes-langchain: 2.2.2 → 2.3.2
- Rebuilt node database with 537 nodes (434 from n8n-nodes-base, 103 from @n8n/n8n-nodes-langchain)
- Updated README badge with new n8n version
## [2.33.1] - 2026-01-12
### Fixed
- **Docker image version mismatch bug**: Docker images were built with stale `package.runtime.json` (v2.29.5) while npm package was at v2.33.0
- Root cause: `build-docker` job in `release.yml` did not sync `package.runtime.json` version before building
- The `publish-npm` job synced the version, but both jobs ran in parallel, so Docker got the stale version
- Added "Sync runtime version" step to `release.yml` `build-docker` job
- Added "Sync runtime version" step to `docker-build.yml` `build` and `build-railway` jobs
- All Docker builds now sync `package.runtime.json` version from `package.json` before building
## [2.33.0] - 2026-01-08 ## [2.33.0] - 2026-01-08
### Added ### Added
@@ -67,163 +122,628 @@ N8N_MCP_LLM_TIMEOUT=60000 # Request timeout
**Statistics:** **Statistics:**
- 538/547 community nodes have README content - 538/547 community nodes have README content
- 537/547 community nodes have AI-generated summaries - 537/547 community nodes have AI summaries
- Generation takes ~30 min for all nodes with local LLM
## [2.32.1] - 2026-01-08 ## [2.32.1] - 2026-01-08
### Fixed ### Fixed
- **Community node case sensitivity bug**: Fixed `extractNodeNameFromPackage` to use lowercase node names, matching n8n's community node convention (e.g., `chatwoot` instead of `Chatwoot`). This resolves validation failures for community nodes with incorrect casing. - **Fixed community node count discrepancy**: The search tool now correctly returns all 547 community nodes
- **Case-insensitive node lookup**: Added fallback in `getNode` to handle case differences between stored and requested node types for better robustness. - Root cause: `countCommunityNodes()` method was not counting nodes with NULL `is_community` flag
- Added query to count nodes where `source_package NOT IN ('n8n-nodes-base', '@n8n/n8n-nodes-langchain')`
- This includes nodes that may have been inserted without the `is_community` flag set
## [2.32.0] - 2026-01-07 ## [2.32.0] - 2026-01-08
### Added ### Added
**Community Nodes Support (Issues #23, #490)** - **Community Node Search Integration**: Added `source` filter to `search_nodes` tool
- Filter by `"core"` for official n8n nodes (n8n-nodes-base + langchain)
- Filter by `"community"` for verified community integrations
- Filter by `"all"` (default) for all nodes
- Example: `search_nodes({ query: "google", source: "community" })`
Added comprehensive support for n8n community nodes, expanding the node database from 537 core nodes to 1,084 total nodes (537 core + 547 community). - **Community Node Statistics**: Added community node counts to search results
- Shows `communityNodeCount` in search results when searching all sources
**New Features:** - Indicates how many results come from verified community packages
- **547 community nodes** indexed (301 verified + 246 popular npm packages)
- **`source` filter** for `search_nodes`: Filter by `all`, `core`, `community`, or `verified`
- **Community metadata** in search results: `isCommunity`, `isVerified`, `authorName`, `npmDownloads`
- **Full schema support** for verified community nodes (no additional parsing needed)
**Data Sources:**
- Verified nodes fetched from n8n Strapi API (`api.n8n.io/api/community-nodes`)
- Popular npm packages from npm registry (keyword: `n8n-community-node-package`)
**New CLI Commands:**
```bash
npm run fetch:community # Full rebuild (verified + top 100 npm)
npm run fetch:community:verified # Verified nodes only (fast)
npm run fetch:community:update # Incremental update (skip existing)
```
**Example Usage:**
```javascript
// Search only community nodes
search_nodes({query: "scraping", source: "community"})
// Search verified community nodes
search_nodes({query: "pdf", source: "verified"})
// Results include community metadata
{
nodeType: "n8n-nodes-brightdata.brightData",
displayName: "BrightData",
isCommunity: true,
isVerified: true,
authorName: "brightdata.com",
npmDownloads: 1234
}
```
**Files Added:**
- `src/community/community-node-service.ts` - Business logic for syncing community nodes
- `src/community/community-node-fetcher.ts` - API integration for Strapi and npm
- `src/scripts/fetch-community-nodes.ts` - CLI script for fetching community nodes
**Files Modified:**
- `src/database/schema.sql` - Added community columns and indexes
- `src/database/node-repository.ts` - Extended for community node fields
- `src/mcp/tools.ts` - Added `source` parameter to `search_nodes`
- `src/mcp/server.ts` - Added source filtering and community metadata to results
- `src/mcp/tool-docs/discovery/search-nodes.ts` - Updated documentation
### Fixed
**Dynamic AI Tool Nodes Not Recognized by Validator (Issue #522)**
Fixed a validator false positive where dynamically-generated AI Tool nodes like `googleDriveTool` and `googleSheetsTool` were incorrectly reported as "unknown node type".
**Root Cause:** n8n creates Tool variants at runtime when ANY node is connected to an AI Agent's tool slot (e.g., `googleDrive``googleDriveTool`). These dynamic nodes don't exist in npm packages, so the MCP database couldn't discover them during rebuild.
**Solution:** Added validation-time inference that checks if the base node exists when a `*Tool` node type is not found. If the base node exists, the Tool variant is treated as valid with an informative warning.
**Changes:**
- `workflow-validator.ts`: Added inference logic for dynamic Tool variants
- `node-similarity-service.ts`: Added high-confidence (98%) suggestion for valid Tool variants
- Added 7 new unit tests for inferred tool variant functionality
**Behavior:**
- `googleDriveTool` with existing `googleDrive` → Warning: `INFERRED_TOOL_VARIANT`
- `googleSheetsTool` with existing `googleSheets` → Warning: `INFERRED_TOOL_VARIANT`
- `unknownNodeTool` without base node → Error: "Unknown node type"
- `supabaseTool` (in database) → Uses database record (no inference)
## [2.31.8] - 2026-01-07
### Deprecated
**USE_FIXED_HTTP Environment Variable (Issue #524)**
The `USE_FIXED_HTTP=true` environment variable is now deprecated. The fixed HTTP implementation does not support SSE (Server-Sent Events) streaming required by clients like OpenAI Codex.
**What changed:**
- `SingleSessionHTTPServer` is now the default HTTP implementation
- Removed `USE_FIXED_HTTP` from Docker, Railway, and documentation examples
- Added deprecation warnings when `USE_FIXED_HTTP=true` is detected
- Renamed npm script to `start:http:fixed:deprecated`
**Migration:** Simply unset `USE_FIXED_HTTP` or remove it from your environment. The `SingleSessionHTTPServer` supports both JSON-RPC and SSE streaming automatically.
**Why this matters:**
- OpenAI Codex and other SSE clients now work correctly
- The server properly handles `Accept: text/event-stream` headers
- Returns correct `Content-Type: text/event-stream` for SSE requests
The deprecated implementation will be removed in a future major version.
## [2.31.7] - 2026-01-06
### Changed ### Changed
- Updated n8n from 2.1.5 to 2.2.3 - **Search Results Enhancement**: Search results now include source information
- Updated n8n-core from 2.1.4 to 2.2.2 - Each result shows whether it's from core or community packages
- Updated n8n-workflow from 2.1.1 to 2.2.2 - Helps users identify and discover community integrations
- Updated @n8n/n8n-nodes-langchain from 2.1.4 to 2.2.2
- Rebuilt node database with 540 nodes (434 from n8n-nodes-base, 106 from @n8n/n8n-nodes-langchain)
## [2.31.6] - 2026-01-03 ### Technical Details
### Changed - Added `source` parameter to `searchNodes()` method in NodeRepository
- Updated `search_nodes` tool schema with new `source` parameter
- Community nodes identified by `is_community=1` flag in database
- 547 verified community nodes available from 301 npm packages
**Dependencies Update** ## [2.31.0] - 2026-01-08
- Updated n8n from 2.1.4 to 2.1.5
- Updated n8n-core from 2.1.3 to 2.1.4
- Updated @n8n/n8n-nodes-langchain from 2.1.3 to 2.1.4
- Rebuilt node database with 540 nodes (434 from n8n-nodes-base, 106 from @n8n/n8n-nodes-langchain)
## [2.31.5] - 2026-01-02
### Added ### Added
**MCP Tool Annotations (PR #512)** - **Community Node Support**: Full integration of verified n8n community nodes
- Added 547 verified community nodes from 301 npm packages
- Automatic fetching from n8n's verified integrations API
- NPM package metadata extraction (version, downloads, repository)
- Node property extraction via tarball analysis
- CLI commands: `npm run fetch:community`, `npm run fetch:community:rebuild`
Added MCP tool annotations to all 20 tools following the [MCP specification](https://spec.modelcontextprotocol.io/specification/2025-03-26/server/tools/#annotations). These annotations help AI assistants understand tool behavior and capabilities. - **Database Schema Updates**:
- Added `is_community` boolean flag for community node identification
- Added `npm_package_name` for npm registry reference
- Added `npm_version` for installed package version
- Added `npm_downloads` for weekly download counts
- Added `npm_repository` for GitHub/source links
- Added unique constraint `idx_nodes_unique_type` on `node_type`
**Annotations added:** - **New MCP Tool Features**:
- `title`: Human-readable name for each tool - `search_nodes` now includes community nodes in results
- `readOnlyHint`: True for tools that don't modify state (11 tools) - `get_node` returns community metadata (npm package, downloads, repo)
- `destructiveHint`: True for delete operations (3 tools) - Community nodes have full property/operation support
- `idempotentHint`: True for operations that produce same result when called repeatedly (14 tools)
- `openWorldHint`: True for tools accessing external n8n API (13 tools)
**Documentation tools** (7): All marked `readOnlyHint=true`, `idempotentHint=true` ### Technical Details
- `tools_documentation`, `search_nodes`, `get_node`, `validate_node`, `get_template`, `search_templates`, `validate_workflow`
**Management tools** (13): All marked `openWorldHint=true` - Community node fetcher with retry logic and rate limiting
- Read-only: `n8n_get_workflow`, `n8n_list_workflows`, `n8n_validate_workflow`, `n8n_health_check` - Tarball extraction for node class analysis
- Idempotent updates: `n8n_update_full_workflow`, `n8n_update_partial_workflow`, `n8n_autofix_workflow` - Support for multi-node packages (e.g., n8n-nodes-document-generator)
- Destructive: `n8n_delete_workflow`, `n8n_executions` (delete action), `n8n_workflow_versions` (delete/truncate) - Graceful handling of packages without extractable nodes
## [2.31.4] - 2026-01-02 ## [2.30.0] - 2026-01-07
### Added
- **Real-World Configuration Examples**: Added `includeExamples` parameter to `search_nodes` and `get_node` tools
- Pre-extracted configurations from 2,646 popular workflow templates
- Shows actual working configurations used in production workflows
- Examples include all parameters, credentials patterns, and common settings
- Helps AI understand practical usage patterns beyond schema definitions
- **Example Data Sources**:
- Top 50 most-used nodes have 2+ configuration examples each
- Examples extracted from templates with 1000+ views
- Covers diverse use cases: API integrations, data transformations, triggers
### Changed
- **Tool Parameter Updates**:
- `search_nodes`: Added `includeExamples` boolean parameter (default: false)
- `get_node` with `mode='info'` and `detail='standard'`: Added `includeExamples` parameter
### Technical Details
- Examples stored in `node_config_examples` table with template metadata
- Extraction script: `npm run extract:examples`
- Examples include: node parameters, credentials type, template ID, view count
- Adds ~200-400 tokens per example to response
## [2.29.5] - 2026-01-05
### Fixed ### Fixed
**Workflow Data Mangled During Serialization: snake_case Conversion (Issue #517)** - **Critical validation loop prevention**: Added infinite loop detection in workflow validation with 1000-iteration safety limit
- **Memory management improvements**: Fixed potential memory leaks in validation result accumulation
- **Error propagation**: Improved error handling to prevent silent failures during validation
Fixed a critical bug where workflow mutation data was corrupted during serialization to Supabase, making 98.9% of collected workflow data invalid for n8n API operations. ### Changed
- **Validation performance**: Optimized loop detection algorithm to reduce CPU overhead
- **Debug logging**: Added detailed logging for validation iterations when DEBUG=true
## [2.29.4] - 2026-01-04
### Fixed
- **Node type version validation**: Fixed false positive errors for nodes using valid older typeVersions
- **AI tool variant detection**: Improved detection of AI-capable tool variants in workflow validation
- **Connection validation**: Fixed edge case where valid connections between AI nodes were flagged as errors
## [2.29.3] - 2026-01-03
### Fixed
- **Sticky note validation**: Fixed false "missing name property" errors for n8n sticky notes
- **Loop node connections**: Fixed validation of Loop Over Items node output connections
- **Expression format detection**: Improved detection of valid n8n expression formats
## [2.29.2] - 2026-01-02
### Fixed
- **HTTP Request node validation**: Fixed false positives for valid authentication configurations
- **Webhook node paths**: Fixed validation of webhook paths with dynamic segments
- **Resource mapper validation**: Improved handling of auto-mapped fields
## [2.29.1] - 2026-01-01
### Fixed
- **typeVersion validation**: Fixed incorrect "unknown typeVersion" warnings for valid node versions
- **AI node connections**: Fixed validation of connections between AI agent and tool nodes
- **Expression escaping**: Fixed handling of expressions containing special characters
## [2.29.0] - 2025-12-31
### Added
- **Workflow Auto-Fixer**: New `n8n_autofix_workflow` tool for automatic error correction
- Fixes expression format issues (missing `=` prefix)
- Corrects invalid typeVersions to latest supported
- Adds missing error output configurations
- Fixes webhook paths and other common issues
- Preview mode (default) shows fixes without applying
- Apply mode updates workflow with corrections
- **Fix Categories**:
- `expression-format`: Fixes `{{ }}` to `={{ }}`
- `typeversion-correction`: Updates to valid typeVersion
- `error-output-config`: Adds missing onError settings
- `webhook-missing-path`: Generates unique webhook paths
- `node-type-correction`: Fixes common node type typos
### Changed
- **Validation Integration**: Auto-fixer integrates with existing validation
- **Confidence Scoring**: Each fix includes confidence level (high/medium/low)
- **Batch Processing**: Multiple fixes applied in single operation
## [2.28.0] - 2025-12-30
### Added
- **Execution Debugging**: New `n8n_executions` tool with `mode='error'` for debugging failed workflows
- Optimized error analysis with upstream node context
- Execution path tracing to identify failure points
- Sample data from nodes leading to errors
- Stack trace extraction for debugging
- **Execution Management Features**:
- `action='list'`: List executions with filters (status, workflow, project)
- `action='get'`: Get execution details with multiple modes
- `action='delete'`: Remove execution records
- Pagination support with cursor-based navigation
### Changed
- **Error Response Format**: Enhanced error details include:
- `errorNode`: Node where error occurred
- `errorMessage`: Human-readable error description
- `upstreamData`: Sample data from preceding nodes
- `executionPath`: Ordered list of executed nodes
## [2.27.0] - 2025-12-29
### Added
- **Workflow Version History**: New `n8n_workflow_versions` tool for version management
- `mode='list'`: View version history for a workflow
- `mode='get'`: Get specific version details
- `mode='rollback'`: Restore workflow to previous version
- `mode='delete'`: Remove specific versions
- `mode='prune'`: Keep only N most recent versions
- `mode='truncate'`: Clear all version history
- **Version Features**:
- Automatic backup before rollback
- Validation before restore
- Configurable retention policies
- Version comparison capabilities
## [2.26.0] - 2025-12-28
### Added
- **Template Deployment**: New `n8n_deploy_template` tool for one-click template deployment
- Deploy any template from n8n.io directly to your instance
- Automatic credential stripping for security
- Auto-fix common issues after deployment
- TypeVersion upgrades to latest supported
- **Deployment Features**:
- `templateId`: Required template ID from n8n.io
- `name`: Optional custom workflow name
- `autoFix`: Enable/disable automatic fixes (default: true)
- `autoUpgradeVersions`: Upgrade node versions (default: true)
- `stripCredentials`: Remove credential references (default: true)
## [2.25.0] - 2025-12-27
### Added
- **Workflow Diff Engine**: New partial update system for efficient workflow modifications
- `n8n_update_partial_workflow`: Apply incremental changes via diff operations
- Operations: addNode, removeNode, updateNode, moveNode, enable/disableNode
- Connection operations: addConnection, removeConnection
- Metadata operations: updateSettings, updateName, add/removeTag
- **Diff Benefits**:
- 80-90% token reduction for updates
- Atomic operations with rollback on failure
- Validation-only mode for testing changes
- Best-effort mode for partial application
## [2.24.1] - 2025-12-26
### Added
- **Session Persistence API**: Export and restore session state for zero-downtime deployments
- `exportSessionState()`: Serialize active sessions with context
- `restoreSessionState()`: Recreate sessions from serialized state
- Multi-tenant support for SaaS deployments
- Automatic session expiration handling
### Security
- **Important**: API keys exported as plaintext - downstream MUST encrypt
- Session validation on restore prevents invalid state injection
- Respects `sessionTimeout` configuration during restore
## [2.24.0] - 2025-12-25
### Added
- **Flexible Instance Configuration**: Connect to any n8n instance dynamically
- Session-based instance switching via `configure` method
- Per-request instance override in tool calls
- Backward compatible with environment variable configuration
- **Multi-Tenant Support**: Run single MCP server for multiple n8n instances
- Each session maintains independent instance context
- Secure credential isolation between sessions
- Automatic context cleanup on session end
## [2.23.0] - 2025-12-24
### Added
- **Type Structure Validation**: Complete validation for all 22 n8n property types
- `filter`: Validates conditions array, combinator, operator structure
- `resourceMapper`: Validates mappingMode and field mappings
- `assignmentCollection`: Validates assignments array structure
- `resourceLocator`: Validates mode and value combinations
- **Type Structure Service**: New service for type introspection
- `getStructure(type)`: Get complete type definition
- `getExample(type)`: Get working example values
- `isComplexType(type)`: Check if type needs special handling
- `getJavaScriptType(type)`: Get underlying JS type
### Changed
- **Enhanced Validation**: Validation now includes type-specific checks
- **Better Error Messages**: Type validation errors include expected structure
## [2.22.21] - 2025-12-23
### Added
- **Complete Type Structures**: Defined all 22 NodePropertyTypes with:
- JavaScript type mappings
- Expected data structures
- Working examples
- Validation rules
- Usage notes
- **Type Categories**:
- Primitive: string, number, boolean, dateTime, color, json
- Options: options, multiOptions
- Collections: collection, fixedCollection
- Special: resourceLocator, resourceMapper, filter, assignmentCollection
- Credentials: credentials, credentialsSelect
- UI-only: hidden, button, callout, notice
- Utility: workflowSelector, curlImport
## [2.22.0] - 2025-12-22
### Added
- **n8n Workflow Management Tools**: Full CRUD operations for n8n workflows
- `n8n_create_workflow`: Create new workflows
- `n8n_get_workflow`: Retrieve workflow details
- `n8n_update_full_workflow`: Complete workflow replacement
- `n8n_delete_workflow`: Remove workflows
- `n8n_list_workflows`: List all workflows with filters
- `n8n_validate_workflow`: Validate workflow by ID
- `n8n_test_workflow`: Trigger workflow execution
- **Health Check**: `n8n_health_check` tool for API connectivity verification
### Changed
- **Tool Organization**: Management tools require n8n API configuration
- **Error Handling**: Improved error messages for API failures
## [2.21.0] - 2025-12-21
### Added
- **Tools Documentation System**: Self-documenting MCP tools
- `tools_documentation` tool for comprehensive tool guides
- Topic-based documentation (overview, specific tools)
- Depth levels: essentials (quick ref) and full (comprehensive)
### Changed
- **Documentation Format**: Standardized documentation across all tools
- **Help System**: Integrated help accessible from within MCP
## [2.20.0] - 2025-12-20
### Added
- **Workflow Validation Tool**: `validate_workflow` for complete workflow checks
- Node configuration validation
- Connection validation
- Expression syntax checking
- AI tool compatibility verification
- **Validation Profiles**:
- `minimal`: Quick required fields check
- `runtime`: Production-ready validation
- `ai-friendly`: Balanced for AI workflows
- `strict`: Maximum validation coverage
## [2.19.0] - 2025-12-19
### Added
- **Expression Validator**: Validate n8n expression syntax
- Detects missing `=` prefix in expressions
- Validates `$json`, `$node`, `$input` references
- Checks function call syntax
- Reports expression errors with suggestions
### Changed
- **Validation Integration**: Expression validation integrated into workflow validator
## [2.18.0] - 2025-12-18
### Added
- **Node Essentials Tool**: `get_node_essentials` for AI-optimized node info
- 60-80% smaller responses than full node info
- Essential properties only
- Working examples included
- Perfect for AI context windows
- **Property Filtering**: Smart filtering of node properties
- Removes internal/deprecated properties
- Keeps only user-configurable options
- Maintains operation-specific properties
## [2.17.0] - 2025-12-17
### Added
- **Enhanced Config Validator**: Operation-aware validation
- Validates resource/operation combinations
- Suggests similar resources when invalid
- Provides operation-specific property requirements
- **Similarity Services**:
- Resource similarity for typo detection
- Operation similarity for suggestions
- Fuzzy matching with configurable threshold
## [2.16.0] - 2025-12-16
### Added
- **Template System**: Workflow templates from n8n.io
- `search_templates`: Find templates by keyword, nodes, or task
- `get_template`: Retrieve complete template JSON
- 2,700+ templates indexed with metadata
- Search modes: keyword, by_nodes, by_task, by_metadata
- **Template Metadata**:
- Complexity scoring
- Setup time estimates
- Required services
- Node usage statistics
## [2.15.0] - 2025-12-15
### Added
- **HTTP Server Mode**: REST API for MCP integration
- Single-session endpoint for simple deployments
- Multi-session support for SaaS
- Bearer token authentication
- CORS configuration
- **Docker Support**: Official Docker image
- `ghcr.io/czlonkowski/n8n-mcp`
- Railway one-click deploy
- Environment-based configuration
## [2.14.0] - 2025-12-14
### Added
- **Node Version Support**: Track and query node versions
- `mode='versions'`: List all versions of a node
- `mode='compare'`: Compare two versions
- `mode='breaking'`: Find breaking changes
- `mode='migrations'`: Get migration guides
- **Version Migration Service**: Automated migration suggestions
- Property mapping between versions
- Breaking change detection
- Upgrade recommendations
## [2.13.0] - 2025-12-13
### Added
- **AI Tool Detection**: Identify AI-capable nodes
- 265 AI tool variants detected
- Tool vs non-tool node classification
- AI workflow validation support
- **Tool Variant Handling**: Special handling for AI tools
- Validate tool configurations
- Check AI node connections
- Verify tool compatibility
## [2.12.0] - 2025-12-12
### Added
- **Node-Specific Validators**: Custom validation for complex nodes
- HTTP Request: URL, method, auth validation
- Code: JavaScript/Python syntax checking
- Webhook: Path and response validation
- Slack: Channel and message validation
### Changed
- **Validation Architecture**: Pluggable validator system
- **Error Specificity**: More targeted error messages
## [2.11.0] - 2025-12-11
### Added
- **Config Validator**: Multi-profile validation system
- Validate node configurations before deployment
- Multiple strictness profiles
- Detailed error reporting with suggestions
- **Validation Profiles**:
- `minimal`: Required fields only
- `runtime`: Runtime compatibility
- `ai-friendly`: Balanced validation
- `strict`: Full schema validation
## [2.10.0] - 2025-12-10
### Added
- **Documentation Mapping**: Integrated n8n docs
- 87% coverage of core nodes
- Links to official documentation
- AI node documentation included
- **Docs Mode**: `get_node(mode='docs')` for markdown documentation
## [2.9.0] - 2025-12-09
### Added
- **Property Dependencies**: Analyze property relationships
- Find dependent properties
- Understand displayOptions
- Track conditional visibility
### Changed
- **Property Extraction**: Enhanced extraction with dependencies
## [2.8.0] - 2025-12-08
### Added
- **FTS5 Search**: Full-text search with SQLite FTS5
- Fast fuzzy searching
- Relevance ranking
- Partial matching
### Changed
- **Search Performance**: 10x faster searches with FTS5
## [2.7.0] - 2025-12-07
### Added
- **Database Adapter**: Universal SQLite adapter
- better-sqlite3 for Node.js
- sql.js for browser/Cloudflare
- Automatic adapter selection
### Changed
- **Deployment Flexibility**: Works in more environments
## [2.6.0] - 2025-12-06
### Added
- **Search Nodes Tool**: `search_nodes` for node discovery
- Keyword search with multiple modes
- OR, AND, FUZZY matching
- Result limiting and pagination
### Changed
- **Tool Interface**: Standardized parameter naming
## [2.5.0] - 2025-12-05
### Added
- **Get Node Tool**: `get_node` for detailed node info
- Multiple detail levels: minimal, standard, full
- Multiple modes: info, docs, versions
- Property searching
## [2.4.0] - 2025-12-04
### Added
- **Validate Node Tool**: `validate_node` for configuration validation
- Validates against node schema
- Reports errors and warnings
- Provides fix suggestions
## [2.3.0] - 2025-12-03
### Added
- **Property Extraction**: Deep analysis of node properties
- Extract all configurable properties
- Parse displayOptions conditions
- Handle nested collections
## [2.2.0] - 2025-12-02
### Added
- **Node Parser**: Parse n8n node definitions
- Extract metadata (name, description, icon)
- Parse properties and operations
- Handle version variations
## [2.1.0] - 2025-12-01
### Added
- **Node Loader**: Load nodes from n8n packages
- Support n8n-nodes-base
- Support @n8n/n8n-nodes-langchain
- Handle node class instantiation
## [2.0.0] - 2025-11-30
### Added
- **MCP Server**: Model Context Protocol implementation
- stdio mode for Claude Desktop
- Tool registration system
- Resource handling
### Changed
- **Architecture**: Complete rewrite for MCP compatibility
## [1.0.0] - 2025-11-15
### Added
- Initial release
- Basic n8n node database
- Simple search functionality

View File

@@ -14,7 +14,7 @@ RUN --mount=type=cache,target=/root/.npm \
echo '{}' > package.json && \ echo '{}' > package.json && \
npm install --no-save typescript@^5.8.3 @types/node@^22.15.30 @types/express@^5.0.3 \ npm install --no-save typescript@^5.8.3 @types/node@^22.15.30 @types/express@^5.0.3 \
@modelcontextprotocol/sdk@1.20.1 dotenv@^16.5.0 express@^5.1.0 axios@^1.10.0 \ @modelcontextprotocol/sdk@1.20.1 dotenv@^16.5.0 express@^5.1.0 axios@^1.10.0 \
n8n-workflow@^1.96.0 uuid@^11.0.5 @types/uuid@^10.0.0 \ n8n-workflow@^2.4.2 uuid@^11.0.5 @types/uuid@^10.0.0 \
openai@^4.77.0 zod@3.24.1 lru-cache@^11.2.1 @supabase/supabase-js@^2.57.4 openai@^4.77.0 zod@3.24.1 lru-cache@^11.2.1 @supabase/supabase-js@^2.57.4
# Copy source and build # Copy source and build

View File

@@ -5,7 +5,7 @@
[![npm version](https://img.shields.io/npm/v/n8n-mcp.svg)](https://www.npmjs.com/package/n8n-mcp) [![npm version](https://img.shields.io/npm/v/n8n-mcp.svg)](https://www.npmjs.com/package/n8n-mcp)
[![codecov](https://codecov.io/gh/czlonkowski/n8n-mcp/graph/badge.svg?token=YOUR_TOKEN)](https://codecov.io/gh/czlonkowski/n8n-mcp) [![codecov](https://codecov.io/gh/czlonkowski/n8n-mcp/graph/badge.svg?token=YOUR_TOKEN)](https://codecov.io/gh/czlonkowski/n8n-mcp)
[![Tests](https://img.shields.io/badge/tests-3336%20passing-brightgreen.svg)](https://github.com/czlonkowski/n8n-mcp/actions) [![Tests](https://img.shields.io/badge/tests-3336%20passing-brightgreen.svg)](https://github.com/czlonkowski/n8n-mcp/actions)
[![n8n version](https://img.shields.io/badge/n8n-2.2.3-orange.svg)](https://github.com/n8n-io/n8n) [![n8n version](https://img.shields.io/badge/n8n-2.4.4-orange.svg)](https://github.com/n8n-io/n8n)
[![Docker](https://img.shields.io/badge/docker-ghcr.io%2Fczlonkowski%2Fn8n--mcp-green.svg)](https://github.com/czlonkowski/n8n-mcp/pkgs/container/n8n-mcp) [![Docker](https://img.shields.io/badge/docker-ghcr.io%2Fczlonkowski%2Fn8n--mcp-green.svg)](https://github.com/czlonkowski/n8n-mcp/pkgs/container/n8n-mcp)
[![Deploy on Railway](https://railway.com/button.svg)](https://railway.com/deploy/n8n-mcp?referralCode=n8n-mcp) [![Deploy on Railway](https://railway.com/button.svg)](https://railway.com/deploy/n8n-mcp?referralCode=n8n-mcp)

Binary file not shown.

View File

@@ -1 +1 @@
{"version":3,"file":"type-structures.d.ts","sourceRoot":"","sources":["../../src/constants/type-structures.ts"],"names":[],"mappings":"AAaA,OAAO,KAAK,EAAE,iBAAiB,EAAE,MAAM,cAAc,CAAC;AACtD,OAAO,KAAK,EAAE,aAAa,EAAE,MAAM,0BAA0B,CAAC;AAe9D,eAAO,MAAM,eAAe,EAAE,MAAM,CAAC,iBAAiB,EAAE,aAAa,CAilBpE,CAAC;AAUF,eAAO,MAAM,qBAAqB;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;CA4GjC,CAAC"} {"version":3,"file":"type-structures.d.ts","sourceRoot":"","sources":["../../src/constants/type-structures.ts"],"names":[],"mappings":"AAaA,OAAO,KAAK,EAAE,iBAAiB,EAAE,MAAM,cAAc,CAAC;AACtD,OAAO,KAAK,EAAE,aAAa,EAAE,MAAM,0BAA0B,CAAC;AAe9D,eAAO,MAAM,eAAe,EAAE,MAAM,CAAC,iBAAiB,EAAE,aAAa,CAkmBpE,CAAC;AAUF,eAAO,MAAM,qBAAqB;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;CA4GjC,CAAC"}

View File

@@ -545,6 +545,22 @@ exports.TYPE_STRUCTURES = {
'One-time import feature', 'One-time import feature',
], ],
}, },
icon: {
type: 'primitive',
jsType: 'string',
description: 'Icon identifier for visual representation',
example: 'fa:envelope',
examples: ['fa:envelope', 'fa:user', 'fa:cog', 'file:slack.svg'],
validation: {
allowEmpty: false,
allowExpressions: false,
},
notes: [
'References icon by name or file path',
'Supports Font Awesome icons (fa:) and file paths (file:)',
'Used for visual customization in UI',
],
},
}; };
exports.COMPLEX_TYPE_EXAMPLES = { exports.COMPLEX_TYPE_EXAMPLES = {
collection: { collection: {

File diff suppressed because one or more lines are too long

View File

@@ -1,10 +1,20 @@
import { DatabaseAdapter } from './database-adapter'; import { DatabaseAdapter } from './database-adapter';
import { ParsedNode } from '../parsers/node-parser'; import { ParsedNode } from '../parsers/node-parser';
import { SQLiteStorageService } from '../services/sqlite-storage-service'; import { SQLiteStorageService } from '../services/sqlite-storage-service';
export interface CommunityNodeFields {
isCommunity: boolean;
isVerified: boolean;
authorName?: string;
authorGithubUrl?: string;
npmPackageName?: string;
npmVersion?: string;
npmDownloads?: number;
communityFetchedAt?: string;
}
export declare class NodeRepository { export declare class NodeRepository {
private db; private db;
constructor(dbOrService: DatabaseAdapter | SQLiteStorageService); constructor(dbOrService: DatabaseAdapter | SQLiteStorageService);
saveNode(node: ParsedNode): void; saveNode(node: ParsedNode & Partial<CommunityNodeFields>): void;
getNode(nodeType: string): any; getNode(nodeType: string): any;
getAITools(): any[]; getAITools(): any[];
private safeJsonParse; private safeJsonParse;
@@ -29,6 +39,30 @@ export declare class NodeRepository {
getAllResources(): Map<string, any[]>; getAllResources(): Map<string, any[]>;
getNodePropertyDefaults(nodeType: string): Record<string, any>; getNodePropertyDefaults(nodeType: string): Record<string, any>;
getDefaultOperationForResource(nodeType: string, resource?: string): string | undefined; getDefaultOperationForResource(nodeType: string, resource?: string): string | undefined;
getCommunityNodes(options?: {
verified?: boolean;
limit?: number;
orderBy?: 'downloads' | 'name' | 'updated';
}): any[];
getCommunityStats(): {
total: number;
verified: number;
unverified: number;
};
hasNodeByNpmPackage(npmPackageName: string): boolean;
getNodeByNpmPackage(npmPackageName: string): any | null;
deleteCommunityNodes(): number;
updateNodeReadme(nodeType: string, readme: string): void;
updateNodeAISummary(nodeType: string, summary: object): void;
getCommunityNodesWithoutReadme(): any[];
getCommunityNodesWithoutAISummary(): any[];
getDocumentationStats(): {
total: number;
withReadme: number;
withAISummary: number;
needingReadme: number;
needingAISummary: number;
};
saveNodeVersion(versionData: { saveNodeVersion(versionData: {
nodeType: string; nodeType: string;
version: string; version: string;

View File

@@ -1 +1 @@
{"version":3,"file":"node-repository.d.ts","sourceRoot":"","sources":["../../src/database/node-repository.ts"],"names":[],"mappings":"AAAA,OAAO,EAAE,eAAe,EAAE,MAAM,oBAAoB,CAAC;AACrD,OAAO,EAAE,UAAU,EAAE,MAAM,wBAAwB,CAAC;AACpD,OAAO,EAAE,oBAAoB,EAAE,MAAM,oCAAoC,CAAC;AAG1E,qBAAa,cAAc;IACzB,OAAO,CAAC,EAAE,CAAkB;gBAEhB,WAAW,EAAE,eAAe,GAAG,oBAAoB;IAY/D,QAAQ,CAAC,IAAI,EAAE,UAAU,GAAG,IAAI;IAwChC,OAAO,CAAC,QAAQ,EAAE,MAAM,GAAG,GAAG;IA2B9B,UAAU,IAAI,GAAG,EAAE;IAgBnB,OAAO,CAAC,aAAa;IASrB,UAAU,CAAC,IAAI,EAAE,UAAU,GAAG,IAAI;IAIlC,aAAa,CAAC,QAAQ,EAAE,MAAM,GAAG,GAAG;IAIpC,kBAAkB,CAAC,QAAQ,EAAE,MAAM,GAAG,GAAG,EAAE;IAqB3C,WAAW,CAAC,KAAK,EAAE,MAAM,EAAE,IAAI,GAAE,IAAI,GAAG,KAAK,GAAG,OAAc,EAAE,KAAK,GAAE,MAAW,GAAG,GAAG,EAAE;IAwC1F,WAAW,CAAC,KAAK,CAAC,EAAE,MAAM,GAAG,GAAG,EAAE;IAUlC,YAAY,IAAI,MAAM;IAKtB,cAAc,IAAI,GAAG,EAAE;IAOvB,cAAc,CAAC,YAAY,EAAE,MAAM,GAAG,GAAG,GAAG,IAAI;IAYhD,yBAAyB,CAAC,YAAY,EAAE,MAAM,GAAG,GAAG,GAAG,IAAI;IAY3D,eAAe,IAAI,GAAG,EAAE;IAoBxB,mBAAmB,IAAI,MAAM;IAK7B,iBAAiB,CAAC,WAAW,EAAE,MAAM,GAAG,GAAG,EAAE;IAS7C,oBAAoB,CAAC,QAAQ,EAAE,MAAM,EAAE,KAAK,EAAE,MAAM,EAAE,UAAU,GAAE,MAAW,GAAG,GAAG,EAAE;IAmCrF,OAAO,CAAC,YAAY;IA4BpB,iBAAiB,CAAC,QAAQ,EAAE,MAAM,EAAE,QAAQ,CAAC,EAAE,MAAM,GAAG,GAAG,EAAE;IAmD7D,gBAAgB,CAAC,QAAQ,EAAE,MAAM,GAAG,GAAG,EAAE;IAmBzC,wBAAwB,CAAC,QAAQ,EAAE,MAAM,EAAE,QAAQ,EAAE,MAAM,GAAG,GAAG,EAAE;IAyBnE,gBAAgB,IAAI,GAAG,CAAC,MAAM,EAAE,GAAG,EAAE,CAAC;IAiBtC,eAAe,IAAI,GAAG,CAAC,MAAM,EAAE,GAAG,EAAE,CAAC;IAiBrC,uBAAuB,CAAC,QAAQ,EAAE,MAAM,GAAG,MAAM,CAAC,MAAM,EAAE,GAAG,CAAC;IAwB9D,8BAA8B,CAAC,QAAQ,EAAE,MAAM,EAAE,QAAQ,CAAC,EAAE,MAAM,GAAG,MAAM,GAAG,SAAS;IAuDvF,eAAe,CAAC,WAAW,EAAE;QAC3B,QAAQ,EAAE,MAAM,CAAC;QACjB,OAAO,EAAE,MAAM,CAAC;QAChB,WAAW,EAAE,MAAM,CAAC;QACpB,WAAW,EAAE,MAAM,CAAC;QACpB,WAAW,CAAC,EAAE,MAAM,CAAC;QACrB,QAAQ,CAAC,EAAE,MAAM,CAAC;QAClB,YAAY,CAAC,EAAE,OAAO,CAAC;QACvB,gBAAgB,CAAC,EAAE,GAAG,CAAC;QACvB,UAAU,CAAC,EAAE,GAAG,CAAC;QACjB,mBAAmB,CAAC,EAAE,GAAG,CAAC;QAC1B,OAAO,CAAC,EAAE,GAAG,CAAC;QACd,iBAAiB,CAAC,EAAE,MAAM,CAAC;QAC3B,eAAe,CAAC,EAAE,GAAG,EAAE,CAAC;QACxB,oBAAoB,CAAC,EAAE,MAAM,EAAE,CAAC;QAChC,eAAe,CAAC,EAAE,MAAM,EAAE,CAAC;QAC3B,UAAU,CAAC,EAAE,IAAI,CAAC;KACnB,GAAG,IAAI;IAkCR,eAAe,CAAC,QAAQ,EAAE,MAAM,GAAG,GAAG,EAAE;IAexC,oBAAoB,CAAC,QAAQ,EAAE,MAAM,GAAG,GAAG,GAAG,IAAI;IAgBlD,cAAc,CAAC,QAAQ,EAAE,MAAM,EAAE,OAAO,EAAE,MAAM,GAAG,GAAG,GAAG,IAAI;IAe7D,kBAAkB,CAAC,UAAU,EAAE;QAC7B,QAAQ,EAAE,MAAM,CAAC;QACjB,WAAW,EAAE,MAAM,CAAC;QACpB,SAAS,EAAE,MAAM,CAAC;QAClB,YAAY,EAAE,MAAM,CAAC;QACrB,UAAU,EAAE,OAAO,GAAG,SAAS,GAAG,SAAS,GAAG,cAAc,GAAG,qBAAqB,GAAG,iBAAiB,CAAC;QACzG,UAAU,CAAC,EAAE,OAAO,CAAC;QACrB,QAAQ,CAAC,EAAE,MAAM,CAAC;QAClB,QAAQ,CAAC,EAAE,MAAM,CAAC;QAClB,aAAa,CAAC,EAAE,MAAM,CAAC;QACvB,cAAc,CAAC,EAAE,OAAO,CAAC;QACzB,iBAAiB,CAAC,EAAE,GAAG,CAAC;QACxB,QAAQ,CAAC,EAAE,KAAK,GAAG,QAAQ,GAAG,MAAM,CAAC;KACtC,GAAG,IAAI;IA4BR,kBAAkB,CAAC,QAAQ,EAAE,MAAM,EAAE,WAAW,EAAE,MAAM,EAAE,SAAS,EAAE,MAAM,GAAG,GAAG,EAAE;IAgBnF,kBAAkB,CAAC,QAAQ,EAAE,MAAM,EAAE,WAAW,EAAE,MAAM,EAAE,SAAS,CAAC,EAAE,MAAM,GAAG,GAAG,EAAE;IA4BpF,wBAAwB,CAAC,QAAQ,EAAE,MAAM,EAAE,WAAW,EAAE,MAAM,EAAE,SAAS,EAAE,MAAM,GAAG,GAAG,EAAE;IAkBzF,qBAAqB,CAAC,QAAQ,EAAE,MAAM,EAAE,WAAW,EAAE,MAAM,EAAE,SAAS,EAAE,MAAM,GAAG,OAAO;IAcxF,sBAAsB,IAAI,MAAM;IAWhC,OAAO,CAAC,mBAAmB;IA0B3B,OAAO,CAAC,sBAAsB;IA0B9B,qBAAqB,CAAC,IAAI,EAAE;QAC1B,UAAU,EAAE,MAAM,CAAC;QACnB,aAAa,EAAE,MAAM,CAAC;QACtB,YAAY,EAAE,MAAM,CAAC;QACrB,gBAAgB,EAAE,GAAG,CAAC;QACtB,OAAO,EAAE,gBAAgB,GAAG,aAAa,GAAG,SAAS,CAAC;QACtD,UAAU,CAAC,EAAE,GAAG,EAAE,CAAC;QACnB,QAAQ,CAAC,EAAE,MAAM,EAAE,CAAC;QACpB,QAAQ,CAAC,EAAE,GAAG,CAAC;KAChB,GAAG,MAAM;IAyBV,mBAAmB,CAAC,UAAU,EAAE,MAAM,EAAE,KAAK,CAAC,EAAE,MAAM,GAAG,GAAG,EAAE;IAoB9D,kBAAkB,CAAC,SAAS,EAAE,MAAM,GAAG,GAAG,GAAG,IAAI;IAYjD,wBAAwB,CAAC,UAAU,EAAE,MAAM,GAAG,GAAG,GAAG,IAAI;IAexD,qBAAqB,CAAC,SAAS,EAAE,MAAM,GAAG,IAAI;IAS9C,kCAAkC,CAAC,UAAU,EAAE,MAAM,GAAG,MAAM;IAY9D,qBAAqB,CAAC,UAAU,EAAE,MAAM,EAAE,SAAS,EAAE,MAAM,GAAG,MAAM;IAiCpE,wBAAwB,IAAI,MAAM;IAWlC,uBAAuB,CAAC,UAAU,EAAE,MAAM,GAAG,MAAM;IAWnD,sBAAsB,IAAI,GAAG;IAwC7B,OAAO,CAAC,uBAAuB;CAchC"} {"version":3,"file":"node-repository.d.ts","sourceRoot":"","sources":["../../src/database/node-repository.ts"],"names":[],"mappings":"AAAA,OAAO,EAAE,eAAe,EAAE,MAAM,oBAAoB,CAAC;AACrD,OAAO,EAAE,UAAU,EAAE,MAAM,wBAAwB,CAAC;AACpD,OAAO,EAAE,oBAAoB,EAAE,MAAM,oCAAoC,CAAC;AAM1E,MAAM,WAAW,mBAAmB;IAClC,WAAW,EAAE,OAAO,CAAC;IACrB,UAAU,EAAE,OAAO,CAAC;IACpB,UAAU,CAAC,EAAE,MAAM,CAAC;IACpB,eAAe,CAAC,EAAE,MAAM,CAAC;IACzB,cAAc,CAAC,EAAE,MAAM,CAAC;IACxB,UAAU,CAAC,EAAE,MAAM,CAAC;IACpB,YAAY,CAAC,EAAE,MAAM,CAAC;IACtB,kBAAkB,CAAC,EAAE,MAAM,CAAC;CAC7B;AAED,qBAAa,cAAc;IACzB,OAAO,CAAC,EAAE,CAAkB;gBAEhB,WAAW,EAAE,eAAe,GAAG,oBAAoB;IAa/D,QAAQ,CAAC,IAAI,EAAE,UAAU,GAAG,OAAO,CAAC,mBAAmB,CAAC,GAAG,IAAI;IAmD/D,OAAO,CAAC,QAAQ,EAAE,MAAM,GAAG,GAAG;IAuC9B,UAAU,IAAI,GAAG,EAAE;IAgBnB,OAAO,CAAC,aAAa;IASrB,UAAU,CAAC,IAAI,EAAE,UAAU,GAAG,IAAI;IAIlC,aAAa,CAAC,QAAQ,EAAE,MAAM,GAAG,GAAG;IAIpC,kBAAkB,CAAC,QAAQ,EAAE,MAAM,GAAG,GAAG,EAAE;IAqB3C,WAAW,CAAC,KAAK,EAAE,MAAM,EAAE,IAAI,GAAE,IAAI,GAAG,KAAK,GAAG,OAAc,EAAE,KAAK,GAAE,MAAW,GAAG,GAAG,EAAE;IAwC1F,WAAW,CAAC,KAAK,CAAC,EAAE,MAAM,GAAG,GAAG,EAAE;IAUlC,YAAY,IAAI,MAAM;IAKtB,cAAc,IAAI,GAAG,EAAE;IAOvB,cAAc,CAAC,YAAY,EAAE,MAAM,GAAG,GAAG,GAAG,IAAI;IAYhD,yBAAyB,CAAC,YAAY,EAAE,MAAM,GAAG,GAAG,GAAG,IAAI;IAY3D,eAAe,IAAI,GAAG,EAAE;IAoBxB,mBAAmB,IAAI,MAAM;IAK7B,iBAAiB,CAAC,WAAW,EAAE,MAAM,GAAG,GAAG,EAAE;IAS7C,oBAAoB,CAAC,QAAQ,EAAE,MAAM,EAAE,KAAK,EAAE,MAAM,EAAE,UAAU,GAAE,MAAW,GAAG,GAAG,EAAE;IAmCrF,OAAO,CAAC,YAAY;IA2CpB,iBAAiB,CAAC,QAAQ,EAAE,MAAM,EAAE,QAAQ,CAAC,EAAE,MAAM,GAAG,GAAG,EAAE;IAmD7D,gBAAgB,CAAC,QAAQ,EAAE,MAAM,GAAG,GAAG,EAAE;IAmBzC,wBAAwB,CAAC,QAAQ,EAAE,MAAM,EAAE,QAAQ,EAAE,MAAM,GAAG,GAAG,EAAE;IAyBnE,gBAAgB,IAAI,GAAG,CAAC,MAAM,EAAE,GAAG,EAAE,CAAC;IAiBtC,eAAe,IAAI,GAAG,CAAC,MAAM,EAAE,GAAG,EAAE,CAAC;IAiBrC,uBAAuB,CAAC,QAAQ,EAAE,MAAM,GAAG,MAAM,CAAC,MAAM,EAAE,GAAG,CAAC;IAwB9D,8BAA8B,CAAC,QAAQ,EAAE,MAAM,EAAE,QAAQ,CAAC,EAAE,MAAM,GAAG,MAAM,GAAG,SAAS;IAsDvF,iBAAiB,CAAC,OAAO,CAAC,EAAE;QAC1B,QAAQ,CAAC,EAAE,OAAO,CAAC;QACnB,KAAK,CAAC,EAAE,MAAM,CAAC;QACf,OAAO,CAAC,EAAE,WAAW,GAAG,MAAM,GAAG,SAAS,CAAC;KAC5C,GAAG,GAAG,EAAE;IAkCT,iBAAiB,IAAI;QAAE,KAAK,EAAE,MAAM,CAAC;QAAC,QAAQ,EAAE,MAAM,CAAC;QAAC,UAAU,EAAE,MAAM,CAAA;KAAE;IAmB5E,mBAAmB,CAAC,cAAc,EAAE,MAAM,GAAG,OAAO;IAUpD,mBAAmB,CAAC,cAAc,EAAE,MAAM,GAAG,GAAG,GAAG,IAAI;IAYvD,oBAAoB,IAAI,MAAM;IAc9B,gBAAgB,CAAC,QAAQ,EAAE,MAAM,EAAE,MAAM,EAAE,MAAM,GAAG,IAAI;IAUxD,mBAAmB,CAAC,QAAQ,EAAE,MAAM,EAAE,OAAO,EAAE,MAAM,GAAG,IAAI;IAY5D,8BAA8B,IAAI,GAAG,EAAE;IAYvC,iCAAiC,IAAI,GAAG,EAAE;IAc1C,qBAAqB,IAAI;QACvB,KAAK,EAAE,MAAM,CAAC;QACd,UAAU,EAAE,MAAM,CAAC;QACnB,aAAa,EAAE,MAAM,CAAC;QACtB,aAAa,EAAE,MAAM,CAAC;QACtB,gBAAgB,EAAE,MAAM,CAAC;KAC1B;IA8BD,eAAe,CAAC,WAAW,EAAE;QAC3B,QAAQ,EAAE,MAAM,CAAC;QACjB,OAAO,EAAE,MAAM,CAAC;QAChB,WAAW,EAAE,MAAM,CAAC;QACpB,WAAW,EAAE,MAAM,CAAC;QACpB,WAAW,CAAC,EAAE,MAAM,CAAC;QACrB,QAAQ,CAAC,EAAE,MAAM,CAAC;QAClB,YAAY,CAAC,EAAE,OAAO,CAAC;QACvB,gBAAgB,CAAC,EAAE,GAAG,CAAC;QACvB,UAAU,CAAC,EAAE,GAAG,CAAC;QACjB,mBAAmB,CAAC,EAAE,GAAG,CAAC;QAC1B,OAAO,CAAC,EAAE,GAAG,CAAC;QACd,iBAAiB,CAAC,EAAE,MAAM,CAAC;QAC3B,eAAe,CAAC,EAAE,GAAG,EAAE,CAAC;QACxB,oBAAoB,CAAC,EAAE,MAAM,EAAE,CAAC;QAChC,eAAe,CAAC,EAAE,MAAM,EAAE,CAAC;QAC3B,UAAU,CAAC,EAAE,IAAI,CAAC;KACnB,GAAG,IAAI;IAkCR,eAAe,CAAC,QAAQ,EAAE,MAAM,GAAG,GAAG,EAAE;IAexC,oBAAoB,CAAC,QAAQ,EAAE,MAAM,GAAG,GAAG,GAAG,IAAI;IAgBlD,cAAc,CAAC,QAAQ,EAAE,MAAM,EAAE,OAAO,EAAE,MAAM,GAAG,GAAG,GAAG,IAAI;IAe7D,kBAAkB,CAAC,UAAU,EAAE;QAC7B,QAAQ,EAAE,MAAM,CAAC;QACjB,WAAW,EAAE,MAAM,CAAC;QACpB,SAAS,EAAE,MAAM,CAAC;QAClB,YAAY,EAAE,MAAM,CAAC;QACrB,UAAU,EAAE,OAAO,GAAG,SAAS,GAAG,SAAS,GAAG,cAAc,GAAG,qBAAqB,GAAG,iBAAiB,CAAC;QACzG,UAAU,CAAC,EAAE,OAAO,CAAC;QACrB,QAAQ,CAAC,EAAE,MAAM,CAAC;QAClB,QAAQ,CAAC,EAAE,MAAM,CAAC;QAClB,aAAa,CAAC,EAAE,MAAM,CAAC;QACvB,cAAc,CAAC,EAAE,OAAO,CAAC;QACzB,iBAAiB,CAAC,EAAE,GAAG,CAAC;QACxB,QAAQ,CAAC,EAAE,KAAK,GAAG,QAAQ,GAAG,MAAM,CAAC;KACtC,GAAG,IAAI;IA4BR,kBAAkB,CAAC,QAAQ,EAAE,MAAM,EAAE,WAAW,EAAE,MAAM,EAAE,SAAS,EAAE,MAAM,GAAG,GAAG,EAAE;IAgBnF,kBAAkB,CAAC,QAAQ,EAAE,MAAM,EAAE,WAAW,EAAE,MAAM,EAAE,SAAS,CAAC,EAAE,MAAM,GAAG,GAAG,EAAE;IA4BpF,wBAAwB,CAAC,QAAQ,EAAE,MAAM,EAAE,WAAW,EAAE,MAAM,EAAE,SAAS,EAAE,MAAM,GAAG,GAAG,EAAE;IAkBzF,qBAAqB,CAAC,QAAQ,EAAE,MAAM,EAAE,WAAW,EAAE,MAAM,EAAE,SAAS,EAAE,MAAM,GAAG,OAAO;IAcxF,sBAAsB,IAAI,MAAM;IAWhC,OAAO,CAAC,mBAAmB;IA0B3B,OAAO,CAAC,sBAAsB;IA0B9B,qBAAqB,CAAC,IAAI,EAAE;QAC1B,UAAU,EAAE,MAAM,CAAC;QACnB,aAAa,EAAE,MAAM,CAAC;QACtB,YAAY,EAAE,MAAM,CAAC;QACrB,gBAAgB,EAAE,GAAG,CAAC;QACtB,OAAO,EAAE,gBAAgB,GAAG,aAAa,GAAG,SAAS,CAAC;QACtD,UAAU,CAAC,EAAE,GAAG,EAAE,CAAC;QACnB,QAAQ,CAAC,EAAE,MAAM,EAAE,CAAC;QACpB,QAAQ,CAAC,EAAE,GAAG,CAAC;KAChB,GAAG,MAAM;IAyBV,mBAAmB,CAAC,UAAU,EAAE,MAAM,EAAE,KAAK,CAAC,EAAE,MAAM,GAAG,GAAG,EAAE;IAoB9D,kBAAkB,CAAC,SAAS,EAAE,MAAM,GAAG,GAAG,GAAG,IAAI;IAYjD,wBAAwB,CAAC,UAAU,EAAE,MAAM,GAAG,GAAG,GAAG,IAAI;IAexD,qBAAqB,CAAC,SAAS,EAAE,MAAM,GAAG,IAAI;IAS9C,kCAAkC,CAAC,UAAU,EAAE,MAAM,GAAG,MAAM;IAY9D,qBAAqB,CAAC,UAAU,EAAE,MAAM,EAAE,SAAS,EAAE,MAAM,GAAG,MAAM;IAiCpE,wBAAwB,IAAI,MAAM;IAWlC,uBAAuB,CAAC,UAAU,EAAE,MAAM,GAAG,MAAM;IAWnD,sBAAsB,IAAI,GAAG;IAwC7B,OAAO,CAAC,uBAAuB;CAchC"}

View File

@@ -19,10 +19,12 @@ class NodeRepository {
is_webhook, is_versioned, is_tool_variant, tool_variant_of, is_webhook, is_versioned, is_tool_variant, tool_variant_of,
has_tool_variant, version, documentation, has_tool_variant, version, documentation,
properties_schema, operations, credentials_required, properties_schema, operations, credentials_required,
outputs, output_names outputs, output_names,
) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?) is_community, is_verified, author_name, author_github_url,
npm_package_name, npm_version, npm_downloads, community_fetched_at
) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)
`); `);
stmt.run(node.nodeType, node.packageName, node.displayName, node.description, node.category, node.style, node.isAITool ? 1 : 0, node.isTrigger ? 1 : 0, node.isWebhook ? 1 : 0, node.isVersioned ? 1 : 0, node.isToolVariant ? 1 : 0, node.toolVariantOf || null, node.hasToolVariant ? 1 : 0, node.version, node.documentation || null, JSON.stringify(node.properties, null, 2), JSON.stringify(node.operations, null, 2), JSON.stringify(node.credentials, null, 2), node.outputs ? JSON.stringify(node.outputs, null, 2) : null, node.outputNames ? JSON.stringify(node.outputNames, null, 2) : null); stmt.run(node.nodeType, node.packageName, node.displayName, node.description, node.category, node.style, node.isAITool ? 1 : 0, node.isTrigger ? 1 : 0, node.isWebhook ? 1 : 0, node.isVersioned ? 1 : 0, node.isToolVariant ? 1 : 0, node.toolVariantOf || null, node.hasToolVariant ? 1 : 0, node.version, node.documentation || null, JSON.stringify(node.properties, null, 2), JSON.stringify(node.operations, null, 2), JSON.stringify(node.credentials, null, 2), node.outputs ? JSON.stringify(node.outputs, null, 2) : null, node.outputNames ? JSON.stringify(node.outputNames, null, 2) : null, node.isCommunity ? 1 : 0, node.isVerified ? 1 : 0, node.authorName || null, node.authorGithubUrl || null, node.npmPackageName || null, node.npmVersion || null, node.npmDownloads || 0, node.communityFetchedAt || null);
} }
getNode(nodeType) { getNode(nodeType) {
const normalizedType = node_type_normalizer_1.NodeTypeNormalizer.normalizeToFullForm(nodeType); const normalizedType = node_type_normalizer_1.NodeTypeNormalizer.normalizeToFullForm(nodeType);
@@ -37,6 +39,14 @@ class NodeRepository {
return this.parseNodeRow(originalRow); return this.parseNodeRow(originalRow);
} }
} }
if (!row) {
const caseInsensitiveRow = this.db.prepare(`
SELECT * FROM nodes WHERE LOWER(node_type) = LOWER(?)
`).get(nodeType);
if (caseInsensitiveRow) {
return this.parseNodeRow(caseInsensitiveRow);
}
}
if (!row) if (!row)
return null; return null;
return this.parseNodeRow(row); return this.parseNodeRow(row);
@@ -214,7 +224,20 @@ class NodeRepository {
credentials: this.safeJsonParse(row.credentials_required, []), credentials: this.safeJsonParse(row.credentials_required, []),
hasDocumentation: !!row.documentation, hasDocumentation: !!row.documentation,
outputs: row.outputs ? this.safeJsonParse(row.outputs, null) : null, outputs: row.outputs ? this.safeJsonParse(row.outputs, null) : null,
outputNames: row.output_names ? this.safeJsonParse(row.output_names, null) : null outputNames: row.output_names ? this.safeJsonParse(row.output_names, null) : null,
isCommunity: Number(row.is_community) === 1,
isVerified: Number(row.is_verified) === 1,
authorName: row.author_name || null,
authorGithubUrl: row.author_github_url || null,
npmPackageName: row.npm_package_name || null,
npmVersion: row.npm_version || null,
npmDownloads: row.npm_downloads || 0,
communityFetchedAt: row.community_fetched_at || null,
npmReadme: row.npm_readme || null,
aiDocumentationSummary: row.ai_documentation_summary
? this.safeJsonParse(row.ai_documentation_summary, null)
: null,
aiSummaryGeneratedAt: row.ai_summary_generated_at || null,
}; };
} }
getNodeOperations(nodeType, resource) { getNodeOperations(nodeType, resource) {
@@ -360,6 +383,98 @@ class NodeRepository {
} }
return undefined; return undefined;
} }
getCommunityNodes(options) {
let sql = 'SELECT * FROM nodes WHERE is_community = 1';
const params = [];
if (options?.verified !== undefined) {
sql += ' AND is_verified = ?';
params.push(options.verified ? 1 : 0);
}
switch (options?.orderBy) {
case 'downloads':
sql += ' ORDER BY npm_downloads DESC';
break;
case 'updated':
sql += ' ORDER BY community_fetched_at DESC';
break;
case 'name':
default:
sql += ' ORDER BY display_name';
}
if (options?.limit) {
sql += ' LIMIT ?';
params.push(options.limit);
}
const rows = this.db.prepare(sql).all(...params);
return rows.map(row => this.parseNodeRow(row));
}
getCommunityStats() {
const totalResult = this.db.prepare('SELECT COUNT(*) as count FROM nodes WHERE is_community = 1').get();
const verifiedResult = this.db.prepare('SELECT COUNT(*) as count FROM nodes WHERE is_community = 1 AND is_verified = 1').get();
return {
total: totalResult.count,
verified: verifiedResult.count,
unverified: totalResult.count - verifiedResult.count
};
}
hasNodeByNpmPackage(npmPackageName) {
const result = this.db.prepare('SELECT 1 FROM nodes WHERE npm_package_name = ? LIMIT 1').get(npmPackageName);
return !!result;
}
getNodeByNpmPackage(npmPackageName) {
const row = this.db.prepare('SELECT * FROM nodes WHERE npm_package_name = ?').get(npmPackageName);
if (!row)
return null;
return this.parseNodeRow(row);
}
deleteCommunityNodes() {
const result = this.db.prepare('DELETE FROM nodes WHERE is_community = 1').run();
return result.changes;
}
updateNodeReadme(nodeType, readme) {
const stmt = this.db.prepare(`
UPDATE nodes SET npm_readme = ? WHERE node_type = ?
`);
stmt.run(readme, nodeType);
}
updateNodeAISummary(nodeType, summary) {
const stmt = this.db.prepare(`
UPDATE nodes
SET ai_documentation_summary = ?, ai_summary_generated_at = datetime('now')
WHERE node_type = ?
`);
stmt.run(JSON.stringify(summary), nodeType);
}
getCommunityNodesWithoutReadme() {
const rows = this.db.prepare(`
SELECT * FROM nodes
WHERE is_community = 1 AND (npm_readme IS NULL OR npm_readme = '')
ORDER BY npm_downloads DESC
`).all();
return rows.map(row => this.parseNodeRow(row));
}
getCommunityNodesWithoutAISummary() {
const rows = this.db.prepare(`
SELECT * FROM nodes
WHERE is_community = 1
AND npm_readme IS NOT NULL AND npm_readme != ''
AND (ai_documentation_summary IS NULL OR ai_documentation_summary = '')
ORDER BY npm_downloads DESC
`).all();
return rows.map(row => this.parseNodeRow(row));
}
getDocumentationStats() {
const total = this.db.prepare('SELECT COUNT(*) as count FROM nodes WHERE is_community = 1').get().count;
const withReadme = this.db.prepare("SELECT COUNT(*) as count FROM nodes WHERE is_community = 1 AND npm_readme IS NOT NULL AND npm_readme != ''").get().count;
const withAISummary = this.db.prepare("SELECT COUNT(*) as count FROM nodes WHERE is_community = 1 AND ai_documentation_summary IS NOT NULL AND ai_documentation_summary != ''").get().count;
return {
total,
withReadme,
withAISummary,
needingReadme: total - withReadme,
needingAISummary: withReadme - withAISummary
};
}
saveNodeVersion(versionData) { saveNodeVersion(versionData) {
const stmt = this.db.prepare(` const stmt = this.db.prepare(`
INSERT OR REPLACE INTO node_versions ( INSERT OR REPLACE INTO node_versions (

File diff suppressed because one or more lines are too long

View File

@@ -1 +1 @@
{"version":3,"file":"http-server.d.ts","sourceRoot":"","sources":["../src/http-server.ts"],"names":[],"mappings":";AA0CA,wBAAgB,aAAa,IAAI,MAAM,GAAG,IAAI,CAsB7C;AA+DD,wBAAsB,oBAAoB,kBA+dzC;AAGD,OAAO,QAAQ,cAAc,CAAC;IAC5B,UAAU,yBAAyB;QACjC,WAAW,CAAC,IAAI,EAAE,MAAM,EAAE,IAAI,EAAE,GAAG,GAAG,OAAO,CAAC,GAAG,CAAC,CAAC;KACpD;CACF"} {"version":3,"file":"http-server.d.ts","sourceRoot":"","sources":["../src/http-server.ts"],"names":[],"mappings":";AAiDA,wBAAgB,aAAa,IAAI,MAAM,GAAG,IAAI,CAsB7C;AAmED,wBAAsB,oBAAoB,kBAsezC;AAGD,OAAO,QAAQ,cAAc,CAAC;IAC5B,UAAU,yBAAyB;QACjC,WAAW,CAAC,IAAI,EAAE,MAAM,EAAE,IAAI,EAAE,GAAG,GAAG,OAAO,CAAC,GAAG,CAAC,CAAC;KACpD;CACF"}

3
dist/http-server.js vendored
View File

@@ -85,6 +85,9 @@ async function shutdown() {
} }
} }
async function startFixedHTTPServer() { async function startFixedHTTPServer() {
logger_1.logger.warn('DEPRECATION: startFixedHTTPServer() is deprecated as of v2.31.8. ' +
'Use SingleSessionHTTPServer which supports SSE streaming. ' +
'See: https://github.com/czlonkowski/n8n-mcp/issues/524');
validateEnvironment(); validateEnvironment();
const app = (0, express_1.default)(); const app = (0, express_1.default)();
const trustProxy = process.env.TRUST_PROXY ? Number(process.env.TRUST_PROXY) : 0; const trustProxy = process.env.TRUST_PROXY ? Number(process.env.TRUST_PROXY) : 0;

File diff suppressed because one or more lines are too long

9
dist/mcp/index.js vendored
View File

@@ -124,6 +124,15 @@ Learn more: https://github.com/czlonkowski/n8n-mcp/blob/main/PRIVACY.md
checkpoints.push(startup_checkpoints_1.STARTUP_CHECKPOINTS.MCP_HANDSHAKE_STARTING); checkpoints.push(startup_checkpoints_1.STARTUP_CHECKPOINTS.MCP_HANDSHAKE_STARTING);
if (mode === 'http') { if (mode === 'http') {
if (process.env.USE_FIXED_HTTP === 'true') { if (process.env.USE_FIXED_HTTP === 'true') {
logger_1.logger.warn('DEPRECATION WARNING: USE_FIXED_HTTP=true is deprecated as of v2.31.8. ' +
'The fixed HTTP implementation does not support SSE streaming required by clients like OpenAI Codex. ' +
'Please unset USE_FIXED_HTTP to use the modern SingleSessionHTTPServer which supports both JSON-RPC and SSE. ' +
'This option will be removed in a future version. See: https://github.com/czlonkowski/n8n-mcp/issues/524');
console.warn('\n⚠ DEPRECATION WARNING ⚠️');
console.warn('USE_FIXED_HTTP=true is deprecated as of v2.31.8.');
console.warn('The fixed HTTP implementation does not support SSE streaming.');
console.warn('Please unset USE_FIXED_HTTP to use SingleSessionHTTPServer.');
console.warn('See: https://github.com/czlonkowski/n8n-mcp/issues/524\n');
const { startFixedHTTPServer } = await Promise.resolve().then(() => __importStar(require('../http-server'))); const { startFixedHTTPServer } = await Promise.resolve().then(() => __importStar(require('../http-server')));
await startFixedHTTPServer(); await startFixedHTTPServer();
} }

File diff suppressed because one or more lines are too long

View File

@@ -40,6 +40,7 @@ export declare class N8NDocumentationMCPServer {
private rankSearchResults; private rankSearchResults;
private listAITools; private listAITools;
private getNodeDocumentation; private getNodeDocumentation;
private safeJsonParse;
private getDatabaseStatistics; private getDatabaseStatistics;
private getNodeEssentials; private getNodeEssentials;
private getNode; private getNode;

View File

@@ -1 +1 @@
{"version":3,"file":"server.d.ts","sourceRoot":"","sources":["../../src/mcp/server.ts"],"names":[],"mappings":"AAsCA,OAAO,EAAE,eAAe,EAAE,MAAM,2BAA2B,CAAC;AAE5D,OAAO,EAAE,gBAAgB,EAAE,MAAM,iCAAiC,CAAC;AAgGnE,qBAAa,yBAAyB;IACpC,OAAO,CAAC,MAAM,CAAS;IACvB,OAAO,CAAC,EAAE,CAAgC;IAC1C,OAAO,CAAC,UAAU,CAA+B;IACjD,OAAO,CAAC,eAAe,CAAgC;IACvD,OAAO,CAAC,WAAW,CAAgB;IACnC,OAAO,CAAC,KAAK,CAAqB;IAClC,OAAO,CAAC,UAAU,CAAa;IAC/B,OAAO,CAAC,eAAe,CAAC,CAAkB;IAC1C,OAAO,CAAC,YAAY,CAAuB;IAC3C,OAAO,CAAC,qBAAqB,CAAsB;IACnD,OAAO,CAAC,WAAW,CAAiC;IACpD,OAAO,CAAC,kBAAkB,CAA4B;gBAE1C,eAAe,CAAC,EAAE,eAAe,EAAE,WAAW,CAAC,EAAE,gBAAgB;IAiGvE,KAAK,IAAI,OAAO,CAAC,IAAI,CAAC;YA6Bd,kBAAkB;YAwClB,wBAAwB;IA0BtC,OAAO,CAAC,kBAAkB;YA6CZ,iBAAiB;IAa/B,OAAO,CAAC,eAAe,CAAkB;YAE3B,sBAAsB;IAgDpC,OAAO,CAAC,gBAAgB;IAqCxB,OAAO,CAAC,aAAa;IAoTrB,OAAO,CAAC,wBAAwB;IAoFhC,OAAO,CAAC,kBAAkB;IAqE1B,OAAO,CAAC,uBAAuB;IAwB/B,OAAO,CAAC,qBAAqB;YAgTf,SAAS;YA2DT,WAAW;YAkFX,WAAW;YAyCX,cAAc;YAyKd,gBAAgB;IAqD9B,OAAO,CAAC,mBAAmB;IAwE3B,OAAO,CAAC,eAAe;YAsBT,eAAe;IAqI7B,OAAO,CAAC,kBAAkB;IAQ1B,OAAO,CAAC,uBAAuB;IA0D/B,OAAO,CAAC,iBAAiB;YAqFX,WAAW;YAgCX,oBAAoB;YA2EpB,qBAAqB;YAwDrB,iBAAiB;YAiKjB,OAAO;YAgDP,cAAc;YAwFd,iBAAiB;IAqC/B,OAAO,CAAC,iBAAiB;IA0BzB,OAAO,CAAC,iBAAiB;IA0BzB,OAAO,CAAC,eAAe;IAwCvB,OAAO,CAAC,kBAAkB;IAiC1B,OAAO,CAAC,aAAa;IAoCrB,OAAO,CAAC,0BAA0B;IAgClC,OAAO,CAAC,4BAA4B;YAKtB,oBAAoB;IAsDlC,OAAO,CAAC,gBAAgB;YAiBV,SAAS;YA6CT,kBAAkB;YAqElB,uBAAuB;YAsDvB,iBAAiB;IAqE/B,OAAO,CAAC,qBAAqB;IA8C7B,OAAO,CAAC,uBAAuB;IA4D/B,OAAO,CAAC,wBAAwB;IAkChC,OAAO,CAAC,iBAAiB;YAoDX,mBAAmB;YAoEnB,qBAAqB;IAS7B,OAAO,CAAC,SAAS,EAAE,GAAG,GAAG,OAAO,CAAC,IAAI,CAAC;YAS9B,aAAa;YAcb,iBAAiB;YAoBjB,WAAW;YAwBX,eAAe;YAqBf,mBAAmB;YAwBnB,yBAAyB;IA4CvC,OAAO,CAAC,kBAAkB;YAiBZ,gBAAgB;YA6HhB,2BAA2B;YAiE3B,2BAA2B;IAyEnC,GAAG,IAAI,OAAO,CAAC,IAAI,CAAC;IA0BpB,QAAQ,IAAI,OAAO,CAAC,IAAI,CAAC;CAuBhC"} {"version":3,"file":"server.d.ts","sourceRoot":"","sources":["../../src/mcp/server.ts"],"names":[],"mappings":"AAsCA,OAAO,EAAE,eAAe,EAAE,MAAM,2BAA2B,CAAC;AAE5D,OAAO,EAAE,gBAAgB,EAAE,MAAM,iCAAiC,CAAC;AAmGnE,qBAAa,yBAAyB;IACpC,OAAO,CAAC,MAAM,CAAS;IACvB,OAAO,CAAC,EAAE,CAAgC;IAC1C,OAAO,CAAC,UAAU,CAA+B;IACjD,OAAO,CAAC,eAAe,CAAgC;IACvD,OAAO,CAAC,WAAW,CAAgB;IACnC,OAAO,CAAC,KAAK,CAAqB;IAClC,OAAO,CAAC,UAAU,CAAa;IAC/B,OAAO,CAAC,eAAe,CAAC,CAAkB;IAC1C,OAAO,CAAC,YAAY,CAAuB;IAC3C,OAAO,CAAC,qBAAqB,CAAsB;IACnD,OAAO,CAAC,WAAW,CAAiC;IACpD,OAAO,CAAC,kBAAkB,CAA4B;gBAE1C,eAAe,CAAC,EAAE,eAAe,EAAE,WAAW,CAAC,EAAE,gBAAgB;IAiGvE,KAAK,IAAI,OAAO,CAAC,IAAI,CAAC;YA6Bd,kBAAkB;YAwClB,wBAAwB;IA0BtC,OAAO,CAAC,kBAAkB;YA6CZ,iBAAiB;IAa/B,OAAO,CAAC,eAAe,CAAkB;YAE3B,sBAAsB;IAgDpC,OAAO,CAAC,gBAAgB;IAqCxB,OAAO,CAAC,aAAa;IAoTrB,OAAO,CAAC,wBAAwB;IAoFhC,OAAO,CAAC,kBAAkB;IAqE1B,OAAO,CAAC,uBAAuB;IAwB/B,OAAO,CAAC,qBAAqB;YAoTf,SAAS;YA2DT,WAAW;YAkFX,WAAW;YA0CX,cAAc;YA8Md,gBAAgB;IAqD9B,OAAO,CAAC,mBAAmB;IAwE3B,OAAO,CAAC,eAAe;YAsBT,eAAe;IA2L7B,OAAO,CAAC,kBAAkB;IAQ1B,OAAO,CAAC,uBAAuB;IA0D/B,OAAO,CAAC,iBAAiB;YAqFX,WAAW;YAgCX,oBAAoB;IAuFlC,OAAO,CAAC,aAAa;YAQP,qBAAqB;YAwDrB,iBAAiB;YAiKjB,OAAO;YAgDP,cAAc;YAwFd,iBAAiB;IAqC/B,OAAO,CAAC,iBAAiB;IA0BzB,OAAO,CAAC,iBAAiB;IA0BzB,OAAO,CAAC,eAAe;IAwCvB,OAAO,CAAC,kBAAkB;IAiC1B,OAAO,CAAC,aAAa;IAoCrB,OAAO,CAAC,0BAA0B;IAgClC,OAAO,CAAC,4BAA4B;YAKtB,oBAAoB;IAsDlC,OAAO,CAAC,gBAAgB;YAiBV,SAAS;YA6CT,kBAAkB;YAqElB,uBAAuB;YAsDvB,iBAAiB;IAqE/B,OAAO,CAAC,qBAAqB;IA8C7B,OAAO,CAAC,uBAAuB;IA4D/B,OAAO,CAAC,wBAAwB;IAkChC,OAAO,CAAC,iBAAiB;YAoDX,mBAAmB;YAoEnB,qBAAqB;IAS7B,OAAO,CAAC,SAAS,EAAE,GAAG,GAAG,OAAO,CAAC,IAAI,CAAC;YAS9B,aAAa;YAcb,iBAAiB;YAoBjB,WAAW;YAwBX,eAAe;YAqBf,mBAAmB;YAwBnB,yBAAyB;IA4CvC,OAAO,CAAC,kBAAkB;YAiBZ,gBAAgB;YA6HhB,2BAA2B;YAiE3B,2BAA2B;IAyEnC,GAAG,IAAI,OAAO,CAAC,IAAI,CAAC;IA0BpB,QAAQ,IAAI,OAAO,CAAC,IAAI,CAAC;CAuBhC"}

162
dist/mcp/server.js vendored
View File

@@ -750,7 +750,11 @@ class N8NDocumentationMCPServer {
case 'search_nodes': case 'search_nodes':
this.validateToolParams(name, args, ['query']); this.validateToolParams(name, args, ['query']);
const limit = args.limit !== undefined ? Number(args.limit) || 20 : 20; const limit = args.limit !== undefined ? Number(args.limit) || 20 : 20;
return this.searchNodes(args.query, limit, { mode: args.mode, includeExamples: args.includeExamples }); return this.searchNodes(args.query, limit, {
mode: args.mode,
includeExamples: args.includeExamples,
source: args.source
});
case 'get_node': case 'get_node':
this.validateToolParams(name, args, ['nodeType']); this.validateToolParams(name, args, ['nodeType']);
if (args.mode === 'docs') { if (args.mode === 'docs') {
@@ -1089,6 +1093,19 @@ class N8NDocumentationMCPServer {
} }
} }
try { try {
let sourceFilter = '';
const sourceValue = options?.source || 'all';
switch (sourceValue) {
case 'core':
sourceFilter = 'AND n.is_community = 0';
break;
case 'community':
sourceFilter = 'AND n.is_community = 1';
break;
case 'verified':
sourceFilter = 'AND n.is_community = 1 AND n.is_verified = 1';
break;
}
const nodes = this.db.prepare(` const nodes = this.db.prepare(`
SELECT SELECT
n.*, n.*,
@@ -1096,6 +1113,7 @@ class N8NDocumentationMCPServer {
FROM nodes n FROM nodes n
JOIN nodes_fts ON n.rowid = nodes_fts.rowid JOIN nodes_fts ON n.rowid = nodes_fts.rowid
WHERE nodes_fts MATCH ? WHERE nodes_fts MATCH ?
${sourceFilter}
ORDER BY ORDER BY
CASE CASE
WHEN LOWER(n.display_name) = LOWER(?) THEN 0 WHEN LOWER(n.display_name) = LOWER(?) THEN 0
@@ -1128,15 +1146,28 @@ class N8NDocumentationMCPServer {
} }
const result = { const result = {
query, query,
results: scoredNodes.map(node => ({ results: scoredNodes.map(node => {
nodeType: node.node_type, const nodeResult = {
workflowNodeType: (0, node_utils_1.getWorkflowNodeType)(node.package_name, node.node_type), nodeType: node.node_type,
displayName: node.display_name, workflowNodeType: (0, node_utils_1.getWorkflowNodeType)(node.package_name, node.node_type),
description: node.description, displayName: node.display_name,
category: node.category, description: node.description,
package: node.package_name, category: node.category,
relevance: this.calculateRelevance(node, cleanedQuery) package: node.package_name,
})), relevance: this.calculateRelevance(node, cleanedQuery)
};
if (node.is_community === 1) {
nodeResult.isCommunity = true;
nodeResult.isVerified = node.is_verified === 1;
if (node.author_name) {
nodeResult.authorName = node.author_name;
}
if (node.npm_downloads) {
nodeResult.npmDownloads = node.npm_downloads;
}
}
return nodeResult;
}),
totalCount: scoredNodes.length totalCount: scoredNodes.length
}; };
if (mode !== 'OR') { if (mode !== 'OR') {
@@ -1298,24 +1329,51 @@ class N8NDocumentationMCPServer {
async searchNodesLIKE(query, limit, options) { async searchNodesLIKE(query, limit, options) {
if (!this.db) if (!this.db)
throw new Error('Database not initialized'); throw new Error('Database not initialized');
let sourceFilter = '';
const sourceValue = options?.source || 'all';
switch (sourceValue) {
case 'core':
sourceFilter = 'AND is_community = 0';
break;
case 'community':
sourceFilter = 'AND is_community = 1';
break;
case 'verified':
sourceFilter = 'AND is_community = 1 AND is_verified = 1';
break;
}
if (query.startsWith('"') && query.endsWith('"')) { if (query.startsWith('"') && query.endsWith('"')) {
const exactPhrase = query.slice(1, -1); const exactPhrase = query.slice(1, -1);
const nodes = this.db.prepare(` const nodes = this.db.prepare(`
SELECT * FROM nodes SELECT * FROM nodes
WHERE node_type LIKE ? OR display_name LIKE ? OR description LIKE ? WHERE (node_type LIKE ? OR display_name LIKE ? OR description LIKE ?)
${sourceFilter}
LIMIT ? LIMIT ?
`).all(`%${exactPhrase}%`, `%${exactPhrase}%`, `%${exactPhrase}%`, limit * 3); `).all(`%${exactPhrase}%`, `%${exactPhrase}%`, `%${exactPhrase}%`, limit * 3);
const rankedNodes = this.rankSearchResults(nodes, exactPhrase, limit); const rankedNodes = this.rankSearchResults(nodes, exactPhrase, limit);
const result = { const result = {
query, query,
results: rankedNodes.map(node => ({ results: rankedNodes.map(node => {
nodeType: node.node_type, const nodeResult = {
workflowNodeType: (0, node_utils_1.getWorkflowNodeType)(node.package_name, node.node_type), nodeType: node.node_type,
displayName: node.display_name, workflowNodeType: (0, node_utils_1.getWorkflowNodeType)(node.package_name, node.node_type),
description: node.description, displayName: node.display_name,
category: node.category, description: node.description,
package: node.package_name category: node.category,
})), package: node.package_name
};
if (node.is_community === 1) {
nodeResult.isCommunity = true;
nodeResult.isVerified = node.is_verified === 1;
if (node.author_name) {
nodeResult.authorName = node.author_name;
}
if (node.npm_downloads) {
nodeResult.npmDownloads = node.npm_downloads;
}
}
return nodeResult;
}),
totalCount: rankedNodes.length totalCount: rankedNodes.length
}; };
if (options?.includeExamples) { if (options?.includeExamples) {
@@ -1354,21 +1412,35 @@ class N8NDocumentationMCPServer {
const params = words.flatMap(w => [`%${w}%`, `%${w}%`, `%${w}%`]); const params = words.flatMap(w => [`%${w}%`, `%${w}%`, `%${w}%`]);
params.push(limit * 3); params.push(limit * 3);
const nodes = this.db.prepare(` const nodes = this.db.prepare(`
SELECT DISTINCT * FROM nodes SELECT DISTINCT * FROM nodes
WHERE ${conditions} WHERE (${conditions})
${sourceFilter}
LIMIT ? LIMIT ?
`).all(...params); `).all(...params);
const rankedNodes = this.rankSearchResults(nodes, query, limit); const rankedNodes = this.rankSearchResults(nodes, query, limit);
const result = { const result = {
query, query,
results: rankedNodes.map(node => ({ results: rankedNodes.map(node => {
nodeType: node.node_type, const nodeResult = {
workflowNodeType: (0, node_utils_1.getWorkflowNodeType)(node.package_name, node.node_type), nodeType: node.node_type,
displayName: node.display_name, workflowNodeType: (0, node_utils_1.getWorkflowNodeType)(node.package_name, node.node_type),
description: node.description, displayName: node.display_name,
category: node.category, description: node.description,
package: node.package_name category: node.category,
})), package: node.package_name
};
if (node.is_community === 1) {
nodeResult.isCommunity = true;
nodeResult.isVerified = node.is_verified === 1;
if (node.author_name) {
nodeResult.authorName = node.author_name;
}
if (node.npm_downloads) {
nodeResult.npmDownloads = node.npm_downloads;
}
}
return nodeResult;
}),
totalCount: rankedNodes.length totalCount: rankedNodes.length
}; };
if (options?.includeExamples) { if (options?.includeExamples) {
@@ -1545,14 +1617,16 @@ class N8NDocumentationMCPServer {
throw new Error('Database not initialized'); throw new Error('Database not initialized');
const normalizedType = node_type_normalizer_1.NodeTypeNormalizer.normalizeToFullForm(nodeType); const normalizedType = node_type_normalizer_1.NodeTypeNormalizer.normalizeToFullForm(nodeType);
let node = this.db.prepare(` let node = this.db.prepare(`
SELECT node_type, display_name, documentation, description SELECT node_type, display_name, documentation, description,
FROM nodes ai_documentation_summary, ai_summary_generated_at
FROM nodes
WHERE node_type = ? WHERE node_type = ?
`).get(normalizedType); `).get(normalizedType);
if (!node && normalizedType !== nodeType) { if (!node && normalizedType !== nodeType) {
node = this.db.prepare(` node = this.db.prepare(`
SELECT node_type, display_name, documentation, description SELECT node_type, display_name, documentation, description,
FROM nodes ai_documentation_summary, ai_summary_generated_at
FROM nodes
WHERE node_type = ? WHERE node_type = ?
`).get(nodeType); `).get(nodeType);
} }
@@ -1560,8 +1634,9 @@ class N8NDocumentationMCPServer {
const alternatives = (0, node_utils_1.getNodeTypeAlternatives)(normalizedType); const alternatives = (0, node_utils_1.getNodeTypeAlternatives)(normalizedType);
for (const alt of alternatives) { for (const alt of alternatives) {
node = this.db.prepare(` node = this.db.prepare(`
SELECT node_type, display_name, documentation, description SELECT node_type, display_name, documentation, description,
FROM nodes ai_documentation_summary, ai_summary_generated_at
FROM nodes
WHERE node_type = ? WHERE node_type = ?
`).get(alt); `).get(alt);
if (node) if (node)
@@ -1571,6 +1646,9 @@ class N8NDocumentationMCPServer {
if (!node) { if (!node) {
throw new Error(`Node ${nodeType} not found`); throw new Error(`Node ${nodeType} not found`);
} }
const aiDocSummary = node.ai_documentation_summary
? this.safeJsonParse(node.ai_documentation_summary, null)
: null;
if (!node.documentation) { if (!node.documentation) {
const essentials = await this.getNodeEssentials(nodeType); const essentials = await this.getNodeEssentials(nodeType);
return { return {
@@ -1590,7 +1668,9 @@ ${essentials?.commonProperties?.length > 0 ?
## Note ## Note
Full documentation is being prepared. For now, use get_node_essentials for configuration help. Full documentation is being prepared. For now, use get_node_essentials for configuration help.
`, `,
hasDocumentation: false hasDocumentation: false,
aiDocumentationSummary: aiDocSummary,
aiSummaryGeneratedAt: node.ai_summary_generated_at || null,
}; };
} }
return { return {
@@ -1598,8 +1678,18 @@ Full documentation is being prepared. For now, use get_node_essentials for confi
displayName: node.display_name || 'Unknown Node', displayName: node.display_name || 'Unknown Node',
documentation: node.documentation, documentation: node.documentation,
hasDocumentation: true, hasDocumentation: true,
aiDocumentationSummary: aiDocSummary,
aiSummaryGeneratedAt: node.ai_summary_generated_at || null,
}; };
} }
safeJsonParse(json, defaultValue = null) {
try {
return JSON.parse(json);
}
catch {
return defaultValue;
}
}
async getDatabaseStatistics() { async getDatabaseStatistics() {
await this.ensureInitialized(); await this.ensureInitialized();
if (!this.db) if (!this.db)

File diff suppressed because one or more lines are too long

View File

@@ -1 +1 @@
{"version":3,"file":"search-nodes.d.ts","sourceRoot":"","sources":["../../../../src/mcp/tool-docs/discovery/search-nodes.ts"],"names":[],"mappings":"AAAA,OAAO,EAAE,iBAAiB,EAAE,MAAM,UAAU,CAAC;AAE7C,eAAO,MAAM,cAAc,EAAE,iBAmD5B,CAAC"} {"version":3,"file":"search-nodes.d.ts","sourceRoot":"","sources":["../../../../src/mcp/tool-docs/discovery/search-nodes.ts"],"names":[],"mappings":"AAAA,OAAO,EAAE,iBAAiB,EAAE,MAAM,UAAU,CAAC;AAE7C,eAAO,MAAM,cAAc,EAAE,iBAiE5B,CAAC"}

View File

@@ -5,50 +5,64 @@ exports.searchNodesDoc = {
name: 'search_nodes', name: 'search_nodes',
category: 'discovery', category: 'discovery',
essentials: { essentials: {
description: 'Text search across node names and descriptions. Returns most relevant nodes first, with frequently-used nodes (HTTP Request, Webhook, Set, Code, Slack) prioritized in results. Searches all 500+ nodes in the database.', description: 'Text search across node names and descriptions. Returns most relevant nodes first, with frequently-used nodes (HTTP Request, Webhook, Set, Code, Slack) prioritized in results. Searches all 800+ nodes including 300+ verified community nodes.',
keyParameters: ['query', 'mode', 'limit'], keyParameters: ['query', 'mode', 'limit', 'source', 'includeExamples'],
example: 'search_nodes({query: "webhook"})', example: 'search_nodes({query: "webhook"})',
performance: '<20ms even for complex queries', performance: '<20ms even for complex queries',
tips: [ tips: [
'OR mode (default): Matches any search word', 'OR mode (default): Matches any search word',
'AND mode: Requires all words present', 'AND mode: Requires all words present',
'FUZZY mode: Handles typos and spelling errors', 'FUZZY mode: Handles typos and spelling errors',
'Use quotes for exact phrases: "google sheets"' 'Use quotes for exact phrases: "google sheets"',
'Use source="community" to search only community nodes',
'Use source="verified" for verified community nodes only'
] ]
}, },
full: { full: {
description: 'Full-text search engine for n8n nodes using SQLite FTS5. Searches across node names, descriptions, and aliases. Results are ranked by relevance with commonly-used nodes given priority. Common nodes include: HTTP Request, Webhook, Set, Code, IF, Switch, Merge, SplitInBatches, Slack, Google Sheets.', description: 'Full-text search engine for n8n nodes using SQLite FTS5. Searches across node names, descriptions, and aliases. Results are ranked by relevance with commonly-used nodes given priority. Includes 500+ core nodes and 300+ community nodes. Common core nodes include: HTTP Request, Webhook, Set, Code, IF, Switch, Merge, SplitInBatches, Slack, Google Sheets. Community nodes include verified integrations like BrightData, ScrapingBee, CraftMyPDF, and more.',
parameters: { parameters: {
query: { type: 'string', description: 'Search keywords. Use quotes for exact phrases like "google sheets"', required: true }, query: { type: 'string', description: 'Search keywords. Use quotes for exact phrases like "google sheets"', required: true },
limit: { type: 'number', description: 'Maximum results to return. Default: 20, Max: 100', required: false }, limit: { type: 'number', description: 'Maximum results to return. Default: 20, Max: 100', required: false },
mode: { type: 'string', description: 'Search mode: "OR" (any word matches, default), "AND" (all words required), "FUZZY" (typo-tolerant)', required: false } mode: { type: 'string', description: 'Search mode: "OR" (any word matches, default), "AND" (all words required), "FUZZY" (typo-tolerant)', required: false },
source: { type: 'string', description: 'Filter by node source: "all" (default, everything), "core" (n8n base nodes only), "community" (community nodes only), "verified" (verified community nodes only)', required: false },
includeExamples: { type: 'boolean', description: 'Include top 2 real-world configuration examples from popular templates for each node. Default: false. Adds ~200-400 tokens per node.', required: false }
}, },
returns: 'Array of node objects sorted by relevance score. Each object contains: nodeType, displayName, description, category, relevance score. Common nodes appear first when relevance is similar.', returns: 'Array of node objects sorted by relevance score. Each object contains: nodeType, displayName, description, category, relevance score. For community nodes, also includes: isCommunity (boolean), isVerified (boolean), authorName (string), npmDownloads (number). Common nodes appear first when relevance is similar.',
examples: [ examples: [
'search_nodes({query: "webhook"}) - Returns Webhook node as top result', 'search_nodes({query: "webhook"}) - Returns Webhook node as top result',
'search_nodes({query: "database"}) - Returns MySQL, Postgres, MongoDB, Redis, etc.', 'search_nodes({query: "database"}) - Returns MySQL, Postgres, MongoDB, Redis, etc.',
'search_nodes({query: "google sheets", mode: "AND"}) - Requires both words', 'search_nodes({query: "google sheets", mode: "AND"}) - Requires both words',
'search_nodes({query: "slak", mode: "FUZZY"}) - Finds Slack despite typo', 'search_nodes({query: "slak", mode: "FUZZY"}) - Finds Slack despite typo',
'search_nodes({query: "http api"}) - Finds HTTP Request, GraphQL, REST nodes', 'search_nodes({query: "http api"}) - Finds HTTP Request, GraphQL, REST nodes',
'search_nodes({query: "transform data"}) - Finds Set, Code, Function, Item Lists nodes' 'search_nodes({query: "transform data"}) - Finds Set, Code, Function, Item Lists nodes',
'search_nodes({query: "scraping", source: "community"}) - Find community scraping nodes',
'search_nodes({query: "pdf", source: "verified"}) - Find verified community PDF nodes',
'search_nodes({query: "brightdata"}) - Find BrightData community node',
'search_nodes({query: "slack", includeExamples: true}) - Get Slack with template examples'
], ],
useCases: [ useCases: [
'Finding nodes when you know partial names', 'Finding nodes when you know partial names',
'Discovering nodes by functionality (e.g., "email", "database", "transform")', 'Discovering nodes by functionality (e.g., "email", "database", "transform")',
'Handling user typos in node names', 'Handling user typos in node names',
'Finding all nodes related to a service (e.g., "google", "aws", "microsoft")' 'Finding all nodes related to a service (e.g., "google", "aws", "microsoft")',
'Discovering community integrations for specific services',
'Finding verified community nodes for enhanced trust'
], ],
performance: '<20ms for simple queries, <50ms for complex FUZZY searches. Uses FTS5 index for speed', performance: '<20ms for simple queries, <50ms for complex FUZZY searches. Uses FTS5 index for speed',
bestPractices: [ bestPractices: [
'Start with single keywords for broadest results', 'Start with single keywords for broadest results',
'Use FUZZY mode when users might misspell node names', 'Use FUZZY mode when users might misspell node names',
'AND mode works best for 2-3 word searches', 'AND mode works best for 2-3 word searches',
'Combine with get_node after finding the right node' 'Combine with get_node after finding the right node',
'Use source="verified" when recommending community nodes for production',
'Check isVerified flag to ensure community node quality'
], ],
pitfalls: [ pitfalls: [
'AND mode searches all fields (name, description) not just node names', 'AND mode searches all fields (name, description) not just node names',
'FUZZY mode with very short queries (1-2 chars) may return unexpected results', 'FUZZY mode with very short queries (1-2 chars) may return unexpected results',
'Exact matches in quotes are case-sensitive' 'Exact matches in quotes are case-sensitive',
'Community nodes require npm installation (n8n npm install <package-name>)',
'Unverified community nodes (isVerified: false) may have limited support'
], ],
relatedTools: ['get_node to configure found nodes', 'search_templates to find workflow examples', 'validate_node to check configurations'] relatedTools: ['get_node to configure found nodes', 'search_templates to find workflow examples', 'validate_node to check configurations']
} }

View File

@@ -1 +1 @@
{"version":3,"file":"search-nodes.js","sourceRoot":"","sources":["../../../../src/mcp/tool-docs/discovery/search-nodes.ts"],"names":[],"mappings":";;;AAEa,QAAA,cAAc,GAAsB;IAC/C,IAAI,EAAE,cAAc;IACpB,QAAQ,EAAE,WAAW;IACrB,UAAU,EAAE;QACV,WAAW,EAAE,0NAA0N;QACvO,aAAa,EAAE,CAAC,OAAO,EAAE,MAAM,EAAE,OAAO,CAAC;QACzC,OAAO,EAAE,kCAAkC;QAC3C,WAAW,EAAE,gCAAgC;QAC7C,IAAI,EAAE;YACJ,4CAA4C;YAC5C,sCAAsC;YACtC,+CAA+C;YAC/C,+CAA+C;SAChD;KACF;IACD,IAAI,EAAE;QACJ,WAAW,EAAE,2SAA2S;QACxT,UAAU,EAAE;YACV,KAAK,EAAE,EAAE,IAAI,EAAE,QAAQ,EAAE,WAAW,EAAE,oEAAoE,EAAE,QAAQ,EAAE,IAAI,EAAE;YAC5H,KAAK,EAAE,EAAE,IAAI,EAAE,QAAQ,EAAE,WAAW,EAAE,kDAAkD,EAAE,QAAQ,EAAE,KAAK,EAAE;YAC3G,IAAI,EAAE,EAAE,IAAI,EAAE,QAAQ,EAAE,WAAW,EAAE,oGAAoG,EAAE,QAAQ,EAAE,KAAK,EAAE;SAC7J;QACD,OAAO,EAAE,4LAA4L;QACrM,QAAQ,EAAE;YACR,uEAAuE;YACvE,mFAAmF;YACnF,2EAA2E;YAC3E,yEAAyE;YACzE,6EAA6E;YAC7E,uFAAuF;SACxF;QACD,QAAQ,EAAE;YACR,2CAA2C;YAC3C,6EAA6E;YAC7E,mCAAmC;YACnC,6EAA6E;SAC9E;QACD,WAAW,EAAE,uFAAuF;QACpG,aAAa,EAAE;YACb,iDAAiD;YACjD,qDAAqD;YACrD,2CAA2C;YAC3C,oDAAoD;SACrD;QACD,QAAQ,EAAE;YACR,sEAAsE;YACtE,8EAA8E;YAC9E,4CAA4C;SAC7C;QACD,YAAY,EAAE,CAAC,mCAAmC,EAAE,4CAA4C,EAAE,uCAAuC,CAAC;KAC3I;CACF,CAAC"} {"version":3,"file":"search-nodes.js","sourceRoot":"","sources":["../../../../src/mcp/tool-docs/discovery/search-nodes.ts"],"names":[],"mappings":";;;AAEa,QAAA,cAAc,GAAsB;IAC/C,IAAI,EAAE,cAAc;IACpB,QAAQ,EAAE,WAAW;IACrB,UAAU,EAAE;QACV,WAAW,EAAE,kPAAkP;QAC/P,aAAa,EAAE,CAAC,OAAO,EAAE,MAAM,EAAE,OAAO,EAAE,QAAQ,EAAE,iBAAiB,CAAC;QACtE,OAAO,EAAE,kCAAkC;QAC3C,WAAW,EAAE,gCAAgC;QAC7C,IAAI,EAAE;YACJ,4CAA4C;YAC5C,sCAAsC;YACtC,+CAA+C;YAC/C,+CAA+C;YAC/C,uDAAuD;YACvD,yDAAyD;SAC1D;KACF;IACD,IAAI,EAAE;QACJ,WAAW,EAAE,qcAAqc;QACld,UAAU,EAAE;YACV,KAAK,EAAE,EAAE,IAAI,EAAE,QAAQ,EAAE,WAAW,EAAE,oEAAoE,EAAE,QAAQ,EAAE,IAAI,EAAE;YAC5H,KAAK,EAAE,EAAE,IAAI,EAAE,QAAQ,EAAE,WAAW,EAAE,kDAAkD,EAAE,QAAQ,EAAE,KAAK,EAAE;YAC3G,IAAI,EAAE,EAAE,IAAI,EAAE,QAAQ,EAAE,WAAW,EAAE,oGAAoG,EAAE,QAAQ,EAAE,KAAK,EAAE;YAC5J,MAAM,EAAE,EAAE,IAAI,EAAE,QAAQ,EAAE,WAAW,EAAE,kKAAkK,EAAE,QAAQ,EAAE,KAAK,EAAE;YAC5N,eAAe,EAAE,EAAE,IAAI,EAAE,SAAS,EAAE,WAAW,EAAE,sIAAsI,EAAE,QAAQ,EAAE,KAAK,EAAE;SAC3M;QACD,OAAO,EAAE,yTAAyT;QAClU,QAAQ,EAAE;YACR,uEAAuE;YACvE,mFAAmF;YACnF,2EAA2E;YAC3E,yEAAyE;YACzE,6EAA6E;YAC7E,uFAAuF;YACvF,wFAAwF;YACxF,sFAAsF;YACtF,sEAAsE;YACtE,0FAA0F;SAC3F;QACD,QAAQ,EAAE;YACR,2CAA2C;YAC3C,6EAA6E;YAC7E,mCAAmC;YACnC,6EAA6E;YAC7E,0DAA0D;YAC1D,qDAAqD;SACtD;QACD,WAAW,EAAE,uFAAuF;QACpG,aAAa,EAAE;YACb,iDAAiD;YACjD,qDAAqD;YACrD,2CAA2C;YAC3C,oDAAoD;YACpD,wEAAwE;YACxE,wDAAwD;SACzD;QACD,QAAQ,EAAE;YACR,sEAAsE;YACtE,8EAA8E;YAC9E,4CAA4C;YAC5C,2EAA2E;YAC3E,yEAAyE;SAC1E;QACD,YAAY,EAAE,CAAC,mCAAmC,EAAE,4CAA4C,EAAE,uCAAuC,CAAC;KAC3I;CACF,CAAC"}

View File

@@ -1 +1 @@
{"version":3,"file":"tools.d.ts","sourceRoot":"","sources":["../../src/mcp/tools.ts"],"names":[],"mappings":"AAAA,OAAO,EAAE,cAAc,EAAE,MAAM,UAAU,CAAC;AAQ1C,eAAO,MAAM,0BAA0B,EAAE,cAAc,EAkatD,CAAC"} {"version":3,"file":"tools.d.ts","sourceRoot":"","sources":["../../src/mcp/tools.ts"],"names":[],"mappings":"AAAA,OAAO,EAAE,cAAc,EAAE,MAAM,UAAU,CAAC;AAQ1C,eAAO,MAAM,0BAA0B,EAAE,cAAc,EAwatD,CAAC"}

6
dist/mcp/tools.js vendored
View File

@@ -52,6 +52,12 @@ exports.n8nDocumentationToolsFinal = [
description: 'Include top 2 real-world configuration examples from popular templates (default: false)', description: 'Include top 2 real-world configuration examples from popular templates (default: false)',
default: false, default: false,
}, },
source: {
type: 'string',
enum: ['all', 'core', 'community', 'verified'],
description: 'Filter by node source: all=everything (default), core=n8n base nodes, community=community nodes, verified=verified community nodes only',
default: 'all',
},
}, },
required: ['query'], required: ['query'],
}, },

File diff suppressed because one or more lines are too long

View File

@@ -155,6 +155,11 @@ export declare const workflowConnectionSchema: z.ZodRecord<z.ZodString, z.ZodObj
node: string; node: string;
index: number; index: number;
}[][] | undefined; }[][] | undefined;
ai_tool?: {
type: string;
node: string;
index: number;
}[][] | undefined;
ai_languageModel?: { ai_languageModel?: {
type: string; type: string;
node: string; node: string;
@@ -165,11 +170,6 @@ export declare const workflowConnectionSchema: z.ZodRecord<z.ZodString, z.ZodObj
node: string; node: string;
index: number; index: number;
}[][] | undefined; }[][] | undefined;
ai_tool?: {
type: string;
node: string;
index: number;
}[][] | undefined;
ai_embedding?: { ai_embedding?: {
type: string; type: string;
node: string; node: string;
@@ -191,6 +191,11 @@ export declare const workflowConnectionSchema: z.ZodRecord<z.ZodString, z.ZodObj
node: string; node: string;
index: number; index: number;
}[][] | undefined; }[][] | undefined;
ai_tool?: {
type: string;
node: string;
index: number;
}[][] | undefined;
ai_languageModel?: { ai_languageModel?: {
type: string; type: string;
node: string; node: string;
@@ -201,11 +206,6 @@ export declare const workflowConnectionSchema: z.ZodRecord<z.ZodString, z.ZodObj
node: string; node: string;
index: number; index: number;
}[][] | undefined; }[][] | undefined;
ai_tool?: {
type: string;
node: string;
index: number;
}[][] | undefined;
ai_embedding?: { ai_embedding?: {
type: string; type: string;
node: string; node: string;

File diff suppressed because it is too large Load Diff

1961
package-lock.json generated

File diff suppressed because it is too large Load Diff

View File

@@ -1,6 +1,6 @@
{ {
"name": "n8n-mcp", "name": "n8n-mcp",
"version": "2.33.1", "version": "2.33.4",
"description": "Integration between n8n workflow automation and Model Context Protocol (MCP)", "description": "Integration between n8n workflow automation and Model Context Protocol (MCP)",
"main": "dist/index.js", "main": "dist/index.js",
"types": "dist/index.d.ts", "types": "dist/index.d.ts",
@@ -150,16 +150,16 @@
}, },
"dependencies": { "dependencies": {
"@modelcontextprotocol/sdk": "1.20.1", "@modelcontextprotocol/sdk": "1.20.1",
"@n8n/n8n-nodes-langchain": "^2.2.2", "@n8n/n8n-nodes-langchain": "^2.4.3",
"@supabase/supabase-js": "^2.57.4", "@supabase/supabase-js": "^2.57.4",
"dotenv": "^16.5.0", "dotenv": "^16.5.0",
"express": "^5.1.0", "express": "^5.1.0",
"express-rate-limit": "^7.1.5", "express-rate-limit": "^7.1.5",
"form-data": "^4.0.5", "form-data": "^4.0.5",
"lru-cache": "^11.2.1", "lru-cache": "^11.2.1",
"n8n": "^2.2.3", "n8n": "^2.4.4",
"n8n-core": "^2.2.2", "n8n-core": "^2.4.2",
"n8n-workflow": "^2.2.2", "n8n-workflow": "^2.4.2",
"openai": "^4.77.0", "openai": "^4.77.0",
"sql.js": "^1.13.0", "sql.js": "^1.13.0",
"tslib": "^2.6.2", "tslib": "^2.6.2",

View File

@@ -1,6 +1,6 @@
{ {
"name": "n8n-mcp-runtime", "name": "n8n-mcp-runtime",
"version": "2.33.1", "version": "2.33.2",
"description": "n8n MCP Server Runtime Dependencies Only", "description": "n8n MCP Server Runtime Dependencies Only",
"private": true, "private": true,
"dependencies": { "dependencies": {

View File

@@ -5,7 +5,7 @@
* These structures define the expected data format, JavaScript type, * These structures define the expected data format, JavaScript type,
* validation rules, and examples for each property type. * validation rules, and examples for each property type.
* *
* Based on n8n-workflow v1.120.3 NodePropertyTypes * Based on n8n-workflow v2.4.2 NodePropertyTypes
* *
* @module constants/type-structures * @module constants/type-structures
* @since 2.23.0 * @since 2.23.0
@@ -15,7 +15,7 @@ import type { NodePropertyTypes } from 'n8n-workflow';
import type { TypeStructure } from '../types/type-structures'; import type { TypeStructure } from '../types/type-structures';
/** /**
* Complete type structure definitions for all 22 NodePropertyTypes * Complete type structure definitions for all 23 NodePropertyTypes
* *
* Each entry defines: * Each entry defines:
* - type: Category (primitive/object/collection/special) * - type: Category (primitive/object/collection/special)
@@ -620,6 +620,23 @@ export const TYPE_STRUCTURES: Record<NodePropertyTypes, TypeStructure> = {
'One-time import feature', 'One-time import feature',
], ],
}, },
icon: {
type: 'primitive',
jsType: 'string',
description: 'Icon identifier for visual representation',
example: 'fa:envelope',
examples: ['fa:envelope', 'fa:user', 'fa:cog', 'file:slack.svg'],
validation: {
allowEmpty: false,
allowExpressions: false,
},
notes: [
'References icon by name or file path',
'Supports Font Awesome icons (fa:) and file paths (file:)',
'Used for visual customization in UI',
],
},
}; };
/** /**

View File

@@ -677,11 +677,25 @@ export class SingleSessionHTTPServer {
private async resetSessionSSE(res: express.Response): Promise<void> { private async resetSessionSSE(res: express.Response): Promise<void> {
// Clean up old session if exists // Clean up old session if exists
if (this.session) { if (this.session) {
const sessionId = this.session.sessionId;
logger.info('Closing previous session for SSE', { sessionId });
// Close server first to free resources (database, cache timer, etc.)
// This mirrors the cleanup pattern in removeSession() (issue #542)
// Handle server close errors separately so transport close still runs
if (this.session.server && typeof this.session.server.close === 'function') {
try {
await this.session.server.close();
} catch (serverError) {
logger.warn('Error closing server for SSE session', { sessionId, error: serverError });
}
}
// Close transport last - always attempt even if server.close() failed
try { try {
logger.info('Closing previous session for SSE', { sessionId: this.session.sessionId });
await this.session.transport.close(); await this.session.transport.close();
} catch (error) { } catch (transportError) {
logger.warn('Error closing previous session:', error); logger.warn('Error closing transport for SSE session', { sessionId, error: transportError });
} }
} }

View File

@@ -90,7 +90,7 @@ export class TypeStructureService {
/** /**
* Get all type structure definitions * Get all type structure definitions
* *
* Returns a record of all 22 NodePropertyTypes with their structures. * Returns a record of all 23 NodePropertyTypes with their structures.
* Useful for documentation, validation setup, or UI generation. * Useful for documentation, validation setup, or UI generation.
* *
* @returns Record mapping all types to their structures * @returns Record mapping all types to their structures

View File

@@ -11,7 +11,7 @@ import { isTypeStructure } from '@/types/type-structures';
import type { NodePropertyTypes } from 'n8n-workflow'; import type { NodePropertyTypes } from 'n8n-workflow';
describe('TYPE_STRUCTURES', () => { describe('TYPE_STRUCTURES', () => {
// All 22 NodePropertyTypes from n8n-workflow // All 23 NodePropertyTypes from n8n-workflow
const ALL_PROPERTY_TYPES: NodePropertyTypes[] = [ const ALL_PROPERTY_TYPES: NodePropertyTypes[] = [
'boolean', 'boolean',
'button', 'button',
@@ -20,6 +20,7 @@ describe('TYPE_STRUCTURES', () => {
'dateTime', 'dateTime',
'fixedCollection', 'fixedCollection',
'hidden', 'hidden',
'icon',
'json', 'json',
'callout', 'callout',
'notice', 'notice',
@@ -38,16 +39,16 @@ describe('TYPE_STRUCTURES', () => {
]; ];
describe('Completeness', () => { describe('Completeness', () => {
it('should define all 22 NodePropertyTypes', () => { it('should define all 23 NodePropertyTypes', () => {
const definedTypes = Object.keys(TYPE_STRUCTURES); const definedTypes = Object.keys(TYPE_STRUCTURES);
expect(definedTypes).toHaveLength(22); expect(definedTypes).toHaveLength(23);
for (const type of ALL_PROPERTY_TYPES) { for (const type of ALL_PROPERTY_TYPES) {
expect(TYPE_STRUCTURES).toHaveProperty(type); expect(TYPE_STRUCTURES).toHaveProperty(type);
} }
}); });
it('should not have extra types beyond the 22 standard types', () => { it('should not have extra types beyond the 23 standard types', () => {
const definedTypes = Object.keys(TYPE_STRUCTURES); const definedTypes = Object.keys(TYPE_STRUCTURES);
const extraTypes = definedTypes.filter((type) => !ALL_PROPERTY_TYPES.includes(type as NodePropertyTypes)); const extraTypes = definedTypes.filter((type) => !ALL_PROPERTY_TYPES.includes(type as NodePropertyTypes));

View File

@@ -58,9 +58,9 @@ describe('TypeStructureService', () => {
}); });
describe('getAllStructures', () => { describe('getAllStructures', () => {
it('should return all 22 type structures', () => { it('should return all 23 type structures', () => {
const structures = TypeStructureService.getAllStructures(); const structures = TypeStructureService.getAllStructures();
expect(Object.keys(structures)).toHaveLength(22); expect(Object.keys(structures)).toHaveLength(23);
}); });
it('should return a copy not a reference', () => { it('should return a copy not a reference', () => {