Update app.py

app.py

@@ -158,13 +158,15 @@ class GeminiInteractionLoop:
         self.is_running = True
         self.playback_stream = None
 
-    async def send_text_input_to_gemini(self):
+    async def send_text_input_to_gemini(self, user_text):
         if not user_text or not self.gemini_session or not self.is_running:
             logging.warning(
                 "Cannot send text. Session not active, no text, or not running.")
             return
         try:
-            await self.gemini_session.send_client_content
+            logging.info(f"Sending text to Gemini: '{user_text[:50]}...'")
+            # Send text directly using the send method
+            await self.gemini_session.send(input={"text": user_text})
         except Exception as e:
             logging.error(
                 f"Error sending text message to Gemini: {e}", exc_info=True)
@@ -431,7 +433,8 @@ class GeminiInteractionLoop:
                     f"Gemini session established with API for model {MODEL_NAME}.")
                 try:
                     logging.info("Sending system prompt to Gemini...")
-                    await self.gemini_session.send_client_content(types.Part(text=MEDICAL_ASSISTANT_SYSTEM_PROMPT))
+                    # Send system prompt using the correct format
+                    await self.gemini_session.send(input={"text": MEDICAL_ASSISTANT_SYSTEM_PROMPT})
                     logging.info("System prompt sent successfully.")
                 except Exception as e:
                     logging.error(
@@ -468,8 +471,7 @@ class GeminiInteractionLoop:
                             task.cancel()
                     # Await their cancellation (or completion if they finished cleanly before cancel)
                     if tasks: # Ensure tasks list is not empty
-                        await asyncio.gather(*tasks, return_exceptions
-=True) # Suppress errors from already handled/cancelled tasks
+                        await asyncio.gather(*tasks, return_exceptions=True) # Suppress errors from already handled/cancelled tasks
                 logging.info("Gemini interaction tasks processing completed or handled.")
 
         except websockets.exceptions.ConnectionClosedError as e:
@@ -707,4 +709,4 @@ if __name__ == "__main__":
     if client is None:
         logging.critical("Gemini client could not be initialized. Application cannot start.")
     else:
-        run_streamlit_app()
+        run_streamlit_app()