mirror of
https://github.com/kyverno/kyverno.git
synced 2025-03-06 16:06:56 +00:00
ec95724e97
* update webhook registration and monitor * update log * fix test * improve logs * improve logs * format changes * decrease interval for webhook config checks
127 lines
3.7 KiB
Go
127 lines
3.7 KiB
Go
package client
|
|
|
|
import (
|
|
"context"
|
|
"testing"
|
|
|
|
"github.com/kyverno/kyverno/pkg/config"
|
|
meta "k8s.io/apimachinery/pkg/apis/meta/v1"
|
|
"k8s.io/apimachinery/pkg/runtime"
|
|
"k8s.io/apimachinery/pkg/runtime/schema"
|
|
)
|
|
|
|
// GetResource
|
|
// ListResource
|
|
// CreateResource
|
|
// getGroupVersionMapper (valid and invalid resources)
|
|
|
|
//NewMockClient creates a mock client
|
|
// - dynamic client
|
|
// - kubernetes client
|
|
// - objects to initialize the client
|
|
|
|
type fixture struct {
|
|
t *testing.T
|
|
objects []runtime.Object
|
|
client *Client
|
|
}
|
|
|
|
func newFixture(t *testing.T) *fixture {
|
|
// init groupversion
|
|
regResource := []schema.GroupVersionResource{
|
|
{Group: "group", Version: "version", Resource: "thekinds"},
|
|
{Group: "group2", Version: "version", Resource: "thekinds"},
|
|
{Group: "", Version: "v1", Resource: "namespaces"},
|
|
{Group: "apps", Version: "v1", Resource: "deployments"},
|
|
}
|
|
|
|
objects := []runtime.Object{newUnstructured("group/version", "TheKind", "ns-foo", "name-foo"),
|
|
newUnstructured("group2/version", "TheKind", "ns-foo", "name2-foo"),
|
|
newUnstructured("group/version", "TheKind", "ns-foo", "name-bar"),
|
|
newUnstructured("group/version", "TheKind", "ns-foo", "name-baz"),
|
|
newUnstructured("group2/version", "TheKind", "ns-foo", "name2-baz"),
|
|
newUnstructured("apps/v1", "Deployment", config.KyvernoNamespace, config.KyvernoDeploymentName),
|
|
}
|
|
scheme := runtime.NewScheme()
|
|
// Create mock client
|
|
client, err := NewMockClient(scheme, objects...)
|
|
if err != nil {
|
|
t.Fatal(err)
|
|
}
|
|
|
|
// set discovery Client
|
|
client.SetDiscovery(NewFakeDiscoveryClient(regResource))
|
|
|
|
f := fixture{
|
|
t: t,
|
|
objects: objects,
|
|
client: client,
|
|
}
|
|
return &f
|
|
|
|
}
|
|
|
|
func TestCRUDResource(t *testing.T) {
|
|
f := newFixture(t)
|
|
// Get Resource
|
|
_, err := f.client.GetResource("", "thekind", "ns-foo", "name-foo")
|
|
if err != nil {
|
|
t.Errorf("GetResource not working: %s", err)
|
|
}
|
|
// List Resources
|
|
_, err = f.client.ListResource("", "thekind", "ns-foo", nil)
|
|
if err != nil {
|
|
t.Errorf("ListResource not working: %s", err)
|
|
}
|
|
// DeleteResouce
|
|
err = f.client.DeleteResource("", "thekind", "ns-foo", "name-bar", false)
|
|
if err != nil {
|
|
t.Errorf("DeleteResouce not working: %s", err)
|
|
}
|
|
// CreateResource
|
|
_, err = f.client.CreateResource("", "thekind", "ns-foo", newUnstructured("group/version", "TheKind", "ns-foo", "name-foo1"), false)
|
|
if err != nil {
|
|
t.Errorf("CreateResource not working: %s", err)
|
|
}
|
|
// UpdateResource
|
|
_, err = f.client.UpdateResource("", "thekind", "ns-foo", newUnstructuredWithSpec("group/version", "TheKind", "ns-foo", "name-foo1", map[string]interface{}{"foo": "bar"}), false)
|
|
if err != nil {
|
|
t.Errorf("UpdateResource not working: %s", err)
|
|
}
|
|
// UpdateStatusResource
|
|
_, err = f.client.UpdateStatusResource("", "thekind", "ns-foo", newUnstructuredWithSpec("group/version", "TheKind", "ns-foo", "name-foo1", map[string]interface{}{"foo": "status"}), false)
|
|
if err != nil {
|
|
t.Errorf("UpdateStatusResource not working: %s", err)
|
|
}
|
|
}
|
|
|
|
func TestEventInterface(t *testing.T) {
|
|
f := newFixture(t)
|
|
iEvent, err := f.client.GetEventsInterface()
|
|
if err != nil {
|
|
t.Errorf("GetEventsInterface not working: %s", err)
|
|
}
|
|
_, err = iEvent.List(context.TODO(), meta.ListOptions{})
|
|
if err != nil {
|
|
t.Errorf("Testing Event interface not working: %s", err)
|
|
}
|
|
}
|
|
func TestCSRInterface(t *testing.T) {
|
|
f := newFixture(t)
|
|
iCSR, err := f.client.GetCSRInterface()
|
|
if err != nil {
|
|
t.Errorf("GetCSRInterface not working: %s", err)
|
|
}
|
|
_, err = iCSR.List(context.TODO(), meta.ListOptions{})
|
|
if err != nil {
|
|
t.Errorf("Testing CSR interface not working: %s", err)
|
|
}
|
|
}
|
|
|
|
func TestKubePolicyDeployment(t *testing.T) {
|
|
f := newFixture(t)
|
|
_, err := f.client.GetKubePolicyDeployment()
|
|
if err != nil {
|
|
t.Fatal(err)
|
|
}
|
|
}
|