Add re-analyse button and POST /documents/{id}/reprocess endpoint

Resets status to pending, clears error_message, and re-enqueues the
background AI extraction task. Button is disabled while the document
is already pending or processing; returns 409 in that case from the API.

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>

features/doc-service/STATUS.md

@@ -33,6 +33,7 @@ Database: shared PostgreSQL instance, isolated via `alembic_version_doc_service`
 | `PATCH` | `/documents/{id}/title` | Update editable title |
 | `GET` | `/documents/categories` | List all categories for the user |
 | `POST` | `/documents/categories` | Create a category; triggers re-analysis of documents in similar categories |
+| `POST` | `/documents/{id}/reprocess` | Reset status to pending and re-run AI extraction; 409 if already pending/processing |
 | `PATCH` | `/documents/categories/{id}` | Rename a category |
 | `DELETE` | `/documents/categories/{id}` | Delete a category |
 | `POST` | `/documents/{id}/categories/{cat_id}` | Assign category to document |
@@ -138,7 +139,7 @@ backend (proxy)  →  doc-service:8001
 
 ## Future work
 
-- [ ] `POST /documents/{id}/reprocess` — re-run AI extraction
+- [x] `POST /documents/{id}/reprocess` — re-run AI extraction
 - [ ] Advanced filter: query `extracted_data` JSON fields (vendor, due_date, amount) — requires PostgreSQL `jsonb` column or indexed virtual columns
 - [ ] Bulk operations endpoint
 - [ ] Document sharing via groups (blocked on groups/permissions system in backend)

features/doc-service/app/routers/documents.py

@@ -305,6 +305,24 @@ async def update_document_title(
     return _doc_with_categories(doc)
 
 
+@router.post("/{doc_id}/reprocess", response_model=DocumentOut)
+async def reprocess_document(
+    doc_id: str,
+    background_tasks: BackgroundTasks,
+    user_id: str = Depends(get_user_id),
+    db: AsyncSession = Depends(get_db),
+) -> DocumentOut:
+    doc = await _get_user_doc(doc_id, user_id, db)
+    if doc.status in ("pending", "processing"):
+        raise HTTPException(status_code=409, detail="Document is already being processed")
+    doc.status = "pending"
+    doc.error_message = None
+    await db.commit()
+    background_tasks.add_task(process_document, doc_id)
+    doc = await _get_user_doc(doc_id, user_id, db)
+    return _doc_with_categories(doc)
+
+
 @router.delete("/{doc_id}", status_code=204)
 async def delete_document(
     doc_id: str,