Fix cassandra_url handling to be http / https depending on SSL

k8ssandra · Feb 23, 2024 · 2d6579e · 2d6579e
1 parent 018e846
commit 2d6579e
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 1 deletion.
diff --git a/pkg/medusa/reconcile.go b/pkg/medusa/reconcile.go
@@ -122,7 +122,6 @@ func CreateMedusaIni(kc *k8ss.K8ssandraCluster, dcConfig *cassandra.DatacenterCo
     level = DEBUG
 
     [kubernetes]
-    cassandra_url = http://127.0.0.1:8080/api/v0/ops/node/snapshots
     use_mgmt_api = 1
     enabled = 1`
 
@@ -141,9 +140,13 @@ func CreateMedusaIni(kc *k8ss.K8ssandraCluster, dcConfig *cassandra.DatacenterCo
 	// Create Kubernetes config here and append it
 	if dcConfig.ManagementApiAuth != nil && dcConfig.ManagementApiAuth.Manual != nil {
 		medusaConfiig += `
+	cassandra_url = https://127.0.0.1:8080/api/v0/ops/node/snapshots
 	ca_cert = /etc/encryption/mgmt/ca.crt
 	tls_cert = /etc/encryption/mgmt/tls.crt
 	tls_key = /etc/encryption/mgmt/tls.key`
+	} else {
+		medusaConfiig += `
+	cassandra_url = http://127.0.0.1:8080/api/v0/ops/node/snapshots`
 	}
 
 	return medusaConfiig

diff --git a/pkg/medusa/reconcile_test.go b/pkg/medusa/reconcile_test.go
@@ -155,6 +155,7 @@ func testMedusaIniNoPrefix(t *testing.T) {
 	assert.Contains(t, medusaIni, "port = 9001")
 	assert.Contains(t, medusaIni, "secure = False")
 	assert.Contains(t, medusaIni, "backup_grace_period_in_days = 7")
+	assert.Contains(t, medusaIni, "cassandra_url = http://127.0.0.1:8080/api/v0/ops/node/snapshots")
 }
 
 func testMedusaIniSecured(t *testing.T) {
@@ -234,6 +235,7 @@ func testMedusaIniSecured(t *testing.T) {
 	assert.Contains(medusaIni, "ca_cert = /etc/encryption/mgmt/ca.crt")
 	assert.Contains(medusaIni, "tls_cert = /etc/encryption/mgmt/tls.crt")
 	assert.Contains(medusaIni, "tls_key = /etc/encryption/mgmt/tls.key")
+	assert.Contains(medusaIni, "cassandra_url = https://127.0.0.1:8080/api/v0/ops/node/snapshots")
 }
 
 func testMedusaIniSecuredDcLevelSetting(t *testing.T) {
@@ -296,6 +298,7 @@ func testMedusaIniSecuredDcLevelSetting(t *testing.T) {
 	assert.Contains(medusaIni, "ca_cert = /etc/encryption/mgmt/ca.crt")
 	assert.Contains(medusaIni, "tls_cert = /etc/encryption/mgmt/tls.crt")
 	assert.Contains(medusaIni, "tls_key = /etc/encryption/mgmt/tls.key")
+	assert.Contains(medusaIni, "cassandra_url = https://127.0.0.1:8080/api/v0/ops/node/snapshots")
 }
 
 func testMedusaIniUnsecured(t *testing.T) {