From a303a4e455e1ecd180c3dff2de7809ae600e477c Mon Sep 17 00:00:00 2001
From: Agent Zero <agent@media-on.de>
Date: Fri, 31 Jul 2026 12:01:11 +0200
Subject: [PATCH] gate4: use separate API session for audit log in
 confirm_password_reset

---
 app/services/auth_service.py | 29 +++++++++++++++++------------
 1 file changed, 17 insertions(+), 12 deletions(-)

diff --git a/app/services/auth_service.py b/app/services/auth_service.py
index 02e857e..bb93383 100644
--- a/app/services/auth_service.py
+++ b/app/services/auth_service.py
@@ -335,19 +335,24 @@ class AuthService:
         except Exception:
             logger.warning("Failed to invalidate Redis sessions for user %s", user.id, exc_info=True)
 
-        # Audit log entry for password reset
+        # Audit log entry for password reset — use separate API session (crm_api)
+        # to avoid requiring audit_log INSERT grants on crm_auth
         try:
-            from app.core.db import set_tenant_context
-            await set_tenant_context(db, reset_token.tenant_id)
-            await log_audit(
-                db,
-                reset_token.tenant_id,
-                user.id,
-                "password_reset",
-                "user",
-                user.id,
-                changes={"action": "password_changed"},
-            )
+            from app.core.db import get_api_engine, set_tenant_context
+            from sqlalchemy.ext.asyncio import AsyncSession
+            api_engine = get_api_engine()
+            async with AsyncSession(api_engine) as audit_db:
+                await set_tenant_context(audit_db, reset_token.tenant_id)
+                await log_audit(
+                    audit_db,
+                    reset_token.tenant_id,
+                    user.id,
+                    "password_reset",
+                    "user",
+                    user.id,
+                    changes={"action": "password_changed"},
+                )
+                await audit_db.commit()
         except Exception:
             logger.warning("Failed to create audit log for password reset of user %s", user.id, exc_info=True)