Update app.py

app.py

@@ -58,13 +58,14 @@ async def ws_stream():
                     while True:
                         data = await websocket.receive()
                         if isinstance(data, bytes):
-                            # Handle microphone audio
+                            # Send real-time audio input
                             await session.send(
                                 input={"data": data, "mime_type": "audio/pcm;rate=16000"}
                             )
                         elif isinstance(data, str):
-                            # Handle 'echo' text commands from Termux
-                            await session.send(input=data)
+                            # NEW: Explicitly send text as a message turn to trigger response
+                            # This satisfies the new SDK requirements and avoids the deprecation warning
+                            await session.send(input=data, end_of_turn=True)
                 except Exception as e:
                     print(f"Client -> Gemini Error: {e}")
 
@@ -79,8 +80,8 @@ async def ws_stream():
                 except Exception as e:
                     print(f"Gemini -> Client Error: {e}")
 
-            # Run both tasks and wait for them to finish or error out
-            await asyncio.gather(client_to_gemini(), gemini_to_client())
+            # Using gather with return_exceptions to keep tasks alive
+            await asyncio.gather(client_to_gemini(), gemini_to_client(), return_exceptions=True)
                 
     except Exception as e:
         print(f"Connection failed: {e}")