Skip to content

Commit 09858ce

Browse files
ochafikclaude
andcommitted
Apply code formatting
🤖 Generated with [Claude Code](https://claude.com/claude-code) Co-Authored-By: Claude <noreply@anthropic.com>
1 parent 5484fcc commit 09858ce

4 files changed

Lines changed: 58 additions & 42 deletions

File tree

examples/aggregator-server/server.ts

Lines changed: 36 additions & 40 deletions
Original file line numberDiff line numberDiff line change
@@ -127,10 +127,16 @@ function rewriteMeta(prefix: string, meta: Tool["_meta"]): Tool["_meta"] {
127127
result.ui = { ...ui, resourceUri: prefixUri(prefix, ui.resourceUri) };
128128
// Rewrite legacy flat key
129129
if (result["ui/resourceUri"])
130-
result["ui/resourceUri"] = prefixUri(prefix, result["ui/resourceUri"] as string);
130+
result["ui/resourceUri"] = prefixUri(
131+
prefix,
132+
result["ui/resourceUri"] as string,
133+
);
131134
// Rewrite OpenAI outputTemplate key
132135
if (result["openai/outputTemplate"])
133-
result["openai/outputTemplate"] = prefixUri(prefix, result["openai/outputTemplate"] as string);
136+
result["openai/outputTemplate"] = prefixUri(
137+
prefix,
138+
result["openai/outputTemplate"] as string,
139+
);
134140
return result;
135141
}
136142

@@ -214,27 +220,23 @@ async function startHttpServer(port: number): Promise<void> {
214220
session &&
215221
!(session.transport instanceof StreamableHTTPServerTransport)
216222
) {
217-
return res
218-
.status(400)
219-
.json({
220-
jsonrpc: "2.0",
221-
error: {
222-
code: -32000,
223-
message: "Session uses different transport",
224-
},
225-
id: null,
226-
});
223+
return res.status(400).json({
224+
jsonrpc: "2.0",
225+
error: {
226+
code: -32000,
227+
message: "Session uses different transport",
228+
},
229+
id: null,
230+
});
227231
}
228232

229233
if (!session) {
230234
if (req.method !== "POST" || !isInitializeRequest(req.body)) {
231-
return res
232-
.status(400)
233-
.json({
234-
jsonrpc: "2.0",
235-
error: { code: -32000, message: "Bad request: not initialized" },
236-
id: null,
237-
});
235+
return res.status(400).json({
236+
jsonrpc: "2.0",
237+
error: { code: -32000, message: "Bad request: not initialized" },
238+
id: null,
239+
});
238240
}
239241

240242
const serverInstance = await createServerAsync();
@@ -258,13 +260,11 @@ async function startHttpServer(port: number): Promise<void> {
258260
} catch (error) {
259261
console.error("MCP error:", error);
260262
if (!res.headersSent) {
261-
res
262-
.status(500)
263-
.json({
264-
jsonrpc: "2.0",
265-
error: { code: -32603, message: "Internal server error" },
266-
id: null,
267-
});
263+
res.status(500).json({
264+
jsonrpc: "2.0",
265+
error: { code: -32603, message: "Internal server error" },
266+
id: null,
267+
});
268268
}
269269
}
270270
});
@@ -286,25 +286,21 @@ async function startHttpServer(port: number): Promise<void> {
286286
try {
287287
const session = sessions.get(req.query.sessionId as string);
288288
if (!session || !(session.transport instanceof SSEServerTransport)) {
289-
return res
290-
.status(404)
291-
.json({
292-
jsonrpc: "2.0",
293-
error: { code: -32001, message: "Session not found" },
294-
id: null,
295-
});
289+
return res.status(404).json({
290+
jsonrpc: "2.0",
291+
error: { code: -32001, message: "Session not found" },
292+
id: null,
293+
});
296294
}
297295
await session.transport.handlePostMessage(req, res, req.body);
298296
} catch (error) {
299297
console.error("Message error:", error);
300298
if (!res.headersSent) {
301-
res
302-
.status(500)
303-
.json({
304-
jsonrpc: "2.0",
305-
error: { code: -32603, message: "Internal server error" },
306-
id: null,
307-
});
299+
res.status(500).json({
300+
jsonrpc: "2.0",
301+
error: { code: -32603, message: "Internal server error" },
302+
id: null,
303+
});
308304
}
309305
}
310306
});

examples/run-all.ts

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -70,7 +70,10 @@ const commands: Parameters<typeof concurrently>[0] = [
7070
{
7171
command: `npm run --workspace examples/${AGGREGATOR} ${command}`,
7272
name: AGGREGATOR,
73-
env: { PORT: String(aggregator.port), BACKEND_SERVERS: backendServersEnv },
73+
env: {
74+
PORT: String(aggregator.port),
75+
BACKEND_SERVERS: backendServersEnv,
76+
},
7477
},
7578
]
7679
: []),

package-lock.json

Lines changed: 12 additions & 0 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

src/openai/transport.ts

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -523,7 +523,12 @@ export class OpenAITransport implements Transport {
523523
// Generate content from structuredContent if not provided
524524
content = Array.isArray(result.content)
525525
? result.content
526-
: [{ type: "text", text: JSON.stringify(result.structuredContent) }];
526+
: [
527+
{
528+
type: "text",
529+
text: JSON.stringify(result.structuredContent),
530+
},
531+
];
527532
} else if (Array.isArray(result.content)) {
528533
content = result.content;
529534
} else {

0 commit comments

Comments
 (0)