Update app/feedback.py

app/feedback.py

@@ -1,171 +1,140 @@
-import csv
-import os
-from datetime import datetime, timezone
-
-from .google_oauth import GoogleAuthRequiredError, append_feedback_to_sheet, load_credentials
-from .memory import salvar_memoria_negativa
-
-
-BASE_DIR = os.path.dirname(os.path.dirname(os.path.abspath(__file__)))
-LOGS_DIR = os.getenv("LOGS_DIR", "/data/logs")
-FEEDBACK_FILE = os.path.join(LOGS_DIR, "feedback.csv")
-FEEDBACK_HEADERS = [
-    "timestamp",
-    "query",
-    "product_id",
-    "product_name",
-    "rating",
-    "is_helpful",
-    "note",
-    "categoria_inferida",
-    "feedback",
-    "motivo",
-    "score_final",
-    "score_semantico",
-    "bonus_lexical",
-    "penalidade_feedback",
-    "user_message",
-]
-
-
-def garantir_pasta_logs():
-    os.makedirs(LOGS_DIR, exist_ok=True)
-
-
-def inicializar_arquivo_feedback():
-    garantir_pasta_logs()
-
-    if not os.path.exists(FEEDBACK_FILE):
-        with open(FEEDBACK_FILE, mode="w", newline="", encoding="utf-8") as f:
-            writer = csv.writer(f)
-            writer.writerow(FEEDBACK_HEADERS)
-
-
-def google_sheets_habilitado():
-    try:
-        return load_credentials() is not None and bool(os.getenv("GOOGLE_SPREADSHEET_ID", "").strip())
-    except Exception:
-        return False
-
-
-def _append_feedback_csv(row):
-    inicializar_arquivo_feedback()
-
-    with open(FEEDBACK_FILE, mode="a", newline="", encoding="utf-8") as f:
-        writer = csv.writer(f)
-        writer.writerow([row.get(header, "") for header in FEEDBACK_HEADERS])
-
-
-def _build_feedback_payload(
-    query,
-    product_id,
-    product_name,
-    rating=None,
-    is_helpful=None,
-    note=None,
-    categoria_inferida=None,
-    feedback=None,
-    motivo=None,
-    score_final=None,
-    score_semantico=None,
-    bonus_lexical=None,
-    penalidade_feedback=None,
-    user_message=None,
-):
-    return {
-        "timestamp": datetime.now(timezone.utc).isoformat(),
-        "query": query,
-        "product_id": product_id,
-        "product_name": product_name,
-        "rating": rating if rating is not None else "",
-        "is_helpful": is_helpful if is_helpful is not None else "",
-        "note": note or "",
-        "categoria_inferida": categoria_inferida or "",
-        "feedback": feedback or "",
-        "motivo": motivo or "",
-        "score_final": score_final if score_final is not None else "",
-        "score_semantico": score_semantico if score_semantico is not None else "",
-        "bonus_lexical": bonus_lexical if bonus_lexical is not None else "",
-        "penalidade_feedback": penalidade_feedback if penalidade_feedback is not None else "",
-        "user_message": user_message or "",
-    }
-
-
-def salvar_feedback(
-    query,
-    product_id,
-    product_name,
-    rating=None,
-    is_helpful=None,
-    note=None,
-    categoria_inferida=None,
-    feedback=None,
-    motivo=None,
-    score_final=None,
-    score_semantico=None,
-    bonus_lexical=None,
-    penalidade_feedback=None,
-    user_message=None,
-):
-    row = _build_feedback_payload(
-        query=query,
-        product_id=product_id,
-        product_name=product_name,
-        rating=rating,
-        is_helpful=is_helpful,
-        note=note,
-        categoria_inferida=categoria_inferida,
-        feedback=feedback,
-        motivo=motivo,
-        score_final=score_final,
-        score_semantico=score_semantico,
-        bonus_lexical=bonus_lexical,
-        penalidade_feedback=penalidade_feedback,
-        user_message=user_message,
-    )
-
-    _append_feedback_csv(row)
-    saved_google_sheets = False
-    warning = None
-
-    try:
-        append_feedback_to_sheet(row)
-        saved_google_sheets = True
-    except GoogleAuthRequiredError:
-        warning = "Feedback salvo localmente, mas nao enviado ao Google Sheets. Acesse /auth/google para autorizar."
-    except Exception as exc:
-        warning = (
-            "Feedback salvo localmente, mas nao enviado ao Google Sheets. "
-            f"Erro de sincronizacao: {exc}"
-        )
-
-    if rating is not None and rating <= 2:
-        salvar_memoria_negativa(
-            query=query,
-            product_id=product_id,
-            product_name=product_name,
-            rating=rating,
-            motivo="rating_baixo",
-        )
-
-    if is_helpful is False:
-        salvar_memoria_negativa(
-            query=query,
-            product_id=product_id,
-            product_name=product_name,
-            rating=rating if rating is not None else "",
-            motivo="nao_foi_util",
-        )
-
-    response = {
-        "ok": True,
-        "saved_local": True,
-        "saved_google_sheets": saved_google_sheets,
-    }
-    if warning:
-        response["warning"] = warning
-    return response
-
-
-def caminho_feedback():
-    return FEEDBACK_FILE
+import csv
+import os
+import tempfile
+from datetime import datetime, timezone
+from pathlib import Path
+
+from .google_oauth import GoogleAuthRequiredError, append_feedback_to_sheet, load_credentials
+from .memory import salvar_memoria_negativa
+
+
+BASE_DIR = os.path.dirname(os.path.dirname(os.path.abspath(__file__)))
+DEFAULT_LOGS_DIR = Path(os.getenv("LOGS_DIR", "/data/logs"))
+FALLBACK_LOGS_DIR = Path(tempfile.gettempdir()) / "tcc2_agent" / "logs"
+FEEDBACK_HEADERS = [
+    "timestamp",
+    "query",
+    "product_id",
+    "product_name",
+    "rating",
+    "is_helpful",
+    "note",
+    "categoria_inferida",
+    "feedback",
+    "motivo",
+    "score_final",
+    "score_semantico",
+    "bonus_lexical",
+    "penalidade_feedback",
+    "user_message",
+]
+
+
+def _resolve_logs_dir():
+    preferred_dir = os.environ.get("LOGS_DIR", "").strip()
+    candidates = [Path(preferred_dir)] if preferred_dir else []
+    candidates.extend([DEFAULT_LOGS_DIR, FALLBACK_LOGS_DIR])
+
+    for directory in candidates:
+        try:
+            directory.mkdir(parents=True, exist_ok=True)
+            return directory
+        except OSError:
+            continue
+
+    raise OSError(
+        "Nao foi possivel criar um diretorio para armazenar os logs de feedback. "
+        "Defina LOGS_DIR para um caminho gravavel."
+    )
+
+
+def caminho_feedback():
+    return str(_resolve_logs_dir() / "feedback.csv")
+
+
+def inicializar_arquivo_feedback():
+    feedback_file = caminho_feedback()
+
+    if not os.path.exists(feedback_file):
+        with open(feedback_file, mode="w", newline="", encoding="utf-8") as f:
+            writer = csv.writer(f)
+            writer.writerow(FEEDBACK_HEADERS)
+
+
+def google_sheets_habilitado():
+    try:
+        return load_credentials() is not None and bool(os.getenv("GOOGLE_SPREADSHEET_ID", "").strip())
+    except Exception:
+        return False
+
+
+def _append_feedback_csv(row):
+    inicializar_arquivo_feedback()
+    feedback_file = caminho_feedback()
+
+    with open(feedback_file, mode="a", newline="", encoding="utf-8") as f:
+        writer = csv.writer(f)
+        writer.writerow([row.get(header, "") for header in FEEDBACK_HEADERS])
+
+
+def _build_feedback_payload(
+    query,
+    product_id,
+    product_name,
+    rating=None,
+    is_helpful=None,
+    note=None,
+    categoria_inferida=None,
+    feedback=None,
+    motivo=None,
+    score_final=None,
+    score_semantico=None,
+    bonus_lexical=None,
+    penalidade_feedback=None,
+    user_message=None,
+):
+    return {
+        "timestamp": datetime.now(timezone.utc).isoformat(),
+        "query": query,
+        "product_id": product_id,
+        "product_name": product_name,
+        "rating": rating if rating is not None else "",
+        "is_helpful": is_helpful if is_helpful is not None else "",
+        "note": note or "",
+        "categoria_inferida": categoria_inferida or "",
+        "feedback": feedback or "",
+        "motivo": motivo or "",
+        "score_final": score_final if score_final is not None else "",
+        "score_semantico": score_semantico if score_semantico is not None else "",
+        "bonus_lexical": bonus_lexical if bonus_lexical is not None else "",
+        "penalidade_feedback": penalidade_feedback if penalidade_feedback is not None else "",
+        "user_message": user_message or "",
+    }
+
+
+def salvar_feedback(
+    query,
+    product_id,
+    product_name,
+    rating=None,
+    is_helpful=None,
+    note=None,
+    categoria_inferida=None,
+    feedback=None,
+    motivo=None,
+    score_final=None,
+    score_semantico=None,
+    bonus_lexical=None,
+    penalidade_feedback=None,
+    user_message=None,
+):
+    row = _build_feedback_payload(
+        query=query,
+        product_id=product_id,
+        product_name=product_name,
+        rating=rating,
+        is_helpful=is_helpful,
+        note=note,
+        categoria_inferida=categoria_inferida,
+        feedback=feedback,
+