Update app/api/transcribe.py

app/api/transcribe.py

@@ -12,8 +12,7 @@ from app.core.asr_engine import load_model, transcribe_file, transcribe_file_chu
 from app.config import settings
 from app.services.text_normalizer import normalize_text
 from app.services.nlp_postprocess import normalize_and_extract
-from app.services.summary_service import generate_summary
-from app.services.mindmap_service import generate_mindmap
+# Summary and mindmap generation moved to Note Service; do not import here
 from app.services.note_client import NoteServiceClient
 from rq import Queue
 from app.infra.redis_client import redis_client
@@ -111,24 +110,26 @@ async def transcribe(file: UploadFile = File(...)):
                 normalized_text = nlp["normalized_text"]
                 keywords = nlp["keywords"]
 
-                summary = await generate_summary(normalized_text)
-                mindmap = await generate_mindmap(normalized_text)
+                # Summary / mindmap are generated by the Note Service; omit local generation
+                summary = None
+                mindmap = None
 
             info2 = get_audio_info(tmp_wav) or {}
             # persist to Note Service (async HTTP)
-            await note_service.save_transcript(
-                note_id=note_id,
-                raw_text=text,
-                normalized_text=normalized_text,
-                keywords=keywords,
-                summary=summary,
-                mindmap=mindmap,
-                duration=info2.get("duration"),
-                sample_rate=info2.get("samplerate"),
-                chunks=chunks,
-                asr_model="PhoWhisper-base",
-                normalization_model="gemini-1.5",
-            )
+            payload = {
+                "note_id": note_id,
+                "raw_text": text,
+                "normalized_text": normalized_text,
+                "keywords": keywords,
+                "summary": summary,
+                "mindmap": mindmap,
+                "duration": info2.get("duration"),
+                "sample_rate": info2.get("samplerate"),
+                "chunks": chunks,
+                "asr_model": "PhoWhisper-base",
+                "normalization_model": "gemini-1.5",
+            }
+            await note_service.save_transcript(payload)
 
             duration = time.perf_counter() - start_time
             logging.info(f"/transcribe success note_id={note_id} duration={duration:.2f}s audio_dur={info2.get('duration')}")
@@ -240,23 +241,25 @@ async def transcribe_url(payload: dict):
                 normalized_text = nlp["normalized_text"]
                 keywords = nlp["keywords"]
 
-                summary = await generate_summary(normalized_text)
-                mindmap = await generate_mindmap(normalized_text)
+                # Summary / mindmap are generated by the Note Service; omit local generation
+                summary = None
+                mindmap = None
 
             # 5. Persist to Note Service
-            await note_service.save_transcript(
-                note_id=note_id,
-                raw_text=text,
-                normalized_text=normalized_text,
-                keywords=keywords,
-                summary=summary,
-                mindmap=mindmap,
-                duration=info.get("duration"),
-                sample_rate=info.get("samplerate"),
-                chunks=chunks,
-                asr_model="PhoWhisper-base",
-                normalization_model="gemini-1.5",
-            )
+            payload = {
+                "note_id": note_id,
+                "raw_text": text,
+                "normalized_text": normalized_text,
+                "keywords": keywords,
+                "summary": summary,
+                "mindmap": mindmap,
+                "duration": info.get("duration"),
+                "sample_rate": info.get("samplerate"),
+                "chunks": chunks,
+                "asr_model": "PhoWhisper-base",
+                "normalization_model": "gemini-1.5",
+            }
+            await note_service.save_transcript(payload)
 
             duration = time.perf_counter() - start_time
             logging.info(