BillionVerify + Klaviyo 整合 - 驗證電商客戶信箱

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('Verification error:', error);
    res.status(500).send({ error: 'Verification failed' });
  }
});

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)