fixed integration tests for cassandra backend

Author: ayansen

backends/cassandra/build/integration-tests/docker-app.conf

@@ -95,6 +95,7 @@
                         <configuration>
                             <environmentVariables>
                                 <HAYSTACK_PROP_CASSANDRA_ENDPOINTS>cass1,cass2</HAYSTACK_PROP_CASSANDRA_ENDPOINTS>
+                                <HAYSTACK_PROP_CASSANDRA_KEYSPACE_AUTO_CREATE_SCHEMA>cassandra_cql_schema_1</HAYSTACK_PROP_CASSANDRA_KEYSPACE_AUTO_CREATE_SCHEMA>
                             </environmentVariables>
                             <wildcardSuites>com.expedia.www.haystack.trace.storage.backends.cassandra.unit</wildcardSuites>
                         </configuration>
@@ -107,8 +108,7 @@
                         </goals>
                         <configuration>
                             <environmentVariables>
-                                <HAYSTACK_OVERRIDES_CONFIG_PATH>/src/reader/build/integration-tests/docker-app.conf
-                                </HAYSTACK_OVERRIDES_CONFIG_PATH>
+                                <HAYSTACK_OVERRIDES_CONFIG_PATH>/src/backends/cassandra/build/integration-tests/docker-app.conf</HAYSTACK_OVERRIDES_CONFIG_PATH>
                             </environmentVariables>
                             <wildcardSuites>com.expedia.www.haystack.trace.storage.backends.cassandra.integration</wildcardSuites>
                         </configuration>

backends/cassandra/pom.xml

@@ -3,7 +3,7 @@ haystack.graphite.host = "monitoring-influxdb-graphite.kube-system.svc"
 service {
   port = 8090
   ssl {
-    enabled = true
+    enabled = false
     cert.path = "/ssl/cert"
     private.key.path = "/ssl/private-key"
   }
@@ -44,7 +44,8 @@ cassandra {
   keyspace {
     name = "haystack"
     table.name = "traces"
-    auto.create.schema = "cassandra_cql_schema_1",
+    auto.create.schema = "CREATE KEYSPACE IF NOT EXISTS haystack WITH REPLICATION = { 'class': 'SimpleStrategy', 'replication_factor' : 1 } AND durable_writes = false; CREATE TABLE IF NOT EXISTS haystack.traces (id varchar, ts timestamp, spans blob, PRIMARY KEY ((id), ts)) WITH CLUSTERING ORDER BY (ts ASC) AND compaction = { 'class' :  'DateTieredCompactionStrategy', 'max_sstable_age_days': '3' } AND gc_grace_seconds = 86400;"
+
 
   }
 }

backends/cassandra/src/test/resources/config/base.conf

@@ -47,22 +47,19 @@ trait BaseIntegrationTestSpec extends FunSpec with GivenWhenThen with Matchers w
   private var cassandraSession: Session = _
 
   override def beforeAll() {
+    executors.submit(new Runnable {
+      override def run(): Unit = Service.main(null)
+    })
+    //waiting for the service to start up
+
+    Thread.sleep(5000)
     // setup cassandra
     cassandraSession = Cluster
       .builder()
       .addContactPoints(CASSANDRA_ENDPOINT)
       .build()
       .connect(CASSANDRA_KEYSPACE)
     deleteCassandraTableRows()
-
-
-
-    executors.submit(new Runnable {
-      override def run(): Unit = Service.main(null)
-    })
-
-    Thread.sleep(5000)
-
     client = StorageBackendGrpc.newBlockingStub(ManagedChannelBuilder.forAddress("localhost", 8090)
       .usePlaintext(true)
       .build())

backends/cassandra/src/test/scala/com/expedia/www/haystack/trace/storage/backends/cassandra/integration/BaseIntegrationTestSpec.scala

@@ -27,7 +27,7 @@ class ConfigurationLoaderSpec extends BaseUnitTestSpec {
     it("should load the service config from base.conf") {
       val serviceConfig: ServiceConfiguration = project.serviceConfig
       serviceConfig.port shouldBe 8090
-      serviceConfig.ssl.enabled shouldBe true
+      serviceConfig.ssl.enabled shouldBe false
       serviceConfig.ssl.certChainFilePath shouldBe "/ssl/cert"
       serviceConfig.ssl.privateKeyPath shouldBe "/ssl/private-key"
     }