AI Chatbot Management

ANTHROPIC_API_KEY=sk-ant-xxx         # Claude API key
WHATSAPP_PHONE_ID=123456789          # Meta phone ID
WHATSAPP_ACCESS_TOKEN=xxx            # Meta access token
REDIS_URL=redis://localhost:6379     # BullMQ queue storage

const redisUrl = process.env.REDIS_URL;
const redisOpts = { maxRetriesPerRequest: null };

if (!redisUrl) {
  redisOpts.host = process.env.REDIS_HOST || 'localhost';
  redisOpts.port = process.env.REDIS_PORT || 6379;
  redisOpts.password = process.env.REDIS_PASSWORD;
}

const queueConnection = redisUrl 
  ? new IORedis(redisUrl, redisOpts) 
  : new IORedis(redisOpts);

const cleanText = redactPII(text);
const userMsg = { role: 'user', content: cleanText };
history.push(userMsg);

const HANDOVER_KEYWORDS = /\b(humano|agente|asesor|persona|queja|reclamo|ayuda|contactar|hablar con alguien)\b/i;

{
  name: "searchInventory",
  description: "Busca en el inventario actual (catálogo de productos) de KAIU para responder preguntas sobre precios, disponibilidad, y variantes.",
  input_schema: {
    type: "object",
    properties: {
      query: {
        type: "string",
        description: "El nombre del producto, ingrediente o variante a buscar"
      }
    },
    required: ["query"]
  }
}

async function executeSearchInventory(query) {
  // Split query into terms
  const terms = query.split(' ').filter(w => w.length > 3);
  
  // Build OR search conditions
  const searchConditions = terms.map(t => ({
    OR: [
      { name: { contains: t, mode: 'insensitive' } },
      { category: { contains: t, mode: 'insensitive' } },
      { variantName: { contains: t, mode: 'insensitive' } }
    ]
  }));
  
  // Query Prisma
  const products = await prisma.product.findMany({
    where: { OR: searchConditions },
    select: { id, name, variantName, price, stock, isActive, category, description }
  });
  
  // Filter active only
  return JSON.stringify(products.filter(p => p.isActive));
}

{
  name: "searchKnowledgeBase",
  description: "Busca en el 'Cerebro RAG' manuales de la empresa, tiempos de envío, costos de envío a ciudades, y políticas generales.",
  input_schema: {
    type: "object",
    properties: {
      query: {
        type: "string",
        description: "La pregunta o concepto a buscar en la base de políticas"
      }
    },
    required: ["query"]
  }
}

const systemPrompt = `
REGLAS DE ORO:
1. NUNCA respondas sobre productos basándote en tu memoria. 
   SIEMPRE invoca "searchInventory" para CUALQUIER pregunta de producto.

2. PRECIOS están en PESOS COLOMBIANOS (COP). Usa "$" y formato amigable.

3. Si stock es 0, di que está agotado. NO ofrezcas alternativas que no existan.

4. IMÁGENES: Usa [SEND_IMAGE: id] con UUIDs reales de la herramienta.
   NUNCA inventes IDs falsos.
`;

let finalUserQuestion = userQuestion;
if (/(foto|imagen|ver|mostrar)/i.test(finalUserQuestion)) {
  finalUserQuestion += "\n[SISTEMA: Obligatorio ejecutar searchInventory para obtener UUIDs reales.]";
}

// Keep only last 4 messages
const recentHistory = chatHistory.slice(-4);

// New session created
io.emit('session_new', { id: session.id, phone: from, time: session.updatedAt });

// User message received
io.to(`session_${session.id}`).emit('new_message', { 
  sessionId: session.id, 
  message: { role: 'user', content: text, time: "Just now" } 
});

// Bot response sent
io.to(`session_${session.id}`).emit('new_message', { 
  sessionId: session.id, 
  message: { role: 'assistant', content: finalText, time: "Just now" } 
});

// Handover triggered
io.emit('session_update', { id: session.id, status: 'handover' });

// Update chat list
io.emit('chat_list_update', { sessionId: session.id });