feat: add validate interceptor

Author: sysulq

interceptor/kvalidate/validate.go

@@ -0,0 +1,24 @@
+package kvalidate
+
+import (
+	"context"
+	"fmt"
+
+	"github.com/go-kod/kod"
+	"github.com/go-playground/validator/v10"
+)
+
+// Interceptor returns a interceptor that validates the call specified by info.
+func Interceptor() kod.Interceptor {
+	validate := validator.New()
+
+	return func(ctx context.Context, info kod.CallInfo, req, reply []any, invoker kod.HandleFunc) error {
+		for _, v := range req {
+			if err := validate.Struct(v); err != nil {
+				return fmt.Errorf("validate failed: %w", err)
+			}
+		}
+
+		return invoker(ctx, info, req, reply)
+	}
+}

tests/case1/case.go

@@ -16,6 +16,7 @@ import (
 	"github.com/go-kod/kod/interceptor/krecovery"
 	"github.com/go-kod/kod/interceptor/ktimeout"
 	"github.com/go-kod/kod/interceptor/ktrace"
+	"github.com/go-kod/kod/interceptor/kvalidate"
 	"github.com/samber/lo"
 	"go.opentelemetry.io/otel"
 	"go.opentelemetry.io/otel/baggage"
@@ -73,6 +74,7 @@ func (t *test1Component) Interceptors() []kod.Interceptor {
 		kratelimit.Interceptor(),
 		kaccesslog.Interceptor(),
 		kcircuitbreaker.Interceptor(),
+		kvalidate.Interceptor(),
 		ktimeout.Interceptor(ktimeout.WithTimeout(time.Second)),
 	}
 }
@@ -82,7 +84,7 @@ func (t *test1Component) Stop(ctx context.Context) error {
 }
 
 type FooReq struct {
-	Id    int
+	Id    int `validate:"lt=100"`
 	Panic bool
 }
 

tests/case1/case_test.go

@@ -72,6 +72,17 @@ func TestInterfacePanic(t *testing.T) {
 	})
 }
 
+func TestInterfacValidate(t *testing.T) {
+	t.Parallel()
+	kod.RunTest(t, func(ctx context.Context, k Test1Component) {
+
+		_, err := k.Foo(ctx, &FooReq{
+			Id: 101,
+		})
+		assert.Contains(t, err.Error(), "validate failed: Key: 'FooReq.Id' Error:Field validation for 'Id' failed on the 'lt' tag")
+	})
+}
+
 func TestFake(t *testing.T) {
 	t.Parallel()
 	fakeTest1 := &fakeTest1Component{"B"}