Como ligar o Typebot ao WhatsApp oficial

// Converte a resposta do Typebot (startChat ou continueChat, pedida com
// textBubbleContentFormat: 'markdown') nos corpos de envio do CRPRO Hub.
function paraHub(resposta, para) {
  const envios = []
  const textos = []
  const despejarTextos = () => {
    for (const texto of textos.splice(0)) {
      envios.push({ to: para, type: 'text', text: { body: texto.slice(0, 4096) } })
    }
  }

  for (const m of resposta.messages ?? []) {
    if (m.type === 'text' && m.content?.markdown) {
      textos.push(m.content.markdown)
    } else if (paraLink(m)) {
      despejarTextos()
      envios.push({ to: para, type: m.type, [m.type]: { link: m.content.url } })
    } else if (m.type === 'video' && m.content?.url) {
      textos.push(m.content.url)
    }
  }

  const itens = resposta.input?.type === 'choice input' ? resposta.input.items : []
  if (itens.length > 0 && itens.length <= 10) {
    // O ultimo texto vira o corpo da pergunta, como no runtime de WhatsApp
    // do proprio Typebot.
    const pergunta = textos.pop() ?? 'Escolha uma opção:'
    despejarTextos()
    envios.push(perguntaComOpcoes(para, pergunta, itens))
  } else {
    if (itens.length > 10) {
      textos.push(itens.map((item, i) => `${i + 1}. ${item.content}`).join('\n'))
    }
    despejarTextos()
  }
  return envios
}

// Imagem, audio e video por link HTTPS. Video do YouTube, Vimeo e similares
// nao e arquivo: o WhatsApp so aceita MP4, entao ele vai como texto com o link.
function paraLink(m) {
  if (!m.content?.url?.startsWith('https://')) return false
  if (m.type === 'image' || m.type === 'audio') return true
  return m.type === 'video' && m.content.type === 'url'
}

// Ate 3 opcoes viram botoes (titulo de ate 20 caracteres); de 4 a 10, lista
// (ate 24). O id de cada opcao e o id do item no Typebot.
function perguntaComOpcoes(para, pergunta, itens) {
  const titulo = (item, i, max) => (item.content || `Opção ${i + 1}`).slice(0, max)
  const body = { text: pergunta.slice(0, 1024) }
  if (itens.length <= 3) {
    const buttons = itens.map((item, i) => ({ type: 'reply', reply: { id: item.id, title: titulo(item, i, 20) } }))
    return { to: para, type: 'interactive', interactive: { type: 'button', body, action: { buttons } } }
  }
  const rows = itens.map((item, i) => ({ id: item.id, title: titulo(item, i, 24) }))
  return {
    to: para,
    type: 'interactive',
    interactive: { type: 'list', body, action: { button: 'Ver opções', sections: [{ rows }] } },
  }
}

// O que o contato mandou, no formato da API de chat do Typebot. Numa
// resposta de botao ou lista, o id volta em metadata.replyId: e por ele que o
// Typebot sabe qual opcao foi escolhida, mesmo com o titulo cortado.
function paraTypebot(evento) {
  const interativo = evento.data.content?.interactive
  const escolha = interativo?.button_reply ?? interativo?.list_reply
  if (escolha) return { type: 'text', text: escolha.title, metadata: { replyId: escolha.id } }
  return { type: 'text', text: evento.data.text ?? '' }
}

const TYPEBOT = 'https://typebot.io/api/v1' // self-hosted: a URL do viewer
const ID_PUBLICO = 'meu-bot-publicado'        // aba Share do Typebot
const sessoes = new Map() // troque por Redis ou banco: chave canal:contato

async function aoReceber(evento) {
  // Ja verificado (assinatura) e deduplicado pelo id do evento.
  if (evento.event !== 'message.received') return
  const chave = `${evento.channel_id}:${evento.data.from}`
  const mensagem = paraTypebot(evento)

  let resposta
  const sessao = sessoes.get(chave)
  if (sessao) {
    resposta = await chamar(`/sessions/${sessao}/continueChat`, { message: mensagem, textBubbleContentFormat: 'markdown' })
  }
  if (!sessao || resposta.status === 404) {
    // Sessao nova, ou expirada por inatividade (o Typebot responde 404): o
    // fluxo recomeca do inicio, como uma conversa nova.
    resposta = await chamar(`/typebots/${ID_PUBLICO}/startChat`, {
      textBubbleContentFormat: 'markdown',
      prefilledVariables: { telefone: evento.data.from, nome: evento.data.contact?.name ?? '' },
    })
  }
  const corpo = await resposta.json()
  if (corpo.sessionId) sessoes.set(chave, corpo.sessionId)

  for (const [i, envio] of paraHub(corpo, evento.data.from).entries()) {
    await fetch(`https://crprohub.com/api/v1/channels/${evento.channel_id}/messages`, {
      method: 'POST',
      headers: {
        Authorization: `Bearer ${process.env.CRPRO_API_KEY}`,
        'Content-Type': 'application/json',
        // Estavel por mensagem recebida e por posicao: reprocessar nao duplica.
        'Idempotency-Key': `typebot-${evento.data.message_id}-${i}`,
      },
      body: JSON.stringify(envio),
    })
  }
}

function chamar(caminho, corpo) {
  return fetch(`${TYPEBOT}${caminho}`, {
    method: 'POST',
    headers: { 'Content-Type': 'application/json' },
    body: JSON.stringify(corpo),
  })
}