Update app.py

app.py

@@ -845,11 +845,54 @@ async def get_analytics():
         "average_sentiment": avg_sentiment
     }
 
-@app.post("/voice")
+# Load the Hugging Face API token from environment variables
+HUGGING_FACE_API_TOKEN = os.getenv("HUGGING_FACE_API_TOKEN")
+if not HUGGING_FACE_API_TOKEN:
+    raise ValueError("Hugging Face API token not found in environment variables.")
+
+# Hugging Face Whisper API configuration
+WHISPER_API_URL = "https://router.huggingface.co/fal-ai"
+WHISPER_API_HEADERS = {"Authorization": f"Bearer {HUGGING_FACE_API_TOKEN}"}
+
+class TranscriptionResponse(BaseModel):
+    transcription: str
+
+@app.post("/voice", response_model=TranscriptionResponse)
 async def process_voice(file: UploadFile = File(...)):
-    contents = await file.read()
-    simulated_text = "Simulated speech-to-text conversion result."
-    return {"transcription": simulated_text}
+    """
+    Endpoint to process voice notes and transcribe them using OpenAI Whisper via Hugging Face.
+    """
+    try:
+        # Read the uploaded file
+        contents = await file.read()
+
+        # Save the file temporarily (optional, depending on how the API expects the input)
+        temp_file_path = f"temp_{file.filename}"
+        with open(temp_file_path, "wb") as temp_file:
+            temp_file.write(contents)
+
+        # Call the Hugging Face Whisper API
+        with open(temp_file_path, "rb") as audio_file:
+            response = requests.post(
+                WHISPER_API_URL,
+                headers=WHISPER_API_HEADERS,
+                files={"file": audio_file}
+            )
+
+        # Clean up the temporary file
+        os.remove(temp_file_path)
+
+        # Check if the API call was successful
+        if response.status_code != 200:
+            raise HTTPException(status_code=response.status_code, detail="Failed to transcribe audio.")
+
+        # Extract the transcription from the API response
+        transcription = response.json().get("text", "")
+
+        return {"transcription": transcription}
+
+    except Exception as e:
+        raise HTTPException(status_code=500, detail=f"An error occurred: {str(e)}")
 
 # --- Payment Callback Endpoint with Payment Tracking and Redirection ---
 @app.api_route("/payment_callback", methods=["GET", "POST"])