@@ -327,7 +327,7 @@ func doGetMCPTools(ctx context.Context, permissions permission.Service, cfg *con
327
327
}
328
328
329
329
func createAndInitializeClient (ctx context.Context , name string , m config.MCPConfig ) (* client.Client , error ) {
330
- c , err := createMcpClient (m )
330
+ c , err := createMcpClient (name , m )
331
331
if err != nil {
332
332
updateMCPState (name , MCPStateError , err , nil , 0 )
333
333
slog .Error ("error creating mcp client" , "error" , err , "name" , name )
@@ -353,7 +353,7 @@ func createAndInitializeClient(ctx context.Context, name string, m config.MCPCon
353
353
return c , nil
354
354
}
355
355
356
- func createMcpClient (m config.MCPConfig ) (* client.Client , error ) {
356
+ func createMcpClient (name string , m config.MCPConfig ) (* client.Client , error ) {
357
357
switch m .Type {
358
358
case config .MCPStdio :
359
359
if strings .TrimSpace (m .Command ) == "" {
@@ -363,7 +363,7 @@ func createMcpClient(m config.MCPConfig) (*client.Client, error) {
363
363
m .Command ,
364
364
m .ResolvedEnv (),
365
365
m .Args ,
366
- transport .WithCommandLogger (mcpLogger {}),
366
+ transport .WithCommandLogger (mcpLogger {name : name }),
367
367
)
368
368
case config .MCPHttp :
369
369
if strings .TrimSpace (m .URL ) == "" {
@@ -372,7 +372,7 @@ func createMcpClient(m config.MCPConfig) (*client.Client, error) {
372
372
return client .NewStreamableHttpClient (
373
373
m .URL ,
374
374
transport .WithHTTPHeaders (m .ResolvedHeaders ()),
375
- transport .WithHTTPLogger (mcpLogger {}),
375
+ transport .WithHTTPLogger (mcpLogger {name : name }),
376
376
)
377
377
case config .MCPSse :
378
378
if strings .TrimSpace (m .URL ) == "" {
@@ -381,18 +381,23 @@ func createMcpClient(m config.MCPConfig) (*client.Client, error) {
381
381
return client .NewSSEMCPClient (
382
382
m .URL ,
383
383
client .WithHeaders (m .ResolvedHeaders ()),
384
- transport .WithSSELogger (mcpLogger {}),
384
+ transport .WithSSELogger (mcpLogger {name : name }),
385
385
)
386
386
default :
387
387
return nil , fmt .Errorf ("unsupported mcp type: %s" , m .Type )
388
388
}
389
389
}
390
390
391
391
// for MCP's clients.
392
- type mcpLogger struct {}
392
+ type mcpLogger struct { name string }
393
393
394
- func (l mcpLogger ) Errorf (format string , v ... any ) { slog .Error (fmt .Sprintf (format , v ... )) }
395
- func (l mcpLogger ) Infof (format string , v ... any ) { slog .Info (fmt .Sprintf (format , v ... )) }
394
+ func (l mcpLogger ) Errorf (format string , v ... any ) {
395
+ slog .Error (fmt .Sprintf (format , v ... ), "name" , l .name )
396
+ }
397
+
398
+ func (l mcpLogger ) Infof (format string , v ... any ) {
399
+ slog .Info (fmt .Sprintf (format , v ... ), "name" , l .name )
400
+ }
396
401
397
402
func mcpTimeout (m config.MCPConfig ) time.Duration {
398
403
return time .Duration (cmp .Or (m .Timeout , 15 )) * time .Second
0 commit comments