This is an automated email from the ASF dual-hosted git repository. pcongiusti pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel-k.git
The following commit(s) were added to refs/heads/main by this push: new 7e52419aa Add optional install to tests 7e52419aa is described below commit 7e52419aa80f5544fc7b46d9d0e09fdf596b23de Author: Lucie Krejcirova <lfabr...@redhat.com> AuthorDate: Mon Mar 25 12:19:04 2024 +0100 Add optional install to tests --- e2e/support/test_support.go | 28 ++++++++++++++++++++++++++++ 1 file changed, 28 insertions(+) diff --git a/e2e/support/test_support.go b/e2e/support/test_support.go index 4f527a3ee..bc2d726cc 100644 --- a/e2e/support/test_support.go +++ b/e2e/support/test_support.go @@ -27,6 +27,7 @@ import ( "bytes" "context" "encoding/json" + "encoding/pem" "errors" "fmt" "io" @@ -332,6 +333,13 @@ func kamelInstallWithContext(t *testing.T, ctx context.Context, operatorID strin fmt.Printf("Setting operator image pull policy to %s\n", opImagePullPolicy) installArgs = append(installArgs, "--operator-image-pull-policy", opImagePullPolicy) } + if len(os.Getenv("CAMEL_K_TEST_MAVEN_CA_PEM_PATH")) > 0 { + certName := "myCert" + secretName := "maven-ca-certs" + CreateSecretDecoded(t, ctx, namespace, os.Getenv("CAMEL_K_TEST_MAVEN_CA_PEM_PATH"), secretName, certName) + installArgs = append(installArgs, "--maven-repository", os.Getenv("KAMEL_INSTALL_MAVEN_REPOSITORIES"), + "--maven-ca-secret", secretName+"/"+certName) + } installArgs = append(installArgs, args...) installCommand := KamelWithContext(t, ctx, installArgs...) @@ -1758,6 +1766,26 @@ func DeleteSecret(t *testing.T, ctx context.Context, ns string, name string) err return TestClient(t).Delete(ctx, &sec) } +func CreateSecretDecoded(t *testing.T, ctx context.Context, ns string, pathToFile string, secretName string, certName string) error { + bytes, _ := os.ReadFile(pathToFile) + block, _ := pem.Decode(bytes) + + secret := corev1.Secret{ + TypeMeta: metav1.TypeMeta{ + Kind: "Secret", + APIVersion: corev1.SchemeGroupVersion.String(), + }, + ObjectMeta: metav1.ObjectMeta{ + Namespace: ns, + Name: secretName, + }, + Data: map[string][]byte{ + certName: block.Bytes, + }, + } + return TestClient(t).Create(ctx, &secret) +} + func KnativeService(t *testing.T, ctx context.Context, ns string, name string) func() *servingv1.Service { return func() *servingv1.Service { answer := servingv1.Service{