BillionVerify + SendGrid 集成 - 发送前验证邮箱

用户注册表单
      ↓
BillionVerify API (验证邮箱)
      ↓
有效？→ SendGrid API (添加联系人 + 发送)
无效？→ 拒绝或记录

// 示例：在通过 SendGrid 发送欢迎消息前验证邮箱

const axios = require('axios');
const sgMail = require('@sendgrid/mail');

sgMail.setApiKey(process.env.SENDGRID_API_KEY);

async function sendWelcomeEmail(email, name) {
  try {
    // 步骤 1：使用 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：仅在邮箱有效且低风险时发送
    if (status === 'valid' && risk_level === 'low' && !is_disposable) {
      // 邮箱安全可发送
      const msg = {
        to: email,
        from: 'welcome@yourdomain.com',
        subject: '欢迎使用我们的服务！',
        text: `您好 ${name}，欢迎来到我们的平台！`,
        html: `<h1>您好 ${name}</h1><p>欢迎来到我们的平台！</p>`,
      };

      await sgMail.send(msg);
      console.log(`✅ 欢迎邮件已发送至 ${email}`);

      // 可选：添加到 SendGrid 营销联系人
      await addToSendGridContacts(email, name, {
        email_verified: true,
        risk_level: 'low'
      });

      return { success: true, sent: true };
    } else if (status === 'invalid') {
      // 邮箱无效 - 不发送
      console.log(`❌ 邮箱 ${email} 无效。不发送。`);
      return { success: false, reason: 'invalid_email' };
    } else if (is_disposable) {
      // 临时邮箱 - 阻止或标记
      console.log(`⚠️ 邮箱 ${email} 是临时邮箱。标记。`);
      return { success: false, reason: 'disposable_email' };
    } else {
      // 风险邮箱 - 标记以供审核
      console.log(`⚠️ 邮箱 ${email} 有风险 (${risk_level})。需要人工审核。`);
      return { success: false, reason: 'risky_email', risk_level };
    }
  } catch (error) {
    console.error('验证或发送错误:', error);
    return { success: false, reason: 'api_error' };
  }
}

async function addToSendGridContacts(email, name, customFields) {
  const data = {
    contacts: [
      {
        email: email,
        first_name: name.split(' ')[0],
        last_name: name.split(' ')[1] || '',
        custom_fields: customFields
      }
    ]
  };

  await axios.put(
    'https://api.sendgrid.com/v3/marketing/contacts',
    data,
    {
      headers: {
        'Authorization': `Bearer ${process.env.SENDGRID_API_KEY}`,
        'Content-Type': 'application/json'
      }
    }
  );
}

// 使用示例
app.post('/api/signup', async (req, res) => {
  const { email, name } = req.body;

  const result = await sendWelcomeEmail(email, name);

  if (result.success) {
    res.json({ message: '账户已创建并发送欢迎邮件！' });
  } else {
    res.status(400).json({
      error: '无效的邮箱地址',
      reason: result.reason
    });
  }
});

import requests
from sendgrid import SendGridAPIClient
from sendgrid.helpers.mail import Mail

BILLIONVERIFY_API_KEY = 'your_billionverify_api_key'
SENDGRID_API_KEY = 'your_sendgrid_api_key'

def send_welcome_email(email, name):
    # 步骤 1：使用 BillionVerify 验证邮箱
    verification_response = requests.post(
        'https://api.billionverify.com/v1/verify',
        json={'email': email},
        headers={
            'Authorization': f'Bearer {BILLIONVERIFY_API_KEY}',
            'Content-Type': 'application/json'
        }
    )
    result = verification_response.json()

    # 步骤 2：仅在有效且低风险时发送
    if result['status'] == 'valid' and result['risk_level'] == 'low' and not result.get('is_disposable'):
        # 安全可发送
        message = Mail(
            from_email='welcome@yourdomain.com',
            to_emails=email,
            subject=f'欢迎 {name}！',
            html_content=f'<h1>您好 {name}</h1><p>欢迎来到我们的平台！</p>'
        )

        try:
            sg = SendGridAPIClient(SENDGRID_API_KEY)
            response = sg.send(message)
            print(f"✅ 邮件已发送至 {email}，状态代码：{response.status_code}")

            # 可选：添加到营销联系人
            add_to_sendgrid_contacts(email, name, {
                'email_verified': True,
                'risk_level': 'low'
            })

            return {'success': True, 'sent': True}
        except Exception as e:
            print(f"发送邮件错误：{e}")
            return {'success': False, 'reason': 'sendgrid_error'}
    elif result['status'] == 'invalid':
        print(f"❌ 邮箱 {email} 无效。不发送。")
        return {'success': False, 'reason': 'invalid_email'}
    elif result.get('is_disposable'):
        print(f"⚠️ 邮箱 {email} 是临时邮箱。阻止。")
        return {'success': False, 'reason': 'disposable_email'}
    else:
        print(f"⚠️ 邮箱 {email} 有风险。需要人工审核。")
        return {'success': False, 'reason': 'risky_email'}

def add_to_sendgrid_contacts(email, name, custom_fields):
    data = {
        'contacts': [
            {
                'email': email,
                'first_name': name.split(' ')[0],
                'last_name': ' '.join(name.split(' ')[1:]) if len(name.split(' ')) > 1 else '',
                'custom_fields': custom_fields
            }
        ]
    }

    requests.put(
        'https://api.sendgrid.com/v3/marketing/contacts',
        json=data,
        headers={
            'Authorization': f'Bearer {SENDGRID_API_KEY}',
            'Content-Type': 'application/json'
        }
    )

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

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

app.post('/webhook/sendgrid', async (req, res) => {
  const events = req.body;

  for (const event of events) {
    const { event: eventType, email } = event;

    // 处理退信和阻止
    if (['bounce', 'dropped', 'blocked'].includes(eventType)) {
      console.log(`⚠️ SendGrid 事件：${eventType} for ${email}`);

      // 验证邮箱以检查是否永久无效
      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 } = verificationResult.data;

      if (status === 'invalid') {
        // 添加到永久抑制列表
        await addToSuppressionList(email, 'invalid_email');
        console.log(`❌ 邮箱 ${email} 已添加到抑制列表`);
      }
    }
  }

  res.status(200).send('OK');
});

async function addToSuppressionList(email, reason) {
  // 添加到 SendGrid 抑制列表
  await axios.post(
    'https://api.sendgrid.com/v3/suppression/bounces',
    {
      emails: [
        {
          email: email,
          reason: reason
        }
      ]
    },
    {
      headers: {
        'Authorization': `Bearer ${process.env.SENDGRID_API_KEY}`,
        'Content-Type': 'application/json'
      }
    }
  );

  // 还可以记录到数据库以供分析
  // await logInvalidEmail(email, reason);
}

app.listen(3000, () => console.log('Webhook 服务器运行在端口 3000'));