From b0f72736b097c803399417a585a5f3453740cc0d Mon Sep 17 00:00:00 2001 From: Luis Pater Date: Wed, 3 Sep 2025 00:44:35 +0800 Subject: [PATCH] Remove redundant `dataUglyTag` parsing logic in streaming responses Eliminated duplicate blocks handling `dataUglyTag` in `openai-compatibility_client.go`, simplifying the streaming response logic. --- .../client/openai-compatibility_client.go | 24 ------------------- 1 file changed, 24 deletions(-) diff --git a/internal/client/openai-compatibility_client.go b/internal/client/openai-compatibility_client.go index dec34888..0e9a08b4 100644 --- a/internal/client/openai-compatibility_client.go +++ b/internal/client/openai-compatibility_client.go @@ -346,30 +346,6 @@ func (c *OpenAICompatibilityClient) SendRawMessageStream(ctx context.Context, mo c.AddAPIResponseData(ctx, line) dataChan <- []byte(lines[i]) } - } else if bytes.HasPrefix(line, dataUglyTag) { - if bytes.Equal(line, doneTag) { - break - } - lines := translator.Response(handlerType, c.Type(), newCtx, modelName, line[5:], ¶m) - for i := 0; i < len(lines); i++ { - dataChan <- []byte(lines[i]) - } - } else if bytes.HasPrefix(line, dataUglyTag) { - if bytes.Equal(line, doneTag) { - break - } - lines := translator.Response(handlerType, c.Type(), newCtx, modelName, line[5:], ¶m) - for i := 0; i < len(lines); i++ { - dataChan <- []byte(lines[i]) - } - } else if bytes.HasPrefix(line, dataUglyTag) { - if bytes.Equal(line, doneTag) { - break - } - lines := translator.Response(handlerType, c.Type(), newCtx, modelName, line[5:], ¶m) - for i := 0; i < len(lines); i++ { - dataChan <- []byte(lines[i]) - } } } } else {