from flask import Flask, request, jsonify
import logging

app = Flask(__name__)

@app.route('/webhook/threshold-alert', methods=['POST'])
def handle_threshold_alert():
    try:
        # Parse the webhook payload
        data = request.get_json()

        # Validate required fields
        if not all(k in data for k in ['event_uuid', 'type', 'batch_id', 'alerts']):
            return jsonify({'error': 'Missing required fields'}), 400

        # Verify the event type
        if data['type'] != 'BALANCE_THRESHOLD_ALERT':
            return jsonify({'error': 'Unexpected event type'}), 400

        # Process each alert
        for alert in data['alerts']:
            logging.info(
                f"Threshold met: {alert['authorizer_unique_id']} "
                f"has ${alert['balance']} (threshold: ${alert['threshold_amount']})"
            )
            # Take action - initiate payment, send notification, etc.
            process_threshold_alert(alert)

        # Return success response
        return jsonify({'status': 'received'}), 200

    except Exception as e:
        logging.error(f"Webhook processing error: {str(e)}")
        return jsonify({'error': 'Internal server error'}), 500

def process_threshold_alert(alert):
    # Initiate payment collection
    # Update your database
    # Send notifications
    pass