package main
  
  import (
  	"encoding/json"
  	"fmt"
  	"io/ioutil"
  	"net/http"
  	"time"
  )
  
  // WebhookMessage for messages
  type WebhookMessage struct {
  	EventMeta EventMeta `json:"eventmeta"`
  	Text      string    `json:"text"`
  	Time      time.Time `json:"time"`
  }
  
  // EventMeta containes the meta data about the event occurred
  type EventMeta struct {
  	Kind      string `json:"kind"`
  	Name      string `json:"name"`
  	Namespace string `json:"namespace"`
  	Reason    string `json:"reason"`
  }
  
  func handler(w http.ResponseWriter, r *http.Request) {
  	// 读取请求主体
  	body, err := ioutil.ReadAll(r.Body)
  	if err != nil {
  		http.Error(w, "Error reading request body", http.StatusInternalServerError)
  		return
  	}
  
  	// 解码JSON数据到WebhookMessage结构体
  	var webhookMessage WebhookMessage
  	err = json.Unmarshal(body, &webhookMessage)
  	if err != nil {
  		http.Error(w, "Error decoding JSON", http.StatusBadRequest)
  		return
  	}
  
  	// 处理接收到的数据
  	fmt.Printf("Received Webhook Message: %+v\n", webhookMessage)
  
  	// 发送响应
  	w.WriteHeader(http.StatusOK)
  	w.Write([]byte("Success"))
  }
  
  func main() {
  	// 设置路由
  	http.HandleFunc("/webhook", handler)
  
  	// 启动HTTP服务器
  	port := 8080
  	fmt.Printf("Server listening on :%d\n", port)
  	err := http.ListenAndServe(fmt.Sprintf(":%d", port), nil)
  	if err != nil {
  		fmt.Printf("Error starting server: %s\n", err)
  	}
  }