| import json
|
| import time
|
| import re |
|
|
| from fastapi import APIRouter
|
| from pydantic import BaseModel, ConfigDict, Field, field_validator |
|
|
| from src.config import get_settings
|
|
|
| router = APIRouter()
|
|
|
|
|
| class FeedbackRequest(BaseModel): |
| model_config = ConfigDict(extra="forbid") |
| request_id: str = Field(pattern=r"^[A-Za-z0-9_-]{8,80}$") |
| feedback: str |
| comment: str = Field(default="", max_length=500) |
| |
| |
| session_id: str | None = Field(default=None, pattern=r"^[A-Za-z0-9_-]{8,80}$") |
|
|
| @field_validator("feedback")
|
| @classmethod
|
| def valid_feedback(cls, v: str) -> str:
|
| if v not in {"up", "down"}:
|
| raise ValueError("feedback must be up or down")
|
| return v
|
|
|
|
|
| @router.post("")
|
| async def save_feedback(req: FeedbackRequest): |
| settings = get_settings() |
| comment = re.sub(r"[\w.+-]+@[\w-]+\.[\w.-]+", "[email]", req.comment) |
| comment = re.sub(r"\b\d{6,}\b", "[number]", comment) |
| payload = {
|
| "timestamp": time.time(),
|
| "request_id": req.request_id, |
| "feedback": req.feedback, |
| "comment": comment[:500], |
| }
|
| settings.feedback_path.parent.mkdir(parents=True, exist_ok=True)
|
| with settings.feedback_path.open("a", encoding="utf-8") as handle:
|
| handle.write(json.dumps(payload, ensure_ascii=False) + "\n")
|
| try:
|
| from app import metrics_service
|
| metrics_service.incr("feedback_total")
|
| metrics_service.incr_bucket("feedback_breakdown", req.feedback)
|
| except Exception:
|
| pass
|
| return {"status": "ok"}
|
|
|
