fix: use window.location.origin for transcribe endpoint

app.py

@@ -2,8 +2,9 @@ import os
 import tempfile
 import time
 import pathlib
+import json
 from fastapi import FastAPI, File, UploadFile
-from fastapi.responses import HTMLResponse, JSONResponse
+from fastapi.responses import HTMLResponse, JSONResponse, StreamingResponse
 from fastapi.staticfiles import StaticFiles
 from fastapi.middleware.cors import CORSMiddleware
 from faster_whisper import WhisperModel
@@ -41,28 +42,30 @@ async def root():
         return f.read()
 
 @app.post("/transcribe")
-async def transcribe_audio(file: UploadFile = File(...)):
-    try:
-        suffix = Path(file.filename).suffix
-        with tempfile.NamedTemporaryFile(delete=False, suffix=suffix) as tmp:
-            shutil.copyfileobj(file.file, tmp) 
-            tmp_path = tmp.name
+async def transcribe_audio_stream(file: UploadFile = File(...)):
+    async def generate():
+        try:
+            suffix = Path(file.filename).suffix
+            with tempfile.NamedTemporaryFile(delete=False, suffix=suffix) as tmp:
+                shutil.copyfileobj(file.file, tmp) 
+                tmp_path = tmp.name
+            
+            yield json.dumps({"status": "processing", "message": "Загрузка модели..."}) + "\n"
+            
+            loop = asyncio.get_event_loop()
+            result = await loop.run_in_executor(
+                executor,
+                partial(model.transcribe, tmp_path, language="ru")
+            )
+            
+            text = result["text"].strip()
+            Path(tmp_path).unlink()
+            
+            yield json.dumps({"status": "ok", "text": text}) + "\n"
         
-        loop = asyncio.get_event_loop()
-        result = await loop.run_in_executor(
-            executor,
-            partial(model.transcribe, tmp_path, language="ru")
-        )
-        
-        text = result["text"].strip()
-        Path(tmp_path).unlink()
-        
-        return JSONResponse({"text": text, "status": "ok"})
+        except Exception as e:
+            yield json.dumps({"status": "error", "text": f"Ошибка: {str(e)}"}) + "\n"
+        finally:
+            file.file.close()
     
-    except Exception as e:
-        return JSONResponse(
-            {"text": f"Error {str(e)}", "status": "error"},
-            status_code=500
-        )
-    finally:
-        file.file.close()
+    return StreamingResponse(generate(), media_type="application/x-ndjson")

static/script.js

@@ -72,21 +72,42 @@ async function handleFile(file) {
     formData.append('file', file);
     
     try {
-        const baseUrl = window.location.origin;
-	const response = await fetch('transcribe', { 
+        const response = await fetch('/transcribe', {
             method: 'POST',
             body: formData
         });
         
-        const data = await response.json();
+        const reader = response.body.getReader();
+        const decoder = new TextDecoder();
+        let buffer = '';
         
-        if (data.status === 'ok') {
-            transcriptText.value = data.text;
-        } else {
-            transcriptText.value = data.text;
+        while (true) {
+            const { value, done } = await reader.read();
+            if (done) break;
+            
+            buffer += decoder.decode(value, { stream: true });
+            const lines = buffer.split('\n');
+            buffer = lines.pop();
+            
+            for (const line of lines) {
+                if (line.trim()) {
+                    try {
+                        const data = JSON.parse(line);
+                        if (data.status === 'ok') {
+                            transcriptText.value = data.text;
+                        } else if (data.status === 'error') {
+                            transcriptText.value = data.text;
+                        } else if (data.status === 'processing') {
+                            transcriptText.value = data.message;
+                        }
+                    } catch (e) {
+                        console.error('Error parsing JSON:', e);
+                    }
+                }
+            }
         }
     } catch (error) {
-        transcriptText.value = 'Connection Error';
+        transcriptText.value = 'Ошибка соединения';
         console.error(error);
     }
 }