WIP: webhooks

Author: justinsb

Diff for: mockkubeapiserver/apiserver.go

@@ -50,10 +50,13 @@ func NewMockKubeAPIServer(addr string, options ...Option) (*MockKubeAPIServer, e
 		s.storage = storage
 	}
 
+	s.hookSystem = hooks.NewHooks()
+
 	// These hooks mock behaviour that would otherwise require full controllers
 	s.storage.AddStorageHook(&hooks.CRDHook{Storage: s.storage})
 	s.storage.AddStorageHook(&hooks.NamespaceHook{})
 	s.storage.AddStorageHook(&hooks.DeploymentHook{})
+	s.storage.AddStorageHook(&hooks.WebhookHook{Webhooks: s.hookSystem})
 
 	return s, nil
 }
@@ -64,11 +67,12 @@ type MockKubeAPIServer struct {
 
 	storage storage.Storage
 
-	hooks []Hook
+	httpHooks  []Hook
+	hookSystem *hooks.Webhooks
 }
 
 func (s *MockKubeAPIServer) AddHook(hook Hook) {
-	s.hooks = append(s.hooks, hook)
+	s.httpHooks = append(s.httpHooks, hook)
 }
 
 func (s *MockKubeAPIServer) StartServing() (net.Addr, error) {
@@ -95,7 +99,7 @@ func (s *MockKubeAPIServer) Stop() error {
 func (s *MockKubeAPIServer) ServeHTTP(w http.ResponseWriter, r *http.Request) {
 	ctx := r.Context()
 
-	for _, hook := range s.hooks {
+	for _, hook := range s.httpHooks {
 		op := &HTTPOperation{
 			Request: r,
 		}

Diff for: mockkubeapiserver/hooks/interceptwebhooks.go

@@ -0,0 +1,48 @@
+/*
+Copyright 2022 The Kubernetes Authors.
+
+Licensed under the Apache License, Version 2.0 (the "License");
+you may not use this file except in compliance with the License.
+You may obtain a copy of the License at
+
+    http://www.apache.org/licenses/LICENSE-2.0
+
+Unless required by applicable law or agreed to in writing, software
+distributed under the License is distributed on an "AS IS" BASIS,
+WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+See the License for the specific language governing permissions and
+limitations under the License.
+*/
+
+package hooks
+
+import (
+	"k8s.io/apimachinery/pkg/runtime"
+	"k8s.io/apimachinery/pkg/runtime/schema"
+	"k8s.io/klog/v2"
+	admissionregistrationv1 "sigs.k8s.io/kubebuilder-declarative-pattern/mockkubeapiserver/internal/api/admissionregistration/v1"
+	"sigs.k8s.io/kubebuilder-declarative-pattern/mockkubeapiserver/storage"
+)
+
+type WebhookHook struct {
+	Webhooks *Webhooks
+}
+
+func (s *WebhookHook) OnWatchEvent(ev *storage.WatchEvent) {
+	switch ev.GroupKind() {
+	case schema.GroupKind{Group: "admissionregistration.k8s.io", Kind: "MutatingWebhookConfiguration"}:
+
+		// 	// TODO: Deleted / changed webhooks
+
+		u := ev.Unstructured()
+
+		webhook := &admissionregistrationv1.MutatingWebhookConfiguration{}
+		if err := runtime.DefaultUnstructuredConverter.FromUnstructured(u.Object, webhook); err != nil {
+			klog.Fatalf("failed to parse webhook: %v", err)
+		}
+
+		if err := s.Webhooks.update(webhook); err != nil {
+			klog.Fatalf("failed to update webhook: %v", err)
+		}
+	}
+}