update-tansc

src/server/main.py

@@ -816,17 +816,26 @@ async def speech_to_speech(
     try:
         encrypted_content = await file.read()
         file_content = decrypt_data(encrypted_content, session_key)
-        files = {"file": (file.filename, file_content, file.content_type)}
-        external_url = f"{settings.external_api_base_url}/v1/speech_to_speech?language={decrypted_language}"
 
-        response = requests.post(
-            external_url,
-            files=files,
-            headers={"accept": "application/json"},
-            stream=True,
-            timeout=60
-        )
-        response.raise_for_status()
+
+
+        with tempfile.NamedTemporaryFile(delete=False, suffix=file.filename) as temp_file:
+        # Write the decrypted content to the temp file
+            #decrypted_content = await file.read()  # Assuming decrypted_content is the file content
+            temp_file.write(file_content)
+            temp_file_path = temp_file.name
+
+
+        response = dwani.ASR.transcribe(file_path=temp_file_path, language=decrypted_language)
+
+        transcription = response.get("text","")
+
+        chat_response = dwani.Chat.create(prompt=transcription, src_lang=decrypted_language, tgt_lang=decrypted_language)
+        
+
+        response_text = chat_response.get("response", "")
+
+        response = dwani.Audio.speech(input=response_text, response_format="mp3")
 
         headers = {
             "Content-Disposition": f"inline; filename=\"speech.mp3\"",
@@ -835,7 +844,7 @@ async def speech_to_speech(
         }
 
         return StreamingResponse(
-            response.iter_content(chunk_size=8192),
+        bytes_iterator(response),
             media_type="audio/mp3",
             headers=headers
         )