Módulo 2, Aula 4: Fluxos Avançados

// Configuração do nó Pipedrive no N8N
{
  "resource": "person",
  "operation": "create",
  "name": "{{ $json.nome }}",
  "phone": [{ "value": "{{ $json.telefone }}", "primary": true }],
  "email": [{ "value": "{{ $json.email }}", "primary": true }],
  "custom_fields": {
    "origem": "WhatsApp Bot",
    "interesse": "{{ $json.categoria }}",
    "score": "{{ $json.score }}",
    "primeira_interacao": "{{ $json.timestamp }}"
  }
}

// Criar deal automaticamente
{
  "resource": "deal",
  "operation": "create", 
  "title": "Oportunidade WhatsApp - {{ $json.nome }}",
  "value": "{{ $json.valor_estimado }}",
  "currency": "BRL",
  "stage_id": "{{ $json.estagio_id }}",
  "person_id": "{{ $json.person_id }}"
}

// Fluxo de fechamento
async function processarFechamento(lead, decisao) {
  if (decisao === 'sim') {
    // Gerar contrato
    const contrato = await gerarContrato(lead);
    
    // Criar link de pagamento
    const pagamento = await criarLinkPagamento({
      valor: lead.proposta.valor,
      parcelas: lead.proposta.parcelas,
      cliente: lead.dados
    });
    
    // Enviar documentos
    await enviarWhatsApp(lead.telefone, `
Perfeito! 🎉 Vou enviar seus documentos:

📄 Contrato: ${contrato.url}
💳 Pagamento: ${pagamento.url}

Após a confirmação do pagamento, nossa equipe entrará em contato em até 2h para agendar o onboarding.

Tem alguma dúvida sobre o processo?
    `);
    
    // Notificar equipe
    await notificarEquipe({
      tipo: 'nova_venda',
      lead: lead,
      valor: lead.proposta.valor
    });
    
    return { status: 'fechado', proximos_passos: 'aguardar_pagamento' };
  }
  
  // Caso de objeção
  return { status: 'objecao', proximos_passos: 'follow_up' };
}

// Estrutura padrão de log
const logEntry = {
  timestamp: new Date().toISOString(),
  level: 'ERROR|WARN|INFO|DEBUG',
  workflow_id: 'whatsapp_sales_flow',
  node_id: 'http_request_crm',
  user_phone: '+5511999999999',
  session_id: 'session_12345',
  error: {
    message: 'Connection timeout',
    stack: error.stack,
    code: 'ECONNABORTED'
  },
  context: {
    retry_count: 2,
    max_retries: 3,
    api_endpoint: 'https://api.hubspot.com/contacts',
    request_id: 'req_abc123'
  },
  user_impact: 'lead_lost|delayed_response|degraded_service|none',
  recovery_action: 'retry|fallback|manual_intervention|ignore'
};

// Enviar para múltiplos destinos
await Promise.all([
  sendToCloudWatch(logEntry),
  sendToSlack(logEntry),
  updateDashboard(logEntry),
  logToGoogleSheets(logEntry)
]);

// Métricas coletadas automaticamente
const performanceMetrics = {
  // Tempo de resposta
  response_time: {
    p50: 800,     // 50% das respostas em menos de 800ms
    p95: 2100,    // 95% das respostas em menos de 2.1s
    p99: 4500,    // 99% das respostas em menos de 4.5s
    avg: 1200     // Tempo médio de resposta
  },
  
  // Throughput
  requests_per_minute: 150,
  concurrent_users: 25,
  
  // Taxa de erro
  error_rate: 0.02,        // 2% de erro
  timeout_rate: 0.005,     // 0.5% de timeout
  
  // Cache
  cache_hit_rate: 0.85,    // 85% dos requests usam cache
  cache_size_mb: 45,
  
  // Recursos
  memory_usage_mb: 256,
  cpu_usage_percent: 15,
  
  // APIs externas
  api_health: {
    hubspot: 'healthy',
    whatsapp: 'healthy', 
    google_sheets: 'degraded'  // Latência alta
  }
};

// Alertas automáticos
if (performanceMetrics.response_time.p95 > 3000) {
  alertAdmin('Performance degraded: P95 > 3s');
}

if (performanceMetrics.error_rate > 0.05) {
  alertAdmin('High error rate: ' + (performanceMetrics.error_rate * 100) + '%');
}