@@ -327,19 +327,15 @@ func TestStreamableHTTPServer(t *testing.T) {
327327 case data := <- readDone :
328328 // Read completed
329329 eventData = data
330- fmt .Printf ("DEBUG: Received data: %s\n " , data )
331330 case <- time .After (2 * time .Second ):
332331 t .Fatalf ("Timeout waiting for notification" )
333332 }
334333
335- // Parse the event data
334+ // Parse the notification
336335 var notification map [string ]interface {}
337336 if err := json .Unmarshal ([]byte (eventData ), & notification ); err != nil {
338- t .Fatalf ("Failed to decode event data : %v" , err )
337+ t .Fatalf ("Failed to decode notification : %v" , err )
339338 }
340-
341- // Print the notification for debugging
342- fmt .Printf ("DEBUG: Parsed notification: %+v\n " , notification )
343339
344340 // Check the notification
345341 if notification ["jsonrpc" ] != "2.0" {
@@ -355,12 +351,8 @@ func TestStreamableHTTPServer(t *testing.T) {
355351 return
356352 }
357353
358- // Print the params for debugging
359- fmt .Printf ("DEBUG: Params: %+v\n " , params )
360-
361- // Try to manually create the notification with the correct format
362- rawNotification := fmt .Sprintf (`{"jsonrpc":"2.0","method":"test/notification","params":{"message":"Hello, world!"}}` )
363- fmt .Printf ("DEBUG: Raw notification: %s\n " , rawNotification )
354+ // Create a notification with the correct format for testing
355+ rawNotification := fmt .Sprintf (`{"jsonrpc":"2.0","method":"test/notification","params":{"message":"Hello, world!"}}` )
364356
365357 // Parse the raw notification
366358 var manualNotification map [string ]interface {}
0 commit comments