Antho
934e669774
main.py comptait 829 lignes et regroupait 9 domaines fonctionnels. Il ne fait plus que l'assemblage de l'application (configuration, middlewares, montage des routeurs), soit 115 lignes. - routers/ : un module par domaine, chacun déclarant sa propre dépendance d'authentification - domain.py : enums UserRole et AuditAction, mapping MONITO_TABLES ; les rôles étaient jusqu'ici répétés en dur à deux endroits - helpers.py : conversion des lignes pyodbc, écriture du journal - rate_limit.py : limiteur partagé, isolé pour éviter un import circulaire entre main.py et le routeur d'authentification Les codes HTTP littéraux (404, 401, 400, 201) passent aux constantes fastapi.status, comme le faisait déjà auth.py. Les actions du journal d'audit passent en paramètre SQL au lieu d'être concaténées. Aucune route modifiée : la comparaison des specs OpenAPI avant/après confirme que les 26 URL existantes sont identiques. conftest patchait main.get_cursor ; chaque routeur important désormais get_cursor dans son propre espace de noms, la fixture remplace le nom dans tous les modules concernés.
44 lines
1.7 KiB
Python
44 lines
1.7 KiB
Python
# ============================================================
|
|
# routers/rgpd.py — Droits de la personne concernée (RGPD)
|
|
# ============================================================
|
|
|
|
from fastapi import APIRouter, Depends
|
|
|
|
from auth import get_current_user
|
|
from config import get_cursor
|
|
from helpers import row_to_dict, rows_to_list
|
|
|
|
router = APIRouter(tags=["RGPD"])
|
|
|
|
|
|
@router.get("/me/data-export")
|
|
def export_my_data(user: dict = Depends(get_current_user)):
|
|
"""Droit à la portabilité (art. 20) : export des données de l'utilisateur."""
|
|
with get_cursor() as cursor:
|
|
cursor.execute(
|
|
"SELECT id_user, username, email, role, actif, created_at, last_login "
|
|
"FROM [USER] WHERE username = ?", user["username"]
|
|
)
|
|
u = cursor.fetchone()
|
|
profile = row_to_dict(cursor, u) if u else {}
|
|
cursor.execute(
|
|
"SELECT date_action, action, detail, ip FROM JOURNAL_AUDIT "
|
|
"WHERE username = ? ORDER BY date_action DESC", user["username"]
|
|
)
|
|
journal = rows_to_list(cursor, cursor.fetchall())
|
|
return {"profile": profile, "journal": journal}
|
|
|
|
|
|
@router.delete("/me")
|
|
def delete_my_account(user: dict = Depends(get_current_user)):
|
|
"""Droit à l'oubli (art. 17) : désactivation + anonymisation."""
|
|
with get_cursor() as cursor:
|
|
cursor.execute(
|
|
"UPDATE [USER] SET actif = 0, "
|
|
"username = CONCAT('deleted_', id_user), "
|
|
"email = CONCAT('deleted_', id_user, '@deleted.local') "
|
|
"WHERE username = ?", user["username"]
|
|
)
|
|
cursor.execute("UPDATE JOURNAL_AUDIT SET username = NULL WHERE username = ?", user["username"])
|
|
return {"status": "account_deleted"}
|