mirror of
https://github.com/kyverno/kyverno.git
synced 2025-03-06 16:06:56 +00:00
3cf9141f4d
* 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 * initial commit * fix trailing quote in patch * remove comments * initial condition (equal & notequal) * initial support for conditions * initial support fo conditions in generate * support precondition checks * cleanup * re-evaluate GR on namespace update using dynamic informers * add status for generated resources * display loaded variable SA * support delete cleanup of generate request main resources * fix log * remove namespace from SA username * support multiple variables per statement for scalar values * fix fail variables * add check for userInfo * validation checks for conditions * update policy * refactor logs * code review * add openapispec for clusterpolicy preconditions * Update documentation * CR fixes * documentation * CR fixes * update variable * fix logs * update policy * pre-defined variables (serviceAccountName & serviceAccountNamespace) * update test
110 lines
2.3 KiB
Go
110 lines
2.3 KiB
Go
package context
|
|
|
|
import (
|
|
"reflect"
|
|
"testing"
|
|
|
|
kyverno "github.com/nirmata/kyverno/pkg/api/kyverno/v1"
|
|
authenticationv1 "k8s.io/api/authentication/v1"
|
|
)
|
|
|
|
func Test_addResourceAndUserContext(t *testing.T) {
|
|
rawResource := []byte(`
|
|
{
|
|
"apiVersion": "v1",
|
|
"kind": "Pod",
|
|
"metadata": {
|
|
"name": "image-with-hostpath",
|
|
"labels": {
|
|
"app.type": "prod",
|
|
"namespace": "my-namespace"
|
|
}
|
|
},
|
|
"spec": {
|
|
"containers": [
|
|
{
|
|
"name": "image-with-hostpath",
|
|
"image": "docker.io/nautiker/curl",
|
|
"volumeMounts": [
|
|
{
|
|
"name": "var-lib-etcd",
|
|
"mountPath": "/var/lib"
|
|
}
|
|
]
|
|
}
|
|
],
|
|
"volumes": [
|
|
{
|
|
"name": "var-lib-etcd",
|
|
"emptyDir": {}
|
|
}
|
|
]
|
|
}
|
|
}
|
|
`)
|
|
|
|
userInfo := authenticationv1.UserInfo{
|
|
Username: "system:serviceaccount:nirmata:user1",
|
|
UID: "014fbff9a07c",
|
|
}
|
|
userRequestInfo := kyverno.RequestInfo{
|
|
Roles: nil,
|
|
ClusterRoles: nil,
|
|
AdmissionUserInfo: userInfo}
|
|
|
|
var expectedResult string
|
|
ctx := NewContext()
|
|
ctx.AddResource(rawResource)
|
|
result, err := ctx.Query("request.object.apiVersion")
|
|
if err != nil {
|
|
t.Error(err)
|
|
}
|
|
expectedResult = "v1"
|
|
t.Log(result)
|
|
if !reflect.DeepEqual(expectedResult, result) {
|
|
t.Error("exected result does not match")
|
|
}
|
|
|
|
ctx.AddUserInfo(userRequestInfo)
|
|
result, err = ctx.Query("request.object.apiVersion")
|
|
if err != nil {
|
|
t.Error(err)
|
|
}
|
|
expectedResult = "v1"
|
|
t.Log(result)
|
|
if !reflect.DeepEqual(expectedResult, result) {
|
|
t.Error("exected result does not match")
|
|
}
|
|
|
|
result, err = ctx.Query("request.userInfo.username")
|
|
if err != nil {
|
|
t.Error(err)
|
|
}
|
|
expectedResult = "system:serviceaccount:nirmata:user1"
|
|
t.Log(result)
|
|
if !reflect.DeepEqual(expectedResult, result) {
|
|
t.Error("exected result does not match")
|
|
}
|
|
// Add service account Name
|
|
ctx.AddSA(userRequestInfo.AdmissionUserInfo.Username)
|
|
result, err = ctx.Query("serviceAccountName")
|
|
if err != nil {
|
|
t.Error(err)
|
|
}
|
|
expectedResult = "user1"
|
|
t.Log(result)
|
|
if !reflect.DeepEqual(expectedResult, result) {
|
|
t.Error("exected result does not match")
|
|
}
|
|
|
|
// Add service account Namespace
|
|
result, err = ctx.Query("serviceAccountNamespace")
|
|
if err != nil {
|
|
t.Error(err)
|
|
}
|
|
expectedResult = "nirmata"
|
|
t.Log(result)
|
|
if !reflect.DeepEqual(expectedResult, result) {
|
|
t.Error("exected result does not match")
|
|
}
|
|
}
|