@@ -70,7 +70,7 @@ func (c *Client) complete(ctx context.Context, agentName string, req *schemas.Bi
7070
7171 data , err := json .Marshal (req )
7272 if err != nil {
73- return nil , fmt .Errorf ("failed to marshal bifrost request: %w" , err )
73+ return nil , fmt .Errorf ("failed to marshal request: %w" , err )
7474 }
7575 log .Messages (ctx , "bifrost-request" , true , data )
7676
@@ -96,7 +96,7 @@ func (c *Client) complete(ctx context.Context, agentName string, req *schemas.Bi
9696
9797 if httpResp .StatusCode != http .StatusOK {
9898 body , _ := io .ReadAll (httpResp .Body )
99- return nil , fmt .Errorf ("bifrost request failed: %s %q" , httpResp . Status , string (body ))
99+ return nil , fmt .Errorf ("request failed: %q" , string (body ))
100100 }
101101
102102 result , err := c .parseStream (ctx , agentName , httpResp .Body , opt .ProgressToken )
@@ -141,7 +141,7 @@ func (c *Client) parseStream(ctx context.Context, agentName string, body io.Read
141141
142142 var event schemas.BifrostResponsesStreamResponse
143143 if err := json .Unmarshal ([]byte (body ), & event ); err != nil {
144- slog .Error ("bifrost: failed to decode stream event" , "error" , err , "body" , body )
144+ slog .Error ("failed to decode stream event" , "error" , err , "body" , body )
145145 continue
146146 }
147147
@@ -252,9 +252,9 @@ func (c *Client) parseStream(ctx context.Context, agentName string, body io.Read
252252
253253 case schemas .ResponsesStreamResponseTypeFailed , schemas .ResponsesStreamResponseTypeIncomplete :
254254 if event .Response != nil && event .Response .Error != nil {
255- return nil , fmt .Errorf ("bifrost stream error: %s %s" , event .Response .Error .Code , event .Response .Error .Message )
255+ return nil , fmt .Errorf ("stream error: %s %s" , event .Response .Error .Code , event .Response .Error .Message )
256256 }
257- return nil , fmt .Errorf ("bifrost stream ended with status: %s" , event .Type )
257+ return nil , fmt .Errorf ("stream ended with status: %s" , event .Type )
258258 }
259259 }
260260
@@ -290,10 +290,10 @@ func (c *Client) parseStream(ctx context.Context, agentName string, body io.Read
290290
291291 return result , nil
292292 }
293- return nil , fmt .Errorf ("bifrost stream read error: %w" , err )
293+ return nil , fmt .Errorf ("stream read error: %w" , err )
294294 }
295295 if ! started {
296- return nil , fmt .Errorf ("bifrost stream ended without a completed response" )
296+ return nil , fmt .Errorf ("stream ended without a completed response" )
297297 }
298298 return result , nil
299299}
0 commit comments