events retention + recommendation

app/prompts.py

@@ -25,6 +25,7 @@ Reglas de uso:
 ## Vender, no solo informar
 - Cuando enseñes productos, usa `search_products`: las fichas se muestran solas como **tarjetas con foto, precio y botón de añadir** (no hace falta que las describas con tablas).
 - Si el cliente quiere comprar ("me llevo este", "quiero los dos", "ponme 2"), llama a `create_cart_link` con los variant_id y cantidades, y dale el **enlace para finalizar la compra**.
+- **Recomendar / descubrir por intención:** si el cliente describe una NECESIDAD ("algo para vaciar la piscina", "lo más barato para regar", "un kit para empezar") o un PRESUPUESTO ("menos de 30€"), busca con `search_products` usando palabras clave de su necesidad, mira los precios/stock reales y recomiéndale 1-3 opciones que de verdad encajen, explicando por qué y respetando su presupuesto. Si hace falta, pregunta 1 detalle. Nunca recomiendes algo que no esté en los resultados.
 - **Comparar:** si duda entre 2-4 productos, compáralos según SU necesidad (úsalos de search_products + fichas de search_knowledge) y recomiéndale uno con un motivo claro; ofrece añadirlo al carrito.
 - **Talla/compatibilidad:** ante "¿me vale?", "¿qué talla?", "¿es compatible con X?", busca la guía de tallas/compatibilidad en `search_knowledge`, haz 1-2 preguntas si hace falta, y responde con la fuente. Si no está el dato, dilo (no adivines tallas).
 - **Resolver objeciones:** si el cliente duda ("es caro", "no llega a tiempo", "¿y si lo devuelvo?"), responde PRIMERO con datos reales (plazo de envío, política de devoluciones de la base de conocimiento) antes de escalar; muchas veces es lo único que necesita para comprar.

app/retention.py

@@ -7,7 +7,7 @@ from datetime import UTC, datetime, timedelta
 from sqlalchemy import delete, select
 from sqlalchemy.ext.asyncio import AsyncSession
 
-from app.models import ChatMessage, ChatSession
+from app.models import ChatMessage, ChatSession, Event
 
 
 async def purge_old_sessions(db: AsyncSession, days: int) -> int:
@@ -15,7 +15,10 @@ async def purge_old_sessions(db: AsyncSession, days: int) -> int:
     ids = (
         await db.execute(select(ChatSession.id).where(ChatSession.last_seen < cutoff))
     ).scalars().all()
+    # Analytics events older than the window are purged too (keeps storage free).
+    await db.execute(delete(Event).where(Event.created_at < cutoff))
     if not ids:
+        await db.flush()
         return 0
     await db.execute(delete(ChatMessage).where(ChatMessage.session_id.in_(ids)))
     await db.execute(delete(ChatSession).where(ChatSession.id.in_(ids)))

tests/routes/test_retention.py

@@ -4,7 +4,7 @@ from datetime import UTC, datetime, timedelta
 
 from sqlalchemy import select
 
-from app.models import ChatMessage, ChatSession
+from app.models import ChatMessage, ChatSession, Event
 from app.retention import purge_old_sessions
 
 
@@ -27,3 +27,15 @@ async def test_purge_removes_old_keeps_recent(db_session):
 
     msgs = (await db_session.execute(select(ChatMessage))).scalars().all()
     assert msgs == []
+
+
+async def test_purge_removes_old_events(db_session):
+    now = datetime.now(UTC)
+    db_session.add(Event(tenant_id=1, type="turn", created_at=now - timedelta(days=60)))
+    db_session.add(Event(tenant_id=1, type="turn", created_at=now))
+    await db_session.flush()
+
+    await purge_old_sessions(db_session, days=30)
+
+    events = (await db_session.execute(select(Event))).scalars().all()
+    assert len(events) == 1  # old event purged, recent kept (keeps Neon free)