feat: wip admission controller

admission.go

@@ -4,6 +4,7 @@ import (
 	"cmp"
 	"context"
 	"iter"
+	"log"
 	"slices"
 )
 
@@ -14,6 +15,7 @@ type hook struct {
 type ValidationTree interface {
 	Has(method, path string) bool
 	Route(method, path string) *Route
+	Iter() Iter
 }
 
 type MutationTree interface {
@@ -34,13 +36,27 @@ type ValidationRoute interface {
 type MutationRoute interface {
 	ValidationRoute
 	SetPath(path string)
-	PatchAnnotation(fn func(annotations iter.Seq[Annotation]) iter.Seq[Annotation])
+	PatchAnnotations(fn func(annotations iter.Seq[Annotation]) iter.Seq[Annotation])
 	// TODO Patch middleware
 	SetRedirectTrailingSlash(enable bool)
 	SetIgnoreTrailingSlash(enable bool)
 	SetClientIPStrategy(strategy ClientIPStrategy)
 }
 
+type AdmissionController interface {
+	Handles(operation Operation) bool
+	Admit(ctx context.Context, tree MutationTree, route MutationRoute) (err error)
+	Validate(ctx context.Context, tree ValidationTree, route ValidationRoute) (err error)
+}
+
+type Operation uint8
+
+const (
+	Insert Operation = iota
+	Update
+	Delete
+)
+
 type mutationRoute struct {
 	*Route
 }
@@ -49,7 +65,7 @@ func (r mutationRoute) SetPath(path string) {
 	r.path = path
 }
 
-func (r mutationRoute) PatchAnnotation(fn func(annotations iter.Seq[Annotation]) iter.Seq[Annotation]) {
+func (r mutationRoute) PatchAnnotations(fn func(annotations iter.Seq[Annotation]) iter.Seq[Annotation]) {
 	r.annots = slices.Collect(fn(slices.Values(r.annots)))
 }
 
@@ -65,16 +81,37 @@ func (r mutationRoute) SetClientIPStrategy(strategy ClientIPStrategy) {
 	r.ipStrategy = cmp.Or(strategy, ClientIPStrategy(noClientIPStrategy{}))
 }
 
-type AdmissionController interface {
-	Handles(operation Operation) bool
-	Admit(ctx context.Context, tree MutationTree, route MutationRoute) (err error)
-	Validate(ctx context.Context, tree ValidationTree, route ValidationRoute) (err error)
+type validationRoute struct {
+	*Route
 }
 
-type Operation uint8
+func newController() *controller {
+	c := &controller{
+		c: make(chan ValidationRoute),
+	}
 
-const (
-	Insert Operation = iota
-	Update
-	Delete
-)
+	go func(c <-chan ValidationRoute) {
+		for rte := range c {
+			log.Println(rte.Path())
+		}
+	}(c.c)
+
+	return c
+}
+
+type controller struct {
+	c chan ValidationRoute
+}
+
+func (c *controller) Handles(operation Operation) bool {
+	return operation == Insert || operation == Update
+}
+
+func (c *controller) Admit(ctx context.Context, tree MutationTree, route MutationRoute) (err error) {
+	return nil
+}
+
+func (c *controller) Validate(ctx context.Context, tree ValidationTree, route ValidationRoute) (err error) {
+	route.Annotations()
+	return nil
+}