Amazon Connect

import json
import requests  # Requires a Lambda Layer (e.g., AWSSDKPandas-Python311)
import base64
import traceback
from datetime import datetime
# ===============================================
# CONFIGURE YOUR MOENGAGE CREDENTIALS HERE
# ===============================================
# Find these in your MoEngage Dashboard: Settings -> Account -> APIs
WORKSPACE_ID = "YOUR_WORKSPACE_ID"  # e.g., "OAPQQ2AMD01MJZQ2TYZX1YPG"
DATA_API_KEY = "YOUR_DATA_API_KEY"  # From Settings → APIs → Data tile
API_DC = "01"                      # Your data center (01, 02, 03, etc.)
# -----------------------------------------------
 
def lambda_handler(event, context):
    """
    Amazon Connect to MoEngage Data Sync Handler
    This function processes contact data from Connect and sends it
    to the MoEngage Customer API to create/update a user.
    """
    try:
        # Log incoming event for debugging
        print(f"[INFO] Incoming Event: {json.dumps(event, indent=2)}")
        
        # --- 1. Extract Data from Amazon Connect ---
        details = event.get('Details', {})
        contact_data = details.get('ContactData', {})
        
        # User-defined attributes come from the 'Set Contact Attributes' block
        contact_attrs = contact_data.get('Attributes', {})
        
        # --- 2. Map Connect Data to Variables ---
        
        # Get user-defined attributes
        customer_id = contact_attrs.get('customer_id', '')
        email = contact_attrs.get('email', '')
        first_name = contact_attrs.get('first_name', '')
        
        # Get system-defined attributes
        phone = contact_data.get('CustomerEndpoint', {}).get('Address', '')
        contact_id = contact_data.get('ContactId', '')
        
        # Use a fallback identifier if customer_id is not set
        final_customer_id = customer_id or phone or email or contact_id
        if not final_customer_id:
            print("[ERROR] No customer_id, phone, or email found. Cannot sync user.")
            return {'success': False, 'error': 'Missing Identifier'}
 
        # --- 3. Prepare API Credentials ---
        auth_string = f"{WORKSPACE_ID}:{DATA_API_KEY}"
        BASIC_AUTH = base64.b64encode(auth_string.encode()).decode('utf-8')
        
        BASE_URL = f"https://api-{API_DC}.moengage.com/v1"
        headers = {
            'Authorization': f'Basic {BASIC_AUTH}',
            'Content-Type': 'application/json'
        }     
        # --- 4. Build MoEngage User Payload ---
        # This example sends data to the Customer API.
        user_payload = {
            "type": "customer",
            "customer_id": final_customer_id,
            "attributes": {
                "first_name": first_name,
                "email": email,
                "mobile": phone,
                "amazon_connect_contact_id": contact_id,
                "source": "amazon_connect"
            }
        } 
        # Remove any attributes that have empty values
        user_payload["attributes"] = {k: v for k, v in user_payload["attributes"].items() if v}
        
        # --- 5. Send User Data to MoEngage ---
        user_url = f"{BASE_URL}/customer/{WORKSPACE_ID}"
        print(f"[INFO] Sending to MoEngage User API: {user_url}")
        print(f"[INFO] User Payload: {json.dumps(user_payload, indent=2)}")
        
        response = requests.post(
            user_url, 
            json=user_payload, 
            headers=headers, 
            timeout=8 # Max 8-second timeout for Connect
        )
        
        print(f"[INFO] MoEngage API Response: {response.status_code}")
        print(f"[INFO] Response Body: {response.text}")
 
        # Check for HTTP errors (e.g., 401, 404, 500)
        response.raise_for_status() 
        
        # --- 6. Return Success to Amazon Connect ---
        return {
            'statusCode': response.status_code,
            'success': True,
            'customer_id': final_customer_id
        }
            
    except requests.exceptions.RequestException as http_err:
        print(f"[ERROR] HTTP Error: {str(http_err)}")
        print(traceback.format_exc())
        return {'success': False, 'error': f"HTTP Error: {str(http_err)}"}
        
    except Exception as e:
        print(f"[ERROR] Unexpected Error: {str(e)}")
        print(traceback.format_exc())
        return {'success': False, 'error': f"General Error: {str(e)}"}