From 2aa1739b3f53abcdde90681d7049bcaf1fdc463a Mon Sep 17 00:00:00 2001
From: cangui <canguijc@gmail.com>
Date: Fri, 9 May 2025 10:52:26 +0200
Subject: [PATCH] lellele

---
 backend/handlers/main.go | 35 +++++++++++++++++++++++++++++++++++
 backend/routes/routes.go |  1 +
 2 files changed, 36 insertions(+)

diff --git a/backend/handlers/main.go b/backend/handlers/main.go
index 09ab2ef..0a2937c 100644
--- a/backend/handlers/main.go
+++ b/backend/handlers/main.go
@@ -307,6 +307,41 @@ func WebhookVerifyHandler() http.HandlerFunc {
 		w.Write([]byte("Invalid verify token"))
 	}
 }
+func WebhookReceiveHandler(db *gorm.DB) http.HandlerFunc {
+	return func(w http.ResponseWriter, r *http.Request) {
+		var body map[string]interface{}
+		if err := json.NewDecoder(r.Body).Decode(&body); err != nil {
+			http.Error(w, "Invalid JSON", http.StatusBadRequest)
+			return
+		}
+
+		fmt.Println("📩 Webhook reçu :", body)
+
+		// Exemple de parsing
+		entry := body["entry"].([]interface{})[0].(map[string]interface{})
+		change := entry["changes"].([]interface{})[0].(map[string]interface{})
+		value := change["value"].(map[string]interface{})
+
+		messages := value["messages"].([]interface{})
+		if len(messages) > 0 {
+			msg := messages[0].(map[string]interface{})
+			from := msg["from"].(string)
+			msgType := msg["type"].(string)
+
+			var content string
+			if msgType == "text" {
+				content = msg["text"].(map[string]interface{})["body"].(string)
+			}
+
+			fmt.Printf("💬 Message reçu de %s : %s\n", from, content)
+
+			// TODO : enregistrer en base
+		}
+
+		w.WriteHeader(http.StatusOK)
+	}
+}
+
 func CreateUser(db *gorm.DB) http.HandlerFunc {
 	return func(w http.ResponseWriter, r *http.Request) {
 		var user models.User
diff --git a/backend/routes/routes.go b/backend/routes/routes.go
index 79a8c1d..e452572 100644
--- a/backend/routes/routes.go
+++ b/backend/routes/routes.go
@@ -21,6 +21,7 @@ func RoutesPublic(r *mux.Router, db *gorm.DB) {
     // Page de login
     r.HandleFunc("/login", renders.Login)
     r.HandleFunc("/api/whatsapp/webhook", handlers.WebhookVerifyHandler()).Methods("GET")
+    r.HandleFunc("/api/whatsapp/webhook", handlers.WebhookReceiveHandler(db)).Methods("POST")
 
     // Endpoint d'API pour se logger
     r.HandleFunc("/api/login", handlers.LoginHandler(db)).Methods("POST")