add catch all handler for k8s

joshrendek · Nov 15, 2024 · 5e10c74 · 5e10c74
1 parent 00d31f4
commit 5e10c74
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 0 deletions.
diff --git a/kubernetes/handlers.go b/kubernetes/handlers.go
@@ -69,6 +69,12 @@ func (h *honeypot) apiHandler(w http.ResponseWriter, r *http.Request) {
   json.NewEncoder(w).Encode(response)
 }
 
+func (h *honeypot) catchAllHandler(w http.ResponseWriter, r *http.Request) {
+  body := make([]byte, r.ContentLength)
+  _, _ = r.Body.Read(body)
+  h.logger.Info().Str("path", r.URL.Path).Str("method", r.Method).Bytes("body", body).Msg("Request received")
+}
+
 // Handler for /api/v1
 func (h *honeypot) apiV1Handler(w http.ResponseWriter, r *http.Request) {
   response := map[string]interface{}{

diff --git a/kubernetes/k8s.go b/kubernetes/k8s.go
@@ -62,6 +62,10 @@ func (h *honeypot) Start() {
 
 	// Handle /api/v1/namespaces/{namespace}/pods
 	router.HandleFunc("/api/v1/namespaces/{namespace}/pods", h.podsHandler).Methods("GET", "POST")
+  // add a catch all route and log the request and body
+  router.PathPrefix("/").HandlerFunc(h.catchAllHandler).Methods("GET", "POST")
+
+
 
 	// Generate the TLS certificate
 	cert, err := generateSelfSignedCert()