BillionVerify + Klaviyo 連携 - eコマース顧客のメールアドレスを検証

Klaviyo Webhook
      ↓
バックエンドサーバー
      ↓
BillionVerify API
      ↓
Klaviyo API（プロフィール更新）

// 例：Klaviyoに追加されたときにメールを検証

const axios = require('axios');

// Klaviyo webhook ハンドラー
app.post('/webhook/klaviyo-profile-created', async (req, res) => {
  const { email, id: profile_id } = req.body.data.attributes;

  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：結果に基づいてKlaviyoのプロフィールを更新
    const klaviyoApiKey = process.env.KLAVIYO_PRIVATE_API_KEY;

    if (status === 'valid' && risk_level === 'low') {
      // 有効なメール - カスタムプロパティを更新
      await axios.post(
        'https://a.klaviyo.com/api/profile-import/',
        {
          profiles: [
            {
              email: email,
              $email_verification_status: 'verified',
              $email_risk_level: 'low',
              $email_verified_at: new Date().toISOString()
            }
          ]
        },
        {
          headers: {
            'Authorization': `Klaviyo-API-Key ${klaviyoApiKey}`,
            'Content-Type': 'application/json',
            'revision': '2024-10-15'
          }
        }
      );
    } else if (status === 'invalid') {
      // 無効なメール - プロフィールを抑制
      await axios.delete(
        `https://a.klaviyo.com/api/profiles/${profile_id}/`,
        {
          headers: {
            'Authorization': `Klaviyo-API-Key ${klaviyoApiKey}`,
            'revision': '2024-10-15'
          }
        }
      );
    } else {
      // リスクのあるメール - レビュー用にフラグ
      await axios.post(
        'https://a.klaviyo.com/api/profile-import/',
        {
          profiles: [
            {
              email: email,
              $email_verification_status: 'risky',
              $email_risk_level: risk_level,
              $is_disposable: is_disposable,
              $is_catch_all: is_catch_all,
              $is_role_account: is_role
            }
          ]
        },
        {
          headers: {
            'Authorization': `Klaviyo-API-Key ${klaviyoApiKey}`,
            'Content-Type': 'application/json',
            'revision': '2024-10-15'
          }
        }
      );
    }

    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'
KLAVIYO_API_KEY = 'your_klaviyo_private_api_key'

@app.route('/webhook/klaviyo-profile-created', methods=['POST'])
def verify_klaviyo_profile():
    data = request.json.get('data', {})
    attributes = data.get('attributes', {})
    email = attributes.get('email')
    profile_id = data.get('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：Klaviyoプロフィールを更新
    if result['status'] == 'valid' and result['risk_level'] == 'low':
        update_data = {
            'profiles': [
                {
                    'email': email,
                    '$email_verification_status': 'verified',
                    '$email_risk_level': 'low',
                    '$email_verified_at': datetime.now().isoformat()
                }
            ]
        }
        requests.post(
            'https://a.klaviyo.com/api/profile-import/',
            json=update_data,
            headers={
                'Authorization': f'Klaviyo-API-Key {KLAVIYO_API_KEY}',
                'Content-Type': 'application/json',
                'revision': '2024-10-15'
            }
        )
    elif result['status'] == 'invalid':
        requests.delete(
            f'https://a.klaviyo.com/api/profiles/{profile_id}/',
            headers={
                'Authorization': f'Klaviyo-API-Key {KLAVIYO_API_KEY}',
                'revision': '2024-10-15'
            }
        )
    else:
        update_data = {
            'profiles': [
                {
                    'email': email,
                    '$email_verification_status': 'risky',
                    '$email_risk_level': result['risk_level'],
                    '$is_disposable': result.get('is_disposable', False),
                    '$is_catch_all': result.get('is_catch_all', False),
                    '$is_role_account': result.get('is_role', False)
                }
            ]
        }
        requests.post(
            'https://a.klaviyo.com/api/profile-import/',
            json=update_data,
            headers={
                'Authorization': f'Klaviyo-API-Key {KLAVIYO_API_KEY}',
                'Content-Type': 'application/json',
                'revision': '2024-10-15'
            }
        )

    return {'success': True}, 200

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