From 4f8eb6971fe7ea9707b56eeb96f261fddf5084be Mon Sep 17 00:00:00 2001
From: Matthias Wessendorf <mwessend@redhat.com>
Date: Thu, 24 Oct 2024 11:40:08 +0200
Subject: [PATCH] Adding SSL env vars

Signed-off-by: Matthias Wessendorf <mwessend@redhat.com>
---
 .../resources/containersource.go                  | 15 ++++++++++++++-
 1 file changed, 14 insertions(+), 1 deletion(-)

diff --git a/pkg/reconciler/integrationsource/resources/containersource.go b/pkg/reconciler/integrationsource/resources/containersource.go
index 127305fb851..bd0ba7e2f39 100644
--- a/pkg/reconciler/integrationsource/resources/containersource.go
+++ b/pkg/reconciler/integrationsource/resources/containersource.go
@@ -41,7 +41,7 @@ func NewContainerSource(source *v1alpha1.IntegrationSource) *sourcesv1.Container
 }
 
 func generateEnvVarsFromStruct(prefix string, s interface{}) []corev1.EnvVar {
-	var envVars []corev1.EnvVar
+	var envVars = makeSSLEnvVar()
 
 	// Use reflection to inspect the struct fields
 	v := reflect.ValueOf(s)
@@ -168,6 +168,19 @@ func makeEnv(source *v1alpha1.IntegrationSource) []corev1.EnvVar {
 	return envVars
 }
 
+func makeSSLEnvVar() []corev1.EnvVar {
+	return []corev1.EnvVar{
+		{
+			Name:  "CAMEL_KNATIVE_CLIENT_SSL_ENABLED",
+			Value: "true",
+		},
+		{
+			Name:  "CAMEL_KNATIVE_CLIENT_SSL_CERT_PATH",
+			Value: "/knative-custom-certs/knative-eventing-bundle.pem",
+		},
+	}
+}
+
 func selectImage(source *v1alpha1.IntegrationSource) string {
 	if source.Spec.Timer != nil {
 		return "quay.io/openshift-knative/timer-source:1.0-SNAPSHOT"