n8n-mcp/tests/integration/mcp-protocol/error-handling.test.ts

import { describe, it, expect, beforeEach, afterEach } from 'vitest';
import { InMemoryTransport } from '@modelcontextprotocol/sdk/inMemory.js';
import { Client } from '@modelcontextprotocol/sdk/client/index.js';
import { TestableN8NMCPServer } from './test-helpers';

describe('MCP Error Handling', () => {
  let mcpServer: TestableN8NMCPServer;
  let client: Client;

  beforeEach(async () => {
    mcpServer = new TestableN8NMCPServer();
    await mcpServer.initialize();
    
    const [serverTransport, clientTransport] = InMemoryTransport.createLinkedPair();
    await mcpServer.connectToTransport(serverTransport);
    
    client = new Client({
      name: 'test-client',
      version: '1.0.0'
    }, {
      capabilities: {}
    });
    
    await client.connect(clientTransport);
  });

  afterEach(async () => {
    await client.close();
    await mcpServer.close();
  });

  describe('JSON-RPC Error Codes', () => {
    it('should handle invalid request (parse error)', async () => {
      // The MCP SDK handles parsing, so we test with invalid method instead
      try {
        await (client as any).request({
          method: '',  // Empty method
          params: {}
        });
        expect.fail('Should have thrown an error');
      } catch (error: any) {
        expect(error).toBeDefined();
      }
    });

    it('should handle method not found', async () => {
      try {
        await (client as any).request({
          method: 'nonexistent/method',
          params: {}
        });
        expect.fail('Should have thrown an error');
      } catch (error: any) {
        expect(error).toBeDefined();
        expect(error.message).toContain('not found');
      }
    });

    it('should handle invalid params', async () => {
      try {
        // Missing required parameter
        await client.callTool({ name: 'get_node_info', arguments: {} });
        expect.fail('Should have thrown an error');
      } catch (error: any) {
        expect(error).toBeDefined();
        // The error now properly validates required parameters
        expect(error.message).toContain("Missing required parameters");
      }
    });

    it('should handle internal errors gracefully', async () => {
      try {
        // Invalid node type format should cause internal processing error
        await client.callTool({ name: 'get_node_info', arguments: {
          nodeType: 'completely-invalid-format-$$$$'
        } });
        expect.fail('Should have thrown an error');
      } catch (error: any) {
        expect(error).toBeDefined();
        expect(error.message).toContain('not found');
      }
    });
  });

  describe('Tool-Specific Errors', () => {
    describe('Node Discovery Errors', () => {
      it('should handle invalid category filter', async () => {
        const response = await client.callTool({ name: 'list_nodes', arguments: {
          category: 'invalid_category'
        } });

        // Should return empty array, not error
        const result = JSON.parse((response as any).content[0].text);
        expect(result).toHaveProperty('nodes');
        expect(Array.isArray(result.nodes)).toBe(true);
        expect(result.nodes).toHaveLength(0);
      });

      it('should handle invalid search mode', async () => {
        try {
          await client.callTool({ name: 'search_nodes', arguments: {
            query: 'test',
            mode: 'INVALID_MODE' as any
          } });
          expect.fail('Should have thrown an error');
        } catch (error: any) {
          expect(error).toBeDefined();
        }
      });

      it('should handle empty search query', async () => {
        // Empty query returns empty results
        const response = await client.callTool({ name: 'search_nodes', arguments: {
          query: ''
        } });
        
        const result = JSON.parse((response as any).content[0].text);
        // search_nodes returns 'results' not 'nodes'
        expect(result).toHaveProperty('results');
        expect(Array.isArray(result.results)).toBe(true);
        expect(result.results).toHaveLength(0);
      });

      it('should handle non-existent node types', async () => {
        try {
          await client.callTool({ name: 'get_node_info', arguments: {
            nodeType: 'nodes-base.thisDoesNotExist'
          } });
          expect.fail('Should have thrown an error');
        } catch (error: any) {
          expect(error).toBeDefined();
          expect(error.message).toContain('not found');
        }
      });
    });

    describe('Validation Errors', () => {
      it('should handle invalid validation profile', async () => {
        try {
          await client.callTool({ name: 'validate_node_operation', arguments: {
            nodeType: 'nodes-base.httpRequest',
            config: { method: 'GET', url: 'https://api.example.com' },
            profile: 'invalid_profile' as any
          } });
          expect.fail('Should have thrown an error');
        } catch (error: any) {
          expect(error).toBeDefined();
        }
      });

      it('should handle malformed workflow structure', async () => {
        const response = await client.callTool({ name: 'validate_workflow', arguments: {
          workflow: {
            // Missing required 'nodes' array
            connections: {}
          }
        } });
        
        // Should return validation error, not throw
        const validation = JSON.parse((response as any).content[0].text);
        expect(validation.valid).toBe(false);
        expect(validation.errors).toBeDefined();
        expect(validation.errors.length).toBeGreaterThan(0);
        expect(validation.errors[0].message).toContain('nodes');
      });

      it('should handle circular workflow references', async () => {
        const workflow = {
          nodes: [
            {
              id: '1',
              name: 'Node1',
              type: 'nodes-base.noOp',
              typeVersion: 1,
              position: [0, 0],
              parameters: {}
            },
            {
              id: '2',
              name: 'Node2',
              type: 'nodes-base.noOp',
              typeVersion: 1,
              position: [250, 0],
              parameters: {}
            }
          ],
          connections: {
            'Node1': {
              'main': [[{ node: 'Node2', type: 'main', index: 0 }]]
            },
            'Node2': {
              'main': [[{ node: 'Node1', type: 'main', index: 0 }]]
            }
          }
        };

        const response = await client.callTool({ name: 'validate_workflow', arguments: {
          workflow
        } });

        const validation = JSON.parse((response as any).content[0].text);
        expect(validation.warnings).toBeDefined();
      });
    });

    describe('Documentation Errors', () => {
      it('should handle non-existent documentation topics', async () => {
        const response = await client.callTool({ name: 'tools_documentation', arguments: {
          topic: 'completely_fake_tool'
        } });

        expect((response as any).content[0].text).toContain('not found');
      });

      it('should handle invalid depth parameter', async () => {
        try {
          await client.callTool({ name: 'tools_documentation', arguments: {
            depth: 'invalid_depth' as any
          } });
          expect.fail('Should have thrown an error');
        } catch (error: any) {
          expect(error).toBeDefined();
        }
      });
    });
  });

  describe('Large Payload Handling', () => {
    it('should handle large node info requests', async () => {
      // HTTP Request node has extensive properties
      const response = await client.callTool({ name: 'get_node_info', arguments: {
        nodeType: 'nodes-base.httpRequest'
      } });

      expect((response as any).content[0].text.length).toBeGreaterThan(10000);
      
      // Should be valid JSON
      const nodeInfo = JSON.parse((response as any).content[0].text);
      expect(nodeInfo).toHaveProperty('properties');
    });

    it('should handle large workflow validation', async () => {
      // Create a large workflow
      const nodes = [];
      const connections: any = {};

      for (let i = 0; i < 50; i++) {
        const nodeName = `Node${i}`;
        nodes.push({
          id: String(i),
          name: nodeName,
          type: 'nodes-base.noOp',
          typeVersion: 1,
          position: [i * 100, 0],
          parameters: {}
        });

        if (i > 0) {
          const prevNode = `Node${i - 1}`;
          connections[prevNode] = {
            'main': [[{ node: nodeName, type: 'main', index: 0 }]]
          };
        }
      }

      const response = await client.callTool({ name: 'validate_workflow', arguments: {
        workflow: { nodes, connections }
      } });

      const validation = JSON.parse((response as any).content[0].text);
      expect(validation).toHaveProperty('valid');
    });

    it('should handle many concurrent requests', async () => {
      const requestCount = 50;
      const promises = [];

      for (let i = 0; i < requestCount; i++) {
        promises.push(
          client.callTool({ name: 'list_nodes', arguments: {
            limit: 1,
            category: i % 2 === 0 ? 'trigger' : 'transform'
          } })
        );
      }

      const responses = await Promise.all(promises);
      expect(responses).toHaveLength(requestCount);
    });
  });

  describe('Invalid JSON Handling', () => {
    it('should handle invalid JSON in tool parameters', async () => {
      try {
        // Config should be an object, not a string
        await client.callTool({ name: 'validate_node_operation', arguments: {
          nodeType: 'nodes-base.httpRequest',
          config: 'invalid json string' as any
        } });
        expect.fail('Should have thrown an error');
      } catch (error: any) {
        expect(error).toBeDefined();
      }
    });

    it('should handle malformed workflow JSON', async () => {
      try {
        await client.callTool({ name: 'validate_workflow', arguments: {
          workflow: 'not a valid workflow object' as any
        } });
        expect.fail('Should have thrown an error');
      } catch (error: any) {
        expect(error).toBeDefined();
      }
    });
  });

  describe('Timeout Scenarios', () => {
    it('should handle rapid sequential requests', async () => {
      const start = Date.now();
      
      for (let i = 0; i < 20; i++) {
        await client.callTool({ name: 'get_database_statistics', arguments: {} });
      }

      const duration = Date.now() - start;
      
      // Should complete reasonably quickly (under 5 seconds)
      expect(duration).toBeLessThan(5000);
    });

    it('should handle long-running operations', async () => {
      // Search with complex query that requires more processing
      const response = await client.callTool({ name: 'search_nodes', arguments: {
        query: 'a b c d e f g h i j k l m n o p q r s t u v w x y z',
        mode: 'AND'
      } });

      expect(response).toBeDefined();
    });
  });

  describe('Memory Pressure', () => {
    it('should handle multiple large responses', async () => {
      const promises = [];

      // Request multiple large node infos
      const largeNodes = [
        'nodes-base.httpRequest',
        'nodes-base.postgres',
        'nodes-base.googleSheets',
        'nodes-base.slack',
        'nodes-base.gmail'
      ];

      for (const nodeType of largeNodes) {
        promises.push(
          client.callTool({ name: 'get_node_info', arguments: { nodeType } })
            .catch(() => null) // Some might not exist
        );
      }

      const responses = await Promise.all(promises);
      const validResponses = responses.filter(r => r !== null);
      
      expect(validResponses.length).toBeGreaterThan(0);
    });

    it('should handle workflow with many nodes', async () => {
      const nodeCount = 100;
      const nodes = [];

      for (let i = 0; i < nodeCount; i++) {
        nodes.push({
          id: String(i),
          name: `Node${i}`,
          type: 'nodes-base.noOp',
          typeVersion: 1,
          position: [i * 50, Math.floor(i / 10) * 100],
          parameters: {
            // Add some data to increase memory usage
            data: `This is some test data for node ${i}`.repeat(10)
          }
        });
      }

      const response = await client.callTool({ name: 'validate_workflow', arguments: {
        workflow: {
          nodes,
          connections: {}
        }
      } });

      const validation = JSON.parse((response as any).content[0].text);
      expect(validation).toHaveProperty('valid');
    });
  });

  describe('Error Recovery', () => {
    it('should continue working after errors', async () => {
      // Cause an error
      try {
        await client.callTool({ name: 'get_node_info', arguments: {
          nodeType: 'invalid'
        } });
      } catch (error) {
        // Expected
      }

      // Should still work
      const response = await client.callTool({ name: 'list_nodes', arguments: { limit: 1 } });
      expect(response).toBeDefined();
    });

    it('should handle mixed success and failure', async () => {
      const promises = [
        client.callTool({ name: 'list_nodes', arguments: { limit: 5 } }),
        client.callTool({ name: 'get_node_info', arguments: { nodeType: 'invalid' } }).catch(e => ({ error: e })),
        client.callTool({ name: 'get_database_statistics', arguments: {} }),
        client.callTool({ name: 'search_nodes', arguments: { query: '' } }).catch(e => ({ error: e })),
        client.callTool({ name: 'list_ai_tools', arguments: {} })
      ];

      const results = await Promise.all(promises);
      
      // Some should succeed, some should fail
      const successes = results.filter(r => !('error' in r));
      const failures = results.filter(r => 'error' in r);
      
      expect(successes.length).toBeGreaterThan(0);
      expect(failures.length).toBeGreaterThan(0);
    });
  });

  describe('Edge Cases', () => {
    it('should handle empty responses gracefully', async () => {
      const response = await client.callTool({ name: 'list_nodes', arguments: {
        category: 'nonexistent_category'
      } });

      const result = JSON.parse((response as any).content[0].text);
      expect(result).toHaveProperty('nodes');
      expect(Array.isArray(result.nodes)).toBe(true);
      expect(result.nodes).toHaveLength(0);
    });

    it('should handle special characters in parameters', async () => {
      const response = await client.callTool({ name: 'search_nodes', arguments: {
        query: 'test!@#$%^&*()_+-=[]{}|;\':",./<>?'
      } });

      // Should return results or empty array, not error
      const result = JSON.parse((response as any).content[0].text);
      expect(result).toHaveProperty('results');
      expect(Array.isArray(result.results)).toBe(true);
    });

    it('should handle unicode in parameters', async () => {
      const response = await client.callTool({ name: 'search_nodes', arguments: {
        query: 'test 测试 тест परीक्षण'
      } });

      const result = JSON.parse((response as any).content[0].text);
      expect(result).toHaveProperty('results');
      expect(Array.isArray(result.results)).toBe(true);
    });

    it('should handle null and undefined gracefully', async () => {
      // Most tools should handle missing optional params
      const response = await client.callTool({ name: 'list_nodes', arguments: {
        limit: undefined as any,
        category: null as any
      } });

      const result = JSON.parse((response as any).content[0].text);
      expect(result).toHaveProperty('nodes');
      expect(Array.isArray(result.nodes)).toBe(true);
    });
  });

  describe('Error Message Quality', () => {
    it('should provide helpful error messages', async () => {
      try {
        // Use a truly invalid node type
        await client.callTool({ name: 'get_node_info', arguments: {
          nodeType: 'invalid-node-type-that-does-not-exist'
        } });
        expect.fail('Should have thrown an error');
      } catch (error: any) {
        expect(error.message).toBeDefined();
        expect(error.message.length).toBeGreaterThan(10);
        // Should mention the issue
        expect(error.message.toLowerCase()).toMatch(/not found|invalid|missing/);
      }
    });

    it('should indicate missing required parameters', async () => {
      try {
        await client.callTool({ name: 'search_nodes', arguments: {} });
        expect.fail('Should have thrown an error');
      } catch (error: any) {
        expect(error).toBeDefined();
        // The error now properly validates required parameters
        expect(error.message).toContain("Missing required parameters");
      }
    });

    it('should provide context for validation errors', async () => {
      const response = await client.callTool({ name: 'validate_node_operation', arguments: {
        nodeType: 'nodes-base.httpRequest',
        config: {
          // Missing required fields
          method: 'INVALID_METHOD'
        }
      } });

      const validation = JSON.parse((response as any).content[0].text);
      expect(validation.valid).toBe(false);
      expect(validation.errors).toBeDefined();
      expect(Array.isArray(validation.errors)).toBe(true);
      expect(validation.errors.length).toBeGreaterThan(0);
      if (validation.errors.length > 0) {
        expect(validation.errors[0].message).toBeDefined();
        // Field property might not exist on all error types
        if (validation.errors[0].field !== undefined) {
          expect(validation.errors[0].field).toBeDefined();
        }
      }
    });
  });
});