fix: add missing datatable methods to handlers-n8n-manager mock client

CI fails because handlers-manage-datatable.test.ts and handlers-n8n-manager.test.ts share the same Vitest worker and module cache. The manage-datatable test mocks N8nApiClient with 20 methods but handlers-n8n-manager only had 10. When running in parallel, the singleton client state leaked between files causing mock mismatches. Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>
fix: re-apply encodeURIComponent for filter/sortBy in handlers
2026-03-22 18:33:08 +00:00 · 2026-03-21 23:26:39 +01:00 · 2026-03-21 22:35:56 +01:00 · 2026-03-21 22:22:02 +01:00 · 2026-03-21 22:03:07 +01:00
37 changed files with 54 additions and 786 deletions
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@@ -7,32 +7,12 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0

 ## [Unreleased]

-## [2.40.3] - 2026-03-22
-
-### Fixed
-
- **Notification 400 disconnect storms (#654)**: `handleRequest()` now returns 202 Accepted for JSON-RPC notifications with stale/expired session IDs instead of 400. Per JSON-RPC 2.0 spec, notifications don't expect responses — returning 400 caused Claude's proxy to trigger reconnection storms (930 errors/day, 216 users affected)
- **TOCTOU race in session lookup**: Added null guard after transport assignment to handle sessions removed between the existence check and use
- **`updateTable` silently ignoring `columns` parameter**: Now returns a warning message when `columns` is passed to `updateTable`, clarifying that table schema is immutable after creation via the public API
- **Tool schema descriptions clarified**: `name` and `columns` parameter descriptions now explicitly document that `updateTable` is rename-only and columns are for `createTable` only
-
-Conceived by Romuald Członkowski - https://www.aiadvisors.pl/en
-
-## [2.40.2] - 2026-03-22
-
-### Fixed
-
- **Double URL-encoding of `filter` and `sortBy` in `getRows`/`deleteRows`**: Moved `encodeURIComponent()` from handler layer to a custom `paramsSerializer` in the API client. Handlers were encoding values before passing them as Axios params, causing double-encoding (`%257B` instead of `%7B`). Handlers now pass raw values; the API client encodes once via `serializeDataTableParams()`
- **`updateTable` documentation clarified**: Explicitly notes that only renaming is supported (no column modifications via public API)
-
-Conceived by Romuald Członkowski - https://www.aiadvisors.pl/en
-
 ## [2.40.1] - 2026-03-21

 ### Fixed

 - **`n8n_manage_datatable` row operations broken by MCP transport serialization**: `data` parameter received as string instead of JSON — added `z.preprocess` coercers for array/object/filter params
- **`n8n_manage_datatable` filter/sortBy URL encoding**: n8n API requires URL-encoded query params — added `encodeURIComponent()` for filter and sortBy in getRows and deleteRows (revised in 2.40.2 to move encoding to API client layer)
+- **`n8n_manage_datatable` filter/sortBy URL encoding**: n8n API requires URL-encoded query params — added `encodeURIComponent()` for filter and sortBy in getRows and deleteRows
 - **`json` column type rejected by n8n API**: Removed `json` from column type enum (n8n only accepts string/number/boolean/date)
 - **Garbled 404 error messages**: Fixed `N8nNotFoundError` constructor — API error messages are now passed through cleanly instead of being wrapped in "Resource with ID ... not found"

--- a/dist/mcp/handlers-n8n-manager.d.ts
+++ b/dist/mcp/handlers-n8n-manager.d.ts
@@ -26,14 +26,4 @@ export declare function handleDiagnostic(request: any, context?: InstanceContext
 export declare function handleWorkflowVersions(args: unknown, repository: NodeRepository, context?: InstanceContext): Promise<McpToolResponse>;
 export declare function handleDeployTemplate(args: unknown, templateService: TemplateService, repository: NodeRepository, context?: InstanceContext): Promise<McpToolResponse>;
 export declare function handleTriggerWebhookWorkflow(args: unknown, context?: InstanceContext): Promise<McpToolResponse>;
-export declare function handleCreateTable(args: unknown, context?: InstanceContext): Promise<McpToolResponse>;
-export declare function handleListTables(args: unknown, context?: InstanceContext): Promise<McpToolResponse>;
-export declare function handleGetTable(args: unknown, context?: InstanceContext): Promise<McpToolResponse>;
-export declare function handleUpdateTable(args: unknown, context?: InstanceContext): Promise<McpToolResponse>;
-export declare function handleDeleteTable(args: unknown, context?: InstanceContext): Promise<McpToolResponse>;
-export declare function handleGetRows(args: unknown, context?: InstanceContext): Promise<McpToolResponse>;
-export declare function handleInsertRows(args: unknown, context?: InstanceContext): Promise<McpToolResponse>;
-export declare function handleUpdateRows(args: unknown, context?: InstanceContext): Promise<McpToolResponse>;
-export declare function handleUpsertRows(args: unknown, context?: InstanceContext): Promise<McpToolResponse>;
-export declare function handleDeleteRows(args: unknown, context?: InstanceContext): Promise<McpToolResponse>;
 //# sourceMappingURL=handlers-n8n-manager.d.ts.map
--- a/dist/mcp/handlers-n8n-manager.d.ts.map
+++ b/dist/mcp/handlers-n8n-manager.d.ts.map
@@ -1 +1 @@
-{"version":3,"file":"handlers-n8n-manager.d.ts","sourceRoot":"","sources":["../../src/mcp/handlers-n8n-manager.ts"],"names":[],"mappings":"AAAA,OAAO,EAAE,YAAY,EAAE,MAAM,4BAA4B,CAAC;AAE1D,OAAO,EAML,eAAe,EAGhB,MAAM,kBAAkB,CAAC;AAkB1B,OAAO,EAAE,cAAc,EAAE,MAAM,6BAA6B,CAAC;AAC7D,OAAO,EAAE,eAAe,EAA2B,MAAM,2BAA2B,CAAC;AAOrF,OAAO,EAAE,eAAe,EAAE,MAAM,+BAA+B,CAAC;AAqNhE,wBAAgB,0BAA0B,IAAI,MAAM,CAEnD;AAMD,wBAAgB,uBAAuB,gDAEtC;AAKD,wBAAgB,kBAAkB,IAAI,IAAI,CAIzC;AAED,wBAAgB,eAAe,CAAC,OAAO,CAAC,EAAE,eAAe,GAAG,YAAY,GAAG,IAAI,CAgF9E;AA4HD,wBAAsB,oBAAoB,CAAC,IAAI,EAAE,OAAO,EAAE,OAAO,CAAC,EAAE,eAAe,GAAG,OAAO,CAAC,eAAe,CAAC,CA8F7G;AAED,wBAAsB,iBAAiB,CAAC,IAAI,EAAE,OAAO,EAAE,OAAO,CAAC,EAAE,eAAe,GAAG,OAAO,CAAC,eAAe,CAAC,CAiC1G;AAED,wBAAsB,wBAAwB,CAAC,IAAI,EAAE,OAAO,EAAE,OAAO,CAAC,EAAE,eAAe,GAAG,OAAO,CAAC,eAAe,CAAC,CAoDjH;AAED,wBAAsB,0BAA0B,CAAC,IAAI,EAAE,OAAO,EAAE,OAAO,CAAC,EAAE,eAAe,GAAG,OAAO,CAAC,eAAe,CAAC,CAmDnH;AAED,wBAAsB,wBAAwB,CAAC,IAAI,EAAE,OAAO,EAAE,OAAO,CAAC,EAAE,eAAe,GAAG,OAAO,CAAC,eAAe,CAAC,CAyCjH;AAED,wBAAsB,oBAAoB,CACxC,IAAI,EAAE,OAAO,EACb,UAAU,EAAE,cAAc,EAC1B,OAAO,CAAC,EAAE,eAAe,GACxB,OAAO,CAAC,eAAe,CAAC,CA8H1B;AAeD,wBAAsB,oBAAoB,CAAC,IAAI,EAAE,OAAO,EAAE,OAAO,CAAC,EAAE,eAAe,GAAG,OAAO,CAAC,eAAe,CAAC,CAsC7G;AAED,wBAAsB,mBAAmB,CAAC,IAAI,EAAE,OAAO,EAAE,OAAO,CAAC,EAAE,eAAe,GAAG,OAAO,CAAC,eAAe,CAAC,CAiE5G;AAED,wBAAsB,sBAAsB,CAC1C,IAAI,EAAE,OAAO,EACb,UAAU,EAAE,cAAc,EAC1B,OAAO,CAAC,EAAE,eAAe,GACxB,OAAO,CAAC,eAAe,CAAC,CA0F1B;AAED,wBAAsB,qBAAqB,CACzC,IAAI,EAAE,OAAO,EACb,UAAU,EAAE,cAAc,EAC1B,OAAO,CAAC,EAAE,eAAe,GACxB,OAAO,CAAC,eAAe,CAAC,CAoK1B;AAQD,wBAAsB,kBAAkB,CAAC,IAAI,EAAE,OAAO,EAAE,OAAO,CAAC,EAAE,eAAe,GAAG,OAAO,CAAC,eAAe,CAAC,CAwJ3G;AAED,wBAAsB,kBAAkB,CAAC,IAAI,EAAE,OAAO,EAAE,OAAO,CAAC,EAAE,eAAe,GAAG,OAAO,CAAC,eAAe,CAAC,CA8H3G;AAED,wBAAsB,oBAAoB,CAAC,IAAI,EAAE,OAAO,EAAE,OAAO,CAAC,EAAE,eAAe,GAAG,OAAO,CAAC,eAAe,CAAC,CAgD7G;AAED,wBAAsB,qBAAqB,CAAC,IAAI,EAAE,OAAO,EAAE,OAAO,CAAC,EAAE,eAAe,GAAG,OAAO,CAAC,eAAe,CAAC,CAiC9G;AAID,wBAAsB,iBAAiB,CAAC,OAAO,CAAC,EAAE,eAAe,GAAG,OAAO,CAAC,eAAe,CAAC,CAwG3F;AAkLD,wBAAsB,gBAAgB,CAAC,OAAO,EAAE,GAAG,EAAE,OAAO,CAAC,EAAE,eAAe,GAAG,OAAO,CAAC,eAAe,CAAC,CAkQxG;AAED,wBAAsB,sBAAsB,CAC1C,IAAI,EAAE,OAAO,EACb,UAAU,EAAE,cAAc,EAC1B,OAAO,CAAC,EAAE,eAAe,GACxB,OAAO,CAAC,eAAe,CAAC,CAsL1B;AA+BD,wBAAsB,oBAAoB,CACxC,IAAI,EAAE,OAAO,EACb,eAAe,EAAE,eAAe,EAChC,UAAU,EAAE,cAAc,EAC1B,OAAO,CAAC,EAAE,eAAe,GACxB,OAAO,CAAC,eAAe,CAAC,CAoM1B;AAQD,wBAAsB,4BAA4B,CAAC,IAAI,EAAE,OAAO,EAAE,OAAO,CAAC,EAAE,eAAe,GAAG,OAAO,CAAC,eAAe,CAAC,CAyErH;AA8FD,wBAAsB,iBAAiB,CAAC,IAAI,EAAE,OAAO,EAAE,OAAO,CAAC,EAAE,eAAe,GAAG,OAAO,CAAC,eAAe,CAAC,CAgB1G;AAED,wBAAsB,gBAAgB,CAAC,IAAI,EAAE,OAAO,EAAE,OAAO,CAAC,EAAE,eAAe,GAAG,OAAO,CAAC,eAAe,CAAC,CAgBzG;AAED,wBAAsB,cAAc,CAAC,IAAI,EAAE,OAAO,EAAE,OAAO,CAAC,EAAE,eAAe,GAAG,OAAO,CAAC,eAAe,CAAC,CASvG;AAED,wBAAsB,iBAAiB,CAAC,IAAI,EAAE,OAAO,EAAE,OAAO,CAAC,EAAE,eAAe,GAAG,OAAO,CAAC,eAAe,CAAC,CAa1G;AAED,wBAAsB,iBAAiB,CAAC,IAAI,EAAE,OAAO,EAAE,OAAO,CAAC,EAAE,eAAe,GAAG,OAAO,CAAC,eAAe,CAAC,CAS1G;AAED,wBAAsB,aAAa,CAAC,IAAI,EAAE,OAAO,EAAE,OAAO,CAAC,EAAE,eAAe,GAAG,OAAO,CAAC,eAAe,CAAC,CAuBtG;AAED,wBAAsB,gBAAgB,CAAC,IAAI,EAAE,OAAO,EAAE,OAAO,CAAC,EAAE,eAAe,GAAG,OAAO,CAAC,eAAe,CAAC,CAazG;AAED,wBAAsB,gBAAgB,CAAC,IAAI,EAAE,OAAO,EAAE,OAAO,CAAC,EAAE,eAAe,GAAG,OAAO,CAAC,eAAe,CAAC,CAazG;AAED,wBAAsB,gBAAgB,CAAC,IAAI,EAAE,OAAO,EAAE,OAAO,CAAC,EAAE,eAAe,GAAG,OAAO,CAAC,eAAe,CAAC,CAazG;AAED,wBAAsB,gBAAgB,CAAC,IAAI,EAAE,OAAO,EAAE,OAAO,CAAC,EAAE,eAAe,GAAG,OAAO,CAAC,eAAe,CAAC,CAiBzG"}
+{"version":3,"file":"handlers-n8n-manager.d.ts","sourceRoot":"","sources":["../../src/mcp/handlers-n8n-manager.ts"],"names":[],"mappings":"AAAA,OAAO,EAAE,YAAY,EAAE,MAAM,4BAA4B,CAAC;AAE1D,OAAO,EAML,eAAe,EAGhB,MAAM,kBAAkB,CAAC;AAkB1B,OAAO,EAAE,cAAc,EAAE,MAAM,6BAA6B,CAAC;AAC7D,OAAO,EAAE,eAAe,EAA2B,MAAM,2BAA2B,CAAC;AAOrF,OAAO,EAAE,eAAe,EAAE,MAAM,+BAA+B,CAAC;AAqNhE,wBAAgB,0BAA0B,IAAI,MAAM,CAEnD;AAMD,wBAAgB,uBAAuB,gDAEtC;AAKD,wBAAgB,kBAAkB,IAAI,IAAI,CAIzC;AAED,wBAAgB,eAAe,CAAC,OAAO,CAAC,EAAE,eAAe,GAAG,YAAY,GAAG,IAAI,CAgF9E;AA2HD,wBAAsB,oBAAoB,CAAC,IAAI,EAAE,OAAO,EAAE,OAAO,CAAC,EAAE,eAAe,GAAG,OAAO,CAAC,eAAe,CAAC,CA8F7G;AAED,wBAAsB,iBAAiB,CAAC,IAAI,EAAE,OAAO,EAAE,OAAO,CAAC,EAAE,eAAe,GAAG,OAAO,CAAC,eAAe,CAAC,CAiC1G;AAED,wBAAsB,wBAAwB,CAAC,IAAI,EAAE,OAAO,EAAE,OAAO,CAAC,EAAE,eAAe,GAAG,OAAO,CAAC,eAAe,CAAC,CAoDjH;AAED,wBAAsB,0BAA0B,CAAC,IAAI,EAAE,OAAO,EAAE,OAAO,CAAC,EAAE,eAAe,GAAG,OAAO,CAAC,eAAe,CAAC,CAmDnH;AAED,wBAAsB,wBAAwB,CAAC,IAAI,EAAE,OAAO,EAAE,OAAO,CAAC,EAAE,eAAe,GAAG,OAAO,CAAC,eAAe,CAAC,CAyCjH;AAED,wBAAsB,oBAAoB,CACxC,IAAI,EAAE,OAAO,EACb,UAAU,EAAE,cAAc,EAC1B,OAAO,CAAC,EAAE,eAAe,GACxB,OAAO,CAAC,eAAe,CAAC,CA8H1B;AAeD,wBAAsB,oBAAoB,CAAC,IAAI,EAAE,OAAO,EAAE,OAAO,CAAC,EAAE,eAAe,GAAG,OAAO,CAAC,eAAe,CAAC,CAsC7G;AAED,wBAAsB,mBAAmB,CAAC,IAAI,EAAE,OAAO,EAAE,OAAO,CAAC,EAAE,eAAe,GAAG,OAAO,CAAC,eAAe,CAAC,CAiE5G;AAED,wBAAsB,sBAAsB,CAC1C,IAAI,EAAE,OAAO,EACb,UAAU,EAAE,cAAc,EAC1B,OAAO,CAAC,EAAE,eAAe,GACxB,OAAO,CAAC,eAAe,CAAC,CA0F1B;AAED,wBAAsB,qBAAqB,CACzC,IAAI,EAAE,OAAO,EACb,UAAU,EAAE,cAAc,EAC1B,OAAO,CAAC,EAAE,eAAe,GACxB,OAAO,CAAC,eAAe,CAAC,CAoK1B;AAQD,wBAAsB,kBAAkB,CAAC,IAAI,EAAE,OAAO,EAAE,OAAO,CAAC,EAAE,eAAe,GAAG,OAAO,CAAC,eAAe,CAAC,CAwJ3G;AAED,wBAAsB,kBAAkB,CAAC,IAAI,EAAE,OAAO,EAAE,OAAO,CAAC,EAAE,eAAe,GAAG,OAAO,CAAC,eAAe,CAAC,CA8H3G;AAED,wBAAsB,oBAAoB,CAAC,IAAI,EAAE,OAAO,EAAE,OAAO,CAAC,EAAE,eAAe,GAAG,OAAO,CAAC,eAAe,CAAC,CAgD7G;AAED,wBAAsB,qBAAqB,CAAC,IAAI,EAAE,OAAO,EAAE,OAAO,CAAC,EAAE,eAAe,GAAG,OAAO,CAAC,eAAe,CAAC,CAiC9G;AAID,wBAAsB,iBAAiB,CAAC,OAAO,CAAC,EAAE,eAAe,GAAG,OAAO,CAAC,eAAe,CAAC,CAwG3F;AAkLD,wBAAsB,gBAAgB,CAAC,OAAO,EAAE,GAAG,EAAE,OAAO,CAAC,EAAE,eAAe,GAAG,OAAO,CAAC,eAAe,CAAC,CAkQxG;AAED,wBAAsB,sBAAsB,CAC1C,IAAI,EAAE,OAAO,EACb,UAAU,EAAE,cAAc,EAC1B,OAAO,CAAC,EAAE,eAAe,GACxB,OAAO,CAAC,eAAe,CAAC,CAsL1B;AA+BD,wBAAsB,oBAAoB,CACxC,IAAI,EAAE,OAAO,EACb,eAAe,EAAE,eAAe,EAChC,UAAU,EAAE,cAAc,EAC1B,OAAO,CAAC,EAAE,eAAe,GACxB,OAAO,CAAC,eAAe,CAAC,CAoM1B;AAQD,wBAAsB,4BAA4B,CAAC,IAAI,EAAE,OAAO,EAAE,OAAO,CAAC,EAAE,eAAe,GAAG,OAAO,CAAC,eAAe,CAAC,CAyErH"}
--- a/dist/mcp/handlers-n8n-manager.js
+++ b/dist/mcp/handlers-n8n-manager.js
@@ -56,16 +56,6 @@ exports.handleDiagnostic = handleDiagnostic;
 exports.handleWorkflowVersions = handleWorkflowVersions;
 exports.handleDeployTemplate = handleDeployTemplate;
 exports.handleTriggerWebhookWorkflow = handleTriggerWebhookWorkflow;
-exports.handleCreateTable = handleCreateTable;
-exports.handleListTables = handleListTables;
-exports.handleGetTable = handleGetTable;
-exports.handleUpdateTable = handleUpdateTable;
-exports.handleDeleteTable = handleDeleteTable;
-exports.handleGetRows = handleGetRows;
-exports.handleInsertRows = handleInsertRows;
-exports.handleUpdateRows = handleUpdateRows;
-exports.handleUpsertRows = handleUpsertRows;
-exports.handleDeleteRows = handleDeleteRows;
 const n8n_api_client_1 = require("../services/n8n-api-client");
 const n8n_api_1 = require("../config/n8n-api");
 const n8n_api_2 = require("../types/n8n-api");
@@ -185,7 +175,6 @@ const createWorkflowSchema = zod_1.z.object({
        executionTimeout: zod_1.z.number().optional(),
        errorWorkflow: zod_1.z.string().optional(),
    }).optional(),
-    projectId: zod_1.z.string().optional(),
 });
 const updateWorkflowSchema = zod_1.z.object({
    id: zod_1.z.string(),
@@ -1481,7 +1470,7 @@ async function handleDiagnostic(request, context) {
        }
    }
    const documentationTools = 7;
-    const managementTools = apiConfigured ? 14 : 0;
+    const managementTools = apiConfigured ? 13 : 0;
    const totalTools = documentationTools + managementTools;
    const versionCheck = await (0, npm_version_checker_1.checkNpmVersion)();
    const cacheMetricsData = getInstanceCacheMetrics();
@@ -2049,241 +2038,4 @@ async function handleTriggerWebhookWorkflow(args, context) {
        };
    }
 }
-const dataTableFilterConditionSchema = zod_1.z.object({
-    columnName: zod_1.z.string().min(1),
-    condition: zod_1.z.enum(['eq', 'neq', 'like', 'ilike', 'gt', 'gte', 'lt', 'lte']),
-    value: zod_1.z.any(),
-});
-const dataTableFilterSchema = zod_1.z.object({
-    type: zod_1.z.enum(['and', 'or']).optional().default('and'),
-    filters: zod_1.z.array(dataTableFilterConditionSchema).min(1, 'At least one filter condition is required'),
-});
-const tableIdSchema = zod_1.z.object({
-    tableId: zod_1.z.string().min(1, 'tableId is required'),
-});
-const createTableSchema = zod_1.z.object({
-    name: zod_1.z.string().min(1, 'Table name cannot be empty'),
-    columns: zod_1.z.array(zod_1.z.object({
-        name: zod_1.z.string().min(1, 'Column name cannot be empty'),
-        type: zod_1.z.enum(['string', 'number', 'boolean', 'date']).optional(),
-    })).optional(),
-});
-const listTablesSchema = zod_1.z.object({
-    limit: zod_1.z.number().min(1).max(100).optional(),
-    cursor: zod_1.z.string().optional(),
-});
-const updateTableSchema = tableIdSchema.extend({
-    name: zod_1.z.string().min(1, 'New table name cannot be empty'),
-});
-function tryParseJson(val) {
-    if (typeof val !== 'string')
-        return val;
-    try {
-        return JSON.parse(val);
-    }
-    catch {
-        return val;
-    }
-}
-const coerceJsonArray = zod_1.z.preprocess(tryParseJson, zod_1.z.array(zod_1.z.record(zod_1.z.unknown())));
-const coerceJsonObject = zod_1.z.preprocess(tryParseJson, zod_1.z.record(zod_1.z.unknown()));
-const coerceJsonFilter = zod_1.z.preprocess(tryParseJson, dataTableFilterSchema);
-const getRowsSchema = tableIdSchema.extend({
-    limit: zod_1.z.number().min(1).max(100).optional(),
-    cursor: zod_1.z.string().optional(),
-    filter: zod_1.z.union([coerceJsonFilter, zod_1.z.string()]).optional(),
-    sortBy: zod_1.z.string().optional(),
-    search: zod_1.z.string().optional(),
-});
-const insertRowsSchema = tableIdSchema.extend({
-    data: coerceJsonArray.pipe(zod_1.z.array(zod_1.z.record(zod_1.z.unknown())).min(1, 'At least one row is required')),
-    returnType: zod_1.z.enum(['count', 'id', 'all']).optional(),
-});
-const mutateRowsSchema = tableIdSchema.extend({
-    filter: coerceJsonFilter,
-    data: coerceJsonObject,
-    returnData: zod_1.z.boolean().optional(),
-    dryRun: zod_1.z.boolean().optional(),
-});
-const deleteRowsSchema = tableIdSchema.extend({
-    filter: coerceJsonFilter,
-    returnData: zod_1.z.boolean().optional(),
-    dryRun: zod_1.z.boolean().optional(),
-});
-function handleDataTableError(error) {
-    if (error instanceof zod_1.z.ZodError) {
-        return { success: false, error: 'Invalid input', details: { errors: error.errors } };
-    }
-    if (error instanceof n8n_errors_1.N8nApiError) {
-        return {
-            success: false,
-            error: (0, n8n_errors_1.getUserFriendlyErrorMessage)(error),
-            code: error.code,
-            details: error.details,
-        };
-    }
-    return { success: false, error: error instanceof Error ? error.message : 'Unknown error occurred' };
-}
-async function handleCreateTable(args, context) {
-    try {
-        const client = ensureApiConfigured(context);
-        const input = createTableSchema.parse(args);
-        const dataTable = await client.createDataTable(input);
-        if (!dataTable || !dataTable.id) {
-            return { success: false, error: 'Data table creation failed: n8n API returned an empty or invalid response' };
-        }
-        return {
-            success: true,
-            data: { id: dataTable.id, name: dataTable.name },
-            message: `Data table "${dataTable.name}" created with ID: ${dataTable.id}`,
-        };
-    }
-    catch (error) {
-        return handleDataTableError(error);
-    }
-}
-async function handleListTables(args, context) {
-    try {
-        const client = ensureApiConfigured(context);
-        const input = listTablesSchema.parse(args || {});
-        const result = await client.listDataTables(input);
-        return {
-            success: true,
-            data: {
-                tables: result.data,
-                count: result.data.length,
-                nextCursor: result.nextCursor || undefined,
-            },
-        };
-    }
-    catch (error) {
-        return handleDataTableError(error);
-    }
-}
-async function handleGetTable(args, context) {
-    try {
-        const client = ensureApiConfigured(context);
-        const { tableId } = tableIdSchema.parse(args);
-        const dataTable = await client.getDataTable(tableId);
-        return { success: true, data: dataTable };
-    }
-    catch (error) {
-        return handleDataTableError(error);
-    }
-}
-async function handleUpdateTable(args, context) {
-    try {
-        const client = ensureApiConfigured(context);
-        const { tableId, name } = updateTableSchema.parse(args);
-        const dataTable = await client.updateDataTable(tableId, { name });
-        return {
-            success: true,
-            data: dataTable,
-            message: `Data table renamed to "${dataTable.name}"`,
-        };
-    }
-    catch (error) {
-        return handleDataTableError(error);
-    }
-}
-async function handleDeleteTable(args, context) {
-    try {
-        const client = ensureApiConfigured(context);
-        const { tableId } = tableIdSchema.parse(args);
-        await client.deleteDataTable(tableId);
-        return { success: true, message: `Data table ${tableId} deleted successfully` };
-    }
-    catch (error) {
-        return handleDataTableError(error);
-    }
-}
-async function handleGetRows(args, context) {
-    try {
-        const client = ensureApiConfigured(context);
-        const { tableId, filter, sortBy, ...params } = getRowsSchema.parse(args);
-        const queryParams = { ...params };
-        if (filter) {
-            queryParams.filter = typeof filter === 'string' ? filter : JSON.stringify(filter);
-        }
-        if (sortBy) {
-            queryParams.sortBy = sortBy;
-        }
-        const result = await client.getDataTableRows(tableId, queryParams);
-        return {
-            success: true,
-            data: {
-                rows: result.data,
-                count: result.data.length,
-                nextCursor: result.nextCursor || undefined,
-            },
-        };
-    }
-    catch (error) {
-        return handleDataTableError(error);
-    }
-}
-async function handleInsertRows(args, context) {
-    try {
-        const client = ensureApiConfigured(context);
-        const { tableId, ...params } = insertRowsSchema.parse(args);
-        const result = await client.insertDataTableRows(tableId, params);
-        return {
-            success: true,
-            data: result,
-            message: `Rows inserted into data table ${tableId}`,
-        };
-    }
-    catch (error) {
-        return handleDataTableError(error);
-    }
-}
-async function handleUpdateRows(args, context) {
-    try {
-        const client = ensureApiConfigured(context);
-        const { tableId, ...params } = mutateRowsSchema.parse(args);
-        const result = await client.updateDataTableRows(tableId, params);
-        return {
-            success: true,
-            data: result,
-            message: params.dryRun ? 'Dry run: rows matched (no changes applied)' : 'Rows updated successfully',
-        };
-    }
-    catch (error) {
-        return handleDataTableError(error);
-    }
-}
-async function handleUpsertRows(args, context) {
-    try {
-        const client = ensureApiConfigured(context);
-        const { tableId, ...params } = mutateRowsSchema.parse(args);
-        const result = await client.upsertDataTableRow(tableId, params);
-        return {
-            success: true,
-            data: result,
-            message: params.dryRun ? 'Dry run: upsert previewed (no changes applied)' : 'Row upserted successfully',
-        };
-    }
-    catch (error) {
-        return handleDataTableError(error);
-    }
-}
-async function handleDeleteRows(args, context) {
-    try {
-        const client = ensureApiConfigured(context);
-        const { tableId, filter, ...params } = deleteRowsSchema.parse(args);
-        const queryParams = {
-            filter: JSON.stringify(filter),
-            ...params,
-        };
-        const result = await client.deleteDataTableRows(tableId, queryParams);
-        return {
-            success: true,
-            data: result,
-            message: params.dryRun ? 'Dry run: rows matched for deletion (no changes applied)' : 'Rows deleted successfully',
-        };
-    }
-    catch (error) {
-        return handleDataTableError(error);
-    }
-}
 //# sourceMappingURL=handlers-n8n-manager.js.map
--- a/dist/mcp/handlers-n8n-manager.js.map
+++ b/dist/mcp/handlers-n8n-manager.js.map
--- a/dist/mcp/server.d.ts.map
+++ b/dist/mcp/server.d.ts.map
@@ -1 +1 @@
-{"version":3,"file":"server.d.ts","sourceRoot":"","sources":["../../src/mcp/server.ts"],"names":[],"mappings":"AA0CA,OAAO,EAAE,eAAe,EAAE,MAAM,2BAA2B,CAAC;AAE5D,OAAO,EAAE,gBAAgB,EAAE,MAAM,iCAAiC,CAAC;AAmGnE,qBAAa,yBAAyB;IACpC,OAAO,CAAC,MAAM,CAAS;IACvB,OAAO,CAAC,EAAE,CAAgC;IAC1C,OAAO,CAAC,UAAU,CAA+B;IACjD,OAAO,CAAC,eAAe,CAAgC;IACvD,OAAO,CAAC,WAAW,CAAgB;IACnC,OAAO,CAAC,KAAK,CAAqB;IAClC,OAAO,CAAC,UAAU,CAAa;IAC/B,OAAO,CAAC,eAAe,CAAC,CAAkB;IAC1C,OAAO,CAAC,YAAY,CAAuB;IAC3C,OAAO,CAAC,qBAAqB,CAAsB;IACnD,OAAO,CAAC,WAAW,CAAiC;IACpD,OAAO,CAAC,kBAAkB,CAA4B;IACtD,OAAO,CAAC,iBAAiB,CAAkB;IAC3C,OAAO,CAAC,aAAa,CAAoC;IACzD,OAAO,CAAC,UAAU,CAAkB;gBAExB,eAAe,CAAC,EAAE,eAAe,EAAE,WAAW,CAAC,EAAE,gBAAgB;IA8GvE,KAAK,IAAI,OAAO,CAAC,IAAI,CAAC;YA+Cd,kBAAkB;YAiDlB,wBAAwB;IA0BtC,OAAO,CAAC,kBAAkB;YA6CZ,iBAAiB;IAa/B,OAAO,CAAC,eAAe,CAAkB;YAE3B,sBAAsB;IAgDpC,OAAO,CAAC,gBAAgB;IAqCxB,OAAO,CAAC,aAAa;IA0XrB,OAAO,CAAC,wBAAwB;IAoFhC,OAAO,CAAC,kBAAkB;IA0E1B,OAAO,CAAC,uBAAuB;IAwB/B,OAAO,CAAC,qBAAqB;IAiF7B,OAAO,CAAC,2BAA2B;YA8VrB,SAAS;YA2DT,WAAW;YAkFX,WAAW;YA0CX,cAAc;YA8Md,gBAAgB;IAqD9B,OAAO,CAAC,mBAAmB;IAwE3B,OAAO,CAAC,eAAe;YAsBT,eAAe;IA2L7B,OAAO,CAAC,kBAAkB;IAQ1B,OAAO,CAAC,uBAAuB;IA0D/B,OAAO,CAAC,iBAAiB;YAqFX,WAAW;YAgCX,oBAAoB;IAuFlC,OAAO,CAAC,aAAa;YAQP,qBAAqB;YAwDrB,iBAAiB;YAiKjB,OAAO;YAgDP,cAAc;YAwFd,iBAAiB;IAqC/B,OAAO,CAAC,iBAAiB;IA0BzB,OAAO,CAAC,iBAAiB;IA0BzB,OAAO,CAAC,eAAe;IAwCvB,OAAO,CAAC,kBAAkB;IAiC1B,OAAO,CAAC,aAAa;IAoCrB,OAAO,CAAC,0BAA0B;IAgClC,OAAO,CAAC,4BAA4B;YAKtB,oBAAoB;IAsDlC,OAAO,CAAC,gBAAgB;YAiBV,SAAS;YA6CT,kBAAkB;YAqElB,uBAAuB;YAsDvB,iBAAiB;IAqE/B,OAAO,CAAC,qBAAqB;IA8C7B,OAAO,CAAC,uBAAuB;IA4D/B,OAAO,CAAC,wBAAwB;IAkChC,OAAO,CAAC,iBAAiB;YAoDX,mBAAmB;YAoEnB,qBAAqB;IAS7B,OAAO,CAAC,SAAS,EAAE,GAAG,GAAG,OAAO,CAAC,IAAI,CAAC;YAS9B,aAAa;YAcb,iBAAiB;YAoBjB,WAAW;YAwBX,eAAe;YAqBf,mBAAmB;YAwBnB,yBAAyB;IA4CvC,OAAO,CAAC,kBAAkB;YAiBZ,gBAAgB;YA6HhB,2BAA2B;YAiE3B,2BAA2B;IAyEnC,GAAG,IAAI,OAAO,CAAC,IAAI,CAAC;IA0BpB,QAAQ,IAAI,OAAO,CAAC,IAAI,CAAC;CAgEhC"}
+{"version":3,"file":"server.d.ts","sourceRoot":"","sources":["../../src/mcp/server.ts"],"names":[],"mappings":"AA0CA,OAAO,EAAE,eAAe,EAAE,MAAM,2BAA2B,CAAC;AAE5D,OAAO,EAAE,gBAAgB,EAAE,MAAM,iCAAiC,CAAC;AAmGnE,qBAAa,yBAAyB;IACpC,OAAO,CAAC,MAAM,CAAS;IACvB,OAAO,CAAC,EAAE,CAAgC;IAC1C,OAAO,CAAC,UAAU,CAA+B;IACjD,OAAO,CAAC,eAAe,CAAgC;IACvD,OAAO,CAAC,WAAW,CAAgB;IACnC,OAAO,CAAC,KAAK,CAAqB;IAClC,OAAO,CAAC,UAAU,CAAa;IAC/B,OAAO,CAAC,eAAe,CAAC,CAAkB;IAC1C,OAAO,CAAC,YAAY,CAAuB;IAC3C,OAAO,CAAC,qBAAqB,CAAsB;IACnD,OAAO,CAAC,WAAW,CAAiC;IACpD,OAAO,CAAC,kBAAkB,CAA4B;IACtD,OAAO,CAAC,iBAAiB,CAAkB;IAC3C,OAAO,CAAC,aAAa,CAAoC;IACzD,OAAO,CAAC,UAAU,CAAkB;gBAExB,eAAe,CAAC,EAAE,eAAe,EAAE,WAAW,CAAC,EAAE,gBAAgB;IA8GvE,KAAK,IAAI,OAAO,CAAC,IAAI,CAAC;YA+Cd,kBAAkB;YAiDlB,wBAAwB;IA0BtC,OAAO,CAAC,kBAAkB;YA6CZ,iBAAiB;IAa/B,OAAO,CAAC,eAAe,CAAkB;YAE3B,sBAAsB;IAgDpC,OAAO,CAAC,gBAAgB;IAqCxB,OAAO,CAAC,aAAa;IA0XrB,OAAO,CAAC,wBAAwB;IAoFhC,OAAO,CAAC,kBAAkB;IAqE1B,OAAO,CAAC,uBAAuB;IAwB/B,OAAO,CAAC,qBAAqB;IAiF7B,OAAO,CAAC,2BAA2B;YA0UrB,SAAS;YA2DT,WAAW;YAkFX,WAAW;YA0CX,cAAc;YA8Md,gBAAgB;IAqD9B,OAAO,CAAC,mBAAmB;IAwE3B,OAAO,CAAC,eAAe;YAsBT,eAAe;IA2L7B,OAAO,CAAC,kBAAkB;IAQ1B,OAAO,CAAC,uBAAuB;IA0D/B,OAAO,CAAC,iBAAiB;YAqFX,WAAW;YAgCX,oBAAoB;IAuFlC,OAAO,CAAC,aAAa;YAQP,qBAAqB;YAwDrB,iBAAiB;YAiKjB,OAAO;YAgDP,cAAc;YAwFd,iBAAiB;IAqC/B,OAAO,CAAC,iBAAiB;IA0BzB,OAAO,CAAC,iBAAiB;IA0BzB,OAAO,CAAC,eAAe;IAwCvB,OAAO,CAAC,kBAAkB;IAiC1B,OAAO,CAAC,aAAa;IAoCrB,OAAO,CAAC,0BAA0B;IAgClC,OAAO,CAAC,4BAA4B;YAKtB,oBAAoB;IAsDlC,OAAO,CAAC,gBAAgB;YAiBV,SAAS;YA6CT,kBAAkB;YAqElB,uBAAuB;YAsDvB,iBAAiB;IAqE/B,OAAO,CAAC,qBAAqB;IA8C7B,OAAO,CAAC,uBAAuB;IA4D/B,OAAO,CAAC,wBAAwB;IAkChC,OAAO,CAAC,iBAAiB;YAoDX,mBAAmB;YAoEnB,qBAAqB;IAS7B,OAAO,CAAC,SAAS,EAAE,GAAG,GAAG,OAAO,CAAC,IAAI,CAAC;YAS9B,aAAa;YAcb,iBAAiB;YAoBjB,WAAW;YAwBX,eAAe;YAqBf,mBAAmB;YAwBnB,yBAAyB;IA4CvC,OAAO,CAAC,kBAAkB;YAiBZ,gBAAgB;YA6HhB,2BAA2B;YAiE3B,2BAA2B;IAyEnC,GAAG,IAAI,OAAO,CAAC,IAAI,CAAC;IA0BpB,QAAQ,IAAI,OAAO,CAAC,IAAI,CAAC;CAgEhC"}
--- a/dist/mcp/server.js
+++ b/dist/mcp/server.js
@@ -720,11 +720,6 @@ class N8NDocumentationMCPServer {
                        ? { valid: true, errors: [] }
                        : { valid: false, errors: [{ field: 'action', message: 'action is required' }] };
                    break;
-                case 'n8n_manage_datatable':
-                    validationResult = args.action
-                        ? { valid: true, errors: [] }
-                        : { valid: false, errors: [{ field: 'action', message: 'action is required' }] };
-                    break;
                case 'n8n_deploy_template':
                    validationResult = args.templateId !== undefined
                        ? { valid: true, errors: [] }
@@ -1114,24 +1109,6 @@ class N8NDocumentationMCPServer {
                if (!this.repository)
                    throw new Error('Repository not initialized');
                return n8nHandlers.handleDeployTemplate(args, this.templateService, this.repository, this.instanceContext);
-            case 'n8n_manage_datatable': {
-                this.validateToolParams(name, args, ['action']);
-                const dtAction = args.action;
-                switch (dtAction) {
-                    case 'createTable': return n8nHandlers.handleCreateTable(args, this.instanceContext);
-                    case 'listTables': return n8nHandlers.handleListTables(args, this.instanceContext);
-                    case 'getTable': return n8nHandlers.handleGetTable(args, this.instanceContext);
-                    case 'updateTable': return n8nHandlers.handleUpdateTable(args, this.instanceContext);
-                    case 'deleteTable': return n8nHandlers.handleDeleteTable(args, this.instanceContext);
-                    case 'getRows': return n8nHandlers.handleGetRows(args, this.instanceContext);
-                    case 'insertRows': return n8nHandlers.handleInsertRows(args, this.instanceContext);
-                    case 'updateRows': return n8nHandlers.handleUpdateRows(args, this.instanceContext);
-                    case 'upsertRows': return n8nHandlers.handleUpsertRows(args, this.instanceContext);
-                    case 'deleteRows': return n8nHandlers.handleDeleteRows(args, this.instanceContext);
-                    default:
-                        throw new Error(`Unknown action: ${dtAction}. Valid actions: createTable, listTables, getTable, updateTable, deleteTable, getRows, insertRows, updateRows, upsertRows, deleteRows`);
-                }
-            }
            default:
                throw new Error(`Unknown tool: ${name}`);
        }
--- a/dist/mcp/server.js.map
+++ b/dist/mcp/server.js.map
--- a/dist/mcp/tool-docs/index.d.ts.map
+++ b/dist/mcp/tool-docs/index.d.ts.map
@@ -1 +1 @@
-{"version":3,"file":"index.d.ts","sourceRoot":"","sources":["../../../src/mcp/tool-docs/index.ts"],"names":[],"mappings":"AAAA,OAAO,EAAE,iBAAiB,EAAE,MAAM,SAAS,CAAC;AA6B5C,eAAO,MAAM,kBAAkB,EAAE,MAAM,CAAC,MAAM,EAAE,iBAAiB,CAoChE,CAAC;AAGF,YAAY,EAAE,iBAAiB,EAAE,MAAM,SAAS,CAAC"}
+{"version":3,"file":"index.d.ts","sourceRoot":"","sources":["../../../src/mcp/tool-docs/index.ts"],"names":[],"mappings":"AAAA,OAAO,EAAE,iBAAiB,EAAE,MAAM,SAAS,CAAC;AA4B5C,eAAO,MAAM,kBAAkB,EAAE,MAAM,CAAC,MAAM,EAAE,iBAAiB,CAmChE,CAAC;AAGF,YAAY,EAAE,iBAAiB,EAAE,MAAM,SAAS,CAAC"}
--- a/dist/mcp/tool-docs/index.js
+++ b/dist/mcp/tool-docs/index.js
@@ -29,7 +29,6 @@ exports.toolsDocumentation = {
    n8n_test_workflow: workflow_management_1.n8nTestWorkflowDoc,
    n8n_executions: workflow_management_1.n8nExecutionsDoc,
    n8n_workflow_versions: workflow_management_1.n8nWorkflowVersionsDoc,
-    n8n_deploy_template: workflow_management_1.n8nDeployTemplateDoc,
-    n8n_manage_datatable: workflow_management_1.n8nManageDatatableDoc
+    n8n_deploy_template: workflow_management_1.n8nDeployTemplateDoc
 };
 //# sourceMappingURL=index.js.map
--- a/dist/mcp/tool-docs/index.js.map
+++ b/dist/mcp/tool-docs/index.js.map
@@ -1 +1 @@
-{"version":3,"file":"index.js","sourceRoot":"","sources":["../../../src/mcp/tool-docs/index.ts"],"names":[],"mappings":";;;AAGA,2CAA6C;AAC7C,mDAA6C;AAC7C,6CAAoE;AACpE,2CAAiE;AACjE,qCAGkB;AAClB,qCAAyC;AACzC,+DAc+B;AAGlB,QAAA,kBAAkB,GAAsC;IAEnE,mBAAmB,EAAE,8BAAqB;IAC1C,gBAAgB,EAAE,0BAAiB;IAGnC,eAAe,EAAE,sBAAa;IAG9B,YAAY,EAAE,0BAAc;IAG5B,QAAQ,EAAE,0BAAU;IAGpB,aAAa,EAAE,4BAAe;IAC9B,iBAAiB,EAAE,gCAAmB;IAGtC,YAAY,EAAE,0BAAc;IAC5B,gBAAgB,EAAE,8BAAkB;IAGpC,mBAAmB,EAAE,0CAAoB;IACzC,gBAAgB,EAAE,uCAAiB;IACnC,wBAAwB,EAAE,8CAAwB;IAClD,2BAA2B,EAAE,iDAA2B;IACxD,mBAAmB,EAAE,0CAAoB;IACzC,kBAAkB,EAAE,yCAAmB;IACvC,qBAAqB,EAAE,4CAAsB;IAC7C,oBAAoB,EAAE,2CAAqB;IAC3C,iBAAiB,EAAE,wCAAkB;IACrC,cAAc,EAAE,sCAAgB;IAChC,qBAAqB,EAAE,4CAAsB;IAC7C,mBAAmB,EAAE,0CAAoB;IACzC,oBAAoB,EAAE,2CAAqB;CAC5C,CAAC"}
+{"version":3,"file":"index.js","sourceRoot":"","sources":["../../../src/mcp/tool-docs/index.ts"],"names":[],"mappings":";;;AAGA,2CAA6C;AAC7C,mDAA6C;AAC7C,6CAAoE;AACpE,2CAAiE;AACjE,qCAGkB;AAClB,qCAAyC;AACzC,+DAa+B;AAGlB,QAAA,kBAAkB,GAAsC;IAEnE,mBAAmB,EAAE,8BAAqB;IAC1C,gBAAgB,EAAE,0BAAiB;IAGnC,eAAe,EAAE,sBAAa;IAG9B,YAAY,EAAE,0BAAc;IAG5B,QAAQ,EAAE,0BAAU;IAGpB,aAAa,EAAE,4BAAe;IAC9B,iBAAiB,EAAE,gCAAmB;IAGtC,YAAY,EAAE,0BAAc;IAC5B,gBAAgB,EAAE,8BAAkB;IAGpC,mBAAmB,EAAE,0CAAoB;IACzC,gBAAgB,EAAE,uCAAiB;IACnC,wBAAwB,EAAE,8CAAwB;IAClD,2BAA2B,EAAE,iDAA2B;IACxD,mBAAmB,EAAE,0CAAoB;IACzC,kBAAkB,EAAE,yCAAmB;IACvC,qBAAqB,EAAE,4CAAsB;IAC7C,oBAAoB,EAAE,2CAAqB;IAC3C,iBAAiB,EAAE,wCAAkB;IACrC,cAAc,EAAE,sCAAgB;IAChC,qBAAqB,EAAE,4CAAsB;IAC7C,mBAAmB,EAAE,0CAAoB;CAC1C,CAAC"}
--- a/dist/mcp/tool-docs/workflow_management/index.d.ts
+++ b/dist/mcp/tool-docs/workflow_management/index.d.ts
@@ -10,5 +10,4 @@ export { n8nTestWorkflowDoc } from './n8n-test-workflow';
 export { n8nExecutionsDoc } from './n8n-executions';
 export { n8nWorkflowVersionsDoc } from './n8n-workflow-versions';
 export { n8nDeployTemplateDoc } from './n8n-deploy-template';
-export { n8nManageDatatableDoc } from './n8n-manage-datatable';
 //# sourceMappingURL=index.d.ts.map
--- a/dist/mcp/tool-docs/workflow_management/index.d.ts.map
+++ b/dist/mcp/tool-docs/workflow_management/index.d.ts.map
@@ -1 +1 @@
-{"version":3,"file":"index.d.ts","sourceRoot":"","sources":["../../../../src/mcp/tool-docs/workflow_management/index.ts"],"names":[],"mappings":"AAAA,OAAO,EAAE,oBAAoB,EAAE,MAAM,uBAAuB,CAAC;AAC7D,OAAO,EAAE,iBAAiB,EAAE,MAAM,oBAAoB,CAAC;AACvD,OAAO,EAAE,wBAAwB,EAAE,MAAM,4BAA4B,CAAC;AACtE,OAAO,EAAE,2BAA2B,EAAE,MAAM,+BAA+B,CAAC;AAC5E,OAAO,EAAE,oBAAoB,EAAE,MAAM,uBAAuB,CAAC;AAC7D,OAAO,EAAE,mBAAmB,EAAE,MAAM,sBAAsB,CAAC;AAC3D,OAAO,EAAE,sBAAsB,EAAE,MAAM,yBAAyB,CAAC;AACjE,OAAO,EAAE,qBAAqB,EAAE,MAAM,wBAAwB,CAAC;AAC/D,OAAO,EAAE,kBAAkB,EAAE,MAAM,qBAAqB,CAAC;AACzD,OAAO,EAAE,gBAAgB,EAAE,MAAM,kBAAkB,CAAC;AACpD,OAAO,EAAE,sBAAsB,EAAE,MAAM,yBAAyB,CAAC;AACjE,OAAO,EAAE,oBAAoB,EAAE,MAAM,uBAAuB,CAAC;AAC7D,OAAO,EAAE,qBAAqB,EAAE,MAAM,wBAAwB,CAAC"}
+{"version":3,"file":"index.d.ts","sourceRoot":"","sources":["../../../../src/mcp/tool-docs/workflow_management/index.ts"],"names":[],"mappings":"AAAA,OAAO,EAAE,oBAAoB,EAAE,MAAM,uBAAuB,CAAC;AAC7D,OAAO,EAAE,iBAAiB,EAAE,MAAM,oBAAoB,CAAC;AACvD,OAAO,EAAE,wBAAwB,EAAE,MAAM,4BAA4B,CAAC;AACtE,OAAO,EAAE,2BAA2B,EAAE,MAAM,+BAA+B,CAAC;AAC5E,OAAO,EAAE,oBAAoB,EAAE,MAAM,uBAAuB,CAAC;AAC7D,OAAO,EAAE,mBAAmB,EAAE,MAAM,sBAAsB,CAAC;AAC3D,OAAO,EAAE,sBAAsB,EAAE,MAAM,yBAAyB,CAAC;AACjE,OAAO,EAAE,qBAAqB,EAAE,MAAM,wBAAwB,CAAC;AAC/D,OAAO,EAAE,kBAAkB,EAAE,MAAM,qBAAqB,CAAC;AACzD,OAAO,EAAE,gBAAgB,EAAE,MAAM,kBAAkB,CAAC;AACpD,OAAO,EAAE,sBAAsB,EAAE,MAAM,yBAAyB,CAAC;AACjE,OAAO,EAAE,oBAAoB,EAAE,MAAM,uBAAuB,CAAC"}
--- a/dist/mcp/tool-docs/workflow_management/index.js
+++ b/dist/mcp/tool-docs/workflow_management/index.js
@@ -1,6 +1,6 @@
 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-exports.n8nManageDatatableDoc = exports.n8nDeployTemplateDoc = exports.n8nWorkflowVersionsDoc = exports.n8nExecutionsDoc = exports.n8nTestWorkflowDoc = exports.n8nAutofixWorkflowDoc = exports.n8nValidateWorkflowDoc = exports.n8nListWorkflowsDoc = exports.n8nDeleteWorkflowDoc = exports.n8nUpdatePartialWorkflowDoc = exports.n8nUpdateFullWorkflowDoc = exports.n8nGetWorkflowDoc = exports.n8nCreateWorkflowDoc = void 0;
+exports.n8nDeployTemplateDoc = exports.n8nWorkflowVersionsDoc = exports.n8nExecutionsDoc = exports.n8nTestWorkflowDoc = exports.n8nAutofixWorkflowDoc = exports.n8nValidateWorkflowDoc = exports.n8nListWorkflowsDoc = exports.n8nDeleteWorkflowDoc = exports.n8nUpdatePartialWorkflowDoc = exports.n8nUpdateFullWorkflowDoc = exports.n8nGetWorkflowDoc = exports.n8nCreateWorkflowDoc = void 0;
 var n8n_create_workflow_1 = require("./n8n-create-workflow");
 Object.defineProperty(exports, "n8nCreateWorkflowDoc", { enumerable: true, get: function () { return n8n_create_workflow_1.n8nCreateWorkflowDoc; } });
 var n8n_get_workflow_1 = require("./n8n-get-workflow");
@@ -25,6 +25,4 @@ var n8n_workflow_versions_1 = require("./n8n-workflow-versions");
 Object.defineProperty(exports, "n8nWorkflowVersionsDoc", { enumerable: true, get: function () { return n8n_workflow_versions_1.n8nWorkflowVersionsDoc; } });
 var n8n_deploy_template_1 = require("./n8n-deploy-template");
 Object.defineProperty(exports, "n8nDeployTemplateDoc", { enumerable: true, get: function () { return n8n_deploy_template_1.n8nDeployTemplateDoc; } });
-var n8n_manage_datatable_1 = require("./n8n-manage-datatable");
-Object.defineProperty(exports, "n8nManageDatatableDoc", { enumerable: true, get: function () { return n8n_manage_datatable_1.n8nManageDatatableDoc; } });
 //# sourceMappingURL=index.js.map
--- a/dist/mcp/tool-docs/workflow_management/index.js.map
+++ b/dist/mcp/tool-docs/workflow_management/index.js.map
@@ -1 +1 @@
-{"version":3,"file":"index.js","sourceRoot":"","sources":["../../../../src/mcp/tool-docs/workflow_management/index.ts"],"names":[],"mappings":";;;AAAA,6DAA6D;AAApD,2HAAA,oBAAoB,OAAA;AAC7B,uDAAuD;AAA9C,qHAAA,iBAAiB,OAAA;AAC1B,uEAAsE;AAA7D,oIAAA,wBAAwB,OAAA;AACjC,6EAA4E;AAAnE,0IAAA,2BAA2B,OAAA;AACpC,6DAA6D;AAApD,2HAAA,oBAAoB,OAAA;AAC7B,2DAA2D;AAAlD,yHAAA,mBAAmB,OAAA;AAC5B,iEAAiE;AAAxD,+HAAA,sBAAsB,OAAA;AAC/B,+DAA+D;AAAtD,6HAAA,qBAAqB,OAAA;AAC9B,yDAAyD;AAAhD,uHAAA,kBAAkB,OAAA;AAC3B,mDAAoD;AAA3C,kHAAA,gBAAgB,OAAA;AACzB,iEAAiE;AAAxD,+HAAA,sBAAsB,OAAA;AAC/B,6DAA6D;AAApD,2HAAA,oBAAoB,OAAA;AAC7B,+DAA+D;AAAtD,6HAAA,qBAAqB,OAAA"}
+{"version":3,"file":"index.js","sourceRoot":"","sources":["../../../../src/mcp/tool-docs/workflow_management/index.ts"],"names":[],"mappings":";;;AAAA,6DAA6D;AAApD,2HAAA,oBAAoB,OAAA;AAC7B,uDAAuD;AAA9C,qHAAA,iBAAiB,OAAA;AAC1B,uEAAsE;AAA7D,oIAAA,wBAAwB,OAAA;AACjC,6EAA4E;AAAnE,0IAAA,2BAA2B,OAAA;AACpC,6DAA6D;AAApD,2HAAA,oBAAoB,OAAA;AAC7B,2DAA2D;AAAlD,yHAAA,mBAAmB,OAAA;AAC5B,iEAAiE;AAAxD,+HAAA,sBAAsB,OAAA;AAC/B,+DAA+D;AAAtD,6HAAA,qBAAqB,OAAA;AAC9B,yDAAyD;AAAhD,uHAAA,kBAAkB,OAAA;AAC3B,mDAAoD;AAA3C,kHAAA,gBAAgB,OAAA;AACzB,iEAAiE;AAAxD,+HAAA,sBAAsB,OAAA;AAC/B,6DAA6D;AAApD,2HAAA,oBAAoB,OAAA"}
--- a/dist/mcp/tools-n8n-manager.d.ts.map
+++ b/dist/mcp/tools-n8n-manager.d.ts.map
@@ -1 +1 @@
-{"version":3,"file":"tools-n8n-manager.d.ts","sourceRoot":"","sources":["../../src/mcp/tools-n8n-manager.ts"],"names":[],"mappings":"AAAA,OAAO,EAAE,cAAc,EAAE,MAAM,UAAU,CAAC;AAQ1C,eAAO,MAAM,kBAAkB,EAAE,cAAc,EAwoB9C,CAAC"}
+{"version":3,"file":"tools-n8n-manager.d.ts","sourceRoot":"","sources":["../../src/mcp/tools-n8n-manager.ts"],"names":[],"mappings":"AAAA,OAAO,EAAE,cAAc,EAAE,MAAM,UAAU,CAAC;AAQ1C,eAAO,MAAM,kBAAkB,EAAE,cAAc,EAqlB9C,CAAC"}
--- a/dist/mcp/tools-n8n-manager.js
+++ b/dist/mcp/tools-n8n-manager.js
@@ -57,10 +57,6 @@ exports.n8nManagementTools = [
                        executionTimeout: { type: 'number' },
                        errorWorkflow: { type: 'string' }
                    }
-                },
-                projectId: {
-                    type: 'string',
-                    description: 'Optional project ID to create the workflow in (enterprise feature)'
                }
            },
            required: ['name', 'nodes', 'connections']
@@ -587,53 +583,6 @@ exports.n8nManagementTools = [
            destructiveHint: false,
            openWorldHint: true,
        },
-    },
-    {
-        name: 'n8n_manage_datatable',
-        description: `Manage n8n data tables and rows. Actions: createTable, listTables, getTable, updateTable, deleteTable, getRows, insertRows, updateRows, upsertRows, deleteRows. Requires n8n enterprise/cloud with data tables feature.`,
-        inputSchema: {
-            type: 'object',
-            properties: {
-                action: {
-                    type: 'string',
-                    enum: ['createTable', 'listTables', 'getTable', 'updateTable', 'deleteTable', 'getRows', 'insertRows', 'updateRows', 'upsertRows', 'deleteRows'],
-                    description: 'Operation to perform',
-                },
-                tableId: { type: 'string', description: 'Data table ID (required for all actions except createTable and listTables)' },
-                name: { type: 'string', description: 'For createTable/updateTable: table name' },
-                columns: {
-                    type: 'array',
-                    description: 'For createTable: column definitions',
-                    items: {
-                        type: 'object',
-                        properties: {
-                            name: { type: 'string' },
-                            type: { type: 'string', enum: ['string', 'number', 'boolean', 'date'] },
-                        },
-                        required: ['name'],
-                    },
-                },
-                data: { description: 'For insertRows: array of row objects. For updateRows/upsertRows: object with column values.' },
-                filter: {
-                    type: 'object',
-                    description: 'For getRows/updateRows/upsertRows/deleteRows: {type?: "and"|"or", filters: [{columnName, condition, value}]}',
-                },
-                limit: { type: 'number', description: 'For listTables/getRows: max results (1-100)' },
-                cursor: { type: 'string', description: 'For listTables/getRows: pagination cursor' },
-                sortBy: { type: 'string', description: 'For getRows: "columnName:asc" or "columnName:desc"' },
-                search: { type: 'string', description: 'For getRows: text search across string columns' },
-                returnType: { type: 'string', enum: ['count', 'id', 'all'], description: 'For insertRows: what to return (default: count)' },
-                returnData: { type: 'boolean', description: 'For updateRows/upsertRows/deleteRows: return affected rows (default: false)' },
-                dryRun: { type: 'boolean', description: 'For updateRows/upsertRows/deleteRows: preview without applying (default: false)' },
-            },
-            required: ['action'],
-        },
-        annotations: {
-            title: 'Manage Data Tables',
-            readOnlyHint: false,
-            destructiveHint: true,
-            openWorldHint: true,
-        },
-    },
+    }
 ];
 //# sourceMappingURL=tools-n8n-manager.js.map
--- a/dist/mcp/tools-n8n-manager.js.map
+++ b/dist/mcp/tools-n8n-manager.js.map
--- a/dist/services/n8n-api-client.d.ts
+++ b/dist/services/n8n-api-client.d.ts
@@ -1,4 +1,4 @@
-import { Workflow, WorkflowListParams, WorkflowListResponse, Execution, ExecutionListParams, ExecutionListResponse, Credential, CredentialListParams, CredentialListResponse, Tag, TagListParams, TagListResponse, HealthCheckResponse, N8nVersionInfo, Variable, WebhookRequest, SourceControlStatus, SourceControlPullResult, SourceControlPushResult, DataTable, DataTableColumn, DataTableListParams, DataTableRow, DataTableRowListParams, DataTableInsertRowsParams, DataTableUpdateRowsParams, DataTableUpsertRowParams, DataTableDeleteRowsParams } from '../types/n8n-api';
+import { Workflow, WorkflowListParams, WorkflowListResponse, Execution, ExecutionListParams, ExecutionListResponse, Credential, CredentialListParams, CredentialListResponse, Tag, TagListParams, TagListResponse, HealthCheckResponse, N8nVersionInfo, Variable, WebhookRequest, SourceControlStatus, SourceControlPullResult, SourceControlPushResult } from '../types/n8n-api';
 export interface N8nApiClientConfig {
    baseUrl: string;
    apiKey: string;
@@ -45,28 +45,6 @@ export declare class N8nApiClient {
    createVariable(variable: Partial<Variable>): Promise<Variable>;
    updateVariable(id: string, variable: Partial<Variable>): Promise<Variable>;
    deleteVariable(id: string): Promise<void>;
-    createDataTable(params: {
-        name: string;
-        columns?: DataTableColumn[];
-    }): Promise<DataTable>;
-    listDataTables(params?: DataTableListParams): Promise<{
-        data: DataTable[];
-        nextCursor?: string | null;
-    }>;
-    getDataTable(id: string): Promise<DataTable>;
-    updateDataTable(id: string, params: {
-        name: string;
-    }): Promise<DataTable>;
-    deleteDataTable(id: string): Promise<void>;
-    getDataTableRows(id: string, params?: DataTableRowListParams): Promise<{
-        data: DataTableRow[];
-        nextCursor?: string | null;
-    }>;
-    insertDataTableRows(id: string, params: DataTableInsertRowsParams): Promise<any>;
-    updateDataTableRows(id: string, params: DataTableUpdateRowsParams): Promise<any>;
-    upsertDataTableRow(id: string, params: DataTableUpsertRowParams): Promise<any>;
-    deleteDataTableRows(id: string, params: DataTableDeleteRowsParams): Promise<any>;
-    private serializeDataTableParams;
    private validateListResponse;
 }
 //# sourceMappingURL=n8n-api-client.d.ts.map
--- a/dist/services/n8n-api-client.d.ts.map
+++ b/dist/services/n8n-api-client.d.ts.map
@@ -1 +1 @@
-{"version":3,"file":"n8n-api-client.d.ts","sourceRoot":"","sources":["../../src/services/n8n-api-client.ts"],"names":[],"mappings":"AAEA,OAAO,EACL,QAAQ,EACR,kBAAkB,EAClB,oBAAoB,EACpB,SAAS,EACT,mBAAmB,EACnB,qBAAqB,EACrB,UAAU,EACV,oBAAoB,EACpB,sBAAsB,EACtB,GAAG,EACH,aAAa,EACb,eAAe,EACf,mBAAmB,EACnB,cAAc,EACd,QAAQ,EACR,cAAc,EAGd,mBAAmB,EACnB,uBAAuB,EACvB,uBAAuB,EACvB,SAAS,EACT,eAAe,EACf,mBAAmB,EACnB,YAAY,EACZ,sBAAsB,EACtB,yBAAyB,EACzB,yBAAyB,EACzB,wBAAwB,EACxB,yBAAyB,EAC1B,MAAM,kBAAkB,CAAC;AAS1B,MAAM,WAAW,kBAAkB;IACjC,OAAO,EAAE,MAAM,CAAC;IAChB,MAAM,EAAE,MAAM,CAAC;IACf,OAAO,CAAC,EAAE,MAAM,CAAC;IACjB,UAAU,CAAC,EAAE,MAAM,CAAC;CACrB;AAED,qBAAa,YAAY;IACvB,OAAO,CAAC,MAAM,CAAgB;IAC9B,OAAO,CAAC,UAAU,CAAS;IAC3B,OAAO,CAAC,OAAO,CAAS;IACxB,OAAO,CAAC,WAAW,CAA+B;IAClD,OAAO,CAAC,cAAc,CAA+C;gBAEzD,MAAM,EAAE,kBAAkB;IAqDhC,UAAU,IAAI,OAAO,CAAC,cAAc,GAAG,IAAI,CAAC;YAyBpC,gBAAgB;IAa9B,oBAAoB,IAAI,cAAc,GAAG,IAAI;IAKvC,WAAW,IAAI,OAAO,CAAC,mBAAmB,CAAC;IA6C3C,cAAc,CAAC,QAAQ,EAAE,OAAO,CAAC,QAAQ,CAAC,GAAG,OAAO,CAAC,QAAQ,CAAC;IAU9D,WAAW,CAAC,EAAE,EAAE,MAAM,GAAG,OAAO,CAAC,QAAQ,CAAC;IAS1C,cAAc,CAAC,EAAE,EAAE,MAAM,EAAE,QAAQ,EAAE,OAAO,CAAC,QAAQ,CAAC,GAAG,OAAO,CAAC,QAAQ,CAAC;IAsC1E,cAAc,CAAC,EAAE,EAAE,MAAM,GAAG,OAAO,CAAC,QAAQ,CAAC;IAS7C,gBAAgB,CAAC,EAAE,EAAE,MAAM,EAAE,oBAAoB,EAAE,MAAM,GAAG,OAAO,CAAC,IAAI,CAAC;IAQzE,gBAAgB,CAAC,EAAE,EAAE,MAAM,GAAG,OAAO,CAAC,QAAQ,CAAC;IAS/C,kBAAkB,CAAC,EAAE,EAAE,MAAM,GAAG,OAAO,CAAC,QAAQ,CAAC;IAsBjD,aAAa,CAAC,MAAM,GAAE,kBAAuB,GAAG,OAAO,CAAC,oBAAoB,CAAC;IAU7E,YAAY,CAAC,EAAE,EAAE,MAAM,EAAE,WAAW,UAAQ,GAAG,OAAO,CAAC,SAAS,CAAC;IAwBjE,cAAc,CAAC,MAAM,GAAE,mBAAwB,GAAG,OAAO,CAAC,qBAAqB,CAAC;IAShF,eAAe,CAAC,EAAE,EAAE,MAAM,GAAG,OAAO,CAAC,IAAI,CAAC;IAS1C,cAAc,CAAC,OAAO,EAAE,cAAc,GAAG,OAAO,CAAC,GAAG,CAAC;IAiErD,eAAe,CAAC,MAAM,GAAE,oBAAyB,GAAG,OAAO,CAAC,sBAAsB,CAAC;IASnF,aAAa,CAAC,EAAE,EAAE,MAAM,GAAG,OAAO,CAAC,UAAU,CAAC;IAS9C,gBAAgB,CAAC,UAAU,EAAE,OAAO,CAAC,UAAU,CAAC,GAAG,OAAO,CAAC,UAAU,CAAC;IAStE,gBAAgB,CAAC,EAAE,EAAE,MAAM,EAAE,UAAU,EAAE,OAAO,CAAC,UAAU,CAAC,GAAG,OAAO,CAAC,UAAU,CAAC;IASlF,gBAAgB,CAAC,EAAE,EAAE,MAAM,GAAG,OAAO,CAAC,IAAI,CAAC;IAsB3C,QAAQ,CAAC,MAAM,GAAE,aAAkB,GAAG,OAAO,CAAC,eAAe,CAAC;IAS9D,SAAS,CAAC,GAAG,EAAE,OAAO,CAAC,GAAG,CAAC,GAAG,OAAO,CAAC,GAAG,CAAC;IAS1C,SAAS,CAAC,EAAE,EAAE,MAAM,EAAE,GAAG,EAAE,OAAO,CAAC,GAAG,CAAC,GAAG,OAAO,CAAC,GAAG,CAAC;IAStD,SAAS,CAAC,EAAE,EAAE,MAAM,GAAG,OAAO,CAAC,IAAI,CAAC;IAQpC,kBAAkB,CAAC,UAAU,EAAE,MAAM,EAAE,MAAM,EAAE,MAAM,EAAE,GAAG,OAAO,CAAC,GAAG,EAAE,CAAC;IAUxE,sBAAsB,IAAI,OAAO,CAAC,mBAAmB,CAAC;IAStD,iBAAiB,CAAC,KAAK,UAAQ,GAAG,OAAO,CAAC,uBAAuB,CAAC;IASlE,iBAAiB,CACrB,OAAO,EAAE,MAAM,EACf,SAAS,CAAC,EAAE,MAAM,EAAE,GACnB,OAAO,CAAC,uBAAuB,CAAC;IAa7B,YAAY,IAAI,OAAO,CAAC,QAAQ,EAAE,CAAC;IAWnC,cAAc,CAAC,QAAQ,EAAE,OAAO,CAAC,QAAQ,CAAC,GAAG,OAAO,CAAC,QAAQ,CAAC;IAS9D,cAAc,CAAC,EAAE,EAAE,MAAM,EAAE,QAAQ,EAAE,OAAO,CAAC,QAAQ,CAAC,GAAG,OAAO,CAAC,QAAQ,CAAC;IAS1E,cAAc,CAAC,EAAE,EAAE,MAAM,GAAG,OAAO,CAAC,IAAI,CAAC;IAQzC,eAAe,CAAC,MAAM,EAAE;QAAE,IAAI,EAAE,MAAM,CAAC;QAAC,OAAO,CAAC,EAAE,eAAe,EAAE,CAAA;KAAE,GAAG,OAAO,CAAC,SAAS,CAAC;IAS1F,cAAc,CAAC,MAAM,GAAE,mBAAwB,GAAG,OAAO,CAAC;QAAE,IAAI,EAAE,SAAS,EAAE,CAAC;QAAC,UAAU,CAAC,EAAE,MAAM,GAAG,IAAI,CAAA;KAAE,CAAC;IAS5G,YAAY,CAAC,EAAE,EAAE,MAAM,GAAG,OAAO,CAAC,SAAS,CAAC;IAS5C,eAAe,CAAC,EAAE,EAAE,MAAM,EAAE,MAAM,EAAE;QAAE,IAAI,EAAE,MAAM,CAAA;KAAE,GAAG,OAAO,CAAC,SAAS,CAAC;IASzE,eAAe,CAAC,EAAE,EAAE,MAAM,GAAG,OAAO,CAAC,IAAI,CAAC;IAQ1C,gBAAgB,CAAC,EAAE,EAAE,MAAM,EAAE,MAAM,GAAE,sBAA2B,GAAG,OAAO,CAAC;QAAE,IAAI,EAAE,YAAY,EAAE,CAAC;QAAC,UAAU,CAAC,EAAE,MAAM,GAAG,IAAI,CAAA;KAAE,CAAC;IAYhI,mBAAmB,CAAC,EAAE,EAAE,MAAM,EAAE,MAAM,EAAE,yBAAyB,GAAG,OAAO,CAAC,GAAG,CAAC;IAShF,mBAAmB,CAAC,EAAE,EAAE,MAAM,EAAE,MAAM,EAAE,yBAAyB,GAAG,OAAO,CAAC,GAAG,CAAC;IAShF,kBAAkB,CAAC,EAAE,EAAE,MAAM,EAAE,MAAM,EAAE,wBAAwB,GAAG,OAAO,CAAC,GAAG,CAAC;IAS9E,mBAAmB,CAAC,EAAE,EAAE,MAAM,EAAE,MAAM,EAAE,yBAAyB,GAAG,OAAO,CAAC,GAAG,CAAC;IAgBtF,OAAO,CAAC,wBAAwB;IAkBhC,OAAO,CAAC,oBAAoB;CAmC7B"}
+{"version":3,"file":"n8n-api-client.d.ts","sourceRoot":"","sources":["../../src/services/n8n-api-client.ts"],"names":[],"mappings":"AAEA,OAAO,EACL,QAAQ,EACR,kBAAkB,EAClB,oBAAoB,EACpB,SAAS,EACT,mBAAmB,EACnB,qBAAqB,EACrB,UAAU,EACV,oBAAoB,EACpB,sBAAsB,EACtB,GAAG,EACH,aAAa,EACb,eAAe,EACf,mBAAmB,EACnB,cAAc,EACd,QAAQ,EACR,cAAc,EAGd,mBAAmB,EACnB,uBAAuB,EACvB,uBAAuB,EACxB,MAAM,kBAAkB,CAAC;AAS1B,MAAM,WAAW,kBAAkB;IACjC,OAAO,EAAE,MAAM,CAAC;IAChB,MAAM,EAAE,MAAM,CAAC;IACf,OAAO,CAAC,EAAE,MAAM,CAAC;IACjB,UAAU,CAAC,EAAE,MAAM,CAAC;CACrB;AAED,qBAAa,YAAY;IACvB,OAAO,CAAC,MAAM,CAAgB;IAC9B,OAAO,CAAC,UAAU,CAAS;IAC3B,OAAO,CAAC,OAAO,CAAS;IACxB,OAAO,CAAC,WAAW,CAA+B;IAClD,OAAO,CAAC,cAAc,CAA+C;gBAEzD,MAAM,EAAE,kBAAkB;IAqDhC,UAAU,IAAI,OAAO,CAAC,cAAc,GAAG,IAAI,CAAC;YAyBpC,gBAAgB;IAa9B,oBAAoB,IAAI,cAAc,GAAG,IAAI;IAKvC,WAAW,IAAI,OAAO,CAAC,mBAAmB,CAAC;IA6C3C,cAAc,CAAC,QAAQ,EAAE,OAAO,CAAC,QAAQ,CAAC,GAAG,OAAO,CAAC,QAAQ,CAAC;IAU9D,WAAW,CAAC,EAAE,EAAE,MAAM,GAAG,OAAO,CAAC,QAAQ,CAAC;IAS1C,cAAc,CAAC,EAAE,EAAE,MAAM,EAAE,QAAQ,EAAE,OAAO,CAAC,QAAQ,CAAC,GAAG,OAAO,CAAC,QAAQ,CAAC;IAsC1E,cAAc,CAAC,EAAE,EAAE,MAAM,GAAG,OAAO,CAAC,QAAQ,CAAC;IAS7C,gBAAgB,CAAC,EAAE,EAAE,MAAM,EAAE,oBAAoB,EAAE,MAAM,GAAG,OAAO,CAAC,IAAI,CAAC;IAQzE,gBAAgB,CAAC,EAAE,EAAE,MAAM,GAAG,OAAO,CAAC,QAAQ,CAAC;IAS/C,kBAAkB,CAAC,EAAE,EAAE,MAAM,GAAG,OAAO,CAAC,QAAQ,CAAC;IAsBjD,aAAa,CAAC,MAAM,GAAE,kBAAuB,GAAG,OAAO,CAAC,oBAAoB,CAAC;IAU7E,YAAY,CAAC,EAAE,EAAE,MAAM,EAAE,WAAW,UAAQ,GAAG,OAAO,CAAC,SAAS,CAAC;IAwBjE,cAAc,CAAC,MAAM,GAAE,mBAAwB,GAAG,OAAO,CAAC,qBAAqB,CAAC;IAShF,eAAe,CAAC,EAAE,EAAE,MAAM,GAAG,OAAO,CAAC,IAAI,CAAC;IAS1C,cAAc,CAAC,OAAO,EAAE,cAAc,GAAG,OAAO,CAAC,GAAG,CAAC;IAiErD,eAAe,CAAC,MAAM,GAAE,oBAAyB,GAAG,OAAO,CAAC,sBAAsB,CAAC;IASnF,aAAa,CAAC,EAAE,EAAE,MAAM,GAAG,OAAO,CAAC,UAAU,CAAC;IAS9C,gBAAgB,CAAC,UAAU,EAAE,OAAO,CAAC,UAAU,CAAC,GAAG,OAAO,CAAC,UAAU,CAAC;IAStE,gBAAgB,CAAC,EAAE,EAAE,MAAM,EAAE,UAAU,EAAE,OAAO,CAAC,UAAU,CAAC,GAAG,OAAO,CAAC,UAAU,CAAC;IASlF,gBAAgB,CAAC,EAAE,EAAE,MAAM,GAAG,OAAO,CAAC,IAAI,CAAC;IAsB3C,QAAQ,CAAC,MAAM,GAAE,aAAkB,GAAG,OAAO,CAAC,eAAe,CAAC;IAS9D,SAAS,CAAC,GAAG,EAAE,OAAO,CAAC,GAAG,CAAC,GAAG,OAAO,CAAC,GAAG,CAAC;IAS1C,SAAS,CAAC,EAAE,EAAE,MAAM,EAAE,GAAG,EAAE,OAAO,CAAC,GAAG,CAAC,GAAG,OAAO,CAAC,GAAG,CAAC;IAStD,SAAS,CAAC,EAAE,EAAE,MAAM,GAAG,OAAO,CAAC,IAAI,CAAC;IAQpC,kBAAkB,CAAC,UAAU,EAAE,MAAM,EAAE,MAAM,EAAE,MAAM,EAAE,GAAG,OAAO,CAAC,GAAG,EAAE,CAAC;IAUxE,sBAAsB,IAAI,OAAO,CAAC,mBAAmB,CAAC;IAStD,iBAAiB,CAAC,KAAK,UAAQ,GAAG,OAAO,CAAC,uBAAuB,CAAC;IASlE,iBAAiB,CACrB,OAAO,EAAE,MAAM,EACf,SAAS,CAAC,EAAE,MAAM,EAAE,GACnB,OAAO,CAAC,uBAAuB,CAAC;IAa7B,YAAY,IAAI,OAAO,CAAC,QAAQ,EAAE,CAAC;IAWnC,cAAc,CAAC,QAAQ,EAAE,OAAO,CAAC,QAAQ,CAAC,GAAG,OAAO,CAAC,QAAQ,CAAC;IAS9D,cAAc,CAAC,EAAE,EAAE,MAAM,EAAE,QAAQ,EAAE,OAAO,CAAC,QAAQ,CAAC,GAAG,OAAO,CAAC,QAAQ,CAAC;IAS1E,cAAc,CAAC,EAAE,EAAE,MAAM,GAAG,OAAO,CAAC,IAAI,CAAC;IAiB/C,OAAO,CAAC,oBAAoB;CAmC7B"}
--- a/dist/services/n8n-api-client.js
+++ b/dist/services/n8n-api-client.js
@@ -448,110 +448,6 @@ class N8nApiClient {
            throw (0, n8n_errors_1.handleN8nApiError)(error);
        }
    }
-    async createDataTable(params) {
-        try {
-            const response = await this.client.post('/data-tables', params);
-            return response.data;
-        }
-        catch (error) {
-            throw (0, n8n_errors_1.handleN8nApiError)(error);
-        }
-    }
-    async listDataTables(params = {}) {
-        try {
-            const response = await this.client.get('/data-tables', { params });
-            return this.validateListResponse(response.data, 'data-tables');
-        }
-        catch (error) {
-            throw (0, n8n_errors_1.handleN8nApiError)(error);
-        }
-    }
-    async getDataTable(id) {
-        try {
-            const response = await this.client.get(`/data-tables/${id}`);
-            return response.data;
-        }
-        catch (error) {
-            throw (0, n8n_errors_1.handleN8nApiError)(error);
-        }
-    }
-    async updateDataTable(id, params) {
-        try {
-            const response = await this.client.patch(`/data-tables/${id}`, params);
-            return response.data;
-        }
-        catch (error) {
-            throw (0, n8n_errors_1.handleN8nApiError)(error);
-        }
-    }
-    async deleteDataTable(id) {
-        try {
-            await this.client.delete(`/data-tables/${id}`);
-        }
-        catch (error) {
-            throw (0, n8n_errors_1.handleN8nApiError)(error);
-        }
-    }
-    async getDataTableRows(id, params = {}) {
-        try {
-            const response = await this.client.get(`/data-tables/${id}/rows`, {
-                params,
-                paramsSerializer: (p) => this.serializeDataTableParams(p),
-            });
-            return this.validateListResponse(response.data, 'data-table-rows');
-        }
-        catch (error) {
-            throw (0, n8n_errors_1.handleN8nApiError)(error);
-        }
-    }
-    async insertDataTableRows(id, params) {
-        try {
-            const response = await this.client.post(`/data-tables/${id}/rows`, params);
-            return response.data;
-        }
-        catch (error) {
-            throw (0, n8n_errors_1.handleN8nApiError)(error);
-        }
-    }
-    async updateDataTableRows(id, params) {
-        try {
-            const response = await this.client.patch(`/data-tables/${id}/rows/update`, params);
-            return response.data;
-        }
-        catch (error) {
-            throw (0, n8n_errors_1.handleN8nApiError)(error);
-        }
-    }
-    async upsertDataTableRow(id, params) {
-        try {
-            const response = await this.client.post(`/data-tables/${id}/rows/upsert`, params);
-            return response.data;
-        }
-        catch (error) {
-            throw (0, n8n_errors_1.handleN8nApiError)(error);
-        }
-    }
-    async deleteDataTableRows(id, params) {
-        try {
-            const response = await this.client.delete(`/data-tables/${id}/rows/delete`, {
-                params,
-                paramsSerializer: (p) => this.serializeDataTableParams(p),
-            });
-            return response.data;
-        }
-        catch (error) {
-            throw (0, n8n_errors_1.handleN8nApiError)(error);
-        }
-    }
-    serializeDataTableParams(params) {
-        const parts = [];
-        for (const [key, value] of Object.entries(params)) {
-            if (value === undefined || value === null)
-                continue;
-            parts.push(`${encodeURIComponent(key)}=${encodeURIComponent(String(value))}`);
-        }
-        return parts.join('&');
-    }
    validateListResponse(responseData, resourceType) {
        if (!responseData || typeof responseData !== 'object') {
            throw new Error(`Invalid response from n8n API for ${resourceType}: response is not an object`);
--- a/dist/services/n8n-api-client.js.map
+++ b/dist/services/n8n-api-client.js.map
--- a/dist/types/n8n-api.d.ts
+++ b/dist/types/n8n-api.d.ts
@@ -374,69 +374,4 @@ export interface ErrorSuggestion {
    description: string;
    confidence: 'high' | 'medium' | 'low';
 }
-export interface DataTableColumn {
-    name: string;
-    type?: 'string' | 'number' | 'boolean' | 'date';
-}
-export interface DataTableColumnResponse {
-    id: string;
-    name: string;
-    type: 'string' | 'number' | 'boolean' | 'date';
-    index: number;
-}
-export interface DataTable {
-    id: string;
-    name: string;
-    columns?: DataTableColumnResponse[];
-    projectId?: string;
-    createdAt?: string;
-    updatedAt?: string;
-}
-export interface DataTableRow {
-    id?: number;
-    createdAt?: string;
-    updatedAt?: string;
-    [columnName: string]: unknown;
-}
-export interface DataTableFilterCondition {
-    columnName: string;
-    condition: 'eq' | 'neq' | 'like' | 'ilike' | 'gt' | 'gte' | 'lt' | 'lte';
-    value?: any;
-}
-export interface DataTableFilter {
-    type?: 'and' | 'or';
-    filters: DataTableFilterCondition[];
-}
-export interface DataTableListParams {
-    limit?: number;
-    cursor?: string;
-}
-export interface DataTableRowListParams {
-    limit?: number;
-    cursor?: string;
-    filter?: string;
-    sortBy?: string;
-    search?: string;
-}
-export interface DataTableInsertRowsParams {
-    data: Record<string, unknown>[];
-    returnType?: 'count' | 'id' | 'all';
-}
-export interface DataTableUpdateRowsParams {
-    filter: DataTableFilter;
-    data: Record<string, unknown>;
-    returnData?: boolean;
-    dryRun?: boolean;
-}
-export interface DataTableUpsertRowParams {
-    filter: DataTableFilter;
-    data: Record<string, unknown>;
-    returnData?: boolean;
-    dryRun?: boolean;
-}
-export interface DataTableDeleteRowsParams {
-    filter: string;
-    returnData?: boolean;
-    dryRun?: boolean;
-}
 //# sourceMappingURL=n8n-api.d.ts.map
--- a/dist/types/n8n-api.d.ts.map
+++ b/dist/types/n8n-api.d.ts.map
--- a/dist/utils/n8n-errors.d.ts
+++ b/dist/utils/n8n-errors.d.ts
@@ -8,7 +8,7 @@ export declare class N8nAuthenticationError extends N8nApiError {
    constructor(message?: string);
 }
 export declare class N8nNotFoundError extends N8nApiError {
-    constructor(messageOrResource: string, id?: string);
+    constructor(resource: string, id?: string);
 }
 export declare class N8nValidationError extends N8nApiError {
    constructor(message: string, details?: unknown);
--- a/dist/utils/n8n-errors.d.ts.map
+++ b/dist/utils/n8n-errors.d.ts.map
@@ -1 +1 @@
-{"version":3,"file":"n8n-errors.d.ts","sourceRoot":"","sources":["../../src/utils/n8n-errors.ts"],"names":[],"mappings":"AAIA,qBAAa,WAAY,SAAQ,KAAK;IAG3B,UAAU,CAAC,EAAE,MAAM;IACnB,IAAI,CAAC,EAAE,MAAM;IACb,OAAO,CAAC,EAAE,OAAO;gBAHxB,OAAO,EAAE,MAAM,EACR,UAAU,CAAC,EAAE,MAAM,YAAA,EACnB,IAAI,CAAC,EAAE,MAAM,YAAA,EACb,OAAO,CAAC,EAAE,OAAO,YAAA;CAK3B;AAED,qBAAa,sBAAuB,SAAQ,WAAW;gBACzC,OAAO,SAA0B;CAI9C;AAED,qBAAa,gBAAiB,SAAQ,WAAW;gBACnC,iBAAiB,EAAE,MAAM,EAAE,EAAE,CAAC,EAAE,MAAM;CAOnD;AAED,qBAAa,kBAAmB,SAAQ,WAAW;gBACrC,OAAO,EAAE,MAAM,EAAE,OAAO,CAAC,EAAE,OAAO;CAI/C;AAED,qBAAa,iBAAkB,SAAQ,WAAW;gBACpC,UAAU,CAAC,EAAE,MAAM;CAOhC;AAED,qBAAa,cAAe,SAAQ,WAAW;gBACjC,OAAO,SAA0B,EAAE,UAAU,SAAM;CAIhE;AAGD,wBAAgB,iBAAiB,CAAC,KAAK,EAAE,OAAO,GAAG,WAAW,CAuC7D;AAQD,wBAAgB,oBAAoB,CAAC,WAAW,EAAE,MAAM,EAAE,UAAU,CAAC,EAAE,MAAM,GAAG,MAAM,CAGrF;AAMD,wBAAgB,sBAAsB,IAAI,MAAM,CAE/C;AAGD,wBAAgB,2BAA2B,CAAC,KAAK,EAAE,WAAW,GAAG,MAAM,CAmBtE;AAGD,wBAAgB,WAAW,CAAC,KAAK,EAAE,WAAW,EAAE,OAAO,CAAC,EAAE,MAAM,GAAG,IAAI,CAiBtE"}
+{"version":3,"file":"n8n-errors.d.ts","sourceRoot":"","sources":["../../src/utils/n8n-errors.ts"],"names":[],"mappings":"AAIA,qBAAa,WAAY,SAAQ,KAAK;IAG3B,UAAU,CAAC,EAAE,MAAM;IACnB,IAAI,CAAC,EAAE,MAAM;IACb,OAAO,CAAC,EAAE,OAAO;gBAHxB,OAAO,EAAE,MAAM,EACR,UAAU,CAAC,EAAE,MAAM,YAAA,EACnB,IAAI,CAAC,EAAE,MAAM,YAAA,EACb,OAAO,CAAC,EAAE,OAAO,YAAA;CAK3B;AAED,qBAAa,sBAAuB,SAAQ,WAAW;gBACzC,OAAO,SAA0B;CAI9C;AAED,qBAAa,gBAAiB,SAAQ,WAAW;gBACnC,QAAQ,EAAE,MAAM,EAAE,EAAE,CAAC,EAAE,MAAM;CAK1C;AAED,qBAAa,kBAAmB,SAAQ,WAAW;gBACrC,OAAO,EAAE,MAAM,EAAE,OAAO,CAAC,EAAE,OAAO;CAI/C;AAED,qBAAa,iBAAkB,SAAQ,WAAW;gBACpC,UAAU,CAAC,EAAE,MAAM;CAOhC;AAED,qBAAa,cAAe,SAAQ,WAAW;gBACjC,OAAO,SAA0B,EAAE,UAAU,SAAM;CAIhE;AAGD,wBAAgB,iBAAiB,CAAC,KAAK,EAAE,OAAO,GAAG,WAAW,CAuC7D;AAQD,wBAAgB,oBAAoB,CAAC,WAAW,EAAE,MAAM,EAAE,UAAU,CAAC,EAAE,MAAM,GAAG,MAAM,CAGrF;AAMD,wBAAgB,sBAAsB,IAAI,MAAM,CAE/C;AAGD,wBAAgB,2BAA2B,CAAC,KAAK,EAAE,WAAW,GAAG,MAAM,CAmBtE;AAGD,wBAAgB,WAAW,CAAC,KAAK,EAAE,WAAW,EAAE,OAAO,CAAC,EAAE,MAAM,GAAG,IAAI,CAiBtE"}
--- a/dist/utils/n8n-errors.js
+++ b/dist/utils/n8n-errors.js
@@ -25,8 +25,8 @@ class N8nAuthenticationError extends N8nApiError {
 }
 exports.N8nAuthenticationError = N8nAuthenticationError;
 class N8nNotFoundError extends N8nApiError {
-    constructor(messageOrResource, id) {
-        const message = id ? `${messageOrResource} with ID ${id} not found` : messageOrResource;
+    constructor(resource, id) {
+        const message = id ? `${resource} with ID ${id} not found` : `${resource} not found`;
        super(message, 404, 'NOT_FOUND');
        this.name = 'N8nNotFoundError';
    }
@@ -69,7 +69,7 @@ function handleN8nApiError(error) {
                case 401:
                    return new N8nAuthenticationError(message);
                case 404:
-                    return new N8nNotFoundError(message || 'Resource');
+                    return new N8nNotFoundError('Resource', message);
                case 400:
                    return new N8nValidationError(message, data);
                case 429:
--- a/dist/utils/n8n-errors.js.map
+++ b/dist/utils/n8n-errors.js.map
@@ -1 +1 @@
-{"version":3,"file":"n8n-errors.js","sourceRoot":"","sources":["../../src/utils/n8n-errors.ts"],"names":[],"mappings":";;;AA0DA,8CAuCC;AAQD,oDAGC;AAMD,wDAEC;AAGD,kEAmBC;AAGD,kCAiBC;AA9JD,qCAAkC;AAIlC,MAAa,WAAY,SAAQ,KAAK;IACpC,YACE,OAAe,EACR,UAAmB,EACnB,IAAa,EACb,OAAiB;QAExB,KAAK,CAAC,OAAO,CAAC,CAAC;QAJR,eAAU,GAAV,UAAU,CAAS;QACnB,SAAI,GAAJ,IAAI,CAAS;QACb,YAAO,GAAP,OAAO,CAAU;QAGxB,IAAI,CAAC,IAAI,GAAG,aAAa,CAAC;IAC5B,CAAC;CACF;AAVD,kCAUC;AAED,MAAa,sBAAuB,SAAQ,WAAW;IACrD,YAAY,OAAO,GAAG,uBAAuB;QAC3C,KAAK,CAAC,OAAO,EAAE,GAAG,EAAE,sBAAsB,CAAC,CAAC;QAC5C,IAAI,CAAC,IAAI,GAAG,wBAAwB,CAAC;IACvC,CAAC;CACF;AALD,wDAKC;AAED,MAAa,gBAAiB,SAAQ,WAAW;IAC/C,YAAY,iBAAyB,EAAE,EAAW;QAGhD,MAAM,OAAO,GAAG,EAAE,CAAC,CAAC,CAAC,GAAG,iBAAiB,YAAY,EAAE,YAAY,CAAC,CAAC,CAAC,iBAAiB,CAAC;QACxF,KAAK,CAAC,OAAO,EAAE,GAAG,EAAE,WAAW,CAAC,CAAC;QACjC,IAAI,CAAC,IAAI,GAAG,kBAAkB,CAAC;IACjC,CAAC;CACF;AARD,4CAQC;AAED,MAAa,kBAAmB,SAAQ,WAAW;IACjD,YAAY,OAAe,EAAE,OAAiB;QAC5C,KAAK,CAAC,OAAO,EAAE,GAAG,EAAE,kBAAkB,EAAE,OAAO,CAAC,CAAC;QACjD,IAAI,CAAC,IAAI,GAAG,oBAAoB,CAAC;IACnC,CAAC;CACF;AALD,gDAKC;AAED,MAAa,iBAAkB,SAAQ,WAAW;IAChD,YAAY,UAAmB;QAC7B,MAAM,OAAO,GAAG,UAAU;YACxB,CAAC,CAAC,oCAAoC,UAAU,UAAU;YAC1D,CAAC,CAAC,qBAAqB,CAAC;QAC1B,KAAK,CAAC,OAAO,EAAE,GAAG,EAAE,kBAAkB,EAAE,EAAE,UAAU,EAAE,CAAC,CAAC;QACxD,IAAI,CAAC,IAAI,GAAG,mBAAmB,CAAC;IAClC,CAAC;CACF;AARD,8CAQC;AAED,MAAa,cAAe,SAAQ,WAAW;IAC7C,YAAY,OAAO,GAAG,uBAAuB,EAAE,UAAU,GAAG,GAAG;QAC7D,KAAK,CAAC,OAAO,EAAE,UAAU,EAAE,cAAc,CAAC,CAAC;QAC3C,IAAI,CAAC,IAAI,GAAG,gBAAgB,CAAC;IAC/B,CAAC;CACF;AALD,wCAKC;AAGD,SAAgB,iBAAiB,CAAC,KAAc;IAC9C,IAAI,KAAK,YAAY,WAAW,EAAE,CAAC;QACjC,OAAO,KAAK,CAAC;IACf,CAAC;IAED,IAAI,KAAK,YAAY,KAAK,EAAE,CAAC;QAE3B,MAAM,UAAU,GAAG,KAAY,CAAC;QAChC,IAAI,UAAU,CAAC,QAAQ,EAAE,CAAC;YACxB,MAAM,EAAE,MAAM,EAAE,IAAI,EAAE,GAAG,UAAU,CAAC,QAAQ,CAAC;YAC7C,MAAM,OAAO,GAAG,IAAI,EAAE,OAAO,IAAI,UAAU,CAAC,OAAO,CAAC;YAEpD,QAAQ,MAAM,EAAE,CAAC;gBACf,KAAK,GAAG;oBACN,OAAO,IAAI,sBAAsB,CAAC,OAAO,CAAC,CAAC;gBAC7C,KAAK,GAAG;oBACN,OAAO,IAAI,gBAAgB,CAAC,OAAO,IAAI,UAAU,CAAC,CAAC;gBACrD,KAAK,GAAG;oBACN,OAAO,IAAI,kBAAkB,CAAC,OAAO,EAAE,IAAI,CAAC,CAAC;gBAC/C,KAAK,GAAG;oBACN,MAAM,UAAU,GAAG,UAAU,CAAC,QAAQ,CAAC,OAAO,CAAC,aAAa,CAAC,CAAC;oBAC9D,OAAO,IAAI,iBAAiB,CAAC,UAAU,CAAC,CAAC,CAAC,QAAQ,CAAC,UAAU,CAAC,CAAC,CAAC,CAAC,SAAS,CAAC,CAAC;gBAC9E;oBACE,IAAI,MAAM,IAAI,GAAG,EAAE,CAAC;wBAClB,OAAO,IAAI,cAAc,CAAC,OAAO,EAAE,MAAM,CAAC,CAAC;oBAC7C,CAAC;oBACD,OAAO,IAAI,WAAW,CAAC,OAAO,EAAE,MAAM,EAAE,WAAW,EAAE,IAAI,CAAC,CAAC;YAC/D,CAAC;QACH,CAAC;aAAM,IAAI,UAAU,CAAC,OAAO,EAAE,CAAC;YAE9B,OAAO,IAAI,WAAW,CAAC,6BAA6B,EAAE,SAAS,EAAE,aAAa,CAAC,CAAC;QAClF,CAAC;aAAM,CAAC;YAEN,OAAO,IAAI,WAAW,CAAC,UAAU,CAAC,OAAO,EAAE,SAAS,EAAE,eAAe,CAAC,CAAC;QACzE,CAAC;IACH,CAAC;IAGD,OAAO,IAAI,WAAW,CAAC,wBAAwB,EAAE,SAAS,EAAE,eAAe,EAAE,KAAK,CAAC,CAAC;AACtF,CAAC;AAQD,SAAgB,oBAAoB,CAAC,WAAmB,EAAE,UAAmB;IAC3E,MAAM,cAAc,GAAG,UAAU,CAAC,CAAC,CAAC,YAAY,UAAU,aAAa,CAAC,CAAC,CAAC,YAAY,CAAC;IACvF,OAAO,GAAG,cAAc,GAAG,WAAW,wCAAwC,WAAW,gDAAgD,CAAC;AAC5I,CAAC;AAMD,SAAgB,sBAAsB;IACpC,OAAO,2IAA2I,CAAC;AACrJ,CAAC;AAGD,SAAgB,2BAA2B,CAAC,KAAkB;IAC5D,QAAQ,KAAK,CAAC,IAAI,EAAE,CAAC;QACnB,KAAK,sBAAsB;YACzB,OAAO,6DAA6D,CAAC;QACvE,KAAK,WAAW;YACd,OAAO,KAAK,CAAC,OAAO,CAAC;QACvB,KAAK,kBAAkB;YACrB,OAAO,oBAAoB,KAAK,CAAC,OAAO,EAAE,CAAC;QAC7C,KAAK,kBAAkB;YACrB,OAAO,wDAAwD,CAAC;QAClE,KAAK,aAAa;YAChB,OAAO,kFAAkF,CAAC;QAC5F,KAAK,cAAc;YAGjB,OAAO,KAAK,CAAC,OAAO,IAAI,2BAA2B,CAAC;QACtD;YACE,OAAO,KAAK,CAAC,OAAO,IAAI,8BAA8B,CAAC;IAC3D,CAAC;AACH,CAAC;AAGD,SAAgB,WAAW,CAAC,KAAkB,EAAE,OAAgB;IAC9D,MAAM,SAAS,GAAG;QAChB,IAAI,EAAE,KAAK,CAAC,IAAI;QAChB,OAAO,EAAE,KAAK,CAAC,OAAO;QACtB,IAAI,EAAE,KAAK,CAAC,IAAI;QAChB,UAAU,EAAE,KAAK,CAAC,UAAU;QAC5B,OAAO,EAAE,KAAK,CAAC,OAAO;QACtB,OAAO;KACR,CAAC;IAEF,IAAI,KAAK,CAAC,UAAU,IAAI,KAAK,CAAC,UAAU,IAAI,GAAG,EAAE,CAAC;QAChD,eAAM,CAAC,KAAK,CAAC,sBAAsB,EAAE,SAAS,CAAC,CAAC;IAClD,CAAC;SAAM,IAAI,KAAK,CAAC,UAAU,IAAI,KAAK,CAAC,UAAU,IAAI,GAAG,EAAE,CAAC;QACvD,eAAM,CAAC,IAAI,CAAC,sBAAsB,EAAE,SAAS,CAAC,CAAC;IACjD,CAAC;SAAM,CAAC;QACN,eAAM,CAAC,KAAK,CAAC,eAAe,EAAE,SAAS,CAAC,CAAC;IAC3C,CAAC;AACH,CAAC"}
+{"version":3,"file":"n8n-errors.js","sourceRoot":"","sources":["../../src/utils/n8n-errors.ts"],"names":[],"mappings":";;;AAwDA,8CAuCC;AAQD,oDAGC;AAMD,wDAEC;AAGD,kEAmBC;AAGD,kCAiBC;AA5JD,qCAAkC;AAIlC,MAAa,WAAY,SAAQ,KAAK;IACpC,YACE,OAAe,EACR,UAAmB,EACnB,IAAa,EACb,OAAiB;QAExB,KAAK,CAAC,OAAO,CAAC,CAAC;QAJR,eAAU,GAAV,UAAU,CAAS;QACnB,SAAI,GAAJ,IAAI,CAAS;QACb,YAAO,GAAP,OAAO,CAAU;QAGxB,IAAI,CAAC,IAAI,GAAG,aAAa,CAAC;IAC5B,CAAC;CACF;AAVD,kCAUC;AAED,MAAa,sBAAuB,SAAQ,WAAW;IACrD,YAAY,OAAO,GAAG,uBAAuB;QAC3C,KAAK,CAAC,OAAO,EAAE,GAAG,EAAE,sBAAsB,CAAC,CAAC;QAC5C,IAAI,CAAC,IAAI,GAAG,wBAAwB,CAAC;IACvC,CAAC;CACF;AALD,wDAKC;AAED,MAAa,gBAAiB,SAAQ,WAAW;IAC/C,YAAY,QAAgB,EAAE,EAAW;QACvC,MAAM,OAAO,GAAG,EAAE,CAAC,CAAC,CAAC,GAAG,QAAQ,YAAY,EAAE,YAAY,CAAC,CAAC,CAAC,GAAG,QAAQ,YAAY,CAAC;QACrF,KAAK,CAAC,OAAO,EAAE,GAAG,EAAE,WAAW,CAAC,CAAC;QACjC,IAAI,CAAC,IAAI,GAAG,kBAAkB,CAAC;IACjC,CAAC;CACF;AAND,4CAMC;AAED,MAAa,kBAAmB,SAAQ,WAAW;IACjD,YAAY,OAAe,EAAE,OAAiB;QAC5C,KAAK,CAAC,OAAO,EAAE,GAAG,EAAE,kBAAkB,EAAE,OAAO,CAAC,CAAC;QACjD,IAAI,CAAC,IAAI,GAAG,oBAAoB,CAAC;IACnC,CAAC;CACF;AALD,gDAKC;AAED,MAAa,iBAAkB,SAAQ,WAAW;IAChD,YAAY,UAAmB;QAC7B,MAAM,OAAO,GAAG,UAAU;YACxB,CAAC,CAAC,oCAAoC,UAAU,UAAU;YAC1D,CAAC,CAAC,qBAAqB,CAAC;QAC1B,KAAK,CAAC,OAAO,EAAE,GAAG,EAAE,kBAAkB,EAAE,EAAE,UAAU,EAAE,CAAC,CAAC;QACxD,IAAI,CAAC,IAAI,GAAG,mBAAmB,CAAC;IAClC,CAAC;CACF;AARD,8CAQC;AAED,MAAa,cAAe,SAAQ,WAAW;IAC7C,YAAY,OAAO,GAAG,uBAAuB,EAAE,UAAU,GAAG,GAAG;QAC7D,KAAK,CAAC,OAAO,EAAE,UAAU,EAAE,cAAc,CAAC,CAAC;QAC3C,IAAI,CAAC,IAAI,GAAG,gBAAgB,CAAC;IAC/B,CAAC;CACF;AALD,wCAKC;AAGD,SAAgB,iBAAiB,CAAC,KAAc;IAC9C,IAAI,KAAK,YAAY,WAAW,EAAE,CAAC;QACjC,OAAO,KAAK,CAAC;IACf,CAAC;IAED,IAAI,KAAK,YAAY,KAAK,EAAE,CAAC;QAE3B,MAAM,UAAU,GAAG,KAAY,CAAC;QAChC,IAAI,UAAU,CAAC,QAAQ,EAAE,CAAC;YACxB,MAAM,EAAE,MAAM,EAAE,IAAI,EAAE,GAAG,UAAU,CAAC,QAAQ,CAAC;YAC7C,MAAM,OAAO,GAAG,IAAI,EAAE,OAAO,IAAI,UAAU,CAAC,OAAO,CAAC;YAEpD,QAAQ,MAAM,EAAE,CAAC;gBACf,KAAK,GAAG;oBACN,OAAO,IAAI,sBAAsB,CAAC,OAAO,CAAC,CAAC;gBAC7C,KAAK,GAAG;oBACN,OAAO,IAAI,gBAAgB,CAAC,UAAU,EAAE,OAAO,CAAC,CAAC;gBACnD,KAAK,GAAG;oBACN,OAAO,IAAI,kBAAkB,CAAC,OAAO,EAAE,IAAI,CAAC,CAAC;gBAC/C,KAAK,GAAG;oBACN,MAAM,UAAU,GAAG,UAAU,CAAC,QAAQ,CAAC,OAAO,CAAC,aAAa,CAAC,CAAC;oBAC9D,OAAO,IAAI,iBAAiB,CAAC,UAAU,CAAC,CAAC,CAAC,QAAQ,CAAC,UAAU,CAAC,CAAC,CAAC,CAAC,SAAS,CAAC,CAAC;gBAC9E;oBACE,IAAI,MAAM,IAAI,GAAG,EAAE,CAAC;wBAClB,OAAO,IAAI,cAAc,CAAC,OAAO,EAAE,MAAM,CAAC,CAAC;oBAC7C,CAAC;oBACD,OAAO,IAAI,WAAW,CAAC,OAAO,EAAE,MAAM,EAAE,WAAW,EAAE,IAAI,CAAC,CAAC;YAC/D,CAAC;QACH,CAAC;aAAM,IAAI,UAAU,CAAC,OAAO,EAAE,CAAC;YAE9B,OAAO,IAAI,WAAW,CAAC,6BAA6B,EAAE,SAAS,EAAE,aAAa,CAAC,CAAC;QAClF,CAAC;aAAM,CAAC;YAEN,OAAO,IAAI,WAAW,CAAC,UAAU,CAAC,OAAO,EAAE,SAAS,EAAE,eAAe,CAAC,CAAC;QACzE,CAAC;IACH,CAAC;IAGD,OAAO,IAAI,WAAW,CAAC,wBAAwB,EAAE,SAAS,EAAE,eAAe,EAAE,KAAK,CAAC,CAAC;AACtF,CAAC;AAQD,SAAgB,oBAAoB,CAAC,WAAmB,EAAE,UAAmB;IAC3E,MAAM,cAAc,GAAG,UAAU,CAAC,CAAC,CAAC,YAAY,UAAU,aAAa,CAAC,CAAC,CAAC,YAAY,CAAC;IACvF,OAAO,GAAG,cAAc,GAAG,WAAW,wCAAwC,WAAW,gDAAgD,CAAC;AAC5I,CAAC;AAMD,SAAgB,sBAAsB;IACpC,OAAO,2IAA2I,CAAC;AACrJ,CAAC;AAGD,SAAgB,2BAA2B,CAAC,KAAkB;IAC5D,QAAQ,KAAK,CAAC,IAAI,EAAE,CAAC;QACnB,KAAK,sBAAsB;YACzB,OAAO,6DAA6D,CAAC;QACvE,KAAK,WAAW;YACd,OAAO,KAAK,CAAC,OAAO,CAAC;QACvB,KAAK,kBAAkB;YACrB,OAAO,oBAAoB,KAAK,CAAC,OAAO,EAAE,CAAC;QAC7C,KAAK,kBAAkB;YACrB,OAAO,wDAAwD,CAAC;QAClE,KAAK,aAAa;YAChB,OAAO,kFAAkF,CAAC;QAC5F,KAAK,cAAc;YAGjB,OAAO,KAAK,CAAC,OAAO,IAAI,2BAA2B,CAAC;QACtD;YACE,OAAO,KAAK,CAAC,OAAO,IAAI,8BAA8B,CAAC;IAC3D,CAAC;AACH,CAAC;AAGD,SAAgB,WAAW,CAAC,KAAkB,EAAE,OAAgB;IAC9D,MAAM,SAAS,GAAG;QAChB,IAAI,EAAE,KAAK,CAAC,IAAI;QAChB,OAAO,EAAE,KAAK,CAAC,OAAO;QACtB,IAAI,EAAE,KAAK,CAAC,IAAI;QAChB,UAAU,EAAE,KAAK,CAAC,UAAU;QAC5B,OAAO,EAAE,KAAK,CAAC,OAAO;QACtB,OAAO;KACR,CAAC;IAEF,IAAI,KAAK,CAAC,UAAU,IAAI,KAAK,CAAC,UAAU,IAAI,GAAG,EAAE,CAAC;QAChD,eAAM,CAAC,KAAK,CAAC,sBAAsB,EAAE,SAAS,CAAC,CAAC;IAClD,CAAC;SAAM,IAAI,KAAK,CAAC,UAAU,IAAI,KAAK,CAAC,UAAU,IAAI,GAAG,EAAE,CAAC;QACvD,eAAM,CAAC,IAAI,CAAC,sBAAsB,EAAE,SAAS,CAAC,CAAC;IACjD,CAAC;SAAM,CAAC;QACN,eAAM,CAAC,KAAK,CAAC,eAAe,EAAE,SAAS,CAAC,CAAC;IAC3C,CAAC;AACH,CAAC"}
--- a/package.json
+++ b/package.json
@@ -1,6 +1,6 @@
 {
  "name": "n8n-mcp",
-  "version": "2.40.3",
+  "version": "2.40.1",
  "description": "Integration between n8n workflow automation and Model Context Protocol (MCP)",
  "main": "dist/index.js",
  "types": "dist/index.d.ts",
--- a/src/http-server-single-session.ts
+++ b/src/http-server-single-session.ts
@@ -253,21 +253,6 @@ export class SingleSessionHTTPServer {
    // This ensures compatibility with all MCP clients and proxies
    return Boolean(sessionId && sessionId.length > 0);
  }
-
-  /**
-   * Checks if a request body is a JSON-RPC notification (or batch of only notifications).
-   * Notifications have a `method` field but no `id` field per JSON-RPC 2.0 spec.
-   */
-  private isJsonRpcNotification(body: unknown): boolean {
-    if (!body || typeof body !== 'object') return false;
-    if (Array.isArray(body)) {
-      return body.length > 0 && body.every(
-        (msg: any) => msg && typeof msg.method === 'string' && !('id' in msg)
-      );
-    }
-    const msg = body as Record<string, unknown>;
-    return typeof msg.method === 'string' && !('id' in msg);
-  }
  
  /**
   * Sanitize error information for client responses
@@ -629,24 +614,6 @@ export class SingleSessionHTTPServer {
          logger.info('handleRequest: Reusing existing transport for session', { sessionId });
          transport = this.transports[sessionId];

-          // TOCTOU guard: session may have been removed between the check and this line
-          if (!transport) {
-            if (this.isJsonRpcNotification(req.body)) {
-              logger.info('handleRequest: Session removed during lookup, accepting notification', {
-                sessionId,
-              });
-              res.status(202).end();
-              return;
-            }
-            logger.warn('handleRequest: Session removed between check and use (TOCTOU)', { sessionId });
-            res.status(400).json({
-              jsonrpc: '2.0',
-              error: { code: -32000, message: 'Bad Request: Session not found or expired' },
-              id: req.body?.id || null,
-            });
-            return;
-          }
-
          // In multi-tenant shared mode, update instance context if provided
          const isMultiTenantEnabled = process.env.ENABLE_MULTI_TENANT === 'true';
          const sessionStrategy = process.env.MULTI_TENANT_SESSION_STRATEGY || 'instance';
@@ -660,36 +627,23 @@ export class SingleSessionHTTPServer {
          this.updateSessionAccess(sessionId);
          
        } else {
-          // Check if this is a JSON-RPC notification (no "id" field = fire-and-forget)
-          // Per JSON-RPC 2.0 spec, notifications don't expect responses.
-          // Returning 400 for stale-session notifications causes Claude's proxy to
-          // interpret the connection as broken, triggering reconnection storms (#654).
-          if (this.isJsonRpcNotification(req.body)) {
-            logger.info('handleRequest: Accepting notification for stale/missing session', {
-              method: req.body?.method,
-              sessionId: sessionId || 'none',
-            });
-            res.status(202).end();
-            return;
-          }
-
-          // Only return 400 for actual requests that need a valid session
+          // Invalid request - no session ID and not an initialize request
          const errorDetails = {
            hasSessionId: !!sessionId,
            isInitialize: isInitialize,
            sessionIdValid: sessionId ? this.isValidSessionId(sessionId) : false,
            sessionExists: sessionId ? !!this.transports[sessionId] : false
          };
-
+          
          logger.warn('handleRequest: Invalid request - no session ID and not initialize', errorDetails);
-
+          
          let errorMessage = 'Bad Request: No valid session ID provided and not an initialize request';
          if (sessionId && !this.isValidSessionId(sessionId)) {
            errorMessage = 'Bad Request: Invalid session ID format';
          } else if (sessionId && !this.transports[sessionId]) {
            errorMessage = 'Bad Request: Session not found or expired';
          }
-
+          
          res.status(400).json({
            jsonrpc: '2.0',
            error: {
--- a/src/mcp/handlers-n8n-manager.ts
+++ b/src/mcp/handlers-n8n-manager.ts
@@ -2834,13 +2834,10 @@ export async function handleUpdateTable(args: unknown, context?: InstanceContext
    const client = ensureApiConfigured(context);
    const { tableId, name } = updateTableSchema.parse(args);
    const dataTable = await client.updateDataTable(tableId, { name });
-    const rawArgs = args as Record<string, unknown>;
-    const hasColumns = rawArgs && typeof rawArgs === 'object' && 'columns' in rawArgs;
    return {
      success: true,
      data: dataTable,
-      message: `Data table renamed to "${dataTable.name}"` +
-        (hasColumns ? '. Note: columns parameter was ignored — table schema is immutable after creation via the public API' : ''),
+      message: `Data table renamed to "${dataTable.name}"`,
    };
  } catch (error) {
    return handleDataTableError(error);
@@ -2864,10 +2861,11 @@ export async function handleGetRows(args: unknown, context?: InstanceContext): P
    const { tableId, filter, sortBy, ...params } = getRowsSchema.parse(args);
    const queryParams: Record<string, unknown> = { ...params };
    if (filter) {
-      queryParams.filter = typeof filter === 'string' ? filter : JSON.stringify(filter);
+      const filterStr = typeof filter === 'string' ? filter : JSON.stringify(filter);
+      queryParams.filter = encodeURIComponent(filterStr);
    }
    if (sortBy) {
-      queryParams.sortBy = sortBy;
+      queryParams.sortBy = encodeURIComponent(sortBy);
    }
    const result = await client.getDataTableRows(tableId, queryParams as any);
    return {
@@ -2933,7 +2931,7 @@ export async function handleDeleteRows(args: unknown, context?: InstanceContext)
    const client = ensureApiConfigured(context);
    const { tableId, filter, ...params } = deleteRowsSchema.parse(args);
    const queryParams = {
-      filter: JSON.stringify(filter),
+      filter: encodeURIComponent(JSON.stringify(filter)),
      ...params,
    };
    const result = await client.deleteDataTableRows(tableId, queryParams as any);
--- a/src/mcp/tool-docs/workflow_management/n8n-manage-datatable.ts
+++ b/src/mcp/tool-docs/workflow_management/n8n-manage-datatable.ts
@@ -9,7 +9,7 @@ export const n8nManageDatatableDoc: ToolDocumentation = {
    example: 'n8n_manage_datatable({action: "createTable", name: "Contacts", columns: [{name: "email", type: "string"}]})',
    performance: 'Fast (100-500ms)',
    tips: [
-      'Table actions: createTable, listTables, getTable, updateTable (rename only), deleteTable',
+      'Table actions: createTable, listTables, getTable, updateTable, deleteTable',
      'Row actions: getRows, insertRows, updateRows, upsertRows, deleteRows',
      'Use dryRun: true to preview update/upsert/delete before applying',
      'Filter supports: eq, neq, like, ilike, gt, gte, lt, lte conditions',
@@ -22,7 +22,7 @@ export const n8nManageDatatableDoc: ToolDocumentation = {
 - **createTable**: Create a new data table with optional typed columns
 - **listTables**: List all data tables (paginated)
 - **getTable**: Get table details and column definitions by ID
- **updateTable**: Rename an existing table (name only — column modifications not supported via API)
+- **updateTable**: Rename an existing table
 - **deleteTable**: Permanently delete a table and all its rows

 **Row Actions:**
--- a/src/mcp/tools-n8n-manager.ts
+++ b/src/mcp/tools-n8n-manager.ts
@@ -619,10 +619,10 @@ export const n8nManagementTools: ToolDefinition[] = [
          description: 'Operation to perform',
        },
        tableId: { type: 'string', description: 'Data table ID (required for all actions except createTable and listTables)' },
-        name: { type: 'string', description: 'For createTable: table name. For updateTable: new name (rename only — schema is immutable after creation)' },
+        name: { type: 'string', description: 'For createTable/updateTable: table name' },
        columns: {
          type: 'array',
-          description: 'For createTable only: column definitions (schema is immutable after creation via public API)',
+          description: 'For createTable: column definitions',
          items: {
            type: 'object',
            properties: {
--- a/src/services/n8n-api-client.ts
+++ b/src/services/n8n-api-client.ts
@@ -637,10 +637,7 @@ export class N8nApiClient {

  async getDataTableRows(id: string, params: DataTableRowListParams = {}): Promise<{ data: DataTableRow[]; nextCursor?: string | null }> {
    try {
-      const response = await this.client.get(`/data-tables/${id}/rows`, {
-        params,
-        paramsSerializer: (p) => this.serializeDataTableParams(p),
-      });
+      const response = await this.client.get(`/data-tables/${id}/rows`, { params });
      return this.validateListResponse<DataTableRow>(response.data, 'data-table-rows');
    } catch (error) {
      throw handleN8nApiError(error);
@@ -676,29 +673,13 @@ export class N8nApiClient {

  async deleteDataTableRows(id: string, params: DataTableDeleteRowsParams): Promise<any> {
    try {
-      const response = await this.client.delete(`/data-tables/${id}/rows/delete`, {
-        params,
-        paramsSerializer: (p) => this.serializeDataTableParams(p),
-      });
+      const response = await this.client.delete(`/data-tables/${id}/rows/delete`, { params });
      return response.data;
    } catch (error) {
      throw handleN8nApiError(error);
    }
  }

-  /**
-   * Serializes data table query params with explicit encodeURIComponent.
-   * Axios's default serializer doesn't encode some reserved chars that n8n rejects.
-   */
-  private serializeDataTableParams(params: Record<string, any>): string {
-    const parts: string[] = [];
-    for (const [key, value] of Object.entries(params)) {
-      if (value === undefined || value === null) continue;
-      parts.push(`${encodeURIComponent(key)}=${encodeURIComponent(String(value))}`);
-    }
-    return parts.join('&');
-  }
-
  /**
   * Validates and normalizes n8n API list responses.
   * Handles both modern format {data: [], nextCursor?: string} and legacy array format.
--- a/tests/unit/http-server-session-management.test.ts
+++ b/tests/unit/http-server-session-management.test.ts
@@ -219,7 +219,6 @@ describe('HTTP Server Session Management', () => {
      status: vi.fn().mockReturnThis(),
      json: vi.fn().mockReturnThis(),
      send: vi.fn().mockReturnThis(),
-      end: vi.fn().mockReturnThis(),
      setHeader: vi.fn((key: string, value: string) => {
        headers[key.toLowerCase()] = value;
      }),
@@ -1171,7 +1170,7 @@ describe('HTTP Server Session Management', () => {

    it('should show legacy SSE session when present', async () => {
      server = new SingleSessionHTTPServer();
-
+      
      // Mock legacy session
      const mockSession = {
        sessionId: 'sse-session-123',
@@ -1181,111 +1180,10 @@ describe('HTTP Server Session Management', () => {
      (server as any).session = mockSession;

      const sessionInfo = server.getSessionInfo();
-
+      
      expect(sessionInfo.active).toBe(true);
      expect(sessionInfo.sessionId).toBe('sse-session-123');
      expect(sessionInfo.age).toBeGreaterThanOrEqual(0);
    });
  });
-
-  describe('Notification handling for stale sessions (#654)', () => {
-    beforeEach(() => {
-      // Re-apply mockImplementation after vi.clearAllMocks() resets it
-      mockConsoleManager.wrapOperation.mockImplementation(async (fn: () => Promise<any>) => {
-        return await fn();
-      });
-    });
-
-    it('should return 202 for notification with stale session ID', async () => {
-      server = new SingleSessionHTTPServer();
-
-      const { req, res } = createMockReqRes();
-
-      req.headers = { 'mcp-session-id': 'stale-session-that-does-not-exist' };
-      req.method = 'POST';
-      req.body = {
-        jsonrpc: '2.0',
-        method: 'notifications/initialized',
-      };
-
-      await server.handleRequest(req as any, res as any);
-
-      expect(res.status).toHaveBeenCalledWith(202);
-      expect(res.end).toHaveBeenCalled();
-    });
-
-    it('should return 202 for notification batch with stale session ID', async () => {
-      server = new SingleSessionHTTPServer();
-
-      const { req, res } = createMockReqRes();
-
-      req.headers = { 'mcp-session-id': 'stale-session-that-does-not-exist' };
-      req.method = 'POST';
-      req.body = [
-        { jsonrpc: '2.0', method: 'notifications/initialized' },
-        { jsonrpc: '2.0', method: 'notifications/cancelled' },
-      ];
-
-      await server.handleRequest(req as any, res as any);
-
-      expect(res.status).toHaveBeenCalledWith(202);
-      expect(res.end).toHaveBeenCalled();
-    });
-
-    it('should return 400 for request (with id) with stale session ID', async () => {
-      server = new SingleSessionHTTPServer();
-
-      const { req, res } = createMockReqRes();
-      req.headers = { 'mcp-session-id': 'stale-session-that-does-not-exist' };
-      req.method = 'POST';
-      req.body = {
-        jsonrpc: '2.0',
-        method: 'tools/call',
-        params: { name: 'search_nodes', arguments: { query: 'http' } },
-        id: 42,
-      };
-
-      await server.handleRequest(req as any, res as any);
-
-      expect(res.status).toHaveBeenCalledWith(400);
-      expect(res.json).toHaveBeenCalledWith(expect.objectContaining({
-        error: expect.objectContaining({
-          message: 'Bad Request: Session not found or expired',
-        }),
-      }));
-    });
-
-    it('should return 202 for notification with no session ID', async () => {
-      server = new SingleSessionHTTPServer();
-
-      const { req, res } = createMockReqRes();
-
-      req.method = 'POST';
-      req.body = {
-        jsonrpc: '2.0',
-        method: 'notifications/cancelled',
-      };
-
-      await server.handleRequest(req as any, res as any);
-
-      expect(res.status).toHaveBeenCalledWith(202);
-      expect(res.end).toHaveBeenCalled();
-    });
-
-    it('should return 400 for request with no session ID and not initialize', async () => {
-      server = new SingleSessionHTTPServer();
-
-      const { req, res } = createMockReqRes();
-      req.method = 'POST';
-      req.body = {
-        jsonrpc: '2.0',
-        method: 'tools/list',
-        id: 1,
-      };
-
-      await server.handleRequest(req as any, res as any);
-
-      expect(res.status).toHaveBeenCalledWith(400);
-    });
-  });
 });
--- a/tests/unit/mcp/handlers-manage-datatable.test.ts
+++ b/tests/unit/mcp/handlers-manage-datatable.test.ts
@@ -363,22 +363,6 @@ describe('Data Table Handlers (n8n_manage_datatable)', () => {
      expect(result.success).toBe(false);
      expect(result.error).toBe('Update failed');
    });
-
-    it('should warn when columns parameter is passed', async () => {
-      const updatedTable = { id: 'dt-1', name: 'Renamed' };
-      mockApiClient.updateDataTable.mockResolvedValue(updatedTable);
-
-      const result = await handlers.handleUpdateTable({
-        tableId: 'dt-1',
-        name: 'Renamed',
-        columns: [{ name: 'phone', type: 'string' }],
-      });
-
-      expect(result.success).toBe(true);
-      expect(result.message).toContain('columns parameter was ignored');
-      expect(result.message).toContain('immutable after creation');
-      expect(mockApiClient.updateDataTable).toHaveBeenCalledWith('dt-1', { name: 'Renamed' });
-    });
  });

  // ========================================================================
@@ -445,12 +429,12 @@ describe('Data Table Handlers (n8n_manage_datatable)', () => {

      expect(mockApiClient.getDataTableRows).toHaveBeenCalledWith('dt-1', {
        limit: 50,
-        sortBy: 'name:asc',
+        sortBy: encodeURIComponent('name:asc'),
        search: 'john',
      });
    });

-    it('should serialize object filter to JSON string', async () => {
+    it('should serialize object filter to URL-encoded JSON string', async () => {
      mockApiClient.getDataTableRows.mockResolvedValue({ data: [], nextCursor: null });

      const objectFilter = {
@@ -464,11 +448,11 @@ describe('Data Table Handlers (n8n_manage_datatable)', () => {
      });

      expect(mockApiClient.getDataTableRows).toHaveBeenCalledWith('dt-1', {
-        filter: JSON.stringify(objectFilter),
+        filter: encodeURIComponent(JSON.stringify(objectFilter)),
      });
    });

-    it('should pass string filter as-is', async () => {
+    it('should URL-encode string filter', async () => {
      mockApiClient.getDataTableRows.mockResolvedValue({ data: [], nextCursor: null });

      const filterStr = '{"type":"and","filters":[]}';
@@ -478,7 +462,7 @@ describe('Data Table Handlers (n8n_manage_datatable)', () => {
      });

      expect(mockApiClient.getDataTableRows).toHaveBeenCalledWith('dt-1', {
-        filter: filterStr,
+        filter: encodeURIComponent(filterStr),
      });
    });
  });
@@ -697,11 +681,11 @@ describe('Data Table Handlers (n8n_manage_datatable)', () => {
        message: 'Rows deleted successfully',
      });
      expect(mockApiClient.deleteDataTableRows).toHaveBeenCalledWith('dt-1', {
-        filter: JSON.stringify({ type: 'and', ...filter }),
+        filter: encodeURIComponent(JSON.stringify({ type: 'and', ...filter })),
      });
    });

-    it('should serialize filter to JSON string for API call', async () => {
+    it('should URL-encode serialized filter for API call', async () => {
      mockApiClient.deleteDataTableRows.mockResolvedValue({ deletedCount: 1 });

      const filter = {
@@ -715,7 +699,7 @@ describe('Data Table Handlers (n8n_manage_datatable)', () => {
      await handlers.handleDeleteRows({ tableId: 'dt-1', filter });

      expect(mockApiClient.deleteDataTableRows).toHaveBeenCalledWith('dt-1', {
-        filter: JSON.stringify(filter),
+        filter: encodeURIComponent(JSON.stringify(filter)),
      });
    });

@@ -736,7 +720,7 @@ describe('Data Table Handlers (n8n_manage_datatable)', () => {
      expect(result.success).toBe(true);
      expect(result.message).toBe('Dry run: rows matched for deletion (no changes applied)');
      expect(mockApiClient.deleteDataTableRows).toHaveBeenCalledWith('dt-1', {
-        filter: JSON.stringify({ type: 'and', ...filter }),
+        filter: encodeURIComponent(JSON.stringify({ type: 'and', ...filter })),
        dryRun: true,
      });
    });
--- a/tests/unit/services/n8n-api-client.test.ts
+++ b/tests/unit/services/n8n-api-client.test.ts
@@ -1491,7 +1491,7 @@ describe('N8nApiClient', () => {
      const params = { limit: 50, sortBy: 'email:asc', search: 'john' };
      const result = await client.getDataTableRows('dt-1', params);

-      expect(mockAxiosInstance.get).toHaveBeenCalledWith('/data-tables/dt-1/rows', expect.objectContaining({ params }));
+      expect(mockAxiosInstance.get).toHaveBeenCalledWith('/data-tables/dt-1/rows', { params });
      expect(result).toEqual(response);
    });

@@ -1636,7 +1636,7 @@ describe('N8nApiClient', () => {
      const params = { filter: '{"type":"and","filters":[]}', dryRun: false };
      const result = await client.deleteDataTableRows('dt-1', params);

-      expect(mockAxiosInstance.delete).toHaveBeenCalledWith('/data-tables/dt-1/rows/delete', expect.objectContaining({ params }));
+      expect(mockAxiosInstance.delete).toHaveBeenCalledWith('/data-tables/dt-1/rows/delete', { params });
      expect(result).toEqual(deleteResult);
    });
Author	SHA1	Message	Date
czlonkowski	fcc423084a	fix: add missing datatable methods to handlers-n8n-manager mock client CI fails because handlers-manage-datatable.test.ts and handlers-n8n-manager.test.ts share the same Vitest worker and module cache. The manage-datatable test mocks N8nApiClient with 20 methods but handlers-n8n-manager only had 10. When running in parallel, the singleton client state leaked between files causing mock mismatches. Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>	2026-03-21 23:26:39 +01:00
czlonkowski	ba1f9be984	fix: re-apply encodeURIComponent for filter/sortBy in handlers The URL-encoding fixes were reverted by a concurrent agent. Re-applying encodeURIComponent() for filter and sortBy in handleGetRows and handleDeleteRows to match the test expectations and n8n API requirements. Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>	2026-03-21 22:35:56 +01:00
czlonkowski	a62e5f198c	fix: case-insensitive 'not found' assertions in API client tests N8nNotFoundError now passes through API messages directly instead of wrapping them. The n8n API returns "Not found" (capital N) but tests used .toContain('not found') (lowercase). Changed to case-insensitive. Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>	2026-03-21 22:22:02 +01:00
czlonkowski	b0279bd11f	fix: resolve 5 bugs in n8n_manage_datatable row operations and error handling Fix critical issues found during staging QA testing: 1. data parameter serialization: MCP transport sends JSON as strings — added z.preprocess coercers (coerceJsonArray, coerceJsonObject, coerceJsonFilter) to parse string→JSON before Zod validation 2. filter/sortBy URL encoding: n8n API requires URL-encoded query params — added encodeURIComponent() for filter and sortBy in getRows/deleteRows 3. json column type: n8n API only accepts string\|number\|boolean\|date — removed json from enum in types, Zod schema, tool definition, and docs 4. 404 error messages: N8nNotFoundError was wrapping API messages in "Resource with ID <message> not found" — now passes through cleanly 5. Unit test expectations updated for URL-encoded filter/sortBy values Conceived by Romuald Członkowski - https://www.aiadvisors.pl/en Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>	2026-03-21 22:03:07 +01:00