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

const express = require('express');
const app = express();

app.use(express.json());

app.post('/webhook/threshold-alert', async (req, res) => {
  try {
    const { event_uuid, type, batch_id, alerts } = req.body;

    // Validate required fields
    if (!event_uuid || !type || !batch_id || !alerts) {
      return res.status(400).json({ error: 'Missing required fields' });
    }

    // Verify the event type
    if (type !== 'BALANCE_THRESHOLD_ALERT') {
      return res.status(400).json({ error: 'Unexpected event type' });
    }

    // Process each alert
    for (const alert of alerts) {
      console.log(
        `Threshold met: ${alert.authorizer_unique_id} ` +
        `has $${alert.balance} (threshold: $${alert.threshold_amount})`
      );
      // Take action - initiate payment, send notification, etc.
      await processThresholdAlert(alert);
    }

    // Return success response
    res.status(200).json({ status: 'received' });

  } catch (error) {
    console.error('Webhook processing error:', error);
    res.status(500).json({ error: 'Internal server error' });
  }
});

async function processThresholdAlert(alert) {
  // Initiate payment collection
  // Update your database
  // Send notifications
}

app.listen(3000, () => {
  console.log('Webhook server listening on port 3000');
});

<?php
header('Content-Type: application/json');

// Get the webhook payload
$payload = file_get_contents('php://input');
$data = json_decode($payload, true);

// Validate JSON parsing
if (json_last_error() !== JSON_ERROR_NONE) {
    http_response_code(400);
    echo json_encode(['error' => 'Invalid JSON payload']);
    exit;
}

// Validate required fields
if (!isset($data['event_uuid']) || !isset($data['type']) ||
    !isset($data['batch_id']) || !isset($data['alerts'])) {
    http_response_code(400);
    echo json_encode(['error' => 'Missing required fields']);
    exit;
}

// Verify the event type
if ($data['type'] !== 'BALANCE_THRESHOLD_ALERT') {
    http_response_code(400);
    echo json_encode(['error' => 'Unexpected event type']);
    exit;
}

try {
    // Process each alert
    foreach ($data['alerts'] as $alert) {
        error_log(sprintf(
            "Threshold met: %s has $%s (threshold: $%s)",
            $alert['authorizer_unique_id'],
            $alert['balance'],
            $alert['threshold_amount']
        ));
        // Take action - initiate payment, send notification, etc.
        processThresholdAlert($alert);
    }

    // Return success response
    http_response_code(200);
    echo json_encode(['status' => 'received']);

} catch (Exception $e) {
    error_log("Webhook processing error: " . $e->getMessage());
    http_response_code(500);
    echo json_encode(['error' => 'Internal server error']);
}

function processThresholdAlert($alert) {
    // Initiate payment collection
    // Update your database
    // Send notifications
}
?>