Update app.py

app.py

@@ -268,9 +268,19 @@ async def transcribe(websocket: WebSocket):
 
     try:
         await websocket.send_json({"status": "receiving", "detail": "در انتظار دریافت فایل..."})
-        print("Step 1: waiting for bytes")
-        audio_bytes = await websocket.receive_bytes()
-        print(f"Step 2: received {len(audio_bytes)} bytes")
+        print("Step 1: waiting for chunks")
+        chunks = []
+        total_bytes = 0
+        while True:
+            message = await websocket.receive()
+            if "bytes" in message and message["bytes"] is not None:
+                chunk = message["bytes"]
+                chunks.append(chunk)
+                total_bytes += len(chunk)
+            elif "text" in message and message["text"] == "__END__":
+                break
+        audio_bytes = b"".join(chunks)
+        print(f"Step 2: received {total_bytes} bytes in {len(chunks)} chunks")
         size_mb = len(audio_bytes) / (1024 * 1024)
         await websocket.send_json({"status": "receiving", "detail": f"{size_mb:.1f} مگابایت دریافت شد"})