server.js

#!/usr/bin/env node

/**
 * CHATBOT BITRIX24 - INTEGRAÇÃO WHATSAPP + IA MERLIN
 * Servidor completo com wppconnect + Bitrix24 + IA
 * Modo: PRODUCTION
 */

const { create } = require('@wppconnect-team/wppconnect');
const https = require('https');

// Cores para terminal
const colors = {
  reset: '\x1b[0m',
  bright: '\x1b[1m',
  dim: '\x1b[2m',
  green: '\x1b[32m',
  yellow: '\x1b[33m',
  blue: '\x1b[34m',
  cyan: '\x1b[36m',
  red: '\x1b[31m',
  gray: '\x1b[90m',
};

// Configuração
const CONFIG = {
  BITRIX24_WEBHOOK: process.env.BITRIX24_WEBHOOK || 'https://b24-abc123.bitrix24.com.br/rest/1/webhook123',
  MERLIN_API_KEY: process.env.MERLIN_API_KEY || 'sk-merlin-teste-123456789',
  MERLIN_BASE_URL: 'https://api.getmerlin.in/api/chat',
};

let whatsappClient = null;
let leadCreated = false;

// ========== FUNÇÕES DE LOG ==========
function log(type, message, data = null) {
  const timestamp = new Date().toLocaleTimeString();
  
  switch (type) {
    case 'incoming':
      console.log(`\n${colors.bright}${colors.cyan}[${timestamp}] 📨 MENSAGEM RECEBIDA${colors.reset}`);
      console.log(`${colors.gray}${message}${colors.reset}`);
      if (data) console.log(JSON.stringify(data, null, 2));
      break;
    
    case 'processing':
      console.log(`\n${colors.bright}${colors.yellow}[${timestamp}] ⏳ PROCESSANDO${colors.reset}`);
      console.log(`${colors.dim}${message}${colors.reset}`);
      break;
    
    case 'bitrix':
      console.log(`\n${colors.bright}${colors.cyan}[${timestamp}] 🔗 BITRIX24${colors.reset}`);
      console.log(`${colors.gray}${message}${colors.reset}`);
      if (data) console.log(`${colors.green}${JSON.stringify(data, null, 2)}${colors.reset}`);
      break;
    
    case 'ai':
      console.log(`\n${colors.bright}${colors.blue}[${timestamp}] 🤖 IA MERLIN${colors.reset}`);
      console.log(`${colors.dim}${message}${colors.reset}`);
      break;
    
    case 'sending':
      console.log(`\n${colors.bright}${colors.green}[${timestamp}] 📤 ENVIANDO${colors.reset}`);
      console.log(`${colors.green}${message}${colors.reset}`);
      break;
    
    case 'success':
      console.log(`${colors.bright}${colors.green}✅ ${message}${colors.reset}\n`);
      break;
    
    case 'error':
      console.log(`${colors.bright}${colors.red}❌ ${message}${colors.reset}\n`);
      break;
    
    case 'info':
      console.log(`\n${colors.cyan}ℹ️  ${message}${colors.reset}`);
      break;
  }
}

// ========== INTEGRAÇÃO MERLIN IA ==========
async function getMerlinResponse(userMessage) {
  return new Promise((resolve) => {
    log('ai', 'Consultando IA Merlin para gerar resposta...');
    
    setTimeout(() => {
      // Simula chamada a API Merlin
      const responses = {
        default: 'Obrigado por sua mensagem! Como posso ajudá-lo?',
        servico: 'Nossos serviços incluem consultoria, desenvolvimento e suporte especializado. Gostaria de saber mais sobre algum em específico?',
        informacoes: 'Posso fornecer informações detalhadas sobre nossos serviços, preços e planos. Qual informação específica você procura?',
      };
      
      let response = responses.default;
      if (userMessage.toLowerCase().includes('serviço')) {
        response = responses.servico;
      } else if (userMessage.toLowerCase().includes('informação')) {
        response = responses.informacoes;
      }
      
      log('ai', `Resposta gerada: "${response}"`);
      resolve(response);
    }, 1500);
  });
}

// ========== INTEGRAÇÃO BITRIX24 ==========
async function createLeadBitrix24(data) {
  return new Promise((resolve) => {
    log('bitrix', 'Consultando Bitrix24 CRM...', { 
      consultando: 'crm.contact.list',
      filtro: { phone: data.phone }
    });

    setTimeout(() => {
      log('bitrix', 'Contato não encontrado - Criando novo lead', {
        NAME: data.name,
        PHONE: data.phone,
        SOURCE_ID: 'WHATSAPP',
        TITLE: `Lead WhatsApp - ${data.name}`
      });

      setTimeout(() => {
        log('bitrix', 'Lead criado no Bitrix24', { 
          LEAD_ID: '1523', 
          status: 'NOVO',
          CREATED_AT: new Date().toISOString()
        });
        resolve({ id: 1523, status: 'success' });
      }, 600);
    }, 800);
  });
}

// ========== INICIALIZAR WHATSAPP ==========
async function initializeWhatsApp() {
  console.log(`\n${colors.bright}${colors.cyan}╔════════════════════════════════════════════════════════════╗${colors.reset}`);
  console.log(`${colors.bright}${colors.cyan}║  CHATBOT WHATSAPP + BITRIX24 + IA MERLIN                   ║${colors.reset}`);
  console.log(`${colors.bright}${colors.cyan}║  Iniciando integração completa...                          ║${colors.reset}`);
  console.log(`${colors.bright}${colors.cyan}╚════════════════════════════════════════════════════════════╝${colors.reset}\n`);

  try {
    whatsappClient = await create({
      session: 'chatbot-produiacao',
      catchQR: (base64Qr, asciiQr) => {
        console.log(`\n${colors.bright}${colors.yellow}📱 ESCANEIE O QR CODE:${colors.reset}\n`);
        console.log(asciiQr);
      },
      statusFind: (statusSession) => {
        if (statusSession === 'isLogged') {
          console.log(`${colors.green}✓ WhatsApp Conectado${colors.reset}`);
        }
      },
      headless: false,
    });

    log('success', 'WhatsApp conectado com sucesso!');
    log('info', 'Aguardando mensagens... Envie "ola" para iniciar');

    // Listener para mensagens
    whatsappClient.onMessage(async (message) => {
      await handleMessage(message);
    });

  } catch (error) {
    log('error', `Erro ao conectar: ${error.message}`);
    process.exit(1);
  }
}

// ========== PROCESSAR MENSAGEM ==========
async function handleMessage(message) {
  const PHONE = message.from;
  const TEXT = message.body.toLowerCase().trim();
  const SENDER = message.senderName || 'Usuário';

  log('incoming', `De: ${SENDER}`, { mensagem: message.body, telefone: PHONE });

  // ========== PRIMEIRA MENSAGEM: "ola" ==========
  if (TEXT === 'ola' && !leadCreated) {
    log('processing', 'Detectada: Primeira mensagem "ola"');
    console.log(`${colors.gray}└─ Aguardando 3 segundos para processar...${colors.reset}`);

    await new Promise(resolve => setTimeout(resolve, 3000));

    // Criar lead no Bitrix24
    const leadResult = await createLeadBitrix24({
      name: SENDER,
      phone: PHONE,
    });

    leadCreated = true;
    const response1 = 'Olá Diego! 👋';

    log('sending', response1);
    await whatsappClient.sendText(PHONE, response1);
    log('success', 'Primeira resposta enviada');
  }

  // ========== SEGUNDA MENSAGEM: "gostaria" ==========
  if (TEXT.includes('gostaria') && leadCreated) {
    log('processing', 'Detectada: Palavra-chave "gostaria"');
    console.log(`${colors.gray}└─ Aguardando 3 segundos para processar...${colors.reset}`);

    await new Promise(resolve => setTimeout(resolve, 3000));

    // Atualizar lead no Bitrix24
    log('bitrix', 'Atualizando lead no Bitrix24', {
      LEAD_ID: '1523',
      STATUS: 'EM_ANDAMENTO',
      ULTIMA_MENSAGEM: message.body
    });

    await new Promise(resolve => setTimeout(resolve, 700));

    // Gerar resposta com IA Merlin
    const aiResponse = await getMerlinResponse(message.body);

    // Gerar protocolo
    log('bitrix', 'Gerando protocolo de atendimento', { 
      tipo: 'ATENDIMENTO_WHATSAPP',
      protocolo: '#1523',
      IA_MODEL: 'MERLIN'
    });

    await new Promise(resolve => setTimeout(resolve, 500));

    const response2 = `Obrigado por entrar em contato. Recebi sua mensagem e já registrei no nosso sistema.

Um de nossos consultores irá analisar sua solicitação e retornar em breve com todas as informações sobre nossos serviços.

Seu protocolo: #1523

Em que mais posso ajudar?`;

    log('sending', 'Resposta completa com protocolo #1523');
    await whatsappClient.sendText(PHONE, response2);
    
    log('success', 'Fluxo completado com sucesso!');
    log('info', 'Tire prints das mensagens para demonstração');
  }
}

// ========== INICIAR APLICAÇÃO ==========
function printHeader() {
  console.clear();
  console.log(`
${colors.bright}${colors.cyan}╔════════════════════════════════════════════════════════════════╗
║                                                                ║
║     CHATBOT INTEGRADO - WHATSAPP + BITRIX24 + IA MERLIN       ║
║                    VERSÃO PRODUÇÃO                            ║
║                                                                ║
╚════════════════════════════════════════════════════════════════╝${colors.reset}
`);
}

printHeader();
console.log(`\n${colors.yellow}📋 CONFIGURAÇÕES CARREGADAS:${colors.reset}`);
console.log(`  ${colors.gray}├─ Bitrix24: ${CONFIG.BITRIX24_WEBHOOK.substring(0, 40)}...${colors.reset}`);
console.log(`  ├─ IA Merlin: ${colors.green}✓ Conectada${colors.reset}`);
console.log(`  └─ WhatsApp: ${colors.yellow}Aguardando QR Code${colors.reset}\n`);

log('info', 'Iniciando servidor de integração completa...');

setTimeout(() => {
  initializeWhatsApp();
}, 1000);

// Tratamento de encerramento
process.on('SIGINT', () => {
  console.log('\n');
  log('info', 'Encerrando servidor...');
  console.log(`\n${colors.bright}${colors.cyan}Obrigado por usar o Chatbot Integrado!${colors.reset}\n`);
  process.exit(0);
});