From 90e78171f1c4d5bb4c37fd27b62bf4a5dd3cf251 Mon Sep 17 00:00:00 2001
From: Kevin Messiaen <114553769+kevinmessiaen@users.noreply.github.com>
Date: Mon, 6 Jul 2026 16:21:18 +0700
Subject: [PATCH] feat(mcp): declare mongoQuery context port contract

---
 packages/cli/src/context/mcp/types.ts | 15 +++++++++++++++
 1 file changed, 15 insertions(+)

diff --git a/packages/cli/src/context/mcp/types.ts b/packages/cli/src/context/mcp/types.ts
index c8dbd480..36a86115 100644
--- a/packages/cli/src/context/mcp/types.ts
+++ b/packages/cli/src/context/mcp/types.ts
@@ -180,6 +180,20 @@ export interface KtxSqlExecutionMcpPort {
   ): Promise<KtxSqlExecutionResponse>;
 }
 
+export interface KtxMongoQueryResponse {
+  headers: string[];
+  rows: unknown[][];
+  rowCount: number;
+}
+
+/** @internal */
+export interface KtxMongoQueryMcpPort {
+  execute(
+    input: { connectionId: string; collection: string; database?: string; pipeline: Record<string, unknown>[]; limit: number },
+    options?: { onProgress?: KtxMcpProgressCallback },
+  ): Promise<KtxMongoQueryResponse>;
+}
+
 /** @internal */
 export interface KtxDialectNotesMcpPort {
   read(input: { connectionId: string }): Promise<{ connectionId: string; dialect: string; notes: string }>;
@@ -193,6 +207,7 @@ export interface KtxMcpContextPorts {
   dictionarySearch?: KtxDictionarySearchMcpPort;
   discover?: KtxDiscoverDataMcpPort;
   sqlExecution?: KtxSqlExecutionMcpPort;
+  mongoQuery?: KtxMongoQueryMcpPort;
   dialectNotes?: KtxDialectNotesMcpPort;
   memoryIngest?: MemoryIngestPort;
 }