managarten/apps/bauntown/apps/landing/netlify/functions/process-payment-webhook.js

// Netlify Function für Webhooks von Stripe und PayPal

exports.handler = async (event, context) => {
  // CORS Headers
  const headers = {
    "Access-Control-Allow-Origin": "*",
    "Access-Control-Allow-Headers": "Content-Type",
    "Access-Control-Allow-Methods": "POST, OPTIONS"
  };
  
  // Handle OPTIONS request (CORS preflight)
  if (event.httpMethod === "OPTIONS") {
    return {
      statusCode: 200,
      headers,
      body: ""
    };
  }

  // Den Webhook-Source aus URL-Parameter oder Header bestimmen
  const source = event.queryStringParameters.source || 'unknown';
  
  try {
    if (source === 'stripe') {
      // Stripe Webhook verarbeiten
      return processStripeWebhook(event, headers);
    } else if (source === 'paypal') {
      // PayPal Webhook verarbeiten
      return processPayPalWebhook(event, headers);
    } else {
      return {
        statusCode: 400,
        headers,
        body: JSON.stringify({
          error: {
            message: `Unknown webhook source: ${source}`
          }
        })
      };
    }
  } catch (error) {
    console.error(`Webhook error (${source}):`, error);
    
    return {
      statusCode: 500,
      headers,
      body: JSON.stringify({
        error: {
          message: error.message || 'Internal server error'
        }
      })
    };
  }
};

// Stripe Webhook verarbeiten
async function processStripeWebhook(event, headers) {
  // In einer echten Anwendung würden Sie hier die Stripe Signatur überprüfen
  // const stripe = require('stripe')(process.env.STRIPE_SECRET_KEY);
  // const sig = event.headers['stripe-signature'];
  // const endpointSecret = process.env.STRIPE_WEBHOOK_SECRET;
  
  try {
    const data = JSON.parse(event.body);
    
    // Verschiedene Ereignistypen verarbeiten
    switch (data.type) {
      case 'payment_intent.succeeded':
        // Zahlung erfolgreich - hier könnte eine Datenbank aktualisiert werden
        console.log('Payment succeeded:', data.data.object.id);
        break;
        
      case 'payment_intent.payment_failed':
        // Zahlung fehlgeschlagen
        console.log('Payment failed:', data.data.object.id);
        break;
        
      // Weitere Event-Typen hier verarbeiten
      
      default:
        console.log('Unhandled Stripe event type:', data.type);
    }
    
    return {
      statusCode: 200,
      headers,
      body: JSON.stringify({ received: true })
    };
  } catch (error) {
    console.error('Error processing Stripe webhook:', error);
    return {
      statusCode: 400,
      headers,
      body: JSON.stringify({
        error: {
          message: error.message
        }
      })
    };
  }
}

// PayPal Webhook verarbeiten
async function processPayPalWebhook(event, headers) {
  // In einer echten Anwendung würden Sie hier die PayPal-Signatur verifizieren
  
  try {
    const data = JSON.parse(event.body);
    
    // Verschiedene Ereignistypen verarbeiten
    switch (data.event_type) {
      case 'PAYMENT.CAPTURE.COMPLETED':
        // Zahlung erfolgreich - hier könnte eine Datenbank aktualisiert werden
        console.log('PayPal payment completed:', data.resource.id);
        break;
        
      case 'PAYMENT.CAPTURE.DENIED':
        // Zahlung abgelehnt
        console.log('PayPal payment denied:', data.resource.id);
        break;
        
      // Weitere Event-Typen hier verarbeiten
      
      default:
        console.log('Unhandled PayPal event type:', data.event_type);
    }
    
    return {
      statusCode: 200,
      headers,
      body: JSON.stringify({ received: true })
    };
  } catch (error) {
    console.error('Error processing PayPal webhook:', error);
    return {
      statusCode: 400,
      headers,
      body: JSON.stringify({
        error: {
          message: error.message
        }
      })
    };
  }
}