feat: stream validate

TencentBlueKing · Feb 28, 2025 · 980aad5 · 980aad5
1 parent eca9639
commit 980aad5
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/bcs-services/bcs-monitor/pkg/rest/rest.go b/bcs-services/bcs-monitor/pkg/rest/rest.go
@@ -270,6 +270,12 @@ func Stream[In any](handler StreamHandlerFunc[In]) func(w http.ResponseWriter, r
 			_ = render.Render(w, r, AbortWithJSONError(restContext, err))
 			return
 		}
+		err = Struct(r.Context(), in)
+		if err != nil {
+			blog.Errorf("valid request param failed, err: %s", err)
+			_ = render.Render(w, r, AbortWithJSONError(restContext, err))
+			return
+		}
 		svr := &streamingServer{
 			ResponseWriter:     w,
 			ResponseController: http.NewResponseController(w),