Update api/utils.py

api/utils.py

@@ -177,8 +177,8 @@ async def process_streaming_response(request: ChatRequest):
                         yield f"data: {json.dumps(create_chat_completion_data(cleaned_content, request.model, timestamp))}\n\n"
                         response_content += cleaned_content  # Collect the full response content
 
-                # After all chunks are processed, add the advertisement text at the end
-                if ADVERTISEMENT_TEXT:
+                # After all chunks are processed, add the advertisement text at the end only if it's not already present
+                if ADVERTISEMENT_TEXT and ADVERTISEMENT_TEXT not in response_content:
                     response_content += "\n\n" + ADVERTISEMENT_TEXT
                     yield f"data: {json.dumps(create_chat_completion_data(response_content, request.model, timestamp, 'stop'))}\n\n"