16271253098

Committed 14 Jul 2025 03:37PM UTC coverage: 75.779%. First build

Build # 16271253098

Build Type

Pull #359

github

Committed by

web-flow

Commit Message

Merge f0a83b00b into b10990b77

Pull Request Pull Request #359: feat: add streamable http [MCP-55]

Run Details

388 of 602 branches covered (64.45%)

Branch coverage included in aggregate %.

24 of 30 new or added lines in 2 files covered. (80.0%)

901 of 1099 relevant lines covered (81.98%)

114.56 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

50.85

/src/tools/atlas/read/listClusters.ts

import { z } from "zod";
import { CallToolResult } from "@modelcontextprotocol/sdk/types.js";
import { AtlasToolBase } from "../atlasTool.js";
import { ToolArgs, OperationType } from "../../tool.js";
import {
    PaginatedClusterDescription20240805,
    PaginatedOrgGroupView,
    Group,
    PaginatedFlexClusters20241113,
} from "../../../common/atlas/openapi.js";
import { formatCluster, formatFlexCluster } from "../../../common/atlas/cluster.js";

export class ListClustersTool extends AtlasToolBase {
    public name = "atlas-list-clusters";
    protected description = "List MongoDB Atlas clusters";
    public operationType: OperationType = "read";
    protected argsShape = {
        projectId: z.string().describe("Atlas project ID to filter clusters").optional(),
    };

    protected async execute({ projectId }: ToolArgs<typeof this.argsShape>): Promise<CallToolResult> {
        if (!projectId) {
            const data = await this.session.apiClient.listClustersForAllProjects();

            return this.formatAllClustersTable(data);
        } else {
            const project = await this.session.apiClient.getProject({
                params: {
                    path: {
                        groupId: projectId,
                    },
                },
            });

            if (!project?.id) {
                throw new Error(`Project with ID "${projectId}" not found.`);
            }

            const data = await this.session.apiClient.listClusters({
                params: {
                    path: {
                        groupId: project.id || "",
                    },
                },
            });

            return this.formatClustersTable(project, data);
        }
    }

    private formatAllClustersTable(clusters?: PaginatedOrgGroupView): CallToolResult {
        if (!clusters?.results?.length) {
            throw new Error("No clusters found.");
        }
        const formattedClusters = clusters.results
            .map((result) => {
                return (result.clusters || []).map((cluster) => {
                    return { ...result, ...cluster, clusters: undefined };
                });
            })
            .flat();
        if (!formattedClusters.length) {
            throw new Error("No clusters found.");
        }
        const rows = formattedClusters
            .map((cluster) => {
                return `${cluster.groupName} (${cluster.groupId}) | ${cluster.name}`;
            })
            .join("\n");
        return {
            content: [
                {
                    type: "text",
                    text: `Project | Cluster Name
----------------|----------------
${rows}`,
                },
            ],
        };
    }

    private formatClustersTable(
        project: Group,
        clusters?: PaginatedClusterDescription20240805,
        flexClusters?: PaginatedFlexClusters20241113
    ): CallToolResult {
        // Check if both traditional clusters and flex clusters are absent
        if (!clusters?.results?.length && !flexClusters?.results?.length) {
            throw new Error("No clusters found.");
        }
        const formattedClusters = clusters?.results?.map((cluster) => formatCluster(cluster)) || [];
        const formattedFlexClusters = flexClusters?.results?.map((cluster) => formatFlexCluster(cluster)) || [];
        const rows = [...formattedClusters, ...formattedFlexClusters]
            .map((formattedCluster) => {
                return `${formattedCluster.name || "Unknown"} | ${formattedCluster.instanceType} | ${formattedCluster.instanceSize || "N/A"} | ${formattedCluster.state || "UNKNOWN"} | ${formattedCluster.mongoDBVersion || "N/A"} | ${formattedCluster.connectionString || "N/A"}`;
            })
            .join("\n");
        return {
            content: [
                {
                    type: "text",
                    text: `Here are your MongoDB Atlas clusters in project "${project.name}" (${project.id}):`,
                },
                {
                    type: "text",
                    text: `Cluster Name | Cluster Type | Tier | State | MongoDB Version | Connection String
----------------|----------------|----------------|----------------|----------------|----------------
${rows}`,
                },
            ],
        };
    }
}

1	import { z } from "zod";
2	import { CallToolResult } from "@modelcontextprotocol/sdk/types.js";
3	import { AtlasToolBase } from "../atlasTool.js";
4	import { ToolArgs, OperationType } from "../../tool.js";
5	import {
6	PaginatedClusterDescription20240805,
7	PaginatedOrgGroupView,
8	Group,
9	PaginatedFlexClusters20241113,
10	} from "../../../common/atlas/openapi.js";
11	import { formatCluster, formatFlexCluster } from "../../../common/atlas/cluster.js";
12
13	export class ListClustersTool extends AtlasToolBase {
14	public name = "atlas-list-clusters";	68✔
15	protected description = "List MongoDB Atlas clusters";	68✔
16	public operationType: OperationType = "read";	68✔
17	protected argsShape = {	68✔
18	projectId: z.string().describe("Atlas project ID to filter clusters").optional(),
19	};
20
21	protected async execute({ projectId }: ToolArgs<typeof this.argsShape>): Promise<CallToolResult> {
22	if (!projectId) {	2!
23	const data = await this.session.apiClient.listClustersForAllProjects();	×
24
25	return this.formatAllClustersTable(data);	×
26	} else {
27	const project = await this.session.apiClient.getProject({	2✔
28	params: {
29	path: {
30	groupId: projectId,
31	},
32	},
33	});
34
35	if (!project?.id) {	2!
36	throw new Error(`Project with ID "${projectId}" not found.`);	×
37	}
38
39	const data = await this.session.apiClient.listClusters({	2✔
40	params: {
41	path: {
42	groupId: project.id \|\| "",	2!
43	},
44	},
45	});
46
47	return this.formatClustersTable(project, data);	2✔
48	}
49	}
50
51	private formatAllClustersTable(clusters?: PaginatedOrgGroupView): CallToolResult {
52	if (!clusters?.results?.length) {	×
53	throw new Error("No clusters found.");	×
54	}
55	const formattedClusters = clusters.results	×
56	.map((result) => {
57	return (result.clusters \|\| []).map((cluster) => {	×
58	return { ...result, ...cluster, clusters: undefined };	×
59	});
60	})
61	.flat();
62	if (!formattedClusters.length) {	×
63	throw new Error("No clusters found.");	×
64	}
65	const rows = formattedClusters	×
66	.map((cluster) => {
67	return `${cluster.groupName} (${cluster.groupId}) \| ${cluster.name}`;	×
68	})
69	.join("\n");
70	return {	×
71	content: [
72	{
73	type: "text",
74	text: `Project \| Cluster Name
75	----------------\|----------------
76	${rows}`,
77	},
78	],
79	};
80	}
81
82	private formatClustersTable(
83	project: Group,
84	clusters?: PaginatedClusterDescription20240805,
85	flexClusters?: PaginatedFlexClusters20241113
86	): CallToolResult {
87	// Check if both traditional clusters and flex clusters are absent
88	if (!clusters?.results?.length && !flexClusters?.results?.length) {	2!
89	throw new Error("No clusters found.");	×
90	}
91	const formattedClusters = clusters?.results?.map((cluster) => formatCluster(cluster)) \|\| [];	2!
92	const formattedFlexClusters = flexClusters?.results?.map((cluster) => formatFlexCluster(cluster)) \|\| [];	2✔
93	const rows = [...formattedClusters, ...formattedFlexClusters]	2✔
94	.map((formattedCluster) => {
95	return `${formattedCluster.name \|\| "Unknown"} \| ${formattedCluster.instanceType} \| ${formattedCluster.instanceSize \|\| "N/A"} \| ${formattedCluster.state \|\| "UNKNOWN"} \| ${formattedCluster.mongoDBVersion \|\| "N/A"} \| ${formattedCluster.connectionString \|\| "N/A"}`;	2!
96	})
97	.join("\n");
98	return {	2✔
99	content: [
100	{
101	type: "text",
102	text: `Here are your MongoDB Atlas clusters in project "${project.name}" (${project.id}):`,
103	},
104	{
105	type: "text",
106	text: `Cluster Name \| Cluster Type \| Tier \| State \| MongoDB Version \| Connection String
107	----------------\|----------------\|----------------\|----------------\|----------------\|----------------
108	${rows}`,
109	},
110	],
111	};
112	}
113	}

mongodb-js / mongodb-mcp-server / 16271253098

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous