@@ -297,9 +297,6 @@ proc serveOnceDelayedHead(server: SseServer; delayMs: int) =
297297proc serveThread (server: SseServer ) {.thread .} =
298298 serveOnce (server)
299299
300- proc logDiag (msg: string ) =
301- stderr.writeLine (" [diag " , epochTime ().formatFloat (ffDecimal, 3 ), " ] " , msg)
302-
303300proc serveRetryable (server: SseServer ) {.thread .} =
304301 # # Like serveThread, but serves every connection until the test flips
305302 # # `server.done` or the accept deadline passes. The transport re-dials
@@ -546,22 +543,17 @@ suite "streaming SSE: mid-stream error (OpenRouter)":
546543 code = 400 ))
547544 var srv: Thread [SseServer ]
548545 createThread (srv, serveRetryable, server)
549- logDiag " t1 calling callModel"
550546 var usage = Usage ()
551547 var raised = false
552548 try :
553549 discard callModel (testProfile (server),
554550 %* [{" role" : " user" , " content" : " go" }], usage, 0 )
555- logDiag " t1 callModel RETURNED (no raise)"
556551 except ApiError as e:
557552 raised = true
558- logDiag " t1 callModel raised: " & e.msg[0 ..< min (80 , e.msg.len)]
559553 check " Provider disconnected unexpectedly" in e.msg
560554 check raised
561- logDiag " t1 flipping done"
562555 server.done.store (true , moRelease)
563556 joinThread (srv)
564- logDiag " t1 joined"
565557 server.socket.close ()
566558 closeCachedStreamConn ()
567559
@@ -572,22 +564,17 @@ suite "streaming SSE: mid-stream error (OpenRouter)":
572564 " Provider overloaded" , " id-err-2" , code = 400 ))
573565 var srv: Thread [SseServer ]
574566 createThread (srv, serveRetryable, server)
575- logDiag " t2 calling callModel"
576567 var usage = Usage ()
577568 var raised = false
578569 try :
579570 discard callModel (testProfile (server),
580571 %* [{" role" : " user" , " content" : " go" }], usage, 0 )
581- logDiag " t2 callModel RETURNED (no raise)"
582572 except ApiError as e:
583573 raised = true
584- logDiag " t2 callModel raised: " & e.msg[0 ..< min (80 , e.msg.len)]
585574 check " Provider overloaded" in e.msg
586575 check raised
587- logDiag " t2 flipping done"
588576 server.done.store (true , moRelease)
589577 joinThread (srv)
590- logDiag " t2 joined"
591578 server.socket.close ()
592579 closeCachedStreamConn ()
593580
0 commit comments