Skip to content

Commit a87b5ca

Browse files
committed
fix: format
1 parent 85d70ef commit a87b5ca

File tree

4 files changed

+32
-12
lines changed

4 files changed

+32
-12
lines changed

README.md

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -304,7 +304,7 @@ The MongoDB MCP Server can be configured using multiple methods, with the follow
304304
| `apiClientId` | <not set> | Atlas API client ID for authentication. Required for running Atlas tools. |
305305
| `apiClientSecret` | <not set> | Atlas API client secret for authentication. Required for running Atlas tools. |
306306
| `connectionString` | <not set> | MongoDB connection string for direct database connections. Optional, if not set, you'll need to call the `connect` tool before interacting with MongoDB data. |
307-
| `logPath` | see note* | Folder to store logs. |
307+
| `logPath` | see note\* | Folder to store logs. |
308308
| `disabledTools` | <not set> | An array of tool names, operation types, and/or categories of tools that will be disabled. |
309309
| `readOnly` | false | When set to true, only allows read, connect, and metadata operation types, disabling create/update/delete operations. |
310310
| `indexCheck` | false | When set to true, enforces that query operations must use an index, rejecting queries that perform a collection scan. |

src/common/logger.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -183,4 +183,4 @@ class CompositeLogger extends LoggerBase {
183183
}
184184

185185
const logger = new CompositeLogger(new ConsoleLogger());
186-
export default logger;
186+
export default logger;

src/server.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -78,7 +78,7 @@ export class Server {
7878
loggers.push(new ConsoleLogger());
7979
}
8080
logger.setLoggers(...loggers);
81-
81+
8282
this.mcpServer.server.oninitialized = () => {
8383
this.session.setAgentRunner(this.mcpServer.server.getClientVersion());
8484
this.session.sessionId = new ObjectId().toString();

src/transports/streamableHttpTransport.ts

Lines changed: 29 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -12,14 +12,18 @@ export function createHttpTransport(): StreamableHTTPServerTransport {
1212
app.use(express.json());
1313

1414
const transport = new StreamableHTTPServerTransport({
15-
sessionIdGenerator: undefined
15+
sessionIdGenerator: undefined,
1616
});
1717

1818
app.post("/mcp", async (req: express.Request, res: express.Response) => {
1919
try {
2020
await transport.handleRequest(req, res, req.body);
2121
} catch (error) {
22-
logger.error(LogId.streamableHttpTransportRequestFailure, "streamableHttpTransport", `Error handling request: ${error}`);
22+
logger.error(
23+
LogId.streamableHttpTransportRequestFailure,
24+
"streamableHttpTransport",
25+
`Error handling request: ${error}`
26+
);
2327
res.sendStatus(400);
2428
}
2529
});
@@ -28,7 +32,11 @@ export function createHttpTransport(): StreamableHTTPServerTransport {
2832
try {
2933
await transport.handleRequest(req, res, req.body);
3034
} catch (error) {
31-
logger.error(LogId.streamableHttpTransportRequestFailure, "streamableHttpTransport", `Error handling request: ${error}`);
35+
logger.error(
36+
LogId.streamableHttpTransportRequestFailure,
37+
"streamableHttpTransport",
38+
`Error handling request: ${error}`
39+
);
3240
res.sendStatus(400);
3341
}
3442
});
@@ -37,13 +45,21 @@ export function createHttpTransport(): StreamableHTTPServerTransport {
3745
try {
3846
await transport.handleRequest(req, res, req.body);
3947
} catch (error) {
40-
logger.error(LogId.streamableHttpTransportRequestFailure, "streamableHttpTransport", `Error handling request: ${error}`);
48+
logger.error(
49+
LogId.streamableHttpTransportRequestFailure,
50+
"streamableHttpTransport",
51+
`Error handling request: ${error}`
52+
);
4153
res.sendStatus(400);
4254
}
4355
});
4456

4557
const server = app.listen(config.httpPort, config.httpHost, () => {
46-
logger.info(LogId.streamableHttpTransportStarted, "streamableHttpTransport", `Server started on http://${config.httpHost}:${config.httpPort}`);
58+
logger.info(
59+
LogId.streamableHttpTransportStarted,
60+
"streamableHttpTransport",
61+
`Server started on http://${config.httpHost}:${config.httpPort}`
62+
);
4763
});
4864

4965
transport.onclose = async () => {
@@ -60,9 +76,13 @@ export function createHttpTransport(): StreamableHTTPServerTransport {
6076
});
6177
logger.info(LogId.streamableHttpTransportCloseSuccess, "streamableHttpTransport", `Server closed`);
6278
} catch (error: unknown) {
63-
logger.error(LogId.streamableHttpTransportCloseFailure, "streamableHttpTransport", `Error closing server: ${error instanceof Error ? error.message : String(error)}`);
64-
};
65-
}
79+
logger.error(
80+
LogId.streamableHttpTransportCloseFailure,
81+
"streamableHttpTransport",
82+
`Error closing server: ${error instanceof Error ? error.message : String(error)}`
83+
);
84+
}
85+
};
6686

6787
return transport;
68-
}
88+
}

0 commit comments

Comments
 (0)