Update routes/logs.py

routes/logs.py

@@ -109,37 +109,79 @@ async def get_logs(
                 "has_next": False
             }
 
-        # Pegar dados dos usuários responsáveis pelos logs
+        # Buscar dados dos usuários
         user_ids = list({log["user"] for log in logs if log.get("user")})
         user_info_map = {}
 
         if user_ids:
             user_ids_query = ",".join(f'"{uid}"' for uid in user_ids)
-            users_url = f"{SUPABASE_URL}/rest/v1/User?id=in.({user_ids_query})&select=id,name,avatar"
+            users_url = f"{SUPABASE_URL}/rest/v1/User?id=in.({user_ids_query})&select=id,email,avatar,name"
 
             async with aiohttp.ClientSession() as session:
                 async with session.get(users_url, headers=SUPABASE_HEADERS) as response:
                     if response.status == 200:
                         users_data = await response.json()
-                        user_info_map = {user["id"]: {"name": user["name"], "avatar": user["avatar"]} for user in users_data}
+                        user_info_map = {user["id"]: user for user in users_data}
                     else:
                         logger.warning("⚠️ Erro ao buscar dados dos usuários")
 
+        # Função para gerar mensagem descritiva
+        def generate_message(log, user_info):
+            action = log.get("action")
+            reference = log.get("reference")
+            old_data = log.get("old_data")
+            new_data = log.get("new_data")
+
+            email = user_info.get("email", "Alguém")
+            name2 = None
+
+            try:
+                if reference == "User" and new_data:
+                    name2 = eval(new_data).get("name")
+                elif reference == "Approval" and old_data:
+                    name2 = eval(old_data).get("name")
+                elif reference in ("Collaboration", "Onboarding") and new_data:
+                    name2 = eval(new_data).get("name")
+            except Exception:
+                name2 = None
+
+            if action == "update" and reference == "User":
+                return f"{email} atualizou informações de {name2 or 'um usuário'}"
+            elif action == "approve" and reference == "Approval":
+                return f"{email} aprovou o estilista {name2 or ''}"
+            elif action == "deny" and reference == "Approval":
+                return f"{email} negou o estilista {name2 or ''}"
+            elif action == "update" and reference == "Onboarding":
+                return f"{email} atualizou uma pergunta do onboarding"
+            elif action == "add" and reference == "Onboarding":
+                return f"{email} adicionou uma pergunta ao onboarding"
+            elif action == "delete" and reference == "Onboarding":
+                return f"{email} excluiu uma pergunta do onboarding"
+            elif action == "add" and reference == "Collaboration":
+                return f"{email} adicionou um novo colaborador"
+            elif action == "delete" and reference == "Collaboration":
+                return f"{email} excluiu um colaborador da lista de colaboradores"
+            elif action == "update" and reference == "Collaboration":
+                return f"{email} atualizou as permissões de um colaborador"
+
+            return f"{email} realizou uma ação: {action} em {reference}"
+
         enriched_logs = []
         for log in logs:
-            user_data = user_info_map.get(log["user"], {"name": None, "avatar": None})
+            user_raw = user_info_map.get(log["user"], {})
             enriched_logs.append({
                 "id": log["id"],
                 "user": {
-                    "id": log["user"],
-                    "name": user_data["name"],
-                    "avatar": user_data["avatar"]
+                    "id": user_raw.get("id"),
+                    "email": user_raw.get("email"),
+                    "avatar": user_raw.get("avatar")
                 },
                 "action": log["action"],
                 "reference": log["reference"],
                 "old_data": log["old_data"],
                 "new_data": log["new_data"],
-                "created_at": log["created_at"]
+                "created_at": log["created_at"],
+                "message": generate_message(log, user_raw)
             })
 
         has_next = len(logs) == limit
@@ -154,4 +196,4 @@ async def get_logs(
         raise he
     except Exception as e:
         logger.error(f"❌ Erro interno ao buscar logs: {str(e)}")
-        raise HTTPException(status_code=500, detail="Erro interno do servidor")
+        raise HTTPException(status_code=500, detail="Erro interno do servidor")