apunkt/ktx
1
0
Fork 0
mirror of https://github.com/Kaelio/ktx.git synced 2026-07-25 12:01:03 +02:00
Code Issues Projects Releases Packages Wiki Activity

feat(mcp): declare mongoQuery context port contract

Browse source
This commit is contained in:
Kevin Messiaen 2026-07-06 16:21:18 +07:00
parent 3d56f3b0dc
commit 90e78171f1
No known key found for this signature in database
GPG key ID: 19FF750A17315202
1 changed files with 15 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

15
packages/cli/src/context/mcp/types.ts
View file

@ -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;
}