ENTERPILOT
diff --git a/‎internal/providers/groq/groq.go‎
Lines changed: 11 additions & 6 deletions b/‎internal/providers/groq/groq.go‎
Lines changed: 11 additions & 6 deletions
@@ -7,6 +7,7 @@ import (
 	"encoding/json"
 	"fmt"
 	"io"
+	"log/slog"
 	"net/http"
 	"strings"
 	"time"
@@ -280,7 +281,8 @@ func (sc *groqResponsesStreamConverter) Read(p []byte) (n int, err error) {
 		}
 		jsonData, err := json.Marshal(createdEvent)
 		if err != nil {
-			return 0, fmt.Errorf("failed to marshal response.created event: %w", err)
+			slog.Error("failed to marshal response.created event", "error", err, "response_id", sc.responseID)
+			return 0, nil
 		}
 		created := fmt.Sprintf("event: response.created\ndata: %s\n\n", jsonData)
 		sc.buffer = append(sc.buffer, []byte(created)...)
@@ -328,7 +330,8 @@ func (sc *groqResponsesStreamConverter) Read(p []byte) (n int, err error) {
 						}
 						jsonData, err := json.Marshal(doneEvent)
 						if err != nil {
-							return 0, fmt.Errorf("failed to marshal response.done event: %w", err)
+							slog.Error("failed to marshal response.done event", "error", err, "response_id", sc.responseID)
+							continue
 						}
 						doneMsg := fmt.Sprintf("event: response.done\ndata: %s\n\ndata: [DONE]\n\n", jsonData)
 						sc.buffer = append(sc.buffer, []byte(doneMsg)...)
@@ -353,7 +356,8 @@ func (sc *groqResponsesStreamConverter) Read(p []byte) (n int, err error) {
 								}
 								jsonData, err := json.Marshal(deltaEvent)
 								if err != nil {
-									return 0, fmt.Errorf("failed to marshal content delta event: %w", err)
+									slog.Error("failed to marshal content delta event", "error", err, "response_id", sc.responseID)
+									continue
 								}
 								sc.buffer = append(sc.buffer, []byte(fmt.Sprintf("event: response.output_text.delta\ndata: %s\n\n", jsonData))...)
 							}
@@ -381,10 +385,11 @@ func (sc *groqResponsesStreamConverter) Read(p []byte) (n int, err error) {
 				}
 				jsonData, err := json.Marshal(doneEvent)
 				if err != nil {
-					return 0, fmt.Errorf("failed to marshal final response.done event: %w", err)
+					slog.Error("failed to marshal final response.done event", "error", err, "response_id", sc.responseID)
+				} else {
+					doneMsg := fmt.Sprintf("event: response.done\ndata: %s\n\ndata: [DONE]\n\n", jsonData)
+					sc.buffer = append(sc.buffer, []byte(doneMsg)...)
 				}
-				doneMsg := fmt.Sprintf("event: response.done\ndata: %s\n\ndata: [DONE]\n\n", jsonData)
-				sc.buffer = append(sc.buffer, []byte(doneMsg)...)
 			}
 
 			if len(sc.buffer) > 0 {
Original file line number	Diff line number	Diff line change
`@@ -7,6 +7,7 @@ import (`
`7`	`7`	`"encoding/json"`
`8`	`8`	`"fmt"`
`9`	`9`	`"io"`
	`10`	`+ "log/slog"`
`10`	`11`	`"net/http"`
`11`	`12`	`"strings"`
`12`	`13`	`"time"`
`@@ -280,7 +281,8 @@ func (sc *groqResponsesStreamConverter) Read(p []byte) (n int, err error) {`
`280`	`281`	`}`
`281`	`282`	`jsonData, err := json.Marshal(createdEvent)`
`282`	`283`	`if err != nil {`
`283`		`- return 0, fmt.Errorf("failed to marshal response.created event: %w", err)`
	`284`	`+ slog.Error("failed to marshal response.created event", "error", err, "response_id", sc.responseID)`
	`285`	`+ return 0, nil`
`284`	`286`	`}`
`285`	`287`	`created := fmt.Sprintf("event: response.created\ndata: %s\n\n", jsonData)`
`286`	`288`	`sc.buffer = append(sc.buffer, []byte(created)...)`
`@@ -328,7 +330,8 @@ func (sc *groqResponsesStreamConverter) Read(p []byte) (n int, err error) {`
`328`	`330`	`}`
`329`	`331`	`jsonData, err := json.Marshal(doneEvent)`
`330`	`332`	`if err != nil {`
`331`		`- return 0, fmt.Errorf("failed to marshal response.done event: %w", err)`
	`333`	`+ slog.Error("failed to marshal response.done event", "error", err, "response_id", sc.responseID)`
	`334`	`+ continue`
`332`	`335`	`}`
`333`	`336`	`doneMsg := fmt.Sprintf("event: response.done\ndata: %s\n\ndata: [DONE]\n\n", jsonData)`
`334`	`337`	`sc.buffer = append(sc.buffer, []byte(doneMsg)...)`
`@@ -353,7 +356,8 @@ func (sc *groqResponsesStreamConverter) Read(p []byte) (n int, err error) {`
`353`	`356`	`}`
`354`	`357`	`jsonData, err := json.Marshal(deltaEvent)`
`355`	`358`	`if err != nil {`
`356`		`- return 0, fmt.Errorf("failed to marshal content delta event: %w", err)`
	`359`	`+ slog.Error("failed to marshal content delta event", "error", err, "response_id", sc.responseID)`
	`360`	`+ continue`
`357`	`361`	`}`
`358`	`362`	`sc.buffer = append(sc.buffer, []byte(fmt.Sprintf("event: response.output_text.delta\ndata: %s\n\n", jsonData))...)`
`359`	`363`	`}`
`@@ -381,10 +385,11 @@ func (sc *groqResponsesStreamConverter) Read(p []byte) (n int, err error) {`
`381`	`385`	`}`
`382`	`386`	`jsonData, err := json.Marshal(doneEvent)`
`383`	`387`	`if err != nil {`
`384`		`- return 0, fmt.Errorf("failed to marshal final response.done event: %w", err)`
	`388`	`+ slog.Error("failed to marshal final response.done event", "error", err, "response_id", sc.responseID)`
	`389`	`+ } else {`
	`390`	`+ doneMsg := fmt.Sprintf("event: response.done\ndata: %s\n\ndata: [DONE]\n\n", jsonData)`
	`391`	`+ sc.buffer = append(sc.buffer, []byte(doneMsg)...)`
`385`	`392`	`}`
`386`		`- doneMsg := fmt.Sprintf("event: response.done\ndata: %s\n\ndata: [DONE]\n\n", jsonData)`
`387`		`- sc.buffer = append(sc.buffer, []byte(doneMsg)...)`
`388`	`393`	`}`
`389`	`394`
`390`	`395`	`if len(sc.buffer) > 0 {`