Интеграция BillionVerify + ActiveCampaign - Проверка электронной почты для маркетинговой автоматизации

Новый контакт ActiveCampaign
         ↓
Триггер автоматизации ActiveCampaign
         ↓
Вебхук отправлен на ваш сервер
         ↓
API BillionVerify (Проверка email)
         ↓
API ActiveCampaign (Обновление контакта)

// Обработчик вебхука для проверки контактов ActiveCampaign

const express = require('express');
const axios = require('axios');

const app = express();
app.use(express.json());

app.post('/webhook/activecampaign-contact', async (req, res) => {
  const { contact } = req.body;
  const { id, email, fieldValues } = contact;

  try {
    // Шаг 1: Проверка email с BillionVerify
    const verificationResult = await axios.post(
      'https://api.billionverify.com/v1/verify',
      { email },
      {
        headers: {
          'Authorization': `Bearer ${process.env.BILLIONVERIFY_API_KEY}`,
          'Content-Type': 'application/json'
        }
      }
    );

    const { status, risk_level, is_disposable, is_catch_all, is_role } = verificationResult.data;

    // Шаг 2: Вычисление корректировки оценки лида
    let scoreAdjustment = 0;
    if (status === 'valid' && risk_level === 'low') {
      scoreAdjustment = 10; // Бонус за действительный email
    } else if (status === 'invalid') {
      scoreAdjustment = -50; // Большой штраф за недействительный email
    } else if (is_disposable || is_role) {
      scoreAdjustment = -20; // Штраф за одноразовые/ролевые адреса
    } else if (is_catch_all) {
      scoreAdjustment = -5; // Небольшой штраф за catch-all
    }

    // Шаг 3: Обновление контакта ActiveCampaign
    const acApiUrl = `https://${process.env.AC_ACCOUNT}.api-us1.com`;
    const acApiKey = process.env.AC_API_KEY;

    await axios.put(
      `${acApiUrl}/api/3/contacts/${id}`,
      {
        contact: {
          fieldValues: [
            { field: 1, value: status },                    // Пользовательское поле: Статус email
            { field: 2, value: risk_level },                // Пользовательское поле: Уровень риска
            { field: 3, value: is_disposable ? 'Yes' : 'No' }, // Пользовательское поле: Одноразовый
            { field: 4, value: is_catch_all ? 'Yes' : 'No' },  // Пользовательское поле: Catch-all
            { field: 5, value: is_role ? 'Yes' : 'No' }        // Пользовательское поле: Ролевой
          ]
        }
      },
      {
        headers: {
          'Api-Token': acApiKey,
          'Content-Type': 'application/json'
        }
      }
    );

    // Шаг 4: Корректировка оценки контакта
    await axios.post(
      `${acApiUrl}/api/3/contactTags`,
      {
        contactTag: {
          contact: id,
          tag: status === 'valid' ? 'verified-email' : 'invalid-email'
        }
      },
      {
        headers: {
          'Api-Token': acApiKey,
          'Content-Type': 'application/json'
        }
      }
    );

    // Опционально: Корректировка оценки лида
    if (scoreAdjustment !== 0) {
      await axios.post(
        `${acApiUrl}/api/3/scores`,
        {
          score: {
            contact: id,
            score: scoreAdjustment
          }
        },
        {
          headers: {
            'Api-Token': acApiKey,
            'Content-Type': 'application/json'
          }
        }
      );
    }

    res.status(200).send({ success: true, verified: true });
  } catch (error) {
    console.error('Verification error:', error);
    res.status(500).send({ error: 'Verification failed' });
  }
});

app.listen(3000, () => console.log('Вебхук-сервер запущен на порту 3000'));