mirror of
https://github.com/kyverno/kyverno.git
synced 2025-03-09 09:26:54 +00:00
a205bc3e2e
* Fix webhook rules equality when internal is empty The current implementation of the 'webhookRulesEqual' didn't check for the corner case were both the internal representation and the API have length of one, but the internal representation has 1 rule with no selectors. In this case the 'webhookRulesEqual' should return false, as the 2 configurations are not the same. Signed-off-by: Ioannis Bouloumpasis <buluba@arrikto.com> * Fix tests Add a small time delay when checking if a Policy is ready in tests to ensure that the Policy is actually ready. Signed-off-by: Ioannis Bouloumpasis <buluba@arrikto.com>
102 lines
2.5 KiB
Go
102 lines
2.5 KiB
Go
package common
|
|
|
|
import (
|
|
"bytes"
|
|
"fmt"
|
|
"os"
|
|
"strings"
|
|
"time"
|
|
|
|
"github.com/blang/semver/v4"
|
|
"github.com/kyverno/kyverno/test/e2e"
|
|
)
|
|
|
|
const defaultTestK8sVersion = "1.21.0"
|
|
|
|
func CallMetrics() (string, error) {
|
|
requestObj := e2e.APIRequest{
|
|
URL: "http://localhost:8000/metrics",
|
|
Type: "GET",
|
|
}
|
|
|
|
response, err := e2e.CallAPI(requestObj)
|
|
if err != nil {
|
|
return "", err
|
|
}
|
|
|
|
buf := new(bytes.Buffer)
|
|
_, err = buf.ReadFrom(response.Body)
|
|
if err != nil {
|
|
return "", err
|
|
}
|
|
|
|
newStr := buf.String()
|
|
return newStr, nil
|
|
}
|
|
|
|
func GetKubernetesVersion() semver.Version {
|
|
ver, err := semver.Parse(os.Getenv("K8S_VERSION"))
|
|
if err != nil {
|
|
return semver.MustParse(defaultTestK8sVersion)
|
|
}
|
|
return ver
|
|
}
|
|
|
|
// ProcessMetrics checks the metrics log and identify if the policy is added in cache or not
|
|
func ProcessMetrics(newStr, e2ePolicyName string) error {
|
|
splitByNewLine := strings.Split(newStr, "\n")
|
|
for _, lineSplitByNewLine := range splitByNewLine {
|
|
// kyverno_policy_rule_info_total{policy_background_mode=\"false\",policy_name=\"gen-cluster-policy\",policy_namespace=\"-\",policy_type=\"cluster\",policy_validation_mode=\"audit\",rule_name=\"gen-cluster-role\",rule_type=\"generate\",status_ready="false"} 1
|
|
if !strings.HasPrefix(lineSplitByNewLine, "kyverno_policy_rule_info_total{") {
|
|
continue
|
|
}
|
|
|
|
if !strings.HasSuffix(lineSplitByNewLine, "} 1") {
|
|
continue
|
|
}
|
|
|
|
splitByComma := strings.Split(lineSplitByNewLine, ",")
|
|
for _, lineSplitByComma := range splitByComma {
|
|
if strings.HasPrefix(lineSplitByComma, "policy_name=") {
|
|
splitByQuote := strings.Split(lineSplitByComma, "\"")
|
|
policyName := splitByQuote[1]
|
|
if policyName != e2ePolicyName {
|
|
continue
|
|
}
|
|
}
|
|
if strings.HasPrefix(lineSplitByComma, "status_ready=") {
|
|
splitByQuote := strings.Split(lineSplitByComma, "\"")
|
|
status := splitByQuote[1]
|
|
if status == "true" {
|
|
return nil
|
|
}
|
|
}
|
|
|
|
}
|
|
}
|
|
|
|
return fmt.Errorf("policy %s not found in metrics %s", e2ePolicyName, newStr)
|
|
}
|
|
|
|
func PolicyCreated(policyName string) error {
|
|
return e2e.GetWithRetry(1*time.Second, 60, checkPolicyCreated(policyName))
|
|
}
|
|
|
|
func checkPolicyCreated(policyName string) func() error {
|
|
return func() error {
|
|
var metricsString string
|
|
metricsString, err := CallMetrics()
|
|
if err != nil {
|
|
return fmt.Errorf("failed to get metrics: %v", err)
|
|
}
|
|
|
|
err = ProcessMetrics(metricsString, policyName)
|
|
if err != nil {
|
|
return fmt.Errorf("policy not created: %v", err)
|
|
}
|
|
|
|
// Wait to make sure that the Policy is ready.
|
|
time.Sleep(2 * time.Second)
|
|
return nil
|
|
}
|
|
}
|