adding new code

Author: sadrafh

docs/whisper_transcription/whisper_api_server.py

@@ -6,8 +6,9 @@
 from queue import Queue
 from threading import Lock
 from fastapi import FastAPI, UploadFile, File, Form
-from fastapi.responses import StreamingResponse, JSONResponse
-from faster_code_week1_v28 import transcribe_and_summarize, load_whisper_model_faster
+from fastapi.responses import StreamingResponse, JSONResponse, FileResponse
+from whisper_code import transcribe_and_summarize, load_whisper_model_faster
+import logging
 
 app = FastAPI()
 
@@ -28,6 +29,21 @@ async def transcribe_audio_api(
     max_speakers: int = Form(None),
     streaming: bool = Form(False)
 ):
+    
+    # ✅ Setup dynamic logging per request
+    from datetime import datetime
+    basename = os.path.splitext(os.path.basename(audio_file.filename))[0]
+    timestamp = datetime.now().strftime('%Y%m%d_%H%M%S')
+    log_file = f"transcription_log_{basename}_{timestamp}.log"
+
+    logging.basicConfig(
+        level=logging.INFO,
+        format="%(asctime)s - %(levelname)s - %(message)s",
+        filename=log_file,
+        filemode="w",
+        force=True  # ensures logging resets each request
+    )
+
     temp_audio_path = tempfile.mktemp(suffix=f"_{audio_file.filename}")
     with open(temp_audio_path, "wb") as f:
         f.write(await audio_file.read())
@@ -45,6 +61,14 @@ def generator():
             q = Queue()
 
             def api_callback(result):
+                # Log like CLI mode
+                if result.get("chunk_id", "").startswith("chunk_"):
+                    logging.info(f"\n====== Streaming {result['chunk_id']} ======\n{result.get('text', '').strip()}\n")
+                elif result.get("chunk_id") == "summary":
+                    logging.info("\n====== Final Summary ======\n")
+                    logging.info(result.get("summary", "").strip())
+                    result["logfile"] = log_file
+
                 q.put(json.dumps(result) + "\n")
 
             def run_pipeline():
@@ -126,4 +150,11 @@ def run_pipeline():
             return JSONResponse(
                 content={"error": f"Failed to read output JSON: {str(e)}"},
                 status_code=500
-            )
+            )
+
+@app.get("/log/{filename}")
+def get_log_file(filename: str):
+    log_path = os.path.join(".", filename)
+    if not os.path.exists(log_path):
+        return JSONResponse(content={"error": "Log file not found."}, status_code=404)
+    return FileResponse(log_path, media_type="text/plain")