Merge pull request cfpb#1113 from jmarin/cassandra-authentication

Add authentication for cassandra journal and snapshot stores

Author: schbetsy

persistence-model/src/main/resources/application.conf

@@ -77,6 +77,10 @@ cassandra-journal {
   connect-retries = 10
   connect-retry-delay = 5s
   reconnect-max-delay = 60s
+  authentication.username = ""
+  authentication.username = ${?CASSANDRA_CLUSTER_USERNAME}
+  authentication.password = ""
+  authentication.password = ${?CASSANDRA_CLUSTER_PASSWORD}
 }
 
 cassandra-snapshot-store {
@@ -90,6 +94,10 @@ cassandra-snapshot-store {
   connect-retries = 10
   connect-retry-delay = 5s
   reconnect-max-delay = 60s
+  authentication.username = ""
+  authentication.username = ${?CASSANDRA_CLUSTER_USERNAME}
+  authentication.password = ""
+  authentication.password = ${?CASSANDRA_CLUSTER_PASSWORD}
 }
 
 cassandra-query-journal {

query/src/main/resources/application.conf

@@ -69,6 +69,10 @@ cassandra {
   port = ${?CASSANDRA_CLUSTER_PORT}
   keyspace = "hmda_query"
   keyspace = ${?CASSANDRA_QUERY_KEYSPACE}
+  username = ""
+  username = ${?CASSANDRA_CLUSTER_USERNAME}
+  password = ""
+  password = ${?CASSANDRA_CLUSTER_PASSWORD}
   retries = 60
   retry-interval = 1000
 }

query/src/main/scala/hmda/query/CassandraConfig.scala

@@ -7,6 +7,8 @@ object CassandraConfig {
   val cassandraHost = config.getString("cassandra.host")
   val cassandraPort = config.getInt("cassandra.port")
   val cassandraKeyspace = config.getString("cassandra.keyspace")
+  val cassandraUsername = config.getString("cassandra.username")
+  val cassandraPassword = config.getString("cassandra.password")
   val numberOfRetries = config.getInt("cassandra.retries")
   val retryInterval = config.getLong("cassandra.retry-interval")
 }

query/src/main/scala/hmda/query/repository/CassandraRepository.scala

@@ -45,6 +45,7 @@ trait CassandraRepository[A] {
         .builder
         .addContactPoint(cassandraHost)
         .withPort(cassandraPort)
+        .withCredentials(cassandraUsername, cassandraPassword)
         .withReconnectionPolicy(new ExponentialReconnectionPolicy(100L, 200000L))
         .build
         .connect()