API de Integración BiPe Alerta

// Servidor Express para recibir webhooks de BiPe Alerta
const express = require('express');
const bodyParser = require('body-parser');
const app = express();
const PORT = process.env.PORT || 3000;

// Middleware para analizar JSON
app.use(bodyParser.json());

// Endpoint para recibir webhooks de Yape
app.post('/api/webhooks/yape', async (req, res) => {
                        try {
                        const webhook = req.body;
    
                        // Registra la recepción del webhook
    console.log(`Webhook recibido: Pago ${webhook.Tipo} de ${webhook.NombreCliente} por S/${webhook.Monto}`);
    
                        // Procesa la notificación
                        await processPaymentNotification(webhook);
    
                        // Responde con éxito
    res.status(200).json({ success: true });
  } catch (error) {
    console.error('Error al procesar el webhook:', error);
    res.status(500).json({ 
      success: false, 
      error: 'Error al procesar la notificación' 
    });
  }
});

// Función para procesar las notificaciones de pago
async function processPaymentNotification(webhook) {
                        // Aquí va tu lógica para procesar el pago
  // Por ejemplo:
  // - Actualizar el estado de un pedido en la base de datos
  // - Enviar una notificación al cliente o vendedor
  // - Generar un comprobante o factura
  // - etc.
  
                        // Ejemplo: Verificar estado del pago
                        if (webhook.Estado === "Completado") {
                        // Actualiza el estado del pedido o inventario
  }
}

// Iniciar el servidor
app.listen(PORT, () => {
  console.log(`Servidor de webhooks escuchando en el puerto ${PORT}`);
});

# Servidor Flask para recibir webhooks de BiPe Alerta
from flask import Flask, request, jsonify
import logging
from datetime import datetime

# Configuración de logging
logging.basicConfig(
    level=logging.INFO,
    format='%(asctime)s - %(name)s - %(levelname)s - %(message)s'
)
logger = logging.getLogger('bipe-webhook')

app = Flask(__name__)

# Endpoint para recibir webhooks de Yape
@app.route('/api/webhooks/yape', methods=['POST'])
def yape_webhook():
                        # Obtener el JSON recibido
    webhook_data = request.json
    
                        # Registrar la notificación recibida
    logger.info(
                        f"Webhook recibido: Pago {webhook_data.get('Tipo')} de"
                        f" {webhook_data.get('NombreCliente')} por S/{webhook_data.get('Monto')}"
    )
    
                        # Procesar la notificación
    process_payment_notification(webhook_data)
    
                        # Responder con éxito
                        return jsonify({"success": True})

def process_payment_notification(webhook_data):
                        # Extraer información relevante
    payment_id = webhook_data.get('Id')
    client_name = webhook_data.get('NombreCliente')
    amount = webhook_data.get('Monto')
    payment_type = webhook_data.get('Tipo')
    payment_status = webhook_data.get('Estado')
    
                        # Convertir la fecha y hora
                        try:
        payment_datetime = datetime.fromisoformat(webhook_data.get('FechaHora').replace('Z', '+00:00'))
                        except ValueError:
        payment_datetime = datetime.now()  # Valor predeterminado si hay error de formato
    
                        # Implementa tu lógica de negocio aquí
    # Por ejemplo:
    # - Actualizar estado de pedidos en la base de datos
    # - Enviar confirmaciones por correo electrónico
    # - Actualizar inventario
    # - etc.
    
                        # Ejemplo de lógica básica
                        if payment_status == "Completado":
        logger.info(f"Procesando pago completado #{payment_id} de {client_name}")
                        # Aquí actualizarías tu base de datos o sistema

if __name__ == '__main__':
    app.run(host='0.0.0.0', port=5000, debug=False)