Webhook Configuration

package main

import (
    "encoding/json"
    "fmt"
    "io"
    "net/http"
)

type WebhookPayload struct {
    Event     string  `json:"event"`
    OrderID   string  `json:"order_id"`
    Amount    float64 `json:"amount"`
    Currency  string  `json:"currency"`
    Status    string  `json:"status"`
    Timestamp int64   `json:"timestamp"`
}

func webhookHandler(w http.ResponseWriter, r *http.Request) {
    // Read the request body
    body, err := io.ReadAll(r.Body)
    if err != nil {
        http.Error(w, "Failed to read request body", http.StatusBadRequest)
        return
    }
    defer r.Body.Close()

    // Parse webhook payload
    var payload WebhookPayload
    if err := json.Unmarshal(body, &payload); err != nil {
        http.Error(w, "Invalid JSON", http.StatusBadRequest)
        return
    }

    // Process the webhook event
    switch payload.Event {
    case "payment.success":
        fmt.Printf("Payment successful: %s\n", payload.OrderID)
        // Update your database, send confirmation email, etc.
    case "payment.failed":
        fmt.Printf("Payment failed: %s\n", payload.OrderID)
        // Handle failed payment
    case "refund.completed":
        fmt.Printf("Refund completed: %s\n", payload.OrderID)
        // Update order status
    }

    // Respond with 200 OK
    w.WriteHeader(http.StatusOK)
    w.Write([]byte(`{"status":"received"}`))
}

func main() {
    http.HandleFunc("/webhooks/dvpay", webhookHandler)
    fmt.Println("Webhook server listening on :8080")
    http.ListenAndServe(":8080", nil)
}

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

// Middleware to parse JSON
app.use(express.json());

app.post('/webhooks/dvpay', (req, res) => {
  const payload = req.body;

  console.log('Received webhook event:', payload.event);

  // Process webhook events
  switch (payload.event) {
    case 'payment.success':
      console.log(`Payment successful: ${payload.order_id}`);
      // Update your database, send confirmation email, etc.
      break;

    case 'payment.failed':
      console.log(`Payment failed: ${payload.order_id}`);
      // Handle failed payment
      break;

    case 'refund.completed':
      console.log(`Refund completed: ${payload.order_id}`);
      // Update order status
      break;

    default:
      console.log(`Unknown event: ${payload.event}`);
  }

  // Always respond with 200 OK
  res.status(200).json({ status: 'received' });
});

const PORT = process.env.PORT || 8080;
app.listen(PORT, () => {
  console.log(`Webhook server listening on port ${PORT}`);
});