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 事件：${email} 的 ${eventType}`);

      // 驗證信箱以檢查是否永久無效
      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'));