From bcfd562f18738feaa820fad657b76010d6b07ed5 Mon Sep 17 00:00:00 2001
From: Kevin Messiaen <114553769+kevinmessiaen@users.noreply.github.com>
Date: Sat, 11 Jul 2026 21:26:10 +0700
Subject: [PATCH] refactor(mongo-query): forward the query input without
 re-listing fields

Now that KtxMongoQueryArgs extends KtxMongoQueryInput and the runner takes
that type, pass the args/input object straight through instead of rebuilding
it field by field. assertSafeConnectionId returns its input verbatim, so the
`{ ...input, connectionId }` spread was re-asserting an equal value.

Co-Authored-By: Claude Opus 4.8 <noreply@anthropic.com>
Claude-Session: https://claude.ai/code/session_01Ga2tvQ2YCEphmY8HM5Guzq
---
 packages/cli/src/context/mcp/mongo-query-runner.ts | 2 +-
 packages/cli/src/mongo-query.ts                    | 8 +-------
 2 files changed, 2 insertions(+), 8 deletions(-)

diff --git a/packages/cli/src/context/mcp/mongo-query-runner.ts b/packages/cli/src/context/mcp/mongo-query-runner.ts
index 65136cd8..2d45dc54 100644
--- a/packages/cli/src/context/mcp/mongo-query-runner.ts
+++ b/packages/cli/src/context/mcp/mongo-query-runner.ts
@@ -16,7 +16,7 @@ export async function runMongoQuery(
         `Connection "${connectionId}" driver "${connector.driver}" is not a MongoDB connection; mongo_query serves mongodb connections only.`,
       );
     }
-    return await connector.executeQuery({ ...input, connectionId }, { runId: 'mongo-query' });
+    return await connector.executeQuery(input, { runId: 'mongo-query' });
   } finally {
     await connector?.cleanup?.();
   }
diff --git a/packages/cli/src/mongo-query.ts b/packages/cli/src/mongo-query.ts
index 17b1e33e..bc0e6e8f 100644
--- a/packages/cli/src/mongo-query.ts
+++ b/packages/cli/src/mongo-query.ts
@@ -42,13 +42,7 @@ export async function runKtxMongoQuery(
     demoConnection = isDemoConnection(args.connectionId, connection);
 
     const createScanConnector = deps.createScanConnector ?? createKtxCliScanConnector;
-    const result = await runMongoQuery((connectionId) => createScanConnector(project!, connectionId), {
-      connectionId: args.connectionId,
-      collection: args.collection,
-      database: args.database,
-      pipeline: args.pipeline,
-      limit: args.limit,
-    });
+    const result = await runMongoQuery((connectionId) => createScanConnector(project!, connectionId), args);
 
     const output: KtxResultTable = {
       connectionId: args.connectionId,