BillionVerify + Mailchimp 連携 - 送信前にメールアドレスを検証

Mailchimp Webhook
      ↓
バックエンドサーバー
      ↓
BillionVerify API
      ↓
Mailchimp API（コンタクト更新）

// 例：Mailchimpオーディエンスに追加されたときにメールを検証

const axios = require('axios');

// Mailchimp webhook ハンドラー
app.post('/webhook/mailchimp-subscribe', async (req, res) => {
  const { email, list_id, subscriber_id } = req.body.data;

  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 } = verificationResult.data;

    // ステップ2：結果に基づいてMailchimpの購読者を更新
    const mailchimpApiKey = process.env.MAILCHIMP_API_KEY;
    const mailchimpServer = mailchimpApiKey.split('-')[1];

    if (status === 'valid' && risk_level === 'low') {
      // 有効なメール - メインセグメントに追加
      await axios.patch(
        `https://${mailchimpServer}.api.mailchimp.com/3.0/lists/${list_id}/members/${subscriber_id}`,
        {
          status: 'subscribed',
          merge_fields: {
            EMAILSTAT: 'verified',
            RISKLEVEL: 'low'
          },
          tags: ['verified']
        },
        {
          headers: {
            'Authorization': `Bearer ${mailchimpApiKey}`,
            'Content-Type': 'application/json'
          }
        }
      );
    } else if (status === 'invalid') {
      // 無効なメール - 購読解除またはアーカイブ
      await axios.patch(
        `https://${mailchimpServer}.api.mailchimp.com/3.0/lists/${list_id}/members/${subscriber_id}`,
        {
          status: 'unsubscribed',
          merge_fields: {
            EMAILSTAT: 'invalid'
          },
          tags: ['invalid']
        },
        {
          headers: {
            'Authorization': `Bearer ${mailchimpApiKey}`,
            'Content-Type': 'application/json'
          }
        }
      );
    } else {
      // リスクのあるメール - レビュー用にフラグ
      await axios.patch(
        `https://${mailchimpServer}.api.mailchimp.com/3.0/lists/${list_id}/members/${subscriber_id}`,
        {
          merge_fields: {
            EMAILSTAT: 'risky',
            RISKLEVEL: risk_level
          },
          tags: ['needs-review', is_disposable ? 'disposable' : '', is_catch_all ? 'catch-all' : ''].filter(Boolean)
        },
        {
          headers: {
            'Authorization': `Bearer ${mailchimpApiKey}`,
            'Content-Type': 'application/json'
          }
        }
      );
    }

    res.status(200).send({ success: true });
  } catch (error) {
    console.error('検証エラー:', error);
    res.status(500).send({ error: '検証に失敗しました' });
  }
});

import requests
from flask import Flask, request

app = Flask(__name__)

BILLIONVERIFY_API_KEY = 'your_billionverify_api_key'
MAILCHIMP_API_KEY = 'your_mailchimp_api_key'
MAILCHIMP_SERVER = MAILCHIMP_API_KEY.split('-')[1]

@app.route('/webhook/mailchimp-subscribe', methods=['POST'])
def verify_mailchimp_subscriber():
    data = request.json.get('data', {})
    email = data.get('email')
    list_id = data.get('list_id')
    subscriber_id = data.get('subscriber_id')

    # ステップ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：Mailchimp購読者を更新
    mailchimp_url = f'https://{MAILCHIMP_SERVER}.api.mailchimp.com/3.0/lists/{list_id}/members/{subscriber_id}'

    if result['status'] == 'valid' and result['risk_level'] == 'low':
        update_data = {
            'status': 'subscribed',
            'merge_fields': {
                'EMAILSTAT': 'verified',
                'RISKLEVEL': 'low'
            },
            'tags': ['verified']
        }
    elif result['status'] == 'invalid':
        update_data = {
            'status': 'unsubscribed',
            'merge_fields': {
                'EMAILSTAT': 'invalid'
            },
            'tags': ['invalid']
        }
    else:
        update_data = {
            'merge_fields': {
                'EMAILSTAT': 'risky',
                'RISKLEVEL': result['risk_level']
            },
            'tags': ['needs-review']
        }

    requests.patch(
        mailchimp_url,
        json=update_data,
        headers={
            'Authorization': f'Bearer {MAILCHIMP_API_KEY}',
            'Content-Type': 'application/json'
        }
    )

    return {'success': True}, 200

if __name__ == '__main__':
    app.run(port=5000)