Webhooks

app.post('/webhook/safepays', express.json(), async (req, res) => {
  try {
    const { invoice } = req.body;

    switch (invoice.status) {
      case 'Paid':
        await handlePaymentSuccess(invoice);
        break;
      case 'Failed':
        await handlePaymentFailed(invoice);
        break;
    }

    res.status(200).json({ received: true });
  } catch (error) {
    console.error('Webhook error:', error);
    res.status(500).send('Webhook processing failed');
  }
});

async function handlePaymentSuccess(invoice) {
  await db.invoices.update({
    where: { external_id: invoice.id },
    data: {
      status: 'paid',
      paid_at: invoice.paid_on
    }
  });

  await sendPaymentConfirmation(invoice.email, invoice);
}

async function handlePaymentFailed(invoice) {
  await db.payment_failures.create({
    invoice_id: invoice.id,
    failed_at: new Date()
  });

  await sendPaymentFailedEmail(invoice.email, invoice);
}

from flask import Flask, request, jsonify

app = Flask(__name__)

@app.route('/webhook/safepays', methods=['POST'])
def safepays_webhook():
    try:
        data = request.get_json()
        invoice = data.get('invoice')

        if invoice['status'] == 'Paid':
            handle_payment_success(invoice)
        elif invoice['status'] == 'Failed':
            handle_payment_failed(invoice)

        return jsonify({'received': True}), 200

    except Exception as e:
        print(f'Webhook error: {e}')
        return jsonify({'error': 'Webhook processing failed'}), 500

def handle_payment_success(invoice):
    db.execute(
        "UPDATE invoices SET status = 'paid', paid_at = %s WHERE external_id = %s",
        (invoice['paid_on'], invoice['id'])
    )
    send_payment_confirmation(invoice['email'], invoice)

def handle_payment_failed(invoice):
    db.execute(
        "INSERT INTO payment_failures (invoice_id, failed_at) VALUES (%s, NOW())",
        (invoice['id'],)
    )
    send_payment_failed_email(invoice['email'], invoice)

<?php
$payload = file_get_contents('php://input');
$data = json_decode($payload, true);
$invoice = $data['invoice'] ?? [];

try {
    switch ($invoice['status'] ?? '') {
        case 'Paid':
            handlePaymentSuccess($invoice);
            break;
        case 'Failed':
            handlePaymentFailed($invoice);
            break;
    }

    http_response_code(200);
    echo json_encode(['received' => true]);

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

function handlePaymentSuccess($invoice) {
    global $db;
    $stmt = $db->prepare(
        "UPDATE invoices SET status = 'paid', paid_at = ? WHERE external_id = ?"
    );
    $stmt->execute([$invoice['paid_on'], $invoice['id']]);
    sendPaymentConfirmation($invoice['email'], $invoice);
}

function handlePaymentFailed($invoice) {
    global $db;
    $stmt = $db->prepare(
        "INSERT INTO payment_failures (invoice_id, failed_at) VALUES (?, NOW())"
    );
    $stmt->execute([$invoice['id']]);
    sendPaymentFailedEmail($invoice['email'], $invoice);
}
?>