AgentV8 Schedule — Geral

O que este workflow faz?

Este é o coração do atendimento automatizado da Fluity. Ele recebe mensagens de múltiplos canais (WhatsApp, Telegram, Facebook, Instagram e Webchat), processa o conteúdo com inteligência artificial e responde ao usuário pelo mesmo canal em que a mensagem chegou.

Em resumo:

Recebe → Filtra → Entende (texto, áudio ou imagem) → Pensa com IA → Responde

Canais suportados

Fluxo Geral

O workflow é dividido em 8 blocos funcionais que operam em sequência:

┌─────────────────────────────────────────────────────────┐
│  1. ENTRADA (Triggers / Webhooks)                        │
│     WhatsApp · Telegram · Facebook · Instagram · Webchat │
└────────────────────────┬────────────────────────────────┘
                         │
                         ▼
┌─────────────────────────────────────────────────────────┐
│  2. CADASTRO E VERIFICAÇÃO                               │
│     Busca instância → Cadastra contato → Cria chat       │
│     Verifica blacklist · Identifica lead de anúncio      │
└────────────────────────┬────────────────────────────────┘
                         │
                         ▼
┌─────────────────────────────────────────────────────────┐
│  3. FILTRO E ROTEAMENTO                                  │
│     IA ativa? · Tipo de mensagem? · Canal de origem?     │
│     Pausar IA ↔ Reativar IA (atendimento humano)         │
└────────────────────────┬────────────────────────────────┘
                         │
                         ▼
┌─────────────────────────────────────────────────────────┐
│  4. CONVERSÃO DE MÍDIA                                   │
│     Áudio → Transcrição (Whisper)                        │
│     Imagem → Descrição (GPT-4 Vision)                    │
│     Texto → direto                                       │
└────────────────────────┬────────────────────────────────┘
                         │
                         ▼
┌─────────────────────────────────────────────────────────┐
│  5. BUFFER DE MENSAGENS (Redis)                          │
│     Aguarda janela de tempo para consolidar mensagens    │
│     picotadas antes de enviar ao agente                  │
└────────────────────────┬────────────────────────────────┘
                         │
                         ▼
┌─────────────────────────────────────────────────────────┐
│  6. PROCESSAMENTO COM IA (2 agentes em cascata)          │
│                                                          │
│  [Agente RAG] — busca na base vetorial + site           │
│       ↓                                                  │
│  [Atendente] — GPT-4.1 + memória PostgreSQL + MCP       │
└────────────────────────┬────────────────────────────────┘
                         │
                         ▼
┌─────────────────────────────────────────────────────────┐
│  7. ENVIO DA RESPOSTA                                    │
│     Texto · Áudio (TTS) · Imagem                         │
│     Pelo mesmo canal que chegou a mensagem               │
└────────────────────────┬────────────────────────────────┘
                         │
                         ▼
┌─────────────────────────────────────────────────────────┐
│  8. PÓS-PROCESSAMENTO                                    │
│     Salva histórico no Supabase · Limpa cache Redis      │
│     Atualiza fila de atendimento                         │
└─────────────────────────────────────────────────────────┘

Detalhamento por bloco

Bloco 1 — Entrada (Triggers)

O workflow aguarda mensagens simultâneas em 7 webhooks:

Bloco 2 — Cadastro e Verificação

Após receber a mensagem, o workflow:

1. Busca a instância configurada no Supabase (tabela instances)
2. Verifica se o contato está na blacklist — se estiver, encerra sem responder
3. Cadastra ou atualiza o contato via API REST do Supabase (contacts)
4. Cria ou recupera o chat via função RPC no Supabase (get_or_create_chat)
5. Identifica se a mensagem veio de um anúncio e salva o lead em prompt_ads_clientes

Bloco 3 — Filtro e Roteamento

Com o chat identificado, o sistema verifica:

• IA está ativa? → Se pausada por um humano, ignora a mensagem
• Tipo de mensagem → Texto, áudio, imagem ou documento
• Canal de origem → Para rotear a resposta corretamente

Comandos especiais também são processados aqui:

• Palavra-chave de pausa → Pausar IA (humano assume o atendimento)
• Palavra-chave de reativação → Reativar IA

Bloco 4 — Conversão de Mídia

O agente de IA só trabalha com texto, então mídias são convertidas:

Bloco 5 — Buffer de Mensagens (Redis)

O sistema usa o Redis como cache temporário:

1. Salva a mensagem no Redis com chave única por contato+canal
2. Aguarda uma janela de tempo (Wait)
3. Verifica se chegou alguma mensagem nova nesse intervalo
4. Se sim, consolida tudo em uma mensagem única antes de enviar ao agente

Isso evita que o agente responda cada fragmento separadamente.

Bloco 6 — Processamento com IA

Dois agentes operam em sequência:

Agente RAG

• Modelo: GPT-4.1-mini
• Função: Busca informações relevantes na base de conhecimento antes de responder
• Ferramentas:
  • buscar_documentos — consulta o Vector Store no Supabase (busca semântica com pgvector)
  • site_consultas — chama um sub-workflow para consultas externas

Agente Atendente

• Modelo: GPT-4.1
• Função: Agente principal que interage com o usuário
• Características:
  • Prompt dinâmico carregado do Supabase (personalizável por instância)
  • Memória de contexto via PostgreSQL (mantém histórico da conversa)
  • Acesso a ferramentas externas via protocolo MCP

A saída do agente pode ser: texto, audio, imagem ou parser (estruturado).

Bloco 7 — Envio da Resposta

A resposta é roteada pelo canal de origem:

Mensagens longas são automaticamente divididas em partes com um delay de 1 segundo entre cada uma para parecer mais natural.

Bloco 8 — Pós-processamento

Após o envio:

• Histórico da conversa salvo no Supabase (chat_messages)
• Cache do Redis limpo para o contato
• Fila de atendimento atualizada
• Webhook respondido com 200 OK

Integrações e APIs

Serviços externos utilizados

Chamadas HTTP diretas

Modelos de IA utilizados

Tabelas do Supabase utilizadas