wip

Author: cablehead

gpt/xs/call.nu

@@ -18,7 +18,13 @@
 
     let p = anthropic provider
     let prepared = do $p.prepare-request $thread []
-    let response = $prepared | do $p.call $key "claude-3-5-haiku-20241022" | do $p.response_stream_aggregate 
+    let response = $prepared | do $p.call $key "claude-3-5-haiku-20241022" | tee {
+    each {|chunk| 
+     let event = do $p.response_stream_streamer $chunk 
+    if $event == null { return }
+
+     $event | to json | .append gpt.recv} } |
+    do $p.response_stream_aggregate 
 
     $response
   }

tests/end-to-end/bootstrap.nu

@@ -19,7 +19,7 @@ let req = .append gpt.call --meta {continues: (.head gpt.turn).id}
 
 .cat -f | update hash { .cas } | take until {|frame| 
 	print ($frame | table -e) 
-	($frame.topic == "gpt.response") and ($frame.meta?.frame_id == $req.id)
+	($frame.topic in ["gpt.error" "gpt.response"]) and ($frame.meta?.frame_id == $req.id)
 }
 
 sleep 50ms