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 {
    // Step 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;

    // Step 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):
    # Step 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()

    # Step 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 で実行中'));

# SendGrid UI または API 経由で連絡先をエクスポート
# Settings → Marketing → Contacts → Export

// 有効なメールのみを SendGrid にインポート
const validEmails = verifiedData.filter(
  row => row.status === 'valid' && row.risk_level === 'low'
);

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