mirror of
https://github.com/kyverno/kyverno.git
synced 2025-03-09 17:37:12 +00:00
ffd2179b03
* initial commit * background policy validation * correct message * skip non-background policy process for add/update * add Generate Request CR * generate Request Generator Initial * test generate request CR generation * initial commit gr generator * generate controller initial framework * add crd for generate request * gr cleanup controller initial commit * cleanup controller initial * generate mid-commit * generate rule processing * create PV on generate error * embed resource type * testing phase 1- generate resources with variable substitution * fix tests * comment broken test #586 * add printer column for state * return if existing resource for clone * set resync time to 2 mins & remove resource version check in update handler for gr * generate events for reporting * fix logs * cleanup * CR fixes * fix logs
125 lines
3.6 KiB
Go
125 lines
3.6 KiB
Go
package client
|
|
|
|
import (
|
|
"testing"
|
|
|
|
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{
|
|
schema.GroupVersionResource{Group: "group", Version: "version", Resource: "thekinds"},
|
|
schema.GroupVersionResource{Group: "group2", Version: "version", Resource: "thekinds"},
|
|
schema.GroupVersionResource{Group: "", Version: "v1", Resource: "namespaces"},
|
|
schema.GroupVersionResource{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", "kyverno", "kyverno"),
|
|
}
|
|
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(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(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)
|
|
}
|
|
}
|