shop.tonybtw.com

package handlers

import (

	"encoding/json"

	"io"

	"net/http"

	"shop.tonybtw.com/internal/lib"

	"shop.tonybtw.com/internal/models"

)

type Webhook_Handler struct {

	ctx *lib.App_Context

}

func New_Webhook_Handler(ctx *lib.App_Context) *Webhook_Handler {

	return &Webhook_Handler{ctx: ctx}

}

func (h *Webhook_Handler) Handle_Stripe(w http.ResponseWriter, r *http.Request) {

	payload, err := io.ReadAll(r.Body)

	if err != nil {

		http.Error(w, "Invalid payload", http.StatusBadRequest)

		return

	}

	sig_header := r.Header.Get("Stripe-Signature")

	event, err := lib.Verify_Webhook(payload, sig_header)

	if err != nil {

		http.Error(w, "Invalid signature", http.StatusBadRequest)

		return

	}

	event_type, _ := event["type"].(string)

	if event_type == "checkout.session.completed" {

		data := event["data"].(map[string]interface{})

		session_obj := data["object"].(map[string]interface{})

		h.handle_checkout_complete(session_obj)

	}

	w.Header().Set("Content-Type", "application/json")

	json.NewEncoder(w).Encode(map[string]bool{"received": true})

}

func (h *Webhook_Handler) handle_checkout_complete(session map[string]interface{}) {

	shipping_details := map[string]interface{}{}

	if sd, ok := session["shipping_details"].(map[string]interface{}); ok {

		shipping_details = sd

	} else if s, ok := session["shipping"].(map[string]interface{}); ok {

		shipping_details = s

	}

	shipping_name := ""

	if name, ok := shipping_details["name"].(string); ok {

		shipping_name = name

	}

	shipping_address := ""

	if addr, ok := shipping_details["address"].(map[string]interface{}); ok {

		addr_bytes, _ := json.Marshal(addr)

		shipping_address = string(addr_bytes)

	}

	customer_details := session["customer_details"].(map[string]interface{})

	email := customer_details["email"].(string)

	order_id, err := models.Create_Order(

		h.ctx.DB,

		session["id"].(string),

		session["payment_intent"].(string),

		email,

		int(session["amount_total"].(float64)),

		"paid",

		shipping_name,

		shipping_address,

	)

	if err != nil {

		return

	}

	_ = order_id

}