Update gen.py

gen.py

@@ -709,11 +709,16 @@ async def generate_text(
                         if not line:
                             yield "\n", chosen_model
                             continue
-                        if '"error"' in line.lower():
-                            print("[STREAM FALLBACK] Error detected inside SSE → switching to Groq fallback")
-                            async for chunk in stream_fallback(client, body):
-                                yield chunk, fallback_model
-                            return
+                        if line.startswith("event: error"):
+                            fallback()
+                            
+                            if line.startswith("data:"):
+                                try:
+                                    obj = json.loads(line[5:].strip())
+                                    if isinstance(obj, dict) and "error" in obj and isinstance(obj["error"], dict):
+                                        fallback()
+                                except:
+                                    pass
     
                         yield line + "\n", chosen_model