Add note text internal api

app/api/notes/notes_text_internal.py

@@ -0,0 +1,85 @@
+import logging
+from fastapi import APIRouter, BackgroundTasks, HTTPException
+from pydantic import BaseModel
+from typing import List, Optional, Dict
+from app.services.note_store import create_note, get_note
+from app.jobs.async_enrichment_job import enrich_note
+from app.models.enums import NoteType, NoteStatus
+from app.utils.time import now_ts
+
+
+router = APIRouter(prefix="/internal/notes", tags=["internal"])
+logger = logging.getLogger(__name__)
+
+
+class NoteTextInternalCreateRequest(BaseModel):
+    note_id: str
+    raw_text: str
+    folder_id: Optional[str] = None
+    generate: List[str] = []
+
+
+@router.post("/text")
+async def create_text_note_internal(req: NoteTextInternalCreateRequest, bg: BackgroundTasks):
+    """
+    Idempotent create for text notes:
+    - If note exists -> return current status
+    - Else create note with provided `note_id` and optionally enqueue enrichment
+    """
+    now = now_ts()
+
+    allowed = {"normalize", "keywords", "summary", "mindmap"}
+    if not set(req.generate).issubset(allowed):
+        raise HTTPException(400, "Invalid generate task")
+
+    # IDEMPOTENT CHECK
+    existing = get_note(req.note_id)
+    if existing:
+        logger.info("Note already exists, skip create note_id=%s", req.note_id)
+        return {
+            "note_id": req.note_id,
+            "status": existing.get("status"),
+        }
+
+    has_enrichment = bool(req.generate)
+    note = {
+        "note_id": req.note_id,
+        "type": NoteType.text,
+        "raw_text": req.raw_text,
+        "folder_id": req.folder_id,
+        "status": NoteStatus.processing if has_enrichment else NoteStatus.created,
+        "created_at": now,
+        "updated_at": now,
+    }
+
+    # Prepare fields for enrichment if requested
+    if req.generate:
+        note.update({
+            "normalized_text": None,
+            "title": None,
+            "keywords": [],
+            "summary": None,
+            "mindmap": None,
+            "generate": req.generate,
+        })
+
+    try:
+        create_note(note)
+    except ValueError:
+        # race: another worker created it first
+        logger.warning("Race create_note, ignore note_id=%s", req.note_id)
+        existing = get_note(req.note_id)
+        return {
+            "note_id": req.note_id,
+            "status": existing.get("status") if existing else NoteStatus.created,
+        }
+
+    # enqueue enrichment if requested
+    if req.generate:
+        try:
+            bg.add_task(enrich_note, req.note_id, req.generate)
+        except Exception:
+            # don't fail the request if enqueue fails; log and continue
+            logger.exception("Failed to enqueue enrich_note for %s", req.note_id)
+
+    return {"note_id": req.note_id, "status": note["status"]}

app/main.py

@@ -1,5 +1,5 @@
 from fastapi import FastAPI
-from app.api.notes import notes_text, notes_audio, notes_get, notes_update, notes_regenerate, notes_events, internal_notes
+from app.api.notes import notes_text, notes_audio, notes_text_internal, notes_get, notes_update, notes_regenerate, notes_events, internal_notes
 from app.api.folders import folders_create, folders_get, folders_update, folders_delete
 
 app = FastAPI(title="Note Service API")
@@ -7,6 +7,7 @@ app = FastAPI(title="Note Service API")
 # Notes
 app.include_router(notes_text.router)
 app.include_router(notes_audio.router)
+app.include_router(notes_text_internal.router)
 app.include_router(notes_get.router)
 app.include_router(notes_update.router)
 app.include_router(notes_regenerate.router)