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; } +export interface KtxMongoQueryResponse { + headers: string[]; + rows: unknown[][]; + rowCount: number; +} + +/** @internal */ +export interface KtxMongoQueryMcpPort { + execute( + input: { connectionId: string; collection: string; database?: string; pipeline: Record[]; limit: number }, + options?: { onProgress?: KtxMcpProgressCallback }, + ): Promise; +} + /** @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; }