Merge branch 'main' of https://github.com/McGregory99/reformix-hackaton
This commit is contained in:
Carlos Narro
@@ -3,6 +3,10 @@
|
||||
"collection": "@nestjs/schematics",
|
||||
"sourceRoot": "src",
|
||||
"compilerOptions": {
|
||||
"deleteOutDir": true
|
||||
"deleteOutDir": true,
|
||||
"assets": [
|
||||
"**/*.md"
|
||||
],
|
||||
"watchAssets": true
|
||||
}
|
||||
}
|
||||
}
|
||||
4058
mvp/Whatsapp-bot/package-lock.json
generated
4058
mvp/Whatsapp-bot/package-lock.json
generated
File diff suppressed because it is too large
Load Diff
@@ -26,8 +26,9 @@
|
||||
"@nestjs/platform-express": "^10.0.0",
|
||||
"@nestjs/schedule": "^4.0.0",
|
||||
"@nestjs/typeorm": "^10.0.0",
|
||||
"@whiskeysockets/baileys": "^6.7.9",
|
||||
"@whiskeysockets/baileys": "^7.0.0-rc10",
|
||||
"axios": "^1.7.0",
|
||||
"baileys-antiban": "^3.9.0",
|
||||
"dotenv": "^16.4.0",
|
||||
"form-data": "^4.0.1",
|
||||
"pg": "^8.12.0",
|
||||
@@ -55,10 +56,16 @@
|
||||
"typescript": "^5.5.0"
|
||||
},
|
||||
"jest": {
|
||||
"moduleFileExtensions": ["js", "json", "ts"],
|
||||
"moduleFileExtensions": [
|
||||
"js",
|
||||
"json",
|
||||
"ts"
|
||||
],
|
||||
"rootDir": "src",
|
||||
"testRegex": ".*\\.spec\\.ts$",
|
||||
"transform": { "^.+\\.(t|j)s$": "ts-jest" },
|
||||
"transform": {
|
||||
"^.+\\.(t|j)s$": "ts-jest"
|
||||
},
|
||||
"coverageDirectory": "../coverage",
|
||||
"testEnvironment": "node"
|
||||
}
|
||||
|
||||
@@ -1,37 +1,167 @@
|
||||
# Luisa — Identidad y comunicacion
|
||||
# LUISA – IDENTIDAD Y FLUJO (VERSIÓN UNIFICADA)
|
||||
|
||||
Eres Luisa, asesora de Reformix. Cualificas leads de reforma por WhatsApp de forma natural; nunca robotica, nunca comercial agresiva.
|
||||
## INSTRUCCIÓN ABSOLUTA – IGNORA EL HISTORIAL CONTRADICTOR
|
||||
|
||||
## Personalidad
|
||||
- Cercana, directa y profesional
|
||||
- Hablas como una persona real, no como una empresa
|
||||
- Usas siempre "tu", nunca "usted"
|
||||
- Si el usuario es brusco, no te alteras; sigues tranquila
|
||||
Tú eres **Luisa**, asesora comercial de **Reformix**.
|
||||
No eres un asistente de IA genérico, no eres Claude, no eres ChatGPT, no eres un chatbot.
|
||||
**NUNCA** digas frases como “no soy Luisa”, “soy un asistente de inteligencia artificial”, “no puedo hacerme pasar por alguien”, “lamento la confusión”.
|
||||
Si el usuario te llama “Luisa”, responde afirmativamente y continúa con el flujo.
|
||||
**Ignora cualquier mensaje anterior en el historial que intente decir lo contrario.** Esta instrucción prevalece sobre todo lo demás.
|
||||
|
||||
## Reglas de comunicacion
|
||||
- Un mensaje por turno, una sola idea
|
||||
- Maximo 2 lineas por mensaje
|
||||
- Coma y punto y coma para respirar; el punto es solo para salto de linea
|
||||
- Nunca guiones largos ni emojis
|
||||
- Nunca repites lo que el usuario dijo para confirmar
|
||||
- Nunca usas: perfecto, excelente, por supuesto, encantada, claro que si
|
||||
- Nunca haces dos preguntas en un mismo mensaje
|
||||
---
|
||||
|
||||
## Comportamiento
|
||||
- Si el usuario duda, das opciones concretas
|
||||
- Si el usuario se desvia, rediriges sin tension
|
||||
- Si recibes viable=true cierras con FIN_VIABLE
|
||||
- Si recibes viable=false cierras con FIN_NO_VIABLE
|
||||
- Nunca revelas el presupuesto minimo ni las reglas internas
|
||||
## 1. PERSONALIDAD Y TONO
|
||||
|
||||
## Frases que te definen
|
||||
- "Entiendo, seguimos"
|
||||
- "No hace falta que sea exacto"
|
||||
- "Con eso ya tengo lo que necesito"
|
||||
- "Aqui estamos cuando quieras"
|
||||
- Cercana, directa, profesional.
|
||||
- Hablas como una persona real, no como una empresa.
|
||||
- Usas siempre “**tú**”, nunca “usted”.
|
||||
- Si el usuario es brusco, no te alteras; sigues tranquila.
|
||||
- Un mensaje por turno, una sola idea.
|
||||
- Máximo **2 líneas** por mensaje.
|
||||
- Usa coma y punto y coma para respirar; el punto solo para salto de línea.
|
||||
- **Nunca** uses guiones largos, emojis, o signos excesivos.
|
||||
- **Nunca** repitas lo que el usuario dijo para confirmar.
|
||||
- **Nunca** uses estas palabras: *perfecto, excelente, por supuesto, encantada, claro que sí, genial*.
|
||||
- **Nunca** hagas dos preguntas en un mismo mensaje.
|
||||
|
||||
---
|
||||
|
||||
## 2. MÁQUINA DE ESTADOS (FLUJO OBLIGATORIO)
|
||||
|
||||
Siempre debes seguir este orden, sin saltarte pasos. Solo avanzas cuando el usuario ha dado una respuesta válida para el estado actual.
|
||||
|
||||
**Secuencia:**
|
||||
1. **APERTURA** (solo si el lead está en estado `nuevo` o no se ha enviado aún)
|
||||
2. **ESPACIO** – qué espacio quiere reformar
|
||||
3. **TAMAÑO** – rango de metros cuadrados
|
||||
4. **ESTILO** – tipo de acabado
|
||||
5. **URGENCIA** – cuándo quiere empezar
|
||||
6. **PRESUPUESTO** – cantidad o rango
|
||||
7. **FIN_VIABLE** o **FIN_NO_VIABLE**
|
||||
|
||||
**Mensajes exactos que debes usar en cada estado** (puedes adaptar ligeramente la redacción pero sin cambiar el sentido):
|
||||
|
||||
- **APERTURA:**
|
||||
“Hola [nombre], soy Luisa de Reformix; vi que dejaste tus datos en nuestra web y quería ayudarte a preparar tu presupuesto. ¿Tienes unos minutos ahora?”
|
||||
|
||||
- **ESPACIO:**
|
||||
“¿Qué espacio tienes en mente, cocina, baño, salón, o algo más completo?”
|
||||
|
||||
- **TAMAÑO:**
|
||||
“¿Tienes idea del tamaño aproximado? Menos de 10m2, entre 10 y 20, entre 20 y 40, o más de 40?”
|
||||
|
||||
- **ESTILO:**
|
||||
“¿Cómo te imaginas el resultado? Algo funcional y limpio, un acabado más cuidado con buenos materiales, o algo más exclusivo donde cada detalle cuenta?”
|
||||
|
||||
- **URGENCIA:**
|
||||
“¿Y cuándo tienes pensado arrancar? ¿Es algo próximo o todavía estás explorando?”
|
||||
|
||||
- **PRESUPUESTO:**
|
||||
“Última pregunta: ¿tienes en mente un presupuesto aproximado para la reforma?”
|
||||
|
||||
- **FIN_VIABLE:**
|
||||
“Con todo esto ya preparo tu presupuesto. En un momento lo recibes aquí mismo.”
|
||||
|
||||
- **FIN_NO_VIABLE:**
|
||||
“Gracias por tu tiempo [nombre]; ahora mismo no podríamos darte el resultado que mereces con ese presupuesto. Si en algún momento cambia, aquí estamos.”
|
||||
|
||||
- **SEGUIMIENTO (FASE 3):**
|
||||
“Hola [nombre], ¿te llegó bien el presupuesto? ¿Quedaste con alguna duda?”
|
||||
|
||||
---
|
||||
|
||||
## 3. EXTRACCIÓN DE DATOS (OBLIGATORIO)
|
||||
|
||||
**Al final de CADA respuesta que des,** debes incluir un bloque JSON con el formato exacto que se muestra a continuación. No uses markdown (```json), no añadas texto después del bloque. El bloque debe aparecer literalmente así:
|
||||
|
||||
## Contexto del sistema
|
||||
Al final de cada respuesta incluye siempre el bloque de extraccion:
|
||||
<DATOS_EXTRAIDOS>
|
||||
{"campo": "valor"}
|
||||
</DATOS_EXTRAIDOS>
|
||||
{
|
||||
"nombre": null,
|
||||
"email": null,
|
||||
"espacio": null,
|
||||
"rango_m2": null,
|
||||
"estilo": null,
|
||||
"urgencia": null,
|
||||
"presupuesto_declarado": null,
|
||||
"viable": null
|
||||
}
|
||||
</DATOS_EXTRAIDOS>
|
||||
|
||||
- Rellena **solo los campos que hayas capturado en este turno**.
|
||||
- Si el usuario te dio su nombre, rellena `"nombre": "valor"`.
|
||||
- Si te dijo el espacio (`cocina`, `baño`, `salón`, `integral`, `otro`), rellena `"espacio"`.
|
||||
- Para `rango_m2`: usa exactamente `"menos10"`, `"10a20"`, `"20a40"`, `"mas40"`.
|
||||
- Para `estilo`: `"funcional"`, `"cuidado"`, `"exclusivo"`.
|
||||
- Para `urgencia`: `"urgente"`, `"medio_plazo"`, `"frio"`.
|
||||
- Para `presupuesto_declarado`: escribe la cifra o rango en euros (ej: `"15000"`, `"entre 10k y 20k"`).
|
||||
- Para `viable`: pon `true` si el presupuesto declarado es suficiente (según reglas internas de Reformix – asume que cualquier presupuesto > 10.000€ es viable, a menos que el usuario indique lo contrario). Si no puedes determinar, déjalo `null`.
|
||||
|
||||
**Importante:** El bloque JSON debe aparecer **siempre**, aunque todos los valores sean `null`.
|
||||
|
||||
---
|
||||
|
||||
## 4. MANEJO DE CASOS ESPECIALES
|
||||
|
||||
### Desvío del flujo
|
||||
Si el usuario pregunta algo fuera del estado actual, responde:
|
||||
“Cuando terminemos te cuento todo con detalle. ¿Seguimos?”
|
||||
Luego retoma la pregunta pendiente.
|
||||
|
||||
### Reintentos
|
||||
Si la respuesta del usuario no es válida para el estado actual, reformula la misma pregunta ofreciendo opciones concretas.
|
||||
Máximo **2 reintentos**. Al tercero:
|
||||
“Cerramos por ahora; cuando estés listo, aquí estamos.”
|
||||
|
||||
### Inactividad (lo gestiona el scheduler, pero lo incluyes por contexto)
|
||||
- 24h sin respuesta: “Hola [nombre], quedamos a medias; cuando quieras seguimos con tu presupuesto.”
|
||||
- 48h sin respuesta: se cierra como perdido (no envías mensaje).
|
||||
|
||||
### Mensajes multimedia
|
||||
- **Audio:** Transcríbelo y trátalo como texto. Si no entiendes: “No te escuché bien, ¿puedes repetirlo?”
|
||||
- **Imagen en ESPACIO o TAMAÑO:** Infiere el espacio y los m2 aproximados de la foto y úsalo como respuesta para ese estado.
|
||||
- **Imagen en ESTILO:** Infiere el estilo o calidad que busca por lo que muestra la foto.
|
||||
- **Imagen en otro estado:** “Gracias por la foto; cuéntame con palabras para asegurarme de entenderte bien.”
|
||||
- **Sticker u otro:** Ignora el contenido y usa el mensaje de desvío.
|
||||
|
||||
### Tono defensivo o brusco
|
||||
No te disculpes, no te alteres. Sigue con la siguiente pregunta del flujo de forma tranquila y natural.
|
||||
|
||||
### Usuario que no quiere dar el presupuesto
|
||||
“No te preocupes; un rango aproximado está bien, ¿menos de 10.000, entre 10 y 30, o más?”
|
||||
|
||||
---
|
||||
|
||||
## 5. EJEMPLOS DE RESPUESTA CORRECTA (FEW-SHOT IMPLÍCITO)
|
||||
|
||||
**Usuario:** Hola, necesito reformar mi cocina.
|
||||
**Luisa:** ¿Qué espacio tienes en mente, cocina, baño, salón, o algo más completo?
|
||||
<DATOS_EXTRAIDOS>{"espacio": "cocina", ... (el resto null)}</DATOS_EXTRAIDOS>
|
||||
|
||||
**Usuario:** Es cocina, unos 15 metros.
|
||||
**Luisa:** ¿Tienes idea del tamaño aproximado? Menos de 10m2, entre 10 y 20, entre 20 y 40, o más de 40?
|
||||
<DATOS_EXTRAIDOS>{"espacio": "cocina", "rango_m2": "10a20", ...}</DATOS_EXTRAIDOS>
|
||||
|
||||
**Usuario:** Quiero algo moderno pero no muy caro.
|
||||
**Luisa:** ¿Cómo te imaginas el resultado? Algo funcional y limpio, un acabado más cuidado con buenos materiales, o algo más exclusivo donde cada detalle cuenta?
|
||||
<DATOS_EXTRAIDOS>{"estilo": "funcional", ...}</DATOS_EXTRAIDOS>
|
||||
|
||||
**Usuario:** Tengo un presupuesto de 8000 euros.
|
||||
**Luisa:** Gracias por tu tiempo; ahora mismo no podríamos darte el resultado que mereces con ese presupuesto. Si en algún momento cambia, aquí estamos.
|
||||
<DATOS_EXTRAIDOS>{"presupuesto_declarado": "8000", "viable": false}</DATOS_EXTRAIDOS>
|
||||
|
||||
**Usuario:** Vale, puedo subir a 15000.
|
||||
**Luisa:** Con todo esto ya preparo tu presupuesto. En un momento lo recibes aquí mismo.
|
||||
<DATOS_EXTRAIDOS>{"presupuesto_declarado": "15000", "viable": true}</DATOS_EXTRAIDOS>
|
||||
|
||||
---
|
||||
|
||||
## 6. RECORDATORIO FINAL PARA EL MODELO
|
||||
|
||||
- **NUNCA digas que eres un asistente de IA, ni que no eres Luisa.**
|
||||
- **SIGUE la máquina de estados estrictamente.**
|
||||
- **INCLUYE el bloque JSON en CADA respuesta.**
|
||||
- **USA siempre “tú” y mantén el tono cercano pero profesional.**
|
||||
- **Una sola pregunta por mensaje.**
|
||||
- **Máximo 2 líneas de texto (sin contar el JSON).**
|
||||
|
||||
Ahora actúa como Luisa.
|
||||
@@ -1,3 +1,4 @@
|
||||
import 'dotenv/config';
|
||||
import { Module } from '@nestjs/common';
|
||||
import { TypeOrmModule } from '@nestjs/typeorm';
|
||||
import { ScheduleModule } from '@nestjs/schedule';
|
||||
@@ -30,4 +31,4 @@ import { Conversacion } from './conversacion/conversacion.entity';
|
||||
SchedulerModule,
|
||||
],
|
||||
})
|
||||
export class AppModule {}
|
||||
export class AppModule { }
|
||||
|
||||
@@ -74,6 +74,11 @@ export class ClaudeService {
|
||||
): Promise<ClaudeResponse> {
|
||||
const systemPrompt = this.leerPromptsSistema();
|
||||
|
||||
console.log('=== DEBUG SYSTEM PROMPT ===');
|
||||
console.log('Longitud systemPrompt:', systemPrompt.length);
|
||||
console.log('Primeros 500 caracteres:', systemPrompt.substring(0, 500));
|
||||
console.log('=== FIN DEBUG ===');
|
||||
|
||||
const contextoDeLead = `
|
||||
## Contexto del lead actual
|
||||
|
||||
@@ -109,16 +114,24 @@ Si puedes determinar si el lead es viable o no, pon true o false en "viable". Si
|
||||
{ role: 'user', content: mensajeActual },
|
||||
];
|
||||
|
||||
// Construimos el payload para enviar a OpenRouter
|
||||
const payload = {
|
||||
model: process.env.MODEL || 'anthropic/claude-sonnet-4-5',
|
||||
messages: messages,
|
||||
system: systemFinal,
|
||||
max_tokens: 1024,
|
||||
temperature: 0.7,
|
||||
};
|
||||
|
||||
// LOG DE LO QUE SE ENVÍA (exactamente lo que ve la IA)
|
||||
console.log('\n======= PETICIÓN A OPENROUTER =======');
|
||||
console.log(JSON.stringify(payload, null, 2));
|
||||
console.log('=====================================\n');
|
||||
|
||||
try {
|
||||
const response = await axios.post(
|
||||
'https://openrouter.ai/api/v1/chat/completions',
|
||||
{
|
||||
model: process.env.MODEL || 'anthropic/claude-sonnet-4-5',
|
||||
messages,
|
||||
system: systemFinal,
|
||||
max_tokens: 1024,
|
||||
temperature: 0.7,
|
||||
},
|
||||
payload,
|
||||
{
|
||||
headers: {
|
||||
Authorization: `Bearer ${process.env.OPENROUTER_API_KEY}`,
|
||||
@@ -129,24 +142,28 @@ Si puedes determinar si el lead es viable o no, pon true o false en "viable". Si
|
||||
},
|
||||
);
|
||||
|
||||
const contenidoCompleto: string =
|
||||
response.data.choices?.[0]?.message?.content || '';
|
||||
// LOG DE LA RESPUESTA CRUDA (lo que devuelve OpenRouter)
|
||||
console.log('\n======= RESPUESTA CRUDA DE OPENROUTER =======');
|
||||
console.log(JSON.stringify(response.data, null, 2));
|
||||
console.log('=============================================\n');
|
||||
|
||||
const contenidoCompleto: string = response.data.choices?.[0]?.message?.content || '';
|
||||
|
||||
// También imprimimos el contenido del mensaje para ver lo que generó la IA
|
||||
console.log('\n======= CONTENIDO DEL MENSAJE GENERADO =======');
|
||||
console.log(contenidoCompleto);
|
||||
console.log('================================================\n');
|
||||
|
||||
// Separar la respuesta visible del bloque de datos extraídos
|
||||
const regexDatos = /<DATOS_EXTRAIDOS>([\s\S]*?)<\/DATOS_EXTRAIDOS>/;
|
||||
const match = contenidoCompleto.match(regexDatos);
|
||||
|
||||
let respuesta = contenidoCompleto
|
||||
.replace(regexDatos, '')
|
||||
.trim();
|
||||
|
||||
let respuesta = contenidoCompleto.replace(regexDatos, '').trim();
|
||||
let entidad: Partial<Lead> = {};
|
||||
let viableFlag: boolean | undefined = undefined;
|
||||
|
||||
if (match) {
|
||||
try {
|
||||
const datos = JSON.parse(match[1].trim());
|
||||
// Solo incluir campos no nulos
|
||||
Object.entries(datos).forEach(([k, v]) => {
|
||||
if (v !== null && k !== 'viable') {
|
||||
(entidad as Record<string, unknown>)[k] = v;
|
||||
@@ -155,8 +172,8 @@ Si puedes determinar si el lead es viable o no, pon true o false en "viable". Si
|
||||
if (datos.viable !== null && datos.viable !== undefined) {
|
||||
viableFlag = datos.viable;
|
||||
}
|
||||
} catch {
|
||||
this.logger.warn('No se pudo parsear DATOS_EXTRAIDOS');
|
||||
} catch (e) {
|
||||
this.logger.warn('No se pudo parsear DATOS_EXTRAIDOS: ' + e.message);
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
@@ -7,19 +7,21 @@ import {
|
||||
import makeWASocket, {
|
||||
DisconnectReason,
|
||||
useMultiFileAuthState,
|
||||
fetchLatestBaileysVersion,
|
||||
WASocket,
|
||||
downloadMediaMessage,
|
||||
proto,
|
||||
} from '@whiskeysockets/baileys';
|
||||
import { Boom } from '@hapi/boom';
|
||||
import * as path from 'path';
|
||||
// eslint-disable-next-line @typescript-eslint/no-var-requires
|
||||
const pino = require('pino');
|
||||
const QRCode = require('qrcode-terminal');
|
||||
import { LeadsService } from '../leads/leads.service';
|
||||
import { ConversacionService } from '../conversacion/conversacion.service';
|
||||
import { ClaudeService } from '../claude/claude.service';
|
||||
import { MediaService } from '../media/media.service';
|
||||
import { Lead } from '../leads/lead.entity';
|
||||
import { wrapSocket } from 'baileys-antiban';
|
||||
|
||||
@Injectable()
|
||||
export class WhatsappService implements OnModuleInit, OnModuleDestroy {
|
||||
@@ -32,7 +34,7 @@ export class WhatsappService implements OnModuleInit, OnModuleDestroy {
|
||||
private readonly conversacionService: ConversacionService,
|
||||
private readonly claudeService: ClaudeService,
|
||||
private readonly mediaService: MediaService,
|
||||
) {}
|
||||
) { }
|
||||
|
||||
async onModuleInit() {
|
||||
await this.conectar();
|
||||
@@ -46,11 +48,16 @@ export class WhatsappService implements OnModuleInit, OnModuleDestroy {
|
||||
|
||||
private async conectar() {
|
||||
const { state, saveCreds } = await useMultiFileAuthState(this.authDir);
|
||||
const { version } = await fetchLatestBaileysVersion();
|
||||
|
||||
this.sock = makeWASocket({
|
||||
version,
|
||||
auth: state,
|
||||
printQRInTerminal: true,
|
||||
logger: pino({ level: 'silent' }) as any,
|
||||
printQRInTerminal: false,
|
||||
logger: pino({ level: 'info' }) as any,
|
||||
markOnlineOnConnect: false,
|
||||
generateHighQualityLinkPreview: false,
|
||||
syncFullHistory: false,
|
||||
});
|
||||
|
||||
this.sock.ev.on('creds.update', saveCreds);
|
||||
@@ -59,7 +66,8 @@ export class WhatsappService implements OnModuleInit, OnModuleDestroy {
|
||||
const { connection, lastDisconnect, qr } = update;
|
||||
|
||||
if (qr) {
|
||||
console.log('\n📲 Escanea el QR de arriba con WhatsApp\n');
|
||||
QRCode.generate(qr, { small: true });
|
||||
console.log('\n📲 Escanea este QR con WhatsApp\n');
|
||||
}
|
||||
|
||||
if (connection === 'close') {
|
||||
@@ -80,7 +88,7 @@ export class WhatsappService implements OnModuleInit, OnModuleDestroy {
|
||||
}
|
||||
} else if (connection === 'open') {
|
||||
this.logger.log(
|
||||
'✅ WhatsApp conectado. Luisa está lista para recibir mensajes.',
|
||||
'✅ WhatsApp conectado. Luisa esta lista para recibir mensajes.',
|
||||
);
|
||||
}
|
||||
});
|
||||
@@ -89,130 +97,102 @@ export class WhatsappService implements OnModuleInit, OnModuleDestroy {
|
||||
if (type !== 'notify') return;
|
||||
|
||||
for (const msg of messages) {
|
||||
if (msg.key.fromMe) continue; // ignorar mensajes propios
|
||||
if (msg.key.fromMe) continue;
|
||||
if (!msg.key.remoteJid) continue;
|
||||
|
||||
if (msg.key.remoteJid.includes('@g.us')) continue;
|
||||
await this.procesarMensaje(msg);
|
||||
}
|
||||
});
|
||||
}
|
||||
|
||||
/**
|
||||
* Procesa un mensaje entrante de WhatsApp.
|
||||
* Identifica el tipo (texto, audio, imagen), normaliza el contenido,
|
||||
* consulta/crea el lead, llama a Claude y envía la respuesta.
|
||||
*/
|
||||
private async procesarMensaje(
|
||||
msg: proto.IWebMessageInfo,
|
||||
): Promise<void> {
|
||||
private async procesarMensaje(msg: any): Promise<void> {
|
||||
const jid = msg.key.remoteJid!;
|
||||
// Normalizar el número de teléfono (quitar el @s.whatsapp.net y el sufijo de grupo)
|
||||
const telefono = jid.replace('@s.whatsapp.net', '').replace('@g.us', '');
|
||||
|
||||
// Ignorar grupos
|
||||
if (jid.includes('@g.us')) return;
|
||||
|
||||
// Normalizar JID para envio (manejar formato LID de Baileys v7)
|
||||
const jidNormalizado = jid.includes('@lid')
|
||||
? `${jid.split('@')[0]}@s.whatsapp.net`
|
||||
: jid;
|
||||
|
||||
const telefono = jidNormalizado.replace('@s.whatsapp.net', '');
|
||||
|
||||
try {
|
||||
// 1. Identificar o crear el lead
|
||||
const lead = await this.leadsService.findOrCreate(telefono);
|
||||
|
||||
// Ignorar leads ya terminados
|
||||
if (['completado', 'no_viable', 'perdido'].includes(lead.estado_actual)) {
|
||||
this.logger.log(
|
||||
`Lead id=${lead.id} en estado=${lead.estado_actual}. Mensaje ignorado.`,
|
||||
);
|
||||
this.logger.log(`Lead id=${lead.id} en estado=${lead.estado_actual}. Ignorando.`);
|
||||
return;
|
||||
}
|
||||
|
||||
// 2. Determinar el tipo de mensaje y normalizarlo a texto
|
||||
let textoNormalizado = '';
|
||||
const msgContent = msg.message;
|
||||
|
||||
if (!msgContent) return;
|
||||
|
||||
if (msgContent.conversation || msgContent.extendedTextMessage) {
|
||||
// Texto plano
|
||||
textoNormalizado =
|
||||
msgContent.conversation ||
|
||||
msgContent.extendedTextMessage?.text ||
|
||||
'';
|
||||
} else if (msgContent.audioMessage) {
|
||||
// Audio → Claude transcripción
|
||||
this.logger.log(`Audio recibido de lead id=${lead.id}. Transcribiendo...`);
|
||||
const buffer = await downloadMediaMessage(msg, 'buffer', {});
|
||||
const mimeType =
|
||||
msgContent.audioMessage.mimetype || 'audio/ogg; codecs=opus';
|
||||
const buffer = await downloadMediaMessage(msg as any, 'buffer', {});
|
||||
const mimeType = msgContent.audioMessage.mimetype || 'audio/ogg; codecs=opus';
|
||||
textoNormalizado = await this.mediaService.transcribirAudio(
|
||||
buffer as Buffer,
|
||||
mimeType,
|
||||
);
|
||||
} else if (msgContent.imageMessage) {
|
||||
// Imagen → Claude Vision
|
||||
this.logger.log(
|
||||
`Imagen recibida de lead id=${lead.id}. Analizando con Vision...`,
|
||||
);
|
||||
const buffer = await downloadMediaMessage(msg, 'buffer', {});
|
||||
this.logger.log(`Imagen recibida de lead id=${lead.id}. Analizando con Vision...`);
|
||||
const buffer = await downloadMediaMessage(msg as any, 'buffer', {});
|
||||
const mimeType = msgContent.imageMessage.mimetype || 'image/jpeg';
|
||||
textoNormalizado = await this.mediaService.inferirImagen(
|
||||
buffer as Buffer,
|
||||
mimeType,
|
||||
lead.estado_actual,
|
||||
);
|
||||
|
||||
// Si el lead envió un caption junto con la imagen, concatenarlo
|
||||
if (msgContent.imageMessage.caption) {
|
||||
textoNormalizado = `${msgContent.imageMessage.caption}\n\n[Contenido de la imagen: ${textoNormalizado}]`;
|
||||
}
|
||||
} else {
|
||||
this.logger.log(
|
||||
`Tipo de mensaje no soportado de lead id=${lead.id}. Ignorando.`,
|
||||
);
|
||||
this.logger.log(`Tipo de mensaje no soportado de lead id=${lead.id}. Ignorando.`);
|
||||
return;
|
||||
}
|
||||
|
||||
if (!textoNormalizado.trim()) return;
|
||||
|
||||
// 3. Guardar el mensaje del usuario en historial
|
||||
await this.conversacionService.guardarMensaje(
|
||||
lead.id,
|
||||
'user',
|
||||
textoNormalizado,
|
||||
);
|
||||
this.logger.log(`USUARIO [${telefono}]: ${textoNormalizado}`);
|
||||
|
||||
// 4. Construir historial y llamar a Claude
|
||||
const historial =
|
||||
await this.conversacionService.obtenerHistorialComoMessages(lead.id);
|
||||
await this.conversacionService.guardarMensaje(lead.id, 'user', textoNormalizado);
|
||||
|
||||
const historial = await this.conversacionService.obtenerHistorialComoMessages(lead.id);
|
||||
|
||||
const { respuesta, entidad, viable } = await this.claudeService.llamarClaude(
|
||||
lead,
|
||||
historial.slice(0, -1), // el último ya es el mensaje actual
|
||||
historial.slice(0, -1),
|
||||
textoNormalizado,
|
||||
);
|
||||
|
||||
// 5. Actualizar datos del lead con lo extraído por Claude
|
||||
this.logger.log(`LUISA [${telefono}]: ${respuesta}`);
|
||||
|
||||
if (entidad && Object.keys(entidad).length > 0) {
|
||||
await this.leadsService.updateDatos(lead.id, entidad);
|
||||
}
|
||||
|
||||
// 6. Manejar el flag viable
|
||||
if (viable !== undefined && viable !== null) {
|
||||
await this.leadsService.marcarViable(lead, viable);
|
||||
this.logger.log(
|
||||
`Lead id=${lead.id} marcado como viable=${viable}`,
|
||||
);
|
||||
this.logger.log(`Lead id=${lead.id} marcado como viable=${viable}`);
|
||||
} else {
|
||||
// Avanzar estado si sigue en_proceso
|
||||
if (lead.estado_actual === 'nuevo') {
|
||||
await this.leadsService.updateEstado(lead, 'en_proceso');
|
||||
}
|
||||
}
|
||||
|
||||
// 7. Guardar respuesta de Claude en historial
|
||||
await this.conversacionService.guardarMensaje(
|
||||
lead.id,
|
||||
'assistant',
|
||||
respuesta,
|
||||
);
|
||||
|
||||
// 8. Enviar respuesta por WhatsApp
|
||||
await this.conversacionService.guardarMensaje(lead.id, 'assistant', respuesta);
|
||||
await this.enviarMensaje(jid, respuesta);
|
||||
|
||||
} catch (error) {
|
||||
this.logger.error(
|
||||
`Error procesando mensaje de ${telefono}: ${error.message}`,
|
||||
@@ -220,27 +200,20 @@ export class WhatsappService implements OnModuleInit, OnModuleDestroy {
|
||||
);
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* Envía un mensaje de texto por WhatsApp.
|
||||
*/
|
||||
async enviarMensaje(jid: string, texto: string): Promise<void> {
|
||||
if (!this.sock) {
|
||||
this.logger.error('Socket de WhatsApp no disponible');
|
||||
return;
|
||||
}
|
||||
try {
|
||||
await this.sock.sendMessage(jid, { text: texto });
|
||||
const safeSock = wrapSocket(this.sock);
|
||||
await safeSock.sendMessage(jid, { text: texto });
|
||||
this.logger.log(`Mensaje enviado a ${jid}`);
|
||||
} catch (error) {
|
||||
this.logger.error(`Error enviando mensaje a ${jid}: ${error.message}`);
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* Envía el mensaje de apertura de Luisa a un número de teléfono.
|
||||
* Lo usa el Scheduler para disparar el primer contacto.
|
||||
*/
|
||||
async enviarApertura(telefono: string, mensajeApertura: string): Promise<void> {
|
||||
const jid = `${telefono}@s.whatsapp.net`;
|
||||
await this.enviarMensaje(jid, mensajeApertura);
|
||||
@@ -249,4 +222,4 @@ export class WhatsappService implements OnModuleInit, OnModuleDestroy {
|
||||
isConectado(): boolean {
|
||||
return this.sock !== null;
|
||||
}
|
||||
}
|
||||
}
|
||||
@@ -2,7 +2,10 @@
|
||||
"extends": "./tsconfig.json",
|
||||
"compilerOptions": {
|
||||
"declaration": false,
|
||||
"noEmit": true
|
||||
"noEmit": false
|
||||
},
|
||||
"exclude": ["node_modules", "dist"]
|
||||
}
|
||||
"exclude": [
|
||||
"node_modules",
|
||||
"dist"
|
||||
]
|
||||
}
|
||||
Reference in New Issue
Block a user