Compare commits

..

1 Commits

Author SHA1 Message Date
czlonkowski
e583261d37 fix: Add missing tslib dependency to fix npx installation failures (#342)
Fixed critical dependency issue where tslib was missing from the published
npm package, causing MODULE_NOT_FOUND errors when users ran
'npx n8n-mcp@latest' on Windows and other platforms.

Root Cause:
- @supabase/functions-js requires tslib at runtime
- tslib was NOT in package.runtime.json dependencies
- CI/CD copies package.runtime.json → package.json before publishing
- Result: Published package had no tslib → npx installations failed

Changes:
- Added tslib@^2.6.2 to package.runtime.json (critical fix)
- Added tslib@^2.6.2 to package.json (development consistency)
- Updated package.runtime.json version to 2.20.6
- Updated package.json version to 2.20.6
- Added comprehensive CHANGELOG.md entry

Impact:
-  npx n8n-mcp@latest now works on all platforms
-  No breaking changes (tslib already in transitive tree)
-  Fixes 100% failure rate for fresh npx installations

Fixes #342

Conceived by Romuald Członkowski - www.aiadvisors.pl/en
2025-10-21 23:16:30 +02:00
25 changed files with 3025 additions and 7341 deletions

View File

@@ -7,518 +7,6 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
## [Unreleased]
## [2.21.1] - 2025-10-23
### 🐛 Bug Fixes
**Issue #357: Fix AI Node Connection Validation in Partial Workflow Updates**
Fixed critical validation issue where `n8n_update_partial_workflow` incorrectly required `main` connections for AI nodes that exclusively use AI-specific connection types (`ai_languageModel`, `ai_memory`, `ai_embedding`, `ai_vectorStore`, `ai_tool`).
#### Problem
Workflows containing AI nodes (OpenAI Chat Model, Postgres Chat Memory, Embeddings OpenAI, Supabase Vector Store) could not be updated via `n8n_update_partial_workflow`, even for trivial changes to unrelated nodes. The validation logic incorrectly expected ALL nodes to have `main` connections, causing false positive errors:
```
Invalid connections: [
{
"code": "invalid_type",
"expected": "array",
"received": "undefined",
"path": ["OpenAI Chat Model", "main"],
"message": "Required"
}
]
```
**Impact**: Users could not update any workflows containing AI Agent nodes via MCP tools, forcing manual updates through the n8n UI.
#### Root Cause
The Zod schema in `src/services/n8n-validation.ts` (lines 27-39) defined `main` connections as a **required field** for all nodes, without support for AI-specific connection types:
```typescript
// BEFORE (Broken):
export const workflowConnectionSchema = z.record(
z.object({
main: z.array(...), // Required - WRONG for AI nodes!
})
);
```
AI nodes use specialized connection types exclusively:
- **ai_languageModel** - Language models (OpenAI, Anthropic, etc.)
- **ai_memory** - Memory systems (Postgres Chat Memory, etc.)
- **ai_embedding** - Embedding models (Embeddings OpenAI, etc.)
- **ai_vectorStore** - Vector stores (Supabase Vector Store, etc.)
- **ai_tool** - Tools for AI agents
These nodes **never have `main` connections** - they only have their AI-specific connection types.
#### Fixed
**1. Updated Zod Schema** (`src/services/n8n-validation.ts` lines 27-49):
```typescript
// AFTER (Fixed):
const connectionArraySchema = z.array(
z.array(
z.object({
node: z.string(),
type: z.string(),
index: z.number(),
})
)
);
export const workflowConnectionSchema = z.record(
z.object({
main: connectionArraySchema.optional(), // Now optional
error: connectionArraySchema.optional(), // Error connections
ai_tool: connectionArraySchema.optional(), // AI tool connections
ai_languageModel: connectionArraySchema.optional(), // Language model connections
ai_memory: connectionArraySchema.optional(), // Memory connections
ai_embedding: connectionArraySchema.optional(), // Embedding connections
ai_vectorStore: connectionArraySchema.optional(), // Vector store connections
})
);
```
**2. Comprehensive Test Suite** (New file: `tests/integration/workflow-diff/ai-node-connection-validation.test.ts`):
- 13 test scenarios covering all AI connection types
- Tests for AI nodes with ONLY AI-specific connections (no `main`)
- Tests for mixed workflows (regular nodes + AI nodes)
- Tests for the exact scenario from issue #357
- All tests passing ✅
**3. Updated Documentation** (`src/mcp/tool-docs/workflow_management/n8n-update-partial-workflow.ts`):
- Added clarification that AI nodes do NOT require `main` connections
- Documented fix for issue #357
- Updated best practices for AI workflows
#### Testing
**Before Fix**:
-`n8n_validate_workflow`: Returns `valid: true` (correct)
-`n8n_update_partial_workflow`: FAILS with "main connections required" errors
- ❌ Cannot update workflows containing AI nodes at all
**After Fix**:
-`n8n_validate_workflow`: Returns `valid: true` (still correct)
-`n8n_update_partial_workflow`: SUCCEEDS without validation errors
- ✅ AI nodes correctly recognized with AI-specific connection types only
- ✅ All 13 new integration tests passing
- ✅ Tested with actual workflow `019Vrw56aROeEzVj` from issue #357
#### Impact
**Zero Breaking Changes**:
- Making required fields optional is always backward compatible
- All existing workflows continue working
- Validation now correctly matches n8n's actual connection model
**Fixes**:
- Users can now update AI workflows via `n8n_update_partial_workflow`
- AI nodes no longer generate false positive validation errors
- Consistent validation between `n8n_validate_workflow` and `n8n_update_partial_workflow`
#### Files Changed
**Modified (3 files)**:
- `src/services/n8n-validation.ts` - Fixed Zod schema to support all connection types
- `src/mcp/tool-docs/workflow_management/n8n-update-partial-workflow.ts` - Updated documentation
- `package.json` - Version bump to 2.21.1
**Added (1 file)**:
- `tests/integration/workflow-diff/ai-node-connection-validation.test.ts` - Comprehensive test suite (13 tests)
#### References
- **Issue**: #357 - n8n_update_partial_workflow incorrectly validates AI nodes requiring 'main' connections
- **Workflow**: `019Vrw56aROeEzVj` (WOO_Workflow_21_POST_Chat_Send_AI_Agent)
- **Investigation**: Deep code analysis by Explore agent identified exact root cause in Zod schema
- **Confirmation**: n8n-mcp-tester agent verified fix with real workflow
Conceived by Romuald Członkowski - [www.aiadvisors.pl/en](https://www.aiadvisors.pl/en)
## [2.21.0] - 2025-10-23
### ✨ Features
**Issue #353: Auto-Update Connection References on Node Rename**
Enhanced `n8n_update_partial_workflow` to automatically update all connection references when renaming nodes, matching n8n UI behavior and eliminating the need for complex manual workarounds.
#### Problem
When renaming a node using the `updateNode` operation, connections still referenced the old node name, causing validation errors:
```
"Connection references non-existent target node: Old Name"
```
This forced users to manually remove and re-add all connections, requiring:
- 3+ operations instead of 1 simple rename
- Manual tracking of all connection details (source, branch/case, indices)
- Error-prone connection management
- Inconsistent behavior compared to n8n UI
#### Solution: Automatic Connection Reference Updates
When you rename a node, **all connection references are automatically updated throughout the entire workflow**. The system:
1. Detects name changes during `updateNode` operations
2. Tracks old→new name mappings
3. Updates all connection references after node operations complete
4. Handles all connection types and branch configurations
#### What Gets Updated Automatically
**Connection Source Keys:**
- If a source node is renamed, its connections object key is updated
- Example: `connections['Old Name']``connections['New Name']`
**Connection Target References:**
- If a target node is renamed, all connections pointing to it are updated
- Example: `{node: 'Old Name', type: 'main', index: 0}``{node: 'New Name', type: 'main', index: 0}`
**All Connection Types:**
- `main` - Standard connections
- `error` - Error output connections
- `ai_tool` - AI tool connections
- `ai_languageModel` - AI language model connections
- `ai_memory` - AI memory connections
- All other connection types
**All Branch Configurations:**
- IF node branches (true/false outputs)
- Switch node cases (multiple numbered outputs)
- Error output branches
- AI-specific connection routing
#### Examples
**Before (v2.20.8 and earlier) - Failed:**
```javascript
// Attempting to rename would fail
n8n_update_partial_workflow({
id: "workflow_id",
operations: [{
type: "updateNode",
nodeId: "8546d741-1af1-4aa0-bf11-af6c926c0008",
updates: {
name: "Return 404 Not Found" // Rename from "Return 403 Forbidden"
}
}]
});
// Result: ERROR
// "Workflow validation failed with 2 structural issues"
// "Connection references non-existent target node: Return 403 Forbidden"
// Required workaround (3 operations):
operations: [
{type: "removeConnection", source: "IF", target: "Return 403 Forbidden", branch: "false"},
{type: "updateNode", nodeId: "...", updates: {name: "Return 404 Not Found"}},
{type: "addConnection", source: "IF", target: "Return 404 Not Found", branch: "false"}
]
```
**After (v2.21.0) - Works Automatically:**
```javascript
// Same operation now succeeds automatically!
n8n_update_partial_workflow({
id: "workflow_id",
operations: [{
type: "updateNode",
nodeId: "8546d741-1af1-4aa0-bf11-af6c926c0008",
updates: {
name: "Return 404 Not Found", // Connections auto-update!
parameters: {
responseBody: '={{ {"error": "Not Found"} }}',
options: { responseCode: 404 }
}
}
}]
});
// Result: SUCCESS
// All connections automatically point to "Return 404 Not Found"
// Single operation instead of 3+
```
#### Additional Features
**Name Collision Detection:**
```javascript
// Attempting to rename to existing name
{type: "updateNode", nodeId: "abc", updates: {name: "Existing Name"}}
// Result: Clear error message
"Cannot rename node 'Old Name' to 'Existing Name': A node with that name
already exists (id: xyz123...). Please choose a different name."
```
**Batch Rename Support:**
```javascript
// Multiple renames in single call - all connections update correctly
operations: [
{type: "updateNode", nodeId: "node1", updates: {name: "New Name 1"}},
{type: "updateNode", nodeId: "node2", updates: {name: "New Name 2"}},
{type: "updateNode", nodeId: "node3", updates: {name: "New Name 3"}}
]
```
**Chain Operations:**
```javascript
// Rename then immediately use new name in subsequent operations
operations: [
{type: "updateNode", nodeId: "abc", updates: {name: "New Name"}},
{type: "addConnection", source: "New Name", target: "Other Node"}
]
```
#### Technical Implementation
**Files Modified:**
- `src/services/workflow-diff-engine.ts` - Core auto-update logic
- Added `renameMap` property to track name changes
- Added `updateConnectionReferences()` method (lines 943-994)
- Enhanced `validateUpdateNode()` with name collision detection (lines 369-392)
- Modified `applyUpdateNode()` to track renames (lines 613-635)
- Connection updates applied after Pass 1 node operations (lines 156-160)
- `src/mcp/tool-docs/workflow_management/n8n-update-partial-workflow.ts`
- Added comprehensive "Automatic Connection Reference Updates" section
- Added to tips: "Node renames: Connections automatically update"
- Includes before/after examples and best practices
**New Test Files:**
- `tests/unit/services/workflow-diff-node-rename.test.ts` (925 lines, 14 scenarios)
- `tests/integration/workflow-diff/node-rename-integration.test.ts` (4 real-world workflows)
**Test Coverage:**
1. Simple rename with single connection
2. Multiple incoming connections
3. Multiple outgoing connections
4. IF node branches (true/false)
5. Switch node cases (0, 1, 2, ..., N)
6. Error connections
7. AI tool connections (ai_tool, ai_languageModel)
8. Name collision detection
9. Rename to same name (no-op)
10. Multiple renames in single batch
11. Chain operations (rename + add/remove connections)
12. validateOnly mode
13. continueOnError mode
14. Self-connections (loops)
15. Real-world Issue #353 scenario
#### Benefits
**User Experience:**
-**Principle of Least Surprise**: Matches n8n UI behavior
-**Single Operation**: Rename with 1 operation instead of 3+
-**No Manual Tracking**: System handles all connection updates
-**Safer**: Collision detection prevents naming conflicts
-**Faster**: Less error-prone, fewer operations
**Technical:**
-**100% Backward Compatible**: Enhances existing `updateNode` operation
-**All Connection Types**: main, error, AI connections, etc.
-**All Branch Types**: IF, Switch, error outputs
-**Atomic**: All connections update together or rollback
-**Works in Both Modes**: atomic and continueOnError
**Comprehensive:**
-**14 Test Scenarios**: Unit tests covering all edge cases
-**4 Integration Tests**: Real-world workflow validation
-**Complete Documentation**: Tool docs with examples
-**Clear Error Messages**: Name collision detection with actionable guidance
#### Impact on Existing Workflows
**Zero Breaking Changes:**
- All existing workflows continue working
- Existing operations work identically
- Only enhances rename behavior
- No API changes required
**Migration:**
- No migration needed
- Update to v2.21.0 and renames "just work"
- Remove manual connection workarounds at your convenience
#### Related
- **Issue:** #353 - Enhancement: Auto-update connection references on node rename
- **Use Case:** Real-world API endpoint workflow (POST /patients/:id/approaches)
- **Reporter:** Internal testing during workflow refactoring
- **Solution:** Recommended Solution 1 from issue (auto-update)
Conceived by Romuald Członkowski - [www.aiadvisors.pl/en](https://www.aiadvisors.pl/en)
## [2.20.8] - 2025-10-23
### 🐛 Bug Fixes
This release includes two critical bug fixes that improve workflow validation for sticky notes and trigger nodes.
**Fix #1: Sticky Notes Validation - Disconnected Node False Positives (PR #350)**
Fixed bug where sticky notes (UI-only annotation nodes) were incorrectly triggering "disconnected node" validation errors when updating workflows via MCP tools.
#### Problem
- Workflows with sticky notes failed validation with "Node is disconnected" errors
- Validation logic was inconsistent between `workflow-validator.ts` and `n8n-validation.ts`
- Sticky notes are UI-only annotations and should never trigger connection validation
#### Fixed
- **Created Shared Utility Module** (`src/utils/node-classification.ts`):
- `isStickyNote()`: Identifies all sticky note type variations
- `isTriggerNode()`: Identifies trigger nodes (webhook, manual, cron, schedule)
- `isNonExecutableNode()`: Identifies UI-only nodes
- `requiresIncomingConnection()`: Determines if node needs incoming connections
- **Updated Validators**: Both validation files now properly skip sticky notes
**Fix #2: Issue #351 - Recognize All Trigger Node Types Including Execute Workflow Trigger (PR #352)**
Fixed validation logic that was incorrectly treating Execute Workflow Trigger and other trigger nodes as regular nodes, causing "disconnected node" errors during partial workflow updates.
#### Problem
The workflow validation system used a hardcoded list of only 5 trigger types, missing 200+ trigger nodes including `executeWorkflowTrigger`.
Additionally, no validation prevented users from activating workflows that only have `executeWorkflowTrigger` nodes (which cannot activate workflows - they can only be invoked by other workflows).
#### Fixed
- **Enhanced Trigger Detection** (`src/utils/node-type-utils.ts`):
- `isTriggerNode()`: Flexible pattern matching recognizes ALL triggers (200+)
- `isActivatableTrigger()`: Distinguishes triggers that can activate workflows
- `getTriggerTypeDescription()`: Human-readable trigger descriptions
- **Active Workflow Validation** (`src/services/n8n-validation.ts`):
- Prevents activation of workflows with only `executeWorkflowTrigger` nodes
- Clear error messages guide users to add activatable triggers or deactivate the workflow
- **Comprehensive Test Coverage**: 30+ new tests for trigger detection
#### Impact
**Before Fix:**
- ❌ Execute Workflow Trigger and 195+ other triggers flagged as "disconnected nodes"
- ❌ Sticky notes triggered false positive validation errors
- ❌ Could activate workflows with only `executeWorkflowTrigger` (n8n API would reject)
**After Fix:**
- ✅ ALL trigger types recognized (executeWorkflowTrigger, scheduleTrigger, emailTrigger, etc.)
- ✅ Sticky notes properly excluded from validation
- ✅ Clear error messages when trying to activate workflow with only `executeWorkflowTrigger`
- ✅ Future-proof (new trigger nodes automatically supported)
- ✅ Consistent node classification across entire codebase
#### Technical Details
**Files Modified:**
- `src/utils/node-classification.ts` - NEW: Shared node classification utilities
- `src/utils/node-type-utils.ts` - Enhanced trigger detection functions
- `src/services/n8n-validation.ts` - Updated to use shared utilities
- `src/services/workflow-validator.ts` - Updated to use shared utilities
- `tests/unit/utils/node-type-utils.test.ts` - Added 30+ tests
- `package.json` - Version bump to 2.20.8
**Related:**
- **Issue:** #351 - Execute Workflow Trigger not recognized as valid trigger
- **PR:** #350 - Sticky notes validation fix
- **PR:** #352 - Comprehensive trigger detection
Conceived by Romuald Członkowski - [www.aiadvisors.pl/en](https://www.aiadvisors.pl/en)
## [2.20.7] - 2025-10-22
### 🔄 Dependencies
**Updated n8n to v1.116.2**
Updated all n8n dependencies to the latest compatible versions:
- `n8n`: 1.115.2 → 1.116.2
- `n8n-core`: 1.114.0 → 1.115.1
- `n8n-workflow`: 1.112.0 → 1.113.0
- `@n8n/n8n-nodes-langchain`: 1.114.1 → 1.115.1
**Database Rebuild:**
- Rebuilt node database with 542 nodes from updated n8n packages
- All 542 nodes loaded successfully from both n8n-nodes-base (439 nodes) and @n8n/n8n-nodes-langchain (103 nodes)
- Documentation mapping completed for all nodes
**Testing:**
- Changes validated in CI/CD pipeline with full test suite (705 tests)
- Critical nodes validated: httpRequest, code, slack, agent
### 🐛 Bug Fixes
**FTS5 Search Ranking - Exact Match Prioritization**
Fixed critical bug in production search where exact matches weren't appearing first in search results.
#### Problem
- SQL ORDER BY clause was `ORDER BY rank, CASE ... END` (wrong order)
- FTS5 rank sorted first, CASE statement only acted as tiebreaker
- Since FTS5 ranks are always unique, CASE boosting never applied
- Additionally, CASE used case-sensitive comparison failing to match nodes like "Webhook" when searching "webhook"
- Result: Searching "webhook" returned "Webflow Trigger" first, actual "Webhook" node ranked 4th
#### Root Cause Analysis
**SQL Ordering Issue:**
```sql
-- BEFORE (Broken):
ORDER BY rank, CASE ... END -- rank first, CASE never used
-- Result: webhook ranks 4th (-9.64 rank)
-- Top 3: webflowTrigger (-10.20), vonage (-10.09), renameKeys (-10.01)
-- AFTER (Fixed):
ORDER BY CASE ... END, rank -- CASE first, exact matches prioritized
-- Result: webhook ranks 1st (CASE priority 0)
```
**Case-Sensitivity Issue:**
- Old: `WHEN n.display_name = ?` (case-sensitive, fails on "Webhook" vs "webhook")
- New: `WHEN LOWER(n.display_name) = LOWER(?)` (case-insensitive, matches correctly)
#### Fixed
**1. Production Code** (`src/mcp/server.ts` lines 1278-1295)
- Changed ORDER BY from: `rank, CASE ... END`
- To: `CASE WHEN LOWER(n.display_name) = LOWER(?) ... END, rank`
- Added case-insensitive comparison with LOWER() function
- Exact matches now consistently appear first in search results
**2. Test Files Updated**
- `tests/integration/database/node-fts5-search.test.ts` (lines 137-160)
- `tests/integration/ci/database-population.test.ts` (lines 206-234)
- Both updated to match corrected SQL logic with case-insensitive comparison
- Tests now accurately validate production search behavior
#### Impact
**Search Quality:**
- ✅ Exact matches now always rank first (webhook, http, code, etc.)
- ✅ Case-insensitive matching works correctly (Webhook = webhook = WEBHOOK)
- ✅ Better user experience - predictable search results
- ✅ SQL query more efficient (correct ordering at database level)
**Performance:**
- Same or better performance (less JavaScript sorting needed)
- Database does the heavy lifting with correct ORDER BY
- JavaScript sorting still provides additional relevance refinement
**Testing:**
- All 705 tests passing (703 passed + 2 fixed)
- Comprehensive testing by n8n-mcp-tester agent
- Code review approved with minor optimization suggestions for future
**Verified Search Results:**
- "webhook" → nodes-base.webhook (1st)
- "http" → nodes-base.httpRequest (1st)
- "code" → nodes-base.code (1st)
- "slack" → nodes-base.slack (1st)
- All case variations work correctly (WEBHOOK, Webhook, webhook)
## [2.20.6] - 2025-10-21
### 🐛 Bug Fixes

View File

@@ -192,5 +192,4 @@ NEVER proactively create documentation files (*.md) or README files. Only create
- When the user asks to review issues, you should use GH CLI to get the issue and all the comments
- When the task can be divided into separated subtasks, you should spawn separate sub-agents to handle them in paralel
- Use the best sub-agent for the task as per their descriptions
- Do not use hyperbolic or dramatic language in comments and documentation
- Add to every commit and PR: Concieved by Romuald Członkowski - and then link to www.aiadvisors.pl/en. Don't add it in conversations
- Do not use hyperbolic or dramatic language in comments and documentation

View File

@@ -5,7 +5,7 @@
[![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)
[![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-^1.116.2-orange.svg)](https://github.com/n8n-io/n8n)
[![n8n version](https://img.shields.io/badge/n8n-^1.115.2-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)
[![Deploy on Railway](https://railway.com/button.svg)](https://railway.com/deploy/n8n-mcp?referralCode=n8n-mcp)

Binary file not shown.

5997
package-lock.json generated

File diff suppressed because it is too large Load Diff

View File

@@ -1,6 +1,6 @@
{
"name": "n8n-mcp",
"version": "2.21.1",
"version": "2.20.6",
"description": "Integration between n8n workflow automation and Model Context Protocol (MCP)",
"main": "dist/index.js",
"types": "dist/index.d.ts",
@@ -140,15 +140,15 @@
},
"dependencies": {
"@modelcontextprotocol/sdk": "^1.20.1",
"@n8n/n8n-nodes-langchain": "^1.115.1",
"@n8n/n8n-nodes-langchain": "^1.114.1",
"@supabase/supabase-js": "^2.57.4",
"dotenv": "^16.5.0",
"express": "^5.1.0",
"express-rate-limit": "^7.1.5",
"lru-cache": "^11.2.1",
"n8n": "^1.116.2",
"n8n-core": "^1.115.1",
"n8n-workflow": "^1.113.0",
"n8n": "^1.115.2",
"n8n-core": "^1.114.0",
"n8n-workflow": "^1.112.0",
"openai": "^4.77.0",
"sql.js": "^1.13.0",
"tslib": "^2.6.2",

View File

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

View File

@@ -1276,20 +1276,20 @@ export class N8NDocumentationMCPServer {
try {
// Use FTS5 with ranking
const nodes = this.db.prepare(`
SELECT
SELECT
n.*,
rank
FROM nodes n
JOIN nodes_fts ON n.rowid = nodes_fts.rowid
WHERE nodes_fts MATCH ?
ORDER BY
CASE
WHEN LOWER(n.display_name) = LOWER(?) THEN 0
WHEN LOWER(n.display_name) LIKE LOWER(?) THEN 1
WHEN LOWER(n.node_type) LIKE LOWER(?) THEN 2
ORDER BY
rank,
CASE
WHEN n.display_name = ? THEN 0
WHEN n.display_name LIKE ? THEN 1
WHEN n.node_type LIKE ? THEN 2
ELSE 3
END,
rank,
n.display_name
LIMIT ?
`).all(ftsQuery, cleanedQuery, `%${cleanedQuery}%`, `%${cleanedQuery}%`, limit) as (NodeRow & { rank: number })[];

View File

@@ -48,7 +48,7 @@ An n8n AI Agent workflow typically consists of:
- Manages conversation flow
- Decides when to use tools
- Iterates until task is complete
- Supports fallback models for reliability
- Supports fallback models (v2.1+)
3. **Language Model**: The AI brain
- OpenAI GPT-4, Claude, Gemini, etc.
@@ -441,7 +441,7 @@ For real-time user experience:
### Pattern 2: Fallback Language Models
For production reliability with fallback language models:
For production reliability (requires AI Agent v2.1+):
\`\`\`typescript
n8n_update_partial_workflow({
@@ -724,7 +724,7 @@ n8n_validate_workflow({id: "workflow_id"})
'Always validate workflows after making changes',
'AI connections require sourceOutput parameter',
'Streaming mode has specific constraints',
'Fallback models require AI Agent node with fallback support'
'Some features require specific AI Agent versions (v2.1+ for fallback)'
],
relatedTools: [
'n8n_create_workflow',

View File

@@ -12,7 +12,7 @@ export const validateNodeOperationDoc: ToolDocumentation = {
'Profile choices: minimal (editing), runtime (execution), ai-friendly (balanced), strict (deployment)',
'Returns fixes you can apply directly',
'Operation-aware - knows Slack post needs text',
'Validates operator structures for IF and Switch nodes with conditions'
'Validates operator structures for IF v2.2+ and Switch v3.2+ nodes'
]
},
full: {
@@ -90,7 +90,7 @@ export const validateNodeOperationDoc: ToolDocumentation = {
'Fixes are suggestions - review before applying',
'Profile affects what\'s validated - minimal skips many checks',
'**Binary vs Unary operators**: Binary operators (equals, contains, greaterThan) must NOT have singleValue:true. Unary operators (isEmpty, isNotEmpty, true, false) REQUIRE singleValue:true',
'**IF and Switch nodes with conditions**: Must have complete conditions.options structure: {version: 2, leftValue: "", caseSensitive: true/false, typeValidation: "strict"}',
'**IF v2.2+ and Switch v3.2+ nodes**: Must have complete conditions.options structure: {version: 2, leftValue: "", caseSensitive: true/false, typeValidation: "strict"}',
'**Operator type field**: Must be data type (string/number/boolean/dateTime/array/object), NOT operation name (e.g., use type:"string" operation:"equals", not type:"equals")'
],
relatedTools: ['validate_node_minimal for quick checks', 'get_node_essentials for valid examples', 'validate_workflow for complete workflow validation']

View File

@@ -18,8 +18,7 @@ export const n8nUpdatePartialWorkflowDoc: ToolDocumentation = {
'Validate with validateOnly first',
'For AI connections, specify sourceOutput type (ai_languageModel, ai_tool, etc.)',
'Batch AI component connections for atomic updates',
'Auto-sanitization: ALL nodes auto-fixed during updates (operator structures, missing metadata)',
'Node renames automatically update all connection references - no manual connection operations needed'
'Auto-sanitization: ALL nodes auto-fixed during updates (operator structures, missing metadata)'
]
},
full: {
@@ -81,10 +80,6 @@ Full support for all 8 AI connection types used in n8n AI workflows:
- Multiple tools: Batch multiple \`sourceOutput: "ai_tool"\` connections to one AI Agent
- Vector retrieval: Chain ai_embedding → ai_vectorStore → ai_tool → AI Agent
**Important Notes**:
- **AI nodes do NOT require main connections**: Nodes like OpenAI Chat Model, Postgres Chat Memory, Embeddings OpenAI, and Supabase Vector Store use AI-specific connection types exclusively. They should ONLY have connections like \`ai_languageModel\`, \`ai_memory\`, \`ai_embedding\`, or \`ai_tool\` - NOT \`main\` connections.
- **Fixed in v2.21.1**: Validation now correctly recognizes AI nodes that only have AI-specific connections without requiring \`main\` connections (resolves issue #357).
**Best Practices**:
- Always specify \`sourceOutput\` for AI connections (defaults to "main" if omitted)
- Connect language model BEFORE creating/enabling AI Agent (validation requirement)
@@ -113,8 +108,8 @@ When ANY workflow update is made, ALL nodes in the workflow are automatically sa
- Invalid operator structures (e.g., \`{type: "isNotEmpty"}\`) are corrected to \`{type: "boolean", operation: "isNotEmpty"}\`
2. **Missing Metadata Added**:
- IF nodes with conditions get complete \`conditions.options\` structure if missing
- Switch nodes with conditions get complete \`conditions.options\` for all rules
- IF v2.2+ nodes get complete \`conditions.options\` structure if missing
- Switch v3.2+ nodes get complete \`conditions.options\` for all rules
- Required fields: \`{version: 2, leftValue: "", caseSensitive: true, typeValidation: "strict"}\`
### Sanitization Scope
@@ -134,59 +129,7 @@ If validation still fails after auto-sanitization:
2. Use \`validate_workflow\` to see all validation errors
3. For connection issues, use \`cleanStaleConnections\` operation
4. For branch mismatches, add missing output connections
5. For paradoxical corrupted workflows, create new workflow and migrate nodes
## Automatic Connection Reference Updates
When you rename a node using **updateNode**, all connection references throughout the workflow are automatically updated. Both the connection source keys and target references are updated for all connection types (main, error, ai_tool, ai_languageModel, ai_memory, etc.) and all branch configurations (IF node branches, Switch node cases, error outputs).
### Basic Example
\`\`\`javascript
// Rename a node - connections update automatically
n8n_update_partial_workflow({
id: "wf_123",
operations: [{
type: "updateNode",
nodeId: "node_abc",
updates: { name: "Data Processor" }
}]
});
// All incoming and outgoing connections now reference "Data Processor"
\`\`\`
### Multi-Output Node Example
\`\`\`javascript
// Rename nodes in a branching workflow
n8n_update_partial_workflow({
id: "workflow_id",
operations: [
{
type: "updateNode",
nodeId: "if_node_id",
updates: { name: "Value Checker" }
},
{
type: "updateNode",
nodeId: "error_node_id",
updates: { name: "Error Handler" }
}
]
});
// IF node branches and error connections automatically updated
\`\`\`
### Name Collision Protection
Attempting to rename a node to an existing name returns a clear error:
\`\`\`
Cannot rename node "Old Name" to "New Name": A node with that name already exists (id: abc123...).
Please choose a different name.
\`\`\`
### Usage Notes
- Simply rename nodes with updateNode - no manual connection operations needed
- Multiple renames in one call work atomically
- Can rename a node and add/remove connections using the new name in the same batch
- Use \`validateOnly: true\` to preview effects before applying`,
5. For paradoxical corrupted workflows, create new workflow and migrate nodes`,
parameters: {
id: { type: 'string', required: true, description: 'Workflow ID to update' },
operations: {
@@ -219,7 +162,7 @@ Please choose a different name.
'// Connect memory to AI Agent\nn8n_update_partial_workflow({id: "ai3", operations: [{type: "addConnection", source: "Window Buffer Memory", target: "AI Agent", sourceOutput: "ai_memory"}]})',
'// Connect output parser to AI Agent\nn8n_update_partial_workflow({id: "ai4", operations: [{type: "addConnection", source: "Structured Output Parser", target: "AI Agent", sourceOutput: "ai_outputParser"}]})',
'// Complete AI Agent setup: Add language model, tools, and memory\nn8n_update_partial_workflow({id: "ai5", operations: [\n {type: "addConnection", source: "OpenAI Chat Model", target: "AI Agent", sourceOutput: "ai_languageModel"},\n {type: "addConnection", source: "HTTP Request Tool", target: "AI Agent", sourceOutput: "ai_tool"},\n {type: "addConnection", source: "Code Tool", target: "AI Agent", sourceOutput: "ai_tool"},\n {type: "addConnection", source: "Window Buffer Memory", target: "AI Agent", sourceOutput: "ai_memory"}\n]})',
'// Add fallback model to AI Agent for reliability\nn8n_update_partial_workflow({id: "ai6", operations: [\n {type: "addConnection", source: "OpenAI Chat Model", target: "AI Agent", sourceOutput: "ai_languageModel", targetIndex: 0},\n {type: "addConnection", source: "Anthropic Chat Model", target: "AI Agent", sourceOutput: "ai_languageModel", targetIndex: 1}\n]})',
'// Add fallback model to AI Agent (requires v2.1+)\nn8n_update_partial_workflow({id: "ai6", operations: [\n {type: "addConnection", source: "OpenAI Chat Model", target: "AI Agent", sourceOutput: "ai_languageModel", targetIndex: 0},\n {type: "addConnection", source: "Anthropic Chat Model", target: "AI Agent", sourceOutput: "ai_languageModel", targetIndex: 1}\n]})',
'// Vector Store setup: Connect embeddings and documents\nn8n_update_partial_workflow({id: "ai7", operations: [\n {type: "addConnection", source: "Embeddings OpenAI", target: "Pinecone Vector Store", sourceOutput: "ai_embedding"},\n {type: "addConnection", source: "Default Data Loader", target: "Pinecone Vector Store", sourceOutput: "ai_document"}\n]})',
'// Connect Vector Store Tool to AI Agent (retrieval setup)\nn8n_update_partial_workflow({id: "ai8", operations: [\n {type: "addConnection", source: "Pinecone Vector Store", target: "Vector Store Tool", sourceOutput: "ai_vectorStore"},\n {type: "addConnection", source: "Vector Store Tool", target: "AI Agent", sourceOutput: "ai_tool"}\n]})',
'// Rewire AI Agent to use different language model\nn8n_update_partial_workflow({id: "ai9", operations: [{type: "rewireConnection", source: "AI Agent", from: "OpenAI Chat Model", to: "Anthropic Chat Model", sourceOutput: "ai_languageModel"}]})',

View File

@@ -1,7 +1,5 @@
import { z } from 'zod';
import { WorkflowNode, WorkflowConnection, Workflow } from '../types/n8n-api';
import { isTriggerNode, isActivatableTrigger } from '../utils/node-type-utils';
import { isNonExecutableNode } from '../utils/node-classification';
// Zod schemas for n8n API validation
@@ -24,31 +22,17 @@ export const workflowNodeSchema = z.object({
executeOnce: z.boolean().optional(),
});
// Connection array schema used by all connection types
const connectionArraySchema = z.array(
z.array(
z.object({
node: z.string(),
type: z.string(),
index: z.number(),
})
)
);
/**
* Workflow connection schema supporting all connection types.
* Note: 'main' is optional because AI nodes exclusively use AI-specific
* connection types (ai_languageModel, ai_memory, etc.) without main connections.
*/
export const workflowConnectionSchema = z.record(
z.object({
main: connectionArraySchema.optional(),
error: connectionArraySchema.optional(),
ai_tool: connectionArraySchema.optional(),
ai_languageModel: connectionArraySchema.optional(),
ai_memory: connectionArraySchema.optional(),
ai_embedding: connectionArraySchema.optional(),
ai_vectorStore: connectionArraySchema.optional(),
main: z.array(
z.array(
z.object({
node: z.string(),
type: z.string(),
index: z.number(),
})
)
),
})
);
@@ -210,14 +194,6 @@ export function validateWorkflowStructure(workflow: Partial<Workflow>): string[]
errors.push('Workflow must have at least one node');
}
// Check if workflow has only non-executable nodes (sticky notes)
if (workflow.nodes && workflow.nodes.length > 0) {
const hasExecutableNodes = workflow.nodes.some(node => !isNonExecutableNode(node.type));
if (!hasExecutableNodes) {
errors.push('Workflow must have at least one executable node. Sticky notes alone cannot form a valid workflow.');
}
}
if (!workflow.connections) {
errors.push('Workflow connections are required');
}
@@ -235,15 +211,13 @@ export function validateWorkflowStructure(workflow: Partial<Workflow>): string[]
// Check for disconnected nodes in multi-node workflows
if (workflow.nodes && workflow.nodes.length > 1 && workflow.connections) {
// Filter out non-executable nodes (sticky notes) when counting nodes
const executableNodes = workflow.nodes.filter(node => !isNonExecutableNode(node.type));
const connectionCount = Object.keys(workflow.connections).length;
// First check: workflow has no connections at all (only check if there are multiple executable nodes)
if (connectionCount === 0 && executableNodes.length > 1) {
const nodeNames = executableNodes.slice(0, 2).map(n => n.name);
// First check: workflow has no connections at all
if (connectionCount === 0) {
const nodeNames = workflow.nodes.slice(0, 2).map(n => n.name);
errors.push(`Multi-node workflow has no connections between nodes. Add a connection using: {type: 'addConnection', source: '${nodeNames[0]}', target: '${nodeNames[1]}', sourcePort: 'main', targetPort: 'main'}`);
} else if (connectionCount > 0 || executableNodes.length > 1) {
} else {
// Second check: detect disconnected nodes (nodes with no incoming or outgoing connections)
const connectedNodes = new Set<string>();
@@ -262,20 +236,19 @@ export function validateWorkflowStructure(workflow: Partial<Workflow>): string[]
}
});
// Find disconnected nodes (excluding non-executable nodes and triggers)
// Non-executable nodes (sticky notes) are UI-only and don't need connections
// Trigger nodes only need outgoing connections
// Find disconnected nodes (excluding webhook triggers which can be source-only)
const webhookTypes = new Set([
'n8n-nodes-base.webhook',
'n8n-nodes-base.webhookTrigger',
'n8n-nodes-base.manualTrigger'
]);
const disconnectedNodes = workflow.nodes.filter(node => {
// Skip non-executable nodes (sticky notes, etc.) - they're UI-only annotations
if (isNonExecutableNode(node.type)) {
return false;
}
const isConnected = connectedNodes.has(node.name);
const isNodeTrigger = isTriggerNode(node.type);
const isWebhookOrTrigger = webhookTypes.has(node.type);
// Trigger nodes only need outgoing connections
if (isNodeTrigger) {
// Webhook/trigger nodes only need outgoing connections
if (isWebhookOrTrigger) {
return !workflow.connections?.[node.name]; // Disconnected if no outgoing connections
}
@@ -330,29 +303,6 @@ export function validateWorkflowStructure(workflow: Partial<Workflow>): string[]
}
}
// Validate active workflows have activatable triggers
// Issue #351: executeWorkflowTrigger cannot activate a workflow
// It can only be invoked by other workflows
if ((workflow as any).active === true && workflow.nodes && workflow.nodes.length > 0) {
const activatableTriggers = workflow.nodes.filter(node =>
!node.disabled && isActivatableTrigger(node.type)
);
const executeWorkflowTriggers = workflow.nodes.filter(node =>
!node.disabled && node.type.toLowerCase().includes('executeworkflow')
);
if (activatableTriggers.length === 0 && executeWorkflowTriggers.length > 0) {
// Workflow is active but only has executeWorkflowTrigger nodes
const triggerNames = executeWorkflowTriggers.map(n => n.name).join(', ');
errors.push(
`Cannot activate workflow with only Execute Workflow Trigger nodes (${triggerNames}). ` +
'Execute Workflow Trigger can only be invoked by other workflows, not activated. ' +
'Either deactivate the workflow or add a webhook/schedule/polling trigger.'
);
}
}
// Validate Switch and IF node connection structures match their rules
if (workflow.nodes && workflow.connections) {
const switchNodes = workflow.nodes.filter(n => {

View File

@@ -36,9 +36,6 @@ import { sanitizeNode, sanitizeWorkflowNodes } from './node-sanitizer';
const logger = new Logger({ prefix: '[WorkflowDiffEngine]' });
export class WorkflowDiffEngine {
// Track node name changes during operations for connection reference updates
private renameMap: Map<string, string> = new Map();
/**
* Apply diff operations to a workflow
*/
@@ -47,9 +44,6 @@ export class WorkflowDiffEngine {
request: WorkflowDiffRequest
): Promise<WorkflowDiffResult> {
try {
// Reset rename tracking for this diff operation
this.renameMap.clear();
// Clone workflow to avoid modifying original
const workflowCopy = JSON.parse(JSON.stringify(workflow));
@@ -100,12 +94,6 @@ export class WorkflowDiffEngine {
}
}
// Update connection references after all node renames (even in continueOnError mode)
if (this.renameMap.size > 0 && appliedIndices.length > 0) {
this.updateConnectionReferences(workflowCopy);
logger.debug(`Auto-updated ${this.renameMap.size} node name references in connections (continueOnError mode)`);
}
// If validateOnly flag is set, return success without applying
if (request.validateOnly) {
return {
@@ -159,12 +147,6 @@ export class WorkflowDiffEngine {
}
}
// Update connection references after all node renames
if (this.renameMap.size > 0) {
this.updateConnectionReferences(workflowCopy);
logger.debug(`Auto-updated ${this.renameMap.size} node name references in connections`);
}
// Pass 2: Validate and apply other operations (connections, metadata)
for (const { operation, index } of otherOperations) {
const error = this.validateOperation(workflowCopy, operation);
@@ -371,23 +353,6 @@ export class WorkflowDiffEngine {
if (!node) {
return this.formatNodeNotFoundError(workflow, operation.nodeId || operation.nodeName || '', 'updateNode');
}
// Check for name collision if renaming
if (operation.updates.name && operation.updates.name !== node.name) {
const normalizedNewName = this.normalizeNodeName(operation.updates.name);
const normalizedCurrentName = this.normalizeNodeName(node.name);
// Only check collision if the names are actually different after normalization
if (normalizedNewName !== normalizedCurrentName) {
const collision = workflow.nodes.find(n =>
n.id !== node.id && this.normalizeNodeName(n.name) === normalizedNewName
);
if (collision) {
return `Cannot rename node "${node.name}" to "${operation.updates.name}": A node with that name already exists (id: ${collision.id.substring(0, 8)}...). Please choose a different name.`;
}
}
}
return null;
}
@@ -614,14 +579,6 @@ export class WorkflowDiffEngine {
const node = this.findNode(workflow, operation.nodeId, operation.nodeName);
if (!node) return;
// Track node renames for connection reference updates
if (operation.updates.name && operation.updates.name !== node.name) {
const oldName = node.name;
const newName = operation.updates.name;
this.renameMap.set(oldName, newName);
logger.debug(`Tracking rename: "${oldName}" → "${newName}"`);
}
// Apply updates using dot notation
Object.entries(operation.updates).forEach(([path, value]) => {
this.setNestedProperty(node, path, value);
@@ -940,59 +897,6 @@ export class WorkflowDiffEngine {
workflow.connections = operation.connections;
}
/**
* Update all connection references when nodes are renamed.
* This method is called after node operations to ensure connection integrity.
*
* Updates:
* - Connection object keys (source node names)
* - Connection target.node values (target node names)
* - All output types (main, error, ai_tool, ai_languageModel, etc.)
*
* @param workflow - The workflow to update
*/
private updateConnectionReferences(workflow: Workflow): void {
if (this.renameMap.size === 0) return;
logger.debug(`Updating connection references for ${this.renameMap.size} renamed nodes`);
// Create a mapping of all renames (old → new)
const renames = new Map(this.renameMap);
// Step 1: Update connection object keys (source node names)
const updatedConnections: WorkflowConnection = {};
for (const [sourceName, outputs] of Object.entries(workflow.connections)) {
// Check if this source node was renamed
const newSourceName = renames.get(sourceName) || sourceName;
updatedConnections[newSourceName] = outputs;
}
// Step 2: Update target node references within connections
for (const [sourceName, outputs] of Object.entries(updatedConnections)) {
// Iterate through all output types (main, error, ai_tool, ai_languageModel, etc.)
for (const [outputType, connections] of Object.entries(outputs)) {
// connections is Array<Array<{node, type, index}>>
for (let outputIndex = 0; outputIndex < connections.length; outputIndex++) {
const connectionsAtIndex = connections[outputIndex];
for (let connIndex = 0; connIndex < connectionsAtIndex.length; connIndex++) {
const connection = connectionsAtIndex[connIndex];
// Check if target node was renamed
if (renames.has(connection.node)) {
const newTargetName = renames.get(connection.node)!;
connection.node = newTargetName;
logger.debug(`Updated connection: ${sourceName}[${outputType}][${outputIndex}][${connIndex}].node: "${connection.node}" → "${newTargetName}"`);
}
}
}
}
}
// Replace workflow connections with updated connections
workflow.connections = updatedConnections;
logger.info(`Auto-updated ${this.renameMap.size} node name references in connections`);
}
// Helper methods
/**

View File

@@ -11,8 +11,6 @@ import { NodeSimilarityService, NodeSuggestion } from './node-similarity-service
import { NodeTypeNormalizer } from '../utils/node-type-normalizer';
import { Logger } from '../utils/logger';
import { validateAISpecificNodes, hasAINodes } from './ai-node-validator';
import { isTriggerNode } from '../utils/node-type-utils';
import { isNonExecutableNode } from '../utils/node-classification';
const logger = new Logger({ prefix: '[WorkflowValidator]' });
interface WorkflowNode {
@@ -87,8 +85,17 @@ export class WorkflowValidator {
this.similarityService = new NodeSimilarityService(nodeRepository);
}
// Note: isStickyNote logic moved to shared utility: src/utils/node-classification.ts
// Use isNonExecutableNode(node.type) instead
/**
* Check if a node is a Sticky Note or other non-executable node
*/
private isStickyNote(node: WorkflowNode): boolean {
const stickyNoteTypes = [
'n8n-nodes-base.stickyNote',
'nodes-base.stickyNote',
'@n8n/n8n-nodes-base.stickyNote'
];
return stickyNoteTypes.includes(node.type);
}
/**
* Validate a complete workflow
@@ -139,7 +146,7 @@ export class WorkflowValidator {
}
// Update statistics after null check (exclude sticky notes from counts)
const executableNodes = Array.isArray(workflow.nodes) ? workflow.nodes.filter(n => !isNonExecutableNode(n.type)) : [];
const executableNodes = Array.isArray(workflow.nodes) ? workflow.nodes.filter(n => !this.isStickyNote(n)) : [];
result.statistics.totalNodes = executableNodes.length;
result.statistics.enabledNodes = executableNodes.filter(n => !n.disabled).length;
@@ -319,8 +326,16 @@ export class WorkflowValidator {
nodeIds.add(node.id);
}
// Count trigger nodes using shared trigger detection
const triggerNodes = workflow.nodes.filter(n => isTriggerNode(n.type));
// Count trigger nodes - normalize type names first
const triggerNodes = workflow.nodes.filter(n => {
const normalizedType = NodeTypeNormalizer.normalizeToFullForm(n.type);
const lowerType = normalizedType.toLowerCase();
return lowerType.includes('trigger') ||
(lowerType.includes('webhook') && !lowerType.includes('respond')) ||
normalizedType === 'nodes-base.start' ||
normalizedType === 'nodes-base.manualTrigger' ||
normalizedType === 'nodes-base.formTrigger';
});
result.statistics.triggerNodes = triggerNodes.length;
// Check for at least one trigger node
@@ -341,7 +356,7 @@ export class WorkflowValidator {
profile: string
): Promise<void> {
for (const node of workflow.nodes) {
if (node.disabled || isNonExecutableNode(node.type)) continue;
if (node.disabled || this.isStickyNote(node)) continue;
try {
// Validate node name length
@@ -617,12 +632,16 @@ export class WorkflowValidator {
// Check for orphaned nodes (exclude sticky notes)
for (const node of workflow.nodes) {
if (node.disabled || isNonExecutableNode(node.type)) continue;
if (node.disabled || this.isStickyNote(node)) continue;
// Use shared trigger detection function for consistency
const isNodeTrigger = isTriggerNode(node.type);
if (!connectedNodes.has(node.name) && !isNodeTrigger) {
const normalizedType = NodeTypeNormalizer.normalizeToFullForm(node.type);
const isTrigger = normalizedType.toLowerCase().includes('trigger') ||
normalizedType.toLowerCase().includes('webhook') ||
normalizedType === 'nodes-base.start' ||
normalizedType === 'nodes-base.manualTrigger' ||
normalizedType === 'nodes-base.formTrigger';
if (!connectedNodes.has(node.name) && !isTrigger) {
result.warnings.push({
type: 'warning',
nodeId: node.id,
@@ -858,7 +877,7 @@ export class WorkflowValidator {
// Build node type map (exclude sticky notes)
workflow.nodes.forEach(node => {
if (!isNonExecutableNode(node.type)) {
if (!this.isStickyNote(node)) {
nodeTypeMap.set(node.name, node.type);
}
});
@@ -926,7 +945,7 @@ export class WorkflowValidator {
// Check from all executable nodes (exclude sticky notes)
for (const node of workflow.nodes) {
if (!isNonExecutableNode(node.type) && !visited.has(node.name)) {
if (!this.isStickyNote(node) && !visited.has(node.name)) {
if (hasCycleDFS(node.name)) return true;
}
}
@@ -945,7 +964,7 @@ export class WorkflowValidator {
const nodeNames = workflow.nodes.map(n => n.name);
for (const node of workflow.nodes) {
if (node.disabled || isNonExecutableNode(node.type)) continue;
if (node.disabled || this.isStickyNote(node)) continue;
// Skip expression validation for langchain nodes
// They have AI-specific validators and different expression rules
@@ -1092,7 +1111,7 @@ export class WorkflowValidator {
// Check node-level error handling properties for ALL executable nodes
for (const node of workflow.nodes) {
if (!isNonExecutableNode(node.type)) {
if (!this.isStickyNote(node)) {
this.checkNodeErrorHandling(node, workflow, result);
}
}

View File

@@ -1,121 +0,0 @@
/**
* Node Classification Utilities
*
* Provides shared classification logic for workflow nodes.
* Used by validators to consistently identify node types across the codebase.
*
* This module centralizes node type classification to ensure consistent behavior
* between WorkflowValidator and n8n-validation.ts, preventing bugs like sticky
* notes being incorrectly flagged as disconnected nodes.
*/
import { isTriggerNode as isTriggerNodeImpl } from './node-type-utils';
/**
* Check if a node type is a sticky note (documentation-only node)
*
* Sticky notes are UI-only annotation nodes that:
* - Do not participate in workflow execution
* - Never have connections (by design)
* - Should be excluded from connection validation
* - Serve purely as visual documentation in the workflow canvas
*
* Example sticky note types:
* - 'n8n-nodes-base.stickyNote' (standard format)
* - 'nodes-base.stickyNote' (normalized format)
* - '@n8n/n8n-nodes-base.stickyNote' (scoped format)
*
* @param nodeType - The node type to check (e.g., 'n8n-nodes-base.stickyNote')
* @returns true if the node is a sticky note, false otherwise
*/
export function isStickyNote(nodeType: string): boolean {
const stickyNoteTypes = [
'n8n-nodes-base.stickyNote',
'nodes-base.stickyNote',
'@n8n/n8n-nodes-base.stickyNote'
];
return stickyNoteTypes.includes(nodeType);
}
/**
* Check if a node type is a trigger node
*
* This function delegates to the comprehensive trigger detection implementation
* in node-type-utils.ts which supports 200+ trigger types using flexible
* pattern matching instead of a hardcoded list.
*
* Trigger nodes:
* - Start workflow execution
* - Only need outgoing connections (no incoming connections required)
* - Include webhooks, manual triggers, schedule triggers, email triggers, etc.
* - Are the entry points for workflow execution
*
* Examples:
* - Webhooks: Listen for HTTP requests
* - Manual triggers: Started manually by user
* - Schedule/Cron triggers: Run on a schedule
* - Execute Workflow Trigger: Invoked by other workflows
*
* @param nodeType - The node type to check
* @returns true if the node is a trigger, false otherwise
*/
export function isTriggerNode(nodeType: string): boolean {
return isTriggerNodeImpl(nodeType);
}
/**
* Check if a node type is non-executable (UI-only)
*
* Non-executable nodes:
* - Do not participate in workflow execution
* - Serve documentation/annotation purposes only
* - Should be excluded from all execution-related validation
* - Should be excluded from statistics like "total executable nodes"
* - Should be excluded from connection validation
*
* Currently includes: sticky notes
*
* Future: May include other annotation/comment nodes if n8n adds them
*
* @param nodeType - The node type to check
* @returns true if the node is non-executable, false otherwise
*/
export function isNonExecutableNode(nodeType: string): boolean {
return isStickyNote(nodeType);
// Future: Add other non-executable node types here
// Example: || isCommentNode(nodeType) || isAnnotationNode(nodeType)
}
/**
* Check if a node type requires incoming connections
*
* Most nodes require at least one incoming connection to receive data,
* but there are two categories of exceptions:
*
* 1. Trigger nodes: Only need outgoing connections
* - They start workflow execution
* - They generate their own data
* - Examples: webhook, manualTrigger, scheduleTrigger
*
* 2. Non-executable nodes: Don't need any connections
* - They are UI-only annotations
* - They don't participate in execution
* - Examples: stickyNote
*
* @param nodeType - The node type to check
* @returns true if the node requires incoming connections, false otherwise
*/
export function requiresIncomingConnection(nodeType: string): boolean {
// Non-executable nodes don't need any connections
if (isNonExecutableNode(nodeType)) {
return false;
}
// Trigger nodes only need outgoing connections
if (isTriggerNode(nodeType)) {
return false;
}
// Regular nodes need incoming connections
return true;
}

View File

@@ -140,116 +140,4 @@ export function getNodeTypeVariations(type: string): string[] {
// Remove duplicates while preserving order
return [...new Set(variations)];
}
/**
* Check if a node is ANY type of trigger (including executeWorkflowTrigger)
*
* This function determines if a node can start a workflow execution.
* Returns true for:
* - Webhook triggers (webhook, webhookTrigger)
* - Time-based triggers (schedule, cron)
* - Poll-based triggers (emailTrigger, slackTrigger, etc.)
* - Manual triggers (manualTrigger, start, formTrigger)
* - Sub-workflow triggers (executeWorkflowTrigger)
*
* Used for: Disconnection validation (triggers don't need incoming connections)
*
* @param nodeType - The node type to check (e.g., "n8n-nodes-base.executeWorkflowTrigger")
* @returns true if node is any type of trigger
*/
export function isTriggerNode(nodeType: string): boolean {
const normalized = normalizeNodeType(nodeType);
const lowerType = normalized.toLowerCase();
// Check for trigger pattern in node type name
if (lowerType.includes('trigger')) {
return true;
}
// Check for webhook nodes (excluding respondToWebhook which is NOT a trigger)
if (lowerType.includes('webhook') && !lowerType.includes('respond')) {
return true;
}
// Check for specific trigger types that don't have 'trigger' in their name
const specificTriggers = [
'nodes-base.start',
'nodes-base.manualTrigger',
'nodes-base.formTrigger'
];
return specificTriggers.includes(normalized);
}
/**
* Check if a node is an ACTIVATABLE trigger (excludes executeWorkflowTrigger)
*
* This function determines if a node can be used to activate a workflow.
* Returns true for:
* - Webhook triggers (webhook, webhookTrigger)
* - Time-based triggers (schedule, cron)
* - Poll-based triggers (emailTrigger, slackTrigger, etc.)
* - Manual triggers (manualTrigger, start, formTrigger)
*
* Returns FALSE for:
* - executeWorkflowTrigger (can only be invoked by other workflows)
*
* Used for: Activation validation (active workflows need activatable triggers)
*
* @param nodeType - The node type to check
* @returns true if node can activate a workflow
*/
export function isActivatableTrigger(nodeType: string): boolean {
const normalized = normalizeNodeType(nodeType);
const lowerType = normalized.toLowerCase();
// executeWorkflowTrigger cannot activate a workflow (invoked by other workflows)
if (lowerType.includes('executeworkflow')) {
return false;
}
// All other triggers can activate workflows
return isTriggerNode(nodeType);
}
/**
* Get human-readable description of trigger type
*
* @param nodeType - The node type
* @returns Description of what triggers this node
*/
export function getTriggerTypeDescription(nodeType: string): string {
const normalized = normalizeNodeType(nodeType);
const lowerType = normalized.toLowerCase();
if (lowerType.includes('executeworkflow')) {
return 'Execute Workflow Trigger (invoked by other workflows)';
}
if (lowerType.includes('webhook')) {
return 'Webhook Trigger (HTTP requests)';
}
if (lowerType.includes('schedule') || lowerType.includes('cron')) {
return 'Schedule Trigger (time-based)';
}
if (lowerType.includes('manual') || normalized === 'nodes-base.start') {
return 'Manual Trigger (manual execution)';
}
if (lowerType.includes('email') || lowerType.includes('imap') || lowerType.includes('gmail')) {
return 'Email Trigger (polling)';
}
if (lowerType.includes('form')) {
return 'Form Trigger (form submissions)';
}
if (lowerType.includes('trigger')) {
return 'Trigger (event-based)';
}
return 'Unknown trigger type';
}

View File

@@ -205,20 +205,9 @@ describe.skipIf(!dbExists)('Database Content Validation', () => {
it('MUST have FTS5 index properly ranked', () => {
const results = db.prepare(`
SELECT
n.node_type,
rank
FROM nodes n
JOIN nodes_fts ON n.rowid = nodes_fts.rowid
SELECT node_type, rank FROM nodes_fts
WHERE nodes_fts MATCH 'webhook'
ORDER BY
CASE
WHEN LOWER(n.display_name) = LOWER('webhook') THEN 0
WHEN LOWER(n.display_name) LIKE LOWER('%webhook%') THEN 1
WHEN LOWER(n.node_type) LIKE LOWER('%webhook%') THEN 2
ELSE 3
END,
rank
ORDER BY rank
LIMIT 5
`).all();
@@ -226,7 +215,7 @@ describe.skipIf(!dbExists)('Database Content Validation', () => {
'CRITICAL: FTS5 ranking not working. Search quality will be degraded.'
).toBeGreaterThan(0);
// Exact match should be in top results (using production boosting logic with CASE-first ordering)
// Exact match should be in top results
const topNodes = results.slice(0, 3).map((r: any) => r.node_type);
expect(topNodes,
'WARNING: Exact match "nodes-base.webhook" not in top 3 ranked results'

View File

@@ -136,25 +136,14 @@ describe('Node FTS5 Search Integration Tests', () => {
describe('FTS5 Search Quality', () => {
it('should rank exact matches higher', () => {
const results = db.prepare(`
SELECT
n.node_type,
rank
FROM nodes n
JOIN nodes_fts ON n.rowid = nodes_fts.rowid
SELECT node_type, rank FROM nodes_fts
WHERE nodes_fts MATCH 'webhook'
ORDER BY
CASE
WHEN LOWER(n.display_name) = LOWER('webhook') THEN 0
WHEN LOWER(n.display_name) LIKE LOWER('%webhook%') THEN 1
WHEN LOWER(n.node_type) LIKE LOWER('%webhook%') THEN 2
ELSE 3
END,
rank
ORDER BY rank
LIMIT 10
`).all();
expect(results.length).toBeGreaterThan(0);
// Exact match should be in top results (using production boosting logic with CASE-first ordering)
// Exact match should be in top results
const topResults = results.slice(0, 3).map((r: any) => r.node_type);
expect(topResults).toContain('nodes-base.webhook');
});

View File

@@ -1,722 +0,0 @@
/**
* Integration tests for AI node connection validation in workflow diff operations
* Tests that AI nodes with AI-specific connection types (ai_languageModel, ai_memory, etc.)
* are properly validated without requiring main connections
*
* Related to issue #357
*/
import { describe, test, expect } from 'vitest';
import { WorkflowDiffEngine } from '../../../src/services/workflow-diff-engine';
describe('AI Node Connection Validation', () => {
describe('AI-specific connection types', () => {
test('should accept workflow with ai_languageModel connections', async () => {
const workflow = {
id: 'test-workflow',
name: 'AI Language Model Test',
nodes: [
{
id: 'agent-node',
name: 'AI Agent',
type: '@n8n/n8n-nodes-langchain.agent',
typeVersion: 1,
position: [0, 0],
parameters: {}
},
{
id: 'llm-node',
name: 'OpenAI Chat Model',
type: '@n8n/n8n-nodes-langchain.lmChatOpenAi',
typeVersion: 1,
position: [200, 0],
parameters: {}
}
],
connections: {
'OpenAI Chat Model': {
ai_languageModel: [
[{ node: 'AI Agent', type: 'ai_languageModel', index: 0 }]
]
}
}
};
const engine = new WorkflowDiffEngine();
const result = await engine.applyDiff(workflow as any, {
id: workflow.id,
operations: []
});
expect(result.success).toBe(true);
expect(result.workflow).toBeDefined();
});
test('should accept workflow with ai_memory connections', async () => {
const workflow = {
id: 'test-workflow',
name: 'AI Memory Test',
nodes: [
{
id: 'agent-node',
name: 'AI Agent',
type: '@n8n/n8n-nodes-langchain.agent',
typeVersion: 1,
position: [0, 0],
parameters: {}
},
{
id: 'memory-node',
name: 'Postgres Chat Memory',
type: '@n8n/n8n-nodes-langchain.memoryPostgresChat',
typeVersion: 1,
position: [200, 0],
parameters: {}
}
],
connections: {
'Postgres Chat Memory': {
ai_memory: [
[{ node: 'AI Agent', type: 'ai_memory', index: 0 }]
]
}
}
};
const engine = new WorkflowDiffEngine();
const result = await engine.applyDiff(workflow as any, {
id: workflow.id,
operations: []
});
expect(result.success).toBe(true);
expect(result.workflow).toBeDefined();
});
test('should accept workflow with ai_embedding connections', async () => {
const workflow = {
id: 'test-workflow',
name: 'AI Embedding Test',
nodes: [
{
id: 'vectorstore-node',
name: 'Vector Store',
type: '@n8n/n8n-nodes-langchain.vectorStoreSupabase',
typeVersion: 1,
position: [0, 0],
parameters: {}
},
{
id: 'embedding-node',
name: 'Embeddings OpenAI',
type: '@n8n/n8n-nodes-langchain.embeddingsOpenAi',
typeVersion: 1,
position: [200, 0],
parameters: {}
}
],
connections: {
'Embeddings OpenAI': {
ai_embedding: [
[{ node: 'Vector Store', type: 'ai_embedding', index: 0 }]
]
}
}
};
const engine = new WorkflowDiffEngine();
const result = await engine.applyDiff(workflow as any, {
id: workflow.id,
operations: []
});
expect(result.success).toBe(true);
expect(result.workflow).toBeDefined();
});
test('should accept workflow with ai_tool connections', async () => {
const workflow = {
id: 'test-workflow',
name: 'AI Tool Test',
nodes: [
{
id: 'agent-node',
name: 'AI Agent',
type: '@n8n/n8n-nodes-langchain.agent',
typeVersion: 1,
position: [0, 0],
parameters: {}
},
{
id: 'vectorstore-node',
name: 'Vector Store Tool',
type: '@n8n/n8n-nodes-langchain.vectorStoreSupabase',
typeVersion: 1,
position: [200, 0],
parameters: {}
}
],
connections: {
'Vector Store Tool': {
ai_tool: [
[{ node: 'AI Agent', type: 'ai_tool', index: 0 }]
]
}
}
};
const engine = new WorkflowDiffEngine();
const result = await engine.applyDiff(workflow as any, {
id: workflow.id,
operations: []
});
expect(result.success).toBe(true);
expect(result.workflow).toBeDefined();
});
test('should accept workflow with ai_vectorStore connections', async () => {
const workflow = {
id: 'test-workflow',
name: 'AI Vector Store Test',
nodes: [
{
id: 'agent-node',
name: 'AI Agent',
type: '@n8n/n8n-nodes-langchain.agent',
typeVersion: 1,
position: [0, 0],
parameters: {}
},
{
id: 'vectorstore-node',
name: 'Supabase Vector Store',
type: '@n8n/n8n-nodes-langchain.vectorStoreSupabase',
typeVersion: 1,
position: [200, 0],
parameters: {}
}
],
connections: {
'Supabase Vector Store': {
ai_vectorStore: [
[{ node: 'AI Agent', type: 'ai_vectorStore', index: 0 }]
]
}
}
};
const engine = new WorkflowDiffEngine();
const result = await engine.applyDiff(workflow as any, {
id: workflow.id,
operations: []
});
expect(result.success).toBe(true);
expect(result.workflow).toBeDefined();
});
});
describe('Mixed connection types', () => {
test('should accept workflow mixing main and AI connections', async () => {
const workflow = {
id: 'test-workflow',
name: 'Mixed Connections Test',
nodes: [
{
id: 'webhook-node',
name: 'Webhook',
type: 'n8n-nodes-base.webhook',
typeVersion: 1,
position: [0, 0],
parameters: {}
},
{
id: 'agent-node',
name: 'AI Agent',
type: '@n8n/n8n-nodes-langchain.agent',
typeVersion: 1,
position: [200, 0],
parameters: {}
},
{
id: 'llm-node',
name: 'OpenAI Chat Model',
type: '@n8n/n8n-nodes-langchain.lmChatOpenAi',
typeVersion: 1,
position: [200, 200],
parameters: {}
},
{
id: 'respond-node',
name: 'Respond to Webhook',
type: 'n8n-nodes-base.respondToWebhook',
typeVersion: 1,
position: [400, 0],
parameters: {}
}
],
connections: {
'Webhook': {
main: [
[{ node: 'AI Agent', type: 'main', index: 0 }]
]
},
'AI Agent': {
main: [
[{ node: 'Respond to Webhook', type: 'main', index: 0 }]
]
},
'OpenAI Chat Model': {
ai_languageModel: [
[{ node: 'AI Agent', type: 'ai_languageModel', index: 0 }]
]
}
}
};
const engine = new WorkflowDiffEngine();
const result = await engine.applyDiff(workflow as any, {
id: workflow.id,
operations: []
});
expect(result.success).toBe(true);
expect(result.workflow).toBeDefined();
});
test('should accept workflow with error connections alongside AI connections', async () => {
const workflow = {
id: 'test-workflow',
name: 'Error + AI Connections Test',
nodes: [
{
id: 'webhook-node',
name: 'Webhook',
type: 'n8n-nodes-base.webhook',
typeVersion: 1,
position: [0, 0],
parameters: {}
},
{
id: 'agent-node',
name: 'AI Agent',
type: '@n8n/n8n-nodes-langchain.agent',
typeVersion: 1,
position: [200, 0],
parameters: {}
},
{
id: 'llm-node',
name: 'OpenAI Chat Model',
type: '@n8n/n8n-nodes-langchain.lmChatOpenAi',
typeVersion: 1,
position: [200, 200],
parameters: {}
},
{
id: 'error-handler',
name: 'Error Handler',
type: 'n8n-nodes-base.set',
typeVersion: 1,
position: [200, -200],
parameters: {}
}
],
connections: {
'Webhook': {
main: [
[{ node: 'AI Agent', type: 'main', index: 0 }]
]
},
'AI Agent': {
error: [
[{ node: 'Error Handler', type: 'main', index: 0 }]
]
},
'OpenAI Chat Model': {
ai_languageModel: [
[{ node: 'AI Agent', type: 'ai_languageModel', index: 0 }]
]
}
}
};
const engine = new WorkflowDiffEngine();
const result = await engine.applyDiff(workflow as any, {
id: workflow.id,
operations: []
});
expect(result.success).toBe(true);
expect(result.workflow).toBeDefined();
});
});
describe('Complex AI workflow (Issue #357 scenario)', () => {
test('should accept full AI agent workflow with RAG components', async () => {
// Simplified version of the workflow from issue #357
const workflow = {
id: 'test-workflow',
name: 'AI Agent with RAG',
nodes: [
{
id: 'webhook-node',
name: 'Webhook',
type: 'n8n-nodes-base.webhook',
typeVersion: 2,
position: [0, 0],
parameters: {}
},
{
id: 'code-node',
name: 'Prepare Inputs',
type: 'n8n-nodes-base.code',
typeVersion: 2,
position: [200, 0],
parameters: {}
},
{
id: 'agent-node',
name: 'AI Agent',
type: '@n8n/n8n-nodes-langchain.agent',
typeVersion: 1.7,
position: [400, 0],
parameters: {}
},
{
id: 'llm-node',
name: 'OpenAI Chat Model',
type: '@n8n/n8n-nodes-langchain.lmChatOpenAi',
typeVersion: 1,
position: [400, 200],
parameters: {}
},
{
id: 'memory-node',
name: 'Postgres Chat Memory',
type: '@n8n/n8n-nodes-langchain.memoryPostgresChat',
typeVersion: 1.1,
position: [500, 200],
parameters: {}
},
{
id: 'embedding-node',
name: 'Embeddings OpenAI',
type: '@n8n/n8n-nodes-langchain.embeddingsOpenAi',
typeVersion: 1,
position: [600, 400],
parameters: {}
},
{
id: 'vectorstore-node',
name: 'Supabase Vector Store',
type: '@n8n/n8n-nodes-langchain.vectorStoreSupabase',
typeVersion: 1.3,
position: [600, 200],
parameters: {}
},
{
id: 'respond-node',
name: 'Respond to Webhook',
type: 'n8n-nodes-base.respondToWebhook',
typeVersion: 1.1,
position: [600, 0],
parameters: {}
}
],
connections: {
'Webhook': {
main: [
[{ node: 'Prepare Inputs', type: 'main', index: 0 }]
]
},
'Prepare Inputs': {
main: [
[{ node: 'AI Agent', type: 'main', index: 0 }]
]
},
'AI Agent': {
main: [
[{ node: 'Respond to Webhook', type: 'main', index: 0 }]
]
},
'OpenAI Chat Model': {
ai_languageModel: [
[{ node: 'AI Agent', type: 'ai_languageModel', index: 0 }]
]
},
'Postgres Chat Memory': {
ai_memory: [
[{ node: 'AI Agent', type: 'ai_memory', index: 0 }]
]
},
'Embeddings OpenAI': {
ai_embedding: [
[{ node: 'Supabase Vector Store', type: 'ai_embedding', index: 0 }]
]
},
'Supabase Vector Store': {
ai_tool: [
[{ node: 'AI Agent', type: 'ai_tool', index: 0 }]
]
}
}
};
const engine = new WorkflowDiffEngine();
const result = await engine.applyDiff(workflow as any, {
id: workflow.id,
operations: []
});
expect(result.success).toBe(true);
expect(result.workflow).toBeDefined();
expect(result.errors || []).toHaveLength(0);
});
test('should successfully update AI workflow nodes without connection errors', async () => {
// Test that we can update nodes in an AI workflow without triggering validation errors
const workflow = {
id: 'test-workflow',
name: 'AI Workflow Update Test',
nodes: [
{
id: 'webhook-node',
name: 'Webhook',
type: 'n8n-nodes-base.webhook',
typeVersion: 2,
position: [0, 0],
parameters: { path: 'test' }
},
{
id: 'agent-node',
name: 'AI Agent',
type: '@n8n/n8n-nodes-langchain.agent',
typeVersion: 1,
position: [200, 0],
parameters: {}
},
{
id: 'llm-node',
name: 'OpenAI Chat Model',
type: '@n8n/n8n-nodes-langchain.lmChatOpenAi',
typeVersion: 1,
position: [200, 200],
parameters: {}
}
],
connections: {
'Webhook': {
main: [
[{ node: 'AI Agent', type: 'main', index: 0 }]
]
},
'OpenAI Chat Model': {
ai_languageModel: [
[{ node: 'AI Agent', type: 'ai_languageModel', index: 0 }]
]
}
}
};
const engine = new WorkflowDiffEngine();
// Update the webhook node (unrelated to AI nodes)
const result = await engine.applyDiff(workflow as any, {
id: workflow.id,
operations: [
{
type: 'updateNode',
nodeId: 'webhook-node',
updates: {
notes: 'Updated webhook configuration'
}
}
]
});
expect(result.success).toBe(true);
expect(result.workflow).toBeDefined();
expect(result.errors || []).toHaveLength(0);
// Verify the update was applied
const updatedNode = result.workflow.nodes.find((n: any) => n.id === 'webhook-node');
expect(updatedNode?.notes).toBe('Updated webhook configuration');
});
});
describe('Node-only AI nodes (no main connections)', () => {
test('should accept AI nodes with ONLY ai_languageModel connections', async () => {
const workflow = {
id: 'test-workflow',
name: 'AI Node Without Main',
nodes: [
{
id: 'agent-node',
name: 'AI Agent',
type: '@n8n/n8n-nodes-langchain.agent',
typeVersion: 1,
position: [0, 0],
parameters: {}
},
{
id: 'llm-node',
name: 'OpenAI Chat Model',
type: '@n8n/n8n-nodes-langchain.lmChatOpenAi',
typeVersion: 1,
position: [200, 0],
parameters: {}
}
],
connections: {
// OpenAI Chat Model has NO main connections, ONLY ai_languageModel
'OpenAI Chat Model': {
ai_languageModel: [
[{ node: 'AI Agent', type: 'ai_languageModel', index: 0 }]
]
}
}
};
const engine = new WorkflowDiffEngine();
const result = await engine.applyDiff(workflow as any, {
id: workflow.id,
operations: []
});
expect(result.success).toBe(true);
expect(result.workflow).toBeDefined();
expect(result.errors || []).toHaveLength(0);
});
test('should accept AI nodes with ONLY ai_memory connections', async () => {
const workflow = {
id: 'test-workflow',
name: 'Memory Node Without Main',
nodes: [
{
id: 'agent-node',
name: 'AI Agent',
type: '@n8n/n8n-nodes-langchain.agent',
typeVersion: 1,
position: [0, 0],
parameters: {}
},
{
id: 'memory-node',
name: 'Postgres Chat Memory',
type: '@n8n/n8n-nodes-langchain.memoryPostgresChat',
typeVersion: 1,
position: [200, 0],
parameters: {}
}
],
connections: {
// Memory node has NO main connections, ONLY ai_memory
'Postgres Chat Memory': {
ai_memory: [
[{ node: 'AI Agent', type: 'ai_memory', index: 0 }]
]
}
}
};
const engine = new WorkflowDiffEngine();
const result = await engine.applyDiff(workflow as any, {
id: workflow.id,
operations: []
});
expect(result.success).toBe(true);
expect(result.workflow).toBeDefined();
expect(result.errors || []).toHaveLength(0);
});
test('should accept embedding nodes with ONLY ai_embedding connections', async () => {
const workflow = {
id: 'test-workflow',
name: 'Embedding Node Without Main',
nodes: [
{
id: 'vectorstore-node',
name: 'Vector Store',
type: '@n8n/n8n-nodes-langchain.vectorStoreSupabase',
typeVersion: 1,
position: [0, 0],
parameters: {}
},
{
id: 'embedding-node',
name: 'Embeddings OpenAI',
type: '@n8n/n8n-nodes-langchain.embeddingsOpenAi',
typeVersion: 1,
position: [200, 0],
parameters: {}
}
],
connections: {
// Embedding node has NO main connections, ONLY ai_embedding
'Embeddings OpenAI': {
ai_embedding: [
[{ node: 'Vector Store', type: 'ai_embedding', index: 0 }]
]
}
}
};
const engine = new WorkflowDiffEngine();
const result = await engine.applyDiff(workflow as any, {
id: workflow.id,
operations: []
});
expect(result.success).toBe(true);
expect(result.workflow).toBeDefined();
expect(result.errors || []).toHaveLength(0);
});
test('should accept vector store nodes with ONLY ai_tool connections', async () => {
const workflow = {
id: 'test-workflow',
name: 'Vector Store Node Without Main',
nodes: [
{
id: 'agent-node',
name: 'AI Agent',
type: '@n8n/n8n-nodes-langchain.agent',
typeVersion: 1,
position: [0, 0],
parameters: {}
},
{
id: 'vectorstore-node',
name: 'Supabase Vector Store',
type: '@n8n/n8n-nodes-langchain.vectorStoreSupabase',
typeVersion: 1,
position: [200, 0],
parameters: {}
}
],
connections: {
// Vector store has NO main connections, ONLY ai_tool
'Supabase Vector Store': {
ai_tool: [
[{ node: 'AI Agent', type: 'ai_tool', index: 0 }]
]
}
}
};
const engine = new WorkflowDiffEngine();
const result = await engine.applyDiff(workflow as any, {
id: workflow.id,
operations: []
});
expect(result.success).toBe(true);
expect(result.workflow).toBeDefined();
expect(result.errors || []).toHaveLength(0);
});
});
});

View File

@@ -1,573 +0,0 @@
/**
* Integration tests for auto-update connection references on node rename
* Tests real-world workflow scenarios from Issue #353
*/
import { describe, it, expect, beforeEach } from 'vitest';
import { WorkflowDiffEngine } from '@/services/workflow-diff-engine';
import { validateWorkflowStructure } from '@/services/n8n-validation';
import { WorkflowDiffRequest, UpdateNodeOperation } from '@/types/workflow-diff';
import { Workflow, WorkflowNode } from '@/types/n8n-api';
describe('WorkflowDiffEngine - Node Rename Integration Tests', () => {
let diffEngine: WorkflowDiffEngine;
beforeEach(() => {
diffEngine = new WorkflowDiffEngine();
});
describe('Real-world API endpoint workflow (Issue #353 scenario)', () => {
let apiWorkflow: Workflow;
beforeEach(() => {
// Complex real-world API endpoint workflow
apiWorkflow = {
id: 'api-workflow',
name: 'POST /patients/:id/approaches - Add Approach',
nodes: [
{
id: 'webhook-trigger',
name: 'Webhook',
type: 'n8n-nodes-base.webhook',
typeVersion: 2,
position: [0, 0],
parameters: {
path: 'patients/{{$parameter["id"]/approaches',
httpMethod: 'POST',
responseMode: 'responseNode'
}
},
{
id: 'validate-request',
name: 'Validate Request',
type: 'n8n-nodes-base.code',
typeVersion: 2,
position: [200, 0],
parameters: {
mode: 'runOnceForAllItems',
jsCode: '// Validation logic'
}
},
{
id: 'check-auth',
name: 'Check Authorization',
type: 'n8n-nodes-base.if',
typeVersion: 2,
position: [400, 0],
parameters: {
conditions: {
boolean: [{ value1: '={{$json.authorized}}', value2: true }]
}
}
},
{
id: 'process-request',
name: 'Process Request',
type: 'n8n-nodes-base.code',
typeVersion: 2,
position: [600, 0],
parameters: {
mode: 'runOnceForAllItems',
jsCode: '// Processing logic'
}
},
{
id: 'return-success',
name: 'Return 200 OK',
type: 'n8n-nodes-base.respondToWebhook',
typeVersion: 1.1,
position: [800, 0],
parameters: {
responseBody: '={{ {"success": true, "data": $json} }}',
options: { responseCode: 200 }
}
},
{
id: 'return-forbidden',
name: 'Return 403 Forbidden1',
type: 'n8n-nodes-base.respondToWebhook',
typeVersion: 1.1,
position: [600, 200],
parameters: {
responseBody: '={{ {"error": "Forbidden"} }}',
options: { responseCode: 403 }
}
},
{
id: 'handle-error',
name: 'Handle Error',
type: 'n8n-nodes-base.code',
typeVersion: 2,
position: [400, 300],
parameters: {
mode: 'runOnceForAllItems',
jsCode: '// Error handling'
}
},
{
id: 'return-error',
name: 'Return 500 Error',
type: 'n8n-nodes-base.respondToWebhook',
typeVersion: 1.1,
position: [600, 300],
parameters: {
responseBody: '={{ {"error": "Internal Server Error"} }}',
options: { responseCode: 500 }
}
}
],
connections: {
'Webhook': {
main: [[{ node: 'Validate Request', type: 'main', index: 0 }]]
},
'Validate Request': {
main: [[{ node: 'Check Authorization', type: 'main', index: 0 }]],
error: [[{ node: 'Handle Error', type: 'main', index: 0 }]]
},
'Check Authorization': {
main: [
[{ node: 'Process Request', type: 'main', index: 0 }], // true branch
[{ node: 'Return 403 Forbidden1', type: 'main', index: 0 }] // false branch
],
error: [[{ node: 'Handle Error', type: 'main', index: 0 }]]
},
'Process Request': {
main: [[{ node: 'Return 200 OK', type: 'main', index: 0 }]],
error: [[{ node: 'Handle Error', type: 'main', index: 0 }]]
},
'Handle Error': {
main: [[{ node: 'Return 500 Error', type: 'main', index: 0 }]]
}
}
};
});
it('should successfully rename error response node and maintain all connections', async () => {
// The exact operation from Issue #353
const operation: UpdateNodeOperation = {
type: 'updateNode',
nodeId: 'return-forbidden',
updates: {
name: 'Return 404 Not Found',
parameters: {
responseBody: '={{ {"error": "Not Found"} }}',
options: { responseCode: 404 }
}
}
};
const request: WorkflowDiffRequest = {
id: 'api-workflow',
operations: [operation]
};
const result = await diffEngine.applyDiff(apiWorkflow, request);
// Should succeed
expect(result.success).toBe(true);
expect(result.workflow).toBeDefined();
// Node should be renamed
const renamedNode = result.workflow!.nodes.find((n: WorkflowNode) => n.id === 'return-forbidden');
expect(renamedNode?.name).toBe('Return 404 Not Found');
expect(renamedNode?.parameters.options?.responseCode).toBe(404);
// Connection from IF node should be updated
expect(result.workflow!.connections['Check Authorization'].main[1][0].node).toBe('Return 404 Not Found');
// Validate workflow structure
const validationErrors = validateWorkflowStructure(result.workflow!);
expect(validationErrors).toHaveLength(0);
});
it('should handle multiple node renames in complex workflow', async () => {
const operations: UpdateNodeOperation[] = [
{
type: 'updateNode',
nodeId: 'return-forbidden',
updates: { name: 'Return 404 Not Found' }
},
{
type: 'updateNode',
nodeId: 'return-success',
updates: { name: 'Return 201 Created' }
},
{
type: 'updateNode',
nodeId: 'return-error',
updates: { name: 'Return 500 Internal Server Error' }
}
];
const request: WorkflowDiffRequest = {
id: 'api-workflow',
operations
};
const result = await diffEngine.applyDiff(apiWorkflow, request);
expect(result.success).toBe(true);
expect(result.workflow).toBeDefined();
// All nodes should be renamed
expect(result.workflow!.nodes.find((n: WorkflowNode) => n.id === 'return-forbidden')?.name).toBe('Return 404 Not Found');
expect(result.workflow!.nodes.find((n: WorkflowNode) => n.id === 'return-success')?.name).toBe('Return 201 Created');
expect(result.workflow!.nodes.find((n: WorkflowNode) => n.id === 'return-error')?.name).toBe('Return 500 Internal Server Error');
// All connections should be updated
expect(result.workflow!.connections['Check Authorization'].main[1][0].node).toBe('Return 404 Not Found');
expect(result.workflow!.connections['Process Request'].main[0][0].node).toBe('Return 201 Created');
expect(result.workflow!.connections['Handle Error'].main[0][0].node).toBe('Return 500 Internal Server Error');
// Validate entire workflow structure
const validationErrors = validateWorkflowStructure(result.workflow!);
expect(validationErrors).toHaveLength(0);
});
it('should maintain error connections after rename', async () => {
const operation: UpdateNodeOperation = {
type: 'updateNode',
nodeId: 'validate-request',
updates: { name: 'Validate Input' }
};
const request: WorkflowDiffRequest = {
id: 'api-workflow',
operations: [operation]
};
const result = await diffEngine.applyDiff(apiWorkflow, request);
expect(result.success).toBe(true);
expect(result.workflow).toBeDefined();
// Main connection should be updated
expect(result.workflow!.connections['Validate Input']).toBeDefined();
expect(result.workflow!.connections['Validate Input'].main[0][0].node).toBe('Check Authorization');
// Error connection should also be updated
expect(result.workflow!.connections['Validate Input'].error[0][0].node).toBe('Handle Error');
// Validate workflow structure
const validationErrors = validateWorkflowStructure(result.workflow!);
expect(validationErrors).toHaveLength(0);
});
});
describe('AI Agent workflow with tool connections', () => {
let aiWorkflow: Workflow;
beforeEach(() => {
aiWorkflow = {
id: 'ai-workflow',
name: 'AI Customer Support Agent',
nodes: [
{
id: 'webhook-1',
name: 'Customer Query',
type: 'n8n-nodes-base.webhook',
typeVersion: 2,
position: [0, 0],
parameters: { path: 'support', httpMethod: 'POST' }
},
{
id: 'agent-1',
name: 'Support Agent',
type: '@n8n/n8n-nodes-langchain.agent',
typeVersion: 1,
position: [200, 0],
parameters: { promptTemplate: 'Help the customer with: {{$json.query}}' }
},
{
id: 'tool-http',
name: 'Knowledge Base API',
type: '@n8n/n8n-nodes-langchain.toolHttpRequest',
typeVersion: 1,
position: [200, 100],
parameters: { url: 'https://kb.example.com/search' }
},
{
id: 'tool-code',
name: 'Custom Logic Tool',
type: '@n8n/n8n-nodes-langchain.toolCode',
typeVersion: 1,
position: [200, 200],
parameters: { code: '// Custom logic' }
},
{
id: 'response-1',
name: 'Send Response',
type: 'n8n-nodes-base.respondToWebhook',
typeVersion: 1.1,
position: [400, 0],
parameters: {}
}
],
connections: {
'Customer Query': {
main: [[{ node: 'Support Agent', type: 'main', index: 0 }]]
},
'Support Agent': {
main: [[{ node: 'Send Response', type: 'main', index: 0 }]],
ai_tool: [
[
{ node: 'Knowledge Base API', type: 'ai_tool', index: 0 },
{ node: 'Custom Logic Tool', type: 'ai_tool', index: 0 }
]
]
}
}
};
});
// SKIPPED: Pre-existing validation bug - validateWorkflowStructure() doesn't recognize
// AI connections (ai_tool, ai_languageModel, etc.) as valid, causing false positives.
// The rename feature works correctly - connections ARE updated. Validation is the issue.
// TODO: Fix validateWorkflowStructure() to check all connection types, not just 'main'
it.skip('should update AI tool connections when renaming agent', async () => {
const operation: UpdateNodeOperation = {
type: 'updateNode',
nodeId: 'agent-1',
updates: { name: 'AI Support Assistant' }
};
const request: WorkflowDiffRequest = {
id: 'ai-workflow',
operations: [operation]
};
const result = await diffEngine.applyDiff(aiWorkflow, request);
expect(result.success).toBe(true);
expect(result.workflow).toBeDefined();
// Agent should be renamed
expect(result.workflow!.nodes.find((n: WorkflowNode) => n.id === 'agent-1')?.name).toBe('AI Support Assistant');
// All connections should be updated
expect(result.workflow!.connections['AI Support Assistant']).toBeDefined();
expect(result.workflow!.connections['AI Support Assistant'].main[0][0].node).toBe('Send Response');
expect(result.workflow!.connections['AI Support Assistant'].ai_tool[0]).toHaveLength(2);
expect(result.workflow!.connections['AI Support Assistant'].ai_tool[0][0].node).toBe('Knowledge Base API');
expect(result.workflow!.connections['AI Support Assistant'].ai_tool[0][1].node).toBe('Custom Logic Tool');
// Validate workflow structure
const validationErrors = validateWorkflowStructure(result.workflow!);
expect(validationErrors).toHaveLength(0);
});
// SKIPPED: Pre-existing validation bug - validateWorkflowStructure() doesn't recognize
// AI connections (ai_tool, ai_languageModel, etc.) as valid, causing false positives.
// The rename feature works correctly - connections ARE updated. Validation is the issue.
// TODO: Fix validateWorkflowStructure() to check all connection types, not just 'main'
it.skip('should update AI tool connections when renaming tool', async () => {
const operation: UpdateNodeOperation = {
type: 'updateNode',
nodeId: 'tool-http',
updates: { name: 'Documentation Search' }
};
const request: WorkflowDiffRequest = {
id: 'ai-workflow',
operations: [operation]
};
const result = await diffEngine.applyDiff(aiWorkflow, request);
expect(result.success).toBe(true);
expect(result.workflow).toBeDefined();
// Tool should be renamed
expect(result.workflow!.nodes.find((n: WorkflowNode) => n.id === 'tool-http')?.name).toBe('Documentation Search');
// AI tool connection should reference new name
expect(result.workflow!.connections['Support Agent'].ai_tool[0][0].node).toBe('Documentation Search');
// Other tool should remain unchanged
expect(result.workflow!.connections['Support Agent'].ai_tool[0][1].node).toBe('Custom Logic Tool');
// Validate workflow structure
const validationErrors = validateWorkflowStructure(result.workflow!);
expect(validationErrors).toHaveLength(0);
});
});
describe('Multi-branch workflow with IF and Switch nodes', () => {
let multiBranchWorkflow: Workflow;
beforeEach(() => {
multiBranchWorkflow = {
id: 'multi-branch-workflow',
name: 'Order Processing Workflow',
nodes: [
{
id: 'webhook-1',
name: 'New Order',
type: 'n8n-nodes-base.webhook',
typeVersion: 2,
position: [0, 0],
parameters: {}
},
{
id: 'if-1',
name: 'Check Payment Status',
type: 'n8n-nodes-base.if',
typeVersion: 2,
position: [200, 0],
parameters: {}
},
{
id: 'switch-1',
name: 'Route by Order Type',
type: 'n8n-nodes-base.switch',
typeVersion: 3,
position: [400, 0],
parameters: {}
},
{
id: 'process-digital',
name: 'Process Digital Order',
type: 'n8n-nodes-base.code',
typeVersion: 2,
position: [600, 0],
parameters: {}
},
{
id: 'process-physical',
name: 'Process Physical Order',
type: 'n8n-nodes-base.code',
typeVersion: 2,
position: [600, 100],
parameters: {}
},
{
id: 'process-service',
name: 'Process Service Order',
type: 'n8n-nodes-base.code',
typeVersion: 2,
position: [600, 200],
parameters: {}
},
{
id: 'reject-payment',
name: 'Reject Payment',
type: 'n8n-nodes-base.code',
typeVersion: 2,
position: [400, 300],
parameters: {}
}
],
connections: {
'New Order': {
main: [[{ node: 'Check Payment Status', type: 'main', index: 0 }]]
},
'Check Payment Status': {
main: [
[{ node: 'Route by Order Type', type: 'main', index: 0 }], // paid
[{ node: 'Reject Payment', type: 'main', index: 0 }] // not paid
]
},
'Route by Order Type': {
main: [
[{ node: 'Process Digital Order', type: 'main', index: 0 }], // case 0: digital
[{ node: 'Process Physical Order', type: 'main', index: 0 }], // case 1: physical
[{ node: 'Process Service Order', type: 'main', index: 0 }] // case 2: service
]
}
}
};
});
it('should update all branch connections when renaming IF node', async () => {
const operation: UpdateNodeOperation = {
type: 'updateNode',
nodeId: 'if-1',
updates: { name: 'Validate Payment' }
};
const request: WorkflowDiffRequest = {
id: 'multi-branch-workflow',
operations: [operation]
};
const result = await diffEngine.applyDiff(multiBranchWorkflow, request);
expect(result.success).toBe(true);
expect(result.workflow).toBeDefined();
// IF node should be renamed
expect(result.workflow!.nodes.find((n: WorkflowNode) => n.id === 'if-1')?.name).toBe('Validate Payment');
// Both branches should be updated
expect(result.workflow!.connections['Validate Payment']).toBeDefined();
expect(result.workflow!.connections['Validate Payment'].main[0][0].node).toBe('Route by Order Type');
expect(result.workflow!.connections['Validate Payment'].main[1][0].node).toBe('Reject Payment');
// Validate workflow structure
const validationErrors = validateWorkflowStructure(result.workflow!);
expect(validationErrors).toHaveLength(0);
});
it('should update all case connections when renaming Switch node', async () => {
const operation: UpdateNodeOperation = {
type: 'updateNode',
nodeId: 'switch-1',
updates: { name: 'Order Type Router' }
};
const request: WorkflowDiffRequest = {
id: 'multi-branch-workflow',
operations: [operation]
};
const result = await diffEngine.applyDiff(multiBranchWorkflow, request);
expect(result.success).toBe(true);
expect(result.workflow).toBeDefined();
// Switch node should be renamed
expect(result.workflow!.nodes.find((n: WorkflowNode) => n.id === 'switch-1')?.name).toBe('Order Type Router');
// All three cases should be updated
expect(result.workflow!.connections['Order Type Router']).toBeDefined();
expect(result.workflow!.connections['Order Type Router'].main).toHaveLength(3);
expect(result.workflow!.connections['Order Type Router'].main[0][0].node).toBe('Process Digital Order');
expect(result.workflow!.connections['Order Type Router'].main[1][0].node).toBe('Process Physical Order');
expect(result.workflow!.connections['Order Type Router'].main[2][0].node).toBe('Process Service Order');
// Validate workflow structure
const validationErrors = validateWorkflowStructure(result.workflow!);
expect(validationErrors).toHaveLength(0);
});
it('should update specific case target when renamed', async () => {
const operation: UpdateNodeOperation = {
type: 'updateNode',
nodeId: 'process-digital',
updates: { name: 'Send Digital Download Link' }
};
const request: WorkflowDiffRequest = {
id: 'multi-branch-workflow',
operations: [operation]
};
const result = await diffEngine.applyDiff(multiBranchWorkflow, request);
expect(result.success).toBe(true);
expect(result.workflow).toBeDefined();
// Digital order node should be renamed
expect(result.workflow!.nodes.find((n: WorkflowNode) => n.id === 'process-digital')?.name).toBe('Send Digital Download Link');
// Case 0 connection should be updated
expect(result.workflow!.connections['Route by Order Type'].main[0][0].node).toBe('Send Digital Download Link');
// Other cases should remain unchanged
expect(result.workflow!.connections['Route by Order Type'].main[1][0].node).toBe('Process Physical Order');
expect(result.workflow!.connections['Route by Order Type'].main[2][0].node).toBe('Process Service Order');
// Validate workflow structure
const validationErrors = validateWorkflowStructure(result.workflow!);
expect(validationErrors).toHaveLength(0);
});
});
});

View File

@@ -1,532 +0,0 @@
import { describe, test, expect } from 'vitest';
import { validateWorkflowStructure } from '@/services/n8n-validation';
import type { Workflow } from '@/types/n8n-api';
describe('n8n-validation - Sticky Notes Bug Fix', () => {
describe('sticky notes should be excluded from disconnected nodes validation', () => {
test('should allow workflow with sticky notes and connected functional nodes', () => {
const workflow: Partial<Workflow> = {
name: 'Test Workflow',
nodes: [
{
id: '1',
name: 'Webhook',
type: 'n8n-nodes-base.webhook',
typeVersion: 1,
position: [250, 300],
parameters: { path: '/test' }
},
{
id: '2',
name: 'HTTP Request',
type: 'n8n-nodes-base.httpRequest',
typeVersion: 3,
position: [450, 300],
parameters: {}
},
{
id: 'sticky1',
name: 'Documentation Note',
type: 'n8n-nodes-base.stickyNote',
typeVersion: 1,
position: [250, 100],
parameters: { content: 'This is a documentation note' }
}
],
connections: {
'Webhook': {
main: [[{ node: 'HTTP Request', type: 'main', index: 0 }]]
}
}
};
const errors = validateWorkflowStructure(workflow);
// Should have no errors - sticky note should be ignored
expect(errors).toEqual([]);
});
test('should handle multiple sticky notes without errors', () => {
const workflow: Partial<Workflow> = {
name: 'Documented Workflow',
nodes: [
{
id: '1',
name: 'Webhook',
type: 'n8n-nodes-base.webhook',
typeVersion: 1,
position: [250, 300],
parameters: { path: '/test' }
},
{
id: '2',
name: 'Process',
type: 'n8n-nodes-base.set',
typeVersion: 3,
position: [450, 300],
parameters: {}
},
// 10 sticky notes for documentation
...Array.from({ length: 10 }, (_, i) => ({
id: `sticky${i}`,
name: `📝 Note ${i}`,
type: 'n8n-nodes-base.stickyNote',
typeVersion: 1,
position: [100 + i * 50, 100] as [number, number],
parameters: { content: `Documentation note ${i}` }
}))
],
connections: {
'Webhook': {
main: [[{ node: 'Process', type: 'main', index: 0 }]]
}
}
};
const errors = validateWorkflowStructure(workflow);
expect(errors).toEqual([]);
});
test('should handle all sticky note type variations', () => {
const stickyTypes = [
'n8n-nodes-base.stickyNote',
'nodes-base.stickyNote',
'@n8n/n8n-nodes-base.stickyNote'
];
stickyTypes.forEach((stickyType, index) => {
const workflow: Partial<Workflow> = {
name: 'Test Workflow',
nodes: [
{
id: '1',
name: 'Webhook',
type: 'n8n-nodes-base.webhook',
typeVersion: 1,
position: [250, 300],
parameters: { path: '/test' }
},
{
id: `sticky${index}`,
name: `Note ${index}`,
type: stickyType,
typeVersion: 1,
position: [250, 100],
parameters: { content: `Note ${index}` }
}
],
connections: {}
};
const errors = validateWorkflowStructure(workflow);
// Sticky note should be ignored regardless of type variation
expect(errors.every(e => !e.includes(`Note ${index}`))).toBe(true);
});
});
test('should handle complex workflow with multiple sticky notes (real-world scenario)', () => {
// Simulates workflow like "POST /auth/login" with 4 sticky notes
const workflow: Partial<Workflow> = {
name: 'POST /auth/login',
nodes: [
{
id: 'webhook1',
name: 'Webhook Trigger',
type: 'n8n-nodes-base.webhook',
typeVersion: 1,
position: [250, 300],
parameters: { path: '/auth/login', httpMethod: 'POST' }
},
{
id: 'http1',
name: 'Authenticate',
type: 'n8n-nodes-base.httpRequest',
typeVersion: 3,
position: [450, 300],
parameters: {}
},
{
id: 'respond1',
name: 'Return Success',
type: 'n8n-nodes-base.respondToWebhook',
typeVersion: 1,
position: [650, 250],
parameters: {}
},
{
id: 'respond2',
name: 'Return Error',
type: 'n8n-nodes-base.respondToWebhook',
typeVersion: 1,
position: [650, 350],
parameters: {}
},
// 4 sticky notes for documentation
{
id: 'sticky1',
name: '📝 Webhook Trigger',
type: 'n8n-nodes-base.stickyNote',
typeVersion: 1,
position: [250, 150],
parameters: { content: 'Receives login request' }
},
{
id: 'sticky2',
name: '📝 Authenticate with Supabase',
type: 'n8n-nodes-base.stickyNote',
typeVersion: 1,
position: [450, 150],
parameters: { content: 'Validates credentials' }
},
{
id: 'sticky3',
name: '📝 Return Tokens',
type: 'n8n-nodes-base.stickyNote',
typeVersion: 1,
position: [650, 150],
parameters: { content: 'Returns access and refresh tokens' }
},
{
id: 'sticky4',
name: '📝 Return Error',
type: 'n8n-nodes-base.stickyNote',
typeVersion: 1,
position: [650, 450],
parameters: { content: 'Returns error message' }
}
],
connections: {
'Webhook Trigger': {
main: [[{ node: 'Authenticate', type: 'main', index: 0 }]]
},
'Authenticate': {
main: [
[{ node: 'Return Success', type: 'main', index: 0 }],
[{ node: 'Return Error', type: 'main', index: 0 }]
]
}
}
};
const errors = validateWorkflowStructure(workflow);
// Should have no errors - all sticky notes should be ignored
expect(errors).toEqual([]);
});
});
describe('validation should still detect truly disconnected functional nodes', () => {
test('should detect disconnected HTTP node but ignore sticky note', () => {
const workflow: Partial<Workflow> = {
name: 'Test Workflow',
nodes: [
{
id: '1',
name: 'Webhook',
type: 'n8n-nodes-base.webhook',
typeVersion: 1,
position: [250, 300],
parameters: { path: '/test' }
},
{
id: '2',
name: 'Disconnected HTTP',
type: 'n8n-nodes-base.httpRequest',
typeVersion: 3,
position: [450, 300],
parameters: {}
},
{
id: 'sticky1',
name: 'Sticky Note',
type: 'n8n-nodes-base.stickyNote',
typeVersion: 1,
position: [250, 100],
parameters: { content: 'Note' }
}
],
connections: {} // No connections
};
const errors = validateWorkflowStructure(workflow);
// Should error on HTTP node, but NOT on sticky note
expect(errors.length).toBeGreaterThan(0);
const disconnectedError = errors.find(e => e.includes('Disconnected'));
expect(disconnectedError).toBeDefined();
expect(disconnectedError).toContain('Disconnected HTTP');
expect(disconnectedError).not.toContain('Sticky Note');
});
test('should detect multiple disconnected functional nodes but ignore sticky notes', () => {
const workflow: Partial<Workflow> = {
name: 'Test Workflow',
nodes: [
{
id: '1',
name: 'Webhook',
type: 'n8n-nodes-base.webhook',
typeVersion: 1,
position: [250, 300],
parameters: { path: '/test' }
},
{
id: '2',
name: 'Disconnected HTTP',
type: 'n8n-nodes-base.httpRequest',
typeVersion: 3,
position: [450, 300],
parameters: {}
},
{
id: '3',
name: 'Disconnected Set',
type: 'n8n-nodes-base.set',
typeVersion: 3,
position: [650, 300],
parameters: {}
},
// Multiple sticky notes that should be ignored
{
id: 'sticky1',
name: 'Note 1',
type: 'n8n-nodes-base.stickyNote',
typeVersion: 1,
position: [250, 100],
parameters: { content: 'Note 1' }
},
{
id: 'sticky2',
name: 'Note 2',
type: 'n8n-nodes-base.stickyNote',
typeVersion: 1,
position: [450, 100],
parameters: { content: 'Note 2' }
}
],
connections: {} // No connections
};
const errors = validateWorkflowStructure(workflow);
// Should error because there are no connections
// When there are NO connections, validation shows "Multi-node workflow has no connections"
// This is the expected behavior - it suggests connecting any two executable nodes
expect(errors.length).toBeGreaterThan(0);
const connectionError = errors.find(e => e.includes('no connections') || e.includes('Disconnected'));
expect(connectionError).toBeDefined();
// Error should NOT mention sticky notes
expect(connectionError).not.toContain('Note 1');
expect(connectionError).not.toContain('Note 2');
});
test('should allow sticky notes but still validate functional node connections', () => {
const workflow: Partial<Workflow> = {
name: 'Test Workflow',
nodes: [
{
id: '1',
name: 'Webhook',
type: 'n8n-nodes-base.webhook',
typeVersion: 1,
position: [250, 300],
parameters: { path: '/test' }
},
{
id: '2',
name: 'Connected HTTP',
type: 'n8n-nodes-base.httpRequest',
typeVersion: 3,
position: [450, 300],
parameters: {}
},
{
id: '3',
name: 'Disconnected Set',
type: 'n8n-nodes-base.set',
typeVersion: 3,
position: [650, 300],
parameters: {}
},
{
id: 'sticky1',
name: 'Sticky Note',
type: 'n8n-nodes-base.stickyNote',
typeVersion: 1,
position: [250, 100],
parameters: { content: 'Note' }
}
],
connections: {
'Webhook': {
main: [[{ node: 'Connected HTTP', type: 'main', index: 0 }]]
}
}
};
const errors = validateWorkflowStructure(workflow);
// Should error only on disconnected Set node
expect(errors.length).toBeGreaterThan(0);
const disconnectedError = errors.find(e => e.includes('Disconnected'));
expect(disconnectedError).toBeDefined();
expect(disconnectedError).toContain('Disconnected Set');
expect(disconnectedError).not.toContain('Connected HTTP');
expect(disconnectedError).not.toContain('Sticky Note');
});
});
describe('regression tests - ensure sticky notes work like in n8n UI', () => {
test('single webhook with sticky notes should be valid (matches n8n UI behavior)', () => {
const workflow: Partial<Workflow> = {
name: 'Webhook Only with Notes',
nodes: [
{
id: '1',
name: 'Webhook',
type: 'n8n-nodes-base.webhook',
typeVersion: 1,
position: [250, 300],
parameters: { path: '/test' }
},
{
id: 'sticky1',
name: 'Usage Instructions',
type: 'n8n-nodes-base.stickyNote',
typeVersion: 1,
position: [250, 100],
parameters: { content: 'Call this webhook to trigger the workflow' }
}
],
connections: {}
};
const errors = validateWorkflowStructure(workflow);
// Webhook-only workflows are valid in n8n
// Sticky notes should not affect this
expect(errors).toEqual([]);
});
test('workflow with only sticky notes should be invalid (no executable nodes)', () => {
const workflow: Partial<Workflow> = {
name: 'Only Notes',
nodes: [
{
id: 'sticky1',
name: 'Note 1',
type: 'n8n-nodes-base.stickyNote',
typeVersion: 1,
position: [250, 100],
parameters: { content: 'Note 1' }
},
{
id: 'sticky2',
name: 'Note 2',
type: 'n8n-nodes-base.stickyNote',
typeVersion: 1,
position: [450, 100],
parameters: { content: 'Note 2' }
}
],
connections: {}
};
const errors = validateWorkflowStructure(workflow);
// Should fail because there are no executable nodes
expect(errors.length).toBeGreaterThan(0);
expect(errors.some(e => e.includes('at least one executable node'))).toBe(true);
});
test('complex production workflow structure should validate correctly', () => {
// Tests a realistic production workflow structure
const workflow: Partial<Workflow> = {
name: 'Production API Endpoint',
nodes: [
// Functional nodes
{
id: 'webhook1',
name: 'API Webhook',
type: 'n8n-nodes-base.webhook',
typeVersion: 1,
position: [250, 300],
parameters: { path: '/api/endpoint' }
},
{
id: 'validate1',
name: 'Validate Input',
type: 'n8n-nodes-base.code',
typeVersion: 2,
position: [450, 300],
parameters: {}
},
{
id: 'branch1',
name: 'Check Valid',
type: 'n8n-nodes-base.if',
typeVersion: 2,
position: [650, 300],
parameters: {}
},
{
id: 'process1',
name: 'Process Request',
type: 'n8n-nodes-base.httpRequest',
typeVersion: 3,
position: [850, 250],
parameters: {}
},
{
id: 'success1',
name: 'Return Success',
type: 'n8n-nodes-base.respondToWebhook',
typeVersion: 1,
position: [1050, 250],
parameters: {}
},
{
id: 'error1',
name: 'Return Error',
type: 'n8n-nodes-base.respondToWebhook',
typeVersion: 1,
position: [850, 350],
parameters: {}
},
// Documentation sticky notes (11 notes like in real workflow)
...Array.from({ length: 11 }, (_, i) => ({
id: `sticky${i}`,
name: `📝 Documentation ${i}`,
type: 'n8n-nodes-base.stickyNote',
typeVersion: 1,
position: [250 + i * 100, 100] as [number, number],
parameters: { content: `Documentation section ${i}` }
}))
],
connections: {
'API Webhook': {
main: [[{ node: 'Validate Input', type: 'main', index: 0 }]]
},
'Validate Input': {
main: [[{ node: 'Check Valid', type: 'main', index: 0 }]]
},
'Check Valid': {
main: [
[{ node: 'Process Request', type: 'main', index: 0 }],
[{ node: 'Return Error', type: 'main', index: 0 }]
]
},
'Process Request': {
main: [[{ node: 'Return Success', type: 'main', index: 0 }]]
}
}
};
const errors = validateWorkflowStructure(workflow);
// Should be valid - all functional nodes connected, sticky notes ignored
expect(errors).toEqual([]);
});
});
});

File diff suppressed because it is too large Load Diff

View File

@@ -1,240 +0,0 @@
import { describe, test, expect } from 'vitest';
import {
isStickyNote,
isTriggerNode,
isNonExecutableNode,
requiresIncomingConnection
} from '@/utils/node-classification';
describe('Node Classification Utilities', () => {
describe('isStickyNote', () => {
test('should identify standard sticky note type', () => {
expect(isStickyNote('n8n-nodes-base.stickyNote')).toBe(true);
});
test('should identify normalized sticky note type', () => {
expect(isStickyNote('nodes-base.stickyNote')).toBe(true);
});
test('should identify scoped sticky note type', () => {
expect(isStickyNote('@n8n/n8n-nodes-base.stickyNote')).toBe(true);
});
test('should return false for webhook node', () => {
expect(isStickyNote('n8n-nodes-base.webhook')).toBe(false);
});
test('should return false for HTTP request node', () => {
expect(isStickyNote('n8n-nodes-base.httpRequest')).toBe(false);
});
test('should return false for manual trigger node', () => {
expect(isStickyNote('n8n-nodes-base.manualTrigger')).toBe(false);
});
test('should return false for Set node', () => {
expect(isStickyNote('n8n-nodes-base.set')).toBe(false);
});
test('should return false for empty string', () => {
expect(isStickyNote('')).toBe(false);
});
});
describe('isTriggerNode', () => {
test('should identify webhook trigger', () => {
expect(isTriggerNode('n8n-nodes-base.webhook')).toBe(true);
});
test('should identify webhook trigger variant', () => {
expect(isTriggerNode('n8n-nodes-base.webhookTrigger')).toBe(true);
});
test('should identify manual trigger', () => {
expect(isTriggerNode('n8n-nodes-base.manualTrigger')).toBe(true);
});
test('should identify cron trigger', () => {
expect(isTriggerNode('n8n-nodes-base.cronTrigger')).toBe(true);
});
test('should identify schedule trigger', () => {
expect(isTriggerNode('n8n-nodes-base.scheduleTrigger')).toBe(true);
});
test('should return false for HTTP request node', () => {
expect(isTriggerNode('n8n-nodes-base.httpRequest')).toBe(false);
});
test('should return false for Set node', () => {
expect(isTriggerNode('n8n-nodes-base.set')).toBe(false);
});
test('should return false for sticky note', () => {
expect(isTriggerNode('n8n-nodes-base.stickyNote')).toBe(false);
});
test('should return false for empty string', () => {
expect(isTriggerNode('')).toBe(false);
});
});
describe('isNonExecutableNode', () => {
test('should identify sticky note as non-executable', () => {
expect(isNonExecutableNode('n8n-nodes-base.stickyNote')).toBe(true);
});
test('should identify all sticky note variations as non-executable', () => {
expect(isNonExecutableNode('nodes-base.stickyNote')).toBe(true);
expect(isNonExecutableNode('@n8n/n8n-nodes-base.stickyNote')).toBe(true);
});
test('should return false for webhook trigger', () => {
expect(isNonExecutableNode('n8n-nodes-base.webhook')).toBe(false);
});
test('should return false for HTTP request node', () => {
expect(isNonExecutableNode('n8n-nodes-base.httpRequest')).toBe(false);
});
test('should return false for Set node', () => {
expect(isNonExecutableNode('n8n-nodes-base.set')).toBe(false);
});
test('should return false for manual trigger', () => {
expect(isNonExecutableNode('n8n-nodes-base.manualTrigger')).toBe(false);
});
});
describe('requiresIncomingConnection', () => {
describe('non-executable nodes (should not require connections)', () => {
test('should return false for sticky note', () => {
expect(requiresIncomingConnection('n8n-nodes-base.stickyNote')).toBe(false);
});
test('should return false for all sticky note variations', () => {
expect(requiresIncomingConnection('nodes-base.stickyNote')).toBe(false);
expect(requiresIncomingConnection('@n8n/n8n-nodes-base.stickyNote')).toBe(false);
});
});
describe('trigger nodes (should not require incoming connections)', () => {
test('should return false for webhook', () => {
expect(requiresIncomingConnection('n8n-nodes-base.webhook')).toBe(false);
});
test('should return false for webhook trigger', () => {
expect(requiresIncomingConnection('n8n-nodes-base.webhookTrigger')).toBe(false);
});
test('should return false for manual trigger', () => {
expect(requiresIncomingConnection('n8n-nodes-base.manualTrigger')).toBe(false);
});
test('should return false for cron trigger', () => {
expect(requiresIncomingConnection('n8n-nodes-base.cronTrigger')).toBe(false);
});
test('should return false for schedule trigger', () => {
expect(requiresIncomingConnection('n8n-nodes-base.scheduleTrigger')).toBe(false);
});
});
describe('regular nodes (should require incoming connections)', () => {
test('should return true for HTTP request node', () => {
expect(requiresIncomingConnection('n8n-nodes-base.httpRequest')).toBe(true);
});
test('should return true for Set node', () => {
expect(requiresIncomingConnection('n8n-nodes-base.set')).toBe(true);
});
test('should return true for Code node', () => {
expect(requiresIncomingConnection('n8n-nodes-base.code')).toBe(true);
});
test('should return true for Function node', () => {
expect(requiresIncomingConnection('n8n-nodes-base.function')).toBe(true);
});
test('should return true for IF node', () => {
expect(requiresIncomingConnection('n8n-nodes-base.if')).toBe(true);
});
test('should return true for Switch node', () => {
expect(requiresIncomingConnection('n8n-nodes-base.switch')).toBe(true);
});
test('should return true for Respond to Webhook node', () => {
expect(requiresIncomingConnection('n8n-nodes-base.respondToWebhook')).toBe(true);
});
});
describe('edge cases', () => {
test('should return true for unknown node types (conservative approach)', () => {
expect(requiresIncomingConnection('unknown-package.unknownNode')).toBe(true);
});
test('should return true for empty string', () => {
expect(requiresIncomingConnection('')).toBe(true);
});
});
});
describe('integration scenarios', () => {
test('sticky notes should be non-executable and not require connections', () => {
const stickyType = 'n8n-nodes-base.stickyNote';
expect(isNonExecutableNode(stickyType)).toBe(true);
expect(requiresIncomingConnection(stickyType)).toBe(false);
expect(isStickyNote(stickyType)).toBe(true);
expect(isTriggerNode(stickyType)).toBe(false);
});
test('webhook nodes should be triggers and not require incoming connections', () => {
const webhookType = 'n8n-nodes-base.webhook';
expect(isTriggerNode(webhookType)).toBe(true);
expect(requiresIncomingConnection(webhookType)).toBe(false);
expect(isNonExecutableNode(webhookType)).toBe(false);
expect(isStickyNote(webhookType)).toBe(false);
});
test('regular nodes should require incoming connections', () => {
const httpType = 'n8n-nodes-base.httpRequest';
expect(requiresIncomingConnection(httpType)).toBe(true);
expect(isNonExecutableNode(httpType)).toBe(false);
expect(isTriggerNode(httpType)).toBe(false);
expect(isStickyNote(httpType)).toBe(false);
});
test('all trigger types should not require incoming connections', () => {
const triggerTypes = [
'n8n-nodes-base.webhook',
'n8n-nodes-base.webhookTrigger',
'n8n-nodes-base.manualTrigger',
'n8n-nodes-base.cronTrigger',
'n8n-nodes-base.scheduleTrigger'
];
triggerTypes.forEach(type => {
expect(isTriggerNode(type)).toBe(true);
expect(requiresIncomingConnection(type)).toBe(false);
expect(isNonExecutableNode(type)).toBe(false);
});
});
test('all sticky note variations should be non-executable', () => {
const stickyTypes = [
'n8n-nodes-base.stickyNote',
'nodes-base.stickyNote',
'@n8n/n8n-nodes-base.stickyNote'
];
stickyTypes.forEach(type => {
expect(isStickyNote(type)).toBe(true);
expect(isNonExecutableNode(type)).toBe(true);
expect(requiresIncomingConnection(type)).toBe(false);
expect(isTriggerNode(type)).toBe(false);
});
});
});
});

View File

@@ -7,10 +7,7 @@ import {
isBaseNode,
isLangChainNode,
isValidNodeTypeFormat,
getNodeTypeVariations,
isTriggerNode,
isActivatableTrigger,
getTriggerTypeDescription
getNodeTypeVariations
} from '@/utils/node-type-utils';
describe('node-type-utils', () => {
@@ -199,165 +196,4 @@ describe('node-type-utils', () => {
expect(variations.length).toBe(uniqueVariations.length);
});
});
describe('isTriggerNode', () => {
it('recognizes executeWorkflowTrigger as a trigger', () => {
expect(isTriggerNode('n8n-nodes-base.executeWorkflowTrigger')).toBe(true);
expect(isTriggerNode('nodes-base.executeWorkflowTrigger')).toBe(true);
});
it('recognizes schedule triggers', () => {
expect(isTriggerNode('n8n-nodes-base.scheduleTrigger')).toBe(true);
expect(isTriggerNode('n8n-nodes-base.cronTrigger')).toBe(true);
});
it('recognizes webhook triggers', () => {
expect(isTriggerNode('n8n-nodes-base.webhook')).toBe(true);
expect(isTriggerNode('n8n-nodes-base.webhookTrigger')).toBe(true);
});
it('recognizes manual triggers', () => {
expect(isTriggerNode('n8n-nodes-base.manualTrigger')).toBe(true);
expect(isTriggerNode('n8n-nodes-base.start')).toBe(true);
expect(isTriggerNode('n8n-nodes-base.formTrigger')).toBe(true);
});
it('recognizes email and polling triggers', () => {
expect(isTriggerNode('n8n-nodes-base.emailTrigger')).toBe(true);
expect(isTriggerNode('n8n-nodes-base.imapTrigger')).toBe(true);
expect(isTriggerNode('n8n-nodes-base.gmailTrigger')).toBe(true);
});
it('recognizes various trigger types', () => {
expect(isTriggerNode('n8n-nodes-base.slackTrigger')).toBe(true);
expect(isTriggerNode('n8n-nodes-base.githubTrigger')).toBe(true);
expect(isTriggerNode('n8n-nodes-base.twilioTrigger')).toBe(true);
});
it('does NOT recognize respondToWebhook as a trigger', () => {
expect(isTriggerNode('n8n-nodes-base.respondToWebhook')).toBe(false);
});
it('does NOT recognize regular nodes as triggers', () => {
expect(isTriggerNode('n8n-nodes-base.set')).toBe(false);
expect(isTriggerNode('n8n-nodes-base.httpRequest')).toBe(false);
expect(isTriggerNode('n8n-nodes-base.code')).toBe(false);
expect(isTriggerNode('n8n-nodes-base.slack')).toBe(false);
});
it('handles normalized and non-normalized node types', () => {
expect(isTriggerNode('n8n-nodes-base.webhook')).toBe(true);
expect(isTriggerNode('nodes-base.webhook')).toBe(true);
});
it('is case-insensitive', () => {
expect(isTriggerNode('n8n-nodes-base.WebhookTrigger')).toBe(true);
expect(isTriggerNode('n8n-nodes-base.EMAILTRIGGER')).toBe(true);
});
});
describe('isActivatableTrigger', () => {
it('executeWorkflowTrigger is NOT activatable', () => {
expect(isActivatableTrigger('n8n-nodes-base.executeWorkflowTrigger')).toBe(false);
expect(isActivatableTrigger('nodes-base.executeWorkflowTrigger')).toBe(false);
});
it('webhook triggers ARE activatable', () => {
expect(isActivatableTrigger('n8n-nodes-base.webhook')).toBe(true);
expect(isActivatableTrigger('n8n-nodes-base.webhookTrigger')).toBe(true);
});
it('schedule triggers ARE activatable', () => {
expect(isActivatableTrigger('n8n-nodes-base.scheduleTrigger')).toBe(true);
expect(isActivatableTrigger('n8n-nodes-base.cronTrigger')).toBe(true);
});
it('manual triggers ARE activatable', () => {
expect(isActivatableTrigger('n8n-nodes-base.manualTrigger')).toBe(true);
expect(isActivatableTrigger('n8n-nodes-base.start')).toBe(true);
expect(isActivatableTrigger('n8n-nodes-base.formTrigger')).toBe(true);
});
it('polling triggers ARE activatable', () => {
expect(isActivatableTrigger('n8n-nodes-base.emailTrigger')).toBe(true);
expect(isActivatableTrigger('n8n-nodes-base.slackTrigger')).toBe(true);
expect(isActivatableTrigger('n8n-nodes-base.gmailTrigger')).toBe(true);
});
it('regular nodes are NOT activatable', () => {
expect(isActivatableTrigger('n8n-nodes-base.set')).toBe(false);
expect(isActivatableTrigger('n8n-nodes-base.httpRequest')).toBe(false);
expect(isActivatableTrigger('n8n-nodes-base.respondToWebhook')).toBe(false);
});
});
describe('getTriggerTypeDescription', () => {
it('describes executeWorkflowTrigger correctly', () => {
const desc = getTriggerTypeDescription('n8n-nodes-base.executeWorkflowTrigger');
expect(desc).toContain('Execute Workflow');
expect(desc).toContain('invoked by other workflows');
});
it('describes webhook triggers correctly', () => {
const desc = getTriggerTypeDescription('n8n-nodes-base.webhook');
expect(desc).toContain('Webhook');
expect(desc).toContain('HTTP');
});
it('describes schedule triggers correctly', () => {
const desc = getTriggerTypeDescription('n8n-nodes-base.scheduleTrigger');
expect(desc).toContain('Schedule');
expect(desc).toContain('time-based');
});
it('describes manual triggers correctly', () => {
const desc = getTriggerTypeDescription('n8n-nodes-base.manualTrigger');
expect(desc).toContain('Manual');
});
it('describes email triggers correctly', () => {
const desc = getTriggerTypeDescription('n8n-nodes-base.emailTrigger');
expect(desc).toContain('Email');
expect(desc).toContain('polling');
});
it('provides generic description for unknown triggers', () => {
const desc = getTriggerTypeDescription('n8n-nodes-base.customTrigger');
expect(desc).toContain('Trigger');
});
});
describe('Integration: Trigger Classification', () => {
it('all triggers detected by isTriggerNode should be classified correctly', () => {
const triggers = [
'n8n-nodes-base.webhook',
'n8n-nodes-base.webhookTrigger',
'n8n-nodes-base.scheduleTrigger',
'n8n-nodes-base.manualTrigger',
'n8n-nodes-base.executeWorkflowTrigger',
'n8n-nodes-base.emailTrigger'
];
for (const trigger of triggers) {
expect(isTriggerNode(trigger)).toBe(true);
const desc = getTriggerTypeDescription(trigger);
expect(desc).toBeTruthy();
expect(desc).not.toBe('Unknown trigger type');
}
});
it('only executeWorkflowTrigger is non-activatable', () => {
const triggers = [
{ type: 'n8n-nodes-base.webhook', activatable: true },
{ type: 'n8n-nodes-base.scheduleTrigger', activatable: true },
{ type: 'n8n-nodes-base.executeWorkflowTrigger', activatable: false },
{ type: 'n8n-nodes-base.emailTrigger', activatable: true }
];
for (const { type, activatable } of triggers) {
expect(isTriggerNode(type)).toBe(true); // All are triggers
expect(isActivatableTrigger(type)).toBe(activatable); // But only some are activatable
}
});
});
});

View File

@@ -206,7 +206,7 @@ describe('Validation System Fixes', () => {
const result = await workflowValidator.validateWorkflow(workflow);
expect(result).toBeDefined();
expect(result.statistics.totalNodes).toBe(1); // Only webhook, non-executable nodes excluded
expect(result.statistics.totalNodes).toBe(1); // Only webhook, sticky note excluded
expect(result.statistics.enabledNodes).toBe(1);
});