Wrp validation update

primaryHandler.go

@@ -392,7 +392,7 @@
 		otelmux.WithPropagators(tracing.Propagator()),
 		otelmux.WithTracerProvider(tracing.TracerProvider()),
 	}
-	router.Use(otelmux.Middleware("mainSpan", otelMuxOptions...), candlelight.EchoFirstTraceNodeInfo(tracing.Propagator(), true), ValidateWRP())
+	router.Use(otelmux.Middleware("mainSpan", otelMuxOptions...), candlelight.EchoFirstTraceNodeInfo(tracing.Propagator(), true), ValidateWRP(logger))
 
 	router.NotFoundHandler = http.HandlerFunc(func(response http.ResponseWriter, _ *http.Request) {
 		xhttp.WriteError(response, http.StatusBadRequest, "Invalid endpoint")
@@ -563,26 +563,31 @@
 	})
 }
 
-func ValidateWRP() func(http.Handler) http.Handler {
+func ValidateWRP(logger *zap.Logger) func(http.Handler) http.Handler {
 	return func(delegate http.Handler) http.Handler {
 		return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
 
 			if msg, ok := wrpcontext.GetMessage(r.Context()); ok {
-				validators := wrp.SpecValidators()
 				var err error
+
+				validators := wrp.SpecValidators()
 				for _, v := range validators {
 					err = multierr.Append(err, v.Validate(*msg))
 				}
+
 				if err != nil {
-					w.Header().Set("Content-Type", "application/json")
-					w.WriteHeader(http.StatusBadRequest)
-					fmt.Fprintf(
-						w,
-						`{"code": %d, "message": "%s"}`,
-						http.StatusBadRequest,
-						fmt.Sprintf("failed to validate WRP message: %s", err),
-					)
-					return
+					if errors.Is(err, wrp.ErrorInvalidMessageEncoding.Err) || errors.Is(err, wrp.ErrorInvalidMessageType.Err) {
+						w.Header().Set("Content-Type", "application/json")
+						w.WriteHeader(http.StatusBadRequest)
+						fmt.Fprintf(
+							w,
+							`{"code": %d, "message": "%s"}`,
+							http.StatusBadRequest,
+							fmt.Sprintf("failed to validate WRP message: %s", err))
+						return
+					} else if errors.Is(err, wrp.ErrorInvalidDestination) || errors.Is(err, wrp.ErrorInvalidSource.Err) {
+						logger.Warn("WRP message validation failures found", zap.Error(err))
+					}
 				}
 			}